diff --git a/os/src-jvm/ProcessOps.scala b/os/src-jvm/ProcessOps.scala index b9b4a357..6a7db9ba 100644 --- a/os/src-jvm/ProcessOps.scala +++ b/os/src-jvm/ProcessOps.scala @@ -311,7 +311,6 @@ case class ProcGroup private[os] (commands: Seq[proc]) { runnable.run() } catch { case e: IOException => - println(s"Broken pipe in process $index") queue.put(index) } } diff --git a/os/src-jvm/SubProcess.scala b/os/src-jvm/SubProcess.scala index 5a8a7dde..72f8d7ec 100644 --- a/os/src-jvm/SubProcess.scala +++ b/os/src-jvm/SubProcess.scala @@ -241,13 +241,11 @@ class ProcessPipeline( var pipelineRunning = true while (pipelineRunning) { val brokenPipeIndex = queue.take() - println("Killing " + brokenPipeIndex) if (brokenPipeIndex == processes.length) { // Special case signaling finished pipeline pipelineRunning = false } else { processes(brokenPipeIndex).destroyForcibly() } - println("Processes status: " + processes.map(_.isAlive())) } new Thread( new Runnable {