Selaa lähdekoodia

Prevent silent dropping of messages when hwm is exceeded

pull/467/head
Rustam Safargalin 6 vuotta sitten
vanhempi
commit
8039e9c484
2 muutettua tiedostoa jossa 4 lisäystä ja 4 poistoa
  1. +2
    -2
      src/error_logger_lager_h.erl
  2. +2
    -2
      src/lager_file_backend.erl

+ 2
- 2
src/error_logger_lager_h.erl Näytä tiedosto

@ -121,8 +121,8 @@ handle_event(Event, #state{sink=Sink, shaper=Shaper} = State) ->
"lager_error_logger_h dropped ~p messages in the last second that exceeded the limit of ~p messages/sec", "lager_error_logger_h dropped ~p messages in the last second that exceeded the limit of ~p messages/sec",
[Drop, Hwm]), [Drop, Hwm]),
eval_gl(Event, State#state{shaper=NewShaper}); eval_gl(Event, State#state{shaper=NewShaper});
{false, _, NewShaper} ->
{ok, State#state{shaper=NewShaper}}
{false, _, #lager_shaper{dropped=D} = NewShaper} ->
{ok, State#state{shaper=NewShaper#lager_shaper{dropped=D+1}}}
end. end.
handle_info({shaper_expired, ?MODULE}, #state{sink=Sink, shaper=Shaper} = State) -> handle_info({shaper_expired, ?MODULE}, #state{sink=Sink, shaper=Shaper} = State) ->

+ 2
- 2
src/lager_file_backend.erl Näytä tiedosto

@ -179,8 +179,8 @@ handle_event({log, Message},
{ok,write(NewState#state{shaper=NewShaper}, {ok,write(NewState#state{shaper=NewShaper},
lager_msg:timestamp(Message), lager_msg:severity_as_int(Message), lager_msg:timestamp(Message), lager_msg:severity_as_int(Message),
Formatter:format(Message,FormatConfig))}; Formatter:format(Message,FormatConfig))};
{false, _, NewShaper} ->
{ok, State#state{shaper=NewShaper}}
{false, _, #lager_shaper{dropped=D} = NewShaper} ->
{ok, State#state{shaper=NewShaper#lager_shaper{dropped=D+1}}}
end; end;
false -> false ->
{ok, State} {ok, State}

Ladataan…
Peruuta
Tallenna