mark fail: not ready until a new buffer appears

3 files changed, 13 insertions, 0 deletions

diff --git a/lib/block_task.cpp b/lib/block_task.cpp
index b2b08db..9e5917d 100644
--- a/lib/block_task.cpp
+++ b/lib/block_task.cpp
@@ -79,6 +79,9 @@ void BlockActor::input_fail(const size_t i)
     {
         throw std::runtime_error("input_fail called on maximum_items buffer");
     }
+
+    //mark fail: not ready until a new buffer appears
+    this->input_queues.fail(i);
 }
 
 void BlockActor::output_fail(const size_t i)
diff --git a/lib/gras_impl/input_buffer_queues.hpp b/lib/gras_impl/input_buffer_queues.hpp
index f81f226..a6b6ff8 100644
--- a/lib/gras_impl/input_buffer_queues.hpp
+++ b/lib/gras_impl/input_buffer_queues.hpp
@@ -126,6 +126,11 @@ struct InputBufferQueues
         _bitset.reset(i);
     }
 
+    GRAS_FORCE_INLINE void fail(const size_t i)
+    {
+        _bitset.reset(i);
+    }
+
     size_t size(void) const
     {
         return _queues.size();
diff --git a/lib/gras_impl/output_buffer_queues.hpp b/lib/gras_impl/output_buffer_queues.hpp
index c432f4d..722a4c2 100644
--- a/lib/gras_impl/output_buffer_queues.hpp
+++ b/lib/gras_impl/output_buffer_queues.hpp
@@ -56,6 +56,11 @@ struct OutputBufferQueues
         _bitset.set(i, not _queues[i].empty());
     }
 
+    GRAS_FORCE_INLINE void fail(const size_t i)
+    {
+        _bitset.reset(i);
+    }
+
     GRAS_FORCE_INLINE void flush(const size_t i)
     {
         _queues[i].clear();