You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@qpid.apache.org by as...@apache.org on 2011/04/11 23:47:07 UTC
svn commit: r1091224 - /qpid/trunk/qpid/cpp/src/qpid/sys/StateMonitor.h
Author: astitcher
Date: Mon Apr 11 21:47:07 2011
New Revision: 1091224
URL: http://svn.apache.org/viewvc?rev=1091224&view=rev
Log:
QPID-3199: Locking error qpid::sys::StateMonitor
Modified:
qpid/trunk/qpid/cpp/src/qpid/sys/StateMonitor.h
Modified: qpid/trunk/qpid/cpp/src/qpid/sys/StateMonitor.h
URL: http://svn.apache.org/viewvc/qpid/trunk/qpid/cpp/src/qpid/sys/StateMonitor.h?rev=1091224&r1=1091223&r2=1091224&view=diff
==============================================================================
--- qpid/trunk/qpid/cpp/src/qpid/sys/StateMonitor.h (original)
+++ qpid/trunk/qpid/cpp/src/qpid/sys/StateMonitor.h Mon Apr 11 21:47:07 2011
@@ -60,13 +60,13 @@ class StateMonitor : public Waitable
operator Enum() const { return state; }
/** @pre Caller holds a ScopedLock */
- void waitFor(Enum s) { ScopedWait(*this); while (s != state) wait(); }
+ void waitFor(Enum s) { ScopedWait w(*this); while (s != state) wait(); }
/** @pre Caller holds a ScopedLock */
- void waitFor(Set s) { ScopedWait(*this); while (!s.test(state)) wait(); }
+ void waitFor(Set s) { ScopedWait w(*this); while (!s.test(state)) wait(); }
/** @pre Caller holds a ScopedLock */
- void waitNot(Enum s) { ScopedWait(*this); while (s == state) wait(); }
+ void waitNot(Enum s) { ScopedWait w(*this); while (s == state) wait(); }
/** @pre Caller holds a ScopedLock */
- void waitNot(Set s) { ScopedWait(*this); while (s.test(state)) wait(); }
+ void waitNot(Set s) { ScopedWait w(*this); while (s.test(state)) wait(); }
private:
Enum state;
---------------------------------------------------------------------
Apache Qpid - AMQP Messaging Implementation
Project: http://qpid.apache.org
Use/Interact: mailto:commits-subscribe@qpid.apache.org