Print exceptions in the status logs

CorfuDB · May 6, 2024 · 59d90ef · 59d90ef
1 parent 9162582
commit 59d90ef
Showing 1 changed file with 18 additions and 20 deletions.
diff --git a/...ation-tools/src/main/kotlin/org/corfudb/cloud/infrastructure/integration/server/Server.kt b/...ation-tools/src/main/kotlin/org/corfudb/cloud/infrastructure/integration/server/Server.kt
@@ -3,32 +3,25 @@ package org.corfudb.cloud.infrastructure.integration.server
 import com.fasterxml.jackson.databind.SerializationFeature
 import com.fasterxml.jackson.module.kotlin.jacksonObjectMapper
 import com.github.ajalt.clikt.core.CliktCommand
-import io.ktor.application.Application
-import io.ktor.application.ApplicationStopped
-import io.ktor.application.call
-import io.ktor.application.install
-import io.ktor.features.ContentNegotiation
-import io.ktor.features.StatusPages
-import io.ktor.http.HttpStatusCode
-import io.ktor.http.content.resources
-import io.ktor.http.content.static
-import io.ktor.jackson.jackson
-import io.ktor.request.receive
-import io.ktor.response.respond
-import io.ktor.routing.get
-import io.ktor.routing.post
-import io.ktor.routing.routing
-import io.ktor.util.KtorExperimentalAPI
-import java.io.File
-import java.io.PrintWriter
-import java.io.StringWriter
+import io.ktor.application.*
+import io.ktor.features.*
+import io.ktor.http.*
+import io.ktor.http.content.*
+import io.ktor.jackson.*
+import io.ktor.request.*
+import io.ktor.response.*
+import io.ktor.routing.*
+import io.ktor.util.*
 import kotlinx.coroutines.async
 import org.corfudb.cloud.infrastructure.integration.ArchiveConfig
 import org.corfudb.cloud.infrastructure.integration.IntegrationToolConfig
 import org.corfudb.cloud.infrastructure.integration.kv.KvStore
 import org.corfudb.cloud.infrastructure.integration.kv.ProcessingMessage
 import org.corfudb.cloud.infrastructure.integration.kv.RocksDbManager
 import org.corfudb.cloud.infrastructure.integration.processing.ProcessingManager
+import java.io.File
+import java.io.PrintWriter
+import java.io.StringWriter
 
 @KtorExperimentalAPI
 @kotlin.jvm.JvmOverloads
@@ -107,7 +100,12 @@ fun Application.module(testing: Boolean = false) {
                     try {
                         ProcessingManager(kvStore, request.aggregationUnit, config).execute()
                     } catch (ex: Exception) {
-                        kvStore.put(ProcessingMessage.new(request.aggregationUnit, "Processing error"))
+                        val sw = StringWriter()
+                        val pw = PrintWriter(sw)
+                        ex.printStackTrace(pw)
+                        val sStackTrace = sw.toString()
+                        val errStr = "Processing error: $sStackTrace"
+                        kvStore.put(ProcessingMessage.new(request.aggregationUnit, errStr))
                     }
                 }