]> git.apps.os.sepia.ceph.com Git - ceph.git/commitdiff
msg/async: (legacy) handshake using legacy addr
authorSage Weil <sage@redhat.com>
Mon, 4 Jun 2018 21:36:10 +0000 (16:36 -0500)
committerSage Weil <sage@redhat.com>
Tue, 3 Jul 2018 18:01:23 +0000 (13:01 -0500)
Signed-off-by: Sage Weil <sage@redhat.com>
src/msg/async/AsyncConnection.cc

index 52e0b940e3e0c2a5852e8d2adb162946125e7f1b..3777aa3b22de65f9139b53cf0f3b8669b6045f49 100644 (file)
@@ -990,17 +990,19 @@ ssize_t AsyncConnection::_process_connection()
           return 0;
         }
 
-        encode(async_msgr->get_myaddr(), myaddrbl, 0); // legacy
+        encode(async_msgr->get_myaddrs().legacy_addr(), myaddrbl, 0); // legacy
         r = try_send(myaddrbl);
         if (r == 0) {
           state = STATE_CONNECTING_SEND_CONNECT_MSG;
           ldout(async_msgr->cct, 10) << __func__ << " connect sent my addr "
-              << async_msgr->get_myaddr() << dendl;
+                                    << async_msgr->get_myaddrs().legacy_addr()
+                                    << dendl;
         } else if (r > 0) {
           state = STATE_WAIT_SEND;
           state_after_send = STATE_CONNECTING_SEND_CONNECT_MSG;
           ldout(async_msgr->cct, 10) << __func__ << " connect send my addr done: "
-              << async_msgr->get_myaddr() << dendl;
+                                    << async_msgr->get_myaddrs().legacy_addr()
+                                    << dendl;
         } else {
           ldout(async_msgr->cct, 2) << __func__ << " connect couldn't write my addr, "
               << cpp_strerror(r) << dendl;
@@ -1207,8 +1209,9 @@ ssize_t AsyncConnection::_process_connection()
 
         bl.append(CEPH_BANNER, strlen(CEPH_BANNER));
 
-        encode(async_msgr->get_myaddr(), bl, 0); // legacy
-        port = async_msgr->get_myaddr().get_port();
+       auto legacy = async_msgr->get_myaddrs().legacy_addr();
+        encode(legacy, bl, 0); // legacy
+        port = legacy.get_port();
         encode(socket_addr, bl, 0); // legacy
         ldout(async_msgr->cct, 1) << __func__ << " sd=" << cs.fd() << " " << socket_addr << dendl;