BlockStorage/repertory
1
0
Fork 0
Code Issues 8 Pull Requests Releases 6 Wiki Activity

refactor

Browse Source
This commit is contained in:
Scott E. Graves
2024-12-26 09:00:09 -06:00
parent ee68904585
commit 4260aa9d9b
2 changed files with 4 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
repertory/librepertory/src/file_manager/direct_open_file.cpp
View File

@ -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; for (std::size_t chunk = begin_chunk;
not stop_requested_ && (res == api_error::success) && (read_size > 0U); not stop_requested_ && (res == api_error::success) && (read_size > 0U);
++chunk) { ++chunk) {
reset_timeout();
if (chunk > ring_pos_) { if (chunk > ring_pos_) {
forward(chunk - ring_pos_); forward(chunk - ring_pos_);
} else if (chunk < ring_pos_) { } else if (chunk < ring_pos_) {

2
repertory/librepertory/src/file_manager/ring_buffer_open_file.cpp
View File

@ -338,6 +338,8 @@ auto ring_buffer_open_file::read(std::size_t read_size,
for (std::size_t chunk = begin_chunk; for (std::size_t chunk = begin_chunk;
not stop_requested_ && (res == api_error::success) && (read_size > 0U); not stop_requested_ && (res == api_error::success) && (read_size > 0U);
++chunk) { ++chunk) {
reset_timeout();
if (chunk > ring_pos_) { if (chunk > ring_pos_) {
forward(chunk - ring_pos_); forward(chunk - ring_pos_);
} else if (chunk < ring_pos_) { } else if (chunk < ring_pos_) {