cluster_minority_SUITE

Author: dumbbell

deps/rabbit/test/cluster_minority_SUITE.erl

@@ -306,6 +306,7 @@ add_node_when_seed_node_is_leader(Config) ->
 
     AMember = {rabbit_khepri:get_store_id(), A},
     _ = ra:transfer_leadership(AMember, AMember),
+    clustering_utils:assert_cluster_status({Cluster, Cluster}, Cluster),
 
     %% Minority partition: A
     partition_3_node_cluster(Config1),
@@ -338,6 +339,7 @@ add_node_when_seed_node_is_follower(Config) ->
 
     CMember = {rabbit_khepri:get_store_id(), C},
     ra:transfer_leadership(CMember, CMember),
+    clustering_utils:assert_cluster_status({Cluster, Cluster}, Cluster),
 
     %% Minority partition: A
     partition_3_node_cluster(Config1),
@@ -366,7 +368,9 @@ add_node_when_seed_node_is_follower(Config) ->
                match,
                re:run(
                  Msg, "\\{:rabbit, \\{\\{:error, :timeout\\}",
-                 [{capture, none}]));
+                 [{capture, none}])),
+            clustering_utils:assert_cluster_status(
+              {Cluster, Cluster}, Cluster);
         Ret ->
             ct:pal("A is not the expected follower: ~p", [Ret]),
             {skip, "Node A was not a follower"}
@@ -382,6 +386,7 @@ remove_node_when_seed_node_is_leader(Config) ->
 
     AMember = {rabbit_khepri:get_store_id(), A},
     ra:transfer_leadership(AMember, AMember),
+    clustering_utils:assert_cluster_status({Cluster, Cluster}, Cluster),
 
     %% Minority partition: A
     partition_3_node_cluster(Config1),
@@ -410,6 +415,7 @@ remove_node_when_seed_node_is_follower(Config) ->
 
     CMember = {rabbit_khepri:get_store_id(), C},
     ra:transfer_leadership(CMember, CMember),
+    clustering_utils:assert_cluster_status({Cluster, Cluster}, Cluster),
 
     %% Minority partition: A
     partition_3_node_cluster(Config1),