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

test(shared_sub): Increase timeout

This commit is contained in:
ieQu1 2022-07-21 09:59:30 +02:00
parent 489e4fcd74
commit 1a2a8f017c
1 changed files with 6 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
test/emqx_shared_sub_SUITE.erl
View File

@ -284,7 +284,7 @@ test_two_messages(Strategy, Group) ->
ok. ok.
last_message(ExpectedPayload, Pids) -> last_message(ExpectedPayload, Pids) ->
last_message(ExpectedPayload, Pids, 100). last_message(ExpectedPayload, Pids, 6000).
last_message(ExpectedPayload, Pids, Timeout) -> last_message(ExpectedPayload, Pids, Timeout) ->
receive receive
@ -401,10 +401,10 @@ t_local_fallback(_) ->
emqtt:subscribe(ConnPid1, {<<"$share/local_group_fallback/local_foo/bar">>, 0}), emqtt:subscribe(ConnPid1, {<<"$share/local_group_fallback/local_foo/bar">>, 0}),
emqx:publish(Message1), [{share, <<"local_foo/bar">>, {ok, 1}}] = emqx:publish(Message1),
{true, UsedSubPid1} = last_message(<<"hello1">>, [ConnPid1]), {true, UsedSubPid1} = last_message(<<"hello1">>, [ConnPid1]),
rpc:call(Node, emqx, publish, [Message2]), [{share, <<"local_foo/bar">>, {ok, 1}}] = rpc:call(Node, emqx, publish, [Message2]),
{true, UsedSubPid2} = last_message(<<"hello2">>, [ConnPid1]), {true, UsedSubPid2} = last_message(<<"hello2">>, [ConnPid1]),
emqtt:stop(ConnPid1), emqtt:stop(ConnPid1),
@ -537,7 +537,7 @@ start_slave(Name, Port) ->
{erl_flags, ebin_path()}]), {erl_flags, ebin_path()}]),
pong = net_adm:ping(Node), pong = net_adm:ping(Node),
setup_node(Node, Port), ok = setup_node(Node, Port),
Node. Node.
stop_slave(Node) -> stop_slave(Node) ->
@ -573,6 +573,6 @@ setup_node(Node, Port) ->
[ok = rpc:call(Node, application, load, [App]) || App <- [gen_rpc, emqx]], [ok = rpc:call(Node, application, load, [App]) || App <- [gen_rpc, emqx]],
ok = rpc:call(Node, emqx_ct_helpers, start_apps, [[emqx], EnvHandler]), ok = rpc:call(Node, emqx_ct_helpers, start_apps, [[emqx], EnvHandler]),
rpc:call(Node, ekka, join, [node()]), ok = rpc:call(Node, ekka, join, [node()]),
true = lists:member(Node, nodes()),
ok. ok.