/* * Copyright (c) 2021, the SerenityOS developers. * * SPDX-License-Identifier: BSD-2-Clause */ #include #include #include #include #include #include namespace Kernel { NonnullRefPtr RamdiskDevice::create(const RamdiskController& controller, NonnullOwnPtr&& region, int major, int minor) { // FIXME: Try to not hardcode a maximum of 16 partitions per drive! size_t drive_index = minor / 16; // FIXME: We need a way of formatting strings with KString! auto device_name = String::formatted("ramdisk{}", drive_index); auto device_name_kstring = KString::must_create(device_name.view()); auto device_or_error = DeviceManagement::try_create_device(controller, move(region), major, minor, move(device_name_kstring)); // FIXME: Find a way to propagate errors VERIFY(!device_or_error.is_error()); return device_or_error.release_value(); } RamdiskDevice::RamdiskDevice(const RamdiskController&, NonnullOwnPtr&& region, int major, int minor, NonnullOwnPtr device_name) : StorageDevice(major, minor, 512, region->size() / 512, move(device_name)) , m_region(move(region)) { dmesgln("Ramdisk: Device #{} @ {}, Capacity={}", minor, m_region->vaddr(), max_addressable_block() * 512); } RamdiskDevice::~RamdiskDevice() { } StringView RamdiskDevice::class_name() const { return "RamdiskDevice"sv; } void RamdiskDevice::start_request(AsyncBlockDeviceRequest& request) { MutexLocker locker(m_lock); u8* base = m_region->vaddr().as_ptr(); size_t size = m_region->size(); u8* offset = base + request.block_index() * 512; size_t length = request.block_count() * 512; if ((offset + length > base + size) || (offset + length < base)) { request.complete(AsyncDeviceRequest::Failure); } else { ErrorOr result; if (request.request_type() == AsyncBlockDeviceRequest::Read) { result = request.buffer().write(offset, length); } else { result = request.buffer().read(offset, length); } request.complete(!result.is_error() ? AsyncDeviceRequest::Success : AsyncDeviceRequest::MemoryFault); } } }