mirror of
https://github.com/kemko/nomad.git
synced 2026-01-01 16:05:42 +03:00
Add missing timer reset (#15134)
This commit is contained in:
3
.changelog/15134.txt
Normal file
3
.changelog/15134.txt
Normal file
@@ -0,0 +1,3 @@
|
||||
```release-note:bug
|
||||
cleanup: fixed missing timer.Reset for plan queue stat emitter
|
||||
```
|
||||
@@ -201,6 +201,8 @@ func (q *PlanQueue) EmitStats(period time.Duration, stopCh <-chan struct{}) {
|
||||
defer stop()
|
||||
|
||||
for {
|
||||
timer.Reset(period)
|
||||
|
||||
select {
|
||||
case <-timer.C:
|
||||
stats := q.Stats()
|
||||
|
||||
Reference in New Issue
Block a user