Skip to content

Commit 6297067

Browse files
committed
apf: request ejected from queue should use reason 'time-out'
1 parent 11ef951 commit 6297067

File tree

1 file changed

+2
-3
lines changed
  • staging/src/k8s.io/apiserver/pkg/util/flowcontrol/fairqueuing/queueset

1 file changed

+2
-3
lines changed

staging/src/k8s.io/apiserver/pkg/util/flowcontrol/fairqueuing/queueset/queueset.go

Lines changed: 2 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -417,8 +417,7 @@ func (req *request) wait() (bool, bool) {
417417
}
418418
req.waitStarted = true
419419
switch decisionAny {
420-
case decisionCancel:
421-
klog.V(5).Infof("QS(%s): request %#+v %#+v queue wait time exceeded after being enqueued\n", qs.qCfg.Name, req.descr1, req.descr2)
420+
case decisionCancel: // handle in code following this switch
422421
case decisionExecute:
423422
klog.V(5).Infof("QS(%s): Dispatching request %#+v %#+v from its queue", qs.qCfg.Name, req.descr1, req.descr2)
424423
return true, false
@@ -436,7 +435,7 @@ func (req *request) wait() (bool, bool) {
436435
qs.totSeatsWaiting -= req.MaxSeats()
437436
qs.totRequestsRejected++
438437
qs.totRequestsCancelled++
439-
metrics.AddReject(req.ctx, qs.qCfg.Name, req.fsName, "cancelled")
438+
metrics.AddReject(req.ctx, qs.qCfg.Name, req.fsName, "time-out")
440439
metrics.AddRequestsInQueues(req.ctx, qs.qCfg.Name, req.fsName, -1)
441440
metrics.AddSeatsInQueues(req.ctx, qs.qCfg.Name, req.fsName, -req.MaxSeats())
442441
req.NoteQueued(false)

0 commit comments

Comments
 (0)