Fix bugs in test cases

This commit is contained in:
周子博 2018-09-08 11:49:20 +08:00
parent c8361124ae
commit 08bab7efa4
6 changed files with 9 additions and 8 deletions

View File

@ -32,13 +32,13 @@ TEST_ERLC_OPTS += +'{parse_transform, lager_transform}'
EUNIT_OPTS = verbose EUNIT_OPTS = verbose
# CT_SUITES = emqx_mqueue # CT_SUITES = emqx_frame
## emqx_trie emqx_router emqx_frame emqx_mqtt_compat ## emqx_trie emqx_router emqx_frame emqx_mqtt_compat
CT_SUITES = emqx emqx_banned emqx_connection emqx_session emqx_access emqx_broker emqx_cm emqx_frame emqx_guid emqx_inflight \ CT_SUITES = emqx emqx_zone emqx_banned emqx_connection emqx_session emqx_access emqx_broker emqx_cm emqx_frame emqx_guid emqx_inflight \
emqx_json emqx_keepalive emqx_lib emqx_metrics emqx_misc emqx_mod emqx_mqtt_caps \ emqx_json emqx_keepalive emqx_lib emqx_metrics emqx_misc emqx_mod emqx_mqtt_caps \
emqx_mqtt_compat emqx_mqtt_props emqx_mqueue emqx_net emqx_pqueue emqx_router emqx_sm \ emqx_mqtt_compat emqx_mqtt_props emqx_mqueue emqx_net emqx_pqueue emqx_router emqx_sm \
emqx_stats emqx_tables emqx_time emqx_topic emqx_trie emqx_vm emqx_zone \ emqx_stats emqx_tables emqx_time emqx_topic emqx_trie emqx_vm \
emqx_mountpoint emqx_listeners emqx_protocol emqx_mountpoint emqx_listeners emqx_protocol
CT_OPTS = -cover test/ct.cover.spec -erl_args -name emqxct@127.0.0.1 CT_OPTS = -cover test/ct.cover.spec -erl_args -name emqxct@127.0.0.1

View File

@ -38,4 +38,5 @@ t_banned_all(_) ->
timer:sleep(100), timer:sleep(100),
?assert(emqx_banned:check(#{client_id => <<"TestClient">>, username => undefined, peername => {undefined, undefined}})), ?assert(emqx_banned:check(#{client_id => <<"TestClient">>, username => undefined, peername => {undefined, undefined}})),
emqx_banned:del({client_id, <<"TestClient">>}), emqx_banned:del({client_id, <<"TestClient">>}),
?assertNot(emqx_banned:check(#{client_id => <<"TestClient">>, username => undefined, peername => {undefined, undefined}})). ?assertNot(emqx_banned:check(#{client_id => <<"TestClient">>, username => undefined, peername => {undefined, undefined}})),
emqx_ct_broker_helpers:run_teardown_steps().

View File

@ -28,7 +28,6 @@
all() -> all() ->
[{group, pubsub}, [{group, pubsub},
{group, session}, {group, session},
{group, broker},
{group, metrics}, {group, metrics},
{group, stats}, {group, stats},
{group, alarms}]. {group, alarms}].

View File

@ -393,7 +393,7 @@ parse_disconnect(_) ->
?assertEqual({ok, ?DISCONNECT_PACKET(?RC_SUCCESS), <<>>}, parse(<<224, 0>>)). ?assertEqual({ok, ?DISCONNECT_PACKET(?RC_SUCCESS), <<>>}, parse(<<224, 0>>)).
serialize_parse_disconnect(_) -> serialize_parse_disconnect(_) ->
Packet = ?PACKET(?DISCONNECT), Packet = ?DISCONNECT_PACKET(?RC_SUCCESS),
?assertEqual({ok, Packet, <<>>}, parse_serialize(Packet)). ?assertEqual({ok, Packet, <<>>}, parse_serialize(Packet)).
serialize_parse_disconnect_v5(_) -> serialize_parse_disconnect_v5(_) ->

View File

@ -44,7 +44,7 @@ get_last_message() ->
init([ClientId]) -> init([ClientId]) ->
Result = lists:member(?TAB, ets:all()), Result = lists:member(?TAB, ets:all()),
if Result == false -> if Result == false ->
ets:new(?TAB, [set, named_table]); ets:new(?TAB, [set, named_table, public]);
true -> ok true -> ok
end, end,
{ok, {ok,

View File

@ -38,5 +38,6 @@ t_open_close_session(_) ->
emqx_sm:set_session_stats(Session, {open, true}), emqx_sm:set_session_stats(Session, {open, true}),
{open, true} = emqx_sm:get_session_stats(Session), {open, true} = emqx_sm:get_session_stats(Session),
ok = emqx_sm:close_session(SPid), ok = emqx_sm:close_session(SPid),
[] = emqx_sm:lookup_session(<<"client">>). [] = emqx_sm:lookup_session(<<"client">>),
emqx_ct_broker_helpers:run_teardown_steps().