From 65085d012b430d6192ecf5be4047ae713a39f65d Mon Sep 17 00:00:00 2001 From: Thales Macedo Garitezi Date: Wed, 16 Aug 2023 15:57:56 -0300 Subject: [PATCH] refactor: rename fn --- apps/emqx/src/emqx_persistent_session_ds.erl | 7 ++++--- 1 file changed, 4 insertions(+), 3 deletions(-) diff --git a/apps/emqx/src/emqx_persistent_session_ds.erl b/apps/emqx/src/emqx_persistent_session_ds.erl index 19e11b1a3..b862ef0d9 100644 --- a/apps/emqx/src/emqx_persistent_session_ds.erl +++ b/apps/emqx/src/emqx_persistent_session_ds.erl @@ -102,18 +102,19 @@ add_subscription(TopicFilterBin, DSSessionID) -> ?tp_span( persistent_session_ds_open_iterators, Ctx, - ok = open_iterator_on_all_nodes(TopicFilter, StartMS, IteratorID) + ok = open_iterator_on_all_shards(TopicFilter, StartMS, IteratorID) ), {ok, IteratorID, IsNew} end ). --spec open_iterator_on_all_nodes(emqx_topic:words(), emqx_ds:time(), emqx_ds:iterator_id()) -> ok. -open_iterator_on_all_nodes(TopicFilter, StartMS, IteratorID) -> +-spec open_iterator_on_all_shards(emqx_topic:words(), emqx_ds:time(), emqx_ds:iterator_id()) -> ok. +open_iterator_on_all_shards(TopicFilter, StartMS, IteratorID) -> ?tp(persistent_session_ds_will_open_iterators, #{ iterator_id => IteratorID, start_time => StartMS }), + %% Note: currently, shards map 1:1 to nodes, but this will change in the future. Nodes = emqx:running_nodes(), Results = emqx_persistent_session_ds_proto_v1:open_iterator( Nodes, TopicFilter, StartMS, IteratorID