4 * Copyright (C) 2013 Proxmox Server Solutions
5 * Copyright (c) 2019 Virtuozzo International GmbH.
8 * Dietmar Maurer (dietmar@proxmox.com)
9 * Vladimir Sementsov-Ogievskiy <vsementsov@virtuozzo.com>
11 * This work is licensed under the terms of the GNU GPL, version 2 or later.
12 * See the COPYING file in the top-level directory.
18 #include "block/block.h"
19 #include "qemu/co-shared-resource.h"
21 typedef struct BlockCopyInFlightReq
{
24 QLIST_ENTRY(BlockCopyInFlightReq
) list
;
25 CoQueue wait_queue
; /* coroutines blocked on this request */
26 } BlockCopyInFlightReq
;
28 typedef void (*ProgressBytesCallbackFunc
)(int64_t bytes
, void *opaque
);
29 typedef void (*ProgressResetCallbackFunc
)(void *opaque
);
30 typedef struct BlockCopyState
{
32 * BdrvChild objects are not owned or managed by block-copy. They are
33 * provided by block-copy user and user is responsible for appropriate
34 * permissions on these children.
38 BdrvDirtyBitmap
*copy_bitmap
;
43 QLIST_HEAD(, BlockCopyInFlightReq
) inflight_reqs
;
45 BdrvRequestFlags write_flags
;
50 * Used by sync=top jobs, which first scan the source node for unallocated
51 * areas and clear them in the copy_bitmap. During this process, the bitmap
52 * is thus not fully initialized: It may still have bits set for areas that
53 * are unallocated and should actually not be copied.
55 * This is indicated by skip_unallocated.
57 * In this case, block_copy() will query the source’s allocation status,
58 * skip unallocated regions, clear them in the copy_bitmap, and invoke
59 * block_copy_reset_unallocated() every time it does.
61 bool skip_unallocated
;
63 /* progress_bytes_callback: called when some copying progress is done. */
64 ProgressBytesCallbackFunc progress_bytes_callback
;
67 * progress_reset_callback: called when some bytes reset from copy_bitmap
68 * (see @skip_unallocated above). The callee is assumed to recalculate how
69 * many bytes remain based on the dirty bit count of copy_bitmap.
71 ProgressResetCallbackFunc progress_reset_callback
;
72 void *progress_opaque
;
77 BlockCopyState
*block_copy_state_new(BdrvChild
*source
, BdrvChild
*target
,
79 BdrvRequestFlags write_flags
,
82 void block_copy_set_callbacks(
84 ProgressBytesCallbackFunc progress_bytes_callback
,
85 ProgressResetCallbackFunc progress_reset_callback
,
86 void *progress_opaque
);
88 void block_copy_state_free(BlockCopyState
*s
);
90 int64_t block_copy_reset_unallocated(BlockCopyState
*s
,
91 int64_t offset
, int64_t *count
);
93 int coroutine_fn
block_copy(BlockCopyState
*s
, int64_t start
, uint64_t bytes
,
96 #endif /* BLOCK_COPY_H */