X-Git-Url: https://gerrit.opnfv.org/gerrit/gitweb?a=blobdiff_plain;f=src%2Fceph%2Fsrc%2Ftest%2Fmessenger%2Fsimple_server.cc;fp=src%2Fceph%2Fsrc%2Ftest%2Fmessenger%2Fsimple_server.cc;h=0000000000000000000000000000000000000000;hb=7da45d65be36d36b880cc55c5036e96c24b53f00;hp=34277d513ff92129483c07610b14f1fd70834cb1;hpb=691462d09d0987b47e112d6ee8740375df3c51b2;p=stor4nfv.git diff --git a/src/ceph/src/test/messenger/simple_server.cc b/src/ceph/src/test/messenger/simple_server.cc deleted file mode 100644 index 34277d5..0000000 --- a/src/ceph/src/test/messenger/simple_server.cc +++ /dev/null @@ -1,108 +0,0 @@ -// -*- mode:C++; tab-width:8; c-basic-offset:2; indent-tabs-mode:t -*- -// vim: ts=8 sw=2 smarttab -/* - * Ceph - scalable distributed file system - * - * Copyright (C) 2013 CohortFS, LLC - * - * This is free software; you can redistribute it and/or - * modify it under the terms of the GNU Lesser General Public - * License version 2.1, as published by the Free Software - * Foundation. See file COPYING. - * - */ - -#include - -#include -#include - -using namespace std; - -#include "common/config.h" -#include "msg/Messenger.h" -#include "common/Timer.h" -#include "common/ceph_argparse.h" -#include "global/global_init.h" -#include "global/signal_handler.h" -#include "perfglue/heap_profiler.h" -#include "common/address_helper.h" -#include "simple_dispatcher.h" - -#define dout_subsys ceph_subsys_simple_server - - -int main(int argc, const char **argv) -{ - vector args; - Messenger *messenger; - Dispatcher *dispatcher; - std::vector::iterator arg_iter; - std::string val; - entity_addr_t bind_addr; - int r = 0; - - using std::endl; - - std::string addr = "localhost"; - std::string port = "1234"; - - cout << "Simple Server starting..." << endl; - - argv_to_vec(argc, argv, args); - env_to_vec(args); - - auto cct = global_init(NULL, args, CEPH_ENTITY_TYPE_ANY, - CODE_ENVIRONMENT_DAEMON, - 0); - - for (arg_iter = args.begin(); arg_iter != args.end();) { - if (ceph_argparse_witharg(args, arg_iter, &val, "--addr", - (char*) NULL)) { - addr = val; - } else if (ceph_argparse_witharg(args, arg_iter, &val, "--port", - (char*) NULL)) { - port = val; - } else { - ++arg_iter; - } - }; - - string dest_str = "tcp://"; - dest_str += addr; - dest_str += ":"; - dest_str += port; - entity_addr_from_url(&bind_addr, dest_str.c_str()); - - messenger = Messenger::create(g_ceph_context, g_conf->get_val("ms_type"), - entity_name_t::MON(-1), - "simple_server", - 0 /* nonce */, - 0 /* flags */); - // enable timing prints - messenger->set_magic(MSG_MAGIC_TRACE_CTR); - messenger->set_default_policy( - Messenger::Policy::stateless_server(0)); - - r = messenger->bind(bind_addr); - if (r < 0) - goto out; - - // Set up crypto, daemonize, etc. - //global_init_daemonize(g_ceph_context, 0); - common_init_finish(g_ceph_context); - - dispatcher = new SimpleDispatcher(messenger); - - messenger->add_dispatcher_head(dispatcher); // should reach ready() - messenger->start(); - messenger->wait(); // can't be called until ready() - - // done - delete messenger; - -out: - cout << "Simple Server exit" << endl; - return r; -} -