diff options
Diffstat (limited to 'lib/gras_impl/block_actor.hpp')
| -rw-r--r-- | lib/gras_impl/block_actor.hpp | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/lib/gras_impl/block_actor.hpp b/lib/gras_impl/block_actor.hpp index 5dd7421..d32c105 100644 --- a/lib/gras_impl/block_actor.hpp +++ b/lib/gras_impl/block_actor.hpp @@ -110,11 +110,12 @@ struct BlockActor : Apology::Worker void buffer_returner(const size_t index, SBuffer &buffer); void mark_done(void); void handle_task(void); + void input_fail(const size_t index); void sort_tags(const size_t index); void trim_tags(const size_t index); GRAS_FORCE_INLINE bool any_inputs_done(void) { - if (this->inputs_done.none()) return false; + if (this->inputs_done.none() or this->input_queues.all_ready()) return false; for (size_t i = 0; i < this->get_num_inputs(); i++) { if (this->inputs_done[i] and not this->input_queues.ready(i)) @@ -130,7 +131,6 @@ struct BlockActor : Apology::Worker std::vector<size_t> output_items_sizes; std::vector<InputPortConfig> input_configs; std::vector<OutputPortConfig> output_configs; - std::vector<size_t> input_reserve_items; size_t output_multiple_items; //keeps track of production |