You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@qpid.apache.org by gs...@apache.org on 2010/06/02 12:24:10 UTC
svn commit: r950472 - /qpid/trunk/qpid/python/qpid/connection.py
Author: gsim
Date: Wed Jun 2 10:24:10 2010
New Revision: 950472
URL: http://svn.apache.org/viewvc?rev=950472&view=rev
Log:
QPID-2637: Mark connection as failed if read from socket fails
Modified:
qpid/trunk/qpid/python/qpid/connection.py
Modified: qpid/trunk/qpid/python/qpid/connection.py
URL: http://svn.apache.org/viewvc/qpid/trunk/qpid/python/qpid/connection.py?rev=950472&r1=950471&r2=950472&view=diff
==============================================================================
--- qpid/trunk/qpid/python/qpid/connection.py (original)
+++ qpid/trunk/qpid/python/qpid/connection.py Wed Jun 2 10:24:10 2010
@@ -132,6 +132,7 @@ class Connection(Framer):
def detach_all(self):
self.lock.acquire()
+ self.failed = True
try:
for ssn in self.attached.values():
if self.close_code[0] != 200:
---------------------------------------------------------------------
Apache Qpid - AMQP Messaging Implementation
Project: http://qpid.apache.org
Use/Interact: mailto:commits-subscribe@qpid.apache.org