Lines Matching defs:qp

725 dapls_tavor_wrid_init(ib_qp_handle_t qp)
740 dapli_tavor_wrid_wqhdr_lock_both(qp);
741 swq = dapli_tavor_wrid_wqhdr_find(qp->qp_sq_cqhdl, qp->qp_num,
746 swq = dapli_tavor_wrid_wqhdr_create(qp->qp_sq_cqhdl,
747 qp->qp_num, TAVOR_WR_SEND, 1);
753 dapli_tavor_wrid_wqhdr_unlock_both(qp);
757 qp->qp_sq_wqhdr = swq;
758 swq->wq_size = qp->qp_sq_numwqe;
775 dapli_tavor_cq_wqhdr_remove(qp->qp_sq_cqhdl, swq);
778 dapli_tavor_wrid_wqhdr_unlock_both(qp);
791 rwq = dapli_tavor_wrid_wqhdr_find(qp->qp_rq_cqhdl, qp->qp_num,
795 /* if qp is attached to an SRQ don't need to alloc wrid_lock */
796 rwq = dapli_tavor_wrid_wqhdr_create(qp->qp_rq_cqhdl,
797 qp->qp_num, TAVOR_WR_RECV, qp->qp_srq_enabled ? 0 : 1);
809 dapli_tavor_cq_wqhdr_remove(qp->qp_sq_cqhdl,
813 dapli_tavor_wrid_wqhdr_unlock_both(qp);
818 qp->qp_rq_wqhdr = rwq;
819 rwq->wq_size = qp->qp_rq_numwqe;
826 * For qp associated with SRQs the SRQ wridlist is used
828 if (qp->qp_srq_enabled) {
830 r_wridlist = qp->qp_srq->srq_wridlist;
849 dapli_tavor_cq_wqhdr_remove(qp->qp_sq_cqhdl, swq);
852 dapli_tavor_cq_wqhdr_remove(qp->qp_rq_cqhdl, rwq);
855 dapli_tavor_wrid_wqhdr_unlock_both(qp);
860 if (!qp->qp_srq_enabled) {
869 dapli_tavor_wrid_wqhdr_unlock_both(qp);
879 dapls_tavor_wrid_cleanup(DAPL_EP *ep, ib_qp_handle_t qp)
889 dapli_tavor_wrid_wqhdr_lock_both(qp);
890 dapli_tavor_wrid_reaplist_add(qp->qp_sq_cqhdl, qp->qp_sq_wqhdr);
898 if (qp->qp_srq_enabled) {
903 dapl_os_lock(&qp->qp_rq_wqhdr->wq_wrid_lock->wrl_lock);
904 DAPL_FLUSH(ep)(qp);
907 dapli_tavor_wrid_wqhdr_remove(qp->qp_rq_wqhdr,
908 qp->qp_rq_wqhdr->wq_wrid_post);
910 dapl_os_assert(qp->qp_rq_wqhdr->wq_wrid_post == NULL);
912 dapl_os_unlock(&qp->qp_rq_wqhdr->wq_wrid_lock->wrl_lock);
915 dapli_tavor_cq_wqhdr_remove(qp->qp_rq_cqhdl, qp->qp_rq_wqhdr);
917 dapli_tavor_wrid_reaplist_add(qp->qp_rq_cqhdl, qp->qp_rq_wqhdr);
919 dapli_tavor_wrid_wqhdr_unlock_both(qp);
1041 dapli_tavor_wrid_wqhdr_lock_both(ib_qp_handle_t qp)
1045 sq_cq = qp->qp_sq_cqhdl;
1046 rq_cq = qp->qp_rq_cqhdl;
1068 dapli_tavor_wrid_wqhdr_unlock_both(ib_qp_handle_t qp)
1072 sq_cq = qp->qp_sq_cqhdl;
1073 rq_cq = qp->qp_rq_cqhdl;