X-Git-Url: https://gerrit.opnfv.org/gerrit/gitweb?a=blobdiff_plain;f=src%2Fceph%2Fsrc%2Fceph_syn.cc;fp=src%2Fceph%2Fsrc%2Fceph_syn.cc;h=0000000000000000000000000000000000000000;hb=7da45d65be36d36b880cc55c5036e96c24b53f00;hp=81f15cc51d0fc076e19af3fdb821231de36386ea;hpb=691462d09d0987b47e112d6ee8740375df3c51b2;p=stor4nfv.git diff --git a/src/ceph/src/ceph_syn.cc b/src/ceph/src/ceph_syn.cc deleted file mode 100644 index 81f15cc..0000000 --- a/src/ceph/src/ceph_syn.cc +++ /dev/null @@ -1,103 +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) 2004-2006 Sage Weil - * - * 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 "client/SyntheticClient.h" -#include "client/Client.h" - -#include "msg/Messenger.h" - -#include "mon/MonClient.h" - -#include "common/Timer.h" -#include "global/global_init.h" -#include "common/ceph_argparse.h" -#include "common/pick_address.h" - -#include -#include - -extern int syn_filer_flags; - -int main(int argc, const char **argv, char *envp[]) -{ - //cerr << "ceph-syn starting" << std::endl; - vector args; - argv_to_vec(argc, argv, args); - - auto cct = global_init(NULL, args, CEPH_ENTITY_TYPE_CLIENT, - CODE_ENVIRONMENT_UTILITY, 0); - common_init_finish(g_ceph_context); - - parse_syn_options(args); // for SyntheticClient - - pick_addresses(g_ceph_context, CEPH_PICK_ADDRESS_PUBLIC); - - // get monmap - MonClient mc(g_ceph_context); - if (mc.build_initial_monmap() < 0) - return -1; - - list clients; - list synclients; - Messenger* messengers[num_client]; - MonClient* mclients[num_client]; - - cout << "ceph-syn: starting " << num_client << " syn client(s)" << std::endl; - for (int i=0; ibind(g_conf->public_addr); - mclients[i] = new MonClient(g_ceph_context); - mclients[i]->build_initial_monmap(); - auto client = new StandaloneClient(messengers[i], mclients[i]); - client->set_filer_flags(syn_filer_flags); - SyntheticClient *syn = new SyntheticClient(client); - clients.push_back(client); - synclients.push_back(syn); - messengers[i]->start(); - } - - for (list::iterator p = synclients.begin(); - p != synclients.end(); - ++p) - (*p)->start_thread(); - - //cout << "waiting for client(s) to finish" << std::endl; - while (!clients.empty()) { - Client *client = clients.front(); - SyntheticClient *syn = synclients.front(); - clients.pop_front(); - synclients.pop_front(); - syn->join_thread(); - delete syn; - delete client; - } - - for (int i = 0; i < num_client; ++i) { - // wait for messenger to finish - delete mclients[i]; - messengers[i]->shutdown(); - messengers[i]->wait(); - delete messengers[i]; - } - return 0; -} -