From 464c07709ce72382aacb5860a5ea48136fff7326 Mon Sep 17 00:00:00 2001 From: Haomai Wang Date: Wed, 29 Jun 2016 13:56:39 +0800 Subject: [PATCH] msg/async: add "queue_reset" argument Signed-off-by: Haomai Wang --- src/msg/async/AsyncMessenger.cc | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/src/msg/async/AsyncMessenger.cc b/src/msg/async/AsyncMessenger.cc index c4752c1eab28e..ff3223450b403 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; } -- 2.39.5