Lines Matching defs:stream
581 /* 2 SOBs per internal queue stream are reserved for collective */
586 /* 1 monitor per internal queue stream are reserved for collective
587 * 2 monitors per external queue stream are reserved for collective
1089 static void gaudi_collective_map_sobs(struct hl_device *hdev, u32 stream)
1098 stream * HL_RSVD_SOBS + prop->curr_sob_group_idx[stream];
1101 queue_id = GAUDI_QUEUE_ID_NIC_0_0 + stream;
1110 queue_id = GAUDI_QUEUE_ID_DMA_5_0 + stream;
1115 queue_id = GAUDI_QUEUE_ID_TPC_7_0 + stream;
1207 struct hl_cs_job *job, u32 stream, u32 sob_group_offset)
1229 cprop->next_sob_group_val[stream],
1235 wait_prop.sob_val = cprop->next_sob_group_val[stream];
1247 cprop->next_sob_group_val[stream],
1313 u32 stream, queue_id, sob_group_offset;
1362 /* Calculate the stream from collective master queue (1st job) */
1364 stream = job->hw_queue_id % 4;
1366 stream * HL_RSVD_SOBS + cprop->curr_sob_group_idx[stream];
1373 gaudi_collective_master_init_job(hdev, job, stream,
1383 cprop->next_sob_group_val[stream]++;
1385 if (cprop->next_sob_group_val[stream] == HL_MAX_SOB_VAL) {
1393 cprop->next_sob_group_val[stream] = 1;
1395 cprop->curr_sob_group_idx[stream] =
1396 (cprop->curr_sob_group_idx[stream] + 1) &
1399 gaudi_collective_map_sobs(hdev, stream);
1401 dev_dbg(hdev->dev, "switched to SOB group %d, stream: %d\n",
1402 cprop->curr_sob_group_idx[stream], stream);
1529 u32 stream, nic_queue, nic_idx = 0;
1551 stream = wait_queue_id % 4;
1554 collective_queue = GAUDI_QUEUE_ID_DMA_5_0 + stream;
1556 collective_queue = GAUDI_QUEUE_ID_TPC_7_0 + stream;
1559 nic_queue = GAUDI_QUEUE_ID_NIC_0_0 + stream;
2816 /* Configure DMA5 CP_MSG_BASE 2/3 for sync stream collective */
3085 /* Configure TPC7 CP_MSG_BASE 2/3 for sync stream collective */
3191 /* Configure NIC CP_MSG_BASE 2/3 for sync stream collective */
6793 * gaudi_handle_sw_config_stream_data - print SW config stream data
6796 * @stream: the QMAN's stream
6800 static void gaudi_handle_sw_config_stream_data(struct hl_device *hdev, u32 stream,
6809 stream * cq_ptr_lo_off;
6817 dev_info(hdev->dev, "stop on err: stream: %u, addr: %#llx, size: %u\n",
6818 stream, cq_ptr, size);
6823 hdev->captured_err_info.undef_opcode.stream_id = stream;
6832 * @stream: the QMAN's stream
6835 * @pr_sw_conf: if true print the SW config stream data (CQ PTR and SIZE)
6838 u32 stream, u64 qman_base,
6847 q = &hdev->kernel_queues[qid_base + stream];
6851 stream * qm_ci_stream_off;
6859 gaudi_handle_sw_config_stream_data(hdev, stream, qman_base, event_mask);
6881 dev_info(hdev->dev, "stop on err PQE(stream %u): ci: %u, addr: %#llx, size: %u\n",
6882 stream, ci, addr[i], len);
6909 * @stream: the QMAN's stream
6914 * On upper CP print the SW config stream data and last 8 PQEs.
6918 u32 stream, u64 qman_base, u64 event_mask)
6922 if (stream != QMAN_STREAMS) {
6923 gaudi_handle_last_pqes_on_err(hdev, qid_base, stream,
6929 gaudi_handle_sw_config_stream_data(hdev, stream, qman_base, event_mask);
6949 /* Iterate through all stream GLBL_STS1 registers + Lower CP */
6960 snprintf(reg_desc, ARRAY_SIZE(reg_desc), "stream%u", i);
9019 "%s%u, stream %u: fence id %u cnt = 0x%llx (%s%u_QM.CP_FENCE%u_CNT_%u) rdata = 0x%llx (%s%u_QM.CP_FENCE%u_RDATA_%u) value = %u, cp_status = %u\n",