Lines Matching refs:srq
322 struct rxe_srq *srq = qp->srq; in get_srq_wqe() local
323 struct rxe_queue *q = srq->rq.queue; in get_srq_wqe()
327 if (srq->error) in get_srq_wqe()
330 spin_lock_bh(&srq->rq.consumer_lock); in get_srq_wqe()
334 spin_unlock_bh(&srq->rq.consumer_lock); in get_srq_wqe()
344 if (srq->limit && srq->ibsrq.event_handler && in get_srq_wqe()
345 (queue_count(q) < srq->limit)) { in get_srq_wqe()
346 srq->limit = 0; in get_srq_wqe()
350 spin_unlock_bh(&srq->rq.consumer_lock); in get_srq_wqe()
354 spin_unlock_bh(&srq->rq.consumer_lock); in get_srq_wqe()
356 ev.element.srq = qp->ibqp.srq; in get_srq_wqe()
358 srq->ibsrq.event_handler(&ev, srq->ibsrq.srq_context); in get_srq_wqe()
365 struct rxe_srq *srq = qp->srq; in check_resource() local
371 } else if (!srq) { in check_resource()
396 if (srq) in check_resource()
925 if (!qp->srq) in do_complete()
1161 if (qp->srq) { in do_class_d1e_error()
1204 while (!qp->srq && qp->rq.queue && queue_head(qp->rq.queue)) in rxe_drain_req_pkts()
1321 if (qp->srq) { in rxe_responder()
1338 } else if (qp->srq) { in rxe_responder()