apf: call metrics.AddReject for decisionCancel

This commit is contained in:
Abu Kashem 2021-10-18 13:08:56 -04:00
parent 5cf54fe762
commit f6dcf17a10
No known key found for this signature in database
GPG Key ID: 33A4FA7088DB68A9

View File

@ -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)