remove ceph code

[stor4nfv.git] / src / ceph / src / msg / Messenger.cc

diff --git a/src/ceph/src/msg/Messenger.cc b/src/ceph/src/msg/Messenger.cc
deleted file mode 100644 (file)
index 6ab2862..0000000
--- a/src/ceph/src/msg/Messenger.cc
+++ /dev/null
@@ -1,87 +0,0 @@
-// -*- mode:C++; tab-width:8; c-basic-offset:2; indent-tabs-mode:t -*-
-// vim: ts=8 sw=2 smarttab
-
-#include <random>
-#include <netdb.h>
-#include "include/Spinlock.h"
-
-#include "include/types.h"
-#include "Messenger.h"
-
-#include "msg/simple/SimpleMessenger.h"
-#include "msg/async/AsyncMessenger.h"
-#ifdef HAVE_XIO
-#include "msg/xio/XioMessenger.h"
-#endif
-
-Messenger *Messenger::create_client_messenger(CephContext *cct, string lname)
-{
-  std::string public_msgr_type = cct->_conf->ms_public_type.empty() ? cct->_conf->get_val<std::string>("ms_type") : cct->_conf->ms_public_type;
-  uint64_t nonce = 0;
-  get_random_bytes((char*)&nonce, sizeof(nonce));
-  return Messenger::create(cct, public_msgr_type, entity_name_t::CLIENT(),
-                          std::move(lname), nonce, 0);
-}
-
-Messenger *Messenger::create(CephContext *cct, const string &type,
-                            entity_name_t name, string lname,
-                            uint64_t nonce, uint64_t cflags)
-{
-  int r = -1;
-  if (type == "random") {
-    static std::random_device seed;
-    static std::default_random_engine random_engine(seed());
-    static Spinlock random_lock;
-
-    std::lock_guard<Spinlock> lock(random_lock);
-    std::uniform_int_distribution<> dis(0, 1);
-    r = dis(random_engine);
-  }
-  if (r == 0 || type == "simple")
-    return new SimpleMessenger(cct, name, std::move(lname), nonce);
-  else if (r == 1 || type.find("async") != std::string::npos)
-    return new AsyncMessenger(cct, name, type, std::move(lname), nonce);
-#ifdef HAVE_XIO
-  else if ((type == "xio") &&
-          cct->check_experimental_feature_enabled("ms-type-xio"))
-    return new XioMessenger(cct, name, std::move(lname), nonce, cflags);
-#endif
-  lderr(cct) << "unrecognized ms_type '" << type << "'" << dendl;
-  return nullptr;
-}
-
-void Messenger::set_endpoint_addr(const entity_addr_t& a,
-                                  const entity_name_t &name)
-{
-  size_t hostlen;
-  if (a.get_family() == AF_INET)
-    hostlen = sizeof(struct sockaddr_in);
-  else if (a.get_family() == AF_INET6)
-    hostlen = sizeof(struct sockaddr_in6);
-  else
-    hostlen = 0;
-
-  if (hostlen) {
-    char buf[NI_MAXHOST] = { 0 };
-    getnameinfo(a.get_sockaddr(), hostlen, buf, sizeof(buf),
-                NULL, 0, NI_NUMERICHOST);
-
-    trace_endpoint.copy_ip(buf);
-  }
-  trace_endpoint.set_port(a.get_port());
-}
-
-/*
- * Pre-calculate desired software CRC settings.  CRC computation may
- * be disabled by default for some transports (e.g., those with strong
- * hardware checksum support).
- */
-int Messenger::get_default_crc_flags(md_config_t * conf)
-{
-  int r = 0;
-  if (conf->ms_crc_data)
-    r |= MSG_CRC_DATA;
-  if (conf->ms_crc_header)
-    r |= MSG_CRC_HEADER;
-  return r;
-}