gras: dont update item counts until after work

This lets API calls like get_consumed/produced
keep their values until after work is called.
The propagate tags overload need this to work.

1 files changed, 2 insertions, 3 deletions

diff --git a/lib/block_consume.cpp b/lib/block_consume.cpp
index 0316517..4fd2c5d 100644
--- a/lib/block_consume.cpp
+++ b/lib/block_consume.cpp
@@ -23,7 +23,7 @@ void Block::consume(const size_t num_items)
 
 item_index_t Block::get_consumed(const size_t which_input)
 {
-    return (*this)->block_data->stats.items_consumed[which_input];
+    return (*this)->block_data->total_items_consumed[which_input];
 }
 
 SBuffer Block::get_input_buffer(const size_t which_input) const
@@ -37,6 +37,5 @@ GRAS_FORCE_INLINE void BlockActor::consume(const size_t i, const size_t items)
     std::cerr << name << " consume " << items << std::endl;
     #endif
     data->stats.items_consumed[i] += items;
-    const size_t bytes = items*data->input_configs[i].item_size;
-    data->num_input_bytes_read[i] += bytes;
+    data->num_input_items_read[i] += items;
 }