From: Greg Farnum Date: Thu, 8 Jul 2010 19:06:08 +0000 (-0700) Subject: osdmap: move osd_cluster_addr decoding, and make sure that size matches osd_addr X-Git-Tag: v0.22~337 X-Git-Url: http://git-server-git.apps.pok.os.sepia.ceph.com/?a=commitdiff_plain;h=26ff6cb5f2e0f456d8c09a00eb8ee6a3cb411c36;p=ceph.git osdmap: move osd_cluster_addr decoding, and make sure that size matches osd_addr --- diff --git a/src/osd/OSDMap.h b/src/osd/OSDMap.h index 4020246eef9b..58fff5561e8f 100644 --- a/src/osd/OSDMap.h +++ b/src/osd/OSDMap.h @@ -560,10 +560,6 @@ private: osd_info[i->first].down_at = epoch; //cout << "epoch " << epoch << " down osd" << i->first << endl; } - for (map::iterator i = inc.new_up_internal.begin(); - i != inc.new_up_internal.end(); - ++i) - osd_cluster_addr[i->first] = i->second; for (map::iterator i = inc.new_up_client.begin(); i != inc.new_up_client.end(); i++) { @@ -578,7 +574,12 @@ private: osd_info[i->first].up_from = epoch; //cout << "epoch " << epoch << " up osd" << i->first << " at " << i->second << "with hb addr" << osd_hb_addr[i->first] << std::endl; } - + for (map::iterator i = inc.new_up_internal.begin(); + i != inc.new_up_internal.end(); + ++i) + osd_cluster_addr[i->first] = i->second; + if (osd_cluster_addr.size() != osd_addr.size()) + osd_cluster_addr.resize(osd_addr.size()); // info for (map::iterator i = inc.new_up_thru.begin(); i != inc.new_up_thru.end();