| 2084 | |
| 2085 | |
| 2086 | void Master::sendSlaveLost(const SlaveInfo& slaveInfo) |
| 2087 | { |
| 2088 | foreachvalue (Framework* framework, frameworks.registered) { |
| 2089 | if (!framework->connected()) { |
| 2090 | continue; |
| 2091 | } |
| 2092 | |
| 2093 | LOG(INFO) << "Notifying framework " << *framework << " of lost agent " |
| 2094 | << slaveInfo.id() << " (" << slaveInfo.hostname() << ")"; |
| 2095 | |
| 2096 | LostSlaveMessage message; |
| 2097 | message.mutable_slave_id()->MergeFrom(slaveInfo.id()); |
| 2098 | framework->send(message); |
| 2099 | } |
| 2100 | |
| 2101 | if (HookManager::hooksAvailable()) { |
| 2102 | HookManager::masterSlaveLostHook(slaveInfo); |
| 2103 | } |
| 2104 | } |
| 2105 | |
| 2106 | |
| 2107 | void Master::fileAttached(const Future<Nothing>& result, const string& path) |
nothing calls this directly
no test coverage detected