[Date Prev][Date Next][Thread Prev][Thread Next][Date Index][Thread Index]
[Qemu-devel] [PATCH 03/10] vmdk: add vmdk_co_write_compressed
From: |
Denis V. Lunev |
Subject: |
[Qemu-devel] [PATCH 03/10] vmdk: add vmdk_co_write_compressed |
Date: |
Sat, 14 May 2016 15:45:51 +0300 |
From: Pavel Butsykin <address@hidden>
Added implementation of the vmdk_co_write_compressed function that
will allow us to safely use compressed writes for the vmdk from running
VMs.
Signed-off-by: Pavel Butsykin <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 | 56 ++++++--------------------------------------------------
1 file changed, 6 insertions(+), 50 deletions(-)
diff --git a/block/vmdk.c b/block/vmdk.c
index e6c97c2..9530b30 100644
--- a/block/vmdk.c
+++ b/block/vmdk.c
@@ -1651,56 +1651,12 @@ 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_write_compressed(BlockDriverState *bs, int64_t sector_num,
+ int nb_sectors, 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);
- qemu_coroutine_enter(co, &data);
- while (data.ret == -EINPROGRESS) {
- aio_poll(aio_context, true);
- }
- return data.ret;
- } else {
- return -ENOTSUP;
- }
+ return vmdk_co_pwritev(bs, sector_num << BDRV_SECTOR_BITS,
+ (uint64_t)nb_sectors << BDRV_SECTOR_BITS, qiov, 0);
}
static int coroutine_fn vmdk_co_write_zeroes(BlockDriverState *bs,
@@ -2422,7 +2378,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_write_compressed = vmdk_co_write_compressed,
.bdrv_co_write_zeroes = vmdk_co_write_zeroes,
.bdrv_close = vmdk_close,
.bdrv_create = vmdk_create,
--
2.1.4
- [Qemu-devel] [PATCH v3 00/10] backup compression, Denis V. Lunev, 2016/05/14
- [Qemu-devel] [PATCH 04/10] qcow: add qcow_co_write_compressed, Denis V. Lunev, 2016/05/14
- [Qemu-devel] [PATCH 03/10] vmdk: add vmdk_co_write_compressed,
Denis V. Lunev <=
- [Qemu-devel] [PATCH 02/10] qcow2: add qcow2_co_write_compressed, Denis V. Lunev, 2016/05/14
- Re: [Qemu-devel] [PATCH 02/10] qcow2: add qcow2_co_write_compressed, Stefan Hajnoczi, 2016/05/27
- Re: [Qemu-devel] [PATCH 02/10] qcow2: add qcow2_co_write_compressed, Pavel Butsykin, 2016/05/30
- Re: [Qemu-devel] [PATCH 02/10] qcow2: add qcow2_co_write_compressed, Pavel Butsykin, 2016/05/30
- Re: [Qemu-devel] [PATCH 02/10] qcow2: add qcow2_co_write_compressed, Eric Blake, 2016/05/31
- Re: [Qemu-devel] [PATCH 02/10] qcow2: add qcow2_co_write_compressed, Denis V. Lunev, 2016/05/31
- Re: [Qemu-devel] [PATCH 02/10] qcow2: add qcow2_co_write_compressed, Eric Blake, 2016/05/31
[Qemu-devel] [PATCH 01/10] block/io: add bdrv_co_write_compressed, Denis V. Lunev, 2016/05/14