/openbmc/linux/net/sunrpc/ |
H A D | svc.c | 639 rqstp = kzalloc_node(sizeof(*rqstp), GFP_KERNEL, node); in svc_rqst_alloc() 640 if (!rqstp) in svc_rqst_alloc() 664 return rqstp; in svc_rqst_alloc() 677 if (!rqstp) in svc_prepare_thread() 894 int i, count = rqstp->rq_next_page - rqstp->rq_respages; in svc_rqst_release_pages() 1512 rqstp->rq_next_page = &rqstp->rq_respages[1]; in svc_process() 1515 rqstp->rq_res.pages = rqstp->rq_next_page; in svc_process() 1573 rqstp->rq_arg.head[0].iov_len = rqstp->rq_arg.len; in bc_svc_process() 1577 rqstp->rq_arg.page_len = rqstp->rq_arg.len - in bc_svc_process() 1580 rqstp->rq_arg.len = rqstp->rq_arg.head[0].iov_len + in bc_svc_process() [all …]
|
H A D | svc_xprt.c | 558 if ((rqstp->rq_res.len) > rqstp->rq_reserved) in svc_xprt_release() 564 svc_reserve(rqstp, 0); in svc_xprt_release() 566 rqstp->rq_xprt = NULL; in svc_xprt_release() 683 rqstp->rq_page_end = &rqstp->rq_pages[pages]; in svc_alloc_arg() 732 if (rqstp->rq_xprt) in svc_get_next_xprt() 752 if (rqstp->rq_xprt) in svc_get_next_xprt() 877 svc_process(rqstp); in svc_recv() 912 xb = &rqstp->rq_res; in svc_send() 1203 memcpy(&dr->addr, &rqstp->rq_addr, rqstp->rq_addrlen); in svc_defer() 1209 skip = rqstp->rq_arg.len - rqstp->rq_arg.head[0].iov_len; in svc_defer() [all …]
|
H A D | svcsock.c | 316 rqstp->rq_respages = &rqstp->rq_pages[i]; in svc_tcp_read_msg() 317 rqstp->rq_next_page = rqstp->rq_respages + 1; in svc_tcp_read_msg() 620 rqstp->rq_daddrlen = svc_addr_len(svc_daddr(rqstp)); in svc_udp_recvfrom() 642 rqstp->rq_respages = rqstp->rq_pages+1; in svc_udp_recvfrom() 644 rqstp->rq_arg.page_len = len - rqstp->rq_arg.head[0].iov_len; in svc_udp_recvfrom() 645 rqstp->rq_respages = rqstp->rq_pages + 1 + in svc_udp_recvfrom() 648 rqstp->rq_next_page = rqstp->rq_respages+1; in svc_udp_recvfrom() 1149 if (rqstp->rq_arg.len <= rqstp->rq_arg.head[0].iov_len) { in svc_tcp_recvfrom() 1150 rqstp->rq_arg.head[0].iov_len = rqstp->rq_arg.len; in svc_tcp_recvfrom() 1153 rqstp->rq_arg.page_len = rqstp->rq_arg.len - rqstp->rq_arg.head[0].iov_len; in svc_tcp_recvfrom() [all …]
|
H A D | svcauth.c | 80 rqstp->rq_auth_stat = rpc_auth_ok; in svc_authenticate() 95 rqstp->rq_auth_slack = 0; in svc_authenticate() 96 init_svc_cred(&rqstp->rq_cred); in svc_authenticate() 98 rqstp->rq_authop = aops; in svc_authenticate() 99 return aops->accept(rqstp); in svc_authenticate() 115 rqstp->rq_client = NULL; in svc_set_client() 116 return rqstp->rq_authop->set_client(rqstp); in svc_set_client() 126 int svc_authorise(struct svc_rqst *rqstp) in svc_authorise() argument 128 struct auth_ops *aops = rqstp->rq_authop; in svc_authorise() 131 rqstp->rq_authop = NULL; in svc_authorise() [all …]
|
H A D | svcauth_unix.c | 682 sin = svc_addr_in(rqstp); in svcauth_unix_set_client() 687 sin6 = svc_addr_in6(rqstp); in svcauth_unix_set_client() 693 rqstp->rq_client = NULL; in svcauth_unix_set_client() 694 if (rqstp->rq_proc == 0) in svcauth_unix_set_client() 797 if (rqstp->rq_client) in svcauth_null_release() 799 rqstp->rq_client = NULL; in svcauth_null_release() 800 if (rqstp->rq_cred.cr_group_info) in svcauth_null_release() 857 if (rqstp->rq_proc != 0) { in svcauth_tls_accept() 946 userns = (rqstp->rq_xprt && rqstp->rq_xprt->xpt_cred) ? in svcauth_unix_accept() 998 if (rqstp->rq_client) in svcauth_unix_release() [all …]
|
/openbmc/linux/fs/lockd/ |
H A D | svc4proc.c | 96 struct nlm_args *argp = rqstp->rq_argp; in __nlm4svc_proc_test() 126 return __nlm4svc_proc_test(rqstp, rqstp->rq_resp); in nlm4svc_proc_test() 175 return __nlm4svc_proc_lock(rqstp, rqstp->rq_resp); in nlm4svc_proc_lock() 190 if (locks_in_grace(SVC_NET(rqstp))) { in __nlm4svc_proc_cancel() 212 return __nlm4svc_proc_cancel(rqstp, rqstp->rq_resp); in nlm4svc_proc_cancel() 230 if (locks_in_grace(SVC_NET(rqstp))) { in __nlm4svc_proc_unlock() 252 return __nlm4svc_proc_unlock(rqstp, rqstp->rq_resp); in nlm4svc_proc_unlock() 275 return __nlm4svc_proc_granted(rqstp, rqstp->rq_resp); in nlm4svc_proc_granted() 308 host = nlmsvc_lookup_host(rqstp, in nlm4svc_callback() 319 stat = func(rqstp, &call->a_res); in nlm4svc_callback() [all …]
|
H A D | svcproc.c | 105 nlmsvc_proc_null(struct svc_rqst *rqstp) in nlmsvc_proc_null() argument 149 return __nlmsvc_proc_test(rqstp, rqstp->rq_resp); in nlmsvc_proc_test() 198 return __nlmsvc_proc_lock(rqstp, rqstp->rq_resp); in nlmsvc_proc_lock() 207 struct net *net = SVC_NET(rqstp); in __nlmsvc_proc_cancel() 236 return __nlmsvc_proc_cancel(rqstp, rqstp->rq_resp); in nlmsvc_proc_cancel() 248 struct net *net = SVC_NET(rqstp); in __nlmsvc_proc_unlock() 277 return __nlmsvc_proc_unlock(rqstp, rqstp->rq_resp); in nlmsvc_proc_unlock() 300 return __nlmsvc_proc_granted(rqstp, rqstp->rq_resp); in nlmsvc_proc_granted() 341 host = nlmsvc_lookup_host(rqstp, in nlmsvc_callback() 352 stat = func(rqstp, &call->a_res); in nlmsvc_callback() [all …]
|
H A D | xdr4.c | 152 struct nlm_args *argp = rqstp->rq_argp; in nlm4svc_decode_testargs() 170 struct nlm_args *argp = rqstp->rq_argp; in nlm4svc_decode_lockargs() 195 struct nlm_args *argp = rqstp->rq_argp; in nlm4svc_decode_cancargs() 215 struct nlm_args *argp = rqstp->rq_argp; in nlm4svc_decode_unlockargs() 229 struct nlm_res *resp = rqstp->rq_argp; in nlm4svc_decode_res() 242 struct nlm_reboot *argp = rqstp->rq_argp; in nlm4svc_decode_reboot() 268 struct nlm_args *argp = rqstp->rq_argp; in nlm4svc_decode_shareargs() 295 struct nlm_args *argp = rqstp->rq_argp; in nlm4svc_decode_notify() 320 struct nlm_res *resp = rqstp->rq_resp; in nlm4svc_encode_testres() 329 struct nlm_res *resp = rqstp->rq_resp; in nlm4svc_encode_res() [all …]
|
H A D | xdr.c | 157 struct nlm_args *argp = rqstp->rq_argp; in nlmsvc_decode_testargs() 175 struct nlm_args *argp = rqstp->rq_argp; in nlmsvc_decode_lockargs() 200 struct nlm_args *argp = rqstp->rq_argp; in nlmsvc_decode_cancargs() 220 struct nlm_args *argp = rqstp->rq_argp; in nlmsvc_decode_unlockargs() 234 struct nlm_res *resp = rqstp->rq_argp; in nlmsvc_decode_res() 247 struct nlm_reboot *argp = rqstp->rq_argp; in nlmsvc_decode_reboot() 273 struct nlm_args *argp = rqstp->rq_argp; in nlmsvc_decode_shareargs() 300 struct nlm_args *argp = rqstp->rq_argp; in nlmsvc_decode_notify() 325 struct nlm_res *resp = rqstp->rq_resp; in nlmsvc_encode_testres() 334 struct nlm_res *resp = rqstp->rq_resp; in nlmsvc_encode_res() [all …]
|
/openbmc/linux/fs/nfsd/ |
H A D | nfs3xdr.c | 497 struct nfsd_fhandle *args = rqstp->rq_argp; in nfs3svc_decode_fhandleargs() 536 struct nfsd3_readargs *args = rqstp->rq_argp; in nfs3svc_decode_readargs() 552 u32 max_blocksize = svc_max_payload(rqstp); in nfs3svc_decode_writeargs() 616 struct kvec *head = rqstp->rq_arg.head; in nfs3svc_decode_symlinkargs() 673 struct nfsd3_linkargs *args = rqstp->rq_argp; in nfs3svc_decode_linkargs() 743 struct nfsd3_attrstat *resp = rqstp->rq_resp; in nfs3svc_encode_getattrres() 821 struct kvec *head = rqstp->rq_res.head; in nfs3svc_encode_readlinkres() 848 struct nfsd3_readres *resp = rqstp->rq_resp; in nfs3svc_encode_readres() 849 struct kvec *head = rqstp->rq_res.head; in nfs3svc_encode_readres() 864 rqstp->rq_res.page_base, in nfs3svc_encode_readres() [all …]
|
H A D | nfs3proc.c | 35 nfsd3_proc_null(struct svc_rqst *rqstp) in nfsd3_proc_null() argument 44 nfsd3_proc_getattr(struct svc_rqst *rqstp) in nfsd3_proc_getattr() argument 88 nfsd3_proc_lookup(struct svc_rqst *rqstp) in nfsd3_proc_lookup() argument 140 resp->pages = rqstp->rq_next_page++; in nfsd3_proc_readlink() 150 nfsd3_proc_read(struct svc_rqst *rqstp) in nfsd3_proc_read() argument 167 resp->pages = rqstp->rq_next_page; in nfsd3_proc_read() 209 rqstp->rq_vec, nvecs, &cnt, in nfsd3_proc_write() 558 svc_max_payload(rqstp)); in nfsd3_init_dirlist_pages() 565 buf->pages = rqstp->rq_next_page; in nfsd3_init_dirlist_pages() 590 resp->rqstp = rqstp; in nfsd3_proc_readdir() [all …]
|
H A D | nfsxdr.c | 278 struct nfsd_fhandle *args = rqstp->rq_argp; in nfssvc_decode_fhandleargs() 303 struct nfsd_readargs *args = rqstp->rq_argp; in nfssvc_decode_readargs() 369 struct nfsd_linkargs *args = rqstp->rq_argp; in nfssvc_decode_linkargs() 380 struct kvec *head = rqstp->rq_arg.head; in nfssvc_decode_symlinkargs() 418 struct nfsd_stat *resp = rqstp->rq_resp; in nfssvc_encode_statres() 426 struct nfsd_attrstat *resp = rqstp->rq_resp; in nfssvc_encode_attrstatres() 463 struct kvec *head = rqstp->rq_res.head; in nfssvc_encode_readlinkres() 484 struct nfsd_readres *resp = rqstp->rq_resp; in nfssvc_encode_readres() 485 struct kvec *head = rqstp->rq_res.head; in nfssvc_encode_readres() 496 rqstp->rq_res.page_base, in nfssvc_encode_readres() [all …]
|
H A D | nfsproc.c | 17 nfsd_proc_null(struct svc_rqst *rqstp) in nfsd_proc_null() argument 27 nfsd_proc_getattr(struct svc_rqst *rqstp) in nfsd_proc_getattr() argument 29 struct nfsd_fhandle *argp = rqstp->rq_argp; in nfsd_proc_getattr() 49 nfsd_proc_setattr(struct svc_rqst *rqstp) in nfsd_proc_setattr() argument 117 nfsd_proc_root(struct svc_rqst *rqstp) in nfsd_proc_root() argument 162 resp->page = *(rqstp->rq_next_page++); in nfsd_proc_readlink() 175 nfsd_proc_read(struct svc_rqst *rqstp) in nfsd_proc_read() argument 188 resp->pages = rqstp->rq_next_page; in nfsd_proc_read() 202 set_bit(RQ_DROPME, &rqstp->rq_flags); in nfsd_proc_read() 563 buf->pages = rqstp->rq_next_page; in nfsd_init_dirlist_pages() [all …]
|
H A D | xdr3.h | 183 struct svc_rqst * rqstp; member 269 bool nfs3svc_decode_sattrargs(struct svc_rqst *rqstp, struct xdr_stream *xdr); 270 bool nfs3svc_decode_diropargs(struct svc_rqst *rqstp, struct xdr_stream *xdr); 272 bool nfs3svc_decode_readargs(struct svc_rqst *rqstp, struct xdr_stream *xdr); 273 bool nfs3svc_decode_writeargs(struct svc_rqst *rqstp, struct xdr_stream *xdr); 275 bool nfs3svc_decode_mkdirargs(struct svc_rqst *rqstp, struct xdr_stream *xdr); 278 bool nfs3svc_decode_linkargs(struct svc_rqst *rqstp, struct xdr_stream *xdr); 285 bool nfs3svc_encode_wccstat(struct svc_rqst *rqstp, struct xdr_stream *xdr); 289 bool nfs3svc_encode_readres(struct svc_rqst *rqstp, struct xdr_stream *xdr); 290 bool nfs3svc_encode_writeres(struct svc_rqst *rqstp, struct xdr_stream *xdr); [all …]
|
H A D | xdr.h | 145 bool nfssvc_decode_sattrargs(struct svc_rqst *rqstp, struct xdr_stream *xdr); 146 bool nfssvc_decode_diropargs(struct svc_rqst *rqstp, struct xdr_stream *xdr); 147 bool nfssvc_decode_readargs(struct svc_rqst *rqstp, struct xdr_stream *xdr); 151 bool nfssvc_decode_linkargs(struct svc_rqst *rqstp, struct xdr_stream *xdr); 155 bool nfssvc_encode_statres(struct svc_rqst *rqstp, struct xdr_stream *xdr); 157 bool nfssvc_encode_diropres(struct svc_rqst *rqstp, struct xdr_stream *xdr); 159 bool nfssvc_encode_readres(struct svc_rqst *rqstp, struct xdr_stream *xdr); 167 void nfssvc_release_attrstat(struct svc_rqst *rqstp); 168 void nfssvc_release_diropres(struct svc_rqst *rqstp); 169 void nfssvc_release_readres(struct svc_rqst *rqstp); [all …]
|
H A D | nfs2acl.c | 22 nfsacld_proc_null(struct svc_rqst *rqstp) in nfsacld_proc_null() argument 32 struct nfsd3_getaclargs *argp = rqstp->rq_argp; in nfsacld_proc_getacl() 33 struct nfsd3_getaclres *resp = rqstp->rq_resp; in nfsacld_proc_getacl() 95 struct nfsd3_setaclargs *argp = rqstp->rq_argp; in nfsacld_proc_setacl() 96 struct nfsd_attrstat *resp = rqstp->rq_resp; in nfsacld_proc_setacl() 151 struct nfsd_fhandle *argp = rqstp->rq_argp; in nfsacld_proc_getattr() 152 struct nfsd_attrstat *resp = rqstp->rq_resp; in nfsacld_proc_getattr() 170 struct nfsd3_accessargs *argp = rqstp->rq_argp; in nfsacld_proc_access() 171 struct nfsd3_accessres *resp = rqstp->rq_resp; in nfsacld_proc_access() 246 struct nfsd3_getaclres *resp = rqstp->rq_resp; in nfsaclsvc_encode_getaclres() [all …]
|
H A D | nfs4proc.c | 532 struct net *net = SVC_NET(rqstp); in nfsd4_open() 541 open->op_rqstp = rqstp; in nfsd4_open() 981 read->rd_rqstp = rqstp; in nfsd4_read() 1017 readdir->rd_rqstp = rqstp; in nfsd4_readdir() 1026 u->readlink.rl_rqstp = rqstp; in nfsd4_readlink() 2098 rqstp, 0); in _nfsd4_verify() 2197 rqstp, cstate->clp, gdp); in nfsd4_getdeviceinfo() 2637 resp->rqstp = rqstp; in nfsd4_proc_compound() 2741 need_wrongsec_check(rqstp)) in nfsd4_proc_compound() 2799 buflen = (rqstp->rq_page_end - rqstp->rq_next_page) * PAGE_SIZE; in nfsd4_max_payload() [all …]
|
H A D | nfs3acl.c | 20 nfsd3_proc_null(struct svc_rqst *rqstp) in nfsd3_proc_null() argument 28 static __be32 nfsd3_proc_getacl(struct svc_rqst *rqstp) in nfsd3_proc_getacl() argument 30 struct nfsd3_getaclargs *argp = rqstp->rq_argp; in nfsd3_proc_getacl() 31 struct nfsd3_getaclres *resp = rqstp->rq_resp; in nfsd3_proc_getacl() 87 struct nfsd3_setaclargs *argp = rqstp->rq_argp; in nfsd3_proc_setacl() 88 struct nfsd3_attrstat *resp = rqstp->rq_resp; in nfsd3_proc_setacl() 133 struct nfsd3_getaclargs *args = rqstp->rq_argp; in nfs3svc_decode_getaclargs() 146 struct nfsd3_setaclargs *argp = rqstp->rq_argp; in nfs3svc_decode_setaclargs() 172 struct nfsd3_getaclres *resp = rqstp->rq_resp; in nfs3svc_encode_getaclres() 206 struct nfsd3_attrstat *resp = rqstp->rq_resp; in nfs3svc_encode_setaclres() [all …]
|
H A D | vfs.c | 160 if (nfsd_v4client(rqstp) || in nfsd_cross_mnt() 199 exp2 = rqst_exp_parent(rqstp, &path); in nfsd_lookup_parent() 324 err = check_nfsd_access(exp, rqstp); in nfsd_lookup() 956 rqstp->rq_res.page_len)) in nfsd_splice_actor() 963 rqstp->rq_res.page_len += sd->len; in nfsd_splice_actor() 1020 .u.data = rqstp, in nfsd_splice_read() 1058 page = *(rqstp->rq_next_page++); in nfsd_iter_read() 1061 total -= rqstp->rq_vec[v].iov_len; in nfsd_iter_read() 1961 if (nfsd_v4client(rqstp)) in nfsd_unlink() 2106 if (rqstp->rq_vers > 2) in nfsd_readdir() [all …]
|
H A D | nfsfh.c | 83 if (rqstp->rq_vers == 4 && mode == S_IFLNK) in nfsd_mode_check() 97 if (rqstp->rq_cred.cr_flavor >= RPC_AUTH_GSS) in nfsd_originating_port_ok() 99 return test_bit(RQ_SECURE, &rqstp->rq_flags); in nfsd_originating_port_ok() 105 int flags = nfsexp_flags(rqstp, exp); in nfsd_setuser_and_check_port() 116 return nfserrno(nfsd_setuser(rqstp, exp)); in nfsd_setuser_and_check_port() 130 if (!nfsd_v4client(rqstp)) in check_pseudo_root() 166 if (rqstp->rq_vers > 2) in nfsd_set_fh_dentry() 241 if (rqstp->rq_vers > 2) in nfsd_set_fh_dentry() 281 switch (rqstp->rq_vers) { in nfsd_set_fh_dentry() 335 error = nfsd_set_fh_dentry(rqstp, fhp); in fh_verify() [all …]
|
/openbmc/linux/include/linux/sunrpc/ |
H A D | svc.h | 319 int (*dispatch)(struct svc_rqst *rqstp); 381 bool (*pc_decode)(struct svc_rqst *rqstp, 460 svc_reserve(rqstp, space + rqstp->rq_auth_slack); in svc_reserve_auth() 471 struct xdr_buf *buf = &rqstp->rq_arg; in svcxdr_init_decode() 489 struct xdr_buf *buf = &rqstp->rq_res; in svcxdr_init_encode() 522 xdr->page_ptr = rqstp->rq_next_page - 1; in svcxdr_encode_opaque_pages() 536 struct xdr_buf *buf = &rqstp->rq_res; in svcxdr_set_auth_slack() 539 rqstp->rq_auth_slack = slack; in svcxdr_set_auth_slack() 542 buf->buflen -= rqstp->rq_auth_slack; in svcxdr_set_auth_slack() 561 if (unlikely(!rqstp->rq_accept_statp)) in svcxdr_set_accept_stat() [all …]
|
/openbmc/linux/include/linux/lockd/ |
H A D | xdr4.h | 26 bool nlm4svc_decode_void(struct svc_rqst *rqstp, struct xdr_stream *xdr); 27 bool nlm4svc_decode_testargs(struct svc_rqst *rqstp, struct xdr_stream *xdr); 28 bool nlm4svc_decode_lockargs(struct svc_rqst *rqstp, struct xdr_stream *xdr); 29 bool nlm4svc_decode_cancargs(struct svc_rqst *rqstp, struct xdr_stream *xdr); 31 bool nlm4svc_decode_res(struct svc_rqst *rqstp, struct xdr_stream *xdr); 32 bool nlm4svc_decode_reboot(struct svc_rqst *rqstp, struct xdr_stream *xdr); 34 bool nlm4svc_decode_notify(struct svc_rqst *rqstp, struct xdr_stream *xdr); 36 bool nlm4svc_encode_testres(struct svc_rqst *rqstp, struct xdr_stream *xdr); 37 bool nlm4svc_encode_res(struct svc_rqst *rqstp, struct xdr_stream *xdr); 38 bool nlm4svc_encode_void(struct svc_rqst *rqstp, struct xdr_stream *xdr); [all …]
|
H A D | xdr.h | 102 bool nlmsvc_decode_void(struct svc_rqst *rqstp, struct xdr_stream *xdr); 103 bool nlmsvc_decode_testargs(struct svc_rqst *rqstp, struct xdr_stream *xdr); 104 bool nlmsvc_decode_lockargs(struct svc_rqst *rqstp, struct xdr_stream *xdr); 105 bool nlmsvc_decode_cancargs(struct svc_rqst *rqstp, struct xdr_stream *xdr); 107 bool nlmsvc_decode_res(struct svc_rqst *rqstp, struct xdr_stream *xdr); 108 bool nlmsvc_decode_reboot(struct svc_rqst *rqstp, struct xdr_stream *xdr); 110 bool nlmsvc_decode_notify(struct svc_rqst *rqstp, struct xdr_stream *xdr); 112 bool nlmsvc_encode_testres(struct svc_rqst *rqstp, struct xdr_stream *xdr); 113 bool nlmsvc_encode_res(struct svc_rqst *rqstp, struct xdr_stream *xdr); 114 bool nlmsvc_encode_void(struct svc_rqst *rqstp, struct xdr_stream *xdr); [all …]
|
/openbmc/linux/net/sunrpc/auth_gss/ |
H A D | svcauth_gss.c | 732 if (rqstp->rq_deferred) in svcauth_gss_verify_header() 878 if (rqstp->rq_deferred) in svcauth_gss_unwrap_integ() 955 if (rqstp->rq_deferred) { in svcauth_gss_unwrap_priv() 1659 if (rqstp->rq_proc != 0) in svcauth_gss_accept() 1663 if (rqstp->rq_proc != 0) in svcauth_gss_accept() 1681 if (rqstp->rq_proc != 0) in svcauth_gss_accept() 1704 rqstp->rq_cred = rsci->cred; in svcauth_gss_accept() 1979 if (rqstp->rq_client) in svcauth_gss_release() 1981 rqstp->rq_client = NULL; in svcauth_gss_release() 1982 if (rqstp->rq_gssclient) in svcauth_gss_release() [all …]
|
/openbmc/linux/include/trace/events/ |
H A D | rpcgss.h | 177 const struct svc_rqst *rqstp, 181 TP_ARGS(rqstp, maj_stat), 207 TP_ARGS(rqstp, maj_stat)) 216 const struct svc_rqst *rqstp 219 TP_ARGS(rqstp), 236 const struct svc_rqst *rqstp 239 TP_ARGS(rqstp), 256 const struct svc_rqst *rqstp, 319 TP_ARGS(rqstp, gc), 495 TP_ARGS(rqstp, seqno), [all …]
|