28 static int coroutine_fn test_block_job_run(Job *job, Error **errp)  in test_block_job_run()  argument
30     TestBlockJob *s = container_of(job, TestBlockJob, common.job);  in test_block_job_run()
34             job_sleep_ns(job, 0);  in test_block_job_run()
36             job_yield(job);  in test_block_job_run()
39         if (job_is_cancelled(job)) {  in test_block_job_run()
48     TestBlockJob *job;  member
55     if (!ret && job_is_cancelled(&data->job->common.job)) {  in test_block_job_cb()
71 /* Create a block job that completes with a given return code after a given
95     snprintf(job_id, sizeof(job_id), "job%u", counter++);  in test_block_job_start()
99     bdrv_unref(bs); /* referenced by job now */  in test_block_job_start()
104     data->job = s;  in test_block_job_start()
111     BlockJob *job;  in test_single_job()  local
116     job = test_block_job_start(1, true, expected, &result, txn);  in test_single_job()
117     job_start(&job->job);  in test_single_job()
121             job_cancel_locked(&job->job, false);  in test_single_job()
159     job_start(&job1->job);  in test_pair_jobs()
160     job_start(&job2->job);  in test_pair_jobs()
169             job_cancel_locked(&job1->job, false);  in test_pair_jobs()
172             job_cancel_locked(&job2->job, false);  in test_pair_jobs()
180     /* Failure or cancellation of one job cancels the other job */  in test_pair_jobs()
199      * iterations so the code path is different depending on which job fails  in test_pair_jobs_failure()
223     job_start(&job1->job);  in test_pair_jobs_fail_cancel_race()
224     job_start(&job2->job);  in test_pair_jobs_fail_cancel_race()
227         job_cancel_locked(&job1->job, false);  in test_pair_jobs_fail_cancel_race()
231      * the race between a pending kick and another job completing.  in test_pair_jobs_fail_cancel_race()
233     job_enter(&job2->job);  in test_pair_jobs_fail_cancel_race()
234     job_enter(&job2->job);  in test_pair_jobs_fail_cancel_race()