Pārlūkot izejas kodu

get/2 was confusing: Sink, Key or Key, Default. Clean up by forcing into {Sink, Key} tuple

pull/264/head
John R. Daily pirms 10 gadiem
vecāks
revīzija
2926dd51a1
2 mainītis faili ar 17 papildinājumiem un 17 dzēšanām
  1. +8
    -8
      src/lager.erl
  2. +9
    -9
      src/lager_config.erl

+ 8
- 8
src/lager.erl Parādīt failu

@ -90,7 +90,7 @@ dispatch_log(Severity, Metadata, Format, Args, Size) when is_atom(Severity)->
%% this is the same check that the parse transform bakes into the module at compile time %% this is the same check that the parse transform bakes into the module at compile time
dispatch_log(Sink, Severity, Metadata, Format, Args, Size) when is_atom(Severity)-> dispatch_log(Sink, Severity, Metadata, Format, Args, Size) when is_atom(Severity)->
SeverityAsInt=lager_util:level_to_num(Severity), SeverityAsInt=lager_util:level_to_num(Severity),
case {whereis(Sink), lager_config:get(Sink, loglevel, {?LOG_NONE, []})} of
case {whereis(Sink), lager_config:get({Sink, loglevel}, {?LOG_NONE, []})} of
{undefined, _} -> {undefined, _} ->
{error, lager_not_running}; {error, lager_not_running};
{SinkPid, {Level, Traces}} when (Level band SeverityAsInt) /= 0 orelse Traces /= [] -> {SinkPid, {Level, Traces}} when (Level band SeverityAsInt) /= 0 orelse Traces /= [] ->
@ -117,7 +117,7 @@ do_log(Severity, Metadata, Format, Args, Size, SeverityAsInt, LevelThreshold, Tr
end, end,
LagerMsg = lager_msg:new(Msg, LagerMsg = lager_msg:new(Msg,
Severity, Metadata, Destinations), Severity, Metadata, Destinations),
case lager_config:get(Sink, async, false) of %% this needs to be able to get value from a non-default sink
case lager_config:get({Sink, async}, false) of %% this needs to be able to get value from a non-default sink
true -> true ->
gen_event:notify(SinkPid, {log, LagerMsg}); gen_event:notify(SinkPid, {log, LagerMsg});
false -> false ->
@ -250,11 +250,11 @@ stop_trace({Backend, Filter, Level}) ->
stop_trace(Backend, Filter, Level). stop_trace(Backend, Filter, Level).
stop_trace_int({Backend, _Filter, _Level} = Trace, Sink) -> stop_trace_int({Backend, _Filter, _Level} = Trace, Sink) ->
{Level, Traces} = lager_config:get(Sink, loglevel),
{Level, Traces} = lager_config:get({Sink, loglevel}),
NewTraces = lists:delete(Trace, Traces), NewTraces = lists:delete(Trace, Traces),
_ = lager_util:trace_filter([ element(1, T) || T <- NewTraces ]), _ = lager_util:trace_filter([ element(1, T) || T <- NewTraces ]),
%MinLevel = minimum_loglevel(get_loglevels() ++ get_trace_levels(NewTraces)), %MinLevel = minimum_loglevel(get_loglevels() ++ get_trace_levels(NewTraces)),
lager_config:set(Sink, loglevel, {Level, NewTraces}),
lager_config:set({Sink, loglevel}, {Level, NewTraces}),
case get_loglevel(Sink, Backend) of case get_loglevel(Sink, Backend) of
none -> none ->
%% check no other traces point here %% check no other traces point here
@ -389,21 +389,21 @@ get_loglevels(Sink) ->
%% @private %% @private
add_trace_to_loglevel_config(Trace, Sink) -> add_trace_to_loglevel_config(Trace, Sink) ->
{MinLevel, Traces} = lager_config:get(Sink, loglevel),
{MinLevel, Traces} = lager_config:get({Sink, loglevel}),
case lists:member(Trace, Traces) of case lists:member(Trace, Traces) of
false -> false ->
NewTraces = [Trace|Traces], NewTraces = [Trace|Traces],
_ = lager_util:trace_filter([ element(1, T) || T <- NewTraces]), _ = lager_util:trace_filter([ element(1, T) || T <- NewTraces]),
lager_config:set(Sink, loglevel, {MinLevel, [Trace|Traces]});
lager_config:set({Sink, loglevel}, {MinLevel, [Trace|Traces]});
_ -> _ ->
ok ok
end. end.
%% @doc recalculate min log level %% @doc recalculate min log level
update_loglevel_config(Sink) -> update_loglevel_config(Sink) ->
{_, Traces} = lager_config:get(Sink, loglevel),
{_, Traces} = lager_config:get({Sink, loglevel}),
MinLog = minimum_loglevel(get_loglevels(Sink)), MinLog = minimum_loglevel(get_loglevels(Sink)),
lager_config:set(Sink, loglevel, {MinLog, Traces}).
lager_config:set({Sink, loglevel}, {MinLog, Traces}).
%% @private %% @private
minimum_loglevel(Levels) -> minimum_loglevel(Levels) ->

+ 9
- 9
src/lager_config.erl Parādīt failu

@ -20,7 +20,7 @@
-include("lager.hrl"). -include("lager.hrl").
-export([new/0, get/1, get/2, get/3, set/2, set/3,
-export([new/0, get/1, get/2, set/2,
global_get/1, global_get/2, global_set/2]). global_get/1, global_get/2, global_set/2]).
-define(TBL, lager_config). -define(TBL, lager_config).
@ -57,13 +57,11 @@ global_get(Key, Default) ->
global_set(Key, Value) -> global_set(Key, Value) ->
set(?GLOBAL, Key, Value). set(?GLOBAL, Key, Value).
get(Key) ->
get(?DEFAULT_SINK, Key, undefined).
get(Key, Default) ->
get(?DEFAULT_SINK, Key, Default).
get(Key) ->
get({?DEFAULT_SINK, Key}, undefined).
get(Sink, Key, Default) ->
get({Sink, Key}, Default) ->
try try
case ets:lookup(?TBL, {Sink, Key}) of case ets:lookup(?TBL, {Sink, Key}) of
[] -> [] ->
@ -74,10 +72,12 @@ get(Sink, Key, Default) ->
catch catch
_:_ -> _:_ ->
Default Default
end.
end;
get(Key, Default) ->
get({?DEFAULT_SINK, Key}, Default).
set(Key, Value) -> set(Key, Value) ->
set(?DEFAULT_SINK, Key, Value).
set({?DEFAULT_SINK, Key}, Value).
set(Sink, Key, Value) ->
set({Sink, Key}, Value) ->
ets:insert(?TBL, {{Sink, Key}, Value}). ets:insert(?TBL, {{Sink, Key}, Value}).

Notiek ielāde…
Atcelt
Saglabāt