io_x.h File Reference

This graph shows which files directly or indirectly include this file:

Go to the source code of this file.

Functions
static __inline NTSTATUS	IopLockFileObject (_In_ PFILE_OBJECT FileObject, _In_ KPROCESSOR_MODE WaitMode)
static __inline VOID	IopUnlockFileObject (IN PFILE_OBJECT FileObject)
FORCEINLINE VOID	IopQueueIrpToThread (IN PIRP Irp)
FORCEINLINE VOID	IopUnQueueIrpFromThread (IN PIRP Irp)
static __inline VOID	IopUpdateOperationCount (IN IOP_TRANSFER_TYPE Type)
static __inline VOID	IopUpdateTransferCount (IN IOP_TRANSFER_TYPE Type, IN ULONG TransferCount)
static __inline BOOLEAN	IopValidateOpenPacket (IN POPEN_PACKET OpenPacket)

Function Documentation

IopLockFileObject()

static __inline NTSTATUS IopLockFileObject ( _In_ PFILE_OBJECT  FileObject, _In_ KPROCESSOR_MODE  WaitMode  )

static

Definition at line 12 of file io_x.h.

{
    BOOLEAN LockFailed;
 
    /* Lock the FO and check for contention */
    if (InterlockedExchange((PLONG)&FileObject->Busy, TRUE) == FALSE)
    {
        ObReferenceObject(FileObject);
        return STATUS_SUCCESS;
    }
    else
    {
        return IopAcquireFileObjectLock(FileObject,
                                        WaitMode,
                                        BooleanFlagOn(FileObject->Flags, FO_ALERTABLE_IO),
                                        &LockFailed);
    }
}

Referenced by IopCloseFile(), IopDeviceFsIoControl(), IopGetSetSecurityObject(), IopQueryDeviceInformation(), IoSetInformation(), NtFlushBuffersFile(), NtLockFile(), NtNotifyChangeDirectoryFile(), NtQueryDirectoryFile(), NtQueryInformationFile(), NtQueryVolumeInformationFile(), NtReadFile(), NtSetInformationFile(), NtSetVolumeInformationFile(), NtUnlockFile(), and NtWriteFile().

IopQueueIrpToThread()

FORCEINLINE VOID IopQueueIrpToThread

(

IN PIRP

Irp

)

Definition at line 49 of file io_x.h.

{
    PETHREAD Thread = Irp->Tail.Overlay.Thread;
 
    /* Disable special kernel APCs so we can't race with IopCompleteRequest.
     * IRP's thread must be the current thread */
    KeEnterGuardedRegionThread(&Thread->Tcb);
 
    /* Insert it into the list */
    InsertHeadList(&Thread->IrpList, &Irp->ThreadListEntry);
 
    /* Leave the guarded region */
    KeLeaveGuardedRegionThread(&Thread->Tcb);
}

Referenced by IoCancelFileOpen(), IopCloseFile(), IopDeleteFile(), IopGetFileInformation(), IopGetSetSecurityObject(), IopParseDevice(), IopPerformSynchronousRequest(), IopQueryDeviceInformation(), IoQueueThreadIrp(), IoSetInformation(), NtQueryInformationFile(), and NtSetInformationFile().

IopUnlockFileObject()

static __inline VOID IopUnlockFileObject ( IN PFILE_OBJECT  FileObject )

static

Definition at line 36 of file io_x.h.

{
    /* Unlock the FO and wake any waiters up */
    NT_VERIFY(InterlockedExchange((PLONG)&FileObject->Busy, FALSE) == TRUE);
    if (FileObject->Waiters)
    {
        KeSetEvent(&FileObject->Lock, IO_NO_INCREMENT, FALSE);
    }
    ObDereferenceObject(FileObject);
}

Referenced by IopCleanupAfterException(), IopCleanupFailedIrp(), IopCloseFile(), IopDeviceFsIoControl(), IopGetSetSecurityObject(), IopPerformSynchronousRequest(), IopQueryDeviceInformation(), IoSetInformation(), NtQueryInformationFile(), NtQueryVolumeInformationFile(), NtReadFile(), NtSetInformationFile(), and NtWriteFile().

