From f6dcf17a10dfd2cb5ce0ea7923723547c92c2e55 Mon Sep 17 00:00:00 2001 From: Abu Kashem Date: Mon, 18 Oct 2021 13:08:56 -0400 Subject: [PATCH] apf: call metrics.AddReject for decisionCancel --- .../pkg/util/flowcontrol/fairqueuing/queueset/queueset.go | 1 + 1 file changed, 1 insertion(+) diff --git a/staging/src/k8s.io/apiserver/pkg/util/flowcontrol/fairqueuing/queueset/queueset.go b/staging/src/k8s.io/apiserver/pkg/util/flowcontrol/fairqueuing/queueset/queueset.go index 6f74492e3ca..8bff2032f56 100644 --- a/staging/src/k8s.io/apiserver/pkg/util/flowcontrol/fairqueuing/queueset/queueset.go +++ b/staging/src/k8s.io/apiserver/pkg/util/flowcontrol/fairqueuing/queueset/queueset.go @@ -388,6 +388,7 @@ func (req *request) wait() (bool, bool) { // remove the request from the queue as it has timed out if req.removeFromQueueLocked() != nil { qs.totRequestsWaiting-- + metrics.AddReject(req.ctx, qs.qCfg.Name, req.fsName, "cancelled") metrics.AddRequestsInQueues(req.ctx, qs.qCfg.Name, req.fsName, -1) req.NoteQueued(false) qs.obsPair.RequestsWaiting.Add(-1)