abstract

Signed-off-by: husharp <jinhao.hu@pingcap.com>
tikv · Apr 12, 2023 · 1a2f950 · 1a2f950
1 parent b7ff98e
commit 1a2f950
Showing 1 changed file with 1 addition and 9 deletions.
diff --git a/client/resource_group/controller/controller.go b/client/resource_group/controller/controller.go
@@ -237,7 +237,7 @@ func (c *ResourceGroupsController) Start(ctx context.Context) {
 					c.executeOnAllGroups((*groupCostController).applyDegradedMode)
 				}
 			case <-emergencyTokenAcquisitionTicker.C:
-				c.resetEmergencyTokenAcquisition()
+				c.executeOnAllGroups((*groupCostController).resetEmergencyTokenAcquisition)
 			case gc := <-c.tokenBucketUpdateChan:
 				now := gc.run.now
 				go gc.handleTokenBucketUpdateEvent(c.loopCtx, now)
@@ -332,14 +332,6 @@ func (c *ResourceGroupsController) executeOnAllGroups(f func(controller *groupCo
 	})
 }
 
-func (c *ResourceGroupsController) resetEmergencyTokenAcquisition() {
-	c.groupsController.Range(func(name, value any) bool {
-		gc := value.(*groupCostController)
-		gc.resetEmergencyTokenAcquisition()
-		return true
-	})
-}
-
 func (c *ResourceGroupsController) handleTokenBucketResponse(resp []*rmpb.TokenBucketResponse) {
 	if c.responseDeadlineCh != nil {
 		if c.run.responseDeadline.Stop() {