2 files changed, 117 insertions, 0 deletions
diff --git a/kernel/devices/src/storage/ram_disk/ram_disk_controller.cpp b/kernel/devices/src/storage/ram_disk/ram_disk_controller.cpp
new file mode 100644
index 0000000..09f1c85
--- /dev/null
+++ b/kernel/devices/src/storage/ram_disk/ram_disk_controller.cpp
@@ -0,0 +1,48 @@
+#include "devices/storage/ram_disk/ram_disk_controller.hpp"
+
+#include "kapi/boot_module/boot_module_registry.hpp"
+
+#include "devices/block_device.hpp"
+#include "devices/storage/ram_disk/ram_disk_device.hpp"
+
+#include <kstd/print>
+
+#include <algorithm>
+#include <array>
+#include <cstddef>
+
+namespace devices::storage::ram_disk
+{
+  ram_disk_controller::ram_disk_controller(kapi::boot_modules::boot_module_registry const * registry)
+      : m_boot_module_registry(registry)
+  {}
+
+  auto ram_disk_controller::probe() -> void
+  {
+    size_t current_device_index = 0;
+
+    std::ranges::for_each(*m_boot_module_registry, [this, &current_device_index](auto const & module) {
+      auto const minor = current_device_index++ * m_minors_per_device;
+
+      // TODO BA-FS26 use push_back from kstd::vector when available
+      m_devices.at(0) = ram_disk_device{module, m_major, minor};
+    });
+  }
+
+  auto ram_disk_controller::device_by_major_minor(size_t major, size_t minor) -> block_device *
+  {
+    auto it = std::ranges::find_if(
+        m_devices, [major, minor](auto const & device) { return device.major() == major && device.minor() == minor; });
+
+    if (it != m_devices.end())
+    {
+      return &(*it);
+    }
+    return nullptr;
+  }
+
+  auto ram_disk_controller::devices_count() -> size_t
+  {
+    return m_devices.size();
+  }
+}  // namespace devices::storage::ram_disk
+\ No newline at end of file
diff --git a/kernel/devices/src/storage/ram_disk/ram_disk_device.cpp b/kernel/devices/src/storage/ram_disk/ram_disk_device.cpp
new file mode 100644
index 0000000..3bd3967
--- /dev/null
+++ b/kernel/devices/src/storage/ram_disk/ram_disk_device.cpp
@@ -0,0 +1,69 @@
+#include "devices/storage/ram_disk/ram_disk_device.hpp"
+
+#include "kapi/boot_module/boot_module.hpp"
+#include "kapi/system.hpp"
+
+#include "devices/block_device.hpp"
+
+#include <kstd/cstring>
+
+#include <cstddef>
+
+namespace devices::storage::ram_disk
+{
+  namespace
+  {
+    constexpr size_t RAM_DISK_BLOCK_SIZE = 512uz;  // TODO BA-FS26 really correct / good??
+  }  // namespace
+
+  ram_disk_device::ram_disk_device()  // TODO BA-FS26 remove when kstd::vector is available
+      : block_device(0, 0, RAM_DISK_BLOCK_SIZE)
+  {}
+
+  ram_disk_device::ram_disk_device(kapi::boot_modules::boot_module const & module, size_t major, size_t minor)
+      : block_device(major, minor, RAM_DISK_BLOCK_SIZE)
+      , m_boot_module(module)
+  {}
+
+  auto ram_disk_device::read_block(size_t block_index, void * buffer) const -> void
+  {
+    if (buffer == nullptr)
+    {
+      kapi::system::panic("[RAM DISK DEVICE] read_block called with null buffer.");
+    }
+
+    auto const info = calculate_transfer(block_index);
+
+    if (info.to_transfer > 0)
+    {
+      auto const src = static_cast<std::byte const *>(m_boot_module.start_address) + info.offset;
+      kstd::libc::memcpy(buffer, src, info.to_transfer);
+    }
+
+    if (info.remainder > 0)
+    {
+      kstd::libc::memset(static_cast<std::byte *>(buffer) + info.to_transfer, 0, info.remainder);
+    }
+  }
+
+  auto ram_disk_device::write_block(size_t block_index, void const * buffer) -> void
+  {
+    if (buffer == nullptr)
+    {
+      kapi::system::panic("[RAM DISK DEVICE] write_block called with null buffer.");
+    }
+
+    auto const info = calculate_transfer(block_index);
+
+    if (info.to_transfer > 0)
+    {
+      auto const dest = static_cast<std::byte *>(m_boot_module.start_address) + info.offset;
+      kstd::libc::memcpy(dest, buffer, info.to_transfer);
+    }
+  }
+
+  auto ram_disk_device::size() const -> size_t
+  {
+    return m_boot_module.size;
+  }
+}  // namespace devices::storage::ram_disk
+\ No newline at end of file