refactor
This commit is contained in:
@@ -72,10 +72,10 @@ void packet_server::add_client(connection &conn, const std::string &client_id) {
|
|||||||
conn.client_id = client_id;
|
conn.client_id = client_id;
|
||||||
|
|
||||||
recur_mutex_lock connection_lock(connection_mutex_);
|
recur_mutex_lock connection_lock(connection_mutex_);
|
||||||
if (connection_lookup_.find(client_id) == connection_lookup_.end()) {
|
if (connection_lookup_.contains(client_id)) {
|
||||||
connection_lookup_[client_id] = 1U;
|
|
||||||
} else {
|
|
||||||
connection_lookup_.at(client_id)++;
|
connection_lookup_.at(client_id)++;
|
||||||
|
} else {
|
||||||
|
connection_lookup_[client_id] = 1U;
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
@@ -97,7 +97,7 @@ void packet_server::initialize(const uint16_t &port, uint8_t pool_size) {
|
|||||||
}
|
}
|
||||||
listen_for_connection(acceptor);
|
listen_for_connection(acceptor);
|
||||||
|
|
||||||
for (std::uint8_t i = 0U; i < pool_size; i++) {
|
for (std::uint8_t idx = 0U; idx < pool_size; ++idx) {
|
||||||
service_threads_.emplace_back([this]() { io_context_.run(); });
|
service_threads_.emplace_back([this]() { io_context_.run(); });
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|||||||
Reference in New Issue
Block a user