inode.c 60.1 KB
Newer Older
L
Linus Torvalds 已提交
1 2 3 4 5 6 7
/*
 *  linux/fs/nfs/inode.c
 *
 *  Copyright (C) 1992  Rick Sladkey
 *
 *  nfs inode and superblock handling functions
 *
A
Alan Cox 已提交
8
 *  Modularised by Alan Cox <alan@lxorguk.ukuu.org.uk>, while hacking some
L
Linus Torvalds 已提交
9 10 11 12 13 14 15 16 17
 *  experimental NFS changes. Modularisation taken straight from SYS5 fs.
 *
 *  Change to nfs_read_super() to permit NFS mounts to multi-homed hosts.
 *  J.S.Peatfield@damtp.cam.ac.uk
 *
 */

#include <linux/module.h>
#include <linux/init.h>
18
#include <linux/sched/signal.h>
L
Linus Torvalds 已提交
19 20 21 22 23 24 25 26 27
#include <linux/time.h>
#include <linux/kernel.h>
#include <linux/mm.h>
#include <linux/string.h>
#include <linux/stat.h>
#include <linux/errno.h>
#include <linux/unistd.h>
#include <linux/sunrpc/clnt.h>
#include <linux/sunrpc/stats.h>
28
#include <linux/sunrpc/metrics.h>
L
Linus Torvalds 已提交
29 30 31 32 33 34 35
#include <linux/nfs_fs.h>
#include <linux/nfs_mount.h>
#include <linux/nfs4_mount.h>
#include <linux/lockd/bind.h>
#include <linux/seq_file.h>
#include <linux/mount.h>
#include <linux/vfs.h>
36 37
#include <linux/inet.h>
#include <linux/nfs_xdr.h>
38
#include <linux/slab.h>
39
#include <linux/compat.h>
40
#include <linux/freezer.h>
41
#include <linux/uaccess.h>
J
Jeff Layton 已提交
42
#include <linux/iversion.h>
L
Linus Torvalds 已提交
43

44
#include "nfs4_fs.h"
45
#include "callback.h"
L
Linus Torvalds 已提交
46
#include "delegation.h"
47
#include "iostat.h"
D
David Howells 已提交
48
#include "internal.h"
49
#include "fscache.h"
50
#include "pnfs.h"
51
#include "nfs.h"
52
#include "netns.h"
L
Linus Torvalds 已提交
53

54 55
#include "nfstrace.h"

L
Linus Torvalds 已提交
56 57
#define NFSDBG_FACILITY		NFSDBG_VFS

58 59 60
#define NFS_64_BIT_INODE_NUMBERS_ENABLED	1

/* Default is to see 64-bit inode numbers */
61
static bool enable_ino64 = NFS_64_BIT_INODE_NUMBERS_ENABLED;
62

L
Linus Torvalds 已提交
63
static void nfs_invalidate_inode(struct inode *);
64
static int nfs_update_inode(struct inode *, struct nfs_fattr *);
L
Linus Torvalds 已提交
65

66
static struct kmem_cache * nfs_inode_cachep;
67

L
Linus Torvalds 已提交
68 69 70 71 72 73
static inline unsigned long
nfs_fattr_to_ino_t(struct nfs_fattr *fattr)
{
	return nfs_fileid_to_ino_t(fattr->fileid);
}

74
static int nfs_wait_killable(int mode)
75
{
76
	freezable_schedule_unsafe();
77 78
	if (signal_pending_state(mode, current))
		return -ERESTARTSYS;
79 80
	return 0;
}
81 82 83 84 85

int nfs_wait_bit_killable(struct wait_bit_key *key, int mode)
{
	return nfs_wait_killable(mode);
}
B
Bryan Schumaker 已提交
86
EXPORT_SYMBOL_GPL(nfs_wait_bit_killable);
87

88
int nfs_wait_atomic_killable(atomic_t *p, unsigned int mode)
89
{
90
	return nfs_wait_killable(mode);
91 92
}

93 94 95 96 97 98 99 100 101
/**
 * nfs_compat_user_ino64 - returns the user-visible inode number
 * @fileid: 64-bit fileid
 *
 * This function returns a 32-bit inode number if the boot parameter
 * nfs.enable_ino64 is zero.
 */
u64 nfs_compat_user_ino64(u64 fileid)
{
102 103 104 105 106
#ifdef CONFIG_COMPAT
	compat_ulong_t ino;
#else	
	unsigned long ino;
#endif
107 108 109 110 111 112 113 114 115

	if (enable_ino64)
		return fileid;
	ino = fileid;
	if (sizeof(ino) < sizeof(fileid))
		ino ^= fileid >> (sizeof(fileid)-sizeof(ino)) * 8;
	return ino;
}

116 117 118 119 120 121
int nfs_drop_inode(struct inode *inode)
{
	return NFS_STALE(inode) || generic_drop_inode(inode);
}
EXPORT_SYMBOL_GPL(nfs_drop_inode);

122
void nfs_clear_inode(struct inode *inode)
L
Linus Torvalds 已提交
123
{
T
Trond Myklebust 已提交
124 125 126
	/*
	 * The following should never happen...
	 */
127 128
	WARN_ON_ONCE(nfs_have_writebacks(inode));
	WARN_ON_ONCE(!list_empty(&NFS_I(inode)->open_files));
129
	nfs_zap_acl_cache(inode);
130
	nfs_access_zap_cache(inode);
131
	nfs_fscache_clear_inode(inode);
L
Linus Torvalds 已提交
132
}
B
Bryan Schumaker 已提交
133
EXPORT_SYMBOL_GPL(nfs_clear_inode);
L
Linus Torvalds 已提交
134

135 136
void nfs_evict_inode(struct inode *inode)
{
137
	truncate_inode_pages_final(&inode->i_data);
138
	clear_inode(inode);
139 140 141
	nfs_clear_inode(inode);
}

142
int nfs_sync_inode(struct inode *inode)
143
{
144
	inode_dio_wait(inode);
145 146
	return nfs_wb_all(inode);
}
147
EXPORT_SYMBOL_GPL(nfs_sync_inode);
148

T
Trond Myklebust 已提交
149 150 151 152 153
/**
 * nfs_sync_mapping - helper to flush all mmapped dirty data to disk
 */
int nfs_sync_mapping(struct address_space *mapping)
{
T
Trond Myklebust 已提交
154
	int ret = 0;
T
Trond Myklebust 已提交
155

T
Trond Myklebust 已提交
156 157 158 159
	if (mapping->nrpages != 0) {
		unmap_mapping_range(mapping, 0, 0, 0);
		ret = nfs_wb_all(mapping->host);
	}
T
Trond Myklebust 已提交
160 161 162
	return ret;
}

163 164 165 166 167 168 169
static int nfs_attribute_timeout(struct inode *inode)
{
	struct nfs_inode *nfsi = NFS_I(inode);

	return !time_in_range_open(jiffies, nfsi->read_cache_jiffies, nfsi->read_cache_jiffies + nfsi->attrtimeo);
}

170 171 172 173 174 175 176 177 178 179 180 181 182 183 184 185 186 187 188 189 190 191 192 193 194 195 196 197 198 199
static bool nfs_check_cache_invalid_delegated(struct inode *inode, unsigned long flags)
{
	unsigned long cache_validity = READ_ONCE(NFS_I(inode)->cache_validity);

	/* Special case for the pagecache or access cache */
	if (flags == NFS_INO_REVAL_PAGECACHE &&
	    !(cache_validity & NFS_INO_REVAL_FORCED))
		return false;
	return (cache_validity & flags) != 0;
}

static bool nfs_check_cache_invalid_not_delegated(struct inode *inode, unsigned long flags)
{
	unsigned long cache_validity = READ_ONCE(NFS_I(inode)->cache_validity);

	if ((cache_validity & flags) != 0)
		return true;
	if (nfs_attribute_timeout(inode))
		return true;
	return false;
}

bool nfs_check_cache_invalid(struct inode *inode, unsigned long flags)
{
	if (NFS_PROTO(inode)->have_delegation(inode, FMODE_READ))
		return nfs_check_cache_invalid_delegated(inode, flags);

	return nfs_check_cache_invalid_not_delegated(inode, flags);
}

200 201 202 203 204 205 206 207 208 209 210
static void nfs_set_cache_invalid(struct inode *inode, unsigned long flags)
{
	struct nfs_inode *nfsi = NFS_I(inode);

	if (inode->i_mapping->nrpages == 0)
		flags &= ~NFS_INO_INVALID_DATA;
	nfsi->cache_validity |= flags;
	if (flags & NFS_INO_INVALID_DATA)
		nfs_fscache_invalidate(inode);
}

L
Linus Torvalds 已提交
211 212 213
/*
 * Invalidate the local caches
 */
214
static void nfs_zap_caches_locked(struct inode *inode)
L
Linus Torvalds 已提交
215 216 217 218
{
	struct nfs_inode *nfsi = NFS_I(inode);
	int mode = inode->i_mode;

C
Chuck Lever 已提交
219 220
	nfs_inc_stats(inode, NFSIOS_ATTRINVALIDATE);

221 222
	nfsi->attrtimeo = NFS_MINATTRTIMEO(inode);
	nfsi->attrtimeo_timestamp = jiffies;
L
Linus Torvalds 已提交
223

224
	memset(NFS_I(inode)->cookieverf, 0, sizeof(NFS_I(inode)->cookieverf));
D
David Howells 已提交
225
	if (S_ISREG(mode) || S_ISDIR(mode) || S_ISLNK(mode)) {
226
		nfs_set_cache_invalid(inode, NFS_INO_INVALID_ATTR
227 228 229
					| NFS_INO_INVALID_DATA
					| NFS_INO_INVALID_ACCESS
					| NFS_INO_INVALID_ACL
230
					| NFS_INO_REVAL_PAGECACHE);
231
	} else
232
		nfs_set_cache_invalid(inode, NFS_INO_INVALID_ATTR
233 234
					| NFS_INO_INVALID_ACCESS
					| NFS_INO_INVALID_ACL
235
					| NFS_INO_REVAL_PAGECACHE);
236
	nfs_zap_label_cache_locked(nfsi);
237
}
238

239 240 241 242
void nfs_zap_caches(struct inode *inode)
{
	spin_lock(&inode->i_lock);
	nfs_zap_caches_locked(inode);
243
	spin_unlock(&inode->i_lock);
244 245
}

246 247 248 249
void nfs_zap_mapping(struct inode *inode, struct address_space *mapping)
{
	if (mapping->nrpages != 0) {
		spin_lock(&inode->i_lock);
250
		nfs_set_cache_invalid(inode, NFS_INO_INVALID_DATA);
251 252 253 254
		spin_unlock(&inode->i_lock);
	}
}

255
void nfs_zap_acl_cache(struct inode *inode)
256 257 258 259 260 261
{
	void (*clear_acl_cache)(struct inode *);

	clear_acl_cache = NFS_PROTO(inode)->clear_acl_cache;
	if (clear_acl_cache != NULL)
		clear_acl_cache(inode);
262
	spin_lock(&inode->i_lock);
263
	NFS_I(inode)->cache_validity &= ~NFS_INO_INVALID_ACL;
264
	spin_unlock(&inode->i_lock);
L
Linus Torvalds 已提交
265
}
B
Bryan Schumaker 已提交
266
EXPORT_SYMBOL_GPL(nfs_zap_acl_cache);
L
Linus Torvalds 已提交
267

268 269 270
void nfs_invalidate_atime(struct inode *inode)
{
	spin_lock(&inode->i_lock);
271
	nfs_set_cache_invalid(inode, NFS_INO_INVALID_ATIME);
272 273
	spin_unlock(&inode->i_lock);
}
B
Bryan Schumaker 已提交
274
EXPORT_SYMBOL_GPL(nfs_invalidate_atime);
275

L
Linus Torvalds 已提交
276
/*
277 278
 * Invalidate, but do not unhash, the inode.
 * NB: must be called with inode->i_lock held!
L
Linus Torvalds 已提交
279
 */
280
static void nfs_invalidate_inode(struct inode *inode)
L
Linus Torvalds 已提交
281
{
B
Benny Halevy 已提交
282
	set_bit(NFS_INO_STALE, &NFS_I(inode)->flags);
283
	nfs_zap_caches_locked(inode);
L
Linus Torvalds 已提交
284 285 286 287 288 289 290 291 292 293 294 295 296 297 298 299 300 301 302 303 304 305
}

struct nfs_find_desc {
	struct nfs_fh		*fh;
	struct nfs_fattr	*fattr;
};

/*
 * In NFSv3 we can have 64bit inode numbers. In order to support
 * this, and re-exported directories (also seen in NFSv2)
 * we are forced to allow 2 different inodes to have the same
 * i_ino.
 */
static int
nfs_find_actor(struct inode *inode, void *opaque)
{
	struct nfs_find_desc	*desc = (struct nfs_find_desc *)opaque;
	struct nfs_fh		*fh = desc->fh;
	struct nfs_fattr	*fattr = desc->fattr;

	if (NFS_FILEID(inode) != fattr->fileid)
		return 0;
306 307
	if ((S_IFMT & inode->i_mode) != (S_IFMT & fattr->mode))
		return 0;
L
Linus Torvalds 已提交
308 309 310 311 312 313 314 315 316 317 318 319 320
	if (nfs_compare_fh(NFS_FH(inode), fh))
		return 0;
	if (is_bad_inode(inode) || NFS_STALE(inode))
		return 0;
	return 1;
}

