From 6ed3dbd39b1e0c0fdee743ed404c6f840bf2aa04 Mon Sep 17 00:00:00 2001 From: Tobias Lindahl Date: Mon, 6 Dec 2021 12:40:58 +0100 Subject: [PATCH] test(persistent_session_SUITE): protect against non-atom sinks --- apps/emqx/test/emqx_persistent_session_SUITE.erl | 6 +++++- 1 file changed, 5 insertions(+), 1 deletion(-) diff --git a/apps/emqx/test/emqx_persistent_session_SUITE.erl b/apps/emqx/test/emqx_persistent_session_SUITE.erl index 756f7bb97..0fa73ebe2 100644 --- a/apps/emqx/test/emqx_persistent_session_SUITE.erl +++ b/apps/emqx/test/emqx_persistent_session_SUITE.erl @@ -768,7 +768,7 @@ t_lost_messages_because_of_gc(Config) -> check_snabbkaffe_vanilla(Trace) -> ResumeTrace = [T || #{?snk_kind := K} = T <- Trace, - re:run(atom_to_list(K), "^ps_") /= nomatch], + re:run(to_list(K), "^ps_") /= nomatch], ?assertMatch([_|_], ResumeTrace), [_Sid] = lists:usort(?projection(sid, ResumeTrace)), %% Check internal flow of the emqx_cm resuming @@ -811,6 +811,10 @@ check_snabbkaffe_vanilla(Trace) -> [Markers] = ?projection(markers, ?of_kind(ps_node_markers, Trace)), ?assertMatch([_], Markers). +to_list(L) when is_list(L) -> L; +to_list(A) when is_atom(A) -> atom_to_list(A); +to_list(B) when is_binary(B) -> binary_to_list(B). + %%-------------------------------------------------------------------- %% Snabbkaffe tests %%--------------------------------------------------------------------