|
@ -122,9 +122,10 @@ handleCall(_Msg, _State) -> |
|
|
?ERR(<<"~p call receive unexpect msg ~p ~n ">>, [?MODULE, _Msg]), |
|
|
?ERR(<<"~p call receive unexpect msg ~p ~n ">>, [?MODULE, _Msg]), |
|
|
{reply, ok}. |
|
|
{reply, ok}. |
|
|
|
|
|
|
|
|
handleEvent({mWriteLog, Message}, #state{shaper = Shaper, fmtTer = FmtTer, fmtCfg = FmtCfg} = State) -> |
|
|
|
|
|
|
|
|
handleEvent({mWriteLog, Message}, #state{fBName = _FBName, level = Level, shaper = Shaper, fmtTer = FmtTer, fmtCfg = FmtCfg} = State) -> |
|
|
%case lgUtil:isLoggAble(Message, Level, {lgBkdFile, FBName}) of |
|
|
%case lgUtil:isLoggAble(Message, Level, {lgBkdFile, FBName}) of |
|
|
%true -> |
|
|
|
|
|
|
|
|
case Level band Message#lgMsg.severity /= 0 of |
|
|
|
|
|
true -> |
|
|
#lgMsg{timestamp = Timestamp, severity = Severity} = Message, |
|
|
#lgMsg{timestamp = Timestamp, severity = Severity} = Message, |
|
|
case lgUtil:checkHwm(Shaper) of |
|
|
case lgUtil:checkHwm(Shaper) of |
|
|
{true, _Drop, NewShaper} -> |
|
|
{true, _Drop, NewShaper} -> |
|
@ -145,9 +146,9 @@ handleEvent({mWriteLog, Message}, #state{shaper = Shaper, fmtTer = FmtTer, fmtCf |
|
|
{false, _, NewShaper} -> |
|
|
{false, _, NewShaper} -> |
|
|
{noreply, State#state{shaper = NewShaper}} |
|
|
{noreply, State#state{shaper = NewShaper}} |
|
|
end; |
|
|
end; |
|
|
% _ -> |
|
|
|
|
|
% kpS |
|
|
|
|
|
%end; |
|
|
|
|
|
|
|
|
_ -> |
|
|
|
|
|
kpS |
|
|
|
|
|
end; |
|
|
handleEvent(_Msg, _State) -> |
|
|
handleEvent(_Msg, _State) -> |
|
|
?ERR(<<"~p event receive unexpect msg ~p ~n ">>, [?MODULE, _Msg]), |
|
|
?ERR(<<"~p event receive unexpect msg ~p ~n ">>, [?MODULE, _Msg]), |
|
|
kpS. |
|
|
kpS. |
|
|