From caa47896c131ef93ee060a24644cf34657d578a8 Mon Sep 17 00:00:00 2001 From: Hanno Cornelius <68783915+jm-clius@users.noreply.github.com> Date: Fri, 26 Aug 2022 11:20:55 +0200 Subject: [PATCH] fix: peer manager dial logic when dialing an existing peer (#1090) --- waku/v2/node/peer_manager/peer_manager.nim | 4 +--- 1 file changed, 1 insertion(+), 3 deletions(-) diff --git a/waku/v2/node/peer_manager/peer_manager.nim b/waku/v2/node/peer_manager/peer_manager.nim index e1e0c9028..ac8a61115 100644 --- a/waku/v2/node/peer_manager/peer_manager.nim +++ b/waku/v2/node/peer_manager/peer_manager.nim @@ -48,7 +48,7 @@ proc insertOrReplace(ps: PeerStorage, proc dialPeer(pm: PeerManager, peerId: PeerID, addrs: seq[MultiAddress], proto: string, dialTimeout = defaultDialTimeout): Future[Option[Connection]] {.async.} = - info "Dialing peer from manager", wireAddr = addrs[0], peerId = peerId + info "Dialing peer from manager", wireAddr = addrs, peerId = peerId # Dial Peer let dialFut = pm.switch.dial(peerId, addrs, proto) @@ -290,7 +290,5 @@ proc dialPeer*(pm: PeerManager, peerId: PeerID, proto: string, dialTimeout = def return none(Connection) let addrs = pm.switch.peerStore[AddressBook][peerId] - if addrs.len == 0: - return none(Connection) return await pm.dialPeer(peerId, addrs, proto, dialTimeout)