nfs4proc.c 66.2 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>
A
Anna Schumaker 已提交
36
#include <linux/falloc.h>
37
#include <linux/slab.h>
L
Linus Torvalds 已提交
38

39
#include "idmap.h"
40 41
#include "cache.h"
#include "xdr4.h"
42
#include "vfs.h"
43
#include "current_stateid.h"
44
#include "netns.h"
45
#include "acl.h"
46
#include "pnfs.h"
C
Christoph Hellwig 已提交
47
#include "trace.h"
L
Linus Torvalds 已提交
48

49 50 51 52 53 54
#ifdef CONFIG_NFSD_V4_SECURITY_LABEL
#include <linux/security.h>

static inline void
nfsd4_security_inode_setsecctx(struct svc_fh *resfh, struct xdr_netobj *label, u32 *bmval)
{
55
	struct inode *inode = d_inode(resfh->fh_dentry);
56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78
	int status;

	mutex_lock(&inode->i_mutex);
	status = security_inode_setsecctx(resfh->fh_dentry,
		label->data, label->len);
	mutex_unlock(&inode->i_mutex);

	if (status)
		/*
		 * XXX: We should really fail the whole open, but we may
		 * already have created a new file, so it may be too
		 * late.  For now this seems the least of evils:
		 */
		bmval[2] &= ~FATTR4_WORD2_SECURITY_LABEL;

	return;
}
#else
static inline void
nfsd4_security_inode_setsecctx(struct svc_fh *resfh, struct xdr_netobj *label, u32 *bmval)
{ }
#endif

L
Linus Torvalds 已提交
79 80
#define NFSDDBG_FACILITY		NFSDDBG_PROC

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
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;

	/*
109
	 * Check FATTR4_WORD0_ACL can be supported
110 111 112
	 * in current environment or not.
	 */
	if (bmval[0] & FATTR4_WORD0_ACL) {
113
		if (!IS_POSIXACL(d_inode(dentry)))
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 139 140 141 142 143 144 145 146 147
			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;
}

148 149 150 151 152 153 154 155 156 157 158 159 160 161 162 163 164 165 166 167 168 169 170 171 172 173 174 175 176
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 已提交
177 178 179 180 181 182
static inline void
fh_dup2(struct svc_fh *dst, struct svc_fh *src)
{
	fh_put(dst);
	dget(src->fh_dentry);
	if (src->fh_export)
183
		exp_get(src->fh_export);
L
Linus Torvalds 已提交
184 185 186
	*dst = *src;
}

187
static __be32
188
do_open_permission(struct svc_rqst *rqstp, struct svc_fh *current_fh, struct nfsd4_open *open, int accmode)
L
Linus Torvalds 已提交
189
{
190
	__be32 status;
L
Linus Torvalds 已提交
191 192 193 194 195

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

196 197
	accmode |= NFSD_MAY_READ_IF_EXEC;

L
Linus Torvalds 已提交
198
	if (open->op_share_access & NFS4_SHARE_ACCESS_READ)
M
Miklos Szeredi 已提交
199
		accmode |= NFSD_MAY_READ;
200
	if (open->op_share_access & NFS4_SHARE_ACCESS_WRITE)
M
Miklos Szeredi 已提交
201
		accmode |= (NFSD_MAY_WRITE | NFSD_MAY_TRUNC);
202
	if (open->op_share_deny & NFS4_SHARE_DENY_READ)
M
Miklos Szeredi 已提交
203
		accmode |= NFSD_MAY_WRITE;
L
Linus Torvalds 已提交
204 205 206 207 208 209

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

	return status;
}

210 211
static __be32 nfsd_check_obj_isreg(struct svc_fh *fh)
{
212
	umode_t mode = d_inode(fh->fh_dentry)->i_mode;
213 214 215 216 217 218 219 220 221 222 223 224 225 226 227

	if (S_ISREG(mode))
		return nfs_ok;
	if (S_ISDIR(mode))
		return nfserr_isdir;
	/*
	 * Using err_symlink as our catch-all case may look odd; but
	 * there's no other obvious error for this case in 4.0, and we
	 * happen to know that it will cause the linux v4 client to do
	 * the right thing on attempts to open something other than a
	 * regular file.
	 */
	return nfserr_symlink;
}

228 229 230 231 232 233 234 235
static void nfsd4_set_open_owner_reply_cache(struct nfsd4_compound_state *cstate, struct nfsd4_open *open, struct svc_fh *resfh)
{
	if (nfsd4_has_session(cstate))
		return;
	fh_copy_shallow(&open->op_openowner->oo_owner.so_replay.rp_openfh,
			&resfh->fh_handle);
}

236
static __be32
237
do_open_lookup(struct svc_rqst *rqstp, struct nfsd4_compound_state *cstate, struct nfsd4_open *open, struct svc_fh **resfh)
L
Linus Torvalds 已提交
238
{
239
	struct svc_fh *current_fh = &cstate->current_fh;
240
	int accmode;
241
	__be32 status;
L
Linus Torvalds 已提交
242

243 244
	*resfh = kmalloc(sizeof(struct svc_fh), GFP_KERNEL);
	if (!*resfh)
245
		return nfserr_jukebox;
246
	fh_init(*resfh, NFS4_FHSIZE);
L
Linus Torvalds 已提交
247 248 249
	open->op_truncate = 0;

	if (open->op_create) {
B
Benny Halevy 已提交
250 251 252 253 254 255 256 257 258 259 260 261 262 263 264
		/* 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 已提交
265 266
		/*
		 * Note: create modes (UNCHECKED,GUARDED...) are the same
267
		 * in NFSv4 as in v3 except EXCLUSIVE4_1.
L
Linus Torvalds 已提交
268
		 */
269
		status = do_nfsd_create(rqstp, current_fh, open->op_fname.data,
L
Linus Torvalds 已提交
270
					open->op_fname.len, &open->op_iattr,
271
					*resfh, open->op_createmode,
272
					(u32 *)open->op_verf.data,
273
					&open->op_truncate, &open->op_created);
274

275
		if (!status && open->op_label.len)
276
			nfsd4_security_inode_setsecctx(*resfh, &open->op_label, open->op_bmval);
277

278 279 280 281
		/*
		 * Following rfc 3530 14.2.16, use the returned bitmask
		 * to indicate which attributes we used to store the
		 * verifier:
282 283
		 */
		if (open->op_createmode == NFS4_CREATE_EXCLUSIVE && status == 0)
284
			open->op_bmval[1] = (FATTR4_WORD1_TIME_ACCESS |
285
							FATTR4_WORD1_TIME_MODIFY);
286 287 288 289 290 291 292
	} else
		/*
		 * Note this may exit with the parent still locked.
		 * We will hold the lock until nfsd4_open's final
		 * lookup, to prevent renames or unlinks until we've had
		 * a chance to an acquire a delegation if appropriate.
		 */
L
Linus Torvalds 已提交
293
		status = nfsd_lookup(rqstp, current_fh,
294
				     open->op_fname.data, open->op_fname.len, *resfh);
295 296
	if (status)
		goto out;
297
	status = nfsd_check_obj_isreg(*resfh);
298 299
	if (status)
		goto out;
L
Linus Torvalds 已提交
300

301
	if (is_create_with_attrs(open) && open->op_acl != NULL)
302
		do_set_nfs4_acl(rqstp, *resfh, open->op_acl, open->op_bmval);
303

304
	nfsd4_set_open_owner_reply_cache(cstate, open, *resfh);
305
	accmode = NFSD_MAY_NOP;
306 307
	if (open->op_created ||
			open->op_claim_type == NFS4_OPEN_CLAIM_DELEGATE_CUR)
308
		accmode |= NFSD_MAY_OWNER_OVERRIDE;
309
	status = do_open_permission(rqstp, *resfh, open, accmode);
310
	set_change_info(&open->op_cinfo, current_fh);
311
out:
L
Linus Torvalds 已提交
312 313 314
	return status;
}

315
static __be32
316
do_open_fhandle(struct svc_rqst *rqstp, struct nfsd4_compound_state *cstate, struct nfsd4_open *open)
L
Linus Torvalds 已提交
317
{
318
	struct svc_fh *current_fh = &cstate->current_fh;
319
	__be32 status;
320
	int accmode = 0;
L
Linus Torvalds 已提交
321 322 323 324 325 326 327

	/* 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));

328
	nfsd4_set_open_owner_reply_cache(cstate, open, current_fh);
L
Linus Torvalds 已提交
329 330 331

	open->op_truncate = (open->op_iattr.ia_valid & ATTR_SIZE) &&
		(open->op_iattr.ia_size == 0);
332 333 334 335 336 337 338 339 340 341 342
	/*
	 * In the delegation case, the client is telling us about an
	 * open that it *already* performed locally, some time ago.  We
	 * should let it succeed now if possible.
	 *
	 * In the case of a CLAIM_FH open, on the other hand, the client
	 * may be counting on us to enforce permissions (the Linux 4.1
	 * client uses this for normal opens, for example).
	 */
	if (open->op_claim_type == NFS4_OPEN_CLAIM_DELEG_CUR_FH)
		accmode = NFSD_MAY_OWNER_OVERRIDE;
L
Linus Torvalds 已提交
343

344
	status = do_open_permission(rqstp, current_fh, open, accmode);
L
Linus Torvalds 已提交
345 346 347 348

	return status;
}

A
Andy Adamson 已提交
349 350 351 352 353 354 355 356 357
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 已提交
358

359
static __be32
360
nfsd4_open(struct svc_rqst *rqstp, struct nfsd4_compound_state *cstate,
361
	   struct nfsd4_open *open)
