4 // Fraunhofer Institute for Open Communication Systems (FOKUS)
5 // Competence Center NETwork research (NET), St. Augustin, GERMANY
6 // Stefan Bund <g0dil@berlios.de>
8 // This program is free software; you can redistribute it and/or modify
9 // it under the terms of the GNU General Public License as published by
10 // the Free Software Foundation; either version 2 of the License, or
11 // (at your option) any later version.
13 // This program is distributed in the hope that it will be useful,
14 // but WITHOUT ANY WARRANTY; without even the implied warranty of
15 // MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
16 // GNU General Public License for more details.
18 // You should have received a copy of the GNU General Public License
19 // along with this program; if not, write to the
20 // Free Software Foundation, Inc.,
21 // 59 Temple Place - Suite 330, Boston, MA 02111-1307, USA.
24 \brief TimerSource non-inline non-template implementation */
26 #include "TimerSource.hh"
27 //#include "TimerSource.ih"
30 #include "IdleEvent.hh"
32 #include <sys/timerfd.h>
34 #include "senf/Utils/IgnoreValue.hh"
36 //#include "TimerSource.mpp"
38 ///////////////////////////////cc.p////////////////////////////////////////
40 ///////////////////////////////////////////////////////////////////////////
41 // senf::scheduler::detail::TimerSource
43 prefix_ senf::scheduler::detail::TimerSource::~TimerSource()
46 ///////////////////////////////////////////////////////////////////////////
47 // senf::scheduler::detail::POSIXTimerSource
49 prefix_ senf::scheduler::detail::POSIXTimerSource::POSIXTimerSource()
50 : timeoutEnabled_ (false), timeout_ (0), signalEnabled_ (false)
52 if (pipe(timerPipe_) < 0)
53 SENF_THROW_SYSTEM_EXCEPTION("pipe()");
54 senf::scheduler::detail::FdManager::instance().set(
55 timerPipe_[0], detail::FdManager::EV_READ, this);
57 sigemptyset(&sigSet_);
58 sigaddset(&sigSet_, SIGALRM);
59 sigprocmask(SIG_BLOCK, &sigSet_, 0);
62 act.sa_sigaction = &sigHandler;
63 act.sa_mask = sigSet_;
64 act.sa_flags = SA_SIGINFO | SA_RESTART;
65 if (sigaction(SIGALRM, &act, 0) < 0)
66 SENF_THROW_SYSTEM_EXCEPTION("sigaction()");
69 ::memset(&ev, 0, sizeof(ev));
70 ev.sigev_notify = SIGEV_SIGNAL;
71 ev.sigev_signo = SIGALRM;
72 ev.sigev_value.sival_ptr = this;
73 if (timer_create(CLOCK_MONOTONIC, &ev, &timerId_) < 0)
74 SENF_THROW_SYSTEM_EXCEPTION("timer_create()");
77 prefix_ senf::scheduler::detail::POSIXTimerSource::~POSIXTimerSource()
79 timer_delete(timerId_);
80 ::signal(SIGALRM, SIG_IGN);
81 sigprocmask(SIG_UNBLOCK, &sigSet_, 0);
82 senf::scheduler::detail::FdManager::instance().remove(timerPipe_[0]);
88 senf::scheduler::detail::POSIXTimerSource::timeout(ClockService::clock_type timeout)
90 if (! timeoutEnabled_ || timeout_ != timeout) {
94 timeoutEnabled_ = true;
99 prefix_ void senf::scheduler::detail::POSIXTimerSource::notimeout()
101 if (timeoutEnabled_) {
102 timeoutEnabled_ = false;
107 prefix_ void senf::scheduler::detail::POSIXTimerSource::enable()
109 if (! signalEnabled_) {
110 signalEnabled_ = true;
111 sigprocmask(SIG_UNBLOCK, &sigSet_, 0);
115 prefix_ void senf::scheduler::detail::POSIXTimerSource::disable()
117 if (signalEnabled_) {
118 signalEnabled_ = false;
119 sigprocmask(SIG_BLOCK, &sigSet_, 0);
123 prefix_ void senf::scheduler::detail::POSIXTimerSource::sigHandler(int,
124 ::siginfo_t * siginfo,
127 if (siginfo->si_value.sival_ptr == 0)
129 static char data = '\xD0';
130 // If the write fails there's not much we can do anyways ...
131 senf::IGNORE( write(static_cast<POSIXTimerSource*>(siginfo->si_value.sival_ptr)->timerPipe_[1],
132 &data, sizeof(data)) );
135 prefix_ void senf::scheduler::detail::POSIXTimerSource::signal(int events)
138 // This should never fail since we are reading a single character from a signaled
140 senf::IGNORE( read(timerPipe_[0], &data, sizeof(data)) );
141 timeoutEnabled_ = false;
144 prefix_ void senf::scheduler::detail::POSIXTimerSource::reschedule()
146 struct itimerspec timer;
147 memset(&timer, 0, sizeof(timer));
148 if (timeoutEnabled_) {
149 timer.it_value.tv_sec = ClockService::in_seconds(timeout_);
150 timer.it_value.tv_nsec = ClockService::in_nanoseconds(
151 timeout_ - ClockService::seconds(timer.it_value.tv_sec));
153 if (timer_settime(timerId_, TIMER_ABSTIME, &timer, 0)<0)
154 SENF_THROW_SYSTEM_EXCEPTION("timer_settime()");
157 ///////////////////////////////////////////////////////////////////////////
158 // senf::scheduler::detail::PollTimerSource
160 prefix_ void senf::scheduler::detail::PollTimerSource::timeout(ClockService::clock_type timeout)
162 ClockService::clock_type now (ClockService::now());
163 int delay (ClockService::in_milliseconds(timeout-now)+1);
164 IdleEventDispatcher::instance().timeout(delay<0?0:delay);
167 prefix_ void senf::scheduler::detail::PollTimerSource::notimeout()
169 IdleEventDispatcher::instance().timeout(-1);
172 prefix_ void senf::scheduler::detail::PollTimerSource::enable()
175 prefix_ void senf::scheduler::detail::PollTimerSource::disable()
178 ///////////////////////////////////////////////////////////////////////////
179 // senf::scheduler::detail::TimerFDTimerSource
182 prefix_ senf::scheduler::detail::TimerFDTimerSource::TimerFDTimerSource()
183 : timerfd_ (-1), timeoutEnabled_ (false), timeout_ (0)
185 timerfd_ = timerfd_create(CLOCK_MONOTONIC, 0);
187 SENF_THROW_SYSTEM_EXCEPTION("timerfd_create()");
188 senf::scheduler::detail::FdManager::instance().set(
189 timerfd_, detail::FdManager::EV_READ, this);
192 prefix_ senf::scheduler::detail::TimerFDTimerSource::~TimerFDTimerSource()
194 senf::scheduler::detail::FdManager::instance().remove(timerfd_);
199 senf::scheduler::detail::TimerFDTimerSource::timeout(ClockService::clock_type timeout)
201 if (!timeoutEnabled_ || timeout_ != timeout) {
205 timeoutEnabled_ = true;
210 prefix_ void senf::scheduler::detail::TimerFDTimerSource::notimeout()
212 if (timeoutEnabled_) {
213 timeoutEnabled_ = false;
218 prefix_ void senf::scheduler::detail::TimerFDTimerSource::enable()
221 prefix_ void senf::scheduler::detail::TimerFDTimerSource::disable()
232 TimerFdCheck::TimerFdCheck()
235 int fd (timerfd_create(CLOCK_MONOTONIC, 0));
238 SENF_THROW_SYSTEM_EXCEPTION("timerfd_create()");
247 prefix_ bool senf::scheduler::detail::TimerFDTimerSource::haveTimerFD()
249 static TimerFdCheck check;
250 return check.timerFdOk;
253 prefix_ void senf::scheduler::detail::TimerFDTimerSource::signal(int events)
255 uint64_t expirations (0);
256 // We ignore the return value since we ignore the value read anyways
257 senf::IGNORE( read(timerfd_, &expirations, sizeof(expirations)) );
260 prefix_ void senf::scheduler::detail::TimerFDTimerSource::reschedule()
262 struct itimerspec timer;
263 memset(&timer, 0, sizeof(timer));
264 if (timeoutEnabled_) {
265 timer.it_value.tv_sec = ClockService::in_seconds(timeout_);
266 timer.it_value.tv_nsec = ClockService::in_nanoseconds(
267 timeout_ - ClockService::seconds(timer.it_value.tv_sec));
269 if (timerfd_settime(timerfd_, TFD_TIMER_ABSTIME, &timer, 0)<0)
270 SENF_THROW_SYSTEM_EXCEPTION("timerfd_settime()");
274 ///////////////////////////////cc.e////////////////////////////////////////
276 //#include "TimerSource.mpp"
282 // comment-column: 40
283 // c-file-style: "senf"
284 // indent-tabs-mode: nil
285 // ispell-local-dictionary: "american"
286 // compile-command: "scons -u test"