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

test: stabilize flaky test

This commit is contained in:
Thales Macedo Garitezi 2024-05-14 17:11:05 -03:00
parent b0aa7f25aa
commit f062517ccb
1 changed files with 16 additions and 19 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

35
apps/emqx/test/emqx_takeover_SUITE.erl
View File

@ -884,26 +884,23 @@ t_kick_session(Config) ->
{will_qos, 1}
],
Commands =
%% GIVEN: client connect with willmsg payload <<"willpayload_kick">>
[{fun start_client/5, [ClientId, ClientId, ?QOS_1, WillOpts]}] ++
[
{fun start_client/5, [
<<ClientId/binary, <<"_willsub">>/binary>>, WillTopic, ?QOS_1, []
]}
] ++
[
%% kick may fail (not found) without this delay
{
fun(CTX) ->
timer:sleep(100),
CTX
end,
[]
}
] ++
lists:flatten([
%% GIVEN: client connect with willmsg payload <<"willpayload_kick">>
{fun start_client/5, [ClientId, ClientId, ?QOS_1, WillOpts]},
{fun start_client/5, [
<<ClientId/binary, <<"_willsub">>/binary>>, WillTopic, ?QOS_1, []
]},
%% kick may fail (not found) without this delay
{
fun(CTX) ->
timer:sleep(300),
CTX
end,
[]
},
%% WHEN: client is kicked with kick_session
[{fun kick_client/2, [ClientId]}],
{fun kick_client/2, [ClientId]}
]),
FCtx = lists:foldl(
fun({Fun, Args}, Ctx) ->
ct:pal("COMMAND: ~p ~p", [element(2, erlang:fun_info(Fun, name)), Args]),