Skip to content

Commit

Permalink
rename
Browse files Browse the repository at this point in the history
Signed-off-by: Ryan Leung <rleungx@gmail.com>
  • Loading branch information
rleungx committed May 30, 2023
1 parent 525c3f8 commit 1898cf9
Showing 1 changed file with 6 additions and 6 deletions.
12 changes: 6 additions & 6 deletions tests/integrations/mcs/tso/api_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -116,12 +116,12 @@ func TestTSOServerStartFirst(t *testing.T) {
ctx, cancel := context.WithCancel(context.Background())
defer cancel()

pdCluster, err := tests.NewTestAPICluster(ctx, 1, func(conf *config.Config, serverName string) {
apiCluster, err := tests.NewTestAPICluster(ctx, 1, func(conf *config.Config, serverName string) {
conf.Keyspace.PreAlloc = []string{"k1", "k2"}
})
defer pdCluster.Destroy()
defer apiCluster.Destroy()
re.NoError(err)
addr := pdCluster.GetConfig().GetClientURL()
addr := apiCluster.GetConfig().GetClientURL()
ch := make(chan struct{})
defer close(ch)
clusterCh := make(chan *mcs.TestTSOCluster)
Expand All @@ -134,10 +134,10 @@ func TestTSOServerStartFirst(t *testing.T) {
clusterCh <- tsoCluster
ch <- struct{}{}
}()
err = pdCluster.RunInitialServers()
err = apiCluster.RunInitialServers()
re.NoError(err)
leaderName := pdCluster.WaitLeader()
pdLeaderServer := pdCluster.GetServer(leaderName)
leaderName := apiCluster.WaitLeader()
pdLeaderServer := apiCluster.GetServer(leaderName)
re.NoError(pdLeaderServer.BootstrapCluster())
re.NoError(err)
tsoCluster := <-clusterCh
Expand Down

0 comments on commit 1898cf9

Please sign in to comment.