aboutsummaryrefslogtreecommitdiff
path: root/blockjob.c
diff options
context:
space:
mode:
authorFam Zheng <famz@redhat.com>2014-06-24 20:26:35 +0800
committerKevin Wolf <kwolf@redhat.com>2014-06-26 12:12:22 +0200
commitdc71ce45ded4e872e25c2de32d5e7a71842b0985 (patch)
treeaa75e25f7c562b0bf0e77ed653026d7bacaaff2e /blockjob.c
parent2b5b7ae917e8db48431631b1c5d909fa46c223a6 (diff)
blockjob: Add block_job_yield()
This will unset busy flag and put coroutine to sleep, can be used to wait for QMP complete/cancel. Signed-off-by: Fam Zheng <famz@redhat.com> Reviewed-by: Eric Blake <eblake@redhat.com> Signed-off-by: Kevin Wolf <kwolf@redhat.com>
Diffstat (limited to 'blockjob.c')
-rw-r--r--blockjob.c14
1 files changed, 14 insertions, 0 deletions
diff --git a/blockjob.c b/blockjob.c
index 4da86cdfcd..a6db01e953 100644
--- a/blockjob.c
+++ b/blockjob.c
@@ -210,6 +210,20 @@ void block_job_sleep_ns(BlockJob *job, QEMUClockType type, int64_t ns)
job->busy = true;
}
+void block_job_yield(BlockJob *job)
+{
+ assert(job->busy);
+
+ /* Check cancellation *before* setting busy = false, too! */
+ if (block_job_is_cancelled(job)) {
+ return;
+ }
+
+ job->busy = false;
+ qemu_coroutine_yield();
+ job->busy = true;
+}
+
BlockJobInfo *block_job_query(BlockJob *job)
{
BlockJobInfo *info = g_new0(BlockJobInfo, 1);