equal
deleted
inserted
replaced
316 } |
316 } |
317 |
317 |
318 def flush(): Set[Document.Node.Name] = |
318 def flush(): Set[Document.Node.Name] = |
319 changed_nodes.change_result(nodes => (nodes, Set.empty)) |
319 changed_nodes.change_result(nodes => (nodes, Set.empty)) |
320 |
320 |
321 def shutdown() { delay.revoke() } |
321 def revoke() { delay.revoke() } |
322 } |
322 } |
323 |
323 |
324 |
324 |
325 /* prover process */ |
325 /* prover process */ |
326 |
326 |
547 |
547 |
548 case Start(start_prover) if !prover.defined => |
548 case Start(start_prover) if !prover.defined => |
549 prover.set(start_prover(manager.send(_))) |
549 prover.set(start_prover(manager.send(_))) |
550 |
550 |
551 case Stop => |
551 case Stop => |
|
552 consolidation.revoke() |
552 delay_prune.revoke() |
553 delay_prune.revoke() |
553 if (prover.defined) { |
554 if (prover.defined) { |
554 protocol_handlers.exit() |
555 protocol_handlers.exit() |
555 global_state.change(_ => Document.State.init) |
556 global_state.change(_ => Document.State.init) |
556 prover.get.terminate |
557 prover.get.terminate |
652 send_stop() |
653 send_stop() |
653 prover.await_reset() |
654 prover.await_reset() |
654 |
655 |
655 change_parser.shutdown() |
656 change_parser.shutdown() |
656 change_buffer.shutdown() |
657 change_buffer.shutdown() |
657 consolidation.shutdown() |
|
658 manager.shutdown() |
658 manager.shutdown() |
659 dispatcher.shutdown() |
659 dispatcher.shutdown() |
660 |
660 |
661 phase match { |
661 phase match { |
662 case Session.Terminated(result) => result |
662 case Session.Terminated(result) => result |