Minecon724/dncurrency
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages 1 Wiki Activity Actions

Fix connection attempt checks

Browse source
This commit is contained in:
Piotr Wójcik 2024-05-01 13:44:05 +02:00
commit f8812085d1
1 changed files with 18 additions and 18 deletions
Download patch file Download diff file Expand all files Collapse all files

36
nano/node/transport/tcp_listener.cpp
View file

@ -229,6 +229,24 @@ bool nano::transport::tcp_listener::connect (asio::ip::address ip, uint16_t port
port = node.network_params.network.default_node_port;
}
if (auto count = attempts.size (); count > config.max_attempts)
{
stats.inc (nano::stat::type::tcp_listener_rejected, nano::stat::detail::max_attempts, nano::stat::dir::out);
logger.debug (nano::log::type::tcp_listener, "Max connection attempts reached ({}), rejected connection attempt: {}",
count, ip.to_string ());
return false; // Rejected
}
if (auto count = count_attempts (ip); count >= config.max_attempts_per_ip)
{
stats.inc (nano::stat::type::tcp_listener_rejected, nano::stat::detail::max_attempts_per_ip, nano::stat::dir::out);
logger.debug (nano::log::type::tcp_listener, "Connection attempt already in progress ({}), rejected connection attempt: {}",
count, ip.to_string ());
return false; // Rejected
}
if (auto result = check_limits (ip, connection_type::outbound); result != accept_result::accepted)
{
stats.inc (nano::stat::type::tcp_listener, nano::stat::detail::connect_rejected, nano::stat::dir::out);
@ -462,24 +480,6 @@ auto nano::transport::tcp_listener::check_limits (asio::ip::address const & ip,
return accept_result::rejected;
}
if (auto count = attempts.size (); count > config.max_attempts)
{
stats.inc (nano::stat::type::tcp_listener_rejected, nano::stat::detail::max_attempts, to_stat_dir (type));
logger.debug (nano::log::type::tcp_listener, "Max connection attempts reached ({}), unable to initiate new connection: {}",
count, ip.to_string ());
return accept_result::rejected;
}
if (auto count = count_attempts (ip); count >= config.max_attempts_per_ip)
{
stats.inc (nano::stat::type::tcp_listener_rejected, nano::stat::detail::max_attempts_per_ip, to_stat_dir (type));
logger.debug (nano::log::type::tcp_listener, "Connection attempt already in progress ({}), unable to initiate new connection: {}",
count, ip.to_string ());
return accept_result::rejected;
}
}
return accept_result::accepted;