Home
last modified time | relevance | path

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

1234

/linux/net/sunrpc/
A Dsvc.c610 rqstp = kzalloc_node(sizeof(*rqstp), GFP_KERNEL, node); in svc_rqst_alloc()
611 if (!rqstp) in svc_rqst_alloc()
634 return rqstp; in svc_rqst_alloc()
647 if (!rqstp) in svc_prepare_thread()
856 pagevec_add(&rqstp->rq_pvec, *rqstp->rq_next_page); in svc_rqst_replace_page()
1467 rqstp->rq_next_page = &rqstp->rq_respages[1]; in svc_process()
1470 rqstp->rq_res.pages = rqstp->rq_respages + 1; in svc_process()
1527 rqstp->rq_arg.head[0].iov_len = rqstp->rq_arg.len; in bc_svc_process()
1531 rqstp->rq_arg.page_len = rqstp->rq_arg.len - in bc_svc_process()
1534 rqstp->rq_arg.len = rqstp->rq_arg.head[0].iov_len + in bc_svc_process()
[all …]
A Dsvc_xprt.c465 rqstp = NULL; in svc_xprt_do_enqueue()
552 if ((rqstp->rq_res.len) > rqstp->rq_reserved) in svc_xprt_release()
693 rqstp->rq_page_end = &rqstp->rq_pages[pages]; in svc_alloc_arg()
741 if (rqstp->rq_xprt) in svc_get_next_xprt()
764 if (rqstp->rq_xprt) in svc_get_next_xprt()
833 rqstp, rqstp->rq_pool->sp_id, xprt, in svc_handle_xprt()
889 rqstp->rq_xid = svc_getu32(&rqstp->rq_arg.head[0]); in svc_recv()
926 xb = &rqstp->rq_res; in svc_send()
1212 memcpy(&dr->addr, &rqstp->rq_addr, rqstp->rq_addrlen); in svc_defer()
1219 skip = rqstp->rq_arg.len - rqstp->rq_arg.head[0].iov_len; in svc_defer()
[all …]
A Dsvcsock.c271 rqstp->rq_respages = &rqstp->rq_pages[i]; in svc_tcp_read_msg()
272 rqstp->rq_next_page = rqstp->rq_respages + 1; in svc_tcp_read_msg()
489 rqstp->rq_daddrlen = svc_addr_len(svc_daddr(rqstp)); in svc_udp_recvfrom()
511 rqstp->rq_respages = rqstp->rq_pages+1; in svc_udp_recvfrom()
513 rqstp->rq_arg.page_len = len - rqstp->rq_arg.head[0].iov_len; in svc_udp_recvfrom()
514 rqstp->rq_respages = rqstp->rq_pages + 1 + in svc_udp_recvfrom()
517 rqstp->rq_next_page = rqstp->rq_respages+1; in svc_udp_recvfrom()
828 rqstp->rq_arg.head[0].iov_base = page_address(rqstp->rq_pages[0]); in svc_tcp_restore_pages()
1010 if (rqstp->rq_arg.len <= rqstp->rq_arg.head[0].iov_len) { in svc_tcp_recvfrom()
1011 rqstp->rq_arg.head[0].iov_len = rqstp->rq_arg.len; in svc_tcp_recvfrom()
[all …]
A Dsvcauth.c62 svc_authenticate(struct svc_rqst *rqstp) in svc_authenticate() argument
67 rqstp->rq_auth_stat = rpc_auth_ok; 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); in svc_authenticate()
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
103 rqstp->rq_authop = NULL; in svc_authorise()
[all …]
A Dsvcauth_unix.c671 sin = svc_addr_in(rqstp); in svcauth_unix_set_client()
676 sin6 = svc_addr_in6(rqstp); in svcauth_unix_set_client()
682 rqstp->rq_client = NULL; in svcauth_unix_set_client()
683 if (rqstp->rq_proc == 0) in svcauth_unix_set_client()
770 if (rqstp->rq_client) in svcauth_null_release()
772 rqstp->rq_client = NULL; in svcauth_null_release()
773 if (rqstp->rq_cred.cr_group_info) in svcauth_null_release()
818 userns = (rqstp->rq_xprt && rqstp->rq_xprt->xpt_cred) ? in svcauth_unix_accept()
855 if (rqstp->rq_client) in svcauth_unix_release()
857 rqstp->rq_client = NULL; in svcauth_unix_release()
[all …]
/linux/fs/lockd/
A Dsvc4proc.c87 struct nlm_args *argp = rqstp->rq_argp; in __nlm4svc_proc_test()
115 return __nlm4svc_proc_test(rqstp, rqstp->rq_resp); in nlm4svc_proc_test()
164 return __nlm4svc_proc_lock(rqstp, rqstp->rq_resp); in nlm4svc_proc_lock()
179 if (locks_in_grace(SVC_NET(rqstp))) { in __nlm4svc_proc_cancel()
201 return __nlm4svc_proc_cancel(rqstp, rqstp->rq_resp); in nlm4svc_proc_cancel()
219 if (locks_in_grace(SVC_NET(rqstp))) { in __nlm4svc_proc_unlock()
241 return __nlm4svc_proc_unlock(rqstp, rqstp->rq_resp); in nlm4svc_proc_unlock()
264 return __nlm4svc_proc_granted(rqstp, rqstp->rq_resp); in nlm4svc_proc_granted()
297 host = nlmsvc_lookup_host(rqstp, in nlm4svc_callback()
308 stat = func(rqstp, &call->a_res); in nlm4svc_callback()
[all …]
A Dsvcproc.c104 nlmsvc_proc_null(struct svc_rqst *rqstp) in nlmsvc_proc_null() argument
145 return __nlmsvc_proc_test(rqstp, rqstp->rq_resp); in nlmsvc_proc_test()
194 return __nlmsvc_proc_lock(rqstp, rqstp->rq_resp); in nlmsvc_proc_lock()
203 struct net *net = SVC_NET(rqstp); in __nlmsvc_proc_cancel()
232 return __nlmsvc_proc_cancel(rqstp, rqstp->rq_resp); in nlmsvc_proc_cancel()
244 struct net *net = SVC_NET(rqstp); in __nlmsvc_proc_unlock()
273 return __nlmsvc_proc_unlock(rqstp, rqstp->rq_resp); in nlmsvc_proc_unlock()
296 return __nlmsvc_proc_granted(rqstp, rqstp->rq_resp); in nlmsvc_proc_granted()
337 host = nlmsvc_lookup_host(rqstp, in nlmsvc_callback()
348 stat = func(rqstp, &call->a_res); in nlmsvc_callback()
[all …]
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 …]
A Dxdr4.c156 struct nlm_args *argp = rqstp->rq_argp; in nlm4svc_decode_testargs()
174 struct nlm_args *argp = rqstp->rq_argp; in nlm4svc_decode_lockargs()
199 struct nlm_args *argp = rqstp->rq_argp; in nlm4svc_decode_cancargs()
219 struct nlm_args *argp = rqstp->rq_argp; in nlm4svc_decode_unlockargs()
233 struct nlm_res *resp = rqstp->rq_argp; in nlm4svc_decode_res()
246 struct nlm_reboot *argp = rqstp->rq_argp; in nlm4svc_decode_reboot()
272 struct nlm_args *argp = rqstp->rq_argp; in nlm4svc_decode_shareargs()
299 struct nlm_args *argp = rqstp->rq_argp; in nlm4svc_decode_notify()
324 struct nlm_res *resp = rqstp->rq_resp; in nlm4svc_encode_testres()
333 struct nlm_res *resp = rqstp->rq_resp; in nlm4svc_encode_res()
[all …]
/linux/fs/nfsd/
A Dnfs3proc.c33 nfsd3_proc_null(struct svc_rqst *rqstp) in nfsd3_proc_null() argument
42 nfsd3_proc_getattr(struct svc_rqst *rqstp) in nfsd3_proc_getattr() argument
83 nfsd3_proc_lookup(struct svc_rqst *rqstp) in nfsd3_proc_lookup() argument
135 resp->pages = rqstp->rq_next_page++; in nfsd3_proc_readlink()
145 nfsd3_proc_read(struct svc_rqst *rqstp) in nfsd3_proc_read() argument
162 resp->pages = rqstp->rq_next_page; in nfsd3_proc_read()
168 len -= rqstp->rq_vec[v].iov_len; in nfsd3_proc_read()
210 rqstp->rq_vec, nvecs, &cnt, in nfsd3_proc_write()
452 buf->pages = rqstp->rq_next_page; in nfsd3_init_dirlist_pages()
485 resp->rqstp = rqstp; in nfsd3_proc_readdir()
[all …]
A Dnfs3xdr.c562 struct nfsd_fhandle *args = rqstp->rq_argp; in nfs3svc_decode_fhandleargs()
601 struct nfsd3_readargs *args = rqstp->rq_argp; in nfs3svc_decode_readargs()
617 u32 max_blocksize = svc_max_payload(rqstp); in nfs3svc_decode_writeargs()
683 struct kvec *head = rqstp->rq_arg.head; in nfs3svc_decode_symlinkargs()
684 struct kvec *tail = rqstp->rq_arg.tail; in nfs3svc_decode_symlinkargs()
748 struct nfsd3_linkargs *args = rqstp->rq_argp; in nfs3svc_decode_linkargs()
818 struct nfsd3_attrstat *resp = rqstp->rq_resp; in nfs3svc_encode_getattrres()
896 struct kvec *head = rqstp->rq_res.head; in nfs3svc_encode_readlinkres()
922 struct nfsd3_readres *resp = rqstp->rq_resp; in nfs3svc_encode_readres()
923 struct kvec *head = rqstp->rq_res.head; in nfs3svc_encode_readres()
[all …]
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
114 nfsd_proc_root(struct svc_rqst *rqstp) in nfsd_proc_root() argument
159 resp->page = *(rqstp->rq_next_page++); in nfsd_proc_readlink()
172 nfsd_proc_read(struct svc_rqst *rqstp) in nfsd_proc_read() argument
188 resp->pages = rqstp->rq_next_page; in nfsd_proc_read()
194 len -= rqstp->rq_vec[v].iov_len; in nfsd_proc_read()
570 buf->pages = rqstp->rq_next_page; in nfsd_init_dirlist_pages()
[all …]
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()
371 struct nfsd_linkargs *args = rqstp->rq_argp; in nfssvc_decode_linkargs()
382 struct kvec *head = rqstp->rq_arg.head; in nfssvc_decode_symlinkargs()
420 struct nfsd_stat *resp = rqstp->rq_resp; in nfssvc_encode_statres()
428 struct nfsd_attrstat *resp = rqstp->rq_resp; in nfssvc_encode_attrstatres()
445 struct nfsd_diropres *resp = rqstp->rq_resp; in nfssvc_encode_diropres()
465 struct kvec *head = rqstp->rq_res.head; in nfssvc_encode_readlinkres()
485 struct nfsd_readres *resp = rqstp->rq_resp; in nfssvc_encode_readres()
486 struct kvec *head = rqstp->rq_res.head; in nfssvc_encode_readres()
[all …]
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 …]
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()
171 struct nfsd3_accessres *resp = rqstp->rq_resp; in nfsacld_proc_access()
246 struct nfsd3_getaclres *resp = rqstp->rq_resp; in nfsaclsvc_encode_getaclres()
263 rqstp->rq_res.page_len = w = nfsacl_size( in nfsaclsvc_encode_getaclres()
[all …]
A Dnfs4proc.c370 struct net *net = SVC_NET(rqstp); in nfsd4_open()
799 if (!nfsd4_last_compound_op(rqstp)) in nfsd4_read()
812 read->rd_rqstp = rqstp; in nfsd4_read()
848 readdir->rd_rqstp = rqstp; in nfsd4_readdir()
857 u->readlink.rl_rqstp = rqstp; in nfsd4_readlink()
1934 rqstp, 0); in _nfsd4_verify()
2033 rqstp, cstate->clp, gdp); in nfsd4_getdeviceinfo()
2473 resp->rqstp = rqstp; in nfsd4_proc_compound()
2570 need_wrongsec_check(rqstp)) in nfsd4_proc_compound()
2658 return svc_max_payload(rqstp); in nfsd4_getattr_rsize()
[all …]
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 …]
A Dnfs3acl.c20 nfsd3_proc_null(struct svc_rqst *rqstp) in nfsd3_proc_null() 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()
172 struct nfsd3_getaclres *resp = rqstp->rq_resp; in nfs3svc_encode_getaclres()
174 struct kvec *head = rqstp->rq_res.head; in nfs3svc_encode_getaclres()
192 rqstp->rq_res.page_len = w = nfsacl_size( in nfs3svc_encode_getaclres()
196 if (!*(rqstp->rq_next_page++)) in nfs3svc_encode_getaclres()
[all …]
A Dvfs.c93 if (nfsd_v4client(rqstp) || in nfsd_cross_mnt()
132 exp2 = rqst_exp_parent(rqstp, &path); in nfsd_lookup_parent()
263 err = check_nfsd_access(exp, rqstp); in nfsd_lookup()
827 if (rqstp->rq_res.page_len == 0) { in nfsd_splice_actor()
833 rqstp->rq_res.page_len += sd->len; in nfsd_splice_actor()
879 .u.data = rqstp, in nfsd_splice_read()
884 rqstp->rq_next_page = rqstp->rq_respages + 1; in nfsd_splice_read()
999 net_generic(SVC_NET(rqstp), in nfsd_vfs_write()
1900 if (nfsd_v4client(rqstp)) in nfsd_unlink()
2042 if (rqstp->rq_vers > 2) in nfsd_readdir()
[all …]
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()
337 error = nfsd_set_fh_dentry(rqstp, fhp); in fh_verify()
[all …]
/linux/include/linux/lockd/
A Dxdr4.h25 bool nlm4svc_decode_void(struct svc_rqst *rqstp, struct xdr_stream *xdr);
26 bool nlm4svc_decode_testargs(struct svc_rqst *rqstp, struct xdr_stream *xdr);
27 bool nlm4svc_decode_lockargs(struct svc_rqst *rqstp, struct xdr_stream *xdr);
28 bool nlm4svc_decode_cancargs(struct svc_rqst *rqstp, struct xdr_stream *xdr);
30 bool nlm4svc_decode_res(struct svc_rqst *rqstp, struct xdr_stream *xdr);
31 bool nlm4svc_decode_reboot(struct svc_rqst *rqstp, struct xdr_stream *xdr);
33 bool nlm4svc_decode_notify(struct svc_rqst *rqstp, struct xdr_stream *xdr);
35 bool nlm4svc_encode_testres(struct svc_rqst *rqstp, struct xdr_stream *xdr);
36 bool nlm4svc_encode_res(struct svc_rqst *rqstp, struct xdr_stream *xdr);
37 bool nlm4svc_encode_void(struct svc_rqst *rqstp, struct xdr_stream *xdr);
[all …]
A Dxdr.h99 bool nlmsvc_decode_void(struct svc_rqst *rqstp, struct xdr_stream *xdr);
100 bool nlmsvc_decode_testargs(struct svc_rqst *rqstp, struct xdr_stream *xdr);
101 bool nlmsvc_decode_lockargs(struct svc_rqst *rqstp, struct xdr_stream *xdr);
102 bool nlmsvc_decode_cancargs(struct svc_rqst *rqstp, struct xdr_stream *xdr);
104 bool nlmsvc_decode_res(struct svc_rqst *rqstp, struct xdr_stream *xdr);
105 bool nlmsvc_decode_reboot(struct svc_rqst *rqstp, struct xdr_stream *xdr);
107 bool nlmsvc_decode_notify(struct svc_rqst *rqstp, struct xdr_stream *xdr);
109 bool nlmsvc_encode_testres(struct svc_rqst *rqstp, struct xdr_stream *xdr);
110 bool nlmsvc_encode_res(struct svc_rqst *rqstp, struct xdr_stream *xdr);
111 bool nlmsvc_encode_void(struct svc_rqst *rqstp, struct xdr_stream *xdr);
[all …]
/linux/include/linux/sunrpc/
A Dsvc.h353 struct kvec *vec = &rqstp->rq_arg.head[0]; in xdr_argsize_check()
361 struct kvec *vec = &rqstp->rq_res.head[0]; in xdr_ressize_check()
371 while (rqstp->rq_next_page != rqstp->rq_respages) { in svc_free_res_pages()
372 struct page **pp = --rqstp->rq_next_page; in svc_free_res_pages()
457 bool (*pc_decode)(struct svc_rqst *rqstp,
460 bool (*pc_encode)(struct svc_rqst *rqstp,
563 svc_reserve(rqstp, space + rqstp->rq_auth_slack); in svc_reserve_auth()
573 struct xdr_stream *xdr = &rqstp->rq_arg_stream; in svcxdr_init_decode()
574 struct kvec *argv = rqstp->rq_arg.head; in svcxdr_init_decode()
588 struct xdr_buf *buf = &rqstp->rq_res; in svcxdr_init_encode()
[all …]
/linux/net/sunrpc/auth_gss/
A Dsvcauth_gss.c762 p = rqstp->rq_res.head->iov_base + rqstp->rq_res.head->iov_len; in gss_write_null_verf()
790 p = rqstp->rq_res.head->iov_base + rqstp->rq_res.head->iov_len; in gss_write_verf()
906 if (rqstp->rq_deferred) in unwrap_integ_data()
978 if (rqstp->rq_deferred) { in unwrap_priv_data()
1628 rqstp->rq_cred = rsci->cred; in svcauth_gss_accept()
1638 if (unwrap_integ_data(rqstp, &rqstp->rq_arg, in svcauth_gss_accept()
1647 if (unwrap_priv_data(rqstp, &rqstp->rq_arg, in svcauth_gss_accept()
1872 if (rqstp->rq_client) in svcauth_gss_release()
1874 rqstp->rq_client = NULL; in svcauth_gss_release()
1875 if (rqstp->rq_gssclient) in svcauth_gss_release()
[all …]
/linux/include/trace/events/
A Drpcgss.h177 const struct svc_rqst *rqstp,
181 TP_ARGS(rqstp, maj_stat),
207 TP_ARGS(rqstp, maj_stat))
214 const struct svc_rqst *rqstp
217 TP_ARGS(rqstp),
234 const struct svc_rqst *rqstp,
262 const struct svc_rqst *rqstp,
293 const struct svc_rqst *rqstp,
297 TP_ARGS(rqstp, gc),
473 TP_ARGS(rqstp, seqno),
[all …]

Completed in 68 milliseconds

1234