log multiInstanceExecute state (#60)

himadieievsv · Jan 16, 2024 · 39ebe69 · 39ebe69
1 parent b4f95a4
commit 39ebe69
Showing 1 changed file with 4 additions and 0 deletions.
diff --git a/...e/src/main/kotlin/com/himadieiev/redpulsar/core/locks/excecutors/MultyInstanceExecutor.kt b/...e/src/main/kotlin/com/himadieiev/redpulsar/core/locks/excecutors/MultyInstanceExecutor.kt
@@ -6,6 +6,7 @@ import com.himadieiev.redpulsar.core.utils.withTimeoutInThread
 import kotlinx.coroutines.CoroutineScope
 import kotlinx.coroutines.Job
 import kotlinx.coroutines.launch
+import mu.KotlinLogging
 import java.time.Duration
 import java.util.Collections
 import kotlin.system.measureTimeMillis
@@ -59,6 +60,9 @@ suspend inline fun <T : Backend, R> multiInstanceExecute(
             waiter(jobs)
         }
     val validity = timeout.toMillis() - timeDiff - clockDrift
+    val logger = KotlinLogging.logger { }
+    logger.info { "Validity: $validity, Result size: ${results.size}" }
+    logger.info { "Results: $results" }
     if (results.size < quorum || validity < 0) {
         val cleanUpJobs = mutableListOf<Job>()
         backends.forEach { backend ->