From 24932b529c7e8d0bc12b94a5cdf4028438fb9919 Mon Sep 17 00:00:00 2001 From: Prem Chaitanya Prathi Date: Tue, 18 Feb 2025 11:16:16 +0530 Subject: [PATCH] chore: disable filter logs to prevent spam (#1275) --- waku/v2/api/filter/filter_manager.go | 2 -- waku/v2/protocol/filter/filter_health_check.go | 2 +- 2 files changed, 1 insertion(+), 3 deletions(-) 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)