Home
last modified time | relevance | path

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

/linux/net/sunrpc/
H A Dxprt.c522 __xprt_put_cong(req->rq_xprt, req); in xprt_release_rqst_cong()
683 struct rpc_xprt *xprt = req->rq_xprt; in xprt_init_majortimeo()
702 struct rpc_xprt *xprt = req->rq_xprt; in xprt_adjust_timeout()
809 struct rpc_xprt *xprt = req->rq_xprt; in xprt_request_retransmit_after_disconnect()
925 struct rpc_xprt *xprt = task->tk_rqstp->rq_xprt; in xprt_connect()
1149 struct rpc_xprt *xprt = req->rq_xprt; in xprt_request_enqueue_receive()
1186 xprt_request_rb_remove(req->rq_xprt, req); in xprt_request_dequeue_receive_locked()
1220 struct rpc_xprt *xprt = req->rq_xprt; in xprt_complete_rqst()
1239 struct rpc_xprt *xprt = req->rq_xprt; in xprt_timer()
1265 rpc_sleep_on_timeout(&req->rq_xprt->pending, task, xprt_timer, in xprt_wait_for_reply_request_def()
[all …]
H A Dbackchannel_rqst.c101 req->rq_xprt = xprt; in xprt_alloc_bc_req()
284 struct rpc_xprt *xprt = req->rq_xprt; in xprt_free_bc_request()
291 struct rpc_xprt *xprt = req->rq_xprt; in xprt_free_bc_rqst()
371 struct rpc_xprt *xprt = req->rq_xprt; in xprt_complete_bc_request()
387 struct rpc_xprt *xprt = req->rq_xprt; in xprt_enqueue_bc_request()
H A Dsvc.c1363 if (versp->vs_need_cong_ctrl && rqstp->rq_xprt &&
1364 !test_bit(XPT_CONG_CTRL, &rqstp->rq_xprt->xpt_flags))
1523 if (rqstp->rq_xprt && test_bit(XPT_TEMP, &rqstp->rq_xprt->xpt_flags)) in svc_process_common()
1524 svc_xprt_close(rqstp->rq_xprt); in svc_process_common()
1616 svc_xprt_deferred_close(rqstp->rq_xprt); in svc_process()
1676 rqstp->rq_prot = req->rq_xprt->prot; in svc_process_bc()
1677 rqstp->rq_bc_net = req->rq_xprt->xprt_net; in svc_process_bc()
1679 rqstp->rq_addrlen = sizeof(req->rq_xprt->addr); in svc_process_bc()
1680 memcpy(&rqstp->rq_addr, &req->rq_xprt in svc_process_bc()
[all...]
H A Dsvc_xprt.c430 struct svc_xprt *xprt = rqstp->rq_xprt; in svc_xprt_release_slot()
523 struct svc_xprt *xprt = rqstp->rq_xprt; in svc_reserve()
547 struct svc_xprt *xprt = rqstp->rq_xprt; in svc_xprt_release()
572 rqstp->rq_xprt = NULL; in svc_xprt_release()
907 rqstp->rq_xprt = svc_xprt_dequeue(pool); in svc_send()
908 if (rqstp->rq_xprt) { in svc_send()
909 struct svc_xprt *xprt = rqstp->rq_xprt; in svc_send()
965 xprt = rqstp->rq_xprt;
1279 svc_xprt_get(rqstp->rq_xprt);
1280 dr->xprt = rqstp->rq_xprt;
[all...]
H A Dsvcsock.c170 container_of(rqstp->rq_xprt, struct svc_sock, sk_xprt); in svc_set_cmsg_data()
343 container_of(rqstp->rq_xprt, struct svc_sock, sk_xprt); in svc_tcp_read_msg()
601 container_of(rqstp->rq_xprt, struct svc_sock, sk_xprt); in svc_udp_recvfrom()
686 svc_xprt_received(rqstp->rq_xprt); in svc_udp_recvfrom()
705 svc_xprt_received(rqstp->rq_xprt); in svc_udp_recvfrom()
720 struct svc_xprt *xprt = rqstp->rq_xprt;
1143 container_of(rqstp->rq_xprt, struct svc_sock, sk_xprt);
1200 svc_xprt_received(rqstp->rq_xprt); in svc_tcp_recvfrom()
1225 svc_xprt_received(rqstp->rq_xprt); in svc_tcp_recvfrom()
1275 struct svc_xprt *xprt = rqstp->rq_xprt;
[all...]
H A Dsvcauth_unix.c647 struct sunrpc_net *sn = net_generic(rqstp->rq_xprt->xpt_net, in unix_gid_find()
676 struct svc_xprt *xprt = rqstp->rq_xprt; in svcauth_unix_set_client()
836 struct svc_xprt *xprt = rqstp->rq_xprt; in svcauth_tls_accept()
947 userns = (rqstp->rq_xprt && rqstp->rq_xprt->xpt_cred) ? in svcauth_unix_accept()
948 rqstp->rq_xprt->xpt_cred->user_ns : &init_user_ns; in svcauth_unix_accept()
H A Dclnt.c1883 struct rpc_xprt *xprt = req->rq_xprt; in call_allocate()
2031 struct rpc_xprt *xprt = task->tk_rqstp->rq_xprt; in call_bind()
2056 struct rpc_xprt *xprt = task->tk_rqstp->rq_xprt; in call_bind_status()
2139 struct rpc_xprt *xprt = task->tk_rqstp->rq_xprt; in call_connect()
2169 struct rpc_xprt *xprt = task->tk_rqstp->rq_xprt; in call_connect_status()
2210 xprt_conditional_disconnect(task->tk_rqstp->rq_xprt, in call_connect_status()
2421 xprt_conditional_disconnect(req->rq_xprt, in call_bc_transmit_status()
2513 if (!req || !req->rq_xprt) in rpc_check_connected()
2515 return xprt_connected(req->rq_xprt); in rpc_check_connected()
2635 xprt_conditional_disconnect(req->rq_xprt, in call_decode()
H A Dxprtsock.c874 container_of(req->rq_xprt, struct sock_xprt, xprt); in xs_sock_nospace()
888 container_of(req->rq_xprt, struct sock_xprt, xprt); in xs_stream_nospace()
908 struct rpc_xprt *xprt = req->rq_xprt; in xs_stream_abort_send_request()
951 struct rpc_xprt *xprt = req->rq_xprt; in xs_local_send_request()
1022 struct rpc_xprt *xprt = req->rq_xprt; in xs_udp_send_request()
1108 struct rpc_xprt *xprt = req->rq_xprt; in xs_tcp_send_request()
2986 container_of(req->rq_xprt, struct sock_xprt, xprt); in bc_sendto()
3025 xprt = req->rq_xprt->bc_xprt; in bc_send_request()
H A Drpcb_clnt.c943 if (rpc_uaddr2sockaddr(req->rq_xprt->xprt_net, (char *)p, len, in rpcb_dec_getaddr()
/linux/net/sunrpc/xprtrdma/
H A Dbackchannel.c59 struct rpcrdma_xprt *r_xprt = rpcx_to_rdmax(rqst->rq_xprt); in rpcrdma_bc_marshal_reply()
100 struct rpc_xprt *xprt = rqst->rq_xprt; in xprt_rdma_bc_send_reply()
156 struct rpc_xprt *xprt = rqst->rq_xprt; in xprt_rdma_bc_free_rqst()
203 rqst->rq_xprt = xprt; in rpcrdma_bc_rqst_get()
H A Dsvc_rdma_backchannel.c22 struct svc_xprt *sxprt = rqstp->rq_xprt; in svc_rdma_handle_bc_reply()
138 struct rpc_xprt *xprt = rqst->rq_xprt; in rpcrdma_bc_send_request()
182 struct svc_xprt *sxprt = rqst->rq_xprt->bc_xprt; in xprt_rdma_bc_send_request()
H A Dtransport.c574 struct rpcrdma_xprt *r_xprt = rpcx_to_rdmax(rqst->rq_xprt); in xprt_rdma_allocate()
607 frwr_unmap_sync(rpcx_to_rdmax(rqst->rq_xprt), req); in xprt_rdma_free()
636 struct rpc_xprt *xprt = rqst->rq_xprt; in xprt_rdma_send_request()
H A Dsvc_rdma_sendto.c1087 struct svc_xprt *xprt = rqstp->rq_xprt; in svc_rdma_result_payload()
/linux/include/trace/events/
H A Drpcgss.h186 __string(addr, rqstp->rq_xprt->xpt_remotebuf)
223 __string(addr, rqstp->rq_xprt->xpt_remotebuf)
243 __string(addr, rqstp->rq_xprt->xpt_remotebuf)
267 __string(addr, rqstp->rq_xprt->xpt_remotebuf)
295 __string(addr, rqstp->rq_xprt->xpt_remotebuf)
324 __string(addr, rqstp->rq_xprt->xpt_remotebuf)
H A Drpcrdma.h1982 __string(addr, rqst->rq_xprt->xpt_remotebuf)
/linux/fs/nfsd/
H A Dtrace.h25 __sockaddr(server, (r)->rq_xprt->xpt_locallen) \
26 __sockaddr(client, (r)->rq_xprt->xpt_remotelen)
30 struct svc_xprt *xprt = (r)->rq_xprt; \
43 __sockaddr(server, (r)->rq_xprt->xpt_locallen) \
44 __sockaddr(client, (r)->rq_xprt->xpt_remotelen)
48 struct svc_xprt *xprt = (r)->rq_xprt; \
68 __sockaddr(server, rqstp->rq_xprt->xpt_locallen)
69 __sockaddr(client, rqstp->rq_xprt->xpt_remotelen)
72 const struct svc_xprt *xprt = rqstp->rq_xprt;
274 __sockaddr(server, rqstp->rq_xprt->xpt_remotelen)
[all …]
H A Dexport.c1114 struct svc_xprt *xprt = rqstp->rq_xprt; in check_xprtsec_policy()
H A Dnfs4state.c2124 svc_xprt_get(rqstp->rq_xprt); in alloc_conn()
2125 conn->cn_xprt = rqstp->rq_xprt; in alloc_conn()
4172 struct svc_xprt *xpt = rqst->rq_xprt; in nfsd4_match_existing_connection()
/linux/include/linux/sunrpc/
H A Dxprt.h60 struct rpc_xprt * rq_xprt; /* RPC client */ member
/linux/fs/nfs/
H A Dcallback_xdr.c965 svc_xprt_set_valid(rqstp->rq_xprt); in nfs4_callback_compound()