nfs4proc.c 37.0 KB
Newer Older
L
Linus Torvalds 已提交
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34
/*
 *  Server-side procedures for NFSv4.
 *
 *  Copyright (c) 2002 The Regents of the University of Michigan.
 *  All rights reserved.
 *
 *  Kendrick Smith <kmsmith@umich.edu>
 *  Andy Adamson   <andros@umich.edu>
 *
 *  Redistribution and use in source and binary forms, with or without
 *  modification, are permitted provided that the following conditions
 *  are met:
 *
 *  1. Redistributions of source code must retain the above copyright
 *     notice, this list of conditions and the following disclaimer.
 *  2. Redistributions in binary form must reproduce the above copyright
 *     notice, this list of conditions and the following disclaimer in the
 *     documentation and/or other materials provided with the distribution.
 *  3. Neither the name of the University nor the names of its
 *     contributors may be used to endorse or promote products derived
 *     from this software without specific prior written permission.
 *
 *  THIS SOFTWARE IS PROVIDED ``AS IS'' AND ANY EXPRESS OR IMPLIED
 *  WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED WARRANTIES OF
 *  MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE
 *  DISCLAIMED. IN NO EVENT SHALL THE REGENTS OR CONTRIBUTORS BE LIABLE
 *  FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR
 *  CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF
 *  SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR
 *  BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF
 *  LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING
 *  NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF THIS
 *  SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
 */
35
#include <linux/file.h>
L
Linus Torvalds 已提交
36

37 38
#include "cache.h"
#include "xdr4.h"
39
#include "vfs.h"
L
Linus Torvalds 已提交
40 41 42

#define NFSDDBG_FACILITY		NFSDDBG_PROC

43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70
static u32 nfsd_attrmask[] = {
	NFSD_WRITEABLE_ATTRS_WORD0,
	NFSD_WRITEABLE_ATTRS_WORD1,
	NFSD_WRITEABLE_ATTRS_WORD2
};

static u32 nfsd41_ex_attrmask[] = {
	NFSD_SUPPATTR_EXCLCREAT_WORD0,
	NFSD_SUPPATTR_EXCLCREAT_WORD1,
	NFSD_SUPPATTR_EXCLCREAT_WORD2
};

static __be32
check_attr_support(struct svc_rqst *rqstp, struct nfsd4_compound_state *cstate,
		   u32 *bmval, u32 *writable)
{
	struct dentry *dentry = cstate->current_fh.fh_dentry;

	/*
	 * Check about attributes are supported by the NFSv4 server or not.
	 * According to spec, unsupported attributes return ERR_ATTRNOTSUPP.
	 */
	if ((bmval[0] & ~nfsd_suppattrs0(cstate->minorversion)) ||
	    (bmval[1] & ~nfsd_suppattrs1(cstate->minorversion)) ||
	    (bmval[2] & ~nfsd_suppattrs2(cstate->minorversion)))
		return nfserr_attrnotsupp;

	/*
71
	 * Check FATTR4_WORD0_ACL can be supported
72 73 74 75 76 77 78 79 80 81 82 83 84 85 86 87 88 89 90 91 92 93 94 95 96 97 98 99 100 101 102 103 104 105 106 107 108 109
	 * in current environment or not.
	 */
	if (bmval[0] & FATTR4_WORD0_ACL) {
		if (!IS_POSIXACL(dentry->d_inode))
			return nfserr_attrnotsupp;
	}

	/*
	 * According to spec, read-only attributes return ERR_INVAL.
	 */
	if (writable) {
		if ((bmval[0] & ~writable[0]) || (bmval[1] & ~writable[1]) ||
		    (bmval[2] & ~writable[2]))
			return nfserr_inval;
	}

	return nfs_ok;
}

static __be32
nfsd4_check_open_attributes(struct svc_rqst *rqstp,
	struct nfsd4_compound_state *cstate, struct nfsd4_open *open)
{
	__be32 status = nfs_ok;

	if (open->op_create == NFS4_OPEN_CREATE) {
		if (open->op_createmode == NFS4_CREATE_UNCHECKED
		    || open->op_createmode == NFS4_CREATE_GUARDED)
			status = check_attr_support(rqstp, cstate,
					open->op_bmval, nfsd_attrmask);
		else if (open->op_createmode == NFS4_CREATE_EXCLUSIVE4_1)
			status = check_attr_support(rqstp, cstate,
					open->op_bmval, nfsd41_ex_attrmask);
	}

	return status;
}

110 111 112 113 114 115 116 117 118 119 120 121 122 123 124 125 126 127 128 129 130 131 132 133 134 135 136 137 138
static int
is_create_with_attrs(struct nfsd4_open *open)
{
	return open->op_create == NFS4_OPEN_CREATE
		&& (open->op_createmode == NFS4_CREATE_UNCHECKED
		    || open->op_createmode == NFS4_CREATE_GUARDED
		    || open->op_createmode == NFS4_CREATE_EXCLUSIVE4_1);
}

/*
 * if error occurs when setting the acl, just clear the acl bit
 * in the returned attr bitmap.
 */
static void
do_set_nfs4_acl(struct svc_rqst *rqstp, struct svc_fh *fhp,
		struct nfs4_acl *acl, u32 *bmval)
{
	__be32 status;

	status = nfsd4_set_nfs4_acl(rqstp, fhp, acl);
	if (status)
		/*
		 * We should probably fail the whole open at this point,
		 * but we've already created the file, so it's too late;
		 * So this seems the least of evils:
		 */
		bmval[0] &= ~FATTR4_WORD0_ACL;
}

L
Linus Torvalds 已提交
139 140 141 142 143 144 145 146 147 148
static inline void
fh_dup2(struct svc_fh *dst, struct svc_fh *src)
{
	fh_put(dst);
	dget(src->fh_dentry);
	if (src->fh_export)
		cache_get(&src->fh_export->h);
	*dst = *src;
}

149
static __be32
150
do_open_permission(struct svc_rqst *rqstp, struct svc_fh *current_fh, struct nfsd4_open *open, int accmode)
L
Linus Torvalds 已提交
151
{
152
	__be32 status;
L
Linus Torvalds 已提交
153 154 155 156 157 158

	if (open->op_truncate &&
		!(open->op_share_access & NFS4_SHARE_ACCESS_WRITE))
		return nfserr_inval;

	if (open->op_share_access & NFS4_SHARE_ACCESS_READ)
M
Miklos Szeredi 已提交
159
		accmode |= NFSD_MAY_READ;
160
	if (open->op_share_access & NFS4_SHARE_ACCESS_WRITE)
M
Miklos Szeredi 已提交
161
		accmode |= (NFSD_MAY_WRITE | NFSD_MAY_TRUNC);
162
	if (open->op_share_deny & NFS4_SHARE_DENY_READ)
M
Miklos Szeredi 已提交
163
		accmode |= NFSD_MAY_WRITE;
L
Linus Torvalds 已提交
164 165 166 167 168 169

	status = fh_verify(rqstp, current_fh, S_IFREG, accmode);

	return status;
}

