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

Merge pull request #105739 from tkashem/apf-decision-cancel

Browse Source 
apf: call metrics.AddReject for decisionCancel
This commit is contained in:
Kubernetes Prow Robot 2021-10-29 08:10:51 -07:00 committed by GitHub
commit e580aa93d1
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 1 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -388,6 +388,7 @@ func (req *request) wait() (bool, bool) {
// remove the request from the queue as it has timed out // remove the request from the queue as it has timed out
if req.removeFromQueueLocked() != nil { if req.removeFromQueueLocked() != nil {
qs.totRequestsWaiting-- qs.totRequestsWaiting--
metrics.AddReject(req.ctx, qs.qCfg.Name, req.fsName, "cancelled")
metrics.AddRequestsInQueues(req.ctx, qs.qCfg.Name, req.fsName, -1) metrics.AddRequestsInQueues(req.ctx, qs.qCfg.Name, req.fsName, -1)
req.NoteQueued(false) req.NoteQueued(false)
qs.obsPair.RequestsWaiting.Add(-1) qs.obsPair.RequestsWaiting.Add(-1)