cleanup v5

This commit is contained in:
Tim Vaillancourt 2022-07-07 05:10:22 +02:00
parent eead61cb6d
commit e45357097f

View File

@ -252,8 +252,7 @@ func (this *Throttler) collectControlReplicasLag() {
ticker := time.NewTicker(100 * time.Millisecond) ticker := time.NewTicker(100 * time.Millisecond)
defer ticker.Stop() defer ticker.Stop()
for { for range ticker.C {
<-ticker.C
if atomic.LoadInt64(&this.finishedMigrating) > 0 { if atomic.LoadInt64(&this.finishedMigrating) > 0 {
return return
} }