github/kubernetes
1
0
Fork 0
mirror of https://github.com/k3s-io/kubernetes.git synced 2025-08-02 08:17:26 +00:00
Code Issues Projects Releases Wiki Activity

Merge pull request #34951 from wojtek-t/tune_cacher_logs

Browse Source 
Automatic merge from submit-queue

Reduce amount of annoying logs in cacher
This commit is contained in:
Kubernetes Submit Queue 2016-10-17 08:45:00 -07:00 committed by GitHub
commit f85d8f2e66
1 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
pkg/storage/cacher.go
View File

@ -368,7 +368,7 @@ func (c *Cacher) List(ctx context.Context, key string, resourceVersion string, p
} }
trace := util.NewTrace(fmt.Sprintf("cacher %v: List", c.objectType.String())) trace := util.NewTrace(fmt.Sprintf("cacher %v: List", c.objectType.String()))
defer trace.LogIfLong(250 * time.Millisecond) defer trace.LogIfLong(500 * time.Millisecond)
c.ready.wait() c.ready.wait()
trace.Step("Ready") trace.Step("Ready")
@ -749,7 +749,7 @@ func (c *cacheWatcher) process(initEvents []watchCacheEvent, resourceVersion uin
// We should understand what is blocking us in those cases (e.g. // We should understand what is blocking us in those cases (e.g.
// is it lack of CPU, network, or sth else) and potentially // is it lack of CPU, network, or sth else) and potentially
// consider increase size of result buffer in those cases. // consider increase size of result buffer in those cases.
const initProcessThreshold = 100 * time.Millisecond const initProcessThreshold = 500 * time.Millisecond
startTime := time.Now() startTime := time.Now()
for _, event := range initEvents { for _, event := range initEvents {
c.sendWatchCacheEvent(event) c.sendWatchCacheEvent(event)