170
static __be32
L
Linus Torvalds 已提交
171 172 173
do_open_lookup(struct svc_rqst *rqstp, struct svc_fh *current_fh, struct nfsd4_open *open)
{
	struct svc_fh resfh;
174
	__be32 status;
175
	int created = 0;
L
Linus Torvalds 已提交
176 177 178 179 180

	fh_init(&resfh, NFS4_FHSIZE);
	open->op_truncate = 0;

	if (open->op_create) {
B
Benny Halevy 已提交
181 182 183 184 185 186 187 188 189 190 191 192 193 194 195
		/* FIXME: check session persistence and pnfs flags.
		 * The nfsv4.1 spec requires the following semantics:
		 *
		 * Persistent   | pNFS   | Server REQUIRED | Client Allowed
		 * Reply Cache  | server |                 |
		 * -------------+--------+-----------------+--------------------
		 * no           | no     | EXCLUSIVE4_1    | EXCLUSIVE4_1
		 *              |        |                 | (SHOULD)
		 *              |        | and EXCLUSIVE4  | or EXCLUSIVE4
		 *              |        |                 | (SHOULD NOT)
		 * no           | yes    | EXCLUSIVE4_1    | EXCLUSIVE4_1
		 * yes          | no     | GUARDED4        | GUARDED4
		 * yes          | yes    | GUARDED4        | GUARDED4
		 */

L
Linus Torvalds 已提交
196 197 198 199 200 201 202
		/*
		 * Note: create modes (UNCHECKED,GUARDED...) are the same
		 * in NFSv4 as in v3.
		 */
		status = nfsd_create_v3(rqstp, current_fh, open->op_fname.data,
					open->op_fname.len, &open->op_iattr,
					&resfh, open->op_createmode,
203 204 205
					(u32 *)open->op_verf.data,
					&open->op_truncate, &created);

206 207 208 209
		/*
		 * Following rfc 3530 14.2.16, use the returned bitmask
		 * to indicate which attributes we used to store the
		 * verifier:
210 211
		 */
		if (open->op_createmode == NFS4_CREATE_EXCLUSIVE && status == 0)
212
			open->op_bmval[1] = (FATTR4_WORD1_TIME_ACCESS |
213
						FATTR4_WORD1_TIME_MODIFY);
214
	} else {
L
Linus Torvalds 已提交
215 216 217 218
		status = nfsd_lookup(rqstp, current_fh,
				     open->op_fname.data, open->op_fname.len, &resfh);
		fh_unlock(current_fh);
	}
219 220
	if (status)
		goto out;
L
Linus Torvalds 已提交
221

222 223 224
	if (is_create_with_attrs(open) && open->op_acl != NULL)
		do_set_nfs4_acl(rqstp, &resfh, open->op_acl, open->op_bmval);

225
	set_change_info(&open->op_cinfo, current_fh);
J
J. Bruce Fields 已提交
226
	fh_dup2(current_fh, &resfh);
L
Linus Torvalds 已提交
227

228
	/* set reply cache */
229 230
	fh_copy_shallow(&open->op_stateowner->so_replay.rp_openfh,
			&resfh.fh_handle);
231
	if (!created)
M
Miklos Szeredi 已提交
232 233
		status = do_open_permission(rqstp, current_fh, open,
					    NFSD_MAY_NOP);
L
Linus Torvalds 已提交
234

235
out:
L
Linus Torvalds 已提交
236 237 238 239
	fh_put(&resfh);
	return status;
}

240
static __be32
L
Linus Torvalds 已提交
241 242
do_open_fhandle(struct svc_rqst *rqstp, struct svc_fh *current_fh, struct nfsd4_open *open)
{
243
	__be32 status;
L
Linus Torvalds 已提交
244 245 246 247 248 249 250 251 252 253 254 255

	/* Only reclaims from previously confirmed clients are valid */
	if ((status = nfs4_check_open_reclaim(&open->op_clientid)))
		return status;

	/* We don't know the target directory, and therefore can not
	* set the change info
	*/

	memset(&open->op_cinfo, 0, sizeof(struct nfsd4_change_info));

	/* set replay cache */
256 257
	fh_copy_shallow(&open->op_stateowner->so_replay.rp_openfh,
			&current_fh->fh_handle);
L
Linus Torvalds 已提交
258 259 260 261

	open->op_truncate = (open->op_iattr.ia_valid & ATTR_SIZE) &&
		(open->op_iattr.ia_size == 0);

M
Miklos Szeredi 已提交
262 263
	status = do_open_permission(rqstp, current_fh, open,
				    NFSD_MAY_OWNER_OVERRIDE);
L
Linus Torvalds 已提交
264 265 266 267

	return status;
}

A
Andy Adamson 已提交
268 269 270 271 272 273 274 275 276
static void
copy_clientid(clientid_t *clid, struct nfsd4_session *session)
{
	struct nfsd4_sessionid *sid =
			(struct nfsd4_sessionid *)session->se_sessionid.data;

	clid->cl_boot = sid->clientid.cl_boot;
	clid->cl_id = sid->clientid.cl_id;
}
L
Linus Torvalds 已提交
277

278
static __be32
279
nfsd4_open(struct svc_rqst *rqstp, struct nfsd4_compound_state *cstate,
280
	   struct nfsd4_open *open)
L
Linus Torvalds 已提交
281
{
282
	__be32 status;
A
Andy Adamson 已提交
283 284
	struct nfsd4_compoundres *resp;

L
Linus Torvalds 已提交
285 286 287 288 289 290 291 292
	dprintk("NFSD: nfsd4_open filename %.*s op_stateowner %p\n",
		(int)open->op_fname.len, open->op_fname.data,
		open->op_stateowner);

	/* This check required by spec. */
	if (open->op_create && open->op_claim_type != NFS4_OPEN_CLAIM_NULL)
		return nfserr_inval;

A
Andy Adamson 已提交
293 294 295
	if (nfsd4_has_session(cstate))
		copy_clientid(&open->op_clientid, cstate->session);

L
Linus Torvalds 已提交
296 297 298
	nfs4_lock_state();

	/* check seqid for replay. set nfs4_owner */
A
Andy Adamson 已提交
299 300
	resp = rqstp->rq_resp;
	status = nfsd4_process_open1(&resp->cstate, open);
A
Al Viro 已提交
301
	if (status == nfserr_replay_me) {
L
Linus Torvalds 已提交
302
		struct nfs4_replay *rp = &open->op_stateowner->so_replay;
303
		fh_put(&cstate->current_fh);
304 305
		fh_copy_shallow(&cstate->current_fh.fh_handle,
				&rp->rp_openfh);
M
Miklos Szeredi 已提交
306
		status = fh_verify(rqstp, &cstate->current_fh, 0, NFSD_MAY_NOP);
L
Linus Torvalds 已提交
307 308 309 310
		if (status)
			dprintk("nfsd4_open: replay failed"
				" restoring previous filehandle\n");
		else
A
Al Viro 已提交
311
			status = nfserr_replay_me;
L
Linus Torvalds 已提交
312 313 314
	}
	if (status)
		goto out;
315

316 317 318 319
	status = nfsd4_check_open_attributes(rqstp, cstate, open);
	if (status)
		goto out;

320 321
	/* Openowner is now set, so sequence id will get bumped.  Now we need
	 * these checks before we do any creates: */
322
	status = nfserr_grace;
323
	if (locks_in_grace() && open->op_claim_type != NFS4_OPEN_CLAIM_PREVIOUS)
324 325
		goto out;
	status = nfserr_no_grace;
326
	if (!locks_in_grace() && open->op_claim_type == NFS4_OPEN_CLAIM_PREVIOUS)
327
		goto out;
328

L
Linus Torvalds 已提交
329
	switch (open->op_claim_type) {
330
		case NFS4_OPEN_CLAIM_DELEGATE_CUR:
L
Linus Torvalds 已提交
331 332 333 334 335 336 337
		case NFS4_OPEN_CLAIM_NULL:
			/*
			 * (1) set CURRENT_FH to the file being opened,
			 * creating it if necessary, (2) set open->op_cinfo,
			 * (3) set open->op_truncate if the file is to be
			 * truncated after opening, (4) do permission checking.
			 */
338 339
			status = do_open_lookup(rqstp, &cstate->current_fh,
						open);
L
Linus Torvalds 已提交
340 341 342 343
			if (status)
				goto out;
			break;
		case NFS4_OPEN_CLAIM_PREVIOUS:
344
			open->op_stateowner->so_confirmed = 1;
L
Linus Torvalds 已提交
345 346 347 348 349 350
			/*
			 * The CURRENT_FH is already set to the file being
			 * opened.  (1) set open->op_cinfo, (2) set
			 * open->op_truncate if the file is to be truncated
			 * after opening, (3) do permission checking.
			*/
351 352
			status = do_open_fhandle(rqstp, &cstate->current_fh,
						 open);
L
Linus Torvalds 已提交
353 354 355 356
			if (status)
				goto out;
			break;
             	case NFS4_OPEN_CLAIM_DELEGATE_PREV:
357
			open->op_stateowner->so_confirmed = 1;
358
			dprintk("NFSD: unsupported OPEN claim type %d\n",
L
Linus Torvalds 已提交
359 360 361 362
				open->op_claim_type);
			status = nfserr_notsupp;
			goto out;
		default:
363
			dprintk("NFSD: Invalid OPEN claim type %d\n",
L
Linus Torvalds 已提交
364 365 366 367 368 369 370 371 372
				open->op_claim_type);
			status = nfserr_inval;
			goto out;
	}
	/*
	 * nfsd4_process_open2() does the actual opening of the file.  If
	 * successful, it (1) truncates the file if open->op_truncate was
	 * set, (2) sets open->op_stateid, (3) sets open->op_delegation.
	 */
373
	status = nfsd4_process_open2(rqstp, &cstate->current_fh, open);
L
Linus Torvalds 已提交
374
out:
N
Neil Brown 已提交
375
	if (open->op_stateowner) {
L
Linus Torvalds 已提交
376
		nfs4_get_stateowner(open->op_stateowner);
377
		cstate->replay_owner = open->op_stateowner;
N
Neil Brown 已提交
378
	}
L
Linus Torvalds 已提交
379 380 381 382 383 384 385
	nfs4_unlock_state();
	return status;
}

