From 2bdd379a1eb9d0344df41fff0339123849682e7c Mon Sep 17 00:00:00 2001 From: Ted Yu Date: Wed, 13 Nov 2019 20:13:29 -0800 Subject: [PATCH] Correct the checking of robinIndex --- .../pkg/util/flowcontrol/fairqueuing/queueset/queueset.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) 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 fe311a9e2c1..0d3762fd38d 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 @@ -568,7 +568,7 @@ func (qs *queueSet) finishRequestLocked(r *request) { // decrement here to maintain the invariant that (qs.robinIndex+1) % numQueues // is the index of the next queue after the one last dispatched from - if qs.robinIndex >= -r.Queue.Index { + if qs.robinIndex >= r.Queue.Index { qs.robinIndex-- }