msgr: introduce static Messenger::create() function

Create a new messenger, with whatever implementation is appropriate.

Signed-off-by: Sage Weil <sage@newdream.net>

diff --git a/src/Makefile.am b/src/Makefile.am
index b7b040c39e5813ebf1b4fe5e881c08b569dd588b..dd1b0bc993f2a7420974a35ab3b1ad0c8065e1e4 100644 (file)
--- a/src/Makefile.am
+++ b/src/Makefile.am
@@ -945,6 +945,7 @@ libcommon_files = \
        mon/MonCaps.cc \
        mon/MonClient.cc \
        mon/MonMap.cc \
+       msg/Messenger.cc \
        os/hobject.cc \
        osd/OSDMap.cc \
        osd/osd_types.cc \

diff --git a/src/msg/Messenger.cc b/src/msg/Messenger.cc
new file mode 100644 (file)
index 0000000..6cf8e41
--- /dev/null
+++ b/src/msg/Messenger.cc
@@ -0,0 +1,12 @@
+
+#include "include/types.h"
+#include "Messenger.h"
+
+#include "SimpleMessenger.h"
+
+Messenger *Messenger::create(CephContext *cct,
+                            entity_name_t name,
+                            uint64_t nonce)
+{
+  return new SimpleMessenger(cct, name, nonce);
+}

diff --git a/src/msg/Messenger.h b/src/msg/Messenger.h
index e89fa1654c2b71521b2dcbb40fad184b6601dd61..61e35e1bff254bf2ec31a782d5a5c6069b9d9b52 100644 (file)
--- a/src/msg/Messenger.h
+++ b/src/msg/Messenger.h
@@ -299,6 +299,19 @@ protected:
    */
   virtual void set_policy_throttler(int type, Throttle *t) = 0;
 
+  /**
+   * create a new messenger
+   *
+   * Create a new messenger instance, with whatever implementation is
+   * available or specified via the configuration in cct.
+   *
+   * @param cct context
+   * @param name entity name to register
+   * @param nonce nonce value to uniquely identify this instance on the current host
+   */
+  static Messenger *create(CephContext *cct,
+                          entity_name_t name,
+                          uint64_t nonce);
 };