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

fix(topic metrics): calculate the rate correctly

This commit is contained in:
zhouzb 2020-10-21 11:07:09 +08:00 committed by tigercl
parent 2feeb4d91f
commit b927bb7af6
1 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
src/emqx_mod_topic_metrics.erl
View File

@ -278,7 +278,7 @@ handle_info(ticking, State = #state{speeds = Speeds}) ->
Val -> calculate_speed(Val, Speed) Val -> calculate_speed(Val, Speed)
end end
end, Speeds), end, Speeds),
erlang:send_after(timer:seconds(5), self(), ticking), erlang:send_after(timer:seconds(?TICKING_INTERVAL), self(), ticking),
{noreply, State#state{speeds = NSpeeds}}; {noreply, State#state{speeds = NSpeeds}};
handle_info(Info, State) -> handle_info(Info, State) ->
@ -363,7 +363,7 @@ calculate_speed(CurVal, #speed{last_v = LastVal, tick = Tick, acc = Acc, samples
CurSpeed = (CurVal - LastVal) / ?TICKING_INTERVAL, CurSpeed = (CurVal - LastVal) / ?TICKING_INTERVAL,
%% calculate the average speed in last 5 seconds %% calculate the average speed in last 5 seconds
case Tick =< 5 of case Tick < 5 of
true -> true ->
Acc1 = Acc + CurSpeed, Acc1 = Acc + CurSpeed,
#speed{last = Acc1 / Tick, #speed{last = Acc1 / Tick,