]> git-server-git.apps.pok.os.sepia.ceph.com Git - ceph.git/commitdiff
mds: send tell commands to asok infrastructure
authorSage Weil <sage@redhat.com>
Tue, 29 Oct 2019 20:53:15 +0000 (15:53 -0500)
committerSage Weil <sage@redhat.com>
Fri, 15 Nov 2019 18:42:40 +0000 (12:42 -0600)
Signed-off-by: Sage Weil <sage@redhat.com>
src/mds/MDSDaemon.cc

index 3f9f4ebafbf24e989d0d8faacbc87e4f73b2f416..900d4418cead10a6f9926d63a134c47d2baa43d6 100644 (file)
@@ -497,8 +497,6 @@ void MDSDaemon::handle_command(const cref_t<MCommand> &m)
   std::stringstream ss;
   std::string outs;
   bufferlist outbl;
-  Context *run_after = NULL;
-  bool need_reply = true;
 
   if (!session->auth_caps.allow_all()) {
     dout(1) << __func__
@@ -515,22 +513,12 @@ void MDSDaemon::handle_command(const cref_t<MCommand> &m)
     r = -EINVAL;
     outs = ss.str();
   } else {
-    try {
-      r = _handle_command(cmdmap, m, &outbl, &outs, &run_after, &need_reply);
-    } catch (const bad_cmd_get& e) {
-      outs = e.what();
-      r = -EINVAL;
-    }
+    cct->get_admin_socket()->queue_tell_command(m);
+    return;
   }
   priv.reset();
 
-  if (need_reply) {
-    send_command_reply(m, mds_rank, r, outbl, outs);
-  }
-
-  if (run_after) {
-    run_after->complete(0);
-  }
+  send_command_reply(m, mds_rank, r, outbl, outs);
 }
 
 const std::vector<MDSDaemon::MDSCommand>& MDSDaemon::get_commands()