From a87bfe7ba629ce205e536275d4ce343fc11192e3 Mon Sep 17 00:00:00 2001 From: Derrick Hammer Date: Tue, 5 Mar 2024 15:06:42 -0500 Subject: [PATCH] fix: ErrTransportNotSupported check in wrong location --- service/default/p2p.go | 11 ++++++----- 1 file changed, 6 insertions(+), 5 deletions(-) diff --git a/service/default/p2p.go b/service/default/p2p.go index 28d5d6a..a4aff50 100644 --- a/service/default/p2p.go +++ b/service/default/p2p.go @@ -285,6 +285,12 @@ func (p *P2PServiceDefault) ConnectToNode(connectionUris []*url.URL, retried boo return nil } + + if errors.Is(err, net.ErrTransportNotSupported) { + p.Logger().Debug("failed to connect, unsupported transport", zap.String("node", connectionUri.String()), zap.Error(err)) + return err + } + retried = true p.Logger().Error("failed to connect", zap.String("node", connectionUri.String()), zap.Error(err)) @@ -302,11 +308,6 @@ func (p *P2PServiceDefault) ConnectToNode(connectionUris []*url.URL, retried boo return p.ConnectToNode(connectionUris, retried, fromPeer) } - if errors.Is(err, net.ErrTransportNotSupported) { - p.Logger().Debug("failed to connect, unsupported transport", zap.String("node", connectionUri.String()), zap.Error(err)) - return err - } - if p.outgoingPeerFailures.Contains(idString) { p.outgoingPeerFailures.Remove(idString) }