From f6e6b839275de2d4572ef672e3053c7a50cf8a7e Mon Sep 17 00:00:00 2001 From: Mark Allen Date: Fri, 6 Mar 2015 14:43:42 -0600 Subject: [PATCH] Record some code comments from jrd walk-thru --- src/lager.app.src | 9 ++++++--- src/lager.erl | 2 +- 2 files changed, 7 insertions(+), 4 deletions(-) diff --git a/src/lager.app.src b/src/lager.app.src index e41da8e..e1ed54c 100644 --- a/src/lager.app.src +++ b/src/lager.app.src @@ -44,13 +44,16 @@ %% current one - default is 0 {crash_log_count, 5}, %% Whether to redirect error_logger messages into lager - defaults to true - {error_logger_redirect, true}, + {error_logger_redirect, lager_event}, %% <-- sink name %% How many messages per second to allow from error_logger before we start dropping them {error_logger_hwm, 50}, %% How big the gen_event mailbox can get before it is switched into sync mode - {async_threshold, 20}, + {async_threshold, 20}, %% <-- per sink %% Switch back to async mode, when gen_event mailbox size decrease from `async_threshold' %% to async_threshold - async_threshold_window - {async_threshold_window, 5} + {async_threshold_window, 5}, %% <-- per sink + {sinks, [ + {lager_event, [{async_threshold, 20}, {async_threshold_window, 5}]} + ]}, ]} ]}. diff --git a/src/lager.erl b/src/lager.erl index 6f64813..1fa2869 100644 --- a/src/lager.erl +++ b/src/lager.erl @@ -116,7 +116,7 @@ do_log(Severity, Metadata, Format, Args, Size, SeverityAsInt, LevelThreshold, Tr end, LagerMsg = lager_msg:new(Msg, Severity, Metadata, Destinations), - case lager_config:get(async, false) of + case lager_config:get(Sink, async, false) of %% this needs to be able to get value from a non-default sink true -> gen_event:notify(Pid, {log, LagerMsg}); false ->