Home
last modified time | relevance | path

Searched refs:job_id (Results 1 – 25 of 48) sorted by relevance

12

/qemu/tests/qemu-iotests/
H A D03079 self.vm.cmd('block-stream', device='mid', job_id='stream-mid')
180 result = self.vm.qmp('block-stream', job_id='stream',
247 job_id = 'stream-%s' % node_name
248 pending_jobs.append(job_id)
250 job_id=job_id, bottom=f'node{i-1}',
269 job_id = self.dictpath(event, 'data/device')
270 self.assertTrue(job_id in pending_jobs)
272 pending_jobs.remove(job_id)
291 job_id='stream-node4', base=self.imgs[1],
294 … result = self.vm.qmp('block-stream', device='node5', job_id='stream-node5', base=self.imgs[2])
[all …]
H A D14191 job_id='job0', \
103 job_id='job0', \
119 job_id='job0', \
132 job_id='job0', \
144 job_id='job0', \
H A D257163 log(vm.cmd('blockdev-create', job_id='bdc-file-job',
173 log(vm.cmd('blockdev-create', job_id='bdc-fmt-job',
207 job_id = "ref_backup_{:d}".format(n)
209 job_id=job_id)
210 drive.vm.run_job(job_id, auto_dismiss=True)
216 job_id = "backup_{:d}".format(n)
219 job_id=job_id, **kwargs)
220 return job_id
513 sync_mode, job_id='api_job',
H A D041233 result = self.vm.qmp(self.qmp_cmd, job_id='job0',
247 self.vm.cmd(self.qmp_cmd, job_id='job0', device='drive0',
265 self.vm.cmd(self.qmp_cmd, job_id='job0',
797 self.vm.cmd('drive-mirror', job_id='drive0', device='drive0',
805 self.vm.cmd('drive-mirror', job_id='drive0', device='drive0',
813 self.vm.cmd('drive-mirror', job_id='drive0', device='drive0',
825 self.vm.cmd('drive-mirror', job_id='drive0', device='drive0',
848 self.vm.cmd('blockdev-mirror', job_id='drive0', device='drive0',
938 self.vm.cmd('drive-mirror', job_id='job0', device='quorum0',
950 self.vm.cmd('drive-mirror', job_id='job0', device='quorum0',
[all …]
H A D21856 job_id='mirror',
64 job_id='mirror',
172 job_id='mirror',
H A D15183 job_id='mirror',
128 job_id='mirror',
152 job_id='mirror',
307 job_id='mirror',
402 job_id='mirror',
H A D28397 job_id="backup0")
120 job_id='backup',
H A D224102 job_id='commit',
111 job_id='commit',
H A D25643 log(vm.cmd('blockdev-create', job_id='job1',
52 log(vm.cmd('blockdev-create', job_id='job2',
H A D258120 job_id='commit',
128 job_id='stream',
H A D25572 result = vm.qmp_log('block-commit', job_id='job0', auto_finalize=False,
118 vm.qmp_log('blockdev-mirror', job_id='job0', device='src-throttled',
H A D21929 def pause_wait(vm, job_id): argument
34 if job['id'] == job_id and job['status'] in ['paused', 'standby']:
76 iotests.log(vm.qmp(job, job_id='job0', **job_args))
H A D155180 self.vm.cmd(self.cmd, job_id='mirror-job', device='source',
188 self.vm.cmd(self.cmd, job_id='mirror-job', device='source',
291 self.vm.cmd('block-commit', job_id='commit-job',
H A D274112 job_id='job0', auto_dismiss=False)
133 job_id='job0', auto_dismiss=False)
H A D12448 return transaction_action('drive-backup', job_id=device, device=device,
183 res = self.do_qmp_backup(job_id=drive['id'],
195 res = self.do_qmp_backup(job_id=bitmap.drive['id'],
231 res = self.do_qmp_backup(job_id=bitmap.drive['id'],
707 job_id=bitmap.drive['id'],
H A D040579 self.vm.cmd('block-commit', job_id='job0', device='top-fmt',
815 job_id='commit',
831 job_id='commit',
860 job_id='commit',
882 job_id='commit',
937 job_id='commit',
946 job_id='commit',
/qemu/include/block/
H A Dblock_int-global-state.h67 void stream_start(const char *job_id, BlockDriverState *bs,
96 void commit_start(const char *job_id, BlockDriverState *bs,
121 BlockJob *commit_active_start(const char *job_id, BlockDriverState *bs,
157 void mirror_start(const char *job_id, BlockDriverState *bs,
191 BlockJob *backup_job_create(const char *job_id, BlockDriverState *bs,
/qemu/tests/qemu-iotests/tests/
H A Dinactive-node-nbd204 vm.qmp_log('block-commit', job_id='job0', device='snap-fmt',
215 vm.qmp_log('block-commit', job_id='job0', device='snap2-fmt',
221 vm.qmp_log('block-commit', job_id='job0', device='snap2-fmt',
226 vm.qmp_log('blockdev-mirror', job_id='job0', device='snap2-fmt',
246 vm.qmp_log('blockdev-mirror', job_id='job0', device='snap2-fmt',
252 vm.qmp_log('blockdev-backup', job_id='job0', device='snap2-fmt',
267 vm.qmp_log('blockdev-backup', job_id='job0', device='snap2-fmt',
H A Diothreads-stream61 iotests.log(vm.qmp('block-stream', device='disk0', job_id='job0'))
62 iotests.log(vm.qmp('block-stream', device='disk1', job_id='job1'))
H A Diothreads-commit-active70 iotests.log(vm.qmp('blockdev-mirror', job_id='job0', sync='full',
75 iotests.log(vm.qmp('block-commit', device='disk0', job_id='job1',
/qemu/tests/unit/
H A Dtest-blockjob-txn.c86 char job_id[24]; in test_block_job_start() local
95 snprintf(job_id, sizeof(job_id), "job%u", counter++); in test_block_job_start()
96 s = block_job_create(job_id, &test_block_job_driver, txn, bs, in test_block_job_start()
/qemu/block/
H A Dcreate.c68 void qmp_blockdev_create(const char *job_id, BlockdevCreateOptions *options, in qmp_blockdev_create() argument
96 s = job_create(job_id, &blockdev_create_job_driver, NULL, in qmp_blockdev_create()
H A Damend.c88 void qmp_x_blockdev_amend(const char *job_id, in qmp_x_blockdev_amend() argument
134 s = job_create(job_id, &blockdev_amend_job_driver, NULL, in qmp_x_blockdev_amend()
/qemu/
H A Djob.c391 void *job_create(const char *job_id, const JobDriver *driver, JobTxn *txn, in job_create() argument
399 if (job_id) { in job_create()
404 if (!id_wellformed(job_id)) { in job_create()
405 error_setg(errp, "Invalid job ID '%s'", job_id); in job_create()
408 if (job_get_locked(job_id)) { in job_create()
409 error_setg(errp, "Job ID '%s' already in use", job_id); in job_create()
419 job->id = g_strdup(job_id); in job_create()
H A Dblockjob.c490 void *block_job_create(const char *job_id, const BlockJobDriver *driver, in block_job_create() argument
501 if (job_id == NULL && !(flags & JOB_INTERNAL)) { in block_job_create()
502 job_id = bdrv_get_device_name(bs); in block_job_create()
505 job = job_create(job_id, &driver->job_driver, txn, bdrv_get_aio_context(bs), in block_job_create()

12