L
Linus Torvalds 已提交
362
{
363
	__be32 status;
364
	struct svc_fh *resfh = NULL;
A
Andy Adamson 已提交
365
	struct nfsd4_compoundres *resp;
366 367
	struct net *net = SVC_NET(rqstp);
	struct nfsd_net *nn = net_generic(net, nfsd_net_id);
A
Andy Adamson 已提交
368

369
	dprintk("NFSD: nfsd4_open filename %.*s op_openowner %p\n",
L
Linus Torvalds 已提交
370
		(int)open->op_fname.len, open->op_fname.data,
371
		open->op_openowner);
L
Linus Torvalds 已提交
372 373 374 375 376

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

377
	open->op_created = 0;
378 379 380 381 382
	/*
	 * RFC5661 18.51.3
	 * Before RECLAIM_COMPLETE done, server should deny new lock
	 */
	if (nfsd4_has_session(cstate) &&
383 384
	    !test_bit(NFSD4_CLIENT_RECLAIM_COMPLETE,
		      &cstate->session->se_client->cl_flags) &&
385 386 387
	    open->op_claim_type != NFS4_OPEN_CLAIM_PREVIOUS)
		return nfserr_grace;

A
Andy Adamson 已提交
388 389 390
	if (nfsd4_has_session(cstate))
		copy_clientid(&open->op_clientid, cstate->session);

L
Linus Torvalds 已提交
391
	/* check seqid for replay. set nfs4_owner */
A
Andy Adamson 已提交
392
	resp = rqstp->rq_resp;
393
	status = nfsd4_process_open1(&resp->cstate, open, nn);
A
Al Viro 已提交
394
	if (status == nfserr_replay_me) {
395
		struct nfs4_replay *rp = &open->op_openowner->oo_owner.so_replay;
396
		fh_put(&cstate->current_fh);
397 398
		fh_copy_shallow(&cstate->current_fh.fh_handle,
				&rp->rp_openfh);
M
Miklos Szeredi 已提交
399
		status = fh_verify(rqstp, &cstate->current_fh, 0, NFSD_MAY_NOP);
L
Linus Torvalds 已提交
400 401 402 403
		if (status)
			dprintk("nfsd4_open: replay failed"
				" restoring previous filehandle\n");
		else
A
Al Viro 已提交
404
			status = nfserr_replay_me;
L
Linus Torvalds 已提交
405 406 407
	}
	if (status)
		goto out;
408 409 410 411
	if (open->op_xdr_error) {
		status = open->op_xdr_error;
		goto out;
	}
412

413 414 415 416
	status = nfsd4_check_open_attributes(rqstp, cstate, open);
	if (status)
		goto out;

417 418
	/* Openowner is now set, so sequence id will get bumped.  Now we need
	 * these checks before we do any creates: */
419
	status = nfserr_grace;
420
	if (locks_in_grace(net) && open->op_claim_type != NFS4_OPEN_CLAIM_PREVIOUS)
421 422
		goto out;
	status = nfserr_no_grace;
423
	if (!locks_in_grace(net) && open->op_claim_type == NFS4_OPEN_CLAIM_PREVIOUS)
424
		goto out;
425

L
Linus Torvalds 已提交
426
	switch (open->op_claim_type) {
427
		case NFS4_OPEN_CLAIM_DELEGATE_CUR:
L
Linus Torvalds 已提交
428
		case NFS4_OPEN_CLAIM_NULL:
429
			status = do_open_lookup(rqstp, cstate, open, &resfh);
L
Linus Torvalds 已提交
430 431 432 433
			if (status)
				goto out;
			break;
		case NFS4_OPEN_CLAIM_PREVIOUS:
434
			status = nfs4_check_open_reclaim(&open->op_clientid,
435
							 cstate, nn);
436 437
			if (status)
				goto out;
438
			open->op_openowner->oo_flags |= NFS4_OO_CONFIRMED;
439 440
		case NFS4_OPEN_CLAIM_FH:
		case NFS4_OPEN_CLAIM_DELEG_CUR_FH:
441
			status = do_open_fhandle(rqstp, cstate, open);
L
Linus Torvalds 已提交
442 443
			if (status)
				goto out;
444
			resfh = &cstate->current_fh;
L
Linus Torvalds 已提交
445
			break;
446
		case NFS4_OPEN_CLAIM_DELEG_PREV_FH:
L
Linus Torvalds 已提交
447
             	case NFS4_OPEN_CLAIM_DELEGATE_PREV:
448
			dprintk("NFSD: unsupported OPEN claim type %d\n",
L
Linus Torvalds 已提交
449 450 451 452
				open->op_claim_type);
			status = nfserr_notsupp;
			goto out;
		default:
453
			dprintk("NFSD: Invalid OPEN claim type %d\n",
L
Linus Torvalds 已提交
454 455 456 457 458 459 460 461 462
				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.
	 */
463
	status = nfsd4_process_open2(rqstp, resfh, open);
464 465 466
	WARN(status && open->op_created,
	     "nfsd4_process_open2 failed to open newly-created file! status=%u\n",
	     be32_to_cpu(status));
L
Linus Torvalds 已提交
467
out:
468 469 470 471 472
	if (resfh && resfh != &cstate->current_fh) {
		fh_dup2(&cstate->current_fh, resfh);
		fh_put(resfh);
		kfree(resfh);
	}
473
	nfsd4_cleanup_open_state(cstate, open);
474
	nfsd4_bump_seqid(cstate, status);
L
Linus Torvalds 已提交
475 476 477
	return status;
}

478 479 480 481 482 483 484 485 486 487 488 489 490 491 492 493 494 495
/*
 * OPEN is the only seqid-mutating operation whose decoding can fail
 * with a seqid-mutating error (specifically, decoding of user names in
 * the attributes).  Therefore we have to do some processing to look up
 * the stateowner so that we can bump the seqid.
 */
static __be32 nfsd4_open_omfg(struct svc_rqst *rqstp, struct nfsd4_compound_state *cstate, struct nfsd4_op *op)
{
	struct nfsd4_open *open = (struct nfsd4_open *)&op->u;

	if (!seqid_mutating_err(ntohl(op->status)))
		return op->status;
	if (nfsd4_has_session(cstate))
		return op->status;
	open->op_xdr_error = op->status;
	return nfsd4_open(rqstp, cstate, open);
}

L
Linus Torvalds 已提交
496 497 498
/*
 * filehandle-manipulating ops.
 */
499
static __be32
500 501
nfsd4_getfh(struct svc_rqst *rqstp, struct nfsd4_compound_state *cstate,
	    struct svc_fh **getfh)
L
Linus Torvalds 已提交
502
{
503
	if (!cstate->current_fh.fh_dentry)
L
Linus Torvalds 已提交
504 505
		return nfserr_nofilehandle;

506
	*getfh = &cstate->current_fh;
L
Linus Torvalds 已提交
507 508 509
	return nfs_ok;
}

510
static __be32
511 512
nfsd4_putfh(struct svc_rqst *rqstp, struct nfsd4_compound_state *cstate,
	    struct nfsd4_putfh *putfh)
L
Linus Torvalds 已提交
513
{
514 515 516 517
	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);
518
	return fh_verify(rqstp, &cstate->current_fh, 0, NFSD_MAY_BYPASS_GSS);
L
Linus Torvalds 已提交
519 520
}

521
static __be32
522 523
nfsd4_putrootfh(struct svc_rqst *rqstp, struct nfsd4_compound_state *cstate,
		void *arg)
L
Linus Torvalds 已提交
524
{
525
	__be32 status;
L
Linus Torvalds 已提交
526

527
	fh_put(&cstate->current_fh);
528
	status = exp_pseudoroot(rqstp, &cstate->current_fh);
L
Linus Torvalds 已提交
529 530 531
	return status;
}

532
static __be32
533 534
nfsd4_restorefh(struct svc_rqst *rqstp, struct nfsd4_compound_state *cstate,
		void *arg)
L
Linus Torvalds 已提交
535
{
536
	if (!cstate->save_fh.fh_dentry)
L
Linus Torvalds 已提交
537 538
		return nfserr_restorefh;

539
	fh_dup2(&cstate->current_fh, &cstate->save_fh);
540 541 542 543
	if (HAS_STATE_ID(cstate, SAVED_STATE_ID_FLAG)) {
		memcpy(&cstate->current_stateid, &cstate->save_stateid, sizeof(stateid_t));
		SET_STATE_ID(cstate, CURRENT_STATE_ID_FLAG);
	}
L
Linus Torvalds 已提交
544 545 546
	return nfs_ok;
}

547
static __be32
548 549
nfsd4_savefh(struct svc_rqst *rqstp, struct nfsd4_compound_state *cstate,
	     void *arg)
L
Linus Torvalds 已提交
550
{
551
	if (!cstate->current_fh.fh_dentry)
L
Linus Torvalds 已提交
552 553
		return nfserr_nofilehandle;

554
	fh_dup2(&cstate->save_fh, &cstate->current_fh);
555 556 557 558
	if (HAS_STATE_ID(cstate, CURRENT_STATE_ID_FLAG)) {
		memcpy(&cstate->save_stateid, &cstate->current_stateid, sizeof(stateid_t));
		SET_STATE_ID(cstate, SAVED_STATE_ID_FLAG);
	}
L
Linus Torvalds 已提交
559 560 561 562 563 564
	return nfs_ok;
}

/*
 * misc nfsv4 ops
 */
565
static __be32
566 567
nfsd4_access(struct svc_rqst *rqstp, struct nfsd4_compound_state *cstate,
	     struct nfsd4_access *access)
L
Linus Torvalds 已提交
568 569 570 571 572
{
	if (access->ac_req_access & ~NFS3_ACCESS_FULL)
		return nfserr_inval;

	access->ac_resp_access = access->ac_req_access;
573 574
	return nfsd_access(rqstp, &cstate->current_fh, &access->ac_resp_access,
			   &access->ac_supported);
L
Linus Torvalds 已提交
575 576
}

577
static void gen_boot_verifier(nfs4_verifier *verifier, struct net *net)
578 579
{
	__be32 verf[2];
580
	struct nfsd_net *nn = net_generic(net, nfsd_net_id);
581

582 583 584 585 586 587
	/*
	 * This is opaque to client, so no need to byte-swap. Use
	 * __force to keep sparse happy
	 */
	verf[0] = (__force __be32)nn->nfssvc_boot.tv_sec;
	verf[1] = (__force __be32)nn->nfssvc_boot.tv_usec;
588 589 590
	memcpy(verifier->data, verf, sizeof(verifier->data));
}

591
static __be32
592 593
nfsd4_commit(struct svc_rqst *rqstp, struct nfsd4_compound_state *cstate,
	     struct nfsd4_commit *commit)
L
Linus Torvalds 已提交
594
{
595
	gen_boot_verifier(&commit->co_verf, SVC_NET(rqstp));
596
	return nfsd_commit(rqstp, &cstate->current_fh, commit->co_offset,
597
			     commit->co_count);
L
Linus Torvalds 已提交
598 599
}

600
static __be32
601 602
nfsd4_create(struct svc_rqst *rqstp, struct nfsd4_compound_state *cstate,
	     struct nfsd4_create *create)
L
Linus Torvalds 已提交
603 604
{
	struct svc_fh resfh;
605
	__be32 status;
L
Linus Torvalds 已提交
606 607 608 609
	dev_t rdev;

	fh_init(&resfh, NFS4_FHSIZE);

M
Miklos Szeredi 已提交
610 611
	status = fh_verify(rqstp, &cstate->current_fh, S_IFDIR,
			   NFSD_MAY_CREATE);
L
Linus Torvalds 已提交
612 613 614
	if (status)
		return status;

615 616 617 618 619
	status = check_attr_support(rqstp, cstate, create->cr_bmval,
				    nfsd_attrmask);
	if (status)
		return status;

L
Linus Torvalds 已提交
620 621
	switch (create->cr_type) {
	case NF4LNK:
622 623
		status = nfsd_symlink(rqstp, &cstate->current_fh,
				      create->cr_name, create->cr_namelen,
624
				      create->cr_data, &resfh);
L
Linus Torvalds 已提交
625 626 627 628 629 630 631
		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;
632 633 634
		status = nfsd_create(rqstp, &cstate->current_fh,
				     create->cr_name, create->cr_namelen,
				     &create->cr_iattr, S_IFBLK, rdev, &resfh);
L
Linus Torvalds 已提交
635 636 637 638 639 640 641
		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;
642 643 644
		status = nfsd_create(rqstp, &cstate->current_fh,
				     create->cr_name, create->cr_namelen,
				     &create->cr_iattr,S_IFCHR, rdev, &resfh);
L
Linus Torvalds 已提交
645 646 647
		break;

	case NF4SOCK:
648 649 650
		status = nfsd_create(rqstp, &cstate->current_fh,
				     create->cr_name, create->cr_namelen,
				     &create->cr_iattr, S_IFSOCK, 0, &resfh);
L
Linus Torvalds 已提交
651 652 653
		break;

	case NF4FIFO:
654 655 656
		status = nfsd_create(rqstp, &cstate->current_fh,
				     create->cr_name, create->cr_namelen,
				     &create->cr_iattr, S_IFIFO, 0, &resfh);
L
Linus Torvalds 已提交
657 658 659 660
		break;

	case NF4DIR:
		create->cr_iattr.ia_valid &= ~ATTR_SIZE;
661 662 663
		status = nfsd_create(rqstp, &cstate->current_fh,
				     create->cr_name, create->cr_namelen,
				     &create->cr_iattr, S_IFDIR, 0, &resfh);
L
Linus Torvalds 已提交
664 665 666 667 668 669
		break;

	default:
		status = nfserr_badtype;
	}

670 671
	if (status)
		goto out;
L
Linus Torvalds 已提交
672

673 674 675
	if (create->cr_label.len)
		nfsd4_security_inode_setsecctx(&resfh, &create->cr_label, create->cr_bmval);

676 677 678 679 680 681 682 683
	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 已提交
684 685 686 687
	fh_put(&resfh);
	return status;
}

688
static __be32
689 690
nfsd4_getattr(struct svc_rqst *rqstp, struct nfsd4_compound_state *cstate,
	      struct nfsd4_getattr *getattr)
L
Linus Torvalds 已提交
691
{
692
	__be32 status;
L
Linus Torvalds 已提交
693

M
Miklos Szeredi 已提交
694
	status = fh_verify(rqstp, &cstate->current_fh, 0, NFSD_MAY_NOP);
L
Linus Torvalds 已提交
695 696 697 698 699 700
	if (status)
		return status;

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

701 702 703
	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 已提交
704

705
	getattr->ga_fhp = &cstate->current_fh;
L
Linus Torvalds 已提交
706 707 708
	return nfs_ok;
}

709
static __be32
710 711
nfsd4_link(struct svc_rqst *rqstp, struct nfsd4_compound_state *cstate,
	   struct nfsd4_link *link)
L
Linus Torvalds 已提交
712
{
713
	__be32 status = nfserr_nofilehandle;
L
Linus Torvalds 已提交
714

715
	if (!cstate->save_fh.fh_dentry)
L
Linus Torvalds 已提交
716
		return status;
717 718
	status = nfsd_link(rqstp, &cstate->current_fh,
			   link->li_name, link->li_namelen, &cstate->save_fh);
L
Linus Torvalds 已提交
719
	if (!status)
720
		set_change_info(&link->li_cinfo, &cstate->current_fh);
L
Linus Torvalds 已提交
721 722 723
	return status;
}

724
static __be32 nfsd4_do_lookupp(struct svc_rqst *rqstp, struct svc_fh *fh)
L
Linus Torvalds 已提交
725 726
{
	struct svc_fh tmp_fh;
727
	__be32 ret;
L
Linus Torvalds 已提交
728 729

	fh_init(&tmp_fh, NFS4_FHSIZE);
730 731
	ret = exp_pseudoroot(rqstp, &tmp_fh);
	if (ret)
L
Linus Torvalds 已提交
732
		return ret;
733
	if (tmp_fh.fh_dentry == fh->fh_dentry) {
L
Linus Torvalds 已提交
734 735 736 737
		fh_put(&tmp_fh);
		return nfserr_noent;
	}
	fh_put(&tmp_fh);
738 739 740 741 742 743 744 745
	return nfsd_lookup(rqstp, fh, "..", 2, fh);
}

static __be32
nfsd4_lookupp(struct svc_rqst *rqstp, struct nfsd4_compound_state *cstate,
	      void *arg)
{
	return nfsd4_do_lookupp(rqstp, &cstate->current_fh);
L
Linus Torvalds 已提交
746 747
}

748
static __be32
749 750
nfsd4_lookup(struct svc_rqst *rqstp, struct nfsd4_compound_state *cstate,
	     struct nfsd4_lookup *lookup)
L
Linus Torvalds 已提交
751
{
752 753 754
	return nfsd_lookup(rqstp, &cstate->current_fh,
			   lookup->lo_name, lookup->lo_len,
			   &cstate->current_fh);
L
Linus Torvalds 已提交
755 756
}

757
static __be32
758 759
nfsd4_read(struct svc_rqst *rqstp, struct nfsd4_compound_state *cstate,
	   struct nfsd4_read *read)
L
Linus Torvalds 已提交
760
{
761
	__be32 status;
L
Linus Torvalds 已提交
762 763 764

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

765
	read->rd_filp = NULL;
L
Linus Torvalds 已提交
766 767 768
	if (read->rd_offset >= OFFSET_MAX)
		return nfserr_inval;

769 770 771 772 773 774 775 776 777
	/*
	 * If we do a zero copy read, then a client will see read data
	 * that reflects the state of the file *after* performing the
	 * following compound.
	 *
	 * To ensure proper ordering, we therefore turn off zero copy if
	 * the client wants us to do more in this compound:
	 */
	if (!nfsd4_last_compound_op(rqstp))
778
		clear_bit(RQ_SPLICE_OK, &rqstp->rq_flags);
779

L
Linus Torvalds 已提交
780
	/* check stateid */
781 782
	if ((status = nfs4_preprocess_stateid_op(SVC_NET(rqstp),
						 cstate, &read->rd_stateid,
783
						 RD_STATE, &read->rd_filp))) {
L
Linus Torvalds 已提交
784 785 786 787 788 789
		dprintk("NFSD: nfsd4_read: couldn't process stateid!\n");
		goto out;
	}
	status = nfs_ok;
out:
	read->rd_rqstp = rqstp;
790
	read->rd_fhp = &cstate->current_fh;
L
Linus Torvalds 已提交
791 792 793
	return status;
}

794
static __be32
795 796
nfsd4_readdir(struct svc_rqst *rqstp, struct nfsd4_compound_state *cstate,
	      struct nfsd4_readdir *readdir)
L
Linus Torvalds 已提交
797 798 799 800 801 802 803 804 805
{
	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;

806 807 808
	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 已提交
809

810
	if ((cookie == 1) || (cookie == 2) ||
L
Linus Torvalds 已提交
811 812 813 814
	    (cookie == 0 && memcmp(readdir->rd_verf.data, zeroverf.data, NFS4_VERIFIER_SIZE)))
		return nfserr_bad_cookie;

	readdir->rd_rqstp = rqstp;
815
	readdir->rd_fhp = &cstate->current_fh;
L
Linus Torvalds 已提交
816 817 818
	return nfs_ok;
}

819
static __be32
820 821
nfsd4_readlink(struct svc_rqst *rqstp, struct nfsd4_compound_state *cstate,
	       struct nfsd4_readlink *readlink)
L
Linus Torvalds 已提交
822 823
{
	readlink->rl_rqstp = rqstp;
824
	readlink->rl_fhp = &cstate->current_fh;
L
Linus Torvalds 已提交
825 826 827
	return nfs_ok;
}

828
static __be32
829 830
nfsd4_remove(struct svc_rqst *rqstp, struct nfsd4_compound_state *cstate,
	     struct nfsd4_remove *remove)
L
Linus Torvalds 已提交
831
{
832
	__be32 status;
L
Linus Torvalds 已提交
833

834
	if (locks_in_grace(SVC_NET(rqstp)))
835
		return nfserr_grace;
836 837
	status = nfsd_unlink(rqstp, &cstate->current_fh, 0,
			     remove->rm_name, remove->rm_namelen);
L
Linus Torvalds 已提交
838
	if (!status) {
839 840
		fh_unlock(&cstate->current_fh);
		set_change_info(&remove->rm_cinfo, &cstate->current_fh);
L
Linus Torvalds 已提交
841 842 843 844
	}
	return status;
}

845
static __be32
846 847
nfsd4_rename(struct svc_rqst *rqstp, struct nfsd4_compound_state *cstate,
	     struct nfsd4_rename *rename)
L
Linus Torvalds 已提交
848
{
849
	__be32 status = nfserr_nofilehandle;
L
Linus Torvalds 已提交
850

851
	if (!cstate->save_fh.fh_dentry)
L
Linus Torvalds 已提交
852
		return status;
853 854
	if (locks_in_grace(SVC_NET(rqstp)) &&
		!(cstate->save_fh.fh_export->ex_flags & NFSEXP_NOSUBTREECHECK))
855
		return nfserr_grace;
856 857
	status = nfsd_rename(rqstp, &cstate->save_fh, rename->rn_sname,
			     rename->rn_snamelen, &cstate->current_fh,
L
Linus Torvalds 已提交
858
			     rename->rn_tname, rename->rn_tnamelen);
859 860 861 862 863
	if (status)
		return status;
	set_change_info(&rename->rn_sinfo, &cstate->current_fh);
	set_change_info(&rename->rn_tinfo, &cstate->save_fh);
	return nfs_ok;
L
Linus Torvalds 已提交
864 865
}

A
Andy Adamson 已提交
866 867 868 869 870 871 872 873 874 875
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);
876 877 878
	err = fh_verify(rqstp, &cstate->current_fh, S_IFDIR, NFSD_MAY_EXEC);
	if (err)
		return err;
