From: Sage Weil <sage@newdream.net>
Date: Fri, 4 Sep 2009 17:46:11 +0000 (-0700)
Subject: msgr: small fault logic fix
X-Git-Tag: v0.14~32
X-Git-Url: http://git-server-git.apps.pok.os.sepia.ceph.com/?a=commitdiff_plain;h=217533cc19b86a5576b2a675f069b2e7bd47ef72;p=ceph.git

msgr: small fault logic fix
---

diff --git a/src/msg/SimpleMessenger.cc b/src/msg/SimpleMessenger.cc
index 55f5d6649cd..414439099b5 100644
--- 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;