From 2e89656a90deff2d9e5dbacc0ba498ef22a23a00 Mon Sep 17 00:00:00 2001 From: Andrew Mayorov Date: Wed, 17 Jul 2024 20:01:55 +0200 Subject: [PATCH] test(dsraft): start `t_replication_transfers_snapshots` from stable state --- .../test/emqx_ds_replication_SUITE.erl | 12 +++--------- 1 file changed, 3 insertions(+), 9 deletions(-) diff --git a/apps/emqx_ds_builtin_raft/test/emqx_ds_replication_SUITE.erl b/apps/emqx_ds_builtin_raft/test/emqx_ds_replication_SUITE.erl index 306bcdf4b..96edd1043 100644 --- a/apps/emqx_ds_builtin_raft/test/emqx_ds_replication_SUITE.erl +++ b/apps/emqx_ds_builtin_raft/test/emqx_ds_replication_SUITE.erl @@ -130,15 +130,8 @@ t_replication_transfers_snapshots(Config) -> begin %% Initialize DB on all nodes and wait for it to be online. Opts = opts(Config, #{n_shards => 1, n_sites => 3}), - ?assertEqual( - [{ok, ok} || _ <- Nodes], - erpc:multicall(Nodes, emqx_ds, open_db, [?DB, Opts]) - ), - ?retry( - 500, - 10, - ?assertMatch([[_], [_], [_]], [shards_online(N, ?DB) || N <- Nodes]) - ), + assert_db_open(Nodes, ?DB, Opts), + assert_db_stable(Nodes, ?DB), %% Stop the DB on the "offline" node. ?wait_async_action( @@ -476,6 +469,7 @@ t_rebalance_chaotic_converges(Config) -> %% Wait until the LTS timestamp is updated: timer:sleep(5000), + assert_db_stable(Nodes, ?DB), %% Check that all messages are still there. emqx_ds_test_helpers:verify_stream_effects(?DB, ?FUNCTION_NAME, Nodes, TopicStreams)