summaryrefslogtreecommitdiff
path: root/qpid/python
diff options
context:
space:
mode:
authorGordon Sim <gsim@apache.org>2007-01-23 10:51:53 +0000
committerGordon Sim <gsim@apache.org>2007-01-23 10:51:53 +0000
commit2b71226ef16355b63699be381b52eec3d750acc4 (patch)
tree74605e11109cbef642b54ea94183eb8b78540e5b /qpid/python
parentb091dc5a2f7f36ce2d7cd825aaf963adfbc109d1 (diff)
downloadqpid-python-2b71226ef16355b63699be381b52eec3d750acc4.tar.gz
Proper fix to race condition where connection-close is sent by server. Now handle socket close on worker thread also.
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@498983 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'qpid/python')
-rw-r--r--qpid/python/qpid/peer.py24
1 files changed, 9 insertions, 15 deletions
diff --git a/qpid/python/qpid/peer.py b/qpid/python/qpid/peer.py
index ef913d6196..7c6cf91dea 100644
--- a/qpid/python/qpid/peer.py
+++ b/qpid/python/qpid/peer.py
@@ -71,7 +71,7 @@ class Peer:
try:
frame = self.conn.read()
except EOF, e:
- self.close(e)
+ self.work.close()
break
ch = self.channel(frame.channel)
ch.dispatch(frame, self.work)
@@ -100,6 +100,8 @@ class Peer:
try:
while True:
self.dispatch(self.work.get())
+ except QueueClosed, e:
+ self.close(e)
except:
self.fatal()
@@ -127,22 +129,14 @@ class Channel:
self.queue = None
self.closed = False
self.reason = None
- #lock used to synchronise calls to close
- self.lock = thread.allocate_lock()
def close(self, reason):
- self.lock.acquire()
- try:
- if isinstance(reason, Message):
- self.reason = reason
- if self.closed:
- return
- self.closed = True
- self.reason = reason
- self.incoming.close()
- self.responses.close()
- finally:
- self.lock.release()
+ if self.closed:
+ return
+ self.closed = True
+ self.reason = reason
+ self.incoming.close()
+ self.responses.close()
def dispatch(self, frame, work):
payload = frame.payload