Lines Matching defs:job
478 struct hl_cs_job *job);
967 struct hl_cs_job *job;
998 job = hl_cs_allocate_job(hdev, QUEUE_TYPE_EXT, true);
999 if (!job) {
1000 dev_err(hdev->dev, "Failed to allocate a new job\n");
1005 job->id = 0;
1006 job->user_cb = cb;
1007 atomic_inc(&job->user_cb->cs_cnt);
1008 job->user_cb_size = cb_size;
1009 job->hw_queue_id = GAUDI_QUEUE_ID_DMA_0_0;
1010 job->patched_cb = job->user_cb;
1011 job->job_cb_size = job->user_cb_size + sizeof(struct packet_msg_prot);
1013 hl_debugfs_add_job(hdev, job);
1015 rc = gaudi_send_job_on_qman0(hdev, job);
1027 hl_userptr_delete_list(hdev, &job->userptr_list);
1028 hl_debugfs_remove_job(hdev, job);
1029 kfree(job);
1207 struct hl_cs_job *job, u32 stream, u32 sob_group_offset)
1217 queue_id = job->hw_queue_id;
1232 wait_prop.data = (void *) job->patched_cb;
1258 struct hl_cs_job *job, struct hl_cs_compl *cs_cmpl)
1264 queue_id = job->hw_queue_id;
1267 if (job->cs->encaps_signals) {
1272 hl_hw_queue_encaps_sig_set_sob_info(hdev, job->cs, job,
1276 job->cs->sequence,
1282 wait_prop.data = (void *) job->user_cb;
1301 cb_size += gaudi_gen_signal_cb(hdev, job->user_cb,
1316 struct hl_cs_job *job;
1330 * job wait offset value.
1362 /* Calculate the stream from collective master queue (1st job) */
1363 job = list_first_entry(&cs->job_list, struct hl_cs_job, cs_node);
1364 stream = job->hw_queue_id % 4;
1368 list_for_each_entry(job, &cs->job_list, cs_node) {
1369 queue_id = job->hw_queue_id;
1373 gaudi_collective_master_init_job(hdev, job, stream,
1376 gaudi_collective_slave_init_job(hdev, job, cs_cmpl);
1432 struct hl_cs_job *job;
1463 job = hl_cs_allocate_job(hdev, hw_queue_prop->type, true);
1464 if (!job) {
1467 dev_err(hdev->dev, "Failed to allocate a new job\n");
1476 kfree(job);
1480 job->id = 0;
1481 job->cs = cs;
1482 job->user_cb = cb;
1483 atomic_inc(&job->user_cb->cs_cnt);
1484 job->user_cb_size = cb_size;
1485 job->hw_queue_id = queue_id;
1492 job->encaps_sig_wait_offset = encaps_signal_offset;
1501 job->patched_cb = job->user_cb;
1503 job->patched_cb = NULL;
1505 job->job_cb_size = job->user_cb_size;
1512 cs->jobs_in_queue_cnt[job->hw_queue_id]++;
1514 list_add_tail(&job->cs_node, &cs->job_list);
1516 hl_debugfs_add_job(hdev, job);
1561 /* First job goes to the collective master queue, it will wait for
5411 * to it by calling cb_get earlier. After the job will be completed,
5456 * to it by calling cb_get earlier. After the job will be completed,
5572 struct hl_cs_job *job;
5596 job = hl_cs_allocate_job(hdev, QUEUE_TYPE_EXT, true);
5597 if (!job) {
5598 dev_err(hdev->dev, "Failed to allocate a new job\n");
5612 job->id = 0;
5613 job->user_cb = cb;
5614 atomic_inc(&job->user_cb->cs_cnt);
5615 job->user_cb_size = cb_size;
5616 job->hw_queue_id = GAUDI_QUEUE_ID_DMA_0_0;
5617 job->patched_cb = job->user_cb;
5618 job->job_cb_size = job->user_cb_size + sizeof(struct packet_msg_prot);
5620 hl_debugfs_add_job(hdev, job);
5622 rc = gaudi_send_job_on_qman0(hdev, job);
5623 hl_debugfs_remove_job(hdev, job);
5624 kfree(job);
5651 struct hl_cs_job *job;
5681 job = hl_cs_allocate_job(hdev, QUEUE_TYPE_EXT, true);
5682 if (!job) {
5683 dev_err(hdev->dev, "Failed to allocate a new job\n");
5688 job->id = 0;
5689 job->user_cb = cb;
5690 atomic_inc(&job->user_cb->cs_cnt);
5691 job->user_cb_size = cb_size;
5692 job->hw_queue_id = GAUDI_QUEUE_ID_DMA_0_0;
5693 job->patched_cb = job->user_cb;
5694 job->job_cb_size = cb_size;
5696 hl_debugfs_add_job(hdev, job);
5698 rc = gaudi_send_job_on_qman0(hdev, job);
5699 hl_debugfs_remove_job(hdev, job);
5700 kfree(job);
6349 struct hl_cs_job *job)
6370 cb = job->patched_cb;
6373 job->job_cb_size - sizeof(struct packet_msg_prot);
6389 job->job_cb_size, cb->bus_address);