From: Sage Weil <sage@redhat.com>
Date: Thu, 1 Mar 2018 22:17:30 +0000 (-0600)
Subject: ceph-mds: use preforker
X-Git-Tag: v13.0.2~79^2~2
X-Git-Url: http://git-server-git.apps.pok.os.sepia.ceph.com/?a=commitdiff_plain;h=50941e24e28df80c2e97d1beb77d9c39f5b2c939;p=ceph.git

ceph-mds: use preforker

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

diff --git a/src/ceph_mds.cc b/src/ceph_mds.cc
index 0a2548060e1..b1a161abb68 100644
--- a/src/ceph_mds.cc
+++ b/src/ceph_mds.cc
@@ -147,6 +147,24 @@ int main(int argc, const char **argv)
       "MDS names may not start with a numeric digit." << dendl;
   }
 
+  if (global_init_prefork(g_ceph_context) >= 0) {
+    std::string err;
+    int r = forker.prefork(err);
+    if (r < 0) {
+      cerr << err << std::endl;
+      return r;
+    }
+    if (forker.is_parent()) {
+      if (forker.parent_wait(err) != 0) {
+        return -ENXIO;
+      }
+      return 0;
+    }
+    global_init_postfork_start(g_ceph_context);
+  }
+  common_init_finish(g_ceph_context);
+  global_init_chdir(g_ceph_context);
+
   auto nonce = ceph::util::generate_random_number<uint64_t>();
 
   std::string public_msgr_type = g_conf->ms_public_type.empty() ? g_conf->get_val<std::string>("ms_type") : g_conf->ms_public_type;
@@ -154,7 +172,7 @@ int main(int argc, const char **argv)
 				      entity_name_t::MDS(-1), "mds",
 				      nonce, Messenger::HAS_MANY_CONNECTIONS);
   if (!msgr)
-    exit(1);
+    forker.exit(1);
   msgr->set_cluster_protocol(CEPH_MDS_PROTOCOL);
 
   cout << "starting " << g_conf->name << " at " << msgr->get_myaddr()
@@ -173,11 +191,8 @@ int main(int argc, const char **argv)
 
   int r = msgr->bind(g_conf->public_addr);
   if (r < 0)
-    exit(1);
+    forker.exit(1);
 
-  global_init_daemonize(g_ceph_context);
-  common_init_finish(g_ceph_context);
-  
   // set up signal handlers, now that we've daemonized/forked.
   init_async_signal_handler();
   register_async_signal_handler(SIGHUP, sighup_handler);
@@ -185,7 +200,7 @@ int main(int argc, const char **argv)
   // get monmap
   MonClient mc(g_ceph_context);
   if (mc.build_initial_monmap() < 0)
-    return -1;
+    forker.exit(1);
   global_init_chdir(g_ceph_context);
 
   msgr->start();
@@ -197,6 +212,11 @@ int main(int argc, const char **argv)
   mds->orig_argc = argc;
   mds->orig_argv = argv;
 
+  if (g_conf->daemonize) {
+    global_init_postfork_finish(g_ceph_context);
+    forker.daemonize();
+  }
+
   r = mds->init();
   if (r < 0) {
     msgr->wait();