From: Sage Weil <sage@newdream.net>
Date: Wed, 23 Nov 2011 00:02:28 +0000 (-0800)
Subject: mon: calculate rank by addr, not name
X-Git-Tag: v0.39~17^2~3
X-Git-Url: http://git-server-git.apps.pok.os.sepia.ceph.com/?a=commitdiff_plain;h=36978a632981b7c7a3bc80f968c1d66ca3c0b0b2;p=ceph.git

mon: calculate rank by addr, not name

Signed-off-by: Sage Weil <sage@newdream.net>
---

diff --git a/src/mon/MonMap.h b/src/mon/MonMap.h
index bc302f9ef142b..c46c0bda2c8dc 100644
--- a/src/mon/MonMap.h
+++ b/src/mon/MonMap.h
@@ -114,6 +114,12 @@ class MonMap {
 	return i;
     return -1;
   }
+  int get_rank(entity_addr_t a) {
+    for (unsigned i=0; i<rank_addr.size(); i++)
+      if (rank_addr[i] == a)
+	return i;
+    return -1;
+  }
   bool get_addr_name(entity_addr_t a, string& name) {
     if (addr_name.count(a) == 0)
       return false;
diff --git a/src/mon/Monitor.cc b/src/mon/Monitor.cc
index a722a76db4f53..bfd3b8aa844eb 100644
--- a/src/mon/Monitor.cc
+++ b/src/mon/Monitor.cc
@@ -114,7 +114,7 @@ Monitor::Monitor(CephContext* cct_, string nm, MonitorStore *s, Messenger *m, Mo
   paxos(PAXOS_NUM), paxos_service(PAXOS_NUM),
   routed_request_tid(0)
 {
-  rank = map->get_rank(name);
+  rank = -1;
 
   paxos_service[PAXOS_MDSMAP] = new MDSMonitor(this, add_paxos(PAXOS_MDSMAP));
   paxos_service[PAXOS_MONMAP] = new MonmapMonitor(this, add_paxos(PAXOS_MONMAP));
@@ -171,6 +171,8 @@ Monitor::~Monitor()
 void Monitor::init()
 {
   lock.Lock();
+
+  rank = monmap->get_rank(messenger->get_myaddr());
   
   dout(1) << "init fsid " << monmap->fsid << dendl;
   
@@ -234,7 +236,7 @@ void Monitor::bootstrap()
   cancel_probe_timeout();
 
   // note my rank
-  int newrank = monmap->get_rank(name);
+  int newrank = monmap->get_rank(messenger->get_myaddr());
   if (newrank < 0 && rank >= 0) {
     dout(0) << " removed from monmap, suicide." << dendl;
     exit(0);