diff options
Diffstat (limited to 'lib/block_task.cpp')
| -rw-r--r-- | lib/block_task.cpp | 9 |
1 files changed, 3 insertions, 6 deletions
diff --git a/lib/block_task.cpp b/lib/block_task.cpp index f18b9d4..6696b62 100644 --- a/lib/block_task.cpp +++ b/lib/block_task.cpp @@ -248,14 +248,11 @@ void BlockActor::handle_task(void) GRAS_FORCE_INLINE void BlockActor::conclusion(void) { - + //missing at least one upstream provider? //since nothing else is coming in, its safe to mark done - if (this->inputs_done.all()) //no upstream providers + if (this->any_inputs_done() or this->forecast_fail) { - if (not this->input_queues.all_ready() or this->forecast_fail) - { - this->mark_done(); - } + this->mark_done(); } //still have IO ready? kick off another task |