summaryrefslogtreecommitdiff
path: root/lib/buffer_queue_pool.cpp
diff options
context:
space:
mode:
Diffstat (limited to 'lib/buffer_queue_pool.cpp')
-rw-r--r--lib/buffer_queue_pool.cpp10
1 files changed, 7 insertions, 3 deletions
diff --git a/lib/buffer_queue_pool.cpp b/lib/buffer_queue_pool.cpp
index a30f4a6..a2a4c28 100644
--- a/lib/buffer_queue_pool.cpp
+++ b/lib/buffer_queue_pool.cpp
@@ -8,13 +8,16 @@ using namespace gras;
struct BufferQueuePool : BufferQueue
{
- BufferQueuePool(const size_t num)
+ BufferQueuePool(const size_t num):
+ queue(boost::circular_buffer<SBuffer>(num))
{
- queue.resize(num);
+ //NOP
}
SBuffer &front(void)
{
+ ASSERT(not queue.empty());
+ ASSERT(queue.front());
return queue.front();
}
@@ -27,6 +30,7 @@ struct BufferQueuePool : BufferQueue
void push(const SBuffer &buff)
{
+ ASSERT(buff);
queue.push_back(buff);
}
@@ -48,7 +52,7 @@ BufferQueueSptr BufferQueue::make_pool(
{
SBuffer buff(config);
std::memset(buff.get_actual_memory(), 0, buff.get_actual_length());
- bq->push(buff);
+ //bq->push(buff);
}
return bq;
}