diff options
Diffstat (limited to 'lib/block.cpp')
-rw-r--r-- | lib/block.cpp | 51 |
1 files changed, 1 insertions, 50 deletions
diff --git a/lib/block.cpp b/lib/block.cpp index 0d50ef7..3732fdb 100644 --- a/lib/block.cpp +++ b/lib/block.cpp @@ -51,12 +51,8 @@ Block::Block(const std::string &name): //call block methods to init stuff this->set_input_config(InputPortConfig()); this->set_output_config(OutputPortConfig()); - this->set_fixed_rate(true); - this->set_relative_rate(1.0); - this->set_tag_propagation_policy(TPP_ALL_TO_ALL); this->set_interruptible_work(false); this->set_buffer_affinity(-1); - (*this)->block->output_multiple_items = 1; } template <typename V, typename T> @@ -106,7 +102,6 @@ void Block::set_output_config(const OutputPortConfig &config, const size_t which void Block::consume(const size_t which_input, const size_t how_many_items) { (*this)->block->consume_items[which_input] += how_many_items; - (*this)->block->consume_called[which_input] = true; } void Block::consume_each(const size_t how_many_items) @@ -114,7 +109,6 @@ void Block::consume_each(const size_t how_many_items) for (size_t i = 0; i < (*this)->block->consume_items.size(); i++) { (*this)->block->consume_items[i] += how_many_items; - (*this)->block->consume_called[i] = true; } } @@ -123,39 +117,6 @@ void Block::produce(const size_t which_output, const size_t how_many_items) (*this)->block->produce_items[which_output] += how_many_items; } -void Block::set_fixed_rate(const bool fixed_rate) -{ - (*this)->block->enable_fixed_rate = fixed_rate; -} - -bool Block::fixed_rate(void) const -{ - return (*this)->block->enable_fixed_rate; -} - -void Block::set_output_multiple(const size_t multiple) -{ - (*this)->block->output_multiple_items = multiple; - gras::OutputPortConfig config = this->output_config(); - config.reserve_items = multiple; - this->set_output_config(config); -} - -size_t Block::output_multiple(void) const -{ - return (*this)->block->output_multiple_items; -} - -void Block::set_relative_rate(double relative_rate) -{ - (*this)->block->relative_rate = relative_rate; -} - -double Block::relative_rate(void) const -{ - return (*this)->block->relative_rate; -} - uint64_t Block::nitems_read(const size_t which_input) { return (*this)->block->items_consumed[which_input]; @@ -166,16 +127,6 @@ uint64_t Block::nitems_written(const size_t which_output) return (*this)->block->items_produced[which_output]; } -Block::tag_propagation_policy_t Block::tag_propagation_policy(void) -{ - return (*this)->block->tag_prop_policy; -} - -void Block::set_tag_propagation_policy(Block::tag_propagation_policy_t p) -{ - (*this)->block->tag_prop_policy = p; -} - void Block::post_output_tag( const size_t which_output, const Tag &tag @@ -190,7 +141,7 @@ Block::TagIter Block::get_input_tags( return boost::make_iterator_range(input_tags.begin(), input_tags.end()); } -void Block::forecast(int, std::vector<int> &) +void Block::propagate_tags(const size_t, const TagIter &) { //NOP } |