yannick.naumann/RT-Task-Generator-QEMU
1
0
Fork 0
forked from alwin.berger/FRET-qemu
Code Pull Requests Activity

blockjob: rename notifier callbacks as _locked

Browse Source 
They all are called with job_lock held, in job_event_*_locked()

Signed-off-by: Emanuele Giuseppe Esposito <eesposit@redhat.com>
Reviewed-by: Vladimir Sementsov-Ogievskiy <vsementsov@yandex-team.ru>
Reviewed-by: Stefan Hajnoczi <stefanha@redhat.com>
Reviewed-by: Kevin Wolf <kwolf@redhat.com>
Message-Id: <20220926093214.506243-16-eesposit@redhat.com>
Signed-off-by: Kevin Wolf <kwolf@redhat.com>
This commit is contained in:
Emanuele Giuseppe Esposito 2022-09-26 05:32:08 -04:00 committed by Kevin Wolf
parent 3937e12cf8
commit 243c6ec7fe
1 changed files with 15 additions and 10 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

25
blockjob.c
View File

@ -250,7 +250,8 @@ int block_job_add_bdrv(BlockJob *job, const char *name, BlockDriverState *bs,
return 0; return 0;
} }
static void block_job_on_idle(Notifier *n, void *opaque) /* Called with job_mutex lock held. */
static void block_job_on_idle_locked(Notifier *n, void *opaque)
{ {
aio_wait_kick(); aio_wait_kick();
} }
@ -370,7 +371,8 @@ static void block_job_iostatus_set_err(BlockJob *job, int error)
} }
} }
static void block_job_event_cancelled(Notifier *n, void *opaque) /* Called with job_mutex lock held. */
static void block_job_event_cancelled_locked(Notifier *n, void *opaque)
{ {
BlockJob *job = opaque; BlockJob *job = opaque;
uint64_t progress_current, progress_total; uint64_t progress_current, progress_total;
@ -389,7 +391,8 @@ static void block_job_event_cancelled(Notifier *n, void *opaque)
job->speed); job->speed);
} }
static void block_job_event_completed(Notifier *n, void *opaque) /* Called with job_mutex lock held. */
static void block_job_event_completed_locked(Notifier *n, void *opaque)
{ {
BlockJob *job = opaque; BlockJob *job = opaque;
const char *msg = NULL; const char *msg = NULL;
@ -415,7 +418,8 @@ static void block_job_event_completed(Notifier *n, void *opaque)
msg); msg);
} }
static void block_job_event_pending(Notifier *n, void *opaque) /* Called with job_mutex lock held. */
static void block_job_event_pending_locked(Notifier *n, void *opaque)
{ {
BlockJob *job = opaque; BlockJob *job = opaque;
@ -427,7 +431,8 @@ static void block_job_event_pending(Notifier *n, void *opaque)
job->job.id); job->job.id);
} }
static void block_job_event_ready(Notifier *n, void *opaque) /* Called with job_mutex lock held. */
static void block_job_event_ready_locked(Notifier *n, void *opaque)
{ {
BlockJob *job = opaque; BlockJob *job = opaque;
uint64_t progress_current, progress_total; uint64_t progress_current, progress_total;
@ -472,11 +477,11 @@ void *block_job_create(const char *job_id, const BlockJobDriver *driver,
ratelimit_init(&job->limit); ratelimit_init(&job->limit);
job->finalize_cancelled_notifier.notify = block_job_event_cancelled; job->finalize_cancelled_notifier.notify = block_job_event_cancelled_locked;
job->finalize_completed_notifier.notify = block_job_event_completed; job->finalize_completed_notifier.notify = block_job_event_completed_locked;
job->pending_notifier.notify = block_job_event_pending; job->pending_notifier.notify = block_job_event_pending_locked;
job->ready_notifier.notify = block_job_event_ready; job->ready_notifier.notify = block_job_event_ready_locked;
job->idle_notifier.notify = block_job_on_idle; job->idle_notifier.notify = block_job_on_idle_locked;
WITH_JOB_LOCK_GUARD() { WITH_JOB_LOCK_GUARD() {
notifier_list_add(&job->job.on_finalize_cancelled, notifier_list_add(&job->job.on_finalize_cancelled,