diff options
Diffstat (limited to 'lib/gras_impl')
| -rw-r--r-- | lib/gras_impl/block_actor.hpp | 1 | ||||
| -rw-r--r-- | lib/gras_impl/input_buffer_queues.hpp | 6 |
2 files changed, 7 insertions, 0 deletions
diff --git a/lib/gras_impl/block_actor.hpp b/lib/gras_impl/block_actor.hpp index 8a2d5ae..250b4c6 100644 --- a/lib/gras_impl/block_actor.hpp +++ b/lib/gras_impl/block_actor.hpp @@ -135,6 +135,7 @@ struct BlockActor : Apology::Worker const bool has_input_bufs = not this->input_queues.empty(i) and this->input_queues.ready(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->input_queues.update_has_msg(i, has_input_msgs); } GRAS_FORCE_INLINE bool is_input_done(const size_t i) diff --git a/lib/gras_impl/input_buffer_queues.hpp b/lib/gras_impl/input_buffer_queues.hpp index 48533b9..7bdbddc 100644 --- a/lib/gras_impl/input_buffer_queues.hpp +++ b/lib/gras_impl/input_buffer_queues.hpp @@ -151,6 +151,12 @@ struct InputBufferQueues return _enqueued_bytes[i]/_items_sizes[i]; } + GRAS_FORCE_INLINE void update_has_msg(const size_t i, const bool has) + { + if (has) _bitset.set(i); + else __update(i); + } + BitSet _bitset; std::vector<size_t> _items_sizes; std::vector<size_t> _enqueued_bytes; |