| /net/sunrpc/ |
| D | svc.c | 565 svc_init_buffer(struct svc_rqst *rqstp, unsigned int size, int node) in svc_init_buffer() argument
570 if (svc_is_backchannel(rqstp)) in svc_init_buffer()
584 rqstp->rq_pages[arghi++] = p; in svc_init_buffer()
594 svc_release_buffer(struct svc_rqst *rqstp) in svc_release_buffer() argument
598 for (i = 0; i < ARRAY_SIZE(rqstp->rq_pages); i++) in svc_release_buffer()
599 if (rqstp->rq_pages[i]) in svc_release_buffer()
600 put_page(rqstp->rq_pages[i]); in svc_release_buffer()
606 struct svc_rqst *rqstp; in svc_rqst_alloc() local
608 rqstp = kzalloc_node(sizeof(*rqstp), GFP_KERNEL, node); in svc_rqst_alloc()
609 if (!rqstp) in svc_rqst_alloc()
[all …]
|
| D | svc_xprt.c | 30 static int svc_deferred_recv(struct svc_rqst *rqstp);
325 void svc_xprt_copy_addrs(struct svc_rqst *rqstp, struct svc_xprt *xprt) in svc_xprt_copy_addrs() argument
327 memcpy(&rqstp->rq_addr, &xprt->xpt_remote, xprt->xpt_remotelen); in svc_xprt_copy_addrs()
328 rqstp->rq_addrlen = xprt->xpt_remotelen; in svc_xprt_copy_addrs()
334 memcpy(&rqstp->rq_daddr, &xprt->xpt_local, xprt->xpt_locallen); in svc_xprt_copy_addrs()
335 rqstp->rq_daddrlen = xprt->xpt_locallen; in svc_xprt_copy_addrs()
346 char *svc_print_addr(struct svc_rqst *rqstp, char *buf, size_t len) in svc_print_addr() argument
348 return __svc_print_addr(svc_addr(rqstp), buf, len); in svc_print_addr()
360 static bool svc_xprt_reserve_slot(struct svc_rqst *rqstp, struct svc_xprt *xprt) in svc_xprt_reserve_slot() argument
362 if (!test_bit(RQ_DATA, &rqstp->rq_flags)) { in svc_xprt_reserve_slot()
[all …]
|
| D | svcsock.c | 118 static void svc_tcp_release_rqst(struct svc_rqst *rqstp) in svc_tcp_release_rqst() argument
120 struct sk_buff *skb = rqstp->rq_xprt_ctxt; in svc_tcp_release_rqst()
124 container_of(rqstp->rq_xprt, struct svc_sock, sk_xprt); in svc_tcp_release_rqst()
126 rqstp->rq_xprt_ctxt = NULL; in svc_tcp_release_rqst()
136 static void svc_udp_release_rqst(struct svc_rqst *rqstp) in svc_udp_release_rqst() argument
138 struct sk_buff *skb = rqstp->rq_xprt_ctxt; in svc_udp_release_rqst()
141 rqstp->rq_xprt_ctxt = NULL; in svc_udp_release_rqst()
153 static void svc_set_cmsg_data(struct svc_rqst *rqstp, struct cmsghdr *cmh) in svc_set_cmsg_data() argument
156 container_of(rqstp->rq_xprt, struct svc_sock, sk_xprt); in svc_set_cmsg_data()
165 svc_daddr_in(rqstp)->sin_addr.s_addr; in svc_set_cmsg_data()
[all …]
|
| D | svcauth.c | 62 svc_authenticate(struct svc_rqst *rqstp, __be32 *authp) in svc_authenticate() argument
69 flavor = svc_getnl(&rqstp->rq_arg.head[0]); in svc_authenticate()
79 rqstp->rq_auth_slack = 0; in svc_authenticate()
80 init_svc_cred(&rqstp->rq_cred); in svc_authenticate()
82 rqstp->rq_authop = aops; in svc_authenticate()
83 return aops->accept(rqstp, authp); in svc_authenticate()
87 int svc_set_client(struct svc_rqst *rqstp) in svc_set_client() argument
89 rqstp->rq_client = NULL; in svc_set_client()
90 return rqstp->rq_authop->set_client(rqstp); in svc_set_client()
98 int svc_authorise(struct svc_rqst *rqstp) in svc_authorise() argument
[all …]
|
| D | svcauth_unix.c | 649 static struct group_info *unix_gid_find(kuid_t uid, struct svc_rqst *rqstp) in unix_gid_find() argument
654 struct sunrpc_net *sn = net_generic(rqstp->rq_xprt->xpt_net, in unix_gid_find()
660 ret = cache_check(sn->unix_gid_cache, &ug->h, &rqstp->rq_chandle); in unix_gid_find()
676 svcauth_unix_set_client(struct svc_rqst *rqstp) in svcauth_unix_set_client() argument
682 struct svc_cred *cred = &rqstp->rq_cred; in svcauth_unix_set_client()
683 struct svc_xprt *xprt = rqstp->rq_xprt; in svcauth_unix_set_client()
687 switch (rqstp->rq_addr.ss_family) { in svcauth_unix_set_client()
689 sin = svc_addr_in(rqstp); in svcauth_unix_set_client()
694 sin6 = svc_addr_in6(rqstp); in svcauth_unix_set_client()
700 rqstp->rq_client = NULL; in svcauth_unix_set_client()
[all …]
|
| D | cache.c | 297 struct cache_head *h, struct cache_req *rqstp) in cache_check() argument
309 if (rqstp == NULL) { in cache_check()
327 if (!cache_defer_req(rqstp, h)) { in cache_check()
|
| D | clnt.c | 2661 static void rpcproc_encode_null(struct rpc_rqst *rqstp, struct xdr_stream *xdr, in rpcproc_encode_null() argument
2666 static int rpcproc_decode_null(struct rpc_rqst *rqstp, struct xdr_stream *xdr, in rpcproc_decode_null() argument
|
| /net/sunrpc/xprtrdma/ |
| D | svc_rdma_recvfrom.c | 243 void svc_rdma_release_rqst(struct svc_rqst *rqstp) in svc_rdma_release_rqst() argument
245 struct svc_rdma_recv_ctxt *ctxt = rqstp->rq_xprt_ctxt; in svc_rdma_release_rqst()
246 struct svc_xprt *xprt = rqstp->rq_xprt; in svc_rdma_release_rqst()
250 rqstp->rq_xprt_ctxt = NULL; in svc_rdma_release_rqst()
373 static void svc_rdma_build_arg_xdr(struct svc_rqst *rqstp, in svc_rdma_build_arg_xdr() argument
376 struct xdr_buf *arg = &rqstp->rq_arg; in svc_rdma_build_arg_xdr()
692 static void rdma_read_complete(struct svc_rqst *rqstp, in rdma_read_complete() argument
701 put_page(rqstp->rq_pages[page_no]); in rdma_read_complete()
702 rqstp->rq_pages[page_no] = head->rc_pages[page_no]; in rdma_read_complete()
707 rqstp->rq_arg.pages = &rqstp->rq_pages[head->rc_hdr_count]; in rdma_read_complete()
[all …]
|
| D | svc_rdma_rw.c | 630 struct svc_rqst *rqstp, in svc_rdma_build_read_segment() argument
652 rqstp->rq_pages[info->ri_pageno]; in svc_rdma_build_read_segment()
656 sg_set_page(sg, rqstp->rq_pages[info->ri_pageno], in svc_rdma_build_read_segment()
669 &rqstp->rq_pages[info->ri_pageno + 1] > rqstp->rq_page_end) in svc_rdma_build_read_segment()
683 trace_svcrdma_page_overrun_err(cc->cc_rdma, rqstp, info->ri_pageno); in svc_rdma_build_read_segment()
690 static int svc_rdma_build_read_chunk(struct svc_rqst *rqstp, in svc_rdma_build_read_chunk() argument
703 ret = svc_rdma_build_read_segment(info, rqstp, handle, length, in svc_rdma_build_read_chunk()
722 static int svc_rdma_build_normal_read_chunk(struct svc_rqst *rqstp, in svc_rdma_build_normal_read_chunk() argument
729 ret = svc_rdma_build_read_chunk(rqstp, info, p); in svc_rdma_build_normal_read_chunk()
778 static int svc_rdma_build_pz_read_chunk(struct svc_rqst *rqstp, in svc_rdma_build_pz_read_chunk() argument
[all …]
|
| D | svc_rdma_sendto.c | 754 static void svc_rdma_save_io_pages(struct svc_rqst *rqstp, in svc_rdma_save_io_pages() argument
757 int i, pages = rqstp->rq_next_page - rqstp->rq_respages; in svc_rdma_save_io_pages()
761 ctxt->sc_pages[i] = rqstp->rq_respages[i]; in svc_rdma_save_io_pages()
762 rqstp->rq_respages[i] = NULL; in svc_rdma_save_io_pages()
766 rqstp->rq_next_page = rqstp->rq_respages; in svc_rdma_save_io_pages()
790 struct svc_rqst *rqstp) in svc_rdma_send_reply_msg() argument
794 ret = svc_rdma_map_reply_msg(rdma, sctxt, rctxt, &rqstp->rq_res); in svc_rdma_send_reply_msg()
798 svc_rdma_save_io_pages(rqstp, sctxt); in svc_rdma_send_reply_msg()
890 int svc_rdma_sendto(struct svc_rqst *rqstp) in svc_rdma_sendto() argument
892 struct svc_xprt *xprt = rqstp->rq_xprt; in svc_rdma_sendto()
[all …]
|
| D | svc_rdma_backchannel.c | 19 void svc_rdma_handle_bc_reply(struct svc_rqst *rqstp, in svc_rdma_handle_bc_reply() argument
22 struct svc_xprt *sxprt = rqstp->rq_xprt; in svc_rdma_handle_bc_reply()
25 struct xdr_buf *rcvbuf = &rqstp->rq_arg; in svc_rdma_handle_bc_reply()
|
| D | svc_rdma_transport.c | 607 static void svc_rdma_secure_port(struct svc_rqst *rqstp) in svc_rdma_secure_port() argument
609 set_bit(RQ_SECURE, &rqstp->rq_flags); in svc_rdma_secure_port()
|
| /net/sunrpc/auth_gss/ |
| D | svcauth_gss.c | 629 static bool gss_check_seq_num(const struct svc_rqst *rqstp, struct rsc *rsci, in gss_check_seq_num() argument
659 trace_rpcgss_svc_seqno_low(rqstp, seq_num, in gss_check_seq_num()
664 trace_rpcgss_svc_seqno_seen(rqstp, seq_num); in gss_check_seq_num()
713 gss_verify_header(struct svc_rqst *rqstp, struct rsc *rsci, in gss_verify_header() argument
720 struct kvec *argv = &rqstp->rq_arg.head[0]; in gss_verify_header()
737 if (rqstp->rq_deferred) /* skip verification of revisited request */ in gss_verify_header()
745 trace_rpcgss_svc_seqno_large(rqstp, gc->gc_seq); in gss_verify_header()
749 if (!gss_check_seq_num(rqstp, rsci, gc->gc_seq)) in gss_verify_header()
755 gss_write_null_verf(struct svc_rqst *rqstp) in gss_write_null_verf() argument
759 svc_putnl(rqstp->rq_res.head, RPC_AUTH_NULL); in gss_write_null_verf()
[all …]
|
| D | auth_gss.c | 1723 struct rpc_rqst *rqstp = task->tk_rqstp; in gss_wrap_req_integ() local
1724 struct xdr_buf integ_buf, *snd_buf = &rqstp->rq_snd_buf; in gss_wrap_req_integ()
1733 *p = cpu_to_be32(rqstp->rq_seqno); in gss_wrap_req_integ()
1765 priv_release_snd_buf(struct rpc_rqst *rqstp) in priv_release_snd_buf() argument
1769 for (i=0; i < rqstp->rq_enc_pages_num; i++) in priv_release_snd_buf()
1770 __free_page(rqstp->rq_enc_pages[i]); in priv_release_snd_buf()
1771 kfree(rqstp->rq_enc_pages); in priv_release_snd_buf()
1772 rqstp->rq_release_snd_buf = NULL; in priv_release_snd_buf()
1776 alloc_enc_pages(struct rpc_rqst *rqstp) in alloc_enc_pages() argument
1778 struct xdr_buf *snd_buf = &rqstp->rq_snd_buf; in alloc_enc_pages()
[all …]
|
| D | gss_rpc_xdr.h | 170 int gssx_dec_accept_sec_context(struct rpc_rqst *rqstp,
|
| D | gss_rpc_xdr.c | 780 int gssx_dec_accept_sec_context(struct rpc_rqst *rqstp, in gssx_dec_accept_sec_context() argument
|