diff options
Diffstat (limited to 'fs/ext4/file.c')
-rw-r--r-- | fs/ext4/file.c | 33 |
1 files changed, 17 insertions, 16 deletions
diff --git a/fs/ext4/file.c b/fs/ext4/file.c index 7a6defcf3352..e576d682b353 100644 --- a/fs/ext4/file.c +++ b/fs/ext4/file.c | |||
@@ -95,11 +95,9 @@ ext4_file_write_iter(struct kiocb *iocb, struct iov_iter *from) | |||
95 | struct inode *inode = file_inode(iocb->ki_filp); | 95 | struct inode *inode = file_inode(iocb->ki_filp); |
96 | struct mutex *aio_mutex = NULL; | 96 | struct mutex *aio_mutex = NULL; |
97 | struct blk_plug plug; | 97 | struct blk_plug plug; |
98 | int o_direct = io_is_direct(file); | 98 | int o_direct = iocb->ki_flags & IOCB_DIRECT; |
99 | int overwrite = 0; | 99 | int overwrite = 0; |
100 | size_t length = iov_iter_count(from); | ||
101 | ssize_t ret; | 100 | ssize_t ret; |
102 | loff_t pos = iocb->ki_pos; | ||
103 | 101 | ||
104 | /* | 102 | /* |
105 | * Unaligned direct AIO must be serialized; see comment above | 103 | * Unaligned direct AIO must be serialized; see comment above |
@@ -108,16 +106,17 @@ ext4_file_write_iter(struct kiocb *iocb, struct iov_iter *from) | |||
108 | if (o_direct && | 106 | if (o_direct && |
109 | ext4_test_inode_flag(inode, EXT4_INODE_EXTENTS) && | 107 | ext4_test_inode_flag(inode, EXT4_INODE_EXTENTS) && |
110 | !is_sync_kiocb(iocb) && | 108 | !is_sync_kiocb(iocb) && |
111 | (file->f_flags & O_APPEND || | 109 | (iocb->ki_flags & IOCB_APPEND || |
112 | ext4_unaligned_aio(inode, from, pos))) { | 110 | ext4_unaligned_aio(inode, from, iocb->ki_pos))) { |
113 | aio_mutex = ext4_aio_mutex(inode); | 111 | aio_mutex = ext4_aio_mutex(inode); |
114 | mutex_lock(aio_mutex); | 112 | mutex_lock(aio_mutex); |
115 | ext4_unwritten_wait(inode); | 113 | ext4_unwritten_wait(inode); |
116 | } | 114 | } |
117 | 115 | ||
118 | mutex_lock(&inode->i_mutex); | 116 | mutex_lock(&inode->i_mutex); |
119 | if (file->f_flags & O_APPEND) | 117 | ret = generic_write_checks(iocb, from); |
120 | iocb->ki_pos = pos = i_size_read(inode); | 118 | if (ret <= 0) |
119 | goto out; | ||
121 | 120 | ||
122 | /* | 121 | /* |
123 | * If we have encountered a bitmap-format file, the size limit | 122 | * If we have encountered a bitmap-format file, the size limit |
@@ -126,22 +125,19 @@ ext4_file_write_iter(struct kiocb *iocb, struct iov_iter *from) | |||
126 | if (!(ext4_test_inode_flag(inode, EXT4_INODE_EXTENTS))) { | 125 | if (!(ext4_test_inode_flag(inode, EXT4_INODE_EXTENTS))) { |
127 | struct ext4_sb_info *sbi = EXT4_SB(inode->i_sb); | 126 | struct ext4_sb_info *sbi = EXT4_SB(inode->i_sb); |
128 | 127 | ||
129 | if ((pos > sbi->s_bitmap_maxbytes) || | 128 | if (iocb->ki_pos >= sbi->s_bitmap_maxbytes) { |
130 | (pos == sbi->s_bitmap_maxbytes && length > 0)) { | ||
131 | mutex_unlock(&inode->i_mutex); | ||
132 | ret = -EFBIG; | 129 | ret = -EFBIG; |
133 | goto errout; | 130 | goto out; |
134 | } | 131 | } |
135 | 132 | iov_iter_truncate(from, sbi->s_bitmap_maxbytes - iocb->ki_pos); | |
136 | if (pos + length > sbi->s_bitmap_maxbytes) | ||
137 | iov_iter_truncate(from, sbi->s_bitmap_maxbytes - pos); | ||
138 | } | 133 | } |
139 | 134 | ||
140 | iocb->private = &overwrite; | 135 | iocb->private = &overwrite; |
141 | if (o_direct) { | 136 | if (o_direct) { |
137 | size_t length = iov_iter_count(from); | ||
138 | loff_t pos = iocb->ki_pos; | ||
142 | blk_start_plug(&plug); | 139 | blk_start_plug(&plug); |
143 | 140 | ||
144 | |||
145 | /* check whether we do a DIO overwrite or not */ | 141 | /* check whether we do a DIO overwrite or not */ |
146 | if (ext4_should_dioread_nolock(inode) && !aio_mutex && | 142 | if (ext4_should_dioread_nolock(inode) && !aio_mutex && |
147 | !file->f_mapping->nrpages && pos + length <= i_size_read(inode)) { | 143 | !file->f_mapping->nrpages && pos + length <= i_size_read(inode)) { |
@@ -185,7 +181,12 @@ ext4_file_write_iter(struct kiocb *iocb, struct iov_iter *from) | |||
185 | if (o_direct) | 181 | if (o_direct) |
186 | blk_finish_plug(&plug); | 182 | blk_finish_plug(&plug); |
187 | 183 | ||
188 | errout: | 184 | if (aio_mutex) |
185 | mutex_unlock(aio_mutex); | ||
186 | return ret; | ||
187 | |||
188 | out: | ||
189 | mutex_unlock(&inode->i_mutex); | ||
189 | if (aio_mutex) | 190 | if (aio_mutex) |
190 | mutex_unlock(aio_mutex); | 191 | mutex_unlock(aio_mutex); |
191 | return ret; | 192 | return ret; |