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

Merge pull request #35617 from wojtek-t/tweak_traces

Browse Source 
Automatic merge from submit-queue

Reduce amount of not-helping logs in apiserver
This commit is contained in:
Kubernetes Submit Queue 2016-10-26 10:23:37 -07:00 committed by GitHub
commit 349af4e7fa
2 changed files with 5 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
pkg/apiserver/resthandler.go
View File

@ -126,7 +126,7 @@ func GetResource(r rest.Getter, e rest.Exporter, scope RequestScope) restful.Rou
func(ctx api.Context, name string, req *restful.Request) (runtime.Object, error) {
// For performance tracking purposes.
trace := util.NewTrace("Get " + req.Request.URL.Path)
defer trace.LogIfLong(250 * time.Millisecond)
defer trace.LogIfLong(500 * time.Millisecond)
// check for export
if values := req.Request.URL.Query(); len(values) > 0 {
@ -334,7 +334,7 @@ func createHandler(r rest.NamedCreater, scope RequestScope, typer runtime.Object
return func(req *restful.Request, res *restful.Response) {
// For performance tracking purposes.
trace := util.NewTrace("Create " + req.Request.URL.Path)
defer trace.LogIfLong(250 * time.Millisecond)
defer trace.LogIfLong(500 * time.Millisecond)
w := res.ResponseWriter
@ -656,7 +656,7 @@ func UpdateResource(r rest.Updater, scope RequestScope, typer runtime.ObjectType
return func(req *restful.Request, res *restful.Response) {
// For performance tracking purposes.
trace := util.NewTrace("Update " + req.Request.URL.Path)
defer trace.LogIfLong(250 * time.Millisecond)
defer trace.LogIfLong(500 * time.Millisecond)
w := res.ResponseWriter
@ -743,7 +743,7 @@ func DeleteResource(r rest.GracefulDeleter, checkBody bool, scope RequestScope,
return func(req *restful.Request, res *restful.Response) {
// For performance tracking purposes.
trace := util.NewTrace("Delete " + req.Request.URL.Path)
defer trace.LogIfLong(250 * time.Millisecond)
defer trace.LogIfLong(500 * time.Millisecond)
w := res.ResponseWriter

2
pkg/storage/cacher.go
View File

@ -728,7 +728,7 @@ func (c *cacheWatcher) add(event *watchCacheEvent) {
trace := util.NewTrace(
fmt.Sprintf("cacheWatcher %v: waiting for add (initial result size %v)",
reflect.TypeOf(event.Object).String(), len(c.result)))
defer trace.LogIfLong(5 * time.Millisecond)
defer trace.LogIfLong(50 * time.Millisecond)
const timeout = 5 * time.Second
t, ok := timerPool.Get().(*time.Timer)