/*
 * filehandle-manipulating ops.
 */
386
static __be32
387 388
nfsd4_getfh(struct svc_rqst *rqstp, struct nfsd4_compound_state *cstate,
	    struct svc_fh **getfh)
L
Linus Torvalds 已提交
389
{
390
	if (!cstate->current_fh.fh_dentry)
L
Linus Torvalds 已提交
391 392
		return nfserr_nofilehandle;

393
	*getfh = &cstate->current_fh;
L
Linus Torvalds 已提交
394 395 396
	return nfs_ok;
}

397
static __be32
398 399
nfsd4_putfh(struct svc_rqst *rqstp, struct nfsd4_compound_state *cstate,
	    struct nfsd4_putfh *putfh)
L
Linus Torvalds 已提交
400
{
401 402 403 404
	fh_put(&cstate->current_fh);
	cstate->current_fh.fh_handle.fh_size = putfh->pf_fhlen;
	memcpy(&cstate->current_fh.fh_handle.fh_base, putfh->pf_fhval,
	       putfh->pf_fhlen);
M
Miklos Szeredi 已提交
405
	return fh_verify(rqstp, &cstate->current_fh, 0, NFSD_MAY_NOP);
L
Linus Torvalds 已提交
406 407
}

408
static __be32
409 410
nfsd4_putrootfh(struct svc_rqst *rqstp, struct nfsd4_compound_state *cstate,
		void *arg)
L
Linus Torvalds 已提交
411
{
412
	__be32 status;
L
Linus Torvalds 已提交
413

414
	fh_put(&cstate->current_fh);
415
	status = exp_pseudoroot(rqstp, &cstate->current_fh);
L
Linus Torvalds 已提交
416 417 418
	return status;
}

419
static __be32
420 421
nfsd4_restorefh(struct svc_rqst *rqstp, struct nfsd4_compound_state *cstate,
		void *arg)
L
Linus Torvalds 已提交
422
{
423
	if (!cstate->save_fh.fh_dentry)
L
Linus Torvalds 已提交
424 425
		return nfserr_restorefh;

426
	fh_dup2(&cstate->current_fh, &cstate->save_fh);
L
Linus Torvalds 已提交
427 428 429
	return nfs_ok;
}

430
static __be32
431 432
nfsd4_savefh(struct svc_rqst *rqstp, struct nfsd4_compound_state *cstate,
	     void *arg)
L
Linus Torvalds 已提交
433
{
434
	if (!cstate->current_fh.fh_dentry)
L
Linus Torvalds 已提交
435 436
		return nfserr_nofilehandle;

437
	fh_dup2(&cstate->save_fh, &cstate->current_fh);
L
Linus Torvalds 已提交
438 439 440 441 442 443
	return nfs_ok;
}

/*
 * misc nfsv4 ops
 */
444
static __be32
445 446
nfsd4_access(struct svc_rqst *rqstp, struct nfsd4_compound_state *cstate,
	     struct nfsd4_access *access)
L
Linus Torvalds 已提交
447 448 449 450 451
{
	if (access->ac_req_access & ~NFS3_ACCESS_FULL)
		return nfserr_inval;

	access->ac_resp_access = access->ac_req_access;
452 453
	return nfsd_access(rqstp, &cstate->current_fh, &access->ac_resp_access,
			   &access->ac_supported);
L
Linus Torvalds 已提交
454 455
}

456
static __be32
457 458
nfsd4_commit(struct svc_rqst *rqstp, struct nfsd4_compound_state *cstate,
	     struct nfsd4_commit *commit)
L
Linus Torvalds 已提交
459
{
460
	__be32 status;
L
Linus Torvalds 已提交
461 462 463 464 465

	u32 *p = (u32 *)commit->co_verf.data;
	*p++ = nfssvc_boot.tv_sec;
	*p++ = nfssvc_boot.tv_usec;

466 467
	status = nfsd_commit(rqstp, &cstate->current_fh, commit->co_offset,
			     commit->co_count);
L
Linus Torvalds 已提交
468 469 470 471 472
	if (status == nfserr_symlink)
		status = nfserr_inval;
	return status;
}

473
static __be32
474 475
nfsd4_create(struct svc_rqst *rqstp, struct nfsd4_compound_state *cstate,
	     struct nfsd4_create *create)
L
Linus Torvalds 已提交
476 477
{
	struct svc_fh resfh;
478
	__be32 status;
L
Linus Torvalds 已提交
479 480 481 482
	dev_t rdev;

	fh_init(&resfh, NFS4_FHSIZE);

M
Miklos Szeredi 已提交
483 484
	status = fh_verify(rqstp, &cstate->current_fh, S_IFDIR,
			   NFSD_MAY_CREATE);
L
Linus Torvalds 已提交
485 486 487 488 489
	if (status == nfserr_symlink)
		status = nfserr_notdir;
	if (status)
		return status;

490 491 492 493 494
	status = check_attr_support(rqstp, cstate, create->cr_bmval,
				    nfsd_attrmask);
	if (status)
		return status;

L
Linus Torvalds 已提交
495 496 497 498 499 500 501 502 503 504 505
	switch (create->cr_type) {
	case NF4LNK:
		/* ugh! we have to null-terminate the linktext, or
		 * vfs_symlink() will choke.  it is always safe to
		 * null-terminate by brute force, since at worst we
		 * will overwrite the first byte of the create namelen
		 * in the XDR buffer, which has already been extracted
		 * during XDR decode.
		 */
		create->cr_linkname[create->cr_linklen] = 0;

506 507 508 509
		status = nfsd_symlink(rqstp, &cstate->current_fh,
				      create->cr_name, create->cr_namelen,
				      create->cr_linkname, create->cr_linklen,
				      &resfh, &create->cr_iattr);
L
Linus Torvalds 已提交
510 511 512 513 514 515 516
		break;

	case NF4BLK:
		rdev = MKDEV(create->cr_specdata1, create->cr_specdata2);
		if (MAJOR(rdev) != create->cr_specdata1 ||
		    MINOR(rdev) != create->cr_specdata2)
			return nfserr_inval;
517 518 519
		status = nfsd_create(rqstp, &cstate->current_fh,
				     create->cr_name, create->cr_namelen,
				     &create->cr_iattr, S_IFBLK, rdev, &resfh);
L
Linus Torvalds 已提交
520 521 522 523 524 525 526
		break;

	case NF4CHR:
		rdev = MKDEV(create->cr_specdata1, create->cr_specdata2);
		if (MAJOR(rdev) != create->cr_specdata1 ||
		    MINOR(rdev) != create->cr_specdata2)
			return nfserr_inval;
527 528 529
		status = nfsd_create(rqstp, &cstate->current_fh,
				     create->cr_name, create->cr_namelen,
				     &create->cr_iattr,S_IFCHR, rdev, &resfh);
L
Linus Torvalds 已提交
530 531 532
		break;

	case NF4SOCK:
533 534 535
		status = nfsd_create(rqstp, &cstate->current_fh,
				     create->cr_name, create->cr_namelen,
				     &create->cr_iattr, S_IFSOCK, 0, &resfh);
L
Linus Torvalds 已提交
536 537 538
		break;

	case NF4FIFO:
539 540 541
		status = nfsd_create(rqstp, &cstate->current_fh,
				     create->cr_name, create->cr_namelen,
				     &create->cr_iattr, S_IFIFO, 0, &resfh);
L
Linus Torvalds 已提交
542 543 544 545
		break;

	case NF4DIR:
		create->cr_iattr.ia_valid &= ~ATTR_SIZE;
546 547 548
		status = nfsd_create(rqstp, &cstate->current_fh,
				     create->cr_name, create->cr_namelen,
				     &create->cr_iattr, S_IFDIR, 0, &resfh);
L
Linus Torvalds 已提交
549 550 551 552 553 554
		break;

	default:
		status = nfserr_badtype;
	}

555 556
	if (status)
		goto out;
L
Linus Torvalds 已提交
557

558 559 560 561 562 563 564 565
	if (create->cr_acl != NULL)
		do_set_nfs4_acl(rqstp, &resfh, create->cr_acl,
				create->cr_bmval);

	fh_unlock(&cstate->current_fh);
	set_change_info(&create->cr_cinfo, &cstate->current_fh);
	fh_dup2(&cstate->current_fh, &resfh);
out:
L
Linus Torvalds 已提交
566 567 568 569
	fh_put(&resfh);
	return status;
}

