You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@qpid.apache.org by rh...@apache.org on 2010/02/16 04:26:07 UTC
svn commit: r910382 - /qpid/trunk/qpid/python/qpid/connection.py
Author: rhs
Date: Tue Feb 16 03:26:06 2010
New Revision: 910382
URL: http://svn.apache.org/viewvc?rev=910382&view=rev
Log:
capture and report socket errors
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=910382&r1=910381&r2=910382&view=diff
==============================================================================
--- qpid/trunk/qpid/python/qpid/connection.py (original)
+++ qpid/trunk/qpid/python/qpid/connection.py Tue Feb 16 03:26:06 2010
@@ -163,13 +163,15 @@
break
except socket.timeout:
if self.aborted():
+ self.close_code = (None, "connection timed out")
self.detach_all()
- raise Closed("connection timed out")
+ break
else:
continue
except socket.error, e:
+ self.close_code = (None, str(e))
self.detach_all()
- raise Closed(e)
+ break
frame_dec.write(data)
seg_dec.write(*frame_dec.read())
op_dec.write(*seg_dec.read())
---------------------------------------------------------------------
Apache Qpid - AMQP Messaging Implementation
Project: http://qpid.apache.org
Use/Interact: mailto:commits-subscribe@qpid.apache.org