From 28ea184d3a37fa8d878c82571ae64607c6717b43 Mon Sep 17 00:00:00 2001 From: Sage Weil Date: Wed, 29 May 2013 12:24:28 -0700 Subject: osd: remove down hb peers If a (say, random) peer goes down, filter it out. Signed-off-by: Sage Weil --- src/osd/OSD.cc | 14 ++++++++++---- 1 file changed, 10 insertions(+), 4 deletions(-) diff --git a/src/osd/OSD.cc b/src/osd/OSD.cc index c8a5b9a263e..0e65172723c 100644 --- a/src/osd/OSD.cc +++ b/src/osd/OSD.cc @@ -2350,13 +2350,19 @@ void OSD::maybe_update_heartbeat_peers() _add_heartbeat_peer(*p); } - // identify extras - for (map::iterator p = heartbeat_peers.begin(); - p != heartbeat_peers.end(); - ++p) { + // remove down peers; enumerate extras + map::iterator p = heartbeat_peers.begin(); + while (p != heartbeat_peers.end()) { + if (!osdmap->is_up(p->first)) { + int o = p->first; + ++p; + _remove_heartbeat_peer(o); + continue; + } if (p->second.epoch < osdmap->get_epoch()) { extras.insert(p->first); } + ++p; } // too few? -- cgit v1.2.1