A
Andy Adamson 已提交
879 880 881 882 883
	err = nfsd_lookup_dentry(rqstp, &cstate->current_fh,
				    secinfo->si_name, secinfo->si_namelen,
				    &exp, &dentry);
	if (err)
		return err;
884
	if (d_really_is_negative(dentry)) {
A
Andy Adamson 已提交
885 886 887 888 889
		exp_put(exp);
		err = nfserr_noent;
	} else
		secinfo->si_exp = exp;
	dput(dentry);
890 891 892
	if (cstate->minorversion)
		/* See rfc 5661 section 2.6.3.1.1.8 */
		fh_put(&cstate->current_fh);
A
Andy Adamson 已提交
893 894 895
	return err;
}

J
J. Bruce Fields 已提交
896 897 898 899 900 901 902 903 904 905 906 907 908 909 910 911 912
static __be32
nfsd4_secinfo_no_name(struct svc_rqst *rqstp, struct nfsd4_compound_state *cstate,
	      struct nfsd4_secinfo_no_name *sin)
{
	__be32 err;

	switch (sin->sin_style) {
	case NFS4_SECINFO_STYLE4_CURRENT_FH:
		break;
	case NFS4_SECINFO_STYLE4_PARENT:
		err = nfsd4_do_lookupp(rqstp, &cstate->current_fh);
		if (err)
			return err;
		break;
	default:
		return nfserr_inval;
	}
913 914

	sin->sin_exp = exp_get(cstate->current_fh.fh_export);
J
J. Bruce Fields 已提交
915 916 917 918
	fh_put(&cstate->current_fh);
	return nfs_ok;
}

919
static __be32
920 921
nfsd4_setattr(struct svc_rqst *rqstp, struct nfsd4_compound_state *cstate,
	      struct nfsd4_setattr *setattr)
L
Linus Torvalds 已提交
922
{
923
	__be32 status = nfs_ok;
924
	int err;
L
Linus Torvalds 已提交
925 926

	if (setattr->sa_iattr.ia_valid & ATTR_SIZE) {
927
		status = nfs4_preprocess_stateid_op(SVC_NET(rqstp), cstate,
928
			&setattr->sa_stateid, WR_STATE, NULL);
929
		if (status) {
930
			dprintk("NFSD: nfsd4_setattr: couldn't process stateid!\n");
931 932
			return status;
		}
L
Linus Torvalds 已提交
933
	}
934 935 936
	err = fh_want_write(&cstate->current_fh);
	if (err)
		return nfserrno(err);
L
Linus Torvalds 已提交
937
	status = nfs_ok;
938 939 940 941 942 943

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

L
Linus Torvalds 已提交
944
	if (setattr->sa_acl != NULL)
945 946
		status = nfsd4_set_nfs4_acl(rqstp, &cstate->current_fh,
					    setattr->sa_acl);
L
Linus Torvalds 已提交
947
	if (status)
948
		goto out;
949 950 951 952 953
	if (setattr->sa_label.len)
		status = nfsd4_set_nfs4_label(rqstp, &cstate->current_fh,
				&setattr->sa_label);
	if (status)
		goto out;
954
	status = nfsd_setattr(rqstp, &cstate->current_fh, &setattr->sa_iattr,
L
Linus Torvalds 已提交
955
				0, (time_t)0);
956
out:
A
Al Viro 已提交
957
	fh_drop_write(&cstate->current_fh);
L
Linus Torvalds 已提交
958 959 960
	return status;
}

961 962 963 964 965 966 967 968 969 970 971 972 973 974 975 976 977 978
static int fill_in_write_vector(struct kvec *vec, struct nfsd4_write *write)
{
        int i = 1;
        int buflen = write->wr_buflen;

        vec[0].iov_base = write->wr_head.iov_base;
        vec[0].iov_len = min_t(int, buflen, write->wr_head.iov_len);
        buflen -= vec[0].iov_len;

        while (buflen) {
                vec[i].iov_base = page_address(write->wr_pagelist[i - 1]);
                vec[i].iov_len = min_t(int, PAGE_SIZE, buflen);
                buflen -= vec[i].iov_len;
                i++;
        }
        return i;
}

979
static __be32
980 981
nfsd4_write(struct svc_rqst *rqstp, struct nfsd4_compound_state *cstate,
	    struct nfsd4_write *write)
L
Linus Torvalds 已提交
982 983 984
{
	stateid_t *stateid = &write->wr_stateid;
	struct file *filp = NULL;
985
	__be32 status = nfs_ok;
986
	unsigned long cnt;
987
	int nvecs;
L
Linus Torvalds 已提交
988 989 990 991 992 993

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

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

994 995
	status = nfs4_preprocess_stateid_op(SVC_NET(rqstp),
					cstate, stateid, WR_STATE, &filp);
996 997 998 999 1000
	if (status) {
		dprintk("NFSD: nfsd4_write: couldn't process stateid!\n");
		return status;
	}

1001
	cnt = write->wr_buflen;
L
Linus Torvalds 已提交
1002
	write->wr_how_written = write->wr_stable_how;
1003
	gen_boot_verifier(&write->wr_verifier, SVC_NET(rqstp));
L
Linus Torvalds 已提交
1004

1005 1006 1007
	nvecs = fill_in_write_vector(rqstp->rq_vec, write);
	WARN_ON_ONCE(nvecs > ARRAY_SIZE(rqstp->rq_vec));

1008
	status =  nfsd_write(rqstp, &cstate->current_fh, filp,
1009
			     write->wr_offset, rqstp->rq_vec, nvecs,
1010
			     &cnt, &write->wr_how_written);
1011 1012
	if (filp)
		fput(filp);
L
Linus Torvalds 已提交
1013

1014 1015
	write->wr_bytes_written = cnt;

L
Linus Torvalds 已提交
1016 1017 1018
	return status;
}

A
Anna Schumaker 已提交
1019 1020 1021 1022 1023 1024 1025 1026 1027 1028 1029 1030 1031 1032
static __be32
nfsd4_fallocate(struct svc_rqst *rqstp, struct nfsd4_compound_state *cstate,
		struct nfsd4_fallocate *fallocate, int flags)
{
	__be32 status = nfserr_notsupp;
	struct file *file;

	status = nfs4_preprocess_stateid_op(SVC_NET(rqstp), cstate,
					    &fallocate->falloc_stateid,
					    WR_STATE, &file);
	if (status != nfs_ok) {
		dprintk("NFSD: nfsd4_fallocate: couldn't process stateid!\n");
		return status;
	}
1033 1034
	if (!file)
		return nfserr_bad_stateid;
A
Anna Schumaker 已提交
1035 1036 1037 1038 1039 1040 1041 1042 1043 1044 1045 1046 1047 1048 1049 1050

	status = nfsd4_vfs_fallocate(rqstp, &cstate->current_fh, file,
				     fallocate->falloc_offset,
				     fallocate->falloc_length,
				     flags);
	fput(file);
	return status;
}

static __be32
nfsd4_allocate(struct svc_rqst *rqstp, struct nfsd4_compound_state *cstate,
	       struct nfsd4_fallocate *fallocate)
{
	return nfsd4_fallocate(rqstp, cstate, fallocate, 0);
}

