equal
deleted
inserted
replaced
160 val message = message_output(message_stream) |
160 val message = message_output(message_stream) |
161 |
161 |
162 val result = process_result.join |
162 val result = process_result.join |
163 system_output("process terminated") |
163 system_output("process terminated") |
164 command_input_close() |
164 command_input_close() |
165 for (thread <- List(stdout, stderr, message)) thread.join |
165 for (thread <- List(stdout, stderr, message)) thread.join() |
166 system_output("process_manager terminated") |
166 system_output("process_manager terminated") |
167 exit_message(result) |
167 exit_message(result) |
168 } |
168 } |
169 channel.shutdown() |
169 channel.shutdown() |
170 } |
170 } |