/linux/net/sunrpc/ |
H A D | svc.c | 690 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 D | svc_xprt.c | 563 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() 688 rqstp->rq_page_end = &rqstp->rq_pages[pages]; in svc_alloc_arg() 832 svc_process(rqstp); in svc_handle_xprt() 875 if (rqstp->rq_xprt) { in svc_recv() 922 xb = &rqstp->rq_res; in svc_send() 1185 if (rqstp->rq_arg.page_len || !test_bit(RQ_USEDEFERRAL, &rqstp->rq_flags)) in svc_defer() 1201 memcpy(&dr->addr, &rqstp->rq_addr, rqstp->rq_addrlen); in svc_defer() 1207 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() 1139 if (rqstp->rq_arg.len <= rqstp->rq_arg.head[0].iov_len) { in svc_tcp_recvfrom() 1140 rqstp->rq_arg.head[0].iov_len = rqstp->rq_arg.len; in svc_tcp_recvfrom() 1143 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 | 81 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 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() 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/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 | 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 …]
|
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 …]
|
/linux/fs/nfsd/ |
H A D | nfs3xdr.c | 494 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 D | nfs3proc.c | 58 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 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 | 42 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 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 | 542 open->op_rqstp = rqstp; in nfsd4_open() 976 read->rd_rqstp = rqstp; in nfsd4_read() 1012 readdir->rd_rqstp = rqstp; in nfsd4_readdir() 1021 u->readlink.rl_rqstp = rqstp; in nfsd4_readlink() 1332 struct svc_rqst *rqstp) in nfsd4_ssc_setup_dul() argument 2129 rqstp, 0); in _nfsd4_verify() 2237 exp = rqst_exp_find(&rqstp->rq_chandle, SVC_NET(rqstp), in nfsd4_getdeviceinfo() 2238 rqstp->rq_client, rqstp->rq_gssclient, in nfsd4_getdeviceinfo() 2253 rqstp, cstate->clp, gdp); in nfsd4_getdeviceinfo() 2694 resp->rqstp = rqstp; in nfsd4_proc_compound() [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() 682 &nfsd4_get_cstate(rqstp)->save_fh, in nfsd4_clone_file_range() 979 struct svc_rqst *rqstp = sd->u.data; in nfsd_splice_actor() local 993 rqstp->rq_res.page_len)) in nfsd_splice_actor() 1000 rqstp->rq_res.page_len += sd->len; in nfsd_splice_actor() 1059 .u.data = rqstp, in nfsd_splice_read() 1100 page = *(rqstp->rq_next_page++); in nfsd_iter_read() 1103 total -= rqstp->rq_vec[v].iov_len; in nfsd_iter_read() [all …]
|
H A D | nfssvc.c | 960 svc_recv(rqstp); in nfsd() 968 svc_exit_thread(rqstp); in nfsd() 985 __be32 *statp = rqstp->rq_accept_statp; in nfsd_dispatch() 1003 if (!proc->pc_decode(rqstp, &rqstp->rq_arg_stream)) in nfsd_dispatch() 1013 smp_store_release(&rqstp->rq_status_counter, rqstp->rq_status_counter | 1); in nfsd_dispatch() 1026 *statp = proc->pc_func(rqstp); in nfsd_dispatch() 1030 if (!proc->pc_encode(rqstp, &rqstp->rq_res_stream)) in nfsd_dispatch() 1037 smp_store_release(&rqstp->rq_status_counter, rqstp->rq_status_counter + 1); in nfsd_dispatch() 1039 nfsd_cache_update(rqstp, rp, rqstp->rq_cachetype, nfs_reply); in nfsd_dispatch() 1044 trace_nfsd_garbage_args_err(rqstp); in nfsd_dispatch() [all …]
|
/linux/include/linux/sunrpc/ |
H A D | svc.h | 310 set_bit(RQ_VICTIM, &rqstp->rq_flags); in svc_thread_should_stop() 330 rqstp->rq_err = err; in svc_thread_init_status() 335 wake_up_var(&rqstp->rq_err); in svc_thread_init_status() 489 svc_reserve(rqstp, space + rqstp->rq_auth_slack); in svc_reserve_auth() 500 struct xdr_buf *buf = &rqstp->rq_arg; in svcxdr_init_decode() 518 struct xdr_buf *buf = &rqstp->rq_res; in svcxdr_init_encode() 565 struct xdr_buf *buf = &rqstp->rq_res; in svcxdr_set_auth_slack() 568 rqstp->rq_auth_slack = slack; in svcxdr_set_auth_slack() 571 buf->buflen -= rqstp->rq_auth_slack; in svcxdr_set_auth_slack() 590 if (unlikely(!rqstp->rq_accept_statp)) in svcxdr_set_accept_stat() [all …]
|
/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 …]
|
/linux/net/sunrpc/auth_gss/ |
H A D | svcauth_gss.c | 732 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/net/sunrpc/xprtrdma/ |
H A D | svc_rdma_recvfrom.c | 803 buf->pages = &rqstp->rq_pages[0]; in svc_rdma_read_complete_one() 825 buf->pages = &rqstp->rq_pages[1]; in svc_rdma_read_complete_multiple() 844 buf->pages = &rqstp->rq_pages[1]; in svc_rdma_read_complete_pzrc() 863 rqstp->rq_respages = &rqstp->rq_pages[ctxt->rc_page_count]; in svc_rdma_read_complete() 864 rqstp->rq_next_page = rqstp->rq_respages + 1; in svc_rdma_read_complete() 927 rqstp->rq_respages = rqstp->rq_pages; in svc_rdma_recvfrom() 928 rqstp->rq_next_page = rqstp->rq_respages; in svc_rdma_recvfrom() 930 rqstp->rq_xprt_ctxt = NULL; in svc_rdma_recvfrom() 976 rqstp->rq_xprt_ctxt = ctxt; in svc_rdma_recvfrom() 977 rqstp->rq_prot = IPPROTO_MAX; in svc_rdma_recvfrom() [all …]
|