mirror of
https://github.com/k3s-io/kubernetes.git
synced 2025-07-28 14:07:14 +00:00
Extend logging for performance debuggin
This commit is contained in:
parent
630d7ab6d9
commit
949dd90593
@ -645,6 +645,7 @@ func (c *cacheWatcher) add(event *watchCacheEvent) {
|
|||||||
default:
|
default:
|
||||||
}
|
}
|
||||||
|
|
||||||
|
resultLen := len(c.result)
|
||||||
// OK, block sending, but only for up to 5 seconds.
|
// OK, block sending, but only for up to 5 seconds.
|
||||||
// cacheWatcher.add is called very often, so arrange
|
// cacheWatcher.add is called very often, so arrange
|
||||||
// to reuse timers instead of constantly allocating.
|
// to reuse timers instead of constantly allocating.
|
||||||
@ -673,8 +674,8 @@ func (c *cacheWatcher) add(event *watchCacheEvent) {
|
|||||||
c.forget(false)
|
c.forget(false)
|
||||||
c.stop()
|
c.stop()
|
||||||
}
|
}
|
||||||
glog.V(2).Infof("cacheWatcher add function blocked processing of %v for %v",
|
glog.V(2).Infof("cacheWatcher add function blocked processing of %v for %v (initial result size %v)",
|
||||||
reflect.TypeOf(event.Object).String(), time.Since(startTime))
|
reflect.TypeOf(event.Object).String(), time.Since(startTime), resultLen)
|
||||||
}
|
}
|
||||||
|
|
||||||
func (c *cacheWatcher) sendWatchCacheEvent(event watchCacheEvent) {
|
func (c *cacheWatcher) sendWatchCacheEvent(event watchCacheEvent) {
|
||||||
|
Loading…
Reference in New Issue
Block a user