github/client-go
1
0
Fork 0
mirror of https://github.com/kubernetes/client-go.git synced 2025-08-08 02:44:20 +00:00
Code Issues Projects Releases Wiki Activity

reflector: exit retry loop on closed stopCh

Browse Source 
Kubernetes-commit: 8d98c846272b3fb4988bebf54b197d24d8fb3b5f
This commit is contained in:
Dr. Stefan Schimanski 2017-11-07 12:31:31 +01:00 committed by Kubernetes Publisher
parent b9cceae1f8
commit 097057c51c
1 changed files with 7 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
tools/cache/reflector.go vendored
View File

@ -295,6 +295,13 @@ func (r *Reflector) ListAndWatch(stopCh <-chan struct{}) error {
}() }()
for { for {
// give the stopCh a chance to stop the loop, even in case of continue statements further down on errors
select {
case <-stopCh:
return nil
default:
}
timemoutseconds := int64(minWatchTimeout.Seconds() * (rand.Float64() + 1.0)) timemoutseconds := int64(minWatchTimeout.Seconds() * (rand.Float64() + 1.0))
options = metav1.ListOptions{ options = metav1.ListOptions{
ResourceVersion: resourceVersion, ResourceVersion: resourceVersion,