fix(verify_sequence): Don't report repeats as negative numbers

emqx · Dec 18, 2024 · c59dcb9 · c59dcb9
1 parent 22458cb
commit c59dcb9
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/src/behaviors/emqttb_behavior_sub.erl b/src/behaviors/emqttb_behavior_sub.erl
@@ -210,7 +210,7 @@ verify_sequence(#{ number_of_gaps := NGaps, gap_size := GapSize, number_of_repea
     [{_, OldSeqNo}] ->
       logger:info("Repeat detected: ~p ~p; ~p", [OldSeqNo, SeqNo, Key]),
       emqttb_metrics:counter_inc(NRepeats, 1),
-      emqttb_metrics:rolling_average_observe(RepeatSize, SeqNo - OldSeqNo + 1)
+      emqttb_metrics:rolling_average_observe(RepeatSize, OldSeqNo - SeqNo + 1)
   end,
   ets:insert(?seq_tab, {Key, SeqNo}).