X-Git-Url: http://g0dil.de/git?a=blobdiff_plain;f=senf%2FPPI%2FQueueingSocketSink.cti;h=eadc126999e8960d89400aa4a0ec443cb8cdcc34;hb=e3179a2123ad51d0d9eb63834a581145c4f77c92;hp=c131ab7162089f7f533bdf6fb99a89b1336442ee;hpb=32bf29e751e6c73ca2bc78c21996e4320e934673;p=senf.git diff --git a/senf/PPI/QueueingSocketSink.cti b/senf/PPI/QueueingSocketSink.cti index c131ab7..eadc126 100644 --- a/senf/PPI/QueueingSocketSink.cti +++ b/senf/PPI/QueueingSocketSink.cti @@ -28,9 +28,9 @@ // Custom includes #define prefix_ inline -///////////////////////////////cti.p/////////////////////////////////////// +//-///////////////////////////////////////////////////////////////////////////////////////////////// -/////////////////////////////////////////////////////////////////////////// +//-///////////////////////////////////////////////////////////////////////////////////////////////// // senf::ppi::QueueingAlgorithmRegistry::RegistrationProxy template @@ -40,7 +40,7 @@ prefix_ senf::ppi::QueueingAlgorithmRegistry::RegistrationProxy::Reg }; -/////////////////////////////////////////////////////////////////////////// +//-///////////////////////////////////////////////////////////////////////////////////////////////// // senf::ppi::module::PassiveQueueingSocketSink template @@ -56,22 +56,13 @@ prefix_ typename Writer::Handle & senf::ppi::module::PassiveQueueingSocketSink -prefix_ void senf::ppi::module::PassiveQueueingSocketSink::handle(Handle const & handle) -{ - handle_ = handle; - event_.set( handle_, IOEvent::Write); - qAlgo_->clear(); - checkThrottle(); -} - -template prefix_ senf::ppi::QueueingAlgorithm & senf::ppi::module::PassiveQueueingSocketSink::qAlgorithm() { return *qAlgo_; } -///////////////////////////////cti.e/////////////////////////////////////// +//-///////////////////////////////////////////////////////////////////////////////////////////////// #undef prefix_