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-16 10:22:49 -06:00
parent 3cee38bf92
commit 6fc0085292
1 changed files with 7 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

16
repertory/librepertory/src/comm/packet/packet_client.cpp
View File

@ -95,24 +95,22 @@ void packet_client::connect(client &cli) {
} }
auto packet_client::get_client() -> std::shared_ptr<packet_client::client> { auto packet_client::get_client() -> std::shared_ptr<packet_client::client> {
std::shared_ptr<client> ret;
unique_mutex_lock clients_lock(clients_mutex_); unique_mutex_lock clients_lock(clients_mutex_);
if (not allow_connections_) { if (not allow_connections_) {
return ret; return nullptr;
} }
if (clients_.empty()) { if (clients_.empty()) {
clients_lock.unlock(); clients_lock.unlock();
ret = std::make_shared<client>(io_context_); auto cli = std::make_shared<client>(io_context_);
connect(*ret); connect(*cli);
return ret; return cli;
} }
ret = clients_.at(0U); auto cli = clients_.at(0U);
utils::collection::remove_element(clients_, ret); utils::collection::remove_element(clients_, cli);
return ret; return cli;
} }
void packet_client::put_client(std::shared_ptr<client> &cli) { void packet_client::put_client(std::shared_ptr<client> &cli) {