import quincy beta 17.1.0

[ceph.git] / ceph / src / crimson / os / seastore / collection_manager / collection_flat_node.cc

diff --git a/ceph/src/crimson/os/seastore/collection_manager/collection_flat_node.cc b/ceph/src/crimson/os/seastore/collection_manager/collection_flat_node.cc
new file mode 100644 (file)
index 0000000..6181582
--- /dev/null
+++ b/ceph/src/crimson/os/seastore/collection_manager/collection_flat_node.cc
@@ -0,0 +1,122 @@
+// -*- mode:C++; tab-width:8; c-basic-offset:2; indent-tabs-mode:t -*-
+// vim: ts=8 sw=2 smarttab
+
+#include "include/buffer.h"
+#include "osd/osd_types.h"
+#include "crimson/os/seastore/transaction_manager.h"
+#include "crimson/os/seastore/collection_manager/collection_flat_node.h"
+
+namespace {
+  seastar::logger& logger() {
+    return crimson::get_logger(ceph_subsys_seastore);
+  }
+}
+
+namespace crimson::os::seastore::collection_manager {
+
+void delta_t::replay(coll_map_t &l) const
+{
+  switch (op) {
+  case op_t::INSERT: {
+    l.insert(coll, bits);
+    break;
+  }
+  case op_t::UPDATE: {
+    l.update(coll, bits);
+    break;
+  }
+  case op_t::REMOVE: {
+    l.erase(coll);
+    break;
+  }
+  case op_t::INVALID: {
+    assert(0 == "impossible");
+    break;
+  }
+  __builtin_unreachable();
+  }
+}
+
+
+std::ostream &CollectionNode::print_detail_l(std::ostream &out) const
+{
+  return out;
+}
+
+CollectionNode::list_ret
+CollectionNode::list()
+{
+  read_to_local();
+  logger().debug("CollectionNode:{}, {}", __func__, *this);
+  CollectionManager::list_ret_bare list_result;
+  for (auto &[coll, bits] : decoded) {
+    list_result.emplace_back(coll, bits);
+  }
+  return list_ret(
+    interruptible::ready_future_marker{},
+    std::move(list_result));
+}
+
+CollectionNode::create_ret
+CollectionNode::create(coll_context_t cc, coll_t coll, unsigned bits)
+{
+  read_to_local();
+  logger().debug("CollectionNode:{}", __func__);
+  if (!is_pending()) {
+    auto mut = cc.tm.get_mutable_extent(cc.t, this)->cast<CollectionNode>();
+    return mut->create(cc, coll, bits);
+  }
+  logger().debug("CollectionNode::create {} {} {}", coll, bits, *this);
+  auto [iter, inserted] = decoded.insert(coll, bits);
+  assert(inserted);
+  if (encoded_sizeof((base_coll_map_t&)decoded) > get_bptr().length()) {
+    decoded.erase(iter);
+    return create_ret(
+      interruptible::ready_future_marker{},
+      create_result_t::OVERFLOW);
+  } else {
+    if (auto buffer = maybe_get_delta_buffer(); buffer) {
+      buffer->insert(coll, bits);
+    }
+    copy_to_node();
+    return create_ret(
+      interruptible::ready_future_marker{},
+      create_result_t::SUCCESS);
+  }
+}
+
+CollectionNode::update_ret
+CollectionNode::update(coll_context_t cc, coll_t coll, unsigned bits)
+{
+  read_to_local();
+  logger().debug("CollectionNode:{}", __func__);
+  if (!is_pending()) {
+    auto mut = cc.tm.get_mutable_extent(cc.t, this)->cast<CollectionNode>();
+    return mut->update(cc, coll, bits);
+  }
+  if (auto buffer = maybe_get_delta_buffer(); buffer) {
+    buffer->update(coll, bits);
+  }
+  decoded.update(coll, bits);
+  copy_to_node();
+  return seastar::now();
+}
+
+CollectionNode::remove_ret
+CollectionNode::remove(coll_context_t cc, coll_t coll)
+{
+  read_to_local();
+  logger().debug("CollectionNode:{}", __func__);
+  if (!is_pending()) {
+    auto mut = cc.tm.get_mutable_extent(cc.t, this)->cast<CollectionNode>();
+    return mut->remove(cc, coll);
+  }
+  if (auto buffer = maybe_get_delta_buffer(); buffer) {
+    buffer->remove(coll);
+  }
+  decoded.remove(coll);
+  copy_to_node();
+  return seastar::now();
+}
+
+}