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

feat(queue): avoid cyclic dependencies

This commit is contained in:
Ilya Averyanov 2024-07-11 00:53:35 +03:00
parent bab526be24
commit 81f4103d60
2 changed files with 4 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
apps/emqx_durable_storage/src/emqx_ds_skipping_iterator.erl
View File

@ -17,7 +17,6 @@
-module(emqx_ds_skipping_iterator). -module(emqx_ds_skipping_iterator).
-include("emqx_ds_skipping_iterator.hrl"). -include("emqx_ds_skipping_iterator.hrl").
-include_lib("emqx/include/emqx_mqtt.hrl").
-type t() :: ?skipping_iterator(emqx_ds:iterator(), non_neg_integer(), non_neg_integer()). -type t() :: ?skipping_iterator(emqx_ds:iterator(), non_neg_integer(), non_neg_integer()).

4
apps/emqx_durable_storage/src/emqx_ds_skipping_iterator.hrl
View File

@ -30,3 +30,7 @@
-define(skipping_iterator(Iterator, Q1Skip, Q2Skip), #{ -define(skipping_iterator(Iterator, Q1Skip, Q2Skip), #{
?tag => ?IT, ?it => Iterator, ?qos1_skip => Q1Skip, ?qos2_skip => Q2Skip ?tag => ?IT, ?it => Iterator, ?qos1_skip => Q1Skip, ?qos2_skip => Q2Skip
}). }).
-define(QOS_0, 0).
-define(QOS_1, 1).
-define(QOS_2, 2).