Method all_input_queue_empty

bmf/engine/c_engine/src/node.cpp:292–300

}

bool Node::all_input_queue_empty() {
    for (auto input_stream = input_stream_manager_->input_streams_.begin();
         input_stream != input_stream_manager_->input_streams_.end();
         input_stream++) {
        if (!input_stream->second->is_empty())
            return false;
    }
    return true;
}

bool Node::too_many_tasks_pending() {
    return pending_tasks_ >= max_pending_tasks_;