From: Emanuele Giuseppe Esposito <eesposit@redhat.com>
To: qemu-block@nongnu.org
Cc: Kevin Wolf <kwolf@redhat.com>,
Emanuele Giuseppe Esposito <eesposit@redhat.com>,
Vladimir Sementsov-Ogievskiy <vsementsov@virtuozzo.com>,
qemu-devel@nongnu.org, Wen Congyang <wencongyang2@huawei.com>,
Xie Changlong <xiechanglong.d@gmail.com>,
Markus Armbruster <armbru@redhat.com>,
Max Reitz <mreitz@redhat.com>,
Stefan Hajnoczi <stefanha@redhat.com>,
Paolo Bonzini <pbonzini@redhat.com>, John Snow <jsnow@redhat.com>
Subject: [RFC PATCH 4/6] job.h: categorize job fields
Date: Wed, 7 Jul 2021 18:58:11 +0200 [thread overview]
Message-ID: <20210707165813.55361-5-eesposit@redhat.com> (raw)
In-Reply-To: <20210707165813.55361-1-eesposit@redhat.com>
This makes it easier to understand what needs to be protected
by a lock and what doesn't.
Signed-off-by: Emanuele Giuseppe Esposito <eesposit@redhat.com>
---
include/qemu/job.h | 101 ++++++++++++++++++++++++++++++++++++---------
1 file changed, 82 insertions(+), 19 deletions(-)
diff --git a/include/qemu/job.h b/include/qemu/job.h
index ba2f9b2660..4421d08d93 100644
--- a/include/qemu/job.h
+++ b/include/qemu/job.h
@@ -40,24 +40,40 @@ typedef struct JobTxn JobTxn;
* Long-running operation.
*/
typedef struct Job {
- /** The ID of the job. May be NULL for internal jobs. */
+ /**
+ * The ID of the job. May be NULL for internal jobs.
+ * Set it in job_create and just read.
+ */
char *id;
- /** The type of this job. */
+ /**
+ * The type of this job.
+ * Set it in job_create and just read.
+ */
const JobDriver *driver;
- /** Reference count of the block job */
+ /**
+ * Reference count of the block job.
+ * Protected by job_mutex.
+ */
int refcnt;
- /** Current state; See @JobStatus for details. */
+ /**
+ * Current state; See @JobStatus for details.
+ * Protected by job_mutex.
+ */
JobStatus status;
- /** AioContext to run the job coroutine in */
+ /**
+ * AioContext to run the job coroutine in.
+ * Atomic.
+ */
AioContext *aio_context;
/**
* The coroutine that executes the job. If not NULL, it is reentered when
* busy is false and the job is cancelled.
+ * Set it in job_create and just read.
*/
Coroutine *co;
@@ -70,13 +86,15 @@ typedef struct Job {
/**
* Counter for pause request. If non-zero, the block job is either paused,
* or if busy == true will pause itself as soon as possible.
+ * Protected by job_mutex.
*/
int pause_count;
/**
* Set to false by the job while the coroutine has yielded and may be
* re-entered by job_enter(). There may still be I/O or event loop activity
- * pending. Accessed under block_job_mutex (in blockjob.c).
+ * pending.
+ * Protected by job_mutex.
*
* When the job is deferred to the main loop, busy is true as long as the
* bottom half is still pending.
@@ -86,12 +104,14 @@ typedef struct Job {
/**
* Set to true by the job while it is in a quiescent state, where
* no I/O or event loop activity is pending.
+ * Protected by job_mutex.
*/
bool paused;
/**
* Set to true if the job is paused by user. Can be unpaused with the
* block-job-resume QMP command.
+ * Protected by job_mutex.
*/
bool user_paused;
@@ -100,22 +120,33 @@ typedef struct Job {
* always be tested just before toggling the busy flag from false
* to true. After a job has been cancelled, it should only yield
* if #aio_poll will ("sooner or later") reenter the coroutine.
+ * Protected by job_mutex.
*/
bool cancelled;
/**
* Set to true if the job should abort immediately without waiting
* for data to be in sync.
+ * Protected by job_mutex.
*/
bool force_cancel;
- /** Set to true when the job has deferred work to the main loop. */
+ /**
+ * Set to true when the job has deferred work to the main loop.
+ * Protected by job_mutex.
+ */
bool deferred_to_main_loop;
- /** True if this job should automatically finalize itself */
+ /**
+ * True if this job should automatically finalize itself.
+ * Set it in job_create and just read.
+ */
bool auto_finalize;
- /** True if this job should automatically dismiss itself */
+ /**
+ * True if this job should automatically dismiss itself.
+ * Set it in job_create and just read.
+ */
bool auto_dismiss;
ProgressMeter progress;
@@ -124,6 +155,7 @@ typedef struct Job {
* Return code from @run and/or @prepare callback(s).
* Not final until the job has reached the CONCLUDED status.
* 0 on success, -errno on failure.
+ * Protected by job_mutex.
*/
int ret;
@@ -131,37 +163,68 @@ typedef struct Job {
* Error object for a failed job.
* If job->ret is nonzero and an error object was not set, it will be set
* to strerror(-job->ret) during job_completed.
+ * Protected by job_mutex.
*/
Error *err;
- /** The completion function that will be called when the job completes. */
+ /**
+ * The completion function that will be called when the job completes.
+ * Set it in job_create and just read.
+ */
BlockCompletionFunc *cb;
- /** The opaque value that is passed to the completion function. */
+ /**
+ * The opaque value that is passed to the completion function.
+ * Set it in job_create and just read.
+ */
void *opaque;
- /** Notifiers called when a cancelled job is finalised */
+ /**
+ * Notifiers called when a cancelled job is finalised.
+ * Protected by job_mutex.
+ */
NotifierList on_finalize_cancelled;
- /** Notifiers called when a successfully completed job is finalised */
+ /**
+ * Notifiers called when a successfully completed job is finalised.
+ * Protected by job_mutex.
+ */
NotifierList on_finalize_completed;
- /** Notifiers called when the job transitions to PENDING */
+ /**
+ * Notifiers called when the job transitions to PENDING.
+ * Protected by job_mutex.
+ */
NotifierList on_pending;
- /** Notifiers called when the job transitions to READY */
+ /**
+ * Notifiers called when the job transitions to READY.
+ * Protected by job_mutex.
+ */
NotifierList on_ready;
- /** Notifiers called when the job coroutine yields or terminates */
+ /**
+ * Notifiers called when the job coroutine yields or terminates.
+ * Protected by job_mutex.
+ */
NotifierList on_idle;
- /** Element of the list of jobs */
+ /**
+ * Element of the list of jobs.
+ * Protected by job_mutex.
+ */
QLIST_ENTRY(Job) job_list;
- /** Transaction this job is part of */
+ /**
+ * Transaction this job is part of.
+ * Protected by job_mutex.
+ */
JobTxn *txn;
- /** Element of the list of jobs in a job transaction */
+ /**
+ * Element of the list of jobs in a job transaction.
+ * Protected by job_mutex.
+ */
QLIST_ENTRY(Job) txn_list;
} Job;
--
2.31.1
next prev parent reply other threads:[~2021-07-07 17:03 UTC|newest]
Thread overview: 33+ messages / expand[flat|nested] mbox.gz Atom feed top
2021-07-07 16:58 [RFC PATCH 0/6] job: replace AioContext lock with job_mutex Emanuele Giuseppe Esposito
2021-07-07 16:58 ` [RFC PATCH 1/6] job: use getter/setters instead of accessing the Job fields directly Emanuele Giuseppe Esposito
2021-07-07 16:58 ` [RFC PATCH 2/6] job: _locked functions and public job_lock/unlock for next patch Emanuele Giuseppe Esposito
2021-07-08 10:50 ` Stefan Hajnoczi
2021-07-12 8:43 ` Emanuele Giuseppe Esposito
2021-07-13 13:32 ` Stefan Hajnoczi
2021-07-07 16:58 ` [RFC PATCH 3/6] job: minor changes to simplify locking Emanuele Giuseppe Esposito
2021-07-08 10:55 ` Stefan Hajnoczi
2021-07-12 8:43 ` Emanuele Giuseppe Esposito
2021-07-13 17:56 ` Eric Blake
2021-07-07 16:58 ` Emanuele Giuseppe Esposito [this message]
2021-07-08 11:02 ` [RFC PATCH 4/6] job.h: categorize job fields Stefan Hajnoczi
2021-07-12 8:43 ` Emanuele Giuseppe Esposito
2021-07-07 16:58 ` [RFC PATCH 5/6] job: use global job_mutex to protect struct Job Emanuele Giuseppe Esposito
2021-07-08 12:56 ` Stefan Hajnoczi
2021-07-12 8:43 ` Emanuele Giuseppe Esposito
2021-07-07 16:58 ` [RFC PATCH 6/6] jobs: remove unnecessary AioContext aquire/release pairs Emanuele Giuseppe Esposito
2021-07-08 10:36 ` [RFC PATCH 0/6] job: replace AioContext lock with job_mutex Stefan Hajnoczi
2021-07-08 11:32 ` Paolo Bonzini
2021-07-08 12:14 ` Kevin Wolf
2021-07-08 13:04 ` Stefan Hajnoczi
2021-07-12 8:41 ` Emanuele Giuseppe Esposito
2021-07-13 13:10 ` Stefan Hajnoczi
2021-07-13 15:18 ` Vladimir Sementsov-Ogievskiy
2021-07-13 16:38 ` Stefan Hajnoczi
2021-07-15 12:35 ` Vladimir Sementsov-Ogievskiy
2021-07-15 13:29 ` Stefan Hajnoczi
2021-07-16 15:23 ` Kevin Wolf
2021-07-19 9:29 ` Stefan Hajnoczi
2021-07-19 14:54 ` Kevin Wolf
2021-07-08 13:09 ` Stefan Hajnoczi
2021-07-12 8:42 ` Emanuele Giuseppe Esposito
2021-07-13 13:27 ` Stefan Hajnoczi
Reply instructions:
You may reply publicly to this message via plain-text email
using any one of the following methods:
* Save the following mbox file, import it into your mail client,
and reply-to-all from there: mbox
Avoid top-posting and favor interleaved quoting:
https://en.wikipedia.org/wiki/Posting_style#Interleaved_style
* Reply using the --to, --cc, and --in-reply-to
switches of git-send-email(1):
git send-email \
--in-reply-to=20210707165813.55361-5-eesposit@redhat.com \
--to=eesposit@redhat.com \
--cc=armbru@redhat.com \
--cc=jsnow@redhat.com \
--cc=kwolf@redhat.com \
--cc=mreitz@redhat.com \
--cc=pbonzini@redhat.com \
--cc=qemu-block@nongnu.org \
--cc=qemu-devel@nongnu.org \
--cc=stefanha@redhat.com \
--cc=vsementsov@virtuozzo.com \
--cc=wencongyang2@huawei.com \
--cc=xiechanglong.d@gmail.com \
/path/to/YOUR_REPLY
https://kernel.org/pub/software/scm/git/docs/git-send-email.html
* If your mail client supports setting the In-Reply-To header
via mailto: links, try the mailto: link
Be sure your reply has a Subject: header at the top and a blank line
before the message body.
This is a public inbox, see mirroring instructions
for how to clone and mirror all data and code used for this inbox;
as well as URLs for NNTP newsgroup(s).