Update ratelimiter.go

go/ratelimiter/ratelimiter.go

@@ -93,7 +93,7 @@ func (rl *qpsRateLimiter) recalculate(rate int, interval int) (newRate int, left
 		newRate = rate / rl.subintervals
 		leftoverRate = rate % rl.subintervals
 
-		interval = int(float64(newRate*interval) / float64(rate))
+		interval = int(float64(interval) / float64(rl.subintervals))
 		newInterval = time.Duration(interval) * time.Millisecond
 	}
 	return
@@ -182,7 +182,7 @@ func (rl *qpsRateLimiter) run() {
 			max := rl.rate
 			if released < rl.subintervals {
 				if leftoverRate > 0 {
-					stepLeftoverRate := leftoverRate/rl.rate + 1
+					stepLeftoverRate := (leftoverRate/rl.subintervals) + 1
 					max += stepLeftoverRate
 					leftoverRate -= stepLeftoverRate
 				}