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

test(banned): attempt to improve flaky test

This commit is contained in:
Thales Macedo Garitezi 2023-05-30 11:08:31 -03:00
parent 04bd39861d
commit 26992e9d98
1 changed files with 4 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
apps/emqx/test/emqx_banned_SUITE.erl
View File

@ -145,11 +145,12 @@ t_kick(_) ->
t_session_taken(_) -> t_session_taken(_) ->
erlang:process_flag(trap_exit, true), erlang:process_flag(trap_exit, true),
Topic = <<"t/banned">>, Topic = <<"t/banned">>,
ClientId2 = <<"t_session_taken">>, ClientId2 = emqx_guid:to_hexstr(emqx_guid:gen()),
MsgNum = 3, MsgNum = 3,
Connect = fun() -> Connect = fun() ->
ClientId = emqx_guid:to_hexstr(emqx_guid:gen()),
{ok, C} = emqtt:start_link([ {ok, C} = emqtt:start_link([
{clientid, <<"client1">>}, {clientid, ClientId},
{proto_ver, v5}, {proto_ver, v5},
{clean_start, false}, {clean_start, false},
{properties, #{'Session-Expiry-Interval' => 120}} {properties, #{'Session-Expiry-Interval' => 120}}
@ -188,9 +189,9 @@ t_session_taken(_) ->
end, end,
15_000 15_000
), ),
Publish(),
C2 = Connect(), C2 = Connect(),
Publish(),
?assertEqual(MsgNum, length(receive_messages(MsgNum + 1))), ?assertEqual(MsgNum, length(receive_messages(MsgNum + 1))),
ok = emqtt:disconnect(C2), ok = emqtt:disconnect(C2),