summaryrefslogtreecommitdiff
path: root/lib/block_consume.cpp
diff options
context:
space:
mode:
authorJosh Blum2013-06-05 22:26:26 -0700
committerJosh Blum2013-06-05 22:26:26 -0700
commit43c7ef3e7807ad3035a2882d237b0441e6102817 (patch)
treee7d559f27cf3329d3c1b7e008b2cb422bd72eda9 /lib/block_consume.cpp
parent58a54c2cc19113d7644b80ec032b89fa1c38a54a (diff)
downloadsandhi-43c7ef3e7807ad3035a2882d237b0441e6102817.tar.gz
sandhi-43c7ef3e7807ad3035a2882d237b0441e6102817.tar.bz2
sandhi-43c7ef3e7807ad3035a2882d237b0441e6102817.zip
gras: compiles now with separate data struct
Diffstat (limited to 'lib/block_consume.cpp')
-rw-r--r--lib/block_consume.cpp10
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);
}