gras: added hooks to query instantaneous state

1 files changed, 5 insertions, 6 deletions

diff --git a/lib/gras_impl/input_buffer_queues.hpp b/lib/gras_impl/input_buffer_queues.hpp
index 6886e6e..48996ef 100644
--- a/lib/gras_impl/input_buffer_queues.hpp
+++ b/lib/gras_impl/input_buffer_queues.hpp
@@ -105,12 +105,6 @@ struct InputBufferQueues
 
     void push(const size_t i, const SBuffer &buffer);
 
-    GRAS_FORCE_INLINE void flush(const size_t i)
-    {
-        _queues[i].clear();
-        _bitset.reset(i);
-    }
-
     GRAS_FORCE_INLINE void fail(const size_t i)
     {
         _bitset.reset(i);
@@ -148,6 +142,11 @@ struct InputBufferQueues
         _bitset.set(i, _enqueued_bytes[i] >= _reserve_bytes[i]);
     }
 
+    GRAS_FORCE_INLINE size_t get_items_enqueued(const size_t i)
+    {
+        return _enqueued_bytes[i]/_items_sizes[i];
+    }
+
     BitSet _bitset;
     std::vector<size_t> _items_sizes;
     std::vector<size_t> _enqueued_bytes;