/linux/net/sunrpc/ |
H A D | xprt.c | 522 __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 D | svc.c | 1292 if (versp->vs_need_cong_ctrl && rqstp->rq_xprt && in svc_generic_init_request() 1293 !test_bit(XPT_CONG_CTRL, &rqstp->rq_xprt->xpt_flags)) in svc_generic_init_request() 1451 if (rqstp->rq_xprt && test_bit(XPT_TEMP, &rqstp->rq_xprt->xpt_flags)) in svc_process_common() 1452 svc_xprt_close(rqstp->rq_xprt); in svc_process_common() 1542 svc_xprt_deferred_close(rqstp->rq_xprt); in svc_process() 1599 rqstp->rq_prot = req->rq_xprt->prot; in svc_process_bc() 1600 rqstp->rq_bc_net = req->rq_xprt->xprt_net; in svc_process_bc() 1602 rqstp->rq_addrlen = sizeof(req->rq_xprt->addr); in svc_process_bc() 1603 memcpy(&rqstp->rq_addr, &req->rq_xprt->addr, rqstp->rq_addrlen); in svc_process_bc() 1634 atomic_dec(&req->rq_xprt->bc_slot_count); in svc_process_bc() [all …]
|
H A D | backchannel_rqst.c | 85 req->rq_xprt = xprt; in xprt_alloc_bc_req() 269 struct rpc_xprt *xprt = req->rq_xprt; in xprt_free_bc_request() 276 struct rpc_xprt *xprt = req->rq_xprt; in xprt_free_bc_rqst() 356 struct rpc_xprt *xprt = req->rq_xprt; in xprt_complete_bc_request()
|
H A D | svc_xprt.c | 430 struct svc_xprt *xprt = rqstp->rq_xprt; in svc_xprt_release_slot() 522 struct svc_xprt *xprt = rqstp->rq_xprt; in svc_reserve() 546 struct svc_xprt *xprt = rqstp->rq_xprt; in svc_xprt_release() 571 rqstp->rq_xprt = NULL; in svc_xprt_release() 874 rqstp->rq_xprt = svc_xprt_dequeue(pool); in svc_recv() 875 if (rqstp->rq_xprt) { in svc_recv() 876 struct svc_xprt *xprt = rqstp->rq_xprt; in svc_recv() 928 xprt = rqstp->rq_xprt; in svc_send() 1223 svc_xprt_get(rqstp->rq_xprt); in svc_defer() 1224 dr->xprt = rqstp->rq_xprt; in svc_defer() [all …]
|
H A D | svcsock.c | 159 container_of(rqstp->rq_xprt, struct svc_sock, sk_xprt); in svc_set_cmsg_data() 305 container_of(rqstp->rq_xprt, struct svc_sock, sk_xprt); in svc_tcp_read_msg() 565 container_of(rqstp->rq_xprt, struct svc_sock, sk_xprt); in svc_udp_recvfrom() 654 svc_xprt_received(rqstp->rq_xprt); in svc_udp_recvfrom() 673 svc_xprt_received(rqstp->rq_xprt); in svc_udp_recvfrom() 688 struct svc_xprt *xprt = rqstp->rq_xprt; in svc_udp_sendto() 1112 container_of(rqstp->rq_xprt, struct svc_sock, sk_xprt); in svc_tcp_recvfrom() 1169 svc_xprt_received(rqstp->rq_xprt); in svc_tcp_recvfrom() 1201 svc_xprt_received(rqstp->rq_xprt); in svc_tcp_recvfrom() 1256 struct svc_xprt *xprt = rqstp->rq_xprt; in svc_tcp_sendto()
|
H A D | svcauth_unix.c | 647 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() 835 struct svc_xprt *xprt = rqstp->rq_xprt; in svcauth_tls_accept() 946 userns = (rqstp->rq_xprt && rqstp->rq_xprt->xpt_cred) ? in svcauth_unix_accept() 947 rqstp->rq_xprt->xpt_cred->user_ns : &init_user_ns; in svcauth_unix_accept()
|
H A D | clnt.c | 1886 struct rpc_xprt *xprt = req->rq_xprt; in call_allocate() 2040 struct rpc_xprt *xprt = task->tk_rqstp->rq_xprt; in call_bind() 2065 struct rpc_xprt *xprt = task->tk_rqstp->rq_xprt; in call_bind_status() 2145 struct rpc_xprt *xprt = task->tk_rqstp->rq_xprt; in call_connect() 2175 struct rpc_xprt *xprt = task->tk_rqstp->rq_xprt; in call_connect_status() 2213 xprt_conditional_disconnect(task->tk_rqstp->rq_xprt, in call_connect_status() 2424 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 D | xprtsock.c | 854 container_of(req->rq_xprt, struct sock_xprt, xprt); in xs_sock_nospace() 868 container_of(req->rq_xprt, struct sock_xprt, xprt); in xs_stream_nospace() 888 struct rpc_xprt *xprt = req->rq_xprt; in xs_stream_abort_send_request() 931 struct rpc_xprt *xprt = req->rq_xprt; in xs_local_send_request() 1002 struct rpc_xprt *xprt = req->rq_xprt; in xs_udp_send_request() 1088 struct rpc_xprt *xprt = req->rq_xprt; in xs_tcp_send_request() 2958 container_of(req->rq_xprt, struct sock_xprt, xprt); in bc_sendto() 2997 xprt = req->rq_xprt->bc_xprt; in bc_send_request()
|
H A D | rpcb_clnt.c | 942 if (rpc_uaddr2sockaddr(req->rq_xprt->xprt_net, (char *)p, len, in rpcb_dec_getaddr()
|
/linux/net/sunrpc/xprtrdma/ |
H A D | backchannel.c | 58 struct rpcrdma_xprt *r_xprt = rpcx_to_rdmax(rqst->rq_xprt); in rpcrdma_bc_marshal_reply() 99 struct rpc_xprt *xprt = rqst->rq_xprt; in xprt_rdma_bc_send_reply() 155 struct rpc_xprt *xprt = rqst->rq_xprt; in xprt_rdma_bc_free_rqst() 202 rqst->rq_xprt = xprt; in rpcrdma_bc_rqst_get()
|
H A D | svc_rdma_backchannel.c | 22 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 D | transport.c | 561 struct rpcrdma_xprt *r_xprt = rpcx_to_rdmax(rqst->rq_xprt); in xprt_rdma_allocate() 594 frwr_unmap_sync(rpcx_to_rdmax(rqst->rq_xprt), req); in xprt_rdma_free() 623 struct rpc_xprt *xprt = rqst->rq_xprt; in xprt_rdma_send_request()
|
H A D | svc_rdma_recvfrom.c | 918 struct svc_xprt *xprt = rqstp->rq_xprt; in svc_rdma_recvfrom()
|
H A D | svc_rdma_sendto.c | 991 struct svc_xprt *xprt = rqstp->rq_xprt; in svc_rdma_sendto()
|
/linux/fs/nfsd/ |
H A D | trace.h | 33 memcpy(__entry->server, &rqstp->rq_xprt->xpt_local, \ 34 rqstp->rq_xprt->xpt_locallen); \ 35 memcpy(__entry->client, &rqstp->rq_xprt->xpt_remote, \ 36 rqstp->rq_xprt->xpt_remotelen); \ 49 __sockaddr(server, rqstp->rq_xprt->xpt_locallen) 50 __sockaddr(client, rqstp->rq_xprt->xpt_remotelen) 53 const struct svc_xprt *xprt = rqstp->rq_xprt; 206 __sockaddr(server, rqstp->rq_xprt->xpt_remotelen) 207 __sockaddr(client, rqstp->rq_xprt->xpt_remotelen) 216 __assign_sockaddr(server, &rqstp->rq_xprt [all...] |
H A D | nfsd.h | 164 const struct cred *cred = rqstp->rq_xprt->xpt_cred; in nfsd_user_namespace()
|
H A D | export.c | 1080 struct svc_xprt *xprt = rqstp->rq_xprt; in check_nfsd_access()
|
H A D | nfs4state.c | 2025 svc_xprt_get(rqstp->rq_xprt); in alloc_conn() 2026 conn->cn_xprt = rqstp->rq_xprt; in alloc_conn() 3980 struct svc_xprt *xpt = rqst->rq_xprt; in nfsd4_match_existing_connection()
|
/linux/include/trace/events/ |
H A D | rpcgss.h | 186 __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 D | sunrpc.h | 1720 __sockaddr(server, (r)->rq_xprt->xpt_locallen) \ 1721 __sockaddr(client, (r)->rq_xprt->xpt_remotelen) \ 1727 struct svc_xprt *xprt = (r)->rq_xprt; \ 1784 __string(addr, rqst->rq_xprt ? 1785 rqst->rq_xprt->xpt_remotebuf : EVENT_NULL_STR) 2042 SVC_XPRT_ENDPOINT_FIELDS(rqst->rq_xprt) 2048 SVC_XPRT_ENDPOINT_ASSIGNMENTS(rqst->rq_xprt);
|
H A D | rpcrdma.h | 1982 __string(addr, rqst->rq_xprt->xpt_remotebuf)
|
/linux/include/linux/sunrpc/ |
H A D | svc.h | 172 struct svc_xprt * rq_xprt; /* transport ptr */ member 251 #define SVC_NET(rqst) (rqst->rq_xprt ? rqst->rq_xprt->xpt_net : rqst->rq_bc_net)
|
H A D | svc_rdma.h | 122 struct svc_xprt *xprt = rqstp->rq_xprt; in svc_rdma_rqst_rdma()
|
H A D | xprt.h | 58 struct rpc_xprt * rq_xprt; /* RPC client */ member
|