{
senf::scheduler::detail::FIFORunner::instance().startWatchdog();
senf::scheduler::detail::SignalDispatcher::instance().unblockSignals();
- senf::scheduler::detail::TimerDispatcher::instance().unblockSignals();
+ senf::scheduler::detail::TimerDispatcher::instance().enable();
}
~SchedulerScopedInit()
{
- senf::scheduler::detail::TimerDispatcher::instance().blockSignals();
+ senf::scheduler::detail::TimerDispatcher::instance().disable();
senf::scheduler::detail::SignalDispatcher::instance().blockSignals();
senf::scheduler::detail::FIFORunner::instance().stopWatchdog();
}
{
SchedulerScopedInit initScheduler;
terminate_ = false;
+ detail::TimerDispatcher::instance().reschedule();
while(! terminate_ && ! (detail::FdDispatcher::instance().empty() &&
detail::TimerDispatcher::instance().empty() &&
detail::FileDispatcher::instance().empty())) {
detail::FdManager::instance().processOnce();
detail::FileDispatcher::instance().prepareRun();
detail::EventHookDispatcher::instance().prepareRun();
+ detail::TimerDispatcher::instance().prepareRun();
detail::FIFORunner::instance().run();
+ detail::TimerDispatcher::instance().reschedule();
}
}
&& detail::EventHookDispatcher::instance().empty();
}
+prefix_ void senf::scheduler::hiresTimers()
+{
+#ifdef HAVE_TIMERFD
+ if (haveScalableHiresTimers())
+ detail::TimerDispatcher::instance().timerSource(
+ std::auto_ptr<detail::TimerSource>(new detail::TimerFDTimerSource()));
+ else
+#endif
+ detail::TimerDispatcher::instance().timerSource(
+ std::auto_ptr<detail::TimerSource>(new detail::POSIXTimerSource()));
+}
+
///////////////////////////////////////////////////////////////////////////
// senf::schedulerLogTimeSource
return eventTime();
}
+///////////////////////////////////////////////////////////////////////////
+// senf::scheduler::BlockSignals
+
+prefix_ senf::scheduler::BlockSignals::BlockSignals(bool initiallyBlocked)
+ : blocked_ (false)
+{
+ ::sigfillset(&allSigs_);
+ if (initiallyBlocked)
+ block();
+}
+
+prefix_ void senf::scheduler::BlockSignals::block()
+{
+ if (blocked_)
+ return;
+ ::sigprocmask(SIG_BLOCK, &allSigs_, &savedSigs_);
+ blocked_ = true;
+}
+
+prefix_ void senf::scheduler::BlockSignals::unblock()
+{
+ if (!blocked_)
+ return;
+ ::sigprocmask(SIG_SETMASK, &savedSigs_, 0);
+ blocked_ = false;
+}
+
///////////////////////////////cc.e////////////////////////////////////////
#undef prefix_