X-Git-Url: http://g0dil.de/git?a=blobdiff_plain;f=PPI%2FConnectors.cti;h=992bd8c0f29a9de9ff95d4425ca991df5bd4044a;hb=81447258e6ecc9b5d9434fa5a7d382684179c7ab;hp=9c7736851c7fbb1d898666e2e37868dd761d428d;hpb=81ffa1c459b96dd44472bcef37e1e373934ee138;p=senf.git

diff --git a/PPI/Connectors.cti b/PPI/Connectors.cti
index 9c77368..992bd8c 100644
--- a/PPI/Connectors.cti
+++ b/PPI/Connectors.cti
@@ -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///////////////////////////////////////