Clean up sync filters

smartcontractkit · Jul 19, 2024 · 933194d · 933194d
1 parent 64fe028
commit 933194d
Showing 1 changed file with 1 addition and 8 deletions.
diff --git a/core/services/ocr2/plugins/ocr2keeper/evmregistry/v21/logprovider/provider.go b/core/services/ocr2/plugins/ocr2keeper/evmregistry/v21/logprovider/provider.go
@@ -177,7 +177,7 @@ func (p *logEventProvider) Start(context.Context) error {
 			for {
 				select {
 				case <-ticker.C:
-					if err := p.syncBufferFilters(); err != nil {
+					if err := p.buffer.SyncFilters(p.filterStore); err != nil {
 						p.lggr.Warnw("failed to sync buffer filters", "err", err)
 					}
 				case <-ctx.Done():
@@ -500,10 +500,3 @@ func (p *logEventProvider) readLogs(ctx context.Context, latest int64, filters [
 
 	return merr
 }
-
-func (p *logEventProvider) syncBufferFilters() error {
-	p.lock.RLock()
-	defer p.lock.RUnlock()
-
-	return p.buffer.SyncFilters(p.filterStore)
-}