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

fix(retainer): fix test case and xref error

This commit is contained in:
firest 2022-05-06 18:50:26 +08:00
parent a4a9650e66
commit 1355f7c887
2 changed files with 4 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
apps/emqx/src/emqx_limiter/src/emqx_limiter_manager.erl
View File

@ -135,7 +135,7 @@ start_link() ->
| {stop, Reason :: term()} | {stop, Reason :: term()}
| ignore. | ignore.
init([]) -> init([]) ->
emqx_conf:add_handler([limiter], ?MODULE), ok = emqx_config_handler:add_handler([limiter], ?MODULE),
_ = ets:new(?TAB, [ _ = ets:new(?TAB, [
set, set,
public, public,
@ -210,7 +210,7 @@ handle_info(Info, State) ->
State :: term() State :: term()
) -> any(). ) -> any().
terminate(_Reason, _State) -> terminate(_Reason, _State) ->
emqx_conf:remove_handler([limiter]), emqx_config_handler:remove_handler([limiter]),
ok. ok.
%%-------------------------------------------------------------------- %%--------------------------------------------------------------------

4
apps/emqx_retainer/test/emqx_retainer_SUITE.erl
View File

@ -359,7 +359,7 @@ t_flow_control(_) ->
} }
}, },
emqx_config:put([limiter, batch, bucket, retainer], RetainerCfg2), emqx_config:put([limiter, batch, bucket, retainer], RetainerCfg2),
emqx_limiter_manager:restart_server(shared), emqx_limiter_manager:restart_server(batch),
timer:sleep(500), timer:sleep(500),
emqx_retainer_dispatcher:refresh_limiter(), emqx_retainer_dispatcher:refresh_limiter(),
@ -408,7 +408,7 @@ t_flow_control(_) ->
%% recover the limiter %% recover the limiter
emqx_config:put([limiter, batch, bucket, retainer], RetainerCfg), emqx_config:put([limiter, batch, bucket, retainer], RetainerCfg),
emqx_limiter_manager:restart_server(shared), emqx_limiter_manager:restart_server(batch),
timer:sleep(500), timer:sleep(500),
emqx_retainer_dispatcher:refresh_limiter(), emqx_retainer_dispatcher:refresh_limiter(),