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

Merge pull request #12149 from zhongwencool/audit-boots-log 

fix: incorrect behavior in audit logs during stop and start of EMQX
This commit is contained in:
zhongwencool 2023-12-13 09:13:51 +08:00 committed by GitHub
parent a1cd1f7c63 e2e7f96515
commit 8e34d185ac
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
2 changed files with 33 additions and 21 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

22
apps/emqx_ctl/src/emqx_ctl.erl
View File

@ -336,18 +336,25 @@ audit_log(Level, From, Log) ->
{error, _} ->
ignore;
{ok, {Mod, Fun}} ->
case prune_unnecessary_log(Log) of
false -> ok;
{ok, Log1} -> apply_audit_command(Log1, Mod, Fun, Level, From)
end
end.
apply_audit_command(Log, Mod, Fun, Level, From) ->
try
apply(Mod, Fun, [Level, From, normalize_audit_log_args(Log)])
apply(Mod, Fun, [Level, From, Log])
catch
_:{aborted, {no_exists, emqx_audit}} ->
case Log of
#{cmd := cluster, args := ["leave"]} ->
#{cmd := cluster, args := [<<"leave">>]} ->
ok;
_ ->
?LOG_ERROR(#{
msg => "ctl_command_crashed",
reason => "emqx_audit table not found",
log => normalize_audit_log_args(Log),
log => Log,
from => From
})
end;
@ -356,10 +363,15 @@ audit_log(Level, From, Log) ->
msg => "ctl_command_crashed",
stacktrace => Stacktrace,
reason => Reason,
log => normalize_audit_log_args(Log),
log => Log,
from => From
})
end
end.
prune_unnecessary_log(Log) ->
case normalize_audit_log_args(Log) of
#{args := [<<"emqx:is_running()">>]} -> false;
Log1 -> {ok, Log1}
end.
audit_level(ok, _Duration) -> info;

2
apps/emqx_machine/src/emqx_machine_terminator.erl
View File

@ -69,7 +69,7 @@ graceful() ->
graceful_wait() ->
?AUDIT(alert, #{
cmd => emqx,
args => ["stop"],
args => [<<"stop">>],
version => emqx_release:version(),
from => cli,
duration_ms => element(1, erlang:statistics(wall_clock))