};
RateFilter::RateFilter(senf::ClockService::clock_type interval)
- : timer(interval)
+ : timer(interval)
{
route(input,timer);
route(timer,output);
connector::PassiveInput<> & input;
connector::ActiveOutput<> & output;
- RateStuffer(senf::ClockService::clock_type interval,
+ RateStuffer(senf::ClockService::clock_type interval,
senf::Packet packet,
unsigned high = 1,
unsigned low = 0)
queue.qdisc(ppi::ThresholdQueueing(high,low));
}
};
-
+
// ////////////////////////////////////////////////////////////////////////
// ////////////////////////////////////////////////////////////////////////
senf::INet4SocketAddress("localhost:44345"));
module::ActiveSocketSource<> udpSource ( inputSocket );
- RateStuffer stuffer ( 1000000000ul,
+ RateStuffer stuffer ( 1000000000ul,
senf::DataPacket::create(std::string("<idle>\n")),
2u, 1u );
module::PassiveSocketSink<> udpSink ( outputSocket );