(logger slog.Logger, source networkStatsSource, collector statsCollector)
| 43 | } |
| 44 | |
| 45 | func newStatsReporter(logger slog.Logger, source networkStatsSource, collector statsCollector) *statsReporter { |
| 46 | return &statsReporter{ |
| 47 | Cond: sync.NewCond(&sync.Mutex{}), |
| 48 | logger: logger, |
| 49 | source: source, |
| 50 | collector: collector, |
| 51 | } |
| 52 | } |
| 53 | |
| 54 | func (s *statsReporter) callback(_, _ time.Time, virtual, _ map[netlogtype.Connection]netlogtype.Counts) { |
| 55 | s.L.Lock() |
no outgoing calls