Add '_templates/Example.test.cc' template and support double-extensions in '_template...

[senf.git] / PPI / Connectors.cti

diff --git a/PPI/Connectors.cti b/PPI/Connectors.cti
index 9c77368..c62aa2b 100644 (file)
--- a/PPI/Connectors.cti
+++ b/PPI/Connectors.cti
@@ -1,8 +1,8 @@
 // $Id$
 //
 // Copyright (C) 2007 
-// Fraunhofer Institut fuer offene Kommunikationssysteme (FOKUS)
-// Kompetenzzentrum fuer Satelitenkommunikation (SatCom)
+// Fraunhofer Institute for Open Communication Systems (FOKUS) 
+// Competence Center NETwork research (NET), St. Augustin, GERMANY 
 //     Stefan Bund <g0dil@berlios.de>
 //
 // This program is free software; you can redistribute it and/or modify
@@ -40,12 +40,27 @@ prefix_ void senf::ppi::connector::PassiveConnector::onRequest(Handler handler)
 }
 
 ///////////////////////////////////////////////////////////////////////////
+// senf::ppi::connector::ActiveConnector
+
+template <class Handler>
+prefix_ void senf::ppi::connector::ActiveConnector::onThrottle(Handler handler)
+{
+    throttleCallback_ = detail::Callback<>::make(handler, module());
+}
+
+template <class Handler>
+prefix_ void senf::ppi::connector::ActiveConnector::onUnthrottle(Handler handler)
+{
+    unthrottleCallback_ = detail::Callback<>::make(handler, module());
+}
+
+///////////////////////////////////////////////////////////////////////////
 // senf::ppi::connector::PassiveInput
 
 template <class QDisc>
 prefix_ void senf::ppi::connector::PassiveInput::qdisc(QDisc const & disc)
 {
-    qdisc_ = boost::scoped_ptr<QueueingDiscipline>(new QDisc(disc));
+    qdisc_.reset(new QDisc(disc));
 }
 
 ///////////////////////////////cti.e///////////////////////////////////////