From e1e1a5e5563871fda754165e9fc8838fbe5f03f9 Mon Sep 17 00:00:00 2001
From: ShuNing <nolouch@gmail.com>
Date: Thu, 9 May 2024 15:37:08 +0800
Subject: [PATCH] This is an automated cherry-pick of #8160

close tikv/pd#8159

Signed-off-by: ti-chi-bot <ti-community-prow-bot@tidb.io>
---
 client/resource_group/controller/limiter.go | 18 ++++++++++++++++++
 1 file changed, 18 insertions(+)

diff --git a/client/resource_group/controller/limiter.go b/client/resource_group/controller/limiter.go
index 61c2350153b..d908733a5a6 100644
--- a/client/resource_group/controller/limiter.go
+++ b/client/resource_group/controller/limiter.go
@@ -329,6 +329,8 @@ func (lim *Limiter) AvailableTokens(now time.Time) float64 {
 	return tokens
 }
 
+const reserveWarnLogInterval = 10 * time.Millisecond
+
 // reserveN is a helper method for Reserve.
 // maxFutureReserve specifies the maximum reservation wait duration allowed.
 // reserveN returns Reservation, not *Reservation.
@@ -374,6 +376,7 @@ func (lim *Limiter) reserveN(now time.Time, n float64, maxFutureReserve time.Dur
 		lim.tokens = tokens
 		lim.maybeNotify()
 	} else {
+<<<<<<< HEAD
 		log.Warn("[resource group controller] cannot reserve enough tokens",
 			zap.Duration("need-wait-duration", waitDuration),
 			zap.Duration("max-wait-duration", maxFutureReserve),
@@ -382,6 +385,21 @@ func (lim *Limiter) reserveN(now time.Time, n float64, maxFutureReserve time.Dur
 			zap.Float64("request-tokens", n),
 			zap.Int64("burst", lim.burst),
 			zap.Int("remaining-notify-times", lim.remainingNotifyTimes))
+=======
+		// print log if the limiter cannot reserve for a while.
+		if time.Since(lim.last) > reserveWarnLogInterval {
+			log.Warn("[resource group controller] cannot reserve enough tokens",
+				zap.Duration("need-wait-duration", waitDuration),
+				zap.Duration("max-wait-duration", maxFutureReserve),
+				zap.Float64("current-ltb-tokens", lim.tokens),
+				zap.Float64("current-ltb-rate", float64(lim.limit)),
+				zap.Float64("request-tokens", n),
+				zap.Float64("notify-threshold", lim.notifyThreshold),
+				zap.Bool("is-low-process", lim.isLowProcess),
+				zap.Int64("burst", lim.burst),
+				zap.Int("remaining-notify-times", lim.remainingNotifyTimes))
+		}
+>>>>>>> a674e668f (controller: Reduce the frequency of printing logs (#8160))
 		lim.last = last
 		if lim.limit == 0 {
 			lim.notify()