[ion] 22702: [FORMATTING] - Cleanup before I start working on it... there were lots of weird formatting errors caused by my old IDE back when I was working on it. [AUDIT] - The routines in this file mostly come from documented information in "NT File System Internals" by Rajeev Nagar which has pseudo-code for a lot of them, and other WDM Books and information.
Author: ion Date: Fri Jun 30 03:01:09 2006 New Revision: 22702
URL: http://svn.reactos.org/svn/reactos?rev=22702&view=rev Log: [FORMATTING] - Cleanup before I start working on it... there were lots of weird formatting errors caused by my old IDE back when I was working on it. [AUDIT] - The routines in this file mostly come from documented information in "NT File System Internals" by Rajeev Nagar which has pseudo-code for a lot of them, and other WDM Books and information.
Modified: trunk/reactos/ntoskrnl/io/irp.c (contents, props changed)
Modified: trunk/reactos/ntoskrnl/io/irp.c URL: http://svn.reactos.org/svn/reactos/trunk/reactos/ntoskrnl/io/irp.c?rev=22702... ============================================================================== --- trunk/reactos/ntoskrnl/io/irp.c (original) +++ trunk/reactos/ntoskrnl/io/irp.c Fri Jun 30 03:01:09 2006 @@ -17,27 +17,27 @@ /* PRIVATE FUNCTIONS ********************************************************/
VOID -STDCALL -IopFreeIrpKernelApc(PKAPC Apc, - PKNORMAL_ROUTINE *NormalRoutine, - PVOID *NormalContext, - PVOID *SystemArgument1, - PVOID *SystemArgument2) +NTAPI +IopFreeIrpKernelApc(IN PKAPC Apc, + IN PKNORMAL_ROUTINE *NormalRoutine, + IN PVOID *NormalContext, + IN PVOID *SystemArgument1, + IN PVOID *SystemArgument2) { /* Free the IRP */ IoFreeIrp(CONTAINING_RECORD(Apc, IRP, Tail.Apc)); }
VOID -STDCALL -IopAbortIrpKernelApc(PKAPC Apc) +NTAPI +IopAbortIrpKernelApc(IN PKAPC Apc) { /* Free the IRP */ IoFreeIrp(CONTAINING_RECORD(Apc, IRP, Tail.Apc)); }
VOID -STDCALL +NTAPI IopRemoveThreadIrp(VOID) { KIRQL OldIrql; @@ -45,10 +45,10 @@ PETHREAD IrpThread; PLIST_ENTRY IrpEntry; PIO_ERROR_LOG_PACKET ErrorLogEntry; - + /* First, raise to APC to protect IrpList */ KeRaiseIrql(APC_LEVEL, &OldIrql); - + /* Get the Thread and check the list */ IrpThread = PsGetCurrentThread(); if (IsListEmpty(&IrpThread->IrpList)) @@ -57,26 +57,27 @@ KeLowerIrql(OldIrql); return; } - + /* Get the misbehaving IRP */ IrpEntry = IrpThread->IrpList.Flink; DeadIrp = CONTAINING_RECORD(IrpEntry, IRP, ThreadListEntry); - + /* Disown the IRP! */ DeadIrp->Tail.Overlay.Thread = NULL; InitializeListHead(&DeadIrp->ThreadListEntry); RemoveHeadList(&IrpThread->IrpList); - + /* Lower IRQL now */ KeLowerIrql(OldIrql); - + /* Check if we can send an Error Log Entry*/ if (DeadIrp->CurrentLocation <= DeadIrp->StackCount) { /* Allocate an entry */ - ErrorLogEntry = IoAllocateErrorLogEntry(IoGetCurrentIrpStackLocation(DeadIrp)->DeviceObject, - sizeof(IO_ERROR_LOG_PACKET)); - + ErrorLogEntry = IoAllocateErrorLogEntry( + IoGetCurrentIrpStackLocation(DeadIrp)->DeviceObject, + sizeof(IO_ERROR_LOG_PACKET)); + /* Write the entry */ ErrorLogEntry->ErrorCode = 0xBAADF00D; /* FIXME */ IoWriteErrorLogEntry(ErrorLogEntry); @@ -84,12 +85,12 @@ }
VOID -STDCALL -IopCleanupIrp(PIRP Irp, - PFILE_OBJECT FileObject) +NTAPI +IopCleanupIrp(IN PIRP Irp, + IN PFILE_OBJECT FileObject) { PMDL Mdl; - + /* Check if there's an MDL */ while ((Mdl = Irp->MdlAddress)) { @@ -97,43 +98,33 @@ Irp->MdlAddress = Mdl->Next; IoFreeMdl(Mdl); } - + /* Free the buffer */ if (Irp->Flags & IRP_DEALLOCATE_BUFFER) { ExFreePoolWithTag(Irp->AssociatedIrp.SystemBuffer, TAG_SYS_BUF); } - + /* Derefernce the User Event */ if (Irp->UserEvent && !(Irp->Flags & IRP_SYNCHRONOUS_API) && FileObject) { ObDereferenceObject(Irp->UserEvent); } - + /* Dereference the File Object */ if (FileObject) ObDereferenceObject(FileObject); - + /* Free the IRP */ IoFreeIrp(Irp); } - -/* - * FUNCTION: Performs the second stage of irp completion for read/write irps - * - * Called as a special kernel APC kernel-routine or directly from IofCompleteRequest() - * - * Note that we'll never see irp's flagged IRP_PAGING_IO (IRP_MOUNT_OPERATION) - * or IRP_CLOSE_OPERATION (IRP_MJ_CLOSE and IRP_MJ_CLEANUP) here since their - * cleanup/completion is fully taken care of in IoCompleteRequest. - * -Gunnar - */ + VOID -STDCALL -IopCompleteRequest(PKAPC Apc, - PKNORMAL_ROUTINE* NormalRoutine, - PVOID* NormalContext, - PVOID* SystemArgument1, - PVOID* SystemArgument2) +NTAPI +IopCompleteRequest(IN PKAPC Apc, + IN PKNORMAL_ROUTINE* NormalRoutine, + IN PVOID* NormalContext, + IN PVOID* SystemArgument1, + IN PVOID* SystemArgument2) { PFILE_OBJECT FileObject; PIRP Irp; @@ -214,7 +205,10 @@ /* Check if we should signal the File Object Event as well */ if (FileObject) { - /* If the File Object is SYNC, then we need to signal its event too */ + /* + * If the File Object is SYNC, then we need to + * signal its event too + */ if (FileObject->Flags & FO_SYNCHRONOUS_IO) { /* Set the Status */ @@ -224,6 +218,7 @@ KeSetEvent(&FileObject->Event, 0, FALSE); } } + /* Signal the Event */ KeSetEvent(UserEvent, 0, FALSE);
@@ -240,20 +235,21 @@
/* Signal the File Object Instead */ KeSetEvent(&FileObject->Event, 0, FALSE); - }
/* Now call the User APC if one was requested */ - if (Irp->Overlay.AsynchronousParameters.UserApcRoutine != NULL) + if (Irp->Overlay.AsynchronousParameters.UserApcRoutine) { KeInitializeApc(&Irp->Tail.Apc, KeGetCurrentThread(), CurrentApcEnvironment, IopFreeIrpKernelApc, IopAbortIrpKernelApc, - (PKNORMAL_ROUTINE)Irp->Overlay.AsynchronousParameters.UserApcRoutine, + (PKNORMAL_ROUTINE)Irp-> + Overlay.AsynchronousParameters.UserApcRoutine, Irp->RequestorMode, - Irp->Overlay.AsynchronousParameters.UserApcContext); + Irp-> + Overlay.AsynchronousParameters.UserApcContext);
KeInsertQueueApc(&Irp->Tail.Apc, Irp->UserIosb, @@ -273,7 +269,9 @@ } else { - /* Signal the Events only if PendingReturned and we have a File Object */ + /* + * Signal the Events only if PendingReturned and we have a File Object + */ if (FileObject && Irp->PendingReturned) { /* Check for SYNC IRP */ @@ -384,9 +382,11 @@ CurrentApcEnvironment, IopFreeIrpKernelApc, IopAbortIrpKernelApc, - (PKNORMAL_ROUTINE)Irp->Overlay.AsynchronousParameters.UserApcRoutine, + (PKNORMAL_ROUTINE)Irp-> + Overlay.AsynchronousParameters.UserApcRoutine, Irp->RequestorMode, - Irp->Overlay.AsynchronousParameters.UserApcContext); + Irp-> + Overlay.AsynchronousParameters.UserApcContext);
KeInsertQueueApc(&Irp->Tail.Apc, Irp->UserIosb, @@ -399,7 +399,8 @@ /* Call the IO Completion Port if we have one, instead */ IoSetIoCompletion(FileObject->CompletionContext->Port, FileObject->CompletionContext->Key, - Irp->Overlay.AsynchronousParameters.UserApcContext, + Irp-> + Overlay.AsynchronousParameters.UserApcContext, Irp->IoStatus.Status, Irp->IoStatus.Information, FALSE); @@ -429,15 +430,9 @@
/* * @implemented - * - * FUNCTION: Allocates an IRP - * ARGUMENTS: - * StackSize = the size of the stack required for the irp - * ChargeQuota = Charge allocation to current threads quota - * RETURNS: Irp allocated */ PIRP -STDCALL +NTAPI IoAllocateIrp(CCHAR StackSize, BOOLEAN ChargeQuota) { @@ -447,56 +442,49 @@ UCHAR Flags = 0; PNPAGED_LOOKASIDE_LIST List = NULL; PP_NPAGED_LOOKASIDE_NUMBER ListType = LookasideSmallIrpList; - + /* Figure out which Lookaside List to use */ if ((StackSize <= 8) && (ChargeQuota == FALSE)) { - DPRINT("Using lookaside, %d\n", StackSize); /* Set Fixed Size Flag */ Flags = IRP_ALLOCATED_FIXED_SIZE; - + /* See if we should use big list */ if (StackSize != 1) { - DPRINT("Using large lookaside\n"); Size = IoSizeOfIrp(8); ListType = LookasideLargeIrpList; } - + /* Get the PRCB */ Prcb = KeGetCurrentPrcb(); - + /* Get the P List First */ List = (PNPAGED_LOOKASIDE_LIST)Prcb->PPLookasideList[ListType].P; - + /* Attempt allocation */ List->L.TotalAllocates++; - DPRINT("Total allocates: %d\n", List->L.TotalAllocates); Irp = (PIRP)InterlockedPopEntrySList(&List->L.ListHead); - DPRINT("Alloc attempt on CPU list: %p\n", Irp); - + /* Check if the P List failed */ if (!Irp) { /* Let the balancer know */ List->L.AllocateMisses++; - DPRINT("Total misses: %d\n", List->L.AllocateMisses); - + /* Try the L List */ List = (PNPAGED_LOOKASIDE_LIST)Prcb->PPLookasideList[ListType].L; List->L.TotalAllocates++; Irp = (PIRP)InterlockedPopEntrySList(&List->L.ListHead); - DPRINT("Alloc attempt on SYS list: %p\n", Irp); - } - } - + } + } + /* Check if we have to use the pool */ if (!Irp) { - DPRINT("Using pool\n"); /* Did we try lookaside and fail? */ if (Flags & IRP_ALLOCATED_FIXED_SIZE) List->L.AllocateMisses++; - + /* Check if we shoudl charge quota */ if (ChargeQuota) { @@ -509,23 +497,22 @@ /* Allocate the IRP With no Quota charge */ Irp = ExAllocatePoolWithTag(NonPagedPool, Size, TAG_IRP); } - + /* Make sure it was sucessful */ - if (!Irp) return(NULL); + if (!Irp) return(NULL); } else { /* We have an IRP from Lookaside */ Flags |= IRP_LOOKASIDE_ALLOCATION; } - + /* Set Flag */ if (ChargeQuota) Flags |= IRP_QUOTA_CHARGED; - + /* Now Initialize it */ - DPRINT("irp allocated\n"); IoInitializeIrp(Irp, Size, StackSize); - + /* Set the Allocation Flags */ Irp->AllocationFlags = Flags;
@@ -535,21 +522,9 @@
/* * @implemented - * - * FUNCTION: Allocates and sets up an IRP to be sent to lower level drivers - * ARGUMENTS: - * MajorFunction = One of IRP_MJ_READ, IRP_MJ_WRITE, - * IRP_MJ_FLUSH_BUFFERS or IRP_MJ_SHUTDOWN - * DeviceObject = Device object to send the irp to - * Buffer = Buffer into which data will be read or written - * Length = Length in bytes of the irp to be allocated - * StartingOffset = Starting offset on the device - * IoStatusBlock (OUT) = Storage for the result of the operation - * RETURNS: The IRP allocated on success, or - * NULL on failure */ PIRP -STDCALL +NTAPI IoBuildAsynchronousFsdRequest(ULONG MajorFunction, PDEVICE_OBJECT DeviceObject, PVOID Buffer, @@ -561,11 +536,6 @@ PIO_STACK_LOCATION StackPtr; LOCK_OPERATION AccessType;
- DPRINT("IoBuildAsynchronousFsdRequest(MajorFunction %x, DeviceObject 0x%p, " - "Buffer 0x%p, Length %x, StartingOffset 0x%p, " - "IoStatusBlock 0x%p\n",MajorFunction,DeviceObject,Buffer,Length, - StartingOffset,IoStatusBlock); - /* Allocate IRP */ if (!(Irp = IoAllocateIrp(DeviceObject->StackSize, FALSE))) return Irp;
@@ -584,9 +554,8 @@ if (DeviceObject->Flags & DO_BUFFERED_IO) { /* Allocate the System Buffer */ - Irp->AssociatedIrp.SystemBuffer = ExAllocatePoolWithTag(NonPagedPool, - Length, - TAG_SYS_BUF); + Irp->AssociatedIrp.SystemBuffer = + ExAllocatePoolWithTag(NonPagedPool, Length, TAG_SYS_BUF);
/* Set flags */ Irp->Flags = IRP_BUFFERED_IO | IRP_DEALLOCATE_BUFFER; @@ -608,7 +577,6 @@ { /* Use an MDL for Direct I/O */ Irp->MdlAddress = MmCreateMdl(NULL, Buffer, Length); -
if (MajorFunction == IRP_MJ_READ) { @@ -657,7 +625,6 @@ }
/* Set the Current Thread and IOSB */ - if (!IoStatusBlock) KEBUGCHECK(0); /* Temporary to catch illegal ROS Drivers */ Irp->UserIosb = IoStatusBlock; Irp->Tail.Overlay.Thread = PsGetCurrentThread();
@@ -665,28 +632,11 @@ return Irp; }
- -/* - * @implemented - * - * FUNCTION: Allocates and sets up an IRP to be sent to drivers - * ARGUMENTS: - * IoControlCode = Device io control code - * DeviceObject = Device object to send the irp to - * InputBuffer = Buffer from which data will be read by the driver - * InputBufferLength = Length in bytes of the input buffer - * OutputBuffer = Buffer into which data will be written by the driver - * OutputBufferLength = Length in bytes of the output buffer - * InternalDeviceIoControl = Determines weather - * IRP_MJ_INTERNAL_DEVICE_CONTROL or - * IRP_MJ_DEVICE_CONTROL will be used - * Event = Event used to notify the caller of completion - * IoStatusBlock (OUT) = Storage for the result of the operation - * RETURNS: The IRP allocated on success, or - * NULL on failure +/* + * @implemented */ PIRP -STDCALL +NTAPI IoBuildDeviceIoControlRequest (ULONG IoControlCode, PDEVICE_OBJECT DeviceObject, PVOID InputBuffer, @@ -702,13 +652,6 @@ ULONG BufferLength; LOCK_OPERATION AccessType;
- DPRINT("IoBuildDeviceIoRequest(IoControlCode %x, DeviceObject 0x%p, " - "InputBuffer 0x%p, InputBufferLength %x, OutputBuffer 0x%p, " - "OutputBufferLength %x, InternalDeviceIoControl %x " - "Event 0x%p, IoStatusBlock 0x%p\n",IoControlCode,DeviceObject, - InputBuffer,InputBufferLength,OutputBuffer,OutputBufferLength, - InternalDeviceIoControl,Event,IoStatusBlock); - /* Allocate IRP */ if (!(Irp = IoAllocateIrp(DeviceObject->StackSize, FALSE))) return Irp;
@@ -717,29 +660,30 @@
/* Set the DevCtl Type */ StackPtr->MajorFunction = InternalDeviceIoControl ? - IRP_MJ_INTERNAL_DEVICE_CONTROL : IRP_MJ_DEVICE_CONTROL; + IRP_MJ_INTERNAL_DEVICE_CONTROL : + IRP_MJ_DEVICE_CONTROL;
/* Set the IOCTL Data */ StackPtr->Parameters.DeviceIoControl.IoControlCode = IoControlCode; StackPtr->Parameters.DeviceIoControl.InputBufferLength = InputBufferLength; - StackPtr->Parameters.DeviceIoControl.OutputBufferLength = OutputBufferLength; + StackPtr->Parameters.DeviceIoControl.OutputBufferLength = + OutputBufferLength;
/* Handle the Methods */ switch (IO_METHOD_FROM_CTL_CODE(IoControlCode)) { case METHOD_BUFFERED: - DPRINT("Using METHOD_BUFFERED!\n");
/* Select the right Buffer Length */ - BufferLength = InputBufferLength > OutputBufferLength ? InputBufferLength : OutputBufferLength; + BufferLength = InputBufferLength > OutputBufferLength ? + InputBufferLength : OutputBufferLength;
/* Make sure there is one */ if (BufferLength) { /* Allocate the System Buffer */ - Irp->AssociatedIrp.SystemBuffer = ExAllocatePoolWithTag(NonPagedPool, - BufferLength, - TAG_SYS_BUF); + Irp->AssociatedIrp.SystemBuffer = + ExAllocatePoolWithTag(NonPagedPool, BufferLength, TAG_SYS_BUF);
/* Fail if we couldn't */ if (Irp->AssociatedIrp.SystemBuffer == NULL) @@ -774,15 +718,15 @@
case METHOD_IN_DIRECT: case METHOD_OUT_DIRECT: - DPRINT("Using METHOD_IN/OUT DIRECT!\n");
/* Check if we got an input buffer */ if (InputBuffer) { /* Allocate the System Buffer */ - Irp->AssociatedIrp.SystemBuffer = ExAllocatePoolWithTag(NonPagedPool, - InputBufferLength, - TAG_SYS_BUF); + Irp->AssociatedIrp.SystemBuffer = + ExAllocatePoolWithTag(NonPagedPool, + InputBufferLength, + TAG_SYS_BUF);
/* Fail if we couldn't */ if (Irp->AssociatedIrp.SystemBuffer == NULL) @@ -861,7 +805,6 @@ }
/* Now write the Event and IoSB */ - if (!IoStatusBlock) KEBUGCHECK(0); /* Temporary to catch illegal ROS Drivers */ Irp->UserIosb = IoStatusBlock; Irp->UserEvent = Event;
@@ -875,23 +818,9 @@
/* * @implemented - * - * FUNCTION: Allocates and builds an IRP to be sent synchronously to lower - * level driver(s) - * ARGUMENTS: - * MajorFunction = Major function code, one of IRP_MJ_READ, - * IRP_MJ_WRITE, IRP_MJ_FLUSH_BUFFERS, IRP_MJ_SHUTDOWN - * DeviceObject = Target device object - * Buffer = Buffer containing data for a read or write - * Length = Length in bytes of the information to be transferred - * StartingOffset = Offset to begin the read/write from - * Event (OUT) = Will be set when the operation is complete - * IoStatusBlock (OUT) = Set to the status of the operation - * RETURNS: The IRP allocated on success, or - * NULL on failure */ PIRP -STDCALL +NTAPI IoBuildSynchronousFsdRequest(ULONG MajorFunction, PDEVICE_OBJECT DeviceObject, PVOID Buffer, @@ -902,11 +831,6 @@ { PIRP Irp;
- DPRINT("IoBuildSynchronousFsdRequest(MajorFunction %x, DeviceObject 0x%p, " - "Buffer 0x%p, Length %x, StartingOffset 0x%p, Event 0x%p, " - "IoStatusBlock 0x%p\n",MajorFunction,DeviceObject,Buffer,Length, - StartingOffset,Event,IoStatusBlock); - /* Do the big work to set up the IRP */ Irp = IoBuildAsynchronousFsdRequest(MajorFunction, DeviceObject, @@ -927,7 +851,7 @@ * @implemented */ BOOLEAN -STDCALL +NTAPI IoCancelIrp(PIRP Irp) { KIRQL oldlvl; @@ -951,16 +875,11 @@ return(TRUE); }
-/** +/* * @name IoCancelThreadIo - * - * Cancel all pending I/O request associated with specified thread. - * - * @param Thread - * Thread to cancel requests for. */ VOID -STDCALL +NTAPI IoCancelThreadIo(PETHREAD Thread) { PIRP Irp; @@ -977,7 +896,7 @@ /* Cancel it */ IoCancelIrp(Irp); } - + /* Wait 100 milliseconds */ Interval.QuadPart = -1000000;
@@ -1011,8 +930,9 @@ * @implemented */ NTSTATUS -STDCALL -IoCallDriver (PDEVICE_OBJECT DeviceObject, PIRP Irp) +NTAPI +IoCallDriver(PDEVICE_OBJECT DeviceObject, + PIRP Irp) { /* Call fast call */ return IofCallDriver(DeviceObject, Irp); @@ -1023,7 +943,7 @@ */ #undef IoCompleteRequest VOID -STDCALL +NTAPI IoCompleteRequest(PIRP Irp, CCHAR PriorityBoost) { @@ -1035,7 +955,7 @@ * @implemented */ VOID -STDCALL +NTAPI IoEnqueueIrp(IN PIRP Irp) { IoQueueThreadIrp(Irp); @@ -1043,20 +963,15 @@
/* * @implemented - * - * FUNCTION: Sends an IRP to the next lower driver */ NTSTATUS FASTCALL IofCallDriver(PDEVICE_OBJECT DeviceObject, PIRP Irp) - { PDRIVER_OBJECT DriverObject; PIO_STACK_LOCATION Param;
- DPRINT("IofCallDriver(DeviceObject 0x%p, Irp 0x%p)\n",DeviceObject,Irp); - /* Get the Driver Object */ DriverObject = DeviceObject->DriverObject;
@@ -1066,13 +981,12 @@ /* Get the current one */ Param = IoGetCurrentIrpStackLocation(Irp);
- DPRINT("IrpSp 0x0x%p\n", Param); - /* Get the Device Object */ Param->DeviceObject = DeviceObject;
/* Call it */ - return DriverObject->MajorFunction[Param->MajorFunction](DeviceObject, Irp); + return DriverObject->MajorFunction[Param->MajorFunction](DeviceObject, + Irp); }
#ifdef IoCompleteRequest @@ -1080,13 +994,6 @@ #endif /* * @implemented - * - * FUNCTION: Indicates the caller has finished all processing for a given - * I/O request and is returning the given IRP to the I/O manager - * ARGUMENTS: - * Irp = Irp to be cancelled - * PriorityBoost = Increment by which to boost the priority of the - * thread making the request */ VOID FASTCALL @@ -1099,9 +1006,6 @@ PETHREAD Thread = Irp->Tail.Overlay.Thread; NTSTATUS Status; PMDL Mdl; - - DPRINT("IofCompleteRequest(Irp 0x%p, PriorityBoost %d) Event 0x%p THread 0x%p\n", - Irp,PriorityBoost, Irp->UserEvent, PsGetCurrentThread());
ASSERT(KeGetCurrentIrql() <= DISPATCH_LEVEL); ASSERT(!Irp->CancelRoutine); @@ -1167,7 +1071,6 @@ ULONG MasterIrpCount; PIRP MasterIrp = Irp->AssociatedIrp.MasterIrp;
- DPRINT("Handling Associated IRP\n"); /* This should never happen! */ ASSERT(IsListEmpty(&Irp->ThreadListEntry));
@@ -1190,7 +1093,6 @@ /* Windows NT File System Internals, page 165 */ if (Irp->Flags & (IRP_PAGING_IO|IRP_CLOSE_OPERATION)) { - DPRINT("Handling Paging or Close I/O\n"); /* This should never happen! */ ASSERT(IsListEmpty(&Irp->ThreadListEntry));
@@ -1198,14 +1100,12 @@ if (Irp->Flags & (IRP_SYNCHRONOUS_PAGING_IO | IRP_CLOSE_OPERATION)) { /* Set the I/O Status and Signal the Event */ - DPRINT("Handling Sync Paging or Close I/O\n"); *Irp->UserIosb = Irp->IoStatus; KeSetEvent(Irp->UserEvent, PriorityBoost, FALSE);
/* Free the IRP for a Paging I/O Only, Close is handled by us */ if (Irp->Flags & IRP_SYNCHRONOUS_PAGING_IO) { - DPRINT("Handling Sync Paging I/O\n"); IoFreeIrp(Irp); } } @@ -1237,22 +1137,19 @@ Mdl = Irp->MdlAddress; while (Mdl) { - DPRINT("Unlocking MDL: 0x%p\n", Mdl); MmUnlockPages(Mdl); - Mdl = Mdl->Next; + Mdl = Mdl->Next; }
/* Check if we should exit because of a Deferred I/O (page 168) */ if (Irp->Flags & IRP_DEFER_IO_COMPLETION && !Irp->PendingReturned) { - DPRINT("Quick return\n"); return; }
/* Now queue the special APC */ if (!Irp->Cancel) { - DPRINT("KMODE APC QUEUE\n"); KeInitializeApc(&Irp->Tail.Apc, &Thread->Tcb, Irp->ApcEnvironment, @@ -1272,7 +1169,6 @@ if ((Thread = Irp->Tail.Overlay.Thread)) { /* Yes! There is still hope! */ - DPRINT("KMODE APC QUEUE\n"); KeInitializeApc(&Irp->Tail.Apc, &Thread->Tcb, Irp->ApcEnvironment, @@ -1298,7 +1194,7 @@ * @unimplemented */ BOOLEAN -STDCALL +NTAPI IoForwardIrpSynchronously(IN PDEVICE_OBJECT DeviceObject, IN PIRP Irp) { @@ -1308,13 +1204,9 @@
/* * @implemented - * - * FUNCTION: Releases a caller allocated irp - * ARGUMENTS: - * Irp = Irp to free */ VOID -STDCALL +NTAPI IoFreeIrp(PIRP Irp) { PNPAGED_LOOKASIDE_LIST List; @@ -1325,61 +1217,56 @@ if (!(Irp->AllocationFlags & IRP_ALLOCATED_FIXED_SIZE)) { /* Free it */ - DPRINT("Freeing pool IRP\n"); ExFreePool(Irp); } else { - DPRINT("Freeing Lookaside IRP\n"); - /* Check if this was a Big IRP */ if (Irp->StackCount != 1) { - DPRINT("Large IRP\n"); ListType = LookasideLargeIrpList; } - + /* Get the PRCB */ Prcb = KeGetCurrentPrcb(); - + /* Use the P List */ List = (PNPAGED_LOOKASIDE_LIST)Prcb->PPLookasideList[ListType].P; List->L.TotalFrees++; - + /* Check if the Free was within the Depth or not */ if (ExQueryDepthSList(&List->L.ListHead) >= List->L.Depth) { /* Let the balancer know */ List->L.FreeMisses++; - + /* Use the L List */ List = (PNPAGED_LOOKASIDE_LIST)Prcb->PPLookasideList[ListType].L; List->L.TotalFrees++;
/* Check if the Free was within the Depth or not */ if (ExQueryDepthSList(&List->L.ListHead) >= List->L.Depth) - { + { /* All lists failed, use the pool */ List->L.FreeMisses++; ExFreePool(Irp); Irp = NULL; } } - + /* The free was within dhe Depth */ if (Irp) { - InterlockedPushEntrySList(&List->L.ListHead, (PSINGLE_LIST_ENTRY)Irp); - } - } - - DPRINT("Free done\n"); -} - -/* - * @implemented - */ -PEPROCESS STDCALL + InterlockedPushEntrySList(&List->L.ListHead, + (PSINGLE_LIST_ENTRY)Irp); + } + } +} + +/* + * @implemented + */ +PEPROCESS NTAPI IoGetRequestorProcess(IN PIRP Irp) { return(Irp->Tail.Overlay.Thread->ThreadsProcess); @@ -1389,7 +1276,7 @@ * @implemented */ ULONG -STDCALL +NTAPI IoGetRequestorProcessId(IN PIRP Irp) { return (ULONG)(IoGetRequestorProcess(Irp)->UniqueProcessId); @@ -1399,7 +1286,7 @@ * @implemented */ NTSTATUS -STDCALL +NTAPI IoGetRequestorSessionId(IN PIRP Irp, OUT PULONG pSessionId) { @@ -1412,7 +1299,7 @@ * @implemented */ PIRP -STDCALL +NTAPI IoGetTopLevelIrp(VOID) { return (PIRP)PsGetCurrentThread()->TopLevelIrp; @@ -1420,22 +1307,14 @@
/* * @implemented - * - * FUNCTION: Initalizes an irp allocated by the caller - * ARGUMENTS: - * Irp = IRP to initalize - * PacketSize = Size in bytes of the IRP - * StackSize = Number of stack locations in the IRP */ VOID -STDCALL +NTAPI IoInitializeIrp(PIRP Irp, USHORT PacketSize, CCHAR StackSize) { ASSERT(Irp != NULL); - - DPRINT("IoInitializeIrp(StackSize %x, Irp 0x%p)\n",StackSize, Irp);
/* Clear it */ RtlZeroMemory(Irp, PacketSize); @@ -1450,28 +1329,13 @@
/* Initialize the Thread List */ InitializeListHead(&Irp->ThreadListEntry); - - DPRINT("Irp->Tail.Overlay.CurrentStackLocation 0x%p\n", Irp->Tail.Overlay.CurrentStackLocation); -} - -/* - * NAME EXPORTED - * IoIsOperationSynchronous@4 - * - * DESCRIPTION - * Check if the I/O operation associated with the given IRP - * is synchronous. - * - * ARGUMENTS - * Irp Packet to check. - * - * RETURN VALUE - * TRUE if Irp's operation is synchronous; otherwise FALSE. - * +} + +/* * @implemented */ BOOLEAN -STDCALL +NTAPI IoIsOperationSynchronous(IN PIRP Irp) { /* Check the flags */ @@ -1492,7 +1356,7 @@ * @unimplemented */ BOOLEAN -STDCALL +NTAPI IoIsValidNameGraftingBuffer(IN PIRP Irp, IN PREPARSE_DATA_BUFFER ReparseBuffer) { @@ -1502,17 +1366,9 @@
/* * @implemented - * - * FUNCTION: Allocates and initializes an irp to associated with a master irp - * ARGUMENTS: - * Irp = Master irp - * StackSize = Number of stack locations to be allocated in the irp - * RETURNS: The irp allocated - * NOTE: The caller is responsible for incrementing - * Irp->AssociatedIrp.IrpCount. */ PIRP -STDCALL +NTAPI IoMakeAssociatedIrp(PIRP Irp, CCHAR StackSize) { @@ -1538,7 +1394,7 @@ * @implemented */ NTSTATUS -STDCALL +NTAPI IoPageRead(PFILE_OBJECT FileObject, PMDL Mdl, PLARGE_INTEGER Offset, @@ -1548,9 +1404,6 @@ PIRP Irp; PIO_STACK_LOCATION StackPtr; PDEVICE_OBJECT DeviceObject; - - DPRINT("IoPageRead(FileObject 0x%p, Mdl 0x%p)\n", - FileObject, Mdl);
/* Get the Device Object */ DeviceObject = IoGetRelatedDeviceObject(FileObject); @@ -1567,7 +1420,10 @@ Irp->UserIosb = StatusBlock; Irp->UserEvent = Event; Irp->RequestorMode = KernelMode; - Irp->Flags = IRP_PAGING_IO | IRP_NOCACHE | IRP_SYNCHRONOUS_PAGING_IO | IRP_INPUT_OPERATION; + Irp->Flags = IRP_PAGING_IO | + IRP_NOCACHE | + IRP_SYNCHRONOUS_PAGING_IO | + IRP_INPUT_OPERATION; Irp->Tail.Overlay.OriginalFileObject = FileObject; Irp->Tail.Overlay.Thread = PsGetCurrentThread();
@@ -1585,7 +1441,7 @@ * @implemented */ VOID -STDCALL +NTAPI IoQueueThreadIrp(IN PIRP Irp) { KIRQL OldIrql; @@ -1609,7 +1465,7 @@ * Reference: Chris Cant's "Writing WDM Device Drivers" */ VOID -STDCALL +NTAPI IoReuseIrp(IN OUT PIRP Irp, IN NTSTATUS Status) { @@ -1630,7 +1486,7 @@ * @implemented */ VOID -STDCALL +NTAPI IoSetTopLevelIrp(IN PIRP Irp) { PsGetCurrentThread()->TopLevelIrp = (ULONG)Irp; @@ -1640,7 +1496,7 @@ * @implemented */ NTSTATUS -STDCALL +NTAPI IoSynchronousPageWrite(PFILE_OBJECT FileObject, PMDL Mdl, PLARGE_INTEGER Offset, @@ -1650,9 +1506,6 @@ PIRP Irp; PIO_STACK_LOCATION StackPtr; PDEVICE_OBJECT DeviceObject; - - DPRINT("IoSynchronousPageWrite(FileObject 0x%p, Mdl 0x%p)\n", - FileObject, Mdl);
/* Get the Device Object */ DeviceObject = IoGetRelatedDeviceObject(FileObject);
Propchange: trunk/reactos/ntoskrnl/io/irp.c ------------------------------------------------------------------------------ --- svn:needs-lock (original) +++ svn:needs-lock (removed) @@ -1,1 +1,0 @@ -*
-
ion＠svn.reactos.org