job.c: API functions not used outside should be static
job_event_* functions can all be static, as they are not used outside job.c. Same applies for job_txn_add_job(). Signed-off-by: Emanuele Giuseppe Esposito <eesposit@redhat.com> Reviewed-by: Stefan Hajnoczi <stefanha@redhat.com> Reviewed-by: Vladimir Sementsov-Ogievskiy <vsementsov@yandex-team.ru> Reviewed-by: Kevin Wolf <kwolf@redhat.com> Message-Id: <20220926093214.506243-4-eesposit@redhat.com> Signed-off-by: Kevin Wolf <kwolf@redhat.com>
This commit is contained in:
parent
d08f07541f
commit
544f4d5258
@ -358,18 +358,6 @@ JobTxn *job_txn_new(void);
|
|||||||
*/
|
*/
|
||||||
void job_txn_unref(JobTxn *txn);
|
void job_txn_unref(JobTxn *txn);
|
||||||
|
|
||||||
/**
|
|
||||||
* @txn: The transaction (may be NULL)
|
|
||||||
* @job: Job to add to the transaction
|
|
||||||
*
|
|
||||||
* Add @job to the transaction. The @job must not already be in a transaction.
|
|
||||||
* The caller must call either job_txn_unref() or job_completed() to release
|
|
||||||
* the reference that is automatically grabbed here.
|
|
||||||
*
|
|
||||||
* If @txn is NULL, the function does nothing.
|
|
||||||
*/
|
|
||||||
void job_txn_add_job(JobTxn *txn, Job *job);
|
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* Create a new long-running job and return it.
|
* Create a new long-running job and return it.
|
||||||
*
|
*
|
||||||
@ -431,12 +419,6 @@ void job_progress_set_remaining(Job *job, uint64_t remaining);
|
|||||||
*/
|
*/
|
||||||
void job_progress_increase_remaining(Job *job, uint64_t delta);
|
void job_progress_increase_remaining(Job *job, uint64_t delta);
|
||||||
|
|
||||||
/** To be called when a cancelled job is finalised. */
|
|
||||||
void job_event_cancelled(Job *job);
|
|
||||||
|
|
||||||
/** To be called when a successfully completed job is finalised. */
|
|
||||||
void job_event_completed(Job *job);
|
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* Conditionally enter the job coroutine if the job is ready to run, not
|
* Conditionally enter the job coroutine if the job is ready to run, not
|
||||||
* already busy and fn() returns true. fn() is called while under the job_lock
|
* already busy and fn() returns true. fn() is called while under the job_lock
|
||||||
|
22
job.c
22
job.c
@ -125,7 +125,17 @@ void job_txn_unref(JobTxn *txn)
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
void job_txn_add_job(JobTxn *txn, Job *job)
|
/**
|
||||||
|
* @txn: The transaction (may be NULL)
|
||||||
|
* @job: Job to add to the transaction
|
||||||
|
*
|
||||||
|
* Add @job to the transaction. The @job must not already be in a transaction.
|
||||||
|
* The caller must call either job_txn_unref() or job_completed() to release
|
||||||
|
* the reference that is automatically grabbed here.
|
||||||
|
*
|
||||||
|
* If @txn is NULL, the function does nothing.
|
||||||
|
*/
|
||||||
|
static void job_txn_add_job(JobTxn *txn, Job *job)
|
||||||
{
|
{
|
||||||
if (!txn) {
|
if (!txn) {
|
||||||
return;
|
return;
|
||||||
@ -427,12 +437,18 @@ void job_progress_increase_remaining(Job *job, uint64_t delta)
|
|||||||
progress_increase_remaining(&job->progress, delta);
|
progress_increase_remaining(&job->progress, delta);
|
||||||
}
|
}
|
||||||
|
|
||||||
void job_event_cancelled(Job *job)
|
/**
|
||||||
|
* To be called when a cancelled job is finalised.
|
||||||
|
*/
|
||||||
|
static void job_event_cancelled(Job *job)
|
||||||
{
|
{
|
||||||
notifier_list_notify(&job->on_finalize_cancelled, job);
|
notifier_list_notify(&job->on_finalize_cancelled, job);
|
||||||
}
|
}
|
||||||
|
|
||||||
void job_event_completed(Job *job)
|
/**
|
||||||
|
* To be called when a successfully completed job is finalised.
|
||||||
|
*/
|
||||||
|
static void job_event_completed(Job *job)
|
||||||
{
|
{
|
||||||
notifier_list_notify(&job->on_finalize_completed, job);
|
notifier_list_notify(&job->on_finalize_completed, job);
|
||||||
}
|
}
|
||||||
|
Loading…
x
Reference in New Issue
Block a user