summaryrefslogtreecommitdiff
path: root/lib/block_message.cpp
diff options
context:
space:
mode:
Diffstat (limited to 'lib/block_message.cpp')
-rw-r--r--lib/block_message.cpp12
1 files changed, 6 insertions, 6 deletions
diff --git a/lib/block_message.cpp b/lib/block_message.cpp
index ef7dda6..84078ce 100644
--- a/lib/block_message.cpp
+++ b/lib/block_message.cpp
@@ -8,29 +8,29 @@ using namespace gras;
void Block::post_output_tag(const size_t which_output, const Tag &tag)
{
- (*this)->block->stats.tags_produced[which_output]++;
+ (*this)->block_data->stats.tags_produced[which_output]++;
(*this)->block->post_downstream(which_output, InputTagMessage(tag));
}
void Block::_post_output_msg(const size_t which_output, const PMCC &msg)
{
- (*this)->block->stats.msgs_produced[which_output]++;
+ (*this)->block_data->stats.msgs_produced[which_output]++;
(*this)->block->post_downstream(which_output, InputMsgMessage(msg));
}
TagIter Block::get_input_tags(const size_t which_input)
{
- const std::vector<Tag> &input_tags = (*this)->block->input_tags[which_input];
+ const std::vector<Tag> &input_tags = (*this)->block_data->input_tags[which_input];
return TagIter(input_tags.begin(), input_tags.end());
}
PMCC Block::pop_input_msg(const size_t which_input)
{
- std::vector<PMCC> &input_msgs = (*this)->block->input_msgs[which_input];
- size_t &num_read = (*this)->block->num_input_msgs_read[which_input];
+ std::vector<PMCC> &input_msgs = (*this)->block_data->input_msgs[which_input];
+ size_t &num_read = (*this)->block_data->num_input_msgs_read[which_input];
if (num_read >= input_msgs.size()) return PMCC();
PMCC p = input_msgs[num_read++];
- (*this)->block->stats.msgs_consumed[which_input]++;
+ (*this)->block_data->stats.msgs_consumed[which_input]++;
return p;
}