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

Method lostExecutor

src/sched/sched.cpp:1121–1159  ·  view source on GitHub ↗

Source from the content-addressed store, hash-verified

1119 }
1120
1121 void lostExecutor(
1122 const UPID& from,
1123 const ExecutorID& executorId,
1124 const SlaveID& slaveId,
1125 int32_t status)
1126 {
1127 if (!running.load()) {
1128 VLOG(1)
1129 << "Ignoring lost executor message because the driver is not running!";
1130 return;
1131 }
1132
1133 if (!connected) {
1134 VLOG(1)
1135 << "Ignoring lost executor message because the driver is disconnected!";
1136 return;
1137 }
1138
1139 CHECK_SOME(master);
1140 if (from != master->pid()) {
1141 VLOG(1) << "Ignoring lost executor message because it was sent "
1142 << "from '" << from << "' instead of the leading master '"
1143 << master->pid() << "'";
1144 return;
1145 }
1146
1147 VLOG(1)
1148 << "Executor " << executorId << " on agent " << slaveId
1149 << " exited with status " << status;
1150
1151 Stopwatch stopwatch;
1152 if (FLAGS_v >= 1) {
1153 stopwatch.start();
1154 }
1155
1156 scheduler->executorLost(driver, executorId, slaveId, status);
1157
1158 VLOG(1) << "Scheduler::executorLost took " << stopwatch.elapsed();
1159 }
1160
1161 void frameworkMessage(
1162 const SlaveID& slaveId,

Callers

nothing calls this directly

Calls 5

elapsedMethod · 0.80
startMethod · 0.65
executorLostMethod · 0.65
loadMethod · 0.45
pidMethod · 0.45

Tested by

no test coverage detected