// 59 Temple Place - Suite 330, Boston, MA 02111-1307, USA.
/** \file
- \brief TimerEvent.test unit tests */
+ \brief TimerEvent unit tests */
//#include "TimerEvent.test.hh"
//#include "TimerEvent.test.ih"
// Custom includes
#include "TimerEvent.hh"
+#include "Scheduler.hh"
+#include <boost/bind.hpp>
#include "../Utils//auto_unit_test.hh"
#include <boost/test/test_tools.hpp>
+#include <boost/random.hpp>
#define prefix_
///////////////////////////////cc.p////////////////////////////////////////
SENF_CHECK_NO_THROW( timer.disable() );
SENF_CHECK_NO_THROW( timer.enable() );
BOOST_CHECK( timer.enabled() );
- SENF_CHECK_NO_THROW( senf::scheduler::detail::TimerDispatcher::instance().enable() );
- SENF_CHECK_NO_THROW( senf::scheduler::detail::TimerDispatcher::instance().reschedule() );
- SENF_CHECK_NO_THROW( senf::scheduler::detail::FdManager::instance().processOnce() );
- SENF_CHECK_NO_THROW( senf::scheduler::detail::TimerDispatcher::instance().prepareRun() );
- SENF_CHECK_NO_THROW( senf::scheduler::detail::FIFORunner::instance().run() );
- SENF_CHECK_NO_THROW( senf::scheduler::detail::TimerDispatcher::instance().disable() );
+ SENF_CHECK_NO_THROW( senf::scheduler::process() );
senf::ClockService::clock_type t2 (senf::ClockService::now());
BOOST_CHECK( called );
BOOST_CHECK( ! timer.enabled() );
}
}
+namespace {
+
+ senf::ClockService::clock_type randomDelay()
+ {
+ static boost::uniform_smallint<> random (100,300);
+ static boost::mt19937 generator;
+ return senf::scheduler::now() + senf::ClockService::milliseconds(random(generator));
+ }
+
+ unsigned count (0);
+ senf::ClockService::clock_type delay (0);
+ bool haveCb (false);
+
+ void jitterCb(senf::scheduler::TimerEvent & tm)
+ {
+ std::cerr << "diff:" << senf::ClockService::in_microseconds( senf::scheduler::now() - tm.timeout()) << '\n';
+ count ++;
+ delay += senf::ClockService::in_microseconds( senf::scheduler::now() - tm.timeout());
+ haveCb = true;
+ tm.timeout(randomDelay());
+ }
+
+ void preCb()
+ {
+ haveCb = false;
+ }
+
+ void postCb()
+ {
+ if (! haveCb)
+ std::cerr << senf::scheduler::now() << '\n';
+ }
+
+ void idleCb(senf::scheduler::TimerEvent & tm)
+ {
+ tm.timeout( senf::scheduler::now());
+ }
+
+ void jitterTest()
+ {
+ count = 0;
+ delay = 0;
+ senf::scheduler::EventHook pre ("jitterTest::preCb", &preCb,
+ senf::scheduler::EventHook::PRE);
+ senf::scheduler::EventHook post ("jitterTest::postCb", &postCb,
+ senf::scheduler::EventHook::POST);
+
+ senf::scheduler::TimerEvent tm1 (
+ "jitterTest::tm1", boost::bind(&jitterCb, boost::ref(tm1)), randomDelay());
+ senf::scheduler::TimerEvent tm2 (
+ "jitterTest::tm2", boost::bind(&jitterCb, boost::ref(tm2)), randomDelay());
+ senf::scheduler::TimerEvent tm3 (
+ "jitterTest::tm3", boost::bind(&jitterCb, boost::ref(tm3)), randomDelay());
+
+ // enabled "Idle"-Event will degrade scheduling delay
+ //senf::scheduler::TimerEvent idle (
+ // "jitterTest::idle", boost::bind(&idleCb, boost::ref(idle)), senf::scheduler::now());
+
+ senf::scheduler::TimerEvent timeout("jitterTest::timeout", &senf::scheduler::terminate,
+ senf::scheduler::now() + senf::ClockService::seconds(5));
+
+ senf::scheduler::process();
+
+ std::cerr << "Average scheduling delay: " << delay/count << "\n";
+ }
+
+}
+
+BOOST_AUTO_UNIT_TEST(timerJitter)
+{
+ senf::scheduler::watchdogTimeout(0);
+ std::cerr << "Epoll timers\n";
+ senf::scheduler::loresTimers();
+ jitterTest();
+ std::cerr << "Hires timers\n";
+ senf::scheduler::hiresTimers();
+ jitterTest();
+ senf::scheduler::loresTimers();
+ senf::scheduler::watchdogTimeout(1000);
+}
+
///////////////////////////////cc.e////////////////////////////////////////
#undef prefix_