aboutsummaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
authorAl Viro <viro@zeniv.linux.org.uk>2016-10-10 13:26:27 -0400
committerAl Viro <viro@zeniv.linux.org.uk>2016-10-10 13:36:06 -0400
commitc3a690240423fc4eb8a0c3c7df025d13eadf140b (patch)
tree20f4a32910427c2aa4ccf8e33633d6e7194628bf
parenta949e63992469fed87aef197347960ced31701b8 (diff)
fix ITER_PIPE interaction with direct_IO
by making sure we call iov_iter_advance() on original iov_iter even if direct_IO (done on its copy) has returned 0. It's a no-op for old iov_iter flavours and does the right thing (== truncation of the stuff we'd allocated, but not filled) in ITER_PIPE case. Failures (e.g. -EIO) get caught and dealt with by cleanup in generic_file_read_iter(). Signed-off-by: Al Viro <viro@zeniv.linux.org.uk>
-rw-r--r--fs/splice.c12
-rw-r--r--fs/xfs/xfs_file.c2
-rw-r--r--mm/filemap.c2
3 files changed, 5 insertions, 11 deletions
diff --git a/fs/splice.c b/fs/splice.c
index aa38901a4f10..153d4f3bd441 100644
--- a/fs/splice.c
+++ b/fs/splice.c
@@ -315,15 +315,9 @@ ssize_t generic_file_splice_read(struct file *in, loff_t *ppos,
315 *ppos = kiocb.ki_pos; 315 *ppos = kiocb.ki_pos;
316 file_accessed(in); 316 file_accessed(in);
317 } else if (ret < 0) { 317 } else if (ret < 0) {
318 if (WARN_ON(to.idx != idx || to.iov_offset)) { 318 to.idx = idx;
319 /* 319 to.iov_offset = 0;
320 * a bogus ->read_iter() has copied something and still 320 iov_iter_advance(&to, 0); /* to free what was emitted */
321 * returned an error instead of a short read.
322 */
323 to.idx = idx;
324 to.iov_offset = 0;
325 iov_iter_advance(&to, 0); /* to free what was emitted */
326 }
327 /* 321 /*
328 * callers of ->splice_read() expect -EAGAIN on 322 * callers of ->splice_read() expect -EAGAIN on
329 * "can't put anything in there", rather than -EFAULT. 323 * "can't put anything in there", rather than -EFAULT.
diff --git a/fs/xfs/xfs_file.c b/fs/xfs/xfs_file.c
index 92f16cfb81e8..26cf153e3714 100644
--- a/fs/xfs/xfs_file.c
+++ b/fs/xfs/xfs_file.c
@@ -317,7 +317,7 @@ xfs_file_dio_aio_read(
317 data = *to; 317 data = *to;
318 ret = __blockdev_direct_IO(iocb, inode, target->bt_bdev, &data, 318 ret = __blockdev_direct_IO(iocb, inode, target->bt_bdev, &data,
319 xfs_get_blocks_direct, NULL, NULL, 0); 319 xfs_get_blocks_direct, NULL, NULL, 0);
320 if (ret > 0) { 320 if (ret >= 0) {
321 iocb->ki_pos += ret; 321 iocb->ki_pos += ret;
322 iov_iter_advance(to, ret); 322 iov_iter_advance(to, ret);
323 } 323 }
diff --git a/mm/filemap.c b/mm/filemap.c
index 8a287dfc5372..6b965efe215e 100644
--- a/mm/filemap.c
+++ b/mm/filemap.c
@@ -1920,7 +1920,7 @@ generic_file_read_iter(struct kiocb *iocb, struct iov_iter *iter)
1920 retval = mapping->a_ops->direct_IO(iocb, &data); 1920 retval = mapping->a_ops->direct_IO(iocb, &data);
1921 } 1921 }
1922 1922
1923 if (retval > 0) { 1923 if (retval >= 0) {
1924 iocb->ki_pos += retval; 1924 iocb->ki_pos += retval;
1925 iov_iter_advance(iter, retval); 1925 iov_iter_advance(iter, retval);
1926 } 1926 }