X-Git-Url: https://git.piment-noir.org/?a=blobdiff_plain;f=src%2Flib%2Futil%2Fbuffer.h;h=d49de62554ea7ea8305c1c810ce2809d8f2228eb;hb=8bca69de10349c3cfb7ea3ba4ab5f7ebbb34a740;hp=dc7af8366c062f102fb03a80c4ba85cf84e78745;hpb=fac23b028a858e6c8e4773b8a1670b4f96c96ce7;p=deb_libcec.git

diff --git a/src/lib/util/buffer.h b/src/lib/util/buffer.h
index dc7af83..d49de62 100644
--- a/src/lib/util/buffer.h
+++ b/src/lib/util/buffer.h
@@ -31,44 +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) {}
 
-    bool Push(_BType entry)
-    {
-      CLockObject lock(&m_mutex);
-      if (m_buffer.size() == m_maxSize)
-        return false;
+      int Size(void) const { return m_buffer.size(); }
 
-      m_buffer.push(entry);
-      return true;
-    }
+      bool Push(_BType entry)
+      {
+        CLockObject lock(&m_mutex);
+        if (m_buffer.size() == m_maxSize)
+          return false;
 
-    bool Pop(_BType &entry)
-    {
-      bool bReturn(false);
-      CLockObject lock(&m_mutex);
-      if (m_buffer.size() > 0)
+        m_buffer.push(entry);
+        return true;
+      }
+
+      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;
+    };
+};