equal
deleted
inserted
replaced
80 receiver(new Prover.Protocol_Output(props, bytes)) |
80 receiver(new Prover.Protocol_Output(props, bytes)) |
81 } |
81 } |
82 |
82 |
83 private def output(kind: String, props: Properties.T, body: XML.Body) |
83 private def output(kind: String, props: Properties.T, body: XML.Body) |
84 { |
84 { |
85 if (kind == Markup.INIT) channel.accepted() |
|
86 |
|
87 val main = XML.Elem(Markup(kind, props), Protocol_Message.clean_reports(body)) |
85 val main = XML.Elem(Markup(kind, props), Protocol_Message.clean_reports(body)) |
88 val reports = Protocol_Message.reports(props, body) |
86 val reports = Protocol_Message.reports(props, body) |
89 for (msg <- main :: reports) receiver(new Prover.Output(xml_cache.elem(msg))) |
87 for (msg <- main :: reports) receiver(new Prover.Output(xml_cache.elem(msg))) |
90 } |
88 } |
91 |
89 |
153 command_input_close() |
151 command_input_close() |
154 for (thread <- List(stdout, stderr, message)) thread.join |
152 for (thread <- List(stdout, stderr, message)) thread.join |
155 system_output("process_manager terminated") |
153 system_output("process_manager terminated") |
156 exit_message(result) |
154 exit_message(result) |
157 } |
155 } |
158 channel.accepted() |
156 channel.shutdown() |
159 } |
157 } |
160 |
158 |
161 |
159 |
162 /* management methods */ |
160 /* management methods */ |
163 |
161 |