static int
nfs_init_locked(struct inode *inode, void *opaque)
{
	struct nfs_find_desc	*desc = (struct nfs_find_desc *)opaque;
	struct nfs_fattr	*fattr = desc->fattr;

321
	set_nfs_fileid(inode, fattr->fileid);
322
	inode->i_mode = fattr->mode;
L
Linus Torvalds 已提交
323 324 325 326
	nfs_copy_fh(NFS_FH(inode), desc->fh);
	return 0;
}

327
#ifdef CONFIG_NFS_V4_SECURITY_LABEL
328 329 330 331 332 333 334
static void nfs_clear_label_invalid(struct inode *inode)
{
	spin_lock(&inode->i_lock);
	NFS_I(inode)->cache_validity &= ~NFS_INO_INVALID_LABEL;
	spin_unlock(&inode->i_lock);
}

335 336 337 338 339 340 341 342 343 344 345 346 347 348 349 350 351
void nfs_setsecurity(struct inode *inode, struct nfs_fattr *fattr,
					struct nfs4_label *label)
{
	int error;

	if (label == NULL)
		return;

	if ((fattr->valid & NFS_ATTR_FATTR_V4_SECURITY_LABEL) && inode->i_security) {
		error = security_inode_notifysecctx(inode, label->label,
				label->len);
		if (error)
			printk(KERN_ERR "%s() %s %d "
					"security_inode_notifysecctx() %d\n",
					__func__,
					(char *)label->label,
					label->len, error);
352
		nfs_clear_label_invalid(inode);
353 354 355
	}
}

356 357 358 359 360 361 362 363 364 365 366 367 368 369 370 371 372 373 374 375 376 377 378 379 380
struct nfs4_label *nfs4_label_alloc(struct nfs_server *server, gfp_t flags)
{
	struct nfs4_label *label = NULL;
	int minor_version = server->nfs_client->cl_minorversion;

	if (minor_version < 2)
		return label;

	if (!(server->caps & NFS_CAP_SECURITY_LABEL))
		return label;

	label = kzalloc(sizeof(struct nfs4_label), flags);
	if (label == NULL)
		return ERR_PTR(-ENOMEM);

	label->label = kzalloc(NFS4_MAXLABELLEN, flags);
	if (label->label == NULL) {
		kfree(label);
		return ERR_PTR(-ENOMEM);
	}
	label->len = NFS4_MAXLABELLEN;

	return label;
}
EXPORT_SYMBOL_GPL(nfs4_label_alloc);
381
#else
382
void nfs_setsecurity(struct inode *inode, struct nfs_fattr *fattr,
383 384 385
					struct nfs4_label *label)
{
}
386
#endif
387
EXPORT_SYMBOL_GPL(nfs_setsecurity);
388

P
Peng Tao 已提交
389 390 391 392 393 394 395 396 397 398 399 400 401 402 403 404 405 406 407 408 409 410
/* Search for inode identified by fh, fileid and i_mode in inode cache. */
struct inode *
nfs_ilookup(struct super_block *sb, struct nfs_fattr *fattr, struct nfs_fh *fh)
{
	struct nfs_find_desc desc = {
		.fh	= fh,
		.fattr	= fattr,
	};
	struct inode *inode;
	unsigned long hash;

	if (!(fattr->valid & NFS_ATTR_FATTR_FILEID) ||
	    !(fattr->valid & NFS_ATTR_FATTR_TYPE))
		return NULL;

	hash = nfs_fattr_to_ino_t(fattr);
	inode = ilookup5(sb, hash, nfs_find_actor, &desc);

	dprintk("%s: returning %p\n", __func__, inode);
	return inode;
}

L
Linus Torvalds 已提交
411 412 413 414 415
/*
 * This is our front-end to iget that looks up inodes by file handle
 * instead of inode number.
 */
struct inode *
416
nfs_fhget(struct super_block *sb, struct nfs_fh *fh, struct nfs_fattr *fattr, struct nfs4_label *label)
L
Linus Torvalds 已提交
417 418 419 420 421
{
	struct nfs_find_desc desc = {
		.fh	= fh,
		.fattr	= fattr
	};
422
	struct inode *inode = ERR_PTR(-ENOENT);
L
Linus Torvalds 已提交
423 424
	unsigned long hash;

425 426
	nfs_attr_check_mountpoint(sb, fattr);

427 428 429
	if (nfs_attr_use_mounted_on_fileid(fattr))
		fattr->fileid = fattr->mounted_on_fileid;
	else if ((fattr->valid & NFS_ATTR_FATTR_FILEID) == 0)
L
Linus Torvalds 已提交
430
		goto out_no_inode;
431
	if ((fattr->valid & NFS_ATTR_FATTR_TYPE) == 0)
L
Linus Torvalds 已提交
432 433 434 435
		goto out_no_inode;

	hash = nfs_fattr_to_ino_t(fattr);

436 437 438
	inode = iget5_locked(sb, hash, nfs_find_actor, nfs_init_locked, &desc);
	if (inode == NULL) {
		inode = ERR_PTR(-ENOMEM);
L
Linus Torvalds 已提交
439
		goto out_no_inode;
440
	}
L
Linus Torvalds 已提交
441 442 443

	if (inode->i_state & I_NEW) {
		struct nfs_inode *nfsi = NFS_I(inode);
444
		unsigned long now = jiffies;
L
Linus Torvalds 已提交
445 446 447 448 449 450 451 452

		/* We set i_ino for the few things that still rely on it,
		 * such as stat(2) */
		inode->i_ino = hash;

		/* We can't support update_atime(), since the server will reset it */
		inode->i_flags |= S_NOATIME|S_NOCMTIME;
		inode->i_mode = fattr->mode;
453 454
		if ((fattr->valid & NFS_ATTR_FATTR_MODE) == 0
				&& nfs_server_capable(inode, NFS_CAP_MODE))
455
			nfs_set_cache_invalid(inode, NFS_INO_INVALID_ATTR);
L
Linus Torvalds 已提交
456 457 458
		/* Why so? Because we want revalidate for devices/FIFOs, and
		 * that's precisely what we have in nfs_file_inode_operations.
		 */
459
		inode->i_op = NFS_SB(sb)->nfs_client->rpc_ops->file_inode_ops;
L
Linus Torvalds 已提交
460
		if (S_ISREG(inode->i_mode)) {
461
			inode->i_fop = NFS_SB(sb)->nfs_client->rpc_ops->file_ops;
L
Linus Torvalds 已提交
462 463
			inode->i_data.a_ops = &nfs_file_aops;
		} else if (S_ISDIR(inode->i_mode)) {
464
			inode->i_op = NFS_SB(sb)->nfs_client->rpc_ops->dir_inode_ops;
L
Linus Torvalds 已提交
465
			inode->i_fop = &nfs_dir_operations;
466
			inode->i_data.a_ops = &nfs_dir_aops;
467
			/* Deal with crossing mountpoints */
468 469
			if (fattr->valid & NFS_ATTR_FATTR_MOUNTPOINT ||
					fattr->valid & NFS_ATTR_FATTR_V4_REFERRAL) {
M
Manoj Naik 已提交
470 471 472 473
				if (fattr->valid & NFS_ATTR_FATTR_V4_REFERRAL)
					inode->i_op = &nfs_referral_inode_operations;
				else
					inode->i_op = &nfs_mountpoint_inode_operations;
474
				inode->i_fop = NULL;
475
				inode->i_flags |= S_AUTOMOUNT;
476
			}
477
		} else if (S_ISLNK(inode->i_mode)) {
L
Linus Torvalds 已提交
478
			inode->i_op = &nfs_symlink_inode_operations;
479 480
			inode_nohighmem(inode);
		} else
L
Linus Torvalds 已提交
481 482
			init_special_inode(inode, inode->i_mode, fattr->rdev);

483 484 485
		memset(&inode->i_atime, 0, sizeof(inode->i_atime));
		memset(&inode->i_mtime, 0, sizeof(inode->i_mtime));
		memset(&inode->i_ctime, 0, sizeof(inode->i_ctime));
J
Jeff Layton 已提交
486
		inode_set_iversion_raw(inode, 0);
487
		inode->i_size = 0;
488
		clear_nlink(inode);
489 490
		inode->i_uid = make_kuid(&init_user_ns, -2);
		inode->i_gid = make_kgid(&init_user_ns, -2);
491 492
		inode->i_blocks = 0;
		memset(nfsi->cookieverf, 0, sizeof(nfsi->cookieverf));
493 494
		nfsi->write_io = 0;
		nfsi->read_io = 0;
495

496
		nfsi->read_cache_jiffies = fattr->time_start;
497
		nfsi->attr_gencount = fattr->gencount;
498 499
		if (fattr->valid & NFS_ATTR_FATTR_ATIME)
			inode->i_atime = fattr->atime;
500
		else if (nfs_server_capable(inode, NFS_CAP_ATIME))
501
			nfs_set_cache_invalid(inode, NFS_INO_INVALID_ATTR);
502 503
		if (fattr->valid & NFS_ATTR_FATTR_MTIME)
			inode->i_mtime = fattr->mtime;
504
		else if (nfs_server_capable(inode, NFS_CAP_MTIME))
505
			nfs_set_cache_invalid(inode, NFS_INO_INVALID_ATTR);
506 507
		if (fattr->valid & NFS_ATTR_FATTR_CTIME)
			inode->i_ctime = fattr->ctime;
508
		else if (nfs_server_capable(inode, NFS_CAP_CTIME))
509
			nfs_set_cache_invalid(inode, NFS_INO_INVALID_ATTR);
510
		if (fattr->valid & NFS_ATTR_FATTR_CHANGE)
J
Jeff Layton 已提交
511
			inode_set_iversion_raw(inode, fattr->change_attr);
512
		else
513 514
			nfs_set_cache_invalid(inode, NFS_INO_INVALID_ATTR
				| NFS_INO_REVAL_PAGECACHE);
515 516
		if (fattr->valid & NFS_ATTR_FATTR_SIZE)
			inode->i_size = nfs_size_to_loff_t(fattr->size);
517
		else
518 519
			nfs_set_cache_invalid(inode, NFS_INO_INVALID_ATTR
				| NFS_INO_REVAL_PAGECACHE);
520
		if (fattr->valid & NFS_ATTR_FATTR_NLINK)
M
Miklos Szeredi 已提交
521
			set_nlink(inode, fattr->nlink);
522
		else if (nfs_server_capable(inode, NFS_CAP_NLINK))
523
			nfs_set_cache_invalid(inode, NFS_INO_INVALID_ATTR);
524 525
		if (fattr->valid & NFS_ATTR_FATTR_OWNER)
			inode->i_uid = fattr->uid;
526
		else if (nfs_server_capable(inode, NFS_CAP_OWNER))
527
			nfs_set_cache_invalid(inode, NFS_INO_INVALID_ATTR);
528 529
		if (fattr->valid & NFS_ATTR_FATTR_GROUP)
			inode->i_gid = fattr->gid;
530
		else if (nfs_server_capable(inode, NFS_CAP_OWNER_GROUP))
531
			nfs_set_cache_invalid(inode, NFS_INO_INVALID_ATTR);
532 533 534
		if (fattr->valid & NFS_ATTR_FATTR_BLOCKS_USED)
			inode->i_blocks = fattr->du.nfs2.blocks;
		if (fattr->valid & NFS_ATTR_FATTR_SPACE_USED) {
L
Linus Torvalds 已提交
535 536 537 538 539
			/*
			 * report the blocks in 512byte units
			 */
			inode->i_blocks = nfs_calc_block_size(fattr->du.nfs3.used);
		}
540 541 542

		nfs_setsecurity(inode, fattr, label);

L
Linus Torvalds 已提交
543
		nfsi->attrtimeo = NFS_MINATTRTIMEO(inode);
544
		nfsi->attrtimeo_timestamp = now;
545
		nfsi->access_cache = RB_ROOT;
L
Linus Torvalds 已提交
546

547
		nfs_fscache_init_inode(inode);
D
David Howells 已提交
548

L
Linus Torvalds 已提交
549
		unlock_new_inode(inode);
550 551 552 553 554 555 556 557
	} else {
		int err = nfs_refresh_inode(inode, fattr);
		if (err < 0) {
			iput(inode);
			inode = ERR_PTR(err);
			goto out_no_inode;
		}
	}
558
	dprintk("NFS: nfs_fhget(%s/%Lu fh_crc=0x%08x ct=%d)\n",
L
Linus Torvalds 已提交
559
		inode->i_sb->s_id,
560
		(unsigned long long)NFS_FILEID(inode),
561
		nfs_display_fhandle_hash(fh),
L
Linus Torvalds 已提交
562 563 564 565 566 567
		atomic_read(&inode->i_count));

out:
	return inode;

out_no_inode:
568
	dprintk("nfs_fhget: iget failed with error %ld\n", PTR_ERR(inode));
L
Linus Torvalds 已提交
569 570
	goto out;
}
B
Bryan Schumaker 已提交
571
EXPORT_SYMBOL_GPL(nfs_fhget);
L
Linus Torvalds 已提交
572

