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;
Messenger *msgr = Messenger::create(g_ceph_context, type, entity_name_t::CLIENT(0), "client", getpid()+i, 0);
msgr->set_default_policy(Messenger::Policy::lossless_client(0));
msgr->start();
- entity_inst_t inst(entity_name_t::OSD(0), addr);
- ConnectionRef conn = msgr->get_connection(inst);
+ entity_addrvec_t addrs(addr);
+ ConnectionRef conn = msgr->connect_to_osd(addrs);
ClientThread *t = new ClientThread(msgr, c, conn, msg_len, ops, think_time_us);
msgrs.push_back(msgr);
clients.push_back(t);