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-28 19:35:17 -06:00
parent 43bf3c0cb2
commit b4b688d3b9
1 changed files with 14 additions and 12 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

26
repertory/librepertory/src/comm/packet/client_pool.cpp
View File

@ -146,18 +146,20 @@ void client_pool::remove_client(const std::string &client_id) {
} }
void client_pool::shutdown() { void client_pool::shutdown() {
if (not shutdown_) { if (shutdown_) {
event_system::instance().raise<service_shutdown_begin>("client_pool"); return;
unique_mutex_lock pool_lock(pool_mutex_);
if (not shutdown_) {
shutdown_ = true;
for (auto &pool_entry : pool_lookup_) {
pool_entry.second->shutdown();
}
pool_lookup_.clear();
}
pool_lock.unlock();
event_system::instance().raise<service_shutdown_end>("client_pool");
} }
event_system::instance().raise<service_shutdown_begin>("client_pool");
unique_mutex_lock pool_lock(pool_mutex_);
if (not shutdown_) {
shutdown_ = true;
for (auto &pool_entry : pool_lookup_) {
pool_entry.second->shutdown();
}
pool_lookup_.clear();
}
pool_lock.unlock();
event_system::instance().raise<service_shutdown_end>("client_pool");
} }
} // namespace repertory } // namespace repertory