Merge pull request #5 from amlel-el-mahrouss/dev

pr/ahci: important patches.

9 files changed, 244 insertions, 137 deletions

diff --git a/dev/kernel/HALKit/AMD64/HalPagingMgrAMD64.cc b/dev/kernel/HALKit/AMD64/HalPagingMgrAMD64.cc
index ac80f48e..5819f1d9 100644
--- a/dev/kernel/HALKit/AMD64/HalPagingMgrAMD64.cc
+++ b/dev/kernel/HALKit/AMD64/HalPagingMgrAMD64.cc
@@ -91,7 +91,7 @@ namespace Kernel::HAL
 		// Lastly, grab the pte entry.
 		NE_PDE* pde_struct = reinterpret_cast<NE_PDE*>(pt_base);
 
-		return pde_struct->fEntries[pt_entry]->PhysicalAddress;
+		return pde_struct->fEntries[pt_index]->PhysicalAddress;
 	}
 
 	/***********************************************************************************/
@@ -106,7 +106,7 @@ namespace Kernel::HAL
 		kout << (pte->User ? "User" : "Not User") << kendl;
 	}
 
-	STATIC Int32 mmi_map_page_table_entry(UInt32 physical_address, UInt32 flags, NE_PTE* pt_entry, NE_PDE* pd_entry);
+	STATIC Int32 mmi_map_page_table_entry(UIntPtr virtual_address, UInt32 physical_address, UInt32 flags, NE_PTE* pt_entry, NE_PDE* pd_entry);
 
 	/***********************************************************************************/
 	/// @brief Maps or allocates a page from virtual_address.
@@ -154,14 +154,14 @@ namespace Kernel::HAL
 		// Lastly, grab the pte entry.
 		NE_PDE* pde_struct = reinterpret_cast<NE_PDE*>(pt_base);
 
-		return mmi_map_page_table_entry((UInt32)(UInt64)physical_address, flags, pde_struct->fEntries[pt_entry], pde_struct);
+		return mmi_map_page_table_entry(reinterpret_cast<UIntPtr>(virtual_address), (UInt32)(UInt64)physical_address, flags, pde_struct->fEntries[pt_entry], pde_struct);
 	}
 
 	/***********************************************************************************/
 	/// @brief Maps flags for a specific pte.
 	/// @internal Internal function.
 	/***********************************************************************************/
-	STATIC Int32 mmi_map_page_table_entry(UInt32 physical_address, UInt32 flags, NE_PTE* pt_entry, NE_PDE* pd_entry)
+	STATIC Int32 mmi_map_page_table_entry(UIntPtr virtual_address, UInt32 physical_address, UInt32 flags, NE_PTE* pt_entry, NE_PDE* pd_entry)
 	{
 		if (!pt_entry)
 			return 1;
@@ -185,7 +185,7 @@ namespace Kernel::HAL
 
 		pt_entry->PhysicalAddress = physical_address;
 
-		hal_invl_tlb(reinterpret_cast<VoidPtr>(pt_entry));
+		hal_invl_tlb(reinterpret_cast<VoidPtr>(virtual_address));
 
 		mmi_page_status(pt_entry);
 
diff --git a/dev/kernel/HALKit/AMD64/PCI/Device.cc b/dev/kernel/HALKit/AMD64/PCI/Device.cc
index 68bf64ea..9c27cb10 100644
--- a/dev/kernel/HALKit/AMD64/PCI/Device.cc
+++ b/dev/kernel/HALKit/AMD64/PCI/Device.cc
@@ -99,7 +99,7 @@ namespace Kernel::PCI
 
 	UShort Device::InterfaceId()
 	{
-		return (UShort)(NE_PCIReadRaw(0x0, fBus, fDevice, fFunction) >> 16);
+		return (UShort)(NE_PCIReadRaw(0x09, fBus, fDevice, fFunction) >> 16);
 	}
 
 	UChar Device::Class()
@@ -122,25 +122,24 @@ namespace Kernel::PCI
 		return (UChar)(NE_PCIReadRaw(0xC, fBus, fDevice, fFunction) >> 16);
 	}
 
-	void Device::EnableMmio(UInt32 bar_in)
+	void Device::EnableMmio()
 	{
-		UInt32 enable = Read(bar_in, sizeof(UInt32));
-		enable |= (1 << 1);
+		UInt32 command = Read(0x04, sizeof(UInt32));
+		command |= (1 << 1); // Memory Space Enable (bit 1)
 
-		Write(bar_in, enable, sizeof(UInt32));
+		Write(0x04, command, sizeof(UInt32));
 	}
 
