X-Git-Url: http://g0dil.de/git?a=blobdiff_plain;f=senf%2FPPI%2FRateFilter.test.cc;h=3a6f54a50780edb1cdfad1004f1b87388ee7d3b8;hb=7ee689fe38d66aa3a0004d55e8708750d35adc0b;hp=2f8e1bdb5b29089e4271a1b570822b078ebd78ca;hpb=767a76da8e5b96a69b620e44d32e0a1b04005679;p=senf.git diff --git a/senf/PPI/RateFilter.test.cc b/senf/PPI/RateFilter.test.cc index 2f8e1bd..3a6f54a 100644 --- a/senf/PPI/RateFilter.test.cc +++ b/senf/PPI/RateFilter.test.cc @@ -33,7 +33,7 @@ #include #define prefix_ -///////////////////////////////cc.p//////////////////////////////////////// +//-///////////////////////////////////////////////////////////////////////////////////////////////// namespace ppi = senf::ppi; namespace module = ppi::module; namespace debug = module::debug; @@ -49,19 +49,19 @@ SENF_AUTO_UNIT_TEST(rateFilter) module::RateFilter rateFilter ( senf::ClockService::milliseconds(100) ); debug::PassiveSource source; debug::PassiveSink sink; - + ppi::connect(source, rateFilter); ppi::connect(rateFilter, sink); - + std::string data ("TEST"); senf::Packet p (senf::DataPacket::create(data)); for (int i=0; i<10; i++) - source.submit(p); - + source.submit(p); + senf::scheduler::TimerEvent timer ( "rateFilter test timer", &timeout, senf::ClockService::now() + senf::ClockService::milliseconds(250)); - + senf::ppi::run(); BOOST_CHECK_EQUAL( rateFilter.interval(), senf::ClockService::milliseconds(100) ); @@ -90,24 +90,24 @@ SENF_AUTO_UNIT_TEST(rateFilter_changeInterval) module::RateFilter rateFilter ( senf::ClockService::milliseconds(100) ); debug::PassiveSource source; debug::PassiveSink sink; - + ppi::connect(source, rateFilter); ppi::connect(rateFilter, sink); - + std::string data ("TEST"); senf::Packet p (senf::DataPacket::create(data)); for (int i=0; i<10; i++) - source.submit(p); - + source.submit(p); + senf::scheduler::TimerEvent timeoutTimer ( "rateFilter test timer", &timeout, senf::ClockService::now() + senf::ClockService::milliseconds(675)); - + RateFilter_IntervalChanger intervalChanger (rateFilter); - senf::scheduler::TimerEvent timer ( "RateFilter_IntervalChanger timer", + senf::scheduler::TimerEvent timer ( "RateFilter_IntervalChanger timer", senf::membind(&RateFilter_IntervalChanger::changeInterval, intervalChanger), senf::ClockService::now() + senf::ClockService::milliseconds(250)); - + senf::ppi::run(); BOOST_CHECK_EQUAL( rateFilter.interval(), senf::ClockService::milliseconds(200) ); @@ -115,7 +115,7 @@ SENF_AUTO_UNIT_TEST(rateFilter_changeInterval) BOOST_CHECK_EQUAL( sink.size(), 4); } -///////////////////////////////cc.e//////////////////////////////////////// +//-///////////////////////////////////////////////////////////////////////////////////////////////// #undef prefix_