573
#define NFS_VALID_ATTRS (ATTR_MODE|ATTR_UID|ATTR_GID|ATTR_SIZE|ATTR_ATIME|ATTR_ATIME_SET|ATTR_MTIME|ATTR_MTIME_SET|ATTR_FILE|ATTR_OPEN)
L
Linus Torvalds 已提交
574 575 576 577

int
nfs_setattr(struct dentry *dentry, struct iattr *attr)
{
578
	struct inode *inode = d_inode(dentry);
579
	struct nfs_fattr *fattr;
580
	int error = 0;
L
Linus Torvalds 已提交
581

C
Chuck Lever 已提交
582 583
	nfs_inc_stats(inode, NFSIOS_VFSSETATTR);

584 585 586 587
	/* skip mode change if it's just for clearing setuid/setgid */
	if (attr->ia_valid & (ATTR_KILL_SUID | ATTR_KILL_SGID))
		attr->ia_valid &= ~ATTR_MODE;

L
Linus Torvalds 已提交
588
	if (attr->ia_valid & ATTR_SIZE) {
589 590
		BUG_ON(!S_ISREG(inode->i_mode));

591 592 593 594 595
		error = inode_newsize_ok(inode, attr->ia_size);
		if (error)
			return error;

		if (attr->ia_size == i_size_read(inode))
L
Linus Torvalds 已提交
596 597 598 599 600
			attr->ia_valid &= ~ATTR_SIZE;
	}

	/* Optimization: if the end result is no change, don't RPC */
	attr->ia_valid &= NFS_VALID_ATTRS;
601
	if ((attr->ia_valid & ~(ATTR_FILE|ATTR_OPEN)) == 0)
L
Linus Torvalds 已提交
602 603
		return 0;

604 605
	trace_nfs_setattr_enter(inode);

606
	/* Write all dirty data */
607 608
	if (S_ISREG(inode->i_mode))
		nfs_sync_inode(inode);
609 610

	fattr = nfs_alloc_fattr();
611 612
	if (fattr == NULL) {
		error = -ENOMEM;
613
		goto out;
614 615
	}

616
	error = NFS_PROTO(inode)->setattr(dentry, fattr, attr);
617
	if (error == 0)
618
		error = nfs_refresh_inode(inode, fattr);
619 620
	nfs_free_fattr(fattr);
out:
621
	trace_nfs_setattr_exit(inode, error);
622 623
	return error;
}
B
Bryan Schumaker 已提交
624
EXPORT_SYMBOL_GPL(nfs_setattr);
625

626 627 628 629 630 631 632 633
/**
 * nfs_vmtruncate - unmap mappings "freed" by truncate() syscall
 * @inode: inode of the file used
 * @offset: file offset to start truncating
 *
 * This is a copy of the common vmtruncate, but with the locking
 * corrected to take into account the fact that NFS requires
 * inode->i_size to be updated under the inode->i_lock.
634
 * Note: must be called with inode->i_lock held!
635 636 637
 */
static int nfs_vmtruncate(struct inode * inode, loff_t offset)
{
N
npiggin@suse.de 已提交
638
	int err;
639

N
npiggin@suse.de 已提交
640 641 642
	err = inode_newsize_ok(inode, offset);
	if (err)
		goto out;
643

N
npiggin@suse.de 已提交
644
	i_size_write(inode, offset);
645 646 647
	/* Optimisation */
	if (offset == 0)
		NFS_I(inode)->cache_validity &= ~NFS_INO_INVALID_DATA;
N
npiggin@suse.de 已提交
648

649
	spin_unlock(&inode->i_lock);
650
	truncate_pagecache(inode, offset);
651
	spin_lock(&inode->i_lock);
N
npiggin@suse.de 已提交
652 653
out:
	return err;
654 655
}

656 657 658 659 660 661 662 663
/**
 * nfs_setattr_update_inode - Update inode metadata after a setattr call.
 * @inode: pointer to struct inode
 * @attr: pointer to struct iattr
 *
 * Note: we do this in the *proc.c in order to ensure that
 *       it works for things like exclusive creates too.
 */
664 665
void nfs_setattr_update_inode(struct inode *inode, struct iattr *attr,
		struct nfs_fattr *fattr)
666
{
667 668 669 670 671
	/* Barrier: bump the attribute generation count. */
	nfs_fattr_set_barrier(fattr);

	spin_lock(&inode->i_lock);
	NFS_I(inode)->attr_gencount = fattr->gencount;
672
	if ((attr->ia_valid & (ATTR_MODE|ATTR_UID|ATTR_GID)) != 0) {
L
Linus Torvalds 已提交
673
		if ((attr->ia_valid & ATTR_MODE) != 0) {
674 675
			int mode = attr->ia_mode & S_IALLUGO;
			mode |= inode->i_mode & ~S_IALLUGO;
L
Linus Torvalds 已提交
676 677 678 679 680 681
			inode->i_mode = mode;
		}
		if ((attr->ia_valid & ATTR_UID) != 0)
			inode->i_uid = attr->ia_uid;
		if ((attr->ia_valid & ATTR_GID) != 0)
			inode->i_gid = attr->ia_gid;
682 683
		nfs_set_cache_invalid(inode, NFS_INO_INVALID_ACCESS
				| NFS_INO_INVALID_ACL);
684 685
	}
	if ((attr->ia_valid & ATTR_SIZE) != 0) {
C
Chuck Lever 已提交
686
		nfs_inc_stats(inode, NFSIOS_SETATTRTRUNC);
687
		nfs_vmtruncate(inode, attr->ia_size);
688
	}
689 690 691 692
	if (fattr->valid)
		nfs_update_inode(inode, fattr);
	else
		NFS_I(inode)->cache_validity |= NFS_INO_INVALID_ATTR;
693
	spin_unlock(&inode->i_lock);
L
Linus Torvalds 已提交
694
}
B
Bryan Schumaker 已提交
695
EXPORT_SYMBOL_GPL(nfs_setattr_update_inode);
L
Linus Torvalds 已提交
696

697
static void nfs_readdirplus_parent_cache_miss(struct dentry *dentry)
698 699 700
{
	struct dentry *parent;

701 702
	if (!nfs_server_capable(d_inode(dentry), NFS_CAP_READDIRPLUS))
		return;
703
	parent = dget_parent(dentry);
704
	nfs_force_use_readdirplus(d_inode(parent));
705 706 707
	dput(parent);
}

708 709 710 711 712 713 714 715 716 717 718
static void nfs_readdirplus_parent_cache_hit(struct dentry *dentry)
{
	struct dentry *parent;

	if (!nfs_server_capable(d_inode(dentry), NFS_CAP_READDIRPLUS))
		return;
	parent = dget_parent(dentry);
	nfs_advise_use_readdirplus(d_inode(parent));
	dput(parent);
}

719 720 721 722 723 724 725 726 727 728
static bool nfs_need_revalidate_inode(struct inode *inode)
{
	if (NFS_I(inode)->cache_validity &
			(NFS_INO_INVALID_ATTR|NFS_INO_INVALID_LABEL))
		return true;
	if (nfs_attribute_cache_expired(inode))
		return true;
	return false;
}

729 730
int nfs_getattr(const struct path *path, struct kstat *stat,
		u32 request_mask, unsigned int query_flags)
L
Linus Torvalds 已提交
731
{
732
	struct inode *inode = d_inode(path->dentry);
733 734
	struct nfs_server *server = NFS_SERVER(inode);
	unsigned long cache_validity;
735
	int err = 0;
736 737
	bool force_sync = query_flags & AT_STATX_FORCE_SYNC;
	bool do_update = false;
L
Linus Torvalds 已提交
738

739
	trace_nfs_getattr_enter(inode);
740 741 742 743

	if ((query_flags & AT_STATX_DONT_SYNC) && !force_sync)
		goto out_no_update;

744
	/* Flush out writes to the server in order to update c/mtime.  */
745 746
	if ((request_mask & (STATX_CTIME|STATX_MTIME)) &&
			S_ISREG(inode->i_mode)) {
747
		err = filemap_write_and_wait(inode->i_mapping);
748 749
		if (err)
			goto out;
750
	}
751 752 753 754 755 756 757

	/*
	 * We may force a getattr if the user cares about atime.
	 *
	 * Note that we only have to check the vfsmount flags here:
	 *  - NFS always sets S_NOATIME by so checking it would give a
	 *    bogus result
758
	 *  - NFS never sets SB_NOATIME or SB_NODIRATIME so there is
759 760
	 *    no point in checking those.
	 */
761 762
	if ((path->mnt->mnt_flags & MNT_NOATIME) ||
	    ((path->mnt->mnt_flags & MNT_NODIRATIME) && S_ISDIR(inode->i_mode)))
763 764 765 766 767 768 769 770 771 772 773 774 775 776 777 778 779 780 781
		request_mask &= ~STATX_ATIME;

	/* Is the user requesting attributes that might need revalidation? */
	if (!(request_mask & (STATX_MODE|STATX_NLINK|STATX_ATIME|STATX_CTIME|
					STATX_MTIME|STATX_UID|STATX_GID|
					STATX_SIZE|STATX_BLOCKS)))
		goto out_no_revalidate;

	/* Check whether the cached attributes are stale */
	do_update |= force_sync || nfs_attribute_cache_expired(inode);
	cache_validity = READ_ONCE(NFS_I(inode)->cache_validity);
	do_update |= cache_validity &
		(NFS_INO_INVALID_ATTR|NFS_INO_INVALID_LABEL);
	if (request_mask & STATX_ATIME)
		do_update |= cache_validity & NFS_INO_INVALID_ATIME;
	if (request_mask & (STATX_CTIME|STATX_MTIME))
		do_update |= cache_validity & NFS_INO_REVAL_PAGECACHE;
	if (do_update) {
		/* Update the attribute cache */
782 783 784 785
		if (!(server->flags & NFS_MOUNT_NOAC))
			nfs_readdirplus_parent_cache_miss(path->dentry);
		else
			nfs_readdirplus_parent_cache_hit(path->dentry);
786
		err = __nfs_revalidate_inode(server, inode);
787 788
		if (err)
			goto out;
789
	} else
790
		nfs_readdirplus_parent_cache_hit(path->dentry);
791 792 793 794 795 796 797 798
out_no_revalidate:
	/* Only return attributes that were revalidated. */
	stat->result_mask &= request_mask;
out_no_update:
	generic_fillattr(inode, stat);
	stat->ino = nfs_compat_user_ino64(NFS_FILEID(inode));
	if (S_ISDIR(inode->i_mode))
		stat->blksize = NFS_SERVER(inode)->dtsize;
799
out:
800
	trace_nfs_getattr_exit(inode, err);
L
Linus Torvalds 已提交
801 802
	return err;
}
B
Bryan Schumaker 已提交
803
EXPORT_SYMBOL_GPL(nfs_getattr);
L
Linus Torvalds 已提交
804

805 806
static void nfs_init_lock_context(struct nfs_lock_context *l_ctx)
{
807
	refcount_set(&l_ctx->count, 1);
N
NeilBrown 已提交
808
	l_ctx->lockowner = current->files;
809
	INIT_LIST_HEAD(&l_ctx->list);
810
	atomic_set(&l_ctx->io_count, 0);
811 812 813 814
}

static struct nfs_lock_context *__nfs_find_lock_context(struct nfs_open_context *ctx)
{
815 816
	struct nfs_lock_context *head = &ctx->lock_context;
	struct nfs_lock_context *pos = head;
817

818
	do {
N
NeilBrown 已提交
819
		if (pos->lockowner != current->files)
820
			continue;
821
		refcount_inc(&pos->count);
822
		return pos;
823
	} while ((pos = list_entry(pos->list.next, typeof(*pos), list)) != head);
824 825 826 827 828 829
	return NULL;
}

struct nfs_lock_context *nfs_get_lock_context(struct nfs_open_context *ctx)
{
	struct nfs_lock_context *res, *new = NULL;
830
	struct inode *inode = d_inode(ctx->dentry);
831 832 833 834 835 836 837

	spin_lock(&inode->i_lock);
	res = __nfs_find_lock_context(ctx);
	if (res == NULL) {
		spin_unlock(&inode->i_lock);
		new = kmalloc(sizeof(*new), GFP_KERNEL);
		if (new == NULL)
838
			return ERR_PTR(-ENOMEM);
839 840 841 842 843 844 845 846 847 848 849 850 851 852
		nfs_init_lock_context(new);
		spin_lock(&inode->i_lock);
		res = __nfs_find_lock_context(ctx);
		if (res == NULL) {
			list_add_tail(&new->list, &ctx->lock_context.list);
			new->open_context = ctx;
			res = new;
			new = NULL;
		}
	}
	spin_unlock(&inode->i_lock);
	kfree(new);
	return res;
}
A
Anna Schumaker 已提交
853
EXPORT_SYMBOL_GPL(nfs_get_lock_context);
854 855 856 857

void nfs_put_lock_context(struct nfs_lock_context *l_ctx)
{
	struct nfs_open_context *ctx = l_ctx->open_context;
858
	struct inode *inode = d_inode(ctx->dentry);
859

860
	if (!refcount_dec_and_lock(&l_ctx->count, &inode->i_lock))
861 862 863 864 865
		return;
	list_del(&l_ctx->list);
	spin_unlock(&inode->i_lock);
	kfree(l_ctx);
}
A
Anna Schumaker 已提交
866
EXPORT_SYMBOL_GPL(nfs_put_lock_context);
867

