diff --git a/repertory/librepertory/src/file_manager/direct_open_file.cpp b/repertory/librepertory/src/file_manager/direct_open_file.cpp index d7b0fdbc..46ae03c7 100644 --- a/repertory/librepertory/src/file_manager/direct_open_file.cpp +++ b/repertory/librepertory/src/file_manager/direct_open_file.cpp @@ -275,6 +275,8 @@ auto direct_open_file::read(std::size_t read_size, std::uint64_t read_offset, for (std::size_t chunk = begin_chunk; not stop_requested_ && (res == api_error::success) && (read_size > 0U); ++chunk) { + reset_timeout(); + if (chunk > ring_pos_) { forward(chunk - ring_pos_); } else if (chunk < ring_pos_) { diff --git a/repertory/librepertory/src/file_manager/ring_buffer_open_file.cpp b/repertory/librepertory/src/file_manager/ring_buffer_open_file.cpp index 336af3fb..b0ab0500 100644 --- a/repertory/librepertory/src/file_manager/ring_buffer_open_file.cpp +++ b/repertory/librepertory/src/file_manager/ring_buffer_open_file.cpp @@ -338,6 +338,8 @@ auto ring_buffer_open_file::read(std::size_t read_size, for (std::size_t chunk = begin_chunk; not stop_requested_ && (res == api_error::success) && (read_size > 0U); ++chunk) { + reset_timeout(); + if (chunk > ring_pos_) { forward(chunk - ring_pos_); } else if (chunk < ring_pos_) {