/openbmc/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], 294 … result = self.vm.qmp('block-stream', device='node5', job_id='stream-node5', base=self.imgs[2]) [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', 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 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'],
|
/openbmc/linux/drivers/accel/ivpu/ |
H A D | ivpu_job.c | 197 entry->job_id = job->job_id; in ivpu_cmdq_push_job() 256 ivpu_dbg(vdev, KREF, "Job get: id %u refcount %u\n", job->job_id, kref_read(&job->ref)); in job_get() 272 ivpu_dbg(vdev, KREF, "Job released: id %u\n", job->job_id); in job_release() 283 ivpu_dbg(vdev, KREF, "Job put: id %u refcount %u\n", job->job_id, kref_read(&job->ref)); in job_put() 326 static int ivpu_job_done(struct ivpu_device *vdev, u32 job_id, u32 job_status) in ivpu_job_done() argument 330 job = xa_erase(&vdev->submitted_jobs_xa, job_id); in ivpu_job_done() 341 job->job_id, job->file_priv->ctx.id, job->engine_idx, job_status); in ivpu_job_done() 355 ret = ivpu_job_done(vdev, payload->job_id, payload->job_status); in ivpu_job_done_message() 357 ivpu_err(vdev, "Failed to finish job %d: %d\n", payload->job_id, ret); in ivpu_job_done_message() 391 ret = xa_alloc(&vdev->submitted_jobs_xa, &job->job_id, job, job_id_range, GFP_KERNEL); in ivpu_direct_job_submission() [all …]
|
/openbmc/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,
|
/openbmc/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()
|
/openbmc/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()
|
/openbmc/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',
|
/openbmc/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()
|
/openbmc/phosphor-ipmi-flash/bmc/ |
H A D | general_systemd.cpp | 120 uint32_t job_id; in match() local 126 m.read(job_id, job_path, unit, result); in match()
|