89     /* Is this txn being cancelled? */
116     JobTxn *txn = g_new0(JobTxn, 1);  in job_txn_new()  local
117     QLIST_INIT(&txn->jobs);  in job_txn_new()
118     txn->refcnt = 1;  in job_txn_new()
119     return txn;  in job_txn_new()
123 static void job_txn_ref_locked(JobTxn *txn)  in job_txn_ref_locked()  argument
125     txn->refcnt++;  in job_txn_ref_locked()
128 void job_txn_unref_locked(JobTxn *txn)  in job_txn_unref_locked()  argument
130     if (txn && --txn->refcnt == 0) {  in job_txn_unref_locked()
131         g_free(txn);  in job_txn_unref_locked()
135 void job_txn_unref(JobTxn *txn)  in job_txn_unref()  argument
138     job_txn_unref_locked(txn);  in job_txn_unref()
142  * @txn: The transaction (may be NULL)
149  * If @txn is NULL, the function does nothing.
153 static void job_txn_add_job_locked(JobTxn *txn, Job *job)  in job_txn_add_job_locked()  argument
155     if (!txn) {  in job_txn_add_job_locked()
159     assert(!job->txn);  in job_txn_add_job_locked()
160     job->txn = txn;  in job_txn_add_job_locked()
162     QLIST_INSERT_HEAD(&txn->jobs, job, txn_list);  in job_txn_add_job_locked()
163     job_txn_ref_locked(txn);  in job_txn_add_job_locked()
169     if (job->txn) {  in job_txn_del_job_locked()
171         job_txn_unref_locked(job->txn);  in job_txn_del_job_locked()
172         job->txn = NULL;  in job_txn_del_job_locked()
180     JobTxn *txn = job->txn;  in job_txn_apply_locked()  local
191     QLIST_FOREACH_SAFE(other_job, &txn->jobs, txn_list, next) {  in job_txn_apply_locked()
385 void *job_create(const char *job_id, const JobDriver *driver, JobTxn *txn,  in job_create()  argument
441     if (!txn) {  in job_create()
442         txn = job_txn_new();  in job_create()
443         job_txn_add_job_locked(txn, job);  in job_create()
444         job_txn_unref_locked(txn);  in job_create()
446         job_txn_add_job_locked(txn, job);  in job_create()
464         assert(!job->txn);  in job_unref_locked()
925     JobTxn *txn = job->txn;  in job_completed_txn_abort_locked()  local
928     if (txn->aborting) {  in job_completed_txn_abort_locked()
934     txn->aborting = true;  in job_completed_txn_abort_locked()
935     job_txn_ref_locked(txn);  in job_completed_txn_abort_locked()
942     QLIST_FOREACH(other_job, &txn->jobs, txn_list) {  in job_completed_txn_abort_locked()
952     while (!QLIST_EMPTY(&txn->jobs)) {  in job_completed_txn_abort_locked()
953         other_job = QLIST_FIRST(&txn->jobs);  in job_completed_txn_abort_locked()
962     job_txn_unref_locked(txn);  in job_completed_txn_abort_locked()
993     assert(job && job->txn);  in job_do_finalize_locked()
1033     JobTxn *txn = job->txn;  in job_completed_txn_success_locked()  local
1040      * txn.  in job_completed_txn_success_locked()
1042     QLIST_FOREACH(other_job, &txn->jobs, txn_list) {  in job_completed_txn_success_locked()
1060     assert(job && job->txn && !job_is_completed_locked(job));  in job_completed_locked()