Add event option

Signed-off-by: Haomai Wang <haomaiwang@gmail.com>

diff --git a/src/common/config_opts.h b/src/common/config_opts.h
index 9376b759041001a292727f6ed33e996a9236dc0e..980e74afe867a1ed80fcf6a13b6f4082d13587cc 100644 (file)
--- a/src/common/config_opts.h
+++ b/src/common/config_opts.h
@@ -142,6 +142,7 @@ OPTION(ms_dump_corrupt_message_level, OPT_INT, 1)  // debug level to hexdump und
 OPTION(ms_event_op_threads, OPT_INT, 2)
 OPTION(ms_event_thread_timeout, OPT_INT, 15)
 OPTION(ms_event_thread_suicide_timeout, OPT_INT, 180)
+OPTION(ms_use_event, OPT_BOOL, false)
 
 OPTION(inject_early_sigterm, OPT_BOOL, false)
 

diff --git a/src/msg/Messenger.cc b/src/msg/Messenger.cc
index 8be11d44ac72327bcc4df8bb2f64f1f25989f0d1..21ccea1d2fa18d89e940b885f0bc4ff27d1ed3c8 100644 (file)
--- a/src/msg/Messenger.cc
+++ b/src/msg/Messenger.cc
@@ -3,6 +3,7 @@
 #include "Messenger.h"
 
 #include "msg/simple/SimpleMessenger.h"
+#include "AsyncMessenger.h"
 
 Messenger *Messenger::create(CephContext *cct,
                             entity_name_t name,
@@ -11,6 +12,8 @@ Messenger *Messenger::create(CephContext *cct,
 {
   if (cct->_conf->ms_type == "simple")
     return new SimpleMessenger(cct, name, lname, nonce);
+  else if (cct->_conf->ms_type == "async")
+    return new AsyncMessenger(cct, name, lname, nonce);
   lderr(cct) << "unrecognized ms_type '" << cct->_conf->ms_type << "'" << dendl;
   return NULL;
 }