job: take each job's lock individually in job_txn_apply

[mirror_qemu.git] / tests / test-blockjob.c

diff --git a/tests/test-blockjob.c b/tests/test-blockjob.c
index 4eeb184caf8ec175948aaeace2a2caf1503258f1..751984791203260bac879656bd47d33f31b870ec 100644 (file)
--- a/tests/test-blockjob.c
+++ b/tests/test-blockjob.c
@@ -367,7 +367,9 @@ static void test_cancel_concluded(void)
     aio_poll(qemu_get_aio_context(), true);
     assert(job->status == JOB_STATUS_PENDING);
 
+    aio_context_acquire(job->aio_context);
     job_finalize(job, &error_abort);
+    aio_context_release(job->aio_context);
     assert(job->status == JOB_STATUS_CONCLUDED);
 
     cancel_common(s);