570
static __be32
571 572
nfsd4_getattr(struct svc_rqst *rqstp, struct nfsd4_compound_state *cstate,
	      struct nfsd4_getattr *getattr)
L
Linus Torvalds 已提交
573
{
574
	__be32 status;
L
Linus Torvalds 已提交
575

M
Miklos Szeredi 已提交
576
	status = fh_verify(rqstp, &cstate->current_fh, 0, NFSD_MAY_NOP);
L
Linus Torvalds 已提交
577 578 579 580 581 582
	if (status)
		return status;

	if (getattr->ga_bmval[1] & NFSD_WRITEONLY_ATTRS_WORD1)
		return nfserr_inval;

583 584 585
	getattr->ga_bmval[0] &= nfsd_suppattrs0(cstate->minorversion);
	getattr->ga_bmval[1] &= nfsd_suppattrs1(cstate->minorversion);
	getattr->ga_bmval[2] &= nfsd_suppattrs2(cstate->minorversion);
L
Linus Torvalds 已提交
586

587
	getattr->ga_fhp = &cstate->current_fh;
L
Linus Torvalds 已提交
588 589 590
	return nfs_ok;
}

591
static __be32
592 593
nfsd4_link(struct svc_rqst *rqstp, struct nfsd4_compound_state *cstate,
	   struct nfsd4_link *link)
L
Linus Torvalds 已提交
594
{
595
	__be32 status = nfserr_nofilehandle;
L
Linus Torvalds 已提交
596

597
	if (!cstate->save_fh.fh_dentry)
L
Linus Torvalds 已提交
598
		return status;
599 600
	status = nfsd_link(rqstp, &cstate->current_fh,
			   link->li_name, link->li_namelen, &cstate->save_fh);
L
Linus Torvalds 已提交
601
	if (!status)
602
		set_change_info(&link->li_cinfo, &cstate->current_fh);
L
Linus Torvalds 已提交
603 604 605
	return status;
}

606
static __be32
607 608
nfsd4_lookupp(struct svc_rqst *rqstp, struct nfsd4_compound_state *cstate,
	      void *arg)
L
Linus Torvalds 已提交
609 610
{
	struct svc_fh tmp_fh;
611
	__be32 ret;
L
Linus Torvalds 已提交
612 613

	fh_init(&tmp_fh, NFS4_FHSIZE);
614 615
	ret = exp_pseudoroot(rqstp, &tmp_fh);
	if (ret)
L
Linus Torvalds 已提交
616
		return ret;
617
	if (tmp_fh.fh_dentry == cstate->current_fh.fh_dentry) {
L
Linus Torvalds 已提交
618 619 620 621
		fh_put(&tmp_fh);
		return nfserr_noent;
	}
	fh_put(&tmp_fh);
622 623
	return nfsd_lookup(rqstp, &cstate->current_fh,
			   "..", 2, &cstate->current_fh);
L
Linus Torvalds 已提交
624 625
}

626
static __be32
627 628
nfsd4_lookup(struct svc_rqst *rqstp, struct nfsd4_compound_state *cstate,
	     struct nfsd4_lookup *lookup)
L
Linus Torvalds 已提交
629
{
630 631 632
	return nfsd_lookup(rqstp, &cstate->current_fh,
			   lookup->lo_name, lookup->lo_len,
			   &cstate->current_fh);
L
Linus Torvalds 已提交
633 634
}

635
static __be32
636 637
nfsd4_read(struct svc_rqst *rqstp, struct nfsd4_compound_state *cstate,
	   struct nfsd4_read *read)
L
Linus Torvalds 已提交
638
{
639
	__be32 status;
L
Linus Torvalds 已提交
640 641 642

	/* no need to check permission - this will be done in nfsd_read() */

643
	read->rd_filp = NULL;
L
Linus Torvalds 已提交
644 645 646 647 648
	if (read->rd_offset >= OFFSET_MAX)
		return nfserr_inval;

	nfs4_lock_state();
	/* check stateid */
649 650
	if ((status = nfs4_preprocess_stateid_op(cstate, &read->rd_stateid,
						 RD_STATE, &read->rd_filp))) {
L
Linus Torvalds 已提交
651 652 653
		dprintk("NFSD: nfsd4_read: couldn't process stateid!\n");
		goto out;
	}
654 655
	if (read->rd_filp)
		get_file(read->rd_filp);
L
Linus Torvalds 已提交
656 657 658 659
	status = nfs_ok;
out:
	nfs4_unlock_state();
	read->rd_rqstp = rqstp;
660
	read->rd_fhp = &cstate->current_fh;
L
Linus Torvalds 已提交
661 662 663
	return status;
}

664
static __be32
665 666
nfsd4_readdir(struct svc_rqst *rqstp, struct nfsd4_compound_state *cstate,
	      struct nfsd4_readdir *readdir)
L
Linus Torvalds 已提交
667 668 669 670 671 672 673 674 675
{
	u64 cookie = readdir->rd_cookie;
	static const nfs4_verifier zeroverf;

	/* no need to check permission - this will be done in nfsd_readdir() */

	if (readdir->rd_bmval[1] & NFSD_WRITEONLY_ATTRS_WORD1)
		return nfserr_inval;

676 677 678
	readdir->rd_bmval[0] &= nfsd_suppattrs0(cstate->minorversion);
	readdir->rd_bmval[1] &= nfsd_suppattrs1(cstate->minorversion);
	readdir->rd_bmval[2] &= nfsd_suppattrs2(cstate->minorversion);
L
Linus Torvalds 已提交
679 680 681 682 683 684

	if ((cookie > ~(u32)0) || (cookie == 1) || (cookie == 2) ||
	    (cookie == 0 && memcmp(readdir->rd_verf.data, zeroverf.data, NFS4_VERIFIER_SIZE)))
		return nfserr_bad_cookie;

	readdir->rd_rqstp = rqstp;
685
	readdir->rd_fhp = &cstate->current_fh;
L
Linus Torvalds 已提交
686 687 688
	return nfs_ok;
}

689
static __be32
690 691
nfsd4_readlink(struct svc_rqst *rqstp, struct nfsd4_compound_state *cstate,
	       struct nfsd4_readlink *readlink)
L
Linus Torvalds 已提交
692 693
{
	readlink->rl_rqstp = rqstp;
694
	readlink->rl_fhp = &cstate->current_fh;
L
Linus Torvalds 已提交
695 696 697
	return nfs_ok;
}

698
static __be32
699 700
nfsd4_remove(struct svc_rqst *rqstp, struct nfsd4_compound_state *cstate,
	     struct nfsd4_remove *remove)
L
Linus Torvalds 已提交
701
{
702
	__be32 status;
L
Linus Torvalds 已提交
703

704
	if (locks_in_grace())
705
		return nfserr_grace;
706 707
	status = nfsd_unlink(rqstp, &cstate->current_fh, 0,
			     remove->rm_name, remove->rm_namelen);
L
Linus Torvalds 已提交
708 709 710
	if (status == nfserr_symlink)
		return nfserr_notdir;
	if (!status) {
711 712
		fh_unlock(&cstate->current_fh);
		set_change_info(&remove->rm_cinfo, &cstate->current_fh);
L
Linus Torvalds 已提交
713 714 715 716
	}
	return status;
}

717
static __be32
718 719
nfsd4_rename(struct svc_rqst *rqstp, struct nfsd4_compound_state *cstate,
	     struct nfsd4_rename *rename)
