From: Sage Weil <sage@redhat.com>
Date: Tue, 6 Feb 2018 17:27:36 +0000 (-0600)
Subject: osd: rename OSDShard waiting_for_pg_osdmap -> osdmap
X-Git-Tag: v13.1.0~390^2~79
X-Git-Url: http://git-server-git.apps.pok.os.sepia.ceph.com/?a=commitdiff_plain;h=eed90d4a8f3a1be2652736740f2891a856cafb86;p=ceph.git

osd: rename OSDShard waiting_for_pg_osdmap -> osdmap

Signed-off-by: Sage Weil <sage@redhat.com>
---

diff --git a/src/osd/OSD.cc b/src/osd/OSD.cc
index 67236a4fb23..623be6c24d2 100644
--- a/src/osd/OSD.cc
+++ b/src/osd/OSD.cc
@@ -9508,7 +9508,7 @@ void OSD::ShardedOpWQ::prune_or_wake_pg_waiters(OSDMapRef osdmap, int whoami)
   bool queued = false;
   for (auto sdata : osd->shards) {
     Mutex::Locker l(sdata->sdata_op_ordering_lock);
-    sdata->waiting_for_pg_osdmap = osdmap;
+    sdata->osdmap = osdmap;
     auto p = sdata->pg_slots.begin();
     while (p != sdata->pg_slots.end()) {
       OSDShard::pg_slot& slot = p->second;
@@ -9589,7 +9589,7 @@ void OSD::ShardedOpWQ::clear_pg_slots()
   for (auto sdata : osd->shards) {
     Mutex::Locker l(sdata->sdata_op_ordering_lock);
     sdata->pg_slots.clear();
-    sdata->waiting_for_pg_osdmap.reset();
+    sdata->osdmap.reset();
     // don't bother with reserved pushes; we are shutting down
   }
 }
@@ -9761,7 +9761,7 @@ void OSD::ShardedOpWQ::_process(uint32_t thread_index, heartbeat_handle_d *hb)
 
   while (!pg) {
     // should this pg shard exist on this osd in this (or a later) epoch?
-    OSDMapRef osdmap = sdata->waiting_for_pg_osdmap;
+    OSDMapRef osdmap = sdata->osdmap;
     const PGCreateInfo *create_info = qi.creates_pg();
     if (slot.waiting_for_split) {
       dout(20) << __func__ << " " << token
@@ -9820,7 +9820,7 @@ void OSD::ShardedOpWQ::_process(uint32_t thread_index, heartbeat_handle_d *hb)
 	Session *session = static_cast<Session *>(
 	  (*_op)->get_req()->get_connection()->get_priv());
 	if (session) {
-	  osd->maybe_share_map(session, *_op, sdata->waiting_for_pg_osdmap);
+	  osd->maybe_share_map(session, *_op, sdata->osdmap);
 	  session->put();
 	}
       }
@@ -9835,7 +9835,7 @@ void OSD::ShardedOpWQ::_process(uint32_t thread_index, heartbeat_handle_d *hb)
     return;
   }
   if (qi.is_peering()) {
-    OSDMapRef osdmap = sdata->waiting_for_pg_osdmap;
+    OSDMapRef osdmap = sdata->osdmap;
     if (qi.get_map_epoch() > osdmap->get_epoch()) {
       _add_slot_waiter(token, slot, std::move(qi));
       sdata->sdata_op_ordering_lock.Unlock();
diff --git a/src/osd/OSD.h b/src/osd/OSD.h
index 55f64dee1d5..6e526729b74 100644
--- a/src/osd/OSD.h
+++ b/src/osd/OSD.h
@@ -1120,7 +1120,7 @@ struct OSDShard {
 
   Mutex sdata_op_ordering_lock;   ///< protects all members below
 
-  OSDMapRef waiting_for_pg_osdmap;
+  OSDMapRef osdmap;
 
   struct pg_slot {
     PGRef pg;                     ///< cached pg reference [optional]