From: Sage Weil Date: Wed, 30 May 2018 19:38:39 +0000 (-0500) Subject: osdc/Objecter: use get_addrs X-Git-Tag: v14.0.1~1208^2~13 X-Git-Url: http://git.apps.os.sepia.ceph.com/?a=commitdiff_plain;h=9fda383ff9c44a2ba0496547244d5a890954baf0;p=ceph-ci.git osdc/Objecter: use get_addrs Signed-off-by: Sage Weil --- diff --git a/src/osdc/Objecter.cc b/src/osdc/Objecter.cc index 62accf4ed4a..f058ea90afb 100644 --- a/src/osdc/Objecter.cc +++ b/src/osdc/Objecter.cc @@ -1244,7 +1244,7 @@ void Objecter::handle_osd_map(MOSDMap *m) // osd down or addr change? if (!osdmap->is_up(s->osd) || (s->con && - s->con->get_peer_addr() != osdmap->get_inst(s->osd).addr)) { + s->con->get_peer_addrs() != osdmap->get_addrs(s->osd))) { close_session(s); } } @@ -1801,7 +1801,7 @@ int Objecter::_get_session(int osd, OSDSession **session, shunique_lock& sul) } OSDSession *s = new OSDSession(cct, osd); osd_sessions[osd] = s; - s->con = messenger->get_connection(osdmap->get_inst(osd)); + s->con = messenger->connect_to_osd(osdmap->get_addrs(osd)); s->con->set_priv(RefCountedPtr{s}); logger->inc(l_osdc_osd_session_open); logger->set(l_osdc_osd_sessions, osd_sessions.size()); @@ -1836,15 +1836,15 @@ void Objecter::_reopen_session(OSDSession *s) { // s->lock is locked - entity_inst_t inst = osdmap->get_inst(s->osd); + auto addrs = osdmap->get_addrs(s->osd); ldout(cct, 10) << "reopen_session osd." << s->osd << " session, addr now " - << inst << dendl; + << addrs << dendl; if (s->con) { s->con->set_priv(NULL); s->con->mark_down(); logger->inc(l_osdc_osd_session_close); } - s->con = messenger->get_connection(inst); + s->con = messenger->connect_to_osd(addrs); s->con->set_priv(RefCountedPtr{s}); s->incarnation++; logger->inc(l_osdc_osd_session_open);