]> git.apps.os.sepia.ceph.com Git - ceph.git/commitdiff
ceph_test_msgr: remove final get_connection() user
authorSage Weil <sage@redhat.com>
Mon, 14 Jan 2019 20:17:29 +0000 (14:17 -0600)
committerSage Weil <sage@redhat.com>
Mon, 14 Jan 2019 20:17:29 +0000 (14:17 -0600)
Signed-off-by: Sage Weil <sage@redhat.com>
src/test/msgr/test_msgr.cc

index bf8666405ff8277032becf2624c8d5d53ce4d640..035b2f865d24b731a6b89dbe250ea23007854904 100644 (file)
@@ -313,9 +313,9 @@ TEST_P(MessengerTest, SimpleMsgr2Test) {
 
   // 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);
@@ -339,9 +339,9 @@ TEST_P(MessengerTest, SimpleMsgr2Test) {
     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);