X-Git-Url: http://g0dil.de/git?a=blobdiff_plain;f=senf%2FPPI%2FQueueingSocketSink.ct;h=2d991c657c36001cf878a58cd24837cec261ccd9;hb=73c33f663ff0f65e4656ea5a5f6f07a43a2e1722;hp=3ae8cbfdb7c25c0e0fbc25e1b9bd4fb1a12cb1f2;hpb=fc1569e67cfda71bc8c406617a5e0b05f28f1b47;p=senf.git

diff --git a/senf/PPI/QueueingSocketSink.ct b/senf/PPI/QueueingSocketSink.ct
index 3ae8cbf..2d991c6 100644
--- a/senf/PPI/QueueingSocketSink.ct
+++ b/senf/PPI/QueueingSocketSink.ct
@@ -56,7 +56,7 @@ prefix_ senf::ppi::QueueingAlgorithm::ptr senf::ppi::detail::QueueingAlgorithmRe
 // senf::ppi::module::PassiveQueueingSocketSink<Writer>
 
 template <class Writer>
-prefix_ senf::ppi::module::PassiveQueueingSocketSink<Writer>::PassiveQueueingSocketSink(Handle handle, QueueingAlgorithm::ptr qAlgorithm)
+prefix_ senf::ppi::module::PassiveQueueingSocketSink<Writer>::PassiveQueueingSocketSink(Handle const & handle, QueueingAlgorithm::ptr qAlgorithm)
     : dir( this),
       handle_( handle), writer_( ),
       qAlgo_( qAlgorithm),
@@ -72,6 +72,7 @@ prefix_ senf::ppi::module::PassiveQueueingSocketSink<Writer>::PassiveQueueingSoc
     event_.enabled( false);
     noroute(input);
     input.onRequest( &PassiveQueueingSocketSink::write);
+    input.qdisc( QueueingDiscipline::NONE);
     checkThrottle();
 }
 
@@ -85,7 +86,7 @@ prefix_ void senf::ppi::module::PassiveQueueingSocketSink<Writer>::write()
     }
     if (! writer_( handle_, p)) {
         if (qAlgo_->enqueue( p) && !event_.enabled()) {
-            event_.enabled( true);
+          event_.enabled( true);
         }
     }
 }
@@ -138,4 +139,4 @@ prefix_ void senf::ppi::module::PassiveQueueingSocketSink<Writer>::setQAlgorithm
 // indent-tabs-mode: nil
 // ispell-local-dictionary: "american"
 // compile-command: "scons -u test"
-// End:
+// End::