X-Git-Url: http://g0dil.de/git?a=blobdiff_plain;f=Scheduler%2FScheduler.cci;h=873b64f0ff8d17ca87a35d6348edc72edccead28;hb=5443435c4c2b6e4386c5334b5b8358273f2bae93;hp=1e69ee1e2d5935bebd1fbaeb8631439904d8e75e;hpb=ac90835cbb00ca83a51ab9efb23fdcb75518e808;p=senf.git diff --git a/Scheduler/Scheduler.cci b/Scheduler/Scheduler.cci index 1e69ee1..873b64f 100644 --- a/Scheduler/Scheduler.cci +++ b/Scheduler/Scheduler.cci @@ -39,21 +39,66 @@ prefix_ senf::ClockService::clock_type senf::scheduler::eventTime() return scheduler::detail::FdManager::instance().eventTime(); } -prefix_ void senf::scheduler::taskTimeout(unsigned ms) +prefix_ void senf::scheduler::watchdogTimeout(unsigned ms) { scheduler::detail::FIFORunner::instance().taskTimeout(ms); } -prefix_ unsigned senf::scheduler::taskTimeout() +prefix_ unsigned senf::scheduler::watchdogTimeout() { return scheduler::detail::FIFORunner::instance().taskTimeout(); } -prefix_ unsigned senf::scheduler::hangCount() +prefix_ unsigned senf::scheduler::watchdogEvents() { return scheduler::detail::FIFORunner::instance().hangCount(); } +prefix_ void senf::scheduler::watchdogAbort(bool flag) +{ + scheduler::detail::FIFORunner::instance().abortOnTimeout(flag); +} + +prefix_ bool senf::scheduler::watchdogAbort() +{ + return scheduler::detail::FIFORunner::instance().abortOnTimeout(); +} + +prefix_ void senf::scheduler::loresTimers() +{ + detail::TimerDispatcher::instance().timerSource( + std::auto_ptr(new detail::PollTimerSource())); +} + +prefix_ bool senf::scheduler::haveScalableHiresTimers() +{ +#ifndef HAVE_TIMERFD + return false; +#else + return detail::TimerFDTimerSource::haveTimerFD(); +#endif +} + +prefix_ bool senf::scheduler::usingHiresTimers() +{ + return dynamic_cast( + detail::TimerDispatcher::instance().timerSource()) == 0; +} + +/////////////////////////////////////////////////////////////////////////// +// senf::scheduler::BlockSignals + +prefix_ senf::scheduler::BlockSignals::~BlockSignals() +{ + unblock(); +} + +prefix_ bool senf::scheduler::BlockSignals::blocked() + const +{ + return blocked_; +} + ///////////////////////////////cci.e/////////////////////////////////////// #undef prefix_