A
Anna Schumaker 已提交
1051 1052 1053 1054 1055 1056 1057 1058
static __be32
nfsd4_deallocate(struct svc_rqst *rqstp, struct nfsd4_compound_state *cstate,
		 struct nfsd4_fallocate *fallocate)
{
	return nfsd4_fallocate(rqstp, cstate, fallocate,
			       FALLOC_FL_PUNCH_HOLE | FALLOC_FL_KEEP_SIZE);
}

A
Anna Schumaker 已提交
1059 1060 1061 1062 1063 1064 1065 1066 1067 1068 1069 1070 1071 1072 1073
static __be32
nfsd4_seek(struct svc_rqst *rqstp, struct nfsd4_compound_state *cstate,
		struct nfsd4_seek *seek)
{
	int whence;
	__be32 status;
	struct file *file;

	status = nfs4_preprocess_stateid_op(SVC_NET(rqstp), cstate,
					    &seek->seek_stateid,
					    RD_STATE, &file);
	if (status) {
		dprintk("NFSD: nfsd4_seek: couldn't process stateid!\n");
		return status;
	}
1074 1075
	if (!file)
		return nfserr_bad_stateid;
A
Anna Schumaker 已提交
1076 1077 1078 1079 1080 1081 1082 1083 1084 1085 1086 1087 1088 1089 1090 1091 1092 1093 1094 1095 1096 1097 1098 1099 1100 1101 1102 1103

	switch (seek->seek_whence) {
	case NFS4_CONTENT_DATA:
		whence = SEEK_DATA;
		break;
	case NFS4_CONTENT_HOLE:
		whence = SEEK_HOLE;
		break;
	default:
		status = nfserr_union_notsupp;
		goto out;
	}

	/*
	 * Note:  This call does change file->f_pos, but nothing in NFSD
	 *        should ever file->f_pos.
	 */
	seek->seek_pos = vfs_llseek(file, seek->seek_offset, whence);
	if (seek->seek_pos < 0)
		status = nfserrno(seek->seek_pos);
	else if (seek->seek_pos >= i_size_read(file_inode(file)))
		seek->seek_eof = true;

out:
	fput(file);
	return status;
}

L
Linus Torvalds 已提交
1104 1105 1106 1107 1108
/* 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.
 */
1109
static __be32
1110
_nfsd4_verify(struct svc_rqst *rqstp, struct nfsd4_compound_state *cstate,
1111
	     struct nfsd4_verify *verify)
L
Linus Torvalds 已提交
1112
{
A
Al Viro 已提交
1113
	__be32 *buf, *p;
L
Linus Torvalds 已提交
1114
	int count;
1115
	__be32 status;
L
Linus Torvalds 已提交
1116

M
Miklos Szeredi 已提交
1117
	status = fh_verify(rqstp, &cstate->current_fh, 0, NFSD_MAY_NOP);
L
Linus Torvalds 已提交
1118 1119 1120
	if (status)
		return status;

1121 1122 1123 1124
	status = check_attr_support(rqstp, cstate, verify->ve_bmval, NULL);
	if (status)
		return status;

L
Linus Torvalds 已提交
1125 1126 1127 1128 1129 1130 1131 1132 1133 1134 1135 1136
	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)
1137
		return nfserr_jukebox;
L
Linus Torvalds 已提交
1138

1139
	p = buf;
1140
	status = nfsd4_encode_fattr_to_buf(&p, count, &cstate->current_fh,
1141
				    cstate->current_fh.fh_export,
1142 1143
				    cstate->current_fh.fh_dentry,
				    verify->ve_bmval,
1144
				    rqstp, 0);
J
J. Bruce Fields 已提交
1145 1146 1147 1148
	/*
	 * If nfsd4_encode_fattr() ran out of space, assume that's because
	 * the attributes are longer (hence different) than those given:
	 */
1149
	if (status == nfserr_resource)
L
Linus Torvalds 已提交
1150 1151 1152 1153
		status = nfserr_not_same;
	if (status)
		goto out_kfree;

1154 1155
	/* skip bitmap */
	p = buf + 1 + ntohl(buf[0]);
L
Linus Torvalds 已提交
1156 1157 1158 1159 1160 1161 1162 1163 1164 1165 1166
	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;
}

1167 1168 1169 1170 1171 1172 1173 1174 1175 1176 1177 1178 1179 1180 1181 1182 1183 1184 1185 1186
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;
}

1187 1188 1189 1190 1191 1192 1193 1194 1195 1196 1197 1198 1199 1200 1201 1202 1203 1204 1205 1206 1207 1208 1209 1210 1211 1212 1213 1214 1215 1216 1217 1218 1219 1220 1221 1222 1223 1224 1225 1226 1227 1228 1229 1230 1231 1232 1233 1234 1235 1236 1237 1238 1239 1240 1241 1242 1243 1244
#ifdef CONFIG_NFSD_PNFS
static const struct nfsd4_layout_ops *
nfsd4_layout_verify(struct svc_export *exp, unsigned int layout_type)
{
	if (!exp->ex_layout_type) {
		dprintk("%s: export does not support pNFS\n", __func__);
		return NULL;
	}

	if (exp->ex_layout_type != layout_type) {
		dprintk("%s: layout type %d not supported\n",
			__func__, layout_type);
		return NULL;
	}

	return nfsd4_layout_ops[layout_type];
}

static __be32
nfsd4_getdeviceinfo(struct svc_rqst *rqstp,
		struct nfsd4_compound_state *cstate,
		struct nfsd4_getdeviceinfo *gdp)
{
	const struct nfsd4_layout_ops *ops;
	struct nfsd4_deviceid_map *map;
	struct svc_export *exp;
	__be32 nfserr;

	dprintk("%s: layout_type %u dev_id [0x%llx:0x%x] maxcnt %u\n",
	       __func__,
	       gdp->gd_layout_type,
	       gdp->gd_devid.fsid_idx, gdp->gd_devid.generation,
	       gdp->gd_maxcount);

	map = nfsd4_find_devid_map(gdp->gd_devid.fsid_idx);
	if (!map) {
		dprintk("%s: couldn't find device ID to export mapping!\n",
			__func__);
		return nfserr_noent;
	}

	exp = rqst_exp_find(rqstp, map->fsid_type, map->fsid);
	if (IS_ERR(exp)) {
		dprintk("%s: could not find device id\n", __func__);
		return nfserr_noent;
	}

	nfserr = nfserr_layoutunavailable;
	ops = nfsd4_layout_verify(exp, gdp->gd_layout_type);
	if (!ops)
		goto out;

	nfserr = nfs_ok;
	if (gdp->gd_maxcount != 0)
		nfserr = ops->proc_getdeviceinfo(exp->ex_path.mnt->mnt_sb, gdp);

	gdp->gd_notify_types &= ops->notify_types;
out:
1245
	exp_put(exp);
1246 1247 1248 1249 1250 1251 1252 1253 1254 1255 1256 1257 1258 1259 1260 1261 1262 1263 1264 1265 1266 1267 1268 1269 1270 1271 1272 1273 1274 1275 1276 1277 1278 1279 1280 1281 1282 1283 1284 1285 1286 1287 1288 1289 1290 1291 1292 1293 1294 1295 1296 1297 1298 1299 1300 1301 1302 1303 1304 1305
	return nfserr;
}

static __be32
nfsd4_layoutget(struct svc_rqst *rqstp,
		struct nfsd4_compound_state *cstate,
		struct nfsd4_layoutget *lgp)
{
	struct svc_fh *current_fh = &cstate->current_fh;
	const struct nfsd4_layout_ops *ops;
	struct nfs4_layout_stateid *ls;
	__be32 nfserr;
	int accmode;

	switch (lgp->lg_seg.iomode) {
	case IOMODE_READ:
		accmode = NFSD_MAY_READ;
		break;
	case IOMODE_RW:
		accmode = NFSD_MAY_READ | NFSD_MAY_WRITE;
		break;
	default:
		dprintk("%s: invalid iomode %d\n",
			__func__, lgp->lg_seg.iomode);
		nfserr = nfserr_badiomode;
		goto out;
	}

	nfserr = fh_verify(rqstp, current_fh, 0, accmode);
	if (nfserr)
		goto out;

	nfserr = nfserr_layoutunavailable;
	ops = nfsd4_layout_verify(current_fh->fh_export, lgp->lg_layout_type);
	if (!ops)
		goto out;

	/*
	 * Verify minlength and range as per RFC5661:
	 *  o  If loga_length is less than loga_minlength,
	 *     the metadata server MUST return NFS4ERR_INVAL.
	 *  o  If the sum of loga_offset and loga_minlength exceeds
	 *     NFS4_UINT64_MAX, and loga_minlength is not
	 *     NFS4_UINT64_MAX, the error NFS4ERR_INVAL MUST result.
	 *  o  If the sum of loga_offset and loga_length exceeds
	 *     NFS4_UINT64_MAX, and loga_length is not NFS4_UINT64_MAX,
	 *     the error NFS4ERR_INVAL MUST result.
	 */
	nfserr = nfserr_inval;
	if (lgp->lg_seg.length < lgp->lg_minlength ||
	    (lgp->lg_minlength != NFS4_MAX_UINT64 &&
	     lgp->lg_minlength > NFS4_MAX_UINT64 - lgp->lg_seg.offset) ||
	    (lgp->lg_seg.length != NFS4_MAX_UINT64 &&
	     lgp->lg_seg.length > NFS4_MAX_UINT64 - lgp->lg_seg.offset))
		goto out;
	if (lgp->lg_seg.length == 0)
		goto out;

	nfserr = nfsd4_preprocess_layout_stateid(rqstp, cstate, &lgp->lg_sid,
						true, lgp->lg_layout_type, &ls);
C
Christoph Hellwig 已提交
1306 1307
	if (nfserr) {
		trace_layout_get_lookup_fail(&lgp->lg_sid);
1308
		goto out;
C
Christoph Hellwig 已提交
1309
	}
1310

1311 1312 1313 1314
	nfserr = nfserr_recallconflict;
	if (atomic_read(&ls->ls_stid.sc_file->fi_lo_recalls))
		goto out_put_stid;

1315
	nfserr = ops->proc_layoutget(d_inode(current_fh->fh_dentry),
1316 1317 1318 1319 1320 1321 1322 1323 1324 1325 1326 1327 1328 1329 1330 1331 1332 1333 1334 1335 1336 1337 1338 1339 1340 1341 1342 1343 1344 1345 1346 1347 1348
				     current_fh, lgp);
	if (nfserr)
		goto out_put_stid;

	nfserr = nfsd4_insert_layout(lgp, ls);

out_put_stid:
	nfs4_put_stid(&ls->ls_stid);
out:
	return nfserr;
}

static __be32
nfsd4_layoutcommit(struct svc_rqst *rqstp,
		struct nfsd4_compound_state *cstate,
		struct nfsd4_layoutcommit *lcp)
{
	const struct nfsd4_layout_seg *seg = &lcp->lc_seg;
	struct svc_fh *current_fh = &cstate->current_fh;
	const struct nfsd4_layout_ops *ops;
	loff_t new_size = lcp->lc_last_wr + 1;
	struct inode *inode;
	struct nfs4_layout_stateid *ls;
	__be32 nfserr;

	nfserr = fh_verify(rqstp, current_fh, 0, NFSD_MAY_WRITE);
	if (nfserr)
		goto out;

	nfserr = nfserr_layoutunavailable;
	ops = nfsd4_layout_verify(current_fh->fh_export, lcp->lc_layout_type);
	if (!ops)
		goto out;
1349
	inode = d_inode(current_fh->fh_dentry);
1350 1351 1352 1353 1354 1355 1356 1357 1358 1359 1360 1361 1362 1363 1364 1365 1366 1367 1368

	nfserr = nfserr_inval;
	if (new_size <= seg->offset) {
		dprintk("pnfsd: last write before layout segment\n");
		goto out;
	}
	if (new_size > seg->offset + seg->length) {
		dprintk("pnfsd: last write beyond layout segment\n");
		goto out;
	}
	if (!lcp->lc_newoffset && new_size > i_size_read(inode)) {
		dprintk("pnfsd: layoutcommit beyond EOF\n");
		goto out;
	}

	nfserr = nfsd4_preprocess_layout_stateid(rqstp, cstate, &lcp->lc_sid,
						false, lcp->lc_layout_type,
						&ls);
	if (nfserr) {
C
Christoph Hellwig 已提交
1369
		trace_layout_commit_lookup_fail(&lcp->lc_sid);
1370 1371 1372 1373 1374 1375 1376 1377 1378 1379 1380 1381 1382 1383 1384 1385 1386 1387 1388 1389 1390 1391 1392 1393 1394 1395 1396 1397 1398 1399 1400 1401 1402 1403 1404 1405 1406 1407 1408 1409 1410 1411 1412 1413 1414 1415 1416 1417 1418 1419 1420 1421 1422 1423 1424 1425 1426 1427 1428 1429 1430 1431 1432 1433 1434 1435 1436 1437 1438 1439
		/* fixup error code as per RFC5661 */
		if (nfserr == nfserr_bad_stateid)
			nfserr = nfserr_badlayout;
		goto out;
	}

