fixed input fail logic w/ input_queues.is_front_maximal

1 files changed, 2 insertions, 5 deletions

diff --git a/lib/block_task.cpp b/lib/block_task.cpp
index 7507e85..5e1db89 100644
--- a/lib/block_task.cpp
+++ b/lib/block_task.cpp
@@ -59,8 +59,6 @@ void BlockActor::mark_done(void)
 
 void BlockActor::input_fail(const size_t i)
 {
-    SBuffer &buff = this->input_queues.front(i);
-
     //input failed, accumulate and try again
     if (not this->input_queues.is_accumulated(i))
     {
@@ -77,10 +75,9 @@ void BlockActor::input_fail(const size_t i)
     }
 
     //check that the input is not already maxed
-    const size_t front_items = buff.length/this->input_items_sizes[i];
-    if (front_items >= this->input_configs[i].maximum_items)
+    if (this->input_queues.is_front_maximal(i))
     {
-        //throw std::runtime_error("input_fail called on maximum_items buffer");
+        throw std::runtime_error("input_fail called on maximum_items buffer");
     }
 }