gras: auto increase queue size to fix #44

1 files changed, 6 insertions, 2 deletions

diff --git a/lib/gras_impl/input_buffer_queues.hpp b/lib/gras_impl/input_buffer_queues.hpp
index 14d77c2..d15e472 100644
--- a/lib/gras_impl/input_buffer_queues.hpp
+++ b/lib/gras_impl/input_buffer_queues.hpp
@@ -20,7 +20,6 @@ namespace gras
 
 struct InputBufferQueues
 {
-    enum {MAX_QUEUE_SIZE = 128};
     enum {MAX_AUX_BUFF_BYTES=(1<<16)};
 
     static SBuffer make_null_buff(void)
@@ -158,7 +157,7 @@ GRAS_FORCE_INLINE void InputBufferQueues::resize(const size_t size)
     _enqueued_bytes.resize(size, 0);
     _reserve_bytes.resize(size, 1);
     _maximum_bytes.resize(size, MAX_AUX_BUFF_BYTES);
-    _queues.resize(size, boost::circular_buffer<SBuffer>(MAX_QUEUE_SIZE));
+    _queues.resize(size, boost::circular_buffer<SBuffer>(1));
     _preload_bytes.resize(size, 0);
     _aux_queues.resize(size);
 
@@ -253,7 +252,12 @@ GRAS_FORCE_INLINE void InputBufferQueues::accumulate(const size_t i)
 
 GRAS_FORCE_INLINE void InputBufferQueues::push(const size_t i, const SBuffer &buffer)
 {
+    if (_queues[i].full())
+    {
+        _queues[i].set_capacity(_queues[i].size()*2);
+    }
     ASSERT(not _queues[i].full());
+
     if (buffer.length == 0) return;
     _queues[i].push_back(buffer);
     _enqueued_bytes[i] += buffer.length;