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

Merge pull request #7058 from lafirest/fix/hook_remove_error 

fix(emqx_slow_subs): fix upgrade action error
This commit is contained in:
lafirest 2022-02-18 16:44:51 +08:00 committed by GitHub
parent 513942a2d8 1a1415a996
commit f886cd705c
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 10 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

16
apps/emqx_plugin_libs/src/emqx_slow_subs/emqx_slow_subs.erl
View File

@ -192,19 +192,23 @@ code_change({down, _Vsn}, #{config := Cfg} = State, ["4.4.0"]) ->
{ok, State};
code_change(_OldVsn, #{config := Conf} = State, ["4.4.0"]) ->
%% clear old data
HookPoint = 'message.slow_subs_stats',
case emqx_hooks:lookup(HookPoint) of
[Action | _] ->
emqx_hooks:del(HookPoint, Action);
_ ->
ok
end,
Callbacks = emqx_hooks:lookup(HookPoint),
_ = [emqx_hooks:del(HookPoint, Action) ||
{callback, Action, _Filter, _Priority} <- Callbacks],
try
ets:delete_all_objects(?TOPK_TAB)
catch _:_ ->
ok
end,
%% add new table
init_tab(),
[_Sup, SupPid] = erlang:get('$ancestors'),
ets:give_away(?INDEX_TAB, SupPid, undefined),
%% enable
expire_tick(Conf),
load(Conf),
{ok, State};