X-Git-Url: http://g0dil.de/git?a=blobdiff_plain;f=PPI%2FConnectors.cci;h=9e0f8325159573d3808c42e2a927b5018fc75ba3;hb=416cdd1c85cdf2669785e93a71426a3206166758;hp=51aff51cc019c717f8c079dcb107b4d8136d8b6c;hpb=97a8cbc66aa41ab56f8c6887738c498acf28696e;p=senf.git diff --git a/PPI/Connectors.cci b/PPI/Connectors.cci index 51aff51..9e0f832 100644 --- a/PPI/Connectors.cci +++ b/PPI/Connectors.cci @@ -279,80 +279,80 @@ prefix_ senf::ppi::connector::OutputConnector::OutputConnector() {} /////////////////////////////////////////////////////////////////////////// -// senf::ppi::connector::PassiveInput +// senf::ppi::connector::GenericPassiveInput -prefix_ senf::ppi::connector::PassiveInput::PassiveInput() +prefix_ senf::ppi::connector::GenericPassiveInput::GenericPassiveInput() : qdisc_(new ThresholdQueueing(1,0)) {} -prefix_ senf::ppi::connector::ActiveOutput & senf::ppi::connector::PassiveInput::peer() +prefix_ senf::ppi::connector::GenericActiveOutput & senf::ppi::connector::GenericPassiveInput::peer() const { - return dynamic_cast(Connector::peer()); + return dynamic_cast(Connector::peer()); } -prefix_ bool senf::ppi::connector::PassiveInput::boolean_test() +prefix_ bool senf::ppi::connector::GenericPassiveInput::boolean_test() const { return ! empty(); } /////////////////////////////////////////////////////////////////////////// -// senf::ppi::connector::PassiveOutput +// senf::ppi::connector::GenericPassiveOutput -prefix_ senf::ppi::connector::ActiveInput & senf::ppi::connector::PassiveOutput::peer() +prefix_ senf::ppi::connector::GenericActiveInput & senf::ppi::connector::GenericPassiveOutput::peer() const { - return dynamic_cast(Connector::peer()); + return dynamic_cast(Connector::peer()); } -prefix_ bool senf::ppi::connector::PassiveOutput::boolean_test() +prefix_ bool senf::ppi::connector::GenericPassiveOutput::boolean_test() const { return true; } -prefix_ void senf::ppi::connector::PassiveOutput::connect(ActiveInput & target) +prefix_ void senf::ppi::connector::GenericPassiveOutput::connect(GenericActiveInput & target) { Connector::connect(target); } /////////////////////////////////////////////////////////////////////////// -// senf::ppi::connector::ActiveInput +// senf::ppi::connector::GenericActiveInput -prefix_ senf::ppi::connector::PassiveOutput & senf::ppi::connector::ActiveInput::peer() +prefix_ senf::ppi::connector::GenericPassiveOutput & senf::ppi::connector::GenericActiveInput::peer() const { - return dynamic_cast(Connector::peer()); + return dynamic_cast(Connector::peer()); } -prefix_ bool senf::ppi::connector::ActiveInput::boolean_test() +prefix_ bool senf::ppi::connector::GenericActiveInput::boolean_test() const { return ! empty() || ! peer().throttled(); } -prefix_ void senf::ppi::connector::ActiveInput::request() +prefix_ void senf::ppi::connector::GenericActiveInput::request() { peer().emit(); } /////////////////////////////////////////////////////////////////////////// -// senf::ppi::connector::ActiveOutput +// senf::ppi::connector::GenericActiveOutput -prefix_ senf::ppi::connector::PassiveInput & senf::ppi::connector::ActiveOutput::peer() +prefix_ senf::ppi::connector::GenericPassiveInput & senf::ppi::connector::GenericActiveOutput::peer() const { - return dynamic_cast(Connector::peer()); + return dynamic_cast(Connector::peer()); } -prefix_ bool senf::ppi::connector::ActiveOutput::boolean_test() +prefix_ bool senf::ppi::connector::GenericActiveOutput::boolean_test() const { return ! peer().throttled(); } -prefix_ void senf::ppi::connector::ActiveOutput::connect(PassiveInput & target) +prefix_ void senf::ppi::connector::GenericActiveOutput::connect(GenericPassiveInput & target) { Connector::connect(target); }