add SignHandler & rename MsgHandler -> MSGHandler

Make.defines

@@ -8,7 +8,7 @@ CLEAN = \
 		include/TimeEventSet \
 		include/Status \
 		include/TCPAcceptor \
-		include/Selector  MsgHandler\
+		include/Selector  MSGHandler\
 		tests/echo_client \
 		tests/echo_server \
 		tests/test_log \
@@ -29,4 +29,4 @@ CLEAN = \
 		utils/Atomic \
 		utils/Buffer \
 		utils/Thread \
-		include/MsgHandler
+		include/MSGHandler

core/EventLoop.cpp

@@ -206,4 +206,15 @@ void EventLoop::attach(const Callback<void> &call, const Timer &timer)
     m_heap.add(call, timer);
 }
 
+void EventLoop::attach(int signo, void (*sighandler)(int))
+{
+    m_signal -> attach(signo, sighandler);
+}
+
+void EventLoop::attach()
+{
+    SignalOuter &outer = SignalOuter::Instance();
+    m_signal = new SignalHandler(this, outer.sockets().second);
+}
+
 };

core/EventPool.cpp

@@ -31,6 +31,9 @@ EventPool::EventPool(int loopNum) : m_loopNum(loopNum)
 
     for(int i=0; i < loopNum ; i++)
         m_loops[i] = new EventLoop(this);
+
+    /// Attach Signal Handler to the master thread
+    m_loops[0] -> attach();
 }
 
 EventPool::~EventPool()
@@ -118,4 +121,9 @@ void* EventPool::ThreadFunc(void *arg)
     pthread_exit(NULL);
 }
 
+void EventPool::attach(int signo, void (*sighandler)(int))
+{
+    m_loops[0] -> attach(signo, sighandler);
+}
+
 };

http/HttpRequest.h

@@ -5,7 +5,7 @@
 #ifndef _HTTP_CONN_H
 #define _HTTP_CONN_H
 
-#include "MsgHandler.h"
+#include "MSGHandler.h"
 using namespace eventserver;
 
 namespace http

include/EventLoop.h

@@ -12,6 +12,7 @@ using namespace utils;
 #include "Handler.h"
 #include "Acceptor.h"
 #include "Selector.h"
+#include "SignalHandler.h"
 
 namespace eventserver
 {
@@ -81,6 +82,12 @@ class EventLoop : public Noncopyable
     /// Attach Timer to this loop
     void attach(const Callback<void> &call, const Timer &timer);
 
+    /// Attach Signal Handler
+    void attach(int signo, void (*sighandler)(int));
+
+    /// Attach signal handler
+    void attach();
+
 private:
     /// Run After dispatch(for all active events)
     void runAllActives();
@@ -103,6 +110,7 @@ class EventLoop : public Noncopyable
     vector<Handler*>   m_del;
     map<int, Handler*> m_map;
     TimerEvents        m_heap;
+    SignalHandler     *m_signal;
 
     friend class Acceptor;
 };

include/EventPool.h

@@ -45,6 +45,10 @@ class EventPool : public Noncopyable
     /// get the Number of Loops
     int        getLoopNum() const;
 
+public:
+    /// attach signal handler
+    void       attach(int signo, void(*sighanler)(int));
+
 private:
     /// Threadxxxx is used to assist the `run`
     void*        ThreadBody(int id);