motorhead/qemu
1
0
Fork 0
mirror of https://github.com/Motorhead1991/qemu.git synced 2025-08-09 02:24:58 -06:00
Code Issues Projects Releases Packages Wiki Activity Actions

block.c: assertions to the block layer permissions API

Browse source 
Now that we "covered" the three main cases where the
permission API was being used under BQL (fuse,
amend and invalidate_cache), we can safely assert for
the permission functions implemented in block.c

Signed-off-by: Emanuele Giuseppe Esposito <eesposit@redhat.com>
Message-Id: <20220303151616.325444-11-eesposit@redhat.com>
Signed-off-by: Kevin Wolf <kwolf@redhat.com>
This commit is contained in:
Emanuele Giuseppe Esposito 2022-03-03 10:15:55 -05:00 • committed by Kevin Wolf
parent 37868b2ac6
commit 862fded928
1 changed files with 12 additions and 0 deletions
Download patch file Download diff file Expand all files Collapse all files

12
block.c
View file

@ -2109,6 +2109,7 @@ static bool bdrv_a_allow_b(BdrvChild *a, BdrvChild *b, Error **errp)
assert(a->bs); assert(a->bs);
assert(a->bs == b->bs); assert(a->bs == b->bs);
GLOBAL_STATE_CODE();
if ((b->perm & a->shared_perm) == b->perm) { if ((b->perm & a->shared_perm) == b->perm) {
return true; return true;
@ -2132,6 +2133,7 @@ static bool bdrv_a_allow_b(BdrvChild *a, BdrvChild *b, Error **errp)
static bool bdrv_parent_perms_conflict(BlockDriverState *bs, Error **errp) static bool bdrv_parent_perms_conflict(BlockDriverState *bs, Error **errp)
{ {
BdrvChild *a, *b; BdrvChild *a, *b;
GLOBAL_STATE_CODE();
/* /*
* During the loop we'll look at each pair twice. That's correct because * During the loop we'll look at each pair twice. That's correct because
@ -2213,6 +2215,8 @@ static void bdrv_child_set_perm_abort(void *opaque)
{ {
BdrvChildSetPermState *s = opaque; BdrvChildSetPermState *s = opaque;
GLOBAL_STATE_CODE();
s->child->perm = s->old_perm; s->child->perm = s->old_perm;
s->child->shared_perm = s->old_shared_perm; s->child->shared_perm = s->old_shared_perm;
} }
@ -2226,6 +2230,7 @@ static void bdrv_child_set_perm(BdrvChild *c, uint64_t perm,
uint64_t shared, Transaction *tran) uint64_t shared, Transaction *tran)
{ {
BdrvChildSetPermState *s = g_new(BdrvChildSetPermState, 1); BdrvChildSetPermState *s = g_new(BdrvChildSetPermState, 1);
GLOBAL_STATE_CODE();
*s = (BdrvChildSetPermState) { *s = (BdrvChildSetPermState) {
.child = c, .child = c,
@ -2405,6 +2410,7 @@ static int bdrv_node_refresh_perm(BlockDriverState *bs, BlockReopenQueue *q,
BdrvChild *c; BdrvChild *c;
int ret; int ret;
uint64_t cumulative_perms, cumulative_shared_perms; uint64_t cumulative_perms, cumulative_shared_perms;
GLOBAL_STATE_CODE();
bdrv_get_cumulative_perm(bs, &cumulative_perms, &cumulative_shared_perms); bdrv_get_cumulative_perm(bs, &cumulative_perms, &cumulative_shared_perms);
@ -2473,6 +2479,7 @@ static int bdrv_list_refresh_perms(GSList *list, BlockReopenQueue *q,
{ {
int ret; int ret;
BlockDriverState *bs; BlockDriverState *bs;
GLOBAL_STATE_CODE();
for ( ; list; list = list->next) { for ( ; list; list = list->next) {
bs = list->data; bs = list->data;
@ -2540,6 +2547,7 @@ static int bdrv_refresh_perms(BlockDriverState *bs, Error **errp)
int ret; int ret;
Transaction *tran = tran_new(); Transaction *tran = tran_new();
g_autoptr(GSList) list = bdrv_topological_dfs(NULL, NULL, bs); g_autoptr(GSList) list = bdrv_topological_dfs(NULL, NULL, bs);
GLOBAL_STATE_CODE();
ret = bdrv_list_refresh_perms(list, NULL, tran, errp); ret = bdrv_list_refresh_perms(list, NULL, tran, errp);
tran_finalize(tran, ret); tran_finalize(tran, ret);
@ -2602,6 +2610,7 @@ static void bdrv_filter_default_perms(BlockDriverState *bs, BdrvChild *c,
uint64_t perm, uint64_t shared, uint64_t perm, uint64_t shared,
uint64_t *nperm, uint64_t *nshared) uint64_t *nperm, uint64_t *nshared)
{ {
GLOBAL_STATE_CODE();
*nperm = perm & DEFAULT_PERM_PASSTHROUGH; *nperm = perm & DEFAULT_PERM_PASSTHROUGH;
*nshared = (shared & DEFAULT_PERM_PASSTHROUGH) | DEFAULT_PERM_UNCHANGED; *nshared = (shared & DEFAULT_PERM_PASSTHROUGH) | DEFAULT_PERM_UNCHANGED;
} }
@ -2613,6 +2622,7 @@ static void bdrv_default_perms_for_cow(BlockDriverState *bs, BdrvChild *c,
uint64_t *nperm, uint64_t *nshared) uint64_t *nperm, uint64_t *nshared)
{ {
assert(role & BDRV_CHILD_COW); assert(role & BDRV_CHILD_COW);
GLOBAL_STATE_CODE();
/* /*
* We want consistent read from backing files if the parent needs it. * We want consistent read from backing files if the parent needs it.
@ -2649,6 +2659,7 @@ static void bdrv_default_perms_for_storage(BlockDriverState *bs, BdrvChild *c,
{ {
int flags; int flags;
GLOBAL_STATE_CODE();
assert(role & (BDRV_CHILD_METADATA | BDRV_CHILD_DATA)); assert(role & (BDRV_CHILD_METADATA | BDRV_CHILD_DATA));
flags = bdrv_reopen_get_flags(reopen_queue, bs); flags = bdrv_reopen_get_flags(reopen_queue, bs);
@ -6028,6 +6039,7 @@ static void xdbg_graph_add_edge(XDbgBlockGraphConstructor *gr, void *parent,
{ {
BlockPermission qapi_perm; BlockPermission qapi_perm;
XDbgBlockGraphEdge *edge; XDbgBlockGraphEdge *edge;
GLOBAL_STATE_CODE();
edge = g_new0(XDbgBlockGraphEdge, 1); edge = g_new0(XDbgBlockGraphEdge, 1);