Home
last modified time | relevance | path

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

1234

/linux-6.15/net/sunrpc/
H A Dsvc.c690 rqstp = kzalloc_node(sizeof(*rqstp), GFP_KERNEL, node); in svc_prepare_thread()
691 if (!rqstp) in svc_prepare_thread()
724 return rqstp; in svc_prepare_thread()
810 if (!rqstp) in svc_start_kthreads()
931 int i, count = rqstp->rq_next_page - rqstp->rq_respages; in svc_rqst_release_pages()
1556 rqstp->rq_next_page = &rqstp->rq_respages[1]; in svc_process()
1559 rqstp->rq_res.pages = rqstp->rq_next_page; in svc_process()
1617 rqstp->rq_arg.head[0].iov_len = rqstp->rq_arg.len; in svc_process_bc()
1621 rqstp->rq_arg.page_len = rqstp->rq_arg.len - in svc_process_bc()
1624 rqstp->rq_arg.len = rqstp->rq_arg.head[0].iov_len + in svc_process_bc()
[all …]
H A Dsvc_xprt.c563 if ((rqstp->rq_res.len) > rqstp->rq_reserved) in svc_xprt_release()
569 svc_reserve(rqstp, 0); in svc_xprt_release()
571 rqstp->rq_xprt = NULL; in svc_xprt_release()
680 rqstp->rq_page_end = &rqstp->rq_pages[pages]; in svc_alloc_arg()
824 svc_process(rqstp); in svc_handle_xprt()
867 if (rqstp->rq_xprt) { in svc_recv()
914 xb = &rqstp->rq_res; in svc_send()
1178 if (rqstp->rq_arg.page_len || !test_bit(RQ_USEDEFERRAL, &rqstp->rq_flags)) in svc_defer()
1194 memcpy(&dr->addr, &rqstp->rq_addr, rqstp->rq_addrlen); in svc_defer()
1200 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()
1136 if (rqstp->rq_arg.len <= rqstp->rq_arg.head[0].iov_len) { in svc_tcp_recvfrom()
1137 rqstp->rq_arg.head[0].iov_len = rqstp->rq_arg.len; in svc_tcp_recvfrom()
1140 rqstp->rq_arg.page_len = rqstp->rq_arg.len - rqstp->rq_arg.head[0].iov_len; in svc_tcp_recvfrom()
[all …]
H A Dsvcauth.c81 rqstp->rq_auth_stat = rpc_auth_ok; in svc_authenticate()
96 rqstp->rq_auth_slack = 0; in svc_authenticate()
97 init_svc_cred(&rqstp->rq_cred); in svc_authenticate()
99 rqstp->rq_authop = aops; in svc_authenticate()
100 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
131 rqstp->rq_authop = NULL; in svc_authorise()
134 rv = aops->release(rqstp); 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()
798 if (rqstp->rq_client) in svcauth_null_release()
800 rqstp->rq_client = NULL; in svcauth_null_release()
801 if (rqstp->rq_cred.cr_group_info) in svcauth_null_release()
858 if (rqstp->rq_proc != 0) { in svcauth_tls_accept()
947 userns = (rqstp->rq_xprt && rqstp->rq_xprt->xpt_cred) ? in svcauth_unix_accept()
999 if (rqstp->rq_client) in svcauth_unix_release()
[all …]
/linux-6.15/fs/lockd/
H A Dsvc4proc.c97 struct nlm_args *argp = rqstp->rq_argp; in __nlm4svc_proc_test()
128 return __nlm4svc_proc_test(rqstp, rqstp->rq_resp); in nlm4svc_proc_test()
165 return __nlm4svc_proc_lock(rqstp, rqstp->rq_resp); in nlm4svc_proc_lock()
180 if (locks_in_grace(SVC_NET(rqstp))) { in __nlm4svc_proc_cancel()
202 return __nlm4svc_proc_cancel(rqstp, rqstp->rq_resp); in nlm4svc_proc_cancel()
220 if (locks_in_grace(SVC_NET(rqstp))) { in __nlm4svc_proc_unlock()
242 return __nlm4svc_proc_unlock(rqstp, rqstp->rq_resp); in nlm4svc_proc_unlock()
265 return __nlm4svc_proc_granted(rqstp, rqstp->rq_resp); in nlm4svc_proc_granted()
298 host = nlmsvc_lookup_host(rqstp, in nlm4svc_callback()
309 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
150 return __nlmsvc_proc_test(rqstp, rqstp->rq_resp); in nlmsvc_proc_test()
187 return __nlmsvc_proc_lock(rqstp, rqstp->rq_resp); in nlmsvc_proc_lock()
196 struct net *net = SVC_NET(rqstp); in __nlmsvc_proc_cancel()
225 return __nlmsvc_proc_cancel(rqstp, rqstp->rq_resp); in nlmsvc_proc_cancel()
237 struct net *net = SVC_NET(rqstp); in __nlmsvc_proc_unlock()
266 return __nlmsvc_proc_unlock(rqstp, rqstp->rq_resp); in nlmsvc_proc_unlock()
289 return __nlmsvc_proc_granted(rqstp, rqstp->rq_resp); in nlmsvc_proc_granted()
330 host = nlmsvc_lookup_host(rqstp, in nlmsvc_callback()
341 stat = func(rqstp, &call->a_res); in nlmsvc_callback()
[all …]
H A Dxdr4.c151 struct nlm_args *argp = rqstp->rq_argp; in nlm4svc_decode_testargs()
169 struct nlm_args *argp = rqstp->rq_argp; in nlm4svc_decode_lockargs()
194 struct nlm_args *argp = rqstp->rq_argp; in nlm4svc_decode_cancargs()
214 struct nlm_args *argp = rqstp->rq_argp; in nlm4svc_decode_unlockargs()
228 struct nlm_res *resp = rqstp->rq_argp; in nlm4svc_decode_res()
241 struct nlm_reboot *argp = rqstp->rq_argp; in nlm4svc_decode_reboot()
267 struct nlm_args *argp = rqstp->rq_argp; in nlm4svc_decode_shareargs()
293 struct nlm_args *argp = rqstp->rq_argp; in nlm4svc_decode_notify()
318 struct nlm_res *resp = rqstp->rq_resp; in nlm4svc_encode_testres()
327 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 …]
/linux-6.15/fs/nfsd/
H A Dnfs3xdr.c494 struct nfsd_fhandle *args = rqstp->rq_argp; in nfs3svc_decode_fhandleargs()
533 struct nfsd3_readargs *args = rqstp->rq_argp; in nfs3svc_decode_readargs()
549 u32 max_blocksize = svc_max_payload(rqstp); in nfs3svc_decode_writeargs()
613 struct kvec *head = rqstp->rq_arg.head; in nfs3svc_decode_symlinkargs()
670 struct nfsd3_linkargs *args = rqstp->rq_argp; in nfs3svc_decode_linkargs()
740 struct nfsd3_attrstat *resp = rqstp->rq_resp; in nfs3svc_encode_getattrres()
818 struct kvec *head = rqstp->rq_res.head; in nfs3svc_encode_readlinkres()
845 struct nfsd3_readres *resp = rqstp->rq_resp; in nfs3svc_encode_readres()
846 struct kvec *head = rqstp->rq_res.head; in nfs3svc_encode_readres()
861 rqstp->rq_res.page_base, in nfs3svc_encode_readres()
[all …]
H A Dnfs3proc.c58 nfsd3_proc_null(struct svc_rqst *rqstp) in nfsd3_proc_null() argument
67 nfsd3_proc_getattr(struct svc_rqst *rqstp) in nfsd3_proc_getattr() argument
115 nfsd3_proc_lookup(struct svc_rqst *rqstp) in nfsd3_proc_lookup() argument
169 resp->pages = rqstp->rq_next_page++; in nfsd3_proc_readlink()
180 nfsd3_proc_read(struct svc_rqst *rqstp) in nfsd3_proc_read() argument
197 resp->pages = rqstp->rq_next_page; in nfsd3_proc_read()
241 rqstp->rq_vec, nvecs, &cnt, in nfsd3_proc_write()
599 svc_max_payload(rqstp)); in nfsd3_init_dirlist_pages()
606 buf->pages = rqstp->rq_next_page; in nfsd3_init_dirlist_pages()
631 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.c42 nfsd_proc_null(struct svc_rqst *rqstp) in nfsd_proc_null() argument
52 nfsd_proc_getattr(struct svc_rqst *rqstp) in nfsd_proc_getattr() argument
75 nfsd_proc_setattr(struct svc_rqst *rqstp) in nfsd_proc_setattr() argument
144 nfsd_proc_root(struct svc_rqst *rqstp) in nfsd_proc_root() argument
190 resp->page = *(rqstp->rq_next_page++); in nfsd_proc_readlink()
204 nfsd_proc_read(struct svc_rqst *rqstp) in nfsd_proc_read() argument
217 resp->pages = rqstp->rq_next_page; in nfsd_proc_read()
231 set_bit(RQ_DROPME, &rqstp->rq_flags); in nfsd_proc_read()
366 &rqstp->rq_cred, in nfsd_proc_create()
602 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()
97 struct nfsd3_setaclargs *argp = rqstp->rq_argp; in nfsacld_proc_setacl()
98 struct nfsd_attrstat *resp = rqstp->rq_resp; in nfsacld_proc_setacl()
153 struct nfsd_fhandle *argp = rqstp->rq_argp; in nfsacld_proc_getattr()
154 struct nfsd_attrstat *resp = rqstp->rq_resp; in nfsacld_proc_getattr()
172 struct nfsd3_accessargs *argp = rqstp->rq_argp; in nfsacld_proc_access()
173 struct nfsd3_accessres *resp = rqstp->rq_resp; in nfsacld_proc_access()
248 struct nfsd3_getaclres *resp = rqstp->rq_resp; in nfsaclsvc_encode_getaclres()
[all …]
H A Dnfs4proc.c544 open->op_rqstp = rqstp; in nfsd4_open()
978 read->rd_rqstp = rqstp; in nfsd4_read()
1014 readdir->rd_rqstp = rqstp; in nfsd4_readdir()
1023 u->readlink.rl_rqstp = rqstp; in nfsd4_readlink()
1427 struct svc_rqst *rqstp) in nfsd4_ssc_setup_dul() argument
2238 rqstp, 0); in _nfsd4_verify()
2346 exp = rqst_exp_find(&rqstp->rq_chandle, SVC_NET(rqstp), in nfsd4_getdeviceinfo()
2347 rqstp->rq_client, rqstp->rq_gssclient, in nfsd4_getdeviceinfo()
2362 rqstp, cstate->clp, gdp); in nfsd4_getdeviceinfo()
2803 resp->rqstp = rqstp; in nfsd4_proc_compound()
[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()
89 struct nfsd3_setaclargs *argp = rqstp->rq_argp; in nfsd3_proc_setacl()
90 struct nfsd3_attrstat *resp = rqstp->rq_resp; in nfsd3_proc_setacl()
135 struct nfsd3_getaclargs *args = rqstp->rq_argp; in nfs3svc_decode_getaclargs()
148 struct nfsd3_setaclargs *argp = rqstp->rq_argp; in nfs3svc_decode_setaclargs()
174 struct nfsd3_getaclres *resp = rqstp->rq_resp; in nfs3svc_encode_getaclres()
208 struct nfsd3_attrstat *resp = rqstp->rq_resp; in nfs3svc_encode_setaclres()
[all …]
H A Dvfs.c158 if (nfsd_v4client(rqstp) || in nfsd_cross_mnt()
197 exp2 = rqst_exp_parent(rqstp, &path); in nfsd_lookup_parent()
423 err = nfsd_permission(&rqstp->rq_cred, in nfsd_get_write_access()
680 &nfsd4_get_cstate(rqstp)->save_fh, in nfsd4_clone_file_range()
969 struct svc_rqst *rqstp = sd->u.data; in nfsd_splice_actor() local
983 rqstp->rq_res.page_len)) in nfsd_splice_actor()
990 rqstp->rq_res.page_len += sd->len; in nfsd_splice_actor()
1049 .u.data = rqstp, in nfsd_splice_read()
1090 page = *(rqstp->rq_next_page++); in nfsd_iter_read()
1093 total -= rqstp->rq_vec[v].iov_len; in nfsd_iter_read()
[all …]
H A Dnfssvc.c926 svc_recv(rqstp); in nfsd()
933 svc_exit_thread(rqstp); in nfsd()
950 __be32 *statp = rqstp->rq_accept_statp; in nfsd_dispatch()
968 if (!proc->pc_decode(rqstp, &rqstp->rq_arg_stream)) in nfsd_dispatch()
978 smp_store_release(&rqstp->rq_status_counter, rqstp->rq_status_counter | 1); in nfsd_dispatch()
991 *statp = proc->pc_func(rqstp); in nfsd_dispatch()
995 if (!proc->pc_encode(rqstp, &rqstp->rq_res_stream)) in nfsd_dispatch()
1002 smp_store_release(&rqstp->rq_status_counter, rqstp->rq_status_counter + 1); in nfsd_dispatch()
1004 nfsd_cache_update(rqstp, rp, rqstp->rq_cachetype, nfs_reply); in nfsd_dispatch()
1009 trace_nfsd_garbage_args_err(rqstp); in nfsd_dispatch()
[all …]
/linux-6.15/include/linux/sunrpc/
H A Dsvc.h306 set_bit(RQ_VICTIM, &rqstp->rq_flags); in svc_thread_should_stop()
346 int (*dispatch)(struct svc_rqst *rqstp);
480 svc_reserve(rqstp, space + rqstp->rq_auth_slack); in svc_reserve_auth()
491 struct xdr_buf *buf = &rqstp->rq_arg; in svcxdr_init_decode()
509 struct xdr_buf *buf = &rqstp->rq_res; in svcxdr_init_encode()
542 xdr->page_ptr = rqstp->rq_next_page - 1; in svcxdr_encode_opaque_pages()
556 struct xdr_buf *buf = &rqstp->rq_res; in svcxdr_set_auth_slack()
559 rqstp->rq_auth_slack = slack; in svcxdr_set_auth_slack()
562 buf->buflen -= rqstp->rq_auth_slack; in svcxdr_set_auth_slack()
581 if (unlikely(!rqstp->rq_accept_statp)) in svcxdr_set_accept_stat()
[all …]
/linux-6.15/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.h100 bool nlmsvc_decode_void(struct svc_rqst *rqstp, struct xdr_stream *xdr);
101 bool nlmsvc_decode_testargs(struct svc_rqst *rqstp, struct xdr_stream *xdr);
102 bool nlmsvc_decode_lockargs(struct svc_rqst *rqstp, struct xdr_stream *xdr);
103 bool nlmsvc_decode_cancargs(struct svc_rqst *rqstp, struct xdr_stream *xdr);
105 bool nlmsvc_decode_res(struct svc_rqst *rqstp, struct xdr_stream *xdr);
106 bool nlmsvc_decode_reboot(struct svc_rqst *rqstp, struct xdr_stream *xdr);
108 bool nlmsvc_decode_notify(struct svc_rqst *rqstp, struct xdr_stream *xdr);
110 bool nlmsvc_encode_testres(struct svc_rqst *rqstp, struct xdr_stream *xdr);
111 bool nlmsvc_encode_res(struct svc_rqst *rqstp, struct xdr_stream *xdr);
112 bool nlmsvc_encode_void(struct svc_rqst *rqstp, struct xdr_stream *xdr);
[all …]
/linux-6.15/net/sunrpc/auth_gss/
H A Dsvcauth_gss.c732 if (rqstp->rq_deferred) in svcauth_gss_verify_header()
870 if (rqstp->rq_deferred) in svcauth_gss_unwrap_integ()
945 if (rqstp->rq_deferred) { in svcauth_gss_unwrap_priv()
1649 if (rqstp->rq_proc != 0) in svcauth_gss_accept()
1653 if (rqstp->rq_proc != 0) in svcauth_gss_accept()
1671 if (rqstp->rq_proc != 0) in svcauth_gss_accept()
1694 rqstp->rq_cred = rsci->cred; in svcauth_gss_accept()
1969 if (rqstp->rq_client) in svcauth_gss_release()
1971 rqstp->rq_client = NULL; in svcauth_gss_release()
1972 if (rqstp->rq_gssclient) in svcauth_gss_release()
[all …]
/linux-6.15/net/sunrpc/xprtrdma/
H A Dsvc_rdma_recvfrom.c809 buf->pages = &rqstp->rq_pages[0]; in svc_rdma_read_complete_one()
831 buf->pages = &rqstp->rq_pages[1]; in svc_rdma_read_complete_multiple()
850 buf->pages = &rqstp->rq_pages[1]; in svc_rdma_read_complete_pzrc()
869 rqstp->rq_respages = &rqstp->rq_pages[ctxt->rc_page_count]; in svc_rdma_read_complete()
870 rqstp->rq_next_page = rqstp->rq_respages + 1; in svc_rdma_read_complete()
933 rqstp->rq_respages = rqstp->rq_pages; in svc_rdma_recvfrom()
934 rqstp->rq_next_page = rqstp->rq_respages; in svc_rdma_recvfrom()
936 rqstp->rq_xprt_ctxt = NULL; in svc_rdma_recvfrom()
982 rqstp->rq_xprt_ctxt = ctxt; in svc_rdma_recvfrom()
983 rqstp->rq_prot = IPPROTO_MAX; in svc_rdma_recvfrom()
[all …]

1234