summaryrefslogtreecommitdiff
path: root/python
diff options
context:
space:
mode:
authorRafael H. Schloming <rhs@apache.org>2010-02-16 03:26:06 +0000
committerRafael H. Schloming <rhs@apache.org>2010-02-16 03:26:06 +0000
commite70d6cf30da590232609f8acaa3c2c84d17a17f0 (patch)
treeae6bed85dbbdcce8d1b91d0b38db2ff322737863 /python
parent3a8b11514dc93922effa1fafd884696c046b47e5 (diff)
downloadqpid-python-e70d6cf30da590232609f8acaa3c2c84d17a17f0.tar.gz
capture and report socket errors
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@910382 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'python')
-rw-r--r--python/qpid/connection.py6
1 files changed, 4 insertions, 2 deletions
diff --git a/python/qpid/connection.py b/python/qpid/connection.py
index 81ce446ab6..39fd7d5ff8 100644
--- a/python/qpid/connection.py
+++ b/python/qpid/connection.py
@@ -163,13 +163,15 @@ class Connection(Framer):
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())