X-Git-Url: http://g0dil.de/git?a=blobdiff_plain;f=Scheduler%2FScheduler.cci;h=acce9dbc9019075dd497c1d72db56f7667639389;hb=556aea04a82b3e2e5cdfe28a0abd3b275c7decf9;hp=1e69ee1e2d5935bebd1fbaeb8631439904d8e75e;hpb=ac90835cbb00ca83a51ab9efb23fdcb75518e808;p=senf.git diff --git a/Scheduler/Scheduler.cci b/Scheduler/Scheduler.cci index 1e69ee1..acce9db 100644 --- a/Scheduler/Scheduler.cci +++ b/Scheduler/Scheduler.cci @@ -54,6 +54,53 @@ prefix_ unsigned senf::scheduler::hangCount() return scheduler::detail::FIFORunner::instance().hangCount(); } +prefix_ void senf::scheduler::hiresTimers() +{ +#ifdef HAVE_TIMERFD + if (haveScalableHiresTimers()) + detail::TimerDispatcher::instance().timerSource( + std::auto_ptr(new detail::TimerFDTimerSource())); + else +#endif + detail::TimerDispatcher::instance().timerSource( + std::auto_ptr(new detail::POSIXTimerSource())); +} + +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 true; +#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_