Lines Matching refs:job
268 static void ext_queue_schedule_job(struct hl_cs_job *job) in ext_queue_schedule_job() argument
270 struct hl_device *hdev = job->cs->ctx->hdev; in ext_queue_schedule_job()
271 struct hl_hw_queue *q = &hdev->kernel_queues[job->hw_queue_id]; in ext_queue_schedule_job()
286 cb = job->patched_cb; in ext_queue_schedule_job()
287 len = job->job_cb_size; in ext_queue_schedule_job()
291 if (!cs_needs_completion(job->cs)) in ext_queue_schedule_job()
311 job->user_cb_size, in ext_queue_schedule_job()
315 job->contains_dma_pkt); in ext_queue_schedule_job()
317 q->shadow_queue[hl_pi_2_offset(q->pi)] = job; in ext_queue_schedule_job()
333 static void int_queue_schedule_job(struct hl_cs_job *job) in int_queue_schedule_job() argument
335 struct hl_device *hdev = job->cs->ctx->hdev; in int_queue_schedule_job()
336 struct hl_hw_queue *q = &hdev->kernel_queues[job->hw_queue_id]; in int_queue_schedule_job()
341 bd.len = cpu_to_le32(job->job_cb_size); in int_queue_schedule_job()
343 if (job->is_kernel_allocated_cb) in int_queue_schedule_job()
347 bd.ptr = cpu_to_le64(job->user_cb->bus_address); in int_queue_schedule_job()
349 bd.ptr = cpu_to_le64((u64) (uintptr_t) job->user_cb); in int_queue_schedule_job()
369 static void hw_queue_schedule_job(struct hl_cs_job *job) in hw_queue_schedule_job() argument
371 struct hl_device *hdev = job->cs->ctx->hdev; in hw_queue_schedule_job()
372 struct hl_hw_queue *q = &hdev->kernel_queues[job->hw_queue_id]; in hw_queue_schedule_job()
382 offset = job->cs->sequence & (hdev->asic_prop.max_pending_cs - 1); in hw_queue_schedule_job()
386 len = job->job_cb_size; in hw_queue_schedule_job()
394 if (job->patched_cb) in hw_queue_schedule_job()
395 ptr = job->patched_cb->bus_address; in hw_queue_schedule_job()
396 else if (job->is_kernel_allocated_cb) in hw_queue_schedule_job()
397 ptr = job->user_cb->bus_address; in hw_queue_schedule_job()
399 ptr = (u64) (uintptr_t) job->user_cb; in hw_queue_schedule_job()
405 struct hl_cs_job *job, struct hl_cs_compl *cs_cmpl) in init_signal_cs() argument
412 q_idx = job->hw_queue_id; in init_signal_cs()
427 hdev->asic_funcs->gen_signal_cb(hdev, job->patched_cb, in init_signal_cs()
433 job->cs->sob_addr_offset = hw_sob->sob_addr; in init_signal_cs()
434 job->cs->initial_sob_count = prop->next_sob_val - 1; in init_signal_cs()
440 struct hl_cs *cs, struct hl_cs_job *job, in hl_hw_queue_encaps_sig_set_sob_info() argument
457 if (job->encaps_sig_wait_offset) in hl_hw_queue_encaps_sig_set_sob_info()
458 offset = job->encaps_sig_wait_offset - 1; in hl_hw_queue_encaps_sig_set_sob_info()
464 struct hl_cs_job *job, struct hl_cs_compl *cs_cmpl) in init_wait_cs() argument
471 q_idx = job->hw_queue_id; in init_wait_cs()
483 hl_hw_queue_encaps_sig_set_sob_info(hdev, cs, job, cs_cmpl); in init_wait_cs()
489 job->encaps_sig_wait_offset); in init_wait_cs()
524 wait_prop.data = (void *) job->patched_cb; in init_wait_cs()
551 struct hl_cs_job *job; in init_signal_wait_cs() local
557 job = list_first_entry(&cs->job_list, struct hl_cs_job, in init_signal_wait_cs()
561 rc = init_signal_cs(hdev, job, cs_cmpl); in init_signal_wait_cs()
563 rc = init_wait_cs(hdev, cs, job, cs_cmpl); in init_signal_wait_cs()
631 struct hl_cs_job *job, *tmp; in hl_hw_queue_schedule_cs() local
761 list_for_each_entry_safe(job, tmp, &cs->job_list, cs_node) in hl_hw_queue_schedule_cs()
762 switch (job->queue_type) { in hl_hw_queue_schedule_cs()
764 ext_queue_schedule_job(job); in hl_hw_queue_schedule_cs()
767 int_queue_schedule_job(job); in hl_hw_queue_schedule_cs()
770 hw_queue_schedule_job(job); in hl_hw_queue_schedule_cs()