[Date Prev][Date Next][Thread Prev][Thread Next][Date Index][Thread Index]
[Qemu-devel] [PATCH v5 05/12] block/mirror: Improve progress report
From: |
Max Reitz |
Subject: |
[Qemu-devel] [PATCH v5 05/12] block/mirror: Improve progress report |
Date: |
Thu, 17 Apr 2014 23:59:45 +0200 |
Instead of taking the total length of the block device as the block
job's length, use the number of dirty sectors. The progress is now the
number of sectors mirrored to the target block device. Note that this
may result in the job's length increasing during operation, which is
however in fact desirable.
Signed-off-by: Max Reitz <address@hidden>
---
block/mirror.c | 32 +++++++++++++++++++++-----------
1 file changed, 21 insertions(+), 11 deletions(-)
diff --git a/block/mirror.c b/block/mirror.c
index 2618c37..576b74e 100644
--- a/block/mirror.c
+++ b/block/mirror.c
@@ -39,6 +39,7 @@ typedef struct MirrorBlockJob {
int64_t sector_num;
int64_t granularity;
size_t buf_size;
+ int64_t bdev_length;
unsigned long *cow_bitmap;
BdrvDirtyBitmap *dirty_bitmap;
HBitmapIter hbi;
@@ -48,6 +49,7 @@ typedef struct MirrorBlockJob {
unsigned long *in_flight_bitmap;
int in_flight;
+ int sectors_in_flight;
int ret;
} MirrorBlockJob;
@@ -81,6 +83,7 @@ static void mirror_iteration_done(MirrorOp *op, int ret)
trace_mirror_iteration_done(s, op->sector_num, op->nb_sectors, ret);
s->in_flight--;
+ s->sectors_in_flight -= op->nb_sectors;
iov = op->qiov.iov;
for (i = 0; i < op->qiov.niov; i++) {
MirrorBuffer *buf = (MirrorBuffer *) iov[i].iov_base;
@@ -92,8 +95,11 @@ static void mirror_iteration_done(MirrorOp *op, int ret)
chunk_num = op->sector_num / sectors_per_chunk;
nb_chunks = op->nb_sectors / sectors_per_chunk;
bitmap_clear(s->in_flight_bitmap, chunk_num, nb_chunks);
- if (s->cow_bitmap && ret >= 0) {
- bitmap_set(s->cow_bitmap, chunk_num, nb_chunks);
+ if (ret >= 0) {
+ if (s->cow_bitmap) {
+ bitmap_set(s->cow_bitmap, chunk_num, nb_chunks);
+ }
+ s->common.offset += (uint64_t)op->nb_sectors * BDRV_SECTOR_SIZE;
}
qemu_iovec_destroy(&op->qiov);
@@ -166,7 +172,7 @@ static uint64_t coroutine_fn
mirror_iteration(MirrorBlockJob *s)
hbitmap_next_sector = s->sector_num;
sector_num = s->sector_num;
sectors_per_chunk = s->granularity >> BDRV_SECTOR_BITS;
- end = s->common.len >> BDRV_SECTOR_BITS;
+ end = s->bdev_length / BDRV_SECTOR_SIZE;
/* Extend the QEMUIOVector to include all adjacent blocks that will
* be copied in this operation.
@@ -278,6 +284,7 @@ static uint64_t coroutine_fn
mirror_iteration(MirrorBlockJob *s)
/* Copy the dirty cluster. */
s->in_flight++;
+ s->sectors_in_flight += nb_sectors;
trace_mirror_one_iteration(s, sector_num, nb_sectors);
bdrv_aio_readv(source, sector_num, &op->qiov, nb_sectors,
mirror_read_complete, op);
@@ -323,13 +330,13 @@ static void coroutine_fn mirror_run(void *opaque)
goto immediate_exit;
}
- s->common.len = bdrv_getlength(bs);
- if (s->common.len <= 0) {
- block_job_completed(&s->common, s->common.len);
+ s->bdev_length = bdrv_getlength(bs);
+ if (s->bdev_length <= 0) {
+ block_job_completed(&s->common, s->bdev_length);
return;
}
- length = (bdrv_getlength(bs) + s->granularity - 1) / s->granularity;
+ length = (s->bdev_length + s->granularity - 1) / s->granularity;
s->in_flight_bitmap = bitmap_new(length);
/* If we have no backing file yet in the destination, we cannot let
@@ -346,7 +353,7 @@ static void coroutine_fn mirror_run(void *opaque)
}
}
- end = s->common.len >> BDRV_SECTOR_BITS;
+ end = s->bdev_length / BDRV_SECTOR_SIZE;
s->buf = qemu_blockalign(bs, s->buf_size);
sectors_per_chunk = s->granularity >> BDRV_SECTOR_BITS;
mirror_free_init(s);
@@ -386,6 +393,12 @@ static void coroutine_fn mirror_run(void *opaque)
}
cnt = bdrv_get_dirty_count(bs, s->dirty_bitmap);
+ /* s->common.offset contains the number of bytes already processed so
+ * far, cnt is the number of dirty sectors remaining and
+ * s->sectors_in_flight is the number of sectors currently being
+ * processed; together those are the current total operation length */
+ s->common.len = s->common.offset +
+ (cnt + s->sectors_in_flight) * BDRV_SECTOR_SIZE;
/* Note that even when no rate limit is applied we need to yield
* periodically with no pending I/O so that qemu_aio_flush() returns.
@@ -421,7 +434,6 @@ static void coroutine_fn mirror_run(void *opaque)
* report completion. This way, block-job-cancel will leave
* the target in a consistent state.
*/
- s->common.offset = end * BDRV_SECTOR_SIZE;
if (!s->synced) {
block_job_ready(&s->common);
s->synced = true;
@@ -450,8 +462,6 @@ static void coroutine_fn mirror_run(void *opaque)
ret = 0;
trace_mirror_before_sleep(s, cnt, s->synced, delay_ns);
if (!s->synced) {
- /* Publish progress */
- s->common.offset = (end - cnt) * BDRV_SECTOR_SIZE;
block_job_sleep_ns(&s->common, QEMU_CLOCK_REALTIME, delay_ns);
if (block_job_is_cancelled(&s->common)) {
break;
--
1.9.2
- [Qemu-devel] [PATCH v5 00/12] qemu-img: Implement commit like QMP, Max Reitz, 2014/04/17
- [Qemu-devel] [PATCH v5 01/12] qcow2: Allow "full" discard, Max Reitz, 2014/04/17
- [Qemu-devel] [PATCH v5 04/12] blockjob: Add "ready" field, Max Reitz, 2014/04/17
- [Qemu-devel] [PATCH v5 03/12] blockjob: Introduce block_job_complete_sync(), Max Reitz, 2014/04/17
- [Qemu-devel] [PATCH v5 05/12] block/mirror: Improve progress report,
Max Reitz <=
- [Qemu-devel] [PATCH v5 06/12] qemu-img: Implement commit like QMP, Max Reitz, 2014/04/17
- [Qemu-devel] [PATCH v5 07/12] qemu-img: Empty images after commit, Max Reitz, 2014/04/17
- Re: [Qemu-devel] [PATCH v5 07/12] qemu-img: Empty images after commit, Eric Blake, 2014/04/22
- Re: [Qemu-devel] [PATCH v5 07/12] qemu-img: Empty images after commit, Max Reitz, 2014/04/22
- Re: [Qemu-devel] [PATCH v5 07/12] qemu-img: Empty images after commit, Max Reitz, 2014/04/22
- Re: [Qemu-devel] [PATCH v5 07/12] qemu-img: Empty images after commit, Eric Blake, 2014/04/22
- Re: [Qemu-devel] [PATCH v5 07/12] qemu-img: Empty images after commit, Max Reitz, 2014/04/22
- Re: [Qemu-devel] [PATCH v5 07/12] qemu-img: Empty images after commit, Eric Blake, 2014/04/22
- Re: [Qemu-devel] [PATCH v5 07/12] qemu-img: Empty images after commit, Kevin Wolf, 2014/04/23
- Re: [Qemu-devel] [PATCH v5 07/12] qemu-img: Empty images after commit, Max Reitz, 2014/04/24