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:21:54 -06:00
parent f85d0bd333
commit 3cee38bf92
1 changed files with 13 additions and 11 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -85,7 +85,7 @@ void packet_client::connect(client &cli) {
cli.socket.set_option(boost::asio::socket_base::linger(false, 0)); cli.socket.set_option(boost::asio::socket_base::linger(false, 0));
packet response; packet response;
const auto res = read_packet(cli, response); auto res = read_packet(cli, response);
if (res != 0) { if (res != 0) {
throw std::runtime_error(std::to_string(res)); throw std::runtime_error(std::to_string(res));
} }
@ -98,18 +98,20 @@ auto packet_client::get_client() -> std::shared_ptr<packet_client::client> {
std::shared_ptr<client> ret; std::shared_ptr<client> ret;
unique_mutex_lock clients_lock(clients_mutex_); unique_mutex_lock clients_lock(clients_mutex_);
if (allow_connections_) { if (not allow_connections_) {
if (clients_.empty()) { return ret;
clients_lock.unlock();
ret = std::make_shared<client>(io_context_);
connect(*ret);
} else {
ret = clients_[0U];
utils::collection::remove_element(clients_, ret);
clients_lock.unlock();
}
} }
if (clients_.empty()) {
clients_lock.unlock();
ret = std::make_shared<client>(io_context_);
connect(*ret);
return ret;
}
ret = clients_.at(0U);
utils::collection::remove_element(clients_, ret);
return ret; return ret;
} }