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() -> #{}.