return fd;
}
-prefix_ senf::Scheduler::timer_id senf::Scheduler::timeout(ClockService::clock_type timeout,
- SimpleCallback const & cb)
-{
- return timerDispatcher_.add("<anon timer>", timeout, cb);
-}
-
-prefix_ senf::Scheduler::timer_id senf::Scheduler::timeout(std::string const & name,
- ClockService::clock_type timeout,
- SimpleCallback const & cb)
-{
- return timerDispatcher_.add(name, timeout, cb);
-}
-
-prefix_ void senf::Scheduler::cancelTimeout(timer_id id)
-{
- timerDispatcher_.remove(id);
-}
-
-prefix_ senf::ClockService::clock_type senf::Scheduler::timeoutEarly()
- const
-{
- SENF_LOG( (senf::log::IMPORTANT)
- ("timeoutEarly() is deprecated and a no-op. It will be removed") );
- return 0;
-}
-
-prefix_ void senf::Scheduler::timeoutEarly(ClockService::clock_type v)
+prefix_ void senf::Scheduler::terminate()
{
- SENF_LOG( (senf::log::IMPORTANT)
- ("timeoutEarly() is deprecated and a no-op. It will be removed") );
+ terminate_ = true;
}
-prefix_ senf::ClockService::clock_type senf::Scheduler::timeoutAdjust()
+prefix_ senf::ClockService::clock_type senf::Scheduler::eventTime()
const
{
- SENF_LOG( (senf::log::IMPORTANT)
- ("timeoutAdjust() is deprecated and a no-op. It will be removed") );
- return 0;
-}
-
-prefix_ void senf::Scheduler::timeoutAdjust(ClockService::clock_type v)
-{
- SENF_LOG( (senf::log::IMPORTANT)
- ("timeoutAdjust() is deprecated and a no-op. It will be removed") );
-}
-
-prefix_ void senf::Scheduler::registerSignal(unsigned signal, SignalCallback const & cb)
-{
- signalDispatcher_.add(signal, cb);
+ return scheduler::FdManager::instance().eventTime();
}
-prefix_ void senf::Scheduler::unregisterSignal(unsigned signal)
+prefix_ void senf::Scheduler::taskTimeout(unsigned ms)
{
- signalDispatcher_.remove(signal);
+ scheduler::FIFORunner::instance().taskTimeout(ms);
}
-prefix_ void senf::Scheduler::terminate()
-{
- terminate_ = true;
-}
-
-prefix_ senf::ClockService::clock_type senf::Scheduler::eventTime()
+prefix_ unsigned senf::Scheduler::taskTimeout()
const
{
- return manager_.eventTime();
+ return scheduler::FIFORunner::instance().taskTimeout();
}
prefix_ unsigned senf::Scheduler::hangCount()
const
{
- return runner_.hangCount();
+ return scheduler::FIFORunner::instance().hangCount();
}
prefix_ senf::Scheduler::Scheduler()
: terminate_ (false),
- fdDispatcher_ (manager_, runner_),
- timerDispatcher_ (manager_, runner_),
- signalDispatcher_ (manager_, runner_),
- fileDispatcher_ (manager_, runner_)
+ fdDispatcher_ (scheduler::FdManager::instance(), scheduler::FIFORunner::instance()),
+ fileDispatcher_ (scheduler::FdManager::instance(), scheduler::FIFORunner::instance())
{}
///////////////////////////////cci.e///////////////////////////////////////