Lines Matching refs:rdma
105 #include <rdma/ib_verbs.h>
106 #include <rdma/rdma_cm.h>
116 static void svc_rdma_send_cid_init(struct svcxprt_rdma *rdma,
119 cid->ci_queue_id = rdma->sc_sq_cq->res.id;
120 cid->ci_completion_id = atomic_inc_return(&rdma->sc_completion_ids);
124 svc_rdma_send_ctxt_alloc(struct svcxprt_rdma *rdma)
126 int node = ibdev_to_node(rdma->sc_cm_id->device);
132 ctxt = kmalloc_node(struct_size(ctxt, sc_sges, rdma->sc_max_send_sges),
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_TO_DEVICE);
141 if (ib_dma_mapping_error(rdma->sc_pd->device, addr))
144 svc_rdma_send_cid_init(rdma, &ctxt->sc_cid);
153 rdma->sc_max_req_size);
156 for (i = 0; i < rdma->sc_max_send_sges; i++)
157 ctxt->sc_sges[i].lkey = rdma->sc_pd->local_dma_lkey;
170 * @rdma: svcxprt_rdma being torn down
173 void svc_rdma_send_ctxts_destroy(struct svcxprt_rdma *rdma)
178 while ((node = llist_del_first(&rdma->sc_send_ctxts)) != NULL) {
180 ib_dma_unmap_single(rdma->sc_pd->device,
182 rdma->sc_max_req_size,
191 * @rdma: controlling svcxprt_rdma
196 struct svc_rdma_send_ctxt *svc_rdma_send_ctxt_get(struct svcxprt_rdma *rdma)
201 spin_lock(&rdma->sc_send_lock);
202 node = llist_del_first(&rdma->sc_send_ctxts);
206 spin_unlock(&rdma->sc_send_lock);
219 spin_unlock(&rdma->sc_send_lock);
220 ctxt = svc_rdma_send_ctxt_alloc(rdma);
228 * @rdma: controlling svcxprt_rdma
233 void svc_rdma_send_ctxt_put(struct svcxprt_rdma *rdma,
236 struct ib_device *device = rdma->sc_cm_id->device;
250 trace_svcrdma_dma_unmap_page(rdma,
255 llist_add(&ctxt->sc_node, &rdma->sc_send_ctxts);
260 * @rdma: controlling transport
264 void svc_rdma_wake_send_waiters(struct svcxprt_rdma *rdma, int avail)
266 atomic_add(avail, &rdma->sc_sq_avail);
268 if (unlikely(waitqueue_active(&rdma->sc_send_wait)))
269 wake_up(&rdma->sc_send_wait);
282 struct svcxprt_rdma *rdma = cq->cq_context;
287 svc_rdma_wake_send_waiters(rdma, 1);
293 svc_rdma_send_ctxt_put(rdma, ctxt);
301 svc_rdma_send_ctxt_put(rdma, ctxt);
302 svc_xprt_deferred_close(&rdma->sc_xprt);
307 * @rdma: transport on which to post the WR
313 int svc_rdma_send(struct svcxprt_rdma *rdma, struct svc_rdma_send_ctxt *ctxt)
321 ib_dma_sync_single_for_device(rdma->sc_pd->device,
328 if ((atomic_dec_return(&rdma->sc_sq_avail) < 0)) {
330 trace_svcrdma_sq_full(rdma);
331 atomic_inc(&rdma->sc_sq_avail);
332 wait_event(rdma->sc_send_wait,
333 atomic_read(&rdma->sc_sq_avail) > 1);
334 if (test_bit(XPT_CLOSE, &rdma->sc_xprt.xpt_flags))
336 trace_svcrdma_sq_retry(rdma);
341 ret = ib_post_send(rdma->sc_qp, wr, NULL);
347 trace_svcrdma_sq_post_err(rdma, ret);
348 svc_xprt_deferred_close(&rdma->sc_xprt);
349 wake_up(&rdma->sc_send_wait);
526 struct svcxprt_rdma *rdma = args->md_rdma;
528 struct ib_device *dev = rdma->sc_cm_id->device;
537 trace_svcrdma_dma_map_page(rdma, dma_addr, len);
544 trace_svcrdma_dma_map_err(rdma, dma_addr, len);
654 * @rdma: controlling transport
663 static bool svc_rdma_pull_up_needed(const struct svcxprt_rdma *rdma,
682 return args.pd_num_sges >= rdma->sc_max_send_sges;
729 * @rdma: controlling transport
744 static int svc_rdma_pull_up_reply_msg(const struct svcxprt_rdma *rdma,
765 * @rdma: controlling transport
777 int svc_rdma_map_reply_msg(struct svcxprt_rdma *rdma,
783 .md_rdma = rdma,
800 if (svc_rdma_pull_up_needed(rdma, sctxt, rctxt, xdr))
801 return svc_rdma_pull_up_reply_msg(rdma, sctxt, rctxt, xdr);
844 static int svc_rdma_send_reply_msg(struct svcxprt_rdma *rdma,
851 ret = svc_rdma_map_reply_msg(rdma, sctxt, rctxt, &rqstp->rq_res);
864 return svc_rdma_send(rdma, sctxt);
869 * @rdma: controlling transport context
882 void svc_rdma_send_error_msg(struct svcxprt_rdma *rdma,
901 *p++ = rdma->sc_fc_credits;
928 if (svc_rdma_send(rdma, sctxt))
933 svc_rdma_send_ctxt_put(rdma, sctxt);
951 struct svcxprt_rdma *rdma =
965 sctxt = svc_rdma_send_ctxt_get(rdma);
975 ret = svc_rdma_send_reply_chunk(rdma, rctxt, &rqstp->rq_res);
982 *p++ = rdma->sc_fc_credits;
995 ret = svc_rdma_send_reply_msg(rdma, sctxt, rctxt, rqstp);
1008 svc_rdma_send_error_msg(rdma, sctxt, rctxt, ret);
1012 svc_rdma_send_ctxt_put(rdma, sctxt);
1015 svc_xprt_deferred_close(&rdma->sc_xprt);
1039 struct svcxprt_rdma *rdma;
1057 rdma = container_of(rqstp->rq_xprt, struct svcxprt_rdma, sc_xprt);
1058 ret = svc_rdma_send_write_chunk(rdma, chunk, &subbuf);