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

diff --git a/senf/PPI/QueueingSocketSink.ct b/senf/PPI/QueueingSocketSink.ct
index 93a412e..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();
 }
 
@@ -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::