[Date Prev][Date Next][Thread Prev][Thread Next][Date Index][Thread Index]
[PATCH 08/12] reopen: add a transaction to drain_end nodes picked in bdr
From: |
Emanuele Giuseppe Esposito |
Subject: |
[PATCH 08/12] reopen: add a transaction to drain_end nodes picked in bdrv_reopen_parse_file_or_backing |
Date: |
Tue, 18 Jan 2022 11:27:34 -0500 |
Depending on the options given to reopen_state,
bdrv_reopen_parse_file_or_backing could pick another bs
that could be from another graph, and thus not protected
by subtree_drained_begin called by the callers of this
function.
We can't simply drain-undrain here, because of transactions.
To simplify the logic, transactions always assume that they
are run under drain, so the various subtree_drain introduced
so far always take care of covering tran_commit().
And since we cannot directly do it, as the transaction is
created/committed higher above, we can just add a new
transaction to the list that just executes subtree_drained_end
to match the drained_begin done in this function.
Signed-off-by: Emanuele Giuseppe Esposito <eesposit@redhat.com>
---
block.c | 25 ++++++++++++++++++++-----
1 file changed, 20 insertions(+), 5 deletions(-)
diff --git a/block.c b/block.c
index fb5bc3077a..fcc44a49a0 100644
--- a/block.c
+++ b/block.c
@@ -4522,6 +4522,10 @@ int bdrv_reopen_set_read_only(BlockDriverState *bs, bool
read_only,
return bdrv_reopen(bs, opts, true, errp);
}
+TransactionActionDrv bdrv_drv_subtree_end = {
+ .clean = (void (*)(void *)) bdrv_subtree_drained_end_unlocked,
+};
+
/*
* Take a BDRVReopenState and check if the value of 'backing' in the
* reopen_state->options QDict is valid or not.
@@ -4550,6 +4554,7 @@ static int
bdrv_reopen_parse_file_or_backing(BDRVReopenState *reopen_state,
const char *child_name = is_backing ? "backing" : "file";
QObject *value;
const char *str;
+ int ret = 0;
assert(qemu_in_main_thread());
@@ -4573,6 +4578,8 @@ static int
bdrv_reopen_parse_file_or_backing(BDRVReopenState *reopen_state,
"cycle", str, child_name, bs->node_name);
return -EINVAL;
}
+ /* This will be paired with a drained_end in tran_commit */
+ bdrv_subtree_drained_begin_unlocked(new_child_bs);
break;
default:
/*
@@ -4583,18 +4590,19 @@ static int
bdrv_reopen_parse_file_or_backing(BDRVReopenState *reopen_state,
}
if (old_child_bs == new_child_bs) {
- return 0;
+ goto end;
}
if (old_child_bs) {
if (bdrv_skip_implicit_filters(old_child_bs) == new_child_bs) {
- return 0;
+ goto end;
}
if (old_child_bs->implicit) {
error_setg(errp, "Cannot replace implicit %s child of %s",
child_name, bs->node_name);
- return -EPERM;
+ ret = -EPERM;
+ goto end;
}
}
@@ -4605,7 +4613,8 @@ static int
bdrv_reopen_parse_file_or_backing(BDRVReopenState *reopen_state,
*/
error_setg(errp, "'%s' is a %s filter node that does not support a "
"%s child", bs->node_name, bs->drv->format_name,
child_name);
- return -EINVAL;
+ ret = -EINVAL;
+ goto end;
}
if (is_backing) {
@@ -4614,8 +4623,14 @@ static int
bdrv_reopen_parse_file_or_backing(BDRVReopenState *reopen_state,
reopen_state->old_file_bs = old_child_bs;
}
- return bdrv_set_file_or_backing_noperm(bs, new_child_bs, is_backing,
+ ret = bdrv_set_file_or_backing_noperm(bs, new_child_bs, is_backing,
tran, errp);
+
+end:
+ if (new_child_bs) {
+ tran_add(tran, &bdrv_drv_subtree_end, new_child_bs);
+ }
+ return ret;
}
/*
--
2.31.1
- [PATCH 00/12] Removal of Aiocontext lock through drains: protect bdrv_replace_child_noperm., Emanuele Giuseppe Esposito, 2022/01/18
- [PATCH 05/12] test-bdrv-drain.c: adapt test to the coming subtree drains, Emanuele Giuseppe Esposito, 2022/01/18
- [PATCH 01/12] introduce BDRV_POLL_WHILE_UNLOCKED, Emanuele Giuseppe Esposito, 2022/01/18
- [PATCH 09/12] jobs: ensure sleep in job_sleep_ns is fully performed, Emanuele Giuseppe Esposito, 2022/01/18
- [PATCH 08/12] reopen: add a transaction to drain_end nodes picked in bdrv_reopen_parse_file_or_backing,
Emanuele Giuseppe Esposito <=
- [PATCH 10/12] block.c: add subtree_drains where needed, Emanuele Giuseppe Esposito, 2022/01/18
- [PATCH 12/12] block.c: additional assert qemu in main tread, Emanuele Giuseppe Esposito, 2022/01/18
- [PATCH 06/12] test-bdrv-drain.c: remove test_detach_by_parent_cb(), Emanuele Giuseppe Esposito, 2022/01/18
- [PATCH 03/12] block.c: bdrv_replace_child_noperm: first remove the child, and then call ->detach(), Emanuele Giuseppe Esposito, 2022/01/18
- [PATCH 02/12] block/io.c: make bdrv_do_drained_begin_quiesce static and introduce bdrv_drained_begin_no_poll, Emanuele Giuseppe Esposito, 2022/01/18
- [PATCH 04/12] block.c: bdrv_replace_child_noperm: first call ->attach(), and then add child, Emanuele Giuseppe Esposito, 2022/01/18