yannick.naumann/RT-Task-Generator-QEMU
1
0
Fork 0
forked from alwin.berger/FRET-qemu
Code Pull Requests Activity

block-backend: replace bdrv_*_above with blk_*_above

Browse Source 
Avoid mixing bdrv_* functions with blk_*, so create blk_* counterparts
for bdrv_block_status_above and bdrv_is_allocated_above.

Note that since blk_co_block_status_above only calls the g_c_w function
bdrv_common_block_status_above and is marked as coroutine_fn, call
directly bdrv_co_common_block_status_above() to avoid using a g_c_w.
Same applies to blk_co_is_allocated_above.

Signed-off-by: Emanuele Giuseppe Esposito <eesposit@redhat.com>
Reviewed-by: Vladimir Sementsov-Ogievskiy <vsementsov@yandex-team.ru>
Message-Id: <20221128142337.657646-5-eesposit@redhat.com>
Reviewed-by: Kevin Wolf <kwolf@redhat.com>
Signed-off-by: Kevin Wolf <kwolf@redhat.com>
This commit is contained in:
Emanuele Giuseppe Esposito 2022-11-28 09:23:27 -05:00 committed by Kevin Wolf
parent 6f58ac5539
commit ff7e261bb9
4 changed files with 48 additions and 18 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

21
block/block-backend.c
View File

