X-Git-Url: http://g0dil.de/git?a=blobdiff_plain;f=PPI%2FSocketSink.ct;h=69726a28d44250d6ca8c8c179cada27127fbb4f0;hb=6927c87144ca23845065e3c23e37c75f5f059cf3;hp=e578fd07ae614fa5fee0714d05f03cc58d7d6e7d;hpb=a1a6c76a214ad1935032826713cabaf9ac57bf07;p=senf.git

diff --git a/PPI/SocketSink.ct b/PPI/SocketSink.ct
index e578fd0..69726a2 100644
--- a/PPI/SocketSink.ct
+++ b/PPI/SocketSink.ct
@@ -34,6 +34,21 @@
 // senf::ppi::module::ActiveSocketSink<Writer>
 
 template <class Writer>
+prefix_ senf::ppi::module::ActiveSocketSink<Writer>::ActiveSocketSink()
+{
+    registerEvent( event_, &ActiveSocketSink::write );
+    route(input, event_);
+}
+
+template <class Writer>
+prefix_ senf::ppi::module::ActiveSocketSink<Writer>::ActiveSocketSink(Writer const & writer)
+    : writer_ (writer)
+{
+    registerEvent( event_, &ActiveSocketSink::write );
+    route(input, event_);
+}
+
+template <class Writer>
 prefix_ senf::ppi::module::ActiveSocketSink<Writer>::ActiveSocketSink(Handle handle)
     : handle_(handle), event_(handle_, IOEvent::Write), writer_()
 {
@@ -63,11 +78,29 @@ prefix_ void senf::ppi::module::ActiveSocketSink<Writer>::write()
 // senf::ppi::module::PassiveSocketSink<Writer>
 
 template <class Writer>
+prefix_ senf::ppi::module::PassiveSocketSink<Writer>::PassiveSocketSink()
+{
+    noroute(input);
+    input.onRequest(&PassiveSocketSink::write);
+    checkThrottle();
+}
+
+template <class Writer>
+prefix_ senf::ppi::module::PassiveSocketSink<Writer>::PassiveSocketSink(Writer const & writer)
+    : writer_ (writer)
+{
+    noroute(input);
+    input.onRequest(&PassiveSocketSink::write);
+    checkThrottle();
+}
+
+template <class Writer>
 prefix_ senf::ppi::module::PassiveSocketSink<Writer>::PassiveSocketSink(Handle handle)
     : handle_(handle), writer_()
 {
     noroute(input);
     input.onRequest(&PassiveSocketSink::write);
+    checkThrottle();
 }
 
 template <class Writer>
@@ -77,6 +110,7 @@ prefix_ senf::ppi::module::PassiveSocketSink<Writer>::PassiveSocketSink(Handle h
 {
     noroute(input);
     input.onRequest(&PassiveSocketSink::write);
+    checkThrottle();
 }
 
 ////////////////////////////////////////
@@ -88,6 +122,15 @@ prefix_ void senf::ppi::module::PassiveSocketSink<Writer>::write()
     writer_(handle_,input());
 }
 
+template <class Writer>
+prefix_ void senf::ppi::module::PassiveSocketSink<Writer>::checkThrottle()
+{
+    if (handle_)
+        input.unthrottle();
+    else
+        input.throttle();
+}
+
 ///////////////////////////////ct.e////////////////////////////////////////
 #undef prefix_