| 129 | } |
| 130 | |
| 131 | void RNode::waitOutgoingTask(int time) { |
| 132 | // if (time <= Message::kInvalidTime) return; |
| 133 | for (auto& w : exec_.group(id())) { |
| 134 | // LL << w->id(); |
| 135 | w->outgoing_task_.wait(time); |
| 136 | } |
| 137 | } |
| 138 | |
| 139 | bool RNode::tryWaitOutgoingTask(int time) { |
| 140 | // if (time <= Message::kInvalidTime) return true; |
no test coverage detected