From 3f0c865c3f33f6b66d718d155f70ab0da8c90dc7 Mon Sep 17 00:00:00 2001 From: Gabriel mermelstein Date: Tue, 1 Oct 2024 14:30:09 +0300 Subject: [PATCH] adding debug logs --- waku/node/peer_manager/peer_manager.nim | 14 ++++++++++++++ 1 file changed, 14 insertions(+) diff --git a/waku/node/peer_manager/peer_manager.nim b/waku/node/peer_manager/peer_manager.nim index 6e5a9c6976..bc5d1725cb 100644 --- a/waku/node/peer_manager/peer_manager.nim +++ b/waku/node/peer_manager/peer_manager.nim @@ -727,6 +727,12 @@ proc connectToRelayPeers*(pm: PeerManager) {.async.} = var (inRelayPeers, outRelayPeers) = pm.connectedPeers(WakuRelayCodec) let totalRelayPeers = inRelayPeers.len + outRelayPeers.len + info "connectToRelayPeers", + inRelayPeers = inRelayPeers.len, + inRelayPeersTarget = pm.inRelayPeersTarget, + outRelayPeers = outRelayPeers.len, + outRelayPeersTarget = pm.outRelayPeersTarget + if inRelayPeers.len > pm.inRelayPeersTarget: await pm.pruneInRelayConns(inRelayPeers.len - pm.inRelayPeersTarget) @@ -744,6 +750,8 @@ proc connectToRelayPeers*(pm: PeerManager) {.async.} = min(outsideBackoffPeers.len, pm.outRelayPeersTarget - outRelayPeers.len) ## number of outstanding connection requests + info "connectToRelayPeers connecting to peers", + numPendingConnReqs = numPendingConnReqs while numPendingConnReqs > 0 and outRelayPeers.len < pm.outRelayPeersTarget: let numPeersToConnect = min(numPendingConnReqs, MaxParallelDials) await pm.connectToNodes(outsideBackoffPeers[index ..< (index + numPeersToConnect)]) @@ -752,6 +760,12 @@ proc connectToRelayPeers*(pm: PeerManager) {.async.} = index += numPeersToConnect numPendingConnReqs -= numPeersToConnect + (inRelayPeers, outRelayPeers) = pm.connectedPeers(WakuRelayCodec) + info "finished connectToRelayPeers", + inRelayPeers = inRelayPeers.len, + inRelayPeersTarget = pm.inRelayPeersTarget, + outRelayPeers = outRelayPeers.len, + outRelayPeersTarget = pm.outRelayPeersTarget proc manageRelayPeers*(pm: PeerManager) {.async.} = if pm.wakuMetadata.shards.len == 0: