diff options
-rw-r--r-- | fs/fuse/dir.c | 7 | ||||
-rw-r--r-- | fs/fuse/file.c | 8 | ||||
-rw-r--r-- | fs/fuse/fuse_i.h | 2 | ||||
-rw-r--r-- | fs/fuse/inode.c | 3 |
4 files changed, 17 insertions, 3 deletions
diff --git a/fs/fuse/dir.c b/fs/fuse/dir.c index c49b8c722e27..c8334f75c8c9 100644 --- a/fs/fuse/dir.c +++ b/fs/fuse/dir.c | |||
@@ -1590,6 +1590,7 @@ int fuse_do_setattr(struct inode *inode, struct iattr *attr, | |||
1590 | struct file *file) | 1590 | struct file *file) |
1591 | { | 1591 | { |
1592 | struct fuse_conn *fc = get_fuse_conn(inode); | 1592 | struct fuse_conn *fc = get_fuse_conn(inode); |
1593 | struct fuse_inode *fi = get_fuse_inode(inode); | ||
1593 | struct fuse_req *req; | 1594 | struct fuse_req *req; |
1594 | struct fuse_setattr_in inarg; | 1595 | struct fuse_setattr_in inarg; |
1595 | struct fuse_attr_out outarg; | 1596 | struct fuse_attr_out outarg; |
@@ -1617,8 +1618,10 @@ int fuse_do_setattr(struct inode *inode, struct iattr *attr, | |||
1617 | if (IS_ERR(req)) | 1618 | if (IS_ERR(req)) |
1618 | return PTR_ERR(req); | 1619 | return PTR_ERR(req); |
1619 | 1620 | ||
1620 | if (is_truncate) | 1621 | if (is_truncate) { |
1621 | fuse_set_nowrite(inode); | 1622 | fuse_set_nowrite(inode); |
1623 | set_bit(FUSE_I_SIZE_UNSTABLE, &fi->state); | ||
1624 | } | ||
1622 | 1625 | ||
1623 | memset(&inarg, 0, sizeof(inarg)); | 1626 | memset(&inarg, 0, sizeof(inarg)); |
1624 | memset(&outarg, 0, sizeof(outarg)); | 1627 | memset(&outarg, 0, sizeof(outarg)); |
@@ -1680,12 +1683,14 @@ int fuse_do_setattr(struct inode *inode, struct iattr *attr, | |||
1680 | invalidate_inode_pages2(inode->i_mapping); | 1683 | invalidate_inode_pages2(inode->i_mapping); |
1681 | } | 1684 | } |
1682 | 1685 | ||
1686 | clear_bit(FUSE_I_SIZE_UNSTABLE, &fi->state); | ||
1683 | return 0; | 1687 | return 0; |
1684 | 1688 | ||
1685 | error: | 1689 | error: |
1686 | if (is_truncate) | 1690 | if (is_truncate) |
1687 | fuse_release_nowrite(inode); | 1691 | fuse_release_nowrite(inode); |
1688 | 1692 | ||
1693 | clear_bit(FUSE_I_SIZE_UNSTABLE, &fi->state); | ||
1689 | return err; | 1694 | return err; |
1690 | } | 1695 | } |
1691 | 1696 | ||
diff --git a/fs/fuse/file.c b/fs/fuse/file.c index d1715b30f6c4..d409deafc67b 100644 --- a/fs/fuse/file.c +++ b/fs/fuse/file.c | |||
@@ -629,7 +629,8 @@ static void fuse_read_update_size(struct inode *inode, loff_t size, | |||
629 | struct fuse_inode *fi = get_fuse_inode(inode); | 629 | struct fuse_inode *fi = get_fuse_inode(inode); |
630 | 630 | ||
631 | spin_lock(&fc->lock); | 631 | spin_lock(&fc->lock); |
632 | if (attr_ver == fi->attr_version && size < inode->i_size) { | 632 | if (attr_ver == fi->attr_version && size < inode->i_size && |
633 | !test_bit(FUSE_I_SIZE_UNSTABLE, &fi->state)) { | ||
633 | fi->attr_version = ++fc->attr_version; | 634 | fi->attr_version = ++fc->attr_version; |
634 | i_size_write(inode, size); | 635 | i_size_write(inode, size); |
635 | } | 636 | } |
@@ -1032,12 +1033,16 @@ static ssize_t fuse_perform_write(struct file *file, | |||
1032 | { | 1033 | { |
1033 | struct inode *inode = mapping->host; | 1034 | struct inode *inode = mapping->host; |
1034 | struct fuse_conn *fc = get_fuse_conn(inode); | 1035 | struct fuse_conn *fc = get_fuse_conn(inode); |
1036 | struct fuse_inode *fi = get_fuse_inode(inode); | ||
1035 | int err = 0; | 1037 | int err = 0; |
1036 | ssize_t res = 0; | 1038 | ssize_t res = 0; |
1037 | 1039 | ||
1038 | if (is_bad_inode(inode)) | 1040 | if (is_bad_inode(inode)) |
1039 | return -EIO; | 1041 | return -EIO; |
1040 | 1042 | ||
1043 | if (inode->i_size < pos + iov_iter_count(ii)) | ||
1044 | set_bit(FUSE_I_SIZE_UNSTABLE, &fi->state); | ||
1045 | |||
1041 | do { | 1046 | do { |
1042 | struct fuse_req *req; | 1047 | struct fuse_req *req; |
1043 | ssize_t count; | 1048 | ssize_t count; |
@@ -1073,6 +1078,7 @@ static ssize_t fuse_perform_write(struct file *file, | |||
1073 | if (res > 0) | 1078 | if (res > 0) |
1074 | fuse_write_update_size(inode, pos); | 1079 | fuse_write_update_size(inode, pos); |
1075 | 1080 | ||
1081 | clear_bit(FUSE_I_SIZE_UNSTABLE, &fi->state); | ||
1076 | fuse_invalidate_attr(inode); | 1082 | fuse_invalidate_attr(inode); |
1077 | 1083 | ||
1078 | return res > 0 ? res : err; | 1084 | return res > 0 ? res : err; |
diff --git a/fs/fuse/fuse_i.h b/fs/fuse/fuse_i.h index fde7249a3a96..5ced199b50bb 100644 --- a/fs/fuse/fuse_i.h +++ b/fs/fuse/fuse_i.h | |||
@@ -115,6 +115,8 @@ struct fuse_inode { | |||
115 | enum { | 115 | enum { |
116 | /** Advise readdirplus */ | 116 | /** Advise readdirplus */ |
117 | FUSE_I_ADVISE_RDPLUS, | 117 | FUSE_I_ADVISE_RDPLUS, |
118 | /** An operation changing file size is in progress */ | ||
119 | FUSE_I_SIZE_UNSTABLE, | ||
118 | }; | 120 | }; |
119 | 121 | ||
120 | struct fuse_conn; | 122 | struct fuse_conn; |
diff --git a/fs/fuse/inode.c b/fs/fuse/inode.c index 0b578598c6ac..e0fe703ee3d6 100644 --- a/fs/fuse/inode.c +++ b/fs/fuse/inode.c | |||
@@ -201,7 +201,8 @@ void fuse_change_attributes(struct inode *inode, struct fuse_attr *attr, | |||
201 | struct timespec old_mtime; | 201 | struct timespec old_mtime; |
202 | 202 | ||
203 | spin_lock(&fc->lock); | 203 | spin_lock(&fc->lock); |
204 | if (attr_version != 0 && fi->attr_version > attr_version) { | 204 | if ((attr_version != 0 && fi->attr_version > attr_version) || |
205 | test_bit(FUSE_I_SIZE_UNSTABLE, &fi->state)) { | ||
205 | spin_unlock(&fc->lock); | 206 | spin_unlock(&fc->lock); |
206 | return; | 207 | return; |
207 | } | 208 | } |