equal
deleted
inserted
replaced
202 |
202 |
203 val consumer = |
203 val consumer = |
204 { |
204 { |
205 val delay_nodes_status = |
205 val delay_nodes_status = |
206 Standard_Thread.delay_first(nodes_status_delay max Time.zero) { |
206 Standard_Thread.delay_first(nodes_status_delay max Time.zero) { |
207 progress.nodes_status(session.snapshot(), use_theories_state.value.nodes_status) |
207 progress.nodes_status(use_theories_state.value.nodes_status) |
208 } |
208 } |
209 |
209 |
210 val delay_commit_clean = |
210 val delay_commit_clean = |
211 Standard_Thread.delay_first(commit_cleanup_delay max Time.zero) { |
211 Standard_Thread.delay_first(commit_cleanup_delay max Time.zero) { |
212 val clean = use_theories_state.value.already_committed.keySet |
212 val clean = use_theories_state.value.already_committed.keySet |
237 delay_nodes_status.invoke |
237 delay_nodes_status.invoke |
238 } |
238 } |
239 |
239 |
240 val theory_progress = |
240 val theory_progress = |
241 (for { |
241 (for { |
242 (name, node_status) <- nodes_status1.present(snapshot).iterator |
242 (name, node_status) <- nodes_status1.present.iterator |
243 if changed.nodes.contains(name) && !st.already_committed.isDefinedAt(name) |
243 if changed.nodes.contains(name) && !st.already_committed.isDefinedAt(name) |
244 p1 = node_status.percentage |
244 p1 = node_status.percentage |
245 if p1 > 0 && Some(p1) != st.nodes_status.get(name).map(_.percentage) |
245 if p1 > 0 && Some(p1) != st.nodes_status.get(name).map(_.percentage) |
246 } yield Progress.Theory(name.theory, percentage = Some(p1))).toList |
246 } yield Progress.Theory(name.theory, percentage = Some(p1))).toList |
247 |
247 |