[Date Prev][Date Next][Thread Prev][Thread Next][Date Index][Thread Index]
Re: [Qemu-devel] [PATCH 05/42] blockjob: Introduce block_job_ratelimit_g
From: |
John Snow |
Subject: |
Re: [Qemu-devel] [PATCH 05/42] blockjob: Introduce block_job_ratelimit_get_delay() |
Date: |
Mon, 14 May 2018 15:36:23 -0400 |
User-agent: |
Mozilla/5.0 (X11; Linux x86_64; rv:52.0) Gecko/20100101 Thunderbird/52.7.0 |
On 05/09/2018 12:26 PM, Kevin Wolf wrote:
> This gets us rid of more direct accesses to BlockJob fields from the
> job drivers.
>
> Signed-off-by: Kevin Wolf <address@hidden>
> Reviewed-by: Eric Blake <address@hidden>
Reviewed-by: John Snow <address@hidden>
> ---
> include/block/blockjob_int.h | 8 ++++++++
> block/backup.c | 18 +++++++-----------
> block/commit.c | 4 ++--
> block/mirror.c | 5 +----
> block/stream.c | 4 ++--
> blockjob.c | 9 +++++++++
> 6 files changed, 29 insertions(+), 19 deletions(-)
>
[...]
> diff --git a/block/backup.c b/block/backup.c
> index 8468fd9f94..cfdb6ecdf5 100644
> --- a/block/backup.c
> +++ b/block/backup.c
> @@ -325,21 +325,17 @@ static void backup_complete(BlockJob *job, void *opaque)
>
> static bool coroutine_fn yield_and_check(BackupBlockJob *job)
> {
> + uint64_t delay_ns;
> +
> if (block_job_is_cancelled(&job->common)) {
> return true;
> }
>
> - /* we need to yield so that bdrv_drain_all() returns.
> - * (without, VM does not reboot)
> - */
I'll kind of miss this terse comment. "without, VM does not reboot" is
very direct and to the point. :)
> - if (job->common.speed) {
> - uint64_t delay_ns = ratelimit_calculate_delay(&job->common.limit,
> - job->bytes_read);
> - job->bytes_read = 0;
> - block_job_sleep_ns(&job->common, delay_ns);
> - } else {
> - block_job_sleep_ns(&job->common, 0);
> - }
> + /* We need to yield even for delay_ns = 0 so that bdrv_drain_all() can
> + * return. Without a yield, the VM would not reboot. */
> + delay_ns = block_job_ratelimit_get_delay(&job->common, job->bytes_read);
> + job->bytes_read = 0;
> + block_job_sleep_ns(&job->common, delay_ns);
>
> if (block_job_is_cancelled(&job->common)) {
> return true;
- [Qemu-devel] [PATCH 07/42] blockjob: Remove block_job_pause/resume_all(), (continued)
- [Qemu-devel] [PATCH 07/42] blockjob: Remove block_job_pause/resume_all(), Kevin Wolf, 2018/05/09
- [Qemu-devel] [PATCH 04/42] blockjob: Implement block_job_set_speed() centrally, Kevin Wolf, 2018/05/09
- [Qemu-devel] [PATCH 05/42] blockjob: Introduce block_job_ratelimit_get_delay(), Kevin Wolf, 2018/05/09
- [Qemu-devel] [PATCH 06/42] blockjob: Add block_job_driver(), Kevin Wolf, 2018/05/09
- [Qemu-devel] [PATCH 09/42] job: Rename BlockJobType into JobType, Kevin Wolf, 2018/05/09
- [Qemu-devel] [PATCH 11/42] job: Add job_delete(), Kevin Wolf, 2018/05/09