[Date Prev][Date Next][Thread Prev][Thread Next][Date Index][Thread Index]
[Qemu-devel] [PATCH v7 06/16] vmdk: add vmdk_co_pwritev_compressed
From: |
Denis V. Lunev |
Subject: |
[Qemu-devel] [PATCH v7 06/16] vmdk: add vmdk_co_pwritev_compressed |
Date: |
Fri, 22 Jul 2016 11:17:45 +0300 |
From: Pavel Butsykin <address@hidden>
Added implementation of the vmdk_co_pwritev_compressed function that
will allow us to safely use compressed writes for the vmdk from running
VMs.
Signed-off-by: Pavel Butsykin <address@hidden>
Reviewed-by: Stefan Hajnoczi <address@hidden>
Signed-off-by: Denis V. Lunev <address@hidden>
CC: Jeff Cody <address@hidden>
CC: Markus Armbruster <address@hidden>
CC: Eric Blake <address@hidden>
CC: John Snow <address@hidden>
CC: Stefan Hajnoczi <address@hidden>
CC: Kevin Wolf <address@hidden>
---
block/vmdk.c | 55 +++++--------------------------------------------------
1 file changed, 5 insertions(+), 50 deletions(-)
diff --git a/block/vmdk.c b/block/vmdk.c
index 46d474e..a11c27a 100644
--- a/block/vmdk.c
+++ b/block/vmdk.c
@@ -1645,56 +1645,11 @@ vmdk_co_pwritev(BlockDriverState *bs, uint64_t offset,
uint64_t bytes,
return ret;
}
-typedef struct VmdkWriteCompressedCo {
- BlockDriverState *bs;
- int64_t sector_num;
- const uint8_t *buf;
- int nb_sectors;
- int ret;
-} VmdkWriteCompressedCo;
-
-static void vmdk_co_write_compressed(void *opaque)
-{
- VmdkWriteCompressedCo *co = opaque;
- QEMUIOVector local_qiov;
- uint64_t offset = co->sector_num * BDRV_SECTOR_SIZE;
- uint64_t bytes = co->nb_sectors * BDRV_SECTOR_SIZE;
-
- struct iovec iov = (struct iovec) {
- .iov_base = (uint8_t*) co->buf,
- .iov_len = bytes,
- };
- qemu_iovec_init_external(&local_qiov, &iov, 1);
-
- co->ret = vmdk_pwritev(co->bs, offset, bytes, &local_qiov, false, false);
-}
-
-static int vmdk_write_compressed(BlockDriverState *bs,
- int64_t sector_num,
- const uint8_t *buf,
- int nb_sectors)
+static int coroutine_fn
+vmdk_co_pwritev_compressed(BlockDriverState *bs, uint64_t offset,
+ uint64_t bytes, QEMUIOVector *qiov)
{
- BDRVVmdkState *s = bs->opaque;
-
- if (s->num_extents == 1 && s->extents[0].compressed) {
- Coroutine *co;
- AioContext *aio_context = bdrv_get_aio_context(bs);
- VmdkWriteCompressedCo data = {
- .bs = bs,
- .sector_num = sector_num,
- .buf = buf,
- .nb_sectors = nb_sectors,
- .ret = -EINPROGRESS,
- };
- co = qemu_coroutine_create(vmdk_co_write_compressed, &data);
- qemu_coroutine_enter(co);
- while (data.ret == -EINPROGRESS) {
- aio_poll(aio_context, true);
- }
- return data.ret;
- } else {
- return -ENOTSUP;
- }
+ return vmdk_co_pwritev(bs, offset, bytes, qiov, 0);
}
static int coroutine_fn vmdk_co_pwrite_zeroes(BlockDriverState *bs,
@@ -2393,7 +2348,7 @@ static BlockDriver bdrv_vmdk = {
.bdrv_reopen_prepare = vmdk_reopen_prepare,
.bdrv_co_preadv = vmdk_co_preadv,
.bdrv_co_pwritev = vmdk_co_pwritev,
- .bdrv_write_compressed = vmdk_write_compressed,
+ .bdrv_co_pwritev_compressed = vmdk_co_pwritev_compressed,
.bdrv_co_pwrite_zeroes = vmdk_co_pwrite_zeroes,
.bdrv_close = vmdk_close,
.bdrv_create = vmdk_create,
--
2.1.4
- [Qemu-devel] [PATCH v7 01/16] block: switch blk_write_compressed() to byte-based interface, (continued)
- [Qemu-devel] [PATCH v7 01/16] block: switch blk_write_compressed() to byte-based interface, Denis V. Lunev, 2016/07/22
- [Qemu-devel] [PATCH v7 11/16] block: simplify drive-backup, Denis V. Lunev, 2016/07/22
- [Qemu-devel] [PATCH v7 13/16] drive-backup: added support for data compression, Denis V. Lunev, 2016/07/22
- [Qemu-devel] [PATCH v7 10/16] block/io: turn on dirty_bitmaps for the compressed writes, Denis V. Lunev, 2016/07/22
- [Qemu-devel] [PATCH v7 05/16] qcow2: cleanup qcow2_co_pwritev_compressed to avoid the recursion, Denis V. Lunev, 2016/07/22
- [Qemu-devel] [PATCH v7 04/16] qcow2: add qcow2_co_pwritev_compressed, Denis V. Lunev, 2016/07/22
- [Qemu-devel] [PATCH v7 16/16] qemu-iotests: add vmdk for test backup compression in 055, Denis V. Lunev, 2016/07/22
- [Qemu-devel] [PATCH v7 02/16] block: Convert bdrv_pwrite_compressed() to BdrvChild, Denis V. Lunev, 2016/07/22
- [Qemu-devel] [PATCH v7 15/16] qemu-iotests: test backup compression in 055, Denis V. Lunev, 2016/07/22
- [Qemu-devel] [PATCH v7 12/16] block: simplify blockdev-backup, Denis V. Lunev, 2016/07/22
- [Qemu-devel] [PATCH v7 06/16] vmdk: add vmdk_co_pwritev_compressed,
Denis V. Lunev <=