diff --git a/waku/v2/api/filter/filter_manager.go b/waku/v2/api/filter/filter_manager.go index 66762238..530cb7e7 100644 --- a/waku/v2/api/filter/filter_manager.go +++ b/waku/v2/api/filter/filter_manager.go @@ -111,8 +111,6 @@ func (mgr *FilterManager) startFilterSubLoop() { mgr.incompleteFilterBatch = make(map[string]filterConfig) mgr.Unlock() } - subs := mgr.node.Subscriptions() - mgr.logger.Debug("filter stats", zap.Int("agg filters count", len(mgr.filterSubscriptions)), zap.Int("filter subs count", len(subs))) } } } diff --git a/waku/v2/protocol/filter/filter_health_check.go b/waku/v2/protocol/filter/filter_health_check.go index 7bdd1569..86fa77e7 100644 --- a/waku/v2/protocol/filter/filter_health_check.go +++ b/waku/v2/protocol/filter/filter_health_check.go @@ -25,7 +25,7 @@ func (wf *WakuFilterLightNode) PingPeer(peer peer.ID) { defer cancel() err := wf.Ping(ctxWithTimeout, peer) if err != nil && wf.onlineChecker.IsOnline() { - wf.log.Warn("Filter ping failed towards peer", zap.Stringer("peer", peer), zap.Error(err)) + wf.log.Info("Filter ping failed towards peer", zap.Stringer("peer", peer), zap.Error(err)) //quickly retry ping again before marking subscription as failure //Note that PingTimeout is a fraction of PingInterval so this shouldn't cause parallel pings being sent. ctxWithTimeout, cancel := context.WithTimeout(wf.CommonService.Context(), PingTimeout)