-	void Device::BecomeBusMaster(UInt32 bar_in)
+	void Device::BecomeBusMaster()
 	{
-		UInt32 enable = Read(bar_in, sizeof(UInt32));
-		enable |= (1 << 2);
-
-		Write(bar_in, enable, sizeof(UInt32));
+		UInt32 command = Read(0x04, sizeof(UInt32));
+		command |= (1 << 2); // Bus Master Enable (bit 2)
+		Write(0x04, command, sizeof(UInt32));
 	}
 
 	UIntPtr Device::Bar(UInt32 bar_in)
 	{
-		UInt32 bar = NE_PCIReadRaw(bar_in & ~0x03, fBus, fDevice, fFunction);
+		UInt32 bar = NE_PCIReadRaw(bar_in, fBus, fDevice, fFunction);
 
 		if (bar & PCI_BAR_IO)
 			return static_cast<UIntPtr>(bar & ~0x03);
@@ -156,16 +155,12 @@ namespace Kernel::PCI
 
 	UShort Device::Vendor()
 	{
-		UShort vendor = VendorId();
-
-		if (vendor != (UShort)PciConfigKind::Invalid)
-			fDevice = (UShort)Read(0x0, sizeof(UShort));
-
-		return fDevice;
+		UShort vendor = this->VendorId();
+		return vendor;
 	}
 
 	Device::operator bool()
 	{
-		return VendorId() != (UShort)PciConfigKind::Invalid;
+		return this->VendorId() != (UShort)PciConfigKind::Invalid;
 	}
 } // namespace Kernel::PCI
diff --git a/dev/kernel/HALKit/AMD64/Storage/AHCI+Generic.cc b/dev/kernel/HALKit/AMD64/Storage/AHCI+Generic.cc
index e5f10db3..2a360e60 100644
--- a/dev/kernel/HALKit/AMD64/Storage/AHCI+Generic.cc
+++ b/dev/kernel/HALKit/AMD64/Storage/AHCI+Generic.cc
@@ -7,7 +7,7 @@
 /**
  * @file AHCI+Generic.cc
  * @author Amlal El Mahrouss (amlal@nekernel.org)
- * @brief AHCI driver.
+ * @brief AHCI Generic driver.
  * @version 0.1
  * @date 2024-02-02
  *
@@ -15,6 +15,7 @@
  *
  */
 
+#include "NewKit/Defines.h"
 #include <KernelKit/DeviceMgr.h>
 #include <KernelKit/DriveMgr.h>
 #include <KernelKit/ProcessScheduler.h>
@@ -56,7 +57,7 @@ STATIC PCI::Device kSATADev;
 STATIC HbaMemRef   kSATAHba;
 STATIC Lba		   kSATASectorCount		 = 0UL;
 STATIC UInt16	   kSATAIndex			 = 0U;
-STATIC Char		   kCurrentDiskModel[50] = {"UNKNOWN AHCI DRIVE"};
+STATIC Char		   kCurrentDiskModel[50] = {"GENERIC SATA"};
 STATIC UInt16	   kSATAPortsImplemented = 0U;
 
 template <BOOL Write, BOOL CommandOrCTRL, BOOL Identify>
@@ -74,11 +75,7 @@ STATIC Void drv_compute_disk_ahci() noexcept
 	const UInt16 kSzIdent = kib_cast(1);
 
 	/// Push it to the stack
-	static UInt8 identify_data[kSzIdent] ATTRIBUTE(aligned(4096)) = {0};
-
-	HAL::mm_map_page((void*)mib_cast(1), (void*)mib_cast(1), HAL::kMMFlagsWr);
-
-	rt_set_memory(identify_data, 0, kSzIdent);
+	UInt8* identify_data ATTRIBUTE(aligned(4096)) = new UInt8[kSzIdent];
 
 	/// Send AHCI command for identification.
 	drv_std_input_output_ahci<NO, YES, YES>(0, identify_data, kAHCISectorSize, kSzIdent);
@@ -87,19 +84,13 @@ STATIC Void drv_compute_disk_ahci() noexcept
 
 	UInt64 lba48_sectors = 0;
 	lba48_sectors |= (UInt64)identify_data[100];
