// 1. simple round trip
MPing *m = new MPing();
- ConnectionRef conn = client_msgr->get_connection(entity_inst_t(
- entity_name_t(server_msgr->get_mytype(), -1),
- server_msgr->get_myaddrs().msgr2_addr()));
+ ConnectionRef conn = client_msgr->connect_to(
+ server_msgr->get_mytype(),
+ server_msgr->get_myaddrs());
{
ASSERT_EQ(conn->send_message(m), 0);
Mutex::Locker l(cli_dispatcher.lock);
ASSERT_TRUE(avoid_ports.count(a.get_port()) == 0);
}
- conn = client_msgr->get_connection(entity_inst_t(
- entity_name_t(server_msgr->get_mytype(), -1),
- server_msgr->get_myaddrs().msgr2_addr()));
+ conn = client_msgr->connect_to(
+ server_msgr->get_mytype(),
+ server_msgr->get_myaddrs());
{
m = new MPing();
ASSERT_EQ(conn->send_message(m), 0);