diff options
Diffstat (limited to 'fs/nfs/inode.c')
| -rw-r--r-- | fs/nfs/inode.c | 104 | 
1 files changed, 18 insertions, 86 deletions
| diff --git a/fs/nfs/inode.c b/fs/nfs/inode.c index f141bde7756a..e358df75a6ad 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; | 
| @@ -759,7 +729,7 @@ int nfs_attribute_timeout(struct inode *inode) | |||
| 759 | { | 729 | { | 
| 760 | struct nfs_inode *nfsi = NFS_I(inode); | 730 | struct nfs_inode *nfsi = NFS_I(inode); | 
| 761 | 731 | ||
| 762 | if (nfs_have_delegation(inode, FMODE_READ)) | 732 | if (nfs_have_delegated_attributes(inode)) | 
| 763 | return 0; | 733 | return 0; | 
| 764 | return !time_in_range_open(jiffies, nfsi->read_cache_jiffies, nfsi->read_cache_jiffies + nfsi->attrtimeo); | 734 | return !time_in_range_open(jiffies, nfsi->read_cache_jiffies, nfsi->read_cache_jiffies + nfsi->attrtimeo); | 
| 765 | } | 735 | } | 
| @@ -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 | { | 
| @@ -1420,6 +1351,7 @@ static void init_once(void *foo) | |||
| 1420 | INIT_LIST_HEAD(&nfsi->access_cache_inode_lru); | 1351 | INIT_LIST_HEAD(&nfsi->access_cache_inode_lru); | 
| 1421 | INIT_RADIX_TREE(&nfsi->nfs_page_tree, GFP_ATOMIC); | 1352 | INIT_RADIX_TREE(&nfsi->nfs_page_tree, GFP_ATOMIC); | 
| 1422 | nfsi->npages = 0; | 1353 | nfsi->npages = 0; | 
| 1354 | nfsi->ncommit = 0; | ||
| 1423 | atomic_set(&nfsi->silly_count, 1); | 1355 | atomic_set(&nfsi->silly_count, 1); | 
| 1424 | INIT_HLIST_HEAD(&nfsi->silly_list); | 1356 | INIT_HLIST_HEAD(&nfsi->silly_list); | 
| 1425 | init_waitqueue_head(&nfsi->waitqueue); | 1357 | init_waitqueue_head(&nfsi->waitqueue); | 
