diff options
author | Al Viro <viro@zeniv.linux.org.uk> | 2016-10-10 13:26:27 -0400 |
---|---|---|
committer | Al Viro <viro@zeniv.linux.org.uk> | 2016-10-10 13:36:06 -0400 |
commit | c3a690240423fc4eb8a0c3c7df025d13eadf140b (patch) | |
tree | 20f4a32910427c2aa4ccf8e33633d6e7194628bf | |
parent | a949e63992469fed87aef197347960ced31701b8 (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.c | 12 | ||||
-rw-r--r-- | fs/xfs/xfs_file.c | 2 | ||||
-rw-r--r-- | mm/filemap.c | 2 |
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 | } |