-    lba48_sectors |= (UInt64)identify_data[101] << 16;
-    lba48_sectors |= (UInt64)identify_data[102] << 32;
+	lba48_sectors |= (UInt64)identify_data[101] << 16;
+	lba48_sectors |= (UInt64)identify_data[102] << 32;
 
 	if (lba48_sectors == 0)
 		kSATASectorCount = (identify_data[61] << 16) | identify_data[60];
 	else
 		kSATASectorCount = lba48_sectors;
-
-	/// Show what we got.
-	
-	kout << "Disk Model: " << kCurrentDiskModel << kendl;
-	kout << "Disk Size: " << number(drv_get_size()) << kendl;
-	kout << "Disk Sector Count: " << number(kSATASectorCount) << kendl;
 }
 
 /// @brief Finds a command slot for a HBA port.
@@ -152,7 +143,7 @@ STATIC Void drv_std_input_output_ahci(UInt64 lba, UInt8* buffer, SizeT sector_sz
 
 	MUST_PASS(command_header);
 
-	constexpr const UInt32 kMaxPRDSize = mib_cast(4);
+	constexpr const UInt32 kMaxPRDSize = kib_cast(4);
 
 	command_header->Cfl	  = sizeof(FisRegH2D) / sizeof(UInt32);
 	command_header->Write = Write;
@@ -172,6 +163,9 @@ STATIC Void drv_std_input_output_ahci(UInt64 lba, UInt8* buffer, SizeT sector_sz
 	{
 		UInt32 chunk = (bytes_remaining > kMaxPRDSize) ? kMaxPRDSize : bytes_remaining;
 
+		if (chunk == 0)
+			break;
+
 		command_table->Prdt[i].Dba	= (UInt32)(buffer_phys & 0xFFFFFFFF);
 		command_table->Prdt[i].Dbau = (UInt32)(buffer_phys >> 32);
 		command_table->Prdt[i].Dbc	= chunk - 1;
@@ -181,7 +175,7 @@ STATIC Void drv_std_input_output_ahci(UInt64 lba, UInt8* buffer, SizeT sector_sz
 		bytes_remaining -= chunk;
 	}
 
-	volatile FisRegH2D* h2d_fis = (volatile FisRegH2D*)(&command_table->Cfis);
+	volatile FisRegH2D* h2d_fis = (volatile FisRegH2D*)(&command_table->Cfis[0]);
 
 	rt_set_memory((FisRegH2D*)h2d_fis, 0, sizeof(FisRegH2D));
 
@@ -275,7 +269,8 @@ STATIC Void ahci_enable_and_probe()
 
 	// Relocate Command List Base.
 
-	constexpr UIntPtr const kAHCIBaseAddress = mib_cast(4);
+	auto const addr				= mm_new_heap(kib_cast(64), YES, NO, 0);
+	auto	   kAHCIBaseAddress = (UIntPtr)addr;
 
 	port->Clb  = kAHCIBaseAddress + (kSATAIndex << 10);
 	port->Clbu = 0;
@@ -302,6 +297,12 @@ STATIC Void ahci_enable_and_probe()
 		rt_set_memory(reinterpret_cast<VoidPtr>(cmd_hdr[i].Ctba), 0, 256);
 	}
 
+	for (UIntPtr offset = 0; offset < kib_cast(64); offset += kib_cast(1))
+	{
+		VoidPtr addr = reinterpret_cast<VoidPtr>(kAHCIBaseAddress + offset);
+		HAL::mm_map_page(addr, addr, HAL::kMMFlagsWr);
+	}
+
 	// Now we are ready.
 
 	kSATAHba->Ports[kSATAIndex].Cmd |= kHBAPxCmdFre;
@@ -337,8 +338,8 @@ STATIC Bool drv_std_init_ahci(UInt16& pi, BOOL& atapi)
 		{
 			HbaMem* mem_ahci = (HbaMem*)kSATADev.Bar(kSATABar5);
 
-			kSATADev.EnableMmio((UIntPtr)mem_ahci);
-			kSATADev.BecomeBusMaster((UIntPtr)mem_ahci);
+			kSATADev.EnableMmio();
+			kSATADev.BecomeBusMaster();
 
 			UInt32 ports_implemented = mem_ahci->Pi;
 			UInt16 ahci_index		 = 0;
@@ -368,7 +369,9 @@ STATIC Bool drv_std_init_ahci(UInt16& pi, BOOL& atapi)
 
 					ahci_enable_and_probe();
 
-					break;
+					err_global_get() = kErrorSuccess;
+
+					return YES;
 				}
 				else if (atapi && kSATAPISignature == mem_ahci->Ports[ahci_index].Sig)
 				{
@@ -377,16 +380,14 @@ STATIC Bool drv_std_init_ahci(UInt16& pi, BOOL& atapi)
 
 					ahci_enable_and_probe();
 
-					break;
+					err_global_get() = kErrorSuccess;
+
+					return YES;
 				}
 
 				ports_implemented >>= 1;
 				++ahci_index;
 			}
-
-			err_global_get() = kErrorSuccess;
-
-			return YES;
 		}
 	}
 
