From a0b23fbdfdf030e9d3b7c29356c21308c8fd306b Mon Sep 17 00:00:00 2001 From: Gabriel mermelstein Date: Tue, 1 Oct 2024 15:07:18 +0300 Subject: [PATCH] more logs --- waku/node/peer_manager/peer_manager.nim | 2 ++ waku/node/waku_node.nim | 1 + 2 files changed, 3 insertions(+) diff --git a/waku/node/peer_manager/peer_manager.nim b/waku/node/peer_manager/peer_manager.nim index f0ca376892..15812b0b12 100644 --- a/waku/node/peer_manager/peer_manager.nim +++ b/waku/node/peer_manager/peer_manager.nim @@ -190,6 +190,7 @@ proc connectRelay*( wireAddr = peer.addrs, peerId = peerId, failedAttempts = failedAttempts var deadline = sleepAsync(dialTimeout) + info "calling connectRelay" let workfut = pm.switch.connect(peerId, peer.addrs) # Can't use catch: with .withTimeout() in this case @@ -685,6 +686,7 @@ proc reconnectPeers*( ## Reconnect to peers registered for this protocol. This will update connectedness. ## Especially useful to resume connections from persistent storage after a restart. + info "calling reconnectPeers" debug "Reconnecting peers", proto = proto # Proto is not persisted, we need to iterate over all peers. diff --git a/waku/node/waku_node.nim b/waku/node/waku_node.nim index 9996e6c138..ce54633c5f 100644 --- a/waku/node/waku_node.nim +++ b/waku/node/waku_node.nim @@ -196,6 +196,7 @@ proc connectToNodes*( ) {.async.} = ## `source` indicates source of node addrs (static config, api call, discovery, etc) # NOTE Connects to the node without a give protocol, which automatically creates streams for relay + info "calling connectToNodes" await peer_manager.connectToNodes(node.peerManager, nodes, source = source) proc disconnectNode*(node: WakuNode, remotePeer: RemotePeerInfo) {.async.} =