Lines Matching refs:wq
62 dapls_tavor_workq_hdr_t *wq;
72 wq = dapli_tavor_wrid_wqhdr_find(cq, qpnum, send_or_recv);
74 dapl_os_assert(wq != NULL);
86 dapl_os_lock(&wq->wq_wrid_lock->wrl_lock);
87 wre_tmp = dapli_tavor_wrid_find_match(wq, cqe);
107 wre->wr_wqeaddrsz = dapli_tavor_wrid_get_wqeaddrsz(wq);
113 dapl_os_unlock(&wq->wq_wrid_lock->wrl_lock);
124 dapli_tavor_wrid_find_match(dapls_tavor_workq_hdr_t *wq, tavor_hw_cqe_t *cqe)
132 /* dapl_os_assert(MUTEX_HELD(&wq->wq_wrid_lock)); */
148 container = wq->wq_wrid_poll;
152 last_container = (container != wq->wq_wrid_post) ? 0 : 1;
211 wq->wq_wrid_poll = container->wl_next;
241 wq->wq_head = wq->wq_wrid_post->wl_head;
242 wq->wq_full = wq->wq_wrid_post->wl_full;
509 dapli_tavor_wrid_reaplist_add(ib_cq_handle_t cq, dapls_tavor_workq_hdr_t *wq)
513 dapl_os_lock(&wq->wq_wrid_lock->wrl_lock);
521 cq->cq_wrid_reap_head = wq->wq_wrid_post;
522 cq->cq_wrid_reap_tail = wq->wq_wrid_post;
524 cq->cq_wrid_reap_tail->wl_reap_next = wq->wq_wrid_post;
525 cq->cq_wrid_reap_tail = wq->wq_wrid_post;
528 dapl_os_unlock(&wq->wq_wrid_lock->wrl_lock);
567 dapli_tavor_wrid_get_wqeaddrsz(dapls_tavor_workq_hdr_t *wq)
582 if (wq->wq_wrid_poll->wl_head == wq->wq_wrid_poll->wl_tail) {
592 head = wq->wq_wrid_poll->wl_head;
593 wre = &wq->wq_wrid_poll->wl_wre[head];