| 148 | } |
| 149 | |
| 150 | void RNode::waitIncomingTask(int time) { |
| 151 | // if (time <= Message::kInvalidTime) return; |
| 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())) |