1 files changed, 88 insertions, 0 deletions
diff --git a/src/crimson/os/seastore/onode_manager/staged-fltree/node_extent_manager/seastore.cc b/src/crimson/os/seastore/onode_manager/staged-fltree/node_extent_manager/seastore.cc
new file mode 100644
index 000000000..8d88485bf
--- /dev/null
+++ b/src/crimson/os/seastore/onode_manager/staged-fltree/node_extent_manager/seastore.cc
@@ -0,0 +1,88 @@
+// -*- mode:C++; tab-width:8; c-basic-offset:2; indent-tabs-mode:t -*-
+// vim: ts=8 sw=2 smarttab
+
+#include "seastore.h"
+
+#include "crimson/os/seastore/onode_manager/staged-fltree/node_extent_accessor.h"
+#include "crimson/os/seastore/onode_manager/staged-fltree/stages/node_stage_layout.h"
+
+namespace {
+
+seastar::logger& logger() {
+  return crimson::get_logger(ceph_subsys_filestore);
+}
+
+}
+
+namespace crimson::os::seastore::onode {
+
+static DeltaRecorderURef create_recorder(
+    node_type_t node_type, field_type_t field_type) {
+  if (node_type == node_type_t::LEAF) {
+    if (field_type == field_type_t::N0) {
+      return DeltaRecorderT<node_fields_0_t, node_type_t::LEAF>::create();
+    } else if (field_type == field_type_t::N1) {
+      return DeltaRecorderT<node_fields_1_t, node_type_t::LEAF>::create();
+    } else if (field_type == field_type_t::N2) {
+      return DeltaRecorderT<node_fields_2_t, node_type_t::LEAF>::create();
+    } else if (field_type == field_type_t::N3) {
+      return DeltaRecorderT<leaf_fields_3_t, node_type_t::LEAF>::create();
+    } else {
+      ceph_abort("impossible path");
+    }
+  } else if (node_type == node_type_t::INTERNAL) {
+    if (field_type == field_type_t::N0) {
+      return DeltaRecorderT<node_fields_0_t, node_type_t::INTERNAL>::create();
+    } else if (field_type == field_type_t::N1) {
+      return DeltaRecorderT<node_fields_1_t, node_type_t::INTERNAL>::create();
+    } else if (field_type == field_type_t::N2) {
+      return DeltaRecorderT<node_fields_2_t, node_type_t::INTERNAL>::create();
+    } else if (field_type == field_type_t::N3) {
+      return DeltaRecorderT<internal_fields_3_t, node_type_t::INTERNAL>::create();
+    } else {
+      ceph_abort("impossible path");
+    }
+  } else {
+    ceph_abort("impossible path");
+  }
+}
+
+void SeastoreSuper::write_root_laddr(context_t c, laddr_t addr) {
+  logger().info("OTree::Seastore: update root {:#x} ...", addr);
+  root_addr = addr;
+  auto nm = static_cast<SeastoreNodeExtentManager*>(&c.nm);
+  nm->get_tm().write_onode_root(c.t, addr);
+}
+
+NodeExtentRef SeastoreNodeExtent::mutate(
+    context_t c, DeltaRecorderURef&& _recorder) {
+  logger().debug("OTree::Seastore: mutate {:#x} ...", get_laddr());
+  auto nm = static_cast<SeastoreNodeExtentManager*>(&c.nm);
+  auto extent = nm->get_tm().get_mutable_extent(c.t, this);
+  auto ret = extent->cast<SeastoreNodeExtent>();
+  assert(!ret->recorder || ret->recorder->is_empty());
+  ret->recorder = std::move(_recorder);
+  return ret;
+}
+
+void SeastoreNodeExtent::apply_delta(const ceph::bufferlist& bl) {
+  logger().debug("OTree::Seastore: replay {:#x} ...", get_laddr());
+  if (!recorder) {
+    auto [node_type, field_type] = get_types();
+    recorder = create_recorder(node_type, field_type);
+  } else {
+#ifndef NDEBUG
+    auto [node_type, field_type] = get_types();
+    assert(recorder->node_type() == node_type);
+    assert(recorder->field_type() == field_type);
+#endif
+  }
+  assert(is_clean());
+  auto node = do_get_mutable();
+  auto p = bl.cbegin();
+  while (p != bl.end()) {
+    recorder->apply_delta(p, node);
+  }
+}
+
+}