Home
last modified time | relevance | path

Searched refs:rq_xprt (Results 1 – 20 of 20) sorted by relevance

/Linux-v5.4/net/sunrpc/
Dxprt.c455 __xprt_put_cong(req->rq_xprt, req); in xprt_release_rqst_cong()
609 struct rpc_xprt *xprt = req->rq_xprt; in xprt_init_majortimeo()
626 struct rpc_xprt *xprt = req->rq_xprt; in xprt_adjust_timeout()
716 struct rpc_xprt *xprt = req->rq_xprt; in xprt_request_retransmit_after_disconnect()
819 struct rpc_xprt *xprt = task->tk_rqstp->rq_xprt; in xprt_connect()
1047 struct rpc_xprt *xprt = req->rq_xprt; in xprt_request_enqueue_receive()
1080 xprt_request_rb_remove(req->rq_xprt, req); in xprt_request_dequeue_receive_locked()
1114 struct rpc_xprt *xprt = req->rq_xprt; in xprt_complete_rqst()
1135 struct rpc_xprt *xprt = req->rq_xprt; in xprt_timer()
1161 rpc_sleep_on_timeout(&req->rq_xprt->pending, task, xprt_timer, in xprt_wait_for_reply_request_def()
[all …]
Dsvc_xprt.c362 struct svc_xprt *xprt = rqstp->rq_xprt; in svc_xprt_release_slot()
490 struct svc_xprt *xprt = rqstp->rq_xprt; in svc_reserve()
505 struct svc_xprt *xprt = rqstp->rq_xprt; in svc_xprt_release()
529 rqstp->rq_xprt = NULL; in svc_xprt_release()
705 WARN_ON_ONCE(rqstp->rq_xprt); in svc_get_next_xprt()
707 rqstp->rq_xprt = svc_xprt_dequeue(pool); in svc_get_next_xprt()
708 if (rqstp->rq_xprt) in svc_get_next_xprt()
730 rqstp->rq_xprt = svc_xprt_dequeue(pool); in svc_get_next_xprt()
731 if (rqstp->rq_xprt) in svc_get_next_xprt()
749 return rqstp->rq_xprt; in svc_get_next_xprt()
[all …]
Dbackchannel_rqst.c88 req->rq_xprt = xprt; in xprt_alloc_bc_req()
273 struct rpc_xprt *xprt = req->rq_xprt; in xprt_free_bc_request()
280 struct rpc_xprt *xprt = req->rq_xprt; in xprt_free_bc_rqst()
359 struct rpc_xprt *xprt = req->rq_xprt; in xprt_complete_bc_request()
Dsvc.c1251 if (versp->vs_need_cong_ctrl && rqstp->rq_xprt && in svc_generic_init_request()
1252 !test_bit(XPT_CONG_CTRL, &rqstp->rq_xprt->xpt_flags)) in svc_generic_init_request()
1432 if (rqstp->rq_xprt && test_bit(XPT_TEMP, &rqstp->rq_xprt->xpt_flags)) in svc_process_common()
1433 svc_close_xprt(rqstp->rq_xprt); in svc_process_common()
1563 rqstp->rq_prot = req->rq_xprt->prot; in bc_svc_process()
1565 rqstp->rq_bc_net = req->rq_xprt->xprt_net; in bc_svc_process()
1567 rqstp->rq_addrlen = sizeof(req->rq_xprt->addr); in bc_svc_process()
1568 memcpy(&rqstp->rq_addr, &req->rq_xprt->addr, rqstp->rq_addrlen); in bc_svc_process()
1598 atomic_dec(&req->rq_xprt->bc_slot_count); in bc_svc_process()
1629 u32 max = rqstp->rq_xprt->xpt_class->xcl_max_payload; in svc_max_payload()
Dsvcsock.c119 container_of(rqstp->rq_xprt, struct svc_sock, sk_xprt); in svc_release_skb()
149 container_of(rqstp->rq_xprt, struct svc_sock, sk_xprt); in svc_set_cmsg_data()
242 container_of(rqstp->rq_xprt, struct svc_sock, sk_xprt); in svc_sendto()
326 container_of(rqstp->rq_xprt, struct svc_sock, sk_xprt); in svc_recvfrom()
498 container_of(rqstp->rq_xprt, struct svc_sock, sk_xprt); in svc_udp_recvfrom()
1033 container_of(rqstp->rq_xprt, struct svc_sock, sk_xprt); in svc_tcp_recvfrom()
1152 rqstp->rq_xprt->xpt_server->sv_name, in svc_tcp_sendto()
1155 set_bit(XPT_CLOSE, &rqstp->rq_xprt->xpt_flags); in svc_tcp_sendto()
1156 svc_xprt_enqueue(rqstp->rq_xprt); in svc_tcp_sendto()
Dsvcauth_unix.c643 struct sunrpc_net *sn = net_generic(rqstp->rq_xprt->xpt_net, in unix_gid_find()
672 struct svc_xprt *xprt = rqstp->rq_xprt; in svcauth_unix_set_client()
821 userns = (rqstp->rq_xprt && rqstp->rq_xprt->xpt_cred) ? in svcauth_unix_accept()
822 rqstp->rq_xprt->xpt_cred->user_ns : &init_user_ns; in svcauth_unix_accept()
Dclnt.c1789 struct rpc_xprt *xprt = req->rq_xprt; in call_allocate()
1949 struct rpc_xprt *xprt = task->tk_rqstp->rq_xprt; in call_bind()
1976 struct rpc_xprt *xprt = task->tk_rqstp->rq_xprt; in call_bind_status()
2068 struct rpc_xprt *xprt = task->tk_rqstp->rq_xprt; in call_connect()
2102 struct rpc_xprt *xprt = task->tk_rqstp->rq_xprt; in call_connect_status()
2140 xprt_conditional_disconnect(task->tk_rqstp->rq_xprt, in call_connect_status()
2329 xprt_conditional_disconnect(req->rq_xprt, in call_bc_transmit_status()
2415 if (!req || !req->rq_xprt) in rpc_check_connected()
2417 return xprt_connected(req->rq_xprt); in rpc_check_connected()
2537 xprt_conditional_disconnect(req->rq_xprt, in call_decode()
Dxprtsock.c878 struct rpc_xprt *xprt = req->rq_xprt; in xs_nospace()
956 struct rpc_xprt *xprt = req->rq_xprt; in xs_local_send_request()
1025 struct rpc_xprt *xprt = req->rq_xprt; in xs_udp_send_request()
1104 struct rpc_xprt *xprt = req->rq_xprt; in xs_tcp_send_request()
2648 container_of(req->rq_xprt, struct sock_xprt, xprt); in bc_sendto()
2691 xprt = req->rq_xprt->bc_xprt; in bc_send_request()
Drpcb_clnt.c994 if (rpc_uaddr2sockaddr(req->rq_xprt->xprt_net, (char *)p, len, in rpcb_dec_getaddr()
/Linux-v5.4/include/trace/events/
Dsunrpc.h854 __string(addr, rqst->rq_xprt->xpt_remotebuf)
861 __assign_str(addr, rqst->rq_xprt->xpt_remotebuf);
879 __string(addr, rqst->rq_xprt ?
880 rqst->rq_xprt->xpt_remotebuf : "(null)")
888 __assign_str(addr, rqst->rq_xprt ?
889 rqst->rq_xprt->xpt_remotebuf : "(null)");
908 __string(addr, rqst->rq_xprt->xpt_remotebuf)
914 __assign_str(addr, rqst->rq_xprt->xpt_remotebuf);
941 __string(addr, rqst->rq_xprt->xpt_remotebuf)
948 __assign_str(addr, rqst->rq_xprt->xpt_remotebuf);
[all …]
Drpcrdma.h1563 __string(addr, rqst->rq_xprt->xpt_remotebuf)
1569 __entry->xprt = rqst->rq_xprt;
1570 __assign_str(addr, rqst->rq_xprt->xpt_remotebuf);
/Linux-v5.4/net/sunrpc/xprtrdma/
Dbackchannel.c62 struct rpcrdma_xprt *r_xprt = rpcx_to_rdmax(rqst->rq_xprt); in rpcrdma_bc_marshal_reply()
103 struct rpc_xprt *xprt = rqst->rq_xprt; in xprt_rdma_bc_send_reply()
158 struct rpc_xprt *xprt = rqst->rq_xprt; in xprt_rdma_bc_free_rqst()
200 rqst->rq_xprt = xprt; in rpcrdma_bc_rqst_get()
Dsvc_rdma_backchannel.c174 struct rpc_xprt *xprt = rqst->rq_xprt; in rpcrdma_bc_send_request()
216 struct svc_xprt *sxprt = rqst->rq_xprt->bc_xprt; in xprt_rdma_bc_send_request()
Dtransport.c621 struct rpcrdma_xprt *r_xprt = rpcx_to_rdmax(rqst->rq_xprt); in xprt_rdma_allocate()
656 struct rpcrdma_xprt *r_xprt = rpcx_to_rdmax(rqst->rq_xprt); in xprt_rdma_free()
690 struct rpc_xprt *xprt = rqst->rq_xprt; in xprt_rdma_send_request()
Dsvc_rdma_recvfrom.c752 struct svc_xprt *xprt = rqstp->rq_xprt; in svc_rdma_recvfrom()
Dsvc_rdma_sendto.c820 struct svc_xprt *xprt = rqstp->rq_xprt; in svc_rdma_sendto()
/Linux-v5.4/include/linux/sunrpc/
Dsvc.h232 struct svc_xprt * rq_xprt; /* transport ptr */ member
304 #define SVC_NET(rqst) (rqst->rq_xprt ? rqst->rq_xprt->xpt_net : rqst->rq_bc_net)
Dxprt.h69 struct rpc_xprt * rq_xprt; /* RPC client */ member
/Linux-v5.4/fs/nfsd/
Dnfsd.h130 const struct cred *cred = rqstp->rq_xprt->xpt_cred; in nfsd_user_namespace()
Dnfs4state.c1679 svc_xprt_get(rqstp->rq_xprt); in alloc_conn()
1680 conn->cn_xprt = rqstp->rq_xprt; in alloc_conn()