-/* $Id: rawfs.c,v 1.2 2003/05/15 13:34:37 ekohl Exp $
+/* $Id$
*
* COPYRIGHT: See COPYING in the top level directory
* PROJECT: ReactOS kernel
* FILE: ntoskrnl/io/rawfs.c
* PURPOSE: Raw filesystem driver
- * PROGRAMMER: Casper S. Hornstrup (chorns@users.sourceforge.net)
- * UPDATE HISTORY:
- * Created 13/04/2003
+ *
+ * PROGRAMMERS: Casper S. Hornstrup (chorns@users.sourceforge.net)
*/
/* INCLUDES *****************************************************************/
-#include <ddk/ntddk.h>
-#include <ddk/ntifs.h>
-#include <reactos/bugcodes.h>
-
+#include <ntoskrnl.h>
#define NDEBUG
#include <internal/debug.h>
typedef struct _RAWFS_FCB
{
/* Start FCB header required by ReactOS/Windows NT */
- REACTOS_COMMON_FCB_HEADER RFCB;
+ FSRTL_COMMON_FCB_HEADER RFCB;
SECTION_OBJECT_POINTERS SectionObjectPointers;
ERESOURCE MainResource;
ERESOURCE PagingIoResource;
/* GLOBALS ******************************************************************/
-#define TAG_IRP TAG('R', 'I', 'R', 'P')
-
static PDRIVER_OBJECT RawFsDriverObject;
static PDEVICE_OBJECT DiskDeviceObject;
static PDEVICE_OBJECT CdromDeviceObject;
pDeviceObject,
Buffer,
WriteLength,
- WriteOffset,
- &Event,
+ WriteOffset,
+ &Event,
&IoStatus);
if (!Irp)
{
IN ULONG CtlCode,
IN PVOID InputBuffer,
IN ULONG InputBufferSize,
- IN OUT PVOID OutputBuffer,
+ IN OUT PVOID OutputBuffer,
IN OUT PULONG pOutputBufferSize)
{
ULONG OutputBufferSize = 0;
NTSTATUS Status;
DPRINT("RawFsBlockDeviceIoControl(DeviceObject %x, CtlCode %x, "
- "InputBuffer %x, InputBufferSize %x, OutputBuffer %x, "
- "POutputBufferSize %x (%x)\n", DeviceObject, CtlCode,
- InputBuffer, InputBufferSize, OutputBuffer, pOutputBufferSize,
+ "InputBuffer %x, InputBufferSize %x, OutputBuffer %x, "
+ "POutputBufferSize %x (%x)\n", DeviceObject, CtlCode,
+ InputBuffer, InputBufferSize, OutputBuffer, pOutputBufferSize,
pOutputBufferSize ? *pOutputBufferSize : 0);
if (pOutputBufferSize)
KeInitializeEvent(&Event, NotificationEvent, FALSE);
DPRINT("Building device I/O control request ...\n");
- Irp = IoBuildDeviceIoControlRequest(CtlCode,
- DeviceObject,
- InputBuffer,
- InputBufferSize,
+ Irp = IoBuildDeviceIoControlRequest(CtlCode,
+ DeviceObject,
+ InputBuffer,
+ InputBufferSize,
OutputBuffer,
- OutputBufferSize,
- FALSE,
- &Event,
+ OutputBufferSize,
+ FALSE,
+ &Event,
&IoStatus);
if (Irp == NULL)
{
memset(Fcb, 0, sizeof(RAWFS_FCB));
ExInitializeResourceLite(&Fcb->PagingIoResource);
ExInitializeResourceLite(&Fcb->MainResource);
-// FsRtlInitializeFileLock(&Fcb->FileLock, NULL, NULL);
+// FsRtlInitializeFileLock(&Fcb->FileLock, NULL, NULL);
return Fcb;
}
static VOID
RawFsDestroyFCB(IN PRAWFS_GLOBAL_DATA pGlobalData, IN PRAWFS_FCB pFcb)
{
- //FsRtlUninitializeFileLock(&pFcb->FileLock);
+ //FsRtlUninitializeFileLock(&pFcb->FileLock);
ExDeleteResourceLite(&pFcb->PagingIoResource);
ExDeleteResourceLite(&pFcb->MainResource);
ExFreeToNPagedLookasideList(&pGlobalData->FcbLookasideList, pFcb);
DPRINT("RawFsAllocateIrpContext(DeviceObject %x, Irp %x)\n", DeviceObject, Irp);
- assert(DeviceObject);
- assert(Irp);
+ ASSERT(DeviceObject);
+ ASSERT(Irp);
GlobalData = (PRAWFS_GLOBAL_DATA) DeviceObject->DeviceExtension;
IrpContext = ExAllocateFromNPagedLookasideList(&IrpContextLookasideList);
IrpContext->DeviceObject = DeviceObject;
IrpContext->DeviceExt = DeviceObject->DeviceExtension;
IrpContext->Stack = IoGetCurrentIrpStackLocation(Irp);
- assert(IrpContext->Stack);
+ ASSERT(IrpContext->Stack);
MajorFunction = IrpContext->MajorFunction = IrpContext->Stack->MajorFunction;
IrpContext->MinorFunction = IrpContext->Stack->MinorFunction;
IrpContext->FileObject = IrpContext->Stack->FileObject;
{
DPRINT("RawFsFreeIrpContext(IrpContext %x)\n", IrpContext);
- assert(IrpContext);
+ ASSERT(IrpContext);
ExFreeToNPagedLookasideList(&IrpContextLookasideList, IrpContext);
}
{
ULONG Count;
+ Count = InterlockedDecrement(&RawFsQueueCount);
+
DPRINT("RawFsDoRequest(IrpContext %x), MajorFunction %x, %d\n",
IrpContext, ((PRAWFS_IRP_CONTEXT) IrpContext)->MajorFunction, Count);
- Count = InterlockedDecrement(&RawFsQueueCount);
RawFsDispatchRequest((PRAWFS_IRP_CONTEXT) IrpContext);
}
{
ULONG Count;
- DPRINT("RawFsQueueRequest (IrpContext %x), %d\n", IrpContext, Count);
-
- assert(IrpContext != NULL);
- assert(IrpContext->Irp != NULL);
+ ASSERT(IrpContext != NULL);
+ ASSERT(IrpContext->Irp != NULL);
Count = InterlockedIncrement(&RawFsQueueCount);
+ DPRINT("RawFsQueueRequest (IrpContext %x), %d\n", IrpContext, Count);
+
IrpContext->Flags |= IRPCONTEXT_CANWAIT;
IoMarkIrpPending (IrpContext->Irp);
ExInitializeWorkItem (&IrpContext->WorkQueueItem, RawFsDoRequest, IrpContext);
RawFsClose(IN PRAWFS_IRP_CONTEXT IrpContext)
{
DPRINT("RawFsClose(IrpContext %x)\n", IrpContext);
- UNIMPLEMENTED
+ UNIMPLEMENTED;
return STATUS_NOT_IMPLEMENTED;
}
FileObject = IoSp->FileObject;
DeviceExt = IrpContext->DeviceObject->DeviceExtension;
- if (FileObject->FileName.Length == 0 &&
+ if (FileObject->FileName.Length == 0 &&
FileObject->RelatedFileObject == NULL)
{
/* This a open operation for the volume itself */
return (STATUS_INSUFFICIENT_RESOURCES);
}
- FileObject->Flags |= FO_FCB_IS_VALID;
- FileObject->SectionObjectPointers = &pFcb->SectionObjectPointers;
+ FileObject->SectionObjectPointer = &pFcb->SectionObjectPointers;
FileObject->FsContext = pFcb;
FileObject->FsContext2 = pCcb;
pFcb->RefCount++;
DPRINT("RawFsCreate(IrpContext %x)\n", IrpContext);
- assert(IrpContext);
-
+ ASSERT(IrpContext);
+
if (RawFsIsRawFileSystemDeviceObject(IrpContext->DeviceObject))
{
/* DeviceObject represents FileSystem instead of logical volume */
Status = RawFsCreateFile(IrpContext);
IrpContext->Irp->IoStatus.Status = Status;
- IoCompleteRequest(IrpContext->Irp,
- NT_SUCCESS(Status) ? IO_DISK_INCREMENT : IO_NO_INCREMENT);
+ IoCompleteRequest(IrpContext->Irp,
+ (CCHAR)(NT_SUCCESS(Status) ? IO_DISK_INCREMENT : IO_NO_INCREMENT));
RawFsFreeIrpContext(IrpContext);
return Status;
RawFsRead(IN PRAWFS_IRP_CONTEXT IrpContext)
{
DPRINT("RawFsRead(IrpContext %x)\n", IrpContext);
- UNIMPLEMENTED
+ UNIMPLEMENTED;
return STATUS_NOT_IMPLEMENTED;
}
RawFsWrite(IN PRAWFS_IRP_CONTEXT IrpContext)
{
DPRINT("RawFsWrite(IrpContext %x)\n", IrpContext);
- UNIMPLEMENTED
+ UNIMPLEMENTED;
return STATUS_NOT_IMPLEMENTED;
}
static NTSTATUS
RawFsMount(IN PRAWFS_IRP_CONTEXT IrpContext)
{
- PRAWFS_GLOBAL_DATA GlobalData;
+ PRAWFS_GLOBAL_DATA GlobalData = NULL;
PDEVICE_OBJECT DeviceObject = NULL;
PRAWFS_DEVICE_EXTENSION DeviceExt = NULL;
PRAWFS_FCB VolumeFcb = NULL;
DPRINT("RawFsMount(IrpContext %x)\n", IrpContext);
- assert(IrpContext);
+ ASSERT(IrpContext);
if (!RawFsIsRawFileSystemDeviceObject(IrpContext->DeviceObject))
{
DeviceObject->Flags |= DO_DIRECT_IO;
DeviceExt = (PVOID) DeviceObject->DeviceExtension;
RtlZeroMemory(DeviceExt, sizeof(RAWFS_DEVICE_EXTENSION));
-
+
/* Use same vpb as device disk */
DeviceObject->Vpb = IrpContext->Stack->Parameters.MountVolume.DeviceObject->Vpb;
DeviceExt->StorageDevice = IrpContext->Stack->Parameters.MountVolume.DeviceObject;
DeviceExt->StorageDevice->Vpb->Flags |= VPB_MOUNTED;
DeviceObject->StackSize = DeviceExt->StorageDevice->StackSize + 1;
DeviceObject->Flags &= ~DO_DEVICE_INITIALIZING;
-
+
KeInitializeSpinLock(&DeviceExt->FcbListLock);
InitializeListHead(&DeviceExt->FcbListHead);
VolumeFcb->RFCB.AllocationSize.QuadPart = VolumeFcb->RFCB.FileSize.QuadPart;
DeviceExt->VolumeFcb = VolumeFcb;
+ KeEnterCriticalRegion();
ExAcquireResourceExclusiveLite(&GlobalData->VolumeListLock, TRUE);
InsertHeadList(&GlobalData->VolumeListHead, &DeviceExt->VolumeListEntry);
ExReleaseResourceLite(&GlobalData->VolumeListLock);
+ KeLeaveCriticalRegion();
/* No serial number */
DeviceObject->Vpb->SerialNumber = 0;
NTSTATUS Status;
DPRINT("RawFsFileSystemControl(IrpContext %x)\n", IrpContext);
-
- assert (IrpContext);
+
+ ASSERT(IrpContext);
switch (IrpContext->MinorFunction)
{
RawFsQueryInformation(IN PRAWFS_IRP_CONTEXT IrpContext)
{
DPRINT("RawFsQueryInformation(IrpContext %x)\n", IrpContext);
- UNIMPLEMENTED
+ UNIMPLEMENTED;
return STATUS_NOT_IMPLEMENTED;
}
RawFsSetInformation(IN PRAWFS_IRP_CONTEXT IrpContext)
{
DPRINT("RawFsSetInformation(IrpContext %x)\n", IrpContext);
- UNIMPLEMENTED
+ UNIMPLEMENTED;
return STATUS_NOT_IMPLEMENTED;
}
RawFsDirectoryControl(IN PRAWFS_IRP_CONTEXT IrpContext)
{
DPRINT("RawFsDirectoryControl(IrpContext %x)\n", IrpContext);
- UNIMPLEMENTED
+ UNIMPLEMENTED;
return STATUS_NOT_IMPLEMENTED;
}
RawFsQueryVolumeInformation(IN PRAWFS_IRP_CONTEXT IrpContext)
{
DPRINT("RawFsQueryVolumeInformation(IrpContext %x)\n", IrpContext);
- UNIMPLEMENTED
+ UNIMPLEMENTED;
return STATUS_NOT_IMPLEMENTED;
}
RawFsSetVolumeInformation(IN PRAWFS_IRP_CONTEXT IrpContext)
{
DPRINT("RawFsSetVolumeInformation(IrpContext %x)\n", IrpContext);
- UNIMPLEMENTED
+ UNIMPLEMENTED;
return STATUS_NOT_IMPLEMENTED;
}
RawFsLockControl(IN PRAWFS_IRP_CONTEXT IrpContext)
{
DPRINT("RawFsLockControl(IrpContext %x)\n", IrpContext);
- UNIMPLEMENTED
+ UNIMPLEMENTED;
return STATUS_NOT_IMPLEMENTED;
}
RawFsCleanup(IN PRAWFS_IRP_CONTEXT IrpContext)
{
DPRINT("RawFsCleanup(IrpContext %x)\n", IrpContext);
- UNIMPLEMENTED
+ UNIMPLEMENTED;
return STATUS_NOT_IMPLEMENTED;
}
RawFsFlush(IN PRAWFS_IRP_CONTEXT IrpContext)
{
DPRINT("RawFsFlush(IrpContext %x)\n", IrpContext);
- UNIMPLEMENTED
+ UNIMPLEMENTED;
return STATUS_NOT_IMPLEMENTED;
}
DPRINT("RawFsDispatchRequest(IrpContext %x), MajorFunction %x\n",
IrpContext, IrpContext->MajorFunction);
- assert (IrpContext);
+ ASSERT(IrpContext);
switch (IrpContext->MajorFunction)
{
DPRINT("RawFsBuildRequest(DeviceObject %x, Irp %x)\n", DeviceObject, Irp);
- assert(DeviceObject);
- assert(Irp);
+ ASSERT(DeviceObject);
+ ASSERT(Irp);
IrpContext = RawFsAllocateIrpContext(DeviceObject, Irp);
if (IrpContext == NULL)
if (!NT_SUCCESS(Status))
{
CPRINT("IoCreateDevice() failed with status 0x%.08x\n", Status);
- KeBugCheck(PHASE1_INITIALIZATION_FAILED);
+ KEBUGCHECKEX(PHASE1_INITIALIZATION_FAILED, Status, 0, 0, 0);
return(Status);
}
DeviceData = DiskDeviceObject->DeviceExtension;
if (!NT_SUCCESS(Status))
{
CPRINT("IoCreateDevice() failed with status 0x%.08x\n", Status);
- KeBugCheck(PHASE1_INITIALIZATION_FAILED);
+ KEBUGCHECKEX(PHASE1_INITIALIZATION_FAILED, Status, 0, 0, 0);
return(Status);
}
DeviceData = CdromDeviceObject->DeviceExtension;
&TapeDeviceObject);
if (!NT_SUCCESS(Status))
{
- CPRINT("IoCreateDevice() failed with status 0x%.08x\n", Status);
- KeBugCheck(PHASE1_INITIALIZATION_FAILED);
+ KEBUGCHECKEX(PHASE1_INITIALIZATION_FAILED, Status, 0, 0, 0);
return(Status);
}
DeviceData = TapeDeviceObject->DeviceExtension;
projects / reactos.git / blobdiff