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

fix
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-26 16:00:37 -06:00
parent ef98fb7d59
commit c7870fdab4
1 changed files with 6 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@ -36,11 +36,13 @@ direct_open_file::direct_open_file(std::uint64_t chunk_size,
ring_state_(ring_size), ring_state_(ring_size),
total_chunks_(static_cast<std::size_t>( total_chunks_(static_cast<std::size_t>(
utils::divide_with_ceiling(fsi_.size, chunk_size))) { utils::divide_with_ceiling(fsi_.size, chunk_size))) {
if (fsi_.size > 0U) {
ring_state_.resize(std::min(total_chunks_, ring_state_.size()));
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);
ring_state_.set(0U, ring_state_.size(), true); ring_state_.set(0U, ring_state_.size(), true);
if (fsi_.size > 0U) {
reader_thread_ = reader_thread_ =
std::make_unique<std::thread>([this]() { background_reader_thread(); }); std::make_unique<std::thread>([this]() { background_reader_thread(); });
} }