github/kubernetes
1
0
Fork 0
mirror of https://github.com/k3s-io/kubernetes.git synced 2025-09-09 13:12:20 +00:00
Code Issues Projects Releases Wiki Activity

Merge pull request #79599 from tedyu/cacher-clear-watchers

Browse Source 
Clear valueWatchers instead of removing every entry using a loop
This commit is contained in:
Kubernetes Prow Robot
2019-07-01 09:43:47 -07:00
committed by GitHub
parent f56b336976 a06daff032
commit 1b259bf75a
1 changed files with 2 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
staging/src/k8s.io/apiserver/pkg/storage/cacher/cacher.go
View File

@@ -154,10 +154,10 @@ func (i *indexedWatchers) terminateAll(objectType reflect.Type, done func(*cache
klog.Warningf("Terminating all watchers from cacher %v", objectType) klog.Warningf("Terminating all watchers from cacher %v", objectType)
} }
i.allWatchers.terminateAll(done) i.allWatchers.terminateAll(done)
for index, watchers := range i.valueWatchers { for _, watchers := range i.valueWatchers {
watchers.terminateAll(done) watchers.terminateAll(done)
delete(i.valueWatchers, index)
} }
i.valueWatchers = map[string]watchersMap{}
} }
// As we don't need a high precision here, we keep all watchers timeout within a // As we don't need a high precision here, we keep all watchers timeout within a