Avoid use of wait(AbsTime::farFuture()) - causes hanging on 32 bit.

git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@589636 13f79535-47bb-0310-9956-ffa450edef68

1 files changed, 4 insertions, 7 deletions

diff --git a/qpid/cpp/src/qpid/sys/ConcurrentQueue.h b/qpid/cpp/src/qpid/sys/ConcurrentQueue.h
index cf8199954e..43e82cadce 100644
--- a/qpid/cpp/src/qpid/sys/ConcurrentQueue.h
+++ b/qpid/cpp/src/qpid/sys/ConcurrentQueue.h
@@ -79,18 +79,15 @@ template <class T> class ConcurrentQueue : public Waitable {
         return true;
     }
 
-    /** Wait up to a timeout for a data item to be available.
-     *@return true if data was available, false if timed out or shut down.
-     *@throws ShutdownException if the queue is destroyed.
+    /** Wait for a data item to be available.
+     * Return false if shut down.
      */
-    bool waitPop(T& data, Duration timeout=TIME_INFINITE) {
+    bool waitPop(T& data) {
         ScopedLock l(lock);
-        AbsTime deadline(now(), timeout);
         {
             ScopedWait(*this);
             while (!shutdownFlag && queue.empty())
-                if (!lock.wait(deadline))
-                    return false;
+                lock.wait();
         }
         if (queue.empty())
             return false;