| /qemu/tests/qemu-iotests/ |
| H A D | 030 | 79 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],
418 base_node='commit-filter', job_id='node4')
[all …]
|
| H A D | 141 | 91 job_id='job0', \
103 job_id='job0', \
119 job_id='job0', \
132 job_id='job0', \
144 job_id='job0', \
|
| H A D | 257 | 163 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 D | 041 | 233 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',
938 self.vm.cmd('drive-mirror', job_id='job0', device='quorum0',
950 self.vm.cmd('drive-mirror', job_id='job0', device='quorum0',
1012 result = self.vm.qmp('drive-mirror', job_id='job0',
1148 self.vm.cmd('blockdev-mirror', job_id='job', device='src',
1171 self.vm.cmd('blockdev-mirror', job_id='job', device='src',
1302 job_id='mirror',
1332 job_id='mirror',
[all …]
|
| H A D | 218 | 56 job_id='mirror',
64 job_id='mirror',
172 job_id='mirror',
|
| H A D | 283 | 97 job_id="backup0")
120 job_id='backup',
|
| H A D | 151 | 83 job_id='mirror',
128 job_id='mirror',
152 job_id='mirror',
307 job_id='mirror',
402 job_id='mirror',
|
| H A D | 224 | 102 job_id='commit',
111 job_id='commit',
|
| H A D | 256 | 43 log(vm.cmd('blockdev-create', job_id='job1',
52 log(vm.cmd('blockdev-create', job_id='job2',
|
| H A D | 255 | 72 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 D | 258 | 120 job_id='commit',
128 job_id='stream',
|
| H A D | 219 | 29 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 D | 155 | 180 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 D | 274 | 112 job_id='job0', auto_dismiss=False)
133 job_id='job0', auto_dismiss=False)
|
| H A D | 124 | 48 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'],
|
| /qemu/include/block/ |
| H A D | block_int-global-state.h | 67 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/unit/ |
| H A D | test-blockjob-txn.c | 86 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 D | create.c | 68 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 D | amend.c | 88 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/tests/qemu-iotests/tests/ |
| H A D | iothreads-stream | 61 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 D | iothreads-commit-active | 70 iotests.log(vm.qmp('blockdev-mirror', job_id='job0', sync='full',
75 iotests.log(vm.qmp('block-commit', device='disk0', job_id='job1',
|
| H A D | iothreads-create | 52 job_id='job0',
|
| H A D | image-fleecing | 147 job_id='fleecing',
169 job_id='push-backup', speed=1))
|
| /qemu/ |
| H A D | job.c | 385 void *job_create(const char *job_id, const JobDriver *driver, JobTxn *txn, in job_create() argument
393 if (job_id) { in job_create()
398 if (!id_wellformed(job_id)) { in job_create()
399 error_setg(errp, "Invalid job ID '%s'", job_id); in job_create()
402 if (job_get_locked(job_id)) { in job_create()
403 error_setg(errp, "Job ID '%s' already in use", job_id); in job_create()
413 job->id = g_strdup(job_id); in job_create()
|
| H A D | blockjob.c | 490 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()
|