diff options
Diffstat (limited to 'lib/block_consume.cpp')
| -rw-r--r-- | lib/block_consume.cpp | 10 |
1 files changed, 5 insertions, 5 deletions
diff --git a/lib/block_consume.cpp b/lib/block_consume.cpp index efdb07e..04529f4 100644 --- a/lib/block_consume.cpp +++ b/lib/block_consume.cpp @@ -24,12 +24,12 @@ void Block::consume(const size_t num_items) item_index_t Block::get_consumed(const size_t which_input) { - return (*this)->block->stats.items_consumed[which_input]; + return (*this)->block_data->stats.items_consumed[which_input]; } SBuffer Block::get_input_buffer(const size_t which_input) const { - return (*this)->block->input_queues.front(which_input); + return (*this)->block_data->input_queues.front(which_input); } GRAS_FORCE_INLINE void BlockActor::consume(const size_t i, const size_t items) @@ -37,8 +37,8 @@ GRAS_FORCE_INLINE void BlockActor::consume(const size_t i, const size_t items) #ifdef ITEM_CONSPROD std::cerr << name << " consume " << items << std::endl; #endif - this->stats.items_consumed[i] += items; - const size_t bytes = items*this->input_configs[i].item_size; - this->input_queues.consume(i, bytes); + data->stats.items_consumed[i] += items; + const size_t bytes = items*data->input_configs[i].item_size; + data->input_queues.consume(i, bytes); this->trim_tags(i); } |