T
Trond Myklebust 已提交
868 869 870 871 872
/**
 * nfs_close_context - Common close_context() routine NFSv2/v3
 * @ctx: pointer to context
 * @is_sync: is this a synchronous close
 *
873 874 875
 * Ensure that the attributes are up to date if we're mounted
 * with close-to-open semantics and we have cached data that will
 * need to be revalidated on open.
T
Trond Myklebust 已提交
876 877 878
 */
void nfs_close_context(struct nfs_open_context *ctx, int is_sync)
{
879
	struct nfs_inode *nfsi;
T
Trond Myklebust 已提交
880 881 882 883 884 885 886
	struct inode *inode;
	struct nfs_server *server;

	if (!(ctx->mode & FMODE_WRITE))
		return;
	if (!is_sync)
		return;
887
	inode = d_inode(ctx->dentry);
888 889
	if (NFS_PROTO(inode)->have_delegation(inode, FMODE_READ))
		return;
890 891 892 893 894 895
	nfsi = NFS_I(inode);
	if (inode->i_mapping->nrpages == 0)
		return;
	if (nfsi->cache_validity & NFS_INO_INVALID_DATA)
		return;
	if (!list_empty(&nfsi->open_files))
T
Trond Myklebust 已提交
896 897 898 899 900 901
		return;
	server = NFS_SERVER(inode);
	if (server->flags & NFS_MOUNT_NOCTO)
		return;
	nfs_revalidate_inode(server, inode);
}
B
Bryan Schumaker 已提交
902
EXPORT_SYMBOL_GPL(nfs_close_context);
T
Trond Myklebust 已提交
903

N
NeilBrown 已提交
904 905 906
struct nfs_open_context *alloc_nfs_open_context(struct dentry *dentry,
						fmode_t f_mode,
						struct file *filp)
L
Linus Torvalds 已提交
907 908
{
	struct nfs_open_context *ctx;
909 910 911
	struct rpc_cred *cred = rpc_lookup_cred();
	if (IS_ERR(cred))
		return ERR_CAST(cred);
L
Linus Torvalds 已提交
912

913
	ctx = kmalloc(sizeof(*ctx), GFP_KERNEL);
914 915 916
	if (!ctx) {
		put_rpccred(cred);
		return ERR_PTR(-ENOMEM);
L
Linus Torvalds 已提交
917
	}
918 919 920 921 922 923 924
	nfs_sb_active(dentry->d_sb);
	ctx->dentry = dget(dentry);
	ctx->cred = cred;
	ctx->state = NULL;
	ctx->mode = f_mode;
	ctx->flags = 0;
	ctx->error = 0;
N
NeilBrown 已提交
925
	ctx->flock_owner = (fl_owner_t)filp;
926 927 928
	nfs_init_lock_context(&ctx->lock_context);
	ctx->lock_context.open_context = ctx;
	INIT_LIST_HEAD(&ctx->list);
929
	ctx->mdsthreshold = NULL;
L
Linus Torvalds 已提交
930 931
	return ctx;
}
B
Bryan Schumaker 已提交
932
EXPORT_SYMBOL_GPL(alloc_nfs_open_context);
L
Linus Torvalds 已提交
933 934 935 936

struct nfs_open_context *get_nfs_open_context(struct nfs_open_context *ctx)
{
	if (ctx != NULL)
937
		refcount_inc(&ctx->lock_context.count);
L
Linus Torvalds 已提交
938 939
	return ctx;
}
B
Bryan Schumaker 已提交
940
EXPORT_SYMBOL_GPL(get_nfs_open_context);
L
Linus Torvalds 已提交
941

T
Trond Myklebust 已提交
942
static void __put_nfs_open_context(struct nfs_open_context *ctx, int is_sync)
L
Linus Torvalds 已提交
943
{
944
	struct inode *inode = d_inode(ctx->dentry);
945
	struct super_block *sb = ctx->dentry->d_sb;
946

947
	if (!list_empty(&ctx->list)) {
948
		if (!refcount_dec_and_lock(&ctx->lock_context.count, &inode->i_lock))
949 950 951
			return;
		list_del(&ctx->list);
		spin_unlock(&inode->i_lock);
952
	} else if (!refcount_dec_and_test(&ctx->lock_context.count))
T
Trond Myklebust 已提交
953
		return;
954 955
	if (inode != NULL)
		NFS_PROTO(inode)->close_context(ctx, is_sync);
956 957
	if (ctx->cred != NULL)
		put_rpccred(ctx->cred);
958
	dput(ctx->dentry);
959
	nfs_sb_deactive(sb);
960
	kfree(ctx->mdsthreshold);
961 962 963
	kfree(ctx);
}

964 965 966 967
void put_nfs_open_context(struct nfs_open_context *ctx)
{
	__put_nfs_open_context(ctx, 0);
}
B
Bryan Schumaker 已提交
968
EXPORT_SYMBOL_GPL(put_nfs_open_context);
969

970 971 972 973 974
static void put_nfs_open_context_sync(struct nfs_open_context *ctx)
{
	__put_nfs_open_context(ctx, 1);
}

L
Linus Torvalds 已提交
975 976 977 978
/*
 * Ensure that mmap has a recent RPC credential for use when writing out
 * shared pages
 */
979
void nfs_inode_attach_open_context(struct nfs_open_context *ctx)
L
Linus Torvalds 已提交
980
{
981
	struct inode *inode = d_inode(ctx->dentry);
L
Linus Torvalds 已提交
982 983 984
	struct nfs_inode *nfsi = NFS_I(inode);

	spin_lock(&inode->i_lock);
985 986 987 988
	if (ctx->mode & FMODE_WRITE)
		list_add(&ctx->list, &nfsi->open_files);
	else
		list_add_tail(&ctx->list, &nfsi->open_files);
L
Linus Torvalds 已提交
989 990
	spin_unlock(&inode->i_lock);
}
991 992 993 994 995 996 997 998
EXPORT_SYMBOL_GPL(nfs_inode_attach_open_context);

void nfs_file_set_open_context(struct file *filp, struct nfs_open_context *ctx)
{
	filp->private_data = get_nfs_open_context(ctx);
	if (list_empty(&ctx->list))
		nfs_inode_attach_open_context(ctx);
}
B
Bryan Schumaker 已提交
999
EXPORT_SYMBOL_GPL(nfs_file_set_open_context);
L
Linus Torvalds 已提交
1000

1001 1002 1003
/*
 * Given an inode, search for an open context with the desired characteristics
 */
1004
struct nfs_open_context *nfs_find_open_context(struct inode *inode, struct rpc_cred *cred, fmode_t mode)
L
Linus Torvalds 已提交
1005 1006 1007 1008 1009 1010
{
	struct nfs_inode *nfsi = NFS_I(inode);
	struct nfs_open_context *pos, *ctx = NULL;

	spin_lock(&inode->i_lock);
	list_for_each_entry(pos, &nfsi->open_files, list) {
1011 1012
		if (cred != NULL && pos->cred != cred)
			continue;
1013 1014 1015 1016
		if ((pos->mode & (FMODE_READ|FMODE_WRITE)) != mode)
			continue;
		ctx = get_nfs_open_context(pos);
		break;
L
Linus Torvalds 已提交
1017 1018 1019 1020 1021
	}
	spin_unlock(&inode->i_lock);
	return ctx;
}

A
Anna Schumaker 已提交
1022
void nfs_file_clear_open_context(struct file *filp)
L
Linus Torvalds 已提交
1023
{
1024
	struct nfs_open_context *ctx = nfs_file_open_context(filp);
L
Linus Torvalds 已提交
1025 1026

	if (ctx) {
1027
		struct inode *inode = d_inode(ctx->dentry);
1028

1029 1030 1031 1032 1033 1034
		/*
		 * We fatal error on write before. Try to writeback
		 * every page again.
		 */
		if (ctx->error < 0)
			invalidate_inode_pages2(inode->i_mapping);
L
Linus Torvalds 已提交
1035 1036 1037 1038
		filp->private_data = NULL;
		spin_lock(&inode->i_lock);
		list_move_tail(&ctx->list, &NFS_I(inode)->open_files);
		spin_unlock(&inode->i_lock);
1039
		put_nfs_open_context_sync(ctx);
L
Linus Torvalds 已提交
1040 1041 1042 1043 1044 1045 1046 1047 1048 1049
	}
}

/*
 * These allocate and release file read/write context information.
 */
int nfs_open(struct inode *inode, struct file *filp)
{
	struct nfs_open_context *ctx;

N
NeilBrown 已提交
1050
	ctx = alloc_nfs_open_context(file_dentry(filp), filp->f_mode, filp);
1051 1052
	if (IS_ERR(ctx))
		return PTR_ERR(ctx);
L
Linus Torvalds 已提交
1053 1054
	nfs_file_set_open_context(filp, ctx);
	put_nfs_open_context(ctx);
1055
	nfs_fscache_open_file(inode, filp);
L
Linus Torvalds 已提交
1056 1057 1058 1059 1060 1061 1062 1063 1064 1065 1066
	return 0;
}

/*
 * This function is called whenever some part of NFS notices that
 * the cached attributes have to be refreshed.
 */
int
__nfs_revalidate_inode(struct nfs_server *server, struct inode *inode)
{
	int		 status = -ESTALE;
1067
	struct nfs4_label *label = NULL;
1068
	struct nfs_fattr *fattr = NULL;
L
Linus Torvalds 已提交
1069 1070
	struct nfs_inode *nfsi = NFS_I(inode);

1071 1072
	dfprintk(PAGECACHE, "NFS: revalidating (%s/%Lu)\n",
		inode->i_sb->s_id, (unsigned long long)NFS_FILEID(inode));
L
Linus Torvalds 已提交
1073

1074 1075
	trace_nfs_revalidate_inode_enter(inode);

1076
	if (is_bad_inode(inode))
1077
		goto out;
L
Linus Torvalds 已提交
1078
	if (NFS_STALE(inode))
1079
		goto out;
1080

1081 1082 1083 1084 1085 1086 1087
	/* pNFS: Attributes aren't updated until we layoutcommit */
	if (S_ISREG(inode->i_mode)) {
		status = pnfs_sync_inode(inode, false);
		if (status)
			goto out;
	}

1088 1089 1090 1091 1092
	status = -ENOMEM;
	fattr = nfs_alloc_fattr();
	if (fattr == NULL)
		goto out;

1093
	nfs_inc_stats(inode, NFSIOS_INODEREVALIDATE);
1094 1095 1096 1097 1098 1099 1100

	label = nfs4_label_alloc(NFS_SERVER(inode), GFP_KERNEL);
	if (IS_ERR(label)) {
		status = PTR_ERR(label);
		goto out;
	}

1101
	status = NFS_PROTO(inode)->getattr(server, NFS_FH(inode), fattr, label);
L
Linus Torvalds 已提交
1102
	if (status != 0) {
1103
		dfprintk(PAGECACHE, "nfs_revalidate_inode: (%s/%Lu) getattr failed, error=%d\n",
L
Linus Torvalds 已提交
1104
			 inode->i_sb->s_id,
1105
			 (unsigned long long)NFS_FILEID(inode), status);
L
Linus Torvalds 已提交
1106 1107 1108
		if (status == -ESTALE) {
			nfs_zap_caches(inode);
			if (!S_ISDIR(inode->i_mode))
B
Benny Halevy 已提交
1109
				set_bit(NFS_INO_STALE, &NFS_I(inode)->flags);
L
Linus Torvalds 已提交
1110
		}
1111
		goto err_out;
L
Linus Torvalds 已提交
1112 1113
	}

1114
	status = nfs_refresh_inode(inode, fattr);
L
Linus Torvalds 已提交
1115
	if (status) {
1116
		dfprintk(PAGECACHE, "nfs_revalidate_inode: (%s/%Lu) refresh failed, error=%d\n",
L
Linus Torvalds 已提交
1117
			 inode->i_sb->s_id,
1118
			 (unsigned long long)NFS_FILEID(inode), status);
1119
		goto err_out;
L
Linus Torvalds 已提交
1120
	}
1121

1122
	if (nfsi->cache_validity & NFS_INO_INVALID_ACL)
1123
		nfs_zap_acl_cache(inode);
1124

1125 1126
	nfs_setsecurity(inode, fattr, label);

1127
	dfprintk(PAGECACHE, "NFS: (%s/%Lu) revalidation complete\n",
L
Linus Torvalds 已提交
1128
		inode->i_sb->s_id,
1129
		(unsigned long long)NFS_FILEID(inode));
L
Linus Torvalds 已提交
1130

1131 1132 1133
err_out:
	nfs4_label_free(label);
out:
1134
	nfs_free_fattr(fattr);
1135
	trace_nfs_revalidate_inode_exit(inode, status);
L
Linus Torvalds 已提交
1136 1137 1138
	return status;
}

1139
int nfs_attribute_cache_expired(struct inode *inode)
1140
{
1141
	if (nfs_have_delegated_attributes(inode))
L
Linus Torvalds 已提交
1142
		return 0;
1143
	return nfs_attribute_timeout(inode);
L
Linus Torvalds 已提交
1144 1145 1146 1147 1148 1149 1150 1151 1152 1153 1154
}

