summaryrefslogtreecommitdiff
path: root/lib/block.cpp
diff options
context:
space:
mode:
Diffstat (limited to 'lib/block.cpp')
-rw-r--r--lib/block.cpp51
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
}