]> git.apps.os.sepia.ceph.com Git - ceph.git/commitdiff
msg/async: fix some debug prefixes
authorSage Weil <sage@redhat.com>
Mon, 4 Jun 2018 21:35:36 +0000 (16:35 -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 e1d9e287db96bc2de560c18fb09c3de995ab7b2b..52e0b940e3e0c2a5852e8d2adb162946125e7f1b 100644 (file)
@@ -33,7 +33,7 @@
 #undef dout_prefix
 #define dout_prefix _conn_prefix(_dout)
 ostream& AsyncConnection::_conn_prefix(std::ostream *_dout) {
-  return *_dout << "-- " << async_msgr->get_myaddr() << " >> "
+  return *_dout << "-- " << async_msgr->get_myaddrs() << " >> "
                << peer_addrs << " conn(" << this
                 << " :" << port
                 << " s=" << get_state_name(state)
@@ -1886,8 +1886,8 @@ int AsyncConnection::send_message(Message *m)
 {
   FUNCTRACE(async_msgr->cct);
   lgeneric_subdout(async_msgr->cct, ms,
-                  1) << "-- " << async_msgr->get_myaddr() << " --> "
-                     << get_peer_addr() << " -- "
+                  1) << "-- " << async_msgr->get_myaddrs() << " --> "
+                     << get_peer_addrs() << " -- "
                      << *m << " -- " << m << " con "
                      << m->get_connection().get()
                      << dendl;
@@ -1904,7 +1904,7 @@ int AsyncConnection::send_message(Message *m)
   else if (m->get_type() == CEPH_MSG_OSD_OPREPLY)
     OID_EVENT_TRACE_WITH_MSG(m, "SEND_MSG_OSD_OPREPLY_BEGIN", true);
 
-  if (async_msgr->get_myaddr() == get_peer_addr()) { //loopback connection
+  if (async_msgr->get_myaddrs() == get_peer_addrs()) { //loopback connection
     ldout(async_msgr->cct, 20) << __func__ << " " << *m << " local" << dendl;
     std::lock_guard<std::mutex> l(write_lock);
     if (can_write != WriteStatus::CLOSED) {