]> git.apps.os.sepia.ceph.com Git - ceph.git/commitdiff
osd/OSDMap: new_up_internal -> new_up_cluster
authorSage Weil <sage@inktank.com>
Wed, 22 May 2013 23:03:36 +0000 (16:03 -0700)
committerSage Weil <sage@inktank.com>
Wed, 22 May 2013 23:03:36 +0000 (16:03 -0700)
Signed-off-by: Sage Weil <sage@inktank.com>
src/mon/OSDMonitor.cc
src/osd/OSDMap.cc
src/osd/OSDMap.h

index 31aae22a4711d70f362008d73fbeb541dbb98d1b..aa9eff2819b246280cdfbb1f203d8ec83eedfa30 100644 (file)
@@ -248,7 +248,7 @@ bool OSDMonitor::thrash()
     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;
@@ -1126,7 +1126,7 @@ bool OSDMonitor::prepare_boot(MOSDBoot *m)
     // 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?
index 8e0474eb7818f0e8b5b135026d4dd2654a12b044..e5fc4144e5baee736e10b0f58321a95b158e685b 100644 (file)
@@ -323,7 +323,7 @@ void OSDMap::Incremental::encode(bufferlist& bl, uint64_t features) const
   ::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);
@@ -411,7 +411,7 @@ void OSDMap::Incremental::decode(bufferlist::iterator &p)
   ::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)
@@ -468,7 +468,7 @@ void OSDMap::Incremental::dump(Formatter *f) const
     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();
   }
@@ -876,8 +876,8 @@ int OSDMap::apply_incremental(const Incremental &inc)
        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));
 
index 6588382971fbef9f5ce67d02b27fc8e17f407d21..e961b11360d78bf50cd675c25c52c874784d32c7 100644 (file)
@@ -127,7 +127,7 @@ public:
     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