Home
last modified time | relevance | path

Searched refs:rq_arg (Results 1 – 13 of 13) sorted by relevance

/linux/net/sunrpc/xprtrdma/
H A Dsvc_rdma_recvfrom.c55 * Short messages are moved directly into svc_rqst::rq_arg, and
414 struct xdr_buf *arg = &rqstp->rq_arg; in svc_rdma_build_arg_xdr()
679 * @rq_arg: xdr_buf containing ingress RPC/RDMA message
693 static int svc_rdma_xdr_decode_req(struct xdr_buf *rq_arg, in svc_rdma_xdr_decode_req() argument
699 rdma_argp = rq_arg->head[0].iov_base; in svc_rdma_xdr_decode_req()
700 xdr_init_decode(&rctxt->rc_stream, rq_arg, rdma_argp, NULL); in svc_rdma_xdr_decode_req()
731 rq_arg->head[0].iov_base = rctxt->rc_stream.p; in svc_rdma_xdr_decode_req()
734 rq_arg->head[0].iov_len - hdr_len)) in svc_rdma_xdr_decode_req()
736 rq_arg->head[0].iov_len -= hdr_len; in svc_rdma_xdr_decode_req()
737 rq_arg in svc_rdma_xdr_decode_req()
[all...]
H A Dsvc_rdma_backchannel.c25 struct xdr_buf *rcvbuf = &rqstp->rq_arg; in svc_rdma_handle_bc_reply()
/linux/net/sunrpc/
H A Dsvcsock.c620 rqstp->rq_arg.len = len; in svc_udp_recvfrom()
632 if (csum_partial_copy_to_xdr(&rqstp->rq_arg, skb)) in svc_udp_recvfrom()
638 rqstp->rq_arg.head[0].iov_base = skb->data; in svc_udp_recvfrom()
639 rqstp->rq_arg.head[0].iov_len = len; in svc_udp_recvfrom()
645 rqstp->rq_arg.page_base = 0; in svc_udp_recvfrom()
646 if (len <= rqstp->rq_arg.head[0].iov_len) { in svc_udp_recvfrom()
647 rqstp->rq_arg.head[0].iov_len = len; in svc_udp_recvfrom()
648 rqstp->rq_arg.page_len = 0; in svc_udp_recvfrom()
650 rqstp->rq_arg.page_len = len - rqstp->rq_arg in svc_udp_recvfrom()
[all...]
H A Dsvc.c1619 rqstp->rq_arg.len);
1780 memcpy(&rqstp->rq_arg, &req->rq_rcv_buf, sizeof(rqstp->rq_arg));
1784 rqstp->rq_arg.len = req->rq_private_buf.len;
1785 if (rqstp->rq_arg.len <= rqstp->rq_arg.head[0].iov_len) {
1786 rqstp->rq_arg.head[0].iov_len = rqstp->rq_arg.len;
1787 rqstp->rq_arg.page_len = 0; in svc_max_payload()
1788 } else if (rqstp->rq_arg in svc_max_payload()
[all...]
H A Dsvc_xprt.c720 struct xdr_buf *arg = &rqstp->rq_arg; in svc_alloc_arg()
886 trace_svc_xdr_recvfrom(&rqstp->rq_arg); in svc_handle_xprt()
1303 * entirely in rq_arg.head[0] can be deferred. in svc_defer()
1310 if (rqstp->rq_arg.page_len || !test_bit(RQ_USEDEFERRAL, &rqstp->rq_flags)) in svc_defer()
1318 if (rqstp->rq_arg.len > rqstp->rq_arg.head[0].iov_len) in svc_defer()
1322 size = sizeof(struct svc_deferred_req) + rqstp->rq_arg.len;
1332 dr->argslen = rqstp->rq_arg.len >> 2; in svc_deferred_recv()
1334 memcpy(dr->args, rqstp->rq_arg.head[0].iov_base, in svc_deferred_recv()
1357 rqstp->rq_arg in svc_deferred_dequeue()
[all...]
/linux/include/linux/sunrpc/
H A Dsvc.h216 struct xdr_buf rq_arg;
543 struct xdr_buf *buf = &rqstp->rq_arg; in svcxdr_init_decode()
213 struct xdr_buf rq_arg; global() member
/linux/fs/nfsd/
H A Dnfscache.c110 rp->c_key.k_len = rqstp->rq_arg.len; in nfsd_cacherep_alloc()
371 /* rq_arg.head first */ in nfsd_cache_csum()
454 * @start: starting byte in @rqstp->rq_arg of the NFS Call header
486 csum = nfsd_cache_csum(&rqstp->rq_arg, start, len); in nfsd_cache_lookup()
H A Dnfsxdr.c
H A Dnfsproc.c
H A Dnfs3xdr.c619 struct kvec *head = rqstp->rq_arg.head; in nfs3svc_decode_symlinkargs()
H A Dnfs3proc.c536 page_address(rqstp->rq_arg.pages[0]), in nfsd3_proc_remove()
H A Dnfs4state.c4975 struct xdr_buf *xb = &rqstp->rq_arg;
/linux/net/sunrpc/auth_gss/
H A Dsvcauth_gss.c1100 from_offs = rqstp->rq_arg.page_base; in gss_read_proxy_verf()
1111 page_address(rqstp->rq_arg.pages[pgfrom]) + pgfrom_offs, in gss_read_proxy_verf()