[Date Prev][Date Next][Thread Prev][Thread Next][Date Index][Thread Index]
[Qemu-block] [PATCH 06/10] qed: move tail of qed_aio_write_main to qed_a
From: |
Paolo Bonzini |
Subject: |
[Qemu-block] [PATCH 06/10] qed: move tail of qed_aio_write_main to qed_aio_write_{cow, alloc} |
Date: |
Tue, 27 Jun 2017 17:22:44 +0200 |
This part is never called for in-place writes, move it away to avoid
the "backwards" coding style typical of callback-based code.
Reviewed-by: Stefan Hajnoczi <address@hidden>
Signed-off-by: Paolo Bonzini <address@hidden>
---
block/qed.c | 69 +++++++++++++++++++++++++++----------------------------------
1 file changed, 31 insertions(+), 38 deletions(-)
diff --git a/block/qed.c b/block/qed.c
index 385381a78a..3ffdc1716d 100644
--- a/block/qed.c
+++ b/block/qed.c
@@ -982,40 +982,11 @@ static int coroutine_fn qed_aio_write_main(QEDAIOCB *acb)
BDRVQEDState *s = acb_to_s(acb);
uint64_t offset = acb->cur_cluster +
qed_offset_into_cluster(s, acb->cur_pos);
- int ret;
trace_qed_aio_write_main(s, acb, 0, offset, acb->cur_qiov.size);
BLKDBG_EVENT(s->bs->file, BLKDBG_WRITE_AIO);
- ret = bdrv_co_pwritev(s->bs->file, offset, acb->cur_qiov.size,
- &acb->cur_qiov, 0);
- if (ret < 0) {
- return ret;
- }
-
- if (acb->find_cluster_ret != QED_CLUSTER_FOUND) {
- if (s->bs->backing) {
- /*
- * Flush new data clusters before updating the L2 table
- *
- * This flush is necessary when a backing file is in use. A crash
- * during an allocating write could result in empty clusters in the
- * image. If the write only touched a subregion of the cluster,
- * then backing image sectors have been lost in the untouched
- * region. The solution is to flush after writing a new data
- * cluster and before updating the L2 table.
- */
- ret = bdrv_co_flush(s->bs->file->bs);
- if (ret < 0) {
- return ret;
- }
- }
- ret = qed_aio_write_l2_update(acb, acb->cur_cluster);
- if (ret < 0) {
- return ret;
- }
- }
- return 0;
+ return bdrv_co_pwritev(s->bs->file, offset, &acb->cur_qiov);
}
/**
@@ -1050,7 +1021,29 @@ static int coroutine_fn qed_aio_write_cow(QEDAIOCB *acb)
return ret;
}
- return qed_aio_write_main(acb);
+ ret = qed_aio_write_main(acb);
+ if (ret < 0) {
+ return ret;
+ }
+
+ if (s->bs->backing) {
+ /*
+ * Flush new data clusters before updating the L2 table
+ *
+ * This flush is necessary when a backing file is in use. A crash
+ * during an allocating write could result in empty clusters in the
+ * image. If the write only touched a subregion of the cluster,
+ * then backing image sectors have been lost in the untouched
+ * region. The solution is to flush after writing a new data
+ * cluster and before updating the L2 table.
+ */
+ ret = bdrv_co_flush(s->bs->file->bs);
+ if (ret < 0) {
+ return ret;
+ }
+ }
+
+ return 0;
}
/**
@@ -1103,6 +1096,7 @@ static int coroutine_fn qed_aio_write_alloc(QEDAIOCB
*acb, size_t len)
if (acb->find_cluster_ret == QED_CLUSTER_ZERO) {
return 0;
}
+ acb->cur_cluster = 1;
} else {
acb->cur_cluster = qed_alloc_clusters(s, acb->cur_nclusters);
}
@@ -1115,15 +1109,14 @@ static int coroutine_fn qed_aio_write_alloc(QEDAIOCB
*acb, size_t len)
}
}
- if (acb->flags & QED_AIOCB_ZERO) {
- ret = qed_aio_write_l2_update(acb, 1);
- } else {
+ if (!(acb->flags & QED_AIOCB_ZERO)) {
ret = qed_aio_write_cow(acb);
+ if (ret < 0) {
+ return ret;
+ }
}
- if (ret < 0) {
- return ret;
- }
- return 0;
+
+ return qed_aio_write_l2_update(acb, acb->cur_cluster);
}
/**
--
2.13.0
- [Qemu-block] [PATCH 00/10] Block layer thread-safety, part 2, Paolo Bonzini, 2017/06/27
- [Qemu-block] [PATCH 07/10] block: invoke .bdrv_drain callback in coroutine context and from AioContext, Paolo Bonzini, 2017/06/27
- [Qemu-block] [PATCH 09/10] sheepdog: add queue_lock, Paolo Bonzini, 2017/06/27
- [Qemu-block] [PATCH 10/10] ssh: support I/O from any AioContext, Paolo Bonzini, 2017/06/27
- [Qemu-block] [PATCH 04/10] vpc: make it thread-safe, Paolo Bonzini, 2017/06/27
- [Qemu-block] [PATCH 06/10] qed: move tail of qed_aio_write_main to qed_aio_write_{cow, alloc},
Paolo Bonzini <=
- [Qemu-block] [PATCH 05/10] vvfat: make it thread-safe, Paolo Bonzini, 2017/06/27
- [Qemu-block] [PATCH 08/10] qed: protect table cache with CoMutex, Paolo Bonzini, 2017/06/27
- [Qemu-block] [PATCH 01/10] qcow2: call CoQueue APIs under CoMutex, Paolo Bonzini, 2017/06/27
- [Qemu-block] [PATCH 02/10] coroutine-lock: add qemu_co_rwlock_downgrade and qemu_co_rwlock_upgrade, Paolo Bonzini, 2017/06/27
- [Qemu-block] [PATCH 03/10] vdi: make it thread-safe, Paolo Bonzini, 2017/06/27
- Re: [Qemu-block] [PATCH 00/10] Block layer thread-safety, part 2, Paolo Bonzini, 2017/06/27
- Re: [Qemu-block] [Qemu-devel] [PATCH 00/10] Block layer thread-safety, part 2, no-reply, 2017/06/28