diff options
Diffstat (limited to 'cpp/src/qpid/ha/QueueGuard.h')
-rw-r--r-- | cpp/src/qpid/ha/QueueGuard.h | 12 |
1 files changed, 9 insertions, 3 deletions
diff --git a/cpp/src/qpid/ha/QueueGuard.h b/cpp/src/qpid/ha/QueueGuard.h index 3904b3bd3f..e7ceb351e8 100644 --- a/cpp/src/qpid/ha/QueueGuard.h +++ b/cpp/src/qpid/ha/QueueGuard.h @@ -54,6 +54,9 @@ class ReplicatingSubscription; * THREAD SAFE: Concurrent calls: * - enqueued() via QueueObserver in arbitrary connection threads. * - attach(), cancel(), complete() from ReplicatingSubscription in subscription thread. + * + * Lock Hierarchy: ReplicatingSubscription MUS NOT call QueueGuard with it's lock held + * QueueGuard MAY call ReplicatingSubscription with it's lock held. */ class QueueGuard { public: @@ -104,17 +107,20 @@ class QueueGuard { private: class QueueObserver; + typedef std::map<framing::SequenceNumber, + boost::intrusive_ptr<broker::AsyncCompletion> > Delayed; + + void complete(framing::SequenceNumber, sys::Mutex::ScopedLock &); + void complete(Delayed::iterator, sys::Mutex::ScopedLock &); sys::Mutex lock; + bool cancelled; std::string logPrefix; broker::Queue& queue; - typedef std::map<framing::SequenceNumber, boost::intrusive_ptr<broker::AsyncCompletion> > Delayed; Delayed delayed; ReplicatingSubscription* subscription; boost::shared_ptr<QueueObserver> observer; QueueRange range; - - void completeRange(Delayed::iterator begin, Delayed::iterator end); }; }} // namespace qpid::ha |