diff --git a/waku/node/peer_manager/peer_manager.nim b/waku/node/peer_manager/peer_manager.nim index a5fecce0b..b8988dd28 100644 --- a/waku/node/peer_manager/peer_manager.nim +++ b/waku/node/peer_manager/peer_manager.nim @@ -53,7 +53,7 @@ const ConnectivityLoopInterval = chronos.seconds(15) # How often the peer store is pruned - PrunePeerStoreInterval = chronos.minutes(5) + PrunePeerStoreInterval = chronos.minutes(10) # How often metrics and logs are shown/updated LogAndMetricsInterval = chronos.minutes(3) @@ -583,15 +583,16 @@ proc connectToRelayPeers*(pm: PeerManager) {.async.} = let totalRelayPeers = inRelayPeers.len + outRelayPeers.len let inPeersTarget = maxConnections - pm.outRelayPeersTarget - if inRelayPeers.len > pm.inRelayPeersTarget: - await pm.pruneInRelayConns(inRelayPeers.len - pm.inRelayPeersTarget) + # TODO: Temporally disabled. Might be causing connection issues + #if inRelayPeers.len > pm.inRelayPeersTarget: + # await pm.pruneInRelayConns(inRelayPeers.len - pm.inRelayPeersTarget) if outRelayPeers.len >= pm.outRelayPeersTarget: return let notConnectedPeers = pm.peerStore.getNotConnectedPeers().mapIt(RemotePeerInfo.init(it.peerId, it.addrs)) let outsideBackoffPeers = notConnectedPeers.filterIt(pm.canBeConnected(it.peerId)) - let numPeersToConnect = min(min(maxConnections - totalRelayPeers, outsideBackoffPeers.len), MaxParalelDials) + let numPeersToConnect = min(outsideBackoffPeers.len, MaxParalelDials) await pm.connectToNodes(outsideBackoffPeers[0..