[Date Prev][Date Next][Thread Prev][Thread Next][Date Index][Thread Index]
[PATCH 1/9] block: call bdrv_co_drain_begin in a coroutine
From: |
Emanuele Giuseppe Esposito |
Subject: |
[PATCH 1/9] block: call bdrv_co_drain_begin in a coroutine |
Date: |
Thu, 3 Nov 2022 09:41:58 -0400 |
It seems that bdrv_open_driver() forgot to create a coroutine
where to call bs->drv->bdrv_co_drain_begin(), a callback
marked as coroutine_fn.
Signed-off-by: Emanuele Giuseppe Esposito <eesposit@redhat.com>
---
block.c | 32 +++++++++++++++++++++++++++-----
1 file changed, 27 insertions(+), 5 deletions(-)
diff --git a/block.c b/block.c
index 5311b21f8e..7211f62001 100644
--- a/block.c
+++ b/block.c
@@ -1637,12 +1637,34 @@ out:
g_free(gen_node_name);
}
+typedef struct DrainCo {
+ BlockDriverState *bs;
+ int ret;
+} DrainCo;
+
+static void coroutine_fn bdrv_co_drain_begin(void *opaque)
+{
+ int i;
+ DrainCo *co = opaque;
+ BlockDriverState *bs = co->bs;
+
+ for (i = 0; i < bs->quiesce_counter; i++) {
+ bs->drv->bdrv_co_drain_begin(bs);
+ }
+ co->ret = 0;
+}
+
static int bdrv_open_driver(BlockDriverState *bs, BlockDriver *drv,
const char *node_name, QDict *options,
int open_flags, Error **errp)
{
Error *local_err = NULL;
- int i, ret;
+ int ret;
+ Coroutine *co;
+ DrainCo dco = {
+ .bs = bs,
+ .ret = NOT_DONE,
+ };
GLOBAL_STATE_CODE();
bdrv_assign_node_name(bs, node_name, &local_err);
@@ -1690,10 +1712,10 @@ static int bdrv_open_driver(BlockDriverState *bs,
BlockDriver *drv,
assert(bdrv_min_mem_align(bs) != 0);
assert(is_power_of_2(bs->bl.request_alignment));
- for (i = 0; i < bs->quiesce_counter; i++) {
- if (drv->bdrv_co_drain_begin) {
- drv->bdrv_co_drain_begin(bs);
- }
+ if (drv->bdrv_co_drain_begin) {
+ co = qemu_coroutine_create(bdrv_co_drain_begin, &dco);
+ qemu_coroutine_enter(co);
+ AIO_WAIT_WHILE(qemu_get_aio_context(), dco.ret == NOT_DONE);
}
return 0;
--
2.31.1
- [PATCH 0/9] Still more coroutine and various fixes in block layer, Emanuele Giuseppe Esposito, 2022/11/03
- [PATCH 1/9] block: call bdrv_co_drain_begin in a coroutine,
Emanuele Giuseppe Esposito <=
- [PATCH 5/9] block: distinguish between bdrv_create running in coroutine and not, Emanuele Giuseppe Esposito, 2022/11/03
- [PATCH 4/9] block-backend: replace bdrv_*_above with blk_*_above, Emanuele Giuseppe Esposito, 2022/11/03
- [PATCH 7/9] block: bdrv_create_file is a coroutine_fn, Emanuele Giuseppe Esposito, 2022/11/03
- [PATCH 3/9] nbd/server.c: add missing coroutine_fn annotations, Emanuele Giuseppe Esposito, 2022/11/03
- [PATCH 8/9] block: bdrv_create is never called in non-coroutine context, Emanuele Giuseppe Esposito, 2022/11/03
- [PATCH 2/9] block-copy: add missing coroutine_fn annotations, Emanuele Giuseppe Esposito, 2022/11/03