@@ -473,7 +474,7 @@ namespace Kernel
 	UInt16 sk_init_ahci_device(BOOL atapi)
 	{
 		UInt16 pi = 0;
-		return drv_std_init_ahci(pi, atapi);
+		drv_std_init_ahci(pi, atapi);
 
 		kSATAPortsImplemented = pi;
 
diff --git a/dev/kernel/HALKit/AMD64/Storage/DMA+Generic.cc b/dev/kernel/HALKit/AMD64/Storage/DMA+Generic.cc
index cc848f64..300b959f 100644
--- a/dev/kernel/HALKit/AMD64/Storage/DMA+Generic.cc
+++ b/dev/kernel/HALKit/AMD64/Storage/DMA+Generic.cc
@@ -32,7 +32,7 @@ STATIC Boolean kATADetected			 = false;
 STATIC Int32   kATADeviceType		 = kATADeviceCount;
 STATIC Char	   kATAData[kATADataLen] = {0};
 STATIC Kernel::PCI::Device kATADevice;
-STATIC Char				   kCurrentDiskModel[50] = {"UNKNOWN DMA DRIVE"};
+STATIC Char				   kCurrentDiskModel[50] = {"GENERIC DMA"};
 
 Boolean drv_std_wait_io(UInt16 IO)
 {
@@ -73,76 +73,29 @@ Boolean drv_std_init(UInt16 Bus, UInt8 Drive, UInt16& OutBus, UInt8& OutMaster)
 	{
 		kATADevice = iterator[device_index].Leak(); // And then leak the reference.
 
-		// if SATA and then interface is AHCI...
+		/// IDE interface
 		if (kATADevice.Subclass() == 0x01)
 		{
-			UInt16 IO = Bus;
-
-			drv_std_select(IO);
-
-			// Bus init, NEIN bit.
-			rt_out8(IO + ATA_REG_NEIN, 1);
-
-			// identify until it's good.
-		ATAInit_Retry:
-			auto status_rdy = rt_in8(IO + ATA_REG_STATUS);
-
-			if (status_rdy & ATA_SR_ERR)
-			{
-				return false;
-			}
-
-			if ((status_rdy & ATA_SR_BSY))
-				goto ATAInit_Retry;
-
-			rt_out8(IO + ATA_REG_COMMAND, ATA_CMD_IDENTIFY);
-
-			/// fetch serial info
-			/// model, speed, number of sectors...
-
-			drv_std_wait_io(IO);
-
-			for (SizeT i = 0ul; i < kATADataLen; ++i)
-			{
-				drv_std_wait_io(IO);
-				kATAData[i] = Kernel::HAL::rt_in16(IO + ATA_REG_DATA);
-				drv_std_wait_io(IO);
-			}
-
-			for (SizeT i = 0; i < 40; i += 2)
-			{
-				kCurrentDiskModel[i * 2]	 = kATAData[27 + i * 2] >> 8;
-				kCurrentDiskModel[i * 2 + 1] = kATAData[27 + i * 2] & 0xFF;
-			}
-
-			kCurrentDiskModel[40] = '\0';
-
-			kout << "Drive Model: " << kCurrentDiskModel << kendl;
-
-			OutBus	  = (Bus == ATA_PRIMARY_IO) ? ATA_PRIMARY_IO : ATA_SECONDARY_IO;
-			OutMaster = (Bus == ATA_PRIMARY_IO) ? ATA_MASTER : ATA_SLAVE;
-
-			return YES;
+		
+			break;
 		}
 	}
 
-	ke_panic(RUNTIME_CHECK_BOOTSTRAP, "Invalid ATA DMA driver, not detected");
-
 	return NO;
 }
 
 namespace Kernel::Detail
 {
-	struct PRDEntry
+	struct PRDEntry final
 	{
 		UInt32 mAddress;
 		UInt16 mByteCount;
-		UInt16 mFlags;
+		UInt16 mFlags; /// @param PRD flags, set to 0x8000 to indicate end of prd.
 	};
 } // namespace Kernel::Detail
 
 static UIntPtr kReadAddr  = mib_cast(2);
-static UIntPtr kWriteAddr = mib_cast(4);
+static UIntPtr kWriteAddr = mib_cast(2) + kib_cast(64);
 
 Void drv_std_read(UInt64 Lba, UInt16 IO, UInt8 Master, Char* Buf, SizeT SectorSz, SizeT Size)
 {
diff --git a/dev/kernel/HALKit/AMD64/Storage/PIO+Generic.cc b/dev/kernel/HALKit/AMD64/Storage/PIO+Generic.cc
index 201cdf30..c6eee7f7 100644
--- a/dev/kernel/HALKit/AMD64/Storage/PIO+Generic.cc
+++ b/dev/kernel/HALKit/AMD64/Storage/PIO+Generic.cc
@@ -15,10 +15,11 @@
  *
  */
 
+#include "NewKit/Defines.h"
 #include <modules/ATA/ATA.h>
 #include <ArchKit/ArchKit.h>
-
-#ifdef __ATA_PIO__
+#include <KernelKit/DriveMgr.h>
+#include <StorageKit/ATA.h>
 
 using namespace Kernel;
 using namespace Kernel::HAL;
@@ -30,9 +31,9 @@ using namespace Kernel::HAL;
 STATIC Boolean kATADetected			 = false;
 STATIC Int32   kATADeviceType		 = kATADeviceCount;
 STATIC Char	   kATAData[kATADataLen] = {0};
-STATIC Char	   kCurrentDiskModel[50] = {"UNKNOWN PIO DRIVE"};
+STATIC Char	   kCurrentDiskModel[50] = {"GENERIC PIO"};
 
-Boolean drv_std_wait_io(UInt16 IO)
+static Boolean drv_pio_std_wait_io(UInt16 IO)
 {
 	for (int i = 0; i < 400; i++)
 		rt_in8(IO + ATA_REG_STATUS);
@@ -55,7 +56,7 @@ ATAWaitForIO_Retry2:
 	return true;
 }
 
-Void drv_std_select(UInt16 Bus)
+static Void drv_pio_std_select(UInt16 Bus)
 {
 	if (Bus == ATA_PRIMARY_IO)
 		rt_out8(Bus + ATA_REG_HDDEVSEL, ATA_PRIMARY_SEL);
@@ -63,11 +64,11 @@ Void drv_std_select(UInt16 Bus)
 		rt_out8(Bus + ATA_REG_HDDEVSEL, ATA_SECONDARY_SEL);
 }
 
-Boolean drv_std_init(UInt16 Bus, UInt8 Drive, UInt16& OutBus, UInt8& OutMaster)
+Boolean drv_pio_std_init(UInt16 Bus, UInt8 Drive, UInt16& OutBus, UInt8& OutMaster)
 {
 	UInt16 IO = Bus;
 
-	drv_std_select(IO);
+	drv_pio_std_select(IO);
 
 	// Bus init, NEIN bit.
 	rt_out8(IO + ATA_REG_NEIN, 1);
@@ -89,7 +90,7 @@ ATAInit_Retry:
 
 	rt_out8(OutBus + ATA_REG_COMMAND, ATA_CMD_IDENTIFY);
 
-	drv_std_wait_io(IO);
+	drv_pio_std_wait_io(IO);
 
 	/// fetch serial info
 	/// model, speed, number of sectors...
@@ -114,14 +115,14 @@ ATAInit_Retry:
 	return true;
 }
 
-Void drv_std_read(UInt64 Lba, UInt16 IO, UInt8 Master, Char* Buf, SizeT SectorSz, SizeT Size)
+Void drv_pio_std_read(UInt64 Lba, UInt16 IO, UInt8 Master, Char* Buf, SizeT SectorSz, SizeT Size)
 {
 	Lba /= SectorSz;
 
 	UInt8 Command = ((!Master) ? 0xE0 : 0xF0);
 
-	drv_std_wait_io(IO);
-	drv_std_select(IO);
+	drv_pio_std_wait_io(IO);
+	drv_pio_std_select(IO);
 
 	rt_out8(IO + ATA_REG_HDDEVSEL, (Command) | (((Lba) >> 24) & 0x0F));
 
@@ -136,19 +137,19 @@ Void drv_std_read(UInt64 Lba, UInt16 IO, UInt8 Master, Char* Buf, SizeT SectorSz
 
 	for (SizeT IndexOff = 0; IndexOff < Size; ++IndexOff)
 	{
-		drv_std_wait_io(IO);
+		drv_pio_std_wait_io(IO);
 		Buf[IndexOff] = HAL::rt_in16(IO + ATA_REG_DATA);
 	}
 }
 
-Void drv_std_write(UInt64 Lba, UInt16 IO, UInt8 Master, Char* Buf, SizeT SectorSz, SizeT Size)
+Void drv_pio_std_write(UInt64 Lba, UInt16 IO, UInt8 Master, Char* Buf, SizeT SectorSz, SizeT Size)
 {
 	Lba /= SectorSz;
 
 	UInt8 Command = ((!Master) ? 0xE0 : 0xF0);
 
-	drv_std_wait_io(IO);
-	drv_std_select(IO);
+	drv_pio_std_wait_io(IO);
+	drv_pio_std_select(IO);
 
 	rt_out8(IO + ATA_REG_HDDEVSEL, (Command) | (((Lba) >> 24) & 0x0F));
 
@@ -163,13 +164,13 @@ Void drv_std_write(UInt64 Lba, UInt16 IO, UInt8 Master, Char* Buf, SizeT SectorS
 
 	for (SizeT IndexOff = 0; IndexOff < Size; ++IndexOff)
 	{
-		drv_std_wait_io(IO);
+		drv_pio_std_wait_io(IO);
 		rt_out16(IO + ATA_REG_DATA, Buf[IndexOff]);
 	}
 }
 
 /// @brief is ATA detected?
-Boolean drv_std_detected(Void)
+Boolean drv_pio_std_detected(Void)
 {
 	return kATADetected;
 }
@@ -177,15 +178,116 @@ Boolean drv_std_detected(Void)
 /***
 	 @brief Getter, gets the number of sectors inside the drive.
  */
-SizeT drv_get_sector_count()
+SizeT drv_pio_get_sector_count()
 {
 	return (kATAData[61] << 16) | kATAData[60];
 }
 
 /// @brief Get the drive size.
+SizeT drv_pio_get_size()
+{
+	return (drv_pio_get_sector_count()) * kATASectorSize;
+}
+
+namespace Kernel
+{
+	/// @brief Initialize an PIO device (StorageKit function)
+	/// @param is_master is the current PIO master?
+	/// @return [io:master] for PIO device.
+	BOOL sk_init_pio_device(BOOL is_master, UInt16& io, UInt8& master)
+	{
+		return drv_pio_std_init(ATA_SECONDARY_IO, is_master, io, master);
+	}
+
+	/// @brief Implementation details namespace.
+	namespace Detail
+	{
+		/// @brief Read PIO device.
+		/// @param self device
+		/// @param mnt mounted disk.
+		STATIC Void sk_io_read_pio(IDeviceObject<MountpointInterface*>* self, MountpointInterface* mnt)
+		{
+			ATADeviceInterface* dev = (ATADeviceInterface*)self;
+
+			err_global_get() = kErrorDisk;
+
+			if (!dev)
+				return;
+
+			auto disk = mnt->GetAddressOf(dev->GetIndex());
+
+			if (!disk)
+				return;
+
+			err_global_get() = kErrorSuccess;
+
+			drv_pio_std_read(disk->fPacket.fPacketLba, dev->GetIO(), dev->GetMaster(), (Char*)disk->fPacket.fPacketContent, kATASectorSize, disk->fPacket.fPacketSize);
+		}
+
+		/// @brief Write PIO device.
+		/// @param self device
+		/// @param mnt mounted disk.
+		STATIC Void sk_io_write_pio(IDeviceObject<MountpointInterface*>* self, MountpointInterface* mnt)
+		{
+			ATADeviceInterface* dev = (ATADeviceInterface*)self;
+
+			err_global_get() = kErrorDisk;
+
+			if (!dev)
+				return;
+
+			auto disk = mnt->GetAddressOf(dev->GetIndex());
+
+			if (!disk)
+				return;
+
+			err_global_get() = kErrorSuccess;
+
+			drv_pio_std_write(disk->fPacket.fPacketLba, dev->GetIO(), dev->GetMaster(), (Char*)disk->fPacket.fPacketContent, kATASectorSize, disk->fPacket.fPacketSize);
+		}
+	} // namespace Detail
+
+	/// @brief Acquires a new PIO device with drv_index in mind.
+	/// @param drv_index The drive index to assign.
+	/// @return A wrapped device interface if successful, or error code.
+	ErrorOr<ATADeviceInterface> sk_acquire_pio_device(Int32 drv_index)
+	{
+		/// here we don't check if we probed ATA, since we'd need to grab IO after that.
+		ATADeviceInterface device(Detail::sk_io_read_pio,
+								  Detail::sk_io_write_pio,
+								  nullptr);
+
+		device.SetIndex(drv_index);
+
+		return ErrorOr<ATADeviceInterface>(device);
+	}
+} // namespace Kernel
+
+#ifdef __ATA_PIO__
+
+Void drv_std_read(UInt64 Lba, UInt16 IO, UInt8 Master, Char* Buf, SizeT SectorSz, SizeT Size)
+{
+	drv_pio_std_read(Lba, IO, Master, Buf, SectorSz, Size);
+}
+
+Void drv_std_write(UInt64 Lba, UInt16 IO, UInt8 Master, Char* Buf, SizeT SectorSz, SizeT Size)
+{
+	drv_pio_std_write(Lba, IO, Master, Buf, SectorSz, Size);
+}
+
 SizeT drv_get_size()
 {
-	return (drv_get_sector_count()) * kATASectorSize;
+	return drv_pio_get_size();
+}
+
+SizeT drv_get_sector_count()
+{
+	return drv_pio_get_sector_count();
+}
+
+Boolean drv_std_init(UInt16 Bus, UInt8 Drive, UInt16& OutBus, UInt8& OutMaster)
+{
+	return drv_pio_std_init(Bus, Drive, OutBus, OutMaster);
 }
 
-#endif /* ifdef __ATA_PIO__ */
\ No newline at end of file
+#endif
\ No newline at end of file
diff --git a/dev/kernel/KernelKit/PCI/Device.h b/dev/kernel/KernelKit/PCI/Device.h
index b098c2d6..f97aeb6a 100644
--- a/dev/kernel/KernelKit/PCI/Device.h
+++ b/dev/kernel/KernelKit/PCI/Device.h
@@ -64,8 +64,8 @@ namespace Kernel::PCI
 		UIntPtr Bar(UInt32 bar_in);
 
 	public:
-		void EnableMmio(UInt32 bar_in);
-		void BecomeBusMaster(UInt32 bar_in); // for PCI-DMA, PC-DMA does not need that.
+		void EnableMmio();
+		void BecomeBusMaster(); // for PCI-DMA, PC-DMA does not need that.
 
 		UShort Vendor();
 
diff --git a/dev/kernel/StorageKit/ATA.h b/dev/kernel/StorageKit/ATA.h
index 1609ec7d..b5e4b2d9 100644
--- a/dev/kernel/StorageKit/ATA.h
+++ b/dev/kernel/StorageKit/ATA.h
@@ -13,7 +13,7 @@
 
 namespace Kernel
 {
-	/// @brief ATA device interface type.
+	/// @brief ATA device interface class.
 	class ATADeviceInterface : public IDeviceObject<MountpointInterface*>
 	{
 	public:
@@ -33,7 +33,29 @@ namespace Kernel
 
 		const Char* Name() const override;
 
+		const UInt16& GetIO();
+		Void SetIO(const UInt16& io);
+
+		const UInt16& GetMaster();
+		Void SetMaster(const UInt16& master);
+
+		const UInt32& GetIndex();
+		Void SetIndex(const UInt32& drv);
+
 	private:
 		void (*fCleanup)(void) = {nullptr};
+		UInt32 fDriveIndex{0U};
+		UInt16 fIO, fMaster{0U};
+
 	};
+
+	/// @brief Initialize an PIO device (StorageKit function)
+	/// @param is_master is the current PIO master?
+	/// @return [io:master] for PIO device.
+	BOOL sk_init_pio_device(BOOL is_master, UInt16& io, UInt8& master);
+
+	/// @brief Acquires a new PIO device with drv_index in mind.
+	/// @param drv_index The drive index to assign.
+	/// @return A wrapped device interface if successful, or error code.
+	ErrorOr<ATADeviceInterface> sk_acquire_pio_device(Int32 drv_index);
 } // namespace Kernel
diff --git a/dev/kernel/src/Storage/AHCIDeviceInterface.cc b/dev/kernel/src/Storage/AHCIDeviceInterface.cc
index 9419dc4e..1798e9a9 100644
--- a/dev/kernel/src/Storage/AHCIDeviceInterface.cc
+++ b/dev/kernel/src/Storage/AHCIDeviceInterface.cc
@@ -36,16 +36,16 @@ const Char* AHCIDeviceInterface::Name() const
 }
 
 /// @brief Output operator.
-/// @param Data the disk mountpoint.
+/// @param mnt the disk mountpoint.
 /// @return the class itself after operation.
-AHCIDeviceInterface& AHCIDeviceInterface::operator<<(MountpointInterface* Data)
+AHCIDeviceInterface& AHCIDeviceInterface::operator<<(MountpointInterface* mnt)
 {
-	if (!Data)
+	if (!mnt)
 		return *this;
 
 	for (SizeT driveCount = 0; driveCount < kDriveMaxCount; ++driveCount)
 	{
-		auto interface = Data->GetAddressOf(driveCount);
+		auto interface = mnt->GetAddressOf(driveCount);
 
 		if ((interface) && rt_string_cmp((interface)->fProtocol(), "AHCI", rt_string_len("AHCI")) == 0)
 		{
@@ -59,20 +59,20 @@ AHCIDeviceInterface& AHCIDeviceInterface::operator<<(MountpointInterface* Data)
 	}
 
 	return (AHCIDeviceInterface&)IDeviceObject<MountpointInterface*>::operator<<(
-		Data);
+		mnt);
 }
 
 /// @brief Input operator.
-/// @param Data the disk mountpoint.
+/// @param mnt the disk mountpoint.
 /// @return the class itself after operation.
-AHCIDeviceInterface& AHCIDeviceInterface::operator>>(MountpointInterface* Data)
+AHCIDeviceInterface& AHCIDeviceInterface::operator>>(MountpointInterface* mnt)
 {
-	if (!Data)
+	if (!mnt)
 		return *this;
 
 	for (SizeT driveCount = 0; driveCount < kDriveMaxCount; ++driveCount)
 	{
-		auto interface = Data->GetAddressOf(driveCount);
+		auto interface = mnt->GetAddressOf(driveCount);
 
 		// really check if it's ATA.
 		if ((interface) && rt_string_cmp((interface)->fProtocol(), "AHCI", rt_string_len("AHCI")) == 0)
@@ -87,7 +87,7 @@ AHCIDeviceInterface& AHCIDeviceInterface::operator>>(MountpointInterface* Data)
 	}
 
 	return (AHCIDeviceInterface&)IDeviceObject<MountpointInterface*>::operator>>(
-		Data);
+		mnt);
 }
 
 const UInt16& AHCIDeviceInterface::GetPortsImplemented()
@@ -109,4 +109,5 @@ const UInt32& AHCIDeviceInterface::GetIndex()
 Void AHCIDeviceInterface::SetIndex(const UInt32& drv)
 {
 	MUST_PASS(MountpointInterface::kDriveIndexInvalid != drv);
+	this->fDriveIndex = drv;
 }
\ No newline at end of file
diff --git a/dev/kernel/src/Storage/ATADeviceInterface.cc b/dev/kernel/src/Storage/ATADeviceInterface.cc
index 118a6d0a..2e7022a7 100644
--- a/dev/kernel/src/Storage/ATADeviceInterface.cc
+++ b/dev/kernel/src/Storage/ATADeviceInterface.cc
@@ -89,3 +89,36 @@ ATADeviceInterface& ATADeviceInterface::operator>>(MountpointInterface* Data)
 	return (ATADeviceInterface&)IDeviceObject<MountpointInterface*>::operator>>(
 		Data);
 }
+
+const UInt32& ATADeviceInterface::GetIndex()
+{
+	return this->fDriveIndex;
+}
+
+Void ATADeviceInterface::SetIndex(const UInt32& drv)
+{
+	MUST_PASS(MountpointInterface::kDriveIndexInvalid != drv);
+	this->fDriveIndex = drv;
+}
+
+const UInt16& ATADeviceInterface::GetIO()
+{
+	return this->fIO;
+}
+
+Void ATADeviceInterface::SetIO(const UInt16& drv)
+{
+	MUST_PASS(0xFFFF != drv);
+	this->fIO = drv;
+}
+
+const UInt16& ATADeviceInterface::GetMaster()
+{
+	return this->fIO;
+}
+
+Void ATADeviceInterface::SetMaster(const UInt16& drv)
+{
+	MUST_PASS(0xFFFF != drv);
+	this->fMaster = drv;
+}
\ No newline at end of file