Kaynağa Gözat

test(emqx_machine): ensure node is down before testing open ports

Ivan Dyachkov 1 yıl önce
ebeveyn
işleme
b27fc0da26
1 değiştirilmiş dosya ile 6 ekleme ve 0 silme
  1. 6 0
      apps/emqx_machine/test/emqx_machine_SUITE.erl

+ 6 - 0
apps/emqx_machine/test/emqx_machine_SUITE.erl

@@ -144,7 +144,13 @@ t_open_ports_check(Config) ->
     ?assertEqual(ok, erpc:call(Core2, emqx_machine, open_ports_check, [])),
     ?assertEqual(ok, erpc:call(Replicant, emqx_machine, open_ports_check, [])),
 
+    true = erlang:monitor_node(Core2, true),
     ok = emqx_cth_cluster:stop_node(Core2),
+    receive
+        {nodedown, Core2} -> ok
+    after 10000 ->
+        ct:fail("nodedown message not received after 10 seconds.")
+    end,
 
     ?assertEqual(ok, erpc:call(Replicant, emqx_machine, open_ports_check, [])),
     Results = erpc:call(Core1, emqx_machine, open_ports_check, []),