	nfserr = ops->proc_layoutcommit(inode, lcp);
	if (nfserr)
		goto out_put_stid;

	if (new_size > i_size_read(inode)) {
		lcp->lc_size_chg = 1;
		lcp->lc_newsize = new_size;
	} else {
		lcp->lc_size_chg = 0;
	}

out_put_stid:
	nfs4_put_stid(&ls->ls_stid);
out:
	return nfserr;
}

static __be32
nfsd4_layoutreturn(struct svc_rqst *rqstp,
		struct nfsd4_compound_state *cstate,
		struct nfsd4_layoutreturn *lrp)
{
	struct svc_fh *current_fh = &cstate->current_fh;
	__be32 nfserr;

	nfserr = fh_verify(rqstp, current_fh, 0, NFSD_MAY_NOP);
	if (nfserr)
		goto out;

	nfserr = nfserr_layoutunavailable;
	if (!nfsd4_layout_verify(current_fh->fh_export, lrp->lr_layout_type))
		goto out;

	switch (lrp->lr_seg.iomode) {
	case IOMODE_READ:
	case IOMODE_RW:
	case IOMODE_ANY:
		break;
	default:
		dprintk("%s: invalid iomode %d\n", __func__,
			lrp->lr_seg.iomode);
		nfserr = nfserr_inval;
		goto out;
	}

	switch (lrp->lr_return_type) {
	case RETURN_FILE:
		nfserr = nfsd4_return_file_layouts(rqstp, cstate, lrp);
		break;
	case RETURN_FSID:
	case RETURN_ALL:
		nfserr = nfsd4_return_client_layouts(rqstp, cstate, lrp);
		break;
	default:
		dprintk("%s: invalid return_type %d\n", __func__,
			lrp->lr_return_type);
		nfserr = nfserr_inval;
		break;
	}
out:
	return nfserr;
}
#endif /* CONFIG_NFSD_PNFS */

L
Linus Torvalds 已提交
1440 1441 1442
/*
 * NULL call.
 */
A
Al Viro 已提交
1443
static __be32
L
Linus Torvalds 已提交
1444 1445 1446 1447 1448
nfsd4_proc_null(struct svc_rqst *rqstp, void *argp, void *resp)
{
	return nfs_ok;
}

1449 1450 1451 1452 1453 1454
static inline void nfsd4_increment_op_stats(u32 opnum)
{
	if (opnum >= FIRST_NFS4_OP && opnum <= LAST_NFS4_OP)
		nfsdstats.nfs4_opcount[opnum]++;
}

1455 1456
typedef __be32(*nfsd4op_func)(struct svc_rqst *, struct nfsd4_compound_state *,
			      void *);
1457
typedef u32(*nfsd4op_rsize)(struct svc_rqst *, struct nfsd4_op *op);
1458 1459
typedef void(*stateid_setter)(struct nfsd4_compound_state *, void *);
typedef void(*stateid_getter)(struct nfsd4_compound_state *, void *);
1460

1461 1462
enum nfsd4_op_flags {
	ALLOWED_WITHOUT_FH = 1 << 0,	/* No current filehandle required */
1463 1464
	ALLOWED_ON_ABSENT_FS = 1 << 1,	/* ops processed on absent fs */
	ALLOWED_AS_FIRST_OP = 1 << 2,	/* ops reqired first in compound */
1465 1466 1467
	/* For rfc 5661 section 2.6.3.1.1: */
	OP_HANDLES_WRONGSEC = 1 << 3,
	OP_IS_PUTFH_LIKE = 1 << 4,
1468
	/*
1469 1470 1471 1472 1473 1474 1475 1476
	 * These are the ops whose result size we estimate before
	 * encoding, to avoid performing an op then not being able to
	 * respond or cache a response.  This includes writes and setattrs
	 * as well as the operations usually called "nonidempotent":
	 */
	OP_MODIFIES_SOMETHING = 1 << 5,
	/*
	 * Cache compounds containing these ops in the xid-based drc:
1477 1478 1479 1480 1481 1482 1483
	 * We use the DRC for compounds containing non-idempotent
	 * operations, *except* those that are 4.1-specific (since
	 * sessions provide their own EOS), and except for stateful
	 * operations other than setclientid and setclientid_confirm
	 * (since sequence numbers provide EOS for open, lock, etc in
	 * the v4.0 case).
	 */
1484
	OP_CACHEME = 1 << 6,
1485 1486 1487 1488
	/*
	 * These are ops which clear current state id.
	 */
	OP_CLEAR_STATEID = 1 << 7,
1489 1490 1491 1492 1493 1494
};

struct nfsd4_operation {
	nfsd4op_func op_func;
	u32 op_flags;
	char *op_name;
1495 1496
	/* Try to get response size before operation */
	nfsd4op_rsize op_rsize_bop;
1497 1498
	stateid_getter op_get_currentstateid;
	stateid_setter op_set_currentstateid;
1499 1500 1501 1502
};

static struct nfsd4_operation nfsd4_ops[];

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

1505
/*
1506
 * Enforce NFSv4.1 COMPOUND ordering rules:
1507
 *
1508 1509 1510
 * Also note, enforced elsewhere:
 *	- SEQUENCE other than as first op results in
 *	  NFS4ERR_SEQUENCE_POS. (Enforced in nfsd4_sequence().)
1511 1512
 *	- BIND_CONN_TO_SESSION must be the only op in its compound.
 *	  (Enforced in nfsd4_bind_conn_to_session().)
1513 1514 1515
 *	- 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().)
1516
 */
1517
static __be32 nfs41_check_op_ordering(struct nfsd4_compoundargs *args)
1518
{
1519 1520 1521 1522 1523 1524 1525 1526 1527 1528 1529 1530 1531 1532 1533 1534 1535
	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;
1536 1537
}

J
J. Bruce Fields 已提交
1538 1539 1540 1541 1542
static inline struct nfsd4_operation *OPDESC(struct nfsd4_op *op)
{
	return &nfsd4_ops[op->opnum];
}

1543 1544
bool nfsd4_cache_this_op(struct nfsd4_op *op)
{
1545 1546
	if (op->opnum == OP_ILLEGAL)
		return false;
1547
	return OPDESC(op)->op_flags & OP_CACHEME;
1548 1549
}

1550 1551 1552 1553 1554 1555 1556 1557 1558 1559 1560 1561 1562 1563 1564 1565 1566 1567 1568 1569 1570 1571 1572
static bool need_wrongsec_check(struct svc_rqst *rqstp)
{
	struct nfsd4_compoundres *resp = rqstp->rq_resp;
	struct nfsd4_compoundargs *argp = rqstp->rq_argp;
	struct nfsd4_op *this = &argp->ops[resp->opcnt - 1];
	struct nfsd4_op *next = &argp->ops[resp->opcnt];
	struct nfsd4_operation *thisd;
	struct nfsd4_operation *nextd;

	thisd = OPDESC(this);
	/*
	 * Most ops check wronsec on our own; only the putfh-like ops
	 * have special rules.
	 */
	if (!(thisd->op_flags & OP_IS_PUTFH_LIKE))
		return false;
	/*
	 * rfc 5661 2.6.3.1.1.6: don't bother erroring out a
	 * put-filehandle operation if we're not going to use the
	 * result:
	 */
	if (argp->opcnt == resp->opcnt)
		return false;
1573 1574
	if (next->opnum == OP_ILLEGAL)
		return false;
1575 1576 1577 1578 1579 1580 1581 1582 1583
	nextd = OPDESC(next);
	/*
	 * Rest of 2.6.3.1.1: certain operations will return WRONGSEC
	 * errors themselves as necessary; others should check for them
	 * now:
	 */
	return !(nextd->op_flags & OP_HANDLES_WRONGSEC);
}

1584 1585 1586 1587 1588 1589 1590 1591
static void svcxdr_init_encode(struct svc_rqst *rqstp,
			       struct nfsd4_compoundres *resp)
{
	struct xdr_stream *xdr = &resp->xdr;
	struct xdr_buf *buf = &rqstp->rq_res;
	struct kvec *head = buf->head;

	xdr->buf = buf;
1592
	xdr->iov = head;
1593
	xdr->p   = head->iov_base + head->iov_len;
1594
	xdr->end = head->iov_base + PAGE_SIZE - rqstp->rq_auth_slack;
1595 1596
	/* Tail and page_len should be zero at this point: */
	buf->len = buf->head[0].iov_len;
1597
	xdr->scratch.iov_len = 0;
1598
	xdr->page_ptr = buf->pages - 1;
1599
	buf->buflen = PAGE_SIZE * (1 + rqstp->rq_page_end - buf->pages)
1600
		- rqstp->rq_auth_slack;
1601 1602
}

L
Linus Torvalds 已提交
1603 1604 1605
/*
 * COMPOUND call.
 */
A
Al Viro 已提交
1606
static __be32
L
Linus Torvalds 已提交
1607 1608 1609 1610 1611
nfsd4_proc_compound(struct svc_rqst *rqstp,
		    struct nfsd4_compoundargs *args,
		    struct nfsd4_compoundres *resp)
{
	struct nfsd4_op	*op;
1612
	struct nfsd4_operation *opdesc;
1613
	struct nfsd4_compound_state *cstate = &resp->cstate;
1614 1615
	struct svc_fh *current_fh = &cstate->current_fh;
	struct svc_fh *save_fh = &cstate->save_fh;
1616
	__be32		status;
L
Linus Torvalds 已提交
1617

1618
	svcxdr_init_encode(rqstp, resp);
1619
	resp->tagp = resp->xdr.p;
L
Linus Torvalds 已提交
1620
	/* reserve space for: taglen, tag, and opcnt */
1621
	xdr_reserve_space(&resp->xdr, 8 + args->taglen);
L
Linus Torvalds 已提交
1622 1623 1624
	resp->taglen = args->taglen;
	resp->tag = args->tag;
	resp->rqstp = rqstp;
1625 1626 1627
	cstate->minorversion = args->minorversion;
	fh_init(current_fh, NFS4_FHSIZE);
	fh_init(save_fh, NFS4_FHSIZE);
N
NeilBrown 已提交
1628 1629 1630 1631
	/*
	 * Don't use the deferral mechanism for NFSv4; compounds make it
	 * too hard to avoid non-idempotency problems.
	 */
1632
	clear_bit(RQ_USEDEFERRAL, &rqstp->rq_flags);
L
Linus Torvalds 已提交
1633 1634 1635 1636 1637

	/*
	 * According to RFC3010, this takes precedence over all other errors.
	 */
	status = nfserr_minor_vers_mismatch;
1638
	if (nfsd_minorversion(args->minorversion, NFSD_TEST) <= 0)
L
Linus Torvalds 已提交
1639 1640
		goto out;

1641 1642
	status = nfs41_check_op_ordering(args);
	if (status) {
1643
		op = &args->ops[0];
1644
		op->status = status;
1645 1646 1647
		goto encode_op;
	}

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

B
Benny Halevy 已提交
1651 1652 1653
		dprintk("nfsv4 compound op #%d/%d: %d (%s)\n",
			resp->opcnt, args->opcnt, op->opnum,
			nfsd4_op_name(op->opnum));
L
Linus Torvalds 已提交
1654 1655 1656 1657 1658
		/*
		 * 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.
		 */
1659 1660 1661
		if (op->status) {
			if (op->opnum == OP_OPEN)
				op->status = nfsd4_open_omfg(rqstp, cstate, op);
L
Linus Torvalds 已提交
1662
			goto encode_op;
1663
		}
L
Linus Torvalds 已提交
1664

J
J. Bruce Fields 已提交
1665
		opdesc = OPDESC(op);
1666

1667
		if (!current_fh->fh_dentry) {
1668
			if (!(opdesc->op_flags & ALLOWED_WITHOUT_FH)) {
1669 1670 1671
				op->status = nfserr_nofilehandle;
				goto encode_op;
			}
1672
		} else if (current_fh->fh_export->ex_fslocs.migrated &&
1673
			  !(opdesc->op_flags & ALLOWED_ON_ABSENT_FS)) {
1674
			op->status = nfserr_moved;
L
Linus Torvalds 已提交
1675 1676
			goto encode_op;
		}
1677

1678 1679
		fh_clear_wcc(current_fh);

1680 1681
		/* If op is non-idempotent */
		if (opdesc->op_flags & OP_MODIFIES_SOMETHING) {
1682
			/*
J
J. Bruce Fields 已提交
1683 1684 1685 1686 1687 1688
			 * Don't execute this op if we couldn't encode a
			 * succesful reply:
			 */
			u32 plen = opdesc->op_rsize_bop(rqstp, op);
			/*
			 * Plus if there's another operation, make sure
1689 1690 1691 1692
			 * we'll have space to at least encode an error:
			 */
			if (resp->opcnt < args->opcnt)
				plen += COMPOUND_ERR_SLACK_SPACE;
1693 1694 1695 1696 1697 1698
			op->status = nfsd4_check_resp_size(resp, plen);
		}

