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);
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;
}
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;
}
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));