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

refactor
All checks were successful
BlockStorage/repertory/pipeline/head This commit looks good
Details

Browse Source
This commit is contained in:
Scott E. Graves
2024-12-28 13:55:25 -06:00
parent 9ae56c17a1
commit d6475a85d7
1 changed files with 5 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

5
repertory/librepertory/src/file_manager/open_file.cpp
View File

@@ -663,6 +663,7 @@ void open_file::update_reader(std::size_t chunk) {
reader_thread_ = std::make_unique<std::thread>([this]() { reader_thread_ = std::make_unique<std::thread>([this]() {
unique_recur_mutex_lock lock(rw_mtx_); unique_recur_mutex_lock lock(rw_mtx_);
auto next_chunk{read_chunk_}; auto next_chunk{read_chunk_};
auto read_chunk{read_chunk_};
lock.unlock(); lock.unlock();
while (not stop_requested_) { while (not stop_requested_) {
@@ -675,6 +676,10 @@ void open_file::update_reader(std::size_t chunk) {
continue; continue;
} }
if (read_chunk != read_chunk_) {
next_chunk = read_chunk = read_chunk_;
}
next_chunk = next_chunk + 1U >= read_state.size() ? 0U : next_chunk + 1U; next_chunk = next_chunk + 1U >= read_state.size() ? 0U : next_chunk + 1U;
lock.unlock(); lock.unlock();