return job->pause_count > 0;
}
+static void block_job_do_yield(BlockJob *job)
+{
+ job->busy = false;
+ qemu_coroutine_yield();
+
+ /* Set by block_job_enter before re-entering the coroutine. */
+ assert(job->busy);
+}
+
void coroutine_fn block_job_pause_point(BlockJob *job)
{
assert(job && block_job_started(job));
if (block_job_should_pause(job) && !block_job_is_cancelled(job)) {
job->paused = true;
- job->busy = false;
- qemu_coroutine_yield(); /* wait for block_job_resume() */
- job->busy = true;
+ block_job_do_yield(job);
job->paused = false;
}
return;
}
- if (!job->busy) {
- bdrv_coroutine_enter(blk_bs(job->blk), job->co);
+ if (job->busy) {
+ return;
}
+
+ job->busy = true;
+ aio_co_wake(job->co);
}
bool block_job_is_cancelled(BlockJob *job)
return;
}
- job->busy = false;
if (!block_job_should_pause(job)) {
- qemu_coroutine_yield();
+ block_job_do_yield(job);
}
- job->busy = true;
block_job_pause_point(job);
}