From: Greg Farnum <greg@inktank.com>
Date: Mon, 9 Dec 2013 16:41:54 +0000 (-0800)
Subject: Elector: share local command set when deferring
X-Git-Tag: v0.75~125^2~6
X-Git-Url: http://git-server-git.apps.pok.os.sepia.ceph.com/?a=commitdiff_plain;h=f1ccdb418b916aed36d12e090d41c432cf0f86e0;p=ceph.git

Elector: share local command set when deferring

We're about to use this at a basic level, to identify when we have
"classic" monitors in-quorum, but could also do something more
sophisticated like a set intersection on the commands.

Signed-off-by: Greg Farnum <greg@inktank.com>
---

diff --git a/src/mon/Elector.cc b/src/mon/Elector.cc
index 12c89bbb54f5..625e2bb0bb34 100644
--- a/src/mon/Elector.cc
+++ b/src/mon/Elector.cc
@@ -61,6 +61,7 @@ void Elector::bump_epoch(epoch_t e)
   // clear up some state
   electing_me = false;
   acked_me.clear();
+  acker_commands.clear();
 }
 
 
@@ -73,6 +74,7 @@ void Elector::start()
   dout(5) << "start -- can i be leader?" << dendl;
 
   acked_me.clear();
+  acker_commands.clear();
   init();
   
   // start by trying to elect me
@@ -100,14 +102,23 @@ void Elector::defer(int who)
   if (electing_me) {
     // drop out
     acked_me.clear();
+    acker_commands.clear();
     electing_me = false;
   }
 
+  // encode my commands for transmission
+  if(!my_supported_commands.length()) {
+    const MonCommand *cmds;
+    int cmdsize;
+    get_locally_supported_monitor_commands(&cmds, &cmdsize);
+    MonCommand::encode_array(cmds, cmdsize, my_supported_commands);
+  }
   // ack them
   leader_acked = who;
   ack_stamp = ceph_clock_now(g_ceph_context);
-  mon->messenger->send_message(new MMonElection(MMonElection::OP_ACK, epoch, mon->monmap),
-			       mon->monmap->get_inst(who));
+  MMonElection *m = new MMonElection(MMonElection::OP_ACK, epoch, mon->monmap);
+  m->commands = my_supported_commands;
+  mon->messenger->send_message(m, mon->monmap->get_inst(who));
   
   // set a timer
   reset_timer(1.0);  // give the leader some extra time to declare victory
@@ -260,6 +271,7 @@ void Elector::handle_ack(MMonElection *m)
   if (electing_me) {
     // thanks
     acked_me[from] = m->get_connection()->get_features();
+    acker_commands.push_back(m->commands);
     dout(5) << " so far i have " << acked_me << dendl;
     
     // is that _everyone_?
diff --git a/src/mon/Elector.h b/src/mon/Elector.h
index d17429ffa78f..8efa4d367e34 100644
--- a/src/mon/Elector.h
+++ b/src/mon/Elector.h
@@ -114,6 +114,7 @@ class Elector {
    * victory.  Also note each peer's feature set.
    */
   map<int, uint64_t> acked_me;
+  list<bufferlist> acker_commands;
   bufferlist my_supported_commands;
   /**
    * @}