From 854062d73c485027f2f40abac159cb19e85c0dca Mon Sep 17 00:00:00 2001 From: Alan Conway Date: Fri, 14 May 2010 13:55:18 +0000 Subject: Initial multi-thread unit test for messaging API. - added Receiver::isClosed() to test for local close. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@944261 13f79535-47bb-0310-9956-ffa450edef68 --- cpp/src/qpid/client/amqp0_10/ReceiverImpl.cpp | 7 +++++++ cpp/src/qpid/client/amqp0_10/ReceiverImpl.h | 2 ++ 2 files changed, 9 insertions(+) (limited to 'cpp/src/qpid/client') diff --git a/cpp/src/qpid/client/amqp0_10/ReceiverImpl.cpp b/cpp/src/qpid/client/amqp0_10/ReceiverImpl.cpp index 49cfec7497..9b706ab3de 100644 --- a/cpp/src/qpid/client/amqp0_10/ReceiverImpl.cpp +++ b/cpp/src/qpid/client/amqp0_10/ReceiverImpl.cpp @@ -193,6 +193,13 @@ void ReceiverImpl::closeImpl() } } +bool ReceiverImpl::isClosed() const { + sys::Mutex::ScopedLock l(lock); + return state == CANCELLED; +} + + + void ReceiverImpl::setCapacityImpl(uint32_t c) { sys::Mutex::ScopedLock l(lock); diff --git a/cpp/src/qpid/client/amqp0_10/ReceiverImpl.h b/cpp/src/qpid/client/amqp0_10/ReceiverImpl.h index c7e24b774a..5693b7b71f 100644 --- a/cpp/src/qpid/client/amqp0_10/ReceiverImpl.h +++ b/cpp/src/qpid/client/amqp0_10/ReceiverImpl.h @@ -65,6 +65,8 @@ class ReceiverImpl : public qpid::messaging::ReceiverImpl uint32_t getUnsettled(); void received(qpid::messaging::Message& message); qpid::messaging::Session getSession() const; + bool isClosed() const; + private: mutable sys::Mutex lock; boost::intrusive_ptr parent; -- cgit v1.2.1