summaryrefslogtreecommitdiff
path: root/python/qpid/delegates.py
diff options
context:
space:
mode:
authorGordon Sim <gsim@apache.org>2008-08-18 16:52:11 +0000
committerGordon Sim <gsim@apache.org>2008-08-18 16:52:11 +0000
commitb0edfc1f74ecb304390a1bfffc467f125d4bbf20 (patch)
treed228003409193c73808c800b18f55cbdd68d4231 /python/qpid/delegates.py
parente3b5f0555c3e6ab3f875e8fa97153076bdef309e (diff)
downloadqpid-python-b0edfc1f74ecb304390a1bfffc467f125d4bbf20.tar.gz
QPID-1250: Ensure broker receives session.detached before channel can be reused.
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@686818 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'python/qpid/delegates.py')
-rw-r--r--python/qpid/delegates.py7
1 files changed, 6 insertions, 1 deletions
diff --git a/python/qpid/delegates.py b/python/qpid/delegates.py
index 69b93e73dc..bf26553dda 100644
--- a/python/qpid/delegates.py
+++ b/python/qpid/delegates.py
@@ -74,8 +74,13 @@ class Delegate:
notify(ch.session.condition)
def session_detach(self, ch, d):
- ssn = self.connection.detach(d.name, ch)
+ #send back the confirmation of detachment before removing the
+ #channel from the attached set; this avoids needing to hold the
+ #connection lock during the sending of this control and ensures
+ #that if the channel is immediately reused for a new session the
+ #attach request will follow the detached notification.
ch.session_detached(d.name)
+ ssn = self.connection.detach(d.name, ch)
def session_detached(self, ch, d):
self.connection.detach(d.name, ch)