GNU Linux-libre 5.4.200-gnu1
[releases.git] / fs / nfsd / nfs4proc.c
1 /*
2  *  Server-side procedures for NFSv4.
3  *
4  *  Copyright (c) 2002 The Regents of the University of Michigan.
5  *  All rights reserved.
6  *
7  *  Kendrick Smith <kmsmith@umich.edu>
8  *  Andy Adamson   <andros@umich.edu>
9  *
10  *  Redistribution and use in source and binary forms, with or without
11  *  modification, are permitted provided that the following conditions
12  *  are met:
13  *
14  *  1. Redistributions of source code must retain the above copyright
15  *     notice, this list of conditions and the following disclaimer.
16  *  2. Redistributions in binary form must reproduce the above copyright
17  *     notice, this list of conditions and the following disclaimer in the
18  *     documentation and/or other materials provided with the distribution.
19  *  3. Neither the name of the University nor the names of its
20  *     contributors may be used to endorse or promote products derived
21  *     from this software without specific prior written permission.
22  *
23  *  THIS SOFTWARE IS PROVIDED ``AS IS'' AND ANY EXPRESS OR IMPLIED
24  *  WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED WARRANTIES OF
25  *  MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE
26  *  DISCLAIMED. IN NO EVENT SHALL THE REGENTS OR CONTRIBUTORS BE LIABLE
27  *  FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR
28  *  CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF
29  *  SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR
30  *  BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF
31  *  LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING
32  *  NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF THIS
33  *  SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
34  */
35 #include <linux/fs_struct.h>
36 #include <linux/file.h>
37 #include <linux/falloc.h>
38 #include <linux/slab.h>
39 #include <linux/kthread.h>
40
41 #include "idmap.h"
42 #include "cache.h"
43 #include "xdr4.h"
44 #include "vfs.h"
45 #include "current_stateid.h"
46 #include "netns.h"
47 #include "acl.h"
48 #include "pnfs.h"
49 #include "trace.h"
50
51 #ifdef CONFIG_NFSD_V4_SECURITY_LABEL
52 #include <linux/security.h>
53
54 static inline void
55 nfsd4_security_inode_setsecctx(struct svc_fh *resfh, struct xdr_netobj *label, u32 *bmval)
56 {
57         struct inode *inode = d_inode(resfh->fh_dentry);
58         int status;
59
60         inode_lock(inode);
61         status = security_inode_setsecctx(resfh->fh_dentry,
62                 label->data, label->len);
63         inode_unlock(inode);
64
65         if (status)
66                 /*
67                  * XXX: We should really fail the whole open, but we may
68                  * already have created a new file, so it may be too
69                  * late.  For now this seems the least of evils:
70                  */
71                 bmval[2] &= ~FATTR4_WORD2_SECURITY_LABEL;
72
73         return;
74 }
75 #else
76 static inline void
77 nfsd4_security_inode_setsecctx(struct svc_fh *resfh, struct xdr_netobj *label, u32 *bmval)
78 { }
79 #endif
80
81 #define NFSDDBG_FACILITY                NFSDDBG_PROC
82
83 static u32 nfsd_attrmask[] = {
84         NFSD_WRITEABLE_ATTRS_WORD0,
85         NFSD_WRITEABLE_ATTRS_WORD1,
86         NFSD_WRITEABLE_ATTRS_WORD2
87 };
88
89 static u32 nfsd41_ex_attrmask[] = {
90         NFSD_SUPPATTR_EXCLCREAT_WORD0,
91         NFSD_SUPPATTR_EXCLCREAT_WORD1,
92         NFSD_SUPPATTR_EXCLCREAT_WORD2
93 };
94
95 static __be32
96 check_attr_support(struct svc_rqst *rqstp, struct nfsd4_compound_state *cstate,
97                    u32 *bmval, u32 *writable)
98 {
99         struct dentry *dentry = cstate->current_fh.fh_dentry;
100         struct svc_export *exp = cstate->current_fh.fh_export;
101
102         if (!nfsd_attrs_supported(cstate->minorversion, bmval))
103                 return nfserr_attrnotsupp;
104         if ((bmval[0] & FATTR4_WORD0_ACL) && !IS_POSIXACL(d_inode(dentry)))
105                 return nfserr_attrnotsupp;
106         if ((bmval[2] & FATTR4_WORD2_SECURITY_LABEL) &&
107                         !(exp->ex_flags & NFSEXP_SECURITY_LABEL))
108                 return nfserr_attrnotsupp;
109         if (writable && !bmval_is_subset(bmval, writable))
110                 return nfserr_inval;
111         if (writable && (bmval[2] & FATTR4_WORD2_MODE_UMASK) &&
112                         (bmval[1] & FATTR4_WORD1_MODE))
113                 return nfserr_inval;
114         return nfs_ok;
115 }
116
117 static __be32
118 nfsd4_check_open_attributes(struct svc_rqst *rqstp,
119         struct nfsd4_compound_state *cstate, struct nfsd4_open *open)
120 {
121         __be32 status = nfs_ok;
122
123         if (open->op_create == NFS4_OPEN_CREATE) {
124                 if (open->op_createmode == NFS4_CREATE_UNCHECKED
125                     || open->op_createmode == NFS4_CREATE_GUARDED)
126                         status = check_attr_support(rqstp, cstate,
127                                         open->op_bmval, nfsd_attrmask);
128                 else if (open->op_createmode == NFS4_CREATE_EXCLUSIVE4_1)
129                         status = check_attr_support(rqstp, cstate,
130                                         open->op_bmval, nfsd41_ex_attrmask);
131         }
132
133         return status;
134 }
135
136 static int
137 is_create_with_attrs(struct nfsd4_open *open)
138 {
139         return open->op_create == NFS4_OPEN_CREATE
140                 && (open->op_createmode == NFS4_CREATE_UNCHECKED
141                     || open->op_createmode == NFS4_CREATE_GUARDED
142                     || open->op_createmode == NFS4_CREATE_EXCLUSIVE4_1);
143 }
144
145 /*
146  * if error occurs when setting the acl, just clear the acl bit
147  * in the returned attr bitmap.
148  */
149 static void
150 do_set_nfs4_acl(struct svc_rqst *rqstp, struct svc_fh *fhp,
151                 struct nfs4_acl *acl, u32 *bmval)
152 {
153         __be32 status;
154
155         status = nfsd4_set_nfs4_acl(rqstp, fhp, acl);
156         if (status)
157                 /*
158                  * We should probably fail the whole open at this point,
159                  * but we've already created the file, so it's too late;
160                  * So this seems the least of evils:
161                  */
162                 bmval[0] &= ~FATTR4_WORD0_ACL;
163 }
164
165 static inline void
166 fh_dup2(struct svc_fh *dst, struct svc_fh *src)
167 {
168         fh_put(dst);
169         dget(src->fh_dentry);
170         if (src->fh_export)
171                 exp_get(src->fh_export);
172         *dst = *src;
173 }
174
175 static __be32
176 do_open_permission(struct svc_rqst *rqstp, struct svc_fh *current_fh, struct nfsd4_open *open, int accmode)
177 {
178         __be32 status;
179
180         if (open->op_truncate &&
181                 !(open->op_share_access & NFS4_SHARE_ACCESS_WRITE))
182                 return nfserr_inval;
183
184         accmode |= NFSD_MAY_READ_IF_EXEC;
185
186         if (open->op_share_access & NFS4_SHARE_ACCESS_READ)
187                 accmode |= NFSD_MAY_READ;
188         if (open->op_share_access & NFS4_SHARE_ACCESS_WRITE)
189                 accmode |= (NFSD_MAY_WRITE | NFSD_MAY_TRUNC);
190         if (open->op_share_deny & NFS4_SHARE_DENY_READ)
191                 accmode |= NFSD_MAY_WRITE;
192
193         status = fh_verify(rqstp, current_fh, S_IFREG, accmode);
194
195         return status;
196 }
197
198 static __be32 nfsd_check_obj_isreg(struct svc_fh *fh)
199 {
200         umode_t mode = d_inode(fh->fh_dentry)->i_mode;
201
202         if (S_ISREG(mode))
203                 return nfs_ok;
204         if (S_ISDIR(mode))
205                 return nfserr_isdir;
206         /*
207          * Using err_symlink as our catch-all case may look odd; but
208          * there's no other obvious error for this case in 4.0, and we
209          * happen to know that it will cause the linux v4 client to do
210          * the right thing on attempts to open something other than a
211          * regular file.
212          */
213         return nfserr_symlink;
214 }
215
216 static void nfsd4_set_open_owner_reply_cache(struct nfsd4_compound_state *cstate, struct nfsd4_open *open, struct svc_fh *resfh)
217 {
218         if (nfsd4_has_session(cstate))
219                 return;
220         fh_copy_shallow(&open->op_openowner->oo_owner.so_replay.rp_openfh,
221                         &resfh->fh_handle);
222 }
223
224 static __be32
225 do_open_lookup(struct svc_rqst *rqstp, struct nfsd4_compound_state *cstate, struct nfsd4_open *open, struct svc_fh **resfh)
226 {
227         struct svc_fh *current_fh = &cstate->current_fh;
228         int accmode;
229         __be32 status;
230
231         *resfh = kmalloc(sizeof(struct svc_fh), GFP_KERNEL);
232         if (!*resfh)
233                 return nfserr_jukebox;
234         fh_init(*resfh, NFS4_FHSIZE);
235         open->op_truncate = 0;
236
237         if (open->op_create) {
238                 /* FIXME: check session persistence and pnfs flags.
239                  * The nfsv4.1 spec requires the following semantics:
240                  *
241                  * Persistent   | pNFS   | Server REQUIRED | Client Allowed
242                  * Reply Cache  | server |                 |
243                  * -------------+--------+-----------------+--------------------
244                  * no           | no     | EXCLUSIVE4_1    | EXCLUSIVE4_1
245                  *              |        |                 | (SHOULD)
246                  *              |        | and EXCLUSIVE4  | or EXCLUSIVE4
247                  *              |        |                 | (SHOULD NOT)
248                  * no           | yes    | EXCLUSIVE4_1    | EXCLUSIVE4_1
249                  * yes          | no     | GUARDED4        | GUARDED4
250                  * yes          | yes    | GUARDED4        | GUARDED4
251                  */
252
253                 /*
254                  * Note: create modes (UNCHECKED,GUARDED...) are the same
255                  * in NFSv4 as in v3 except EXCLUSIVE4_1.
256                  */
257                 current->fs->umask = open->op_umask;
258                 status = do_nfsd_create(rqstp, current_fh, open->op_fname.data,
259                                         open->op_fname.len, &open->op_iattr,
260                                         *resfh, open->op_createmode,
261                                         (u32 *)open->op_verf.data,
262                                         &open->op_truncate, &open->op_created);
263                 current->fs->umask = 0;
264
265                 if (!status && open->op_label.len)
266                         nfsd4_security_inode_setsecctx(*resfh, &open->op_label, open->op_bmval);
267
268                 /*
269                  * Following rfc 3530 14.2.16, and rfc 5661 18.16.4
270                  * use the returned bitmask to indicate which attributes
271                  * we used to store the verifier:
272                  */
273                 if (nfsd_create_is_exclusive(open->op_createmode) && status == 0)
274                         open->op_bmval[1] |= (FATTR4_WORD1_TIME_ACCESS |
275                                                 FATTR4_WORD1_TIME_MODIFY);
276         } else
277                 /*
278                  * Note this may exit with the parent still locked.
279                  * We will hold the lock until nfsd4_open's final
280                  * lookup, to prevent renames or unlinks until we've had
281                  * a chance to an acquire a delegation if appropriate.
282                  */
283                 status = nfsd_lookup(rqstp, current_fh,
284                                      open->op_fname.data, open->op_fname.len, *resfh);
285         if (status)
286                 goto out;
287         status = nfsd_check_obj_isreg(*resfh);
288         if (status)
289                 goto out;
290
291         if (is_create_with_attrs(open) && open->op_acl != NULL)
292                 do_set_nfs4_acl(rqstp, *resfh, open->op_acl, open->op_bmval);
293
294         nfsd4_set_open_owner_reply_cache(cstate, open, *resfh);
295         accmode = NFSD_MAY_NOP;
296         if (open->op_created ||
297                         open->op_claim_type == NFS4_OPEN_CLAIM_DELEGATE_CUR)
298                 accmode |= NFSD_MAY_OWNER_OVERRIDE;
299         status = do_open_permission(rqstp, *resfh, open, accmode);
300         set_change_info(&open->op_cinfo, current_fh);
301 out:
302         return status;
303 }
304
305 static __be32
306 do_open_fhandle(struct svc_rqst *rqstp, struct nfsd4_compound_state *cstate, struct nfsd4_open *open)
307 {
308         struct svc_fh *current_fh = &cstate->current_fh;
309         __be32 status;
310         int accmode = 0;
311
312         /* We don't know the target directory, and therefore can not
313         * set the change info
314         */
315
316         memset(&open->op_cinfo, 0, sizeof(struct nfsd4_change_info));
317
318         nfsd4_set_open_owner_reply_cache(cstate, open, current_fh);
319
320         open->op_truncate = (open->op_iattr.ia_valid & ATTR_SIZE) &&
321                 (open->op_iattr.ia_size == 0);
322         /*
323          * In the delegation case, the client is telling us about an
324          * open that it *already* performed locally, some time ago.  We
325          * should let it succeed now if possible.
326          *
327          * In the case of a CLAIM_FH open, on the other hand, the client
328          * may be counting on us to enforce permissions (the Linux 4.1
329          * client uses this for normal opens, for example).
330          */
331         if (open->op_claim_type == NFS4_OPEN_CLAIM_DELEG_CUR_FH)
332                 accmode = NFSD_MAY_OWNER_OVERRIDE;
333
334         status = do_open_permission(rqstp, current_fh, open, accmode);
335
336         return status;
337 }
338
339 static void
340 copy_clientid(clientid_t *clid, struct nfsd4_session *session)
341 {
342         struct nfsd4_sessionid *sid =
343                         (struct nfsd4_sessionid *)session->se_sessionid.data;
344
345         clid->cl_boot = sid->clientid.cl_boot;
346         clid->cl_id = sid->clientid.cl_id;
347 }
348
349 static __be32
350 nfsd4_open(struct svc_rqst *rqstp, struct nfsd4_compound_state *cstate,
351            union nfsd4_op_u *u)
352 {
353         struct nfsd4_open *open = &u->open;
354         __be32 status;
355         struct svc_fh *resfh = NULL;
356         struct net *net = SVC_NET(rqstp);
357         struct nfsd_net *nn = net_generic(net, nfsd_net_id);
358         bool reclaim = false;
359
360         dprintk("NFSD: nfsd4_open filename %.*s op_openowner %p\n",
361                 (int)open->op_fname.len, open->op_fname.data,
362                 open->op_openowner);
363
364         /* This check required by spec. */
365         if (open->op_create && open->op_claim_type != NFS4_OPEN_CLAIM_NULL)
366                 return nfserr_inval;
367
368         open->op_created = 0;
369         /*
370          * RFC5661 18.51.3
371          * Before RECLAIM_COMPLETE done, server should deny new lock
372          */
373         if (nfsd4_has_session(cstate) &&
374             !test_bit(NFSD4_CLIENT_RECLAIM_COMPLETE,
375                       &cstate->session->se_client->cl_flags) &&
376             open->op_claim_type != NFS4_OPEN_CLAIM_PREVIOUS)
377                 return nfserr_grace;
378
379         if (nfsd4_has_session(cstate))
380                 copy_clientid(&open->op_clientid, cstate->session);
381
382         /* check seqid for replay. set nfs4_owner */
383         status = nfsd4_process_open1(cstate, open, nn);
384         if (status == nfserr_replay_me) {
385                 struct nfs4_replay *rp = &open->op_openowner->oo_owner.so_replay;
386                 fh_put(&cstate->current_fh);
387                 fh_copy_shallow(&cstate->current_fh.fh_handle,
388                                 &rp->rp_openfh);
389                 status = fh_verify(rqstp, &cstate->current_fh, 0, NFSD_MAY_NOP);
390                 if (status)
391                         dprintk("nfsd4_open: replay failed"
392                                 " restoring previous filehandle\n");
393                 else
394                         status = nfserr_replay_me;
395         }
396         if (status)
397                 goto out;
398         if (open->op_xdr_error) {
399                 status = open->op_xdr_error;
400                 goto out;
401         }
402
403         status = nfsd4_check_open_attributes(rqstp, cstate, open);
404         if (status)
405                 goto out;
406
407         /* Openowner is now set, so sequence id will get bumped.  Now we need
408          * these checks before we do any creates: */
409         status = nfserr_grace;
410         if (opens_in_grace(net) && open->op_claim_type != NFS4_OPEN_CLAIM_PREVIOUS)
411                 goto out;
412         status = nfserr_no_grace;
413         if (!opens_in_grace(net) && open->op_claim_type == NFS4_OPEN_CLAIM_PREVIOUS)
414                 goto out;
415
416         switch (open->op_claim_type) {
417                 case NFS4_OPEN_CLAIM_DELEGATE_CUR:
418                 case NFS4_OPEN_CLAIM_NULL:
419                         status = do_open_lookup(rqstp, cstate, open, &resfh);
420                         if (status)
421                                 goto out;
422                         break;
423                 case NFS4_OPEN_CLAIM_PREVIOUS:
424                         status = nfs4_check_open_reclaim(&open->op_clientid,
425                                                          cstate, nn);
426                         if (status)
427                                 goto out;
428                         open->op_openowner->oo_flags |= NFS4_OO_CONFIRMED;
429                         reclaim = true;
430                         /* fall through */
431                 case NFS4_OPEN_CLAIM_FH:
432                 case NFS4_OPEN_CLAIM_DELEG_CUR_FH:
433                         status = do_open_fhandle(rqstp, cstate, open);
434                         if (status)
435                                 goto out;
436                         resfh = &cstate->current_fh;
437                         break;
438                 case NFS4_OPEN_CLAIM_DELEG_PREV_FH:
439                 case NFS4_OPEN_CLAIM_DELEGATE_PREV:
440                         dprintk("NFSD: unsupported OPEN claim type %d\n",
441                                 open->op_claim_type);
442                         status = nfserr_notsupp;
443                         goto out;
444                 default:
445                         dprintk("NFSD: Invalid OPEN claim type %d\n",
446                                 open->op_claim_type);
447                         status = nfserr_inval;
448                         goto out;
449         }
450         /*
451          * nfsd4_process_open2() does the actual opening of the file.  If
452          * successful, it (1) truncates the file if open->op_truncate was
453          * set, (2) sets open->op_stateid, (3) sets open->op_delegation.
454          */
455         status = nfsd4_process_open2(rqstp, resfh, open);
456         WARN(status && open->op_created,
457              "nfsd4_process_open2 failed to open newly-created file! status=%u\n",
458              be32_to_cpu(status));
459         if (reclaim && !status)
460                 nn->somebody_reclaimed = true;
461 out:
462         if (resfh && resfh != &cstate->current_fh) {
463                 fh_dup2(&cstate->current_fh, resfh);
464                 fh_put(resfh);
465                 kfree(resfh);
466         }
467         nfsd4_cleanup_open_state(cstate, open);
468         nfsd4_bump_seqid(cstate, status);
469         return status;
470 }
471
472 /*
473  * OPEN is the only seqid-mutating operation whose decoding can fail
474  * with a seqid-mutating error (specifically, decoding of user names in
475  * the attributes).  Therefore we have to do some processing to look up
476  * the stateowner so that we can bump the seqid.
477  */
478 static __be32 nfsd4_open_omfg(struct svc_rqst *rqstp, struct nfsd4_compound_state *cstate, struct nfsd4_op *op)
479 {
480         struct nfsd4_open *open = &op->u.open;
481
482         if (!seqid_mutating_err(ntohl(op->status)))
483                 return op->status;
484         if (nfsd4_has_session(cstate))
485                 return op->status;
486         open->op_xdr_error = op->status;
487         return nfsd4_open(rqstp, cstate, &op->u);
488 }
489
490 /*
491  * filehandle-manipulating ops.
492  */
493 static __be32
494 nfsd4_getfh(struct svc_rqst *rqstp, struct nfsd4_compound_state *cstate,
495             union nfsd4_op_u *u)
496 {
497         u->getfh = &cstate->current_fh;
498         return nfs_ok;
499 }
500
501 static __be32
502 nfsd4_putfh(struct svc_rqst *rqstp, struct nfsd4_compound_state *cstate,
503             union nfsd4_op_u *u)
504 {
505         struct nfsd4_putfh *putfh = &u->putfh;
506
507         fh_put(&cstate->current_fh);
508         cstate->current_fh.fh_handle.fh_size = putfh->pf_fhlen;
509         memcpy(&cstate->current_fh.fh_handle.fh_base, putfh->pf_fhval,
510                putfh->pf_fhlen);
511         return fh_verify(rqstp, &cstate->current_fh, 0, NFSD_MAY_BYPASS_GSS);
512 }
513
514 static __be32
515 nfsd4_putrootfh(struct svc_rqst *rqstp, struct nfsd4_compound_state *cstate,
516                 union nfsd4_op_u *u)
517 {
518         __be32 status;
519
520         fh_put(&cstate->current_fh);
521         status = exp_pseudoroot(rqstp, &cstate->current_fh);
522         return status;
523 }
524
525 static __be32
526 nfsd4_restorefh(struct svc_rqst *rqstp, struct nfsd4_compound_state *cstate,
527                 union nfsd4_op_u *u)
528 {
529         if (!cstate->save_fh.fh_dentry)
530                 return nfserr_restorefh;
531
532         fh_dup2(&cstate->current_fh, &cstate->save_fh);
533         if (HAS_STATE_ID(cstate, SAVED_STATE_ID_FLAG)) {
534                 memcpy(&cstate->current_stateid, &cstate->save_stateid, sizeof(stateid_t));
535                 SET_STATE_ID(cstate, CURRENT_STATE_ID_FLAG);
536         }
537         return nfs_ok;
538 }
539
540 static __be32
541 nfsd4_savefh(struct svc_rqst *rqstp, struct nfsd4_compound_state *cstate,
542              union nfsd4_op_u *u)
543 {
544         fh_dup2(&cstate->save_fh, &cstate->current_fh);
545         if (HAS_STATE_ID(cstate, CURRENT_STATE_ID_FLAG)) {
546                 memcpy(&cstate->save_stateid, &cstate->current_stateid, sizeof(stateid_t));
547                 SET_STATE_ID(cstate, SAVED_STATE_ID_FLAG);
548         }
549         return nfs_ok;
550 }
551
552 /*
553  * misc nfsv4 ops
554  */
555 static __be32
556 nfsd4_access(struct svc_rqst *rqstp, struct nfsd4_compound_state *cstate,
557              union nfsd4_op_u *u)
558 {
559         struct nfsd4_access *access = &u->access;
560
561         if (access->ac_req_access & ~NFS3_ACCESS_FULL)
562                 return nfserr_inval;
563
564         access->ac_resp_access = access->ac_req_access;
565         return nfsd_access(rqstp, &cstate->current_fh, &access->ac_resp_access,
566                            &access->ac_supported);
567 }
568
569 static void gen_boot_verifier(nfs4_verifier *verifier, struct net *net)
570 {
571         __be32 *verf = (__be32 *)verifier->data;
572
573         BUILD_BUG_ON(2*sizeof(*verf) != sizeof(verifier->data));
574
575         nfsd_copy_boot_verifier(verf, net_generic(net, nfsd_net_id));
576 }
577
578 static __be32
579 nfsd4_commit(struct svc_rqst *rqstp, struct nfsd4_compound_state *cstate,
580              union nfsd4_op_u *u)
581 {
582         struct nfsd4_commit *commit = &u->commit;
583
584         gen_boot_verifier(&commit->co_verf, SVC_NET(rqstp));
585         return nfsd_commit(rqstp, &cstate->current_fh, commit->co_offset,
586                              commit->co_count);
587 }
588
589 static __be32
590 nfsd4_create(struct svc_rqst *rqstp, struct nfsd4_compound_state *cstate,
591              union nfsd4_op_u *u)
592 {
593         struct nfsd4_create *create = &u->create;
594         struct svc_fh resfh;
595         __be32 status;
596         dev_t rdev;
597
598         fh_init(&resfh, NFS4_FHSIZE);
599
600         status = fh_verify(rqstp, &cstate->current_fh, S_IFDIR, NFSD_MAY_NOP);
601         if (status)
602                 return status;
603
604         status = check_attr_support(rqstp, cstate, create->cr_bmval,
605                                     nfsd_attrmask);
606         if (status)
607                 return status;
608
609         current->fs->umask = create->cr_umask;
610         switch (create->cr_type) {
611         case NF4LNK:
612                 status = nfsd_symlink(rqstp, &cstate->current_fh,
613                                       create->cr_name, create->cr_namelen,
614                                       create->cr_data, &resfh);
615                 break;
616
617         case NF4BLK:
618                 status = nfserr_inval;
619                 rdev = MKDEV(create->cr_specdata1, create->cr_specdata2);
620                 if (MAJOR(rdev) != create->cr_specdata1 ||
621                     MINOR(rdev) != create->cr_specdata2)
622                         goto out_umask;
623                 status = nfsd_create(rqstp, &cstate->current_fh,
624                                      create->cr_name, create->cr_namelen,
625                                      &create->cr_iattr, S_IFBLK, rdev, &resfh);
626                 break;
627
628         case NF4CHR:
629                 status = nfserr_inval;
630                 rdev = MKDEV(create->cr_specdata1, create->cr_specdata2);
631                 if (MAJOR(rdev) != create->cr_specdata1 ||
632                     MINOR(rdev) != create->cr_specdata2)
633                         goto out_umask;
634                 status = nfsd_create(rqstp, &cstate->current_fh,
635                                      create->cr_name, create->cr_namelen,
636                                      &create->cr_iattr,S_IFCHR, rdev, &resfh);
637                 break;
638
639         case NF4SOCK:
640                 status = nfsd_create(rqstp, &cstate->current_fh,
641                                      create->cr_name, create->cr_namelen,
642                                      &create->cr_iattr, S_IFSOCK, 0, &resfh);
643                 break;
644
645         case NF4FIFO:
646                 status = nfsd_create(rqstp, &cstate->current_fh,
647                                      create->cr_name, create->cr_namelen,
648                                      &create->cr_iattr, S_IFIFO, 0, &resfh);
649                 break;
650
651         case NF4DIR:
652                 create->cr_iattr.ia_valid &= ~ATTR_SIZE;
653                 status = nfsd_create(rqstp, &cstate->current_fh,
654                                      create->cr_name, create->cr_namelen,
655                                      &create->cr_iattr, S_IFDIR, 0, &resfh);
656                 break;
657
658         default:
659                 status = nfserr_badtype;
660         }
661
662         if (status)
663                 goto out;
664
665         if (create->cr_label.len)
666                 nfsd4_security_inode_setsecctx(&resfh, &create->cr_label, create->cr_bmval);
667
668         if (create->cr_acl != NULL)
669                 do_set_nfs4_acl(rqstp, &resfh, create->cr_acl,
670                                 create->cr_bmval);
671
672         fh_unlock(&cstate->current_fh);
673         set_change_info(&create->cr_cinfo, &cstate->current_fh);
674         fh_dup2(&cstate->current_fh, &resfh);
675 out:
676         fh_put(&resfh);
677 out_umask:
678         current->fs->umask = 0;
679         return status;
680 }
681
682 static __be32
683 nfsd4_getattr(struct svc_rqst *rqstp, struct nfsd4_compound_state *cstate,
684               union nfsd4_op_u *u)
685 {
686         struct nfsd4_getattr *getattr = &u->getattr;
687         __be32 status;
688
689         status = fh_verify(rqstp, &cstate->current_fh, 0, NFSD_MAY_NOP);
690         if (status)
691                 return status;
692
693         if (getattr->ga_bmval[1] & NFSD_WRITEONLY_ATTRS_WORD1)
694                 return nfserr_inval;
695
696         getattr->ga_bmval[0] &= nfsd_suppattrs[cstate->minorversion][0];
697         getattr->ga_bmval[1] &= nfsd_suppattrs[cstate->minorversion][1];
698         getattr->ga_bmval[2] &= nfsd_suppattrs[cstate->minorversion][2];
699
700         getattr->ga_fhp = &cstate->current_fh;
701         return nfs_ok;
702 }
703
704 static __be32
705 nfsd4_link(struct svc_rqst *rqstp, struct nfsd4_compound_state *cstate,
706            union nfsd4_op_u *u)
707 {
708         struct nfsd4_link *link = &u->link;
709         __be32 status;
710
711         status = nfsd_link(rqstp, &cstate->current_fh,
712                            link->li_name, link->li_namelen, &cstate->save_fh);
713         if (!status)
714                 set_change_info(&link->li_cinfo, &cstate->current_fh);
715         return status;
716 }
717
718 static __be32 nfsd4_do_lookupp(struct svc_rqst *rqstp, struct svc_fh *fh)
719 {
720         struct svc_fh tmp_fh;
721         __be32 ret;
722
723         fh_init(&tmp_fh, NFS4_FHSIZE);
724         ret = exp_pseudoroot(rqstp, &tmp_fh);
725         if (ret)
726                 return ret;
727         if (tmp_fh.fh_dentry == fh->fh_dentry) {
728                 fh_put(&tmp_fh);
729                 return nfserr_noent;
730         }
731         fh_put(&tmp_fh);
732         return nfsd_lookup(rqstp, fh, "..", 2, fh);
733 }
734
735 static __be32
736 nfsd4_lookupp(struct svc_rqst *rqstp, struct nfsd4_compound_state *cstate,
737               union nfsd4_op_u *u)
738 {
739         return nfsd4_do_lookupp(rqstp, &cstate->current_fh);
740 }
741
742 static __be32
743 nfsd4_lookup(struct svc_rqst *rqstp, struct nfsd4_compound_state *cstate,
744              union nfsd4_op_u *u)
745 {
746         return nfsd_lookup(rqstp, &cstate->current_fh,
747                            u->lookup.lo_name, u->lookup.lo_len,
748                            &cstate->current_fh);
749 }
750
751 static __be32
752 nfsd4_read(struct svc_rqst *rqstp, struct nfsd4_compound_state *cstate,
753            union nfsd4_op_u *u)
754 {
755         struct nfsd4_read *read = &u->read;
756         __be32 status;
757
758         read->rd_nf = NULL;
759         if (read->rd_offset >= OFFSET_MAX)
760                 return nfserr_inval;
761
762         trace_nfsd_read_start(rqstp, &cstate->current_fh,
763                               read->rd_offset, read->rd_length);
764
765         /*
766          * If we do a zero copy read, then a client will see read data
767          * that reflects the state of the file *after* performing the
768          * following compound.
769          *
770          * To ensure proper ordering, we therefore turn off zero copy if
771          * the client wants us to do more in this compound:
772          */
773         if (!nfsd4_last_compound_op(rqstp))
774                 clear_bit(RQ_SPLICE_OK, &rqstp->rq_flags);
775
776         /* check stateid */
777         status = nfs4_preprocess_stateid_op(rqstp, cstate, &cstate->current_fh,
778                                         &read->rd_stateid, RD_STATE,
779                                         &read->rd_nf);
780         if (status) {
781                 dprintk("NFSD: nfsd4_read: couldn't process stateid!\n");
782                 goto out;
783         }
784         status = nfs_ok;
785 out:
786         read->rd_rqstp = rqstp;
787         read->rd_fhp = &cstate->current_fh;
788         return status;
789 }
790
791
792 static void
793 nfsd4_read_release(union nfsd4_op_u *u)
794 {
795         if (u->read.rd_nf)
796                 nfsd_file_put(u->read.rd_nf);
797         trace_nfsd_read_done(u->read.rd_rqstp, u->read.rd_fhp,
798                              u->read.rd_offset, u->read.rd_length);
799 }
800
801 static __be32
802 nfsd4_readdir(struct svc_rqst *rqstp, struct nfsd4_compound_state *cstate,
803               union nfsd4_op_u *u)
804 {
805         struct nfsd4_readdir *readdir = &u->readdir;
806         u64 cookie = readdir->rd_cookie;
807         static const nfs4_verifier zeroverf;
808
809         /* no need to check permission - this will be done in nfsd_readdir() */
810
811         if (readdir->rd_bmval[1] & NFSD_WRITEONLY_ATTRS_WORD1)
812                 return nfserr_inval;
813
814         readdir->rd_bmval[0] &= nfsd_suppattrs[cstate->minorversion][0];
815         readdir->rd_bmval[1] &= nfsd_suppattrs[cstate->minorversion][1];
816         readdir->rd_bmval[2] &= nfsd_suppattrs[cstate->minorversion][2];
817
818         if ((cookie == 1) || (cookie == 2) ||
819             (cookie == 0 && memcmp(readdir->rd_verf.data, zeroverf.data, NFS4_VERIFIER_SIZE)))
820                 return nfserr_bad_cookie;
821
822         readdir->rd_rqstp = rqstp;
823         readdir->rd_fhp = &cstate->current_fh;
824         return nfs_ok;
825 }
826
827 static __be32
828 nfsd4_readlink(struct svc_rqst *rqstp, struct nfsd4_compound_state *cstate,
829                union nfsd4_op_u *u)
830 {
831         u->readlink.rl_rqstp = rqstp;
832         u->readlink.rl_fhp = &cstate->current_fh;
833         return nfs_ok;
834 }
835
836 static __be32
837 nfsd4_remove(struct svc_rqst *rqstp, struct nfsd4_compound_state *cstate,
838              union nfsd4_op_u *u)
839 {
840         struct nfsd4_remove *remove = &u->remove;
841         __be32 status;
842
843         if (opens_in_grace(SVC_NET(rqstp)))
844                 return nfserr_grace;
845         status = nfsd_unlink(rqstp, &cstate->current_fh, 0,
846                              remove->rm_name, remove->rm_namelen);
847         if (!status) {
848                 fh_unlock(&cstate->current_fh);
849                 set_change_info(&remove->rm_cinfo, &cstate->current_fh);
850         }
851         return status;
852 }
853
854 static __be32
855 nfsd4_rename(struct svc_rqst *rqstp, struct nfsd4_compound_state *cstate,
856              union nfsd4_op_u *u)
857 {
858         struct nfsd4_rename *rename = &u->rename;
859         __be32 status;
860
861         if (opens_in_grace(SVC_NET(rqstp)))
862                 return nfserr_grace;
863         status = nfsd_rename(rqstp, &cstate->save_fh, rename->rn_sname,
864                              rename->rn_snamelen, &cstate->current_fh,
865                              rename->rn_tname, rename->rn_tnamelen);
866         if (status)
867                 return status;
868         set_change_info(&rename->rn_sinfo, &cstate->current_fh);
869         set_change_info(&rename->rn_tinfo, &cstate->save_fh);
870         return nfs_ok;
871 }
872
873 static __be32
874 nfsd4_secinfo(struct svc_rqst *rqstp, struct nfsd4_compound_state *cstate,
875               union nfsd4_op_u *u)
876 {
877         struct nfsd4_secinfo *secinfo = &u->secinfo;
878         struct svc_export *exp;
879         struct dentry *dentry;
880         __be32 err;
881
882         err = fh_verify(rqstp, &cstate->current_fh, S_IFDIR, NFSD_MAY_EXEC);
883         if (err)
884                 return err;
885         err = nfsd_lookup_dentry(rqstp, &cstate->current_fh,
886                                     secinfo->si_name, secinfo->si_namelen,
887                                     &exp, &dentry);
888         if (err)
889                 return err;
890         fh_unlock(&cstate->current_fh);
891         if (d_really_is_negative(dentry)) {
892                 exp_put(exp);
893                 err = nfserr_noent;
894         } else
895                 secinfo->si_exp = exp;
896         dput(dentry);
897         if (cstate->minorversion)
898                 /* See rfc 5661 section 2.6.3.1.1.8 */
899                 fh_put(&cstate->current_fh);
900         return err;
901 }
902
903 static __be32
904 nfsd4_secinfo_no_name(struct svc_rqst *rqstp, struct nfsd4_compound_state *cstate,
905                 union nfsd4_op_u *u)
906 {
907         __be32 err;
908
909         switch (u->secinfo_no_name.sin_style) {
910         case NFS4_SECINFO_STYLE4_CURRENT_FH:
911                 break;
912         case NFS4_SECINFO_STYLE4_PARENT:
913                 err = nfsd4_do_lookupp(rqstp, &cstate->current_fh);
914                 if (err)
915                         return err;
916                 break;
917         default:
918                 return nfserr_inval;
919         }
920
921         u->secinfo_no_name.sin_exp = exp_get(cstate->current_fh.fh_export);
922         fh_put(&cstate->current_fh);
923         return nfs_ok;
924 }
925
926 static void
927 nfsd4_secinfo_release(union nfsd4_op_u *u)
928 {
929         if (u->secinfo.si_exp)
930                 exp_put(u->secinfo.si_exp);
931 }
932
933 static void
934 nfsd4_secinfo_no_name_release(union nfsd4_op_u *u)
935 {
936         if (u->secinfo_no_name.sin_exp)
937                 exp_put(u->secinfo_no_name.sin_exp);
938 }
939
940 static __be32
941 nfsd4_setattr(struct svc_rqst *rqstp, struct nfsd4_compound_state *cstate,
942               union nfsd4_op_u *u)
943 {
944         struct nfsd4_setattr *setattr = &u->setattr;
945         __be32 status = nfs_ok;
946         int err;
947
948         if (setattr->sa_iattr.ia_valid & ATTR_SIZE) {
949                 status = nfs4_preprocess_stateid_op(rqstp, cstate,
950                                 &cstate->current_fh, &setattr->sa_stateid,
951                                 WR_STATE, NULL);
952                 if (status) {
953                         dprintk("NFSD: nfsd4_setattr: couldn't process stateid!\n");
954                         return status;
955                 }
956         }
957         err = fh_want_write(&cstate->current_fh);
958         if (err)
959                 return nfserrno(err);
960         status = nfs_ok;
961
962         status = check_attr_support(rqstp, cstate, setattr->sa_bmval,
963                                     nfsd_attrmask);
964         if (status)
965                 goto out;
966
967         if (setattr->sa_acl != NULL)
968                 status = nfsd4_set_nfs4_acl(rqstp, &cstate->current_fh,
969                                             setattr->sa_acl);
970         if (status)
971                 goto out;
972         if (setattr->sa_label.len)
973                 status = nfsd4_set_nfs4_label(rqstp, &cstate->current_fh,
974                                 &setattr->sa_label);
975         if (status)
976                 goto out;
977         status = nfsd_setattr(rqstp, &cstate->current_fh, &setattr->sa_iattr,
978                                 0, (time_t)0);
979 out:
980         fh_drop_write(&cstate->current_fh);
981         return status;
982 }
983
984 static __be32
985 nfsd4_write(struct svc_rqst *rqstp, struct nfsd4_compound_state *cstate,
986             union nfsd4_op_u *u)
987 {
988         struct nfsd4_write *write = &u->write;
989         stateid_t *stateid = &write->wr_stateid;
990         struct nfsd_file *nf = NULL;
991         __be32 status = nfs_ok;
992         unsigned long cnt;
993         int nvecs;
994
995         if (write->wr_offset > (u64)OFFSET_MAX ||
996             write->wr_offset + write->wr_buflen > (u64)OFFSET_MAX)
997                 return nfserr_fbig;
998
999         cnt = write->wr_buflen;
1000         trace_nfsd_write_start(rqstp, &cstate->current_fh,
1001                                write->wr_offset, cnt);
1002         status = nfs4_preprocess_stateid_op(rqstp, cstate, &cstate->current_fh,
1003                                                 stateid, WR_STATE, &nf);
1004         if (status) {
1005                 dprintk("NFSD: nfsd4_write: couldn't process stateid!\n");
1006                 return status;
1007         }
1008
1009         write->wr_how_written = write->wr_stable_how;
1010         gen_boot_verifier(&write->wr_verifier, SVC_NET(rqstp));
1011
1012         nvecs = svc_fill_write_vector(rqstp, write->wr_pagelist,
1013                                       &write->wr_head, write->wr_buflen);
1014         WARN_ON_ONCE(nvecs > ARRAY_SIZE(rqstp->rq_vec));
1015
1016         status = nfsd_vfs_write(rqstp, &cstate->current_fh, nf->nf_file,
1017                                 write->wr_offset, rqstp->rq_vec, nvecs, &cnt,
1018                                 write->wr_how_written);
1019         nfsd_file_put(nf);
1020
1021         write->wr_bytes_written = cnt;
1022         trace_nfsd_write_done(rqstp, &cstate->current_fh,
1023                               write->wr_offset, cnt);
1024         return status;
1025 }
1026
1027 static __be32
1028 nfsd4_verify_copy(struct svc_rqst *rqstp, struct nfsd4_compound_state *cstate,
1029                   stateid_t *src_stateid, struct nfsd_file **src,
1030                   stateid_t *dst_stateid, struct nfsd_file **dst)
1031 {
1032         __be32 status;
1033
1034         if (!cstate->save_fh.fh_dentry)
1035                 return nfserr_nofilehandle;
1036
1037         status = nfs4_preprocess_stateid_op(rqstp, cstate, &cstate->save_fh,
1038                                             src_stateid, RD_STATE, src);
1039         if (status) {
1040                 dprintk("NFSD: %s: couldn't process src stateid!\n", __func__);
1041                 goto out;
1042         }
1043
1044         status = nfs4_preprocess_stateid_op(rqstp, cstate, &cstate->current_fh,
1045                                             dst_stateid, WR_STATE, dst);
1046         if (status) {
1047                 dprintk("NFSD: %s: couldn't process dst stateid!\n", __func__);
1048                 goto out_put_src;
1049         }
1050
1051         /* fix up for NFS-specific error code */
1052         if (!S_ISREG(file_inode((*src)->nf_file)->i_mode) ||
1053             !S_ISREG(file_inode((*dst)->nf_file)->i_mode)) {
1054                 status = nfserr_wrong_type;
1055                 goto out_put_dst;
1056         }
1057
1058 out:
1059         return status;
1060 out_put_dst:
1061         nfsd_file_put(*dst);
1062 out_put_src:
1063         nfsd_file_put(*src);
1064         goto out;
1065 }
1066
1067 static __be32
1068 nfsd4_clone(struct svc_rqst *rqstp, struct nfsd4_compound_state *cstate,
1069                 union nfsd4_op_u *u)
1070 {
1071         struct nfsd4_clone *clone = &u->clone;
1072         struct nfsd_file *src, *dst;
1073         __be32 status;
1074
1075         status = nfsd4_verify_copy(rqstp, cstate, &clone->cl_src_stateid, &src,
1076                                    &clone->cl_dst_stateid, &dst);
1077         if (status)
1078                 goto out;
1079
1080         status = nfsd4_clone_file_range(src->nf_file, clone->cl_src_pos,
1081                         dst->nf_file, clone->cl_dst_pos, clone->cl_count,
1082                         EX_ISSYNC(cstate->current_fh.fh_export));
1083
1084         nfsd_file_put(dst);
1085         nfsd_file_put(src);
1086 out:
1087         return status;
1088 }
1089
1090 void nfs4_put_copy(struct nfsd4_copy *copy)
1091 {
1092         if (!refcount_dec_and_test(&copy->refcount))
1093                 return;
1094         kfree(copy);
1095 }
1096
1097 static bool
1098 check_and_set_stop_copy(struct nfsd4_copy *copy)
1099 {
1100         bool value;
1101
1102         spin_lock(&copy->cp_clp->async_lock);
1103         value = copy->stopped;
1104         if (!copy->stopped)
1105                 copy->stopped = true;
1106         spin_unlock(&copy->cp_clp->async_lock);
1107         return value;
1108 }
1109
1110 static void nfsd4_stop_copy(struct nfsd4_copy *copy)
1111 {
1112         /* only 1 thread should stop the copy */
1113         if (!check_and_set_stop_copy(copy))
1114                 kthread_stop(copy->copy_task);
1115         nfs4_put_copy(copy);
1116 }
1117
1118 static struct nfsd4_copy *nfsd4_get_copy(struct nfs4_client *clp)
1119 {
1120         struct nfsd4_copy *copy = NULL;
1121
1122         spin_lock(&clp->async_lock);
1123         if (!list_empty(&clp->async_copies)) {
1124                 copy = list_first_entry(&clp->async_copies, struct nfsd4_copy,
1125                                         copies);
1126                 refcount_inc(&copy->refcount);
1127         }
1128         spin_unlock(&clp->async_lock);
1129         return copy;
1130 }
1131
1132 void nfsd4_shutdown_copy(struct nfs4_client *clp)
1133 {
1134         struct nfsd4_copy *copy;
1135
1136         while ((copy = nfsd4_get_copy(clp)) != NULL)
1137                 nfsd4_stop_copy(copy);
1138 }
1139
1140 static void nfsd4_cb_offload_release(struct nfsd4_callback *cb)
1141 {
1142         struct nfsd4_copy *copy = container_of(cb, struct nfsd4_copy, cp_cb);
1143
1144         nfs4_put_copy(copy);
1145 }
1146
1147 static int nfsd4_cb_offload_done(struct nfsd4_callback *cb,
1148                                  struct rpc_task *task)
1149 {
1150         return 1;
1151 }
1152
1153 static const struct nfsd4_callback_ops nfsd4_cb_offload_ops = {
1154         .release = nfsd4_cb_offload_release,
1155         .done = nfsd4_cb_offload_done
1156 };
1157
1158 static void nfsd4_init_copy_res(struct nfsd4_copy *copy, bool sync)
1159 {
1160         copy->cp_res.wr_stable_how = NFS_UNSTABLE;
1161         copy->cp_synchronous = sync;
1162         gen_boot_verifier(&copy->cp_res.wr_verifier, copy->cp_clp->net);
1163 }
1164
1165 static ssize_t _nfsd_copy_file_range(struct nfsd4_copy *copy)
1166 {
1167         ssize_t bytes_copied = 0;
1168         size_t bytes_total = copy->cp_count;
1169         u64 src_pos = copy->cp_src_pos;
1170         u64 dst_pos = copy->cp_dst_pos;
1171
1172         do {
1173                 if (kthread_should_stop())
1174                         break;
1175                 bytes_copied = nfsd_copy_file_range(copy->nf_src->nf_file,
1176                                 src_pos, copy->nf_dst->nf_file, dst_pos,
1177                                 bytes_total);
1178                 if (bytes_copied <= 0)
1179                         break;
1180                 bytes_total -= bytes_copied;
1181                 copy->cp_res.wr_bytes_written += bytes_copied;
1182                 src_pos += bytes_copied;
1183                 dst_pos += bytes_copied;
1184         } while (bytes_total > 0 && !copy->cp_synchronous);
1185         return bytes_copied;
1186 }
1187
1188 static __be32 nfsd4_do_copy(struct nfsd4_copy *copy, bool sync)
1189 {
1190         __be32 status;
1191         ssize_t bytes;
1192
1193         bytes = _nfsd_copy_file_range(copy);
1194         /* for async copy, we ignore the error, client can always retry
1195          * to get the error
1196          */
1197         if (bytes < 0 && !copy->cp_res.wr_bytes_written)
1198                 status = nfserrno(bytes);
1199         else {
1200                 nfsd4_init_copy_res(copy, sync);
1201                 status = nfs_ok;
1202         }
1203
1204         nfsd_file_put(copy->nf_src);
1205         nfsd_file_put(copy->nf_dst);
1206         return status;
1207 }
1208
1209 static void dup_copy_fields(struct nfsd4_copy *src, struct nfsd4_copy *dst)
1210 {
1211         dst->cp_src_pos = src->cp_src_pos;
1212         dst->cp_dst_pos = src->cp_dst_pos;
1213         dst->cp_count = src->cp_count;
1214         dst->cp_synchronous = src->cp_synchronous;
1215         memcpy(&dst->cp_res, &src->cp_res, sizeof(src->cp_res));
1216         memcpy(&dst->fh, &src->fh, sizeof(src->fh));
1217         dst->cp_clp = src->cp_clp;
1218         dst->nf_dst = nfsd_file_get(src->nf_dst);
1219         dst->nf_src = nfsd_file_get(src->nf_src);
1220         memcpy(&dst->cp_stateid, &src->cp_stateid, sizeof(src->cp_stateid));
1221 }
1222
1223 static void cleanup_async_copy(struct nfsd4_copy *copy)
1224 {
1225         nfs4_free_cp_state(copy);
1226         nfsd_file_put(copy->nf_dst);
1227         nfsd_file_put(copy->nf_src);
1228         spin_lock(&copy->cp_clp->async_lock);
1229         list_del(&copy->copies);
1230         spin_unlock(&copy->cp_clp->async_lock);
1231         nfs4_put_copy(copy);
1232 }
1233
1234 static int nfsd4_do_async_copy(void *data)
1235 {
1236         struct nfsd4_copy *copy = (struct nfsd4_copy *)data;
1237         struct nfsd4_copy *cb_copy;
1238
1239         copy->nfserr = nfsd4_do_copy(copy, 0);
1240         cb_copy = kzalloc(sizeof(struct nfsd4_copy), GFP_KERNEL);
1241         if (!cb_copy)
1242                 goto out;
1243         memcpy(&cb_copy->cp_res, &copy->cp_res, sizeof(copy->cp_res));
1244         cb_copy->cp_clp = copy->cp_clp;
1245         cb_copy->nfserr = copy->nfserr;
1246         memcpy(&cb_copy->fh, &copy->fh, sizeof(copy->fh));
1247         nfsd4_init_cb(&cb_copy->cp_cb, cb_copy->cp_clp,
1248                         &nfsd4_cb_offload_ops, NFSPROC4_CLNT_CB_OFFLOAD);
1249         nfsd4_run_cb(&cb_copy->cp_cb);
1250 out:
1251         cleanup_async_copy(copy);
1252         return 0;
1253 }
1254
1255 static __be32
1256 nfsd4_copy(struct svc_rqst *rqstp, struct nfsd4_compound_state *cstate,
1257                 union nfsd4_op_u *u)
1258 {
1259         struct nfsd4_copy *copy = &u->copy;
1260         __be32 status;
1261         struct nfsd4_copy *async_copy = NULL;
1262
1263         status = nfsd4_verify_copy(rqstp, cstate, &copy->cp_src_stateid,
1264                                    &copy->nf_src, &copy->cp_dst_stateid,
1265                                    &copy->nf_dst);
1266         if (status)
1267                 goto out;
1268
1269         copy->cp_clp = cstate->clp;
1270         memcpy(&copy->fh, &cstate->current_fh.fh_handle,
1271                 sizeof(struct knfsd_fh));
1272         if (!copy->cp_synchronous) {
1273                 struct nfsd_net *nn = net_generic(SVC_NET(rqstp), nfsd_net_id);
1274
1275                 status = nfserrno(-ENOMEM);
1276                 async_copy = kzalloc(sizeof(struct nfsd4_copy), GFP_KERNEL);
1277                 if (!async_copy)
1278                         goto out;
1279                 if (!nfs4_init_cp_state(nn, copy)) {
1280                         kfree(async_copy);
1281                         goto out;
1282                 }
1283                 refcount_set(&async_copy->refcount, 1);
1284                 memcpy(&copy->cp_res.cb_stateid, &copy->cp_stateid,
1285                         sizeof(copy->cp_stateid));
1286                 dup_copy_fields(copy, async_copy);
1287                 async_copy->copy_task = kthread_create(nfsd4_do_async_copy,
1288                                 async_copy, "%s", "copy thread");
1289                 if (IS_ERR(async_copy->copy_task))
1290                         goto out_err;
1291                 spin_lock(&async_copy->cp_clp->async_lock);
1292                 list_add(&async_copy->copies,
1293                                 &async_copy->cp_clp->async_copies);
1294                 spin_unlock(&async_copy->cp_clp->async_lock);
1295                 wake_up_process(async_copy->copy_task);
1296                 status = nfs_ok;
1297         } else
1298                 status = nfsd4_do_copy(copy, 1);
1299 out:
1300         return status;
1301 out_err:
1302         if (async_copy)
1303                 cleanup_async_copy(async_copy);
1304         goto out;
1305 }
1306
1307 struct nfsd4_copy *
1308 find_async_copy(struct nfs4_client *clp, stateid_t *stateid)
1309 {
1310         struct nfsd4_copy *copy;
1311
1312         spin_lock(&clp->async_lock);
1313         list_for_each_entry(copy, &clp->async_copies, copies) {
1314                 if (memcmp(&copy->cp_stateid, stateid, NFS4_STATEID_SIZE))
1315                         continue;
1316                 refcount_inc(&copy->refcount);
1317                 spin_unlock(&clp->async_lock);
1318                 return copy;
1319         }
1320         spin_unlock(&clp->async_lock);
1321         return NULL;
1322 }
1323
1324 static __be32
1325 nfsd4_offload_cancel(struct svc_rqst *rqstp,
1326                      struct nfsd4_compound_state *cstate,
1327                      union nfsd4_op_u *u)
1328 {
1329         struct nfsd4_offload_status *os = &u->offload_status;
1330         __be32 status = 0;
1331         struct nfsd4_copy *copy;
1332         struct nfs4_client *clp = cstate->clp;
1333
1334         copy = find_async_copy(clp, &os->stateid);
1335         if (copy)
1336                 nfsd4_stop_copy(copy);
1337         else
1338                 status = nfserr_bad_stateid;
1339
1340         return status;
1341 }
1342
1343 static __be32
1344 nfsd4_fallocate(struct svc_rqst *rqstp, struct nfsd4_compound_state *cstate,
1345                 struct nfsd4_fallocate *fallocate, int flags)
1346 {
1347         __be32 status;
1348         struct nfsd_file *nf;
1349
1350         status = nfs4_preprocess_stateid_op(rqstp, cstate, &cstate->current_fh,
1351                                             &fallocate->falloc_stateid,
1352                                             WR_STATE, &nf);
1353         if (status != nfs_ok) {
1354                 dprintk("NFSD: nfsd4_fallocate: couldn't process stateid!\n");
1355                 return status;
1356         }
1357
1358         status = nfsd4_vfs_fallocate(rqstp, &cstate->current_fh, nf->nf_file,
1359                                      fallocate->falloc_offset,
1360                                      fallocate->falloc_length,
1361                                      flags);
1362         nfsd_file_put(nf);
1363         return status;
1364 }
1365 static __be32
1366 nfsd4_offload_status(struct svc_rqst *rqstp,
1367                      struct nfsd4_compound_state *cstate,
1368                      union nfsd4_op_u *u)
1369 {
1370         struct nfsd4_offload_status *os = &u->offload_status;
1371         __be32 status = 0;
1372         struct nfsd4_copy *copy;
1373         struct nfs4_client *clp = cstate->clp;
1374
1375         copy = find_async_copy(clp, &os->stateid);
1376         if (copy) {
1377                 os->count = copy->cp_res.wr_bytes_written;
1378                 nfs4_put_copy(copy);
1379         } else
1380                 status = nfserr_bad_stateid;
1381
1382         return status;
1383 }
1384
1385 static __be32
1386 nfsd4_allocate(struct svc_rqst *rqstp, struct nfsd4_compound_state *cstate,
1387                union nfsd4_op_u *u)
1388 {
1389         return nfsd4_fallocate(rqstp, cstate, &u->allocate, 0);
1390 }
1391
1392 static __be32
1393 nfsd4_deallocate(struct svc_rqst *rqstp, struct nfsd4_compound_state *cstate,
1394                  union nfsd4_op_u *u)
1395 {
1396         return nfsd4_fallocate(rqstp, cstate, &u->deallocate,
1397                                FALLOC_FL_PUNCH_HOLE | FALLOC_FL_KEEP_SIZE);
1398 }
1399
1400 static __be32
1401 nfsd4_seek(struct svc_rqst *rqstp, struct nfsd4_compound_state *cstate,
1402            union nfsd4_op_u *u)
1403 {
1404         struct nfsd4_seek *seek = &u->seek;
1405         int whence;
1406         __be32 status;
1407         struct nfsd_file *nf;
1408
1409         status = nfs4_preprocess_stateid_op(rqstp, cstate, &cstate->current_fh,
1410                                             &seek->seek_stateid,
1411                                             RD_STATE, &nf);
1412         if (status) {
1413                 dprintk("NFSD: nfsd4_seek: couldn't process stateid!\n");
1414                 return status;
1415         }
1416
1417         switch (seek->seek_whence) {
1418         case NFS4_CONTENT_DATA:
1419                 whence = SEEK_DATA;
1420                 break;
1421         case NFS4_CONTENT_HOLE:
1422                 whence = SEEK_HOLE;
1423                 break;
1424         default:
1425                 status = nfserr_union_notsupp;
1426                 goto out;
1427         }
1428
1429         /*
1430          * Note:  This call does change file->f_pos, but nothing in NFSD
1431          *        should ever file->f_pos.
1432          */
1433         seek->seek_pos = vfs_llseek(nf->nf_file, seek->seek_offset, whence);
1434         if (seek->seek_pos < 0)
1435                 status = nfserrno(seek->seek_pos);
1436         else if (seek->seek_pos >= i_size_read(file_inode(nf->nf_file)))
1437                 seek->seek_eof = true;
1438
1439 out:
1440         nfsd_file_put(nf);
1441         return status;
1442 }
1443
1444 /* This routine never returns NFS_OK!  If there are no other errors, it
1445  * will return NFSERR_SAME or NFSERR_NOT_SAME depending on whether the
1446  * attributes matched.  VERIFY is implemented by mapping NFSERR_SAME
1447  * to NFS_OK after the call; NVERIFY by mapping NFSERR_NOT_SAME to NFS_OK.
1448  */
1449 static __be32
1450 _nfsd4_verify(struct svc_rqst *rqstp, struct nfsd4_compound_state *cstate,
1451              struct nfsd4_verify *verify)
1452 {
1453         __be32 *buf, *p;
1454         int count;
1455         __be32 status;
1456
1457         status = fh_verify(rqstp, &cstate->current_fh, 0, NFSD_MAY_NOP);
1458         if (status)
1459                 return status;
1460
1461         status = check_attr_support(rqstp, cstate, verify->ve_bmval, NULL);
1462         if (status)
1463                 return status;
1464
1465         if ((verify->ve_bmval[0] & FATTR4_WORD0_RDATTR_ERROR)
1466             || (verify->ve_bmval[1] & NFSD_WRITEONLY_ATTRS_WORD1))
1467                 return nfserr_inval;
1468         if (verify->ve_attrlen & 3)
1469                 return nfserr_inval;
1470
1471         /* count in words:
1472          *   bitmap_len(1) + bitmap(2) + attr_len(1) = 4
1473          */
1474         count = 4 + (verify->ve_attrlen >> 2);
1475         buf = kmalloc(count << 2, GFP_KERNEL);
1476         if (!buf)
1477                 return nfserr_jukebox;
1478
1479         p = buf;
1480         status = nfsd4_encode_fattr_to_buf(&p, count, &cstate->current_fh,
1481                                     cstate->current_fh.fh_export,
1482                                     cstate->current_fh.fh_dentry,
1483                                     verify->ve_bmval,
1484                                     rqstp, 0);
1485         /*
1486          * If nfsd4_encode_fattr() ran out of space, assume that's because
1487          * the attributes are longer (hence different) than those given:
1488          */
1489         if (status == nfserr_resource)
1490                 status = nfserr_not_same;
1491         if (status)
1492                 goto out_kfree;
1493
1494         /* skip bitmap */
1495         p = buf + 1 + ntohl(buf[0]);
1496         status = nfserr_not_same;
1497         if (ntohl(*p++) != verify->ve_attrlen)
1498                 goto out_kfree;
1499         if (!memcmp(p, verify->ve_attrval, verify->ve_attrlen))
1500                 status = nfserr_same;
1501
1502 out_kfree:
1503         kfree(buf);
1504         return status;
1505 }
1506
1507 static __be32
1508 nfsd4_nverify(struct svc_rqst *rqstp, struct nfsd4_compound_state *cstate,
1509               union nfsd4_op_u *u)
1510 {
1511         __be32 status;
1512
1513         status = _nfsd4_verify(rqstp, cstate, &u->verify);
1514         return status == nfserr_not_same ? nfs_ok : status;
1515 }
1516
1517 static __be32
1518 nfsd4_verify(struct svc_rqst *rqstp, struct nfsd4_compound_state *cstate,
1519              union nfsd4_op_u *u)
1520 {
1521         __be32 status;
1522
1523         status = _nfsd4_verify(rqstp, cstate, &u->nverify);
1524         return status == nfserr_same ? nfs_ok : status;
1525 }
1526
1527 #ifdef CONFIG_NFSD_PNFS
1528 static const struct nfsd4_layout_ops *
1529 nfsd4_layout_verify(struct svc_export *exp, unsigned int layout_type)
1530 {
1531         if (!exp->ex_layout_types) {
1532                 dprintk("%s: export does not support pNFS\n", __func__);
1533                 return NULL;
1534         }
1535
1536         if (layout_type >= LAYOUT_TYPE_MAX ||
1537             !(exp->ex_layout_types & (1 << layout_type))) {
1538                 dprintk("%s: layout type %d not supported\n",
1539                         __func__, layout_type);
1540                 return NULL;
1541         }
1542
1543         return nfsd4_layout_ops[layout_type];
1544 }
1545
1546 static __be32
1547 nfsd4_getdeviceinfo(struct svc_rqst *rqstp,
1548                 struct nfsd4_compound_state *cstate, union nfsd4_op_u *u)
1549 {
1550         struct nfsd4_getdeviceinfo *gdp = &u->getdeviceinfo;
1551         const struct nfsd4_layout_ops *ops;
1552         struct nfsd4_deviceid_map *map;
1553         struct svc_export *exp;
1554         __be32 nfserr;
1555
1556         dprintk("%s: layout_type %u dev_id [0x%llx:0x%x] maxcnt %u\n",
1557                __func__,
1558                gdp->gd_layout_type,
1559                gdp->gd_devid.fsid_idx, gdp->gd_devid.generation,
1560                gdp->gd_maxcount);
1561
1562         map = nfsd4_find_devid_map(gdp->gd_devid.fsid_idx);
1563         if (!map) {
1564                 dprintk("%s: couldn't find device ID to export mapping!\n",
1565                         __func__);
1566                 return nfserr_noent;
1567         }
1568
1569         exp = rqst_exp_find(rqstp, map->fsid_type, map->fsid);
1570         if (IS_ERR(exp)) {
1571                 dprintk("%s: could not find device id\n", __func__);
1572                 return nfserr_noent;
1573         }
1574
1575         nfserr = nfserr_layoutunavailable;
1576         ops = nfsd4_layout_verify(exp, gdp->gd_layout_type);
1577         if (!ops)
1578                 goto out;
1579
1580         nfserr = nfs_ok;
1581         if (gdp->gd_maxcount != 0) {
1582                 nfserr = ops->proc_getdeviceinfo(exp->ex_path.mnt->mnt_sb,
1583                                 rqstp, cstate->session->se_client, gdp);
1584         }
1585
1586         gdp->gd_notify_types &= ops->notify_types;
1587 out:
1588         exp_put(exp);
1589         return nfserr;
1590 }
1591
1592 static void
1593 nfsd4_getdeviceinfo_release(union nfsd4_op_u *u)
1594 {
1595         kfree(u->getdeviceinfo.gd_device);
1596 }
1597
1598 static __be32
1599 nfsd4_layoutget(struct svc_rqst *rqstp,
1600                 struct nfsd4_compound_state *cstate, union nfsd4_op_u *u)
1601 {
1602         struct nfsd4_layoutget *lgp = &u->layoutget;
1603         struct svc_fh *current_fh = &cstate->current_fh;
1604         const struct nfsd4_layout_ops *ops;
1605         struct nfs4_layout_stateid *ls;
1606         __be32 nfserr;
1607         int accmode = NFSD_MAY_READ_IF_EXEC;
1608
1609         switch (lgp->lg_seg.iomode) {
1610         case IOMODE_READ:
1611                 accmode |= NFSD_MAY_READ;
1612                 break;
1613         case IOMODE_RW:
1614                 accmode |= NFSD_MAY_READ | NFSD_MAY_WRITE;
1615                 break;
1616         default:
1617                 dprintk("%s: invalid iomode %d\n",
1618                         __func__, lgp->lg_seg.iomode);
1619                 nfserr = nfserr_badiomode;
1620                 goto out;
1621         }
1622
1623         nfserr = fh_verify(rqstp, current_fh, 0, accmode);
1624         if (nfserr)
1625                 goto out;
1626
1627         nfserr = nfserr_layoutunavailable;
1628         ops = nfsd4_layout_verify(current_fh->fh_export, lgp->lg_layout_type);
1629         if (!ops)
1630                 goto out;
1631
1632         /*
1633          * Verify minlength and range as per RFC5661:
1634          *  o  If loga_length is less than loga_minlength,
1635          *     the metadata server MUST return NFS4ERR_INVAL.
1636          *  o  If the sum of loga_offset and loga_minlength exceeds
1637          *     NFS4_UINT64_MAX, and loga_minlength is not
1638          *     NFS4_UINT64_MAX, the error NFS4ERR_INVAL MUST result.
1639          *  o  If the sum of loga_offset and loga_length exceeds
1640          *     NFS4_UINT64_MAX, and loga_length is not NFS4_UINT64_MAX,
1641          *     the error NFS4ERR_INVAL MUST result.
1642          */
1643         nfserr = nfserr_inval;
1644         if (lgp->lg_seg.length < lgp->lg_minlength ||
1645             (lgp->lg_minlength != NFS4_MAX_UINT64 &&
1646              lgp->lg_minlength > NFS4_MAX_UINT64 - lgp->lg_seg.offset) ||
1647             (lgp->lg_seg.length != NFS4_MAX_UINT64 &&
1648              lgp->lg_seg.length > NFS4_MAX_UINT64 - lgp->lg_seg.offset))
1649                 goto out;
1650         if (lgp->lg_seg.length == 0)
1651                 goto out;
1652
1653         nfserr = nfsd4_preprocess_layout_stateid(rqstp, cstate, &lgp->lg_sid,
1654                                                 true, lgp->lg_layout_type, &ls);
1655         if (nfserr) {
1656                 trace_nfsd_layout_get_lookup_fail(&lgp->lg_sid);
1657                 goto out;
1658         }
1659
1660         nfserr = nfserr_recallconflict;
1661         if (atomic_read(&ls->ls_stid.sc_file->fi_lo_recalls))
1662                 goto out_put_stid;
1663
1664         nfserr = ops->proc_layoutget(d_inode(current_fh->fh_dentry),
1665                                      current_fh, lgp);
1666         if (nfserr)
1667                 goto out_put_stid;
1668
1669         nfserr = nfsd4_insert_layout(lgp, ls);
1670
1671 out_put_stid:
1672         mutex_unlock(&ls->ls_mutex);
1673         nfs4_put_stid(&ls->ls_stid);
1674 out:
1675         return nfserr;
1676 }
1677
1678 static void
1679 nfsd4_layoutget_release(union nfsd4_op_u *u)
1680 {
1681         kfree(u->layoutget.lg_content);
1682 }
1683
1684 static __be32
1685 nfsd4_layoutcommit(struct svc_rqst *rqstp,
1686                 struct nfsd4_compound_state *cstate, union nfsd4_op_u *u)
1687 {
1688         struct nfsd4_layoutcommit *lcp = &u->layoutcommit;
1689         const struct nfsd4_layout_seg *seg = &lcp->lc_seg;
1690         struct svc_fh *current_fh = &cstate->current_fh;
1691         const struct nfsd4_layout_ops *ops;
1692         loff_t new_size = lcp->lc_last_wr + 1;
1693         struct inode *inode;
1694         struct nfs4_layout_stateid *ls;
1695         __be32 nfserr;
1696
1697         nfserr = fh_verify(rqstp, current_fh, 0, NFSD_MAY_WRITE);
1698         if (nfserr)
1699                 goto out;
1700
1701         nfserr = nfserr_layoutunavailable;
1702         ops = nfsd4_layout_verify(current_fh->fh_export, lcp->lc_layout_type);
1703         if (!ops)
1704                 goto out;
1705         inode = d_inode(current_fh->fh_dentry);
1706
1707         nfserr = nfserr_inval;
1708         if (new_size <= seg->offset) {
1709                 dprintk("pnfsd: last write before layout segment\n");
1710                 goto out;
1711         }
1712         if (new_size > seg->offset + seg->length) {
1713                 dprintk("pnfsd: last write beyond layout segment\n");
1714                 goto out;
1715         }
1716         if (!lcp->lc_newoffset && new_size > i_size_read(inode)) {
1717                 dprintk("pnfsd: layoutcommit beyond EOF\n");
1718                 goto out;
1719         }
1720
1721         nfserr = nfsd4_preprocess_layout_stateid(rqstp, cstate, &lcp->lc_sid,
1722                                                 false, lcp->lc_layout_type,
1723                                                 &ls);
1724         if (nfserr) {
1725                 trace_nfsd_layout_commit_lookup_fail(&lcp->lc_sid);
1726                 /* fixup error code as per RFC5661 */
1727                 if (nfserr == nfserr_bad_stateid)
1728                         nfserr = nfserr_badlayout;
1729                 goto out;
1730         }
1731
1732         /* LAYOUTCOMMIT does not require any serialization */
1733         mutex_unlock(&ls->ls_mutex);
1734
1735         if (new_size > i_size_read(inode)) {
1736                 lcp->lc_size_chg = 1;
1737                 lcp->lc_newsize = new_size;
1738         } else {
1739                 lcp->lc_size_chg = 0;
1740         }
1741
1742         nfserr = ops->proc_layoutcommit(inode, lcp);
1743         nfs4_put_stid(&ls->ls_stid);
1744 out:
1745         return nfserr;
1746 }
1747
1748 static __be32
1749 nfsd4_layoutreturn(struct svc_rqst *rqstp,
1750                 struct nfsd4_compound_state *cstate, union nfsd4_op_u *u)
1751 {
1752         struct nfsd4_layoutreturn *lrp = &u->layoutreturn;
1753         struct svc_fh *current_fh = &cstate->current_fh;
1754         __be32 nfserr;
1755
1756         nfserr = fh_verify(rqstp, current_fh, 0, NFSD_MAY_NOP);
1757         if (nfserr)
1758                 goto out;
1759
1760         nfserr = nfserr_layoutunavailable;
1761         if (!nfsd4_layout_verify(current_fh->fh_export, lrp->lr_layout_type))
1762                 goto out;
1763
1764         switch (lrp->lr_seg.iomode) {
1765         case IOMODE_READ:
1766         case IOMODE_RW:
1767         case IOMODE_ANY:
1768                 break;
1769         default:
1770                 dprintk("%s: invalid iomode %d\n", __func__,
1771                         lrp->lr_seg.iomode);
1772                 nfserr = nfserr_inval;
1773                 goto out;
1774         }
1775
1776         switch (lrp->lr_return_type) {
1777         case RETURN_FILE:
1778                 nfserr = nfsd4_return_file_layouts(rqstp, cstate, lrp);
1779                 break;
1780         case RETURN_FSID:
1781         case RETURN_ALL:
1782                 nfserr = nfsd4_return_client_layouts(rqstp, cstate, lrp);
1783                 break;
1784         default:
1785                 dprintk("%s: invalid return_type %d\n", __func__,
1786                         lrp->lr_return_type);
1787                 nfserr = nfserr_inval;
1788                 break;
1789         }
1790 out:
1791         return nfserr;
1792 }
1793 #endif /* CONFIG_NFSD_PNFS */
1794
1795 /*
1796  * NULL call.
1797  */
1798 static __be32
1799 nfsd4_proc_null(struct svc_rqst *rqstp)
1800 {
1801         return nfs_ok;
1802 }
1803
1804 static inline void nfsd4_increment_op_stats(u32 opnum)
1805 {
1806         if (opnum >= FIRST_NFS4_OP && opnum <= LAST_NFS4_OP)
1807                 nfsdstats.nfs4_opcount[opnum]++;
1808 }
1809
1810 static const struct nfsd4_operation nfsd4_ops[];
1811
1812 static const char *nfsd4_op_name(unsigned opnum);
1813
1814 /*
1815  * Enforce NFSv4.1 COMPOUND ordering rules:
1816  *
1817  * Also note, enforced elsewhere:
1818  *      - SEQUENCE other than as first op results in
1819  *        NFS4ERR_SEQUENCE_POS. (Enforced in nfsd4_sequence().)
1820  *      - BIND_CONN_TO_SESSION must be the only op in its compound.
1821  *        (Enforced in nfsd4_bind_conn_to_session().)
1822  *      - DESTROY_SESSION must be the final operation in a compound, if
1823  *        sessionid's in SEQUENCE and DESTROY_SESSION are the same.
1824  *        (Enforced in nfsd4_destroy_session().)
1825  */
1826 static __be32 nfs41_check_op_ordering(struct nfsd4_compoundargs *args)
1827 {
1828         struct nfsd4_op *first_op = &args->ops[0];
1829
1830         /* These ordering requirements don't apply to NFSv4.0: */
1831         if (args->minorversion == 0)
1832                 return nfs_ok;
1833         /* This is weird, but OK, not our problem: */
1834         if (args->opcnt == 0)
1835                 return nfs_ok;
1836         if (first_op->status == nfserr_op_illegal)
1837                 return nfs_ok;
1838         if (!(nfsd4_ops[first_op->opnum].op_flags & ALLOWED_AS_FIRST_OP))
1839                 return nfserr_op_not_in_session;
1840         if (first_op->opnum == OP_SEQUENCE)
1841                 return nfs_ok;
1842         /*
1843          * So first_op is something allowed outside a session, like
1844          * EXCHANGE_ID; but then it has to be the only op in the
1845          * compound:
1846          */
1847         if (args->opcnt != 1)
1848                 return nfserr_not_only_op;
1849         return nfs_ok;
1850 }
1851
1852 const struct nfsd4_operation *OPDESC(struct nfsd4_op *op)
1853 {
1854         return &nfsd4_ops[op->opnum];
1855 }
1856
1857 bool nfsd4_cache_this_op(struct nfsd4_op *op)
1858 {
1859         if (op->opnum == OP_ILLEGAL)
1860                 return false;
1861         return OPDESC(op)->op_flags & OP_CACHEME;
1862 }
1863
1864 static bool need_wrongsec_check(struct svc_rqst *rqstp)
1865 {
1866         struct nfsd4_compoundres *resp = rqstp->rq_resp;
1867         struct nfsd4_compoundargs *argp = rqstp->rq_argp;
1868         struct nfsd4_op *this = &argp->ops[resp->opcnt - 1];
1869         struct nfsd4_op *next = &argp->ops[resp->opcnt];
1870         const struct nfsd4_operation *thisd = OPDESC(this);
1871         const struct nfsd4_operation *nextd;
1872
1873         /*
1874          * Most ops check wronsec on our own; only the putfh-like ops
1875          * have special rules.
1876          */
1877         if (!(thisd->op_flags & OP_IS_PUTFH_LIKE))
1878                 return false;
1879         /*
1880          * rfc 5661 2.6.3.1.1.6: don't bother erroring out a
1881          * put-filehandle operation if we're not going to use the
1882          * result:
1883          */
1884         if (argp->opcnt == resp->opcnt)
1885                 return false;
1886         if (next->opnum == OP_ILLEGAL)
1887                 return false;
1888         nextd = OPDESC(next);
1889         /*
1890          * Rest of 2.6.3.1.1: certain operations will return WRONGSEC
1891          * errors themselves as necessary; others should check for them
1892          * now:
1893          */
1894         return !(nextd->op_flags & OP_HANDLES_WRONGSEC);
1895 }
1896
1897 static void svcxdr_init_encode(struct svc_rqst *rqstp,
1898                                struct nfsd4_compoundres *resp)
1899 {
1900         struct xdr_stream *xdr = &resp->xdr;
1901         struct xdr_buf *buf = &rqstp->rq_res;
1902         struct kvec *head = buf->head;
1903
1904         xdr->buf = buf;
1905         xdr->iov = head;
1906         xdr->p   = head->iov_base + head->iov_len;
1907         xdr->end = head->iov_base + PAGE_SIZE - rqstp->rq_auth_slack;
1908         /* Tail and page_len should be zero at this point: */
1909         buf->len = buf->head[0].iov_len;
1910         xdr->scratch.iov_len = 0;
1911         xdr->page_ptr = buf->pages - 1;
1912         buf->buflen = PAGE_SIZE * (1 + rqstp->rq_page_end - buf->pages)
1913                 - rqstp->rq_auth_slack;
1914 }
1915
1916 /*
1917  * COMPOUND call.
1918  */
1919 static __be32
1920 nfsd4_proc_compound(struct svc_rqst *rqstp)
1921 {
1922         struct nfsd4_compoundargs *args = rqstp->rq_argp;
1923         struct nfsd4_compoundres *resp = rqstp->rq_resp;
1924         struct nfsd4_op *op;
1925         struct nfsd4_compound_state *cstate = &resp->cstate;
1926         struct svc_fh *current_fh = &cstate->current_fh;
1927         struct svc_fh *save_fh = &cstate->save_fh;
1928         struct nfsd_net *nn = net_generic(SVC_NET(rqstp), nfsd_net_id);
1929         __be32          status;
1930
1931         svcxdr_init_encode(rqstp, resp);
1932         resp->tagp = resp->xdr.p;
1933         /* reserve space for: taglen, tag, and opcnt */
1934         xdr_reserve_space(&resp->xdr, 8 + args->taglen);
1935         resp->taglen = args->taglen;
1936         resp->tag = args->tag;
1937         resp->rqstp = rqstp;
1938         cstate->minorversion = args->minorversion;
1939         fh_init(current_fh, NFS4_FHSIZE);
1940         fh_init(save_fh, NFS4_FHSIZE);
1941         /*
1942          * Don't use the deferral mechanism for NFSv4; compounds make it
1943          * too hard to avoid non-idempotency problems.
1944          */
1945         clear_bit(RQ_USEDEFERRAL, &rqstp->rq_flags);
1946
1947         /*
1948          * According to RFC3010, this takes precedence over all other errors.
1949          */
1950         status = nfserr_minor_vers_mismatch;
1951         if (nfsd_minorversion(nn, args->minorversion, NFSD_TEST) <= 0)
1952                 goto out;
1953         status = nfserr_resource;
1954         if (args->opcnt > NFSD_MAX_OPS_PER_COMPOUND)
1955                 goto out;
1956
1957         status = nfs41_check_op_ordering(args);
1958         if (status) {
1959                 op = &args->ops[0];
1960                 op->status = status;
1961                 resp->opcnt = 1;
1962                 goto encode_op;
1963         }
1964
1965         trace_nfsd_compound(rqstp, args->opcnt);
1966         while (!status && resp->opcnt < args->opcnt) {
1967                 op = &args->ops[resp->opcnt++];
1968
1969                 /*
1970                  * The XDR decode routines may have pre-set op->status;
1971                  * for example, if there is a miscellaneous XDR error
1972                  * it will be set to nfserr_bad_xdr.
1973                  */
1974                 if (op->status) {
1975                         if (op->opnum == OP_OPEN)
1976                                 op->status = nfsd4_open_omfg(rqstp, cstate, op);
1977                         goto encode_op;
1978                 }
1979
1980                 if (!current_fh->fh_dentry) {
1981                         if (!(op->opdesc->op_flags & ALLOWED_WITHOUT_FH)) {
1982                                 op->status = nfserr_nofilehandle;
1983                                 goto encode_op;
1984                         }
1985                 } else if (current_fh->fh_export->ex_fslocs.migrated &&
1986                           !(op->opdesc->op_flags & ALLOWED_ON_ABSENT_FS)) {
1987                         op->status = nfserr_moved;
1988                         goto encode_op;
1989                 }
1990
1991                 fh_clear_wcc(current_fh);
1992
1993                 /* If op is non-idempotent */
1994                 if (op->opdesc->op_flags & OP_MODIFIES_SOMETHING) {
1995                         /*
1996                          * Don't execute this op if we couldn't encode a
1997                          * succesful reply:
1998                          */
1999                         u32 plen = op->opdesc->op_rsize_bop(rqstp, op);
2000                         /*
2001                          * Plus if there's another operation, make sure
2002                          * we'll have space to at least encode an error:
2003                          */
2004                         if (resp->opcnt < args->opcnt)
2005                                 plen += COMPOUND_ERR_SLACK_SPACE;
2006                         op->status = nfsd4_check_resp_size(resp, plen);
2007                 }
2008
2009                 if (op->status)
2010                         goto encode_op;
2011
2012                 if (op->opdesc->op_get_currentstateid)
2013                         op->opdesc->op_get_currentstateid(cstate, &op->u);
2014                 op->status = op->opdesc->op_func(rqstp, cstate, &op->u);
2015
2016                 /* Only from SEQUENCE */
2017                 if (cstate->status == nfserr_replay_cache) {
2018                         dprintk("%s NFS4.1 replay from cache\n", __func__);
2019                         status = op->status;
2020                         goto out;
2021                 }
2022                 if (!op->status) {
2023                         if (op->opdesc->op_set_currentstateid)
2024                                 op->opdesc->op_set_currentstateid(cstate, &op->u);
2025
2026                         if (op->opdesc->op_flags & OP_CLEAR_STATEID)
2027                                 clear_current_stateid(cstate);
2028
2029                         if (need_wrongsec_check(rqstp))
2030                                 op->status = check_nfsd_access(current_fh->fh_export, rqstp);
2031                 }
2032 encode_op:
2033                 if (op->status == nfserr_replay_me) {
2034                         op->replay = &cstate->replay_owner->so_replay;
2035                         nfsd4_encode_replay(&resp->xdr, op);
2036                         status = op->status = op->replay->rp_status;
2037                 } else {
2038                         nfsd4_encode_operation(resp, op);
2039                         status = op->status;
2040                 }
2041
2042                 trace_nfsd_compound_status(args->opcnt, resp->opcnt, status,
2043                                            nfsd4_op_name(op->opnum));
2044
2045                 nfsd4_cstate_clear_replay(cstate);
2046                 nfsd4_increment_op_stats(op->opnum);
2047         }
2048
2049         cstate->status = status;
2050         fh_put(current_fh);
2051         fh_put(save_fh);
2052         BUG_ON(cstate->replay_owner);
2053 out:
2054         /* Reset deferral mechanism for RPC deferrals */
2055         set_bit(RQ_USEDEFERRAL, &rqstp->rq_flags);
2056         dprintk("nfsv4 compound returned %d\n", ntohl(status));
2057         return status;
2058 }
2059
2060 #define op_encode_hdr_size              (2)
2061 #define op_encode_stateid_maxsz         (XDR_QUADLEN(NFS4_STATEID_SIZE))
2062 #define op_encode_verifier_maxsz        (XDR_QUADLEN(NFS4_VERIFIER_SIZE))
2063 #define op_encode_change_info_maxsz     (5)
2064 #define nfs4_fattr_bitmap_maxsz         (4)
2065
2066 /* We'll fall back on returning no lockowner if run out of space: */
2067 #define op_encode_lockowner_maxsz       (0)
2068 #define op_encode_lock_denied_maxsz     (8 + op_encode_lockowner_maxsz)
2069
2070 #define nfs4_owner_maxsz                (1 + XDR_QUADLEN(IDMAP_NAMESZ))
2071
2072 #define op_encode_ace_maxsz             (3 + nfs4_owner_maxsz)
2073 #define op_encode_delegation_maxsz      (1 + op_encode_stateid_maxsz + 1 + \
2074                                          op_encode_ace_maxsz)
2075
2076 #define op_encode_channel_attrs_maxsz   (6 + 1 + 1)
2077
2078 static inline u32 nfsd4_only_status_rsize(struct svc_rqst *rqstp, struct nfsd4_op *op)
2079 {
2080         return (op_encode_hdr_size) * sizeof(__be32);
2081 }
2082
2083 static inline u32 nfsd4_status_stateid_rsize(struct svc_rqst *rqstp, struct nfsd4_op *op)
2084 {
2085         return (op_encode_hdr_size + op_encode_stateid_maxsz)* sizeof(__be32);
2086 }
2087
2088 static inline u32 nfsd4_access_rsize(struct svc_rqst *rqstp, struct nfsd4_op *op)
2089 {
2090         /* ac_supported, ac_resp_access */
2091         return (op_encode_hdr_size + 2)* sizeof(__be32);
2092 }
2093
2094 static inline u32 nfsd4_commit_rsize(struct svc_rqst *rqstp, struct nfsd4_op *op)
2095 {
2096         return (op_encode_hdr_size + op_encode_verifier_maxsz) * sizeof(__be32);
2097 }
2098
2099 static inline u32 nfsd4_create_rsize(struct svc_rqst *rqstp, struct nfsd4_op *op)
2100 {
2101         return (op_encode_hdr_size + op_encode_change_info_maxsz
2102                 + nfs4_fattr_bitmap_maxsz) * sizeof(__be32);
2103 }
2104
2105 /*
2106  * Note since this is an idempotent operation we won't insist on failing
2107  * the op prematurely if the estimate is too large.  We may turn off splice
2108  * reads unnecessarily.
2109  */
2110 static inline u32 nfsd4_getattr_rsize(struct svc_rqst *rqstp,
2111                                       struct nfsd4_op *op)
2112 {
2113         u32 *bmap = op->u.getattr.ga_bmval;
2114         u32 bmap0 = bmap[0], bmap1 = bmap[1], bmap2 = bmap[2];
2115         u32 ret = 0;
2116
2117         if (bmap0 & FATTR4_WORD0_ACL)
2118                 return svc_max_payload(rqstp);
2119         if (bmap0 & FATTR4_WORD0_FS_LOCATIONS)
2120                 return svc_max_payload(rqstp);
2121
2122         if (bmap1 & FATTR4_WORD1_OWNER) {
2123                 ret += IDMAP_NAMESZ + 4;
2124                 bmap1 &= ~FATTR4_WORD1_OWNER;
2125         }
2126         if (bmap1 & FATTR4_WORD1_OWNER_GROUP) {
2127                 ret += IDMAP_NAMESZ + 4;
2128                 bmap1 &= ~FATTR4_WORD1_OWNER_GROUP;
2129         }
2130         if (bmap0 & FATTR4_WORD0_FILEHANDLE) {
2131                 ret += NFS4_FHSIZE + 4;
2132                 bmap0 &= ~FATTR4_WORD0_FILEHANDLE;
2133         }
2134         if (bmap2 & FATTR4_WORD2_SECURITY_LABEL) {
2135                 ret += NFS4_MAXLABELLEN + 12;
2136                 bmap2 &= ~FATTR4_WORD2_SECURITY_LABEL;
2137         }
2138         /*
2139          * Largest of remaining attributes are 16 bytes (e.g.,
2140          * supported_attributes)
2141          */
2142         ret += 16 * (hweight32(bmap0) + hweight32(bmap1) + hweight32(bmap2));
2143         /* bitmask, length */
2144         ret += 20;
2145         return ret;
2146 }
2147
2148 static inline u32 nfsd4_getfh_rsize(struct svc_rqst *rqstp, struct nfsd4_op *op)
2149 {
2150         return (op_encode_hdr_size + 1) * sizeof(__be32) + NFS4_FHSIZE;
2151 }
2152
2153 static inline u32 nfsd4_link_rsize(struct svc_rqst *rqstp, struct nfsd4_op *op)
2154 {
2155         return (op_encode_hdr_size + op_encode_change_info_maxsz)
2156                 * sizeof(__be32);
2157 }
2158
2159 static inline u32 nfsd4_lock_rsize(struct svc_rqst *rqstp, struct nfsd4_op *op)
2160 {
2161         return (op_encode_hdr_size + op_encode_lock_denied_maxsz)
2162                 * sizeof(__be32);
2163 }
2164
2165 static inline u32 nfsd4_open_rsize(struct svc_rqst *rqstp, struct nfsd4_op *op)
2166 {
2167         return (op_encode_hdr_size + op_encode_stateid_maxsz
2168                 + op_encode_change_info_maxsz + 1
2169                 + nfs4_fattr_bitmap_maxsz
2170                 + op_encode_delegation_maxsz) * sizeof(__be32);
2171 }
2172
2173 static inline u32 nfsd4_read_rsize(struct svc_rqst *rqstp, struct nfsd4_op *op)
2174 {
2175         u32 maxcount = 0, rlen = 0;
2176
2177         maxcount = svc_max_payload(rqstp);
2178         rlen = min(op->u.read.rd_length, maxcount);
2179
2180         return (op_encode_hdr_size + 2 + XDR_QUADLEN(rlen)) * sizeof(__be32);
2181 }
2182
2183 static inline u32 nfsd4_readdir_rsize(struct svc_rqst *rqstp, struct nfsd4_op *op)
2184 {
2185         u32 maxcount = 0, rlen = 0;
2186
2187         maxcount = svc_max_payload(rqstp);
2188         rlen = min(op->u.readdir.rd_maxcount, maxcount);
2189
2190         return (op_encode_hdr_size + op_encode_verifier_maxsz +
2191                 XDR_QUADLEN(rlen)) * sizeof(__be32);
2192 }
2193
2194 static inline u32 nfsd4_readlink_rsize(struct svc_rqst *rqstp, struct nfsd4_op *op)
2195 {
2196         return (op_encode_hdr_size + 1) * sizeof(__be32) + PAGE_SIZE;
2197 }
2198
2199 static inline u32 nfsd4_remove_rsize(struct svc_rqst *rqstp, struct nfsd4_op *op)
2200 {
2201         return (op_encode_hdr_size + op_encode_change_info_maxsz)
2202                 * sizeof(__be32);
2203 }
2204
2205 static inline u32 nfsd4_rename_rsize(struct svc_rqst *rqstp, struct nfsd4_op *op)
2206 {
2207         return (op_encode_hdr_size + op_encode_change_info_maxsz
2208                 + op_encode_change_info_maxsz) * sizeof(__be32);
2209 }
2210
2211 static inline u32 nfsd4_sequence_rsize(struct svc_rqst *rqstp,
2212                                        struct nfsd4_op *op)
2213 {
2214         return (op_encode_hdr_size
2215                 + XDR_QUADLEN(NFS4_MAX_SESSIONID_LEN) + 5) * sizeof(__be32);
2216 }
2217
2218 static inline u32 nfsd4_test_stateid_rsize(struct svc_rqst *rqstp, struct nfsd4_op *op)
2219 {
2220         return (op_encode_hdr_size + 1 + op->u.test_stateid.ts_num_ids)
2221                 * sizeof(__be32);
2222 }
2223
2224 static inline u32 nfsd4_setattr_rsize(struct svc_rqst *rqstp, struct nfsd4_op *op)
2225 {
2226         return (op_encode_hdr_size + nfs4_fattr_bitmap_maxsz) * sizeof(__be32);
2227 }
2228
2229 static inline u32 nfsd4_secinfo_rsize(struct svc_rqst *rqstp, struct nfsd4_op *op)
2230 {
2231         return (op_encode_hdr_size + RPC_AUTH_MAXFLAVOR *
2232                 (4 + XDR_QUADLEN(GSS_OID_MAX_LEN))) * sizeof(__be32);
2233 }
2234
2235 static inline u32 nfsd4_setclientid_rsize(struct svc_rqst *rqstp, struct nfsd4_op *op)
2236 {
2237         return (op_encode_hdr_size + 2 + XDR_QUADLEN(NFS4_VERIFIER_SIZE)) *
2238                                                                 sizeof(__be32);
2239 }
2240
2241 static inline u32 nfsd4_write_rsize(struct svc_rqst *rqstp, struct nfsd4_op *op)
2242 {
2243         return (op_encode_hdr_size + 2 + op_encode_verifier_maxsz) * sizeof(__be32);
2244 }
2245
2246 static inline u32 nfsd4_exchange_id_rsize(struct svc_rqst *rqstp, struct nfsd4_op *op)
2247 {
2248         return (op_encode_hdr_size + 2 + 1 + /* eir_clientid, eir_sequenceid */\
2249                 1 + 1 + /* eir_flags, spr_how */\
2250                 4 + /* spo_must_enforce & _allow with bitmap */\
2251                 2 + /*eir_server_owner.so_minor_id */\
2252                 /* eir_server_owner.so_major_id<> */\
2253                 XDR_QUADLEN(NFS4_OPAQUE_LIMIT) + 1 +\
2254                 /* eir_server_scope<> */\
2255                 XDR_QUADLEN(NFS4_OPAQUE_LIMIT) + 1 +\
2256                 1 + /* eir_server_impl_id array length */\
2257                 0 /* ignored eir_server_impl_id contents */) * sizeof(__be32);
2258 }
2259
2260 static inline u32 nfsd4_bind_conn_to_session_rsize(struct svc_rqst *rqstp, struct nfsd4_op *op)
2261 {
2262         return (op_encode_hdr_size + \
2263                 XDR_QUADLEN(NFS4_MAX_SESSIONID_LEN) + /* bctsr_sessid */\
2264                 2 /* bctsr_dir, use_conn_in_rdma_mode */) * sizeof(__be32);
2265 }
2266
2267 static inline u32 nfsd4_create_session_rsize(struct svc_rqst *rqstp, struct nfsd4_op *op)
2268 {
2269         return (op_encode_hdr_size + \
2270                 XDR_QUADLEN(NFS4_MAX_SESSIONID_LEN) + /* sessionid */\
2271                 2 + /* csr_sequence, csr_flags */\
2272                 op_encode_channel_attrs_maxsz + \
2273                 op_encode_channel_attrs_maxsz) * sizeof(__be32);
2274 }
2275
2276 static inline u32 nfsd4_copy_rsize(struct svc_rqst *rqstp, struct nfsd4_op *op)
2277 {
2278         return (op_encode_hdr_size +
2279                 1 /* wr_callback */ +
2280                 op_encode_stateid_maxsz /* wr_callback */ +
2281                 2 /* wr_count */ +
2282                 1 /* wr_committed */ +
2283                 op_encode_verifier_maxsz +
2284                 1 /* cr_consecutive */ +
2285                 1 /* cr_synchronous */) * sizeof(__be32);
2286 }
2287
2288 static inline u32 nfsd4_offload_status_rsize(struct svc_rqst *rqstp,
2289                                              struct nfsd4_op *op)
2290 {
2291         return (op_encode_hdr_size +
2292                 2 /* osr_count */ +
2293                 1 /* osr_complete<1> optional 0 for now */) * sizeof(__be32);
2294 }
2295
2296 #ifdef CONFIG_NFSD_PNFS
2297 static inline u32 nfsd4_getdeviceinfo_rsize(struct svc_rqst *rqstp, struct nfsd4_op *op)
2298 {
2299         u32 maxcount = 0, rlen = 0;
2300
2301         maxcount = svc_max_payload(rqstp);
2302         rlen = min(op->u.getdeviceinfo.gd_maxcount, maxcount);
2303
2304         return (op_encode_hdr_size +
2305                 1 /* gd_layout_type*/ +
2306                 XDR_QUADLEN(rlen) +
2307                 2 /* gd_notify_types */) * sizeof(__be32);
2308 }
2309
2310 /*
2311  * At this stage we don't really know what layout driver will handle the request,
2312  * so we need to define an arbitrary upper bound here.
2313  */
2314 #define MAX_LAYOUT_SIZE         128
2315 static inline u32 nfsd4_layoutget_rsize(struct svc_rqst *rqstp, struct nfsd4_op *op)
2316 {
2317         return (op_encode_hdr_size +
2318                 1 /* logr_return_on_close */ +
2319                 op_encode_stateid_maxsz +
2320                 1 /* nr of layouts */ +
2321                 MAX_LAYOUT_SIZE) * sizeof(__be32);
2322 }
2323
2324 static inline u32 nfsd4_layoutcommit_rsize(struct svc_rqst *rqstp, struct nfsd4_op *op)
2325 {
2326         return (op_encode_hdr_size +
2327                 1 /* locr_newsize */ +
2328                 2 /* ns_size */) * sizeof(__be32);
2329 }
2330
2331 static inline u32 nfsd4_layoutreturn_rsize(struct svc_rqst *rqstp, struct nfsd4_op *op)
2332 {
2333         return (op_encode_hdr_size +
2334                 1 /* lrs_stateid */ +
2335                 op_encode_stateid_maxsz) * sizeof(__be32);
2336 }
2337 #endif /* CONFIG_NFSD_PNFS */
2338
2339
2340 static inline u32 nfsd4_seek_rsize(struct svc_rqst *rqstp, struct nfsd4_op *op)
2341 {
2342         return (op_encode_hdr_size + 3) * sizeof(__be32);
2343 }
2344
2345 static const struct nfsd4_operation nfsd4_ops[] = {
2346         [OP_ACCESS] = {
2347                 .op_func = nfsd4_access,
2348                 .op_name = "OP_ACCESS",
2349                 .op_rsize_bop = nfsd4_access_rsize,
2350         },
2351         [OP_CLOSE] = {
2352                 .op_func = nfsd4_close,
2353                 .op_flags = OP_MODIFIES_SOMETHING,
2354                 .op_name = "OP_CLOSE",
2355                 .op_rsize_bop = nfsd4_status_stateid_rsize,
2356                 .op_get_currentstateid = nfsd4_get_closestateid,
2357                 .op_set_currentstateid = nfsd4_set_closestateid,
2358         },
2359         [OP_COMMIT] = {
2360                 .op_func = nfsd4_commit,
2361                 .op_flags = OP_MODIFIES_SOMETHING,
2362                 .op_name = "OP_COMMIT",
2363                 .op_rsize_bop = nfsd4_commit_rsize,
2364         },
2365         [OP_CREATE] = {
2366                 .op_func = nfsd4_create,
2367                 .op_flags = OP_MODIFIES_SOMETHING | OP_CACHEME | OP_CLEAR_STATEID,
2368                 .op_name = "OP_CREATE",
2369                 .op_rsize_bop = nfsd4_create_rsize,
2370         },
2371         [OP_DELEGRETURN] = {
2372                 .op_func = nfsd4_delegreturn,
2373                 .op_flags = OP_MODIFIES_SOMETHING,
2374                 .op_name = "OP_DELEGRETURN",
2375                 .op_rsize_bop = nfsd4_only_status_rsize,
2376                 .op_get_currentstateid = nfsd4_get_delegreturnstateid,
2377         },
2378         [OP_GETATTR] = {
2379                 .op_func = nfsd4_getattr,
2380                 .op_flags = ALLOWED_ON_ABSENT_FS,
2381                 .op_rsize_bop = nfsd4_getattr_rsize,
2382                 .op_name = "OP_GETATTR",
2383         },
2384         [OP_GETFH] = {
2385                 .op_func = nfsd4_getfh,
2386                 .op_name = "OP_GETFH",
2387                 .op_rsize_bop = nfsd4_getfh_rsize,
2388         },
2389         [OP_LINK] = {
2390                 .op_func = nfsd4_link,
2391                 .op_flags = ALLOWED_ON_ABSENT_FS | OP_MODIFIES_SOMETHING
2392                                 | OP_CACHEME,
2393                 .op_name = "OP_LINK",
2394                 .op_rsize_bop = nfsd4_link_rsize,
2395         },
2396         [OP_LOCK] = {
2397                 .op_func = nfsd4_lock,
2398                 .op_flags = OP_MODIFIES_SOMETHING |
2399                                 OP_NONTRIVIAL_ERROR_ENCODE,
2400                 .op_name = "OP_LOCK",
2401                 .op_rsize_bop = nfsd4_lock_rsize,
2402                 .op_set_currentstateid = nfsd4_set_lockstateid,
2403         },
2404         [OP_LOCKT] = {
2405                 .op_func = nfsd4_lockt,
2406                 .op_flags = OP_NONTRIVIAL_ERROR_ENCODE,
2407                 .op_name = "OP_LOCKT",
2408                 .op_rsize_bop = nfsd4_lock_rsize,
2409         },
2410         [OP_LOCKU] = {
2411                 .op_func = nfsd4_locku,
2412                 .op_flags = OP_MODIFIES_SOMETHING,
2413                 .op_name = "OP_LOCKU",
2414                 .op_rsize_bop = nfsd4_status_stateid_rsize,
2415                 .op_get_currentstateid = nfsd4_get_lockustateid,
2416         },
2417         [OP_LOOKUP] = {
2418                 .op_func = nfsd4_lookup,
2419                 .op_flags = OP_HANDLES_WRONGSEC | OP_CLEAR_STATEID,
2420                 .op_name = "OP_LOOKUP",
2421                 .op_rsize_bop = nfsd4_only_status_rsize,
2422         },
2423         [OP_LOOKUPP] = {
2424                 .op_func = nfsd4_lookupp,
2425                 .op_flags = OP_HANDLES_WRONGSEC | OP_CLEAR_STATEID,
2426                 .op_name = "OP_LOOKUPP",
2427                 .op_rsize_bop = nfsd4_only_status_rsize,
2428         },
2429         [OP_NVERIFY] = {
2430                 .op_func = nfsd4_nverify,
2431                 .op_name = "OP_NVERIFY",
2432                 .op_rsize_bop = nfsd4_only_status_rsize,
2433         },
2434         [OP_OPEN] = {
2435                 .op_func = nfsd4_open,
2436                 .op_flags = OP_HANDLES_WRONGSEC | OP_MODIFIES_SOMETHING,
2437                 .op_name = "OP_OPEN",
2438                 .op_rsize_bop = nfsd4_open_rsize,
2439                 .op_set_currentstateid = nfsd4_set_openstateid,
2440         },
2441         [OP_OPEN_CONFIRM] = {
2442                 .op_func = nfsd4_open_confirm,
2443                 .op_flags = OP_MODIFIES_SOMETHING,
2444                 .op_name = "OP_OPEN_CONFIRM",
2445                 .op_rsize_bop = nfsd4_status_stateid_rsize,
2446         },
2447         [OP_OPEN_DOWNGRADE] = {
2448                 .op_func = nfsd4_open_downgrade,
2449                 .op_flags = OP_MODIFIES_SOMETHING,
2450                 .op_name = "OP_OPEN_DOWNGRADE",
2451                 .op_rsize_bop = nfsd4_status_stateid_rsize,
2452                 .op_get_currentstateid = nfsd4_get_opendowngradestateid,
2453                 .op_set_currentstateid = nfsd4_set_opendowngradestateid,
2454         },
2455         [OP_PUTFH] = {
2456                 .op_func = nfsd4_putfh,
2457                 .op_flags = ALLOWED_WITHOUT_FH | ALLOWED_ON_ABSENT_FS
2458                                 | OP_IS_PUTFH_LIKE | OP_CLEAR_STATEID,
2459                 .op_name = "OP_PUTFH",
2460                 .op_rsize_bop = nfsd4_only_status_rsize,
2461         },
2462         [OP_PUTPUBFH] = {
2463                 .op_func = nfsd4_putrootfh,
2464                 .op_flags = ALLOWED_WITHOUT_FH | ALLOWED_ON_ABSENT_FS
2465                                 | OP_IS_PUTFH_LIKE | OP_CLEAR_STATEID,
2466                 .op_name = "OP_PUTPUBFH",
2467                 .op_rsize_bop = nfsd4_only_status_rsize,
2468         },
2469         [OP_PUTROOTFH] = {
2470                 .op_func = nfsd4_putrootfh,
2471                 .op_flags = ALLOWED_WITHOUT_FH | ALLOWED_ON_ABSENT_FS
2472                                 | OP_IS_PUTFH_LIKE | OP_CLEAR_STATEID,
2473                 .op_name = "OP_PUTROOTFH",
2474                 .op_rsize_bop = nfsd4_only_status_rsize,
2475         },
2476         [OP_READ] = {
2477                 .op_func = nfsd4_read,
2478                 .op_release = nfsd4_read_release,
2479                 .op_name = "OP_READ",
2480                 .op_rsize_bop = nfsd4_read_rsize,
2481                 .op_get_currentstateid = nfsd4_get_readstateid,
2482         },
2483         [OP_READDIR] = {
2484                 .op_func = nfsd4_readdir,
2485                 .op_name = "OP_READDIR",
2486                 .op_rsize_bop = nfsd4_readdir_rsize,
2487         },
2488         [OP_READLINK] = {
2489                 .op_func = nfsd4_readlink,
2490                 .op_name = "OP_READLINK",
2491                 .op_rsize_bop = nfsd4_readlink_rsize,
2492         },
2493         [OP_REMOVE] = {
2494                 .op_func = nfsd4_remove,
2495                 .op_flags = OP_MODIFIES_SOMETHING | OP_CACHEME,
2496                 .op_name = "OP_REMOVE",
2497                 .op_rsize_bop = nfsd4_remove_rsize,
2498         },
2499         [OP_RENAME] = {
2500                 .op_func = nfsd4_rename,
2501                 .op_flags = OP_MODIFIES_SOMETHING | OP_CACHEME,
2502                 .op_name = "OP_RENAME",
2503                 .op_rsize_bop = nfsd4_rename_rsize,
2504         },
2505         [OP_RENEW] = {
2506                 .op_func = nfsd4_renew,
2507                 .op_flags = ALLOWED_WITHOUT_FH | ALLOWED_ON_ABSENT_FS
2508                                 | OP_MODIFIES_SOMETHING,
2509                 .op_name = "OP_RENEW",
2510                 .op_rsize_bop = nfsd4_only_status_rsize,
2511
2512         },
2513         [OP_RESTOREFH] = {
2514                 .op_func = nfsd4_restorefh,
2515                 .op_flags = ALLOWED_WITHOUT_FH | ALLOWED_ON_ABSENT_FS
2516                                 | OP_IS_PUTFH_LIKE | OP_MODIFIES_SOMETHING,
2517                 .op_name = "OP_RESTOREFH",
2518                 .op_rsize_bop = nfsd4_only_status_rsize,
2519         },
2520         [OP_SAVEFH] = {
2521                 .op_func = nfsd4_savefh,
2522                 .op_flags = OP_HANDLES_WRONGSEC | OP_MODIFIES_SOMETHING,
2523                 .op_name = "OP_SAVEFH",
2524                 .op_rsize_bop = nfsd4_only_status_rsize,
2525         },
2526         [OP_SECINFO] = {
2527                 .op_func = nfsd4_secinfo,
2528                 .op_release = nfsd4_secinfo_release,
2529                 .op_flags = OP_HANDLES_WRONGSEC,
2530                 .op_name = "OP_SECINFO",
2531                 .op_rsize_bop = nfsd4_secinfo_rsize,
2532         },
2533         [OP_SETATTR] = {
2534                 .op_func = nfsd4_setattr,
2535                 .op_name = "OP_SETATTR",
2536                 .op_flags = OP_MODIFIES_SOMETHING | OP_CACHEME
2537                                 | OP_NONTRIVIAL_ERROR_ENCODE,
2538                 .op_rsize_bop = nfsd4_setattr_rsize,
2539                 .op_get_currentstateid = nfsd4_get_setattrstateid,
2540         },
2541         [OP_SETCLIENTID] = {
2542                 .op_func = nfsd4_setclientid,
2543                 .op_flags = ALLOWED_WITHOUT_FH | ALLOWED_ON_ABSENT_FS
2544                                 | OP_MODIFIES_SOMETHING | OP_CACHEME
2545                                 | OP_NONTRIVIAL_ERROR_ENCODE,
2546                 .op_name = "OP_SETCLIENTID",
2547                 .op_rsize_bop = nfsd4_setclientid_rsize,
2548         },
2549         [OP_SETCLIENTID_CONFIRM] = {
2550                 .op_func = nfsd4_setclientid_confirm,
2551                 .op_flags = ALLOWED_WITHOUT_FH | ALLOWED_ON_ABSENT_FS
2552                                 | OP_MODIFIES_SOMETHING | OP_CACHEME,
2553                 .op_name = "OP_SETCLIENTID_CONFIRM",
2554                 .op_rsize_bop = nfsd4_only_status_rsize,
2555         },
2556         [OP_VERIFY] = {
2557                 .op_func = nfsd4_verify,
2558                 .op_name = "OP_VERIFY",
2559                 .op_rsize_bop = nfsd4_only_status_rsize,
2560         },
2561         [OP_WRITE] = {
2562                 .op_func = nfsd4_write,
2563                 .op_flags = OP_MODIFIES_SOMETHING | OP_CACHEME,
2564                 .op_name = "OP_WRITE",
2565                 .op_rsize_bop = nfsd4_write_rsize,
2566                 .op_get_currentstateid = nfsd4_get_writestateid,
2567         },
2568         [OP_RELEASE_LOCKOWNER] = {
2569                 .op_func = nfsd4_release_lockowner,
2570                 .op_flags = ALLOWED_WITHOUT_FH | ALLOWED_ON_ABSENT_FS
2571                                 | OP_MODIFIES_SOMETHING,
2572                 .op_name = "OP_RELEASE_LOCKOWNER",
2573                 .op_rsize_bop = nfsd4_only_status_rsize,
2574         },
2575
2576         /* NFSv4.1 operations */
2577         [OP_EXCHANGE_ID] = {
2578                 .op_func = nfsd4_exchange_id,
2579                 .op_flags = ALLOWED_WITHOUT_FH | ALLOWED_AS_FIRST_OP
2580                                 | OP_MODIFIES_SOMETHING,
2581                 .op_name = "OP_EXCHANGE_ID",
2582                 .op_rsize_bop = nfsd4_exchange_id_rsize,
2583         },
2584         [OP_BACKCHANNEL_CTL] = {
2585                 .op_func = nfsd4_backchannel_ctl,
2586                 .op_flags = ALLOWED_WITHOUT_FH | OP_MODIFIES_SOMETHING,
2587                 .op_name = "OP_BACKCHANNEL_CTL",
2588                 .op_rsize_bop = nfsd4_only_status_rsize,
2589         },
2590         [OP_BIND_CONN_TO_SESSION] = {
2591                 .op_func = nfsd4_bind_conn_to_session,
2592                 .op_flags = ALLOWED_WITHOUT_FH | ALLOWED_AS_FIRST_OP
2593                                 | OP_MODIFIES_SOMETHING,
2594                 .op_name = "OP_BIND_CONN_TO_SESSION",
2595                 .op_rsize_bop = nfsd4_bind_conn_to_session_rsize,
2596         },
2597         [OP_CREATE_SESSION] = {
2598                 .op_func = nfsd4_create_session,
2599                 .op_flags = ALLOWED_WITHOUT_FH | ALLOWED_AS_FIRST_OP
2600                                 | OP_MODIFIES_SOMETHING,
2601                 .op_name = "OP_CREATE_SESSION",
2602                 .op_rsize_bop = nfsd4_create_session_rsize,
2603         },
2604         [OP_DESTROY_SESSION] = {
2605                 .op_func = nfsd4_destroy_session,
2606                 .op_flags = ALLOWED_WITHOUT_FH | ALLOWED_AS_FIRST_OP
2607                                 | OP_MODIFIES_SOMETHING,
2608                 .op_name = "OP_DESTROY_SESSION",
2609                 .op_rsize_bop = nfsd4_only_status_rsize,
2610         },
2611         [OP_SEQUENCE] = {
2612                 .op_func = nfsd4_sequence,
2613                 .op_flags = ALLOWED_WITHOUT_FH | ALLOWED_AS_FIRST_OP,
2614                 .op_name = "OP_SEQUENCE",
2615                 .op_rsize_bop = nfsd4_sequence_rsize,
2616         },
2617         [OP_DESTROY_CLIENTID] = {
2618                 .op_func = nfsd4_destroy_clientid,
2619                 .op_flags = ALLOWED_WITHOUT_FH | ALLOWED_AS_FIRST_OP
2620                                 | OP_MODIFIES_SOMETHING,
2621                 .op_name = "OP_DESTROY_CLIENTID",
2622                 .op_rsize_bop = nfsd4_only_status_rsize,
2623         },
2624         [OP_RECLAIM_COMPLETE] = {
2625                 .op_func = nfsd4_reclaim_complete,
2626                 .op_flags = ALLOWED_WITHOUT_FH | OP_MODIFIES_SOMETHING,
2627                 .op_name = "OP_RECLAIM_COMPLETE",
2628                 .op_rsize_bop = nfsd4_only_status_rsize,
2629         },
2630         [OP_SECINFO_NO_NAME] = {
2631                 .op_func = nfsd4_secinfo_no_name,
2632                 .op_release = nfsd4_secinfo_no_name_release,
2633                 .op_flags = OP_HANDLES_WRONGSEC,
2634                 .op_name = "OP_SECINFO_NO_NAME",
2635                 .op_rsize_bop = nfsd4_secinfo_rsize,
2636         },
2637         [OP_TEST_STATEID] = {
2638                 .op_func = nfsd4_test_stateid,
2639                 .op_flags = ALLOWED_WITHOUT_FH,
2640                 .op_name = "OP_TEST_STATEID",
2641                 .op_rsize_bop = nfsd4_test_stateid_rsize,
2642         },
2643         [OP_FREE_STATEID] = {
2644                 .op_func = nfsd4_free_stateid,
2645                 .op_flags = ALLOWED_WITHOUT_FH | OP_MODIFIES_SOMETHING,
2646                 .op_name = "OP_FREE_STATEID",
2647                 .op_get_currentstateid = nfsd4_get_freestateid,
2648                 .op_rsize_bop = nfsd4_only_status_rsize,
2649         },
2650 #ifdef CONFIG_NFSD_PNFS
2651         [OP_GETDEVICEINFO] = {
2652                 .op_func = nfsd4_getdeviceinfo,
2653                 .op_release = nfsd4_getdeviceinfo_release,
2654                 .op_flags = ALLOWED_WITHOUT_FH,
2655                 .op_name = "OP_GETDEVICEINFO",
2656                 .op_rsize_bop = nfsd4_getdeviceinfo_rsize,
2657         },
2658         [OP_LAYOUTGET] = {
2659                 .op_func = nfsd4_layoutget,
2660                 .op_release = nfsd4_layoutget_release,
2661                 .op_flags = OP_MODIFIES_SOMETHING,
2662                 .op_name = "OP_LAYOUTGET",
2663                 .op_rsize_bop = nfsd4_layoutget_rsize,
2664         },
2665         [OP_LAYOUTCOMMIT] = {
2666                 .op_func = nfsd4_layoutcommit,
2667                 .op_flags = OP_MODIFIES_SOMETHING,
2668                 .op_name = "OP_LAYOUTCOMMIT",
2669                 .op_rsize_bop = nfsd4_layoutcommit_rsize,
2670         },
2671         [OP_LAYOUTRETURN] = {
2672                 .op_func = nfsd4_layoutreturn,
2673                 .op_flags = OP_MODIFIES_SOMETHING,
2674                 .op_name = "OP_LAYOUTRETURN",
2675                 .op_rsize_bop = nfsd4_layoutreturn_rsize,
2676         },
2677 #endif /* CONFIG_NFSD_PNFS */
2678
2679         /* NFSv4.2 operations */
2680         [OP_ALLOCATE] = {
2681                 .op_func = nfsd4_allocate,
2682                 .op_flags = OP_MODIFIES_SOMETHING,
2683                 .op_name = "OP_ALLOCATE",
2684                 .op_rsize_bop = nfsd4_only_status_rsize,
2685         },
2686         [OP_DEALLOCATE] = {
2687                 .op_func = nfsd4_deallocate,
2688                 .op_flags = OP_MODIFIES_SOMETHING,
2689                 .op_name = "OP_DEALLOCATE",
2690                 .op_rsize_bop = nfsd4_only_status_rsize,
2691         },
2692         [OP_CLONE] = {
2693                 .op_func = nfsd4_clone,
2694                 .op_flags = OP_MODIFIES_SOMETHING,
2695                 .op_name = "OP_CLONE",
2696                 .op_rsize_bop = nfsd4_only_status_rsize,
2697         },
2698         [OP_COPY] = {
2699                 .op_func = nfsd4_copy,
2700                 .op_flags = OP_MODIFIES_SOMETHING,
2701                 .op_name = "OP_COPY",
2702                 .op_rsize_bop = nfsd4_copy_rsize,
2703         },
2704         [OP_SEEK] = {
2705                 .op_func = nfsd4_seek,
2706                 .op_name = "OP_SEEK",
2707                 .op_rsize_bop = nfsd4_seek_rsize,
2708         },
2709         [OP_OFFLOAD_STATUS] = {
2710                 .op_func = nfsd4_offload_status,
2711                 .op_name = "OP_OFFLOAD_STATUS",
2712                 .op_rsize_bop = nfsd4_offload_status_rsize,
2713         },
2714         [OP_OFFLOAD_CANCEL] = {
2715                 .op_func = nfsd4_offload_cancel,
2716                 .op_flags = OP_MODIFIES_SOMETHING,
2717                 .op_name = "OP_OFFLOAD_CANCEL",
2718                 .op_rsize_bop = nfsd4_only_status_rsize,
2719         },
2720 };
2721
2722 /**
2723  * nfsd4_spo_must_allow - Determine if the compound op contains an
2724  * operation that is allowed to be sent with machine credentials
2725  *
2726  * @rqstp: a pointer to the struct svc_rqst
2727  *
2728  * Checks to see if the compound contains a spo_must_allow op
2729  * and confirms that it was sent with the proper machine creds.
2730  */
2731
2732 bool nfsd4_spo_must_allow(struct svc_rqst *rqstp)
2733 {
2734         struct nfsd4_compoundres *resp = rqstp->rq_resp;
2735         struct nfsd4_compoundargs *argp = rqstp->rq_argp;
2736         struct nfsd4_op *this = &argp->ops[resp->opcnt - 1];
2737         struct nfsd4_compound_state *cstate = &resp->cstate;
2738         struct nfs4_op_map *allow = &cstate->clp->cl_spo_must_allow;
2739         u32 opiter;
2740
2741         if (!cstate->minorversion)
2742                 return false;
2743
2744         if (cstate->spo_must_allowed == true)
2745                 return true;
2746
2747         opiter = resp->opcnt;
2748         while (opiter < argp->opcnt) {
2749                 this = &argp->ops[opiter++];
2750                 if (test_bit(this->opnum, allow->u.longs) &&
2751                         cstate->clp->cl_mach_cred &&
2752                         nfsd4_mach_creds_match(cstate->clp, rqstp)) {
2753                         cstate->spo_must_allowed = true;
2754                         return true;
2755                 }
2756         }
2757         cstate->spo_must_allowed = false;
2758         return false;
2759 }
2760
2761 int nfsd4_max_reply(struct svc_rqst *rqstp, struct nfsd4_op *op)
2762 {
2763         if (op->opnum == OP_ILLEGAL || op->status == nfserr_notsupp)
2764                 return op_encode_hdr_size * sizeof(__be32);
2765
2766         BUG_ON(OPDESC(op)->op_rsize_bop == NULL);
2767         return OPDESC(op)->op_rsize_bop(rqstp, op);
2768 }
2769
2770 void warn_on_nonidempotent_op(struct nfsd4_op *op)
2771 {
2772         if (OPDESC(op)->op_flags & OP_MODIFIES_SOMETHING) {
2773                 pr_err("unable to encode reply to nonidempotent op %d (%s)\n",
2774                         op->opnum, nfsd4_op_name(op->opnum));
2775                 WARN_ON_ONCE(1);
2776         }
2777 }
2778
2779 static const char *nfsd4_op_name(unsigned opnum)
2780 {
2781         if (opnum < ARRAY_SIZE(nfsd4_ops))
2782                 return nfsd4_ops[opnum].op_name;
2783         return "unknown_operation";
2784 }
2785
2786 #define nfsd4_voidres                   nfsd4_voidargs
2787 struct nfsd4_voidargs { int dummy; };
2788
2789 static const struct svc_procedure nfsd_procedures4[2] = {
2790         [NFSPROC4_NULL] = {
2791                 .pc_func = nfsd4_proc_null,
2792                 .pc_encode = nfs4svc_encode_voidres,
2793                 .pc_argsize = sizeof(struct nfsd4_voidargs),
2794                 .pc_ressize = sizeof(struct nfsd4_voidres),
2795                 .pc_cachetype = RC_NOCACHE,
2796                 .pc_xdrressize = 1,
2797         },
2798         [NFSPROC4_COMPOUND] = {
2799                 .pc_func = nfsd4_proc_compound,
2800                 .pc_decode = nfs4svc_decode_compoundargs,
2801                 .pc_encode = nfs4svc_encode_compoundres,
2802                 .pc_argsize = sizeof(struct nfsd4_compoundargs),
2803                 .pc_ressize = sizeof(struct nfsd4_compoundres),
2804                 .pc_release = nfsd4_release_compoundargs,
2805                 .pc_cachetype = RC_NOCACHE,
2806                 .pc_xdrressize = NFSD_BUFSIZE/4,
2807         },
2808 };
2809
2810 static unsigned int nfsd_count3[ARRAY_SIZE(nfsd_procedures4)];
2811 const struct svc_version nfsd_version4 = {
2812         .vs_vers                = 4,
2813         .vs_nproc               = 2,
2814         .vs_proc                = nfsd_procedures4,
2815         .vs_count               = nfsd_count3,
2816         .vs_dispatch            = nfsd_dispatch,
2817         .vs_xdrsize             = NFS4_SVC_XDRSIZE,
2818         .vs_rpcb_optnl          = true,
2819         .vs_need_cong_ctrl      = true,
2820 };
2821
2822 /*
2823  * Local variables:
2824  *  c-basic-offset: 8
2825  * End:
2826  */