From: Haomai Wang <haomaiwang@gmail.com>
Date: Fri, 13 Feb 2015 09:49:50 +0000 (+0800)
Subject: AsyncConnection: release message when connection is closed
X-Git-Tag: suse_latest~36^2
X-Git-Url: http://git-server-git.apps.pok.os.sepia.ceph.com/?a=commitdiff_plain;h=refs%2Fpull%2F3697%2Fhead;p=ceph.git

AsyncConnection: release message when connection is closed

Signed-off-by: Haomai Wang <haomaiwang@gmail.com>
---

diff --git a/src/msg/async/AsyncConnection.cc b/src/msg/async/AsyncConnection.cc
index aed8c10ed691..a0deea1f2d47 100644
--- a/src/msg/async/AsyncConnection.cc
+++ b/src/msg/async/AsyncConnection.cc
@@ -1899,12 +1899,13 @@ int AsyncConnection::send_message(Message *m)
       center->dispatch_event_external(write_handler);
     }
   } else if (state == STATE_CLOSED) {
-      ldout(async_msgr->cct, 10) << __func__ << " connection closed."
-                                 << " Drop message " << m << dendl;
+    ldout(async_msgr->cct, 10) << __func__ << " connection closed."
+                               << " Drop message " << m << dendl;
+    m->put();
   } else if (async_msgr->get_myaddr() == get_peer_addr()) { //loopback connection
-      ldout(async_msgr->cct, 20) << __func__ << " " << *m << " local" << dendl;
-      local_messages.push_back(m);
-      center->dispatch_event_external(local_deliver_handler);
+    ldout(async_msgr->cct, 20) << __func__ << " " << *m << " local" << dendl;
+    local_messages.push_back(m);
+    center->dispatch_event_external(local_deliver_handler);
   } else {
     out_q[m->get_priority()].push_back(m);
     if (state == STATE_STANDBY && !policy.server) {