Home
last modified time | relevance | path

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

123

/openbmc/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 D28397 job_id="backup0")
120 job_id='backup',
H A D15183 job_id='mirror',
128 job_id='mirror',
152 job_id='mirror',
307 job_id='mirror',
402 job_id='mirror',
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 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 D258120 job_id='commit',
128 job_id='stream',
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'],
/openbmc/linux/drivers/accel/ivpu/
H A Divpu_job.c197 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 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,
/openbmc/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()
/openbmc/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()
/openbmc/qemu/tests/qemu-iotests/tests/
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',
/openbmc/qemu/
H A Djob.c385 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 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()
/openbmc/phosphor-ipmi-flash/bmc/
H A Dgeneral_systemd.cpp120 uint32_t job_id; in match() local
126 m.read(job_id, job_path, unit, result); in match()

123