{
return (a<b ? b-a : a-b) < senf::ClockService::milliseconds(100);
}
-
+
senf::ClockService::clock_type sigtime (0);
void sigusr(siginfo_t const &)
buffer[size]=0;
BOOST_CHECK_EQUAL( buffer, "OK" );
}
-
+
{
- senf::scheduler::TimerEvent timer1 ("testTimer1", &timeout,
+ senf::scheduler::TimerEvent timer1 ("testTimer1", &timeout,
senf::ClockService::now()+senf::ClockService::milliseconds(200));
senf::scheduler::TimerEvent timer2 ("testTimer2", &timeout,
senf::ClockService::now()+senf::ClockService::milliseconds(400));
-
+
event = senf::scheduler::FdEvent::EV_NONE;
senf::ClockService::clock_type t (senf::ClockService::now());
SENF_CHECK_NO_THROW( senf::scheduler::process() );
senf::ClockService::clock_type t = senf::ClockService::now();
::kill(::getpid(), SIGUSR1);
delay(200);
- SENF_CHECK_NO_THROW( senf::scheduler::process() );
+ SENF_CHECK_NO_THROW( senf::scheduler::process() );
if (enabled) {
BOOST_CHECK_PREDICATE( is_close, (senf::ClockService::now()) (t+senf::ClockService::milliseconds(200)) );
BOOST_CHECK_PREDICATE( is_close, (sigtime) (t+senf::ClockService::milliseconds(200)) );
}
- SENF_CHECK_NO_THROW( senf::scheduler::process() );
- }
+ SENF_CHECK_NO_THROW( senf::scheduler::process() );
+ }
BOOST_CHECK( eventCount >= 8u );
-
+
///////////////////////////////////////////////////////////////////////////
close(sock);
BOOST_CHECK (stop_server(pid));
}
-BOOST_AUTO_UNIT_TEST(testSchedulerPollTimers)
+SENF_AUTO_UNIT_TEST(testSchedulerPollTimers)
{
BOOST_CHECK( ! senf::scheduler::usingHiresTimers() );
schedulerTest();
}
-BOOST_AUTO_UNIT_TEST(testSchedulerHiresTimers)
+SENF_AUTO_UNIT_TEST(testSchedulerHiresTimers)
{
if (senf::scheduler::haveScalableHiresTimers())
BOOST_MESSAGE( "Using timerfd() hires timers" );
BOOST_CHECK( ! senf::scheduler::usingHiresTimers() );
}
-BOOST_AUTO_UNIT_TEST(testSchedulerPOSIXTimers)
+SENF_AUTO_UNIT_TEST(testSchedulerPOSIXTimers)
{
if (senf::scheduler::haveScalableHiresTimers()) {
SENF_CHECK_NO_THROW( senf::scheduler::detail::TimerDispatcher::instance().timerSource(
}
namespace {
-
+
void sigme()
{
senf::scheduler::BlockSignals signalBlocker;
}
-BOOST_AUTO_UNIT_TEST(blockSignals)
+SENF_AUTO_UNIT_TEST(blockSignals)
{
char const * enabled (getenv("SENF_TIMING_CRITICAL_TESTS"));
BOOST_WARN_MESSAGE(enabled, "Set SENF_TIMING_CRITICAL_TESTS to not skip timing critical tests");
senf::scheduler::TimerEvent timer (
"testWatchdog", &timeout, senf::ClockService::now()+senf::ClockService::milliseconds(400));
senf::scheduler::SignalEvent sig (SIGUSR1, &sigusr);
-
+
senf::ClockService::clock_type t = senf::ClockService::now();
- SENF_CHECK_NO_THROW( senf::scheduler::process() );
+ SENF_CHECK_NO_THROW( senf::scheduler::process() );
if (enabled) {
- BOOST_CHECK_PREDICATE( is_close,
- (senf::ClockService::now())
+ BOOST_CHECK_PREDICATE( is_close,
+ (senf::ClockService::now())
(t+senf::ClockService::milliseconds(200)) );
BOOST_CHECK_PREDICATE( is_close, (sigtime) (t+senf::ClockService::milliseconds(200)) );
}
- SENF_CHECK_NO_THROW( senf::scheduler::process() );
+ SENF_CHECK_NO_THROW( senf::scheduler::process() );
}
///////////////////////////////cc.e////////////////////////////////////////