diff options
Diffstat (limited to 'lib/block_task.cpp')
| -rw-r--r-- | lib/block_task.cpp | 5 |
1 files changed, 4 insertions, 1 deletions
diff --git a/lib/block_task.cpp b/lib/block_task.cpp index 0ec66ba..52a641c 100644 --- a/lib/block_task.cpp +++ b/lib/block_task.cpp @@ -215,7 +215,10 @@ void BlockActor::handle_task(void) //------------------------------------------------------------------ //missing at least one upstream provider? //since nothing else is coming in, its safe to mark done - if (this->any_inputs_done()) this->mark_done(); + for (size_t i = 0; i < num_inputs; i++) + { + if (this->is_input_done(i)) this->mark_done(); + } //still have IO ready? kick off another task if (this->input_queues.all_ready() and this->output_queues.all_ready()) |