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

fix(sessds): Add debug logs for the session garbage collection

This commit is contained in:
ieQu1 2023-12-06 15:36:51 +01:00
parent 89c7de9a5e
commit c43b3eb535
2 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
apps/emqx/src/emqx_persistent_session_ds_gc_worker.erl
View File

@ -82,7 +82,7 @@ try_gc() ->
CoreNodes = mria_membership:running_core_nodelist(), CoreNodes = mria_membership:running_core_nodelist(),
Res = global:trans( Res = global:trans(
{?MODULE, self()}, {?MODULE, self()},
fun() -> ?tp_span(ds_session_gc, #{}, start_gc()) end, fun() -> ?tp_span(debug, ds_session_gc, #{}, start_gc()) end,
CoreNodes, CoreNodes,
%% Note: we set retries to 1 here because, in rare occasions, GC might start at the %% Note: we set retries to 1 here because, in rare occasions, GC might start at the
%% same time in more than one node, and each one will abort the other. By allowing %% same time in more than one node, and each one will abort the other. By allowing

2
apps/emqx_durable_storage/src/emqx_ds.erl
View File

@ -195,7 +195,7 @@ store_batch(DB, Msgs) ->
%% replay. This function returns stream together with its %% replay. This function returns stream together with its
%% "coordinate": `stream_rank()'. %% "coordinate": `stream_rank()'.
%% %%
%% Stream rank is a tuple of two integers, let's call them X and Y. If %% Stream rank is a tuple of two terms, let's call them X and Y. If
%% X coordinate of two streams is different, they are independent and %% X coordinate of two streams is different, they are independent and
%% can be replayed in parallel. If it's the same, then the stream with %% can be replayed in parallel. If it's the same, then the stream with
%% smaller Y coordinate should be replayed first. If Y coordinates are %% smaller Y coordinate should be replayed first. If Y coordinates are