diff options
| author | Haomai Wang <haomai@xsky.com> | 2016-06-29 07:56:39 +0200 |
|---|---|---|
| committer | Haomai Wang <haomai@xsky.com> | 2016-06-29 07:56:39 +0200 |
| commit | 464c07709ce72382aacb5860a5ea48136fff7326 (patch) | |
| tree | 21930d568a7e1e0004f2a3c2dd52837b06fd2320 /src/msg/async/AsyncMessenger.cc | |
| parent | Merge pull request #9991 from stiopaa1/msg_asyncmess_moveCProcessorAccept_class (diff) | |
| download | ceph-464c07709ce72382aacb5860a5ea48136fff7326.tar.xz ceph-464c07709ce72382aacb5860a5ea48136fff7326.zip | |
msg/async: add "queue_reset" argument
Signed-off-by: Haomai Wang <haomai@xsky.com>
Diffstat (limited to '')
| -rw-r--r-- | src/msg/async/AsyncMessenger.cc | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/src/msg/async/AsyncMessenger.cc b/src/msg/async/AsyncMessenger.cc index c4752c1eab2..ff3223450b4 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; } |