From d81be88d8de9d5da48d364654b984417d94d9516 Mon Sep 17 00:00:00 2001 From: "Scott E. Graves" Date: Sat, 28 Dec 2024 09:42:55 -0600 Subject: [PATCH] refactor --- .../librepertory/src/file_manager/direct_open_file.cpp | 3 --- .../librepertory/src/file_manager/ring_buffer_open_file.cpp | 6 ++++-- 2 files changed, 4 insertions(+), 5 deletions(-) diff --git a/repertory/librepertory/src/file_manager/direct_open_file.cpp b/repertory/librepertory/src/file_manager/direct_open_file.cpp index f24feb52..e2466187 100644 --- a/repertory/librepertory/src/file_manager/direct_open_file.cpp +++ b/repertory/librepertory/src/file_manager/direct_open_file.cpp @@ -266,9 +266,6 @@ void direct_open_file::reader_thread() { chunk_lock.unlock(); download_chunk(next_chunk, true); - - chunk_lock.lock(); - check_and_wait(); } event_system::instance().raise(get_api_path(), "direct", diff --git a/repertory/librepertory/src/file_manager/ring_buffer_open_file.cpp b/repertory/librepertory/src/file_manager/ring_buffer_open_file.cpp index 9621ccb8..6cae6b05 100644 --- a/repertory/librepertory/src/file_manager/ring_buffer_open_file.cpp +++ b/repertory/librepertory/src/file_manager/ring_buffer_open_file.cpp @@ -181,8 +181,10 @@ auto ring_buffer_open_file::download_chunk(std::size_t chunk, }; unlock_and_notify(); - auto res = get_provider().read_file_bytes( - get_api_path(), data_size, data_offset, buffer, stop_requested_); + auto res{ + get_provider().read_file_bytes(get_api_path(), data_size, data_offset, + buffer, stop_requested_), + }; chunk_lock.lock(); if (chunk < ring_begin_ || chunk > ring_end_) {