Locked Channel::close() due to race.

git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@497404 13f79535-47bb-0310-9956-ffa450edef68

1 files changed, 13 insertions, 7 deletions

diff --git a/qpid/python/qpid/peer.py b/qpid/python/qpid/peer.py
index a265e45f43..ef913d6196 100644
--- a/qpid/python/qpid/peer.py
+++ b/qpid/python/qpid/peer.py
@@ -127,16 +127,22 @@ 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):
-    if isinstance(reason, Message):
+    self.lock.acquire()
+    try:
+      if isinstance(reason, Message):
+        self.reason = reason
+      if self.closed:
+        return
+      self.closed = True
       self.reason = reason
-    if self.closed:
-      return
-    self.closed = True
-    self.reason = reason
-    self.incoming.close()
-    self.responses.close()
+      self.incoming.close()
+      self.responses.close()
+    finally:
+      self.lock.release()
 
   def dispatch(self, frame, work):
     payload = frame.payload