BlockStorage/repertory
1
0
Fork 0
Code Issues 8 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-26 20:20:44 -06:00
parent c7870fdab4
commit 45a5e7b9aa
2 changed files with 17 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
repertory/librepertory/include/file_manager/ring_buffer_open_file.hpp
View File

@ -67,6 +67,8 @@ private:
private: private:
void background_reader_thread(); void background_reader_thread();
[[nodiscard]] auto check_allocation() -> api_error;
auto download_chunk(std::size_t chunk, bool skip_active) -> api_error; auto download_chunk(std::size_t chunk, bool skip_active) -> api_error;
public: public:

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

@ -87,15 +87,19 @@ ring_buffer_open_file::~ring_buffer_open_file() {
close(); close();
nf_->close(); if (nf_) {
if (not utils::file::file(source_path_).remove()) { nf_->close();
utils::error::raise_api_path_error( if (not utils::file::file(source_path_).remove()) {
function_name, fsi_.api_path, source_path_, utils::error::raise_api_path_error(
utils::get_last_error_code(), "failed to delete file"); function_name, fsi_.api_path, source_path_,
utils::get_last_error_code(), "failed to delete file");
}
} }
reader_thread_->join(); if (reader_thread_) {
reader_thread_.reset(); reader_thread_->join();
reader_thread_.reset();
}
} }
void ring_buffer_open_file::background_reader_thread() { void ring_buffer_open_file::background_reader_thread() {
@ -148,6 +152,10 @@ auto ring_buffer_open_file::can_handle_file(std::uint64_t file_size,
return file_size >= (static_cast<std::uint64_t>(ring_size) * chunk_size); return file_size >= (static_cast<std::uint64_t>(ring_size) * chunk_size);
} }
auto ring_buffer_open_file::check_allocation() -> api_error {
}
auto ring_buffer_open_file::close() -> bool { auto ring_buffer_open_file::close() -> bool {
stop_requested_ = true; stop_requested_ = true;