diff options
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 |