| /Linux-v5.4/net/sunrpc/xprtrdma/ |
| D | verbs.c | 79 static void rpcrdma_mrs_create(struct rpcrdma_xprt *r_xprt);
87 static void rpcrdma_post_recvs(struct rpcrdma_xprt *r_xprt, bool temp);
93 static void rpcrdma_xprt_drain(struct rpcrdma_xprt *r_xprt) in rpcrdma_xprt_drain() argument
95 struct rpcrdma_ia *ia = &r_xprt->rx_ia; in rpcrdma_xprt_drain()
120 struct rpcrdma_xprt *r_xprt = container_of(ep, struct rpcrdma_xprt, in rpcrdma_qp_event_handler() local
123 trace_xprtrdma_qp_event(r_xprt, event); in rpcrdma_qp_event_handler()
156 struct rpcrdma_xprt *r_xprt = rep->rr_rxprt; in rpcrdma_wc_receive() local
160 --r_xprt->rx_ep.rep_receive_count; in rpcrdma_wc_receive()
173 rpcrdma_post_recvs(r_xprt, false); in rpcrdma_wc_receive()
182 rpcrdma_update_connect_private(struct rpcrdma_xprt *r_xprt, in rpcrdma_update_connect_private() argument
[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_ep_connect(&r_xprt->rx_ep, &r_xprt->rx_ia); in xprt_rdma_connect_worker()
245 if (r_xprt->rx_ep.rep_connected > 0) { in xprt_rdma_connect_worker()
268 struct rpcrdma_xprt *r_xprt = rpcx_to_rdmax(xprt); in xprt_rdma_inject_disconnect() local
270 trace_xprtrdma_op_inject_dsc(r_xprt); in xprt_rdma_inject_disconnect()
271 rdma_disconnect(r_xprt->rx_ia.ri_id); in xprt_rdma_inject_disconnect()
284 struct rpcrdma_xprt *r_xprt = rpcx_to_rdmax(xprt); in xprt_rdma_destroy() local
286 trace_xprtrdma_op_destroy(r_xprt); in xprt_rdma_destroy()
288 cancel_delayed_work_sync(&r_xprt->rx_connect_worker); in xprt_rdma_destroy()
[all …]
|
| D | rpc_rdma.c | 116 void rpcrdma_set_max_header_sizes(struct rpcrdma_xprt *r_xprt) in rpcrdma_set_max_header_sizes() argument
118 unsigned int maxsegs = r_xprt->rx_ia.ri_max_segs; in rpcrdma_set_max_header_sizes()
119 struct rpcrdma_ep *ep = &r_xprt->rx_ep; in rpcrdma_set_max_header_sizes()
135 static bool rpcrdma_args_inline(struct rpcrdma_xprt *r_xprt, in rpcrdma_args_inline() argument
141 if (xdr->len > r_xprt->rx_ep.rep_max_inline_send) in rpcrdma_args_inline()
152 if (++count > r_xprt->rx_ia.ri_max_send_sges) in rpcrdma_args_inline()
166 static bool rpcrdma_results_inline(struct rpcrdma_xprt *r_xprt, in rpcrdma_results_inline() argument
169 return rqst->rq_rcv_buf.buflen <= r_xprt->rx_ep.rep_max_inline_recv; in rpcrdma_results_inline()
177 rpcrdma_nonpayload_inline(const struct rpcrdma_xprt *r_xprt, in rpcrdma_nonpayload_inline() argument
183 r_xprt->rx_ep.rep_max_inline_recv; in rpcrdma_nonpayload_inline()
[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_ep_post(&r_xprt->rx_ia, &r_xprt->rx_ep, req)) in xprt_rdma_bc_send_reply()
[all …]
|
| D | xprt_rdma.h | 439 rpcrdma_addrstr(const struct rpcrdma_xprt *r_xprt) in rpcrdma_addrstr() argument
441 return r_xprt->rx_xprt.address_strings[RPC_DISPLAY_ADDR]; in rpcrdma_addrstr()
445 rpcrdma_portstr(const struct rpcrdma_xprt *r_xprt) in rpcrdma_portstr() argument
447 return r_xprt->rx_xprt.address_strings[RPC_DISPLAY_PORT]; in rpcrdma_portstr()
470 int rpcrdma_ep_create(struct rpcrdma_xprt *r_xprt);
471 void rpcrdma_ep_destroy(struct rpcrdma_xprt *r_xprt);
481 struct rpcrdma_req *rpcrdma_req_create(struct rpcrdma_xprt *r_xprt, size_t size,
486 struct rpcrdma_sendctx *rpcrdma_sendctx_get_locked(struct rpcrdma_xprt *r_xprt);
488 struct rpcrdma_mr *rpcrdma_mr_get(struct rpcrdma_xprt *r_xprt);
504 bool __rpcrdma_regbuf_dma_map(struct rpcrdma_xprt *r_xprt,
[all …]
|
| D | frwr_ops.c | 91 static void frwr_mr_recycle(struct rpcrdma_xprt *r_xprt, struct rpcrdma_mr *mr) in frwr_mr_recycle() argument
97 ib_dma_unmap_sg(r_xprt->rx_ia.ri_id->device, in frwr_mr_recycle()
102 spin_lock(&r_xprt->rx_buf.rb_lock); in frwr_mr_recycle()
104 r_xprt->rx_stats.mrs_recycled++; in frwr_mr_recycle()
105 spin_unlock(&r_xprt->rx_buf.rb_lock); in frwr_mr_recycle()
299 size_t frwr_maxpages(struct rpcrdma_xprt *r_xprt) in frwr_maxpages() argument
301 struct rpcrdma_ia *ia = &r_xprt->rx_ia; in frwr_maxpages()
322 struct rpcrdma_mr_seg *frwr_map(struct rpcrdma_xprt *r_xprt, in frwr_map() argument
327 struct rpcrdma_ia *ia = &r_xprt->rx_ia; in frwr_map()
525 void frwr_unmap_sync(struct rpcrdma_xprt *r_xprt, struct rpcrdma_req *req) in frwr_unmap_sync() argument
[all …]
|
| D | svc_rdma_backchannel.c | 30 struct rpcrdma_xprt *r_xprt = rpcx_to_rdmax(xprt); in svc_rdma_handle_bc_reply() local
72 else if (credits > r_xprt->rx_buf.rb_bc_max_requests) in svc_rdma_handle_bc_reply()
73 credits = r_xprt->rx_buf.rb_bc_max_requests; in svc_rdma_handle_bc_reply()
175 struct rpcrdma_xprt *r_xprt = rpcx_to_rdmax(xprt); in rpcrdma_bc_send_request() local
187 *p++ = cpu_to_be32(r_xprt->rx_buf.rb_bc_max_requests); in rpcrdma_bc_send_request()
|
| /Linux-v5.4/include/trace/events/ |
| D | rpcrdma.h | 30 __field(const void *, r_xprt)
38 __entry->r_xprt = rep->rr_rxprt;
45 __entry->r_xprt, __entry->xid, __entry->rep,
59 const struct rpcrdma_xprt *r_xprt
62 TP_ARGS(r_xprt),
65 __field(const void *, r_xprt)
66 __string(addr, rpcrdma_addrstr(r_xprt))
67 __string(port, rpcrdma_portstr(r_xprt))
71 __entry->r_xprt = r_xprt;
72 __assign_str(addr, rpcrdma_addrstr(r_xprt));
[all …]
|
| /Linux-v5.4/net/sunrpc/ |
| D | rpcb_clnt.c | 119 struct rpc_xprt * r_xprt; member
159 rpcb_wake_rpcbind_waiters(map->r_xprt, map->r_status); in rpcb_map_release()
160 xprt_put(map->r_xprt); in rpcb_map_release()
773 map->r_xprt = xprt; in rpcb_getport_async()
826 struct rpc_xprt *xprt = map->r_xprt; in rpcb_getport_done()
|
