X-Git-Url: http://g0dil.de/git?a=blobdiff_plain;f=senf%2FPPI%2FConnectors.cc;h=9b0232db300d188c5947633206c402825234d974;hb=7ee689fe38d66aa3a0004d55e8708750d35adc0b;hp=6181eb997784f23b1fa1c8f48d066e950ea6197d;hpb=61b2e2ea5cb50df90931acf3fcd840493ba762a9;p=senf.git diff --git a/senf/PPI/Connectors.cc b/senf/PPI/Connectors.cc index 6181eb9..9b0232d 100644 --- a/senf/PPI/Connectors.cc +++ b/senf/PPI/Connectors.cc @@ -32,9 +32,9 @@ //#include "Connectors.mpp" #define prefix_ -///////////////////////////////cc.p//////////////////////////////////////// +//-///////////////////////////////////////////////////////////////////////////////////////////////// -/////////////////////////////////////////////////////////////////////////// +//-///////////////////////////////////////////////////////////////////////////////////////////////// // senf::ppi::connector::Connector prefix_ senf::ppi::connector::Connector::~Connector() @@ -66,6 +66,7 @@ prefix_ void senf::ppi::connector::Connector::connect(Connector & target) SENF_ASSERT( ! target.peer_, "senf::ppi::connector::Connector::connect(): (target) " "duplicate connection" ); + if (! (packetTypeID() == typeid(void) || target.packetTypeID() == typeid(void) || packetTypeID() == target.packetTypeID()) ) @@ -220,7 +221,7 @@ prefix_ void senf::ppi::connector::Connector::v_disconnected() prefix_ void senf::ppi::connector::Connector::v_connected() {} -/////////////////////////////////////////////////////////////////////////// +//-///////////////////////////////////////////////////////////////////////////////////////////////// // senf::ppi::connector::PassiveConnector prefix_ senf::ppi::connector::PassiveConnector::~PassiveConnector() @@ -241,7 +242,7 @@ prefix_ void senf::ppi::connector::PassiveConnector::v_connected() peer_ = & dynamic_cast(Connector::peer()); } -//////////////////////////////////////// +//-///////////////////////////////////////////////////////////////////////////////////////////////// // private members prefix_ void senf::ppi::connector::PassiveConnector::v_init() @@ -285,7 +286,7 @@ prefix_ void senf::ppi::connector::PassiveConnector::notifyUnthrottle() SENF_PPI_THROTTLE_TRACE("OUT", "not forwarding unthrottle event"); } -/////////////////////////////////////////////////////////////////////////// +//-///////////////////////////////////////////////////////////////////////////////////////////////// // senf::ppi::connector::ActiveConnector prefix_ senf::ppi::connector::ActiveConnector::~ActiveConnector() @@ -306,7 +307,7 @@ prefix_ void senf::ppi::connector::ActiveConnector::v_connected() peer_ = & dynamic_cast(Connector::peer()); } -//////////////////////////////////////// +//-///////////////////////////////////////////////////////////////////////////////////////////////// // private members prefix_ void senf::ppi::connector::ActiveConnector::v_init() @@ -355,7 +356,7 @@ prefix_ void senf::ppi::connector::ActiveConnector::unregisterRoute(ForwardingRo notifyRoutes_.erase(i); } -/////////////////////////////////////////////////////////////////////////// +//-///////////////////////////////////////////////////////////////////////////////////////////////// // senf::ppi::connector::InputConnector prefix_ senf::Packet senf::ppi::connector::InputConnector::operator()() @@ -386,7 +387,7 @@ prefix_ void senf::ppi::connector::InputConnector::v_connected() peer_ = & dynamic_cast(Connector::peer()); } -//////////////////////////////////////// +//-///////////////////////////////////////////////////////////////////////////////////////////////// // private members prefix_ void senf::ppi::connector::InputConnector::v_requestEvent() @@ -398,7 +399,7 @@ prefix_ void senf::ppi::connector::InputConnector::v_enqueueEvent() prefix_ void senf::ppi::connector::InputConnector::v_dequeueEvent() {} -/////////////////////////////////////////////////////////////////////////// +//-///////////////////////////////////////////////////////////////////////////////////////////////// // senf::ppi::connector::OutputConnector prefix_ void senf::ppi::connector::OutputConnector::v_disconnected() @@ -413,10 +414,10 @@ prefix_ void senf::ppi::connector::OutputConnector::v_connected() peer_ = & dynamic_cast(Connector::peer()); } -/////////////////////////////////////////////////////////////////////////// +//-///////////////////////////////////////////////////////////////////////////////////////////////// // senf::ppi::connector::GenericActiveInput -//////////////////////////////////////// +//-///////////////////////////////////////////////////////////////////////////////////////////////// // private members prefix_ void senf::ppi::connector::GenericActiveInput::v_requestEvent() @@ -424,7 +425,7 @@ prefix_ void senf::ppi::connector::GenericActiveInput::v_requestEvent() request(); } -/////////////////////////////////////////////////////////////////////////// +//-///////////////////////////////////////////////////////////////////////////////////////////////// // senf::ppi::connector::GenericPassiveInput prefix_ void senf::ppi::connector::GenericPassiveInput::v_disconnected() @@ -441,7 +442,7 @@ prefix_ void senf::ppi::connector::GenericPassiveInput::v_connected() peer_ = & dynamic_cast(Connector::peer()); } -//////////////////////////////////////// +//-///////////////////////////////////////////////////////////////////////////////////////////////// // private members prefix_ void senf::ppi::connector::GenericPassiveInput::v_enqueueEvent() @@ -474,7 +475,7 @@ prefix_ void senf::ppi::connector::GenericPassiveInput::v_unthrottleEvent() } } -/////////////////////////////////////////////////////////////////////////// +//-///////////////////////////////////////////////////////////////////////////////////////////////// // senf::ppi::connector::GenericPassiveOutput prefix_ void senf::ppi::connector::GenericPassiveOutput::v_disconnected() @@ -491,7 +492,7 @@ prefix_ void senf::ppi::connector::GenericPassiveOutput::v_connected() peer_ = & dynamic_cast(Connector::peer()); } -/////////////////////////////////////////////////////////////////////////// +//-///////////////////////////////////////////////////////////////////////////////////////////////// // senf::ppi::connector::GenericActiveInput prefix_ void senf::ppi::connector::GenericActiveInput::v_disconnected() @@ -508,7 +509,7 @@ prefix_ void senf::ppi::connector::GenericActiveInput::v_connected() peer_ = & dynamic_cast(Connector::peer()); } -/////////////////////////////////////////////////////////////////////////// +//-///////////////////////////////////////////////////////////////////////////////////////////////// // senf::ppi::connector::GenericActiveOutput prefix_ void senf::ppi::connector::GenericActiveOutput::v_disconnected() @@ -526,7 +527,7 @@ prefix_ void senf::ppi::connector::GenericActiveOutput::v_connected() } -///////////////////////////////cc.e//////////////////////////////////////// +//-///////////////////////////////////////////////////////////////////////////////////////////////// #undef prefix_ //#include "Connectors.mpp"