| 1507 | } |
| 1508 | |
| 1509 | void forward(const TaskStatus& status) |
| 1510 | { |
| 1511 | Call call; |
| 1512 | call.set_type(Call::UPDATE); |
| 1513 | |
| 1514 | call.mutable_framework_id()->CopyFrom(frameworkId); |
| 1515 | call.mutable_executor_id()->CopyFrom(executorId); |
| 1516 | |
| 1517 | call.mutable_update()->mutable_status()->CopyFrom(status); |
| 1518 | |
| 1519 | // Capture the status update. |
| 1520 | unacknowledgedUpdates[id::UUID::fromBytes(status.uuid()).get()] = |
| 1521 | call.update(); |
| 1522 | |
| 1523 | // Overwrite the last task status. |
| 1524 | CHECK(containers.contains(status.task_id())); |
| 1525 | containers.at(status.task_id())->lastTaskStatus = status; |
| 1526 | |
| 1527 | mesos->send(evolve(call)); |
| 1528 | } |
| 1529 | |
| 1530 | Future<Response> post( |
| 1531 | Option<Connection> connection, |