yuanbiao
/
emqx
1
0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

test(machine): attempt to stabilize flaky test

This commit is contained in:
Thales Macedo Garitezi 2024-03-07 10:23:02 -03:00
parent 98034cb4dd
commit b52c9c0062
1 changed files with 28 additions and 25 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

53
apps/emqx_machine/test/emqx_machine_SUITE.erl
View File

@ -147,29 +147,32 @@ t_open_ports_check(Config) ->
ok = emqx_cth_cluster:stop_node(Core2),
?assertEqual(ok, erpc:call(Replicant, emqx_machine, open_ports_check, [])),
Results = erpc:call(Core1, emqx_machine, open_ports_check, []),
?assertMatch(
#{
msg := "some ports are unreachable",
results :=
#{
Core2 :=
#{
open_ports := #{},
ports_to_check := [_, _],
resolved_ips := [_],
status := bad_ports
}
}
},
Results,
#{core2 => Core2, gen_rpc_port => GenRPCPort, ekka_port => EkkaPort}
),
%% 2 ports to check; we don't assert the exact ekka port because, when running
%% multiple nodes on the same machine as we do in tests, the order of returned ports
%% might change between invocations.
NumPorts = 2,
?assertEqual(
NumPorts, map_size(emqx_utils_maps:deep_get([results, Core2, open_ports], Results))
),
?retry(200, 20, begin
Results = erpc:call(Core1, emqx_machine, open_ports_check, []),
?assertMatch(
#{
msg := "some ports are unreachable",
results :=
#{
Core2 :=
#{
open_ports := #{},
ports_to_check := [_, _],
resolved_ips := [_],
status := bad_ports
}
}
},
Results,
#{core2 => Core2, gen_rpc_port => GenRPCPort, ekka_port => EkkaPort}
),
%% 2 ports to check; we don't assert the exact ekka port because, when running
%% multiple nodes on the same machine as we do in tests, the order of returned ports
%% might change between invocations.
NumPorts = 2,
?assertEqual(
NumPorts, map_size(emqx_utils_maps:deep_get([results, Core2, open_ports], Results))
),
ok
end),
ok.