Correct the checking of robinIndex

Kubernetes-commit: 2bdd379a1eb9d0344df41fff0339123849682e7c
2019-11-13 20:13:29 -08:00 · 2019-11-13 20:13:29 -08:00 · 82980a5db1
parent 6b2c200efa
commit 82980a5db1
1 changed files with 1 additions and 1 deletions
--- a/pkg/util/flowcontrol/fairqueuing/queueset/queueset.go
+++ b/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--
 		}