diff --git a/src/system/kernel/cache/file_map.cpp b/src/system/kernel/cache/file_map.cpp index ae936a31ae..b7a90472aa 100644 --- a/src/system/kernel/cache/file_map.cpp +++ b/src/system/kernel/cache/file_map.cpp @@ -253,7 +253,7 @@ file_map_translate(void *_map, off_t offset, size_t size, file_io_vec *vecs, size_t maxVecs = *_count; status_t status = B_OK; - if (offset > map.size) { + if (offset >= map.size) { *_count = 0; return B_OK; } diff --git a/src/system/kernel/fs/vfs.cpp b/src/system/kernel/fs/vfs.cpp index dcc8a456a1..f21b080d6c 100644 --- a/src/system/kernel/fs/vfs.cpp +++ b/src/system/kernel/fs/vfs.cpp @@ -2594,7 +2594,7 @@ common_file_io_vec_pages(struct vnode *vnode, void *cookie, status_t status; size_t size; - if (!doWrite) { + if (!doWrite && vecOffset == 0) { // now directly read the data from the device // the first file_io_vec can be read directly @@ -2603,8 +2603,8 @@ common_file_io_vec_pages(struct vnode *vnode, void *cookie, size = numBytes; status = FS_CALL(vnode, read_pages)(vnode->mount->cookie, - vnode->private_node, cookie, fileVecs[0].offset, vecs, vecCount, - &size, false); + vnode->private_node, cookie, fileVecs[0].offset, &vecs[vecIndex], + vecCount - vecIndex, &size, false); if (status < B_OK) return status; @@ -2636,9 +2636,11 @@ common_file_io_vec_pages(struct vnode *vnode, void *cookie, for (; vecIndex < vecCount; vecIndex++) { if (size < vecs[vecIndex].iov_len) break; - + size -= vecs[vecIndex].iov_len; } + + vecOffset = size; } else { fileVecIndex = 0; size = 0; diff --git a/src/tools/fs_shell/vfs.cpp b/src/tools/fs_shell/vfs.cpp index b403ef2533..51d249a267 100644 --- a/src/tools/fs_shell/vfs.cpp +++ b/src/tools/fs_shell/vfs.cpp @@ -1749,7 +1749,7 @@ common_file_io_vec_pages(int fd, const fssh_file_io_vec *fileVecs, fssh_status_t status; fssh_size_t size; - if (!doWrite) { + if (!doWrite && vecOffset == 0) { // now directly read the data from the device // the first file_io_vec can be read directly @@ -1757,8 +1757,8 @@ common_file_io_vec_pages(int fd, const fssh_file_io_vec *fileVecs, if (size > numBytes) size = numBytes; - status = fssh_read_pages(fd, fileVecs[0].offset, vecs, vecCount, - &size, false); + status = fssh_read_pages(fd, fileVecs[0].offset, &vecs[vecIndex], + vecCount - vecIndex, &size, false); if (status < FSSH_B_OK) return status; @@ -1790,9 +1790,11 @@ common_file_io_vec_pages(int fd, const fssh_file_io_vec *fileVecs, for (; vecIndex < vecCount; vecIndex++) { if (size < vecs[vecIndex].iov_len) break; - + size -= vecs[vecIndex].iov_len; } + + vecOffset = size; } else { fileVecIndex = 0; size = 0;