From: Haomai Wang <haomai@xsky.com>
Date: Wed, 29 Jun 2016 05:56:39 +0000 (+0800)
Subject: msg/async: add "queue_reset" argument
X-Git-Tag: ses5-milestone5~572^2
X-Git-Url: http://git-server-git.apps.pok.os.sepia.ceph.com/?a=commitdiff_plain;h=464c07709ce72382aacb5860a5ea48136fff7326;p=ceph.git

msg/async: add "queue_reset" argument

Signed-off-by: Haomai Wang <haomai@xsky.com>
---

diff --git a/src/msg/async/AsyncMessenger.cc b/src/msg/async/AsyncMessenger.cc
index c4752c1eab28..ff3223450b40 100644
--- a/src/msg/async/AsyncMessenger.cc
+++ b/src/msg/async/AsyncMessenger.cc
@@ -807,7 +807,7 @@ void AsyncMessenger::mark_down(const entity_addr_t& addr)
   AsyncConnectionRef p = _lookup_conn(addr);
   if (p) {
     ldout(cct, 1) << __func__ << " " << addr << " -- " << p << dendl;
-    p->stop();
+    p->stop(true);
   } else {
     ldout(cct, 1) << __func__ << " " << addr << " -- connection dne" << dendl;
   }