From 045d8b7f10af95a463287ac7eac301083941c318 Mon Sep 17 00:00:00 2001 From: Andrew Mayorov Date: Tue, 19 Sep 2023 13:59:50 +0400 Subject: [PATCH] refactor(ds): reorder functions to improve readability --- apps/emqx_durable_storage/src/emqx_ds.erl | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/apps/emqx_durable_storage/src/emqx_ds.erl b/apps/emqx_durable_storage/src/emqx_ds.erl index e06d994e1..8f8510e55 100644 --- a/apps/emqx_durable_storage/src/emqx_ds.erl +++ b/apps/emqx_durable_storage/src/emqx_ds.erl @@ -255,6 +255,9 @@ session_del_iterator(DSSessionId, TopicFilter) -> mnesia:delete(?ITERATOR_REF_TAB, IteratorRefId, write) end). +session_del_iterator(#iterator_ref{ref_id = IteratorRefId}) -> + mnesia:delete(?ITERATOR_REF_TAB, IteratorRefId, write). + session_read_iterators(DSSessionId) -> % NOTE: somewhat convoluted way to trick dialyzer Pat = erlang:make_tuple(record_info(size, iterator_ref), '_', [ @@ -263,9 +266,6 @@ session_read_iterators(DSSessionId) -> ]), mnesia:match_object(?ITERATOR_REF_TAB, Pat, read). -session_del_iterator(#iterator_ref{ref_id = IteratorRefId}) -> - mnesia:delete(?ITERATOR_REF_TAB, IteratorRefId, write). - -spec session_stats() -> #{}. session_stats() -> #{}.