Home
last modified time | relevance | path

Searched refs:xdr (Results 1 – 24 of 24) sorted by relevance

/net/sunrpc/auth_gss/
A Dgss_rpc_xdr.c15 p = xdr_reserve_space(xdr, 4); in gssx_enc_bool()
26 p = xdr_inline_decode(xdr, 4); in gssx_dec_bool()
50 p = xdr_reserve_space(xdr, 4); in gssx_enc_in_token()
68 p = xdr_inline_decode(xdr, 4); in gssx_dec_buffer()
127 p = xdr_reserve_space(xdr, 4); in dummy_enc_opt_array()
142 p = xdr_inline_decode(xdr, 4); in dummy_dec_opt_array()
148 gssx_dec_option(xdr, &dummy); in dummy_dec_opt_array()
160 p = xdr_inline_decode(xdr, 4); in get_host_u32()
177 p = xdr_inline_decode(xdr, 4); in gssx_dec_linux_creds()
734 struct xdr_stream *xdr, in gssx_enc_accept_sec_context() argument
[all …]
A Dsvcauth_gss.c865 struct xdr_buf *buf = xdr->buf; in svcauth_gss_unwrap_integ()
877 offset = xdr_stream_pos(xdr); in svcauth_gss_unwrap_integ()
940 struct xdr_buf *buf = xdr->buf; in svcauth_gss_unwrap_priv()
950 if (len > xdr_stream_remaining(xdr)) in svcauth_gss_unwrap_priv()
952 offset = xdr_stream_pos(xdr); in svcauth_gss_unwrap_priv()
1068 if (inlen > xdr_stream_remaining(xdr)) in gss_read_proxy_verf()
1085 length = min_t(unsigned int, inlen, (char *)xdr->end - (char *)xdr->p); in gss_read_proxy_verf()
1179 p = xdr_inline_decode(xdr, len); in svcauth_gss_legacy_init()
1575 p = xdr_inline_decode(xdr, XDR_UNIT); in svcauth_gss_decode_credbody()
1790 struct xdr_buf *buf = xdr->buf; in svcauth_gss_wrap_integ()
[all …]
A Dauth_gss.c1543 p = xdr_reserve_space(xdr, 7 * sizeof(*p) + in gss_marshal()
1573 p = xdr_reserve_space(xdr, sizeof(*p)); in gss_marshal()
1708 p = xdr_inline_decode(xdr, len); in gss_validate()
1759 if (rpcauth_wrap_req_encode(task, xdr)) in gss_wrap_req_integ()
1768 p = xdr_reserve_space(xdr, 0); in gss_wrap_req_integ()
1856 if (rpcauth_wrap_req_encode(task, xdr)) in gss_wrap_req_priv()
1990 struct xdr_stream *xdr) in gss_unwrap_resp_integ() argument
2001 if (xdr_stream_decode_u32(xdr, &len)) in gss_unwrap_resp_integ()
2006 if (xdr_stream_decode_u32(xdr, &seqno)) in gss_unwrap_resp_integ()
2062 struct xdr_stream *xdr) in gss_unwrap_resp_priv() argument
[all …]
A Dgss_rpc_xdr.h168 struct xdr_stream *xdr,
171 struct xdr_stream *xdr,
/net/sunrpc/
A Dxdr.c954 BUG_ON(p < xdr->p || p > xdr->end); in xdr_init_encode()
977 xdr->p = page_address(*xdr->page_ptr); in xdr_init_encode_pages()
1121 if (xdr->iov == xdr->buf->head) { in xdr_reserve_space_vec()
1123 xdr->end = xdr->p; in xdr_reserve_space_vec()
1283 BUG_ON(xdr->p >= xdr->end); in xdr_write_pages()
1391 else if (xdr->iov == xdr->buf->head) in xdr_set_next_buffer()
1393 return xdr->p != xdr->end; in xdr_set_next_buffer()
1414 xdr->nwords -= p - xdr->p; in xdr_init_decode()
1505 if (xdr->p == xdr->end && !xdr_set_next_buffer(xdr)) in xdr_inline_decode()
1737 if (xdr->p == xdr->end && !xdr_set_next_buffer(xdr)) in xdr_stream_subsegment()
[all …]
A Dsocklib.c67 struct page **ppage = xdr->pages + (xdr->page_base >> PAGE_SHIFT); in xdr_partial_copy_from_skb()
69 unsigned int pglen = xdr->page_len; in xdr_partial_copy_from_skb()
73 if (xdr->head[0].iov_len == 0) in xdr_partial_copy_from_skb()
77 xdr->head[0].iov_len); in xdr_partial_copy_from_skb()
110 if (xdr->tail[0].iov_len) { in xdr_partial_copy_from_skb()
112 xdr->tail[0].iov_len); in xdr_partial_copy_from_skb()
178 iov_iter_bvec(&msg->msg_iter, ITER_SOURCE, xdr->bvec, xdr_buf_pagecount(xdr), in xprt_send_pagedata()
179 xdr->page_len + xdr->page_base); in xprt_send_pagedata()
242 &xdr->head[0], base); in xprt_sock_sendmsg()
253 if (base < xdr->page_len) { in xprt_sock_sendmsg()
[all …]
A Dauth_unix.c111 unx_marshal(struct rpc_task *task, struct xdr_stream *xdr) in unx_marshal() argument
123 p = xdr_reserve_space(xdr, 3 * sizeof(*p)); in unx_marshal()
129 if (xdr_stream_encode_opaque(xdr, clnt->cl_nodename, in unx_marshal()
132 p = xdr_reserve_space(xdr, 3 * sizeof(*p)); in unx_marshal()
144 p = xdr_reserve_space(xdr, (p - gidarr_len - 1) << 2); in unx_marshal()
150 p = xdr_reserve_space(xdr, 2 * sizeof(*p)); in unx_marshal()
173 unx_validate(struct rpc_task *task, struct xdr_stream *xdr) in unx_validate() argument
179 p = xdr_inline_decode(xdr, 2 * sizeof(*p)); in unx_validate()
193 p = xdr_inline_decode(xdr, size); in unx_validate()
A Dauth_tls.c19 static void tls_encode_probe(struct rpc_rqst *rqstp, struct xdr_stream *xdr, in tls_encode_probe() argument
24 static int tls_decode_probe(struct rpc_rqst *rqstp, struct xdr_stream *xdr, in tls_decode_probe() argument
99 static int tls_marshal(struct rpc_task *task, struct xdr_stream *xdr) in tls_marshal() argument
103 p = xdr_reserve_space(xdr, 4 * XDR_UNIT); in tls_marshal()
121 static int tls_validate(struct rpc_task *task, struct xdr_stream *xdr) in tls_validate() argument
126 p = xdr_inline_decode(xdr, XDR_UNIT); in tls_validate()
131 if (xdr_stream_decode_opaque_inline(xdr, &str, starttls_len) != starttls_len) in tls_validate()
A Drpcb_clnt.c839 p = xdr_reserve_space(xdr, RPCB_mappingargs_sz << 2); in rpcb_enc_mapping()
855 p = xdr_inline_decode(xdr, 4); in rpcb_dec_getport()
867 static int rpcb_dec_set(struct rpc_rqst *req, struct xdr_stream *xdr, in rpcb_dec_set() argument
873 p = xdr_inline_decode(xdr, 4); in rpcb_dec_set()
894 p = xdr_reserve_space(xdr, 4 + len); in encode_rpcb_string()
904 p = xdr_reserve_space(xdr, (RPCB_program_sz + RPCB_version_sz) << 2); in rpcb_enc_getaddr()
908 encode_rpcb_string(xdr, rpcb->r_netid, RPCBIND_MAXNETIDLEN); in rpcb_enc_getaddr()
909 encode_rpcb_string(xdr, rpcb->r_addr, RPCBIND_MAXUADDRLEN); in rpcb_enc_getaddr()
910 encode_rpcb_string(xdr, rpcb->r_owner, RPCB_MAXOWNERLEN); in rpcb_enc_getaddr()
924 p = xdr_inline_decode(xdr, 4); in rpcb_dec_getaddr()
[all …]
A Dauth_null.c63 nul_marshal(struct rpc_task *task, struct xdr_stream *xdr) in nul_marshal() argument
67 p = xdr_reserve_space(xdr, 4 * sizeof(*p)); in nul_marshal()
90 nul_validate(struct rpc_task *task, struct xdr_stream *xdr) in nul_validate() argument
94 p = xdr_inline_decode(xdr, 2 * sizeof(*p)); in nul_validate()
A Dauth.c724 int rpcauth_marshcred(struct rpc_task *task, struct xdr_stream *xdr) in rpcauth_marshcred() argument
728 return ops->crmarshal(task, xdr); in rpcauth_marshcred()
743 encode(task->tk_rqstp, xdr, task->tk_msg.rpc_argp); in rpcauth_wrap_req_encode()
757 int rpcauth_wrap_req(struct rpc_task *task, struct xdr_stream *xdr) in rpcauth_wrap_req() argument
761 return ops->crwrap_req(task, xdr); in rpcauth_wrap_req()
779 rpcauth_checkverf(struct rpc_task *task, struct xdr_stream *xdr) in rpcauth_checkverf() argument
783 return ops->crvalidate(task, xdr); in rpcauth_checkverf()
794 rpcauth_unwrap_resp_decode(struct rpc_task *task, struct xdr_stream *xdr) in rpcauth_unwrap_resp_decode() argument
798 return decode(task->tk_rqstp, xdr, task->tk_msg.rpc_resp); in rpcauth_unwrap_resp_decode()
810 rpcauth_unwrap_resp(struct rpc_task *task, struct xdr_stream *xdr) in rpcauth_unwrap_resp() argument
[all …]
A Dsvcauth_unix.c757 struct xdr_stream *xdr = &rqstp->rq_arg_stream; in svcauth_null_accept() local
763 if (xdr_stream_decode_u32(xdr, &len) < 0) in svcauth_null_accept()
834 struct xdr_stream *xdr = &rqstp->rq_arg_stream; in svcauth_tls_accept() local
842 if (xdr_stream_decode_u32(xdr, &len) < 0) in svcauth_tls_accept()
919 struct xdr_stream *xdr = &rqstp->rq_arg_stream; in svcauth_unix_accept() local
931 p = xdr_inline_decode(xdr, XDR_UNIT * 3); in svcauth_unix_accept()
937 if (!xdr_inline_decode(xdr, len)) in svcauth_unix_accept()
949 if (xdr_stream_decode_u32(xdr, &i) < 0) in svcauth_unix_accept()
952 if (xdr_stream_decode_u32(xdr, &i) < 0) in svcauth_unix_accept()
956 if (xdr_stream_decode_u32(xdr, &len) < 0) in svcauth_unix_accept()
[all …]
A Dsvc.c1346 xdr_stream_encode_be32(xdr, rqstp->rq_xid); in svc_process_common()
1347 xdr_stream_encode_be32(xdr, rpc_reply); in svc_process_common()
1419 aoffset = xdr_stream_pos(xdr); in svc_process_common()
1431 xdr_finish_decode(xdr); in svc_process_common()
1439 xdr_truncate_encode(xdr, aoffset); in svc_process_common()
1470 xdr_stream_encode_u32(xdr, RPC_MSG_DENIED); in svc_process_common()
1471 xdr_stream_encode_u32(xdr, RPC_MISMATCH); in svc_process_common()
1473 xdr_stream_encode_u32(xdr, RPC_VERSION); in svc_process_common()
1474 xdr_stream_encode_u32(xdr, RPC_VERSION); in svc_process_common()
1483 xdr_truncate_encode(xdr, XDR_UNIT * 2); in svc_process_common()
[all …]
A Dsocklib.h10 int csum_partial_copy_to_xdr(struct xdr_buf *xdr, struct sk_buff *skb);
12 struct xdr_buf *xdr, unsigned int base,
A Dclnt.c70 struct xdr_stream *xdr);
72 struct xdr_stream *xdr);
1940 struct xdr_stream xdr; in rpc_xdr_encode() local
1951 xdr_init_encode(&xdr, &req->rq_snd_buf, in rpc_xdr_encode()
1953 if (rpc_encode_header(task, &xdr)) in rpc_xdr_encode()
2585 struct xdr_stream xdr; in call_decode() local
2622 xdr_init_decode(&xdr, &req->rq_rcv_buf, in call_decode()
2624 err = rpc_decode_header(task, &xdr); in call_decode()
2630 xdr_finish_decode(&xdr); in call_decode()
2668 error = rpcauth_marshcred(task, xdr); in rpc_encode_header()
[all …]
A Dxprtsock.c931 xs_stream_record_marker(struct xdr_buf *xdr) in xs_stream_record_marker() argument
933 if (!xdr->len) in xs_stream_record_marker()
954 struct xdr_buf *xdr = &req->rq_snd_buf; in xs_local_send_request() local
955 rpc_fraghdr rm = xs_stream_record_marker(xdr); in xs_local_send_request()
1024 struct xdr_buf *xdr = &req->rq_snd_buf; in xs_udp_send_request() local
1050 xdr->len, status); in xs_udp_send_request()
1110 struct xdr_buf *xdr = &req->rq_snd_buf; in xs_tcp_send_request() local
1111 rpc_fraghdr rm = xs_stream_record_marker(xdr); in xs_tcp_send_request()
2983 struct xdr_buf *xdr = &req->rq_snd_buf; in bc_sendto() local
2990 (u32)xdr->len); in bc_sendto()
[all …]
A DMakefile14 addr.o rpcb_clnt.o timer.o xdr.o \
A Dsvcsock.c717 struct xdr_buf *xdr = &rqstp->rq_res; in svc_udp_sendto() local
743 count = xdr_buf_to_bvec(rqstp->rq_bvec, rqstp->rq_maxpages, xdr); in svc_udp_sendto()
1274 struct xdr_buf *xdr = &rqstp->rq_res; in svc_tcp_sendto() local
1276 (u32)xdr->len); in svc_tcp_sendto()
1287 if (err < 0 || sent != (xdr->len + sizeof(marker))) in svc_tcp_sendto()
1299 (err < 0) ? err : sent, xdr->len); in svc_tcp_sendto()
/net/sunrpc/xprtrdma/
A Drpc_rdma.c136 if (xdr->page_len) { in rpcrdma_args_inline()
137 remaining = xdr->page_len; in rpcrdma_args_inline()
605 ppages = xdr->pages + (xdr->page_base >> PAGE_SHIFT); in rpcrdma_prepare_pagelist()
607 remaining = xdr->page_len; in rpcrdma_prepare_pagelist()
669 dst += xdr->head[0].iov_len + xdr->page_len; in rpcrdma_pullup_tail_iov()
670 memmove(dst, xdr->tail[0].iov_base, xdr->tail[0].iov_len); in rpcrdma_pullup_tail_iov()
686 ppages = xdr->pages + (xdr->page_base >> PAGE_SHIFT); in rpcrdma_pullup_pagelist()
688 remaining = xdr->page_len; in rpcrdma_pullup_pagelist()
714 struct xdr_buf *xdr) in rpcrdma_prepare_noch_pullup() argument
728 struct xdr_buf *xdr) in rpcrdma_prepare_noch_mapped() argument
[all …]
A Dsvc_rdma_sendto.c642 ppages = xdr->pages + (xdr->page_base >> PAGE_SHIFT); in svc_rdma_xb_dma_map()
644 remaining = xdr->page_len; in svc_rdma_xb_dma_map()
660 return xdr->len; in svc_rdma_xb_dma_map()
684 if (xdr->head[0].iov_len) in svc_rdma_xb_count_sges()
688 remaining = xdr->page_len; in svc_rdma_xb_count_sges()
695 if (xdr->tail[0].iov_len) in svc_rdma_xb_count_sges()
751 if (xdr->head[0].iov_len) { in svc_rdma_xb_linearize()
752 memcpy(args->pd_dest, xdr->head[0].iov_base, xdr->head[0].iov_len); in svc_rdma_xb_linearize()
756 ppages = xdr->pages + (xdr->page_base >> PAGE_SHIFT); in svc_rdma_xb_linearize()
758 remaining = xdr->page_len; in svc_rdma_xb_linearize()
[all …]
A Dsvc_rdma_rw.c445 page = xdr->pages + page_no; in svc_rdma_pagelist_to_sg()
556 const struct xdr_buf *xdr, in svc_rdma_pages_write() argument
560 info->wi_xdr = xdr; in svc_rdma_pages_write()
582 if (xdr->head[0].iov_len) { in svc_rdma_xb_write()
588 if (xdr->page_len) { in svc_rdma_xb_write()
589 ret = svc_rdma_pages_write(info, xdr, xdr->head[0].iov_len, in svc_rdma_xb_write()
590 xdr->page_len); in svc_rdma_xb_write()
595 if (xdr->tail[0].iov_len) { in svc_rdma_xb_write()
601 return xdr->len; in svc_rdma_xb_write()
682 const struct xdr_buf *xdr) in svc_rdma_prepare_reply_chunk() argument
[all …]
A Dsvc_rdma_pcl.c232 static int pcl_process_region(const struct xdr_buf *xdr, in pcl_process_region() argument
241 if (xdr_buf_subsegment(xdr, &subbuf, offset, length)) in pcl_process_region()
266 const struct xdr_buf *xdr, in pcl_process_nonpayloads() argument
278 return actor(xdr, data); in pcl_process_nonpayloads()
281 ret = pcl_process_region(xdr, 0, chunk->ch_position, actor, data); in pcl_process_nonpayloads()
291 ret = pcl_process_region(xdr, start, next->ch_position - start, in pcl_process_nonpayloads()
301 ret = pcl_process_region(xdr, start, xdr->len - start, actor, data); in pcl_process_nonpayloads()
A Dxprt_rdma.h564 struct xdr_buf *xdr,
574 static inline void rpcrdma_set_xdrlen(struct xdr_buf *xdr, size_t len) in rpcrdma_set_xdrlen() argument
576 xdr->head[0].iov_len = len; in rpcrdma_set_xdrlen()
577 xdr->len = len; in rpcrdma_set_xdrlen()
/net/rxrpc/
A Dkey.c62 ntohl(xdr[0]), ntohl(xdr[1]), ntohl(xdr[2]), ntohl(xdr[3]), in rxrpc_preparse_xdr_rxkad()
67 tktlen = ntohl(xdr[7]); in rxrpc_preparse_xdr_rxkad()
134 return (u64)ntohl(xdr[0]) << 32 | (u64)ntohl(xdr[1]); in xdr_dec64()
177 ntohl(xdr[0]), ntohl(xdr[1]), ntohl(xdr[2]), ntohl(xdr[3]), in rxrpc_preparse_xdr_yfs_rxgk()
299 ntohl(xdr[0]), ntohl(xdr[1]), ntohl(xdr[2]), ntohl(xdr[3]), in rxrpc_preparse_xdr()
316 len = ntohl(*xdr++); in rxrpc_preparse_xdr()
334 xdr += paddedlen >> 2; in rxrpc_preparse_xdr()
346 p = xdr; in rxrpc_preparse_xdr()
373 token = xdr; in rxrpc_preparse_xdr()
817 xdr += 8 >> 2; \ in rxrpc_read()
[all …]

Completed in 81 milliseconds