apf: call metrics.AddReject for decisionCancel

Kubernetes-commit: f6dcf17a10dfd2cb5ce0ea7923723547c92c2e55
2021-10-18 13:08:56 -04:00 · 2021-10-18 13:08:56 -04:00 · 3f529d0551
parent 9692745d3a
commit 3f529d0551
1 changed files with 1 additions and 0 deletions
--- 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)