Lines Matching defs:rdma
105 #include <rdma/ib_verbs.h>
106 #include <rdma/rdma_cm.h>
117 svc_rdma_send_ctxt_alloc(struct svcxprt_rdma *rdma)
119 int node = ibdev_to_node(rdma->sc_cm_id->device);
126 ctxt = kzalloc_node(struct_size(ctxt, sc_sges, rdma->sc_max_send_sges),
130 pages = svc_serv_maxpages(rdma->sc_xprt.xpt_server);
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);
146 ctxt->sc_rdma = rdma;
154 rdma->sc_max_req_size);
157 for (i = 0; i < rdma->sc_max_send_sges; i++)
158 ctxt->sc_sges[i].lkey = rdma->sc_pd->local_dma_lkey;
173 * @rdma: svcxprt_rdma being torn down
176 void svc_rdma_send_ctxts_destroy(struct svcxprt_rdma *rdma)
181 while ((node = llist_del_first(&rdma->sc_send_ctxts)) != NULL) {
183 ib_dma_unmap_single(rdma->sc_pd->device,
185 rdma->sc_max_req_size,
195 * @rdma: controlling svcxprt_rdma
200 struct svc_rdma_send_ctxt *svc_rdma_send_ctxt_get(struct svcxprt_rdma *rdma)
205 spin_lock(&rdma->sc_send_lock);
206 node = llist_del_first(&rdma->sc_send_ctxts);
207 spin_unlock(&rdma->sc_send_lock);
218 svc_rdma_cc_init(rdma, &ctxt->sc_reply_info.wi_cc);
228 ctxt = svc_rdma_send_ctxt_alloc(rdma);
234 static void svc_rdma_send_ctxt_release(struct svcxprt_rdma *rdma,
237 struct ib_device *device = rdma->sc_cm_id->device;
240 svc_rdma_reply_chunk_release(rdma, ctxt);
258 llist_add(&ctxt->sc_node, &rdma->sc_send_ctxts);
271 * @rdma: controlling svcxprt_rdma
276 void svc_rdma_send_ctxt_put(struct svcxprt_rdma *rdma,
285 * @rdma: controlling transport
289 void svc_rdma_wake_send_waiters(struct svcxprt_rdma *rdma, int avail)
291 atomic_add(avail, &rdma->sc_sq_avail);
293 if (unlikely(waitqueue_active(&rdma->sc_send_wait)))
294 wake_up(&rdma->sc_send_wait);
307 struct svcxprt_rdma *rdma = cq->cq_context;
312 svc_rdma_wake_send_waiters(rdma, ctxt->sc_sqecount);
318 svc_rdma_send_ctxt_put(rdma, ctxt);
326 svc_rdma_send_ctxt_put(rdma, ctxt);
327 svc_xprt_deferred_close(&rdma->sc_xprt);
332 * @rdma: transport context
348 int svc_rdma_post_send(struct svcxprt_rdma *rdma,
360 ib_dma_sync_single_for_device(rdma->sc_pd->device,
366 while (!test_bit(XPT_CLOSE, &rdma->sc_xprt.xpt_flags)) {
367 if (atomic_sub_return(sqecount, &rdma->sc_sq_avail) < 0) {
368 svc_rdma_wake_send_waiters(rdma, sqecount);
377 trace_svcrdma_sq_full(rdma, &cid);
378 wait_event(rdma->sc_send_wait,
379 atomic_read(&rdma->sc_sq_avail) > 0);
380 trace_svcrdma_sq_retry(rdma, &cid);
385 ret = ib_post_send(rdma->sc_qp, first_wr, &bad_wr);
387 trace_svcrdma_sq_post_err(rdma, &cid, ret);
388 svc_xprt_deferred_close(&rdma->sc_xprt);
394 svc_rdma_wake_send_waiters(rdma, sqecount);
576 struct svcxprt_rdma *rdma = args->md_rdma;
578 struct ib_device *dev = rdma->sc_cm_id->device;
704 * @rdma: controlling transport
713 static bool svc_rdma_pull_up_needed(const struct svcxprt_rdma *rdma,
732 return args.pd_num_sges >= rdma->sc_max_send_sges;
779 * @rdma: controlling transport
794 static int svc_rdma_pull_up_reply_msg(const struct svcxprt_rdma *rdma,
815 * @rdma: controlling transport
828 int svc_rdma_map_reply_msg(struct svcxprt_rdma *rdma,
835 .md_rdma = rdma,
852 if (svc_rdma_pull_up_needed(rdma, sctxt, write_pcl, xdr))
853 return svc_rdma_pull_up_reply_msg(rdma, sctxt, write_pcl, xdr);
890 static int svc_rdma_send_reply_msg(struct svcxprt_rdma *rdma,
898 ret = svc_rdma_map_reply_msg(rdma, sctxt, &rctxt->rc_write_pcl,
915 return svc_rdma_post_send(rdma, sctxt);
920 * @rdma: controlling transport context
933 void svc_rdma_send_error_msg(struct svcxprt_rdma *rdma,
952 *p++ = rdma->sc_fc_credits;
979 if (svc_rdma_post_send(rdma, sctxt))
984 svc_rdma_send_ctxt_put(rdma, sctxt);
1002 struct svcxprt_rdma *rdma =
1016 sctxt = svc_rdma_send_ctxt_get(rdma);
1026 ret = svc_rdma_send_write_list(rdma, rctxt, &rqstp->rq_res);
1032 ret = svc_rdma_prepare_reply_chunk(rdma, &rctxt->rc_write_pcl,
1042 *p++ = rdma->sc_fc_credits;
1055 ret = svc_rdma_send_reply_msg(rdma, sctxt, rctxt, rqstp);
1068 svc_rdma_send_error_msg(rdma, sctxt, rctxt, ret);
1072 svc_rdma_send_ctxt_put(rdma, sctxt);
1075 svc_xprt_deferred_close(&rdma->sc_xprt);