repositories
/
deb_libcec.git
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
tree
raw
|
inline
| side by side
cec: fixed int parameter sizes and some signed/unsigned warnings. will need to be...
[deb_libcec.git]
/
src
/
lib
/
util
/
buffer.h
diff --git
a/src/lib/util/buffer.h
b/src/lib/util/buffer.h
index dc7af8366c062f102fb03a80c4ba85cf84e78745..d49de62554ea7ea8305c1c810ce2809d8f2228eb 100644
(file)
--- a/
src/lib/util/buffer.h
+++ b/
src/lib/util/buffer.h
@@
-31,44
+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(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;
+ };
+};