From a625cd966de078a804d179ca9b8665685d58be24 Mon Sep 17 00:00:00 2001 From: Ethan Reesor Date: Fri, 8 Sep 2023 18:24:25 -0500 Subject: [PATCH] tweaks --- pkg/api/v3/p2p/dial.go | 9 +++++---- 1 file changed, 5 insertions(+), 4 deletions(-) diff --git a/pkg/api/v3/p2p/dial.go b/pkg/api/v3/p2p/dial.go index 73888ae86..6553fbc69 100644 --- a/pkg/api/v3/p2p/dial.go +++ b/pkg/api/v3/p2p/dial.go @@ -81,7 +81,11 @@ func (d *dialer) Dial(ctx context.Context, addr multiaddr.Multiaddr) (stream mes // BadDial notifies the dialer that a transport error was encountered while // processing the stream. func (d *dialer) BadDial(ctx context.Context, addr multiaddr.Multiaddr, s message.Stream, err error) bool { - ss := s.(*stream) + ss, ok := s.(*stream) + if !ok { + return false + } + slog.InfoCtx(ctx, "Bad dial", "peer", ss.peer, "address", addr, "error", err) d.tracker.markBad(ctx, ss.peer, addr) return true } @@ -273,9 +277,6 @@ func (d *dialer) dial(ctx context.Context, peer peer.ID, service *api.ServiceAdd return stream } - // Mark the peer bad - d.tracker.markBad(ctx, peer, addr) - // Log the error var timeoutError interface{ Timeout() bool } switch {