X-Git-Url: http://g0dil.de/git?a=blobdiff_plain;f=senf%2FPPI%2FJoins.cc;h=bad31fab00d7b79131c35517a4d95d16ffaf0427;hb=a9c9fa201ef6a90e40a7acc690e8c0c12a901736;hp=9338347b8043df5060d9f198a04a01f61d84f262;hpb=7dfac76816b629e4482401f464d3289e783b4422;p=senf.git diff --git a/senf/PPI/Joins.cc b/senf/PPI/Joins.cc index 9338347..bad31fa 100644 --- a/senf/PPI/Joins.cc +++ b/senf/PPI/Joins.cc @@ -39,6 +39,13 @@ /////////////////////////////////////////////////////////////////////////// // senf::ppi::module::PassiveJoin +prefix_ senf::ppi::module::PassiveJoin::PassiveJoin() +{ + noroute(output); + output.onThrottle(&PassiveJoin::onThrottle); + output.onUnthrottle(&PassiveJoin::onUnthrottle); +} + //////////////////////////////////////// // private members @@ -48,11 +55,6 @@ prefix_ void senf::ppi::module::PassiveJoin::connectorSetup(connector::PassiveIn conn.onRequest(boost::bind(&PassiveJoin::request,this,boost::ref(conn))); } -prefix_ void senf::ppi::module::PassiveJoin::request(connector::GenericPassiveInput & input) -{ - output(input()); -} - prefix_ void senf::ppi::module::PassiveJoin::onThrottle() { using boost::lambda::_1; @@ -72,6 +74,12 @@ prefix_ void senf::ppi::module::PassiveJoin::onUnthrottle() /////////////////////////////////////////////////////////////////////////// // senf::ppi::module::PriorityJoin +prefix_ senf::ppi::module::PriorityJoin::PriorityJoin() +{ + noroute(output); + output.onRequest(&PriorityJoin::request); +} + //////////////////////////////////////// // private members