diff options
| author | Josh Blum | 2012-11-18 19:23:17 -0800 |
|---|---|---|
| committer | Josh Blum | 2012-11-18 19:23:17 -0800 |
| commit | eaaf23409d7748409a343a39eb8087216057d3da (patch) | |
| tree | 8f6a3e4c5a667f8f359defe87c2f79b6b2c4796f /lib/block_task.cpp | |
| parent | 308a2403b23888c3f1d2b1ff3b579c1b17450cf1 (diff) | |
| download | sandhi-eaaf23409d7748409a343a39eb8087216057d3da.tar.gz sandhi-eaaf23409d7748409a343a39eb8087216057d3da.tar.bz2 sandhi-eaaf23409d7748409a343a39eb8087216057d3da.zip | |
improvements to done logic (helps reserve 0 case)
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()) |