pNFS: Ensure we layoutcommit before revalidating attributes
[deliverable/linux.git] / fs / nfs / inode.c
1 /*
2 * linux/fs/nfs/inode.c
3 *
4 * Copyright (C) 1992 Rick Sladkey
5 *
6 * nfs inode and superblock handling functions
7 *
8 * Modularised by Alan Cox <alan@lxorguk.ukuu.org.uk>, while hacking some
9 * experimental NFS changes. Modularisation taken straight from SYS5 fs.
10 *
11 * Change to nfs_read_super() to permit NFS mounts to multi-homed hosts.
12 * J.S.Peatfield@damtp.cam.ac.uk
13 *
14 */
15
16 #include <linux/module.h>
17 #include <linux/init.h>
18 #include <linux/sched.h>
19 #include <linux/time.h>
20 #include <linux/kernel.h>
21 #include <linux/mm.h>
22 #include <linux/string.h>
23 #include <linux/stat.h>
24 #include <linux/errno.h>
25 #include <linux/unistd.h>
26 #include <linux/sunrpc/clnt.h>
27 #include <linux/sunrpc/stats.h>
28 #include <linux/sunrpc/metrics.h>
29 #include <linux/nfs_fs.h>
30 #include <linux/nfs_mount.h>
31 #include <linux/nfs4_mount.h>
32 #include <linux/lockd/bind.h>
33 #include <linux/seq_file.h>
34 #include <linux/mount.h>
35 #include <linux/vfs.h>
36 #include <linux/inet.h>
37 #include <linux/nfs_xdr.h>
38 #include <linux/slab.h>
39 #include <linux/compat.h>
40 #include <linux/freezer.h>
41
42 #include <asm/uaccess.h>
43
44 #include "nfs4_fs.h"
45 #include "callback.h"
46 #include "delegation.h"
47 #include "iostat.h"
48 #include "internal.h"
49 #include "fscache.h"
50 #include "pnfs.h"
51 #include "nfs.h"
52 #include "netns.h"
53
54 #include "nfstrace.h"
55
56 #define NFSDBG_FACILITY NFSDBG_VFS
57
58 #define NFS_64_BIT_INODE_NUMBERS_ENABLED 1
59
60 /* Default is to see 64-bit inode numbers */
61 static bool enable_ino64 = NFS_64_BIT_INODE_NUMBERS_ENABLED;
62
63 static void nfs_invalidate_inode(struct inode *);
64 static int nfs_update_inode(struct inode *, struct nfs_fattr *);
65
66 static struct kmem_cache * nfs_inode_cachep;
67
68 static inline unsigned long
69 nfs_fattr_to_ino_t(struct nfs_fattr *fattr)
70 {
71 return nfs_fileid_to_ino_t(fattr->fileid);
72 }
73
74 static int nfs_wait_killable(int mode)
75 {
76 freezable_schedule_unsafe();
77 if (signal_pending_state(mode, current))
78 return -ERESTARTSYS;
79 return 0;
80 }
81
82 int nfs_wait_bit_killable(struct wait_bit_key *key, int mode)
83 {
84 return nfs_wait_killable(mode);
85 }
86 EXPORT_SYMBOL_GPL(nfs_wait_bit_killable);
87
88 int nfs_wait_atomic_killable(atomic_t *p)
89 {
90 return nfs_wait_killable(TASK_KILLABLE);
91 }
92
93 /**
94 * nfs_compat_user_ino64 - returns the user-visible inode number
95 * @fileid: 64-bit fileid
96 *
97 * This function returns a 32-bit inode number if the boot parameter
98 * nfs.enable_ino64 is zero.
99 */
100 u64 nfs_compat_user_ino64(u64 fileid)
101 {
102 #ifdef CONFIG_COMPAT
103 compat_ulong_t ino;
104 #else
105 unsigned long ino;
106 #endif
107
108 if (enable_ino64)
109 return fileid;
110 ino = fileid;
111 if (sizeof(ino) < sizeof(fileid))
112 ino ^= fileid >> (sizeof(fileid)-sizeof(ino)) * 8;
113 return ino;
114 }
115
116 int nfs_drop_inode(struct inode *inode)
117 {
118 return NFS_STALE(inode) || generic_drop_inode(inode);
119 }
120 EXPORT_SYMBOL_GPL(nfs_drop_inode);
121
122 void nfs_clear_inode(struct inode *inode)
123 {
124 /*
125 * The following should never happen...
126 */
127 WARN_ON_ONCE(nfs_have_writebacks(inode));
128 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);
132 }
133 EXPORT_SYMBOL_GPL(nfs_clear_inode);
134
135 void nfs_evict_inode(struct inode *inode)
136 {
137 truncate_inode_pages_final(&inode->i_data);
138 clear_inode(inode);
139 nfs_clear_inode(inode);
140 }
141
142 int nfs_sync_inode(struct inode *inode)
143 {
144 inode_dio_wait(inode);
145 return nfs_wb_all(inode);
146 }
147 EXPORT_SYMBOL_GPL(nfs_sync_inode);
148
149 /**
150 * nfs_sync_mapping - helper to flush all mmapped dirty data to disk
151 */
152 int nfs_sync_mapping(struct address_space *mapping)
153 {
154 int ret = 0;
155
156 if (mapping->nrpages != 0) {
157 unmap_mapping_range(mapping, 0, 0, 0);
158 ret = nfs_wb_all(mapping->host);
159 }
160 return ret;
161 }
162
163 static void nfs_set_cache_invalid(struct inode *inode, unsigned long flags)
164 {
165 struct nfs_inode *nfsi = NFS_I(inode);
166
167 if (inode->i_mapping->nrpages == 0)
168 flags &= ~NFS_INO_INVALID_DATA;
169 nfsi->cache_validity |= flags;
170 if (flags & NFS_INO_INVALID_DATA)
171 nfs_fscache_invalidate(inode);
172 }
173
174 /*
175 * Invalidate the local caches
176 */
177 static void nfs_zap_caches_locked(struct inode *inode)
178 {
179 struct nfs_inode *nfsi = NFS_I(inode);
180 int mode = inode->i_mode;
181
182 nfs_inc_stats(inode, NFSIOS_ATTRINVALIDATE);
183
184 nfsi->attrtimeo = NFS_MINATTRTIMEO(inode);
185 nfsi->attrtimeo_timestamp = jiffies;
186
187 memset(NFS_I(inode)->cookieverf, 0, sizeof(NFS_I(inode)->cookieverf));
188 if (S_ISREG(mode) || S_ISDIR(mode) || S_ISLNK(mode)) {
189 nfs_set_cache_invalid(inode, NFS_INO_INVALID_ATTR
190 | NFS_INO_INVALID_DATA
191 | NFS_INO_INVALID_ACCESS
192 | NFS_INO_INVALID_ACL
193 | NFS_INO_REVAL_PAGECACHE);
194 } else
195 nfs_set_cache_invalid(inode, NFS_INO_INVALID_ATTR
196 | NFS_INO_INVALID_ACCESS
197 | NFS_INO_INVALID_ACL
198 | NFS_INO_REVAL_PAGECACHE);
199 nfs_zap_label_cache_locked(nfsi);
200 }
201
202 void nfs_zap_caches(struct inode *inode)
203 {
204 spin_lock(&inode->i_lock);
205 nfs_zap_caches_locked(inode);
206 spin_unlock(&inode->i_lock);
207 }
208
209 void nfs_zap_mapping(struct inode *inode, struct address_space *mapping)
210 {
211 if (mapping->nrpages != 0) {
212 spin_lock(&inode->i_lock);
213 nfs_set_cache_invalid(inode, NFS_INO_INVALID_DATA);
214 spin_unlock(&inode->i_lock);
215 }
216 }
217
218 void nfs_zap_acl_cache(struct inode *inode)
219 {
220 void (*clear_acl_cache)(struct inode *);
221
222 clear_acl_cache = NFS_PROTO(inode)->clear_acl_cache;
223 if (clear_acl_cache != NULL)
224 clear_acl_cache(inode);
225 spin_lock(&inode->i_lock);
226 NFS_I(inode)->cache_validity &= ~NFS_INO_INVALID_ACL;
227 spin_unlock(&inode->i_lock);
228 }
229 EXPORT_SYMBOL_GPL(nfs_zap_acl_cache);
230
231 void nfs_invalidate_atime(struct inode *inode)
232 {
233 spin_lock(&inode->i_lock);
234 nfs_set_cache_invalid(inode, NFS_INO_INVALID_ATIME);
235 spin_unlock(&inode->i_lock);
236 }
237 EXPORT_SYMBOL_GPL(nfs_invalidate_atime);
238
239 /*
240 * Invalidate, but do not unhash, the inode.
241 * NB: must be called with inode->i_lock held!
242 */
243 static void nfs_invalidate_inode(struct inode *inode)
244 {
245 set_bit(NFS_INO_STALE, &NFS_I(inode)->flags);
246 nfs_zap_caches_locked(inode);
247 }
248
249 struct nfs_find_desc {
250 struct nfs_fh *fh;
251 struct nfs_fattr *fattr;
252 };
253
254 /*
255 * In NFSv3 we can have 64bit inode numbers. In order to support
256 * this, and re-exported directories (also seen in NFSv2)
257 * we are forced to allow 2 different inodes to have the same
258 * i_ino.
259 */
260 static int
261 nfs_find_actor(struct inode *inode, void *opaque)
262 {
263 struct nfs_find_desc *desc = (struct nfs_find_desc *)opaque;
264 struct nfs_fh *fh = desc->fh;
265 struct nfs_fattr *fattr = desc->fattr;
266
267 if (NFS_FILEID(inode) != fattr->fileid)
268 return 0;
269 if ((S_IFMT & inode->i_mode) != (S_IFMT & fattr->mode))
270 return 0;
271 if (nfs_compare_fh(NFS_FH(inode), fh))
272 return 0;
273 if (is_bad_inode(inode) || NFS_STALE(inode))
274 return 0;
275 return 1;
276 }
277
278 static int
279 nfs_init_locked(struct inode *inode, void *opaque)
280 {
281 struct nfs_find_desc *desc = (struct nfs_find_desc *)opaque;
282 struct nfs_fattr *fattr = desc->fattr;
283
284 set_nfs_fileid(inode, fattr->fileid);
285 nfs_copy_fh(NFS_FH(inode), desc->fh);
286 return 0;
287 }
288
289 #ifdef CONFIG_NFS_V4_SECURITY_LABEL
290 static void nfs_clear_label_invalid(struct inode *inode)
291 {
292 spin_lock(&inode->i_lock);
293 NFS_I(inode)->cache_validity &= ~NFS_INO_INVALID_LABEL;
294 spin_unlock(&inode->i_lock);
295 }
296
297 void nfs_setsecurity(struct inode *inode, struct nfs_fattr *fattr,
298 struct nfs4_label *label)
299 {
300 int error;
301
302 if (label == NULL)
303 return;
304
305 if ((fattr->valid & NFS_ATTR_FATTR_V4_SECURITY_LABEL) && inode->i_security) {
306 error = security_inode_notifysecctx(inode, label->label,
307 label->len);
308 if (error)
309 printk(KERN_ERR "%s() %s %d "
310 "security_inode_notifysecctx() %d\n",
311 __func__,
312 (char *)label->label,
313 label->len, error);
314 nfs_clear_label_invalid(inode);
315 }
316 }
317
318 struct nfs4_label *nfs4_label_alloc(struct nfs_server *server, gfp_t flags)
319 {
320 struct nfs4_label *label = NULL;
321 int minor_version = server->nfs_client->cl_minorversion;
322
323 if (minor_version < 2)
324 return label;
325
326 if (!(server->caps & NFS_CAP_SECURITY_LABEL))
327 return label;
328
329 label = kzalloc(sizeof(struct nfs4_label), flags);
330 if (label == NULL)
331 return ERR_PTR(-ENOMEM);
332
333 label->label = kzalloc(NFS4_MAXLABELLEN, flags);
334 if (label->label == NULL) {
335 kfree(label);
336 return ERR_PTR(-ENOMEM);
337 }
338 label->len = NFS4_MAXLABELLEN;
339
340 return label;
341 }
342 EXPORT_SYMBOL_GPL(nfs4_label_alloc);
343 #else
344 void nfs_setsecurity(struct inode *inode, struct nfs_fattr *fattr,
345 struct nfs4_label *label)
346 {
347 }
348 #endif
349 EXPORT_SYMBOL_GPL(nfs_setsecurity);
350
351 /*
352 * This is our front-end to iget that looks up inodes by file handle
353 * instead of inode number.
354 */
355 struct inode *
356 nfs_fhget(struct super_block *sb, struct nfs_fh *fh, struct nfs_fattr *fattr, struct nfs4_label *label)
357 {
358 struct nfs_find_desc desc = {
359 .fh = fh,
360 .fattr = fattr
361 };
362 struct inode *inode = ERR_PTR(-ENOENT);
363 unsigned long hash;
364
365 nfs_attr_check_mountpoint(sb, fattr);
366
367 if (nfs_attr_use_mounted_on_fileid(fattr))
368 fattr->fileid = fattr->mounted_on_fileid;
369 else if ((fattr->valid & NFS_ATTR_FATTR_FILEID) == 0)
370 goto out_no_inode;
371 if ((fattr->valid & NFS_ATTR_FATTR_TYPE) == 0)
372 goto out_no_inode;
373
374 hash = nfs_fattr_to_ino_t(fattr);
375
376 inode = iget5_locked(sb, hash, nfs_find_actor, nfs_init_locked, &desc);
377 if (inode == NULL) {
378 inode = ERR_PTR(-ENOMEM);
379 goto out_no_inode;
380 }
381
382 if (inode->i_state & I_NEW) {
383 struct nfs_inode *nfsi = NFS_I(inode);
384 unsigned long now = jiffies;
385
386 /* We set i_ino for the few things that still rely on it,
387 * such as stat(2) */
388 inode->i_ino = hash;
389
390 /* We can't support update_atime(), since the server will reset it */
391 inode->i_flags |= S_NOATIME|S_NOCMTIME;
392 inode->i_mode = fattr->mode;
393 if ((fattr->valid & NFS_ATTR_FATTR_MODE) == 0
394 && nfs_server_capable(inode, NFS_CAP_MODE))
395 nfs_set_cache_invalid(inode, NFS_INO_INVALID_ATTR);
396 /* Why so? Because we want revalidate for devices/FIFOs, and
397 * that's precisely what we have in nfs_file_inode_operations.
398 */
399 inode->i_op = NFS_SB(sb)->nfs_client->rpc_ops->file_inode_ops;
400 if (S_ISREG(inode->i_mode)) {
401 inode->i_fop = NFS_SB(sb)->nfs_client->rpc_ops->file_ops;
402 inode->i_data.a_ops = &nfs_file_aops;
403 } else if (S_ISDIR(inode->i_mode)) {
404 inode->i_op = NFS_SB(sb)->nfs_client->rpc_ops->dir_inode_ops;
405 inode->i_fop = &nfs_dir_operations;
406 inode->i_data.a_ops = &nfs_dir_aops;
407 /* Deal with crossing mountpoints */
408 if (fattr->valid & NFS_ATTR_FATTR_MOUNTPOINT ||
409 fattr->valid & NFS_ATTR_FATTR_V4_REFERRAL) {
410 if (fattr->valid & NFS_ATTR_FATTR_V4_REFERRAL)
411 inode->i_op = &nfs_referral_inode_operations;
412 else
413 inode->i_op = &nfs_mountpoint_inode_operations;
414 inode->i_fop = NULL;
415 inode->i_flags |= S_AUTOMOUNT;
416 }
417 } else if (S_ISLNK(inode->i_mode)) {
418 inode->i_op = &nfs_symlink_inode_operations;
419 inode_nohighmem(inode);
420 } else
421 init_special_inode(inode, inode->i_mode, fattr->rdev);
422
423 memset(&inode->i_atime, 0, sizeof(inode->i_atime));
424 memset(&inode->i_mtime, 0, sizeof(inode->i_mtime));
425 memset(&inode->i_ctime, 0, sizeof(inode->i_ctime));
426 inode->i_version = 0;
427 inode->i_size = 0;
428 clear_nlink(inode);
429 inode->i_uid = make_kuid(&init_user_ns, -2);
430 inode->i_gid = make_kgid(&init_user_ns, -2);
431 inode->i_blocks = 0;
432 memset(nfsi->cookieverf, 0, sizeof(nfsi->cookieverf));
433 nfsi->write_io = 0;
434 nfsi->read_io = 0;
435
436 nfsi->read_cache_jiffies = fattr->time_start;
437 nfsi->attr_gencount = fattr->gencount;
438 if (fattr->valid & NFS_ATTR_FATTR_ATIME)
439 inode->i_atime = fattr->atime;
440 else if (nfs_server_capable(inode, NFS_CAP_ATIME))
441 nfs_set_cache_invalid(inode, NFS_INO_INVALID_ATTR);
442 if (fattr->valid & NFS_ATTR_FATTR_MTIME)
443 inode->i_mtime = fattr->mtime;
444 else if (nfs_server_capable(inode, NFS_CAP_MTIME))
445 nfs_set_cache_invalid(inode, NFS_INO_INVALID_ATTR);
446 if (fattr->valid & NFS_ATTR_FATTR_CTIME)
447 inode->i_ctime = fattr->ctime;
448 else if (nfs_server_capable(inode, NFS_CAP_CTIME))
449 nfs_set_cache_invalid(inode, NFS_INO_INVALID_ATTR);
450 if (fattr->valid & NFS_ATTR_FATTR_CHANGE)
451 inode->i_version = fattr->change_attr;
452 else
453 nfs_set_cache_invalid(inode, NFS_INO_INVALID_ATTR
454 | NFS_INO_REVAL_PAGECACHE);
455 if (fattr->valid & NFS_ATTR_FATTR_SIZE)
456 inode->i_size = nfs_size_to_loff_t(fattr->size);
457 else
458 nfs_set_cache_invalid(inode, NFS_INO_INVALID_ATTR
459 | NFS_INO_REVAL_PAGECACHE);
460 if (fattr->valid & NFS_ATTR_FATTR_NLINK)
461 set_nlink(inode, fattr->nlink);
462 else if (nfs_server_capable(inode, NFS_CAP_NLINK))
463 nfs_set_cache_invalid(inode, NFS_INO_INVALID_ATTR);
464 if (fattr->valid & NFS_ATTR_FATTR_OWNER)
465 inode->i_uid = fattr->uid;
466 else if (nfs_server_capable(inode, NFS_CAP_OWNER))
467 nfs_set_cache_invalid(inode, NFS_INO_INVALID_ATTR);
468 if (fattr->valid & NFS_ATTR_FATTR_GROUP)
469 inode->i_gid = fattr->gid;
470 else if (nfs_server_capable(inode, NFS_CAP_OWNER_GROUP))
471 nfs_set_cache_invalid(inode, NFS_INO_INVALID_ATTR);
472 if (fattr->valid & NFS_ATTR_FATTR_BLOCKS_USED)
473 inode->i_blocks = fattr->du.nfs2.blocks;
474 if (fattr->valid & NFS_ATTR_FATTR_SPACE_USED) {
475 /*
476 * report the blocks in 512byte units
477 */
478 inode->i_blocks = nfs_calc_block_size(fattr->du.nfs3.used);
479 }
480
481 nfs_setsecurity(inode, fattr, label);
482
483 nfsi->attrtimeo = NFS_MINATTRTIMEO(inode);
484 nfsi->attrtimeo_timestamp = now;
485 nfsi->access_cache = RB_ROOT;
486
487 nfs_fscache_init_inode(inode);
488
489 unlock_new_inode(inode);
490 } else
491 nfs_refresh_inode(inode, fattr);
492 dprintk("NFS: nfs_fhget(%s/%Lu fh_crc=0x%08x ct=%d)\n",
493 inode->i_sb->s_id,
494 (unsigned long long)NFS_FILEID(inode),
495 nfs_display_fhandle_hash(fh),
496 atomic_read(&inode->i_count));
497
498 out:
499 return inode;
500
501 out_no_inode:
502 dprintk("nfs_fhget: iget failed with error %ld\n", PTR_ERR(inode));
503 goto out;
504 }
505 EXPORT_SYMBOL_GPL(nfs_fhget);
506
507 #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)
508
509 int
510 nfs_setattr(struct dentry *dentry, struct iattr *attr)
511 {
512 struct inode *inode = d_inode(dentry);
513 struct nfs_fattr *fattr;
514 int error = 0;
515
516 nfs_inc_stats(inode, NFSIOS_VFSSETATTR);
517
518 /* skip mode change if it's just for clearing setuid/setgid */
519 if (attr->ia_valid & (ATTR_KILL_SUID | ATTR_KILL_SGID))
520 attr->ia_valid &= ~ATTR_MODE;
521
522 if (attr->ia_valid & ATTR_SIZE) {
523 BUG_ON(!S_ISREG(inode->i_mode));
524
525 error = inode_newsize_ok(inode, attr->ia_size);
526 if (error)
527 return error;
528
529 if (attr->ia_size == i_size_read(inode))
530 attr->ia_valid &= ~ATTR_SIZE;
531 }
532
533 /* Optimization: if the end result is no change, don't RPC */
534 attr->ia_valid &= NFS_VALID_ATTRS;
535 if ((attr->ia_valid & ~(ATTR_FILE|ATTR_OPEN)) == 0)
536 return 0;
537
538 trace_nfs_setattr_enter(inode);
539
540 /* Write all dirty data */
541 if (S_ISREG(inode->i_mode))
542 nfs_sync_inode(inode);
543
544 fattr = nfs_alloc_fattr();
545 if (fattr == NULL) {
546 error = -ENOMEM;
547 goto out;
548 }
549
550 /*
551 * Return any delegations if we're going to change ACLs
552 */
553 if ((attr->ia_valid & (ATTR_MODE|ATTR_UID|ATTR_GID)) != 0)
554 NFS_PROTO(inode)->return_delegation(inode);
555 error = NFS_PROTO(inode)->setattr(dentry, fattr, attr);
556 if (error == 0)
557 error = nfs_refresh_inode(inode, fattr);
558 nfs_free_fattr(fattr);
559 out:
560 trace_nfs_setattr_exit(inode, error);
561 return error;
562 }
563 EXPORT_SYMBOL_GPL(nfs_setattr);
564
565 /**
566 * nfs_vmtruncate - unmap mappings "freed" by truncate() syscall
567 * @inode: inode of the file used
568 * @offset: file offset to start truncating
569 *
570 * This is a copy of the common vmtruncate, but with the locking
571 * corrected to take into account the fact that NFS requires
572 * inode->i_size to be updated under the inode->i_lock.
573 * Note: must be called with inode->i_lock held!
574 */
575 static int nfs_vmtruncate(struct inode * inode, loff_t offset)
576 {
577 int err;
578
579 err = inode_newsize_ok(inode, offset);
580 if (err)
581 goto out;
582
583 i_size_write(inode, offset);
584 /* Optimisation */
585 if (offset == 0)
586 NFS_I(inode)->cache_validity &= ~NFS_INO_INVALID_DATA;
587
588 spin_unlock(&inode->i_lock);
589 truncate_pagecache(inode, offset);
590 spin_lock(&inode->i_lock);
591 out:
592 return err;
593 }
594
595 /**
596 * nfs_setattr_update_inode - Update inode metadata after a setattr call.
597 * @inode: pointer to struct inode
598 * @attr: pointer to struct iattr
599 *
600 * Note: we do this in the *proc.c in order to ensure that
601 * it works for things like exclusive creates too.
602 */
603 void nfs_setattr_update_inode(struct inode *inode, struct iattr *attr,
604 struct nfs_fattr *fattr)
605 {
606 /* Barrier: bump the attribute generation count. */
607 nfs_fattr_set_barrier(fattr);
608
609 spin_lock(&inode->i_lock);
610 NFS_I(inode)->attr_gencount = fattr->gencount;
611 if ((attr->ia_valid & (ATTR_MODE|ATTR_UID|ATTR_GID)) != 0) {
612 if ((attr->ia_valid & ATTR_MODE) != 0) {
613 int mode = attr->ia_mode & S_IALLUGO;
614 mode |= inode->i_mode & ~S_IALLUGO;
615 inode->i_mode = mode;
616 }
617 if ((attr->ia_valid & ATTR_UID) != 0)
618 inode->i_uid = attr->ia_uid;
619 if ((attr->ia_valid & ATTR_GID) != 0)
620 inode->i_gid = attr->ia_gid;
621 nfs_set_cache_invalid(inode, NFS_INO_INVALID_ACCESS
622 | NFS_INO_INVALID_ACL);
623 }
624 if ((attr->ia_valid & ATTR_SIZE) != 0) {
625 nfs_inc_stats(inode, NFSIOS_SETATTRTRUNC);
626 nfs_vmtruncate(inode, attr->ia_size);
627 }
628 if (fattr->valid)
629 nfs_update_inode(inode, fattr);
630 else
631 NFS_I(inode)->cache_validity |= NFS_INO_INVALID_ATTR;
632 spin_unlock(&inode->i_lock);
633 }
634 EXPORT_SYMBOL_GPL(nfs_setattr_update_inode);
635
636 static void nfs_request_parent_use_readdirplus(struct dentry *dentry)
637 {
638 struct dentry *parent;
639
640 parent = dget_parent(dentry);
641 nfs_force_use_readdirplus(d_inode(parent));
642 dput(parent);
643 }
644
645 static bool nfs_need_revalidate_inode(struct inode *inode)
646 {
647 if (NFS_I(inode)->cache_validity &
648 (NFS_INO_INVALID_ATTR|NFS_INO_INVALID_LABEL))
649 return true;
650 if (nfs_attribute_cache_expired(inode))
651 return true;
652 return false;
653 }
654
655 int nfs_getattr(struct vfsmount *mnt, struct dentry *dentry, struct kstat *stat)
656 {
657 struct inode *inode = d_inode(dentry);
658 int need_atime = NFS_I(inode)->cache_validity & NFS_INO_INVALID_ATIME;
659 int err = 0;
660
661 trace_nfs_getattr_enter(inode);
662 /* Flush out writes to the server in order to update c/mtime. */
663 if (S_ISREG(inode->i_mode)) {
664 inode_lock(inode);
665 err = nfs_sync_inode(inode);
666 inode_unlock(inode);
667 if (err)
668 goto out;
669 }
670
671 /*
672 * We may force a getattr if the user cares about atime.
673 *
674 * Note that we only have to check the vfsmount flags here:
675 * - NFS always sets S_NOATIME by so checking it would give a
676 * bogus result
677 * - NFS never sets MS_NOATIME or MS_NODIRATIME so there is
678 * no point in checking those.
679 */
680 if ((mnt->mnt_flags & MNT_NOATIME) ||
681 ((mnt->mnt_flags & MNT_NODIRATIME) && S_ISDIR(inode->i_mode)))
682 need_atime = 0;
683
684 if (need_atime || nfs_need_revalidate_inode(inode)) {
685 struct nfs_server *server = NFS_SERVER(inode);
686
687 if (server->caps & NFS_CAP_READDIRPLUS)
688 nfs_request_parent_use_readdirplus(dentry);
689 err = __nfs_revalidate_inode(server, inode);
690 }
691 if (!err) {
692 generic_fillattr(inode, stat);
693 stat->ino = nfs_compat_user_ino64(NFS_FILEID(inode));
694 if (S_ISDIR(inode->i_mode))
695 stat->blksize = NFS_SERVER(inode)->dtsize;
696 }
697 out:
698 trace_nfs_getattr_exit(inode, err);
699 return err;
700 }
701 EXPORT_SYMBOL_GPL(nfs_getattr);
702
703 static void nfs_init_lock_context(struct nfs_lock_context *l_ctx)
704 {
705 atomic_set(&l_ctx->count, 1);
706 l_ctx->lockowner.l_owner = current->files;
707 l_ctx->lockowner.l_pid = current->tgid;
708 INIT_LIST_HEAD(&l_ctx->list);
709 atomic_set(&l_ctx->io_count, 0);
710 }
711
712 static struct nfs_lock_context *__nfs_find_lock_context(struct nfs_open_context *ctx)
713 {
714 struct nfs_lock_context *head = &ctx->lock_context;
715 struct nfs_lock_context *pos = head;
716
717 do {
718 if (pos->lockowner.l_owner != current->files)
719 continue;
720 if (pos->lockowner.l_pid != current->tgid)
721 continue;
722 atomic_inc(&pos->count);
723 return pos;
724 } while ((pos = list_entry(pos->list.next, typeof(*pos), list)) != head);
725 return NULL;
726 }
727
728 struct nfs_lock_context *nfs_get_lock_context(struct nfs_open_context *ctx)
729 {
730 struct nfs_lock_context *res, *new = NULL;
731 struct inode *inode = d_inode(ctx->dentry);
732
733 spin_lock(&inode->i_lock);
734 res = __nfs_find_lock_context(ctx);
735 if (res == NULL) {
736 spin_unlock(&inode->i_lock);
737 new = kmalloc(sizeof(*new), GFP_KERNEL);
738 if (new == NULL)
739 return ERR_PTR(-ENOMEM);
740 nfs_init_lock_context(new);
741 spin_lock(&inode->i_lock);
742 res = __nfs_find_lock_context(ctx);
743 if (res == NULL) {
744 list_add_tail(&new->list, &ctx->lock_context.list);
745 new->open_context = ctx;
746 res = new;
747 new = NULL;
748 }
749 }
750 spin_unlock(&inode->i_lock);
751 kfree(new);
752 return res;
753 }
754 EXPORT_SYMBOL_GPL(nfs_get_lock_context);
755
756 void nfs_put_lock_context(struct nfs_lock_context *l_ctx)
757 {
758 struct nfs_open_context *ctx = l_ctx->open_context;
759 struct inode *inode = d_inode(ctx->dentry);
760
761 if (!atomic_dec_and_lock(&l_ctx->count, &inode->i_lock))
762 return;
763 list_del(&l_ctx->list);
764 spin_unlock(&inode->i_lock);
765 kfree(l_ctx);
766 }
767 EXPORT_SYMBOL_GPL(nfs_put_lock_context);
768
769 /**
770 * nfs_close_context - Common close_context() routine NFSv2/v3
771 * @ctx: pointer to context
772 * @is_sync: is this a synchronous close
773 *
774 * Ensure that the attributes are up to date if we're mounted
775 * with close-to-open semantics and we have cached data that will
776 * need to be revalidated on open.
777 */
778 void nfs_close_context(struct nfs_open_context *ctx, int is_sync)
779 {
780 struct nfs_inode *nfsi;
781 struct inode *inode;
782 struct nfs_server *server;
783
784 if (!(ctx->mode & FMODE_WRITE))
785 return;
786 if (!is_sync)
787 return;
788 inode = d_inode(ctx->dentry);
789 nfsi = NFS_I(inode);
790 if (inode->i_mapping->nrpages == 0)
791 return;
792 if (nfsi->cache_validity & NFS_INO_INVALID_DATA)
793 return;
794 if (!list_empty(&nfsi->open_files))
795 return;
796 server = NFS_SERVER(inode);
797 if (server->flags & NFS_MOUNT_NOCTO)
798 return;
799 nfs_revalidate_inode(server, inode);
800 }
801 EXPORT_SYMBOL_GPL(nfs_close_context);
802
803 struct nfs_open_context *alloc_nfs_open_context(struct dentry *dentry, fmode_t f_mode)
804 {
805 struct nfs_open_context *ctx;
806 struct rpc_cred *cred = rpc_lookup_cred();
807 if (IS_ERR(cred))
808 return ERR_CAST(cred);
809
810 ctx = kmalloc(sizeof(*ctx), GFP_KERNEL);
811 if (!ctx) {
812 put_rpccred(cred);
813 return ERR_PTR(-ENOMEM);
814 }
815 nfs_sb_active(dentry->d_sb);
816 ctx->dentry = dget(dentry);
817 ctx->cred = cred;
818 ctx->state = NULL;
819 ctx->mode = f_mode;
820 ctx->flags = 0;
821 ctx->error = 0;
822 nfs_init_lock_context(&ctx->lock_context);
823 ctx->lock_context.open_context = ctx;
824 INIT_LIST_HEAD(&ctx->list);
825 ctx->mdsthreshold = NULL;
826 return ctx;
827 }
828 EXPORT_SYMBOL_GPL(alloc_nfs_open_context);
829
830 struct nfs_open_context *get_nfs_open_context(struct nfs_open_context *ctx)
831 {
832 if (ctx != NULL)
833 atomic_inc(&ctx->lock_context.count);
834 return ctx;
835 }
836 EXPORT_SYMBOL_GPL(get_nfs_open_context);
837
838 static void __put_nfs_open_context(struct nfs_open_context *ctx, int is_sync)
839 {
840 struct inode *inode = d_inode(ctx->dentry);
841 struct super_block *sb = ctx->dentry->d_sb;
842
843 if (!list_empty(&ctx->list)) {
844 if (!atomic_dec_and_lock(&ctx->lock_context.count, &inode->i_lock))
845 return;
846 list_del(&ctx->list);
847 spin_unlock(&inode->i_lock);
848 } else if (!atomic_dec_and_test(&ctx->lock_context.count))
849 return;
850 if (inode != NULL)
851 NFS_PROTO(inode)->close_context(ctx, is_sync);
852 if (ctx->cred != NULL)
853 put_rpccred(ctx->cred);
854 dput(ctx->dentry);
855 nfs_sb_deactive(sb);
856 kfree(ctx->mdsthreshold);
857 kfree(ctx);
858 }
859
860 void put_nfs_open_context(struct nfs_open_context *ctx)
861 {
862 __put_nfs_open_context(ctx, 0);
863 }
864 EXPORT_SYMBOL_GPL(put_nfs_open_context);
865
866 static void put_nfs_open_context_sync(struct nfs_open_context *ctx)
867 {
868 __put_nfs_open_context(ctx, 1);
869 }
870
871 /*
872 * Ensure that mmap has a recent RPC credential for use when writing out
873 * shared pages
874 */
875 void nfs_inode_attach_open_context(struct nfs_open_context *ctx)
876 {
877 struct inode *inode = d_inode(ctx->dentry);
878 struct nfs_inode *nfsi = NFS_I(inode);
879
880 spin_lock(&inode->i_lock);
881 if (ctx->mode & FMODE_WRITE)
882 list_add(&ctx->list, &nfsi->open_files);
883 else
884 list_add_tail(&ctx->list, &nfsi->open_files);
885 spin_unlock(&inode->i_lock);
886 }
887 EXPORT_SYMBOL_GPL(nfs_inode_attach_open_context);
888
889 void nfs_file_set_open_context(struct file *filp, struct nfs_open_context *ctx)
890 {
891 filp->private_data = get_nfs_open_context(ctx);
892 if (list_empty(&ctx->list))
893 nfs_inode_attach_open_context(ctx);
894 }
895 EXPORT_SYMBOL_GPL(nfs_file_set_open_context);
896
897 /*
898 * Given an inode, search for an open context with the desired characteristics
899 */
900 struct nfs_open_context *nfs_find_open_context(struct inode *inode, struct rpc_cred *cred, fmode_t mode)
901 {
902 struct nfs_inode *nfsi = NFS_I(inode);
903 struct nfs_open_context *pos, *ctx = NULL;
904
905 spin_lock(&inode->i_lock);
906 list_for_each_entry(pos, &nfsi->open_files, list) {
907 if (cred != NULL && pos->cred != cred)
908 continue;
909 if ((pos->mode & (FMODE_READ|FMODE_WRITE)) != mode)
910 continue;
911 ctx = get_nfs_open_context(pos);
912 break;
913 }
914 spin_unlock(&inode->i_lock);
915 return ctx;
916 }
917
918 void nfs_file_clear_open_context(struct file *filp)
919 {
920 struct nfs_open_context *ctx = nfs_file_open_context(filp);
921
922 if (ctx) {
923 struct inode *inode = d_inode(ctx->dentry);
924
925 /*
926 * We fatal error on write before. Try to writeback
927 * every page again.
928 */
929 if (ctx->error < 0)
930 invalidate_inode_pages2(inode->i_mapping);
931 filp->private_data = NULL;
932 spin_lock(&inode->i_lock);
933 list_move_tail(&ctx->list, &NFS_I(inode)->open_files);
934 spin_unlock(&inode->i_lock);
935 put_nfs_open_context_sync(ctx);
936 }
937 }
938
939 /*
940 * These allocate and release file read/write context information.
941 */
942 int nfs_open(struct inode *inode, struct file *filp)
943 {
944 struct nfs_open_context *ctx;
945
946 ctx = alloc_nfs_open_context(file_dentry(filp), filp->f_mode);
947 if (IS_ERR(ctx))
948 return PTR_ERR(ctx);
949 nfs_file_set_open_context(filp, ctx);
950 put_nfs_open_context(ctx);
951 nfs_fscache_open_file(inode, filp);
952 return 0;
953 }
954
955 /*
956 * This function is called whenever some part of NFS notices that
957 * the cached attributes have to be refreshed.
958 */
959 int
960 __nfs_revalidate_inode(struct nfs_server *server, struct inode *inode)
961 {
962 int status = -ESTALE;
963 struct nfs4_label *label = NULL;
964 struct nfs_fattr *fattr = NULL;
965 struct nfs_inode *nfsi = NFS_I(inode);
966
967 dfprintk(PAGECACHE, "NFS: revalidating (%s/%Lu)\n",
968 inode->i_sb->s_id, (unsigned long long)NFS_FILEID(inode));
969
970 trace_nfs_revalidate_inode_enter(inode);
971
972 if (is_bad_inode(inode))
973 goto out;
974 if (NFS_STALE(inode))
975 goto out;
976
977 /* pNFS: Attributes aren't updated until we layoutcommit */
978 if (S_ISREG(inode->i_mode)) {
979 status = pnfs_sync_inode(inode, false);
980 if (status)
981 goto out;
982 }
983
984 status = -ENOMEM;
985 fattr = nfs_alloc_fattr();
986 if (fattr == NULL)
987 goto out;
988
989 nfs_inc_stats(inode, NFSIOS_INODEREVALIDATE);
990
991 label = nfs4_label_alloc(NFS_SERVER(inode), GFP_KERNEL);
992 if (IS_ERR(label)) {
993 status = PTR_ERR(label);
994 goto out;
995 }
996
997 status = NFS_PROTO(inode)->getattr(server, NFS_FH(inode), fattr, label);
998 if (status != 0) {
999 dfprintk(PAGECACHE, "nfs_revalidate_inode: (%s/%Lu) getattr failed, error=%d\n",
1000 inode->i_sb->s_id,
1001 (unsigned long long)NFS_FILEID(inode), status);
1002 if (status == -ESTALE) {
1003 nfs_zap_caches(inode);
1004 if (!S_ISDIR(inode->i_mode))
1005 set_bit(NFS_INO_STALE, &NFS_I(inode)->flags);
1006 }
1007 goto err_out;
1008 }
1009
1010 status = nfs_refresh_inode(inode, fattr);
1011 if (status) {
1012 dfprintk(PAGECACHE, "nfs_revalidate_inode: (%s/%Lu) refresh failed, error=%d\n",
1013 inode->i_sb->s_id,
1014 (unsigned long long)NFS_FILEID(inode), status);
1015 goto err_out;
1016 }
1017
1018 if (nfsi->cache_validity & NFS_INO_INVALID_ACL)
1019 nfs_zap_acl_cache(inode);
1020
1021 nfs_setsecurity(inode, fattr, label);
1022
1023 dfprintk(PAGECACHE, "NFS: (%s/%Lu) revalidation complete\n",
1024 inode->i_sb->s_id,
1025 (unsigned long long)NFS_FILEID(inode));
1026
1027 err_out:
1028 nfs4_label_free(label);
1029 out:
1030 nfs_free_fattr(fattr);
1031 trace_nfs_revalidate_inode_exit(inode, status);
1032 return status;
1033 }
1034
1035 int nfs_attribute_timeout(struct inode *inode)
1036 {
1037 struct nfs_inode *nfsi = NFS_I(inode);
1038
1039 return !time_in_range_open(jiffies, nfsi->read_cache_jiffies, nfsi->read_cache_jiffies + nfsi->attrtimeo);
1040 }
1041
1042 int nfs_attribute_cache_expired(struct inode *inode)
1043 {
1044 if (nfs_have_delegated_attributes(inode))
1045 return 0;
1046 return nfs_attribute_timeout(inode);
1047 }
1048
1049 /**
1050 * nfs_revalidate_inode - Revalidate the inode attributes
1051 * @server - pointer to nfs_server struct
1052 * @inode - pointer to inode struct
1053 *
1054 * Updates inode attribute information by retrieving the data from the server.
1055 */
1056 int nfs_revalidate_inode(struct nfs_server *server, struct inode *inode)
1057 {
1058 if (!nfs_need_revalidate_inode(inode))
1059 return NFS_STALE(inode) ? -ESTALE : 0;
1060 return __nfs_revalidate_inode(server, inode);
1061 }
1062 EXPORT_SYMBOL_GPL(nfs_revalidate_inode);
1063
1064 int nfs_revalidate_inode_rcu(struct nfs_server *server, struct inode *inode)
1065 {
1066 if (!(NFS_I(inode)->cache_validity &
1067 (NFS_INO_INVALID_ATTR|NFS_INO_INVALID_LABEL))
1068 && !nfs_attribute_cache_expired(inode))
1069 return NFS_STALE(inode) ? -ESTALE : 0;
1070 return -ECHILD;
1071 }
1072
1073 static int nfs_invalidate_mapping(struct inode *inode, struct address_space *mapping)
1074 {
1075 struct nfs_inode *nfsi = NFS_I(inode);
1076 int ret;
1077
1078 if (mapping->nrpages != 0) {
1079 if (S_ISREG(inode->i_mode)) {
1080 unmap_mapping_range(mapping, 0, 0, 0);
1081 ret = nfs_sync_mapping(mapping);
1082 if (ret < 0)
1083 return ret;
1084 }
1085 ret = invalidate_inode_pages2(mapping);
1086 if (ret < 0)
1087 return ret;
1088 }
1089 if (S_ISDIR(inode->i_mode)) {
1090 spin_lock(&inode->i_lock);
1091 memset(nfsi->cookieverf, 0, sizeof(nfsi->cookieverf));
1092 spin_unlock(&inode->i_lock);
1093 }
1094 nfs_inc_stats(inode, NFSIOS_DATAINVALIDATE);
1095 nfs_fscache_wait_on_invalidate(inode);
1096
1097 dfprintk(PAGECACHE, "NFS: (%s/%Lu) data cache invalidated\n",
1098 inode->i_sb->s_id,
1099 (unsigned long long)NFS_FILEID(inode));
1100 return 0;
1101 }
1102
1103 static bool nfs_mapping_need_revalidate_inode(struct inode *inode)
1104 {
1105 if (nfs_have_delegated_attributes(inode))
1106 return false;
1107 return (NFS_I(inode)->cache_validity & NFS_INO_REVAL_PAGECACHE)
1108 || nfs_attribute_timeout(inode)
1109 || NFS_STALE(inode);
1110 }
1111
1112 int nfs_revalidate_mapping_rcu(struct inode *inode)
1113 {
1114 struct nfs_inode *nfsi = NFS_I(inode);
1115 unsigned long *bitlock = &nfsi->flags;
1116 int ret = 0;
1117
1118 if (IS_SWAPFILE(inode))
1119 goto out;
1120 if (nfs_mapping_need_revalidate_inode(inode)) {
1121 ret = -ECHILD;
1122 goto out;
1123 }
1124 spin_lock(&inode->i_lock);
1125 if (test_bit(NFS_INO_INVALIDATING, bitlock) ||
1126 (nfsi->cache_validity & NFS_INO_INVALID_DATA))
1127 ret = -ECHILD;
1128 spin_unlock(&inode->i_lock);
1129 out:
1130 return ret;
1131 }
1132
1133 /**
1134 * __nfs_revalidate_mapping - Revalidate the pagecache
1135 * @inode - pointer to host inode
1136 * @mapping - pointer to mapping
1137 * @may_lock - take inode->i_mutex?
1138 */
1139 static int __nfs_revalidate_mapping(struct inode *inode,
1140 struct address_space *mapping,
1141 bool may_lock)
1142 {
1143 struct nfs_inode *nfsi = NFS_I(inode);
1144 unsigned long *bitlock = &nfsi->flags;
1145 int ret = 0;
1146
1147 /* swapfiles are not supposed to be shared. */
1148 if (IS_SWAPFILE(inode))
1149 goto out;
1150
1151 if (nfs_mapping_need_revalidate_inode(inode)) {
1152 ret = __nfs_revalidate_inode(NFS_SERVER(inode), inode);
1153 if (ret < 0)
1154 goto out;
1155 }
1156
1157 /*
1158 * We must clear NFS_INO_INVALID_DATA first to ensure that
1159 * invalidations that come in while we're shooting down the mappings
1160 * are respected. But, that leaves a race window where one revalidator
1161 * can clear the flag, and then another checks it before the mapping
1162 * gets invalidated. Fix that by serializing access to this part of
1163 * the function.
1164 *
1165 * At the same time, we need to allow other tasks to see whether we
1166 * might be in the middle of invalidating the pages, so we only set
1167 * the bit lock here if it looks like we're going to be doing that.
1168 */
1169 for (;;) {
1170 ret = wait_on_bit_action(bitlock, NFS_INO_INVALIDATING,
1171 nfs_wait_bit_killable, TASK_KILLABLE);
1172 if (ret)
1173 goto out;
1174 spin_lock(&inode->i_lock);
1175 if (test_bit(NFS_INO_INVALIDATING, bitlock)) {
1176 spin_unlock(&inode->i_lock);
1177 continue;
1178 }
1179 if (nfsi->cache_validity & NFS_INO_INVALID_DATA)
1180 break;
1181 spin_unlock(&inode->i_lock);
1182 goto out;
1183 }
1184
1185 set_bit(NFS_INO_INVALIDATING, bitlock);
1186 smp_wmb();
1187 nfsi->cache_validity &= ~NFS_INO_INVALID_DATA;
1188 spin_unlock(&inode->i_lock);
1189 trace_nfs_invalidate_mapping_enter(inode);
1190 if (may_lock) {
1191 inode_lock(inode);
1192 ret = nfs_invalidate_mapping(inode, mapping);
1193 inode_unlock(inode);
1194 } else
1195 ret = nfs_invalidate_mapping(inode, mapping);
1196 trace_nfs_invalidate_mapping_exit(inode, ret);
1197
1198 clear_bit_unlock(NFS_INO_INVALIDATING, bitlock);
1199 smp_mb__after_atomic();
1200 wake_up_bit(bitlock, NFS_INO_INVALIDATING);
1201 out:
1202 return ret;
1203 }
1204
1205 /**
1206 * nfs_revalidate_mapping - Revalidate the pagecache
1207 * @inode - pointer to host inode
1208 * @mapping - pointer to mapping
1209 */
1210 int nfs_revalidate_mapping(struct inode *inode, struct address_space *mapping)
1211 {
1212 return __nfs_revalidate_mapping(inode, mapping, false);
1213 }
1214
1215 /**
1216 * nfs_revalidate_mapping_protected - Revalidate the pagecache
1217 * @inode - pointer to host inode
1218 * @mapping - pointer to mapping
1219 *
1220 * Differs from nfs_revalidate_mapping() in that it grabs the inode->i_mutex
1221 * while invalidating the mapping.
1222 */
1223 int nfs_revalidate_mapping_protected(struct inode *inode, struct address_space *mapping)
1224 {
1225 return __nfs_revalidate_mapping(inode, mapping, true);
1226 }
1227
1228 static bool nfs_file_has_writers(struct nfs_inode *nfsi)
1229 {
1230 struct inode *inode = &nfsi->vfs_inode;
1231
1232 assert_spin_locked(&inode->i_lock);
1233
1234 if (!S_ISREG(inode->i_mode))
1235 return false;
1236 if (list_empty(&nfsi->open_files))
1237 return false;
1238 /* Note: This relies on nfsi->open_files being ordered with writers
1239 * being placed at the head of the list.
1240 * See nfs_inode_attach_open_context()
1241 */
1242 return (list_first_entry(&nfsi->open_files,
1243 struct nfs_open_context,
1244 list)->mode & FMODE_WRITE) == FMODE_WRITE;
1245 }
1246
1247 static unsigned long nfs_wcc_update_inode(struct inode *inode, struct nfs_fattr *fattr)
1248 {
1249 struct nfs_inode *nfsi = NFS_I(inode);
1250 unsigned long ret = 0;
1251
1252 if ((fattr->valid & NFS_ATTR_FATTR_PRECHANGE)
1253 && (fattr->valid & NFS_ATTR_FATTR_CHANGE)
1254 && inode->i_version == fattr->pre_change_attr) {
1255 inode->i_version = fattr->change_attr;
1256 if (S_ISDIR(inode->i_mode))
1257 nfs_set_cache_invalid(inode, NFS_INO_INVALID_DATA);
1258 ret |= NFS_INO_INVALID_ATTR;
1259 }
1260 /* If we have atomic WCC data, we may update some attributes */
1261 if ((fattr->valid & NFS_ATTR_FATTR_PRECTIME)
1262 && (fattr->valid & NFS_ATTR_FATTR_CTIME)
1263 && timespec_equal(&inode->i_ctime, &fattr->pre_ctime)) {
1264 memcpy(&inode->i_ctime, &fattr->ctime, sizeof(inode->i_ctime));
1265 ret |= NFS_INO_INVALID_ATTR;
1266 }
1267
1268 if ((fattr->valid & NFS_ATTR_FATTR_PREMTIME)
1269 && (fattr->valid & NFS_ATTR_FATTR_MTIME)
1270 && timespec_equal(&inode->i_mtime, &fattr->pre_mtime)) {
1271 memcpy(&inode->i_mtime, &fattr->mtime, sizeof(inode->i_mtime));
1272 if (S_ISDIR(inode->i_mode))
1273 nfs_set_cache_invalid(inode, NFS_INO_INVALID_DATA);
1274 ret |= NFS_INO_INVALID_ATTR;
1275 }
1276 if ((fattr->valid & NFS_ATTR_FATTR_PRESIZE)
1277 && (fattr->valid & NFS_ATTR_FATTR_SIZE)
1278 && i_size_read(inode) == nfs_size_to_loff_t(fattr->pre_size)
1279 && nfsi->nrequests == 0) {
1280 i_size_write(inode, nfs_size_to_loff_t(fattr->size));
1281 ret |= NFS_INO_INVALID_ATTR;
1282 }
1283
1284 return ret;
1285 }
1286
1287 /**
1288 * nfs_check_inode_attributes - verify consistency of the inode attribute cache
1289 * @inode - pointer to inode
1290 * @fattr - updated attributes
1291 *
1292 * Verifies the attribute cache. If we have just changed the attributes,
1293 * so that fattr carries weak cache consistency data, then it may
1294 * also update the ctime/mtime/change_attribute.
1295 */
1296 static int nfs_check_inode_attributes(struct inode *inode, struct nfs_fattr *fattr)
1297 {
1298 struct nfs_inode *nfsi = NFS_I(inode);
1299 loff_t cur_size, new_isize;
1300 unsigned long invalid = 0;
1301
1302
1303 if (nfs_have_delegated_attributes(inode))
1304 return 0;
1305 /* Has the inode gone and changed behind our back? */
1306 if ((fattr->valid & NFS_ATTR_FATTR_FILEID) && nfsi->fileid != fattr->fileid)
1307 return -EIO;
1308 if ((fattr->valid & NFS_ATTR_FATTR_TYPE) && (inode->i_mode & S_IFMT) != (fattr->mode & S_IFMT))
1309 return -EIO;
1310
1311 if (!nfs_file_has_writers(nfsi)) {
1312 /* Verify a few of the more important attributes */
1313 if ((fattr->valid & NFS_ATTR_FATTR_CHANGE) != 0 && inode->i_version != fattr->change_attr)
1314 invalid |= NFS_INO_INVALID_ATTR | NFS_INO_REVAL_PAGECACHE;
1315
1316 if ((fattr->valid & NFS_ATTR_FATTR_MTIME) && !timespec_equal(&inode->i_mtime, &fattr->mtime))
1317 invalid |= NFS_INO_INVALID_ATTR;
1318
1319 if ((fattr->valid & NFS_ATTR_FATTR_CTIME) && !timespec_equal(&inode->i_ctime, &fattr->ctime))
1320 invalid |= NFS_INO_INVALID_ATTR;
1321
1322 if (fattr->valid & NFS_ATTR_FATTR_SIZE) {
1323 cur_size = i_size_read(inode);
1324 new_isize = nfs_size_to_loff_t(fattr->size);
1325 if (cur_size != new_isize)
1326 invalid |= NFS_INO_INVALID_ATTR|NFS_INO_REVAL_PAGECACHE;
1327 }
1328 }
1329
1330 /* Have any file permissions changed? */
1331 if ((fattr->valid & NFS_ATTR_FATTR_MODE) && (inode->i_mode & S_IALLUGO) != (fattr->mode & S_IALLUGO))
1332 invalid |= NFS_INO_INVALID_ATTR | NFS_INO_INVALID_ACCESS | NFS_INO_INVALID_ACL;
1333 if ((fattr->valid & NFS_ATTR_FATTR_OWNER) && !uid_eq(inode->i_uid, fattr->uid))
1334 invalid |= NFS_INO_INVALID_ATTR | NFS_INO_INVALID_ACCESS | NFS_INO_INVALID_ACL;
1335 if ((fattr->valid & NFS_ATTR_FATTR_GROUP) && !gid_eq(inode->i_gid, fattr->gid))
1336 invalid |= NFS_INO_INVALID_ATTR | NFS_INO_INVALID_ACCESS | NFS_INO_INVALID_ACL;
1337
1338 /* Has the link count changed? */
1339 if ((fattr->valid & NFS_ATTR_FATTR_NLINK) && inode->i_nlink != fattr->nlink)
1340 invalid |= NFS_INO_INVALID_ATTR;
1341
1342 if ((fattr->valid & NFS_ATTR_FATTR_ATIME) && !timespec_equal(&inode->i_atime, &fattr->atime))
1343 invalid |= NFS_INO_INVALID_ATIME;
1344
1345 if (invalid != 0)
1346 nfs_set_cache_invalid(inode, invalid);
1347
1348 nfsi->read_cache_jiffies = fattr->time_start;
1349 return 0;
1350 }
1351
1352 static atomic_long_t nfs_attr_generation_counter;
1353
1354 static unsigned long nfs_read_attr_generation_counter(void)
1355 {
1356 return atomic_long_read(&nfs_attr_generation_counter);
1357 }
1358
1359 unsigned long nfs_inc_attr_generation_counter(void)
1360 {
1361 return atomic_long_inc_return(&nfs_attr_generation_counter);
1362 }
1363 EXPORT_SYMBOL_GPL(nfs_inc_attr_generation_counter);
1364
1365 void nfs_fattr_init(struct nfs_fattr *fattr)
1366 {
1367 fattr->valid = 0;
1368 fattr->time_start = jiffies;
1369 fattr->gencount = nfs_inc_attr_generation_counter();
1370 fattr->owner_name = NULL;
1371 fattr->group_name = NULL;
1372 }
1373 EXPORT_SYMBOL_GPL(nfs_fattr_init);
1374
1375 /**
1376 * nfs_fattr_set_barrier
1377 * @fattr: attributes
1378 *
1379 * Used to set a barrier after an attribute was updated. This
1380 * barrier ensures that older attributes from RPC calls that may
1381 * have raced with our update cannot clobber these new values.
1382 * Note that you are still responsible for ensuring that other
1383 * operations which change the attribute on the server do not
1384 * collide.
1385 */
1386 void nfs_fattr_set_barrier(struct nfs_fattr *fattr)
1387 {
1388 fattr->gencount = nfs_inc_attr_generation_counter();
1389 }
1390
1391 struct nfs_fattr *nfs_alloc_fattr(void)
1392 {
1393 struct nfs_fattr *fattr;
1394
1395 fattr = kmalloc(sizeof(*fattr), GFP_NOFS);
1396 if (fattr != NULL)
1397 nfs_fattr_init(fattr);
1398 return fattr;
1399 }
1400 EXPORT_SYMBOL_GPL(nfs_alloc_fattr);
1401
1402 struct nfs_fh *nfs_alloc_fhandle(void)
1403 {
1404 struct nfs_fh *fh;
1405
1406 fh = kmalloc(sizeof(struct nfs_fh), GFP_NOFS);
1407 if (fh != NULL)
1408 fh->size = 0;
1409 return fh;
1410 }
1411 EXPORT_SYMBOL_GPL(nfs_alloc_fhandle);
1412
1413 #ifdef NFS_DEBUG
1414 /*
1415 * _nfs_display_fhandle_hash - calculate the crc32 hash for the filehandle
1416 * in the same way that wireshark does
1417 *
1418 * @fh: file handle
1419 *
1420 * For debugging only.
1421 */
1422 u32 _nfs_display_fhandle_hash(const struct nfs_fh *fh)
1423 {
1424 /* wireshark uses 32-bit AUTODIN crc and does a bitwise
1425 * not on the result */
1426 return nfs_fhandle_hash(fh);
1427 }
1428 EXPORT_SYMBOL_GPL(_nfs_display_fhandle_hash);
1429
1430 /*
1431 * _nfs_display_fhandle - display an NFS file handle on the console
1432 *
1433 * @fh: file handle to display
1434 * @caption: display caption
1435 *
1436 * For debugging only.
1437 */
1438 void _nfs_display_fhandle(const struct nfs_fh *fh, const char *caption)
1439 {
1440 unsigned short i;
1441
1442 if (fh == NULL || fh->size == 0) {
1443 printk(KERN_DEFAULT "%s at %p is empty\n", caption, fh);
1444 return;
1445 }
1446
1447 printk(KERN_DEFAULT "%s at %p is %u bytes, crc: 0x%08x:\n",
1448 caption, fh, fh->size, _nfs_display_fhandle_hash(fh));
1449 for (i = 0; i < fh->size; i += 16) {
1450 __be32 *pos = (__be32 *)&fh->data[i];
1451
1452 switch ((fh->size - i - 1) >> 2) {
1453 case 0:
1454 printk(KERN_DEFAULT " %08x\n",
1455 be32_to_cpup(pos));
1456 break;
1457 case 1:
1458 printk(KERN_DEFAULT " %08x %08x\n",
1459 be32_to_cpup(pos), be32_to_cpup(pos + 1));
1460 break;
1461 case 2:
1462 printk(KERN_DEFAULT " %08x %08x %08x\n",
1463 be32_to_cpup(pos), be32_to_cpup(pos + 1),
1464 be32_to_cpup(pos + 2));
1465 break;
1466 default:
1467 printk(KERN_DEFAULT " %08x %08x %08x %08x\n",
1468 be32_to_cpup(pos), be32_to_cpup(pos + 1),
1469 be32_to_cpup(pos + 2), be32_to_cpup(pos + 3));
1470 }
1471 }
1472 }
1473 EXPORT_SYMBOL_GPL(_nfs_display_fhandle);
1474 #endif
1475
1476 /**
1477 * nfs_inode_attrs_need_update - check if the inode attributes need updating
1478 * @inode - pointer to inode
1479 * @fattr - attributes
1480 *
1481 * Attempt to divine whether or not an RPC call reply carrying stale
1482 * attributes got scheduled after another call carrying updated ones.
1483 *
1484 * To do so, the function first assumes that a more recent ctime means
1485 * that the attributes in fattr are newer, however it also attempt to
1486 * catch the case where ctime either didn't change, or went backwards
1487 * (if someone reset the clock on the server) by looking at whether
1488 * or not this RPC call was started after the inode was last updated.
1489 * Note also the check for wraparound of 'attr_gencount'
1490 *
1491 * The function returns 'true' if it thinks the attributes in 'fattr' are
1492 * more recent than the ones cached in the inode.
1493 *
1494 */
1495 static int nfs_inode_attrs_need_update(const struct inode *inode, const struct nfs_fattr *fattr)
1496 {
1497 const struct nfs_inode *nfsi = NFS_I(inode);
1498
1499 return ((long)fattr->gencount - (long)nfsi->attr_gencount) > 0 ||
1500 ((long)nfsi->attr_gencount - (long)nfs_read_attr_generation_counter() > 0);
1501 }
1502
1503 static int nfs_refresh_inode_locked(struct inode *inode, struct nfs_fattr *fattr)
1504 {
1505 int ret;
1506
1507 trace_nfs_refresh_inode_enter(inode);
1508
1509 if (nfs_inode_attrs_need_update(inode, fattr))
1510 ret = nfs_update_inode(inode, fattr);
1511 else
1512 ret = nfs_check_inode_attributes(inode, fattr);
1513
1514 trace_nfs_refresh_inode_exit(inode, ret);
1515 return ret;
1516 }
1517
1518 /**
1519 * nfs_refresh_inode - try to update the inode attribute cache
1520 * @inode - pointer to inode
1521 * @fattr - updated attributes
1522 *
1523 * Check that an RPC call that returned attributes has not overlapped with
1524 * other recent updates of the inode metadata, then decide whether it is
1525 * safe to do a full update of the inode attributes, or whether just to
1526 * call nfs_check_inode_attributes.
1527 */
1528 int nfs_refresh_inode(struct inode *inode, struct nfs_fattr *fattr)
1529 {
1530 int status;
1531
1532 if ((fattr->valid & NFS_ATTR_FATTR) == 0)
1533 return 0;
1534 spin_lock(&inode->i_lock);
1535 status = nfs_refresh_inode_locked(inode, fattr);
1536 spin_unlock(&inode->i_lock);
1537
1538 return status;
1539 }
1540 EXPORT_SYMBOL_GPL(nfs_refresh_inode);
1541
1542 static int nfs_post_op_update_inode_locked(struct inode *inode, struct nfs_fattr *fattr)
1543 {
1544 unsigned long invalid = NFS_INO_INVALID_ATTR;
1545
1546 /*
1547 * Don't revalidate the pagecache if we hold a delegation, but do
1548 * force an attribute update
1549 */
1550 if (NFS_PROTO(inode)->have_delegation(inode, FMODE_READ))
1551 invalid = NFS_INO_INVALID_ATTR|NFS_INO_REVAL_FORCED;
1552
1553 if (S_ISDIR(inode->i_mode))
1554 invalid |= NFS_INO_INVALID_DATA;
1555 nfs_set_cache_invalid(inode, invalid);
1556 if ((fattr->valid & NFS_ATTR_FATTR) == 0)
1557 return 0;
1558 return nfs_refresh_inode_locked(inode, fattr);
1559 }
1560
1561 /**
1562 * nfs_post_op_update_inode - try to update the inode attribute cache
1563 * @inode - pointer to inode
1564 * @fattr - updated attributes
1565 *
1566 * After an operation that has changed the inode metadata, mark the
1567 * attribute cache as being invalid, then try to update it.
1568 *
1569 * NB: if the server didn't return any post op attributes, this
1570 * function will force the retrieval of attributes before the next
1571 * NFS request. Thus it should be used only for operations that
1572 * are expected to change one or more attributes, to avoid
1573 * unnecessary NFS requests and trips through nfs_update_inode().
1574 */
1575 int nfs_post_op_update_inode(struct inode *inode, struct nfs_fattr *fattr)
1576 {
1577 int status;
1578
1579 spin_lock(&inode->i_lock);
1580 nfs_fattr_set_barrier(fattr);
1581 status = nfs_post_op_update_inode_locked(inode, fattr);
1582 spin_unlock(&inode->i_lock);
1583
1584 return status;
1585 }
1586 EXPORT_SYMBOL_GPL(nfs_post_op_update_inode);
1587
1588 /**
1589 * nfs_post_op_update_inode_force_wcc_locked - update the inode attribute cache
1590 * @inode - pointer to inode
1591 * @fattr - updated attributes
1592 *
1593 * After an operation that has changed the inode metadata, mark the
1594 * attribute cache as being invalid, then try to update it. Fake up
1595 * weak cache consistency data, if none exist.
1596 *
1597 * This function is mainly designed to be used by the ->write_done() functions.
1598 */
1599 int nfs_post_op_update_inode_force_wcc_locked(struct inode *inode, struct nfs_fattr *fattr)
1600 {
1601 int status;
1602
1603 /* Don't do a WCC update if these attributes are already stale */
1604 if ((fattr->valid & NFS_ATTR_FATTR) == 0 ||
1605 !nfs_inode_attrs_need_update(inode, fattr)) {
1606 fattr->valid &= ~(NFS_ATTR_FATTR_PRECHANGE
1607 | NFS_ATTR_FATTR_PRESIZE
1608 | NFS_ATTR_FATTR_PREMTIME
1609 | NFS_ATTR_FATTR_PRECTIME);
1610 goto out_noforce;
1611 }
1612 if ((fattr->valid & NFS_ATTR_FATTR_CHANGE) != 0 &&
1613 (fattr->valid & NFS_ATTR_FATTR_PRECHANGE) == 0) {
1614 fattr->pre_change_attr = inode->i_version;
1615 fattr->valid |= NFS_ATTR_FATTR_PRECHANGE;
1616 }
1617 if ((fattr->valid & NFS_ATTR_FATTR_CTIME) != 0 &&
1618 (fattr->valid & NFS_ATTR_FATTR_PRECTIME) == 0) {
1619 memcpy(&fattr->pre_ctime, &inode->i_ctime, sizeof(fattr->pre_ctime));
1620 fattr->valid |= NFS_ATTR_FATTR_PRECTIME;
1621 }
1622 if ((fattr->valid & NFS_ATTR_FATTR_MTIME) != 0 &&
1623 (fattr->valid & NFS_ATTR_FATTR_PREMTIME) == 0) {
1624 memcpy(&fattr->pre_mtime, &inode->i_mtime, sizeof(fattr->pre_mtime));
1625 fattr->valid |= NFS_ATTR_FATTR_PREMTIME;
1626 }
1627 if ((fattr->valid & NFS_ATTR_FATTR_SIZE) != 0 &&
1628 (fattr->valid & NFS_ATTR_FATTR_PRESIZE) == 0) {
1629 fattr->pre_size = i_size_read(inode);
1630 fattr->valid |= NFS_ATTR_FATTR_PRESIZE;
1631 }
1632 out_noforce:
1633 status = nfs_post_op_update_inode_locked(inode, fattr);
1634 return status;
1635 }
1636
1637 /**
1638 * nfs_post_op_update_inode_force_wcc - try to update the inode attribute cache
1639 * @inode - pointer to inode
1640 * @fattr - updated attributes
1641 *
1642 * After an operation that has changed the inode metadata, mark the
1643 * attribute cache as being invalid, then try to update it. Fake up
1644 * weak cache consistency data, if none exist.
1645 *
1646 * This function is mainly designed to be used by the ->write_done() functions.
1647 */
1648 int nfs_post_op_update_inode_force_wcc(struct inode *inode, struct nfs_fattr *fattr)
1649 {
1650 int status;
1651
1652 spin_lock(&inode->i_lock);
1653 nfs_fattr_set_barrier(fattr);
1654 status = nfs_post_op_update_inode_force_wcc_locked(inode, fattr);
1655 spin_unlock(&inode->i_lock);
1656 return status;
1657 }
1658 EXPORT_SYMBOL_GPL(nfs_post_op_update_inode_force_wcc);
1659
1660
1661 static inline bool nfs_fileid_valid(struct nfs_inode *nfsi,
1662 struct nfs_fattr *fattr)
1663 {
1664 bool ret1 = true, ret2 = true;
1665
1666 if (fattr->valid & NFS_ATTR_FATTR_FILEID)
1667 ret1 = (nfsi->fileid == fattr->fileid);
1668 if (fattr->valid & NFS_ATTR_FATTR_MOUNTED_ON_FILEID)
1669 ret2 = (nfsi->fileid == fattr->mounted_on_fileid);
1670 return ret1 || ret2;
1671 }
1672
1673 /*
1674 * Many nfs protocol calls return the new file attributes after
1675 * an operation. Here we update the inode to reflect the state
1676 * of the server's inode.
1677 *
1678 * This is a bit tricky because we have to make sure all dirty pages
1679 * have been sent off to the server before calling invalidate_inode_pages.
1680 * To make sure no other process adds more write requests while we try
1681 * our best to flush them, we make them sleep during the attribute refresh.
1682 *
1683 * A very similar scenario holds for the dir cache.
1684 */
1685 static int nfs_update_inode(struct inode *inode, struct nfs_fattr *fattr)
1686 {
1687 struct nfs_server *server;
1688 struct nfs_inode *nfsi = NFS_I(inode);
1689 loff_t cur_isize, new_isize;
1690 unsigned long invalid = 0;
1691 unsigned long now = jiffies;
1692 unsigned long save_cache_validity;
1693 bool have_writers = nfs_file_has_writers(nfsi);
1694 bool cache_revalidated = true;
1695
1696 dfprintk(VFS, "NFS: %s(%s/%lu fh_crc=0x%08x ct=%d info=0x%x)\n",
1697 __func__, inode->i_sb->s_id, inode->i_ino,
1698 nfs_display_fhandle_hash(NFS_FH(inode)),
1699 atomic_read(&inode->i_count), fattr->valid);
1700
1701 if (!nfs_fileid_valid(nfsi, fattr)) {
1702 printk(KERN_ERR "NFS: server %s error: fileid changed\n"
1703 "fsid %s: expected fileid 0x%Lx, got 0x%Lx\n",
1704 NFS_SERVER(inode)->nfs_client->cl_hostname,
1705 inode->i_sb->s_id, (long long)nfsi->fileid,
1706 (long long)fattr->fileid);
1707 goto out_err;
1708 }
1709
1710 /*
1711 * Make sure the inode's type hasn't changed.
1712 */
1713 if ((fattr->valid & NFS_ATTR_FATTR_TYPE) && (inode->i_mode & S_IFMT) != (fattr->mode & S_IFMT)) {
1714 /*
1715 * Big trouble! The inode has become a different object.
1716 */
1717 printk(KERN_DEBUG "NFS: %s: inode %lu mode changed, %07o to %07o\n",
1718 __func__, inode->i_ino, inode->i_mode, fattr->mode);
1719 goto out_err;
1720 }
1721
1722 server = NFS_SERVER(inode);
1723 /* Update the fsid? */
1724 if (S_ISDIR(inode->i_mode) && (fattr->valid & NFS_ATTR_FATTR_FSID) &&
1725 !nfs_fsid_equal(&server->fsid, &fattr->fsid) &&
1726 !IS_AUTOMOUNT(inode))
1727 server->fsid = fattr->fsid;
1728
1729 /*
1730 * Update the read time so we don't revalidate too often.
1731 */
1732 nfsi->read_cache_jiffies = fattr->time_start;
1733
1734 save_cache_validity = nfsi->cache_validity;
1735 nfsi->cache_validity &= ~(NFS_INO_INVALID_ATTR
1736 | NFS_INO_INVALID_ATIME
1737 | NFS_INO_REVAL_FORCED
1738 | NFS_INO_REVAL_PAGECACHE);
1739
1740 /* Do atomic weak cache consistency updates */
1741 invalid |= nfs_wcc_update_inode(inode, fattr);
1742
1743 /* More cache consistency checks */
1744 if (fattr->valid & NFS_ATTR_FATTR_CHANGE) {
1745 if (inode->i_version != fattr->change_attr) {
1746 dprintk("NFS: change_attr change on server for file %s/%ld\n",
1747 inode->i_sb->s_id, inode->i_ino);
1748 /* Could it be a race with writeback? */
1749 if (!have_writers) {
1750 invalid |= NFS_INO_INVALID_ATTR
1751 | NFS_INO_INVALID_DATA
1752 | NFS_INO_INVALID_ACCESS
1753 | NFS_INO_INVALID_ACL;
1754 if (S_ISDIR(inode->i_mode))
1755 nfs_force_lookup_revalidate(inode);
1756 }
1757 inode->i_version = fattr->change_attr;
1758 }
1759 } else {
1760 nfsi->cache_validity |= save_cache_validity;
1761 cache_revalidated = false;
1762 }
1763
1764 if (fattr->valid & NFS_ATTR_FATTR_MTIME) {
1765 memcpy(&inode->i_mtime, &fattr->mtime, sizeof(inode->i_mtime));
1766 } else if (server->caps & NFS_CAP_MTIME) {
1767 nfsi->cache_validity |= save_cache_validity &
1768 (NFS_INO_INVALID_ATTR
1769 | NFS_INO_REVAL_FORCED);
1770 cache_revalidated = false;
1771 }
1772
1773 if (fattr->valid & NFS_ATTR_FATTR_CTIME) {
1774 memcpy(&inode->i_ctime, &fattr->ctime, sizeof(inode->i_ctime));
1775 } else if (server->caps & NFS_CAP_CTIME) {
1776 nfsi->cache_validity |= save_cache_validity &
1777 (NFS_INO_INVALID_ATTR
1778 | NFS_INO_REVAL_FORCED);
1779 cache_revalidated = false;
1780 }
1781
1782 /* Check if our cached file size is stale */
1783 if (fattr->valid & NFS_ATTR_FATTR_SIZE) {
1784 new_isize = nfs_size_to_loff_t(fattr->size);
1785 cur_isize = i_size_read(inode);
1786 if (new_isize != cur_isize) {
1787 /* Do we perhaps have any outstanding writes, or has
1788 * the file grown beyond our last write? */
1789 if (nfsi->nrequests == 0 || new_isize > cur_isize) {
1790 i_size_write(inode, new_isize);
1791 if (!have_writers)
1792 invalid |= NFS_INO_INVALID_ATTR|NFS_INO_INVALID_DATA;
1793 }
1794 dprintk("NFS: isize change on server for file %s/%ld "
1795 "(%Ld to %Ld)\n",
1796 inode->i_sb->s_id,
1797 inode->i_ino,
1798 (long long)cur_isize,
1799 (long long)new_isize);
1800 }
1801 } else {
1802 nfsi->cache_validity |= save_cache_validity &
1803 (NFS_INO_INVALID_ATTR
1804 | NFS_INO_REVAL_PAGECACHE
1805 | NFS_INO_REVAL_FORCED);
1806 cache_revalidated = false;
1807 }
1808
1809
1810 if (fattr->valid & NFS_ATTR_FATTR_ATIME)
1811 memcpy(&inode->i_atime, &fattr->atime, sizeof(inode->i_atime));
1812 else if (server->caps & NFS_CAP_ATIME) {
1813 nfsi->cache_validity |= save_cache_validity &
1814 (NFS_INO_INVALID_ATIME
1815 | NFS_INO_REVAL_FORCED);
1816 cache_revalidated = false;
1817 }
1818
1819 if (fattr->valid & NFS_ATTR_FATTR_MODE) {
1820 if ((inode->i_mode & S_IALLUGO) != (fattr->mode & S_IALLUGO)) {
1821 umode_t newmode = inode->i_mode & S_IFMT;
1822 newmode |= fattr->mode & S_IALLUGO;
1823 inode->i_mode = newmode;
1824 invalid |= NFS_INO_INVALID_ATTR|NFS_INO_INVALID_ACCESS|NFS_INO_INVALID_ACL;
1825 }
1826 } else if (server->caps & NFS_CAP_MODE) {
1827 nfsi->cache_validity |= save_cache_validity &
1828 (NFS_INO_INVALID_ATTR
1829 | NFS_INO_INVALID_ACCESS
1830 | NFS_INO_INVALID_ACL
1831 | NFS_INO_REVAL_FORCED);
1832 cache_revalidated = false;
1833 }
1834
1835 if (fattr->valid & NFS_ATTR_FATTR_OWNER) {
1836 if (!uid_eq(inode->i_uid, fattr->uid)) {
1837 invalid |= NFS_INO_INVALID_ATTR|NFS_INO_INVALID_ACCESS|NFS_INO_INVALID_ACL;
1838 inode->i_uid = fattr->uid;
1839 }
1840 } else if (server->caps & NFS_CAP_OWNER) {
1841 nfsi->cache_validity |= save_cache_validity &
1842 (NFS_INO_INVALID_ATTR
1843 | NFS_INO_INVALID_ACCESS
1844 | NFS_INO_INVALID_ACL
1845 | NFS_INO_REVAL_FORCED);
1846 cache_revalidated = false;
1847 }
1848
1849 if (fattr->valid & NFS_ATTR_FATTR_GROUP) {
1850 if (!gid_eq(inode->i_gid, fattr->gid)) {
1851 invalid |= NFS_INO_INVALID_ATTR|NFS_INO_INVALID_ACCESS|NFS_INO_INVALID_ACL;
1852 inode->i_gid = fattr->gid;
1853 }
1854 } else if (server->caps & NFS_CAP_OWNER_GROUP) {
1855 nfsi->cache_validity |= save_cache_validity &
1856 (NFS_INO_INVALID_ATTR
1857 | NFS_INO_INVALID_ACCESS
1858 | NFS_INO_INVALID_ACL
1859 | NFS_INO_REVAL_FORCED);
1860 cache_revalidated = false;
1861 }
1862
1863 if (fattr->valid & NFS_ATTR_FATTR_NLINK) {
1864 if (inode->i_nlink != fattr->nlink) {
1865 invalid |= NFS_INO_INVALID_ATTR;
1866 if (S_ISDIR(inode->i_mode))
1867 invalid |= NFS_INO_INVALID_DATA;
1868 set_nlink(inode, fattr->nlink);
1869 }
1870 } else if (server->caps & NFS_CAP_NLINK) {
1871 nfsi->cache_validity |= save_cache_validity &
1872 (NFS_INO_INVALID_ATTR
1873 | NFS_INO_REVAL_FORCED);
1874 cache_revalidated = false;
1875 }
1876
1877 if (fattr->valid & NFS_ATTR_FATTR_SPACE_USED) {
1878 /*
1879 * report the blocks in 512byte units
1880 */
1881 inode->i_blocks = nfs_calc_block_size(fattr->du.nfs3.used);
1882 } else if (fattr->valid & NFS_ATTR_FATTR_BLOCKS_USED)
1883 inode->i_blocks = fattr->du.nfs2.blocks;
1884 else
1885 cache_revalidated = false;
1886
1887 /* Update attrtimeo value if we're out of the unstable period */
1888 if (invalid & NFS_INO_INVALID_ATTR) {
1889 nfs_inc_stats(inode, NFSIOS_ATTRINVALIDATE);
1890 nfsi->attrtimeo = NFS_MINATTRTIMEO(inode);
1891 nfsi->attrtimeo_timestamp = now;
1892 /* Set barrier to be more recent than all outstanding updates */
1893 nfsi->attr_gencount = nfs_inc_attr_generation_counter();
1894 } else {
1895 if (cache_revalidated) {
1896 if (!time_in_range_open(now, nfsi->attrtimeo_timestamp,
1897 nfsi->attrtimeo_timestamp + nfsi->attrtimeo)) {
1898 nfsi->attrtimeo <<= 1;
1899 if (nfsi->attrtimeo > NFS_MAXATTRTIMEO(inode))
1900 nfsi->attrtimeo = NFS_MAXATTRTIMEO(inode);
1901 }
1902 nfsi->attrtimeo_timestamp = now;
1903 }
1904 /* Set the barrier to be more recent than this fattr */
1905 if ((long)fattr->gencount - (long)nfsi->attr_gencount > 0)
1906 nfsi->attr_gencount = fattr->gencount;
1907 }
1908
1909 /* Don't declare attrcache up to date if there were no attrs! */
1910 if (cache_revalidated)
1911 invalid &= ~NFS_INO_INVALID_ATTR;
1912
1913 /* Don't invalidate the data if we were to blame */
1914 if (!(S_ISREG(inode->i_mode) || S_ISDIR(inode->i_mode)
1915 || S_ISLNK(inode->i_mode)))
1916 invalid &= ~NFS_INO_INVALID_DATA;
1917 if (!NFS_PROTO(inode)->have_delegation(inode, FMODE_READ) ||
1918 (save_cache_validity & NFS_INO_REVAL_FORCED))
1919 nfs_set_cache_invalid(inode, invalid);
1920
1921 return 0;
1922 out_err:
1923 /*
1924 * No need to worry about unhashing the dentry, as the
1925 * lookup validation will know that the inode is bad.
1926 * (But we fall through to invalidate the caches.)
1927 */
1928 nfs_invalidate_inode(inode);
1929 return -ESTALE;
1930 }
1931
1932 struct inode *nfs_alloc_inode(struct super_block *sb)
1933 {
1934 struct nfs_inode *nfsi;
1935 nfsi = kmem_cache_alloc(nfs_inode_cachep, GFP_KERNEL);
1936 if (!nfsi)
1937 return NULL;
1938 nfsi->flags = 0UL;
1939 nfsi->cache_validity = 0UL;
1940 #if IS_ENABLED(CONFIG_NFS_V4)
1941 nfsi->nfs4_acl = NULL;
1942 #endif /* CONFIG_NFS_V4 */
1943 return &nfsi->vfs_inode;
1944 }
1945 EXPORT_SYMBOL_GPL(nfs_alloc_inode);
1946
1947 static void nfs_i_callback(struct rcu_head *head)
1948 {
1949 struct inode *inode = container_of(head, struct inode, i_rcu);
1950 kmem_cache_free(nfs_inode_cachep, NFS_I(inode));
1951 }
1952
1953 void nfs_destroy_inode(struct inode *inode)
1954 {
1955 call_rcu(&inode->i_rcu, nfs_i_callback);
1956 }
1957 EXPORT_SYMBOL_GPL(nfs_destroy_inode);
1958
1959 static inline void nfs4_init_once(struct nfs_inode *nfsi)
1960 {
1961 #if IS_ENABLED(CONFIG_NFS_V4)
1962 INIT_LIST_HEAD(&nfsi->open_states);
1963 nfsi->delegation = NULL;
1964 init_rwsem(&nfsi->rwsem);
1965 nfsi->layout = NULL;
1966 #endif
1967 }
1968
1969 static void init_once(void *foo)
1970 {
1971 struct nfs_inode *nfsi = (struct nfs_inode *) foo;
1972
1973 inode_init_once(&nfsi->vfs_inode);
1974 INIT_LIST_HEAD(&nfsi->open_files);
1975 INIT_LIST_HEAD(&nfsi->access_cache_entry_lru);
1976 INIT_LIST_HEAD(&nfsi->access_cache_inode_lru);
1977 INIT_LIST_HEAD(&nfsi->commit_info.list);
1978 nfsi->nrequests = 0;
1979 nfsi->commit_info.ncommit = 0;
1980 atomic_set(&nfsi->commit_info.rpcs_out, 0);
1981 init_rwsem(&nfsi->rmdir_sem);
1982 nfs4_init_once(nfsi);
1983 }
1984
1985 static int __init nfs_init_inodecache(void)
1986 {
1987 nfs_inode_cachep = kmem_cache_create("nfs_inode_cache",
1988 sizeof(struct nfs_inode),
1989 0, (SLAB_RECLAIM_ACCOUNT|
1990 SLAB_MEM_SPREAD|SLAB_ACCOUNT),
1991 init_once);
1992 if (nfs_inode_cachep == NULL)
1993 return -ENOMEM;
1994
1995 return 0;
1996 }
1997
1998 static void nfs_destroy_inodecache(void)
1999 {
2000 /*
2001 * Make sure all delayed rcu free inodes are flushed before we
2002 * destroy cache.
2003 */
2004 rcu_barrier();
2005 kmem_cache_destroy(nfs_inode_cachep);
2006 }
2007
2008 struct workqueue_struct *nfsiod_workqueue;
2009 EXPORT_SYMBOL_GPL(nfsiod_workqueue);
2010
2011 /*
2012 * start up the nfsiod workqueue
2013 */
2014 static int nfsiod_start(void)
2015 {
2016 struct workqueue_struct *wq;
2017 dprintk("RPC: creating workqueue nfsiod\n");
2018 wq = alloc_workqueue("nfsiod", WQ_MEM_RECLAIM, 0);
2019 if (wq == NULL)
2020 return -ENOMEM;
2021 nfsiod_workqueue = wq;
2022 return 0;
2023 }
2024
2025 /*
2026 * Destroy the nfsiod workqueue
2027 */
2028 static void nfsiod_stop(void)
2029 {
2030 struct workqueue_struct *wq;
2031
2032 wq = nfsiod_workqueue;
2033 if (wq == NULL)
2034 return;
2035 nfsiod_workqueue = NULL;
2036 destroy_workqueue(wq);
2037 }
2038
2039 int nfs_net_id;
2040 EXPORT_SYMBOL_GPL(nfs_net_id);
2041
2042 static int nfs_net_init(struct net *net)
2043 {
2044 nfs_clients_init(net);
2045 return nfs_fs_proc_net_init(net);
2046 }
2047
2048 static void nfs_net_exit(struct net *net)
2049 {
2050 nfs_fs_proc_net_exit(net);
2051 nfs_cleanup_cb_ident_idr(net);
2052 }
2053
2054 static struct pernet_operations nfs_net_ops = {
2055 .init = nfs_net_init,
2056 .exit = nfs_net_exit,
2057 .id = &nfs_net_id,
2058 .size = sizeof(struct nfs_net),
2059 };
2060
2061 /*
2062 * Initialize NFS
2063 */
2064 static int __init init_nfs_fs(void)
2065 {
2066 int err;
2067
2068 err = register_pernet_subsys(&nfs_net_ops);
2069 if (err < 0)
2070 goto out9;
2071
2072 err = nfs_fscache_register();
2073 if (err < 0)
2074 goto out8;
2075
2076 err = nfsiod_start();
2077 if (err)
2078 goto out7;
2079
2080 err = nfs_fs_proc_init();
2081 if (err)
2082 goto out6;
2083
2084 err = nfs_init_nfspagecache();
2085 if (err)
2086 goto out5;
2087
2088 err = nfs_init_inodecache();
2089 if (err)
2090 goto out4;
2091
2092 err = nfs_init_readpagecache();
2093 if (err)
2094 goto out3;
2095
2096 err = nfs_init_writepagecache();
2097 if (err)
2098 goto out2;
2099
2100 err = nfs_init_directcache();
2101 if (err)
2102 goto out1;
2103
2104 rpc_proc_register(&init_net, &nfs_rpcstat);
2105
2106 err = register_nfs_fs();
2107 if (err)
2108 goto out0;
2109
2110 return 0;
2111 out0:
2112 rpc_proc_unregister(&init_net, "nfs");
2113 nfs_destroy_directcache();
2114 out1:
2115 nfs_destroy_writepagecache();
2116 out2:
2117 nfs_destroy_readpagecache();
2118 out3:
2119 nfs_destroy_inodecache();
2120 out4:
2121 nfs_destroy_nfspagecache();
2122 out5:
2123 nfs_fs_proc_exit();
2124 out6:
2125 nfsiod_stop();
2126 out7:
2127 nfs_fscache_unregister();
2128 out8:
2129 unregister_pernet_subsys(&nfs_net_ops);
2130 out9:
2131 return err;
2132 }
2133
2134 static void __exit exit_nfs_fs(void)
2135 {
2136 nfs_destroy_directcache();
2137 nfs_destroy_writepagecache();
2138 nfs_destroy_readpagecache();
2139 nfs_destroy_inodecache();
2140 nfs_destroy_nfspagecache();
2141 nfs_fscache_unregister();
2142 unregister_pernet_subsys(&nfs_net_ops);
2143 rpc_proc_unregister(&init_net, "nfs");
2144 unregister_nfs_fs();
2145 nfs_fs_proc_exit();
2146 nfsiod_stop();
2147 }
2148
2149 /* Not quite true; I just maintain it */
2150 MODULE_AUTHOR("Olaf Kirch <okir@monad.swb.de>");
2151 MODULE_LICENSE("GPL");
2152 module_param(enable_ino64, bool, 0644);
2153
2154 module_init(init_nfs_fs)
2155 module_exit(exit_nfs_fs)
This page took 0.073037 seconds and 6 git commands to generate.