From 786e6d7146061021f83cf95c1253a5dcd3d367da Mon Sep 17 00:00:00 2001 From: Cabinfever_B Date: Tue, 28 Nov 2023 14:35:18 +0800 Subject: [PATCH] add test Signed-off-by: Cabinfever_B add test Signed-off-by: Cabinfever_B --- tests/server/region_syncer/region_syncer_test.go | 11 ++++++----- 1 file changed, 6 insertions(+), 5 deletions(-) diff --git a/tests/server/region_syncer/region_syncer_test.go b/tests/server/region_syncer/region_syncer_test.go index 7e4b31b6620..8607b209f19 100644 --- a/tests/server/region_syncer/region_syncer_test.go +++ b/tests/server/region_syncer/region_syncer_test.go @@ -65,16 +65,15 @@ func TestRegionSyncer(t *testing.T) { re.NoError(leaderServer.BootstrapCluster()) rc := leaderServer.GetServer().GetRaftCluster() re.NotNil(rc) + followerServer := cluster.GetServer(cluster.GetFollower()) testutil.Eventually(re, func() bool { - follower := cluster.GetServer(cluster.GetFollower()) - return !follower.GetServer().DirectlyGetRaftCluster().GetRegionSyncer().IsRunningAsClient() + return !followerServer.GetServer().DirectlyGetRaftCluster().GetRegionSyncer().IsRunningAsClient() }) re.NoError(failpoint.Disable("github.com/tikv/pd/pkg/syncer/disableClientStreaming")) re.True(cluster.WaitRegionSyncerClientsReady(2)) testutil.Eventually(re, func() bool { - follower := cluster.GetServer(cluster.GetFollower()) - return follower.GetServer().DirectlyGetRaftCluster().GetRegionSyncer().IsRunningAsClient() + return followerServer.GetServer().DirectlyGetRaftCluster().GetRegionSyncer().IsRunningAsClient() }) regionLen := 110 @@ -133,7 +132,6 @@ func TestRegionSyncer(t *testing.T) { time.Sleep(4 * time.Second) // test All regions have been synchronized to the cache of followerServer - followerServer := cluster.GetServer(cluster.GetFollower()) re.NotNil(followerServer) cacheRegions := leaderServer.GetServer().GetBasicCluster().GetRegions() re.Len(cacheRegions, regionLen) @@ -155,6 +153,9 @@ func TestRegionSyncer(t *testing.T) { re.NoError(err) cluster.WaitLeader() leaderServer = cluster.GetLeaderServer() + testutil.Eventually(re, func() bool { + return !leaderServer.GetServer().GetRaftCluster().GetRegionSyncer().IsRunningAsClient() + }) re.NotNil(leaderServer) loadRegions := leaderServer.GetServer().GetRaftCluster().GetRegions() re.Len(loadRegions, regionLen)