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

Fix error for test case

This commit is contained in:
zhanghongtong 2020-01-09 10:45:02 +08:00 committed by turtleDeng
parent fdeade3212
commit 693bd493f0
1 changed files with 7 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
test/mqtt_protocol_v5_SUITE.erl
View File

@ -119,6 +119,7 @@ t_connect_limit_timeout(_) ->
timer:sleep(200), timer:sleep(200),
?assert(is_reference(emqx_connection:info(limit_timer, sys:get_state(ClientPid)))), ?assert(is_reference(emqx_connection:info(limit_timer, sys:get_state(ClientPid)))),
emqtt:disconnect(Client),
meck:unload(proplists). meck:unload(proplists).
t_connect_emit_stats_timeout(_) -> t_connect_emit_stats_timeout(_) ->
@ -133,7 +134,8 @@ t_connect_emit_stats_timeout(_) ->
pong = emqtt:ping(Client), pong = emqtt:ping(Client),
?assert(is_reference(emqx_connection:info(stats_timer, sys:get_state(ClientPid)))), ?assert(is_reference(emqx_connection:info(stats_timer, sys:get_state(ClientPid)))),
timer:sleep(timer:seconds(IdleTimeout)), timer:sleep(timer:seconds(IdleTimeout)),
?assertEqual(undefined, emqx_connection:info(stats_timer, sys:get_state(ClientPid))). ?assertEqual(undefined, emqx_connection:info(stats_timer, sys:get_state(ClientPid))),
emqtt:disconnect(Client).
%% [MQTT-3.1.2-22] %% [MQTT-3.1.2-22]
t_connect_keepalive_timeout(_) -> t_connect_keepalive_timeout(_) ->
@ -156,6 +158,7 @@ t_connect_keepalive_timeout(_) ->
%%-------------------------------------------------------------------- %%--------------------------------------------------------------------
t_shared_subscriptions_client_terminates_when_qos_eq_2(_) -> t_shared_subscriptions_client_terminates_when_qos_eq_2(_) ->
process_flag(trap_exit, true),
application:set_env(emqx, shared_dispatch_ack_enabled, true), application:set_env(emqx, shared_dispatch_ack_enabled, true),
Topic = nth(1, ?TOPICS), Topic = nth(1, ?TOPICS),
@ -184,5 +187,7 @@ t_shared_subscriptions_client_terminates_when_qos_eq_2(_) ->
{ok, _} = emqtt:connect(Pub), {ok, _} = emqtt:connect(Pub),
{ok, _} = emqtt:publish(Pub, Topic, <<"t_shared_subscriptions_client_terminates_when_qos_eq_2">>, 2), {ok, _} = emqtt:publish(Pub, Topic, <<"t_shared_subscriptions_client_terminates_when_qos_eq_2">>, 2),
timer:sleep(200), receive
{disconnected,shutdown,for_testiong} -> ok
end,
?assertEqual(1, counters:get(CRef, 1)). ?assertEqual(1, counters:get(CRef, 1)).