Merge pull request #10904 from thalesmg/fix-global-gc-config-get-v50
test(global_gc): fix flaky test
This commit is contained in:
commit
d320497d0c
|
@ -23,14 +23,31 @@
|
||||||
|
|
||||||
all() -> emqx_common_test_helpers:all(?MODULE).
|
all() -> emqx_common_test_helpers:all(?MODULE).
|
||||||
|
|
||||||
|
init_per_suite(Config) ->
|
||||||
|
Config.
|
||||||
|
|
||||||
|
end_per_suite(_Config) ->
|
||||||
|
emqx_config:erase_all(),
|
||||||
|
ok.
|
||||||
|
|
||||||
t_run_gc(_) ->
|
t_run_gc(_) ->
|
||||||
ok = emqx_config:put([node, global_gc_interval], 1000),
|
Conf0 = #{
|
||||||
|
node => #{
|
||||||
|
cookie => <<"cookie">>,
|
||||||
|
data_dir => <<"data">>,
|
||||||
|
global_gc_interval => 1000
|
||||||
|
}
|
||||||
|
},
|
||||||
|
emqx_common_test_helpers:load_config(emqx_conf_schema, Conf0),
|
||||||
|
?assertEqual({ok, 1000}, application:get_env(emqx_machine, global_gc_interval)),
|
||||||
{ok, _} = emqx_global_gc:start_link(),
|
{ok, _} = emqx_global_gc:start_link(),
|
||||||
ok = timer:sleep(1500),
|
ok = timer:sleep(1500),
|
||||||
{ok, MilliSecs} = emqx_global_gc:run(),
|
{ok, MilliSecs} = emqx_global_gc:run(),
|
||||||
ct:print("Global GC: ~w(ms)~n", [MilliSecs]),
|
ct:pal("Global GC: ~w(ms)~n", [MilliSecs]),
|
||||||
emqx_global_gc:stop(),
|
emqx_global_gc:stop(),
|
||||||
ok = emqx_config:put([node, global_gc_interval], disabled),
|
Conf1 = emqx_utils_maps:deep_put([node, global_gc_interval], Conf0, disabled),
|
||||||
|
emqx_common_test_helpers:load_config(emqx_conf_schema, Conf1),
|
||||||
{ok, Pid} = emqx_global_gc:start_link(),
|
{ok, Pid} = emqx_global_gc:start_link(),
|
||||||
?assertMatch(#{timer := undefined}, sys:get_state(Pid)),
|
?assertMatch(#{timer := undefined}, sys:get_state(Pid)),
|
||||||
|
?assertEqual({ok, disabled}, application:get_env(emqx_machine, global_gc_interval)),
|
||||||
ok.
|
ok.
|
||||||
|
|
Loading…
Reference in New Issue