diff options
Diffstat (limited to 'fs/nfs/inode.c')
-rw-r--r-- | fs/nfs/inode.c | 106 |
1 files changed, 20 insertions, 86 deletions
diff --git a/fs/nfs/inode.c b/fs/nfs/inode.c index faa091865ad0..657201acda84 100644 --- a/fs/nfs/inode.c +++ b/fs/nfs/inode.c | |||
@@ -97,22 +97,6 @@ u64 nfs_compat_user_ino64(u64 fileid) | |||
97 | return ino; | 97 | return ino; |
98 | } | 98 | } |
99 | 99 | ||
100 | int nfs_write_inode(struct inode *inode, int sync) | ||
101 | { | ||
102 | int ret; | ||
103 | |||
104 | if (sync) { | ||
105 | ret = filemap_fdatawait(inode->i_mapping); | ||
106 | if (ret == 0) | ||
107 | ret = nfs_commit_inode(inode, FLUSH_SYNC); | ||
108 | } else | ||
109 | ret = nfs_commit_inode(inode, 0); | ||
110 | if (ret >= 0) | ||
111 | return 0; | ||
112 | __mark_inode_dirty(inode, I_DIRTY_DATASYNC); | ||
113 | return ret; | ||
114 | } | ||
115 | |||
116 | void nfs_clear_inode(struct inode *inode) | 100 | void nfs_clear_inode(struct inode *inode) |
117 | { | 101 | { |
118 | /* | 102 | /* |
@@ -130,16 +114,12 @@ void nfs_clear_inode(struct inode *inode) | |||
130 | */ | 114 | */ |
131 | int nfs_sync_mapping(struct address_space *mapping) | 115 | int nfs_sync_mapping(struct address_space *mapping) |
132 | { | 116 | { |
133 | int ret; | 117 | int ret = 0; |
134 | 118 | ||
135 | if (mapping->nrpages == 0) | 119 | if (mapping->nrpages != 0) { |
136 | return 0; | 120 | unmap_mapping_range(mapping, 0, 0, 0); |
137 | unmap_mapping_range(mapping, 0, 0, 0); | 121 | ret = nfs_wb_all(mapping->host); |
138 | ret = filemap_write_and_wait(mapping); | 122 | } |
139 | if (ret != 0) | ||
140 | goto out; | ||
141 | ret = nfs_wb_all(mapping->host); | ||
142 | out: | ||
143 | return ret; | 123 | return ret; |
144 | } | 124 | } |
145 | 125 | ||
@@ -511,17 +491,11 @@ int nfs_getattr(struct vfsmount *mnt, struct dentry *dentry, struct kstat *stat) | |||
511 | int need_atime = NFS_I(inode)->cache_validity & NFS_INO_INVALID_ATIME; | 491 | int need_atime = NFS_I(inode)->cache_validity & NFS_INO_INVALID_ATIME; |
512 | int err; | 492 | int err; |
513 | 493 | ||
514 | /* | 494 | /* Flush out writes to the server in order to update c/mtime. */ |
515 | * Flush out writes to the server in order to update c/mtime. | ||
516 | * | ||
517 | * Hold the i_mutex to suspend application writes temporarily; | ||
518 | * this prevents long-running writing applications from blocking | ||
519 | * nfs_wb_nocommit. | ||
520 | */ | ||
521 | if (S_ISREG(inode->i_mode)) { | 495 | if (S_ISREG(inode->i_mode)) { |
522 | mutex_lock(&inode->i_mutex); | 496 | err = filemap_write_and_wait(inode->i_mapping); |
523 | nfs_wb_nocommit(inode); | 497 | if (err) |
524 | mutex_unlock(&inode->i_mutex); | 498 | goto out; |
525 | } | 499 | } |
526 | 500 | ||
527 | /* | 501 | /* |
@@ -545,6 +519,7 @@ int nfs_getattr(struct vfsmount *mnt, struct dentry *dentry, struct kstat *stat) | |||
545 | generic_fillattr(inode, stat); | 519 | generic_fillattr(inode, stat); |
546 | stat->ino = nfs_compat_user_ino64(NFS_FILEID(inode)); | 520 | stat->ino = nfs_compat_user_ino64(NFS_FILEID(inode)); |
547 | } | 521 | } |
522 | out: | ||
548 | return err; | 523 | return err; |
549 | } | 524 | } |
550 | 525 | ||
@@ -574,14 +549,14 @@ void nfs_close_context(struct nfs_open_context *ctx, int is_sync) | |||
574 | nfs_revalidate_inode(server, inode); | 549 | nfs_revalidate_inode(server, inode); |
575 | } | 550 | } |
576 | 551 | ||
577 | static struct nfs_open_context *alloc_nfs_open_context(struct vfsmount *mnt, struct dentry *dentry, struct rpc_cred *cred) | 552 | static struct nfs_open_context *alloc_nfs_open_context(struct path *path, struct rpc_cred *cred) |
578 | { | 553 | { |
579 | struct nfs_open_context *ctx; | 554 | struct nfs_open_context *ctx; |
580 | 555 | ||
581 | ctx = kmalloc(sizeof(*ctx), GFP_KERNEL); | 556 | ctx = kmalloc(sizeof(*ctx), GFP_KERNEL); |
582 | if (ctx != NULL) { | 557 | if (ctx != NULL) { |
583 | ctx->path.dentry = dget(dentry); | 558 | ctx->path = *path; |
584 | ctx->path.mnt = mntget(mnt); | 559 | path_get(&ctx->path); |
585 | ctx->cred = get_rpccred(cred); | 560 | ctx->cred = get_rpccred(cred); |
586 | ctx->state = NULL; | 561 | ctx->state = NULL; |
587 | ctx->lockowner = current->files; | 562 | ctx->lockowner = current->files; |
@@ -620,11 +595,6 @@ void put_nfs_open_context(struct nfs_open_context *ctx) | |||
620 | __put_nfs_open_context(ctx, 0); | 595 | __put_nfs_open_context(ctx, 0); |
621 | } | 596 | } |
622 | 597 | ||
623 | static void put_nfs_open_context_sync(struct nfs_open_context *ctx) | ||
624 | { | ||
625 | __put_nfs_open_context(ctx, 1); | ||
626 | } | ||
627 | |||
628 | /* | 598 | /* |
629 | * Ensure that mmap has a recent RPC credential for use when writing out | 599 | * Ensure that mmap has a recent RPC credential for use when writing out |
630 | * shared pages | 600 | * shared pages |
@@ -671,7 +641,7 @@ static void nfs_file_clear_open_context(struct file *filp) | |||
671 | spin_lock(&inode->i_lock); | 641 | spin_lock(&inode->i_lock); |
672 | list_move_tail(&ctx->list, &NFS_I(inode)->open_files); | 642 | list_move_tail(&ctx->list, &NFS_I(inode)->open_files); |
673 | spin_unlock(&inode->i_lock); | 643 | spin_unlock(&inode->i_lock); |
674 | put_nfs_open_context_sync(ctx); | 644 | __put_nfs_open_context(ctx, filp->f_flags & O_DIRECT ? 0 : 1); |
675 | } | 645 | } |
676 | } | 646 | } |
677 | 647 | ||
@@ -686,7 +656,7 @@ int nfs_open(struct inode *inode, struct file *filp) | |||
686 | cred = rpc_lookup_cred(); | 656 | cred = rpc_lookup_cred(); |
687 | if (IS_ERR(cred)) | 657 | if (IS_ERR(cred)) |
688 | return PTR_ERR(cred); | 658 | return PTR_ERR(cred); |
689 | ctx = alloc_nfs_open_context(filp->f_path.mnt, filp->f_path.dentry, cred); | 659 | ctx = alloc_nfs_open_context(&filp->f_path, cred); |
690 | put_rpccred(cred); | 660 | put_rpccred(cred); |
691 | if (ctx == NULL) | 661 | if (ctx == NULL) |
692 | return -ENOMEM; | 662 | return -ENOMEM; |
@@ -779,7 +749,7 @@ int nfs_revalidate_inode(struct nfs_server *server, struct inode *inode) | |||
779 | return __nfs_revalidate_inode(server, inode); | 749 | return __nfs_revalidate_inode(server, inode); |
780 | } | 750 | } |
781 | 751 | ||
782 | static int nfs_invalidate_mapping_nolock(struct inode *inode, struct address_space *mapping) | 752 | static int nfs_invalidate_mapping(struct inode *inode, struct address_space *mapping) |
783 | { | 753 | { |
784 | struct nfs_inode *nfsi = NFS_I(inode); | 754 | struct nfs_inode *nfsi = NFS_I(inode); |
785 | 755 | ||
@@ -800,49 +770,10 @@ static int nfs_invalidate_mapping_nolock(struct inode *inode, struct address_spa | |||
800 | return 0; | 770 | return 0; |
801 | } | 771 | } |
802 | 772 | ||
803 | static int nfs_invalidate_mapping(struct inode *inode, struct address_space *mapping) | ||
804 | { | ||
805 | int ret = 0; | ||
806 | |||
807 | mutex_lock(&inode->i_mutex); | ||
808 | if (NFS_I(inode)->cache_validity & NFS_INO_INVALID_DATA) { | ||
809 | ret = nfs_sync_mapping(mapping); | ||
810 | if (ret == 0) | ||
811 | ret = nfs_invalidate_mapping_nolock(inode, mapping); | ||
812 | } | ||
813 | mutex_unlock(&inode->i_mutex); | ||
814 | return ret; | ||
815 | } | ||
816 | |||
817 | /** | ||
818 | * nfs_revalidate_mapping_nolock - Revalidate the pagecache | ||
819 | * @inode - pointer to host inode | ||
820 | * @mapping - pointer to mapping | ||
821 | */ | ||
822 | int nfs_revalidate_mapping_nolock(struct inode *inode, struct address_space *mapping) | ||
823 | { | ||
824 | struct nfs_inode *nfsi = NFS_I(inode); | ||
825 | int ret = 0; | ||
826 | |||
827 | if ((nfsi->cache_validity & NFS_INO_REVAL_PAGECACHE) | ||
828 | || nfs_attribute_timeout(inode) || NFS_STALE(inode)) { | ||
829 | ret = __nfs_revalidate_inode(NFS_SERVER(inode), inode); | ||
830 | if (ret < 0) | ||
831 | goto out; | ||
832 | } | ||
833 | if (nfsi->cache_validity & NFS_INO_INVALID_DATA) | ||
834 | ret = nfs_invalidate_mapping_nolock(inode, mapping); | ||
835 | out: | ||
836 | return ret; | ||
837 | } | ||
838 | |||
839 | /** | 773 | /** |
840 | * nfs_revalidate_mapping - Revalidate the pagecache | 774 | * nfs_revalidate_mapping - Revalidate the pagecache |
841 | * @inode - pointer to host inode | 775 | * @inode - pointer to host inode |
842 | * @mapping - pointer to mapping | 776 | * @mapping - pointer to mapping |
843 | * | ||
844 | * This version of the function will take the inode->i_mutex and attempt to | ||
845 | * flush out all dirty data if it needs to invalidate the page cache. | ||
846 | */ | 777 | */ |
847 | int nfs_revalidate_mapping(struct inode *inode, struct address_space *mapping) | 778 | int nfs_revalidate_mapping(struct inode *inode, struct address_space *mapping) |
848 | { | 779 | { |
@@ -1261,8 +1192,10 @@ static int nfs_update_inode(struct inode *inode, struct nfs_fattr *fattr) | |||
1261 | 1192 | ||
1262 | if (fattr->valid & NFS_ATTR_FATTR_MODE) { | 1193 | if (fattr->valid & NFS_ATTR_FATTR_MODE) { |
1263 | if ((inode->i_mode & S_IALLUGO) != (fattr->mode & S_IALLUGO)) { | 1194 | if ((inode->i_mode & S_IALLUGO) != (fattr->mode & S_IALLUGO)) { |
1195 | umode_t newmode = inode->i_mode & S_IFMT; | ||
1196 | newmode |= fattr->mode & S_IALLUGO; | ||
1197 | inode->i_mode = newmode; | ||
1264 | invalid |= NFS_INO_INVALID_ATTR|NFS_INO_INVALID_ACCESS|NFS_INO_INVALID_ACL; | 1198 | invalid |= NFS_INO_INVALID_ATTR|NFS_INO_INVALID_ACCESS|NFS_INO_INVALID_ACL; |
1265 | inode->i_mode = fattr->mode; | ||
1266 | } | 1199 | } |
1267 | } else if (server->caps & NFS_CAP_MODE) | 1200 | } else if (server->caps & NFS_CAP_MODE) |
1268 | invalid |= save_cache_validity & (NFS_INO_INVALID_ATTR | 1201 | invalid |= save_cache_validity & (NFS_INO_INVALID_ATTR |
@@ -1418,6 +1351,7 @@ static void init_once(void *foo) | |||
1418 | INIT_LIST_HEAD(&nfsi->access_cache_inode_lru); | 1351 | INIT_LIST_HEAD(&nfsi->access_cache_inode_lru); |
1419 | INIT_RADIX_TREE(&nfsi->nfs_page_tree, GFP_ATOMIC); | 1352 | INIT_RADIX_TREE(&nfsi->nfs_page_tree, GFP_ATOMIC); |
1420 | nfsi->npages = 0; | 1353 | nfsi->npages = 0; |
1354 | nfsi->ncommit = 0; | ||
1421 | atomic_set(&nfsi->silly_count, 1); | 1355 | atomic_set(&nfsi->silly_count, 1); |
1422 | INIT_HLIST_HEAD(&nfsi->silly_list); | 1356 | INIT_HLIST_HEAD(&nfsi->silly_list); |
1423 | init_waitqueue_head(&nfsi->waitqueue); | 1357 | init_waitqueue_head(&nfsi->waitqueue); |