diff --git a/server/grpc_service.go b/server/grpc_service.go index 1301abe2ae9..953ff1cfbc9 100644 --- a/server/grpc_service.go +++ b/server/grpc_service.go @@ -1532,14 +1532,12 @@ func (s *GrpcServer) GetRegionByID(ctx context.Context, request *pdpb.GetRegionB // QueryRegion provides a stream processing of the region query. func (s *GrpcServer) QueryRegion(stream pdpb.PD_QueryRegionServer) error { - if s.GetServiceMiddlewarePersistOptions().IsGRPCRateLimitEnabled() { - fName := currentFunction() - limiter := s.GetGRPCRateLimiter() - if done, err := limiter.Allow(fName); err == nil { - defer done() - } else { - return err - } + done, err := s.rateLimitCheck() + if err != nil { + return err + } + if done != nil { + defer done() } for {