Skip to content

Commit

Permalink
logs
Browse files Browse the repository at this point in the history
  • Loading branch information
gabrielmer committed Oct 1, 2024
1 parent 1ca9970 commit 3a1f0a8
Show file tree
Hide file tree
Showing 2 changed files with 2 additions and 1 deletion.
1 change: 1 addition & 0 deletions waku/node/peer_manager/peer_manager.nim
Original file line number Diff line number Diff line change
Expand Up @@ -367,6 +367,7 @@ proc onConnEvent(pm: PeerManager, peerId: PeerID, event: ConnEvent) {.async.} =
discard

proc onPeerMetadata(pm: PeerManager, peerId: PeerId) {.async.} =
info "calling onPeerMetadata"
let res = catch:
await pm.switch.dial(peerId, WakuMetadataCodec)

Expand Down
2 changes: 1 addition & 1 deletion waku/node/waku_node.nim
Original file line number Diff line number Diff line change
Expand Up @@ -434,6 +434,7 @@ proc startRelay*(node: WakuNode) {.async.} =
let backoffPeriod =
node.wakuRelay.parameters.pruneBackoff + chronos.seconds(BackoffSlackTime)

info "calling reconnectPeers", backoffPeriod = backoffPeriod
await node.peerManager.reconnectPeers(WakuRelayCodec, backoffPeriod)

# Start the WakuRelay protocol
Expand Down Expand Up @@ -1252,7 +1253,6 @@ proc keepaliveLoop(node: WakuNode, keepalive: chronos.Duration) {.async.} =

for peer in peers:
try:
info "calling keepAlive dial"
let conn = await node.switch.dial(peer.peerId, peer.addrs, PingCodec)
let pingDelay = await node.libp2pPing.ping(conn)
await conn.close()
Expand Down

0 comments on commit 3a1f0a8

Please sign in to comment.