fix process IO

vorpal-research · Apr 22, 2024 · e41d05f · e41d05f
1 parent bb4d048
commit e41d05f
Show file tree

Hide file tree

Showing 2 changed files with 10 additions and 2 deletions.
diff --git a/kex-executor/src/main/kotlin/org/vorpal/research/kex/worker/ExecutorMaster.kt b/kex-executor/src/main/kotlin/org/vorpal/research/kex/worker/ExecutorMaster.kt
@@ -98,7 +98,7 @@ class ExecutorMaster(
                 "--option", "kex:log:${outputDir.resolve("kex-executor-worker$id.log").toAbsolutePath()}",
                 "--classpath", kfgClassPath.joinToString(getPathSeparator()),
                 "--port", "${connection.workerPort}"
-            )
+            ).inheritIO()
             log.debug("Starting worker process with command: '${pb.command().joinToString(" ")}'")
             return pb.start()
         }
@@ -139,6 +139,9 @@ class ExecutorMaster(
         fun destroy() {
             workerConnection.close()
             process.destroy()
+            if (process.isAlive) {
+                process.destroyForcibly()
+            }
         }
     }
 
@@ -182,7 +185,9 @@ class ExecutorMaster(
     }
 
     fun destroy() {
+        log.debug("Master is destroying all the workers")
         for (worker in workers) {
+            log.debug("Destroying worker ${worker.id}")
             worker.destroy()
         }
     }

diff --git a/...ner/src/main/kotlin/org/vorpal/research/kex/trace/runner/SymbolicExternalTracingRunner.kt b/...ner/src/main/kotlin/org/vorpal/research/kex/trace/runner/SymbolicExternalTracingRunner.kt
@@ -71,7 +71,7 @@ internal object ExecutorMasterController : AutoCloseable {
             "--kfgClassPath", kfgClassPath.joinToString(getPathSeparator()),
             "--workerClassPath", workerClassPath.joinToString(getPathSeparator()),
             "--numOfWorkers", "$numberOfWorkers"
-        )
+        ).inheritIO()
         log.debug("Starting executor master process with command: '${pb.command().joinToString(" ")}'")
         process = pb.start()
         runBlocking {
@@ -85,6 +85,9 @@ internal object ExecutorMasterController : AutoCloseable {
 
     override fun close() {
         process.destroy()
+        if (process.isAlive) {
+            process.destroyForcibly()
+        }
         controllerSocket.close()
     }
 }