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 Scheduler non-inline non-template implementation
26 \idea Multithreading support: To support multithreading, the
27 static member Scheduler::instance() must return a thread-local
28 value (that is Scheduler::instance() must allocate one Scheduler
29 instance per thread). Another possibility would be to distribute
30 the async load unto several threads (one scheduler for multiple
34 #include "Scheduler.hh"
35 //#include "Scheduler.ih"
38 #include "SignalEvent.hh"
41 ///////////////////////////////cc.p////////////////////////////////////////
43 prefix_ void senf::Scheduler::process()
46 while(! terminate_ && ! (fdDispatcher_.empty() &&
47 timerDispatcher_.empty() &&
48 fileDispatcher_.empty())) {
49 scheduler::detail::SignalDispatcher::instance().unblockSignals();
50 timerDispatcher_.unblockSignals();
51 scheduler::FdManager::instance().processOnce();
52 timerDispatcher_.blockSignals();
53 scheduler::detail::SignalDispatcher::instance().blockSignals();
54 fileDispatcher_.prepareRun();
55 scheduler::FIFORunner::instance().run();
59 prefix_ void senf::Scheduler::restart()
61 scheduler::FdManager* fdm (&scheduler::FdManager::instance());
62 scheduler::FIFORunner* ffr (&scheduler::FIFORunner::instance());
63 scheduler::FdDispatcher* fdd (&fdDispatcher_);
64 scheduler::TimerDispatcher* td (&timerDispatcher_);
65 scheduler::detail::SignalDispatcher* sd (&scheduler::detail::SignalDispatcher::instance());
66 scheduler::FileDispatcher* fld (&fileDispatcher_);
68 fld->~FileDispatcher();
69 sd->~SignalDispatcher();
70 td->~TimerDispatcher();
75 new (fdm) scheduler::FdManager();
76 new (ffr) scheduler::FIFORunner();
77 new (fdd) scheduler::FdDispatcher(*fdm, *ffr);
78 new (td) scheduler::TimerDispatcher(*fdm, *ffr);
79 new (sd) scheduler::detail::SignalDispatcher();
80 new (fld) scheduler::FileDispatcher(*fdm, *ffr);
83 ///////////////////////////////////////////////////////////////////////////
84 // senf::SchedulerLogTimeSource
86 prefix_ senf::log::time_type senf::SchedulerLogTimeSource::operator()()
89 return Scheduler::instance().eventTime();
92 ///////////////////////////////cc.e////////////////////////////////////////
99 // c-file-style: "senf"
100 // indent-tabs-mode: nil
101 // ispell-local-dictionary: "american"
102 // compile-command: "scons -u test"
103 // comment-column: 40