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

feat(queue): use tp to trace new lease events

This commit is contained in:
Ilya Averyanov 2024-06-20 21:12:15 +03:00
parent 1205e34650
commit 979fb58e50
1 changed files with 1 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
apps/emqx/src/emqx_persistent_session_ds/emqx_persistent_session_ds_shared_subs.erl
View File

@ -101,13 +101,7 @@ renew_streams(S0, #{agent := Agent0} = SharedSubS0) ->
{StreamLeaseEvents, Agent1} = emqx_persistent_session_ds_shared_subs_agent:renew_streams( {StreamLeaseEvents, Agent1} = emqx_persistent_session_ds_shared_subs_agent:renew_streams(
Agent0 Agent0
), ),
StreamLeaseEvents =/= [] andalso ?tp(info, shared_subs_new_stream_lease_events, #{stream_lease_events => StreamLeaseEvents}),
?SLOG(
info, #{
msg => shared_subs_new_stream_lease_events, stream_lease_events => StreamLeaseEvents
}
),
% StreamLeaseEvents =/= [] andalso ct:print("StreamLeaseEvents: ~p~n", [StreamLeaseEvents]),
S1 = lists:foldl( S1 = lists:foldl(
fun fun
(#{type := lease} = Event, S) -> accept_stream(Event, S); (#{type := lease} = Event, S) -> accept_stream(Event, S);