L
Linus Torvalds 已提交
720
{
721
	__be32 status = nfserr_nofilehandle;
L
Linus Torvalds 已提交
722

723
	if (!cstate->save_fh.fh_dentry)
L
Linus Torvalds 已提交
724
		return status;
725
	if (locks_in_grace() && !(cstate->save_fh.fh_export->ex_flags
726 727
					& NFSEXP_NOSUBTREECHECK))
		return nfserr_grace;
728 729
	status = nfsd_rename(rqstp, &cstate->save_fh, rename->rn_sname,
			     rename->rn_snamelen, &cstate->current_fh,
L
Linus Torvalds 已提交
730 731 732 733 734 735 736
			     rename->rn_tname, rename->rn_tnamelen);

	/* the underlying filesystem returns different error's than required
	 * by NFSv4. both save_fh and current_fh have been verified.. */
	if (status == nfserr_isdir)
		status = nfserr_exist;
	else if ((status == nfserr_notdir) &&
737 738
                  (S_ISDIR(cstate->save_fh.fh_dentry->d_inode->i_mode) &&
                   S_ISDIR(cstate->current_fh.fh_dentry->d_inode->i_mode)))
L
Linus Torvalds 已提交
739 740 741 742 743
		status = nfserr_exist;
	else if (status == nfserr_symlink)
		status = nfserr_notdir;

	if (!status) {
744 745
		set_change_info(&rename->rn_sinfo, &cstate->current_fh);
		set_change_info(&rename->rn_tinfo, &cstate->save_fh);
L
Linus Torvalds 已提交
746 747 748 749
	}
	return status;
}

A
Andy Adamson 已提交
750 751 752 753 754 755 756 757 758 759 760 761 762 763 764 765 766 767 768 769 770 771 772 773
static __be32
nfsd4_secinfo(struct svc_rqst *rqstp, struct nfsd4_compound_state *cstate,
	      struct nfsd4_secinfo *secinfo)
{
	struct svc_fh resfh;
	struct svc_export *exp;
	struct dentry *dentry;
	__be32 err;

	fh_init(&resfh, NFS4_FHSIZE);
	err = nfsd_lookup_dentry(rqstp, &cstate->current_fh,
				    secinfo->si_name, secinfo->si_namelen,
				    &exp, &dentry);
	if (err)
		return err;
	if (dentry->d_inode == NULL) {
		exp_put(exp);
		err = nfserr_noent;
	} else
		secinfo->si_exp = exp;
	dput(dentry);
	return err;
}

774
static __be32
775 776
nfsd4_setattr(struct svc_rqst *rqstp, struct nfsd4_compound_state *cstate,
	      struct nfsd4_setattr *setattr)
L
Linus Torvalds 已提交
777
{
778
	__be32 status = nfs_ok;
L
Linus Torvalds 已提交
779 780 781

	if (setattr->sa_iattr.ia_valid & ATTR_SIZE) {
		nfs4_lock_state();
782
		status = nfs4_preprocess_stateid_op(cstate,
783
			&setattr->sa_stateid, WR_STATE, NULL);
L
Linus Torvalds 已提交
784
		nfs4_unlock_state();
785
		if (status) {
786
			dprintk("NFSD: nfsd4_setattr: couldn't process stateid!\n");
787 788
			return status;
		}
L
Linus Torvalds 已提交
789
	}
790 791 792
	status = mnt_want_write(cstate->current_fh.fh_export->ex_path.mnt);
	if (status)
		return status;
L
Linus Torvalds 已提交
793
	status = nfs_ok;
794 795 796 797 798 799

	status = check_attr_support(rqstp, cstate, setattr->sa_bmval,
				    nfsd_attrmask);
	if (status)
		goto out;

L
Linus Torvalds 已提交
800
	if (setattr->sa_acl != NULL)
801 802
		status = nfsd4_set_nfs4_acl(rqstp, &cstate->current_fh,
					    setattr->sa_acl);
L
Linus Torvalds 已提交
803
	if (status)
804
		goto out;
805
	status = nfsd_setattr(rqstp, &cstate->current_fh, &setattr->sa_iattr,
L
Linus Torvalds 已提交
806
				0, (time_t)0);
807 808
out:
	mnt_drop_write(cstate->current_fh.fh_export->ex_path.mnt);
L
Linus Torvalds 已提交
809 810 811
	return status;
}

812
static __be32
813 814
nfsd4_write(struct svc_rqst *rqstp, struct nfsd4_compound_state *cstate,
	    struct nfsd4_write *write)
L
Linus Torvalds 已提交
815 816 817 818
{
	stateid_t *stateid = &write->wr_stateid;
	struct file *filp = NULL;
	u32 *p;
819
	__be32 status = nfs_ok;
820
	unsigned long cnt;
L
Linus Torvalds 已提交
821 822 823 824 825 826 827

	/* no need to check permission - this will be done in nfsd_write() */

	if (write->wr_offset >= OFFSET_MAX)
		return nfserr_inval;

	nfs4_lock_state();
828
	status = nfs4_preprocess_stateid_op(cstate, stateid, WR_STATE, &filp);
829 830
	if (filp)
		get_file(filp);
L
Linus Torvalds 已提交
831 832
	nfs4_unlock_state();

833 834 835 836 837
	if (status) {
		dprintk("NFSD: nfsd4_write: couldn't process stateid!\n");
		return status;
	}

838
	cnt = write->wr_buflen;
L
Linus Torvalds 已提交
839 840 841 842 843
	write->wr_how_written = write->wr_stable_how;
	p = (u32 *)write->wr_verifier.data;
	*p++ = nfssvc_boot.tv_sec;
	*p++ = nfssvc_boot.tv_usec;

844 845
	status =  nfsd_write(rqstp, &cstate->current_fh, filp,
			     write->wr_offset, rqstp->rq_vec, write->wr_vlen,
846
			     &cnt, &write->wr_how_written);
847 848
	if (filp)
		fput(filp);
L
Linus Torvalds 已提交
849

850 851
	write->wr_bytes_written = cnt;

L
Linus Torvalds 已提交
852 853 854 855 856 857 858 859 860 861
	if (status == nfserr_symlink)
		status = nfserr_inval;
	return status;
}

/* This routine never returns NFS_OK!  If there are no other errors, it
 * will return NFSERR_SAME or NFSERR_NOT_SAME depending on whether the
 * attributes matched.  VERIFY is implemented by mapping NFSERR_SAME
 * to NFS_OK after the call; NVERIFY by mapping NFSERR_NOT_SAME to NFS_OK.
 */
862
static __be32
863
_nfsd4_verify(struct svc_rqst *rqstp, struct nfsd4_compound_state *cstate,
864
	     struct nfsd4_verify *verify)
L
Linus Torvalds 已提交
865
{
A
Al Viro 已提交
866
	__be32 *buf, *p;
L
Linus Torvalds 已提交
867
	int count;
868
	__be32 status;
L
Linus Torvalds 已提交
869

M
Miklos Szeredi 已提交
870
	status = fh_verify(rqstp, &cstate->current_fh, 0, NFSD_MAY_NOP);
L
Linus Torvalds 已提交
871 872 873
	if (status)
		return status;

874 875 876 877
	status = check_attr_support(rqstp, cstate, verify->ve_bmval, NULL);
	if (status)
		return status;

L
Linus Torvalds 已提交
878 879 880 881 882 883 884 885 886 887 888 889 890 891
	if ((verify->ve_bmval[0] & FATTR4_WORD0_RDATTR_ERROR)
	    || (verify->ve_bmval[1] & NFSD_WRITEONLY_ATTRS_WORD1))
		return nfserr_inval;
	if (verify->ve_attrlen & 3)
		return nfserr_inval;

	/* count in words:
	 *   bitmap_len(1) + bitmap(2) + attr_len(1) = 4
	 */
	count = 4 + (verify->ve_attrlen >> 2);
	buf = kmalloc(count << 2, GFP_KERNEL);
	if (!buf)
		return nfserr_resource;

892 893 894
	status = nfsd4_encode_fattr(&cstate->current_fh,
				    cstate->current_fh.fh_export,
				    cstate->current_fh.fh_dentry, buf,
L
Linus Torvalds 已提交
895
				    &count, verify->ve_bmval,
896
				    rqstp, 0);
L
Linus Torvalds 已提交
897 898 899 900 901 902 903

	/* this means that nfsd4_encode_fattr() ran out of space */
	if (status == nfserr_resource && count == 0)
		status = nfserr_not_same;
	if (status)
		goto out_kfree;

904 905
	/* skip bitmap */
	p = buf + 1 + ntohl(buf[0]);
L
Linus Torvalds 已提交
906 907 908 909 910 911 912 913 914 915 916
	status = nfserr_not_same;
	if (ntohl(*p++) != verify->ve_attrlen)
		goto out_kfree;
	if (!memcmp(p, verify->ve_attrval, verify->ve_attrlen))
		status = nfserr_same;

out_kfree:
	kfree(buf);
	return status;
}

