Lines Matching defs:srq

489 dapli_arbel_wqe_srq_build(ib_srq_handle_t srq, ibt_recv_wr_t *wr,
503 if (wr->wr_nds > srq->srq_wq_sgl) {
536 if (num_ds < srq->srq_wq_sgl) {
1289 ib_srq_handle_t srq;
1297 srq = srqp->srq_handle;
1300 dapl_os_lock(&srq->srq_wridlist->wl_lock->wrl_lock);
1313 if (srq->srq_wridlist->wl_freel_entries == 0) {
1314 dapl_os_unlock(&srq->srq_wridlist->wl_lock->wrl_lock);
1319 qsize_msk = srq->srq_wridlist->wl_size - 1;
1320 head = srq->srq_wridlist->wl_freel_head;
1325 desc = srq->srq_wridlist->wl_free_list[head];
1327 wqe_index = TAVOR_SRQ_WQ_INDEX(srq->srq_wq_desc_addr, desc,
1328 srq->srq_wq_wqesz);
1331 wqe_addr = TAVOR_SRQ_WQ_ENTRY(srq, wqe_index);
1338 status = dapli_arbel_wqe_srq_build(srq, wr, wqe_addr);
1340 dapl_os_unlock(&srq->srq_wridlist->wl_lock->wrl_lock);
1347 dapli_tavor_wrid_add_entry_srq(srq, wr->wr_id, wqe_index);
1350 if (srq->srq_wq_lastwqeindex == -1) {
1353 last_wqe_addr = TAVOR_SRQ_WQ_ENTRY(srq,
1354 srq->srq_wq_lastwqeindex);
1365 srq->srq_wq_lastwqeindex = wqe_index;
1366 srq->srq_wridlist->wl_freel_head = next_head;
1367 srq->srq_wridlist->wl_freel_entries--;
1368 dapl_os_assert(srq->srq_wridlist->wl_freel_entries <=
1369 srq->srq_wridlist->wl_size);
1372 srq->srq_counter++;
1373 (srq->srq_dbp)[0] = HTOBE_32(srq->srq_counter);
1375 dapl_os_unlock(&srq->srq_wridlist->wl_lock->wrl_lock);
1601 dapli_arbel_srq_init(ib_srq_handle_t srq)
1603 (srq->srq_dbp)[1] =
1604 HTOBE_32((srq->srq_num << 8) | ARBEL_DBR_SRQ);
1607 dapli_arbel_rq_prelink(srq->srq_addr, srq->srq_wq_desc_addr,
1608 srq->srq_wq_wqesz, srq->srq_wq_numwqe, 0);
1609 srq->srq_counter = 0;