ts.tv_nsec = 0;
argv_to_vec(argc, argv, args);
- env_to_vec(args);
auto cct = global_init(NULL, args, CEPH_ENTITY_TYPE_ANY,
CODE_ENVIRONMENT_UTILITY,
- 0);
+ CINIT_FLAG_NO_DEFAULT_CONFIG_FILE);
for (arg_iter = args.begin(); arg_iter != args.end();) {
if (ceph_argparse_witharg(args, arg_iter, &val, "--addr",
"initial msgs (pipe depth) " << n_msgs << " " <<
"data buffer size " << n_dsize << std::endl;
- messenger = Messenger::create(g_ceph_context, g_conf->get_val<std::string>("ms_type"),
+ messenger = Messenger::create(g_ceph_context, g_conf().get_val<std::string>("ms_type"),
entity_name_t::MON(-1),
"client",
getpid(), 0);
dest_str += ":";
dest_str += port;
entity_addr_from_url(&dest_addr, dest_str.c_str());
- entity_inst_t dest_server(entity_name_t::MON(-1), dest_addr);
+ entity_addrvec_t dest_addrs(dest_addr);
dispatcher = new SimpleDispatcher(messenger);
messenger->add_dispatcher_head(dispatcher);
if (r < 0)
goto out;
- conn = messenger->get_connection(dest_server);
+ conn = messenger->connect_to_mon(dest_addrs);
// do stuff
time_t t1, t2;