mds: drop reference if message in laggy queue is unrecognized

drop reference if message in laggy queue is unrecognized

Signed-off-by: huanwen ren <ren.huanwen@zte.com.cn>

diff --git a/src/mds/MDSRank.cc b/src/mds/MDSRank.cc
index 188750a195dc4b961d39d44716d84ec8a0086004..b7cee46484b0c7e0d0ff2bf2380b0c0cea48ff1d 100644 (file)
--- a/src/mds/MDSRank.cc
+++ b/src/mds/MDSRank.cc
@@ -662,7 +662,10 @@ void MDSRank::_advance_queues()
       old->put();
     } else {
       dout(7) << " processing laggy deferred " << *old << dendl;
-      handle_deferrable_message(old);
+      if (!handle_deferrable_message(old)) {
+        dout(0) << "unrecognized message " << *old << dendl;
+        old->put();
+      }
     }
 
     heartbeat_reset();