]> git.apps.os.sepia.ceph.com Git - ceph.git/commitdiff
crimson/osd/shard_services: Refactor OSDSingletonState::load_map
authorMatan Breizman <mbreizma@redhat.com>
Wed, 10 May 2023 13:54:17 +0000 (13:54 +0000)
committerMatan Breizman <mbreizma@redhat.com>
Tue, 20 Jun 2023 17:19:54 +0000 (17:19 +0000)
Added logs
If case reconstructed - epoch is unsigned.

Signed-off-by: Matan Breizman <mbreizma@redhat.com>
src/crimson/osd/shard_services.cc

index 6ec6b5cbcbeff94742faeda66780c11076b2be91..2d410937b7d3dd1926e844bb3d8c47b81215c5fb 100644 (file)
@@ -405,14 +405,14 @@ seastar::future<std::map<epoch_t, bufferlist>> OSDSingletonState::load_map_bls(
 seastar::future<std::unique_ptr<OSDMap>> OSDSingletonState::load_map(epoch_t e)
 {
   auto o = std::make_unique<OSDMap>();
-  if (e > 0) {
-    return load_map_bl(e).then([o=std::move(o)](bufferlist bl) mutable {
-      o->decode(bl);
-      return seastar::make_ready_future<std::unique_ptr<OSDMap>>(std::move(o));
-    });
-  } else {
+  logger().info("{} osdmap.{}", __func__, e);
+  if (e == 0) {
     return seastar::make_ready_future<std::unique_ptr<OSDMap>>(std::move(o));
   }
+  return load_map_bl(e).then([o=std::move(o)](bufferlist bl) mutable {
+    o->decode(bl);
+    return seastar::make_ready_future<std::unique_ptr<OSDMap>>(std::move(o));
+  });
 }
 
 seastar::future<> OSDSingletonState::store_maps(ceph::os::Transaction& t,