/**
 * nfs_revalidate_inode - Revalidate the inode attributes
 * @server - pointer to nfs_server struct
 * @inode - pointer to inode struct
 *
 * Updates inode attribute information by retrieving the data from the server.
 */
int nfs_revalidate_inode(struct nfs_server *server, struct inode *inode)
{
1155
	if (!nfs_need_revalidate_inode(inode))
L
Linus Torvalds 已提交
1156 1157 1158
		return NFS_STALE(inode) ? -ESTALE : 0;
	return __nfs_revalidate_inode(server, inode);
}
B
Bryan Schumaker 已提交
1159
EXPORT_SYMBOL_GPL(nfs_revalidate_inode);
L
Linus Torvalds 已提交
1160

1161
static int nfs_invalidate_mapping(struct inode *inode, struct address_space *mapping)
1162 1163
{
	struct nfs_inode *nfsi = NFS_I(inode);
1164 1165
	int ret;

1166
	if (mapping->nrpages != 0) {
1167 1168 1169 1170 1171 1172
		if (S_ISREG(inode->i_mode)) {
			ret = nfs_sync_mapping(mapping);
			if (ret < 0)
				return ret;
		}
		ret = invalidate_inode_pages2(mapping);
1173 1174 1175
		if (ret < 0)
			return ret;
	}
1176 1177
	if (S_ISDIR(inode->i_mode)) {
		spin_lock(&inode->i_lock);
1178
		memset(nfsi->cookieverf, 0, sizeof(nfsi->cookieverf));
1179 1180
		spin_unlock(&inode->i_lock);
	}
1181
	nfs_inc_stats(inode, NFSIOS_DATAINVALIDATE);
D
David Howells 已提交
1182
	nfs_fscache_wait_on_invalidate(inode);
1183

1184 1185 1186
	dfprintk(PAGECACHE, "NFS: (%s/%Lu) data cache invalidated\n",
			inode->i_sb->s_id,
			(unsigned long long)NFS_FILEID(inode));
1187 1188 1189
	return 0;
}

1190
bool nfs_mapping_need_revalidate_inode(struct inode *inode)
1191
{
1192 1193
	return nfs_check_cache_invalid(inode, NFS_INO_REVAL_PAGECACHE) ||
		NFS_STALE(inode);
1194 1195
}

A
Al Viro 已提交
1196 1197 1198 1199 1200 1201 1202 1203 1204 1205 1206 1207 1208 1209 1210 1211 1212 1213 1214 1215 1216
int nfs_revalidate_mapping_rcu(struct inode *inode)
{
	struct nfs_inode *nfsi = NFS_I(inode);
	unsigned long *bitlock = &nfsi->flags;
	int ret = 0;

	if (IS_SWAPFILE(inode))
		goto out;
	if (nfs_mapping_need_revalidate_inode(inode)) {
		ret = -ECHILD;
		goto out;
	}
	spin_lock(&inode->i_lock);
	if (test_bit(NFS_INO_INVALIDATING, bitlock) ||
	    (nfsi->cache_validity & NFS_INO_INVALID_DATA))
		ret = -ECHILD;
	spin_unlock(&inode->i_lock);
out:
	return ret;
}

1217
/**
1218
 * nfs_revalidate_mapping - Revalidate the pagecache
1219 1220 1221
 * @inode - pointer to host inode
 * @mapping - pointer to mapping
 */
1222 1223
int nfs_revalidate_mapping(struct inode *inode,
		struct address_space *mapping)
1224 1225
{
	struct nfs_inode *nfsi = NFS_I(inode);
1226
	unsigned long *bitlock = &nfsi->flags;
1227
	int ret = 0;
1228

1229 1230 1231 1232
	/* swapfiles are not supposed to be shared. */
	if (IS_SWAPFILE(inode))
		goto out;

1233
	if (nfs_mapping_need_revalidate_inode(inode)) {
1234 1235 1236
		ret = __nfs_revalidate_inode(NFS_SERVER(inode), inode);
		if (ret < 0)
			goto out;
1237
	}
1238 1239 1240 1241 1242 1243 1244 1245 1246 1247 1248 1249 1250 1251

	/*
	 * We must clear NFS_INO_INVALID_DATA first to ensure that
	 * invalidations that come in while we're shooting down the mappings
	 * are respected. But, that leaves a race window where one revalidator
	 * can clear the flag, and then another checks it before the mapping
	 * gets invalidated. Fix that by serializing access to this part of
	 * the function.
	 *
	 * At the same time, we need to allow other tasks to see whether we
	 * might be in the middle of invalidating the pages, so we only set
	 * the bit lock here if it looks like we're going to be doing that.
	 */
	for (;;) {
1252 1253
		ret = wait_on_bit_action(bitlock, NFS_INO_INVALIDATING,
					 nfs_wait_bit_killable, TASK_KILLABLE);
1254 1255
		if (ret)
			goto out;
1256 1257 1258 1259 1260 1261
		spin_lock(&inode->i_lock);
		if (test_bit(NFS_INO_INVALIDATING, bitlock)) {
			spin_unlock(&inode->i_lock);
			continue;
		}
		if (nfsi->cache_validity & NFS_INO_INVALID_DATA)
1262 1263
			break;
		spin_unlock(&inode->i_lock);
1264
		goto out;
1265 1266
	}

1267
	set_bit(NFS_INO_INVALIDATING, bitlock);
1268
	smp_wmb();
1269 1270 1271
	nfsi->cache_validity &= ~NFS_INO_INVALID_DATA;
	spin_unlock(&inode->i_lock);
	trace_nfs_invalidate_mapping_enter(inode);
1272
	ret = nfs_invalidate_mapping(inode, mapping);
1273 1274
	trace_nfs_invalidate_mapping_exit(inode, ret);

1275
	clear_bit_unlock(NFS_INO_INVALIDATING, bitlock);
1276
	smp_mb__after_atomic();
1277
	wake_up_bit(bitlock, NFS_INO_INVALIDATING);
1278
out:
1279
	return ret;
1280 1281
}

1282
static bool nfs_file_has_writers(struct nfs_inode *nfsi)
1283
{
1284 1285 1286 1287 1288 1289 1290 1291 1292 1293 1294 1295 1296 1297 1298
	struct inode *inode = &nfsi->vfs_inode;

	assert_spin_locked(&inode->i_lock);

	if (!S_ISREG(inode->i_mode))
		return false;
	if (list_empty(&nfsi->open_files))
		return false;
	/* Note: This relies on nfsi->open_files being ordered with writers
	 *       being placed at the head of the list.
	 *       See nfs_inode_attach_open_context()
	 */
	return (list_first_entry(&nfsi->open_files,
			struct nfs_open_context,
			list)->mode & FMODE_WRITE) == FMODE_WRITE;
1299 1300
}

1301
static bool nfs_file_has_buffered_writers(struct nfs_inode *nfsi)
1302
{
1303
	return nfs_file_has_writers(nfsi) && nfs_file_io_is_buffered(nfsi);
1304 1305
}

1306
static void nfs_wcc_update_inode(struct inode *inode, struct nfs_fattr *fattr)
1307
{
1308 1309
	if ((fattr->valid & NFS_ATTR_FATTR_PRECHANGE)
			&& (fattr->valid & NFS_ATTR_FATTR_CHANGE)
1310
			&& inode_eq_iversion_raw(inode, fattr->pre_change_attr)) {
J
Jeff Layton 已提交
1311
		inode_set_iversion_raw(inode, fattr->change_attr);
1312
		if (S_ISDIR(inode->i_mode))
1313
			nfs_set_cache_invalid(inode, NFS_INO_INVALID_DATA);
1314
	}
1315
	/* If we have atomic WCC data, we may update some attributes */
1316 1317
	if ((fattr->valid & NFS_ATTR_FATTR_PRECTIME)
			&& (fattr->valid & NFS_ATTR_FATTR_CTIME)
1318 1319 1320
			&& timespec_equal(&inode->i_ctime, &fattr->pre_ctime)) {
		memcpy(&inode->i_ctime, &fattr->ctime, sizeof(inode->i_ctime));
	}
1321 1322 1323 1324

	if ((fattr->valid & NFS_ATTR_FATTR_PREMTIME)
			&& (fattr->valid & NFS_ATTR_FATTR_MTIME)
			&& timespec_equal(&inode->i_mtime, &fattr->pre_mtime)) {
1325 1326
		memcpy(&inode->i_mtime, &fattr->mtime, sizeof(inode->i_mtime));
		if (S_ISDIR(inode->i_mode))
1327
			nfs_set_cache_invalid(inode, NFS_INO_INVALID_DATA);
1328
	}
1329 1330 1331
	if ((fattr->valid & NFS_ATTR_FATTR_PRESIZE)
			&& (fattr->valid & NFS_ATTR_FATTR_SIZE)
			&& i_size_read(inode) == nfs_size_to_loff_t(fattr->pre_size)
1332
			&& !nfs_have_writebacks(inode)) {
1333 1334
		i_size_write(inode, nfs_size_to_loff_t(fattr->size));
	}
1335 1336
}

L
Linus Torvalds 已提交
1337
/**
1338
 * nfs_check_inode_attributes - verify consistency of the inode attribute cache
L
Linus Torvalds 已提交
1339 1340 1341 1342 1343 1344 1345
 * @inode - pointer to inode
 * @fattr - updated attributes
 *
 * Verifies the attribute cache. If we have just changed the attributes,
 * so that fattr carries weak cache consistency data, then it may
 * also update the ctime/mtime/change_attribute.
 */
1346
static int nfs_check_inode_attributes(struct inode *inode, struct nfs_fattr *fattr)
L
Linus Torvalds 已提交
1347 1348 1349
{
	struct nfs_inode *nfsi = NFS_I(inode);
	loff_t cur_size, new_isize;
1350
	unsigned long invalid = 0;
L
Linus Torvalds 已提交
1351

1352

1353 1354
	if (nfs_have_delegated_attributes(inode))
		return 0;
1355
	/* Has the inode gone and changed behind our back? */
1356
	if ((fattr->valid & NFS_ATTR_FATTR_FILEID) && nfsi->fileid != fattr->fileid)
1357
		return -ESTALE;
1358
	if ((fattr->valid & NFS_ATTR_FATTR_TYPE) && (inode->i_mode & S_IFMT) != (fattr->mode & S_IFMT))
1359
		return -ESTALE;
1360

1361
	if (!nfs_file_has_buffered_writers(nfsi)) {
1362
		/* Verify a few of the more important attributes */
1363
		if ((fattr->valid & NFS_ATTR_FATTR_CHANGE) != 0 && !inode_eq_iversion_raw(inode, fattr->change_attr))
1364
			invalid |= NFS_INO_INVALID_ATTR | NFS_INO_REVAL_PAGECACHE;
L
Linus Torvalds 已提交
1365

1366 1367
		if ((fattr->valid & NFS_ATTR_FATTR_MTIME) && !timespec_equal(&inode->i_mtime, &fattr->mtime))
			invalid |= NFS_INO_INVALID_ATTR;
1368

1369 1370 1371 1372 1373 1374 1375 1376 1377
		if ((fattr->valid & NFS_ATTR_FATTR_CTIME) && !timespec_equal(&inode->i_ctime, &fattr->ctime))
			invalid |= NFS_INO_INVALID_ATTR;

		if (fattr->valid & NFS_ATTR_FATTR_SIZE) {
			cur_size = i_size_read(inode);
			new_isize = nfs_size_to_loff_t(fattr->size);
			if (cur_size != new_isize)
				invalid |= NFS_INO_INVALID_ATTR|NFS_INO_REVAL_PAGECACHE;
		}
1378
	}
L
Linus Torvalds 已提交
1379 1380

	/* Have any file permissions changed? */
1381 1382
	if ((fattr->valid & NFS_ATTR_FATTR_MODE) && (inode->i_mode & S_IALLUGO) != (fattr->mode & S_IALLUGO))
		invalid |= NFS_INO_INVALID_ATTR | NFS_INO_INVALID_ACCESS | NFS_INO_INVALID_ACL;
1383
	if ((fattr->valid & NFS_ATTR_FATTR_OWNER) && !uid_eq(inode->i_uid, fattr->uid))
1384
		invalid |= NFS_INO_INVALID_ATTR | NFS_INO_INVALID_ACCESS | NFS_INO_INVALID_ACL;
1385
	if ((fattr->valid & NFS_ATTR_FATTR_GROUP) && !gid_eq(inode->i_gid, fattr->gid))
1386
		invalid |= NFS_INO_INVALID_ATTR | NFS_INO_INVALID_ACCESS | NFS_INO_INVALID_ACL;
L
Linus Torvalds 已提交
1387 1388

	/* Has the link count changed? */
1389
	if ((fattr->valid & NFS_ATTR_FATTR_NLINK) && inode->i_nlink != fattr->nlink)
1390
		invalid |= NFS_INO_INVALID_ATTR;
L
Linus Torvalds 已提交
1391

1392
	if ((fattr->valid & NFS_ATTR_FATTR_ATIME) && !timespec_equal(&inode->i_atime, &fattr->atime))
1393 1394 1395
		invalid |= NFS_INO_INVALID_ATIME;

	if (invalid != 0)
1396
		nfs_set_cache_invalid(inode, invalid | NFS_INO_REVAL_FORCED);
L
Linus Torvalds 已提交
1397

1398
	nfsi->read_cache_jiffies = fattr->time_start;
L
Linus Torvalds 已提交
1399 1400 1401
	return 0;
}

