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

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

Browse Source
This commit is contained in:
Abu Kashem 2023-08-29 16:30:02 -04:00
parent 11ef9514da
commit 6297067ff1
No known key found for this signature in database
GPG Key ID: E5ECC1124B5F9C68
1 changed files with 2 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
staging/src/k8s.io/apiserver/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)