From 3f529d055136aafa1d0b3950ec96c662a5797521 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 Kubernetes-commit: f6dcf17a10dfd2cb5ce0ea7923723547c92c2e55 --- pkg/util/flowcontrol/fairqueuing/queueset/queueset.go | 1 + 1 file changed, 1 insertion(+) diff --git a/pkg/util/flowcontrol/fairqueuing/queueset/queueset.go b/pkg/util/flowcontrol/fairqueuing/queueset/queueset.go index 6f74492e3..8bff2032f 100644 --- a/pkg/util/flowcontrol/fairqueuing/queueset/queueset.go +++ b/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)