[websocket] fixed getRanged requests

[profile/ivi/automotive-message-broker.git] / lib / asyncqueue.hpp

diff --git a/lib/asyncqueue.hpp b/lib/asyncqueue.hpp
index ed0c69b..6557958 100644 (file)
--- a/lib/asyncqueue.hpp
+++ b/lib/asyncqueue.hpp
@@ -56,7 +56,7 @@ public:
 
                if(mBlocking)
                {
-                       while(!mQueue.size())
+                       if(!mQueue.size())
                        {
                                cond.wait(lock);
                        }
@@ -78,13 +78,12 @@ public:
        {
                {
                        std::lock_guard<std::mutex> lock(mutex);
-
                        mQueue.insert(item);
                }
 
                if(mBlocking)
                {
-                       cond.notify_one();
+                       cond.notify_all();
                }
        }