• Home
  • Raw
  • Download

Lines Matching refs:rqstp

828 nfsd_acl_init_request(struct svc_rqst *rqstp,  in nfsd_acl_init_request()  argument
832 struct nfsd_net *nn = net_generic(SVC_NET(rqstp), nfsd_net_id); in nfsd_acl_init_request()
835 if (likely(nfsd_support_acl_version(rqstp->rq_vers) && in nfsd_acl_init_request()
836 nfsd_vers(nn, rqstp->rq_vers, NFSD_TEST))) in nfsd_acl_init_request()
837 return svc_generic_init_request(rqstp, progp, ret); in nfsd_acl_init_request()
841 if (nfsd_support_acl_version(rqstp->rq_vers) && in nfsd_acl_init_request()
851 if (nfsd_support_acl_version(rqstp->rq_vers) && in nfsd_acl_init_request()
873 nfsd_init_request(struct svc_rqst *rqstp, in nfsd_init_request() argument
877 struct nfsd_net *nn = net_generic(SVC_NET(rqstp), nfsd_net_id); in nfsd_init_request()
880 if (likely(nfsd_vers(nn, rqstp->rq_vers, NFSD_TEST))) in nfsd_init_request()
881 return svc_generic_init_request(rqstp, progp, ret); in nfsd_init_request()
908 struct svc_rqst *rqstp = (struct svc_rqst *) vrqstp; in nfsd() local
909 …struct svc_xprt *perm_sock = list_entry(rqstp->rq_server->sv_permsocks.next, typeof(struct svc_xpr… in nfsd()
946 rqstp->rq_server->sv_maxconn = nn->max_connections; in nfsd()
952 while ((err = svc_recv(rqstp, 60*60*HZ)) == -EAGAIN) in nfsd()
957 svc_process(rqstp); in nfsd()
968 rqstp->rq_server = NULL; in nfsd()
971 svc_exit_thread(rqstp); in nfsd()
998 static bool nfs_request_too_big(struct svc_rqst *rqstp, in nfs_request_too_big() argument
1005 if (rqstp->rq_prog != NFS_PROGRAM) in nfs_request_too_big()
1011 if (rqstp->rq_vers >= 4) in nfs_request_too_big()
1018 return rqstp->rq_arg.len > PAGE_SIZE; in nfs_request_too_big()
1022 nfsd_dispatch(struct svc_rqst *rqstp, __be32 *statp) in nfsd_dispatch() argument
1029 rqstp->rq_vers, rqstp->rq_proc); in nfsd_dispatch()
1030 proc = rqstp->rq_procinfo; in nfsd_dispatch()
1032 if (nfs_request_too_big(rqstp, proc)) { in nfsd_dispatch()
1033 dprintk("nfsd: NFSv%d argument too large\n", rqstp->rq_vers); in nfsd_dispatch()
1041 rqstp->rq_cachetype = proc->pc_cachetype; in nfsd_dispatch()
1044 !proc->pc_decode(rqstp, (__be32*)rqstp->rq_arg.head[0].iov_base)) { in nfsd_dispatch()
1051 switch (nfsd_cache_lookup(rqstp)) { in nfsd_dispatch()
1063 nfserrp = rqstp->rq_res.head[0].iov_base in nfsd_dispatch()
1064 + rqstp->rq_res.head[0].iov_len; in nfsd_dispatch()
1065 rqstp->rq_res.head[0].iov_len += sizeof(__be32); in nfsd_dispatch()
1068 nfserr = proc->pc_func(rqstp); in nfsd_dispatch()
1069 nfserr = map_new_errors(rqstp->rq_vers, nfserr); in nfsd_dispatch()
1070 if (nfserr == nfserr_dropit || test_bit(RQ_DROPME, &rqstp->rq_flags)) { in nfsd_dispatch()
1072 nfsd_cache_update(rqstp, RC_NOCACHE, NULL); in nfsd_dispatch()
1076 if (rqstp->rq_proc != 0) in nfsd_dispatch()
1082 if (!(nfserr && rqstp->rq_vers == 2)) { in nfsd_dispatch()
1083 if (proc->pc_encode && !proc->pc_encode(rqstp, nfserrp)) { in nfsd_dispatch()
1086 nfsd_cache_update(rqstp, RC_NOCACHE, NULL); in nfsd_dispatch()
1093 nfsd_cache_update(rqstp, rqstp->rq_cachetype, statp + 1); in nfsd_dispatch()