From 4260aa9d9b7e06abd9f6bf2c6a69968b23d9ddee Mon Sep 17 00:00:00 2001 From: "Scott E. Graves" Date: Thu, 26 Dec 2024 09:00:09 -0600 Subject: [PATCH] refactor --- repertory/librepertory/src/file_manager/direct_open_file.cpp | 2 ++ .../librepertory/src/file_manager/ring_buffer_open_file.cpp | 2 ++ 2 files changed, 4 insertions(+) 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_) {