1 files changed, 0 insertions, 83 deletions
diff --git a/lib/block_handlers.cpp b/lib/block_handlers.cpp
index bf081a1..68cb8d3 100644
--- a/lib/block_handlers.cpp
+++ b/lib/block_handlers.cpp
@@ -14,9 +14,7 @@
 // You should have received a copy of the GNU Lesser General Public License
 // along with io_sig program.  If not, see <http://www.gnu.org/licenses/>.
 
-#include "element_impl.hpp"
 #include <gras_impl/block_actor.hpp>
-#include <gras_impl/vector_utils.hpp>
 #include <boost/make_shared.hpp>
 #include <boost/bind.hpp>
 
@@ -150,84 +148,3 @@ void BlockActor::handle_check_tokens(
         this->mark_done();
     }
 }
-
-void BlockActor::handle_topology(
-    const Apology::WorkerTopologyMessage &,
-    const Theron::Address
-){
-    MESSAGE_TRACER();
-
-    const size_t num_inputs = this->get_num_inputs();
-    const size_t num_outputs = this->get_num_outputs();
-
-    //call check_topology on block before committing settings
-    this->block_ptr->check_topology(num_inputs, num_outputs);
-
-    //fill the item sizes from the IO signatures
-    fill_item_sizes_from_sig(this->input_items_sizes, (*block_ptr)->input_signature, num_inputs);
-    fill_item_sizes_from_sig(this->output_items_sizes, (*block_ptr)->output_signature, num_outputs);
-
-    //resize and fill port properties
-    resize_fill_back(this->input_history_items, num_inputs);
-    resize_fill_back(this->output_multiple_items, num_outputs);
-    resize_fill_grow(this->input_inline_enables, num_inputs, false);
-
-    //resize the bytes consumed/produced
-    resize_fill_grow(this->items_consumed, num_inputs, 0);
-    resize_fill_grow(this->items_produced, num_outputs, 0);
-
-    //resize all work buffers to match current connections
-    this->work_input_items.resize(num_inputs);
-    this->work_output_items.resize(num_outputs);
-    this->work_ninput_items.resize(num_inputs);
-    this->fcast_ninput_items.resize(num_inputs);
-    this->input_items.resize(num_inputs);
-    this->output_items.resize(num_outputs);
-    this->consume_items.resize(num_inputs, 0);
-    this->consume_called.resize(num_inputs, false);
-    this->produce_items.resize(num_outputs, 0);
-    this->input_queues.resize(num_inputs);
-    this->output_queues.resize(num_outputs);
-    this->forecast_enable = num_outputs != 0 and num_inputs != 0;
-
-    this->input_tokens.resize(num_inputs);
-    this->output_tokens.resize(num_outputs);
-    this->output_allocation_hints.resize(num_outputs);
-
-    //resize tags vector to match sizes
-    this->input_tags_changed.resize(num_inputs);
-    this->input_tags.resize(num_inputs);
-
-    //a block looses all connections, allow it to free
-    if (num_inputs == 0 and num_outputs == 0)
-    {
-        this->mark_done();
-    }
-
-    this->topology_init = true;
-    this->handle_update_inputs(UpdateInputsMessage(), Theron::Address());
-}
-
-void BlockActor::handle_update_inputs(
-    const UpdateInputsMessage &,
-    const Theron::Address
-){
-    const size_t num_inputs = this->get_num_inputs();
-    const size_t num_outputs = this->get_num_outputs();
-
-    //impose input reserve requirements based on relative rate and output multiple
-    resize_fill_grow(this->input_multiple_items, num_inputs, 1);
-    for (size_t i = 0; i < num_inputs; i++)
-    {
-        //TODO, this is a little cheap, we only look at output multiple [0]
-        const size_t multiple = (num_outputs)?this->output_multiple_items.front():1;
-        if (this->enable_fixed_rate)
-        {
-            this->input_multiple_items[i] = size_t(std::ceil(multiple/this->relative_rate));
-        }
-        if (this->input_multiple_items[i] == 0) this->input_multiple_items[i] = 1;
-    }
-
-    //init the history comprehension on input queues
-    this->input_queues.init(this->input_history_items, this->input_multiple_items, this->input_items_sizes);
-}