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

removed debug logs
Some checks are pending
BlockStorage/repertory/pipeline/head Build queued...
Details

Browse Source
This commit is contained in:
Scott E. Graves
2024-12-24 13:28:14 -06:00
parent 02053ad8f2
commit dcaa200b67
1 changed files with 0 additions and 10 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@ -137,25 +137,19 @@ auto file_manager::create(const std::string &api_path, api_meta_map &meta,
auto file_manager::evict_file(const std::string &api_path) -> bool { auto file_manager::evict_file(const std::string &api_path) -> bool {
REPERTORY_USES_FUNCTION_NAME(); REPERTORY_USES_FUNCTION_NAME();
fmt::println("try evict|{}", api_path);
if (provider_.is_read_only()) { if (provider_.is_read_only()) {
return false; return false;
} }
unique_recur_mutex_lock open_lock(open_file_mtx_); unique_recur_mutex_lock open_lock(open_file_mtx_);
fmt::println("try evict locked|{}", api_path);
if (is_processing(api_path)) { if (is_processing(api_path)) {
fmt::println("proccessing|{}", api_path);
return false; return false;
} }
fmt::println("not proccessing|{}", api_path);
if (get_open_file_count(api_path) != 0U) { if (get_open_file_count(api_path) != 0U) {
fmt::println("open count|{}", api_path);
return false; return false;
} }
fmt::println("not open|{}", api_path);
std::string pinned; std::string pinned;
auto res = provider_.get_item_meta(api_path, META_PINNED, pinned); auto res = provider_.get_item_meta(api_path, META_PINNED, pinned);
@ -359,20 +353,17 @@ auto file_manager::is_processing(const std::string &api_path) const -> bool {
return false; return false;
} }
fmt::println("ul lock|{}", api_path);
unique_mutex_lock upload_lock(upload_mtx_); unique_mutex_lock upload_lock(upload_mtx_);
if (upload_lookup_.find(api_path) != upload_lookup_.end()) { if (upload_lookup_.find(api_path) != upload_lookup_.end()) {
return true; return true;
} }
upload_lock.unlock(); upload_lock.unlock();
fmt::println("ul unlocked|{}", api_path);
auto upload = mgr_db_->get_upload(api_path); auto upload = mgr_db_->get_upload(api_path);
if (upload.has_value()) { if (upload.has_value()) {
return true; return true;
}; };
fmt::println("of lock|{}", api_path);
unique_recur_mutex_lock open_lock(open_file_mtx_); unique_recur_mutex_lock open_lock(open_file_mtx_);
auto file_iter = open_file_lookup_.find(api_path); auto file_iter = open_file_lookup_.find(api_path);
if (file_iter == open_file_lookup_.end()) { if (file_iter == open_file_lookup_.end()) {
@ -380,7 +371,6 @@ auto file_manager::is_processing(const std::string &api_path) const -> bool {
} }
auto file = file_iter->second; auto file = file_iter->second;
fmt::println("of unlocked|{}", api_path);
open_lock.unlock(); open_lock.unlock();
return file->is_modified() || not file->is_complete(); return file->is_modified() || not file->is_complete();