4 * The secure anycast tunneling protocol (satp) defines a protocol used
5 * for communication between any combination of unicast and anycast
6 * tunnel endpoints. It has less protocol overhead than IPSec in Tunnel
7 * mode and allows tunneling of every ETHER TYPE protocol (e.g.
8 * ethernet, ip, arp ...). satp directly includes cryptography and
9 * message authentication based on the methodes used by SRTP. It is
10 * intended to deliver a generic, scaleable and secure solution for
11 * tunneling and relaying of packets of any protocol.
14 * Copyright (C) 2007-2009 Othmar Gsenger, Erwin Nindl,
15 * Christian Pointner <satp@wirdorange.org>
17 * This file is part of Anytun.
19 * Anytun is free software: you can redistribute it and/or modify
20 * it under the terms of the GNU General Public License as published by
21 * the Free Software Foundation, either version 3 of the License, or
24 * Anytun is distributed in the hope that it will be useful,
25 * but WITHOUT ANY WARRANTY; without even the implied warranty of
26 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
27 * GNU General Public License for more details.
29 * You should have received a copy of the GNU General Public License
30 * along with anytun. If not, see <http://www.gnu.org/licenses/>.
36 #include "signalController.h"
38 #include "anytunError.h"
39 #include "threadUtils.hpp"
43 #include <boost/bind.hpp>
48 SignalController* SignalController::inst = NULL;
49 Mutex SignalController::instMutex;
50 SignalController& gSignalController = SignalController::instance();
52 SignalController& SignalController::instance()
55 static instanceCleaner c;
57 inst = new SignalController();
62 int SigErrorHandler::handle(const std::string& msg)
64 AnytunError::throwErr() << msg;
71 int SigIntHandler::handle()
73 cLog.msg(Log::PRIO_NOTICE) << "SIG-Int caught, exiting";
78 int SigQuitHandler::handle()
80 cLog.msg(Log::PRIO_NOTICE) << "SIG-Quit caught, exiting";
85 int SigHupHandler::handle()
87 cLog.msg(Log::PRIO_NOTICE) << "SIG-Hup caught";
92 int SigTermHandler::handle()
94 cLog.msg(Log::PRIO_NOTICE) << "SIG-Term caughtm, exiting";
99 int SigUsr1Handler::handle()
101 cLog.msg(Log::PRIO_NOTICE) << "SIG-Usr1 caught";
106 int SigUsr2Handler::handle()
108 cLog.msg(Log::PRIO_NOTICE) << "SIG-Usr2 caught";
113 int CtrlCHandler::handle()
115 cLog.msg(Log::PRIO_NOTICE) << "CTRL-C Event received, exitting";
120 int CtrlBreakHandler::handle()
122 cLog.msg(Log::PRIO_NOTICE) << "CTRL-Break Event received, ignoring";
127 int CtrlCloseHandler::handle()
129 cLog.msg(Log::PRIO_NOTICE) << "Close Event received, exitting";
134 int CtrlLogoffHandler::handle()
136 cLog.msg(Log::PRIO_NOTICE) << "LogOff Event received, exitting";
141 int CtrlShutdownHandler::handle()
143 cLog.msg(Log::PRIO_NOTICE) << "Shutdown Event received, exitting";
149 SignalController::~SignalController()
151 for(HandlerMap::iterator it = handler.begin(); it != handler.end(); ++it)
156 void SignalController::handle()
163 sigfillset(&signal_set);
164 sigwait(&signal_set, &sigNum);
169 bool SignalController::handle(DWORD ctrlType)
171 gSignalController.inject(ctrlType);
176 void SignalController::init()
181 sigfillset(&signal_set);
182 sigdelset(&signal_set, SIGCHLD);
183 sigdelset(&signal_set, SIGSEGV);
184 sigdelset(&signal_set, SIGBUS);
185 sigdelset(&signal_set, SIGFPE);
187 #if defined(BOOST_HAS_PTHREADS)
188 pthread_sigmask(SIG_BLOCK, &signal_set, NULL);
190 #error The signalhandler works only with pthreads
193 boost::thread(boost::bind(&SignalController::handle, this));
195 handler[SIGINT] = new SigIntHandler;
196 handler[SIGQUIT] = new SigQuitHandler;
197 handler[SIGHUP] = new SigHupHandler;
198 handler[SIGTERM] = new SigTermHandler;
199 handler[SIGUSR1] = new SigUsr1Handler;
200 handler[SIGUSR2] = new SigUsr2Handler;
202 if(!SetConsoleCtrlHandler((PHANDLER_ROUTINE)SignalController::handle, true))
203 AnytunError::throwErr() << "Error on SetConsoleCtrlhandler: " << AnytunErrno(GetLastError());
205 handler[CTRL_C_EVENT] = new CtrlCHandler;
206 handler[CTRL_BREAK_EVENT] = new CtrlBreakHandler;
207 handler[CTRL_CLOSE_EVENT] = new CtrlCloseHandler;
208 handler[CTRL_LOGOFF_EVENT] = new CtrlLogoffHandler;
209 handler[CTRL_SHUTDOWN_EVENT] = new CtrlShutdownHandler;
212 handler[SIGERROR] = new SigErrorHandler;
215 void SignalController::inject(int sig, const std::string& msg)
218 Lock lock(sigQueueMutex);
219 sigQueue.push(SigPair(sig, msg));
224 int SignalController::run()
230 Lock lock(sigQueueMutex);
231 sig = sigQueue.front();
235 HandlerMap::iterator it = handler.find(sig.first);
236 if(it != handler.end())
240 ret = it->second->handle();
242 ret = it->second->handle(sig.second);
248 cLog.msg(Log::PRIO_NOTICE) << "SIG " << sig.first << " caught with message '" << sig.second << "' - ignoring";