summaryrefslogtreecommitdiff
path: root/lib/buffer_queue_circ.cpp
diff options
context:
space:
mode:
authorJosh Blum2012-12-16 19:39:30 -0800
committerJosh Blum2012-12-16 19:39:30 -0800
commita1ed270616fa0d99c4ad790d9b183a65ce5ee512 (patch)
tree8fdb8d88ce797f67a3ca42af4eba0e86532fa56e /lib/buffer_queue_circ.cpp
parent540c2343a44b823c0060ab9ab1bdc4d55f01e66d (diff)
downloadsandhi-a1ed270616fa0d99c4ad790d9b183a65ce5ee512.tar.gz
sandhi-a1ed270616fa0d99c4ad790d9b183a65ce5ee512.tar.bz2
sandhi-a1ed270616fa0d99c4ad790d9b183a65ce5ee512.zip
some cleanup with the flush/fail for output
Diffstat (limited to 'lib/buffer_queue_circ.cpp')
-rw-r--r--lib/buffer_queue_circ.cpp3
1 files changed, 2 insertions, 1 deletions
diff --git a/lib/buffer_queue_circ.cpp b/lib/buffer_queue_circ.cpp
index 5e69fe0..a75e0b0 100644
--- a/lib/buffer_queue_circ.cpp
+++ b/lib/buffer_queue_circ.cpp
@@ -53,7 +53,7 @@ BufferQueueCirc::BufferQueueCirc(const SBufferConfig &config, const size_t num_b
_bytes_avail = _circ_buff.get_actual_length();
//allocate pool of sbuffers
- _available_buffers.resize(num_buffs);
+ _available_buffers.set_capacity(num_buffs);
_returned_buffers.resize(num_buffs);
_outgone_bytes.resize(num_buffs, 0);
SBufferConfig sconfig = config;
@@ -70,6 +70,7 @@ SBuffer &BufferQueueCirc::front(void)
{
ASSERT(not this->empty());
SBuffer &front = _available_buffers.front();
+ ASSERT(front);
front->config.memory = _write_ptr;
return front;
}