		if (op->status)
			goto encode_op;

J
J. Bruce Fields 已提交
1699 1700 1701
		if (opdesc->op_get_currentstateid)
			opdesc->op_get_currentstateid(cstate, &op->u);
		op->status = opdesc->op_func(rqstp, cstate, &op->u);
L
Linus Torvalds 已提交
1702

1703 1704 1705 1706 1707
		if (!op->status) {
			if (opdesc->op_set_currentstateid)
				opdesc->op_set_currentstateid(cstate, &op->u);

			if (opdesc->op_flags & OP_CLEAR_STATEID)
1708
				clear_current_stateid(cstate);
1709 1710

			if (need_wrongsec_check(rqstp))
1711
				op->status = check_nfsd_access(current_fh->fh_export, rqstp);
1712
		}
1713

L
Linus Torvalds 已提交
1714
encode_op:
1715
		/* Only from SEQUENCE */
1716
		if (cstate->status == nfserr_replay_cache) {
A
Andy Adamson 已提交
1717
			dprintk("%s NFS4.1 replay from cache\n", __func__);
1718
			status = op->status;
A
Andy Adamson 已提交
1719 1720
			goto out;
		}
A
Al Viro 已提交
1721
		if (op->status == nfserr_replay_me) {
1722
			op->replay = &cstate->replay_owner->so_replay;
1723
			nfsd4_encode_replay(&resp->xdr, op);
L
Linus Torvalds 已提交
1724 1725 1726 1727 1728
			status = op->status = op->replay->rp_status;
		} else {
			nfsd4_encode_operation(resp, op);
			status = op->status;
		}
1729 1730 1731 1732 1733

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

1734
		nfsd4_cstate_clear_replay(cstate);
1735 1736 1737
		/* 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);
1738 1739

		nfsd4_increment_op_stats(op->opnum);
L
Linus Torvalds 已提交
1740 1741
	}

1742 1743 1744 1745
	cstate->status = status;
	fh_put(current_fh);
	fh_put(save_fh);
	BUG_ON(cstate->replay_owner);
L
Linus Torvalds 已提交
1746
out:
1747
	/* Reset deferral mechanism for RPC deferrals */
1748
	set_bit(RQ_USEDEFERRAL, &rqstp->rq_flags);
1749
	dprintk("nfsv4 compound returned %d\n", ntohl(status));
L
Linus Torvalds 已提交
1750 1751 1752
	return status;
}

1753 1754 1755 1756 1757 1758
#define op_encode_hdr_size		(2)
#define op_encode_stateid_maxsz		(XDR_QUADLEN(NFS4_STATEID_SIZE))
#define op_encode_verifier_maxsz	(XDR_QUADLEN(NFS4_VERIFIER_SIZE))
#define op_encode_change_info_maxsz	(5)
#define nfs4_fattr_bitmap_maxsz		(4)

1759 1760
/* We'll fall back on returning no lockowner if run out of space: */
#define op_encode_lockowner_maxsz	(0)
1761 1762 1763 1764 1765 1766 1767 1768 1769 1770 1771 1772 1773 1774 1775 1776 1777 1778 1779 1780 1781 1782 1783 1784 1785 1786 1787 1788 1789 1790 1791
#define op_encode_lock_denied_maxsz	(8 + op_encode_lockowner_maxsz)

#define nfs4_owner_maxsz		(1 + XDR_QUADLEN(IDMAP_NAMESZ))

#define op_encode_ace_maxsz		(3 + nfs4_owner_maxsz)
#define op_encode_delegation_maxsz	(1 + op_encode_stateid_maxsz + 1 + \
					 op_encode_ace_maxsz)

#define op_encode_channel_attrs_maxsz	(6 + 1 + 1)

static inline u32 nfsd4_only_status_rsize(struct svc_rqst *rqstp, struct nfsd4_op *op)
{
	return (op_encode_hdr_size) * sizeof(__be32);
}

static inline u32 nfsd4_status_stateid_rsize(struct svc_rqst *rqstp, struct nfsd4_op *op)
{
	return (op_encode_hdr_size + op_encode_stateid_maxsz)* sizeof(__be32);
}

static inline u32 nfsd4_commit_rsize(struct svc_rqst *rqstp, struct nfsd4_op *op)
{
	return (op_encode_hdr_size + op_encode_verifier_maxsz) * sizeof(__be32);
}

static inline u32 nfsd4_create_rsize(struct svc_rqst *rqstp, struct nfsd4_op *op)
{
	return (op_encode_hdr_size + op_encode_change_info_maxsz
		+ nfs4_fattr_bitmap_maxsz) * sizeof(__be32);
}

1792 1793 1794 1795 1796 1797 1798 1799 1800 1801 1802 1803 1804 1805 1806 1807 1808 1809 1810 1811 1812 1813 1814 1815 1816 1817 1818 1819 1820 1821
/*
 * Note since this is an idempotent operation we won't insist on failing
 * the op prematurely if the estimate is too large.  We may turn off splice
 * reads unnecessarily.
 */
static inline u32 nfsd4_getattr_rsize(struct svc_rqst *rqstp,
				      struct nfsd4_op *op)
{
	u32 *bmap = op->u.getattr.ga_bmval;
	u32 bmap0 = bmap[0], bmap1 = bmap[1], bmap2 = bmap[2];
	u32 ret = 0;

	if (bmap0 & FATTR4_WORD0_ACL)
		return svc_max_payload(rqstp);
	if (bmap0 & FATTR4_WORD0_FS_LOCATIONS)
		return svc_max_payload(rqstp);

	if (bmap1 & FATTR4_WORD1_OWNER) {
		ret += IDMAP_NAMESZ + 4;
		bmap1 &= ~FATTR4_WORD1_OWNER;
	}
	if (bmap1 & FATTR4_WORD1_OWNER_GROUP) {
		ret += IDMAP_NAMESZ + 4;
		bmap1 &= ~FATTR4_WORD1_OWNER_GROUP;
	}
	if (bmap0 & FATTR4_WORD0_FILEHANDLE) {
		ret += NFS4_FHSIZE + 4;
		bmap0 &= ~FATTR4_WORD0_FILEHANDLE;
	}
	if (bmap2 & FATTR4_WORD2_SECURITY_LABEL) {
1822
		ret += NFS4_MAXLABELLEN + 12;
1823 1824 1825 1826 1827 1828 1829 1830 1831 1832 1833 1834
		bmap2 &= ~FATTR4_WORD2_SECURITY_LABEL;
	}
	/*
	 * Largest of remaining attributes are 16 bytes (e.g.,
	 * supported_attributes)
	 */
	ret += 16 * (hweight32(bmap0) + hweight32(bmap1) + hweight32(bmap2));
	/* bitmask, length */
	ret += 20;
	return ret;
}

1835 1836 1837 1838 1839 1840 1841 1842 1843 1844 1845 1846 1847 1848 1849 1850 1851 1852 1853 1854 1855 1856 1857 1858 1859
static inline u32 nfsd4_link_rsize(struct svc_rqst *rqstp, struct nfsd4_op *op)
{
	return (op_encode_hdr_size + op_encode_change_info_maxsz)
		* sizeof(__be32);
}

static inline u32 nfsd4_lock_rsize(struct svc_rqst *rqstp, struct nfsd4_op *op)
{
	return (op_encode_hdr_size + op_encode_lock_denied_maxsz)
		* sizeof(__be32);
}

static inline u32 nfsd4_open_rsize(struct svc_rqst *rqstp, struct nfsd4_op *op)
{
	return (op_encode_hdr_size + op_encode_stateid_maxsz
		+ op_encode_change_info_maxsz + 1
		+ nfs4_fattr_bitmap_maxsz
		+ op_encode_delegation_maxsz) * sizeof(__be32);
}

static inline u32 nfsd4_read_rsize(struct svc_rqst *rqstp, struct nfsd4_op *op)
{
	u32 maxcount = 0, rlen = 0;

	maxcount = svc_max_payload(rqstp);
1860
	rlen = min(op->u.read.rd_length, maxcount);
1861

1862
	return (op_encode_hdr_size + 2 + XDR_QUADLEN(rlen)) * sizeof(__be32);
1863 1864 1865 1866
}

static inline u32 nfsd4_readdir_rsize(struct svc_rqst *rqstp, struct nfsd4_op *op)
{
1867
	u32 maxcount = 0, rlen = 0;
1868

1869 1870
	maxcount = svc_max_payload(rqstp);
	rlen = min(op->u.readdir.rd_maxcount, maxcount);
1871

J
J. Bruce Fields 已提交
1872 1873
	return (op_encode_hdr_size + op_encode_verifier_maxsz +
		XDR_QUADLEN(rlen)) * sizeof(__be32);
1874 1875 1876 1877 1878 1879 1880 1881 1882 1883 1884 1885 1886 1887
}

static inline u32 nfsd4_remove_rsize(struct svc_rqst *rqstp, struct nfsd4_op *op)
{
	return (op_encode_hdr_size + op_encode_change_info_maxsz)
		* sizeof(__be32);
}

static inline u32 nfsd4_rename_rsize(struct svc_rqst *rqstp, struct nfsd4_op *op)
{
	return (op_encode_hdr_size + op_encode_change_info_maxsz
		+ op_encode_change_info_maxsz) * sizeof(__be32);
}

1888 1889 1890
static inline u32 nfsd4_sequence_rsize(struct svc_rqst *rqstp,
				       struct nfsd4_op *op)
{
1891 1892
	return (op_encode_hdr_size
		+ XDR_QUADLEN(NFS4_MAX_SESSIONID_LEN) + 5) * sizeof(__be32);
1893 1894
}

1895 1896 1897 1898 1899 1900 1901
static inline u32 nfsd4_setattr_rsize(struct svc_rqst *rqstp, struct nfsd4_op *op)
{
	return (op_encode_hdr_size + nfs4_fattr_bitmap_maxsz) * sizeof(__be32);
}

static inline u32 nfsd4_setclientid_rsize(struct svc_rqst *rqstp, struct nfsd4_op *op)
{
1902 1903
	return (op_encode_hdr_size + 2 + XDR_QUADLEN(NFS4_VERIFIER_SIZE)) *
								sizeof(__be32);
1904 1905 1906 1907
}

static inline u32 nfsd4_write_rsize(struct svc_rqst *rqstp, struct nfsd4_op *op)
{
1908
	return (op_encode_hdr_size + 2 + op_encode_verifier_maxsz) * sizeof(__be32);
1909 1910 1911 1912 1913
}

static inline u32 nfsd4_exchange_id_rsize(struct svc_rqst *rqstp, struct nfsd4_op *op)
{
	return (op_encode_hdr_size + 2 + 1 + /* eir_clientid, eir_sequenceid */\
1914 1915
		1 + 1 + /* eir_flags, spr_how */\
		4 + /* spo_must_enforce & _allow with bitmap */\
1916 1917 1918 1919 1920 1921 1922 1923 1924 1925 1926 1927 1928 1929 1930 1931 1932 1933 1934 1935 1936 1937 1938 1939 1940
		2 + /*eir_server_owner.so_minor_id */\
		/* eir_server_owner.so_major_id<> */\
		XDR_QUADLEN(NFS4_OPAQUE_LIMIT) + 1 +\
		/* eir_server_scope<> */\
		XDR_QUADLEN(NFS4_OPAQUE_LIMIT) + 1 +\
		1 + /* eir_server_impl_id array length */\
		0 /* ignored eir_server_impl_id contents */) * sizeof(__be32);
}

static inline u32 nfsd4_bind_conn_to_session_rsize(struct svc_rqst *rqstp, struct nfsd4_op *op)
{
	return (op_encode_hdr_size + \
		XDR_QUADLEN(NFS4_MAX_SESSIONID_LEN) + /* bctsr_sessid */\
		2 /* bctsr_dir, use_conn_in_rdma_mode */) * sizeof(__be32);
}

static inline u32 nfsd4_create_session_rsize(struct svc_rqst *rqstp, struct nfsd4_op *op)
{
	return (op_encode_hdr_size + \
		XDR_QUADLEN(NFS4_MAX_SESSIONID_LEN) + /* sessionid */\
		2 + /* csr_sequence, csr_flags */\
		op_encode_channel_attrs_maxsz + \
		op_encode_channel_attrs_maxsz) * sizeof(__be32);
}

1941 1942 1943 1944 1945 1946 1947 1948 1949 1950 1951 1952 1953 1954 1955 1956 1957 1958 1959 1960 1961 1962 1963 1964 1965 1966 1967 1968 1969 1970
#ifdef CONFIG_NFSD_PNFS
/*
 * At this stage we don't really know what layout driver will handle the request,
 * so we need to define an arbitrary upper bound here.
 */
#define MAX_LAYOUT_SIZE		128
static inline u32 nfsd4_layoutget_rsize(struct svc_rqst *rqstp, struct nfsd4_op *op)
{
	return (op_encode_hdr_size +
		1 /* logr_return_on_close */ +
		op_encode_stateid_maxsz +
		1 /* nr of layouts */ +
		MAX_LAYOUT_SIZE) * sizeof(__be32);
}

