| 250 | } |
| 251 | |
| 252 | void reregistered(const SlaveID& slaveId, const SlaveInfo& slaveInfo) |
| 253 | { |
| 254 | if (aborted.load()) { |
| 255 | VLOG(1) << "Ignoring reregistered message from agent " << slaveId |
| 256 | << " because the driver is aborted!"; |
| 257 | return; |
| 258 | } |
| 259 | |
| 260 | LOG(INFO) << "Executor reregistered on agent " << slaveId; |
| 261 | |
| 262 | connected = true; |
| 263 | connection = id::UUID::random(); |
| 264 | |
| 265 | Stopwatch stopwatch; |
| 266 | if (FLAGS_v >= 1) { |
| 267 | stopwatch.start(); |
| 268 | } |
| 269 | |
| 270 | executor->reregistered(driver, slaveInfo); |
| 271 | |
| 272 | VLOG(1) << "Executor::reregistered took " << stopwatch.elapsed(); |
| 273 | } |
| 274 | |
| 275 | void reconnect(const UPID& from, const SlaveID& slaveId) |
| 276 | { |
nothing calls this directly
no test coverage detected