From 87b93a7799d3bc97874334347a223ba6a0a661b2 Mon Sep 17 00:00:00 2001 From: Ryan Leung Date: Fri, 27 Sep 2024 14:56:00 +0800 Subject: [PATCH] fix Signed-off-by: Ryan Leung --- tests/server/server_test.go | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/tests/server/server_test.go b/tests/server/server_test.go index c41ed0f96a6..68c4d5da65e 100644 --- a/tests/server/server_test.go +++ b/tests/server/server_test.go @@ -168,7 +168,7 @@ func TestGRPCRateLimit(t *testing.T) { jsonBody, err := json.Marshal(input) re.NoError(err) err = testutil.CheckPostJSON(tests.TestDialClient, urlPrefix, jsonBody, - testutil.StatusOK(re), testutil.StringContain(re, "QPS rate limiter is changed")) + testutil.StatusOK(re), testutil.StringContain(re, "gRPC limiter is updated")) re.NoError(err) for i := 0; i < 2; i++ { resp, err := grpcPDClient.GetRegion(context.Background(), &pdpb.GetRegionRequest{ @@ -188,7 +188,7 @@ func TestGRPCRateLimit(t *testing.T) { jsonBody, err = json.Marshal(input) re.NoError(err) err = testutil.CheckPostJSON(tests.TestDialClient, urlPrefix, jsonBody, - testutil.StatusOK(re), testutil.StringContain(re, "QPS rate limiter is deleted")) + testutil.StatusOK(re), testutil.StringContain(re, "gRPC limiter is deleted")) re.NoError(err) for i := 0; i < 100; i++ { resp, err := grpcPDClient.GetRegion(context.Background(), &pdpb.GetRegionRequest{ @@ -208,7 +208,7 @@ func TestGRPCRateLimit(t *testing.T) { errCh = make(chan string) ) err = testutil.CheckPostJSON(tests.TestDialClient, urlPrefix, jsonBody, - testutil.StatusOK(re), testutil.StringContain(re, "Concurrency limiter is changed")) + testutil.StatusOK(re), testutil.StringContain(re, "gRPC limiter is updated")) re.NoError(err) re.NoError(failpoint.Enable("github.com/tikv/pd/server/delayProcess", `pause`)) var wg sync.WaitGroup