X-Git-Url: http://g0dil.de/git?a=blobdiff_plain;f=senf%2FPPI%2FConnectors.cti;h=880111ea00e62ec1e4d9c071881ccd5478a5dbcb;hb=93d9568d448749dc187e7622b733a4a3caa319df;hp=b8f5bf3cc541a8f2a5fefcbb9794aafc0c5d418a;hpb=601d1f509f5bb24df167a4dd5a20da67a0af9af8;p=senf.git diff --git a/senf/PPI/Connectors.cti b/senf/PPI/Connectors.cti index b8f5bf3..880111e 100644 --- a/senf/PPI/Connectors.cti +++ b/senf/PPI/Connectors.cti @@ -28,27 +28,27 @@ // Custom includes #define prefix_ inline -///////////////////////////////cti.p/////////////////////////////////////// +//-///////////////////////////////////////////////////////////////////////////////////////////////// -/////////////////////////////////////////////////////////////////////////// +//-///////////////////////////////////////////////////////////////////////////////////////////////// // senf::ppi::connectors::detail::TypedInputMixin template prefix_ typename senf::ppi::connector::detail::TypedInputMixin::Type senf::ppi::connector::detail::TypedInputMixin::operator()() { - return read(); + Packet p (static_cast(this)->InputConnector::operator()()); + return p ? p.as() : Type(); } template prefix_ typename senf::ppi::connector::detail::TypedInputMixin::Type senf::ppi::connector::detail::TypedInputMixin::read() { - Packet p (static_cast(this)->InputConnector::read()); - return p ? p.as() : Type(); + return operator()(); } -/////////////////////////////////////////////////////////////////////////// +//-///////////////////////////////////////////////////////////////////////////////////////////////// // senf::ppi::connector::detail::TypedOutputMixin template @@ -63,40 +63,7 @@ prefix_ void senf::ppi::connector::detail::TypedOutputMixin::wr static_cast(this)->OutputConnector::write(p); } -/////////////////////////////////////////////////////////////////////////// -// senf::ppi::connector::PassiveConnector - -template -prefix_ void senf::ppi::connector::PassiveConnector::onRequest(Handler handler) -{ - callback_ = ppi::detail::Callback<>::make(handler, module()); -} - -/////////////////////////////////////////////////////////////////////////// -// senf::ppi::connector::ActiveConnector - -template -prefix_ void senf::ppi::connector::ActiveConnector::onThrottle(Handler handler) -{ - throttleCallback_ = ppi::detail::Callback<>::make(handler, module()); -} - -template -prefix_ void senf::ppi::connector::ActiveConnector::onUnthrottle(Handler handler) -{ - unthrottleCallback_ = ppi::detail::Callback<>::make(handler, module()); -} - -/////////////////////////////////////////////////////////////////////////// -// senf::ppi::connector::GenericPassiveInput - -template -prefix_ void senf::ppi::connector::GenericPassiveInput::qdisc(QDisc const & disc) -{ - qdisc_.reset(new QDisc(disc)); -} - -///////////////////////////////cti.e/////////////////////////////////////// +//-///////////////////////////////////////////////////////////////////////////////////////////////// #undef prefix_