diff options
| author | Josh Blum | 2013-03-31 20:41:04 -0700 |
|---|---|---|
| committer | Josh Blum | 2013-03-31 20:41:04 -0700 |
| commit | e93c4eee812900480b5b2a8c7deab77417cdf448 (patch) | |
| tree | c99af1370859d93fa506baeaaf35c9001a179bf7 /lib/block_task.cpp | |
| parent | 36b49de271c778a1645d27d16cc2e8f4007bed73 (diff) | |
| download | sandhi-e93c4eee812900480b5b2a8c7deab77417cdf448.tar.gz sandhi-e93c4eee812900480b5b2a8c7deab77417cdf448.tar.bz2 sandhi-e93c4eee812900480b5b2a8c7deab77417cdf448.zip | |
gras: fix #60 by checking done logic after handler
Diffstat (limited to 'lib/block_task.cpp')
| -rw-r--r-- | lib/block_task.cpp | 4 |
1 files changed, 1 insertions, 3 deletions
diff --git a/lib/block_task.cpp b/lib/block_task.cpp index 21986fc..cc707a8 100644 --- a/lib/block_task.cpp +++ b/lib/block_task.cpp @@ -211,9 +211,7 @@ void BlockActor::handle_task(void) this->trim_msgs(i); //update the inputs available bit field - const bool has_input_bufs = not this->input_queues.empty(i); - const bool has_input_msgs = not this->input_msgs[i].empty(); - this->inputs_available.set(i, has_input_bufs or has_input_msgs); + this->update_input_avail(i); //missing at least one upstream provider? //since nothing else is coming in, its safe to mark done |