dout(5) << "thrash_map osd." << o << " up" << dendl;
pending_inc.new_state[o] = CEPH_OSD_UP;
pending_inc.new_up_client[o] = entity_addr_t();
- pending_inc.new_up_internal[o] = entity_addr_t();
+ pending_inc.new_up_cluster[o] = entity_addr_t();
pending_inc.new_hb_up[o] = entity_addr_t();
pending_inc.new_weight[o] = CEPH_OSD_IN;
thrash_last_up_osd = o;
// mark new guy up.
pending_inc.new_up_client[from] = m->get_orig_source_addr();
if (!m->cluster_addr.is_blank_ip())
- pending_inc.new_up_internal[from] = m->cluster_addr;
+ pending_inc.new_up_cluster[from] = m->cluster_addr;
pending_inc.new_hb_up[from] = m->hb_addr;
// mark in?
::encode(new_lost, bl);
::encode(new_blacklist, bl);
::encode(old_blacklist, bl);
- ::encode(new_up_internal, bl);
+ ::encode(new_up_cluster, bl);
::encode(cluster_snapshot, bl);
::encode(new_uuid, bl);
::encode(new_xinfo, bl);
::decode(new_blacklist, p);
::decode(old_blacklist, p);
if (ev >= 6)
- ::decode(new_up_internal, p);
+ ::decode(new_up_cluster, p);
if (ev >= 7)
::decode(cluster_snapshot, p);
if (ev >= 8)
f->open_object_section("osd");
f->dump_int("osd", p->first);
f->dump_stream("public_addr") << p->second;
- f->dump_stream("cluster_addr") << new_up_internal.find(p->first)->second;
+ f->dump_stream("cluster_addr") << new_up_cluster.find(p->first)->second;
f->dump_stream("heartbeat_addr") << new_hb_up.find(p->first)->second;
f->close_section();
}
new entity_addr_t(inc.new_hb_up.find(i->first)->second));
osd_info[i->first].up_from = epoch;
}
- for (map<int32_t,entity_addr_t>::const_iterator i = inc.new_up_internal.begin();
- i != inc.new_up_internal.end();
+ for (map<int32_t,entity_addr_t>::const_iterator i = inc.new_up_cluster.begin();
+ i != inc.new_up_cluster.end();
++i)
osd_addrs->cluster_addr[i->first].reset(new entity_addr_t(i->second));
map<int64_t,string> new_pool_names;
set<int64_t> old_pools;
map<int32_t,entity_addr_t> new_up_client;
- map<int32_t,entity_addr_t> new_up_internal;
+ map<int32_t,entity_addr_t> new_up_cluster;
map<int32_t,uint8_t> new_state; // XORed onto previous state.
map<int32_t,uint32_t> new_weight;
map<pg_t,vector<int32_t> > new_pg_temp; // [] to remove