/openbmc/qemu/ |
H A D | job.c | 616 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 D | blockjob.c | 53 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 D | job-qmp.c | 37 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 …]
|
/openbmc/qemu/tests/unit/ |
H A D | test-blockjob.c | 129 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 D | test-blockjob-txn.c | 30 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 …]
|
/openbmc/linux/drivers/gpu/drm/nouveau/ |
H A D | nouveau_sched.c | 47 if (job->sync) in nouveau_job_init() 60 if (job->sync) { in nouveau_job_init() 74 job->out_sync.objs = kcalloc(job->out_sync.count, in nouveau_job_init() 82 job->out_sync.chains = kcalloc(job->out_sync.count, in nouveau_job_init() 124 job->ops->free(job); in nouveau_job_fini() 285 ret = job->ops->submit(job); in nouveau_job_submit() 291 job->done_fence = dma_fence_get(&job->base.s_fence->finished); in nouveau_job_submit() 292 if (job->sync) in nouveau_job_submit() 318 job->ops->armed_submit(job); in nouveau_job_submit() 358 fence = job->ops->run(job); in nouveau_job_run() [all …]
|
H A D | nouveau_exec.c | 148 dma_resv_add_fence(obj->resv, job->done_fence, job->resv_usage); in nouveau_exec_job_armed_submit() 195 nouveau_job_free(job); in nouveau_exec_job_free() 231 struct nouveau_exec_job *job; in nouveau_exec_job_init() local 246 job = *pjob = kzalloc(sizeof(*job), GFP_KERNEL); in nouveau_exec_job_init() 247 if (!job) in nouveau_exec_job_init() 256 if (!job->push.s) { in nouveau_exec_job_init() 262 job->chan = __args->chan; in nouveau_exec_job_init() 283 kfree(job->push.s); in nouveau_exec_job_init() 285 kfree(job); in nouveau_exec_job_init() 294 struct nouveau_exec_job *job; in nouveau_exec() local [all …]
|
/openbmc/linux/drivers/gpu/drm/amd/amdgpu/ |
H A D | amdgpu_job.c | 101 if (!*job) in amdgpu_job_alloc() 137 kfree(*job); in amdgpu_job_alloc_with_ib() 167 if (job->base.s_fence && job->base.s_fence->finished.ops) in amdgpu_job_free_resources() 188 kfree(job); in amdgpu_job_free_cb() 216 if (job->gang_submit != &job->base.s_fence->scheduled) in amdgpu_job_free() 220 kfree(job); in amdgpu_job_free() 243 r = amdgpu_ib_schedule(ring, job->num_ibs, job->ibs, job, fence); in amdgpu_job_submit_direct() 268 while (!fence && job->vm && !job->vmid) { in amdgpu_job_prepare_job() 269 r = amdgpu_vmid_grab(job->vm, ring, job, &fence); in amdgpu_job_prepare_job() 298 (job->job_run_counter && job->gang_submit)) in amdgpu_job_run() [all …]
|
/openbmc/qemu/include/qemu/ |
H A D | job.h | 266 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 …]
|
/openbmc/qemu/block/ |
H A D | backup.c | 87 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 …]
|
/openbmc/linux/drivers/gpu/host1x/ |
H A D | job.c | 52 if (!job) in host1x_job_alloc() 70 job->reloc_addr_phys = job->addr_phys; in host1x_job_alloc() 71 job->gather_addr_phys = &job->addr_phys[num_relocs]; in host1x_job_alloc() 73 return job; in host1x_job_alloc() 80 return job; in host1x_job_get() 89 job->release(job); in job_free() 200 job->addr_phys[job->num_unpins] = map->phys; in pin_job() 201 job->unpins[job->num_unpins].map = map; in pin_job() 263 job->addr_phys[job->num_unpins] = map->phys; in pin_job() 264 job->unpins[job->num_unpins].map = map; in pin_job() [all …]
|
H A D | cdma.c | 326 if (job->timeout) in update_cdma_locked() 340 if (job->num_slots) { in update_cdma_locked() 349 list_del(&job->list); in update_cdma_locked() 350 host1x_job_put(job); in update_cdma_locked() 398 job = NULL; in host1x_cdma_update_sync_queue() 413 if (!job) in host1x_cdma_update_sync_queue() 422 job->timeout = 0; in host1x_cdma_update_sync_queue() 432 job->num_slots); in host1x_cdma_update_sync_queue() 470 unsigned int next_job = (job->first_get/8 + job->num_slots) in host1x_cdma_update_sync_queue() 564 if (job->timeout) { in host1x_cdma_begin() [all …]
|
/openbmc/linux/drivers/md/ |
H A D | dm-kcopyd.c | 434 job->master_job->write_offset += job->source.count; in pop_io_job() 460 return job; in pop() 500 if (job->pages && job->pages != &zero_page_list) in run_complete_job() 506 if (job->master_job == job) { in run_complete_job() 574 job->write_err = job->master_job->write_err; in run_io_job() 596 push(&job->kc->io_jobs, job); in run_pages_job() 715 if ((!job->read_err && !job->write_err) || in segment_complete() 829 memset(&job->source, 0, sizeof(job->source)); in dm_kcopyd_copy() 830 job->source.count = job->dests[0].count; in dm_kcopyd_copy() 846 job->master_job = job; in dm_kcopyd_copy() [all …]
|
/openbmc/linux/drivers/gpu/host1x/hw/ |
H A D | channel_hw.c | 233 submit_wait(job, job->syncpt->id, fence, job->class); in channel_program_cdma() 236 job->syncpt_end = host1x_syncpt_incr_max(sp, job->syncpt_incrs); in channel_program_cdma() 237 submit_gathers(job, job->syncpt_end - job->syncpt_incrs); in channel_program_cdma() 245 submit_wait(job, job->syncpt->id, fence, job->class); in channel_program_cdma() 268 if (job->class) in channel_program_cdma() 273 job->syncpt_end = host1x_syncpt_incr_max(sp, job->syncpt_incrs); in channel_program_cdma() 275 submit_gathers(job, job->syncpt_end - job->syncpt_incrs); in channel_program_cdma() 297 job->num_cmds, job->num_relocs, in channel_submit() 298 job->syncpt->id, job->syncpt_incrs); in channel_submit() 328 job->fence = NULL; in channel_submit() [all …]
|
/openbmc/linux/drivers/gpu/drm/v3d/ |
H A D | v3d_sched.c | 62 v3d_job_cleanup(job); in v3d_sched_job_free() 71 if (job->perfmon && v3d->active_perfmon != job->perfmon) in v3d_switch_perfmon() 90 v3d->bin_job = job; in v3d_bin_job_run() 108 job->start, job->end); in v3d_bin_job_run() 115 if (job->qma) { in v3d_bin_job_run() 119 if (job->qts) { in v3d_bin_job_run() 122 job->qts); in v3d_bin_job_run() 159 job->start, job->end); in v3d_render_job_run() 186 v3d->tfu_job = job; in v3d_tfu_job_run() 314 &job->timedout_ctca, &job->timedout_ctra); in v3d_bin_job_timedout() [all …]
|
H A D | v3d_gem.c | 275 drm_gem_unlock_reservations(job->bo, job->bo_count, acquire_ctx); in v3d_lock_bo_reservations() 314 job->bo_count, &job->bo); in v3d_lookup_bos() 323 if (job->bo) { in v3d_job_free() 335 kfree(job); in v3d_job_free() 354 if (!job) in v3d_job_cleanup() 363 kref_put(&job->refcount, job->free); in v3d_job_put() 416 job->v3d = v3d; in v3d_job_init() 469 job->done_fence = dma_fence_get(&job->base.s_fence->finished); in v3d_push_job() 491 dma_resv_add_fence(job->bo[i]->resv, job->done_fence, in v3d_attach_fences_and_unlock_reservation() 840 ret = v3d_job_init(v3d, file_priv, (void *)&job, sizeof(*job), in v3d_submit_tfu_ioctl() [all …]
|
/openbmc/linux/block/ |
H A D | bsg-lib.c | 31 struct bsg_job *job; in bsg_transport_sg_io_fn() local 50 reply = job->reply; in bsg_transport_sg_io_fn() 51 memset(job, 0, sizeof(*job)); in bsg_transport_sg_io_fn() 52 job->reply = reply; in bsg_transport_sg_io_fn() 54 job->dd_data = job + 1; in bsg_transport_sg_io_fn() 76 job->bidi_bio = job->bidi_rq->bio; in bsg_transport_sg_io_fn() 140 if (job->bidi_rq) in bsg_transport_sg_io_fn() 143 if (job->bidi_rq) in bsg_transport_sg_io_fn() 245 ret = bsg_map_buffer(&job->reply_payload, job->bidi_rq); in bsg_prepare_job() 249 job->dev = dev; in bsg_prepare_job() [all …]
|
/openbmc/qemu/qapi/ |
H A D | job.json | 11 # 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 # make use of JOB_READY event, job-cancel or job-complete will still 214 # @job-finalize: 225 # @id: The identifier of any job in the transaction, or of a job that [all …]
|
/openbmc/linux/drivers/accel/ivpu/ |
H A D | ivpu_job.c | 254 *link = job; in job_get() 273 kfree(job); in job_release() 299 if (!job) in ivpu_create_job() 317 return job; in ivpu_create_job() 320 kfree(job); in ivpu_create_job() 331 if (!job) in ivpu_job_done() 341 job->job_id, job->file_priv->ctx.id, job->engine_idx, job_status); in ivpu_job_done() 343 job_put(job); in ivpu_job_done() 390 job_get(job, &job); in ivpu_direct_job_submission() 402 job->job_id, job->cmd_buf_vpu_addr, file_priv->ctx.id, in ivpu_direct_job_submission() [all …]
|
/openbmc/qemu/ui/ |
H A D | vnc-jobs.c | 87 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 …]
|
/openbmc/linux/drivers/gpu/drm/panfrost/ |
H A D | panfrost_job.c | 161 WARN_ON(!job); in panfrost_dequeue_job() 165 return job; in panfrost_dequeue_job() 281 ret = drm_gem_lock_reservations(job->bos, job->bo_count, in panfrost_job_push() 291 ret = panfrost_acquire_object_fences(job->bos, job->bo_count, in panfrost_job_push() 304 panfrost_attach_object_fences(job->bos, job->bo_count, in panfrost_job_push() 340 kfree(job); in panfrost_job_cleanup() 370 if (!job->jc) in panfrost_job_run() 429 job->jc = 0; in panfrost_job_handle_err() 436 job->jc = 0; in panfrost_job_handle_err() 459 job->jc = 0; in panfrost_job_handle_done() [all …]
|
/openbmc/qemu/migration/ |
H A D | multifd-qpl.c | 26 qpl_job *job; member 64 qpl_job *job; in check_hw_avail() local 72 g_free(job); in check_hw_avail() 75 g_free(job); in check_hw_avail() 142 g_free(job); in multifd_qpl_init_sw_job() 145 qpl->sw_job = job; in multifd_qpl_init_sw_job() 170 qpl->hw_jobs[i].job = job; in multifd_qpl_init_hw_job() 291 job->level = 1; in multifd_qpl_prepare_job() 645 qpl_job *job; in multifd_qpl_decompress_pages() local 657 job = qpl->hw_jobs[i].job; in multifd_qpl_decompress_pages() [all …]
|
/openbmc/qemu/tests/qemu-iotests/ |
H A D | 212.out | 5 {"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 D | 213.out | 5 {"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 D | 295.out | 1 {"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 …]
|