sw/rxe/rxe_verbs.c

366 /* srq */
372 	struct rxe_srq *srq = to_rsrq(ibsrq);
387 		rxe_dbg_dev(rxe, "srq type = %d, not supported\n",
398 	err = rxe_add_to_pool(&rxe->srq_pool, srq);
400 		rxe_dbg_dev(rxe, "unable to create srq, err = %d\n", err);
405 	srq->pd = pd;
407 	err = rxe_srq_from_init(rxe, srq, init, udata, uresp);
409 		rxe_dbg_srq(srq, "create srq failed, err = %d\n", err);
416 	cleanup_err = rxe_cleanup(srq);
418 		rxe_err_srq(srq, "cleanup failed, err = %d\n", cleanup_err);
428 	struct rxe_srq *srq = to_rsrq(ibsrq);
436 			rxe_dbg_srq(srq, "malformed udata\n");
443 			rxe_dbg_srq(srq, "unable to read udata\n");
448 	err = rxe_srq_chk_attr(rxe, srq, attr, mask);
450 		rxe_dbg_srq(srq, "bad init attributes\n");
454 	err = rxe_srq_from_attr(rxe, srq, attr, mask, &cmd, udata);
456 		rxe_dbg_srq(srq, "bad attr\n");
463 	rxe_err_srq(srq, "returned err = %d\n", err);
469 	struct rxe_srq *srq = to_rsrq(ibsrq);
472 	if (srq->error) {
474 		rxe_dbg_srq(srq, "srq in error state\n");
478 	attr->max_wr = srq->rq.queue->buf->index_mask;
479 	attr->max_sge = srq->rq.max_sge;
480 	attr->srq_limit = srq->limit;
484 	rxe_err_srq(srq, "returned err = %d\n", err);
492 	struct rxe_srq *srq = to_rsrq(ibsrq);
495 	spin_lock_irqsave(&srq->rq.producer_lock, flags);
498 		err = post_one_recv(&srq->rq, wr);
504 	spin_unlock_irqrestore(&srq->rq.producer_lock, flags);
508 		rxe_err_srq(srq, "returned err = %d\n", err);
516 	struct rxe_srq *srq = to_rsrq(ibsrq);
519 	err = rxe_cleanup(srq);
521 		rxe_err_srq(srq, "cleanup failed, err = %d\n", err);
1028 	if (unlikely(qp->srq)) {
1030 		rxe_dbg_qp(qp, "qp has srq, use post_srq_recv instead\n");