Home
last modified time | relevance | path

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

/linux-4.4.14/net/sunrpc/
Dsvc_xprt.c371 rqstp->rq_xprt = xprt; in svc_xprt_do_enqueue()
460 struct svc_xprt *xprt = rqstp->rq_xprt; in svc_reserve()
473 struct svc_xprt *xprt = rqstp->rq_xprt; in svc_xprt_release()
475 rqstp->rq_xprt->xpt_ops->xpo_release_rqst(rqstp); in svc_xprt_release()
496 rqstp->rq_xprt = NULL; in svc_xprt_release()
673 WARN_ON_ONCE(rqstp->rq_xprt); in svc_get_next_xprt()
682 rqstp->rq_xprt = xprt; in svc_get_next_xprt()
712 xprt = rqstp->rq_xprt; in svc_get_next_xprt()
800 if (rqstp->rq_xprt) in svc_recv()
855 dprintk("svc: xprt %p dropped request\n", rqstp->rq_xprt); in svc_drop()
[all …]
Dbackchannel_rqst.c99 req->rq_xprt = xprt; in xprt_alloc_bc_req()
278 struct rpc_xprt *xprt = req->rq_xprt; in xprt_free_bc_request()
285 struct rpc_xprt *xprt = req->rq_xprt; in xprt_free_bc_rqst()
354 struct rpc_xprt *xprt = req->rq_xprt; in xprt_complete_bc_request()
Dxprt.c427 __xprt_put_cong(req->rq_xprt, req); in xprt_release_rqst_cong()
498 struct rpc_xprt *xprt = req->rq_xprt; in xprt_wait_for_buffer_space()
579 struct rpc_xprt *xprt = req->rq_xprt; in xprt_adjust_timeout()
737 struct rpc_xprt *xprt = task->tk_rqstp->rq_xprt; in xprt_connect()
769 struct rpc_xprt *xprt = task->tk_rqstp->rq_xprt; in xprt_connect_status()
849 struct rpc_xprt *xprt = req->rq_xprt; in xprt_complete_rqst()
873 struct rpc_xprt *xprt = req->rq_xprt; in xprt_timer()
901 struct rpc_xprt *xprt = req->rq_xprt; in xprt_prepare_transmit()
932 xprt_release_write(task->tk_rqstp->rq_xprt, task); in xprt_end_transmit()
944 struct rpc_xprt *xprt = req->rq_xprt; in xprt_transmit()
[all …]
Dsvc.c1094 rqstp->rq_xprt->xpt_ops->xpo_prep_reply_hdr(rqstp); in svc_process_common()
1141 if (test_bit(XPT_TEMP, &rqstp->rq_xprt->xpt_flags)) in svc_process_common()
1142 svc_close_xprt(rqstp->rq_xprt); in svc_process_common()
1357 rqstp->rq_xprt = serv->sv_bc_xprt; in bc_svc_process()
1359 rqstp->rq_prot = req->rq_xprt->prot; in bc_svc_process()
1362 rqstp->rq_addrlen = sizeof(req->rq_xprt->addr); in bc_svc_process()
1363 memcpy(&rqstp->rq_addr, &req->rq_xprt->addr, rqstp->rq_addrlen); in bc_svc_process()
1393 atomic_inc(&req->rq_xprt->bc_free_slots); in bc_svc_process()
1424 u32 max = rqstp->rq_xprt->xpt_class->xcl_max_payload; in svc_max_payload()
Dsvcsock.c126 container_of(rqstp->rq_xprt, struct svc_sock, sk_xprt); in svc_release_skb()
144 container_of(rqstp->rq_xprt, struct svc_sock, sk_xprt); in svc_set_cmsg_data()
237 container_of(rqstp->rq_xprt, struct svc_sock, sk_xprt); in svc_sendto()
321 container_of(rqstp->rq_xprt, struct svc_sock, sk_xprt); in svc_recvfrom()
565 container_of(rqstp->rq_xprt, struct svc_sock, sk_xprt); in svc_udp_recvfrom()
1110 container_of(rqstp->rq_xprt, struct svc_sock, sk_xprt); in svc_tcp_recvfrom()
1230 rqstp->rq_xprt->xpt_server->sv_name, in svc_tcp_sendto()
1233 set_bit(XPT_CLOSE, &rqstp->rq_xprt->xpt_flags); in svc_tcp_sendto()
1234 svc_xprt_enqueue(rqstp->rq_xprt); in svc_tcp_sendto()
Dclnt.c1578 struct rpc_xprt *xprt = req->rq_xprt; in call_allocate()
1687 struct rpc_xprt *xprt = task->tk_rqstp->rq_xprt; in call_bind()
1782 struct rpc_xprt *xprt = task->tk_rqstp->rq_xprt; in call_connect()
1882 rpc_wake_up_queued_task(&task->tk_rqstp->rq_xprt->pending, task); in call_transmit()
1955 if (req->rq_connect_cookie != req->rq_xprt->connect_cookie) in call_bc_transmit()
1987 xprt_conditional_disconnect(req->rq_xprt, in call_bc_transmit()
2000 rpc_wake_up_queued_task(&req->rq_xprt->pending, task); in call_bc_transmit()
2005 req->rq_connect_cookie = req->rq_xprt->connect_cookie; in call_bc_transmit()
2052 xprt_conditional_disconnect(req->rq_xprt, in call_status()
2209 xprt_conditional_disconnect(req->rq_xprt, in call_decode()
[all …]
Dxprtsock.c441 struct sock_xprt *transport = container_of(task->tk_rqstp->rq_xprt, struct sock_xprt, xprt); in xs_nospace_callback()
454 struct rpc_xprt *xprt = req->rq_xprt; in xs_nospace()
505 struct rpc_xprt *xprt = req->rq_xprt; in xs_local_send_request()
566 struct rpc_xprt *xprt = req->rq_xprt; in xs_udp_send_request()
641 struct rpc_xprt *xprt = req->rq_xprt; in xs_tcp_send_request()
2536 struct rpc_xprt *xprt = req->rq_xprt; in bc_sendto()
2572 xprt = req->rq_xprt->bc_xprt; in bc_send_request()
Dsvcauth_unix.c633 struct sunrpc_net *sn = net_generic(rqstp->rq_xprt->xpt_net, in unix_gid_find()
662 struct svc_xprt *xprt = rqstp->rq_xprt; in svcauth_unix_set_client()
Drpcb_clnt.c975 if (rpc_uaddr2sockaddr(req->rq_xprt->xprt_net, (char *)p, len, in rpcb_dec_getaddr()
/linux-4.4.14/net/sunrpc/xprtrdma/
Dxprt_rdma.h332 (rpcx_to_rdmad(rq->rq_xprt).inline_rsize)
335 (rpcx_to_rdmad(rq->rq_xprt).inline_wsize)
338 rpcx_to_rdmad(rq->rq_xprt).padding
Dbackchannel.c144 rqst->rq_xprt = &r_xprt->rx_xprt; in xprt_rdma_bc_setup()
205 struct rpc_xprt *xprt = rqst->rq_xprt; in rpcrdma_bc_marshal_reply()
270 struct rpc_xprt *xprt = rqst->rq_xprt; in xprt_rdma_bc_free_rqst()
Drpc_rdma.c247 struct rpcrdma_xprt *r_xprt = rpcx_to_rdmax(rqst->rq_xprt); in rpcrdma_create_chunks()
370 struct rpcrdma_xprt *r_xprt = rpcx_to_rdmax(rqst->rq_xprt); in rpcrdma_inline_pullup()
435 struct rpc_xprt *xprt = rqst->rq_xprt; in rpcrdma_marshal_req()
641 rpcx_to_rdmax(rqst->rq_xprt)->rx_stats.fixup_copy_count += olen; in rpcrdma_inline_fixup()
Dtransport.c491 struct rpc_xprt *xprt = task->tk_rqstp->rq_xprt; in xprt_rdma_allocate()
607 struct rpc_xprt *xprt = rqst->rq_xprt; in xprt_rdma_send_request()
Dsvc_rdma_recvfrom.c557 svc_xprt_copy_addrs(rqstp, rqstp->rq_xprt); in rdma_read_complete()
577 struct svc_xprt *xprt = rqstp->rq_xprt; in svc_rdma_recvfrom()
Dsvc_rdma_sendto.c571 struct svc_xprt *xprt = rqstp->rq_xprt; in svc_rdma_sendto()
/linux-4.4.14/include/linux/sunrpc/
Dsvc.h230 struct svc_xprt * rq_xprt; /* transport ptr */ member
295 #define SVC_NET(svc_rqst) (svc_rqst->rq_xprt->xpt_net)
Dxprt.h67 struct rpc_xprt * rq_xprt; /* RPC client */ member
/linux-4.4.14/net/sunrpc/auth_gss/
Dsvcauth_gss.c1107 struct sunrpc_net *sn = net_generic(rqstp->rq_xprt->xpt_net, sunrpc_net_id); in svcauth_gss_legacy_init()
1218 struct net *net = rqstp->rq_xprt->xpt_net; in svcauth_gss_proxy_init()
1408 struct sunrpc_net *sn = net_generic(rqstp->rq_xprt->xpt_net, sunrpc_net_id); in svcauth_gss_accept()
1696 struct sunrpc_net *sn = net_generic(rqstp->rq_xprt->xpt_net, sunrpc_net_id); in svcauth_gss_release()
Dauth_gss.c1507 iov.iov_base = xprt_skip_transport_header(req->rq_xprt, in gss_marshal()
/linux-4.4.14/fs/nfsd/
Dnfs4state.c1496 svc_xprt_get(rqstp->rq_xprt); in alloc_conn()
1497 conn->cn_xprt = rqstp->rq_xprt; in alloc_conn()