equal
deleted
inserted
replaced
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 |