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:54:01 -06:00
parent 4f419be42d
commit 1a84e507fc
1 changed files with 9 additions and 0 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

@ -112,6 +112,12 @@ void ring_buffer_open_file::background_reader_thread() {
next_chunk = next_chunk + 1U > ring_end_ ? ring_begin_ : next_chunk + 1U; next_chunk = next_chunk + 1U > ring_end_ ? ring_begin_ : next_chunk + 1U;
const auto check_and_wait = [this, &chunk_lock, &next_chunk]() { const auto check_and_wait = [this, &chunk_lock, &next_chunk]() {
if (stop_requested_) {
chunk_notify_.notify_all();
chunk_lock.unlock();
return;
}
if (get_read_state().all()) { if (get_read_state().all()) {
chunk_notify_.wait(chunk_lock); chunk_notify_.wait(chunk_lock);
next_chunk = ring_pos_; next_chunk = ring_pos_;
@ -130,6 +136,9 @@ void ring_buffer_open_file::background_reader_thread() {
chunk_lock.unlock(); chunk_lock.unlock();
download_chunk(next_chunk, true); download_chunk(next_chunk, true);
chunk_lock.lock();
check_and_wait();
} }
} }