]> git-server-git.apps.pok.os.sepia.ceph.com Git - ceph.git/commitdiff
osd: inline advance_map()
authorSage Weil <sage@redhat.com>
Tue, 2 Feb 2016 15:40:34 +0000 (10:40 -0500)
committerSage Weil <sage@redhat.com>
Tue, 8 Mar 2016 16:19:26 +0000 (11:19 -0500)
This has shrunk over time and is short enough it's easier to
follow the code with it inline.

Signed-off-by: Sage Weil <sage@redhat.com>
src/osd/OSD.cc
src/osd/OSD.h

index bc636a4d6a8381d1d41e46d13c0f6c1c09a1bdba..78e581e9395ceca386667af741f2be54b5c378f3 100644 (file)
@@ -6646,8 +6646,22 @@ void OSD::handle_osd_map(MOSDMap *m)
     osdmap = newmap;
 
     superblock.current_epoch = cur;
-    advance_map();
     had_map_since = ceph_clock_now(cct);
+
+    epoch_t up_epoch;
+    epoch_t boot_epoch;
+    service.retrieve_epochs(&boot_epoch, &up_epoch, NULL);
+    if (!up_epoch &&
+       osdmap->is_up(whoami) &&
+       osdmap->get_inst(whoami) == client_messenger->get_myinst()) {
+      up_epoch = osdmap->get_epoch();
+      dout(10) << "up_epoch is " << up_epoch << dendl;
+      if (!boot_epoch) {
+       boot_epoch = osdmap->get_epoch();
+       dout(10) << "boot_epoch is " << boot_epoch << dendl;
+      }
+      service.set_epochs(&boot_epoch, &up_epoch, NULL);
+    }
   }
 
   epoch_t _bind_epoch = service.get_bind_epoch();
@@ -6948,32 +6962,6 @@ bool OSD::advance_pg(
   return true;
 }
 
-/**
- * update service map; check pg creations
- */
-void OSD::advance_map()
-{
-  assert(osd_lock.is_locked());
-
-  dout(7) << "advance_map epoch " << osdmap->get_epoch()
-          << dendl;
-
-  epoch_t up_epoch;
-  epoch_t boot_epoch;
-  service.retrieve_epochs(&boot_epoch, &up_epoch, NULL);
-  if (!up_epoch &&
-      osdmap->is_up(whoami) &&
-      osdmap->get_inst(whoami) == client_messenger->get_myinst()) {
-    up_epoch = osdmap->get_epoch();
-    dout(10) << "up_epoch is " << up_epoch << dendl;
-    if (!boot_epoch) {
-      boot_epoch = osdmap->get_epoch();
-      dout(10) << "boot_epoch is " << boot_epoch << dendl;
-    }
-    service.set_epochs(&boot_epoch, &up_epoch, NULL);
-  }
-}
-
 void OSD::consume_map()
 {
   assert(osd_lock.is_locked());
index 57848540204f1a92f4734c15cb1e918b6b3c6755..339f13886d37a711282ca1a770ec75b926c70a33 100644 (file)
@@ -1864,7 +1864,6 @@ private:
     PG::RecoveryCtx *rctx,
     set<boost::intrusive_ptr<PG> > *split_pgs
   );
-  void advance_map();
   void consume_map();
   void activate_map();