1 files changed, 71 insertions, 0 deletions
diff --git a/src/crimson/os/seastore/onode_manager/simple-fltree/onode_block.cc b/src/crimson/os/seastore/onode_manager/simple-fltree/onode_block.cc
new file mode 100644
index 000000000..b05ea76a3
--- /dev/null
+++ b/src/crimson/os/seastore/onode_manager/simple-fltree/onode_block.cc
@@ -0,0 +1,71 @@
+// -*- mode:C++; tab-width:8; c-basic-offset:2; indent-tabs-mode:t -*-
+// vim: ts=8 sw=2 smarttab
+
+#include "onode_block.h"
+
+namespace crimson::os::seastore {
+
+ceph::bufferlist OnodeBlock::get_delta()
+{
+  bufferlist bl;
+  assert(deltas.size() <= std::numeric_limits<uint8_t>::max());
+  uint8_t n_deltas = deltas.size();
+  ceph::encode(n_deltas, bl);
+  for (auto& delta : deltas) {
+    delta->encode(bl);
+  }
+  return bl;
+}
+
+void OnodeBlock::logical_on_delta_write()
+{
+  // journal submitted to disk, now update the memory
+  apply_pending_changes(true);
+}
+
+void OnodeBlock::apply_delta(const ceph::bufferlist &bl)
+{
+  assert(deltas.empty());
+
+  auto p = bl.cbegin();
+  uint8_t n_deltas = 0;
+  ceph::decode(n_deltas, p);
+  for (uint8_t i = 0; i < n_deltas; i++) {
+    delta_t delta;
+    delta.decode(p);
+    mutate(std::move(delta));
+  }
+  apply_pending_changes(true);
+}
+
+void OnodeBlock::mutate(delta_t&& d)
+{
+  if (is_initial_pending()) {
+    char* const p = get_bptr().c_str();
+    mutate_func(p, d);
+  }
+  deltas.push_back(std::make_unique<delta_t>(std::move(d)));
+}
+
+void OnodeBlock::apply_pending_changes(bool do_cleanup)
+{
+  if (!is_mutation_pending()) {
+    return;
+  }
+  if (share_buffer) {
+    // do a deep copy so i can change my own copy
+    get_bptr() = ceph::bufferptr{get_bptr().c_str(),
+				 get_bptr().length()};
+    share_buffer = false;
+  }
+  assert(mutate_func);
+  char* const p = get_bptr().c_str();
+  for (auto& delta : deltas) {
+    mutate_func(p, *delta);
+    if (do_cleanup) {
+      delta.reset();
+    }
+  }
+}
+
+}