mirror of
https://github.com/status-im/go-waku.git
synced 2025-02-26 12:07:34 +00:00
chore: disable filter logs to prevent spam (#1275)
This commit is contained in:
parent
4ef460cb95
commit
24932b529c
@ -111,8 +111,6 @@ func (mgr *FilterManager) startFilterSubLoop() {
|
|||||||
mgr.incompleteFilterBatch = make(map[string]filterConfig)
|
mgr.incompleteFilterBatch = make(map[string]filterConfig)
|
||||||
mgr.Unlock()
|
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)))
|
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
@ -25,7 +25,7 @@ func (wf *WakuFilterLightNode) PingPeer(peer peer.ID) {
|
|||||||
defer cancel()
|
defer cancel()
|
||||||
err := wf.Ping(ctxWithTimeout, peer)
|
err := wf.Ping(ctxWithTimeout, peer)
|
||||||
if err != nil && wf.onlineChecker.IsOnline() {
|
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
|
//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.
|
//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)
|
ctxWithTimeout, cancel := context.WithTimeout(wf.CommonService.Context(), PingTimeout)
|
||||||
|
Loading…
x
Reference in New Issue
Block a user