1 files changed, 87 insertions, 0 deletions
diff --git a/Master/Masterarbeit/src/XorayaLogPlugin/bounded_buffer.hpp b/Master/Masterarbeit/src/XorayaLogPlugin/bounded_buffer.hpp
new file mode 100644
index 0000000..09181c7
--- /dev/null
+++ b/Master/Masterarbeit/src/XorayaLogPlugin/bounded_buffer.hpp
@@ -0,0 +1,87 @@
+/*
+ * bounded_buffer.hpp
+ *
+ *  Created on: 25.11.2011
+ *      Author: Eisenhauer
+ */
+
+#ifndef BOUNDED_BUFFER_HPP_
+#define BOUNDED_BUFFER_HPP_
+
+
+#include <boost/circular_buffer.hpp>
+#include <boost/thread/mutex.hpp>
+#include <boost/thread/condition.hpp>
+#include <boost/thread/thread.hpp>
+#include <boost/call_traits.hpp>
+#include <boost/progress.hpp>
+#include <boost/bind.hpp>
+#include <pthread.h>
+#include "global.h"
+
+template <class T>
+class bounded_buffer {
+public:
+
+  typedef boost::circular_buffer<T> container_type;
+  typedef typename container_type::size_type size_type;
+  typedef typename container_type::value_type value_type;
+  typedef typename boost::call_traits<value_type>::param_type param_type;
+
+  explicit bounded_buffer(size_type capacity) : m_unread(0), m_container(capacity)
+  {
+		if(pthread_mutexattr_init(&m_xMutexAttr))
+		{
+			ERROR_PRINT("pthread_mutexattr_init failed");
+		}
+		if(pthread_mutexattr_setprotocol(&m_xMutexAttr, PTHREAD_PRIO_INHERIT))
+		{
+			ERROR_PRINT("pthread_mutexattr_setprotocol PTHREAD_PRIO_INHERIT failed");
+		}
+		if(pthread_mutexattr_settype(&m_xMutexAttr, PTHREAD_MUTEX_RECURSIVE))
+		{
+			ERROR_PRINT("pthread_mutexattr_settype PTHREAD_MUTEX_RECURSIVE failed");
+		}
+		if(pthread_mutex_init(m_mutex.native_handle(), &m_xMutexAttr))
+		{
+			ERROR_PRINT("pthread_mutex_init failed");
+		}
+  }
+
+  void push_front(/*boost::call_traits<value_type>::*/param_type item)
+  {
+	  // param_type represents the "best" way to pass a parameter of type value_type to a method
+	  boost::mutex::scoped_lock lock(m_mutex);
+	  m_not_full.wait(lock, boost::bind(&bounded_buffer<value_type>::is_not_full, this));
+	  m_container.push_front(item);
+	  ++m_unread;
+	  lock.unlock();
+	  m_not_empty.notify_one();
+  }
+
+  void pop_back(value_type* pItem)
+  {
+	  boost::mutex::scoped_lock lock(m_mutex);
+	  m_not_empty.wait(lock, boost::bind(&bounded_buffer<value_type>::is_not_empty, this));
+	  *pItem = m_container[--m_unread];
+	  lock.unlock();
+	  m_not_full.notify_one();
+  }
+
+private:
+  bounded_buffer(const bounded_buffer&);              // Disabled copy constructor
+  bounded_buffer& operator = (const bounded_buffer&); // Disabled assign operator
+
+  bool is_not_empty() const { return m_unread > 0; }
+  bool is_not_full() const { return m_unread < m_container.capacity(); }
+
+  size_type m_unread;
+  container_type m_container;
+  boost::mutex m_mutex;
+  pthread_mutexattr_t m_xMutexAttr;
+  boost::condition m_not_empty;
+  boost::condition m_not_full;
+};
+
+
+#endif /* BOUNDED_BUFFER_HPP_ */