iktdev/MediaProcessing
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Correction to filter++

Browse Source
This commit is contained in:
bskjon 2025-04-19 02:20:32 +02:00
parent f452678990
commit c86ea07073
1 changed files with 1 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
shared/eventi/src/main/kotlin/no/iktdev/eventi/implementations/EventCoordinator.kt
View File

@ -94,7 +94,7 @@ abstract class EventCoordinator<T : EventImpl, E : EventsManagerImpl<T>> {
} }
val bashed = bashingReferenceObject[referenceId]?.takeLast(10) ?: emptyList() 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 // We have entered a deadlock here
// Due to the nature of the deadlock the event will be determined to be dead // 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" } log.error { "Producing Failure on $referenceId on event ${event.eventType} due to deadlock in $listenerName" }