Home
last modified time | relevance | path

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

/Linux-v4.19/net/sunrpc/xprtrdma/
Dbackchannel.c53 rqst->rq_xprt = xprt; in rpcrdma_bc_setup_reqs()
156 struct rpcrdma_xprt *r_xprt = rpcx_to_rdmax(rqst->rq_xprt); in rpcrdma_bc_marshal_reply()
197 struct rpcrdma_xprt *r_xprt = rpcx_to_rdmax(rqst->rq_xprt); in xprt_rdma_bc_send_reply()
201 if (!xprt_connected(rqst->rq_xprt)) in xprt_rdma_bc_send_reply()
217 xprt_disconnect_done(rqst->rq_xprt); in xprt_rdma_bc_send_reply()
250 struct rpc_xprt *xprt = rqst->rq_xprt; in xprt_rdma_bc_free_rqst()
Dsvc_rdma_backchannel.c177 struct rpc_xprt *xprt = rqst->rq_xprt; in rpcrdma_bc_send_request()
221 struct svc_xprt *sxprt = rqst->rq_xprt->bc_xprt; in xprt_rdma_bc_send_request()
Dtransport.c653 struct rpcrdma_xprt *r_xprt = rpcx_to_rdmax(rqst->rq_xprt); in xprt_rdma_allocate()
686 struct rpcrdma_xprt *r_xprt = rpcx_to_rdmax(rqst->rq_xprt); in xprt_rdma_free()
712 struct rpc_xprt *xprt = rqst->rq_xprt; in xprt_rdma_send_request()
Dsvc_rdma_recvfrom.c700 struct svc_xprt *xprt = rqstp->rq_xprt; in svc_rdma_recvfrom()
Dsvc_rdma_sendto.c762 struct svc_xprt *xprt = rqstp->rq_xprt; in svc_rdma_sendto()
/Linux-v4.19/include/trace/events/
Dsunrpc.h560 __string(addr, rqst->rq_xprt->xpt_remotebuf)
567 __assign_str(addr, rqst->rq_xprt->xpt_remotebuf);
585 __string(addr, rqst->rq_xprt->xpt_remotebuf)
593 __assign_str(addr, rqst->rq_xprt->xpt_remotebuf);
610 __string(addr, rqst->rq_xprt->xpt_remotebuf)
616 __assign_str(addr, rqst->rq_xprt->xpt_remotebuf);
642 __string(addr, rqst->rq_xprt->xpt_remotebuf)
649 __assign_str(addr, rqst->rq_xprt->xpt_remotebuf);
737 __string(addr, rqst->rq_xprt->xpt_remotebuf)
741 __entry->xprt = rqst->rq_xprt;
[all …]
Drpcrdma.h1244 __string(addr, rqst->rq_xprt->xpt_remotebuf)
1250 __entry->xprt = rqst->rq_xprt;
1251 __assign_str(addr, rqst->rq_xprt->xpt_remotebuf);
/Linux-v4.19/net/sunrpc/
Dsvc_xprt.c358 struct svc_xprt *xprt = rqstp->rq_xprt; in svc_xprt_release_slot()
475 struct svc_xprt *xprt = rqstp->rq_xprt; in svc_reserve()
486 struct svc_xprt *xprt = rqstp->rq_xprt; in svc_xprt_release()
510 rqstp->rq_xprt = NULL; in svc_xprt_release()
686 WARN_ON_ONCE(rqstp->rq_xprt); in svc_get_next_xprt()
688 rqstp->rq_xprt = svc_xprt_dequeue(pool); in svc_get_next_xprt()
689 if (rqstp->rq_xprt) in svc_get_next_xprt()
711 rqstp->rq_xprt = svc_xprt_dequeue(pool); in svc_get_next_xprt()
712 if (rqstp->rq_xprt) in svc_get_next_xprt()
730 return rqstp->rq_xprt; in svc_get_next_xprt()
[all …]
Dxprt.c430 __xprt_put_cong(req->rq_xprt, req); in xprt_release_rqst_cong()
501 struct rpc_xprt *xprt = req->rq_xprt; in xprt_wait_for_buffer_space()
583 struct rpc_xprt *xprt = req->rq_xprt; in xprt_adjust_timeout()
759 struct rpc_xprt *xprt = task->tk_rqstp->rq_xprt; in xprt_connect()
792 struct rpc_xprt *xprt = task->tk_rqstp->rq_xprt; in xprt_connect_status()
880 __must_hold(&req->rq_xprt->recv_lock) in xprt_wait_on_pinned_rqst()
885 spin_unlock(&req->rq_xprt->recv_lock); in xprt_wait_on_pinned_rqst()
890 spin_lock(&req->rq_xprt->recv_lock); in xprt_wait_on_pinned_rqst()
925 struct rpc_xprt *xprt = req->rq_xprt; in xprt_complete_rqst()
946 struct rpc_xprt *xprt = req->rq_xprt; in xprt_timer()
[all …]
Dbackchannel_rqst.c93 req->rq_xprt = xprt; in xprt_alloc_bc_req()
272 struct rpc_xprt *xprt = req->rq_xprt; in xprt_free_bc_request()
279 struct rpc_xprt *xprt = req->rq_xprt; in xprt_free_bc_rqst()
348 struct rpc_xprt *xprt = req->rq_xprt; in xprt_complete_bc_request()
Dsvc.c1175 rqstp->rq_xprt->xpt_ops->xpo_prep_reply_hdr(rqstp); in svc_process_common()
1248 !test_bit(XPT_CONG_CTRL, &rqstp->rq_xprt->xpt_flags)) in svc_process_common()
1339 if (test_bit(XPT_TEMP, &rqstp->rq_xprt->xpt_flags)) in svc_process_common()
1340 svc_close_xprt(rqstp->rq_xprt); in svc_process_common()
1462 rqstp->rq_xprt = serv->sv_bc_xprt; in bc_svc_process()
1464 rqstp->rq_prot = req->rq_xprt->prot; in bc_svc_process()
1467 rqstp->rq_addrlen = sizeof(req->rq_xprt->addr); in bc_svc_process()
1468 memcpy(&rqstp->rq_addr, &req->rq_xprt->addr, rqstp->rq_addrlen); in bc_svc_process()
1498 atomic_inc(&req->rq_xprt->bc_free_slots); in bc_svc_process()
1529 u32 max = rqstp->rq_xprt->xpt_class->xcl_max_payload; in svc_max_payload()
Dsvcsock.c125 container_of(rqstp->rq_xprt, struct svc_sock, sk_xprt); in svc_release_skb()
155 container_of(rqstp->rq_xprt, struct svc_sock, sk_xprt); in svc_set_cmsg_data()
248 container_of(rqstp->rq_xprt, struct svc_sock, sk_xprt); in svc_sendto()
332 container_of(rqstp->rq_xprt, struct svc_sock, sk_xprt); in svc_recvfrom()
525 container_of(rqstp->rq_xprt, struct svc_sock, sk_xprt); in svc_udp_recvfrom()
1068 container_of(rqstp->rq_xprt, struct svc_sock, sk_xprt); in svc_tcp_recvfrom()
1188 rqstp->rq_xprt->xpt_server->sv_name, in svc_tcp_sendto()
1191 set_bit(XPT_CLOSE, &rqstp->rq_xprt->xpt_flags); in svc_tcp_sendto()
1192 svc_xprt_enqueue(rqstp->rq_xprt); in svc_tcp_sendto()
Dclnt.c1676 struct rpc_xprt *xprt = req->rq_xprt; in call_allocate()
1777 struct rpc_xprt *xprt = task->tk_rqstp->rq_xprt; in call_bind()
1873 struct rpc_xprt *xprt = task->tk_rqstp->rq_xprt; in call_connect()
1924 xprt_conditional_disconnect(task->tk_rqstp->rq_xprt, in call_connect_status()
1986 rpc_wake_up_queued_task(&task->tk_rqstp->rq_xprt->pending, task); in call_transmit()
2064 if (req->rq_connect_cookie != req->rq_xprt->connect_cookie) in call_bc_transmit()
2097 xprt_conditional_disconnect(req->rq_xprt, in call_bc_transmit()
2110 rpc_wake_up_queued_task(&req->rq_xprt->pending, task); in call_bc_transmit()
2115 req->rq_connect_cookie = req->rq_xprt->connect_cookie; in call_bc_transmit()
2317 xprt_conditional_disconnect(req->rq_xprt, in call_decode()
[all …]
Dxprtsock.c445 struct sock_xprt *transport = container_of(task->tk_rqstp->rq_xprt, struct sock_xprt, xprt); in xs_nospace_callback()
458 struct rpc_xprt *xprt = req->rq_xprt; in xs_nospace()
518 struct rpc_xprt *xprt = req->rq_xprt; in xs_local_send_request()
581 struct rpc_xprt *xprt = req->rq_xprt; in xs_udp_send_request()
657 struct rpc_xprt *xprt = req->rq_xprt; in xs_tcp_send_request()
2681 struct rpc_xprt *xprt = req->rq_xprt; in bc_sendto()
2717 xprt = req->rq_xprt->bc_xprt; in bc_send_request()
Dsvcauth_unix.c634 struct sunrpc_net *sn = net_generic(rqstp->rq_xprt->xpt_net, in unix_gid_find()
663 struct svc_xprt *xprt = rqstp->rq_xprt; in svcauth_unix_set_client()
Drpcb_clnt.c979 if (rpc_uaddr2sockaddr(req->rq_xprt->xprt_net, (char *)p, len, in rpcb_dec_getaddr()
/Linux-v4.19/include/linux/sunrpc/
Dsvc.h232 struct svc_xprt * rq_xprt; /* transport ptr */ member
300 #define SVC_NET(svc_rqst) (svc_rqst->rq_xprt->xpt_net)
Dxprt.h69 struct rpc_xprt * rq_xprt; /* RPC client */ member
/Linux-v4.19/net/sunrpc/auth_gss/
Dsvcauth_gss.c1125 struct sunrpc_net *sn = net_generic(rqstp->rq_xprt->xpt_net, sunrpc_net_id); in svcauth_gss_legacy_init()
1236 struct net *net = rqstp->rq_xprt->xpt_net; in svcauth_gss_proxy_init()
1427 struct sunrpc_net *sn = net_generic(rqstp->rq_xprt->xpt_net, sunrpc_net_id); in svcauth_gss_accept()
1717 struct sunrpc_net *sn = net_generic(rqstp->rq_xprt->xpt_net, sunrpc_net_id); in svcauth_gss_release()
Dauth_gss.c1555 iov.iov_base = xprt_skip_transport_header(req->rq_xprt, in gss_marshal()
/Linux-v4.19/fs/nfsd/
Dnfs4state.c1603 svc_xprt_get(rqstp->rq_xprt); in alloc_conn()
1604 conn->cn_xprt = rqstp->rq_xprt; in alloc_conn()