Scheduler: Implement SignalDispatcher
[senf.git] / Scheduler / SignalDispatcher.hh
1 // $Id$
2 //
3 // Copyright (C) 2008 
4 // Fraunhofer Institute for Open Communication Systems (FOKUS)
5 // Competence Center NETwork research (NET), St. Augustin, GERMANY
6 //     Stefan Bund <g0dil@berlios.de>
7 //
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.
12 //
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.
17 //
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.
22
23 /** \file
24     \brief SignalDispatcher public header */
25
26 #ifndef HH_SignalDispatcher_
27 #define HH_SignalDispatcher_ 1
28
29 // Custom includes
30 #include <signal.h>
31 #include <map>
32 #include "FdManager.hh"
33 #include "FIFORunner.hh"
34
35 //#include "SignalDispatcher.mpp"
36 ///////////////////////////////hh.p////////////////////////////////////////
37
38 namespace senf {
39 namespace scheduler {
40
41     /** \brief
42       */
43     class SignalDispatcher
44         : public FdManager::Event
45     {
46     public:
47         ///////////////////////////////////////////////////////////////////////////
48         // Types
49
50         typedef boost::function<void (siginfo_t const &)> Callback;
51
52         ///////////////////////////////////////////////////////////////////////////
53         ///\name Structors and default members
54         ///@{
55
56         explicit SignalDispatcher(FdManager & manager, FIFORunner & runner);
57         ~SignalDispatcher();
58
59         ///@}
60         ///////////////////////////////////////////////////////////////////////////
61
62         void add(int signal, Callback const & cb);
63         void remove(int signal);
64
65         void blockSignals();
66         void unblockSignals();
67
68     protected:
69
70     private:
71         struct SignalEvent
72             : public FIFORunner::TaskInfo
73         {
74             explicit SignalEvent(Callback cb_);
75             virtual ~SignalEvent();
76             virtual void run();
77
78             siginfo_t siginfo;
79             Callback cb;
80         };
81
82         virtual void signal(int events);
83         static void sigHandler(int signal, ::siginfo_t * siginfo, void *);
84
85         FdManager & manager_;
86         FIFORunner & runner_;
87
88         typedef std::map<int, SignalEvent> HandlerMap;
89         HandlerMap handlers_;
90
91         int sigPipe_[2];
92
93         bool blocked_;
94         sigset_t sigSet_;
95
96         static SignalDispatcher * instance_;
97     };
98
99
100 }}
101
102 ///////////////////////////////hh.e////////////////////////////////////////
103 #include "SignalDispatcher.cci"
104 //#include "SignalDispatcher.ct"
105 //#include "SignalDispatcher.cti"
106 #endif
107
108 \f
109 // Local Variables:
110 // mode: c++
111 // fill-column: 100
112 // comment-column: 40
113 // c-file-style: "senf"
114 // indent-tabs-mode: nil
115 // ispell-local-dictionary: "american"
116 // compile-command: "scons -u test"
117 // End: