Lines Matching refs:rqstp
825 nfsd_acl_init_request(struct svc_rqst *rqstp,
829 struct nfsd_net *nn = net_generic(SVC_NET(rqstp), nfsd_net_id);
832 if (likely(nfsd_support_acl_version(rqstp->rq_vers) &&
833 nfsd_vers(nn, rqstp->rq_vers, NFSD_TEST)))
834 return svc_generic_init_request(rqstp, progp, ret);
838 if (nfsd_support_acl_version(rqstp->rq_vers) &&
848 if (nfsd_support_acl_version(rqstp->rq_vers) &&
870 nfsd_init_request(struct svc_rqst *rqstp,
874 struct nfsd_net *nn = net_generic(SVC_NET(rqstp), nfsd_net_id);
877 if (likely(nfsd_vers(nn, rqstp->rq_vers, NFSD_TEST)))
878 return svc_generic_init_request(rqstp, progp, ret);
905 struct svc_rqst *rqstp = (struct svc_rqst *) vrqstp;
906 struct svc_xprt *perm_sock = list_entry(rqstp->rq_server->sv_permsocks.next, typeof(struct svc_xprt), xpt_list);
914 svc_thread_init_status(rqstp, unshare_fs_struct());
925 while (!svc_thread_should_stop(rqstp)) {
926 svc_recv(rqstp);
933 svc_exit_thread(rqstp);
939 * @rqstp: incoming request
945 * %1: Processing complete; send Reply in rqstp->rq_res
947 int nfsd_dispatch(struct svc_rqst *rqstp)
949 const struct svc_procedure *proc = rqstp->rq_procinfo;
950 __be32 *statp = rqstp->rq_accept_statp;
959 rqstp->rq_cachetype = proc->pc_cachetype;
966 start = xdr_stream_pos(&rqstp->rq_arg_stream);
967 len = xdr_stream_remaining(&rqstp->rq_arg_stream);
968 if (!proc->pc_decode(rqstp, &rqstp->rq_arg_stream))
974 * notify the consumers if the rqstp fields are stable
978 smp_store_release(&rqstp->rq_status_counter, rqstp->rq_status_counter | 1);
981 switch (nfsd_cache_lookup(rqstp, start, len, &rp)) {
990 nfs_reply = xdr_inline_decode(&rqstp->rq_res_stream, 0);
991 *statp = proc->pc_func(rqstp);
992 if (test_bit(RQ_DROPME, &rqstp->rq_flags))
995 if (!proc->pc_encode(rqstp, &rqstp->rq_res_stream))
1002 smp_store_release(&rqstp->rq_status_counter, rqstp->rq_status_counter + 1);
1004 nfsd_cache_update(rqstp, rp, rqstp->rq_cachetype, nfs_reply);
1009 trace_nfsd_garbage_args_err(rqstp);
1014 nfsd_cache_update(rqstp, rp, RC_NOCACHE, NULL);
1019 trace_nfsd_cant_encode_err(rqstp);
1020 nfsd_cache_update(rqstp, rp, RC_NOCACHE, NULL);
1027 * @rqstp: Server RPC transaction context
1034 bool nfssvc_decode_voidarg(struct svc_rqst *rqstp, struct xdr_stream *xdr)
1041 * @rqstp: Server RPC transaction context
1048 bool nfssvc_encode_voidres(struct svc_rqst *rqstp, struct xdr_stream *xdr)