mds: install async signal handlers for SIG{HUP,INT,TERM}

Signed-off-by: Sage Weil <sage.weil@dreamhost.com>

2 files changed, 13 insertions, 2 deletions

diff --git a/src/mds/MDS.cc b/src/mds/MDS.cc
index 86890d3beee..cc5609aa60b 100644
--- a/src/mds/MDS.cc
+++ b/src/mds/MDS.cc
@@ -12,7 +12,7 @@
  * 
  */
 
-
+#include "global/signal_handler.h"
 
 #include "include/types.h"
 #include "common/entity_name.h"
@@ -20,6 +20,7 @@
 #include "common/signal.h"
 #include "common/ceph_argparse.h"
 
+
 #include "msg/Messenger.h"
 #include "mon/MonClient.h"
 
@@ -1511,7 +1512,14 @@ void MDS::stopping_done()
   request_state(MDSMap::STATE_STOPPED);
 }
 
-  
+void MDS::handle_signal(int signum)
+{
+  assert(signum == SIGINT || signum == SIGTERM);
+  derr << "*** got signal " << sys_siglist[signum] << " ***" << dendl;
+  mds_lock.Lock();
+  suicide();
+  mds_lock.Unlock();
+}
 
 void MDS::suicide()
 {
diff --git a/src/mds/MDS.h b/src/mds/MDS.h
index 0ca2ea08b86..67a51028d9c 100644
--- a/src/mds/MDS.h
+++ b/src/mds/MDS.h
@@ -323,6 +323,9 @@ class MDS : public Dispatcher {
   MDS(const std::string &n, Messenger *m, MonClient *mc);
   ~MDS();
 
+  // handle a signal (e.g., SIGTERM)
+  void handle_signal(int signum);
+
   // who am i etc
   int get_nodeid() { return whoami; }
   MDSMap *get_mds_map() { return mdsmap; }