repositories
/
deb_libcec.git
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
tree
raw
|
inline
| side by side
renamed libPlatform -> platform. stuck everything from libCEC in the CEC namespace...
[deb_libcec.git]
/
src
/
lib
/
util
/
buffer.h
diff --git
a/src/lib/util/buffer.h
b/src/lib/util/buffer.h
index cafa65574414b5864718038b175d697566572cf9..f284131d2ca1c511ea4932be199603e2435b5dad 100644
(file)
--- a/
src/lib/util/buffer.h
+++ b/
src/lib/util/buffer.h
@@
-31,46
+31,49
@@
* http://www.pulse-eight.net/
*/
* http://www.pulse-eight.net/
*/
-#include "threads.h"
+#include "
../platform/
threads.h"
#include <queue>
#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(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:
+ int m_maxSize;
+ std::queue<_BType> m_buffer;
+ CMutex m_mutex;
+ };
+};