static inline u32 nfsd4_layoutcommit_rsize(struct svc_rqst *rqstp, struct nfsd4_op *op)
{
	return (op_encode_hdr_size +
		1 /* locr_newsize */ +
		2 /* ns_size */) * sizeof(__be32);
}

static inline u32 nfsd4_layoutreturn_rsize(struct svc_rqst *rqstp, struct nfsd4_op *op)
{
	return (op_encode_hdr_size +
		1 /* lrs_stateid */ +
		op_encode_stateid_maxsz) * sizeof(__be32);
}
#endif /* CONFIG_NFSD_PNFS */

B
Benny Halevy 已提交
1971
static struct nfsd4_operation nfsd4_ops[] = {
1972 1973
	[OP_ACCESS] = {
		.op_func = (nfsd4op_func)nfsd4_access,
B
Benny Halevy 已提交
1974
		.op_name = "OP_ACCESS",
1975 1976 1977
	},
	[OP_CLOSE] = {
		.op_func = (nfsd4op_func)nfsd4_close,
1978
		.op_flags = OP_MODIFIES_SOMETHING,
B
Benny Halevy 已提交
1979
		.op_name = "OP_CLOSE",
1980
		.op_rsize_bop = (nfsd4op_rsize)nfsd4_status_stateid_rsize,
1981 1982
		.op_get_currentstateid = (stateid_getter)nfsd4_get_closestateid,
		.op_set_currentstateid = (stateid_setter)nfsd4_set_closestateid,
1983 1984 1985
	},
	[OP_COMMIT] = {
		.op_func = (nfsd4op_func)nfsd4_commit,
1986
		.op_flags = OP_MODIFIES_SOMETHING,
B
Benny Halevy 已提交
1987
		.op_name = "OP_COMMIT",
1988
		.op_rsize_bop = (nfsd4op_rsize)nfsd4_commit_rsize,
1989 1990 1991
	},
	[OP_CREATE] = {
		.op_func = (nfsd4op_func)nfsd4_create,
1992
		.op_flags = OP_MODIFIES_SOMETHING | OP_CACHEME | OP_CLEAR_STATEID,
B
Benny Halevy 已提交
1993
		.op_name = "OP_CREATE",
1994
		.op_rsize_bop = (nfsd4op_rsize)nfsd4_create_rsize,
1995 1996 1997
	},
	[OP_DELEGRETURN] = {
		.op_func = (nfsd4op_func)nfsd4_delegreturn,
1998
		.op_flags = OP_MODIFIES_SOMETHING,
B
Benny Halevy 已提交
1999
		.op_name = "OP_DELEGRETURN",
2000
		.op_rsize_bop = nfsd4_only_status_rsize,
2001
		.op_get_currentstateid = (stateid_getter)nfsd4_get_delegreturnstateid,
2002 2003 2004
	},
	[OP_GETATTR] = {
		.op_func = (nfsd4op_func)nfsd4_getattr,
2005
		.op_flags = ALLOWED_ON_ABSENT_FS,
2006
		.op_rsize_bop = nfsd4_getattr_rsize,
B
Benny Halevy 已提交
2007
		.op_name = "OP_GETATTR",
2008 2009 2010
	},
	[OP_GETFH] = {
		.op_func = (nfsd4op_func)nfsd4_getfh,
B
Benny Halevy 已提交
2011
		.op_name = "OP_GETFH",
2012 2013 2014
	},
	[OP_LINK] = {
		.op_func = (nfsd4op_func)nfsd4_link,
2015 2016
		.op_flags = ALLOWED_ON_ABSENT_FS | OP_MODIFIES_SOMETHING
				| OP_CACHEME,
B
Benny Halevy 已提交
2017
		.op_name = "OP_LINK",
2018
		.op_rsize_bop = (nfsd4op_rsize)nfsd4_link_rsize,
2019 2020 2021
	},
	[OP_LOCK] = {
		.op_func = (nfsd4op_func)nfsd4_lock,
2022
		.op_flags = OP_MODIFIES_SOMETHING,
B
Benny Halevy 已提交
2023
		.op_name = "OP_LOCK",
2024
		.op_rsize_bop = (nfsd4op_rsize)nfsd4_lock_rsize,
2025
		.op_set_currentstateid = (stateid_setter)nfsd4_set_lockstateid,
2026 2027 2028
	},
	[OP_LOCKT] = {
		.op_func = (nfsd4op_func)nfsd4_lockt,
B
Benny Halevy 已提交
2029
		.op_name = "OP_LOCKT",
2030 2031 2032
	},
	[OP_LOCKU] = {
		.op_func = (nfsd4op_func)nfsd4_locku,
2033
		.op_flags = OP_MODIFIES_SOMETHING,
B
Benny Halevy 已提交
2034
		.op_name = "OP_LOCKU",
2035
		.op_rsize_bop = (nfsd4op_rsize)nfsd4_status_stateid_rsize,
2036
		.op_get_currentstateid = (stateid_getter)nfsd4_get_lockustateid,
2037 2038 2039
	},
	[OP_LOOKUP] = {
		.op_func = (nfsd4op_func)nfsd4_lookup,
2040
		.op_flags = OP_HANDLES_WRONGSEC | OP_CLEAR_STATEID,
B
Benny Halevy 已提交
2041
		.op_name = "OP_LOOKUP",
2042 2043 2044
	},
	[OP_LOOKUPP] = {
		.op_func = (nfsd4op_func)nfsd4_lookupp,
2045
		.op_flags = OP_HANDLES_WRONGSEC | OP_CLEAR_STATEID,
B
Benny Halevy 已提交
2046
		.op_name = "OP_LOOKUPP",
2047 2048 2049
	},
	[OP_NVERIFY] = {
		.op_func = (nfsd4op_func)nfsd4_nverify,
B
Benny Halevy 已提交
2050
		.op_name = "OP_NVERIFY",
2051 2052 2053
	},
	[OP_OPEN] = {
		.op_func = (nfsd4op_func)nfsd4_open,
2054
		.op_flags = OP_HANDLES_WRONGSEC | OP_MODIFIES_SOMETHING,
B
Benny Halevy 已提交
2055
		.op_name = "OP_OPEN",
2056
		.op_rsize_bop = (nfsd4op_rsize)nfsd4_open_rsize,
2057
		.op_set_currentstateid = (stateid_setter)nfsd4_set_openstateid,
2058 2059 2060
	},
	[OP_OPEN_CONFIRM] = {
		.op_func = (nfsd4op_func)nfsd4_open_confirm,
2061
		.op_flags = OP_MODIFIES_SOMETHING,
B
Benny Halevy 已提交
2062
		.op_name = "OP_OPEN_CONFIRM",
2063
		.op_rsize_bop = (nfsd4op_rsize)nfsd4_status_stateid_rsize,
2064 2065 2066
	},
	[OP_OPEN_DOWNGRADE] = {
		.op_func = (nfsd4op_func)nfsd4_open_downgrade,
2067
		.op_flags = OP_MODIFIES_SOMETHING,
B
Benny Halevy 已提交
2068
		.op_name = "OP_OPEN_DOWNGRADE",
2069
		.op_rsize_bop = (nfsd4op_rsize)nfsd4_status_stateid_rsize,
2070 2071
		.op_get_currentstateid = (stateid_getter)nfsd4_get_opendowngradestateid,
		.op_set_currentstateid = (stateid_setter)nfsd4_set_opendowngradestateid,
2072 2073 2074
	},
	[OP_PUTFH] = {
		.op_func = (nfsd4op_func)nfsd4_putfh,
2075
		.op_flags = ALLOWED_WITHOUT_FH | ALLOWED_ON_ABSENT_FS
2076
				| OP_IS_PUTFH_LIKE | OP_CLEAR_STATEID,
B
Benny Halevy 已提交
2077
		.op_name = "OP_PUTFH",
2078
		.op_rsize_bop = (nfsd4op_rsize)nfsd4_only_status_rsize,
2079
	},
2080
	[OP_PUTPUBFH] = {
2081
		.op_func = (nfsd4op_func)nfsd4_putrootfh,
2082
		.op_flags = ALLOWED_WITHOUT_FH | ALLOWED_ON_ABSENT_FS
2083
				| OP_IS_PUTFH_LIKE | OP_CLEAR_STATEID,
B
Benny Halevy 已提交
2084
		.op_name = "OP_PUTPUBFH",
2085
		.op_rsize_bop = (nfsd4op_rsize)nfsd4_only_status_rsize,
2086
	},
2087 2088
	[OP_PUTROOTFH] = {
		.op_func = (nfsd4op_func)nfsd4_putrootfh,
2089
		.op_flags = ALLOWED_WITHOUT_FH | ALLOWED_ON_ABSENT_FS
2090
				| OP_IS_PUTFH_LIKE | OP_CLEAR_STATEID,
B
Benny Halevy 已提交
2091
		.op_name = "OP_PUTROOTFH",
2092
		.op_rsize_bop = (nfsd4op_rsize)nfsd4_only_status_rsize,
2093 2094 2095
	},
	[OP_READ] = {
		.op_func = (nfsd4op_func)nfsd4_read,
B
Benny Halevy 已提交
2096
		.op_name = "OP_READ",
2097
		.op_rsize_bop = (nfsd4op_rsize)nfsd4_read_rsize,
2098
		.op_get_currentstateid = (stateid_getter)nfsd4_get_readstateid,
2099 2100 2101
	},
	[OP_READDIR] = {
		.op_func = (nfsd4op_func)nfsd4_readdir,
B
Benny Halevy 已提交
2102
		.op_name = "OP_READDIR",
2103
		.op_rsize_bop = (nfsd4op_rsize)nfsd4_readdir_rsize,
2104 2105 2106
	},
	[OP_READLINK] = {
		.op_func = (nfsd4op_func)nfsd4_readlink,
B
Benny Halevy 已提交
2107
		.op_name = "OP_READLINK",
2108 2109 2110
	},
	[OP_REMOVE] = {
		.op_func = (nfsd4op_func)nfsd4_remove,
2111
		.op_flags = OP_MODIFIES_SOMETHING | OP_CACHEME,
B
Benny Halevy 已提交
2112
		.op_name = "OP_REMOVE",
2113
		.op_rsize_bop = (nfsd4op_rsize)nfsd4_remove_rsize,
2114 2115 2116
	},
	[OP_RENAME] = {
		.op_func = (nfsd4op_func)nfsd4_rename,
2117
		.op_flags = OP_MODIFIES_SOMETHING | OP_CACHEME,
2118 2119
		.op_name = "OP_RENAME",
		.op_rsize_bop = (nfsd4op_rsize)nfsd4_rename_rsize,
2120 2121 2122
	},
	[OP_RENEW] = {
		.op_func = (nfsd4op_func)nfsd4_renew,
2123 2124
		.op_flags = ALLOWED_WITHOUT_FH | ALLOWED_ON_ABSENT_FS
				| OP_MODIFIES_SOMETHING,
B
Benny Halevy 已提交
2125
		.op_name = "OP_RENEW",
2126 2127
		.op_rsize_bop = (nfsd4op_rsize)nfsd4_only_status_rsize,

2128 2129 2130
	},
	[OP_RESTOREFH] = {
		.op_func = (nfsd4op_func)nfsd4_restorefh,
2131
		.op_flags = ALLOWED_WITHOUT_FH | ALLOWED_ON_ABSENT_FS
2132
				| OP_IS_PUTFH_LIKE | OP_MODIFIES_SOMETHING,
B
Benny Halevy 已提交
2133
		.op_name = "OP_RESTOREFH",
2134
		.op_rsize_bop = (nfsd4op_rsize)nfsd4_only_status_rsize,
2135 2136 2137
	},
	[OP_SAVEFH] = {
		.op_func = (nfsd4op_func)nfsd4_savefh,
2138
		.op_flags = OP_HANDLES_WRONGSEC | OP_MODIFIES_SOMETHING,
B
Benny Halevy 已提交
2139
		.op_name = "OP_SAVEFH",
2140
		.op_rsize_bop = (nfsd4op_rsize)nfsd4_only_status_rsize,
2141
	},
A
Andy Adamson 已提交
2142 2143
	[OP_SECINFO] = {
		.op_func = (nfsd4op_func)nfsd4_secinfo,
2144
		.op_flags = OP_HANDLES_WRONGSEC,
B
Benny Halevy 已提交
2145
		.op_name = "OP_SECINFO",
A
Andy Adamson 已提交
2146
	},
2147 2148
	[OP_SETATTR] = {
		.op_func = (nfsd4op_func)nfsd4_setattr,
B
Benny Halevy 已提交
2149
		.op_name = "OP_SETATTR",
2150
		.op_flags = OP_MODIFIES_SOMETHING | OP_CACHEME,
2151
		.op_rsize_bop = (nfsd4op_rsize)nfsd4_setattr_rsize,
2152
		.op_get_currentstateid = (stateid_getter)nfsd4_get_setattrstateid,
2153 2154 2155
	},
	[OP_SETCLIENTID] = {
		.op_func = (nfsd4op_func)nfsd4_setclientid,
2156
		.op_flags = ALLOWED_WITHOUT_FH | ALLOWED_ON_ABSENT_FS
2157
				| OP_MODIFIES_SOMETHING | OP_CACHEME,
B
Benny Halevy 已提交
2158
		.op_name = "OP_SETCLIENTID",
2159
		.op_rsize_bop = (nfsd4op_rsize)nfsd4_setclientid_rsize,
2160 2161 2162
	},
	[OP_SETCLIENTID_CONFIRM] = {
		.op_func = (nfsd4op_func)nfsd4_setclientid_confirm,
2163
		.op_flags = ALLOWED_WITHOUT_FH | ALLOWED_ON_ABSENT_FS
2164
				| OP_MODIFIES_SOMETHING | OP_CACHEME,
B
Benny Halevy 已提交
2165
		.op_name = "OP_SETCLIENTID_CONFIRM",
2166
		.op_rsize_bop = (nfsd4op_rsize)nfsd4_only_status_rsize,
2167 2168 2169
	},
	[OP_VERIFY] = {
		.op_func = (nfsd4op_func)nfsd4_verify,
B
Benny Halevy 已提交
2170
		.op_name = "OP_VERIFY",
2171 2172 2173
	},
	[OP_WRITE] = {
		.op_func = (nfsd4op_func)nfsd4_write,
2174
		.op_flags = OP_MODIFIES_SOMETHING | OP_CACHEME,
B
Benny Halevy 已提交
2175
		.op_name = "OP_WRITE",
2176
		.op_rsize_bop = (nfsd4op_rsize)nfsd4_write_rsize,
2177
		.op_get_currentstateid = (stateid_getter)nfsd4_get_writestateid,
2178 2179 2180
	},
	[OP_RELEASE_LOCKOWNER] = {
		.op_func = (nfsd4op_func)nfsd4_release_lockowner,
2181 2182
		.op_flags = ALLOWED_WITHOUT_FH | ALLOWED_ON_ABSENT_FS
				| OP_MODIFIES_SOMETHING,
B
Benny Halevy 已提交
2183
		.op_name = "OP_RELEASE_LOCKOWNER",
2184
		.op_rsize_bop = (nfsd4op_rsize)nfsd4_only_status_rsize,
2185
	},
A
Andy Adamson 已提交
2186 2187 2188 2189

