Remove unnecessary logging (#232)

szymon-rd · web-flow · commit 33b688750bd1 · 2023-11-13T20:45:30.000+01:00
It was unfortunately left behind after last round of debugging... Pull request: #232
diff --git 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
@@ -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 {

Original file line number	Diff line number	Diff line change
`@@ -311,7 +311,6 @@ case class ProcGroup private[os] (commands: Seq[proc]) {`
`311`	`311`	`runnable.run()`
`312`	`312`	`} catch {`
`313`	`313`	`case e: IOException =>`
`314`		`- println(s"Broken pipe in process $index")`
`315`	`314`	`queue.put(index)`
`316`	`315`	`}`
`317`	`316`	`}`
Original file line number	Diff line number	Diff line change
`@@ -241,13 +241,11 @@ class ProcessPipeline(`
`241`	`241`	`var pipelineRunning = true`
`242`	`242`	`while (pipelineRunning) {`
`243`	`243`	`val brokenPipeIndex = queue.take()`
`244`		`- println("Killing " + brokenPipeIndex)`
`245`	`244`	`if (brokenPipeIndex == processes.length) { // Special case signaling finished pipeline`
`246`	`245`	`pipelineRunning = false`
`247`	`246`	`} else {`
`248`	`247`	`processes(brokenPipeIndex).destroyForcibly()`
`249`	`248`	`}`
`250`		`- println("Processes status: " + processes.map(_.isAlive()))`
`251`	`249`	`}`
`252`	`250`	`new Thread(`
`253`	`251`	`new Runnable {`