mirror of
https://github.com/reactos/reactos.git
synced 2024-09-11 21:34:09 +00:00
156 lines
4.3 KiB
C
156 lines
4.3 KiB
C
/*
|
|
* COPYRIGHT: See COPYING in the top level directory
|
|
* PROJECT: ReactOS kernel
|
|
* FILE: services/fs/ext2/blockdev.c
|
|
* PURPOSE: Temporary sector reading support
|
|
* PROGRAMMER: David Welch (welch@cwcom.net)
|
|
* UPDATE HISTORY:
|
|
*/
|
|
|
|
/* INCLUDES *****************************************************************/
|
|
|
|
#include <ntddk.h>
|
|
|
|
//#define NDEBUG
|
|
#include <debug.h>
|
|
|
|
#include "ext2fs.h"
|
|
|
|
/* FUNCTIONS ***************************************************************/
|
|
|
|
BOOLEAN
|
|
Ext2ReadSectors(IN PDEVICE_OBJECT pDeviceObject,
|
|
IN ULONG DiskSector,
|
|
IN ULONG SectorCount,
|
|
IN PVOID Buffer)
|
|
{
|
|
LARGE_INTEGER sectorNumber;
|
|
PIRP irp;
|
|
IO_STATUS_BLOCK ioStatus;
|
|
KEVENT event;
|
|
NTSTATUS status;
|
|
ULONG sectorSize;
|
|
int j;
|
|
|
|
DPRINT("VFATReadSector(pDeviceObject %x, DiskSector %d, Buffer %x)\n",
|
|
pDeviceObject,DiskSector,Buffer);
|
|
|
|
sectorNumber.u.HighPart = 0;
|
|
sectorNumber.u.LowPart = DiskSector * BLOCKSIZE;
|
|
|
|
DPRINT("DiskSector:%ld BLKSZ:%ld sectorNumber:%ld:%ld\n",
|
|
(unsigned long) DiskSector,
|
|
(unsigned long) BLOCKSIZE,
|
|
(unsigned long) sectorNumber.u.HighPart,
|
|
(unsigned long) sectorNumber.u.LowPart);
|
|
|
|
KeInitializeEvent(&event, NotificationEvent, FALSE);
|
|
|
|
sectorSize = BLOCKSIZE*SectorCount;
|
|
|
|
|
|
DPRINT("Building synchronous FSD Request...\n");
|
|
irp = IoBuildSynchronousFsdRequest(IRP_MJ_READ,
|
|
pDeviceObject,
|
|
Buffer,
|
|
sectorSize,
|
|
§orNumber,
|
|
&event,
|
|
&ioStatus );
|
|
|
|
if (!irp)
|
|
{
|
|
DbgPrint("READ failed!!!\n");
|
|
return FALSE;
|
|
}
|
|
|
|
DPRINT("Calling IO Driver...\n");
|
|
status = IoCallDriver(pDeviceObject, irp);
|
|
|
|
DPRINT("Waiting for IO Operation...\n");
|
|
if (status == STATUS_PENDING)
|
|
{
|
|
KeWaitForSingleObject(&event,
|
|
Suspended,
|
|
KernelMode,
|
|
FALSE,
|
|
NULL);
|
|
DPRINT("Getting IO Status...\n");
|
|
status = ioStatus.Status;
|
|
}
|
|
|
|
if (!NT_SUCCESS(status))
|
|
{
|
|
DbgPrint("IO failed!!! Error code: %d(%x)\n", status, status);
|
|
return FALSE;
|
|
}
|
|
|
|
return TRUE;
|
|
}
|
|
|
|
BOOLEAN VFATWriteSectors(IN PDEVICE_OBJECT pDeviceObject,
|
|
IN ULONG DiskSector,
|
|
IN ULONG SectorCount,
|
|
IN UCHAR* Buffer)
|
|
{
|
|
LARGE_INTEGER sectorNumber;
|
|
PIRP irp;
|
|
IO_STATUS_BLOCK ioStatus;
|
|
KEVENT event;
|
|
NTSTATUS status;
|
|
ULONG sectorSize;
|
|
PULONG mbr;
|
|
int j;
|
|
|
|
DPRINT("VFATWriteSector(pDeviceObject %x, DiskSector %d, Buffer %x)\n",
|
|
pDeviceObject,DiskSector,Buffer);
|
|
|
|
sectorNumber.u.HighPart = 0;
|
|
sectorNumber.u.LowPart = DiskSector * BLOCKSIZE;
|
|
|
|
KeInitializeEvent(&event, NotificationEvent, FALSE);
|
|
|
|
sectorSize = BLOCKSIZE*SectorCount;
|
|
|
|
|
|
DPRINT("Building synchronous FSD Request...\n");
|
|
irp = IoBuildSynchronousFsdRequest(IRP_MJ_WRITE,
|
|
pDeviceObject,
|
|
Buffer,
|
|
sectorSize,
|
|
§orNumber,
|
|
&event,
|
|
&ioStatus );
|
|
|
|
if (!irp) {
|
|
DbgPrint("WRITE failed!!!\n");
|
|
return FALSE;
|
|
}
|
|
|
|
DPRINT("Calling IO Driver...\n");
|
|
status = IoCallDriver(pDeviceObject,
|
|
irp);
|
|
|
|
DPRINT("Waiting for IO Operation...\n");
|
|
if (status == STATUS_PENDING) {
|
|
KeWaitForSingleObject(&event,
|
|
Suspended,
|
|
KernelMode,
|
|
FALSE,
|
|
NULL);
|
|
DPRINT("Getting IO Status...\n");
|
|
status = ioStatus.Status;
|
|
}
|
|
|
|
if (!NT_SUCCESS(status)) {
|
|
DbgPrint("IO failed!!! Error code: %d(%x)\n", status, status);
|
|
return FALSE;
|
|
}
|
|
|
|
|
|
ExFreePool(mbr);
|
|
DPRINT("Block request succeeded\n");
|
|
return TRUE;
|
|
}
|
|
|