implement update barrier

2013-10-17 18:11:53 +02:00
parent 53a0bc963a
commit 19a457ab7d
4 changed files with 52 additions and 2 deletions
@@ -0,0 +1,18 @@
+#include <boost/interprocess/sync/interprocess_mutex.hpp>
+#include <boost/interprocess/sync/interprocess_condition.hpp>
+
+struct SharedBarriers {
+
+   SharedBarriers () :  update_ongoing(false), number_of_queries(0) { }
+
+   // Mutex to protect access to the boolean variable
+   boost::interprocess::interprocess_mutex      update_mutex;
+   boost::interprocess::interprocess_mutex      query_mutex;
+
+   // Condition that no update is running
+   boost::interprocess::interprocess_condition  update_finished_condition;
+
+   // Is there any message?
+   bool update_ongoing;
+   int number_of_queries;
+};