1402
static atomic_long_t nfs_attr_generation_counter;
1403 1404 1405

static unsigned long nfs_read_attr_generation_counter(void)
{
1406
	return atomic_long_read(&nfs_attr_generation_counter);
1407 1408 1409 1410
}

unsigned long nfs_inc_attr_generation_counter(void)
{
1411
	return atomic_long_inc_return(&nfs_attr_generation_counter);
1412
}
1413
EXPORT_SYMBOL_GPL(nfs_inc_attr_generation_counter);
1414 1415 1416 1417 1418 1419

void nfs_fattr_init(struct nfs_fattr *fattr)
{
	fattr->valid = 0;
	fattr->time_start = jiffies;
	fattr->gencount = nfs_inc_attr_generation_counter();
1420 1421
	fattr->owner_name = NULL;
	fattr->group_name = NULL;
1422
}
B
Bryan Schumaker 已提交
1423
EXPORT_SYMBOL_GPL(nfs_fattr_init);
1424

1425 1426 1427 1428 1429 1430 1431 1432 1433 1434 1435 1436 1437 1438 1439 1440
/**
 * nfs_fattr_set_barrier
 * @fattr: attributes
 *
 * Used to set a barrier after an attribute was updated. This
 * barrier ensures that older attributes from RPC calls that may
 * have raced with our update cannot clobber these new values.
 * Note that you are still responsible for ensuring that other
 * operations which change the attribute on the server do not
 * collide.
 */
void nfs_fattr_set_barrier(struct nfs_fattr *fattr)
{
	fattr->gencount = nfs_inc_attr_generation_counter();
}

1441 1442 1443 1444 1445 1446 1447 1448 1449
struct nfs_fattr *nfs_alloc_fattr(void)
{
	struct nfs_fattr *fattr;

	fattr = kmalloc(sizeof(*fattr), GFP_NOFS);
	if (fattr != NULL)
		nfs_fattr_init(fattr);
	return fattr;
}
B
Bryan Schumaker 已提交
1450
EXPORT_SYMBOL_GPL(nfs_alloc_fattr);
1451 1452 1453 1454 1455 1456 1457 1458 1459 1460

struct nfs_fh *nfs_alloc_fhandle(void)
{
	struct nfs_fh *fh;

	fh = kmalloc(sizeof(struct nfs_fh), GFP_NOFS);
	if (fh != NULL)
		fh->size = 0;
	return fh;
}
B
Bryan Schumaker 已提交
1461
EXPORT_SYMBOL_GPL(nfs_alloc_fhandle);
1462

1463
#ifdef NFS_DEBUG
1464 1465 1466 1467 1468 1469 1470 1471 1472 1473 1474 1475
/*
 * _nfs_display_fhandle_hash - calculate the crc32 hash for the filehandle
 *                             in the same way that wireshark does
 *
 * @fh: file handle
 *
 * For debugging only.
 */
u32 _nfs_display_fhandle_hash(const struct nfs_fh *fh)
{
	/* wireshark uses 32-bit AUTODIN crc and does a bitwise
	 * not on the result */
1476
	return nfs_fhandle_hash(fh);
1477
}
C
Chuck Lever 已提交
1478
EXPORT_SYMBOL_GPL(_nfs_display_fhandle_hash);
1479 1480

/*
1481 1482 1483 1484 1485 1486 1487 1488 1489 1490 1491
 * _nfs_display_fhandle - display an NFS file handle on the console
 *
 * @fh: file handle to display
 * @caption: display caption
 *
 * For debugging only.
 */
void _nfs_display_fhandle(const struct nfs_fh *fh, const char *caption)
{
	unsigned short i;

1492
	if (fh == NULL || fh->size == 0) {
1493 1494 1495 1496
		printk(KERN_DEFAULT "%s at %p is empty\n", caption, fh);
		return;
	}

1497 1498
	printk(KERN_DEFAULT "%s at %p is %u bytes, crc: 0x%08x:\n",
	       caption, fh, fh->size, _nfs_display_fhandle_hash(fh));
1499 1500 1501 1502 1503 1504 1505 1506 1507 1508 1509 1510 1511 1512 1513 1514 1515 1516 1517 1518 1519 1520 1521 1522
	for (i = 0; i < fh->size; i += 16) {
		__be32 *pos = (__be32 *)&fh->data[i];

		switch ((fh->size - i - 1) >> 2) {
		case 0:
			printk(KERN_DEFAULT " %08x\n",
				be32_to_cpup(pos));
			break;
		case 1:
			printk(KERN_DEFAULT " %08x %08x\n",
				be32_to_cpup(pos), be32_to_cpup(pos + 1));
			break;
		case 2:
			printk(KERN_DEFAULT " %08x %08x %08x\n",
				be32_to_cpup(pos), be32_to_cpup(pos + 1),
				be32_to_cpup(pos + 2));
			break;
		default:
			printk(KERN_DEFAULT " %08x %08x %08x %08x\n",
				be32_to_cpup(pos), be32_to_cpup(pos + 1),
				be32_to_cpup(pos + 2), be32_to_cpup(pos + 3));
		}
	}
}
C
Chuck Lever 已提交
1523
EXPORT_SYMBOL_GPL(_nfs_display_fhandle);
1524 1525
#endif

1526 1527 1528 1529 1530 1531 1532 1533 1534 1535 1536 1537 1538
/**
 * nfs_inode_attrs_need_update - check if the inode attributes need updating
 * @inode - pointer to inode
 * @fattr - attributes
 *
 * Attempt to divine whether or not an RPC call reply carrying stale
 * attributes got scheduled after another call carrying updated ones.
 *
 * To do so, the function first assumes that a more recent ctime means
 * that the attributes in fattr are newer, however it also attempt to
 * catch the case where ctime either didn't change, or went backwards
 * (if someone reset the clock on the server) by looking at whether
 * or not this RPC call was started after the inode was last updated.
1539
 * Note also the check for wraparound of 'attr_gencount'
1540 1541 1542 1543 1544 1545 1546 1547 1548
 *
 * The function returns 'true' if it thinks the attributes in 'fattr' are
 * more recent than the ones cached in the inode.
 *
 */
static int nfs_inode_attrs_need_update(const struct inode *inode, const struct nfs_fattr *fattr)
{
	const struct nfs_inode *nfsi = NFS_I(inode);

1549 1550
	return ((long)fattr->gencount - (long)nfsi->attr_gencount) > 0 ||
		((long)nfsi->attr_gencount - (long)nfs_read_attr_generation_counter() > 0);
1551 1552 1553 1554
}

static int nfs_refresh_inode_locked(struct inode *inode, struct nfs_fattr *fattr)
{
1555 1556 1557 1558
	int ret;

	trace_nfs_refresh_inode_enter(inode);

1559
	if (nfs_inode_attrs_need_update(inode, fattr))
1560 1561 1562 1563 1564 1565
		ret = nfs_update_inode(inode, fattr);
	else
		ret = nfs_check_inode_attributes(inode, fattr);

	trace_nfs_refresh_inode_exit(inode, ret);
	return ret;
1566 1567
}

1568 1569 1570 1571 1572 1573 1574 1575 1576 1577 1578 1579 1580 1581 1582 1583 1584
/**
 * nfs_refresh_inode - try to update the inode attribute cache
 * @inode - pointer to inode
 * @fattr - updated attributes
 *
 * Check that an RPC call that returned attributes has not overlapped with
 * other recent updates of the inode metadata, then decide whether it is
 * safe to do a full update of the inode attributes, or whether just to
 * call nfs_check_inode_attributes.
 */
int nfs_refresh_inode(struct inode *inode, struct nfs_fattr *fattr)
{
	int status;

	if ((fattr->valid & NFS_ATTR_FATTR) == 0)
		return 0;
	spin_lock(&inode->i_lock);
1585
	status = nfs_refresh_inode_locked(inode, fattr);
1586
	spin_unlock(&inode->i_lock);
D
David Howells 已提交
1587

1588 1589
	return status;
}
B
Bryan Schumaker 已提交
1590
EXPORT_SYMBOL_GPL(nfs_refresh_inode);
1591

1592 1593
static int nfs_post_op_update_inode_locked(struct inode *inode, struct nfs_fattr *fattr)
{
1594
	unsigned long invalid = NFS_INO_INVALID_ATTR;
1595

1596 1597 1598
	if (S_ISDIR(inode->i_mode))
		invalid |= NFS_INO_INVALID_DATA;
	nfs_set_cache_invalid(inode, invalid);
1599 1600 1601 1602 1603
	if ((fattr->valid & NFS_ATTR_FATTR) == 0)
		return 0;
	return nfs_refresh_inode_locked(inode, fattr);
}

1604 1605 1606 1607 1608 1609 1610
/**
 * nfs_post_op_update_inode - try to update the inode attribute cache
 * @inode - pointer to inode
 * @fattr - updated attributes
 *
 * After an operation that has changed the inode metadata, mark the
 * attribute cache as being invalid, then try to update it.
1611 1612 1613 1614 1615 1616
 *
 * NB: if the server didn't return any post op attributes, this
 * function will force the retrieval of attributes before the next
 * NFS request.  Thus it should be used only for operations that
 * are expected to change one or more attributes, to avoid
 * unnecessary NFS requests and trips through nfs_update_inode().
1617 1618 1619
 */
int nfs_post_op_update_inode(struct inode *inode, struct nfs_fattr *fattr)
{
1620
	int status;
1621

1622
	spin_lock(&inode->i_lock);
1623
	nfs_fattr_set_barrier(fattr);
1624
	status = nfs_post_op_update_inode_locked(inode, fattr);
1625
	spin_unlock(&inode->i_lock);
1626

1627
	return status;
1628
}
B
Bryan Schumaker 已提交
1629
EXPORT_SYMBOL_GPL(nfs_post_op_update_inode);
1630

1631
/**
1632
 * nfs_post_op_update_inode_force_wcc_locked - update the inode attribute cache
1633 1634 1635 1636 1637 1638 1639 1640 1641
 * @inode - pointer to inode
 * @fattr - updated attributes
 *
 * After an operation that has changed the inode metadata, mark the
 * attribute cache as being invalid, then try to update it. Fake up
 * weak cache consistency data, if none exist.
 *
 * This function is mainly designed to be used by the ->write_done() functions.
 */
1642
int nfs_post_op_update_inode_force_wcc_locked(struct inode *inode, struct nfs_fattr *fattr)
1643
{
1644 1645 1646 1647 1648
	int status;

	/* Don't do a WCC update if these attributes are already stale */
	if ((fattr->valid & NFS_ATTR_FATTR) == 0 ||
			!nfs_inode_attrs_need_update(inode, fattr)) {
1649 1650 1651 1652
		fattr->valid &= ~(NFS_ATTR_FATTR_PRECHANGE
				| NFS_ATTR_FATTR_PRESIZE
				| NFS_ATTR_FATTR_PREMTIME
				| NFS_ATTR_FATTR_PRECTIME);
1653 1654
		goto out_noforce;
	}
1655 1656
	if ((fattr->valid & NFS_ATTR_FATTR_CHANGE) != 0 &&
			(fattr->valid & NFS_ATTR_FATTR_PRECHANGE) == 0) {
J
Jeff Layton 已提交
1657
		fattr->pre_change_attr = inode_peek_iversion_raw(inode);
1658
		fattr->valid |= NFS_ATTR_FATTR_PRECHANGE;
1659
	}
1660 1661
	if ((fattr->valid & NFS_ATTR_FATTR_CTIME) != 0 &&
			(fattr->valid & NFS_ATTR_FATTR_PRECTIME) == 0) {
1662
		memcpy(&fattr->pre_ctime, &inode->i_ctime, sizeof(fattr->pre_ctime));
1663 1664 1665 1666
		fattr->valid |= NFS_ATTR_FATTR_PRECTIME;
	}
	if ((fattr->valid & NFS_ATTR_FATTR_MTIME) != 0 &&
			(fattr->valid & NFS_ATTR_FATTR_PREMTIME) == 0) {
1667
		memcpy(&fattr->pre_mtime, &inode->i_mtime, sizeof(fattr->pre_mtime));
1668 1669 1670 1671
		fattr->valid |= NFS_ATTR_FATTR_PREMTIME;
	}
	if ((fattr->valid & NFS_ATTR_FATTR_SIZE) != 0 &&
			(fattr->valid & NFS_ATTR_FATTR_PRESIZE) == 0) {
1672
		fattr->pre_size = i_size_read(inode);
1673
		fattr->valid |= NFS_ATTR_FATTR_PRESIZE;
1674
	}
1675 1676
out_noforce:
	status = nfs_post_op_update_inode_locked(inode, fattr);
1677 1678 1679 1680 1681 1682 1683 1684 1685 1686 1687 1688 1689 1690 1691 1692 1693 1694 1695
	return status;
}

/**
 * nfs_post_op_update_inode_force_wcc - try to update the inode attribute cache
 * @inode - pointer to inode
 * @fattr - updated attributes
 *
 * After an operation that has changed the inode metadata, mark the
 * attribute cache as being invalid, then try to update it. Fake up
 * weak cache consistency data, if none exist.
 *
 * This function is mainly designed to be used by the ->write_done() functions.
 */
