[Date Prev][Date Next][Thread Prev][Thread Next][Date Index][Thread Index]
Re: [PATCH v2 3/7] block/block-copy: factor out block_copy_find_inflight
From: |
Andrey Shinkevich |
Subject: |
Re: [PATCH v2 3/7] block/block-copy: factor out block_copy_find_inflight_req |
Date: |
Wed, 29 Jan 2020 09:25:40 +0000 |
On 27/11/2019 21:08, Vladimir Sementsov-Ogievskiy wrote:
> Split block_copy_find_inflight_req to be used in seprate.
>
> Signed-off-by: Vladimir Sementsov-Ogievskiy <address@hidden>
> ---
> block/block-copy.c | 31 +++++++++++++++++++------------
> 1 file changed, 19 insertions(+), 12 deletions(-)
>
> diff --git a/block/block-copy.c b/block/block-copy.c
> index 74295d93d5..94e7e855ef 100644
> --- a/block/block-copy.c
> +++ b/block/block-copy.c
> @@ -24,23 +24,30 @@
> #define BLOCK_COPY_MAX_BUFFER (1 * MiB)
> #define BLOCK_COPY_MAX_MEM (128 * MiB)
>
> +static BlockCopyInFlightReq *block_copy_find_inflight_req(BlockCopyState *s,
> + int64_t start,
> + int64_t end)
> +{
> + BlockCopyInFlightReq *req;
> +
> + QLIST_FOREACH(req, &s->inflight_reqs, list) {
> + if (end > req->start_byte && start < req->end_byte) {
> + return req;
> + }
> + }
> +
> + return NULL;
> +}
> +
> static void coroutine_fn block_copy_wait_inflight_reqs(BlockCopyState *s,
> int64_t start,
> int64_t end)
> {
> BlockCopyInFlightReq *req;
> - bool waited;
> -
> - do {
> - waited = false;
> - QLIST_FOREACH(req, &s->inflight_reqs, list) {
> - if (end > req->start_byte && start < req->end_byte) {
> - qemu_co_queue_wait(&req->wait_queue, NULL);
> - waited = true;
> - break;
> - }
> - }
> - } while (waited);
> +
> + while ((req = block_copy_find_inflight_req(s, start, end))) {
> + qemu_co_queue_wait(&req->wait_queue, NULL);
> + }
> }
>
> static void block_copy_inflight_req_begin(BlockCopyState *s,
>
Reviewed-by: Andrey Shinkevich <address@hidden>
--
With the best regards,
Andrey Shinkevich
[Prev in Thread] |
Current Thread |
[Next in Thread] |
- Re: [PATCH v2 3/7] block/block-copy: factor out block_copy_find_inflight_req,
Andrey Shinkevich <=