X-Git-Url: http://g0dil.de/git?a=blobdiff_plain;f=PPI%2FConnectors.cci;h=c61555cc3447520ee52d5dec8569e19aecb86afd;hb=1b1d76302a5d61e918ef71f1c8e11f80ac1262e2;hp=9e0f8325159573d3808c42e2a927b5018fc75ba3;hpb=416cdd1c85cdf2669785e93a71426a3206166758;p=senf.git diff --git a/PPI/Connectors.cci b/PPI/Connectors.cci index 9e0f832..c61555c 100644 --- a/PPI/Connectors.cci +++ b/PPI/Connectors.cci @@ -1,8 +1,8 @@ // $Id$ // -// Copyright (C) 2007 -// Fraunhofer Institute for Open Communication Systems (FOKUS) -// Competence Center NETwork research (NET), St. Augustin, GERMANY +// Copyright (C) 2007 +// Fraunhofer Institute for Open Communication Systems (FOKUS) +// Competence Center NETwork research (NET), St. Augustin, GERMANY // Stefan Bund // // This program is free software; you can redistribute it and/or modify @@ -24,6 +24,8 @@ \brief Connectors inline non-template implementation */ // Custom includes +#include "../Utils/TypeInfo.hh" +#include "../Utils/senfassert.hh" #define prefix_ inline ///////////////////////////////cci.p/////////////////////////////////////// @@ -34,14 +36,14 @@ prefix_ senf::ppi::connector::Connector & senf::ppi::connector::Connector::peer() const { - BOOST_ASSERT(peer_); + SENF_ASSERT(peer_); return *peer_; } prefix_ senf::ppi::module::Module & senf::ppi::connector::Connector::module() const { - BOOST_ASSERT(module_); + SENF_ASSERT(module_); return *module_; } @@ -58,13 +60,6 @@ prefix_ senf::ppi::connector::Connector::~Connector() peer_->peer_ = 0; } -prefix_ void senf::ppi::connector::Connector::connect(Connector & target) -{ - BOOST_ASSERT( ! peer_ && ! target.peer_ ); - peer_ = & target; - target.peer_ = this; -} - //////////////////////////////////////// // private members @@ -121,7 +116,7 @@ prefix_ senf::ppi::connector::PassiveConnector::PassiveConnector() prefix_ void senf::ppi::connector::PassiveConnector::emit() { - BOOST_ASSERT(callback_); + SENF_ASSERT(callback_); if (!throttled()) callback_(); } @@ -134,8 +129,8 @@ prefix_ void senf::ppi::connector::PassiveConnector::notifyThrottle() if (!throttled()) { remoteThrottled_ = true; emitThrottle(); - } - else + } + else remoteThrottled_ = true; } @@ -221,7 +216,7 @@ senf::ppi::connector::InputConnector::end() prefix_ senf::Packet senf::ppi::connector::InputConnector::peek() const { - BOOST_ASSERT( ! queue_.empty() ); + SENF_ASSERT( ! queue_.empty() ); return queue_.back(); } @@ -317,6 +312,9 @@ prefix_ void senf::ppi::connector::GenericPassiveOutput::connect(GenericActiveIn Connector::connect(target); } +prefix_ senf::ppi::connector::GenericPassiveOutput::GenericPassiveOutput() +{} + /////////////////////////////////////////////////////////////////////////// // senf::ppi::connector::GenericActiveInput @@ -337,6 +335,9 @@ prefix_ void senf::ppi::connector::GenericActiveInput::request() peer().emit(); } +prefix_ senf::ppi::connector::GenericActiveInput::GenericActiveInput() +{} + /////////////////////////////////////////////////////////////////////////// // senf::ppi::connector::GenericActiveOutput @@ -357,6 +358,9 @@ prefix_ void senf::ppi::connector::GenericActiveOutput::connect(GenericPassiveIn Connector::connect(target); } +prefix_ senf::ppi::connector::GenericActiveOutput::GenericActiveOutput() +{} + ///////////////////////////////cci.e/////////////////////////////////////// #undef prefix_