mds: MMDSOp implementation and detect unversioned messages

Fixes: https://tracker.ceph.com/issues/41565
Signed-off-by: Jos Collin <jcollin@redhat.com>

diff --git a/src/mds/MDSRank.cc b/src/mds/MDSRank.cc
index d6839d5e640b742618553365b34ff1b0a41e5f51..5f460a14b866b8bf3cfb38d4fd00c305ed04044b 100644 (file)
--- a/src/mds/MDSRank.cc
+++ b/src/mds/MDSRank.cc
@@ -13,7 +13,7 @@
  */
 
 #include <string_view>
-
+#include <typeinfo>
 #include "common/debug.h"
 #include "common/errno.h"
 #include "common/async/blocked_completion.h"
@@ -1008,7 +1008,14 @@ void MDSRank::ProgressThread::shutdown()
 
 bool MDSRankDispatcher::ms_dispatch(const cref_t<Message> &m)
 {
-  if (m->get_source().is_client()) {
+  if (m->get_source().is_mds()) {
+    const Message *msg = m.get();
+    const MMDSOp *op = dynamic_cast<const MMDSOp*>(msg);
+    if (!op)
+      dout(0) << typeid(*msg).name() << " is not an MMDSOp type" << dendl;
+    ceph_assert(op);
+  }
+  else if (m->get_source().is_client()) {
     Session *session = static_cast<Session*>(m->get_connection()->get_priv().get());
     if (session)
       session->last_seen = Session::clock::now();

diff --git a/src/messages/MMDSOp.h b/src/messages/MMDSOp.h
new file mode 100644 (file)
index 0000000..4dc6edb
--- /dev/null
+++ b/src/messages/MMDSOp.h
@@ -0,0 +1,15 @@
+#pragma once
+
+#include "msg/Message.h"
+
+/*
+ * MMDSOp is used to ensure that all incoming MDS-MDS
+ * messages in MDSRankDispatcher are versioned. Therefore
+ * all MDS-MDS messages must be of type MMDSOp.
+ */
+class MMDSOp: public SafeMessage {
+public:
+  template<typename... Types>
+  MMDSOp(Types&&... args)
+    : SafeMessage(std::forward<Types>(args)...) {}
+};