Lines Matching defs:srq
466 dapli_hermon_wqe_srq_build(ib_srq_handle_t srq, ibt_recv_wr_t *wr,
480 if (wr->wr_nds > srq->srq_wq_sgl) {
513 if (num_ds < srq->srq_wq_sgl) {
1344 ib_srq_handle_t srq;
1352 srq = srqp->srq_handle;
1355 dapl_os_lock(&srq->srq_wridlist->wl_lock->wrl_lock);
1368 if (srq->srq_wridlist->wl_freel_entries == 0) {
1369 dapl_os_unlock(&srq->srq_wridlist->wl_lock->wrl_lock);
1374 qsize_msk = srq->srq_wridlist->wl_size - 1;
1375 head = srq->srq_wridlist->wl_freel_head;
1380 desc = srq->srq_wridlist->wl_free_list[head];
1382 wqe_index = TAVOR_SRQ_WQ_INDEX(srq->srq_wq_desc_addr, desc,
1383 srq->srq_wq_wqesz);
1386 wqe_addr = TAVOR_SRQ_WQ_ENTRY(srq, wqe_index);
1393 status = dapli_hermon_wqe_srq_build(srq, wr, wqe_addr);
1395 dapl_os_unlock(&srq->srq_wridlist->wl_lock->wrl_lock);
1402 dapli_tavor_wrid_add_entry_srq(srq, wr->wr_id, wqe_index);
1405 if (srq->srq_wq_lastwqeindex == -1) {
1408 last_wqe_addr = TAVOR_SRQ_WQ_ENTRY(srq,
1409 srq->srq_wq_lastwqeindex);
1420 srq->srq_wq_lastwqeindex = wqe_index;
1421 srq->srq_wridlist->wl_freel_head = next_head;
1422 srq->srq_wridlist->wl_freel_entries--;
1423 dapl_os_assert(srq->srq_wridlist->wl_freel_entries <=
1424 srq->srq_wridlist->wl_size);
1427 srq->srq_counter++;
1428 (srq->srq_dbp)[0] = HTOBE_32(srq->srq_counter);
1430 dapl_os_unlock(&srq->srq_wridlist->wl_lock->wrl_lock);
1638 dapli_hermon_srq_init(ib_srq_handle_t srq)
1641 dapli_hermon_rq_prelink(srq->srq_addr, srq->srq_wq_desc_addr,
1642 srq->srq_wq_wqesz, srq->srq_wq_numwqe, 0);
1643 srq->srq_counter = 0;