| 1261 | |
| 1262 | |
| 1263 | void Master::exited( |
| 1264 | const FrameworkID& frameworkId, |
| 1265 | const StreamingHttpConnection<v1::scheduler::Event>& http) |
| 1266 | { |
| 1267 | foreachvalue (Framework* framework, frameworks.registered) { |
| 1268 | if (framework->http().isSome() && |
| 1269 | framework->http()->writer == http.writer) { |
| 1270 | CHECK_EQ(frameworkId, framework->id()); |
| 1271 | _exited(framework); |
| 1272 | return; |
| 1273 | } |
| 1274 | |
| 1275 | // If the framework has reconnected, the writer will not match |
| 1276 | // above, and we will have a framework with a matching id. |
| 1277 | if (frameworkId == framework->id()) { |
| 1278 | LOG(INFO) << "Ignoring disconnection for framework " |
| 1279 | << *framework << " as it has already reconnected"; |
| 1280 | |
| 1281 | return; |
| 1282 | } |
| 1283 | } |
| 1284 | } |
| 1285 | |
| 1286 | |
| 1287 | void Master::exited(const UPID& pid) |