From c86ea07073fd3594837a10808dc74552802e46ff Mon Sep 17 00:00:00 2001 From: bskjon Date: Sat, 19 Apr 2025 02:20:32 +0200 Subject: [PATCH] Correction to filter++ --- .../kotlin/no/iktdev/eventi/implementations/EventCoordinator.kt | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/shared/eventi/src/main/kotlin/no/iktdev/eventi/implementations/EventCoordinator.kt b/shared/eventi/src/main/kotlin/no/iktdev/eventi/implementations/EventCoordinator.kt index b8e4a048..58692ab7 100644 --- a/shared/eventi/src/main/kotlin/no/iktdev/eventi/implementations/EventCoordinator.kt +++ b/shared/eventi/src/main/kotlin/no/iktdev/eventi/implementations/EventCoordinator.kt @@ -94,7 +94,7 @@ abstract class EventCoordinator> { } val bashed = bashingReferenceObject[referenceId]?.takeLast(10) ?: emptyList() - if (bashed.all { it == bashed.first() }) { + if (bashed.size == 10 && bashed.all { it == bashed.first() }) { // We have entered a deadlock here // Due to the nature of the deadlock the event will be determined to be dead log.error { "Producing Failure on $referenceId on event ${event.eventType} due to deadlock in $listenerName" }