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

fix(emqx_slow_subs): add default threshold macro

This commit is contained in:
lafirest 2021-12-06 17:22:36 +08:00
parent 48f8c735ea
commit 3f49e3186c
1 changed files with 4 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
src/emqx_slow_subs/emqx_message_latency_stats.erl
View File

@ -23,7 +23,8 @@
-define(NOW, erlang:system_time(millisecond)). -define(NOW, erlang:system_time(millisecond)).
-define(MINIMUM_INSERT_INTERVAL, 1000). -define(MINIMUM_INSERT_INTERVAL, 1000).
-define(MINIMUM_THRESHOLD, 500). -define(MINIMUM_THRESHOLD, 100).
-define(DEFAULT_THRESHOLD, 500).
-define(THRESHOLD_KEY, {?MODULE, threshold}). -define(THRESHOLD_KEY, {?MODULE, threshold}).
-opaque stats() :: #{ ema := emqx_moving_average:ema() -opaque stats() :: #{ ema := emqx_moving_average:ema()
@ -87,7 +88,7 @@ update_threshold(Threshold) ->
Val. Val.
get_threshold() -> get_threshold() ->
persistent_term:get(?THRESHOLD_KEY, ?MINIMUM_THRESHOLD). persistent_term:get(?THRESHOLD_KEY, ?DEFAULT_THRESHOLD).
%%-------------------------------------------------------------------- %%--------------------------------------------------------------------
%% Internal functions %% Internal functions
@ -98,7 +99,7 @@ call_hook(_, _, _, Latency, S)
S; S;
call_hook(ClientId, Now, Type, Latency, #{last_insert_value := LIV} = Stats) -> call_hook(ClientId, Now, Type, Latency, #{last_insert_value := LIV} = Stats) ->
case get_threshold() >= Latency of case Latency =< get_threshold() of
true -> true ->
Stats#{last_access_time := Now}; Stats#{last_access_time := Now};
_ -> _ ->