917 918 919 920 921 922 923 924 925 926 927 928 929 930 931 932 933 934 935 936
static __be32
nfsd4_nverify(struct svc_rqst *rqstp, struct nfsd4_compound_state *cstate,
	      struct nfsd4_verify *verify)
{
	__be32 status;

	status = _nfsd4_verify(rqstp, cstate, verify);
	return status == nfserr_not_same ? nfs_ok : status;
}

static __be32
nfsd4_verify(struct svc_rqst *rqstp, struct nfsd4_compound_state *cstate,
	     struct nfsd4_verify *verify)
{
	__be32 status;

	status = _nfsd4_verify(rqstp, cstate, verify);
	return status == nfserr_same ? nfs_ok : status;
}

L
Linus Torvalds 已提交
937 938 939
/*
 * NULL call.
 */
A
Al Viro 已提交
940
static __be32
L
Linus Torvalds 已提交
941 942 943 944 945
nfsd4_proc_null(struct svc_rqst *rqstp, void *argp, void *resp)
{
	return nfs_ok;
}

946 947 948 949 950 951
static inline void nfsd4_increment_op_stats(u32 opnum)
{
	if (opnum >= FIRST_NFS4_OP && opnum <= LAST_NFS4_OP)
		nfsdstats.nfs4_opcount[opnum]++;
}

952 953
typedef __be32(*nfsd4op_func)(struct svc_rqst *, struct nfsd4_compound_state *,
			      void *);
954 955 956 957 958
enum nfsd4_op_flags {
	ALLOWED_WITHOUT_FH = 1 << 0,	/* No current filehandle required */
	ALLOWED_ON_ABSENT_FS = 2 << 0,	/* ops processed on absent fs */
	ALLOWED_AS_FIRST_OP = 3 << 0,	/* ops reqired first in compound */
};
959 960 961 962

struct nfsd4_operation {
	nfsd4op_func op_func;
	u32 op_flags;
B
Benny Halevy 已提交
963
	char *op_name;
964 965 966 967
};

static struct nfsd4_operation nfsd4_ops[];

A
Adrian Bunk 已提交
968
static const char *nfsd4_op_name(unsigned opnum);
B
Benny Halevy 已提交
969

970
/*
971
 * Enforce NFSv4.1 COMPOUND ordering rules:
972
 *
973 974 975 976 977 978 979 980
 * Also note, enforced elsewhere:
 *	- SEQUENCE other than as first op results in
 *	  NFS4ERR_SEQUENCE_POS. (Enforced in nfsd4_sequence().)
 *	- BIND_CONN_TO_SESSION must be the only op in its compound
 *	  (Will be enforced in nfsd4_bind_conn_to_session().)
 *	- DESTROY_SESSION must be the final operation in a compound, if
 *	  sessionid's in SEQUENCE and DESTROY_SESSION are the same.
 *	  (Enforced in nfsd4_destroy_session().)
981
 */
982
static __be32 nfs41_check_op_ordering(struct nfsd4_compoundargs *args)
983
{
984 985 986 987 988 989 990 991 992 993 994 995 996 997 998 999 1000
	struct nfsd4_op *op = &args->ops[0];

	/* These ordering requirements don't apply to NFSv4.0: */
	if (args->minorversion == 0)
		return nfs_ok;
	/* This is weird, but OK, not our problem: */
	if (args->opcnt == 0)
		return nfs_ok;
	if (op->status == nfserr_op_illegal)
		return nfs_ok;
	if (!(nfsd4_ops[op->opnum].op_flags & ALLOWED_AS_FIRST_OP))
		return nfserr_op_not_in_session;
	if (op->opnum == OP_SEQUENCE)
		return nfs_ok;
	if (args->opcnt != 1)
		return nfserr_not_only_op;
	return nfs_ok;
1001 1002
}

L
Linus Torvalds 已提交
1003 1004 1005
/*
 * COMPOUND call.
 */
A
Al Viro 已提交
1006
static __be32
L
Linus Torvalds 已提交
1007 1008 1009 1010 1011
nfsd4_proc_compound(struct svc_rqst *rqstp,
		    struct nfsd4_compoundargs *args,
		    struct nfsd4_compoundres *resp)
{
	struct nfsd4_op	*op;
1012
	struct nfsd4_operation *opdesc;
1013
	struct nfsd4_compound_state *cstate = &resp->cstate;
1014
	int		slack_bytes;
1015
	__be32		status;
L
Linus Torvalds 已提交
1016 1017

	resp->xbuf = &rqstp->rq_res;
1018 1019
	resp->p = rqstp->rq_res.head[0].iov_base +
						rqstp->rq_res.head[0].iov_len;
L
Linus Torvalds 已提交
1020 1021 1022 1023 1024 1025 1026 1027
	resp->tagp = resp->p;
	/* reserve space for: taglen, tag, and opcnt */
	resp->p += 2 + XDR_QUADLEN(args->taglen);
	resp->end = rqstp->rq_res.head[0].iov_base + PAGE_SIZE;
	resp->taglen = args->taglen;
	resp->tag = args->tag;
	resp->opcnt = 0;
	resp->rqstp = rqstp;
A
Andy Adamson 已提交
1028
	resp->cstate.minorversion = args->minorversion;
1029
	resp->cstate.replay_owner = NULL;
1030
	resp->cstate.session = NULL;
1031 1032
	fh_init(&resp->cstate.current_fh, NFS4_FHSIZE);
	fh_init(&resp->cstate.save_fh, NFS4_FHSIZE);
1033 1034
	/* Use the deferral mechanism only for NFSv4.0 compounds */
	rqstp->rq_usedeferral = (args->minorversion == 0);
L
Linus Torvalds 已提交
1035 1036 1037 1038 1039

