| /kernel/linux/linux-5.10/net/sunrpc/xprtrdma/ |
| D | verbs.c | 77 static int rpcrdma_sendctxs_create(struct rpcrdma_xprt *r_xprt);
78 static void rpcrdma_sendctxs_destroy(struct rpcrdma_xprt *r_xprt);
79 static void rpcrdma_sendctx_put_locked(struct rpcrdma_xprt *r_xprt,
81 static int rpcrdma_reqs_setup(struct rpcrdma_xprt *r_xprt);
82 static void rpcrdma_reqs_reset(struct rpcrdma_xprt *r_xprt);
84 static void rpcrdma_reps_unmap(struct rpcrdma_xprt *r_xprt);
85 static void rpcrdma_mrs_create(struct rpcrdma_xprt *r_xprt);
86 static void rpcrdma_mrs_destroy(struct rpcrdma_xprt *r_xprt);
99 static void rpcrdma_xprt_drain(struct rpcrdma_xprt *r_xprt) in rpcrdma_xprt_drain() argument
101 struct rpcrdma_ep *ep = r_xprt->rx_ep; in rpcrdma_xprt_drain()
[all …]
|
| D | transport.c | 238 struct rpcrdma_xprt *r_xprt = container_of(work, struct rpcrdma_xprt, in xprt_rdma_connect_worker() local
240 struct rpc_xprt *xprt = &r_xprt->rx_xprt; in xprt_rdma_connect_worker()
243 rc = rpcrdma_xprt_connect(r_xprt); in xprt_rdma_connect_worker()
253 rpcrdma_xprt_disconnect(r_xprt); in xprt_rdma_connect_worker()
254 xprt_unlock_connect(xprt, r_xprt); in xprt_rdma_connect_worker()
270 struct rpcrdma_xprt *r_xprt = rpcx_to_rdmax(xprt); in xprt_rdma_inject_disconnect() local
272 trace_xprtrdma_op_inject_dsc(r_xprt); in xprt_rdma_inject_disconnect()
273 rdma_disconnect(r_xprt->rx_ep->re_id); in xprt_rdma_inject_disconnect()
286 struct rpcrdma_xprt *r_xprt = rpcx_to_rdmax(xprt); in xprt_rdma_destroy() local
288 cancel_delayed_work_sync(&r_xprt->rx_connect_worker); in xprt_rdma_destroy()
[all …]
|
| D | rpc_rdma.c | 130 static bool rpcrdma_args_inline(struct rpcrdma_xprt *r_xprt, in rpcrdma_args_inline() argument
134 struct rpcrdma_ep *ep = r_xprt->rx_ep; in rpcrdma_args_inline()
162 static bool rpcrdma_results_inline(struct rpcrdma_xprt *r_xprt, in rpcrdma_results_inline() argument
165 return rqst->rq_rcv_buf.buflen <= r_xprt->rx_ep->re_max_inline_recv; in rpcrdma_results_inline()
173 rpcrdma_nonpayload_inline(const struct rpcrdma_xprt *r_xprt, in rpcrdma_nonpayload_inline() argument
179 r_xprt->rx_ep->re_max_inline_recv; in rpcrdma_nonpayload_inline()
245 rpcrdma_convert_iovs(struct rpcrdma_xprt *r_xprt, struct xdr_buf *xdrbuf, in rpcrdma_convert_iovs() argument
274 if (type == rpcrdma_readch && r_xprt->rx_ep->re_implicit_roundup) in rpcrdma_convert_iovs()
282 if (type == rpcrdma_writech && r_xprt->rx_ep->re_implicit_roundup) in rpcrdma_convert_iovs()
323 static struct rpcrdma_mr_seg *rpcrdma_mr_prepare(struct rpcrdma_xprt *r_xprt, in rpcrdma_mr_prepare() argument
[all …]
|
| D | xprt_rdma.h | 426 rpcrdma_addrstr(const struct rpcrdma_xprt *r_xprt) in rpcrdma_addrstr() argument
428 return r_xprt->rx_xprt.address_strings[RPC_DISPLAY_ADDR]; in rpcrdma_addrstr()
432 rpcrdma_portstr(const struct rpcrdma_xprt *r_xprt) in rpcrdma_portstr() argument
434 return r_xprt->rx_xprt.address_strings[RPC_DISPLAY_PORT]; in rpcrdma_portstr()
450 void rpcrdma_flush_disconnect(struct rpcrdma_xprt *r_xprt, struct ib_wc *wc);
451 int rpcrdma_xprt_connect(struct rpcrdma_xprt *r_xprt);
452 void rpcrdma_xprt_disconnect(struct rpcrdma_xprt *r_xprt);
454 int rpcrdma_post_sends(struct rpcrdma_xprt *r_xprt, struct rpcrdma_req *req);
455 void rpcrdma_post_recvs(struct rpcrdma_xprt *r_xprt, int needed, bool temp);
460 struct rpcrdma_req *rpcrdma_req_create(struct rpcrdma_xprt *r_xprt, size_t size,
[all …]
|
| D | backchannel.c | 31 struct rpcrdma_xprt *r_xprt = rpcx_to_rdmax(xprt); in xprt_rdma_bc_setup() local
33 r_xprt->rx_buf.rb_bc_srv_max_requests = RPCRDMA_BACKWARD_WRS >> 1; in xprt_rdma_bc_setup()
34 trace_xprtrdma_cb_setup(r_xprt, reqs); in xprt_rdma_bc_setup()
46 struct rpcrdma_xprt *r_xprt = rpcx_to_rdmax(xprt); in xprt_rdma_bc_maxpayload() local
47 struct rpcrdma_ep *ep = r_xprt->rx_ep; in xprt_rdma_bc_maxpayload()
62 struct rpcrdma_xprt *r_xprt = rpcx_to_rdmax(rqst->rq_xprt); in rpcrdma_bc_marshal_reply() local
75 *p++ = cpu_to_be32(r_xprt->rx_buf.rb_bc_srv_max_requests); in rpcrdma_bc_marshal_reply()
81 if (rpcrdma_prepare_send_sges(r_xprt, req, RPCRDMA_HDRLEN_MIN, in rpcrdma_bc_marshal_reply()
104 struct rpcrdma_xprt *r_xprt = rpcx_to_rdmax(xprt); in xprt_rdma_bc_send_reply() local
118 if (rpcrdma_post_sends(r_xprt, req)) in xprt_rdma_bc_send_reply()
[all …]
|
| D | frwr_ops.c | 70 struct rpcrdma_xprt *r_xprt = mr->mr_xprt; in frwr_mr_recycle() local
76 ib_dma_unmap_sg(r_xprt->rx_ep->re_id->device, in frwr_mr_recycle()
81 spin_lock(&r_xprt->rx_buf.rb_lock); in frwr_mr_recycle()
83 r_xprt->rx_stats.mrs_recycled++; in frwr_mr_recycle()
84 spin_unlock(&r_xprt->rx_buf.rb_lock); in frwr_mr_recycle()
115 int frwr_mr_init(struct rpcrdma_xprt *r_xprt, struct rpcrdma_mr *mr) in frwr_mr_init() argument
117 struct rpcrdma_ep *ep = r_xprt->rx_ep; in frwr_mr_init()
131 mr->mr_xprt = r_xprt; in frwr_mr_init()
281 struct rpcrdma_mr_seg *frwr_map(struct rpcrdma_xprt *r_xprt, in frwr_map() argument
286 struct rpcrdma_ep *ep = r_xprt->rx_ep; in frwr_map()
[all …]
|
| D | svc_rdma_backchannel.c | 24 struct rpcrdma_xprt *r_xprt = rpcx_to_rdmax(xprt); in svc_rdma_handle_bc_reply() local
47 else if (credits > r_xprt->rx_buf.rb_bc_max_requests) in svc_rdma_handle_bc_reply()
48 credits = r_xprt->rx_buf.rb_bc_max_requests; in svc_rdma_handle_bc_reply()
136 struct rpcrdma_xprt *r_xprt = rpcx_to_rdmax(xprt); in rpcrdma_bc_send_request() local
150 *p++ = cpu_to_be32(r_xprt->rx_buf.rb_bc_max_requests); in rpcrdma_bc_send_request()
|
| /kernel/linux/linux-5.10/include/trace/events/ |
| D | rpcrdma.h | 72 __field(const void *, r_xprt)
80 __entry->r_xprt = rep->rr_rxprt;
87 __entry->r_xprt, __entry->xid, __entry->rep,
101 const struct rpcrdma_xprt *r_xprt
104 TP_ARGS(r_xprt),
107 __field(const void *, r_xprt)
108 __string(addr, rpcrdma_addrstr(r_xprt))
109 __string(port, rpcrdma_portstr(r_xprt))
113 __entry->r_xprt = r_xprt;
114 __assign_str(addr, rpcrdma_addrstr(r_xprt));
[all …]
|
| /kernel/linux/linux-5.10/net/sunrpc/ |
| D | rpcb_clnt.c | 117 struct rpc_xprt * r_xprt; member
157 rpcb_wake_rpcbind_waiters(map->r_xprt, map->r_status); in rpcb_map_release()
158 xprt_put(map->r_xprt); in rpcb_map_release()
723 map->r_xprt = xprt; in rpcb_getport_async()
768 struct rpc_xprt *xprt = map->r_xprt; in rpcb_getport_done()
|