From: Greg Farnum <greg@inktank.com>
Date: Tue, 29 Jul 2014 01:33:56 +0000 (-0700)
Subject: OSD: add require_same_peer_inst(OpRequestRef&,OSDMap&) helper
X-Git-Tag: v0.80.6~80
X-Git-Url: http://git-server-git.apps.pok.os.sepia.ceph.com/?a=commitdiff_plain;h=7da121d2aa1ea5c5c8accef92d7304912d4b2eb3;p=ceph.git

OSD: add require_same_peer_inst(OpRequestRef&,OSDMap&) helper

Signed-off-by: Greg Farnum <greg@inktank.com>
(cherry picked from commit e99acf9810976b1fc74b84ad289773af43be973f)

Conflicts:

	src/osd/OSD.cc
---

diff --git a/src/osd/OSD.cc b/src/osd/OSD.cc
index 478669764b72..51fdfa94d900 100644
--- a/src/osd/OSD.cc
+++ b/src/osd/OSD.cc
@@ -6152,35 +6152,41 @@ bool OSD::require_self_aliveness(OpRequestRef& op, epoch_t epoch)
   return true;
 }
 
-bool OSD::require_up_osd_peer(OpRequestRef& op, OSDMapRef& map,
-                              epoch_t their_epoch)
+bool OSD::require_same_peer_instance(OpRequestRef& op, OSDMapRef& map)
 {
-  int from = op->get_req()->get_source().num();
-  if (!require_self_aliveness(op, their_epoch)) {
-    return false;
-  } else if (!require_osd_peer(op)) {
-    return false;
-  } else if (map->get_epoch() >= their_epoch &&
-      (!map->have_inst(from) ||
-      map->get_cluster_addr(from) != op->get_req()->get_source_inst().addr)) {
-    dout(0) << "require_osd_peer_up received from non-up osd "
-            << op->get_req()->get_connection()->get_peer_addr()
-            << " " << *op->get_req() << dendl;
+  Message *m = op->get_req();
+  int from = m->get_source().num();
 
-    ConnectionRef con = op->get_req()->get_connection();
+  if (!map->have_inst(from) ||
+      (map->get_cluster_addr(from) != m->get_source_inst().addr)) {
+    dout(5) << "from dead osd." << from << ", marking down, "
+	    << " msg was " << m->get_source_inst().addr
+	    << " expected " << (map->have_inst(from) ?
+				map->get_cluster_addr(from) : entity_addr_t())
+	    << dendl;
+    ConnectionRef con = m->get_connection();
     cluster_messenger->mark_down(con.get());
     Session *s = static_cast<Session*>(con->get_priv());
     if (s) {
-      s->session_dispatch_lock.Lock();
-      clear_session_waiting_on_map(s);
       con->set_priv(NULL);   // break ref <-> session cycle, if any
-      s->session_dispatch_lock.Unlock();
       s->put();
     }
-
     return false;
   }
+  return true;
+}
 
+bool OSD::require_up_osd_peer(OpRequestRef& op, OSDMapRef& map,
+                              epoch_t their_epoch)
+{
+  if (!require_self_aliveness(op, their_epoch)) {
+    return false;
+  } else if (!require_osd_peer(op)) {
+    return false;
+  } else if (map->get_epoch() >= their_epoch &&
+	     !require_same_peer_instance(op, map)) {
+    return false;
+  }
   return true;
 }
 
@@ -6207,19 +6213,9 @@ bool OSD::require_same_or_newer_map(OpRequestRef& op, epoch_t epoch)
   }
 
   // ok, our map is same or newer.. do they still exist?
-  if (m->get_connection()->get_messenger() == cluster_messenger) {
-    int from = m->get_source().num();
-    if (!osdmap->have_inst(from) ||
-	osdmap->get_cluster_addr(from) != m->get_source_inst().addr) {
-      dout(5) << "from dead osd." << from << ", marking down, "
-	      << " msg was " << m->get_source_inst().addr
-	      << " expected " << (osdmap->have_inst(from) ? osdmap->get_cluster_addr(from) : entity_addr_t())
-	      << dendl;
-      ConnectionRef con = m->get_connection();
-      con->set_priv(NULL);   // break ref <-> session cycle, if any
-      cluster_messenger->mark_down(con.get());
-      return false;
-    }
+  if (m->get_connection()->get_messenger() == cluster_messenger &&
+      !require_same_peer_instance(op, osdmap)) {
+    return false;
   }
 
   return true;
diff --git a/src/osd/OSD.h b/src/osd/OSD.h
index 7729a7c791df..d652db7da569 100644
--- a/src/osd/OSD.h
+++ b/src/osd/OSD.h
@@ -1519,6 +1519,12 @@ protected:
    * still are.
    */
   bool require_self_aliveness(OpRequestRef& op, epoch_t alive_since);
+  /**
+   * Verifies that the OSD who sent the given op has the same
+   * address as in the given map.
+   * @pre op was sent by an OSD using the cluster messenger
+   */
+  bool require_same_peer_instance(OpRequestRef& op, OSDMapRef& map);
   bool require_up_osd_peer(OpRequestRef& Op, OSDMapRef& map,
                            epoch_t their_epoch);