Make sleep interruptible

Kubernetes-commit: b705a521d8814b38faabea218097cac65d6ab5c5
This commit is contained in:
Mikhail Mazurskiy 2021-08-21 12:20:30 +10:00 committed by Kubernetes Publisher
parent 6524542499
commit 7a08020ed2

View File

@ -268,7 +268,13 @@ func (rw *RetryWatcher) receive() {
return
}
time.Sleep(retryAfter)
timer := time.NewTimer(retryAfter)
select {
case <-ctx.Done():
timer.Stop()
return
case <-timer.C:
}
klog.V(4).Infof("Restarting RetryWatcher at RV=%q", rw.lastResourceVersion)
}, rw.minRestartDelay)