Home
last modified time | relevance | path

Searched refs:rqstp (Results 1 – 25 of 83) sorted by relevance

1234

/openbmc/linux/net/sunrpc/
H A Dsvc.c639 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 Dsvc_xprt.c558 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 Dsvcsock.c316 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 Dsvcauth.c80 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 Dsvcauth_unix.c682 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 Dsvc4proc.c96 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 Dsvcproc.c105 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 Dxdr4.c152 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 Dxdr.c157 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 Dnfs3xdr.c497 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 Dnfs3proc.c35 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 Dnfsxdr.c278 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 Dnfsproc.c17 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 Dxdr3.h183 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 Dxdr.h145 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 Dnfs2acl.c22 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 Dnfs4proc.c532 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 Dnfs3acl.c20 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 Dvfs.c160 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 Dnfsfh.c83 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 Dsvc.h319 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 Dxdr4.h26 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 Dxdr.h102 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 Dsvcauth_gss.c732 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 Drpcgss.h177 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 …]

1234