Home
last modified time | relevance | path

Searched refs:job (Results 1 – 25 of 119) sorted by relevance

12345

/qemu/
H A Djob.c616 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 Dblockjob.c53 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 Djob-qmp.c37 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 Dtrace-events45 # 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 Dtest-blockjob.c129 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 Dtest-blockjob-txn.c30 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 Dtest-bdrv-drain.c788 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 Dbackup.c87 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 Dmirror.c667 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 Djob.h266 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 Djob.json11 # 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 Dvnc-jobs.c87 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 D212.out5 {"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 D213.out5 {"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 D257.out26 {"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 D295.out1 {"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 D206.out5 {"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 D237.out5 {"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 D266.out4 {"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 D211.out5 {"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 D207.out5 {"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 D256.out8 {"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 Dblockjob.h47 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 Dblockjob_int.h53 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 Dcrossbuilds.yml7 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 …]

12345