diff options
Diffstat (limited to 'lib/block_message.cpp')
-rw-r--r-- | lib/block_message.cpp | 12 |
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; } |