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

Log suppressing

Browse Source
This commit is contained in:
bskjon 2024-08-22 00:57:52 +02:00
parent e169fc39e5
commit 20ce2880d2
1 changed files with 13 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -81,13 +81,17 @@ abstract class EventCoordinator<T : EventImpl, E : EventsManagerImpl<T>> {
} }
} }
private var wasActiveNotify: Boolean = true
private fun onEventCollectionReceived(referenceId: String, events: List<T>) { private fun onEventCollectionReceived(referenceId: String, events: List<T>) {
val orphanedReferences = referencePool.filter { !it.value.isActive }.filter { id -> id.key !in referenceId }.map { it.key } val orphanedReferences = referencePool.filter { !it.value.isActive }.filter { id -> id.key !in referenceId }.map { it.key }
orphanedReferences.forEach { id -> referencePool.remove(id) } orphanedReferences.forEach { id -> referencePool.remove(id) }
activePolls = referencePool.values.filter { it.isActive }.size activePolls = referencePool.values.filter { it.isActive }.size
if (orphanedReferences.isNotEmpty() && referencePool.isEmpty()) { if (orphanedReferences.isNotEmpty() && referencePool.isEmpty() && wasActiveNotify) {
log.info { "Last active references removed from pull pool, " } log.info { "Last active references removed from pull pool, $referenceId" }
wasActiveNotify = false
} else {
wasActiveNotify = true
} }
val isAvailable = if (referenceId in referencePool.keys) { val isAvailable = if (referenceId in referencePool.keys) {
@ -122,12 +126,19 @@ abstract class EventCoordinator<T : EventImpl, E : EventsManagerImpl<T>> {
} }
private var newEventsProducedOnReferenceId: AtomicReference<List<String>> = AtomicReference(emptyList()) private var newEventsProducedOnReferenceId: AtomicReference<List<String>> = AtomicReference(emptyList())
var cachedReferenceList: MutableList<String> = mutableListOf()
private fun pullForEvents() { private fun pullForEvents() {
coroutine.launch { coroutine.launch {
while (taskMode == ActiveMode.Active) { while (taskMode == ActiveMode.Active) {
if (referencePoolIsReadyForEvents()) { if (referencePoolIsReadyForEvents()) {
log.debug { "New pull on database" } log.debug { "New pull on database" }
val referenceIdsAvailable = eventManager.getAvailableReferenceIds() val referenceIdsAvailable = eventManager.getAvailableReferenceIds()
val newReferenceIds = cachedReferenceList.subtract(referenceIdsAvailable.toSet())
cachedReferenceList = referenceIdsAvailable.toMutableList()
log.info { "New referenceIds found,\n ${newReferenceIds.joinToString("\n")}" }
for (referenceId in referenceIdsAvailable) { for (referenceId in referenceIdsAvailable) {
val events = eventManager.readAvailableEventsFor(referenceId) val events = eventManager.readAvailableEventsFor(referenceId)
onEventCollectionReceived(referenceId, events) onEventCollectionReceived(referenceId, events)