Merge pull request #85257 from yutedz/queueset-robin-idx

Correct the checking of robinIndex
2019-11-14 16:38:50 -08:00
parent 9edcaf7c4d 2bdd379a1e
commit 8dffc8db4f
1 changed files with 1 additions and 1 deletions
--- 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--
 		}