| 137 | } |
| 138 | |
| 139 | bool RNode::tryWaitOutgoingTask(int time) { |
| 140 | // if (time <= Message::kInvalidTime) return true; |
| 141 | for (auto& w : exec_.group(id())) |
| 142 | if (!w->outgoing_task_.tryWait(time)) return false; |
| 143 | return true; |
| 144 | } |
| 145 | |
| 146 | void RNode::finishOutgoingTask(int time) { |
| 147 | for (auto& w : exec_.group(id())) w->outgoing_task_.finish(time); |