	/*
	 * According to RFC3010, this takes precedence over all other errors.
	 */
	status = nfserr_minor_vers_mismatch;
1040
	if (args->minorversion > nfsd_supported_minorversion)
L
Linus Torvalds 已提交
1041 1042
		goto out;

1043 1044
	status = nfs41_check_op_ordering(args);
	if (status) {
1045
		op = &args->ops[0];
1046
		op->status = status;
1047 1048 1049
		goto encode_op;
	}

L
Linus Torvalds 已提交
1050 1051 1052
	while (!status && resp->opcnt < args->opcnt) {
		op = &args->ops[resp->opcnt++];

B
Benny Halevy 已提交
1053 1054 1055
		dprintk("nfsv4 compound op #%d/%d: %d (%s)\n",
			resp->opcnt, args->opcnt, op->opnum,
			nfsd4_op_name(op->opnum));
L
Linus Torvalds 已提交
1056 1057 1058 1059 1060 1061 1062 1063 1064 1065 1066 1067 1068
		/*
		 * The XDR decode routines may have pre-set op->status;
		 * for example, if there is a miscellaneous XDR error
		 * it will be set to nfserr_bad_xdr.
		 */
		if (op->status)
			goto encode_op;

		/* We must be able to encode a successful response to
		 * this operation, with enough room left over to encode a
		 * failed response to the next operation.  If we don't
		 * have enough room, fail with ERR_RESOURCE.
		 */
1069 1070 1071 1072
		slack_bytes = (char *)resp->end - (char *)resp->p;
		if (slack_bytes < COMPOUND_SLACK_SPACE
				+ COMPOUND_ERR_SLACK_SPACE) {
			BUG_ON(slack_bytes < COMPOUND_ERR_SLACK_SPACE);
L
Linus Torvalds 已提交
1073 1074 1075 1076
			op->status = nfserr_resource;
			goto encode_op;
		}

1077 1078
		opdesc = &nfsd4_ops[op->opnum];

1079
		if (!cstate->current_fh.fh_dentry) {
1080
			if (!(opdesc->op_flags & ALLOWED_WITHOUT_FH)) {
1081 1082 1083
				op->status = nfserr_nofilehandle;
				goto encode_op;
			}
1084 1085
		} else if (cstate->current_fh.fh_export->ex_fslocs.migrated &&
			  !(opdesc->op_flags & ALLOWED_ON_ABSENT_FS)) {
1086
			op->status = nfserr_moved;
L
Linus Torvalds 已提交
1087 1088
			goto encode_op;
		}
1089 1090 1091 1092

		if (opdesc->op_func)
			op->status = opdesc->op_func(rqstp, cstate, &op->u);
		else
L
Linus Torvalds 已提交
1093 1094 1095
			BUG_ON(op->status == nfs_ok);

encode_op:
1096
		/* Only from SEQUENCE */
A
Andy Adamson 已提交
1097 1098
		if (resp->cstate.status == nfserr_replay_cache) {
			dprintk("%s NFS4.1 replay from cache\n", __func__);
1099
			status = op->status;
A
Andy Adamson 已提交
1100 1101
			goto out;
		}
A
Al Viro 已提交
1102
		if (op->status == nfserr_replay_me) {
1103
			op->replay = &cstate->replay_owner->so_replay;
L
Linus Torvalds 已提交
1104 1105 1106 1107 1108 1109
			nfsd4_encode_replay(resp, op);
			status = op->status = op->replay->rp_status;
		} else {
			nfsd4_encode_operation(resp, op);
			status = op->status;
		}
1110 1111 1112 1113 1114

		dprintk("nfsv4 compound op %p opcnt %d #%d: %d: status %d\n",
			args->ops, args->opcnt, resp->opcnt, op->opnum,
			be32_to_cpu(status));

1115 1116 1117
		if (cstate->replay_owner) {
			nfs4_put_stateowner(cstate->replay_owner);
			cstate->replay_owner = NULL;
L
Linus Torvalds 已提交
1118
		}
1119 1120 1121
		/* XXX Ugh, we need to get rid of this kind of special case: */
		if (op->opnum == OP_READ && op->u.read.rd_filp)
			fput(op->u.read.rd_filp);
1122 1123

		nfsd4_increment_op_stats(op->opnum);
L
Linus Torvalds 已提交
1124
	}
1125 1126 1127 1128
	if (!rqstp->rq_usedeferral && status == nfserr_dropit) {
		dprintk("%s Dropit - send NFS4ERR_DELAY\n", __func__);
		status = nfserr_jukebox;
	}
L
Linus Torvalds 已提交
1129

A
Andy Adamson 已提交
1130
	resp->cstate.status = status;
1131 1132 1133
	fh_put(&resp->cstate.current_fh);
	fh_put(&resp->cstate.save_fh);
	BUG_ON(resp->cstate.replay_owner);
L
Linus Torvalds 已提交
1134 1135
out:
	nfsd4_release_compoundargs(args);
1136 1137
	/* Reset deferral mechanism for RPC deferrals */
	rqstp->rq_usedeferral = 1;
1138
	dprintk("nfsv4 compound returned %d\n", ntohl(status));
L
Linus Torvalds 已提交
1139 1140 1141
	return status;
}

B
Benny Halevy 已提交
1142
static struct nfsd4_operation nfsd4_ops[] = {
1143 1144
	[OP_ACCESS] = {
		.op_func = (nfsd4op_func)nfsd4_access,
B
Benny Halevy 已提交
1145
		.op_name = "OP_ACCESS",
1146 1147 1148
	},
	[OP_CLOSE] = {
		.op_func = (nfsd4op_func)nfsd4_close,
B
Benny Halevy 已提交
1149
		.op_name = "OP_CLOSE",
1150 1151 1152
	},
	[OP_COMMIT] = {
		.op_func = (nfsd4op_func)nfsd4_commit,
B
Benny Halevy 已提交
1153
		.op_name = "OP_COMMIT",
1154 1155 1156
	},
	[OP_CREATE] = {
		.op_func = (nfsd4op_func)nfsd4_create,
B
Benny Halevy 已提交
1157
		.op_name = "OP_CREATE",
1158 1159 1160
	},
	[OP_DELEGRETURN] = {
		.op_func = (nfsd4op_func)nfsd4_delegreturn,
B
Benny Halevy 已提交
1161
		.op_name = "OP_DELEGRETURN",
1162 1163 1164
	},
	[OP_GETATTR] = {
		.op_func = (nfsd4op_func)nfsd4_getattr,
1165
		.op_flags = ALLOWED_ON_ABSENT_FS,
B
Benny Halevy 已提交
1166
		.op_name = "OP_GETATTR",
1167 1168 1169
	},
	[OP_GETFH] = {
		.op_func = (nfsd4op_func)nfsd4_getfh,
B
Benny Halevy 已提交
1170
		.op_name = "OP_GETFH",
1171 1172 1173
	},
	[OP_LINK] = {
		.op_func = (nfsd4op_func)nfsd4_link,
B
Benny Halevy 已提交
1174
		.op_name = "OP_LINK",
1175 1176 1177
	},
	[OP_LOCK] = {
		.op_func = (nfsd4op_func)nfsd4_lock,
B
Benny Halevy 已提交
1178
		.op_name = "OP_LOCK",
1179 1180 1181
	},
	[OP_LOCKT] = {
		.op_func = (nfsd4op_func)nfsd4_lockt,
B
Benny Halevy 已提交
1182
		.op_name = "OP_LOCKT",
1183 1184 1185
	},
	[OP_LOCKU] = {
		.op_func = (nfsd4op_func)nfsd4_locku,
B
Benny Halevy 已提交
1186
		.op_name = "OP_LOCKU",
1187 1188 1189
	},
	[OP_LOOKUP] = {
		.op_func = (nfsd4op_func)nfsd4_lookup,
B
Benny Halevy 已提交
1190
		.op_name = "OP_LOOKUP",
1191 1192 1193
	},
	[OP_LOOKUPP] = {
		.op_func = (nfsd4op_func)nfsd4_lookupp,
B
Benny Halevy 已提交
1194
		.op_name = "OP_LOOKUPP",
1195 1196 1197
	},
	[OP_NVERIFY] = {
		.op_func = (nfsd4op_func)nfsd4_nverify,
B
Benny Halevy 已提交
1198
		.op_name = "OP_NVERIFY",
1199 1200 1201
	},
	[OP_OPEN] = {
		.op_func = (nfsd4op_func)nfsd4_open,
B
Benny Halevy 已提交
1202
		.op_name = "OP_OPEN",
1203 1204 1205
	},
	[OP_OPEN_CONFIRM] = {
		.op_func = (nfsd4op_func)nfsd4_open_confirm,
B
Benny Halevy 已提交
1206
		.op_name = "OP_OPEN_CONFIRM",
1207 1208 1209
	},
	[OP_OPEN_DOWNGRADE] = {
		.op_func = (nfsd4op_func)nfsd4_open_downgrade,
B
Benny Halevy 已提交
1210
		.op_name = "OP_OPEN_DOWNGRADE",
1211 1212 1213
	},
	[OP_PUTFH] = {
		.op_func = (nfsd4op_func)nfsd4_putfh,
1214
		.op_flags = ALLOWED_WITHOUT_FH | ALLOWED_ON_ABSENT_FS,
B
Benny Halevy 已提交
1215
		.op_name = "OP_PUTFH",
1216
	},
1217
	[OP_PUTPUBFH] = {
1218
		.op_func = (nfsd4op_func)nfsd4_putrootfh,
1219
		.op_flags = ALLOWED_WITHOUT_FH | ALLOWED_ON_ABSENT_FS,
B
Benny Halevy 已提交
1220
		.op_name = "OP_PUTPUBFH",
1221
	},
1222 1223
	[OP_PUTROOTFH] = {
		.op_func = (nfsd4op_func)nfsd4_putrootfh,
1224
		.op_flags = ALLOWED_WITHOUT_FH | ALLOWED_ON_ABSENT_FS,
B
Benny Halevy 已提交
1225
		.op_name = "OP_PUTROOTFH",
1226 1227 1228
	},
	[OP_READ] = {
		.op_func = (nfsd4op_func)nfsd4_read,
B
Benny Halevy 已提交
1229
		.op_name = "OP_READ",
1230 1231 1232
	},
	[OP_READDIR] = {
		.op_func = (nfsd4op_func)nfsd4_readdir,
B
Benny Halevy 已提交
1233
		.op_name = "OP_READDIR",
1234 1235 1236
	},
	[OP_READLINK] = {
		.op_func = (nfsd4op_func)nfsd4_readlink,
B
Benny Halevy 已提交
1237
		.op_name = "OP_READLINK",
1238 1239 1240
	},
	[OP_REMOVE] = {
		.op_func = (nfsd4op_func)nfsd4_remove,
B
Benny Halevy 已提交
1241
		.op_name = "OP_REMOVE",
1242 1243
	},
	[OP_RENAME] = {
B
Benny Halevy 已提交
1244
		.op_name = "OP_RENAME",
1245 1246 1247 1248
		.op_func = (nfsd4op_func)nfsd4_rename,
	},
	[OP_RENEW] = {
		.op_func = (nfsd4op_func)nfsd4_renew,
1249
		.op_flags = ALLOWED_WITHOUT_FH | ALLOWED_ON_ABSENT_FS,
B
Benny Halevy 已提交
1250
		.op_name = "OP_RENEW",
1251 1252 1253
	},
	[OP_RESTOREFH] = {
		.op_func = (nfsd4op_func)nfsd4_restorefh,
1254
		.op_flags = ALLOWED_WITHOUT_FH | ALLOWED_ON_ABSENT_FS,
B
Benny Halevy 已提交
1255
		.op_name = "OP_RESTOREFH",
1256 1257 1258
	},
	[OP_SAVEFH] = {
		.op_func = (nfsd4op_func)nfsd4_savefh,
B
Benny Halevy 已提交
1259
		.op_name = "OP_SAVEFH",
1260
	},
A
Andy Adamson 已提交
1261 1262
	[OP_SECINFO] = {
		.op_func = (nfsd4op_func)nfsd4_secinfo,
B
Benny Halevy 已提交
1263
		.op_name = "OP_SECINFO",
A
Andy Adamson 已提交
1264
	},
1265 1266
	[OP_SETATTR] = {
		.op_func = (nfsd4op_func)nfsd4_setattr,
B
Benny Halevy 已提交
1267
		.op_name = "OP_SETATTR",
1268 1269 1270
	},
	[OP_SETCLIENTID] = {
		.op_func = (nfsd4op_func)nfsd4_setclientid,
1271
		.op_flags = ALLOWED_WITHOUT_FH | ALLOWED_ON_ABSENT_FS,
B
Benny Halevy 已提交
1272
		.op_name = "OP_SETCLIENTID",
1273 1274 1275
	},
	[OP_SETCLIENTID_CONFIRM] = {
		.op_func = (nfsd4op_func)nfsd4_setclientid_confirm,
1276
		.op_flags = ALLOWED_WITHOUT_FH | ALLOWED_ON_ABSENT_FS,
B
Benny Halevy 已提交
1277
		.op_name = "OP_SETCLIENTID_CONFIRM",
1278 1279 1280
	},
	[OP_VERIFY] = {
		.op_func = (nfsd4op_func)nfsd4_verify,
B
Benny Halevy 已提交
1281
		.op_name = "OP_VERIFY",
1282 1283 1284
	},
	[OP_WRITE] = {
		.op_func = (nfsd4op_func)nfsd4_write,
B
Benny Halevy 已提交
1285
		.op_name = "OP_WRITE",
1286 1287 1288
	},
	[OP_RELEASE_LOCKOWNER] = {
		.op_func = (nfsd4op_func)nfsd4_release_lockowner,
1289
		.op_flags = ALLOWED_WITHOUT_FH | ALLOWED_ON_ABSENT_FS,
B
Benny Halevy 已提交
1290
		.op_name = "OP_RELEASE_LOCKOWNER",
1291
	},
A
Andy Adamson 已提交
1292 1293 1294 1295

