Skip to content

Commit 213b5b9

Browse files
authored
fix: sync pollLatest (#3133)
sync pollLatest fetch latest at start once wo waiting for tick (do while)
1 parent a3ba56d commit 213b5b9

File tree

1 file changed

+8
-6
lines changed

1 file changed

+8
-6
lines changed

sync/sync.go

Lines changed: 8 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -567,17 +567,19 @@ func (s *Synchronizer) pollLatest(ctx context.Context) {
567567
ticker := time.NewTicker(time.Minute)
568568

569569
for {
570+
highestBlock, err := s.dataSource.BlockLatest(ctx)
571+
if err != nil {
572+
s.log.Warnw("Failed fetching latest block", "err", err)
573+
} else {
574+
s.highestBlockHeader.Store(highestBlock.Header)
575+
}
576+
570577
select {
571578
case <-ctx.Done():
572579
ticker.Stop()
573580
return
574581
case <-ticker.C:
575-
highestBlock, err := s.dataSource.BlockLatest(ctx)
576-
if err != nil {
577-
s.log.Warnw("Failed fetching latest block", "err", err)
578-
} else {
579-
s.highestBlockHeader.Store(highestBlock.Header)
580-
}
582+
continue
581583
}
582584
}
583585
}

0 commit comments

Comments
 (0)