xemu-project/xemu
1
0
Fork 0
mirror of https://github.com/xemu-project/xemu.git synced 2024-11-26 21:10:42 +00:00
Code Issues Actions Packages Projects Releases Wiki Activity

block/reqlist: add reqlist_wait_all()

Browse Source 
Add function to wait for all intersecting requests.
To be used in the further commit.

Signed-off-by: Vladimir Sementsov-Ogievskiy <vsementsov@virtuozzo.com>
Reviewed-by: Nikita Lapshin <nikita.lapshin@virtuozzo.com>
Reviewed-by: Hanna Reitz <hreitz@redhat.com>
Message-Id: <20220303194349.2304213-10-vsementsov@virtuozzo.com>
Signed-off-by: Hanna Reitz <hreitz@redhat.com>
This commit is contained in:
Vladimir Sementsov-Ogievskiy 2022-03-03 20:43:42 +01:00 committed by Hanna Reitz
parent a6426475a7
commit 3b7ca26bdf
2 changed files with 16 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
block/reqlist.c
View File

@ -58,6 +58,14 @@ bool coroutine_fn reqlist_wait_one(BlockReqList *reqs, int64_t offset,
return true; return true;
} }
void coroutine_fn reqlist_wait_all(BlockReqList *reqs, int64_t offset,
int64_t bytes, CoMutex *lock)
{
while (reqlist_wait_one(reqs, offset, bytes, lock)) {
/* continue */
}
}
void coroutine_fn reqlist_shrink_req(BlockReq *req, int64_t new_bytes) void coroutine_fn reqlist_shrink_req(BlockReq *req, int64_t new_bytes)
{ {
if (new_bytes == req->bytes) { if (new_bytes == req->bytes) {

8
include/block/reqlist.h
View File

@ -53,6 +53,14 @@ BlockReq *reqlist_find_conflict(BlockReqList *reqs, int64_t offset,
bool coroutine_fn reqlist_wait_one(BlockReqList *reqs, int64_t offset, bool coroutine_fn reqlist_wait_one(BlockReqList *reqs, int64_t offset,
int64_t bytes, CoMutex *lock); int64_t bytes, CoMutex *lock);
/*
* Wait for all intersecting requests. It just calls reqlist_wait_one() in a
* loop, caller is responsible to stop producing new requests in this region
* in parallel, otherwise reqlist_wait_all() may never return.
*/
void coroutine_fn reqlist_wait_all(BlockReqList *reqs, int64_t offset,
int64_t bytes, CoMutex *lock);
/* /*
* Shrink request and wake all waiting coroutines (maybe some of them are not * Shrink request and wake all waiting coroutines (maybe some of them are not
* intersecting with shrunk request). * intersecting with shrunk request).