| /Linux-v4.19/net/sunrpc/xprtrdma/ |
| D | transport.c | 239 struct rpcrdma_xprt *r_xprt = in rpcrdma_connect_worker() local
241 struct rpc_xprt *xprt = &r_xprt->rx_xprt; in rpcrdma_connect_worker()
257 struct rpcrdma_xprt *r_xprt = container_of(work, struct rpcrdma_xprt, in xprt_rdma_connect_worker() local
259 struct rpc_xprt *xprt = &r_xprt->rx_xprt; in xprt_rdma_connect_worker()
264 rc = rpcrdma_ep_connect(&r_xprt->rx_ep, &r_xprt->rx_ia); in xprt_rdma_connect_worker()
274 struct rpcrdma_xprt *r_xprt = container_of(xprt, struct rpcrdma_xprt, in xprt_rdma_inject_disconnect() local
277 trace_xprtrdma_inject_dsc(r_xprt); in xprt_rdma_inject_disconnect()
278 rdma_disconnect(r_xprt->rx_ia.ri_id); in xprt_rdma_inject_disconnect()
295 struct rpcrdma_xprt *r_xprt = rpcx_to_rdmax(xprt); in xprt_rdma_destroy() local
297 trace_xprtrdma_destroy(r_xprt); in xprt_rdma_destroy()
[all …]
|
| D | backchannel.c | 23 static void rpcrdma_bc_free_rqst(struct rpcrdma_xprt *r_xprt, in rpcrdma_bc_free_rqst() argument
26 struct rpcrdma_buffer *buf = &r_xprt->rx_buf; in rpcrdma_bc_free_rqst()
36 static int rpcrdma_bc_setup_reqs(struct rpcrdma_xprt *r_xprt, in rpcrdma_bc_setup_reqs() argument
39 struct rpc_xprt *xprt = &r_xprt->rx_xprt; in rpcrdma_bc_setup_reqs()
48 req = rpcrdma_create_req(r_xprt); in rpcrdma_bc_setup_reqs()
61 size = r_xprt->rx_data.inline_rsize; in rpcrdma_bc_setup_reqs()
72 rpcrdma_bc_free_rqst(r_xprt, rqst); in rpcrdma_bc_setup_reqs()
85 struct rpcrdma_xprt *r_xprt = rpcx_to_rdmax(xprt); in xprt_rdma_bc_setup() local
100 rc = rpcrdma_bc_setup_reqs(r_xprt, reqs); in xprt_rdma_bc_setup()
104 r_xprt->rx_buf.rb_bc_srv_max_requests = reqs; in xprt_rdma_bc_setup()
[all …]
|
| D | rpc_rdma.c | 110 void rpcrdma_set_max_header_sizes(struct rpcrdma_xprt *r_xprt) in rpcrdma_set_max_header_sizes() argument
112 struct rpcrdma_create_data_internal *cdata = &r_xprt->rx_data; in rpcrdma_set_max_header_sizes()
113 struct rpcrdma_ia *ia = &r_xprt->rx_ia; in rpcrdma_set_max_header_sizes()
130 static bool rpcrdma_args_inline(struct rpcrdma_xprt *r_xprt, in rpcrdma_args_inline() argument
136 if (xdr->len > r_xprt->rx_ia.ri_max_inline_write) in rpcrdma_args_inline()
147 if (++count > r_xprt->rx_ia.ri_max_send_sges) in rpcrdma_args_inline()
161 static bool rpcrdma_results_inline(struct rpcrdma_xprt *r_xprt, in rpcrdma_results_inline() argument
164 struct rpcrdma_ia *ia = &r_xprt->rx_ia; in rpcrdma_results_inline()
207 rpcrdma_convert_iovs(struct rpcrdma_xprt *r_xprt, struct xdr_buf *xdrbuf, in rpcrdma_convert_iovs() argument
244 if (type == rpcrdma_readch && r_xprt->rx_ia.ri_implicit_roundup) in rpcrdma_convert_iovs()
[all …]
|
| D | verbs.c | 77 static void rpcrdma_mrs_create(struct rpcrdma_xprt *r_xprt);
79 static int rpcrdma_create_rep(struct rpcrdma_xprt *r_xprt, bool temp);
115 struct rpcrdma_xprt *r_xprt = container_of(ep, struct rpcrdma_xprt, in rpcrdma_qp_async_error_upcall() local
118 trace_xprtrdma_qp_error(r_xprt, event); in rpcrdma_qp_async_error_upcall()
193 rpcrdma_update_connect_private(struct rpcrdma_xprt *r_xprt, in rpcrdma_update_connect_private() argument
196 struct rpcrdma_create_data_internal *cdata = &r_xprt->rx_data; in rpcrdma_update_connect_private()
201 r_xprt->rx_ia.ri_implicit_roundup = xprt_rdma_pad_optimize; in rpcrdma_update_connect_private()
208 r_xprt->rx_ia.ri_implicit_roundup = true; in rpcrdma_update_connect_private()
219 rpcrdma_set_max_header_sizes(r_xprt); in rpcrdma_update_connect_private()
430 struct rpcrdma_xprt *r_xprt = container_of(ia, struct rpcrdma_xprt, in rpcrdma_ia_remove() local
[all …]
|
| D | fmr_ops.c | 133 struct rpcrdma_xprt *r_xprt = mr->mr_xprt; in fmr_op_recover_mr() local
144 r_xprt->rx_stats.mrs_recovered++; in fmr_op_recover_mr()
149 r_xprt->rx_stats.mrs_orphaned++; in fmr_op_recover_mr()
152 ib_dma_unmap_sg(r_xprt->rx_ia.ri_device, in fmr_op_recover_mr()
155 spin_lock(&r_xprt->rx_buf.rb_mrlock); in fmr_op_recover_mr()
157 spin_unlock(&r_xprt->rx_buf.rb_mrlock); in fmr_op_recover_mr()
196 fmr_op_maxpages(struct rpcrdma_xprt *r_xprt) in fmr_op_maxpages() argument
206 fmr_op_map(struct rpcrdma_xprt *r_xprt, struct rpcrdma_mr_seg *seg, in fmr_op_map() argument
214 mr = rpcrdma_mr_get(r_xprt); in fmr_op_map()
243 mr->mr_nents = ib_dma_map_sg(r_xprt->rx_ia.ri_device, in fmr_op_map()
[all …]
|
| D | frwr_ops.c | 179 struct rpcrdma_xprt *r_xprt = mr->mr_xprt; in frwr_op_recover_mr() local
180 struct rpcrdma_ia *ia = &r_xprt->rx_ia; in frwr_op_recover_mr()
193 r_xprt->rx_stats.mrs_recovered++; in frwr_op_recover_mr()
198 r_xprt->rx_stats.mrs_orphaned++; in frwr_op_recover_mr()
200 spin_lock(&r_xprt->rx_buf.rb_mrlock); in frwr_op_recover_mr()
202 spin_unlock(&r_xprt->rx_buf.rb_mrlock); in frwr_op_recover_mr()
286 frwr_op_maxpages(struct rpcrdma_xprt *r_xprt) in frwr_op_maxpages() argument
288 struct rpcrdma_ia *ia = &r_xprt->rx_ia; in frwr_op_maxpages()
372 frwr_op_map(struct rpcrdma_xprt *r_xprt, struct rpcrdma_mr_seg *seg, in frwr_op_map() argument
375 struct rpcrdma_ia *ia = &r_xprt->rx_ia; in frwr_op_map()
[all …]
|
| D | xprt_rdma.h | 523 rpcrdma_addrstr(const struct rpcrdma_xprt *r_xprt) in rpcrdma_addrstr() argument
525 return r_xprt->rx_xprt.address_strings[RPC_DISPLAY_ADDR]; in rpcrdma_addrstr()
529 rpcrdma_portstr(const struct rpcrdma_xprt *r_xprt) in rpcrdma_portstr() argument
531 return r_xprt->rx_xprt.address_strings[RPC_DISPLAY_PORT]; in rpcrdma_portstr()
567 void rpcrdma_post_recvs(struct rpcrdma_xprt *r_xprt, bool temp);
578 struct rpcrdma_mr *rpcrdma_mr_get(struct rpcrdma_xprt *r_xprt);
631 int rpcrdma_prepare_send_sges(struct rpcrdma_xprt *r_xprt,
636 int rpcrdma_marshal_req(struct rpcrdma_xprt *r_xprt, struct rpc_rqst *rqst);
640 void rpcrdma_release_rqst(struct rpcrdma_xprt *r_xprt,
|
| D | svc_rdma_backchannel.c | 32 struct rpcrdma_xprt *r_xprt = rpcx_to_rdmax(xprt); in svc_rdma_handle_bc_reply() local
73 else if (credits > r_xprt->rx_buf.rb_bc_max_requests) in svc_rdma_handle_bc_reply()
74 credits = r_xprt->rx_buf.rb_bc_max_requests; in svc_rdma_handle_bc_reply()
178 struct rpcrdma_xprt *r_xprt = rpcx_to_rdmax(xprt); in rpcrdma_bc_send_request() local
190 *p++ = cpu_to_be32(r_xprt->rx_buf.rb_bc_max_requests); in rpcrdma_bc_send_request()
|
| /Linux-v4.19/include/trace/events/ |
| D | rpcrdma.h | 29 __field(const void *, r_xprt)
37 __entry->r_xprt = rep->rr_rxprt;
44 __entry->r_xprt, __entry->xid, __entry->rep,
58 const struct rpcrdma_xprt *r_xprt
61 TP_ARGS(r_xprt),
64 __field(const void *, r_xprt)
65 __string(addr, rpcrdma_addrstr(r_xprt))
66 __string(port, rpcrdma_portstr(r_xprt))
70 __entry->r_xprt = r_xprt;
71 __assign_str(addr, rpcrdma_addrstr(r_xprt));
[all …]
|
| /Linux-v4.19/net/sunrpc/ |
| D | rpcb_clnt.c | 118 struct rpc_xprt * r_xprt; member
158 rpcb_wake_rpcbind_waiters(map->r_xprt, map->r_status); in rpcb_map_release()
159 xprt_put(map->r_xprt); in rpcb_map_release()
766 map->r_xprt = xprt; in rpcb_getport_async()
811 struct rpc_xprt *xprt = map->r_xprt; in rpcb_getport_done()
|