	/* NFSv4.1 operations */
	[OP_EXCHANGE_ID] = {
		.op_func = (nfsd4op_func)nfsd4_exchange_id,
1296
		.op_flags = ALLOWED_WITHOUT_FH | ALLOWED_AS_FIRST_OP,
A
Andy Adamson 已提交
1297 1298 1299 1300
		.op_name = "OP_EXCHANGE_ID",
	},
	[OP_CREATE_SESSION] = {
		.op_func = (nfsd4op_func)nfsd4_create_session,
1301
		.op_flags = ALLOWED_WITHOUT_FH | ALLOWED_AS_FIRST_OP,
A
Andy Adamson 已提交
1302 1303 1304 1305
		.op_name = "OP_CREATE_SESSION",
	},
	[OP_DESTROY_SESSION] = {
		.op_func = (nfsd4op_func)nfsd4_destroy_session,
1306
		.op_flags = ALLOWED_WITHOUT_FH | ALLOWED_AS_FIRST_OP,
A
Andy Adamson 已提交
1307 1308 1309 1310
		.op_name = "OP_DESTROY_SESSION",
	},
	[OP_SEQUENCE] = {
		.op_func = (nfsd4op_func)nfsd4_sequence,
1311
		.op_flags = ALLOWED_WITHOUT_FH | ALLOWED_AS_FIRST_OP,
A
Andy Adamson 已提交
1312 1313
		.op_name = "OP_SEQUENCE",
	},
1314 1315
};

A
Adrian Bunk 已提交
1316
static const char *nfsd4_op_name(unsigned opnum)
B
Benny Halevy 已提交
1317 1318 1319 1320 1321 1322
{
	if (opnum < ARRAY_SIZE(nfsd4_ops))
		return nfsd4_ops[opnum].op_name;
	return "unknown_operation";
}

L
Linus Torvalds 已提交
1323 1324 1325 1326 1327 1328 1329 1330 1331 1332 1333 1334 1335 1336
#define nfsd4_voidres			nfsd4_voidargs
struct nfsd4_voidargs { int dummy; };

/*
 * TODO: At the present time, the NFSv4 server does not do XID caching
 * of requests.  Implementing XID caching would not be a serious problem,
 * although it would require a mild change in interfaces since one
 * doesn't know whether an NFSv4 request is idempotent until after the
 * XDR decode.  However, XID caching totally confuses pynfs (Peter
 * Astrand's regression testsuite for NFSv4 servers), which reuses
 * XID's liberally, so I've left it unimplemented until pynfs generates
 * better XID's.
 */
static struct svc_procedure		nfsd_procedures4[2] = {
1337 1338 1339 1340 1341 1342 1343 1344 1345 1346 1347 1348 1349 1350 1351 1352 1353
	[NFSPROC4_NULL] = {
		.pc_func = (svc_procfunc) nfsd4_proc_null,
		.pc_encode = (kxdrproc_t) nfs4svc_encode_voidres,
		.pc_argsize = sizeof(struct nfsd4_voidargs),
		.pc_ressize = sizeof(struct nfsd4_voidres),
		.pc_cachetype = RC_NOCACHE,
		.pc_xdrressize = 1,
	},
	[NFSPROC4_COMPOUND] = {
		.pc_func = (svc_procfunc) nfsd4_proc_compound,
		.pc_decode = (kxdrproc_t) nfs4svc_decode_compoundargs,
		.pc_encode = (kxdrproc_t) nfs4svc_encode_compoundres,
		.pc_argsize = sizeof(struct nfsd4_compoundargs),
		.pc_ressize = sizeof(struct nfsd4_compoundres),
		.pc_cachetype = RC_NOCACHE,
		.pc_xdrressize = NFSD_BUFSIZE/4,
	},
L
Linus Torvalds 已提交
1354 1355 1356 1357 1358 1359 1360 1361 1362 1363 1364 1365 1366 1367 1368
};

struct svc_version	nfsd_version4 = {
		.vs_vers	= 4,
		.vs_nproc	= 2,
		.vs_proc	= nfsd_procedures4,
		.vs_dispatch	= nfsd_dispatch,
		.vs_xdrsize	= NFS4_SVC_XDRSIZE,
};

/*
 * Local variables:
 *  c-basic-offset: 8
 * End:
 */