BlockStorage/repertory
1
0
Fork 0
Code Issues 7 Pull Requests Releases 6 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-22 19:00:22 -06:00
parent 73a8b2c9fc
commit 13f6c10e6e
1 changed files with 5 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -172,18 +172,16 @@ void ring_buffer_open_file::forward(std::size_t count) {
ring_state_.set(0U, ring_state_.size(), true); ring_state_.set(0U, ring_state_.size(), true);
ring_pos_ += count; ring_pos_ += count;
ring_begin_ += added; ring_begin_ += added;
ring_end_ =
std::min(total_chunks_ - 1U, ring_begin_ + ring_state_.size() - 1U);
} else { } else {
for (std::size_t idx = 0U; idx < added; ++idx) { for (std::size_t idx = 0U; idx < added; ++idx) {
ring_state_[(ring_begin_ + idx) % ring_state_.size()] = true; ring_state_[(ring_begin_ + idx) % ring_state_.size()] = true;
} }
ring_begin_ += added; ring_begin_ += added;
ring_pos_ += count; ring_pos_ += count;
}
ring_end_ = ring_end_ =
std::min(total_chunks_ - 1U, ring_begin_ + ring_state_.size() - 1U); std::min(total_chunks_ - 1U, ring_begin_ + ring_state_.size() - 1U);
} }
}
chunk_notify_.notify_all(); chunk_notify_.notify_all();
} }
@ -218,18 +216,17 @@ void ring_buffer_open_file::reverse(std::size_t count) {
ring_state_.set(0U, ring_state_.size(), true); ring_state_.set(0U, ring_state_.size(), true);
ring_pos_ -= count; ring_pos_ -= count;
ring_begin_ = ring_pos_; ring_begin_ = ring_pos_;
ring_end_ =
std::min(total_chunks_ - 1U, ring_begin_ + ring_state_.size() - 1U);
} else { } else {
for (std::size_t idx = 0U; idx < removed; ++idx) { for (std::size_t idx = 0U; idx < removed; ++idx) {
ring_state_[(ring_end_ - idx) % ring_state_.size()] = true; ring_state_[(ring_end_ - idx) % ring_state_.size()] = true;
} }
ring_begin_ -= removed; ring_begin_ -= removed;
ring_pos_ -= count; ring_pos_ -= count;
}
ring_end_ = ring_end_ =
std::min(total_chunks_ - 1U, ring_begin_ + ring_state_.size() - 1U); std::min(total_chunks_ - 1U, ring_begin_ + ring_state_.size() - 1U);
} }
}
chunk_notify_.notify_all(); chunk_notify_.notify_all();
} }