| 311 | } |
| 312 | |
| 313 | void taskCheckUpdated( |
| 314 | const TaskID& _taskId, |
| 315 | const CheckStatusInfo& checkStatus) |
| 316 | { |
| 317 | CHECK_SOME(taskId); |
| 318 | CHECK_EQ(taskId.get(), _taskId); |
| 319 | |
| 320 | // This prevents us from sending check updates after a terminal |
| 321 | // status update, because we may receive an update from a check |
| 322 | // scheduled before the task has been reaped. |
| 323 | // |
| 324 | // TODO(alexr): Consider sending check updates after TASK_KILLING. |
| 325 | if (killed || terminated) { |
| 326 | return; |
| 327 | } |
| 328 | |
| 329 | LOG(INFO) << "Received check update '" << checkStatus << "'"; |
| 330 | |
| 331 | // Use the previous task status to preserve all attached information. |
| 332 | CHECK_SOME(lastTaskStatus); |
| 333 | TaskStatus status = protobuf::createTaskStatus( |
| 334 | lastTaskStatus.get(), |
| 335 | id::UUID::random(), |
| 336 | Clock::now().secs(), |
| 337 | None(), |
| 338 | None(), |
| 339 | None(), |
| 340 | TaskStatus::REASON_TASK_CHECK_STATUS_UPDATED, |
| 341 | None(), |
| 342 | None(), |
| 343 | checkStatus); |
| 344 | |
| 345 | forward(status); |
| 346 | } |
| 347 | |
| 348 | void taskHealthUpdated(const TaskHealthStatus& healthStatus) |
| 349 | { |
nothing calls this directly
no test coverage detected