X-Git-Url: https://git.piment-noir.org/?a=blobdiff_plain;f=src%2Flib%2Futil%2Fbuffer.h;h=d49de62554ea7ea8305c1c810ce2809d8f2228eb;hb=3424a2f327e569e92c7282c6e643536984a65c64;hp=cafa65574414b5864718038b175d697566572cf9;hpb=c49c485b94c3670438d329c15f4a785609a126f6;p=deb_libcec.git

diff --git a/src/lib/util/buffer.h b/src/lib/util/buffer.h
index cafa655..d49de62 100644
--- a/src/lib/util/buffer.h
+++ b/src/lib/util/buffer.h
@@ -31,46 +31,49 @@
  *     http://www.pulse-eight.net/
  */
 
-#include "threads.h"
+#include "../platform/threads.h"
 #include <queue>
 
-template<typename _BType>
-  struct CecBuffer
-  {
-  public:
-    CecBuffer(int iMaxSize = 100)
+namespace CEC
+{
+  template<typename _BType>
+    struct CecBuffer
     {
-      m_maxSize = iMaxSize;
-    }
-    virtual ~CecBuffer(void) {}
+    public:
+      CecBuffer(unsigned int iMaxSize = 100)
+      {
+        m_maxSize = iMaxSize;
+      }
+      virtual ~CecBuffer(void) {}
 
-    int Size(void) const { return m_buffer.size(); }
+      int Size(void) const { return m_buffer.size(); }
 
-    bool Push(_BType entry)
-    {
-      CLockObject lock(&m_mutex);
-      if (m_buffer.size() == m_maxSize)
-        return false;
+      bool Push(_BType entry)
+      {
+        CLockObject lock(&m_mutex);
+        if (m_buffer.size() == m_maxSize)
+          return false;
 
-      m_buffer.push(entry);
-      return true;
-    }
+        m_buffer.push(entry);
+        return true;
+      }
 
-    bool Pop(_BType &entry)
-    {
-      bool bReturn(false);
-      CLockObject lock(&m_mutex);
-      if (m_buffer.size() > 0)
+      bool Pop(_BType &entry)
       {
-        entry = m_buffer.front();
-        m_buffer.pop();
-        bReturn = true;
+        bool bReturn(false);
+        CLockObject lock(&m_mutex);
+        if (m_buffer.size() > 0)
+        {
+          entry = m_buffer.front();
+          m_buffer.pop();
+          bReturn = true;
+        }
+        return bReturn;
       }
-      return bReturn;
-    }
 
-  private:
-    int                m_maxSize;
-    std::queue<_BType> m_buffer;
-    CMutex             m_mutex;
-  };
+    private:
+      unsigned int       m_maxSize;
+      std::queue<_BType> m_buffer;
+      CMutex             m_mutex;
+    };
+};