| 808 | |
| 809 | |
| 810 | Try<Nothing> TaskStatusUpdateStream::replay( |
| 811 | const std::vector<StatusUpdate>& updates, |
| 812 | const hashset<id::UUID>& acks) |
| 813 | { |
| 814 | if (error.isSome()) { |
| 815 | return Error(error.get()); |
| 816 | } |
| 817 | |
| 818 | VLOG(1) << "Replaying task status update stream for task " << taskId; |
| 819 | |
| 820 | foreach (const StatusUpdate& update, updates) { |
| 821 | // Handle the update. |
| 822 | _handle(update, StatusUpdateRecord::UPDATE); |
| 823 | |
| 824 | // Check if the update has an ACK too. |
| 825 | if (acks.contains(id::UUID::fromBytes(update.uuid()).get())) { |
| 826 | _handle(update, StatusUpdateRecord::ACK); |
| 827 | } |
| 828 | } |
| 829 | |
| 830 | return Nothing(); |
| 831 | } |
| 832 | |
| 833 | |
| 834 | Try<Nothing> TaskStatusUpdateStream::handle( |
no test coverage detected