github/kubernetes
1
0
Fork 0
mirror of https://github.com/k3s-io/kubernetes.git synced 2026-07-17 02:06:23 +00:00
Code Issues Projects Releases Wiki Activity

[PATCH] Fixed the debug log format in flowcontrol

Browse Source
This commit is contained in:
yue9944882
2019-08-27 12:27:44 +08:00
committed by Mike Spreitzer
parent cf399d2e7a
commit d2da381bbf
1 changed files with 10 additions and 10 deletions
Download Patch File Download Diff File Expand all files Collapse all files

20
staging/src/k8s.io/apiserver/pkg/util/flowcontrol/reqmgmt.go
View File

@@ -240,18 +240,18 @@ func (reqMgr *requestManager) Wait(requestDigest RequestDigest) (bool, func()) {
fs := rmState.pickFlowSchema(requestDigest)
if fs == nil { // reject
metrics.AddReject("<none>", "non-match")
klog.V(7).Infof("Rejecting requestInfo=%v, user=%v because no FlowSchema matched", requestDigest.RequestInfo, requestDigest.User)
klog.V(7).Infof("Rejecting requestInfo=%#+v, userInfo=%#+v because no FlowSchema matched", requestDigest.RequestInfo, requestDigest.User)
return false, func() {}
}
matchingpriorityLevelName := fs.Spec.PriorityLevelConfiguration.Name
plName := fs.Spec.PriorityLevelConfiguration.Name
// 2. early out for exempt
ps := rmState.priorityLevelStates[matchingpriorityLevelName]
ps := rmState.priorityLevelStates[plName]
if ps.config.Exempt {
klog.V(7).Infof("Serving requestInfo=%v, user=%v, fs=%q without delay", requestDigest.RequestInfo, requestDigest.User, fs.Name)
klog.V(7).Infof("Serving requestInfo=%#+v, userInfo=%#+v, fs=%s, pl=%s without delay", requestDigest.RequestInfo, requestDigest.User, fs.Name, plName)
startExecutionTime := time.Now()
return true, func() {
metrics.ObserveExecutionDuration(matchingpriorityLevelName, fs.Name, time.Now().Sub(startExecutionTime))
metrics.ObserveExecutionDuration(plName, fs.Name, time.Now().Sub(startExecutionTime))
}
}
@@ -262,20 +262,20 @@ func (reqMgr *requestManager) Wait(requestDigest RequestDigest) (bool, func()) {
// 4. queuing
quiescent, execute, afterExecute := ps.queues.Wait(hashValue, ps.config.HandSize)
if quiescent {
klog.V(5).Infof("Request requestInfo=%v, user=%v, fs=%q landed in timing splinter, re-classifying", requestDigest.RequestInfo, requestDigest.User, fs.Name)
klog.V(5).Infof("Request requestInfo=%#+v, userInfo=%#+v, fs=%s, pl=%s landed in timing splinter, re-classifying", requestDigest.RequestInfo, requestDigest.User, fs.Name, plName)
continue
}
// 5. execute or reject
metrics.ObserveWaitingDuration(matchingpriorityLevelName, fs.Name, strconv.FormatBool(execute), time.Now().Sub(startWaitingTime))
metrics.ObserveWaitingDuration(plName, fs.Name, strconv.FormatBool(execute), time.Now().Sub(startWaitingTime))
if !execute {
klog.V(7).Infof("Rejecting requestInfo=%v, user=%v, fs=%q after fair queuing", requestDigest.RequestInfo, requestDigest.User, fs.Name)
klog.V(7).Infof("Rejecting requestInfo=%#+v, userInfo=%#+v, fs=%s, pl=%s after fair queuing", requestDigest.RequestInfo, requestDigest.User, fs.Name, plName)
return false, func() {}
}
klog.V(7).Infof("Serving requestInfo=%v, user=%v, fs=%q after fair queuing", requestDigest.RequestInfo, requestDigest.User, fs.Name)
klog.V(7).Infof("Serving requestInfo=%#+v, userInfo=%#+v, fs=%s, pl=%s after fair queuing", requestDigest.RequestInfo, requestDigest.User, fs.Name, plName)
startExecutionTime := time.Now()
return execute, func() {
metrics.ObserveExecutionDuration(matchingpriorityLevelName, fs.Name, time.Now().Sub(startExecutionTime))
metrics.ObserveExecutionDuration(plName, fs.Name, time.Now().Sub(startExecutionTime))
afterExecute()
}
}