//#include "Scheduler.ih"
// Custom includes
-#include "SignalEvent.hh"
#define prefix_
///////////////////////////////cc.p////////////////////////////////////////
namespace {
bool terminate_ (false);
+ bool running_ (false);
}
prefix_ void senf::scheduler::terminate()
terminate_ = true;
}
+prefix_ bool senf::scheduler::running()
+{
+ return running_;
+}
+
+prefix_ senf::ClockService::clock_type senf::scheduler::now()
+{
+ return running() ? eventTime() : ClockService::now();
+}
+
+namespace {
+
+ // We don't want try { } catch(...) { ... throw; } since that will make debugging more
+ // difficult: the stack backtrace for an unexpected exception would always end here.
+ struct SchedulerScopedInit
+ {
+ SchedulerScopedInit()
+ {
+ senf::scheduler::detail::FIFORunner::instance().startWatchdog();
+ senf::scheduler::detail::SignalDispatcher::instance().unblockSignals();
+ senf::scheduler::detail::TimerDispatcher::instance().enable();
+ running_ = true;
+ }
+
+ ~SchedulerScopedInit()
+ {
+ senf::scheduler::detail::TimerDispatcher::instance().disable();
+ senf::scheduler::detail::SignalDispatcher::instance().blockSignals();
+ senf::scheduler::detail::FIFORunner::instance().stopWatchdog();
+ running_ = false;
+ }
+ };
+}
+
prefix_ void senf::scheduler::process()
{
+ SchedulerScopedInit initScheduler;
terminate_ = false;
+ running_ = true;
+ detail::TimerDispatcher::instance().reschedule();
while(! terminate_ && ! (detail::FdDispatcher::instance().empty() &&
detail::TimerDispatcher::instance().empty() &&
detail::FileDispatcher::instance().empty())) {
- detail::SignalDispatcher::instance().unblockSignals();
- detail::TimerDispatcher::instance().unblockSignals();
detail::FdManager::instance().processOnce();
- detail::TimerDispatcher::instance().blockSignals();
- detail::SignalDispatcher::instance().blockSignals();
detail::FileDispatcher::instance().prepareRun();
+ detail::EventHookDispatcher::instance().prepareRun();
+ detail::TimerDispatcher::instance().prepareRun();
detail::FIFORunner::instance().run();
+ detail::TimerDispatcher::instance().reschedule();
}
}
prefix_ void senf::scheduler::restart()
{
- detail::FdManager* fdm (&detail::FdManager::instance());
- detail::FIFORunner* ffr (&detail::FIFORunner::instance());
- detail::FdDispatcher* fdd (&detail::FdDispatcher::instance());
- detail::TimerDispatcher* tdd (&detail::TimerDispatcher::instance());
- detail::SignalDispatcher* sdd (&detail::SignalDispatcher::instance());
- detail::FileDispatcher* fld (&detail::FileDispatcher::instance());
-
+ detail::FdManager* fdm (&detail::FdManager::instance());
+ detail::FIFORunner* ffr (&detail::FIFORunner::instance());
+ detail::FdDispatcher* fdd (&detail::FdDispatcher::instance());
+ detail::TimerDispatcher* tdd (&detail::TimerDispatcher::instance());
+ detail::SignalDispatcher* sdd (&detail::SignalDispatcher::instance());
+ detail::FileDispatcher* fld (&detail::FileDispatcher::instance());
+ detail::EventHookDispatcher* eed (&detail::EventHookDispatcher::instance());
+
+ eed->~EventHookDispatcher();
fld->~FileDispatcher();
sdd->~SignalDispatcher();
tdd->~TimerDispatcher();
new (tdd) detail::TimerDispatcher();
new (sdd) detail::SignalDispatcher();
new (fld) detail::FileDispatcher();
+ new (eed) detail::EventHookDispatcher();
+}
+
+prefix_ bool senf::scheduler::empty()
+{
+ return detail::FdDispatcher::instance().empty()
+ && detail::TimerDispatcher::instance().empty()
+ && detail::FileDispatcher::instance().empty()
+ && detail::SignalDispatcher::instance().empty()
+ && 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()));
}
///////////////////////////////////////////////////////////////////////////
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_