From dd4cdd721f12b8a4b4827d7f9a641867b4645a71 Mon Sep 17 00:00:00 2001 From: Tristan Wilson Date: Thu, 13 Jul 2023 12:11:59 -0700 Subject: [PATCH] das: Don't log l1SyncService l1 errs until >5 --- das/syncing_fallback_storage.go | 9 +++++++-- 1 file changed, 7 insertions(+), 2 deletions(-) diff --git a/das/syncing_fallback_storage.go b/das/syncing_fallback_storage.go index 8af39d7d3a..7c67dbec68 100644 --- a/das/syncing_fallback_storage.go +++ b/das/syncing_fallback_storage.go @@ -370,20 +370,25 @@ func (s *l1SyncService) readMore(ctx context.Context) error { func (s *l1SyncService) mainThread(ctx context.Context) { headerChan, unsubscribe := s.l1Reader.Subscribe(false) defer unsubscribe() + errCount := 0 for { err := s.readMore(ctx) if err != nil { if ctx.Err() != nil { return } - log.Error("error trying to sync from L1", "err", err) + errCount++ + if errCount > 5 { + log.Error("error trying to sync from L1", "err", err) + } select { case <-ctx.Done(): return - case <-time.After(s.config.DelayOnError): + case <-time.After(s.config.DelayOnError * time.Duration(errCount)): } continue } + errCount = 0 if s.catchingUp { // we're behind. Don't wait. continue