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

Merge pull request #10861 from thalesmg/fix-flaky-telemetry-test-v50 

test(telemetry): fix flaky test
This commit is contained in:
Thales Macedo Garitezi 2023-05-30 09:05:28 -03:00 committed by GitHub
parent aa096f496f fa508a95c1
commit 5bcc28b8df
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 4 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
apps/emqx_telemetry/test/emqx_telemetry_SUITE.erl
View File

@ -430,25 +430,25 @@ t_num_clients(_Config) ->
{port, 1883}, {port, 1883},
{clean_start, false} {clean_start, false}
]), ]),
{{ok, _}, _} = ?wait_async_action( {{ok, _}, {ok, _}} = ?wait_async_action(
{ok, _} = emqtt:connect(Client), {ok, _} = emqtt:connect(Client),
#{ #{
?snk_kind := emqx_stats_setstat, ?snk_kind := emqx_stats_setstat,
count_stat := 'live_connections.count', count_stat := 'live_connections.count',
value := 1 value := 1
}, },
2000 5_000
), ),
{ok, TelemetryData0} = emqx_telemetry:get_telemetry(), {ok, TelemetryData0} = emqx_telemetry:get_telemetry(),
?assertEqual(1, get_value(num_clients, TelemetryData0)), ?assertEqual(1, get_value(num_clients, TelemetryData0)),
{ok, _} = ?wait_async_action( {ok, {ok, _}} = ?wait_async_action(
ok = emqtt:disconnect(Client), ok = emqtt:disconnect(Client),
#{ #{
?snk_kind := emqx_stats_setstat, ?snk_kind := emqx_stats_setstat,
count_stat := 'live_connections.count', count_stat := 'live_connections.count',
value := 0 value := 0
}, },
2000 5_000
), ),
{ok, TelemetryData1} = emqx_telemetry:get_telemetry(), {ok, TelemetryData1} = emqx_telemetry:get_telemetry(),
?assertEqual(0, get_value(num_clients, TelemetryData1)), ?assertEqual(0, get_value(num_clients, TelemetryData1)),