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_page(xprt->sc_cm_id->device,
269 if (ib_dma_mapping_error(xprt->sc_cm_id->device,
272 atomic_inc(&xprt->sc_dma_used);
293 ret = svc_rdma_fastreg(xprt, frmr);
300 printk("svcrdma: error fast registering xdr for xprt %p", xprt);
301 svc_rdma_put_frmr(xprt, frmr);
305 static int rdma_set_ctxt_sge(struct svcxprt_rdma *xprt,
323 ib_dma_map_page(xprt->sc_cm_id->device,
328 if (ib_dma_mapping_error(xprt->sc_cm_id->device,
331 ctxt->sge[i].lkey = xprt->sc_dma_lkey;
332 atomic_inc(&xprt->sc_dma_used);
343 static int rdma_read_max_sge(struct svcxprt_rdma *xprt, int sge_count)
345 if ((rdma_node_get_transport(xprt->sc_cm_id->device->node_type) ==
350 return min_t(int, sge_count, xprt->sc_max_sge);
381 static int rdma_read_xdr(struct svcxprt_rdma *xprt,
412 if (!xprt->sc_frmr_pg_list_len)
413 sge_count = map_read_chunks(xprt, rqstp, hdr_ctxt, rmsgp,
417 sge_count = fast_reg_read_chunks(xprt, rqstp, hdr_ctxt, rmsgp,
432 ctxt = svc_rdma_get_context(xprt);
451 rdma_read_max_sge(xprt, chl_map->ch[ch_no].count);
452 err = rdma_set_ctxt_sge(xprt, ctxt, hdr_ctxt->frmr,
475 if (xprt->sc_dev_caps &
495 err = svc_rdma_send(xprt, &read_wr);
499 set_bit(XPT_CLOSE, &xprt->sc_xprt.xpt_flags);
586 struct svc_xprt *xprt = rqstp->rq_xprt;
588 container_of(xprt, struct svcxprt_rdma, sc_xprt);
615 clear_bit(XPT_DATA, &xprt->xpt_flags);
625 if (test_bit(XPT_CLOSE, &xprt->xpt_flags))
631 dprintk("svcrdma: processing ctxt=%p on xprt=%p, rqstp=%p, status=%d\n",
673 svc_xprt_copy_addrs(rqstp, xprt);
679 dprintk("svcrdma: transport %p is closing\n", xprt);
684 set_bit(XPT_CLOSE, &xprt->xpt_flags);