Lines Matching refs:rdma
98 #include <rdma/ib_verbs.h>
99 #include <rdma/rdma_cm.h>
118 static void svc_rdma_recv_cid_init(struct svcxprt_rdma *rdma,
121 cid->ci_queue_id = rdma->sc_rq_cq->res.id;
122 cid->ci_completion_id = atomic_inc_return(&rdma->sc_completion_ids);
126 svc_rdma_recv_ctxt_alloc(struct svcxprt_rdma *rdma)
128 int node = ibdev_to_node(rdma->sc_cm_id->device);
136 buffer = kmalloc_node(rdma->sc_max_req_size, GFP_KERNEL, node);
139 addr = ib_dma_map_single(rdma->sc_pd->device, buffer,
140 rdma->sc_max_req_size, DMA_FROM_DEVICE);
141 if (ib_dma_mapping_error(rdma->sc_pd->device, addr))
144 svc_rdma_recv_cid_init(rdma, &ctxt->rc_cid);
156 ctxt->rc_recv_sge.length = rdma->sc_max_req_size;
157 ctxt->rc_recv_sge.lkey = rdma->sc_pd->local_dma_lkey;
169 static void svc_rdma_recv_ctxt_destroy(struct svcxprt_rdma *rdma,
172 ib_dma_unmap_single(rdma->sc_pd->device, ctxt->rc_recv_sge.addr,
180 * @rdma: svcxprt_rdma being torn down
183 void svc_rdma_recv_ctxts_destroy(struct svcxprt_rdma *rdma)
188 while ((node = llist_del_first(&rdma->sc_recv_ctxts))) {
190 svc_rdma_recv_ctxt_destroy(rdma, ctxt);
196 * @rdma: controlling svcxprt_rdma
200 struct svc_rdma_recv_ctxt *svc_rdma_recv_ctxt_get(struct svcxprt_rdma *rdma)
205 node = llist_del_first(&rdma->sc_recv_ctxts);
215 ctxt = svc_rdma_recv_ctxt_alloc(rdma);
223 * @rdma: controlling svcxprt_rdma
227 void svc_rdma_recv_ctxt_put(struct svcxprt_rdma *rdma,
235 llist_add(&ctxt->rc_node, &rdma->sc_recv_ctxts);
250 struct svcxprt_rdma *rdma =
254 svc_rdma_recv_ctxt_put(rdma, ctxt);
257 static bool svc_rdma_refresh_recvs(struct svcxprt_rdma *rdma,
265 if (test_bit(XPT_CLOSE, &rdma->sc_xprt.xpt_flags))
270 ctxt = svc_rdma_recv_ctxt_get(rdma);
277 rdma->sc_pending_recvs++;
282 ret = ib_post_recv(rdma->sc_qp, recv_chain, &bad_wr);
288 trace_svcrdma_rq_post_err(rdma, ret);
293 svc_rdma_recv_ctxt_put(rdma, ctxt);
302 * @rdma: fresh svcxprt_rdma
306 bool svc_rdma_post_recvs(struct svcxprt_rdma *rdma)
308 return svc_rdma_refresh_recvs(rdma, rdma->sc_max_requests);
319 struct svcxprt_rdma *rdma = cq->cq_context;
323 rdma->sc_pending_recvs--;
341 if (rdma->sc_pending_recvs < rdma->sc_max_requests)
342 if (!svc_rdma_refresh_recvs(rdma, rdma->sc_recv_batch))
348 spin_lock(&rdma->sc_rq_dto_lock);
349 list_add_tail(&ctxt->rc_list, &rdma->sc_rq_dto_q);
351 set_bit(XPT_DATA, &rdma->sc_xprt.xpt_flags);
352 spin_unlock(&rdma->sc_rq_dto_lock);
353 if (!test_bit(RDMAXPRT_CONN_PENDING, &rdma->sc_flags))
354 svc_xprt_enqueue(&rdma->sc_xprt);
363 svc_rdma_recv_ctxt_put(rdma, ctxt);
364 svc_xprt_deferred_close(&rdma->sc_xprt);
369 * @rdma: svcxprt_rdma being shut down
372 void svc_rdma_flush_recv_queues(struct svcxprt_rdma *rdma)
376 while ((ctxt = svc_rdma_next_recv_ctxt(&rdma->sc_rq_dto_q))) {
378 svc_rdma_recv_ctxt_put(rdma, ctxt);
583 static void svc_rdma_get_inv_rkey(struct svcxprt_rdma *rdma,
592 if (!rdma->sc_snd_w_inv)
713 static void svc_rdma_send_error(struct svcxprt_rdma *rdma,
719 sctxt = svc_rdma_send_ctxt_get(rdma);
722 svc_rdma_send_error_msg(rdma, sctxt, rctxt, status);