MCPcopy Create free account
hub / github.com/apache/mesos / taskCheckUpdated

Method taskCheckUpdated

src/launcher/executor.cpp:313–346  ·  view source on GitHub ↗

Source from the content-addressed store, hash-verified

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 {

Callers

nothing calls this directly

Calls 5

createTaskStatusFunction · 0.85
randomFunction · 0.85
NoneClass · 0.85
getMethod · 0.45
secsMethod · 0.45

Tested by

no test coverage detected