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

refactor

Browse Source
This commit is contained in:
Scott E. Graves 2024-12-22 12:23:06 -06:00
parent ac66240fac
commit 6886f7d392
1 changed files with 6 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

13
repertory/librepertory/src/file_manager/file_manager.cpp
View File

@ -431,27 +431,26 @@ auto file_manager::open(
return download_type::direct; return download_type::direct;
}; };
auto chunk_size =
utils::encryption::encrypting_reader::get_data_chunk_size();
auto chunk_timeout = config_.get_enable_download_timeout() auto chunk_timeout = config_.get_enable_download_timeout()
? config_.get_download_timeout_secs() ? config_.get_download_timeout_secs()
: 0U; : 0U;
switch (get_download_type(config_.get_preferred_download_type())) { switch (get_download_type(config_.get_preferred_download_type())) {
case repertory::download_type::direct: { case repertory::download_type::direct: {
closeable_file = std::make_shared<direct_open_file>( closeable_file = std::make_shared<direct_open_file>(
utils::encryption::encrypting_reader::get_data_chunk_size(), chunk_size, chunk_timeout, fsi, provider_);
chunk_timeout, fsi, provider_);
} break; } break;
case repertory::download_type::ring_buffer: { case repertory::download_type::ring_buffer: {
closeable_file = std::make_shared<ring_buffer_open_file>( closeable_file = std::make_shared<ring_buffer_open_file>(
utils::path::combine(config_.get_data_directory(), {"buffer"}), utils::path::combine(config_.get_data_directory(), {"buffer"}),
utils::encryption::encrypting_reader::get_data_chunk_size(), chunk_size, chunk_timeout, fsi, provider_);
chunk_timeout, fsi, provider_);
} break; } break;
default: { default: {
closeable_file = std::make_shared<open_file>( closeable_file = std::make_shared<open_file>(chunk_size, chunk_timeout,
utils::encryption::encrypting_reader::get_data_chunk_size(), fsi, provider_, *this);
chunk_timeout, fsi, provider_, *this);
} break; } break;
} }
} }