	/* NFSv4.1 operations */
	[OP_EXCHANGE_ID] = {
		.op_func = (nfsd4op_func)nfsd4_exchange_id,
2190 2191
		.op_flags = ALLOWED_WITHOUT_FH | ALLOWED_AS_FIRST_OP
				| OP_MODIFIES_SOMETHING,
A
Andy Adamson 已提交
2192
		.op_name = "OP_EXCHANGE_ID",
2193
		.op_rsize_bop = (nfsd4op_rsize)nfsd4_exchange_id_rsize,
A
Andy Adamson 已提交
2194
	},
2195 2196 2197 2198 2199 2200
	[OP_BACKCHANNEL_CTL] = {
		.op_func = (nfsd4op_func)nfsd4_backchannel_ctl,
		.op_flags = ALLOWED_WITHOUT_FH | OP_MODIFIES_SOMETHING,
		.op_name = "OP_BACKCHANNEL_CTL",
		.op_rsize_bop = (nfsd4op_rsize)nfsd4_only_status_rsize,
	},
2201 2202
	[OP_BIND_CONN_TO_SESSION] = {
		.op_func = (nfsd4op_func)nfsd4_bind_conn_to_session,
2203 2204
		.op_flags = ALLOWED_WITHOUT_FH | ALLOWED_AS_FIRST_OP
				| OP_MODIFIES_SOMETHING,
2205
		.op_name = "OP_BIND_CONN_TO_SESSION",
2206
		.op_rsize_bop = (nfsd4op_rsize)nfsd4_bind_conn_to_session_rsize,
2207
	},
A
Andy Adamson 已提交
2208 2209
	[OP_CREATE_SESSION] = {
		.op_func = (nfsd4op_func)nfsd4_create_session,
2210 2211
		.op_flags = ALLOWED_WITHOUT_FH | ALLOWED_AS_FIRST_OP
				| OP_MODIFIES_SOMETHING,
A
Andy Adamson 已提交
2212
		.op_name = "OP_CREATE_SESSION",
2213
		.op_rsize_bop = (nfsd4op_rsize)nfsd4_create_session_rsize,
A
Andy Adamson 已提交
2214 2215 2216
	},
	[OP_DESTROY_SESSION] = {
		.op_func = (nfsd4op_func)nfsd4_destroy_session,
2217 2218
		.op_flags = ALLOWED_WITHOUT_FH | ALLOWED_AS_FIRST_OP
				| OP_MODIFIES_SOMETHING,
A
Andy Adamson 已提交
2219
		.op_name = "OP_DESTROY_SESSION",
2220
		.op_rsize_bop = (nfsd4op_rsize)nfsd4_only_status_rsize,
A
Andy Adamson 已提交
2221 2222 2223
	},
	[OP_SEQUENCE] = {
		.op_func = (nfsd4op_func)nfsd4_sequence,
2224
		.op_flags = ALLOWED_WITHOUT_FH | ALLOWED_AS_FIRST_OP,
A
Andy Adamson 已提交
2225
		.op_name = "OP_SEQUENCE",
2226
		.op_rsize_bop = (nfsd4op_rsize)nfsd4_sequence_rsize,
A
Andy Adamson 已提交
2227
	},
2228
	[OP_DESTROY_CLIENTID] = {
2229
		.op_func = (nfsd4op_func)nfsd4_destroy_clientid,
2230 2231
		.op_flags = ALLOWED_WITHOUT_FH | ALLOWED_AS_FIRST_OP
				| OP_MODIFIES_SOMETHING,
2232
		.op_name = "OP_DESTROY_CLIENTID",
2233
		.op_rsize_bop = (nfsd4op_rsize)nfsd4_only_status_rsize,
2234
	},
2235 2236
	[OP_RECLAIM_COMPLETE] = {
		.op_func = (nfsd4op_func)nfsd4_reclaim_complete,
2237
		.op_flags = ALLOWED_WITHOUT_FH | OP_MODIFIES_SOMETHING,
2238
		.op_name = "OP_RECLAIM_COMPLETE",
2239
		.op_rsize_bop = (nfsd4op_rsize)nfsd4_only_status_rsize,
2240
	},
J
J. Bruce Fields 已提交
2241 2242
	[OP_SECINFO_NO_NAME] = {
		.op_func = (nfsd4op_func)nfsd4_secinfo_no_name,
2243
		.op_flags = OP_HANDLES_WRONGSEC,
J
J. Bruce Fields 已提交
2244 2245
		.op_name = "OP_SECINFO_NO_NAME",
	},
2246 2247 2248 2249 2250
	[OP_TEST_STATEID] = {
		.op_func = (nfsd4op_func)nfsd4_test_stateid,
		.op_flags = ALLOWED_WITHOUT_FH,
		.op_name = "OP_TEST_STATEID",
	},
2251 2252
	[OP_FREE_STATEID] = {
		.op_func = (nfsd4op_func)nfsd4_free_stateid,
2253
		.op_flags = ALLOWED_WITHOUT_FH | OP_MODIFIES_SOMETHING,
2254
		.op_name = "OP_FREE_STATEID",
2255
		.op_get_currentstateid = (stateid_getter)nfsd4_get_freestateid,
2256
		.op_rsize_bop = (nfsd4op_rsize)nfsd4_only_status_rsize,
2257
	},
2258 2259 2260 2261 2262 2263 2264 2265 2266 2267 2268 2269 2270 2271 2272 2273 2274 2275 2276 2277 2278 2279 2280 2281 2282
#ifdef CONFIG_NFSD_PNFS
	[OP_GETDEVICEINFO] = {
		.op_func = (nfsd4op_func)nfsd4_getdeviceinfo,
		.op_flags = ALLOWED_WITHOUT_FH,
		.op_name = "OP_GETDEVICEINFO",
	},
	[OP_LAYOUTGET] = {
		.op_func = (nfsd4op_func)nfsd4_layoutget,
		.op_flags = OP_MODIFIES_SOMETHING,
		.op_name = "OP_LAYOUTGET",
		.op_rsize_bop = (nfsd4op_rsize)nfsd4_layoutget_rsize,
	},
	[OP_LAYOUTCOMMIT] = {
		.op_func = (nfsd4op_func)nfsd4_layoutcommit,
		.op_flags = OP_MODIFIES_SOMETHING,
		.op_name = "OP_LAYOUTCOMMIT",
		.op_rsize_bop = (nfsd4op_rsize)nfsd4_layoutcommit_rsize,
	},
	[OP_LAYOUTRETURN] = {
		.op_func = (nfsd4op_func)nfsd4_layoutreturn,
		.op_flags = OP_MODIFIES_SOMETHING,
		.op_name = "OP_LAYOUTRETURN",
		.op_rsize_bop = (nfsd4op_rsize)nfsd4_layoutreturn_rsize,
	},
#endif /* CONFIG_NFSD_PNFS */
A
Anna Schumaker 已提交
2283 2284

	/* NFSv4.2 operations */
A
Anna Schumaker 已提交
2285 2286 2287 2288
	[OP_ALLOCATE] = {
		.op_func = (nfsd4op_func)nfsd4_allocate,
		.op_flags = OP_MODIFIES_SOMETHING | OP_CACHEME,
		.op_name = "OP_ALLOCATE",
2289
		.op_rsize_bop = (nfsd4op_rsize)nfsd4_only_status_rsize,
A
Anna Schumaker 已提交
2290
	},
A
Anna Schumaker 已提交
2291 2292 2293 2294
	[OP_DEALLOCATE] = {
		.op_func = (nfsd4op_func)nfsd4_deallocate,
		.op_flags = OP_MODIFIES_SOMETHING | OP_CACHEME,
		.op_name = "OP_DEALLOCATE",
2295
		.op_rsize_bop = (nfsd4op_rsize)nfsd4_only_status_rsize,
A
Anna Schumaker 已提交
2296
	},
A
Anna Schumaker 已提交
2297 2298 2299 2300
	[OP_SEEK] = {
		.op_func = (nfsd4op_func)nfsd4_seek,
		.op_name = "OP_SEEK",
	},
2301 2302
};

2303 2304 2305 2306 2307 2308 2309 2310 2311 2312 2313 2314
int nfsd4_max_reply(struct svc_rqst *rqstp, struct nfsd4_op *op)
{
	struct nfsd4_operation *opdesc;
	nfsd4op_rsize estimator;

	if (op->opnum == OP_ILLEGAL)
		return op_encode_hdr_size * sizeof(__be32);
	opdesc = OPDESC(op);
	estimator = opdesc->op_rsize_bop;
	return estimator ? estimator(rqstp, op) : PAGE_SIZE;
}

2315 2316 2317 2318 2319 2320 2321 2322 2323
void warn_on_nonidempotent_op(struct nfsd4_op *op)
{
	if (OPDESC(op)->op_flags & OP_MODIFIES_SOMETHING) {
		pr_err("unable to encode reply to nonidempotent op %d (%s)\n",
			op->opnum, nfsd4_op_name(op->opnum));
		WARN_ON_ONCE(1);
	}
}

A
Adrian Bunk 已提交
2324
static const char *nfsd4_op_name(unsigned opnum)
B
Benny Halevy 已提交
2325 2326 2327 2328 2329 2330
{
	if (opnum < ARRAY_SIZE(nfsd4_ops))
		return nfsd4_ops[opnum].op_name;
	return "unknown_operation";
}

L
Linus Torvalds 已提交
2331 2332 2333 2334
#define nfsd4_voidres			nfsd4_voidargs
struct nfsd4_voidargs { int dummy; };

static struct svc_procedure		nfsd_procedures4[2] = {
2335 2336 2337 2338 2339 2340 2341 2342 2343 2344 2345 2346 2347 2348
	[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),
2349
		.pc_release = nfsd4_release_compoundargs,
2350 2351 2352
		.pc_cachetype = RC_NOCACHE,
		.pc_xdrressize = NFSD_BUFSIZE/4,
	},
L
Linus Torvalds 已提交
2353 2354 2355 2356 2357 2358 2359 2360
};

struct svc_version	nfsd_version4 = {
		.vs_vers	= 4,
		.vs_nproc	= 2,
		.vs_proc	= nfsd_procedures4,
		.vs_dispatch	= nfsd_dispatch,
		.vs_xdrsize	= NFS4_SVC_XDRSIZE,
2361
		.vs_rpcb_optnl	= 1,
L
Linus Torvalds 已提交
2362 2363 2364 2365 2366 2367 2368
};

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