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

refactor(ds): reorder functions to improve readability

This commit is contained in:
Andrew Mayorov 2023-09-19 13:59:50 +04:00
parent 540ca6d60f
commit 045d8b7f10
No known key found for this signature in database
GPG Key ID: 2837C62ACFBFED5D
1 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
apps/emqx_durable_storage/src/emqx_ds.erl
View File

@ -255,6 +255,9 @@ session_del_iterator(DSSessionId, TopicFilter) ->
mnesia:delete(?ITERATOR_REF_TAB, IteratorRefId, write) mnesia:delete(?ITERATOR_REF_TAB, IteratorRefId, write)
end). end).
session_del_iterator(#iterator_ref{ref_id = IteratorRefId}) ->
mnesia:delete(?ITERATOR_REF_TAB, IteratorRefId, write).
session_read_iterators(DSSessionId) -> session_read_iterators(DSSessionId) ->
% NOTE: somewhat convoluted way to trick dialyzer % NOTE: somewhat convoluted way to trick dialyzer
Pat = erlang:make_tuple(record_info(size, iterator_ref), '_', [ 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). 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() -> #{}. -spec session_stats() -> #{}.
session_stats() -> session_stats() ->
#{}. #{}.