From: Sage Weil Date: Wed, 30 May 2018 17:45:48 +0000 (-0500) Subject: osd: kill get_{cluster,hb_front,hb_back}_inst users X-Git-Tag: v14.0.1~1208^2~21 X-Git-Url: http://git.apps.os.sepia.ceph.com/?a=commitdiff_plain;h=4b674bb9ded626610440cb652c0a9664cff85e4c;p=ceph.git osd: kill get_{cluster,hb_front,hb_back}_inst users Signed-off-by: Sage Weil --- diff --git a/src/osd/OSD.cc b/src/osd/OSD.cc index f60e0ef7e0513..2620a87ff440e 100644 --- a/src/osd/OSD.cc +++ b/src/osd/OSD.cc @@ -849,8 +849,8 @@ void OSDService::send_message_osd_cluster(int peer, Message *m, epoch_t from_epo release_map(next_map); return; } - const entity_inst_t& peer_inst = next_map->get_cluster_inst(peer); - ConnectionRef peer_con = osd->cluster_messenger->get_connection(peer_inst); + ConnectionRef peer_con = osd->cluster_messenger->connect_to_osd( + next_map->get_cluster_addrs(peer)); share_map_peer(peer, peer_con.get(), next_map); peer_con->send_message(m); release_map(next_map); @@ -867,7 +867,8 @@ ConnectionRef OSDService::get_con_osd_cluster(int peer, epoch_t from_epoch) release_map(next_map); return NULL; } - ConnectionRef con = osd->cluster_messenger->get_connection(next_map->get_cluster_inst(peer)); + ConnectionRef con = osd->cluster_messenger->connect_to_osd( + next_map->get_cluster_addrs(peer)); release_map(next_map); return con; } @@ -884,9 +885,10 @@ pair OSDService::get_con_osd_hb(int peer, epoch_t f release_map(next_map); return ret; } - ret.first = osd->hb_back_client_messenger->get_connection(next_map->get_hb_back_inst(peer)); - if (next_map->get_hb_front_addr(peer) != entity_addr_t()) - ret.second = osd->hb_front_client_messenger->get_connection(next_map->get_hb_front_inst(peer)); + ret.first = osd->hb_back_client_messenger->connect_to_osd( + next_map->get_hb_back_addrs(peer)); + ret.second = osd->hb_front_client_messenger->connect_to_osd( + next_map->get_hb_front_addrs(peer)); release_map(next_map); return ret; } diff --git a/src/osd/OSDMap.h b/src/osd/OSDMap.h index 31d874ea9392c..24d0a0c452594 100644 --- a/src/osd/OSDMap.h +++ b/src/osd/OSDMap.h @@ -941,18 +941,6 @@ public: assert(is_up(osd)); return get_most_recent_inst(osd); } - entity_inst_t get_cluster_inst(int osd) const { - assert(is_up(osd)); - return entity_inst_t(entity_name_t::OSD(osd), get_cluster_addr(osd)); - } - entity_inst_t get_hb_back_inst(int osd) const { - assert(is_up(osd)); - return entity_inst_t(entity_name_t::OSD(osd), get_hb_back_addr(osd)); - } - entity_inst_t get_hb_front_inst(int osd) const { - assert(is_up(osd)); - return entity_inst_t(entity_name_t::OSD(osd), get_hb_front_addr(osd)); - } const uuid_d& get_uuid(int osd) const { assert(exists(osd));