dandri/i2pd
1
0
Fork 0
mirror of https://github.com/PurpleI2P/i2pd.git synced 2026-08-28 11:44:16 +00:00
Code Issues Packages Projects Releases Wiki Activity

don't select peer for first hop if too many connection from that subnet

Browse Source
This commit is contained in:
orignal
2026-03-24 20:36:49 -04:00
parent 326675cec2
commit 7cfddc2ea0
2 changed files with 13 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files
libi2pd/Transports.cpp
+12 -6
View File
@@ -1228,13 +1228,19 @@ namespace transport
std::shared_ptr<const i2p::data::RouterInfo> Transports::GetRandomPeer (bool isHighBandwidth) const
{
return GetRandomPeer (
[isHighBandwidth](std::shared_ptr<const Peer> peer)->bool
[isHighBandwidth, this](std::shared_ptr<const Peer> peer)->bool
{
// connected, not overloaded and not slow
return !peer->router && peer->IsConnected () && peer->isEligible &&
peer->sessions.front ()->GetSendQueueSize () <= PEER_ROUTER_INFO_OVERLOAD_QUEUE_SIZE &&
!peer->sessions.front ()->IsSlow () && !peer->sessions.front ()->IsBandwidthExceeded (peer->isHighBandwidth) &&
(!isHighBandwidth || peer->isHighBandwidth);
// check if connected and high bandwidth if required
if (peer->router || !peer->IsConnected () || !peer->isEligible ||
peer->sessions.empty () || (isHighBandwidth && !peer->isHighBandwidth)) return false;
auto session = peer->sessions.front ();
// check if session not overloaded, slow or bandwidth exceeded
if (session->GetSendQueueSize () > PEER_ROUTER_INFO_OVERLOAD_QUEUE_SIZE ||
session->IsSlow () || session->IsBandwidthExceeded (peer->isHighBandwidth)) return false;
// check if max num connections from subnet is not exceeded
auto it = m_ConnectedNetworks.find (GetNetworkAddress (session));
if (it != m_ConnectedNetworks.end () && it->second > MAX_NUM_CONNECTIONS_FROM_SUBNET_FOR_PEER) return false;
return true;
});
}