fix(code_style): some elvis complaints
This commit is contained in:
parent
2242bb9376
commit
77c82cf189
|
@ -73,6 +73,8 @@
|
||||||
, terminate/2
|
, terminate/2
|
||||||
]).
|
]).
|
||||||
|
|
||||||
|
-elvis([{elvis_style, god_modules, disable}]).
|
||||||
|
|
||||||
-ifndef(TEST).
|
-ifndef(TEST).
|
||||||
-define(SECS_5M, 300).
|
-define(SECS_5M, 300).
|
||||||
-define(SAMPLING, 10).
|
-define(SAMPLING, 10).
|
||||||
|
@ -235,7 +237,7 @@ start_link() ->
|
||||||
init([]) ->
|
init([]) ->
|
||||||
erlang:process_flag(trap_exit, true),
|
erlang:process_flag(trap_exit, true),
|
||||||
%% the overall counters
|
%% the overall counters
|
||||||
[ok = emqx_metrics:ensure(Metric)|| Metric <- overall_metrics()],
|
[ok = emqx_metrics:ensure(Metric) || Metric <- overall_metrics()],
|
||||||
%% the speed metrics
|
%% the speed metrics
|
||||||
erlang:send_after(timer:seconds(?SAMPLING), self(), ticking),
|
erlang:send_after(timer:seconds(?SAMPLING), self(), ticking),
|
||||||
{ok, #state{overall_rule_speed = #rule_speed{}}}.
|
{ok, #state{overall_rule_speed = #rule_speed{}}}.
|
||||||
|
@ -388,17 +390,19 @@ calculate_speed(CurrVal, #rule_speed{max = MaxSpeed0, last_v = LastVal,
|
||||||
|
|
||||||
%% calculate the max speed since the emqx startup
|
%% calculate the max speed since the emqx startup
|
||||||
MaxSpeed =
|
MaxSpeed =
|
||||||
if MaxSpeed0 >= CurrSpeed -> MaxSpeed0;
|
case MaxSpeed0 >= CurrSpeed of
|
||||||
true -> CurrSpeed
|
true -> MaxSpeed0;
|
||||||
|
false -> CurrSpeed
|
||||||
end,
|
end,
|
||||||
|
|
||||||
%% calculate the average speed in last 5 mins
|
%% calculate the average speed in last 5 mins
|
||||||
{Last5MinSamples, Acc5Min, Last5Min} =
|
{Last5MinSamples, Acc5Min, Last5Min} =
|
||||||
if Tick =< ?SAMPCOUNT_5M ->
|
case Tick =< ?SAMPCOUNT_5M of
|
||||||
|
true ->
|
||||||
Acc = AccSpeed5Min0 + CurrSpeed,
|
Acc = AccSpeed5Min0 + CurrSpeed,
|
||||||
{lists:reverse([CurrSpeed | lists:reverse(Last5MinSamples0)]),
|
{lists:reverse([CurrSpeed | lists:reverse(Last5MinSamples0)]),
|
||||||
Acc, Acc / Tick};
|
Acc, Acc / Tick};
|
||||||
true ->
|
false ->
|
||||||
[FirstSpeed | Speeds] = Last5MinSamples0,
|
[FirstSpeed | Speeds] = Last5MinSamples0,
|
||||||
Acc = AccSpeed5Min0 + CurrSpeed - FirstSpeed,
|
Acc = AccSpeed5Min0 + CurrSpeed - FirstSpeed,
|
||||||
{lists:reverse([CurrSpeed | lists:reverse(Speeds)]),
|
{lists:reverse([CurrSpeed | lists:reverse(Speeds)]),
|
||||||
|
|
Loading…
Reference in New Issue