| 152 | for (auto& w : exec_.group(id())) w->incoming_task_.wait(time); |
| 153 | } |
| 154 | bool RNode::tryWaitIncomingTask(int time) { |
| 155 | // if (time <= Message::kInvalidTime) return true; |
| 156 | for (auto& w : exec_.group(id())) |
| 157 | if (!w->incoming_task_.tryWait(time)) return false; |
| 158 | return true; |
| 159 | } |
| 160 | |
| 161 | void RNode::finishIncomingTask(int time) { |
| 162 | for (auto& w : exec_.group(id())) w->incoming_task_.finish(time); |