test(ds): Use close_db API
This commit is contained in:
parent
b2f7815a7f
commit
1d3b1868fb
|
@ -185,8 +185,7 @@ t_new_generation_inherit_trie(_Config) ->
|
||||||
%% learned trie.
|
%% learned trie.
|
||||||
ok = emqx_ds_storage_layer:add_generation(?SHARD, _Since = 1_000),
|
ok = emqx_ds_storage_layer:add_generation(?SHARD, _Since = 1_000),
|
||||||
%% Restart the shard, to verify that LTS is persisted.
|
%% Restart the shard, to verify that LTS is persisted.
|
||||||
ok = application:stop(emqx_durable_storage),
|
ok = emqx_ds:close_db(?FUNCTION_NAME),
|
||||||
ok = application:start(emqx_durable_storage),
|
|
||||||
ok = emqx_ds:open_db(?FUNCTION_NAME, ?DEFAULT_CONFIG),
|
ok = emqx_ds:open_db(?FUNCTION_NAME, ?DEFAULT_CONFIG),
|
||||||
%% Store a batch of messages with the same set of topics.
|
%% Store a batch of messages with the same set of topics.
|
||||||
TS2 = 1_500,
|
TS2 = 1_500,
|
||||||
|
|
Loading…
Reference in New Issue