| 1181 | } |
| 1182 | |
| 1183 | void forward(const TaskStatus& status) |
| 1184 | { |
| 1185 | Call call; |
| 1186 | call.set_type(Call::UPDATE); |
| 1187 | |
| 1188 | call.mutable_framework_id()->CopyFrom(frameworkId); |
| 1189 | call.mutable_executor_id()->CopyFrom(executorId); |
| 1190 | |
| 1191 | call.mutable_update()->mutable_status()->CopyFrom(status); |
| 1192 | |
| 1193 | // Capture the status update. |
| 1194 | unacknowledgedUpdates[id::UUID::fromBytes(status.uuid()).get()] = |
| 1195 | call.update(); |
| 1196 | |
| 1197 | // Overwrite the last task status. |
| 1198 | lastTaskStatus = status; |
| 1199 | |
| 1200 | mesos->send(evolve(call)); |
| 1201 | } |
| 1202 | |
| 1203 | void selfTerminate() |
| 1204 | { |