Method finishIncomingTask

src/system/remote_node.cc:161–164

}

void RNode::finishIncomingTask(int time) {
  for (auto& w : exec_.group(id())) w->incoming_task_.finish(time);
  exec_.notify();
}

FilterPtr RNode::findFilter(const FilterConfig& conf) {
  Lock l(filter_mu_);