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

Change rate limit pausing logs to warning

This commit is contained in:
terry-xiaoyu 2020-02-21 12:15:07 +08:00 committed by JianBo He
parent 9b6a8ebe84
commit 6b5a8949c5
2 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
src/emqx_connection.erl
View File

@ -617,7 +617,7 @@ ensure_rate_limit(Stats, State = #state{limiter = Limiter}) ->
{ok, Limiter1} -> {ok, Limiter1} ->
State#state{limiter = Limiter1}; State#state{limiter = Limiter1};
{pause, Time, Limiter1} -> {pause, Time, Limiter1} ->
?LOG(debug, "Pause ~pms due to rate limit", [Time]), ?LOG(warning, "Pause ~pms due to rate limit", [Time]),
TRef = start_timer(Time, limit_timeout), TRef = start_timer(Time, limit_timeout),
State#state{sockstate = blocked, State#state{sockstate = blocked,
limiter = Limiter1, limiter = Limiter1,

2
src/emqx_ws_connection.erl
View File

@ -414,7 +414,7 @@ ensure_rate_limit(Stats, State = #state{limiter = Limiter}) ->
{ok, Limiter1} -> {ok, Limiter1} ->
State#state{limiter = Limiter1}; State#state{limiter = Limiter1};
{pause, Time, Limiter1} -> {pause, Time, Limiter1} ->
?LOG(debug, "Pause ~pms due to rate limit", [Time]), ?LOG(warning, "Pause ~pms due to rate limit", [Time]),
TRef = start_timer(Time, limit_timeout), TRef = start_timer(Time, limit_timeout),
NState = State#state{sockstate = blocked, NState = State#state{sockstate = blocked,
limiter = Limiter1, limiter = Limiter1,