IopUnQueueIrpFromThread()

FORCEINLINE VOID IopUnQueueIrpFromThread

(

IN PIRP

Irp

)

Definition at line 66 of file io_x.h.

{
    /* Special kernel APCs must be disabled so we can't race with
     * IopCompleteRequest (or because we are called from there) */
    ASSERT(KeAreAllApcsDisabled());
 
    /* Remove it from the list and reset it */
    if (IsListEmpty(&Irp->ThreadListEntry))
        return;
    RemoveEntryList(&Irp->ThreadListEntry);
    InitializeListHead(&Irp->ThreadListEntry);
}

Referenced by IoCancelFileOpen(), IopCloseFile(), IopCompleteRequest(), IopDeleteFile(), and IopParseDevice().

IopUpdateOperationCount()

static __inline VOID IopUpdateOperationCount ( IN IOP_TRANSFER_TYPE  Type )

static

Definition at line 82 of file io_x.h.

{
    PLARGE_INTEGER CountToChange;
 
    /* Make sure I/O operations are being counted */
    if (IoCountOperations)
    {
        if (Type == IopReadTransfer)
        {
            /* Increase read count */
            IoReadOperationCount++;
            CountToChange = &PsGetCurrentProcess()->ReadOperationCount;
        }
        else if (Type == IopWriteTransfer)
        {
            /* Increase write count */
            IoWriteOperationCount++;
            CountToChange = &PsGetCurrentProcess()->WriteOperationCount;
        }
        else
        {
            /* Increase other count */
            IoOtherOperationCount++;
            CountToChange = &PsGetCurrentProcess()->OtherOperationCount;
        }
 
        /* Increase the process-wide count */
        ExInterlockedAddLargeStatistic(CountToChange, 1);
    }
}

Referenced by IopCloseFile(), IopCreateFile(), IopGetSetSecurityObject(), IopPerformSynchronousRequest(), IopQueryAttributesFile(), NtCancelIoFile(), NtDeleteFile(), NtQueryInformationFile(), NtReadFile(), NtSetInformationFile(), and NtWriteFile().

IopUpdateTransferCount()

static __inline VOID IopUpdateTransferCount ( IN IOP_TRANSFER_TYPE  Type, IN ULONG  TransferCount  )

static

Definition at line 116 of file io_x.h.

{
    PLARGE_INTEGER CountToChange;
    PLARGE_INTEGER TransferToChange;
 
    /* Make sure I/O operations are being counted */
    if (IoCountOperations)
    {
        if (Type == IopReadTransfer)
        {
            /* Increase read count */
            CountToChange = &PsGetCurrentProcess()->ReadTransferCount;
            TransferToChange = &IoReadTransferCount;
        }
        else if (Type == IopWriteTransfer)
        {
            /* Increase write count */
            CountToChange = &PsGetCurrentProcess()->WriteTransferCount;
            TransferToChange = &IoWriteTransferCount;
        }
        else
        {
            /* Increase other count */
            CountToChange = &PsGetCurrentProcess()->OtherTransferCount;
            TransferToChange = &IoOtherTransferCount;
        }
 
        /* Increase the process-wide count */
        ExInterlockedAddLargeStatistic(CountToChange, TransferCount);
 
        /* Increase global count */
        ExInterlockedAddLargeStatistic(TransferToChange, TransferCount);
    }
}

Referenced by IopCompleteRequest(), NtReadFile(), NtSetInformationFile(), and NtWriteFile().

IopValidateOpenPacket()

static __inline BOOLEAN IopValidateOpenPacket ( IN POPEN_PACKET  OpenPacket )

static

Definition at line 154 of file io_x.h.

{
    /* Validate the packet */
    if (!(OpenPacket) ||
        (OpenPacket->Type != IO_TYPE_OPEN_PACKET) ||
        (OpenPacket->Size != sizeof(OPEN_PACKET)))
    {
        /* Fail */
        return FALSE;
    }
 
    /* Good packet */
    return TRUE;
}

Referenced by IopParseDevice(), and IopParseFile().