| /qemu/ |
| H A D | job.c | 153 static void job_txn_add_job_locked(JobTxn *txn, Job *job) in job_txn_add_job_locked()
167 static void job_txn_del_job_locked(Job *job) in job_txn_del_job_locked()
177 static int job_txn_apply_locked(Job *job, int fn(Job *)) in job_txn_apply_locked() argument
202 bool job_is_internal(Job *job) in job_is_internal()
208 static void job_state_transition_locked(Job *job, JobStatus s1) in job_state_transition_locked()
223 int job_apply_verb_locked(Job *job, JobVerb verb, Error **errp) in job_apply_verb_locked()
237 JobType job_type(const Job *job) in job_type()
242 const char *job_type_str(const Job *job) in job_type_str()
247 bool job_is_cancelled_locked(Job *job) in job_is_cancelled_locked()
254 bool job_is_paused(Job *job) in job_is_paused()
[all …]
|
| H A D | blockjob.c | 39 static bool is_block_job(Job *job) in is_block_job()
49 Job *job = bjob ? &bjob->job : NULL; in block_job_next_locked() local
61 Job *job = job_get_locked(id); in block_job_get_locked() local
77 void block_job_free(Job *job) in block_job_free()
89 BlockJob *job = c->opaque; in child_job_get_parent_desc() local
95 BlockJob *job = c->opaque; in child_job_drained_begin() local
102 Job *job = &bjob->job; in child_job_drained_poll() local
125 BlockJob *job = c->opaque; in child_job_drained_end() local
131 BlockJob *job; member
137 BlockJob *job = s->job; in child_job_set_aio_ctx_commit() local
[all …]
|
| H A D | job-qmp.c | 37 Job *job; in find_job_locked() local
50 Job *job; in qmp_job_cancel() local
65 Job *job; in qmp_job_pause() local
80 Job *job; in qmp_job_resume() local
95 Job *job; in qmp_job_complete() local
110 Job *job; in qmp_job_finalize() local
128 Job *job; in qmp_job_dismiss() local
142 static JobInfo *job_query_single_locked(Job *job, Error **errp) in job_query_single_locked()
169 Job *job; in qmp_query_jobs() local
|
| H A D | blockdev.c | 146 BlockJob *job; in blockdev_mark_auto_del() local
1626 BlockJob *job; member
1816 BlockJob *job; member
2679 BlockJob *job = NULL; in do_backup_common() local
3173 BlockJob *job; in find_block_job_locked() local
3190 BlockJob *job; in qmp_block_job_set_speed() local
3205 BlockJob *job; in qmp_block_job_cancel() local
3230 BlockJob *job; in qmp_block_job_pause() local
3245 BlockJob *job; in qmp_block_job_resume() local
3260 BlockJob *job; in qmp_block_job_complete() local
[all …]
|
| H A D | qemu-img.c | 914 static void run_block_job(BlockJob *job, Error **errp) in run_block_job()
957 BlockJob *job; in img_commit() local
|
| H A D | block.c | 6383 BlockJob *job; in bdrv_get_xdbg_block_graph() local
|
| /qemu/tests/unit/ |
| H A D | test-blockjob.c | 37 BlockJob *job; in mk_job() local
105 BlockJob *job[3]; in test_job_ids() local
168 static void cancel_job_complete(Job *job, Error **errp) in cancel_job_complete()
174 static int coroutine_fn cancel_job_run(Job *job, Error **errp) in cancel_job_run()
206 Job *job; in create_common() local
228 BlockJob *job = &s->common; in cancel_common() local
248 Job *job; in test_cancel_created() local
255 static void assert_job_status_is(Job *job, int status) in assert_job_status_is()
264 Job *job; in test_cancel_running() local
277 Job *job; in test_cancel_paused() local
[all …]
|
| H A D | test-blockjob-txn.c | 28 static int coroutine_fn test_block_job_run(Job *job, Error **errp) in test_block_job_run()
48 TestBlockJob *job; member
111 BlockJob *job; in test_single_job() local
|
| H A D | test-bdrv-drain.c | 641 static int test_job_prepare(Job *job) in test_job_prepare()
650 static void test_job_commit(Job *job) in test_job_commit()
658 static void test_job_abort(Job *job) in test_job_abort()
666 static int coroutine_fn test_job_run(Job *job, Error **errp) in test_job_run()
687 static void test_job_complete(Job *job, Error **errp) in test_job_complete()
724 BlockJob *job; in test_blockjob_common_drain_node() local
1436 static int coroutine_fn test_drop_backing_job_run(Job *job, Error **errp) in test_drop_backing_job_run()
1448 static void test_drop_backing_job_commit(Job *job) in test_drop_backing_job_commit()
1535 TestDropBackingBlockJob *job; in test_blockjob_commit_by_drained_end() local
1582 static int coroutine_fn test_simple_job_run(Job *job, Error **errp) in test_simple_job_run()
[all …]
|
| H A D | test-block-iothread.c | 504 static int test_job_prepare(Job *job) in test_job_prepare()
510 static int coroutine_fn test_job_run(Job *job, Error **errp) in test_job_run()
532 static void test_job_complete(Job *job, Error **errp) in test_job_complete()
748 Job *job = NULL; in test_propagate_mirror() local
|
| /qemu/block/ |
| H A D | backup.c | 56 static void backup_cleanup_sync_bitmap(BackupBlockJob *job, int ret) in backup_cleanup_sync_bitmap()
85 static void backup_commit(Job *job) in backup_commit()
93 static void backup_abort(Job *job) in backup_abort()
101 static void backup_clean(Job *job) in backup_clean()
108 void backup_do_checkpoint(BlockJob *job, Error **errp) in backup_do_checkpoint()
124 static BlockErrorAction backup_error_action(BackupBlockJob *job, in backup_error_action()
148 static int coroutine_fn backup_loop(BackupBlockJob *job) in backup_loop()
229 static void backup_init_bcs_bitmap(BackupBlockJob *job) in backup_init_bcs_bitmap()
250 static int coroutine_fn backup_run(Job *job, Error **errp) in backup_run()
304 static void coroutine_fn backup_pause(Job *job) in backup_pause()
[all …]
|
| H A D | amend.c | 45 static int coroutine_fn blockdev_amend_run(Job *job, Error **errp) in blockdev_amend_run()
68 static void blockdev_amend_free(Job *job) in blockdev_amend_free()
|
| H A D | mirror.c | 101 MirrorBlockJob *job; member
705 static int mirror_exit_common(Job *job) in mirror_exit_common()
857 static int mirror_prepare(Job *job) in mirror_prepare()
862 static void mirror_abort(Job *job) in mirror_abort()
1011 static int coroutine_fn mirror_run(Job *job, Error **errp) in mirror_run()
1262 static void mirror_complete(Job *job, Error **errp) in mirror_complete()
1297 static void coroutine_fn mirror_pause(Job *job) in mirror_pause()
1304 static bool mirror_drained_poll(BlockJob *job) in mirror_drained_poll()
1323 static bool mirror_cancel(Job *job, bool force) in mirror_cancel()
1340 static bool commit_active_cancel(Job *job, bool force) in commit_active_cancel()
[all …]
|
| H A D | stream.c | 54 static int stream_prepare(Job *job) in stream_prepare()
132 static void stream_clean(Job *job) in stream_clean()
153 static int coroutine_fn stream_run(Job *job, Error **errp) in stream_run()
|
| H A D | commit.c | 50 static int commit_prepare(Job *job) in commit_prepare()
71 static void commit_abort(Job *job) in commit_abort()
116 static void commit_clean(Job *job) in commit_clean()
209 static int coroutine_fn commit_run(Job *job, Error **errp) in commit_run()
|
| H A D | create.c | 40 static int coroutine_fn blockdev_create_run(Job *job, Error **errp) in blockdev_create_run()
|
| /qemu/ui/ |
| H A D | vnc-jobs.c | 84 VncJob *job = g_new0(VncJob, 1); in vnc_job_new() local
94 int vnc_job_add_rect(VncJob *job, int x, int y, int w, int h) in vnc_job_add_rect()
111 void vnc_job_push(VncJob *job) in vnc_job_push()
125 VncJob *job; in vnc_has_job_locked() local
210 static bool vnc_worker_clamp_rect(VncState *vs, VncJob *job, VncRect *rect) in vnc_worker_clamp_rect()
240 VncJob *job; in vnc_worker_thread_loop() local
|
| H A D | vnc.c | 1145 VncJob *job; in vnc_update_client() local
|
| /qemu/migration/ |
| H A D | multifd-qpl.c | 26 qpl_job *job; member
64 qpl_job *job; in check_hw_avail() local
130 qpl_job *job = NULL; in multifd_qpl_init_sw_job() local
161 qpl_job *job = NULL; in multifd_qpl_init_hw_job() local
264 static void multifd_qpl_prepare_job(qpl_job *job, bool is_compression, in multifd_qpl_prepare_job()
288 static void multifd_qpl_prepare_comp_job(qpl_job *job, uint8_t *input, in multifd_qpl_prepare_comp_job()
311 static void multifd_qpl_prepare_decomp_job(qpl_job *job, uint8_t *input, in multifd_qpl_prepare_decomp_job()
364 static bool multifd_qpl_submit_job(qpl_job *job) in multifd_qpl_submit_job()
393 qpl_job *job = qpl->sw_job; in multifd_qpl_compress_pages_slow_path() local
531 static bool multifd_qpl_process_and_check_job(qpl_job *job, bool is_hardware, in multifd_qpl_process_and_check_job()
[all …]
|
| H A D | savevm.c | 3595 Job *job = opaque; in snapshot_load_job_bh() local
3616 Job *job = opaque; in snapshot_save_job_bh() local
3630 Job *job = opaque; in snapshot_delete_job_bh() local
3641 static int coroutine_fn snapshot_save_job_run(Job *job, Error **errp) in snapshot_save_job_run()
3652 static int coroutine_fn snapshot_load_job_run(Job *job, Error **errp) in snapshot_load_job_run()
3663 static int coroutine_fn snapshot_delete_job_run(Job *job, Error **errp) in snapshot_delete_job_run()
|
| /qemu/tests/tcg/multiarch/ |
| H A D | signals.c | 63 ThreadJob *job = (ThreadJob *) arg; in background_thread_func() local
80 ThreadJob *job = calloc(sizeof(ThreadJob), 1); in spawn_threads() local
|
| /qemu/tests/qemu-iotests/ |
| H A D | 219 | 67 def test_job_lifecycle(vm, job, job_args, has_ready=False, is_mirror=False): argument
|
| H A D | 264 | 48 def start_job(self, job): argument
|
| /qemu/include/block/ |
| H A D | blockjob.h | 47 Job job; member
|
| /qemu/monitor/ |
| H A D | qmp-cmds.c | 69 BlockJob *job; in qmp_cont() local
|