Fix bug where we marked successfully received messages as lost

redpanda-data · Aug 11, 2021 · 5e11446 · 5e11446
1 parent 634347d
commit 5e11446
Showing 1 changed file with 6 additions and 0 deletions.
diff --git a/e2e/message_tracker.go b/e2e/message_tracker.go
@@ -79,6 +79,12 @@ func (t *messageTracker) onMessageArrived(arrivedMessage *EndToEndMessage) {
 }
 
 func (t *messageTracker) onMessageExpired(_ string, msg *EndToEndMessage) {
+	// Because `t.cache.Delete` will invoke the onEvicted method we have to expect some calls to this function
+	// even though messages have arrived. Thus, we quit early if we receive such a method.
+	if msg.hasArrived {
+		return
+	}
+
 	created := msg.creationTime()
 	age := time.Since(created)
 	t.svc.lostMessages.Inc()