github/kubernetes
1
0
Fork 0
mirror of https://github.com/k3s-io/kubernetes.git synced 2025-07-28 14:07:14 +00:00
Code Issues Projects Releases Wiki Activity

Log warning when terminating all watchers

Browse Source
This commit is contained in:
Wojciech Tyczynski 2016-08-10 17:04:10 +02:00
parent ccb9b2af1d
commit 497f891cfb
1 changed files with 5 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
pkg/storage/cacher.go
View File

@ -138,6 +138,9 @@ type Cacher struct {
// Underlying storage.Interface. // Underlying storage.Interface.
storage Interface storage Interface
// Expected type of objects in the underlying cache.
objectType reflect.Type
// "sliding window" of recent changes of objects and the current state. // "sliding window" of recent changes of objects and the current state.
watchCache *watchCache watchCache *watchCache
reflector *cache.Reflector reflector *cache.Reflector
@ -181,6 +184,7 @@ func NewCacherFromConfig(config CacherConfig) *Cacher {
cacher := &Cacher{ cacher := &Cacher{
ready: newReady(), ready: newReady(),
storage: config.Storage, storage: config.Storage,
objectType: reflect.TypeOf(config.Type),
watchCache: watchCache, watchCache: watchCache,
reflector: cache.NewReflector(listerWatcher, config.Type, watchCache, 0), reflector: cache.NewReflector(listerWatcher, config.Type, watchCache, 0),
versioner: config.Versioner, versioner: config.Versioner,
@ -440,6 +444,7 @@ func (c *Cacher) processEvent(event watchCacheEvent) {
} }
func (c *Cacher) terminateAllWatchers() { func (c *Cacher) terminateAllWatchers() {
glog.Warningf("Terminating all watchers from cacher %v", c.objectType)
c.Lock() c.Lock()
defer c.Unlock() defer c.Unlock()
c.watchers.terminateAll() c.watchers.terminateAll()