import quincy beta 17.1.0

[ceph.git] / ceph / src / crimson / os / seastore / segment_manager.cc

diff --git a/ceph/src/crimson/os/seastore/segment_manager.cc b/ceph/src/crimson/os/seastore/segment_manager.cc
new file mode 100644 (file)
index 0000000..2ed7462
--- /dev/null
+++ b/ceph/src/crimson/os/seastore/segment_manager.cc
@@ -0,0 +1,125 @@
+// -*- mode:C++; tab-width:8; c-basic-offset:2; indent-tabs-mode:t -*-
+// vim: ts=8 sw=2 smarttab
+
+#include "crimson/os/seastore/segment_manager.h"
+#include "crimson/os/seastore/segment_manager/block.h"
+#include "crimson/common/log.h"
+
+
+#ifdef HAVE_ZNS
+#include "crimson/os/seastore/segment_manager/zns.h"
+#endif
+
+namespace{
+
+#ifdef HAVE_ZNS
+seastar::logger &logger(){
+  return crimson::get_logger(ceph_subsys_seastore_device);
+}
+#endif
+
+}
+
+namespace crimson::os::seastore {
+
+std::ostream& operator<<(std::ostream& out, const device_spec_t& ds)
+{
+  return out << "device_spec("
+             << "magic=" << ds.magic
+             << ", device_type=" << ds.dtype
+             << ", device_id=" << std::to_string(ds.id)
+             << ")";
+}
+
+std::ostream& operator<<(std::ostream& out, const block_sm_superblock_t& sb)
+{
+  out << "superblock("
+      << "size=" << sb.size
+      << ", segment_size=" << sb.segment_size
+      << ", block_size=" << sb.block_size
+      << ", segments=" << sb.segments
+      << ", tracker_offset=" << sb.tracker_offset
+      << ", first_segment_offset=" << sb.first_segment_offset
+      << ", major_dev=" << sb.major_dev
+      << ", magic=" << sb.magic
+      << ", device_type=" << sb.dtype
+      << ", device_id=" << std::to_string(sb.device_id)
+      << ", meta=" << sb.meta
+      << ", secondary(";
+  for (const auto& [k, v] : sb.secondary_devices) {
+    out << std::to_string(k) << ": " << v;
+  }
+  return out << "))";
+}
+
+std::ostream& operator<<(std::ostream& out, const segment_manager_config_t& conf)
+{
+  out << "sm_config_t("
+      << "major_dev=" << conf.major_dev
+      << ", magic=" << conf.magic
+      << ", device_type=" << conf.dtype
+      << ", device_id=" << std::to_string(conf.device_id)
+      << ", meta=" << conf.meta
+      << ", secondary(";
+  for (const auto& [k, v] : conf.secondary_devices) {
+    out << std::to_string(k) << ": " << v;
+  }
+  return out << "))";
+}
+
+std::ostream& operator<<(std::ostream &out, Segment::segment_state_t s)
+{
+  using state_t = Segment::segment_state_t;
+  switch (s) {
+  case state_t::EMPTY:
+    return out << "EMPTY";
+  case state_t::OPEN:
+    return out << "OPEN";
+  case state_t::CLOSED:
+    return out << "CLOSED";
+  default:
+    return out << "INVALID_SEGMENT_STATE!";
+  }
+}
+
+seastar::future<crimson::os::seastore::SegmentManagerRef>
+SegmentManager::get_segment_manager(
+  const std::string &device)
+{
+#ifdef HAVE_ZNS
+  return seastar::do_with(
+    static_cast<size_t>(0),
+    [&](auto &nr_zones) {
+      return seastar::open_file_dma(
+       device + "/block",
+       seastar::open_flags::rw
+      ).then([&](auto file) {
+       return seastar::do_with(
+         file,
+         [=, &nr_zones](auto &f) -> seastar::future<int> {
+           ceph_assert(f);
+           return f.ioctl(BLKGETNRZONES, (void *)&nr_zones);
+         });
+      }).then([&](auto ret) -> crimson::os::seastore::SegmentManagerRef {
+       crimson::os::seastore::SegmentManagerRef sm;
+       logger().error("NR_ZONES: {}", nr_zones);
+       if (nr_zones != 0) {
+         return std::make_unique<
+           segment_manager::zns::ZNSSegmentManager
+           >(device + "/block");
+       } else {
+         return std::make_unique<
+           segment_manager::block::BlockSegmentManager
+           >(device + "/block");
+       }
+      });
+    });
+#else
+  return seastar::make_ready_future<crimson::os::seastore::SegmentManagerRef>(
+    std::make_unique<
+      segment_manager::block::BlockSegmentManager
+    >(device + "/block"));
+#endif
+}
+
+}