@ -1424,6 +1424,27 @@ int coroutine_fn blk_co_pwritev(BlockBackend *blk, int64_t offset,
return blk_co_pwritev_part(blk, offset, bytes, qiov, 0, flags); return blk_co_pwritev_part(blk, offset, bytes, qiov, 0, flags);
} }
int coroutine_fn blk_co_block_status_above(BlockBackend *blk,
BlockDriverState *base,
int64_t offset, int64_t bytes,
int64_t *pnum, int64_t *map,
BlockDriverState **file)
{
IO_CODE();
return bdrv_co_block_status_above(blk_bs(blk), base, offset, bytes, pnum,
map, file);
}
int coroutine_fn blk_co_is_allocated_above(BlockBackend *blk,
BlockDriverState *base,
bool include_base, int64_t offset,
int64_t bytes, int64_t *pnum)
{
IO_CODE();
return bdrv_co_is_allocated_above(blk_bs(blk), base, include_base, offset,
bytes, pnum);
}
typedef struct BlkRwCo { typedef struct BlkRwCo {
BlockBackend *blk; BlockBackend *blk;
int64_t offset; int64_t offset;

4
block/commit.c
View File

@ -155,8 +155,8 @@ static int coroutine_fn commit_run(Job *job, Error **errp)
break; break;
} }
/* Copy if allocated above the base */ /* Copy if allocated above the base */
ret = bdrv_is_allocated_above(blk_bs(s->top), s->base_overlay, true, ret = blk_co_is_allocated_above(s->top, s->base_overlay, true,
offset, COMMIT_BUFFER_SIZE, &n); offset, COMMIT_BUFFER_SIZE, &n);
copy = (ret > 0); copy = (ret > 0);
trace_commit_one_iteration(s, offset, n, ret); trace_commit_one_iteration(s, offset, n, ret);
if (copy) { if (copy) {

9
include/sysemu/block-backend-io.h
View File

@ -92,6 +92,15 @@ int coroutine_fn blk_co_copy_range(BlockBackend *blk_in, int64_t off_in,
int64_t bytes, BdrvRequestFlags read_flags, int64_t bytes, BdrvRequestFlags read_flags,
BdrvRequestFlags write_flags); BdrvRequestFlags write_flags);
int coroutine_fn blk_co_block_status_above(BlockBackend *blk,
BlockDriverState *base,
int64_t offset, int64_t bytes,
int64_t *pnum, int64_t *map,
BlockDriverState **file);
int coroutine_fn blk_co_is_allocated_above(BlockBackend *blk,
BlockDriverState *base,
bool include_base, int64_t offset,
int64_t bytes, int64_t *pnum);
/* /*
* "I/O or GS" API functions. These functions can run without * "I/O or GS" API functions. These functions can run without

32
nbd/server.c
View File

@ -1988,7 +1988,7 @@ static int coroutine_fn nbd_co_send_structured_error(NBDClient *client,
} }
/* Do a sparse read and send the structured reply to the client. /* Do a sparse read and send the structured reply to the client.
* Returns -errno if sending fails. bdrv_block_status_above() failure is * Returns -errno if sending fails. blk_co_block_status_above() failure is
* reported to the client, at which point this function succeeds. * reported to the client, at which point this function succeeds.
*/ */
static int coroutine_fn nbd_co_send_sparse_read(NBDClient *client, static int coroutine_fn nbd_co_send_sparse_read(NBDClient *client,
@ -2004,10 +2004,10 @@ static int coroutine_fn nbd_co_send_sparse_read(NBDClient *client,
while (progress < size) { while (progress < size) {
int64_t pnum; int64_t pnum;
int status = bdrv_block_status_above(blk_bs(exp->common.blk), NULL, int status = blk_co_block_status_above(exp->common.blk, NULL,
offset + progress, offset + progress,
size - progress, &pnum, NULL, size - progress, &pnum, NULL,
NULL); NULL);
bool final; bool final;
if (status < 0) { if (status < 0) {
@ -2138,15 +2138,15 @@ static int nbd_extent_array_add(NBDExtentArray *ea,
return 0; return 0;
} }
static int coroutine_fn blockstatus_to_extents(BlockDriverState *bs, static int coroutine_fn blockstatus_to_extents(BlockBackend *blk,
uint64_t offset, uint64_t bytes, uint64_t offset, uint64_t bytes,
NBDExtentArray *ea) NBDExtentArray *ea)
{ {
while (bytes) { while (bytes) {
uint32_t flags; uint32_t flags;
int64_t num; int64_t num;
int ret = bdrv_co_block_status_above(bs, NULL, offset, bytes, &num, int ret = blk_co_block_status_above(blk, NULL, offset, bytes, &num,
NULL, NULL); NULL, NULL);
if (ret < 0) { if (ret < 0) {
return ret; return ret;
@ -2166,14 +2166,14 @@ static int coroutine_fn blockstatus_to_extents(BlockDriverState *bs,
return 0; return 0;
} }
static int coroutine_fn blockalloc_to_extents(BlockDriverState *bs, static int coroutine_fn blockalloc_to_extents(BlockBackend *blk,
uint64_t offset, uint64_t bytes, uint64_t offset, uint64_t bytes,
NBDExtentArray *ea) NBDExtentArray *ea)
{ {
while (bytes) { while (bytes) {
int64_t num; int64_t num;
int ret = bdrv_co_is_allocated_above(bs, NULL, false, offset, bytes, int ret = blk_co_is_allocated_above(blk, NULL, false, offset, bytes,
&num); &num);
if (ret < 0) { if (ret < 0) {
return ret; return ret;
@ -2221,7 +2221,7 @@ static int nbd_co_send_extents(NBDClient *client, uint64_t handle,
/* Get block status from the exported device and send it to the client */ /* Get block status from the exported device and send it to the client */
static int static int
coroutine_fn nbd_co_send_block_status(NBDClient *client, uint64_t handle, coroutine_fn nbd_co_send_block_status(NBDClient *client, uint64_t handle,
BlockDriverState *bs, uint64_t offset, BlockBackend *blk, uint64_t offset,
uint32_t length, bool dont_fragment, uint32_t length, bool dont_fragment,
bool last, uint32_t context_id, bool last, uint32_t context_id,
Error **errp) Error **errp)
@ -2231,9 +2231,9 @@ coroutine_fn nbd_co_send_block_status(NBDClient *client, uint64_t handle,
g_autoptr(NBDExtentArray) ea = nbd_extent_array_new(nb_extents); g_autoptr(NBDExtentArray) ea = nbd_extent_array_new(nb_extents);
if (context_id == NBD_META_ID_BASE_ALLOCATION) { if (context_id == NBD_META_ID_BASE_ALLOCATION) {
ret = blockstatus_to_extents(bs, offset, length, ea); ret = blockstatus_to_extents(blk, offset, length, ea);
} else { } else {
ret = blockalloc_to_extents(bs, offset, length, ea); ret = blockalloc_to_extents(blk, offset, length, ea);
} }
if (ret < 0) { if (ret < 0) {
return nbd_co_send_structured_error( return nbd_co_send_structured_error(
@ -2560,7 +2560,7 @@ static coroutine_fn int nbd_handle_request(NBDClient *client,
if (client->export_meta.base_allocation) { if (client->export_meta.base_allocation) {
ret = nbd_co_send_block_status(client, request->handle, ret = nbd_co_send_block_status(client, request->handle,
blk_bs(exp->common.blk), exp->common.blk,
request->from, request->from,
request->len, dont_fragment, request->len, dont_fragment,
!--contexts_remaining, !--contexts_remaining,
@ -2573,7 +2573,7 @@ static coroutine_fn int nbd_handle_request(NBDClient *client,
if (client->export_meta.allocation_depth) { if (client->export_meta.allocation_depth) {
ret = nbd_co_send_block_status(client, request->handle, ret = nbd_co_send_block_status(client, request->handle,
blk_bs(exp->common.blk), exp->common.blk,
request->from, request->len, request->from, request->len,
dont_fragment, dont_fragment,
!--contexts_remaining, !--contexts_remaining,