diff options
Diffstat (limited to 'lib/buffer_queue_pool.cpp')
-rw-r--r-- | lib/buffer_queue_pool.cpp | 10 |
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; } |