diff --git a/apps/emqx/test/emqx_cm_SUITE.erl b/apps/emqx/test/emqx_cm_SUITE.erl index 4ff8d501e..f28fd6bd8 100644 --- a/apps/emqx/test/emqx_cm_SUITE.erl +++ b/apps/emqx/test/emqx_cm_SUITE.erl @@ -283,6 +283,7 @@ flush_emqx_pool() -> t_discard_session_race(_) -> ClientId = rand_client_id(), ?check_trace( + #{timetrap => 60000}, begin #{conninfo := ConnInfo0} = ?ChanInfo, ConnInfo = ConnInfo0#{conn_mod := emqx_ws_connection}, @@ -290,12 +291,9 @@ t_discard_session_race(_) -> ok = emqx_cm:register_channel(ClientId, Pid, ConnInfo), Pid ! stop, receive {'DOWN', Ref, process, Pid, normal} -> ok end, - ok = emqx_cm:discard_session(ClientId), - {ok, _} = ?block_until(#{?snk_kind := "session_already_gone", pid := Pid}, 1000) + ?assertMatch(ok, emqx_cm:discard_session(ClientId)) end, - fun(_, _) -> - true - end). + []). t_takeover_session(_) -> #{conninfo := ConnInfo} = ?ChanInfo,