src/Pure/General/ssh.scala
changeset 73702 7202e12cb324
parent 73634 c88faa1e09e1
child 73897 0ddb5de0506e
equal deleted inserted replaced
73701:d83e7e444b43 73702:7202e12cb324
   241 
   241 
   242     def close(): Unit = channel.disconnect
   242     def close(): Unit = channel.disconnect
   243 
   243 
   244     val exit_status: Future[Int] =
   244     val exit_status: Future[Int] =
   245       Future.thread("ssh_wait") {
   245       Future.thread("ssh_wait") {
   246         while (!channel.isClosed) exec_wait_delay.sleep
   246         while (!channel.isClosed) exec_wait_delay.sleep()
   247         channel.getExitStatus
   247         channel.getExitStatus
   248       }
   248       }
   249 
   249 
   250     val stdin: OutputStream = channel.getOutputStream
   250     val stdin: OutputStream = channel.getOutputStream
   251     val stdout: InputStream = channel.getInputStream
   251     val stdout: InputStream = channel.getInputStream
   280           if (c == 10) line_flush()
   280           if (c == 10) line_flush()
   281           else if (channel.isClosed) {
   281           else if (channel.isClosed) {
   282             if (line_buffer.size > 0) line_flush()
   282             if (line_buffer.size > 0) line_flush()
   283             finished = true
   283             finished = true
   284           }
   284           }
   285           else exec_wait_delay.sleep
   285           else exec_wait_delay.sleep()
   286         }
   286         }
   287 
   287 
   288         result.toList
   288         result.toList
   289       }
   289       }
   290 
   290