summaryrefslogtreecommitdiff
path: root/qpid/cpp
diff options
context:
space:
mode:
authorGordon Sim <gsim@apache.org>2014-06-27 22:14:21 +0000
committerGordon Sim <gsim@apache.org>2014-06-27 22:14:21 +0000
commit7a393e184c9fdcda2294ab7419d8e919dd432f97 (patch)
tree315b886a448cdde08b94765c219bbbeb25e26a02 /qpid/cpp
parent014c7d30c12b4278319cd7aa68f3497893add5b2 (diff)
downloadqpid-python-7a393e184c9fdcda2294ab7419d8e919dd432f97.tar.gz
QPID-5860: release sender lock before invoking on session
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1606259 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'qpid/cpp')
-rw-r--r--qpid/cpp/src/qpid/client/amqp0_10/SenderImpl.cpp8
1 files changed, 5 insertions, 3 deletions
diff --git a/qpid/cpp/src/qpid/client/amqp0_10/SenderImpl.cpp b/qpid/cpp/src/qpid/client/amqp0_10/SenderImpl.cpp
index 49d65226bc..28a1353895 100644
--- a/qpid/cpp/src/qpid/client/amqp0_10/SenderImpl.cpp
+++ b/qpid/cpp/src/qpid/client/amqp0_10/SenderImpl.cpp
@@ -182,9 +182,11 @@ uint32_t SenderImpl::checkPendingSends(bool flush, const sys::Mutex::ScopedLock&
void SenderImpl::closeImpl()
{
- sys::Mutex::ScopedLock l(lock);
- state = CANCELLED;
- sink->cancel(session, name);
+ {
+ sys::Mutex::ScopedLock l(lock);
+ state = CANCELLED;
+ sink->cancel(session, name);
+ }
parent->senderCancelled(name);
}