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

fix(limiter): change limiter log level to debug

This commit is contained in:
firest 2022-06-15 16:01:16 +08:00
parent c147743895
commit 4e05d751c1
3 changed files with 5 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
apps/emqx/src/emqx_connection.erl
View File

@ -956,7 +956,7 @@ check_limiter(
{ok, Limiter2} -> {ok, Limiter2} ->
WhenOk(Data, Msgs, State#state{limiter = Limiter2}); WhenOk(Data, Msgs, State#state{limiter = Limiter2});
{pause, Time, Limiter2} -> {pause, Time, Limiter2} ->
?SLOG(warning, #{ ?SLOG(debug, #{
msg => "pause_time_dueto_rate_limit", msg => "pause_time_dueto_rate_limit",
needs => Needs, needs => Needs,
time_in_ms => Time time_in_ms => Time
@ -1006,7 +1006,7 @@ retry_limiter(#state{limiter = Limiter} = State) ->
} }
); );
{pause, Time, Limiter2} -> {pause, Time, Limiter2} ->
?SLOG(warning, #{ ?SLOG(debug, #{
msg => "pause_time_dueto_rate_limit", msg => "pause_time_dueto_rate_limit",
types => Types, types => Types,
time_in_ms => Time time_in_ms => Time

4
apps/emqx/src/emqx_ws_connection.erl
View File

@ -586,7 +586,7 @@ check_limiter(
{ok, Limiter2} -> {ok, Limiter2} ->
WhenOk(Data, Msgs, State#state{limiter = Limiter2}); WhenOk(Data, Msgs, State#state{limiter = Limiter2});
{pause, Time, Limiter2} -> {pause, Time, Limiter2} ->
?SLOG(warning, #{ ?SLOG(debug, #{
msg => "pause_time_due_to_rate_limit", msg => "pause_time_due_to_rate_limit",
needs => Needs, needs => Needs,
time_in_ms => Time time_in_ms => Time
@ -634,7 +634,7 @@ retry_limiter(#state{limiter = Limiter} = State) ->
} }
); );
{pause, Time, Limiter2} -> {pause, Time, Limiter2} ->
?SLOG(warning, #{ ?SLOG(debug, #{
msg => "pause_time_due_to_rate_limit", msg => "pause_time_due_to_rate_limit",
types => Types, types => Types,
time_in_ms => Time time_in_ms => Time

2
apps/emqx_retainer/src/emqx_retainer_dispatcher.erl
View File

@ -277,7 +277,7 @@ do_deliver(Msgs, DeliverNum, Pid, Topic, Limiter) ->
do_deliver(ToDelivers, Pid, Topic), do_deliver(ToDelivers, Pid, Topic),
do_deliver(Msgs2, DeliverNum, Pid, Topic, Limiter2); do_deliver(Msgs2, DeliverNum, Pid, Topic, Limiter2);
{drop, _} = Drop -> {drop, _} = Drop ->
?SLOG(error, #{ ?SLOG(debug, #{
msg => "retained_message_dropped", msg => "retained_message_dropped",
reason => "reached_ratelimit", reason => "reached_ratelimit",
dropped_count => length(ToDelivers) dropped_count => length(ToDelivers)