diff --git a/Makefile b/Makefile index 35c2c0bee..0b9e6cc3e 100644 --- a/Makefile +++ b/Makefile @@ -27,17 +27,17 @@ TEST_ERLC_OPTS += +debug_info -DAPPLICATION=emqx EUNIT_OPTS = verbose -CT_SUITES = emqx_bridge +# CT_SUITES = emqx_bridge ## emqx_trie emqx_router emqx_frame emqx_mqtt_compat -# CT_SUITES = emqx emqx_client emqx_zone emqx_banned emqx_session \ -# emqx_access emqx_broker emqx_cm emqx_frame emqx_guid emqx_inflight emqx_json \ -# emqx_keepalive emqx_lib emqx_metrics emqx_mod emqx_mod_sup emqx_mqtt_caps \ -# emqx_mqtt_props emqx_mqueue emqx_net emqx_pqueue emqx_router emqx_sm \ -# emqx_tables emqx_time emqx_topic emqx_trie emqx_vm emqx_mountpoint \ -# emqx_listeners emqx_protocol emqx_pool emqx_shared_sub emqx_bridge \ -# emqx_hooks emqx_batch emqx_sequence emqx_pmon emqx_pd emqx_gc emqx_ws_connection \ -# emqx_packet emqx_connection emqx_tracer emqx_sys_mon emqx_message +CT_SUITES = emqx emqx_client emqx_zone emqx_banned emqx_session \ + emqx_access emqx_broker emqx_cm emqx_frame emqx_guid emqx_inflight emqx_json \ + emqx_keepalive emqx_lib emqx_metrics emqx_mod emqx_mod_sup emqx_mqtt_caps \ + emqx_mqtt_props emqx_mqueue emqx_net emqx_pqueue emqx_router emqx_sm \ + emqx_tables emqx_time emqx_topic emqx_trie emqx_vm emqx_mountpoint \ + emqx_listeners emqx_protocol emqx_pool emqx_shared_sub emqx_bridge \ + emqx_hooks emqx_batch emqx_sequence emqx_pmon emqx_pd emqx_gc emqx_ws_connection \ + emqx_packet emqx_connection emqx_tracer emqx_sys_mon emqx_message CT_NODE_NAME = emqxct@127.0.0.1 CT_OPTS = -cover test/ct.cover.spec -erl_args -name $(CT_NODE_NAME) diff --git a/test/emqx_bridge_SUITE.erl b/test/emqx_bridge_SUITE.erl index 465b20637..238871d05 100644 --- a/test/emqx_bridge_SUITE.erl +++ b/test/emqx_bridge_SUITE.erl @@ -29,8 +29,7 @@ all() -> [t_rpc, t_mqtt, - t_mngr - ]. + t_mngr]. init_per_suite(Config) -> case node() of @@ -91,8 +90,10 @@ t_rpc(Config) when is_list(Config) -> PacketId = 1, emqx_session:publish(SPid, PacketId, Msg1), ?wait(case emqx_mock_client:get_last_message(ConnPid) of - {publish, PacketId, #message{topic = <<"forwarded/t_rpc/one">>}} -> true; - Other -> Other + [{publish, PacketId, #message{topic = <<"forwarded/t_rpc/one">>}}] -> + true; + Other -> + Other end, 4000), emqx_mock_client:close_session(ConnPid) after diff --git a/test/emqx_ct_helpers.erl b/test/emqx_ct_helpers.erl index 361a6b4a9..2f35f42cc 100644 --- a/test/emqx_ct_helpers.erl +++ b/test/emqx_ct_helpers.erl @@ -20,7 +20,7 @@ ensure_mnesia_stopped() -> ekka_mnesia:ensure_stopped(), ekka_mnesia:delete_schema(). -%% Help function to wait for Fun to yeild 'true'. +%% Help function to wait for Fun to yield 'true'. wait_for(Fn, Ln, F, Timeout) -> {Pid, Mref} = erlang:spawn_monitor(fun() -> wait_loop(F, catch_call(F)) end), wait_for_down(Fn, Ln, Timeout, Pid, Mref, false). @@ -66,4 +66,3 @@ catch_call(F) -> C : E : S -> {crashed, {C, E, S}} end. -