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

Complete ring buffer and direct download support #26

Browse Source
This commit is contained in:
Scott E. Graves 2024-12-23 08:46:49 -06:00
parent f344665ddc
commit ad22233308
1 changed files with 10 additions and 12 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -373,33 +373,31 @@ void ring_buffer_open_file::set_api_path(const std::string &api_path) {
}
void ring_buffer_open_file::background_reader_thread() {
unique_mutex_lock read_lock(read_mtx_);
read_lock.unlock();
unique_mutex_lock chunk_lock(chunk_mtx_);
auto next_chunk = ring_pos_;
while (not stop_requested_) {
read_lock.lock();
chunk_notify_.notify_all();
chunk_lock.unlock();
const auto check_and_wait = [this, &next_chunk]() {
unique_mutex_lock chunk_lock(chunk_mtx_);
while (not stop_requested_) {
chunk_lock.lock();
next_chunk = next_chunk + 1U > ring_end_ ? ring_begin_ : next_chunk + 1U;
const auto check_and_wait = [this, &chunk_lock, &next_chunk]() {
if (get_read_state().all()) {
chunk_notify_.wait(chunk_lock);
next_chunk = ring_pos_;
}
chunk_notify_.notify_all();
chunk_lock.unlock();
};
next_chunk = next_chunk + 1U > ring_end_ ? ring_begin_ : next_chunk + 1U;
if (not ring_state_[next_chunk % ring_state_.size()]) {
read_lock.unlock();
check_and_wait();
continue;
}
read_lock.unlock();
download_chunk(next_chunk, true);
check_and_wait();
}
}