| 804 | // --------------------------------------------------------------------------- |
| 805 | |
| 806 | void DerivedEngine::onSourceCommitted(PJ::Span<const PJ::TopicId> changed_topics) { |
| 807 | for (PJ::TopicId tid : changed_topics) { |
| 808 | auto it = impl_->topic_to_nodes.find(tid); |
| 809 | if (it == impl_->topic_to_nodes.end()) { |
| 810 | continue; |
| 811 | } |
| 812 | for (PJ::NodeId nid : it->second) { |
| 813 | auto nit = impl_->nodes.find(nid); |
| 814 | if (nit != impl_->nodes.end()) { |
| 815 | nit.value().dirty = true; |
| 816 | } |
| 817 | } |
| 818 | } |
| 819 | } |
| 820 | |
| 821 | // --------------------------------------------------------------------------- |
| 822 | // run_node_incremental (private helper) |