refactor: do not emit debug logs on periodic license checks
This commit is contained in:
parent
c15e2f8708
commit
492a591298
|
@ -1,6 +1,7 @@
|
||||||
%%--------------------------------------------------------------------
|
%%--------------------------------------------------------------------
|
||||||
%% Copyright (c) 2022-2023 EMQ Technologies Co., Ltd. All Rights Reserved.
|
%% Copyright (c) 2022-2023 EMQ Technologies Co., Ltd. All Rights Reserved.
|
||||||
%%--------------------------------------------------------------------
|
%%--------------------------------------------------------------------
|
||||||
|
|
||||||
-module(emqx_license).
|
-module(emqx_license).
|
||||||
|
|
||||||
-include("emqx_license.hrl").
|
-include("emqx_license.hrl").
|
||||||
|
|
|
@ -117,7 +117,7 @@ handle_cast(_Msg, State) ->
|
||||||
handle_info(check_license, #{license := License} = State) ->
|
handle_info(check_license, #{license := License} = State) ->
|
||||||
#{} = check_license(License),
|
#{} = check_license(License),
|
||||||
NewState = ensure_check_license_timer(State),
|
NewState = ensure_check_license_timer(State),
|
||||||
?tp(debug, emqx_license_checked, #{}),
|
?tp(emqx_license_checked, #{}),
|
||||||
{noreply, NewState};
|
{noreply, NewState};
|
||||||
handle_info(check_expiry_alarm, #{license := License} = State) ->
|
handle_info(check_expiry_alarm, #{license := License} = State) ->
|
||||||
ok = expiry_early_alarm(License),
|
ok = expiry_early_alarm(License),
|
||||||
|
|
|
@ -74,13 +74,13 @@ ensure_timer(#{interval := Interval} = State) ->
|
||||||
check_pid(#{name := Name, pid := OldPid, callback := Callback} = State) ->
|
check_pid(#{name := Name, pid := OldPid, callback := Callback} = State) ->
|
||||||
case whereis(Name) of
|
case whereis(Name) of
|
||||||
undefined ->
|
undefined ->
|
||||||
?tp(debug, emqx_license_installer_noproc, #{old_pid => OldPid}),
|
?tp(emqx_license_installer_noproc, #{old_pid => OldPid}),
|
||||||
State;
|
State;
|
||||||
OldPid ->
|
OldPid ->
|
||||||
?tp(debug, emqx_license_installer_nochange, #{old_pid => OldPid}),
|
?tp(emqx_license_installer_nochange, #{old_pid => OldPid}),
|
||||||
State;
|
State;
|
||||||
NewPid ->
|
NewPid ->
|
||||||
_ = Callback(),
|
_ = Callback(),
|
||||||
?tp(debug, emqx_license_installer_called, #{old_pid => OldPid}),
|
?tp(info, license_reloaded_after_emqx_app_restart, #{old_pid => OldPid}),
|
||||||
State#{pid => NewPid}
|
State#{pid => NewPid}
|
||||||
end.
|
end.
|
||||||
|
|
|
@ -76,7 +76,7 @@ handle_cast(_Msg, State) ->
|
||||||
handle_info(update_resources, State) ->
|
handle_info(update_resources, State) ->
|
||||||
true = update_resources(),
|
true = update_resources(),
|
||||||
connection_quota_early_alarm(),
|
connection_quota_early_alarm(),
|
||||||
?tp(debug, emqx_license_resources_updated, #{}),
|
?tp(emqx_license_resources_updated, #{}),
|
||||||
{noreply, ensure_timer(State)}.
|
{noreply, ensure_timer(State)}.
|
||||||
|
|
||||||
terminate(_Reason, _State) ->
|
terminate(_Reason, _State) ->
|
||||||
|
|
|
@ -74,12 +74,12 @@ t_update(_Config) ->
|
||||||
Pid1 = spawn_link(fun() -> timer:sleep(100) end),
|
Pid1 = spawn_link(fun() -> timer:sleep(100) end),
|
||||||
register(installer_test, Pid1)
|
register(installer_test, Pid1)
|
||||||
end,
|
end,
|
||||||
#{?snk_kind := emqx_license_installer_called},
|
#{?snk_kind := license_reloaded_after_emqx_app_restart},
|
||||||
1000
|
1000
|
||||||
)
|
)
|
||||||
end,
|
end,
|
||||||
fun(Trace) ->
|
fun(Trace) ->
|
||||||
?assertMatch([_ | _], ?of_kind(emqx_license_installer_called, Trace))
|
?assertMatch([_ | _], ?of_kind(license_reloaded_after_emqx_app_restart, Trace))
|
||||||
end
|
end
|
||||||
).
|
).
|
||||||
|
|
||||||
|
|
Loading…
Reference in New Issue