Lines Matching refs:srq
291 struct rxe_srq *srq = qp->srq; in get_srq_wqe() local
292 struct rxe_queue *q = srq->rq.queue; in get_srq_wqe()
296 if (srq->error) in get_srq_wqe()
299 spin_lock_bh(&srq->rq.consumer_lock); in get_srq_wqe()
303 spin_unlock_bh(&srq->rq.consumer_lock); in get_srq_wqe()
313 if (srq->limit && srq->ibsrq.event_handler && in get_srq_wqe()
314 (queue_count(q) < srq->limit)) { in get_srq_wqe()
315 srq->limit = 0; in get_srq_wqe()
319 spin_unlock_bh(&srq->rq.consumer_lock); in get_srq_wqe()
323 spin_unlock_bh(&srq->rq.consumer_lock); in get_srq_wqe()
325 ev.element.srq = qp->ibqp.srq; in get_srq_wqe()
327 srq->ibsrq.event_handler(&ev, srq->ibsrq.srq_context); in get_srq_wqe()
334 struct rxe_srq *srq = qp->srq; in check_resource() local
340 } else if (!srq) { in check_resource()
365 if (srq) in check_resource()
912 if (!qp->srq) in do_complete()
1146 if (qp->srq) { in do_class_d1e_error()
1189 while (!qp->srq && qp->rq.queue && queue_head(qp->rq.queue)) in rxe_drain_req_pkts()
1306 if (qp->srq) { in rxe_responder()
1323 } else if (qp->srq) { in rxe_responder()