int nfs_post_op_update_inode_force_wcc(struct inode *inode, struct nfs_fattr *fattr)
{
	int status;

	spin_lock(&inode->i_lock);
1696
	nfs_fattr_set_barrier(fattr);
1697
	status = nfs_post_op_update_inode_force_wcc_locked(inode, fattr);
1698 1699
	spin_unlock(&inode->i_lock);
	return status;
1700
}
B
Bryan Schumaker 已提交
1701
EXPORT_SYMBOL_GPL(nfs_post_op_update_inode_force_wcc);
1702

1703 1704 1705 1706 1707 1708 1709 1710 1711 1712 1713 1714 1715

static inline bool nfs_fileid_valid(struct nfs_inode *nfsi,
				    struct nfs_fattr *fattr)
{
	bool ret1 = true, ret2 = true;

	if (fattr->valid & NFS_ATTR_FATTR_FILEID)
		ret1 = (nfsi->fileid == fattr->fileid);
	if (fattr->valid & NFS_ATTR_FATTR_MOUNTED_ON_FILEID)
		ret2 = (nfsi->fileid == fattr->mounted_on_fileid);
	return ret1 || ret2;
}

L
Linus Torvalds 已提交
1716 1717 1718 1719 1720 1721 1722 1723 1724 1725 1726 1727
/*
 * Many nfs protocol calls return the new file attributes after
 * an operation.  Here we update the inode to reflect the state
 * of the server's inode.
 *
 * This is a bit tricky because we have to make sure all dirty pages
 * have been sent off to the server before calling invalidate_inode_pages.
 * To make sure no other process adds more write requests while we try
 * our best to flush them, we make them sleep during the attribute refresh.
 *
 * A very similar scenario holds for the dir cache.
 */
1728
static int nfs_update_inode(struct inode *inode, struct nfs_fattr *fattr)
L
Linus Torvalds 已提交
1729
{
1730
	struct nfs_server *server;
L
Linus Torvalds 已提交
1731
	struct nfs_inode *nfsi = NFS_I(inode);
1732
	loff_t cur_isize, new_isize;
1733
	unsigned long invalid = 0;
1734
	unsigned long now = jiffies;
1735
	unsigned long save_cache_validity;
1736
	bool have_writers = nfs_file_has_buffered_writers(nfsi);
1737
	bool cache_revalidated = true;
L
Linus Torvalds 已提交
1738

1739
	dfprintk(VFS, "NFS: %s(%s/%lu fh_crc=0x%08x ct=%d info=0x%x)\n",
1740
			__func__, inode->i_sb->s_id, inode->i_ino,
1741
			nfs_display_fhandle_hash(NFS_FH(inode)),
L
Linus Torvalds 已提交
1742 1743
			atomic_read(&inode->i_count), fattr->valid);

1744
	if (!nfs_fileid_valid(nfsi, fattr)) {
1745 1746 1747 1748 1749 1750 1751
		printk(KERN_ERR "NFS: server %s error: fileid changed\n"
			"fsid %s: expected fileid 0x%Lx, got 0x%Lx\n",
			NFS_SERVER(inode)->nfs_client->cl_hostname,
			inode->i_sb->s_id, (long long)nfsi->fileid,
			(long long)fattr->fileid);
		goto out_err;
	}
L
Linus Torvalds 已提交
1752 1753 1754 1755

	/*
	 * Make sure the inode's type hasn't changed.
	 */
1756 1757 1758 1759
	if ((fattr->valid & NFS_ATTR_FATTR_TYPE) && (inode->i_mode & S_IFMT) != (fattr->mode & S_IFMT)) {
		/*
		* Big trouble! The inode has become a different object.
		*/
1760
		printk(KERN_DEBUG "NFS: %s: inode %lu mode changed, %07o to %07o\n",
1761 1762 1763
				__func__, inode->i_ino, inode->i_mode, fattr->mode);
		goto out_err;
	}
L
Linus Torvalds 已提交
1764

1765
	server = NFS_SERVER(inode);
T
Trond Myklebust 已提交
1766
	/* Update the fsid? */
1767
	if (S_ISDIR(inode->i_mode) && (fattr->valid & NFS_ATTR_FATTR_FSID) &&
1768
			!nfs_fsid_equal(&server->fsid, &fattr->fsid) &&
1769
			!IS_AUTOMOUNT(inode))
1770 1771
		server->fsid = fattr->fsid;

L
Linus Torvalds 已提交
1772 1773 1774
	/*
	 * Update the read time so we don't revalidate too often.
	 */
1775
	nfsi->read_cache_jiffies = fattr->time_start;
1776

1777 1778 1779 1780 1781
	save_cache_validity = nfsi->cache_validity;
	nfsi->cache_validity &= ~(NFS_INO_INVALID_ATTR
			| NFS_INO_INVALID_ATIME
			| NFS_INO_REVAL_FORCED
			| NFS_INO_REVAL_PAGECACHE);
L
Linus Torvalds 已提交
1782

1783
	/* Do atomic weak cache consistency updates */
1784
	nfs_wcc_update_inode(inode, fattr);
1785

1786 1787 1788 1789
	if (pnfs_layoutcommit_outstanding(inode)) {
		nfsi->cache_validity |= save_cache_validity & NFS_INO_INVALID_ATTR;
		cache_revalidated = false;
	}
1790

1791
	/* More cache consistency checks */
1792
	if (fattr->valid & NFS_ATTR_FATTR_CHANGE) {
1793
		if (!inode_eq_iversion_raw(inode, fattr->change_attr)) {
1794 1795
			dprintk("NFS: change_attr change on server for file %s/%ld\n",
					inode->i_sb->s_id, inode->i_ino);
1796
			/* Could it be a race with writeback? */
1797
			if (!have_writers) {
1798 1799 1800 1801 1802 1803 1804
				invalid |= NFS_INO_INVALID_ATTR
					| NFS_INO_INVALID_DATA
					| NFS_INO_INVALID_ACCESS
					| NFS_INO_INVALID_ACL;
				if (S_ISDIR(inode->i_mode))
					nfs_force_lookup_revalidate(inode);
			}
J
Jeff Layton 已提交
1805
			inode_set_iversion_raw(inode, fattr->change_attr);
1806
		}
1807
	} else {
1808 1809 1810 1811
		nfsi->cache_validity |= save_cache_validity &
				(NFS_INO_INVALID_ATTR
				| NFS_INO_REVAL_PAGECACHE
				| NFS_INO_REVAL_FORCED);
1812 1813
		cache_revalidated = false;
	}
1814 1815

	if (fattr->valid & NFS_ATTR_FATTR_MTIME) {
1816
		memcpy(&inode->i_mtime, &fattr->mtime, sizeof(inode->i_mtime));
1817
	} else if (server->caps & NFS_CAP_MTIME) {
1818 1819
		nfsi->cache_validity |= save_cache_validity &
				(NFS_INO_INVALID_ATTR
1820
				| NFS_INO_REVAL_FORCED);
1821 1822
		cache_revalidated = false;
	}
1823

1824
	if (fattr->valid & NFS_ATTR_FATTR_CTIME) {
1825
		memcpy(&inode->i_ctime, &fattr->ctime, sizeof(inode->i_ctime));
1826
	} else if (server->caps & NFS_CAP_CTIME) {
1827 1828
		nfsi->cache_validity |= save_cache_validity &
				(NFS_INO_INVALID_ATTR
1829
				| NFS_INO_REVAL_FORCED);
1830 1831
		cache_revalidated = false;
	}
1832

1833
	/* Check if our cached file size is stale */
1834 1835 1836 1837 1838 1839
	if (fattr->valid & NFS_ATTR_FATTR_SIZE) {
		new_isize = nfs_size_to_loff_t(fattr->size);
		cur_isize = i_size_read(inode);
		if (new_isize != cur_isize) {
			/* Do we perhaps have any outstanding writes, or has
			 * the file grown beyond our last write? */
1840
			if (!nfs_have_writebacks(inode) || new_isize > cur_isize) {
1841
				i_size_write(inode, new_isize);
1842 1843
				if (!have_writers)
					invalid |= NFS_INO_INVALID_ATTR|NFS_INO_INVALID_DATA;
1844
			}
1845 1846 1847 1848 1849 1850
			dprintk("NFS: isize change on server for file %s/%ld "
					"(%Ld to %Ld)\n",
					inode->i_sb->s_id,
					inode->i_ino,
					(long long)cur_isize,
					(long long)new_isize);
L
Linus Torvalds 已提交
1851
		}
1852
	} else {
1853 1854
		nfsi->cache_validity |= save_cache_validity &
				(NFS_INO_INVALID_ATTR
1855 1856
				| NFS_INO_REVAL_PAGECACHE
				| NFS_INO_REVAL_FORCED);
1857 1858
		cache_revalidated = false;
	}
L
Linus Torvalds 已提交
1859 1860


1861 1862
	if (fattr->valid & NFS_ATTR_FATTR_ATIME)
		memcpy(&inode->i_atime, &fattr->atime, sizeof(inode->i_atime));
1863
	else if (server->caps & NFS_CAP_ATIME) {
1864 1865
		nfsi->cache_validity |= save_cache_validity &
				(NFS_INO_INVALID_ATIME
1866
				| NFS_INO_REVAL_FORCED);
1867 1868
		cache_revalidated = false;
	}
L
Linus Torvalds 已提交
1869

1870 1871
	if (fattr->valid & NFS_ATTR_FATTR_MODE) {
		if ((inode->i_mode & S_IALLUGO) != (fattr->mode & S_IALLUGO)) {
1872 1873 1874
			umode_t newmode = inode->i_mode & S_IFMT;
			newmode |= fattr->mode & S_IALLUGO;
			inode->i_mode = newmode;
1875 1876
			invalid |= NFS_INO_INVALID_ATTR|NFS_INO_INVALID_ACCESS|NFS_INO_INVALID_ACL;
		}
1877
	} else if (server->caps & NFS_CAP_MODE) {
1878 1879
		nfsi->cache_validity |= save_cache_validity &
				(NFS_INO_INVALID_ATTR
1880 1881 1882
				| NFS_INO_INVALID_ACCESS
				| NFS_INO_INVALID_ACL
				| NFS_INO_REVAL_FORCED);
1883 1884
		cache_revalidated = false;
	}
1885

1886
	if (fattr->valid & NFS_ATTR_FATTR_OWNER) {
1887
		if (!uid_eq(inode->i_uid, fattr->uid)) {
1888 1889 1890
			invalid |= NFS_INO_INVALID_ATTR|NFS_INO_INVALID_ACCESS|NFS_INO_INVALID_ACL;
			inode->i_uid = fattr->uid;
		}
1891
	} else if (server->caps & NFS_CAP_OWNER) {
1892 1893
		nfsi->cache_validity |= save_cache_validity &
				(NFS_INO_INVALID_ATTR
1894 1895 1896
				| NFS_INO_INVALID_ACCESS
				| NFS_INO_INVALID_ACL
				| NFS_INO_REVAL_FORCED);
1897 1898
		cache_revalidated = false;
	}
1899

1900
	if (fattr->valid & NFS_ATTR_FATTR_GROUP) {
1901
		if (!gid_eq(inode->i_gid, fattr->gid)) {
1902 1903 1904
			invalid |= NFS_INO_INVALID_ATTR|NFS_INO_INVALID_ACCESS|NFS_INO_INVALID_ACL;
			inode->i_gid = fattr->gid;
		}
1905
	} else if (server->caps & NFS_CAP_OWNER_GROUP) {
1906 1907
		nfsi->cache_validity |= save_cache_validity &
				(NFS_INO_INVALID_ATTR
1908 1909 1910
				| NFS_INO_INVALID_ACCESS
				| NFS_INO_INVALID_ACL
				| NFS_INO_REVAL_FORCED);
1911 1912
		cache_revalidated = false;
	}
1913

1914 1915 1916 1917 1918
	if (fattr->valid & NFS_ATTR_FATTR_NLINK) {
		if (inode->i_nlink != fattr->nlink) {
			invalid |= NFS_INO_INVALID_ATTR;
			if (S_ISDIR(inode->i_mode))
				invalid |= NFS_INO_INVALID_DATA;
M
Miklos Szeredi 已提交
1919
			set_nlink(inode, fattr->nlink);
1920
		}
1921
	} else if (server->caps & NFS_CAP_NLINK) {
1922 1923
		nfsi->cache_validity |= save_cache_validity &
				(NFS_INO_INVALID_ATTR
1924
				| NFS_INO_REVAL_FORCED);
1925 1926
		cache_revalidated = false;
	}
L
Linus Torvalds 已提交
1927

1928
	if (fattr->valid & NFS_ATTR_FATTR_SPACE_USED) {
L
Linus Torvalds 已提交
1929 1930 1931 1932
		/*
		 * report the blocks in 512byte units
		 */
		inode->i_blocks = nfs_calc_block_size(fattr->du.nfs3.used);
1933
	} else if (fattr->valid & NFS_ATTR_FATTR_BLOCKS_USED)
1934
		inode->i_blocks = fattr->du.nfs2.blocks;
1935 1936
	else
		cache_revalidated = false;
L
Linus Torvalds 已提交
1937 1938

	/* Update attrtimeo value if we're out of the unstable period */
1939
	if (invalid & NFS_INO_INVALID_ATTR) {
C
Chuck Lever 已提交
1940
		nfs_inc_stats(inode, NFSIOS_ATTRINVALIDATE);
L
Linus Torvalds 已提交
1941
		nfsi->attrtimeo = NFS_MINATTRTIMEO(inode);
1942
		nfsi->attrtimeo_timestamp = now;
1943
		/* Set barrier to be more recent than all outstanding updates */
1944
		nfsi->attr_gencount = nfs_inc_attr_generation_counter();
1945
	} else {
1946 1947 1948 1949 1950 1951 1952
		if (cache_revalidated) {
			if (!time_in_range_open(now, nfsi->attrtimeo_timestamp,
				nfsi->attrtimeo_timestamp + nfsi->attrtimeo)) {
				nfsi->attrtimeo <<= 1;
				if (nfsi->attrtimeo > NFS_MAXATTRTIMEO(inode))
					nfsi->attrtimeo = NFS_MAXATTRTIMEO(inode);
			}
1953 1954
			nfsi->attrtimeo_timestamp = now;
		}
1955 1956 1957
		/* Set the barrier to be more recent than this fattr */
		if ((long)fattr->gencount - (long)nfsi->attr_gencount > 0)
			nfsi->attr_gencount = fattr->gencount;
L
Linus Torvalds 已提交
1958
	}
1959 1960

	/* Don't declare attrcache up to date if there were no attrs! */
1961
	if (cache_revalidated)
1962 1963
		invalid &= ~NFS_INO_INVALID_ATTR;

L
Linus Torvalds 已提交
1964 1965 1966 1967
	/* Don't invalidate the data if we were to blame */
	if (!(S_ISREG(inode->i_mode) || S_ISDIR(inode->i_mode)
				|| S_ISLNK(inode->i_mode)))
		invalid &= ~NFS_INO_INVALID_DATA;
1968
	if (!NFS_PROTO(inode)->have_delegation(inode, FMODE_READ) ||
1969
			(save_cache_validity & NFS_INO_REVAL_FORCED))
1970
		nfs_set_cache_invalid(inode, invalid);
D
David Howells 已提交
1971

L
Linus Torvalds 已提交
1972
	return 0;
1973
 out_err:
L
Linus Torvalds 已提交
1974 1975 1976 1977 1978 1979 1980 1981 1982
	/*
	 * No need to worry about unhashing the dentry, as the
	 * lookup validation will know that the inode is bad.
	 * (But we fall through to invalidate the caches.)
	 */
	nfs_invalidate_inode(inode);
	return -ESTALE;
}

