From 4cdb93f82d58cc147119b733dea60f4042e0ee34 Mon Sep 17 00:00:00 2001
From: Johannes Wendel <j_wendel14@cs.uni-kl.de>
Date: Thu, 28 Nov 2019 23:07:15 +0100
Subject: [PATCH] reverted queue

---
 FlippR-Driver/src/utility/BlockingQueue.hpp | 8 ++++----
 1 file changed, 4 insertions(+), 4 deletions(-)

diff --git a/FlippR-Driver/src/utility/BlockingQueue.hpp b/FlippR-Driver/src/utility/BlockingQueue.hpp
index 1a0a6d3..ec955fd 100644
--- a/FlippR-Driver/src/utility/BlockingQueue.hpp
+++ b/FlippR-Driver/src/utility/BlockingQueue.hpp
@@ -2,7 +2,7 @@
  * BlockingQueue.hpp
  *
  *  Created on: May 17, 2018
- *      Author: Andreas Schneider, Johannes Wendel, Jonas Zeunert
+ *      Author: Andreas Schneider, Johannes Wendel, Jonas Zeunert, Rafael Vinci, Dr. Franca Rupprecht
  */
 
 #ifndef SRC_UTILITIES_BLOCKINGQUEUE_HPP_
@@ -25,7 +25,7 @@ template<typename T>
 class BlockingQueue : public IBlockingQueue<T>
 {
 private:
-  std::mutex write_mutex, read_mutex;
+  std::mutex d_mutex;
   std::condition_variable d_condition;
   heap::priority_queue<T, heap::stable<true>> p_queue;
 
@@ -33,7 +33,7 @@ public:
   void push(T const &value)
   {
     {
-      std::unique_lock<std::mutex> lock(this->write_mutex);
+      std::unique_lock<std::mutex> lock(this->d_mutex);
       p_queue.push(value);
     }
     this->d_condition.notify_one();
@@ -41,7 +41,7 @@ public:
 
   T pop()
   {
-    std::unique_lock<std::mutex> lock(this->read_mutex);
+    std::unique_lock<std::mutex> lock(this->d_mutex);
     this->d_condition.wait(lock, [=]
     { return !this->p_queue.empty(); });
     T rc = *this->p_queue.begin();