fix: Fixes possible wrong lost events count

elastic · Jan 3, 2023 · 586b64d · 586b64d
1 parent 6fba496
commit 586b64d
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/reassembler.go b/reassembler.go
@@ -243,7 +243,7 @@ func (l *eventList) Clear() ([]*event, int) {
 		event := l.events[seq]
 
 		if l.lastSeq > 0 {
-			lost += int(seq - l.lastSeq - 1)
+			lost += int(seq) - int(l.lastSeq) - 1
 		}
 		l.lastSeq = seq
 		evicted = append(evicted, event)
@@ -302,7 +302,7 @@ func (l *eventList) CleanUp() ([]*event, int) {
 
 		if event.complete || size > l.maxSize || event.IsExpired() {
 			if l.lastSeq > 0 {
-				lost += int(seq - l.lastSeq - 1)
+				lost += int(seq) - int(l.lastSeq) - 1
 			}
 			l.lastSeq = seq
 			evicted = append(evicted, event)