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

Add timestamp for alarm

This commit is contained in:
zhouzb 2020-05-22 17:27:52 +08:00
parent 997b0018f5
commit 56dccd2ce5
1 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
src/emqx_alarm_handler.erl
View File

@ -114,7 +114,7 @@ handle_event({set_alarm, Alarm = {AlarmId, AlarmDesc}}, State) ->
{error, Reason} -> {error, Reason} ->
?LOG(error, "Failed to encode alarm: ~p", [Reason]) ?LOG(error, "Failed to encode alarm: ~p", [Reason])
end, end,
set_alarm_(AlarmId, AlarmDesc), set_alarm_(AlarmId, AlarmDesc, erlang:system_time(second)),
{ok, State}; {ok, State};
handle_event({clear_alarm, AlarmId}, State) -> handle_event({clear_alarm, AlarmId}, State) ->
?LOG(info, "Clear Alarm: ~p", [AlarmId]), ?LOG(info, "Clear Alarm: ~p", [AlarmId]),
@ -187,8 +187,8 @@ maybe_to_binary(Data) when is_binary(Data) ->
maybe_to_binary(Data) -> maybe_to_binary(Data) ->
iolist_to_binary(io_lib:format("~p", [Data])). iolist_to_binary(io_lib:format("~p", [Data])).
set_alarm_(Id, Desc) -> set_alarm_(Id, Desc, Ts) ->
mnesia:dirty_write(?ALARM_TAB, #common_alarm{id = Id, desc = Desc}). mnesia:dirty_write(?ALARM_TAB, #common_alarm{id = Id, desc = {Desc, Ts}}).
clear_alarm_(Id) -> clear_alarm_(Id) ->
case mnesia:dirty_read(?ALARM_TAB, Id) of case mnesia:dirty_read(?ALARM_TAB, Id) of