Initialize and reset slot pace stats correctly

safing · Mar 13, 2023 · bd177b1 · bd177b1
1 parent 6531ee9
commit bd177b1
Show file tree

Hide file tree

Showing 2 changed files with 6 additions and 2 deletions.
diff --git a/unit/scheduler.go b/unit/scheduler.go
@@ -123,6 +123,10 @@ func NewScheduler(config *SchedulerConfig) *Scheduler {
 	s.clearanceUpTo.Store(s.config.MinSlotPace)
 	s.slotPace.Store(s.config.MinSlotPace)
 
+	// Initialize stats fields.
+	s.avgPaceSum.Store(s.config.MinSlotPace)
+	s.avgPaceCnt.Store(1)
+
 	return s
 }
 

diff --git a/unit/scheduler_stats.go b/unit/scheduler_stats.go
@@ -18,8 +18,8 @@ func (s *Scheduler) ResetAvgSlotPace() {
 	// latest slot data, while the other has been not.
 	// This is not so much of a problem, as slots are really short and the impact
 	// is very low.
-	s.avgPaceCnt.Store(0)
-	s.avgPaceSum.Store(0)
+	s.avgPaceCnt.Store(1)
+	s.avgPaceSum.Store(s.config.MinSlotPace)
 }
 
 // GetMaxLeveledSlotPace returns the current maximum leveled slot pace.