equal
deleted
inserted
replaced
231 override def commit(change: Session.Change): Unit = |
231 override def commit(change: Session.Change): Unit = |
232 if (change.deps_changed || undefined_blobs(change.version.nodes).nonEmpty) |
232 if (change.deps_changed || undefined_blobs(change.version.nodes).nonEmpty) |
233 delay_load.invoke() |
233 delay_load.invoke() |
234 } |
234 } |
235 |
235 |
236 Some(new Session(resources) { |
236 Some(new Session(options, resources)) |
237 override def output_delay = options.seconds("editor_output_delay") |
|
238 override def prune_delay = options.seconds("editor_prune_delay") |
|
239 override def syslog_limit = options.int("editor_syslog_limit") |
|
240 override def reparse_limit = options.int("editor_reparse_limit") |
|
241 }) |
|
242 } |
237 } |
243 catch { case ERROR(msg) => reply(msg); None } |
238 catch { case ERROR(msg) => reply(msg); None } |
244 |
239 |
245 for (session <- try_session) { |
240 for (session <- try_session) { |
246 session_.change(_ => Some(session)) |
241 session_.change(_ => Some(session)) |
253 var session_phase: Session.Consumer[Session.Phase] = null |
248 var session_phase: Session.Consumer[Session.Phase] = null |
254 session_phase = |
249 session_phase = |
255 Session.Consumer(getClass.getName) { |
250 Session.Consumer(getClass.getName) { |
256 case Session.Ready => |
251 case Session.Ready => |
257 session.phase_changed -= session_phase |
252 session.phase_changed -= session_phase |
258 session.update_options(options) |
|
259 reply("") |
253 reply("") |
260 case Session.Terminated(rc) if rc != 0 => |
254 case Session.Terminated(rc) if rc != 0 => |
261 session.phase_changed -= session_phase |
255 session.phase_changed -= session_phase |
262 reply("Prover startup failed: return code " + rc) |
256 reply("Prover startup failed: return code " + rc) |
263 case _ => |
257 case _ => |