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.} =