kubernetes
/
apiserver
mirror of https://github.com/kubernetes/apiserver.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

apf: request ejected from queue should use reason 'time-out' 

Kubernetes-commit: 6297067ff1afaa2d63d83183a23e8744865d7c2b
This commit is contained in:
Abu Kashem 2023-08-29 16:30:02 -04:00 committed by Kubernetes Publisher
parent d64c9b18da
commit 04acc93a12
1 changed files with 2 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
pkg/util/flowcontrol/fairqueuing/queueset/queueset.go
View File

@ -417,8 +417,7 @@ func (req *request) wait() (bool, bool) {
} }
req.waitStarted = true req.waitStarted = true
switch decisionAny { switch decisionAny {
case decisionCancel: case decisionCancel: // handle in code following this switch
klog.V(5).Infof("QS(%s): request %#+v %#+v queue wait time exceeded after being enqueued\n", qs.qCfg.Name, req.descr1, req.descr2)
case decisionExecute: case decisionExecute:
klog.V(5).Infof("QS(%s): Dispatching request %#+v %#+v from its queue", qs.qCfg.Name, req.descr1, req.descr2) klog.V(5).Infof("QS(%s): Dispatching request %#+v %#+v from its queue", qs.qCfg.Name, req.descr1, req.descr2)
return true, false return true, false
@ -436,7 +435,7 @@ func (req *request) wait() (bool, bool) {
qs.totSeatsWaiting -= req.MaxSeats() qs.totSeatsWaiting -= req.MaxSeats()
qs.totRequestsRejected++ qs.totRequestsRejected++
qs.totRequestsCancelled++ qs.totRequestsCancelled++
metrics.AddReject(req.ctx, qs.qCfg.Name, req.fsName, "cancelled") metrics.AddReject(req.ctx, qs.qCfg.Name, req.fsName, "time-out")
metrics.AddRequestsInQueues(req.ctx, qs.qCfg.Name, req.fsName, -1) metrics.AddRequestsInQueues(req.ctx, qs.qCfg.Name, req.fsName, -1)
metrics.AddSeatsInQueues(req.ctx, qs.qCfg.Name, req.fsName, -req.MaxSeats()) metrics.AddSeatsInQueues(req.ctx, qs.qCfg.Name, req.fsName, -req.MaxSeats())
req.NoteQueued(false) req.NoteQueued(false)