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

Add logging to debug conflicts in kubemark-scale test

Browse Source
This commit is contained in:
Wojciech Tyczynski 2017-06-02 14:34:24 +02:00
parent 7043372d05
commit 1504c7fc31
2 changed files with 6 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -639,6 +639,11 @@ func forgetWatcher(c *Cacher, index int, triggerValue string, triggerSupported b
if lock { if lock {
c.Lock() c.Lock()
defer c.Unlock() defer c.Unlock()
} else {
// false is currently passed only if we are forcing watcher to close due
// to its unresponsiveness and blocking other watchers.
// TODO: Get this information in cleaner way.
glog.V(1).Infof("Forcing watcher close due to unresponsiveness: %v", c.objectType.String())
} }
// It's possible that the watcher is already not in the structure (e.g. in case of // It's possible that the watcher is already not in the structure (e.g. in case of
// simulaneous Stop() and terminateAllWatchers(), but it doesn't break anything. // simulaneous Stop() and terminateAllWatchers(), but it doesn't break anything.

2
staging/src/k8s.io/apiserver/pkg/storage/time_budget.go
View File

@ -23,7 +23,7 @@ import (
const ( const (
refreshPerSecond = 50 * time.Millisecond refreshPerSecond = 50 * time.Millisecond
maxBudget = 250 * time.Millisecond maxBudget = 100 * time.Millisecond
) )
// timeBudget implements a budget of time that you can use and is // timeBudget implements a budget of time that you can use and is