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/file.h>
36 #include <linux/slab.h>
37 
38 #include "cache.h"
39 #include "xdr4.h"
40 #include "vfs.h"
41 
42 #define NFSDDBG_FACILITY		NFSDDBG_PROC
43 
44 static u32 nfsd_attrmask[] = {
45 	NFSD_WRITEABLE_ATTRS_WORD0,
46 	NFSD_WRITEABLE_ATTRS_WORD1,
47 	NFSD_WRITEABLE_ATTRS_WORD2
48 };
49 
50 static u32 nfsd41_ex_attrmask[] = {
51 	NFSD_SUPPATTR_EXCLCREAT_WORD0,
52 	NFSD_SUPPATTR_EXCLCREAT_WORD1,
53 	NFSD_SUPPATTR_EXCLCREAT_WORD2
54 };
55 
56 static __be32
check_attr_support(struct svc_rqst * rqstp,struct nfsd4_compound_state * cstate,u32 * bmval,u32 * writable)57 check_attr_support(struct svc_rqst *rqstp, struct nfsd4_compound_state *cstate,
58 		   u32 *bmval, u32 *writable)
59 {
60 	struct dentry *dentry = cstate->current_fh.fh_dentry;
61 
62 	/*
63 	 * Check about attributes are supported by the NFSv4 server or not.
64 	 * According to spec, unsupported attributes return ERR_ATTRNOTSUPP.
65 	 */
66 	if ((bmval[0] & ~nfsd_suppattrs0(cstate->minorversion)) ||
67 	    (bmval[1] & ~nfsd_suppattrs1(cstate->minorversion)) ||
68 	    (bmval[2] & ~nfsd_suppattrs2(cstate->minorversion)))
69 		return nfserr_attrnotsupp;
70 
71 	/*
72 	 * Check FATTR4_WORD0_ACL can be supported
73 	 * in current environment or not.
74 	 */
75 	if (bmval[0] & FATTR4_WORD0_ACL) {
76 		if (!IS_POSIXACL(dentry->d_inode))
77 			return nfserr_attrnotsupp;
78 	}
79 
80 	/*
81 	 * According to spec, read-only attributes return ERR_INVAL.
82 	 */
83 	if (writable) {
84 		if ((bmval[0] & ~writable[0]) || (bmval[1] & ~writable[1]) ||
85 		    (bmval[2] & ~writable[2]))
86 			return nfserr_inval;
87 	}
88 
89 	return nfs_ok;
90 }
91 
92 static __be32
nfsd4_check_open_attributes(struct svc_rqst * rqstp,struct nfsd4_compound_state * cstate,struct nfsd4_open * open)93 nfsd4_check_open_attributes(struct svc_rqst *rqstp,
94 	struct nfsd4_compound_state *cstate, struct nfsd4_open *open)
95 {
96 	__be32 status = nfs_ok;
97 
98 	if (open->op_create == NFS4_OPEN_CREATE) {
99 		if (open->op_createmode == NFS4_CREATE_UNCHECKED
100 		    || open->op_createmode == NFS4_CREATE_GUARDED)
101 			status = check_attr_support(rqstp, cstate,
102 					open->op_bmval, nfsd_attrmask);
103 		else if (open->op_createmode == NFS4_CREATE_EXCLUSIVE4_1)
104 			status = check_attr_support(rqstp, cstate,
105 					open->op_bmval, nfsd41_ex_attrmask);
106 	}
107 
108 	return status;
109 }
110 
111 static int
is_create_with_attrs(struct nfsd4_open * open)112 is_create_with_attrs(struct nfsd4_open *open)
113 {
114 	return open->op_create == NFS4_OPEN_CREATE
115 		&& (open->op_createmode == NFS4_CREATE_UNCHECKED
116 		    || open->op_createmode == NFS4_CREATE_GUARDED
117 		    || open->op_createmode == NFS4_CREATE_EXCLUSIVE4_1);
118 }
119 
120 /*
121  * if error occurs when setting the acl, just clear the acl bit
122  * in the returned attr bitmap.
123  */
124 static void
do_set_nfs4_acl(struct svc_rqst * rqstp,struct svc_fh * fhp,struct nfs4_acl * acl,u32 * bmval)125 do_set_nfs4_acl(struct svc_rqst *rqstp, struct svc_fh *fhp,
126 		struct nfs4_acl *acl, u32 *bmval)
127 {
128 	__be32 status;
129 
130 	status = nfsd4_set_nfs4_acl(rqstp, fhp, acl);
131 	if (status)
132 		/*
133 		 * We should probably fail the whole open at this point,
134 		 * but we've already created the file, so it's too late;
135 		 * So this seems the least of evils:
136 		 */
137 		bmval[0] &= ~FATTR4_WORD0_ACL;
138 }
139 
140 static inline void
fh_dup2(struct svc_fh * dst,struct svc_fh * src)141 fh_dup2(struct svc_fh *dst, struct svc_fh *src)
142 {
143 	fh_put(dst);
144 	dget(src->fh_dentry);
145 	if (src->fh_export)
146 		cache_get(&src->fh_export->h);
147 	*dst = *src;
148 }
149 
150 static __be32
do_open_permission(struct svc_rqst * rqstp,struct svc_fh * current_fh,struct nfsd4_open * open,int accmode)151 do_open_permission(struct svc_rqst *rqstp, struct svc_fh *current_fh, struct nfsd4_open *open, int accmode)
152 {
153 	__be32 status;
154 
155 	if (open->op_truncate &&
156 		!(open->op_share_access & NFS4_SHARE_ACCESS_WRITE))
157 		return nfserr_inval;
158 
159 	if (open->op_share_access & NFS4_SHARE_ACCESS_READ)
160 		accmode |= NFSD_MAY_READ;
161 	if (open->op_share_access & NFS4_SHARE_ACCESS_WRITE)
162 		accmode |= (NFSD_MAY_WRITE | NFSD_MAY_TRUNC);
163 	if (open->op_share_deny & NFS4_SHARE_DENY_READ)
164 		accmode |= NFSD_MAY_WRITE;
165 
166 	status = fh_verify(rqstp, current_fh, S_IFREG, accmode);
167 
168 	return status;
169 }
170 
171 static __be32
do_open_lookup(struct svc_rqst * rqstp,struct svc_fh * current_fh,struct nfsd4_open * open)172 do_open_lookup(struct svc_rqst *rqstp, struct svc_fh *current_fh, struct nfsd4_open *open)
173 {
174 	struct svc_fh resfh;
175 	__be32 status;
176 	int created = 0;
177 
178 	fh_init(&resfh, NFS4_FHSIZE);
179 	open->op_truncate = 0;
180 
181 	if (open->op_create) {
182 		/* FIXME: check session persistence and pnfs flags.
183 		 * The nfsv4.1 spec requires the following semantics:
184 		 *
185 		 * Persistent   | pNFS   | Server REQUIRED | Client Allowed
186 		 * Reply Cache  | server |                 |
187 		 * -------------+--------+-----------------+--------------------
188 		 * no           | no     | EXCLUSIVE4_1    | EXCLUSIVE4_1
189 		 *              |        |                 | (SHOULD)
190 		 *              |        | and EXCLUSIVE4  | or EXCLUSIVE4
191 		 *              |        |                 | (SHOULD NOT)
192 		 * no           | yes    | EXCLUSIVE4_1    | EXCLUSIVE4_1
193 		 * yes          | no     | GUARDED4        | GUARDED4
194 		 * yes          | yes    | GUARDED4        | GUARDED4
195 		 */
196 
197 		/*
198 		 * Note: create modes (UNCHECKED,GUARDED...) are the same
199 		 * in NFSv4 as in v3.
200 		 */
201 		status = nfsd_create_v3(rqstp, current_fh, open->op_fname.data,
202 					open->op_fname.len, &open->op_iattr,
203 					&resfh, open->op_createmode,
204 					(u32 *)open->op_verf.data,
205 					&open->op_truncate, &created);
206 
207 		/*
208 		 * Following rfc 3530 14.2.16, use the returned bitmask
209 		 * to indicate which attributes we used to store the
210 		 * verifier:
211 		 */
212 		if (open->op_createmode == NFS4_CREATE_EXCLUSIVE && status == 0)
213 			open->op_bmval[1] = (FATTR4_WORD1_TIME_ACCESS |
214 						FATTR4_WORD1_TIME_MODIFY);
215 	} else {
216 		status = nfsd_lookup(rqstp, current_fh,
217 				     open->op_fname.data, open->op_fname.len, &resfh);
218 		fh_unlock(current_fh);
219 	}
220 	if (status)
221 		goto out;
222 
223 	if (is_create_with_attrs(open) && open->op_acl != NULL)
224 		do_set_nfs4_acl(rqstp, &resfh, open->op_acl, open->op_bmval);
225 
226 	set_change_info(&open->op_cinfo, current_fh);
227 	fh_dup2(current_fh, &resfh);
228 
229 	/* set reply cache */
230 	fh_copy_shallow(&open->op_stateowner->so_replay.rp_openfh,
231 			&resfh.fh_handle);
232 	if (!created)
233 		status = do_open_permission(rqstp, current_fh, open,
234 					    NFSD_MAY_NOP);
235 
236 out:
237 	fh_put(&resfh);
238 	return status;
239 }
240 
241 static __be32
do_open_fhandle(struct svc_rqst * rqstp,struct svc_fh * current_fh,struct nfsd4_open * open)242 do_open_fhandle(struct svc_rqst *rqstp, struct svc_fh *current_fh, struct nfsd4_open *open)
243 {
244 	__be32 status;
245 
246 	/* Only reclaims from previously confirmed clients are valid */
247 	if ((status = nfs4_check_open_reclaim(&open->op_clientid)))
248 		return status;
249 
250 	/* We don't know the target directory, and therefore can not
251 	* set the change info
252 	*/
253 
254 	memset(&open->op_cinfo, 0, sizeof(struct nfsd4_change_info));
255 
256 	/* set replay cache */
257 	fh_copy_shallow(&open->op_stateowner->so_replay.rp_openfh,
258 			&current_fh->fh_handle);
259 
260 	open->op_truncate = (open->op_iattr.ia_valid & ATTR_SIZE) &&
261 		(open->op_iattr.ia_size == 0);
262 
263 	status = do_open_permission(rqstp, current_fh, open,
264 				    NFSD_MAY_OWNER_OVERRIDE);
265 
266 	return status;
267 }
268 
269 static void
copy_clientid(clientid_t * clid,struct nfsd4_session * session)270 copy_clientid(clientid_t *clid, struct nfsd4_session *session)
271 {
272 	struct nfsd4_sessionid *sid =
273 			(struct nfsd4_sessionid *)session->se_sessionid.data;
274 
275 	clid->cl_boot = sid->clientid.cl_boot;
276 	clid->cl_id = sid->clientid.cl_id;
277 }
278 
279 static __be32
nfsd4_open(struct svc_rqst * rqstp,struct nfsd4_compound_state * cstate,struct nfsd4_open * open)280 nfsd4_open(struct svc_rqst *rqstp, struct nfsd4_compound_state *cstate,
281 	   struct nfsd4_open *open)
282 {
283 	__be32 status;
284 	struct nfsd4_compoundres *resp;
285 
286 	dprintk("NFSD: nfsd4_open filename %.*s op_stateowner %p\n",
287 		(int)open->op_fname.len, open->op_fname.data,
288 		open->op_stateowner);
289 
290 	/* This check required by spec. */
291 	if (open->op_create && open->op_claim_type != NFS4_OPEN_CLAIM_NULL)
292 		return nfserr_inval;
293 
294 	if (nfsd4_has_session(cstate))
295 		copy_clientid(&open->op_clientid, cstate->session);
296 
297 	nfs4_lock_state();
298 
299 	/* check seqid for replay. set nfs4_owner */
300 	resp = rqstp->rq_resp;
301 	status = nfsd4_process_open1(&resp->cstate, open);
302 	if (status == nfserr_replay_me) {
303 		struct nfs4_replay *rp = &open->op_stateowner->so_replay;
304 		fh_put(&cstate->current_fh);
305 		fh_copy_shallow(&cstate->current_fh.fh_handle,
306 				&rp->rp_openfh);
307 		status = fh_verify(rqstp, &cstate->current_fh, 0, NFSD_MAY_NOP);
308 		if (status)
309 			dprintk("nfsd4_open: replay failed"
310 				" restoring previous filehandle\n");
311 		else
312 			status = nfserr_replay_me;
313 	}
314 	if (status)
315 		goto out;
316 
317 	status = nfsd4_check_open_attributes(rqstp, cstate, open);
318 	if (status)
319 		goto out;
320 
321 	/* Openowner is now set, so sequence id will get bumped.  Now we need
322 	 * these checks before we do any creates: */
323 	status = nfserr_grace;
324 	if (locks_in_grace() && open->op_claim_type != NFS4_OPEN_CLAIM_PREVIOUS)
325 		goto out;
326 	status = nfserr_no_grace;
327 	if (!locks_in_grace() && open->op_claim_type == NFS4_OPEN_CLAIM_PREVIOUS)
328 		goto out;
329 
330 	switch (open->op_claim_type) {
331 		case NFS4_OPEN_CLAIM_DELEGATE_CUR:
332 		case NFS4_OPEN_CLAIM_NULL:
333 			/*
334 			 * (1) set CURRENT_FH to the file being opened,
335 			 * creating it if necessary, (2) set open->op_cinfo,
336 			 * (3) set open->op_truncate if the file is to be
337 			 * truncated after opening, (4) do permission checking.
338 			 */
339 			status = do_open_lookup(rqstp, &cstate->current_fh,
340 						open);
341 			if (status)
342 				goto out;
343 			break;
344 		case NFS4_OPEN_CLAIM_PREVIOUS:
345 			open->op_stateowner->so_confirmed = 1;
346 			/*
347 			 * The CURRENT_FH is already set to the file being
348 			 * opened.  (1) set open->op_cinfo, (2) set
349 			 * open->op_truncate if the file is to be truncated
350 			 * after opening, (3) do permission checking.
351 			*/
352 			status = do_open_fhandle(rqstp, &cstate->current_fh,
353 						 open);
354 			if (status)
355 				goto out;
356 			break;
357              	case NFS4_OPEN_CLAIM_DELEGATE_PREV:
358 			open->op_stateowner->so_confirmed = 1;
359 			dprintk("NFSD: unsupported OPEN claim type %d\n",
360 				open->op_claim_type);
361 			status = nfserr_notsupp;
362 			goto out;
363 		default:
364 			dprintk("NFSD: Invalid OPEN claim type %d\n",
365 				open->op_claim_type);
366 			status = nfserr_inval;
367 			goto out;
368 	}
369 	/*
370 	 * nfsd4_process_open2() does the actual opening of the file.  If
371 	 * successful, it (1) truncates the file if open->op_truncate was
372 	 * set, (2) sets open->op_stateid, (3) sets open->op_delegation.
373 	 */
374 	status = nfsd4_process_open2(rqstp, &cstate->current_fh, open);
375 out:
376 	if (open->op_stateowner) {
377 		nfs4_get_stateowner(open->op_stateowner);
378 		cstate->replay_owner = open->op_stateowner;
379 	}
380 	nfs4_unlock_state();
381 	return status;
382 }
383 
384 /*
385  * filehandle-manipulating ops.
386  */
387 static __be32
nfsd4_getfh(struct svc_rqst * rqstp,struct nfsd4_compound_state * cstate,struct svc_fh ** getfh)388 nfsd4_getfh(struct svc_rqst *rqstp, struct nfsd4_compound_state *cstate,
389 	    struct svc_fh **getfh)
390 {
391 	if (!cstate->current_fh.fh_dentry)
392 		return nfserr_nofilehandle;
393 
394 	*getfh = &cstate->current_fh;
395 	return nfs_ok;
396 }
397 
398 static __be32
nfsd4_putfh(struct svc_rqst * rqstp,struct nfsd4_compound_state * cstate,struct nfsd4_putfh * putfh)399 nfsd4_putfh(struct svc_rqst *rqstp, struct nfsd4_compound_state *cstate,
400 	    struct nfsd4_putfh *putfh)
401 {
402 	fh_put(&cstate->current_fh);
403 	cstate->current_fh.fh_handle.fh_size = putfh->pf_fhlen;
404 	memcpy(&cstate->current_fh.fh_handle.fh_base, putfh->pf_fhval,
405 	       putfh->pf_fhlen);
406 	return fh_verify(rqstp, &cstate->current_fh, 0, NFSD_MAY_NOP);
407 }
408 
409 static __be32
nfsd4_putrootfh(struct svc_rqst * rqstp,struct nfsd4_compound_state * cstate,void * arg)410 nfsd4_putrootfh(struct svc_rqst *rqstp, struct nfsd4_compound_state *cstate,
411 		void *arg)
412 {
413 	__be32 status;
414 
415 	fh_put(&cstate->current_fh);
416 	status = exp_pseudoroot(rqstp, &cstate->current_fh);
417 	return status;
418 }
419 
420 static __be32
nfsd4_restorefh(struct svc_rqst * rqstp,struct nfsd4_compound_state * cstate,void * arg)421 nfsd4_restorefh(struct svc_rqst *rqstp, struct nfsd4_compound_state *cstate,
422 		void *arg)
423 {
424 	if (!cstate->save_fh.fh_dentry)
425 		return nfserr_restorefh;
426 
427 	fh_dup2(&cstate->current_fh, &cstate->save_fh);
428 	return nfs_ok;
429 }
430 
431 static __be32
nfsd4_savefh(struct svc_rqst * rqstp,struct nfsd4_compound_state * cstate,void * arg)432 nfsd4_savefh(struct svc_rqst *rqstp, struct nfsd4_compound_state *cstate,
433 	     void *arg)
434 {
435 	if (!cstate->current_fh.fh_dentry)
436 		return nfserr_nofilehandle;
437 
438 	fh_dup2(&cstate->save_fh, &cstate->current_fh);
439 	return nfs_ok;
440 }
441 
442 /*
443  * misc nfsv4 ops
444  */
445 static __be32
nfsd4_access(struct svc_rqst * rqstp,struct nfsd4_compound_state * cstate,struct nfsd4_access * access)446 nfsd4_access(struct svc_rqst *rqstp, struct nfsd4_compound_state *cstate,
447 	     struct nfsd4_access *access)
448 {
449 	if (access->ac_req_access & ~NFS3_ACCESS_FULL)
450 		return nfserr_inval;
451 
452 	access->ac_resp_access = access->ac_req_access;
453 	return nfsd_access(rqstp, &cstate->current_fh, &access->ac_resp_access,
454 			   &access->ac_supported);
455 }
456 
457 static __be32
nfsd4_commit(struct svc_rqst * rqstp,struct nfsd4_compound_state * cstate,struct nfsd4_commit * commit)458 nfsd4_commit(struct svc_rqst *rqstp, struct nfsd4_compound_state *cstate,
459 	     struct nfsd4_commit *commit)
460 {
461 	__be32 status;
462 
463 	u32 *p = (u32 *)commit->co_verf.data;
464 	*p++ = nfssvc_boot.tv_sec;
465 	*p++ = nfssvc_boot.tv_usec;
466 
467 	status = nfsd_commit(rqstp, &cstate->current_fh, commit->co_offset,
468 			     commit->co_count);
469 	if (status == nfserr_symlink)
470 		status = nfserr_inval;
471 	return status;
472 }
473 
474 static __be32
nfsd4_create(struct svc_rqst * rqstp,struct nfsd4_compound_state * cstate,struct nfsd4_create * create)475 nfsd4_create(struct svc_rqst *rqstp, struct nfsd4_compound_state *cstate,
476 	     struct nfsd4_create *create)
477 {
478 	struct svc_fh resfh;
479 	__be32 status;
480 	dev_t rdev;
481 
482 	fh_init(&resfh, NFS4_FHSIZE);
483 
484 	status = fh_verify(rqstp, &cstate->current_fh, S_IFDIR,
485 			   NFSD_MAY_CREATE);
486 	if (status == nfserr_symlink)
487 		status = nfserr_notdir;
488 	if (status)
489 		return status;
490 
491 	status = check_attr_support(rqstp, cstate, create->cr_bmval,
492 				    nfsd_attrmask);
493 	if (status)
494 		return status;
495 
496 	switch (create->cr_type) {
497 	case NF4LNK:
498 		/* ugh! we have to null-terminate the linktext, or
499 		 * vfs_symlink() will choke.  it is always safe to
500 		 * null-terminate by brute force, since at worst we
501 		 * will overwrite the first byte of the create namelen
502 		 * in the XDR buffer, which has already been extracted
503 		 * during XDR decode.
504 		 */
505 		create->cr_linkname[create->cr_linklen] = 0;
506 
507 		status = nfsd_symlink(rqstp, &cstate->current_fh,
508 				      create->cr_name, create->cr_namelen,
509 				      create->cr_linkname, create->cr_linklen,
510 				      &resfh, &create->cr_iattr);
511 		break;
512 
513 	case NF4BLK:
514 		rdev = MKDEV(create->cr_specdata1, create->cr_specdata2);
515 		if (MAJOR(rdev) != create->cr_specdata1 ||
516 		    MINOR(rdev) != create->cr_specdata2)
517 			return nfserr_inval;
518 		status = nfsd_create(rqstp, &cstate->current_fh,
519 				     create->cr_name, create->cr_namelen,
520 				     &create->cr_iattr, S_IFBLK, rdev, &resfh);
521 		break;
522 
523 	case NF4CHR:
524 		rdev = MKDEV(create->cr_specdata1, create->cr_specdata2);
525 		if (MAJOR(rdev) != create->cr_specdata1 ||
526 		    MINOR(rdev) != create->cr_specdata2)
527 			return nfserr_inval;
528 		status = nfsd_create(rqstp, &cstate->current_fh,
529 				     create->cr_name, create->cr_namelen,
530 				     &create->cr_iattr,S_IFCHR, rdev, &resfh);
531 		break;
532 
533 	case NF4SOCK:
534 		status = nfsd_create(rqstp, &cstate->current_fh,
535 				     create->cr_name, create->cr_namelen,
536 				     &create->cr_iattr, S_IFSOCK, 0, &resfh);
537 		break;
538 
539 	case NF4FIFO:
540 		status = nfsd_create(rqstp, &cstate->current_fh,
541 				     create->cr_name, create->cr_namelen,
542 				     &create->cr_iattr, S_IFIFO, 0, &resfh);
543 		break;
544 
545 	case NF4DIR:
546 		create->cr_iattr.ia_valid &= ~ATTR_SIZE;
547 		status = nfsd_create(rqstp, &cstate->current_fh,
548 				     create->cr_name, create->cr_namelen,
549 				     &create->cr_iattr, S_IFDIR, 0, &resfh);
550 		break;
551 
552 	default:
553 		status = nfserr_badtype;
554 	}
555 
556 	if (status)
557 		goto out;
558 
559 	if (create->cr_acl != NULL)
560 		do_set_nfs4_acl(rqstp, &resfh, create->cr_acl,
561 				create->cr_bmval);
562 
563 	fh_unlock(&cstate->current_fh);
564 	set_change_info(&create->cr_cinfo, &cstate->current_fh);
565 	fh_dup2(&cstate->current_fh, &resfh);
566 out:
567 	fh_put(&resfh);
568 	return status;
569 }
570 
571 static __be32
nfsd4_getattr(struct svc_rqst * rqstp,struct nfsd4_compound_state * cstate,struct nfsd4_getattr * getattr)572 nfsd4_getattr(struct svc_rqst *rqstp, struct nfsd4_compound_state *cstate,
573 	      struct nfsd4_getattr *getattr)
574 {
575 	__be32 status;
576 
577 	status = fh_verify(rqstp, &cstate->current_fh, 0, NFSD_MAY_NOP);
578 	if (status)
579 		return status;
580 
581 	if (getattr->ga_bmval[1] & NFSD_WRITEONLY_ATTRS_WORD1)
582 		return nfserr_inval;
583 
584 	getattr->ga_bmval[0] &= nfsd_suppattrs0(cstate->minorversion);
585 	getattr->ga_bmval[1] &= nfsd_suppattrs1(cstate->minorversion);
586 	getattr->ga_bmval[2] &= nfsd_suppattrs2(cstate->minorversion);
587 
588 	getattr->ga_fhp = &cstate->current_fh;
589 	return nfs_ok;
590 }
591 
592 static __be32
nfsd4_link(struct svc_rqst * rqstp,struct nfsd4_compound_state * cstate,struct nfsd4_link * link)593 nfsd4_link(struct svc_rqst *rqstp, struct nfsd4_compound_state *cstate,
594 	   struct nfsd4_link *link)
595 {
596 	__be32 status = nfserr_nofilehandle;
597 
598 	if (!cstate->save_fh.fh_dentry)
599 		return status;
600 	status = nfsd_link(rqstp, &cstate->current_fh,
601 			   link->li_name, link->li_namelen, &cstate->save_fh);
602 	if (!status)
603 		set_change_info(&link->li_cinfo, &cstate->current_fh);
604 	return status;
605 }
606 
nfsd4_do_lookupp(struct svc_rqst * rqstp,struct svc_fh * fh)607 static __be32 nfsd4_do_lookupp(struct svc_rqst *rqstp, struct svc_fh *fh)
608 {
609 	struct svc_fh tmp_fh;
610 	__be32 ret;
611 
612 	fh_init(&tmp_fh, NFS4_FHSIZE);
613 	ret = exp_pseudoroot(rqstp, &tmp_fh);
614 	if (ret)
615 		return ret;
616 	if (tmp_fh.fh_dentry == fh->fh_dentry) {
617 		fh_put(&tmp_fh);
618 		return nfserr_noent;
619 	}
620 	fh_put(&tmp_fh);
621 	return nfsd_lookup(rqstp, fh, "..", 2, fh);
622 }
623 
624 static __be32
nfsd4_lookupp(struct svc_rqst * rqstp,struct nfsd4_compound_state * cstate,void * arg)625 nfsd4_lookupp(struct svc_rqst *rqstp, struct nfsd4_compound_state *cstate,
626 	      void *arg)
627 {
628 	return nfsd4_do_lookupp(rqstp, &cstate->current_fh);
629 }
630 
631 static __be32
nfsd4_lookup(struct svc_rqst * rqstp,struct nfsd4_compound_state * cstate,struct nfsd4_lookup * lookup)632 nfsd4_lookup(struct svc_rqst *rqstp, struct nfsd4_compound_state *cstate,
633 	     struct nfsd4_lookup *lookup)
634 {
635 	return nfsd_lookup(rqstp, &cstate->current_fh,
636 			   lookup->lo_name, lookup->lo_len,
637 			   &cstate->current_fh);
638 }
639 
640 static __be32
nfsd4_read(struct svc_rqst * rqstp,struct nfsd4_compound_state * cstate,struct nfsd4_read * read)641 nfsd4_read(struct svc_rqst *rqstp, struct nfsd4_compound_state *cstate,
642 	   struct nfsd4_read *read)
643 {
644 	__be32 status;
645 
646 	/* no need to check permission - this will be done in nfsd_read() */
647 
648 	read->rd_filp = NULL;
649 	if (read->rd_offset >= OFFSET_MAX)
650 		return nfserr_inval;
651 
652 	nfs4_lock_state();
653 	/* check stateid */
654 	if ((status = nfs4_preprocess_stateid_op(cstate, &read->rd_stateid,
655 						 RD_STATE, &read->rd_filp))) {
656 		dprintk("NFSD: nfsd4_read: couldn't process stateid!\n");
657 		goto out;
658 	}
659 	if (read->rd_filp)
660 		get_file(read->rd_filp);
661 	status = nfs_ok;
662 out:
663 	nfs4_unlock_state();
664 	read->rd_rqstp = rqstp;
665 	read->rd_fhp = &cstate->current_fh;
666 	return status;
667 }
668 
669 static __be32
nfsd4_readdir(struct svc_rqst * rqstp,struct nfsd4_compound_state * cstate,struct nfsd4_readdir * readdir)670 nfsd4_readdir(struct svc_rqst *rqstp, struct nfsd4_compound_state *cstate,
671 	      struct nfsd4_readdir *readdir)
672 {
673 	u64 cookie = readdir->rd_cookie;
674 	static const nfs4_verifier zeroverf;
675 
676 	/* no need to check permission - this will be done in nfsd_readdir() */
677 
678 	if (readdir->rd_bmval[1] & NFSD_WRITEONLY_ATTRS_WORD1)
679 		return nfserr_inval;
680 
681 	readdir->rd_bmval[0] &= nfsd_suppattrs0(cstate->minorversion);
682 	readdir->rd_bmval[1] &= nfsd_suppattrs1(cstate->minorversion);
683 	readdir->rd_bmval[2] &= nfsd_suppattrs2(cstate->minorversion);
684 
685 	if ((cookie > ~(u32)0) || (cookie == 1) || (cookie == 2) ||
686 	    (cookie == 0 && memcmp(readdir->rd_verf.data, zeroverf.data, NFS4_VERIFIER_SIZE)))
687 		return nfserr_bad_cookie;
688 
689 	readdir->rd_rqstp = rqstp;
690 	readdir->rd_fhp = &cstate->current_fh;
691 	return nfs_ok;
692 }
693 
694 static __be32
nfsd4_readlink(struct svc_rqst * rqstp,struct nfsd4_compound_state * cstate,struct nfsd4_readlink * readlink)695 nfsd4_readlink(struct svc_rqst *rqstp, struct nfsd4_compound_state *cstate,
696 	       struct nfsd4_readlink *readlink)
697 {
698 	readlink->rl_rqstp = rqstp;
699 	readlink->rl_fhp = &cstate->current_fh;
700 	return nfs_ok;
701 }
702 
703 static __be32
nfsd4_remove(struct svc_rqst * rqstp,struct nfsd4_compound_state * cstate,struct nfsd4_remove * remove)704 nfsd4_remove(struct svc_rqst *rqstp, struct nfsd4_compound_state *cstate,
705 	     struct nfsd4_remove *remove)
706 {
707 	__be32 status;
708 
709 	if (locks_in_grace())
710 		return nfserr_grace;
711 	status = nfsd_unlink(rqstp, &cstate->current_fh, 0,
712 			     remove->rm_name, remove->rm_namelen);
713 	if (status == nfserr_symlink)
714 		return nfserr_notdir;
715 	if (!status) {
716 		fh_unlock(&cstate->current_fh);
717 		set_change_info(&remove->rm_cinfo, &cstate->current_fh);
718 	}
719 	return status;
720 }
721 
722 static __be32
nfsd4_rename(struct svc_rqst * rqstp,struct nfsd4_compound_state * cstate,struct nfsd4_rename * rename)723 nfsd4_rename(struct svc_rqst *rqstp, struct nfsd4_compound_state *cstate,
724 	     struct nfsd4_rename *rename)
725 {
726 	__be32 status = nfserr_nofilehandle;
727 
728 	if (!cstate->save_fh.fh_dentry)
729 		return status;
730 	if (locks_in_grace() && !(cstate->save_fh.fh_export->ex_flags
731 					& NFSEXP_NOSUBTREECHECK))
732 		return nfserr_grace;
733 	status = nfsd_rename(rqstp, &cstate->save_fh, rename->rn_sname,
734 			     rename->rn_snamelen, &cstate->current_fh,
735 			     rename->rn_tname, rename->rn_tnamelen);
736 
737 	/* the underlying filesystem returns different error's than required
738 	 * by NFSv4. both save_fh and current_fh have been verified.. */
739 	if (status == nfserr_isdir)
740 		status = nfserr_exist;
741 	else if ((status == nfserr_notdir) &&
742                   (S_ISDIR(cstate->save_fh.fh_dentry->d_inode->i_mode) &&
743                    S_ISDIR(cstate->current_fh.fh_dentry->d_inode->i_mode)))
744 		status = nfserr_exist;
745 	else if (status == nfserr_symlink)
746 		status = nfserr_notdir;
747 
748 	if (!status) {
749 		set_change_info(&rename->rn_sinfo, &cstate->current_fh);
750 		set_change_info(&rename->rn_tinfo, &cstate->save_fh);
751 	}
752 	return status;
753 }
754 
755 static __be32
nfsd4_secinfo(struct svc_rqst * rqstp,struct nfsd4_compound_state * cstate,struct nfsd4_secinfo * secinfo)756 nfsd4_secinfo(struct svc_rqst *rqstp, struct nfsd4_compound_state *cstate,
757 	      struct nfsd4_secinfo *secinfo)
758 {
759 	struct svc_fh resfh;
760 	struct svc_export *exp;
761 	struct dentry *dentry;
762 	__be32 err;
763 
764 	fh_init(&resfh, NFS4_FHSIZE);
765 	err = nfsd_lookup_dentry(rqstp, &cstate->current_fh,
766 				    secinfo->si_name, secinfo->si_namelen,
767 				    &exp, &dentry);
768 	if (err)
769 		return err;
770 	if (dentry->d_inode == NULL) {
771 		exp_put(exp);
772 		err = nfserr_noent;
773 	} else
774 		secinfo->si_exp = exp;
775 	dput(dentry);
776 	if (cstate->minorversion)
777 		/* See rfc 5661 section 2.6.3.1.1.8 */
778 		fh_put(&cstate->current_fh);
779 	return err;
780 }
781 
782 static __be32
nfsd4_secinfo_no_name(struct svc_rqst * rqstp,struct nfsd4_compound_state * cstate,struct nfsd4_secinfo_no_name * sin)783 nfsd4_secinfo_no_name(struct svc_rqst *rqstp, struct nfsd4_compound_state *cstate,
784 	      struct nfsd4_secinfo_no_name *sin)
785 {
786 	__be32 err;
787 
788 	switch (sin->sin_style) {
789 	case NFS4_SECINFO_STYLE4_CURRENT_FH:
790 		break;
791 	case NFS4_SECINFO_STYLE4_PARENT:
792 		err = nfsd4_do_lookupp(rqstp, &cstate->current_fh);
793 		if (err)
794 			return err;
795 		break;
796 	default:
797 		return nfserr_inval;
798 	}
799 	exp_get(cstate->current_fh.fh_export);
800 	sin->sin_exp = cstate->current_fh.fh_export;
801 	fh_put(&cstate->current_fh);
802 	return nfs_ok;
803 }
804 
805 static __be32
nfsd4_setattr(struct svc_rqst * rqstp,struct nfsd4_compound_state * cstate,struct nfsd4_setattr * setattr)806 nfsd4_setattr(struct svc_rqst *rqstp, struct nfsd4_compound_state *cstate,
807 	      struct nfsd4_setattr *setattr)
808 {
809 	__be32 status = nfs_ok;
810 
811 	if (setattr->sa_iattr.ia_valid & ATTR_SIZE) {
812 		nfs4_lock_state();
813 		status = nfs4_preprocess_stateid_op(cstate,
814 			&setattr->sa_stateid, WR_STATE, NULL);
815 		nfs4_unlock_state();
816 		if (status) {
817 			dprintk("NFSD: nfsd4_setattr: couldn't process stateid!\n");
818 			return status;
819 		}
820 	}
821 	status = mnt_want_write(cstate->current_fh.fh_export->ex_path.mnt);
822 	if (status)
823 		return status;
824 	status = nfs_ok;
825 
826 	status = check_attr_support(rqstp, cstate, setattr->sa_bmval,
827 				    nfsd_attrmask);
828 	if (status)
829 		goto out;
830 
831 	if (setattr->sa_acl != NULL)
832 		status = nfsd4_set_nfs4_acl(rqstp, &cstate->current_fh,
833 					    setattr->sa_acl);
834 	if (status)
835 		goto out;
836 	status = nfsd_setattr(rqstp, &cstate->current_fh, &setattr->sa_iattr,
837 				0, (time_t)0);
838 out:
839 	mnt_drop_write(cstate->current_fh.fh_export->ex_path.mnt);
840 	return status;
841 }
842 
843 static __be32
nfsd4_write(struct svc_rqst * rqstp,struct nfsd4_compound_state * cstate,struct nfsd4_write * write)844 nfsd4_write(struct svc_rqst *rqstp, struct nfsd4_compound_state *cstate,
845 	    struct nfsd4_write *write)
846 {
847 	stateid_t *stateid = &write->wr_stateid;
848 	struct file *filp = NULL;
849 	u32 *p;
850 	__be32 status = nfs_ok;
851 	unsigned long cnt;
852 
853 	/* no need to check permission - this will be done in nfsd_write() */
854 
855 	if (write->wr_offset >= OFFSET_MAX)
856 		return nfserr_inval;
857 
858 	nfs4_lock_state();
859 	status = nfs4_preprocess_stateid_op(cstate, stateid, WR_STATE, &filp);
860 	if (filp)
861 		get_file(filp);
862 	nfs4_unlock_state();
863 
864 	if (status) {
865 		dprintk("NFSD: nfsd4_write: couldn't process stateid!\n");
866 		return status;
867 	}
868 
869 	cnt = write->wr_buflen;
870 	write->wr_how_written = write->wr_stable_how;
871 	p = (u32 *)write->wr_verifier.data;
872 	*p++ = nfssvc_boot.tv_sec;
873 	*p++ = nfssvc_boot.tv_usec;
874 
875 	status =  nfsd_write(rqstp, &cstate->current_fh, filp,
876 			     write->wr_offset, rqstp->rq_vec, write->wr_vlen,
877 			     &cnt, &write->wr_how_written);
878 	if (filp)
879 		fput(filp);
880 
881 	write->wr_bytes_written = cnt;
882 
883 	if (status == nfserr_symlink)
884 		status = nfserr_inval;
885 	return status;
886 }
887 
888 /* This routine never returns NFS_OK!  If there are no other errors, it
889  * will return NFSERR_SAME or NFSERR_NOT_SAME depending on whether the
890  * attributes matched.  VERIFY is implemented by mapping NFSERR_SAME
891  * to NFS_OK after the call; NVERIFY by mapping NFSERR_NOT_SAME to NFS_OK.
892  */
893 static __be32
_nfsd4_verify(struct svc_rqst * rqstp,struct nfsd4_compound_state * cstate,struct nfsd4_verify * verify)894 _nfsd4_verify(struct svc_rqst *rqstp, struct nfsd4_compound_state *cstate,
895 	     struct nfsd4_verify *verify)
896 {
897 	__be32 *buf, *p;
898 	int count;
899 	__be32 status;
900 
901 	status = fh_verify(rqstp, &cstate->current_fh, 0, NFSD_MAY_NOP);
902 	if (status)
903 		return status;
904 
905 	status = check_attr_support(rqstp, cstate, verify->ve_bmval, NULL);
906 	if (status)
907 		return status;
908 
909 	if ((verify->ve_bmval[0] & FATTR4_WORD0_RDATTR_ERROR)
910 	    || (verify->ve_bmval[1] & NFSD_WRITEONLY_ATTRS_WORD1))
911 		return nfserr_inval;
912 	if (verify->ve_attrlen & 3)
913 		return nfserr_inval;
914 
915 	/* count in words:
916 	 *   bitmap_len(1) + bitmap(2) + attr_len(1) = 4
917 	 */
918 	count = 4 + (verify->ve_attrlen >> 2);
919 	buf = kmalloc(count << 2, GFP_KERNEL);
920 	if (!buf)
921 		return nfserr_resource;
922 
923 	status = nfsd4_encode_fattr(&cstate->current_fh,
924 				    cstate->current_fh.fh_export,
925 				    cstate->current_fh.fh_dentry, buf,
926 				    &count, verify->ve_bmval,
927 				    rqstp, 0);
928 
929 	/* this means that nfsd4_encode_fattr() ran out of space */
930 	if (status == nfserr_resource && count == 0)
931 		status = nfserr_not_same;
932 	if (status)
933 		goto out_kfree;
934 
935 	/* skip bitmap */
936 	p = buf + 1 + ntohl(buf[0]);
937 	status = nfserr_not_same;
938 	if (ntohl(*p++) != verify->ve_attrlen)
939 		goto out_kfree;
940 	if (!memcmp(p, verify->ve_attrval, verify->ve_attrlen))
941 		status = nfserr_same;
942 
943 out_kfree:
944 	kfree(buf);
945 	return status;
946 }
947 
948 static __be32
nfsd4_nverify(struct svc_rqst * rqstp,struct nfsd4_compound_state * cstate,struct nfsd4_verify * verify)949 nfsd4_nverify(struct svc_rqst *rqstp, struct nfsd4_compound_state *cstate,
950 	      struct nfsd4_verify *verify)
951 {
952 	__be32 status;
953 
954 	status = _nfsd4_verify(rqstp, cstate, verify);
955 	return status == nfserr_not_same ? nfs_ok : status;
956 }
957 
958 static __be32
nfsd4_verify(struct svc_rqst * rqstp,struct nfsd4_compound_state * cstate,struct nfsd4_verify * verify)959 nfsd4_verify(struct svc_rqst *rqstp, struct nfsd4_compound_state *cstate,
960 	     struct nfsd4_verify *verify)
961 {
962 	__be32 status;
963 
964 	status = _nfsd4_verify(rqstp, cstate, verify);
965 	return status == nfserr_same ? nfs_ok : status;
966 }
967 
968 /*
969  * NULL call.
970  */
971 static __be32
nfsd4_proc_null(struct svc_rqst * rqstp,void * argp,void * resp)972 nfsd4_proc_null(struct svc_rqst *rqstp, void *argp, void *resp)
973 {
974 	return nfs_ok;
975 }
976 
nfsd4_increment_op_stats(u32 opnum)977 static inline void nfsd4_increment_op_stats(u32 opnum)
978 {
979 	if (opnum >= FIRST_NFS4_OP && opnum <= LAST_NFS4_OP)
980 		nfsdstats.nfs4_opcount[opnum]++;
981 }
982 
983 typedef __be32(*nfsd4op_func)(struct svc_rqst *, struct nfsd4_compound_state *,
984 			      void *);
985 enum nfsd4_op_flags {
986 	ALLOWED_WITHOUT_FH = 1 << 0,	/* No current filehandle required */
987 	ALLOWED_ON_ABSENT_FS = 1 << 1,	/* ops processed on absent fs */
988 	ALLOWED_AS_FIRST_OP = 1 << 2,	/* ops reqired first in compound */
989 };
990 
991 struct nfsd4_operation {
992 	nfsd4op_func op_func;
993 	u32 op_flags;
994 	char *op_name;
995 };
996 
997 static struct nfsd4_operation nfsd4_ops[];
998 
999 static const char *nfsd4_op_name(unsigned opnum);
1000 
1001 /*
1002  * Enforce NFSv4.1 COMPOUND ordering rules:
1003  *
1004  * Also note, enforced elsewhere:
1005  *	- SEQUENCE other than as first op results in
1006  *	  NFS4ERR_SEQUENCE_POS. (Enforced in nfsd4_sequence().)
1007  *	- BIND_CONN_TO_SESSION must be the only op in its compound.
1008  *	  (Enforced in nfsd4_bind_conn_to_session().)
1009  *	- DESTROY_SESSION must be the final operation in a compound, if
1010  *	  sessionid's in SEQUENCE and DESTROY_SESSION are the same.
1011  *	  (Enforced in nfsd4_destroy_session().)
1012  */
nfs41_check_op_ordering(struct nfsd4_compoundargs * args)1013 static __be32 nfs41_check_op_ordering(struct nfsd4_compoundargs *args)
1014 {
1015 	struct nfsd4_op *op = &args->ops[0];
1016 
1017 	/* These ordering requirements don't apply to NFSv4.0: */
1018 	if (args->minorversion == 0)
1019 		return nfs_ok;
1020 	/* This is weird, but OK, not our problem: */
1021 	if (args->opcnt == 0)
1022 		return nfs_ok;
1023 	if (op->status == nfserr_op_illegal)
1024 		return nfs_ok;
1025 	if (!(nfsd4_ops[op->opnum].op_flags & ALLOWED_AS_FIRST_OP))
1026 		return nfserr_op_not_in_session;
1027 	if (op->opnum == OP_SEQUENCE)
1028 		return nfs_ok;
1029 	if (args->opcnt != 1)
1030 		return nfserr_not_only_op;
1031 	return nfs_ok;
1032 }
1033 
1034 /*
1035  * COMPOUND call.
1036  */
1037 static __be32
nfsd4_proc_compound(struct svc_rqst * rqstp,struct nfsd4_compoundargs * args,struct nfsd4_compoundres * resp)1038 nfsd4_proc_compound(struct svc_rqst *rqstp,
1039 		    struct nfsd4_compoundargs *args,
1040 		    struct nfsd4_compoundres *resp)
1041 {
1042 	struct nfsd4_op	*op;
1043 	struct nfsd4_operation *opdesc;
1044 	struct nfsd4_compound_state *cstate = &resp->cstate;
1045 	int		slack_bytes;
1046 	__be32		status;
1047 
1048 	resp->xbuf = &rqstp->rq_res;
1049 	resp->p = rqstp->rq_res.head[0].iov_base +
1050 						rqstp->rq_res.head[0].iov_len;
1051 	resp->tagp = resp->p;
1052 	/* reserve space for: taglen, tag, and opcnt */
1053 	resp->p += 2 + XDR_QUADLEN(args->taglen);
1054 	resp->end = rqstp->rq_res.head[0].iov_base + PAGE_SIZE;
1055 	resp->taglen = args->taglen;
1056 	resp->tag = args->tag;
1057 	resp->opcnt = 0;
1058 	resp->rqstp = rqstp;
1059 	resp->cstate.minorversion = args->minorversion;
1060 	resp->cstate.replay_owner = NULL;
1061 	resp->cstate.session = NULL;
1062 	fh_init(&resp->cstate.current_fh, NFS4_FHSIZE);
1063 	fh_init(&resp->cstate.save_fh, NFS4_FHSIZE);
1064 	/*
1065 	 * Don't use the deferral mechanism for NFSv4; compounds make it
1066 	 * too hard to avoid non-idempotency problems.
1067 	 */
1068 	rqstp->rq_usedeferral = 0;
1069 
1070 	/*
1071 	 * According to RFC3010, this takes precedence over all other errors.
1072 	 */
1073 	status = nfserr_minor_vers_mismatch;
1074 	if (args->minorversion > nfsd_supported_minorversion)
1075 		goto out;
1076 
1077 	status = nfs41_check_op_ordering(args);
1078 	if (status) {
1079 		op = &args->ops[0];
1080 		op->status = status;
1081 		goto encode_op;
1082 	}
1083 
1084 	while (!status && resp->opcnt < args->opcnt) {
1085 		op = &args->ops[resp->opcnt++];
1086 
1087 		dprintk("nfsv4 compound op #%d/%d: %d (%s)\n",
1088 			resp->opcnt, args->opcnt, op->opnum,
1089 			nfsd4_op_name(op->opnum));
1090 		/*
1091 		 * The XDR decode routines may have pre-set op->status;
1092 		 * for example, if there is a miscellaneous XDR error
1093 		 * it will be set to nfserr_bad_xdr.
1094 		 */
1095 		if (op->status)
1096 			goto encode_op;
1097 
1098 		/* We must be able to encode a successful response to
1099 		 * this operation, with enough room left over to encode a
1100 		 * failed response to the next operation.  If we don't
1101 		 * have enough room, fail with ERR_RESOURCE.
1102 		 */
1103 		slack_bytes = (char *)resp->end - (char *)resp->p;
1104 		if (slack_bytes < COMPOUND_SLACK_SPACE
1105 				+ COMPOUND_ERR_SLACK_SPACE) {
1106 			BUG_ON(slack_bytes < COMPOUND_ERR_SLACK_SPACE);
1107 			op->status = nfserr_resource;
1108 			goto encode_op;
1109 		}
1110 
1111 		opdesc = &nfsd4_ops[op->opnum];
1112 
1113 		if (!cstate->current_fh.fh_dentry) {
1114 			if (!(opdesc->op_flags & ALLOWED_WITHOUT_FH)) {
1115 				op->status = nfserr_nofilehandle;
1116 				goto encode_op;
1117 			}
1118 		} else if (cstate->current_fh.fh_export->ex_fslocs.migrated &&
1119 			  !(opdesc->op_flags & ALLOWED_ON_ABSENT_FS)) {
1120 			op->status = nfserr_moved;
1121 			goto encode_op;
1122 		}
1123 
1124 		if (opdesc->op_func)
1125 			op->status = opdesc->op_func(rqstp, cstate, &op->u);
1126 		else
1127 			BUG_ON(op->status == nfs_ok);
1128 
1129 encode_op:
1130 		/* Only from SEQUENCE */
1131 		if (resp->cstate.status == nfserr_replay_cache) {
1132 			dprintk("%s NFS4.1 replay from cache\n", __func__);
1133 			status = op->status;
1134 			goto out;
1135 		}
1136 		if (op->status == nfserr_replay_me) {
1137 			op->replay = &cstate->replay_owner->so_replay;
1138 			nfsd4_encode_replay(resp, op);
1139 			status = op->status = op->replay->rp_status;
1140 		} else {
1141 			nfsd4_encode_operation(resp, op);
1142 			status = op->status;
1143 		}
1144 
1145 		dprintk("nfsv4 compound op %p opcnt %d #%d: %d: status %d\n",
1146 			args->ops, args->opcnt, resp->opcnt, op->opnum,
1147 			be32_to_cpu(status));
1148 
1149 		if (cstate->replay_owner) {
1150 			nfs4_put_stateowner(cstate->replay_owner);
1151 			cstate->replay_owner = NULL;
1152 		}
1153 		/* XXX Ugh, we need to get rid of this kind of special case: */
1154 		if (op->opnum == OP_READ && op->u.read.rd_filp)
1155 			fput(op->u.read.rd_filp);
1156 
1157 		nfsd4_increment_op_stats(op->opnum);
1158 	}
1159 
1160 	resp->cstate.status = status;
1161 	fh_put(&resp->cstate.current_fh);
1162 	fh_put(&resp->cstate.save_fh);
1163 	BUG_ON(resp->cstate.replay_owner);
1164 out:
1165 	nfsd4_release_compoundargs(args);
1166 	/* Reset deferral mechanism for RPC deferrals */
1167 	rqstp->rq_usedeferral = 1;
1168 	dprintk("nfsv4 compound returned %d\n", ntohl(status));
1169 	return status;
1170 }
1171 
1172 static struct nfsd4_operation nfsd4_ops[] = {
1173 	[OP_ACCESS] = {
1174 		.op_func = (nfsd4op_func)nfsd4_access,
1175 		.op_name = "OP_ACCESS",
1176 	},
1177 	[OP_CLOSE] = {
1178 		.op_func = (nfsd4op_func)nfsd4_close,
1179 		.op_name = "OP_CLOSE",
1180 	},
1181 	[OP_COMMIT] = {
1182 		.op_func = (nfsd4op_func)nfsd4_commit,
1183 		.op_name = "OP_COMMIT",
1184 	},
1185 	[OP_CREATE] = {
1186 		.op_func = (nfsd4op_func)nfsd4_create,
1187 		.op_name = "OP_CREATE",
1188 	},
1189 	[OP_DELEGRETURN] = {
1190 		.op_func = (nfsd4op_func)nfsd4_delegreturn,
1191 		.op_name = "OP_DELEGRETURN",
1192 	},
1193 	[OP_GETATTR] = {
1194 		.op_func = (nfsd4op_func)nfsd4_getattr,
1195 		.op_flags = ALLOWED_ON_ABSENT_FS,
1196 		.op_name = "OP_GETATTR",
1197 	},
1198 	[OP_GETFH] = {
1199 		.op_func = (nfsd4op_func)nfsd4_getfh,
1200 		.op_name = "OP_GETFH",
1201 	},
1202 	[OP_LINK] = {
1203 		.op_func = (nfsd4op_func)nfsd4_link,
1204 		.op_name = "OP_LINK",
1205 	},
1206 	[OP_LOCK] = {
1207 		.op_func = (nfsd4op_func)nfsd4_lock,
1208 		.op_name = "OP_LOCK",
1209 	},
1210 	[OP_LOCKT] = {
1211 		.op_func = (nfsd4op_func)nfsd4_lockt,
1212 		.op_name = "OP_LOCKT",
1213 	},
1214 	[OP_LOCKU] = {
1215 		.op_func = (nfsd4op_func)nfsd4_locku,
1216 		.op_name = "OP_LOCKU",
1217 	},
1218 	[OP_LOOKUP] = {
1219 		.op_func = (nfsd4op_func)nfsd4_lookup,
1220 		.op_name = "OP_LOOKUP",
1221 	},
1222 	[OP_LOOKUPP] = {
1223 		.op_func = (nfsd4op_func)nfsd4_lookupp,
1224 		.op_name = "OP_LOOKUPP",
1225 	},
1226 	[OP_NVERIFY] = {
1227 		.op_func = (nfsd4op_func)nfsd4_nverify,
1228 		.op_name = "OP_NVERIFY",
1229 	},
1230 	[OP_OPEN] = {
1231 		.op_func = (nfsd4op_func)nfsd4_open,
1232 		.op_name = "OP_OPEN",
1233 	},
1234 	[OP_OPEN_CONFIRM] = {
1235 		.op_func = (nfsd4op_func)nfsd4_open_confirm,
1236 		.op_name = "OP_OPEN_CONFIRM",
1237 	},
1238 	[OP_OPEN_DOWNGRADE] = {
1239 		.op_func = (nfsd4op_func)nfsd4_open_downgrade,
1240 		.op_name = "OP_OPEN_DOWNGRADE",
1241 	},
1242 	[OP_PUTFH] = {
1243 		.op_func = (nfsd4op_func)nfsd4_putfh,
1244 		.op_flags = ALLOWED_WITHOUT_FH | ALLOWED_ON_ABSENT_FS,
1245 		.op_name = "OP_PUTFH",
1246 	},
1247 	[OP_PUTPUBFH] = {
1248 		.op_func = (nfsd4op_func)nfsd4_putrootfh,
1249 		.op_flags = ALLOWED_WITHOUT_FH | ALLOWED_ON_ABSENT_FS,
1250 		.op_name = "OP_PUTPUBFH",
1251 	},
1252 	[OP_PUTROOTFH] = {
1253 		.op_func = (nfsd4op_func)nfsd4_putrootfh,
1254 		.op_flags = ALLOWED_WITHOUT_FH | ALLOWED_ON_ABSENT_FS,
1255 		.op_name = "OP_PUTROOTFH",
1256 	},
1257 	[OP_READ] = {
1258 		.op_func = (nfsd4op_func)nfsd4_read,
1259 		.op_name = "OP_READ",
1260 	},
1261 	[OP_READDIR] = {
1262 		.op_func = (nfsd4op_func)nfsd4_readdir,
1263 		.op_name = "OP_READDIR",
1264 	},
1265 	[OP_READLINK] = {
1266 		.op_func = (nfsd4op_func)nfsd4_readlink,
1267 		.op_name = "OP_READLINK",
1268 	},
1269 	[OP_REMOVE] = {
1270 		.op_func = (nfsd4op_func)nfsd4_remove,
1271 		.op_name = "OP_REMOVE",
1272 	},
1273 	[OP_RENAME] = {
1274 		.op_name = "OP_RENAME",
1275 		.op_func = (nfsd4op_func)nfsd4_rename,
1276 	},
1277 	[OP_RENEW] = {
1278 		.op_func = (nfsd4op_func)nfsd4_renew,
1279 		.op_flags = ALLOWED_WITHOUT_FH | ALLOWED_ON_ABSENT_FS,
1280 		.op_name = "OP_RENEW",
1281 	},
1282 	[OP_RESTOREFH] = {
1283 		.op_func = (nfsd4op_func)nfsd4_restorefh,
1284 		.op_flags = ALLOWED_WITHOUT_FH | ALLOWED_ON_ABSENT_FS,
1285 		.op_name = "OP_RESTOREFH",
1286 	},
1287 	[OP_SAVEFH] = {
1288 		.op_func = (nfsd4op_func)nfsd4_savefh,
1289 		.op_name = "OP_SAVEFH",
1290 	},
1291 	[OP_SECINFO] = {
1292 		.op_func = (nfsd4op_func)nfsd4_secinfo,
1293 		.op_name = "OP_SECINFO",
1294 	},
1295 	[OP_SETATTR] = {
1296 		.op_func = (nfsd4op_func)nfsd4_setattr,
1297 		.op_name = "OP_SETATTR",
1298 	},
1299 	[OP_SETCLIENTID] = {
1300 		.op_func = (nfsd4op_func)nfsd4_setclientid,
1301 		.op_flags = ALLOWED_WITHOUT_FH | ALLOWED_ON_ABSENT_FS,
1302 		.op_name = "OP_SETCLIENTID",
1303 	},
1304 	[OP_SETCLIENTID_CONFIRM] = {
1305 		.op_func = (nfsd4op_func)nfsd4_setclientid_confirm,
1306 		.op_flags = ALLOWED_WITHOUT_FH | ALLOWED_ON_ABSENT_FS,
1307 		.op_name = "OP_SETCLIENTID_CONFIRM",
1308 	},
1309 	[OP_VERIFY] = {
1310 		.op_func = (nfsd4op_func)nfsd4_verify,
1311 		.op_name = "OP_VERIFY",
1312 	},
1313 	[OP_WRITE] = {
1314 		.op_func = (nfsd4op_func)nfsd4_write,
1315 		.op_name = "OP_WRITE",
1316 	},
1317 	[OP_RELEASE_LOCKOWNER] = {
1318 		.op_func = (nfsd4op_func)nfsd4_release_lockowner,
1319 		.op_flags = ALLOWED_WITHOUT_FH | ALLOWED_ON_ABSENT_FS,
1320 		.op_name = "OP_RELEASE_LOCKOWNER",
1321 	},
1322 
1323 	/* NFSv4.1 operations */
1324 	[OP_EXCHANGE_ID] = {
1325 		.op_func = (nfsd4op_func)nfsd4_exchange_id,
1326 		.op_flags = ALLOWED_WITHOUT_FH | ALLOWED_AS_FIRST_OP,
1327 		.op_name = "OP_EXCHANGE_ID",
1328 	},
1329 	[OP_BIND_CONN_TO_SESSION] = {
1330 		.op_func = (nfsd4op_func)nfsd4_bind_conn_to_session,
1331 		.op_flags = ALLOWED_WITHOUT_FH | ALLOWED_AS_FIRST_OP,
1332 		.op_name = "OP_BIND_CONN_TO_SESSION",
1333 	},
1334 	[OP_CREATE_SESSION] = {
1335 		.op_func = (nfsd4op_func)nfsd4_create_session,
1336 		.op_flags = ALLOWED_WITHOUT_FH | ALLOWED_AS_FIRST_OP,
1337 		.op_name = "OP_CREATE_SESSION",
1338 	},
1339 	[OP_DESTROY_SESSION] = {
1340 		.op_func = (nfsd4op_func)nfsd4_destroy_session,
1341 		.op_flags = ALLOWED_WITHOUT_FH | ALLOWED_AS_FIRST_OP,
1342 		.op_name = "OP_DESTROY_SESSION",
1343 	},
1344 	[OP_SEQUENCE] = {
1345 		.op_func = (nfsd4op_func)nfsd4_sequence,
1346 		.op_flags = ALLOWED_WITHOUT_FH | ALLOWED_AS_FIRST_OP,
1347 		.op_name = "OP_SEQUENCE",
1348 	},
1349 	[OP_RECLAIM_COMPLETE] = {
1350 		.op_func = (nfsd4op_func)nfsd4_reclaim_complete,
1351 		.op_flags = ALLOWED_WITHOUT_FH,
1352 		.op_name = "OP_RECLAIM_COMPLETE",
1353 	},
1354 	[OP_SECINFO_NO_NAME] = {
1355 		.op_func = (nfsd4op_func)nfsd4_secinfo_no_name,
1356 		.op_name = "OP_SECINFO_NO_NAME",
1357 	},
1358 };
1359 
nfsd4_op_name(unsigned opnum)1360 static const char *nfsd4_op_name(unsigned opnum)
1361 {
1362 	if (opnum < ARRAY_SIZE(nfsd4_ops))
1363 		return nfsd4_ops[opnum].op_name;
1364 	return "unknown_operation";
1365 }
1366 
1367 #define nfsd4_voidres			nfsd4_voidargs
1368 struct nfsd4_voidargs { int dummy; };
1369 
1370 /*
1371  * TODO: At the present time, the NFSv4 server does not do XID caching
1372  * of requests.  Implementing XID caching would not be a serious problem,
1373  * although it would require a mild change in interfaces since one
1374  * doesn't know whether an NFSv4 request is idempotent until after the
1375  * XDR decode.  However, XID caching totally confuses pynfs (Peter
1376  * Astrand's regression testsuite for NFSv4 servers), which reuses
1377  * XID's liberally, so I've left it unimplemented until pynfs generates
1378  * better XID's.
1379  */
1380 static struct svc_procedure		nfsd_procedures4[2] = {
1381 	[NFSPROC4_NULL] = {
1382 		.pc_func = (svc_procfunc) nfsd4_proc_null,
1383 		.pc_encode = (kxdrproc_t) nfs4svc_encode_voidres,
1384 		.pc_argsize = sizeof(struct nfsd4_voidargs),
1385 		.pc_ressize = sizeof(struct nfsd4_voidres),
1386 		.pc_cachetype = RC_NOCACHE,
1387 		.pc_xdrressize = 1,
1388 	},
1389 	[NFSPROC4_COMPOUND] = {
1390 		.pc_func = (svc_procfunc) nfsd4_proc_compound,
1391 		.pc_decode = (kxdrproc_t) nfs4svc_decode_compoundargs,
1392 		.pc_encode = (kxdrproc_t) nfs4svc_encode_compoundres,
1393 		.pc_argsize = sizeof(struct nfsd4_compoundargs),
1394 		.pc_ressize = sizeof(struct nfsd4_compoundres),
1395 		.pc_cachetype = RC_NOCACHE,
1396 		.pc_xdrressize = NFSD_BUFSIZE/4,
1397 	},
1398 };
1399 
1400 struct svc_version	nfsd_version4 = {
1401 		.vs_vers	= 4,
1402 		.vs_nproc	= 2,
1403 		.vs_proc	= nfsd_procedures4,
1404 		.vs_dispatch	= nfsd_dispatch,
1405 		.vs_xdrsize	= NFS4_SVC_XDRSIZE,
1406 };
1407 
1408 /*
1409  * Local variables:
1410  *  c-basic-offset: 8
1411  * End:
1412  */
1413