msgr: small fault logic fix

diff --git a/src/msg/SimpleMessenger.cc b/src/msg/SimpleMessenger.cc
index 55f5d6649cdafcb16a01fba58e8307eca19f76c5..414439099b573088518895ce3eb181e8cef3fce1 100644 (file)
--- a/src/msg/SimpleMessenger.cc
+++ b/src/msg/SimpleMessenger.cc
@@ -1070,7 +1070,7 @@ void SimpleMessenger::Pipe::fault(bool onconnect, bool onread)
   // requeue sent items
   requeue_sent();
 
-  if (q.empty()) {
+  if (!is_queued()) {
     if (state == STATE_CLOSING || onconnect) {
       dout(10) << "fault on connect, or already closing, and q empty: setting closed." << dendl;
       state = STATE_CLOSED;