cleaned up some include dependencies

[senf.git] / senf / PPI / QueueingSocketSink.ct

diff --git a/senf/PPI/QueueingSocketSink.ct b/senf/PPI/QueueingSocketSink.ct
index 6a1e831..b20a961 100644 (file)
--- a/senf/PPI/QueueingSocketSink.ct
+++ b/senf/PPI/QueueingSocketSink.ct
@@ -26,6 +26,7 @@
 //#include "QueueingSocketSink.ih"
 
 // Custom includes
+#include <senf/Utils/Console/ParsedCommand.hh>
 
 #define prefix_
 ///////////////////////////////ct.p////////////////////////////////////////
@@ -77,6 +78,15 @@ prefix_ senf::ppi::module::PassiveQueueingSocketSink<Writer>::PassiveQueueingSoc
 }
 
 template <class Writer>
+prefix_ void senf::ppi::module::PassiveQueueingSocketSink<Writer>::handle(Handle const & handle)
+{
+    handle_ = handle;
+    event_.set( handle_, IOEvent::Write);
+    qAlgo_->clear();
+    checkThrottle();
+}
+
+template <class Writer>
 prefix_ void senf::ppi::module::PassiveQueueingSocketSink<Writer>::write()
 {
     PacketType p ( input());