Lines Matching refs:srq

44 int rxe_srq_from_init(struct rxe_dev *rxe, struct rxe_srq *srq,  in rxe_srq_from_init()  argument
52 srq->ibsrq.event_handler = init->event_handler; in rxe_srq_from_init()
53 srq->ibsrq.srq_context = init->srq_context; in rxe_srq_from_init()
54 srq->limit = init->attr.srq_limit; in rxe_srq_from_init()
55 srq->srq_num = srq->elem.index; in rxe_srq_from_init()
56 srq->rq.max_wr = init->attr.max_wr; in rxe_srq_from_init()
57 srq->rq.max_sge = init->attr.max_sge; in rxe_srq_from_init()
60 srq->rq.max_sge*sizeof(struct ib_sge); in rxe_srq_from_init()
62 spin_lock_init(&srq->rq.producer_lock); in rxe_srq_from_init()
63 spin_lock_init(&srq->rq.consumer_lock); in rxe_srq_from_init()
65 q = rxe_queue_init(rxe, &srq->rq.max_wr, wqe_size, in rxe_srq_from_init()
68 rxe_dbg_srq(srq, "Unable to allocate queue\n"); in rxe_srq_from_init()
76 rxe_dbg_srq(srq, "Unable to init mmap info for caller\n"); in rxe_srq_from_init()
80 srq->rq.queue = q; in rxe_srq_from_init()
81 init->attr.max_wr = srq->rq.max_wr; in rxe_srq_from_init()
84 if (copy_to_user(&uresp->srq_num, &srq->srq_num, in rxe_srq_from_init()
100 int rxe_srq_chk_attr(struct rxe_dev *rxe, struct rxe_srq *srq, in rxe_srq_chk_attr() argument
103 if (srq->error) { in rxe_srq_chk_attr()
104 rxe_dbg_srq(srq, "in error state\n"); in rxe_srq_chk_attr()
110 rxe_dbg_srq(srq, "max_wr(%d) > max_srq_wr(%d)\n", in rxe_srq_chk_attr()
116 rxe_dbg_srq(srq, "max_wr(%d) <= 0\n", attr->max_wr); in rxe_srq_chk_attr()
120 if (srq->limit && (attr->max_wr < srq->limit)) { in rxe_srq_chk_attr()
121 rxe_dbg_srq(srq, "max_wr (%d) < srq->limit (%d)\n", in rxe_srq_chk_attr()
122 attr->max_wr, srq->limit); in rxe_srq_chk_attr()
132 rxe_dbg_srq(srq, "srq_limit(%d) > max_srq_wr(%d)\n", in rxe_srq_chk_attr()
137 if (attr->srq_limit > srq->rq.queue->buf->index_mask) { in rxe_srq_chk_attr()
138 rxe_dbg_srq(srq, "srq_limit (%d) > cur limit(%d)\n", in rxe_srq_chk_attr()
140 srq->rq.queue->buf->index_mask); in rxe_srq_chk_attr()
151 int rxe_srq_from_attr(struct rxe_dev *rxe, struct rxe_srq *srq, in rxe_srq_from_attr() argument
155 struct rxe_queue *q = srq->rq.queue; in rxe_srq_from_attr()
168 srq->rq.max_sge*sizeof(struct ib_sge); in rxe_srq_from_attr()
171 udata, mi, &srq->rq.producer_lock, in rxe_srq_from_attr()
172 &srq->rq.consumer_lock); in rxe_srq_from_attr()
176 srq->rq.max_wr = attr->max_wr; in rxe_srq_from_attr()
180 srq->limit = attr->srq_limit; in rxe_srq_from_attr()
186 srq->rq.queue = NULL; in rxe_srq_from_attr()
192 struct rxe_srq *srq = container_of(elem, typeof(*srq), elem); in rxe_srq_cleanup() local
194 if (srq->pd) in rxe_srq_cleanup()
195 rxe_put(srq->pd); in rxe_srq_cleanup()
197 if (srq->rq.queue) in rxe_srq_cleanup()
198 rxe_queue_cleanup(srq->rq.queue); in rxe_srq_cleanup()