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

don't cache disconnected sockets
Some checks failed
BlockStorage/repertory_mac/pipeline/head There was a failure building this commit
Details
BlockStorage/repertory/pipeline/head This commit looks good
Details

Browse Source
This commit is contained in:
Scott E. Graves
2025-08-04 10:59:03 -05:00
parent c91e51a445
commit ccb56485d8
1 changed files with 6 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@@ -71,6 +71,7 @@ void packet_client::connect(client &cli) {
boost::asio::connect(cli.socket, resolve_results_); boost::asio::connect(cli.socket, resolve_results_);
cli.socket.set_option(boost::asio::ip::tcp::no_delay(true)); cli.socket.set_option(boost::asio::ip::tcp::no_delay(true));
cli.socket.set_option(boost::asio::socket_base::linger(false, 0)); cli.socket.set_option(boost::asio::socket_base::linger(false, 0));
cli.socket.set_option(boost::asio::socket_base::keep_alive(true));
packet response; packet response;
auto res = read_packet(cli, response); auto res = read_packet(cli, response);
@@ -103,7 +104,11 @@ auto packet_client::get_client() -> std::shared_ptr<packet_client::client> {
} }
void packet_client::put_client(std::shared_ptr<client> &cli) { void packet_client::put_client(std::shared_ptr<client> &cli) {
mutex_lock clientsLock(clients_mutex_); if (not cli->socket.is_open()) {
return;
}
mutex_lock clients_lock(clients_mutex_);
if (clients_.size() < cfg_.max_connections) { if (clients_.size() < cfg_.max_connections) {
clients_.emplace_back(cli); clients_.emplace_back(cli);
} }