BlockStorage/repertory
1
0
Fork 0
Code Issues 3 Pull Requests Releases 9 Wiki Activity

Writes should block when maximum cache size is reached #25

Browse Source
This commit is contained in:
sgraves76
2024-12-18 13:51:16 -06:00
parent 9961cb700e
commit 80fd52625e
2 changed files with 8 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
repertory/librepertory/src/file_manager/cache_size_mgr.cpp
View File

@@ -82,7 +82,7 @@ void cache_size_mgr::initialize(app_config *cfg) {
auto cache_size_mgr::shrink(std::uint64_t size) -> api_error { auto cache_size_mgr::shrink(std::uint64_t size) -> api_error {
mutex_lock lock(mtx_); mutex_lock lock(mtx_);
if (size >= cache_size_) { if (cache_size_ >= size) {
cache_size_ -= size; cache_size_ -= size;
} else { } else {
cache_size_ = 0U; cache_size_ = 0U;

8
repertory/librepertory/src/file_manager/open_file.cpp
View File

@@ -499,7 +499,13 @@ auto open_file::close() -> bool {
return true; return true;
} }
if (not utils::file::file(fsi_.source_path).remove()) { auto file = utils::file::file{fsi_.source_path};
if (file.remove()) {
err = cache_size_mgr::instance().shrink(file.size().value_or(0U));
if (err != api_error::success) {
utils::error::raise_api_path_error(function_name, api_path, err,
} "failed to shrink cache");
} else {
utils::error::raise_api_path_error( utils::error::raise_api_path_error(
function_name, get_api_path(), fsi_.source_path, function_name, get_api_path(), fsi_.source_path,
utils::get_last_error_code(), "failed to delete source file"); utils::get_last_error_code(), "failed to delete source file");