From 1355f7c887f5a6985c734ad7d449a48b0836b363 Mon Sep 17 00:00:00 2001 From: firest Date: Fri, 6 May 2022 18:50:26 +0800 Subject: [PATCH] fix(retainer): fix test case and xref error --- apps/emqx/src/emqx_limiter/src/emqx_limiter_manager.erl | 4 ++-- apps/emqx_retainer/test/emqx_retainer_SUITE.erl | 4 ++-- 2 files changed, 4 insertions(+), 4 deletions(-) diff --git a/apps/emqx/src/emqx_limiter/src/emqx_limiter_manager.erl b/apps/emqx/src/emqx_limiter/src/emqx_limiter_manager.erl index 4888368e0..efd89236b 100644 --- a/apps/emqx/src/emqx_limiter/src/emqx_limiter_manager.erl +++ b/apps/emqx/src/emqx_limiter/src/emqx_limiter_manager.erl @@ -135,7 +135,7 @@ start_link() -> | {stop, Reason :: term()} | ignore. init([]) -> - emqx_conf:add_handler([limiter], ?MODULE), + ok = emqx_config_handler:add_handler([limiter], ?MODULE), _ = ets:new(?TAB, [ set, public, @@ -210,7 +210,7 @@ handle_info(Info, State) -> State :: term() ) -> any(). terminate(_Reason, _State) -> - emqx_conf:remove_handler([limiter]), + emqx_config_handler:remove_handler([limiter]), ok. %%-------------------------------------------------------------------- diff --git a/apps/emqx_retainer/test/emqx_retainer_SUITE.erl b/apps/emqx_retainer/test/emqx_retainer_SUITE.erl index f207bdd04..953752788 100644 --- a/apps/emqx_retainer/test/emqx_retainer_SUITE.erl +++ b/apps/emqx_retainer/test/emqx_retainer_SUITE.erl @@ -359,7 +359,7 @@ t_flow_control(_) -> } }, emqx_config:put([limiter, batch, bucket, retainer], RetainerCfg2), - emqx_limiter_manager:restart_server(shared), + emqx_limiter_manager:restart_server(batch), timer:sleep(500), emqx_retainer_dispatcher:refresh_limiter(), @@ -408,7 +408,7 @@ t_flow_control(_) -> %% recover the limiter emqx_config:put([limiter, batch, bucket, retainer], RetainerCfg), - emqx_limiter_manager:restart_server(shared), + emqx_limiter_manager:restart_server(batch), timer:sleep(500), emqx_retainer_dispatcher:refresh_limiter(),