D
David Howells 已提交
1983
struct inode *nfs_alloc_inode(struct super_block *sb)
L
Linus Torvalds 已提交
1984 1985
{
	struct nfs_inode *nfsi;
F
Firo Yang 已提交
1986
	nfsi = kmem_cache_alloc(nfs_inode_cachep, GFP_KERNEL);
L
Linus Torvalds 已提交
1987 1988
	if (!nfsi)
		return NULL;
1989 1990
	nfsi->flags = 0UL;
	nfsi->cache_validity = 0UL;
B
Bryan Schumaker 已提交
1991
#if IS_ENABLED(CONFIG_NFS_V4)
1992 1993
	nfsi->nfs4_acl = NULL;
#endif /* CONFIG_NFS_V4 */
L
Linus Torvalds 已提交
1994 1995
	return &nfsi->vfs_inode;
}
B
Bryan Schumaker 已提交
1996
EXPORT_SYMBOL_GPL(nfs_alloc_inode);
L
Linus Torvalds 已提交
1997

N
Nick Piggin 已提交
1998
static void nfs_i_callback(struct rcu_head *head)
L
Linus Torvalds 已提交
1999
{
N
Nick Piggin 已提交
2000
	struct inode *inode = container_of(head, struct inode, i_rcu);
L
Linus Torvalds 已提交
2001 2002 2003
	kmem_cache_free(nfs_inode_cachep, NFS_I(inode));
}

N
Nick Piggin 已提交
2004 2005 2006 2007
void nfs_destroy_inode(struct inode *inode)
{
	call_rcu(&inode->i_rcu, nfs_i_callback);
}
B
Bryan Schumaker 已提交
2008
EXPORT_SYMBOL_GPL(nfs_destroy_inode);
N
Nick Piggin 已提交
2009

A
Andrew Morton 已提交
2010 2011
static inline void nfs4_init_once(struct nfs_inode *nfsi)
{
B
Bryan Schumaker 已提交
2012
#if IS_ENABLED(CONFIG_NFS_V4)
A
Andrew Morton 已提交
2013 2014 2015
	INIT_LIST_HEAD(&nfsi->open_states);
	nfsi->delegation = NULL;
	init_rwsem(&nfsi->rwsem);
2016
	nfsi->layout = NULL;
A
Andrew Morton 已提交
2017 2018
#endif
}
D
David Howells 已提交
2019

2020
static void init_once(void *foo)
L
Linus Torvalds 已提交
2021 2022 2023
{
	struct nfs_inode *nfsi = (struct nfs_inode *) foo;

C
Christoph Lameter 已提交
2024 2025 2026 2027
	inode_init_once(&nfsi->vfs_inode);
	INIT_LIST_HEAD(&nfsi->open_files);
	INIT_LIST_HEAD(&nfsi->access_cache_entry_lru);
	INIT_LIST_HEAD(&nfsi->access_cache_inode_lru);
F
Fred Isaman 已提交
2028
	INIT_LIST_HEAD(&nfsi->commit_info.list);
2029
	atomic_long_set(&nfsi->nrequests, 0);
2030
	atomic_long_set(&nfsi->commit_info.ncommit, 0);
2031
	atomic_set(&nfsi->commit_info.rpcs_out, 0);
A
Al Viro 已提交
2032
	init_rwsem(&nfsi->rmdir_sem);
2033
	mutex_init(&nfsi->commit_mutex);
C
Christoph Lameter 已提交
2034
	nfs4_init_once(nfsi);
L
Linus Torvalds 已提交
2035
}
2036

D
David Howells 已提交
2037
static int __init nfs_init_inodecache(void)
L
Linus Torvalds 已提交
2038 2039 2040
{
	nfs_inode_cachep = kmem_cache_create("nfs_inode_cache",
					     sizeof(struct nfs_inode),
2041
					     0, (SLAB_RECLAIM_ACCOUNT|
2042
						SLAB_MEM_SPREAD|SLAB_ACCOUNT),
2043
					     init_once);
L
Linus Torvalds 已提交
2044 2045 2046 2047 2048 2049
	if (nfs_inode_cachep == NULL)
		return -ENOMEM;

	return 0;
}

2050
static void nfs_destroy_inodecache(void)
L
Linus Torvalds 已提交
2051
{
2052 2053 2054 2055 2056
	/*
	 * Make sure all delayed rcu free inodes are flushed before we
	 * destroy cache.
	 */
	rcu_barrier();
2057
	kmem_cache_destroy(nfs_inode_cachep);
L
Linus Torvalds 已提交
2058 2059
}

T
Trond Myklebust 已提交
2060
struct workqueue_struct *nfsiod_workqueue;
B
Bryan Schumaker 已提交
2061
EXPORT_SYMBOL_GPL(nfsiod_workqueue);
T
Trond Myklebust 已提交
2062 2063 2064 2065 2066 2067 2068 2069

/*
 * start up the nfsiod workqueue
 */
static int nfsiod_start(void)
{
	struct workqueue_struct *wq;
	dprintk("RPC:       creating workqueue nfsiod\n");
2070
	wq = alloc_workqueue("nfsiod", WQ_MEM_RECLAIM, 0);
T
Trond Myklebust 已提交
2071 2072 2073 2074 2075 2076 2077 2078 2079 2080 2081 2082 2083 2084 2085 2086 2087 2088 2089 2090
	if (wq == NULL)
		return -ENOMEM;
	nfsiod_workqueue = wq;
	return 0;
}

/*
 * Destroy the nfsiod workqueue
 */
static void nfsiod_stop(void)
{
	struct workqueue_struct *wq;

	wq = nfsiod_workqueue;
	if (wq == NULL)
		return;
	nfsiod_workqueue = NULL;
	destroy_workqueue(wq);
}

2091
unsigned int nfs_net_id;
2092
EXPORT_SYMBOL_GPL(nfs_net_id);
2093 2094 2095

static int nfs_net_init(struct net *net)
{
2096
	nfs_clients_init(net);
2097
	return nfs_fs_proc_net_init(net);
2098 2099 2100 2101
}

static void nfs_net_exit(struct net *net)
{
2102 2103
	struct nfs_net *nn = net_generic(net, nfs_net_id);

2104
	nfs_fs_proc_net_exit(net);
2105
	nfs_cleanup_cb_ident_idr(net);
2106 2107
	WARN_ON_ONCE(!list_empty(&nn->nfs_client_list));
	WARN_ON_ONCE(!list_empty(&nn->nfs_volume_list));
2108 2109 2110 2111 2112 2113 2114 2115 2116
}

static struct pernet_operations nfs_net_ops = {
	.init = nfs_net_init,
	.exit = nfs_net_exit,
	.id   = &nfs_net_id,
	.size = sizeof(struct nfs_net),
};

L
Linus Torvalds 已提交
2117 2118 2119 2120 2121 2122 2123
/*
 * Initialize NFS
 */
static int __init init_nfs_fs(void)
{
	int err;

2124
	err = register_pernet_subsys(&nfs_net_ops);
2125
	if (err < 0)
B
Bryan Schumaker 已提交
2126
		goto out9;
2127

2128 2129
	err = nfs_fscache_register();
	if (err < 0)
B
Bryan Schumaker 已提交
2130
		goto out8;
2131

T
Trond Myklebust 已提交
2132 2133
	err = nfsiod_start();
	if (err)
B
Bryan Schumaker 已提交
2134
		goto out7;
T
Trond Myklebust 已提交
2135

2136 2137
	err = nfs_fs_proc_init();
	if (err)
B
Bryan Schumaker 已提交
2138
		goto out6;
2139

L
Linus Torvalds 已提交
2140 2141
	err = nfs_init_nfspagecache();
	if (err)
B
Bryan Schumaker 已提交
2142
		goto out5;
L
Linus Torvalds 已提交
2143 2144 2145

	err = nfs_init_inodecache();
	if (err)
B
Bryan Schumaker 已提交
2146
		goto out4;
L
Linus Torvalds 已提交
2147 2148 2149

	err = nfs_init_readpagecache();
	if (err)
B
Bryan Schumaker 已提交
2150
		goto out3;
L
Linus Torvalds 已提交
2151 2152 2153

	err = nfs_init_writepagecache();
	if (err)
B
Bryan Schumaker 已提交
2154
		goto out2;
L
Linus Torvalds 已提交
2155 2156 2157

	err = nfs_init_directcache();
	if (err)
B
Bryan Schumaker 已提交
2158
		goto out1;
L
Linus Torvalds 已提交
2159

2160
	rpc_proc_register(&init_net, &nfs_rpcstat);
2161 2162 2163

	err = register_nfs_fs();
	if (err)
2164 2165
		goto out0;

L
Linus Torvalds 已提交
2166
	return 0;
2167
out0:
2168
	rpc_proc_unregister(&init_net, "nfs");
L
Linus Torvalds 已提交
2169
	nfs_destroy_directcache();
B
Bryan Schumaker 已提交
2170
out1:
2171
	nfs_destroy_writepagecache();
B
Bryan Schumaker 已提交
2172
out2:
2173
	nfs_destroy_readpagecache();
B
Bryan Schumaker 已提交
2174
out3:
2175
	nfs_destroy_inodecache();
B
Bryan Schumaker 已提交
2176
out4:
2177
	nfs_destroy_nfspagecache();
B
Bryan Schumaker 已提交
2178
out5:
2179
	nfs_fs_proc_exit();
B
Bryan Schumaker 已提交
2180
out6:
2181
	nfsiod_stop();
B
Bryan Schumaker 已提交
2182
out7:
2183
	nfs_fscache_unregister();
B
Bryan Schumaker 已提交
2184
out8:
2185
	unregister_pernet_subsys(&nfs_net_ops);
B
Bryan Schumaker 已提交
2186
out9:
L
Linus Torvalds 已提交
2187 2188 2189 2190 2191 2192 2193 2194 2195 2196
	return err;
}

static void __exit exit_nfs_fs(void)
{
	nfs_destroy_directcache();
	nfs_destroy_writepagecache();
	nfs_destroy_readpagecache();
	nfs_destroy_inodecache();
	nfs_destroy_nfspagecache();
2197
	nfs_fscache_unregister();
2198
	unregister_pernet_subsys(&nfs_net_ops);
2199
	rpc_proc_unregister(&init_net, "nfs");
D
David Howells 已提交
2200
	unregister_nfs_fs();
2201
	nfs_fs_proc_exit();
T
Trond Myklebust 已提交
2202
	nfsiod_stop();
L
Linus Torvalds 已提交
2203 2204 2205 2206 2207
}

/* Not quite true; I just maintain it */
MODULE_AUTHOR("Olaf Kirch <okir@monad.swb.de>");
MODULE_LICENSE("GPL");
2208
module_param(enable_ino64, bool, 0644);
L
Linus Torvalds 已提交
2209 2210 2211

module_init(init_nfs_fs)
module_exit(exit_nfs_fs)