| 222 | } |
| 223 | |
| 224 | void registered( |
| 225 | const ExecutorInfo& executorInfo, |
| 226 | const FrameworkID& frameworkId, |
| 227 | const FrameworkInfo& frameworkInfo, |
| 228 | const SlaveID& slaveId, |
| 229 | const SlaveInfo& slaveInfo) |
| 230 | { |
| 231 | if (aborted.load()) { |
| 232 | VLOG(1) << "Ignoring registered message from agent " << slaveId |
| 233 | << " because the driver is aborted!"; |
| 234 | return; |
| 235 | } |
| 236 | |
| 237 | LOG(INFO) << "Executor registered on agent " << slaveId; |
| 238 | |
| 239 | connected = true; |
| 240 | connection = id::UUID::random(); |
| 241 | |
| 242 | Stopwatch stopwatch; |
| 243 | if (FLAGS_v >= 1) { |
| 244 | stopwatch.start(); |
| 245 | } |
| 246 | |
| 247 | executor->registered(driver, executorInfo, frameworkInfo, slaveInfo); |
| 248 | |
| 249 | VLOG(1) << "Executor::registered took " << stopwatch.elapsed(); |
| 250 | } |
| 251 | |
| 252 | void reregistered(const SlaveID& slaveId, const SlaveInfo& slaveInfo) |
| 253 | { |
nothing calls this directly
no test coverage detected