| 6689 | |
| 6690 | |
| 6691 | void Slave::pingTimeout(Future<Option<MasterInfo>> future) |
| 6692 | { |
| 6693 | // It's possible that a new ping arrived since the timeout fired |
| 6694 | // and we were unable to cancel this timeout. If this occurs, don't |
| 6695 | // bother trying to re-detect. |
| 6696 | if (pingTimer.timeout().expired()) { |
| 6697 | LOG(INFO) << "No pings from master received within " |
| 6698 | << masterPingTimeout; |
| 6699 | |
| 6700 | future.discard(); |
| 6701 | } |
| 6702 | } |
| 6703 | |
| 6704 | |
| 6705 | void Slave::exited(const UPID& pid) |