event_.enabled( false);
noroute(input);
input.onRequest( &PassiveQueueingSocketSink::write);
+ input.qdisc( QueueingDiscipline::NONE);
checkThrottle();
}
template <class Writer>
prefix_ void senf::ppi::module::PassiveQueueingSocketSink<Writer>::write()
{
- PacketType p ( input.read());
+ PacketType p ( input());
if (qAlgo_->size() > 0) {
qAlgo_->enqueue( p);
return;