Lines Matching refs:srq
283 struct rxe_srq *srq = qp->srq; in get_srq_wqe() local
284 struct rxe_queue *q = srq->rq.queue; in get_srq_wqe()
291 if (srq->error) in get_srq_wqe()
294 spin_lock_irqsave(&srq->rq.consumer_lock, flags); in get_srq_wqe()
298 spin_unlock_irqrestore(&srq->rq.consumer_lock, flags); in get_srq_wqe()
303 if (unlikely(wqe->dma.num_sge > srq->rq.max_sge)) { in get_srq_wqe()
304 spin_unlock_irqrestore(&srq->rq.consumer_lock, flags); in get_srq_wqe()
315 if (srq->limit && srq->ibsrq.event_handler && (count < srq->limit)) { in get_srq_wqe()
316 srq->limit = 0; in get_srq_wqe()
320 spin_unlock_irqrestore(&srq->rq.consumer_lock, flags); in get_srq_wqe()
324 spin_unlock_irqrestore(&srq->rq.consumer_lock, flags); in get_srq_wqe()
326 ev.element.srq = qp->ibqp.srq; in get_srq_wqe()
328 srq->ibsrq.event_handler(&ev, srq->ibsrq.srq_context); in get_srq_wqe()
335 struct rxe_srq *srq = qp->srq; in check_resource() local
341 } else if (!srq) { in check_resource()
367 if (srq) in check_resource()
1157 if (!qp->srq) in do_complete()
1393 if (qp->srq) { in do_class_d1e_error()
1438 while (!qp->srq && q && queue_head(q, q->type)) in rxe_drain_req_pkts()
1562 if (qp->srq) { in rxe_responder()
1586 } else if (qp->srq) { in rxe_responder()