[Date Prev][Date Next][Thread Prev][Thread Next][Date Index][Thread Index] [qemu-xen stable-4.13] block: Add bdrv_co_get_self_request()
commit d9b88f7e0d56feb4d7daa2506e2756fc48e975a1 Author: Max Reitz <mreitz@xxxxxxxxxx> AuthorDate: Fri Nov 1 16:25:09 2019 +0100 Commit: Michael Roth <mdroth@xxxxxxxxxxxxxxxxxx> CommitDate: Tue Nov 12 11:59:58 2019 -0600 block: Add bdrv_co_get_self_request() Cc: qemu-stable@xxxxxxxxxx Signed-off-by: Max Reitz <mreitz@xxxxxxxxxx> Message-id: 20191101152510.11719-3-mreitz@xxxxxxxxxx Signed-off-by: Max Reitz <mreitz@xxxxxxxxxx> (cherry picked from commit c28107e9e55b11cd35cf3dc2505e3e69d10dcf13) Signed-off-by: Michael Roth <mdroth@xxxxxxxxxxxxxxxxxx> --- block/io.c | 18 ++++++++++++++++++ include/block/block_int.h | 1 + 2 files changed, 19 insertions(+) diff --git a/block/io.c b/block/io.c index d4ceaaa2ce..65b5102714 100644 --- a/block/io.c +++ b/block/io.c @@ -722,6 +722,24 @@ static bool is_request_serialising_and_aligned(BdrvTrackedRequest *req) } /** + * Return the tracked request on @bs for the current coroutine, or + * NULL if there is none. + */ +BdrvTrackedRequest *coroutine_fn bdrv_co_get_self_request(BlockDriverState *bs) +{ + BdrvTrackedRequest *req; + Coroutine *self = qemu_coroutine_self(); + + QLIST_FOREACH(req, &bs->tracked_requests, list) { + if (req->co == self) { + return req; + } + } + + return NULL; +} + +/** * Round a region to cluster boundaries */ void bdrv_round_to_clusters(BlockDriverState *bs, diff --git a/include/block/block_int.h b/include/block/block_int.h index 4465b02242..05ee6b4866 100644 --- a/include/block/block_int.h +++ b/include/block/block_int.h @@ -964,6 +964,7 @@ void bdrv_unapply_subtree_drain(BdrvChild *child, BlockDriverState *old_parent); bool coroutine_fn bdrv_wait_serialising_requests(BdrvTrackedRequest *self); void bdrv_mark_request_serialising(BdrvTrackedRequest *req, uint64_t align); +BdrvTrackedRequest *coroutine_fn bdrv_co_get_self_request(BlockDriverState *bs); int get_tmp_filename(char *filename, int size); BlockDriver *bdrv_probe_all(const uint8_t *buf, int buf_size, -- generated by git-patchbot for /home/xen/git/qemu-xen.git#stable-4.13
|
Lists.xenproject.org is hosted with RackSpace, monitoring our |