Lines Matching defs:xprt
128 static int map_read_chunks(struct svcxprt_rdma *xprt,
228 static int fast_reg_read_chunks(struct svcxprt_rdma *xprt,
244 frmr = svc_rdma_get_frmr(xprt);
266 ib_dma_map_single(xprt->sc_cm_id->device,
269 if (ib_dma_mapping_error(xprt->sc_cm_id->device,
272 atomic_inc(&xprt->sc_dma_used);
292 ret = svc_rdma_fastreg(xprt, frmr);
299 printk("svcrdma: error fast registering xdr for xprt %p", xprt);
300 svc_rdma_put_frmr(xprt, frmr);
304 static int rdma_set_ctxt_sge(struct svcxprt_rdma *xprt,
319 ib_dma_map_single(xprt->sc_cm_id->device,
323 if (ib_dma_mapping_error(xprt->sc_cm_id->device,
326 ctxt->sge[i].lkey = xprt->sc_dma_lkey;
327 atomic_inc(&xprt->sc_dma_used);
338 static int rdma_read_max_sge(struct svcxprt_rdma *xprt, int sge_count)
340 if ((rdma_node_get_transport(xprt->sc_cm_id->device->node_type) ==
345 return min_t(int, sge_count, xprt->sc_max_sge);
376 static int rdma_read_xdr(struct svcxprt_rdma *xprt,
407 if (!xprt->sc_frmr_pg_list_len)
408 sge_count = map_read_chunks(xprt, rqstp, hdr_ctxt, rmsgp,
412 sge_count = fast_reg_read_chunks(xprt, rqstp, hdr_ctxt, rmsgp,
426 ctxt = svc_rdma_get_context(xprt);
445 rdma_read_max_sge(xprt, chl_map->ch[ch_no].count);
446 err = rdma_set_ctxt_sge(xprt, ctxt, hdr_ctxt->frmr,
469 if (xprt->sc_dev_caps &
489 err = svc_rdma_send(xprt, &read_wr);
493 set_bit(XPT_CLOSE, &xprt->sc_xprt.xpt_flags);
578 struct svc_xprt *xprt = rqstp->rq_xprt;
580 container_of(xprt, struct svcxprt_rdma, sc_xprt);
607 clear_bit(XPT_DATA, &xprt->xpt_flags);
617 if (test_bit(XPT_CLOSE, &xprt->xpt_flags))
623 dprintk("svcrdma: processing ctxt=%p on xprt=%p, rqstp=%p, status=%d\n",
665 svc_xprt_copy_addrs(rqstp, xprt);
671 dprintk("svcrdma: transport %p is closing\n", xprt);
676 set_bit(XPT_CLOSE, &xprt->xpt_flags);