Method launchFixLoop

ethstorage/scanner/scanner.go:222–256

(interval time.Duration)

}

func (s *Scanner) launchFixLoop(interval time.Duration) {
	s.wg.Add(1)
	go func() {
		defer s.wg.Done()

		s.lg.Info("Launching scan fix loop", "interval", interval.String())

		fixTicker := time.NewTicker(interval)
		defer fixTicker.Stop()

		for {
			select {
			case <-fixTicker.C:
				// hold until other possible ongoing scans finish
				if !s.acquireScanPermit() {
					return
				}
				s.statsMu.Lock()
				kvIndices := s.stats.needFix()
				s.statsMu.Unlock()
				s.lg.Info("Scanner fixing batch triggered", "mismatchesToFix", kvIndices)
				err := s.worker.fixBatch(s.ctx, kvIndices, func(kvi uint64, m *scanned) {
					s.updateStats(kvi, m)
				})
				s.releaseScanPermit()
				if err != nil {
					s.lg.Error("Fixing batch failed", "error", err)
				}

			case <-s.ctx.Done():
				return
			}
		}
	}()
}

func (s *Scanner) logStats() {
	localKvCount, sum := s.worker.summaryLocalKvs()