Skip to content

Commit 0e65c57

Browse files
authored
Merge pull request #3390 from drmingdrmer/master
[metasrv] test: write on follower and read on another follower
2 parents 92b8561 + a4381b6 commit 0e65c57

File tree

1 file changed

+16
-12
lines changed

1 file changed

+16
-12
lines changed

metasrv/tests/it/flight/metasrv_flight_meta_api_follower_follower.rs

Lines changed: 16 additions & 12 deletions
Original file line numberDiff line numberDiff line change
@@ -23,12 +23,13 @@ async fn test_meta_api_database_create_get_drop() -> anyhow::Result<()> {
2323
let (_log_guards, ut_span) = init_meta_ut!();
2424
let _ent = ut_span.enter();
2525

26-
let tcs = start_metasrv_cluster(&[0, 1]).await?;
26+
let tcs = start_metasrv_cluster(&[0, 1, 2]).await?;
2727

28-
let client1 = tcs[1].flight_client().await?;
28+
let follower1 = tcs[1].flight_client().await?;
29+
let follower2 = tcs[2].flight_client().await?;
2930

3031
MetaApiTestSuite {}
31-
.database_get_diff_nodes(&client1, &client1)
32+
.database_get_diff_nodes(&follower1, &follower2)
3233
.await
3334
}
3435

@@ -37,12 +38,13 @@ async fn test_meta_api_list_database() -> anyhow::Result<()> {
3738
let (_log_guards, ut_span) = init_meta_ut!();
3839
let _ent = ut_span.enter();
3940

40-
let tcs = start_metasrv_cluster(&[0, 1]).await?;
41+
let tcs = start_metasrv_cluster(&[0, 1, 2]).await?;
4142

42-
let client1 = tcs[1].flight_client().await?;
43+
let follower1 = tcs[1].flight_client().await?;
44+
let follower2 = tcs[2].flight_client().await?;
4345

4446
MetaApiTestSuite {}
45-
.list_database_diff_nodes(&client1, &client1)
47+
.list_database_diff_nodes(&follower1, &follower2)
4648
.await
4749
}
4850

@@ -51,12 +53,13 @@ async fn test_meta_api_table_create_get_drop() -> anyhow::Result<()> {
5153
let (_log_guards, ut_span) = init_meta_ut!();
5254
let _ent = ut_span.enter();
5355

54-
let tcs = start_metasrv_cluster(&[0, 1]).await?;
56+
let tcs = start_metasrv_cluster(&[0, 1, 2]).await?;
5557

56-
let client1 = tcs[1].flight_client().await?;
58+
let follower1 = tcs[1].flight_client().await?;
59+
let follower2 = tcs[2].flight_client().await?;
5760

5861
MetaApiTestSuite {}
59-
.table_get_diff_nodes(&client1, &client1)
62+
.table_get_diff_nodes(&follower1, &follower2)
6063
.await
6164
}
6265

@@ -65,11 +68,12 @@ async fn test_meta_api_list_table() -> anyhow::Result<()> {
6568
let (_log_guards, ut_span) = init_meta_ut!();
6669
let _ent = ut_span.enter();
6770

68-
let tcs = start_metasrv_cluster(&[0, 1]).await?;
71+
let tcs = start_metasrv_cluster(&[0, 1, 2]).await?;
6972

70-
let client1 = tcs[1].flight_client().await?;
73+
let follower1 = tcs[1].flight_client().await?;
74+
let follower2 = tcs[2].flight_client().await?;
7175

7276
MetaApiTestSuite {}
73-
.list_table_diff_nodes(&client1, &client1)
77+
.list_table_diff_nodes(&follower1, &follower2)
7478
.await
7579
}

0 commit comments

Comments
 (0)