[Date Prev][Date Next][Thread Prev][Thread Next][Date Index][Thread Index]
[Qemu-devel] [PULL 37/46] job: Add job_is_ready()
From: |
Kevin Wolf |
Subject: |
[Qemu-devel] [PULL 37/46] job: Add job_is_ready() |
Date: |
Wed, 23 May 2018 15:11:46 +0200 |
Instead of having a 'bool ready' in BlockJob, add a function that
derives its value from the job status.
At the same time, this fixes the behaviour to match what the QAPI
documentation promises for query-block-job: 'true if the job may be
completed'. When the ready flag was introduced in commit ef6dbf1e46e,
the flag never had to be reset to match the description because after
being ready, the jobs would immediately complete and disappear.
Job transactions and manual job finalisation were introduced only later.
With these changes, jobs may stay around even after having completed
(and they are not ready to be completed a second time), however their
patches forgot to reset the ready flag.
Signed-off-by: Kevin Wolf <address@hidden>
Reviewed-by: Max Reitz <address@hidden>
---
include/block/blockjob.h | 5 -----
include/qemu/job.h | 3 +++
blockjob.c | 3 +--
job.c | 22 ++++++++++++++++++++++
qemu-img.c | 2 +-
tests/test-blockjob.c | 2 +-
6 files changed, 28 insertions(+), 9 deletions(-)
diff --git a/include/block/blockjob.h b/include/block/blockjob.h
index 5a81afc6c3..8e1e1ee0de 100644
--- a/include/block/blockjob.h
+++ b/include/block/blockjob.h
@@ -49,11 +49,6 @@ typedef struct BlockJob {
/** The block device on which the job is operating. */
BlockBackend *blk;
- /**
- * Set to true when the job is ready to be completed.
- */
- bool ready;
-
/** Status that is published by the query-block-jobs QMP API */
BlockDeviceIoStatus iostatus;
diff --git a/include/qemu/job.h b/include/qemu/job.h
index 1e8050c6fb..487f9d9a32 100644
--- a/include/qemu/job.h
+++ b/include/qemu/job.h
@@ -367,6 +367,9 @@ bool job_is_cancelled(Job *job);
/** Returns whether the job is in a completed state. */
bool job_is_completed(Job *job);
+/** Returns whether the job is ready to be completed. */
+bool job_is_ready(Job *job);
+
/**
* Request @job to pause at the next pause point. Must be paired with
* job_resume(). If the job is supposed to be resumed by user action, call
diff --git a/blockjob.c b/blockjob.c
index 3ca009bea5..38f18e9ba3 100644
--- a/blockjob.c
+++ b/blockjob.c
@@ -269,7 +269,7 @@ BlockJobInfo *block_job_query(BlockJob *job, Error **errp)
info->offset = job->offset;
info->speed = job->speed;
info->io_status = job->iostatus;
- info->ready = job->ready;
+ info->ready = job_is_ready(&job->job),
info->status = job->job.status;
info->auto_finalize = job->job.auto_finalize;
info->auto_dismiss = job->job.auto_dismiss;
@@ -436,7 +436,6 @@ void block_job_user_resume(Job *job)
void block_job_event_ready(BlockJob *job)
{
job_state_transition(&job->job, JOB_STATUS_READY);
- job->ready = true;
if (block_job_is_internal(job)) {
return;
diff --git a/job.c b/job.c
index 7cd3602782..aa4c746c8a 100644
--- a/job.c
+++ b/job.c
@@ -199,6 +199,28 @@ bool job_is_cancelled(Job *job)
return job->cancelled;
}
+bool job_is_ready(Job *job)
+{
+ switch (job->status) {
+ case JOB_STATUS_UNDEFINED:
+ case JOB_STATUS_CREATED:
+ case JOB_STATUS_RUNNING:
+ case JOB_STATUS_PAUSED:
+ case JOB_STATUS_WAITING:
+ case JOB_STATUS_PENDING:
+ case JOB_STATUS_ABORTING:
+ case JOB_STATUS_CONCLUDED:
+ case JOB_STATUS_NULL:
+ return false;
+ case JOB_STATUS_READY:
+ case JOB_STATUS_STANDBY:
+ return true;
+ default:
+ g_assert_not_reached();
+ }
+ return false;
+}
+
bool job_is_completed(Job *job)
{
switch (job->status) {
diff --git a/qemu-img.c b/qemu-img.c
index efa7b755d4..700e4e187b 100644
--- a/qemu-img.c
+++ b/qemu-img.c
@@ -866,7 +866,7 @@ static void run_block_job(BlockJob *job, Error **errp)
aio_poll(aio_context, true);
qemu_progress_print(job->len ?
((float)job->offset / job->len * 100.f) : 0.0f, 0);
- } while (!job->ready && !job_is_completed(&job->job));
+ } while (!job_is_ready(&job->job) && !job_is_completed(&job->job));
if (!job_is_completed(&job->job)) {
ret = job_complete_sync(&job->job, errp);
diff --git a/tests/test-blockjob.c b/tests/test-blockjob.c
index 7131cabb16..8180d03a5f 100644
--- a/tests/test-blockjob.c
+++ b/tests/test-blockjob.c
@@ -185,7 +185,7 @@ static void coroutine_fn cancel_job_start(void *opaque)
goto defer;
}
- if (!s->common.ready && s->should_converge) {
+ if (!job_is_ready(&s->common.job) && s->should_converge) {
block_job_event_ready(&s->common);
}
--
2.13.6
- [Qemu-devel] [PULL 22/46] job: Replace BlockJob.completed with job_is_completed(), (continued)
- [Qemu-devel] [PULL 22/46] job: Replace BlockJob.completed with job_is_completed(), Kevin Wolf, 2018/05/23
- [Qemu-devel] [PULL 27/46] job: Convert block_job_cancel_async() to Job, Kevin Wolf, 2018/05/23
- [Qemu-devel] [PULL 16/46] job: Move cancelled to Job, Kevin Wolf, 2018/05/23
- [Qemu-devel] [PULL 20/46] job: Add job_sleep_ns(), Kevin Wolf, 2018/05/23
- [Qemu-devel] [PULL 19/46] job: Move coroutine and related code to Job, Kevin Wolf, 2018/05/23
- [Qemu-devel] [PULL 38/46] job: Add job_transition_to_ready(), Kevin Wolf, 2018/05/23
- [Qemu-devel] [PULL 26/46] job: Move single job finalisation to Job, Kevin Wolf, 2018/05/23
- [Qemu-devel] [PULL 25/46] job: Add job_event_*(), Kevin Wolf, 2018/05/23
- [Qemu-devel] [PULL 34/46] block: Cancel job in bdrv_close_all() callers, Kevin Wolf, 2018/05/23
- [Qemu-devel] [PULL 30/46] job: Move job_finish_sync() to Job, Kevin Wolf, 2018/05/23
- [Qemu-devel] [PULL 37/46] job: Add job_is_ready(),
Kevin Wolf <=
- [Qemu-devel] [PULL 39/46] job: Move progress fields to Job, Kevin Wolf, 2018/05/23
- [Qemu-devel] [PULL 33/46] job: Move completion and cancellation to Job, Kevin Wolf, 2018/05/23
- [Qemu-devel] [PULL 36/46] job: Add job_dismiss(), Kevin Wolf, 2018/05/23
- [Qemu-devel] [PULL 31/46] job: Switch transactions to JobTxn, Kevin Wolf, 2018/05/23
- [Qemu-devel] [PULL 43/46] job: Add query-jobs QMP command, Kevin Wolf, 2018/05/23
- [Qemu-devel] [PULL 44/46] blockjob: Remove BlockJob.driver, Kevin Wolf, 2018/05/23
- [Qemu-devel] [PULL 42/46] job: Add lifecycle QMP commands, Kevin Wolf, 2018/05/23
- [Qemu-devel] [PULL 45/46] iotests: Move qmp_to_opts() to VM, Kevin Wolf, 2018/05/23
- [Qemu-devel] [PULL 35/46] job: Add job_yield(), Kevin Wolf, 2018/05/23
- [Qemu-devel] [PULL 40/46] job: Introduce qapi/job.json, Kevin Wolf, 2018/05/23