Home
last modified time | relevance | path

Searched refs:r_xprt (Results 1 – 9 of 9) sorted by relevance

/linux-6.6.21/net/sunrpc/xprtrdma/
Dverbs.c66 static int rpcrdma_sendctxs_create(struct rpcrdma_xprt *r_xprt);
67 static void rpcrdma_sendctxs_destroy(struct rpcrdma_xprt *r_xprt);
68 static void rpcrdma_sendctx_put_locked(struct rpcrdma_xprt *r_xprt,
70 static int rpcrdma_reqs_setup(struct rpcrdma_xprt *r_xprt);
71 static void rpcrdma_reqs_reset(struct rpcrdma_xprt *r_xprt);
73 static void rpcrdma_reps_unmap(struct rpcrdma_xprt *r_xprt);
74 static void rpcrdma_mrs_create(struct rpcrdma_xprt *r_xprt);
75 static void rpcrdma_mrs_destroy(struct rpcrdma_xprt *r_xprt);
87 static void rpcrdma_xprt_drain(struct rpcrdma_xprt *r_xprt) in rpcrdma_xprt_drain() argument
89 struct rpcrdma_ep *ep = r_xprt->rx_ep; in rpcrdma_xprt_drain()
[all …]
Dtransport.c226 struct rpcrdma_xprt *r_xprt = container_of(work, struct rpcrdma_xprt, in xprt_rdma_connect_worker() local
228 struct rpc_xprt *xprt = &r_xprt->rx_xprt; in xprt_rdma_connect_worker()
234 rc = rpcrdma_xprt_connect(r_xprt); in xprt_rdma_connect_worker()
244 rpcrdma_xprt_disconnect(r_xprt); in xprt_rdma_connect_worker()
245 xprt_unlock_connect(xprt, r_xprt); in xprt_rdma_connect_worker()
262 struct rpcrdma_xprt *r_xprt = rpcx_to_rdmax(xprt); in xprt_rdma_inject_disconnect() local
264 trace_xprtrdma_op_inject_dsc(r_xprt); in xprt_rdma_inject_disconnect()
265 rdma_disconnect(r_xprt->rx_ep->re_id); in xprt_rdma_inject_disconnect()
278 struct rpcrdma_xprt *r_xprt = rpcx_to_rdmax(xprt); in xprt_rdma_destroy() local
280 cancel_delayed_work_sync(&r_xprt->rx_connect_worker); in xprt_rdma_destroy()
[all …]
Drpc_rdma.c126 static bool rpcrdma_args_inline(struct rpcrdma_xprt *r_xprt, in rpcrdma_args_inline() argument
130 struct rpcrdma_ep *ep = r_xprt->rx_ep; in rpcrdma_args_inline()
158 static bool rpcrdma_results_inline(struct rpcrdma_xprt *r_xprt, in rpcrdma_results_inline() argument
161 return rqst->rq_rcv_buf.buflen <= r_xprt->rx_ep->re_max_inline_recv; in rpcrdma_results_inline()
169 rpcrdma_nonpayload_inline(const struct rpcrdma_xprt *r_xprt, in rpcrdma_nonpayload_inline() argument
175 r_xprt->rx_ep->re_max_inline_recv; in rpcrdma_nonpayload_inline()
228 rpcrdma_convert_iovs(struct rpcrdma_xprt *r_xprt, struct xdr_buf *xdrbuf, in rpcrdma_convert_iovs() argument
295 static struct rpcrdma_mr_seg *rpcrdma_mr_prepare(struct rpcrdma_xprt *r_xprt, in rpcrdma_mr_prepare() argument
303 *mr = rpcrdma_mr_get(r_xprt); in rpcrdma_mr_prepare()
310 return frwr_map(r_xprt, seg, nsegs, writing, req->rl_slot.rq_xid, *mr); in rpcrdma_mr_prepare()
[all …]
Dbackchannel.c27 struct rpcrdma_xprt *r_xprt = rpcx_to_rdmax(xprt); in xprt_rdma_bc_setup() local
29 r_xprt->rx_buf.rb_bc_srv_max_requests = RPCRDMA_BACKWARD_WRS >> 1; in xprt_rdma_bc_setup()
30 trace_xprtrdma_cb_setup(r_xprt, reqs); in xprt_rdma_bc_setup()
42 struct rpcrdma_xprt *r_xprt = rpcx_to_rdmax(xprt); in xprt_rdma_bc_maxpayload() local
43 struct rpcrdma_ep *ep = r_xprt->rx_ep; in xprt_rdma_bc_maxpayload()
58 struct rpcrdma_xprt *r_xprt = rpcx_to_rdmax(rqst->rq_xprt); in rpcrdma_bc_marshal_reply() local
71 *p++ = cpu_to_be32(r_xprt->rx_buf.rb_bc_srv_max_requests); in rpcrdma_bc_marshal_reply()
77 if (rpcrdma_prepare_send_sges(r_xprt, req, RPCRDMA_HDRLEN_MIN, in rpcrdma_bc_marshal_reply()
81 trace_xprtrdma_cb_reply(r_xprt, rqst); in rpcrdma_bc_marshal_reply()
100 struct rpcrdma_xprt *r_xprt = rpcx_to_rdmax(xprt); in xprt_rdma_bc_send_reply() local
[all …]
Dxprt_rdma.h440 rpcrdma_addrstr(const struct rpcrdma_xprt *r_xprt) in rpcrdma_addrstr() argument
442 return r_xprt->rx_xprt.address_strings[RPC_DISPLAY_ADDR]; in rpcrdma_addrstr()
446 rpcrdma_portstr(const struct rpcrdma_xprt *r_xprt) in rpcrdma_portstr() argument
448 return r_xprt->rx_xprt.address_strings[RPC_DISPLAY_PORT]; in rpcrdma_portstr()
465 void rpcrdma_flush_disconnect(struct rpcrdma_xprt *r_xprt, struct ib_wc *wc);
466 int rpcrdma_xprt_connect(struct rpcrdma_xprt *r_xprt);
467 void rpcrdma_xprt_disconnect(struct rpcrdma_xprt *r_xprt);
469 void rpcrdma_post_recvs(struct rpcrdma_xprt *r_xprt, int needed, bool temp);
474 struct rpcrdma_req *rpcrdma_req_create(struct rpcrdma_xprt *r_xprt,
476 int rpcrdma_req_setup(struct rpcrdma_xprt *r_xprt, struct rpcrdma_req *req);
[all …]
Dfrwr_ops.c57 static void frwr_mr_unmap(struct rpcrdma_xprt *r_xprt, struct rpcrdma_mr *mr) in frwr_mr_unmap() argument
121 int frwr_mr_init(struct rpcrdma_xprt *r_xprt, struct rpcrdma_mr *mr) in frwr_mr_init() argument
123 struct rpcrdma_ep *ep = r_xprt->rx_ep; in frwr_mr_init()
137 mr->mr_xprt = r_xprt; in frwr_mr_init()
284 struct rpcrdma_mr_seg *frwr_map(struct rpcrdma_xprt *r_xprt, in frwr_map() argument
289 struct rpcrdma_ep *ep = r_xprt->rx_ep; in frwr_map()
383 int frwr_send(struct rpcrdma_xprt *r_xprt, struct rpcrdma_req *req) in frwr_send() argument
386 struct rpcrdma_ep *ep = r_xprt->rx_ep; in frwr_send()
418 trace_xprtrdma_post_send_err(r_xprt, req, ret); in frwr_send()
496 void frwr_unmap_sync(struct rpcrdma_xprt *r_xprt, struct rpcrdma_req *req) in frwr_unmap_sync() argument
[all …]
Dsvc_rdma_backchannel.c24 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()
142 struct rpcrdma_xprt *r_xprt = rpcx_to_rdmax(xprt); in rpcrdma_bc_send_request() local
156 *p++ = cpu_to_be32(r_xprt->rx_buf.rb_bc_max_requests); in rpcrdma_bc_send_request()
/linux-6.6.21/include/trace/events/
Drpcrdma.h328 const struct rpcrdma_xprt *r_xprt
331 TP_ARGS(r_xprt),
334 __string(addr, rpcrdma_addrstr(r_xprt))
335 __string(port, rpcrdma_portstr(r_xprt))
339 __assign_str(addr, rpcrdma_addrstr(r_xprt));
340 __assign_str(port, rpcrdma_portstr(r_xprt));
351 const struct rpcrdma_xprt *r_xprt \
353 TP_ARGS(r_xprt))
357 const struct rpcrdma_xprt *r_xprt,
361 TP_ARGS(r_xprt, rc),
[all …]
/linux-6.6.21/net/sunrpc/
Drpcb_clnt.c118 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()
749 map->r_xprt = xprt; in rpcb_getport_async()
798 struct rpc_xprt *xprt = map->r_xprt; in rpcb_getport_done()