From 61cda61c3d674e285295fdaed2478c2cb52045b4 Mon Sep 17 00:00:00 2001 From: Richard Ramos Date: Wed, 9 Mar 2022 19:15:04 -0400 Subject: [PATCH] fix: flag conn error as failure (#209) --- waku/v2/protocol/filter/waku_filter.go | 2 ++ 1 file changed, 2 insertions(+) diff --git a/waku/v2/protocol/filter/waku_filter.go b/waku/v2/protocol/filter/waku_filter.go index 53b0705c..fd1ca234 100644 --- a/waku/v2/protocol/filter/waku_filter.go +++ b/waku/v2/protocol/filter/waku_filter.go @@ -152,6 +152,8 @@ func (wf *WakuFilter) pushMessage(subscriber Subscriber, msg *pb.WakuMessage) er // We connect first so dns4 addresses are resolved (NewStream does not do it) err := wf.h.Connect(wf.ctx, wf.h.Peerstore().PeerInfo(subscriber.peer)) if err != nil { + wf.subscribers.FlagAsFailure(subscriber.peer) + wf.log.Error("failed to connect to peer", err) return err }