From f1f4186f2ba9a73071fb64c4b78055679591886d Mon Sep 17 00:00:00 2001 From: Andrea Maria Piana Date: Fri, 23 Aug 2024 14:45:09 +0100 Subject: [PATCH] reduce filter loop to 300ms --- wakuv2/filter_manager.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/wakuv2/filter_manager.go b/wakuv2/filter_manager.go index ce1984a3a..f89447424 100644 --- a/wakuv2/filter_manager.go +++ b/wakuv2/filter_manager.go @@ -67,7 +67,7 @@ func newFilterManager(ctx context.Context, logger *zap.Logger, cfg *Config, onNe mgr.node = node mgr.onlineChecker = onlinechecker.NewDefaultOnlineChecker(false).(*onlinechecker.DefaultOnlineChecker) mgr.node.SetOnlineChecker(mgr.onlineChecker) - mgr.filterSubBatchDuration = 5 * time.Second + mgr.filterSubBatchDuration = 300 * time.Millisecond mgr.incompleteFilterBatch = make(map[string]filterConfig) mgr.filterConfigs = make(appFilterMap) mgr.waitingToSubQueue = make(chan filterConfig, 100)