]> git-server-git.apps.pok.os.sepia.ceph.com Git - ceph.git/commitdiff
messages/MRoute: remove unused entity_inst_t dest
authorSage Weil <sage@redhat.com>
Wed, 30 May 2018 19:36:08 +0000 (14:36 -0500)
committerSage Weil <sage@redhat.com>
Fri, 1 Jun 2018 13:08:19 +0000 (08:08 -0500)
This is unused in luminous and mimic, too, although the code was
never removed.

Signed-off-by: Sage Weil <sage@redhat.com>
src/messages/MRoute.h
src/mon/Monitor.cc
src/test/mon/test-mon-msg.cc

index c97c2eded417531ba3405d3401115ffe7de886b7..7df923e13b8fb7bd19652a0763e2b2ec7895cd44 100644 (file)
@@ -27,7 +27,6 @@ struct MRoute : public Message {
 
   uint64_t session_mon_tid;
   Message *msg;
-  entity_inst_t dest;
   epoch_t send_osdmap_first;
   
   MRoute() : Message(MSG_ROUTE, HEAD_VERSION, COMPAT_VERSION),
@@ -39,14 +38,6 @@ struct MRoute : public Message {
       session_mon_tid(t),
       msg(m),
       send_osdmap_first(0) {}
-  MRoute(bufferlist bl, const entity_inst_t& i)
-    : Message(MSG_ROUTE, HEAD_VERSION, COMPAT_VERSION),
-      session_mon_tid(0),
-      dest(i),
-      send_osdmap_first(0) {
-    auto p = bl.cbegin();
-    msg = decode_message(NULL, 0, p);
-  }
 private:
   ~MRoute() override {
     if (msg)
@@ -57,7 +48,8 @@ public:
   void decode_payload() override {
     auto p = payload.cbegin();
     decode(session_mon_tid, p);
-    decode(dest, p);
+    entity_inst_t dest_unused;
+    decode(dest_unused, p);
     bool m;
     decode(m, p);
     if (m)
@@ -67,7 +59,8 @@ public:
   void encode_payload(uint64_t features) override {
     using ceph::encode;
     encode(session_mon_tid, payload);
-    encode(dest, payload, features);
+    entity_inst_t dest_unused;
+    encode(dest_unused, payload, features);
     bool m = msg ? true : false;
     encode(m, payload);
     if (msg)
@@ -86,7 +79,7 @@ public:
     if (session_mon_tid)
       o << " tid " << session_mon_tid << ")";
     else
-      o << " to " << dest << ")";
+      o << " tid (none)";
   }
 };
 
index cf526e22f61e48d6fe2787fa71b9963c68570601..f0a430ec290ff5ef86401f205ecb0c6a9a32243e 100644 (file)
@@ -3840,9 +3840,10 @@ void Monitor::handle_route(MonOpRequestRef op)
     return;
   }
   if (m->msg)
-    dout(10) << "handle_route " << *m->msg << " to " << m->dest << dendl;
+    dout(10) << "handle_route tid " << m->session_mon_tid << " " << *m->msg
+            << dendl;
   else
-    dout(10) << "handle_route null to " << m->dest << dendl;
+    dout(10) << "handle_route tid " << m->session_mon_tid << " null" << dendl;
   
   // look it up
   if (m->session_mon_tid) {
@@ -3868,11 +3869,7 @@ void Monitor::handle_route(MonOpRequestRef op)
       dout(10) << " don't have routed request tid " << m->session_mon_tid << dendl;
     }
   } else {
-    dout(10) << " not a routed request, trying to send anyway" << dendl;
-    if (m->msg) {
-      messenger->send_message(m->msg, m->dest);
-      m->msg = NULL;
-    }
+    dout(10) << " not a routed request, ignoring" << dendl;
   }
 }
 
index bb2c4638a65f6c0e36fc35941dc39f45d0c38ffc..f033e859af1242cac3ab62dc12bee4751f2a5ae8 100644 (file)
@@ -301,8 +301,6 @@ TEST_F(MonMsgTest, MRouteTest)
   Message *payload = new MGenericMessage(CEPH_MSG_SHUTDOWN);
   MRoute *m = new MRoute;
   m->msg = payload;
-  m->dest.addr = msg->get_myaddr();
-  m->dest.name = entity_name_t(msg->get_mytype(), -1);
   Message *r = send_wait_reply(m, CEPH_MSG_SHUTDOWN);
   // we want an error
   ASSERT_NE(IS_ERR(r), 0);