Method startReporter

ethstorage/scanner/scanner.go:202–220

()

}

func (s *Scanner) startReporter() {
	s.wg.Add(1)
	go func() {
		defer s.wg.Done()

		localKvCount, sum := s.worker.summaryLocalKvs()
		s.lg.Info("Local storage summary", "localKvs", sum, "localKvCount", localKvCount)
		ticker := time.NewTicker(time.Minute)
		defer ticker.Stop()
		for {
			select {
			case <-ticker.C:
				s.logStats()
			case <-s.ctx.Done():
				return
			}
		}
	}()
}

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