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

Merge pull request #6210 from emqx/fix-more-flaky-persistent-session-tests 

test(persistent_session_SUITE): fix another flaky test
This commit is contained in:
Tobias Lindahl 2021-11-17 15:29:52 +01:00 committed by GitHub
parent 86d0487cb0 e52d8138bf
commit 349c324b2f
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 5 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -273,10 +273,13 @@ snabbkaffe_sync_publish(Topic, Payloads) ->
do_publish(Payloads, Fun, true).
publish(Topic, Payloads) ->
publish(Topic, Payloads, false).
publish(Topic, Payloads, WaitForUnregister) ->
Fun = fun(Client, Payload) ->
{ok, _} = emqtt:publish(Client, Topic, Payload, 2)
end,
do_publish(Payloads, Fun, false).
do_publish(Payloads, Fun, WaitForUnregister).
do_publish(Payloads = [_|_], PublishFun, WaitForUnregister) ->
%% Publish from another process to avoid connection confusion.
@ -883,7 +886,7 @@ t_snabbkaffe_buffered_messages(Config) ->
#{ ?snk_kind := ps_resume_end }),
spawn_link(fun() ->
?block_until(#{?snk_kind := ps_marker_pendings_msgs}, infinity, 5000),
publish(Topic, Payloads2)
publish(Topic, Payloads2, true)
end),
{ok, Client2} = emqtt:start_link([{clean_start, false} | EmqttOpts]),
{ok, _} = emqtt:ConnFun(Client2),