()
| 256 | } |
| 257 | |
| 258 | func (s *Scanner) logStats() { |
| 259 | localKvCount, sum := s.worker.summaryLocalKvs() |
| 260 | s.lg.Info("Local storage summary", "localKvs", sum, "localKvCount", localKvCount) |
| 261 | |
| 262 | s.statsMu.Lock() |
| 263 | mismatched := "[]" |
| 264 | if len(s.stats) > 0 { |
| 265 | mismatched = s.stats.String() |
| 266 | } |
| 267 | errSnapshot := make(map[uint64]error) |
| 268 | if s.stats.hasError() { |
| 269 | maps.Copy(errSnapshot, s.stats.withErrors()) |
| 270 | } |
| 271 | s.statsMu.Unlock() |
| 272 | |
| 273 | s.lg.Info("Scanner stats", "mode", s.cfg.Mode, "mismatched", mismatched) |
| 274 | for i, e := range errSnapshot { |
| 275 | s.lg.Info("Scanner error happened earlier", "kvIndex", i, "error", e) |
| 276 | } |
| 277 | } |
| 278 | |
| 279 | func (s *Scanner) GetScanState() *ScanStats { |
| 280 | if s == nil { |
no test coverage detected