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

test(quic): make tc run independent

This commit is contained in:
William Yang 2023-03-13 12:08:32 +01:00
parent 4c28b9f839
commit fffb92ebb7
1 changed files with 10 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

17
apps/emqx/test/emqx_quic_multistreams_SUITE.erl
View File

@ -190,6 +190,7 @@ end_per_group(_, Config) ->
init_per_testcase(_, Config) ->
emqx_common_test_helpers:start_apps([]),
start_emqx_quic(?config(port, Config)),
Config.
t_quic_sock(Config) ->
@ -1255,7 +1256,8 @@ t_multi_streams_shutdown_pub_data_stream(Config) ->
}}
],
PubRecvs
).
),
emqtt:stop(C).
t_multi_streams_shutdown_sub_data_stream(Config) ->
PubQos = ?config(pub_qos, Config),
@ -1302,7 +1304,8 @@ t_multi_streams_shutdown_sub_data_stream(Config) ->
#{data_stream_socks := [_PubVia | _]} = proplists:get_value(extra, emqtt:info(C)),
timer:sleep(500),
%% Still alive
?assert(is_list(emqtt:info(C))).
?assert(is_list(emqtt:info(C))),
emqtt:stop(C).
t_multi_streams_shutdown_ctrl_stream(Config) ->
PubQos = ?config(pub_qos, Config),
@ -1406,7 +1409,8 @@ t_multi_streams_shutdown_ctrl_stream_then_reconnect(Config) ->
quicer:shutdown_stream(Ctrlstream, ?config(stream_shutdown_flag, Config), 500, 100),
timer:sleep(200),
%% Client should not be closed
?assert(is_list(emqtt:info(C))).
?assert(is_list(emqtt:info(C))),
emqtt:stop(C).
t_multi_streams_emqx_ctrl_kill(Config) ->
erlang:process_flag(trap_exit, true),
@ -1526,6 +1530,7 @@ t_multi_streams_remote_shutdown(Config) ->
{ok, C} = emqtt:start_link([
{proto_ver, v5},
{reconnect, false},
{clientid, atom_to_binary(?FUNCTION_NAME)},
%% speedup test
{connect_timeout, 5}
| Config
@ -1563,7 +1568,6 @@ t_multi_streams_remote_shutdown(Config) ->
{quic, _Conn, _Ctrlstream} = proplists:get_value(socket, emqtt:info(C)),
ok = stop_emqx(),
start_emqx_quic(?config(port, Config)),
%% Client should be closed
assert_client_die(C).
@ -1620,10 +1624,9 @@ t_multi_streams_remote_shutdown_with_reconnect(Config) ->
ok = stop_emqx(),
timer:sleep(200),
start_emqx_quic(?config(port, Config)),
%% Client should be closed
?assert(is_list(emqtt:info(C))).
?assert(is_list(emqtt:info(C))),
emqtt:stop(C).
t_conn_silent_close(Config) ->
erlang:process_flag(trap_exit, true),