/qemu/ |
H A D | job.c | 616 job->driver->pause(job); in job_pause_point_locked() 633 job->driver->resume(job); in job_pause_point_locked() 816 job->driver->commit(job); in job_commit() 825 job->driver->abort(job); in job_abort() 833 job->driver->clean(job); in job_clean() 993 assert(job && job->txn); in job_do_finalize_locked() 1006 assert(job && job->id); in job_finalize_locked() 1060 assert(job && job->txn && !job_is_completed_locked(job)); in job_completed_locked() 1101 assert(job && job->driver && job->driver->run); in job_co_entry() 1106 ret = job->driver->run(job, &job->err); in job_co_entry() [all …]
|
H A D | blockjob.c | 53 job = job_next_locked(job); in block_job_next_locked() 56 return job ? container_of(job, BlockJob, job) : NULL; in block_job_next_locked() 90 return g_strdup_printf("%s job '%s'", job_type_str(&job->job), job->job.id); in child_job_get_parent_desc() 96 job_pause(&job->job); in child_job_drained_begin() 102 Job *job = &bjob->job; in child_job_drained_poll() local 126 job_resume(&job->job); in child_job_drained_end() 137 BlockJob *job = s->job; in child_job_set_aio_ctx_commit() local 166 .job = job, in child_job_change_aio_ctx() 388 if (job->job.ret) { in block_job_query_locked() 441 if (job->job.ret < 0) { in block_job_event_completed_locked() [all …]
|
H A D | job-qmp.c | 37 Job *job; in find_job_locked() local 40 if (!job) { in find_job_locked() 45 return job; in find_job_locked() 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 169 Job *job; in qmp_query_jobs() local [all …]
|
H A D | trace-events | 45 # job.c 46 job_state_transition(void *job, int ret, const char *legal, const char *s0, const char *s1) "job %… 47 job_apply_verb(void *job, const char *state, const char *verb, const char *legal) "job %p in state … 48 job_completed(void *job, int ret) "job %p ret %d" 50 # job-qmp.c 51 qmp_job_cancel(void *job) "job %p" 52 qmp_job_pause(void *job) "job %p" 53 qmp_job_resume(void *job) "job %p" 54 qmp_job_complete(void *job) "job %p" 55 qmp_job_finalize(void *job) "job %p" [all …]
|
/qemu/tests/unit/ |
H A D | test-blockjob.c | 129 job_early_fail(&job[1]->job); in test_job_ids() 135 job_early_fail(&job[0]->job); in test_job_ids() 139 job_early_fail(&job[1]->job); in test_job_ids() 152 job_early_fail(&job[0]->job); in test_job_ids() 153 job_early_fail(&job[1]->job); in test_job_ids() 154 job_early_fail(&job[2]->job); in test_job_ids() 213 job = &bjob->job; in create_common() 230 JobStatus sts = job->job.status; in cancel_common() 232 job_cancel_sync(&job->job, true); in cancel_common() 235 Job *dummy = &job->job; in cancel_common() [all …]
|
H A D | test-blockjob-txn.c | 30 TestBlockJob *s = container_of(job, TestBlockJob, common.job); in test_block_job_run() 36 job_yield(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() 104 data->job = s; in test_block_job_start() 111 BlockJob *job; in test_single_job() local 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() [all …]
|
H A D | test-bdrv-drain.c | 788 job_start(&job->job); in test_blockjob_common_drain_node() 800 g_assert_cmpint(job->job.pause_count, ==, 0); in test_blockjob_common_drain_node() 801 g_assert_false(job->job.paused); in test_blockjob_common_drain_node() 815 g_assert_true(job->job.paused); in test_blockjob_common_drain_node() 828 while (job->job.paused) { in test_blockjob_common_drain_node() 835 g_assert_false(job->job.paused); in test_blockjob_common_drain_node() 848 g_assert_true(job->job.paused); in test_blockjob_common_drain_node() 861 while (job->job.paused) { in test_blockjob_common_drain_node() 868 g_assert_false(job->job.paused); in test_blockjob_common_drain_node() 1542 job_start(&job->common.job); in test_blockjob_commit_by_drained_end() [all …]
|
/qemu/block/ |
H A D | backup.c | 87 BackupBlockJob *s = container_of(job, BackupBlockJob, common.job); in backup_commit() 156 job->bg_bcs_call = s = block_copy_async(job->bcs, 0, in backup_loop() 157 QEMU_ALIGN_UP(job->len, job->cluster_size), in backup_loop() 158 job->perf.max_workers, job->perf.max_chunk, in backup_loop() 162 !job_is_cancelled(&job->common.job)) in backup_loop() 164 job_yield(&job->common.job); in backup_loop() 168 assert(job_is_cancelled(&job->common.job)); in backup_loop() 181 if (job_is_cancelled(&job->common.job) || in backup_loop() 211 job_pause_point(&job->common.job); in backup_loop() 247 job_progress_set_remaining(&job->common.job, estimate); in backup_init_bcs_bitmap() [all …]
|
H A D | mirror.c | 667 MirrorBlockJob *s = container_of(job, MirrorBlockJob, common.job); in mirror_exit_common() 929 MirrorBlockJob *s = container_of(job, MirrorBlockJob, common.job); in mirror_run() 1229 if (!s->common.job.paused && !job_is_cancelled_locked(&job->job) in mirror_drained_poll() 1398 job_progress_increase_remaining(&job->common.job, bytes); in do_sync_target_write() 1423 job_progress_update(&job->common.job, bytes); in do_sync_target_write() 1525 return s->job && s->job->ret >= 0 && in should_copy_to_target() 1526 !job_is_cancelled(&s->job->common.job) && in should_copy_to_target() 1560 if (!copy_to_target && s->job && s->job->dirty_bitmap) { in bdrv_mirror_top_do_write() 2050 BlockJob *job; in commit_active_start() local 2069 if (!job) { in commit_active_start() [all …]
|
/qemu/include/qemu/ |
H A D | job.h | 266 int (*prepare)(Job *job); 276 void (*commit)(Job *job); 286 void (*abort)(Job *job); 294 void (*clean)(Job *job); 314 void (*free)(Job *job); 458 void job_enter_cond_locked(Job *job, bool(*fn)(Job *job)); 468 void job_start(Job *job); 476 void job_enter(Job *job); 555 void job_pause(Job *job); 561 void job_resume(Job *job); [all …]
|
/qemu/qapi/ |
H A D | job.json | 11 # Type of a background job. 132 # @job-pause: 134 # Pause an active job. 152 # @job-resume: 166 # @job-cancel: 185 # @job-complete: 196 # @job-dismiss: 204 # use of JOB_READY event, job-cancel or job-complete will still need 214 # @job-finalize: 225 # @id: The identifier of any job in the transaction, or of a job that [all …]
|
/qemu/ui/ |
H A D | vnc-jobs.c | 87 job->vs = vs; in vnc_job_new() 91 return job; in vnc_job_new() 98 trace_vnc_job_add_rect(job->vs, job, x, y, w, h); in vnc_job_add_rect() 111 void vnc_job_push(VncJob *job) in vnc_job_push() argument 115 g_free(job); in vnc_job_push() 125 VncJob *job; in vnc_has_job_locked() local 240 VncJob *job; in vnc_worker_thread_loop() local 260 vnc_lock_output(job->vs); in vnc_worker_thread_loop() 261 if (job->vs->ioc == NULL || job->vs->abort == true) { in vnc_worker_thread_loop() 314 vnc_lock_output(job->vs); in vnc_worker_thread_loop() [all …]
|
/qemu/tests/qemu-iotests/ |
H A D | 212.out | 5 {"execute": "job-dismiss", "arguments": {"id": "job0"}} 12 {"execute": "job-dismiss", "arguments": {"id": "job0"}} 23 {"execute": "job-dismiss", "arguments": {"id": "job0"}} 28 {"execute": "job-dismiss", "arguments": {"id": "job0"}} 39 {"execute": "job-dismiss", "arguments": {"id": "job0"}} 44 {"execute": "job-dismiss", "arguments": {"id": "job0"}} 56 {"execute": "job-dismiss", "arguments": {"id": "job0"}} 63 {"execute": "job-dismiss", "arguments": {"id": "job0"}} 74 {"execute": "job-dismiss", "arguments": {"id": "job0"}} 86 {"execute": "job-dismiss", "arguments": {"id": "job0"}} [all …]
|
H A D | 213.out | 5 {"execute": "job-dismiss", "arguments": {"id": "job0"}} 12 {"execute": "job-dismiss", "arguments": {"id": "job0"}} 24 {"execute": "job-dismiss", "arguments": {"id": "job0"}} 29 {"execute": "job-dismiss", "arguments": {"id": "job0"}} 41 {"execute": "job-dismiss", "arguments": {"id": "job0"}} 46 {"execute": "job-dismiss", "arguments": {"id": "job0"}} 59 {"execute": "job-dismiss", "arguments": {"id": "job0"}} 66 {"execute": "job-dismiss", "arguments": {"id": "job0"}} 78 {"execute": "job-dismiss", "arguments": {"id": "job0"}} 91 {"execute": "job-dismiss", "arguments": {"id": "job0"}} [all …]
|
H A D | 257.out | 26 {"execute": "job-dismiss", "arguments": {"id": "bdc-file-job"}} 30 {"execute": "job-dismiss", "arguments": {"id": "bdc-fmt-job"}} 73 {"execute": "job-dismiss", "arguments": {"id": "bdc-file-job"}} 77 {"execute": "job-dismiss", "arguments": {"id": "bdc-fmt-job"}} 87 {"execute": "job-dismiss", "arguments": {"id": "bdc-file-job"}} 91 {"execute": "job-dismiss", "arguments": {"id": "bdc-fmt-job"}} 211 {"execute": "job-dismiss", "arguments": {"id": "bdc-file-job"}} 215 {"execute": "job-dismiss", "arguments": {"id": "bdc-fmt-job"}} 225 {"execute": "job-dismiss", "arguments": {"id": "bdc-file-job"}} 229 {"execute": "job-dismiss", "arguments": {"id": "bdc-fmt-job"}} [all …]
|
H A D | 295.out | 1 {"execute": "job-dismiss", "arguments": {"id": "job_add_key"}} 3 {"execute": "job-dismiss", "arguments": {"id": "job_add_key"}} 5 {"execute": "job-dismiss", "arguments": {"id": "job_erase_key"}} 7 .{"execute": "job-dismiss", "arguments": {"id": "job_add_key"}} 9 {"execute": "job-dismiss", "arguments": {"id": "job_erase_key"}} 12 {"execute": "job-dismiss", "arguments": {"id": "job_add_key"}} 14 {"execute": "job-dismiss", "arguments": {"id": "job_add_key"}} 16 .{"execute": "job-dismiss", "arguments": {"id": "job_add_key"}} 18 {"execute": "job-dismiss", "arguments": {"id": "job_add_key"}} 21 {"execute": "job-dismiss", "arguments": {"id": "job_add_key"}} [all …]
|
H A D | 206.out | 5 {"execute": "job-dismiss", "arguments": {"id": "job0"}} 12 {"execute": "job-dismiss", "arguments": {"id": "job0"}} 31 {"execute": "job-dismiss", "arguments": {"id": "job0"}} 36 {"execute": "job-dismiss", "arguments": {"id": "job0"}} 55 {"execute": "job-dismiss", "arguments": {"id": "job0"}} 60 {"execute": "job-dismiss", "arguments": {"id": "job0"}} 79 {"execute": "job-dismiss", "arguments": {"id": "job0"}} 84 {"execute": "job-dismiss", "arguments": {"id": "job0"}} 102 {"execute": "job-dismiss", "arguments": {"id": "job0"}} 160 {"execute": "job-dismiss", "arguments": {"id": "job0"}} [all …]
|
H A D | 237.out | 5 {"execute": "job-dismiss", "arguments": {"id": "job0"}} 12 {"execute": "job-dismiss", "arguments": {"id": "job0"}} 34 {"execute": "job-dismiss", "arguments": {"id": "job0"}} 39 {"execute": "job-dismiss", "arguments": {"id": "job0"}} 61 {"execute": "job-dismiss", "arguments": {"id": "job0"}} 66 {"execute": "job-dismiss", "arguments": {"id": "job0"}} 89 {"execute": "job-dismiss", "arguments": {"id": "job0"}} 98 {"execute": "job-dismiss", "arguments": {"id": "job0"}} 103 {"execute": "job-dismiss", "arguments": {"id": "job0"}} 108 {"execute": "job-dismiss", "arguments": {"id": "job0"}} [all …]
|
H A D | 266.out | 4 {"execute": "job-dismiss", "arguments": {"id": "job0"}} 14 {"execute": "job-dismiss", "arguments": {"id": "job0"}} 26 {"execute": "job-dismiss", "arguments": {"id": "job0"}} 36 {"execute": "job-dismiss", "arguments": {"id": "job0"}} 48 {"execute": "job-dismiss", "arguments": {"id": "job0"}} 58 {"execute": "job-dismiss", "arguments": {"id": "job0"}} 69 {"execute": "job-dismiss", "arguments": {"id": "job0"}} 80 {"execute": "job-dismiss", "arguments": {"id": "job0"}} 89 {"execute": "job-dismiss", "arguments": {"id": "job0"}} 99 {"execute": "job-dismiss", "arguments": {"id": "job0"}} [all …]
|
H A D | 211.out | 5 {"execute": "job-dismiss", "arguments": {"id": "job0"}} 12 {"execute": "job-dismiss", "arguments": {"id": "job0"}} 25 {"execute": "job-dismiss", "arguments": {"id": "job0"}} 30 {"execute": "job-dismiss", "arguments": {"id": "job0"}} 43 {"execute": "job-dismiss", "arguments": {"id": "job0"}} 48 {"execute": "job-dismiss", "arguments": {"id": "job0"}} 62 {"execute": "job-dismiss", "arguments": {"id": "job0"}} 69 {"execute": "job-dismiss", "arguments": {"id": "job0"}} 81 {"execute": "job-dismiss", "arguments": {"id": "job0"}} 94 {"execute": "job-dismiss", "arguments": {"id": "job0"}} [all …]
|
H A D | 207.out | 5 {"execute": "job-dismiss", "arguments": {"id": "job0"}} 23 {"execute": "job-dismiss", "arguments": {"id": "job0"}} 34 {"execute": "job-dismiss", "arguments": {"id": "job0"}} 46 {"execute": "job-dismiss", "arguments": {"id": "job0"}} 51 {"execute": "job-dismiss", "arguments": {"id": "job0"}} 63 {"execute": "job-dismiss", "arguments": {"id": "job0"}} 68 {"execute": "job-dismiss", "arguments": {"id": "job0"}} 80 {"execute": "job-dismiss", "arguments": {"id": "job0"}} 85 {"execute": "job-dismiss", "arguments": {"id": "job0"}} 97 {"execute": "job-dismiss", "arguments": {"id": "job0"}} [all …]
|
H A D | 256.out | 8 {"execute": "job-dismiss", "arguments": {"id": "job1"}} 12 {"execute": "job-dismiss", "arguments": {"id": "job2"}} 16 {"execute": "job-dismiss", "arguments": {"id": "job1"}} 20 {"execute": "job-dismiss", "arguments": {"id": "job2"}} 44 "job-id": "j0", 53 "job-id": "j1", 71 {"execute": "job-dismiss", "arguments": {"id": "job1"}} 75 {"execute": "job-dismiss", "arguments": {"id": "job2"}} 79 {"execute": "job-dismiss", "arguments": {"id": "job1"}} 94 "job-id": "j2", [all …]
|
/qemu/include/block/ |
H A D | blockjob.h | 47 Job job; member 114 BlockJob *block_job_next_locked(BlockJob *job); 142 block_job_add_bdrv(BlockJob *job, const char *name, BlockDriverState *bs, 152 void block_job_remove_all_bdrv(BlockJob *job); 161 bool block_job_has_bdrv(BlockJob *job, BlockDriverState *bs); 184 void block_job_change_locked(BlockJob *job, BlockJobChangeOptions *opts, 195 BlockJobInfo *block_job_query_locked(BlockJob *job, Error **errp); 206 void block_job_iostatus_reset_locked(BlockJob *job); 213 AioContext *block_job_get_aio_context(BlockJob *job); 229 bool block_job_is_internal(BlockJob *job); [all …]
|
H A D | blockjob_int.h | 53 bool (*drained_poll)(BlockJob *job); 67 void (*attached_aio_context)(BlockJob *job, AioContext *new_context); 69 void (*set_speed)(BlockJob *job, int64_t speed); 76 void (*change)(BlockJob *job, BlockJobChangeOptions *opts, Error **errp); 81 void (*query)(BlockJob *job, BlockJobInfo *info); 125 void block_job_free(Job *job); 132 void block_job_user_resume(Job *job); 147 void block_job_ratelimit_processed_bytes(BlockJob *job, uint64_t n); 153 void block_job_ratelimit_sleep(BlockJob *job); 165 BlockErrorAction block_job_error_action(BlockJob *job, BlockdevOnError on_err,
|
/qemu/.gitlab-ci.d/ |
H A D | crossbuilds.yml | 7 job: armel-debian-cross-container 14 job: armhf-debian-cross-container 21 job: arm64-debian-cross-container 28 job: arm64-debian-cross-container 35 job: arm64-debian-cross-container 45 job: i686-debian-cross-container 56 job: i686-debian-cross-container 66 job: mipsel-debian-cross-container 73 job: mipsel-debian-cross-container 135 job: s390x-debian-cross-container [all …]
|