dispatch.c File Reference

#include "ntfs.h"
#include <debug.h>

Include dependency graph for dispatch.c:

Go to the source code of this file.

Macros
#define	NDEBUG

Functions
static NTSTATUS	NtfsQueueRequest (PNTFS_IRP_CONTEXT IrpContext)
static NTSTATUS	NtfsDispatch (PNTFS_IRP_CONTEXT IrpContext)
static VOID NTAPI	NtfsDoRequest (PVOID IrpContext)
NTSTATUS NTAPI	NtfsFsdDispatch (PDEVICE_OBJECT DeviceObject, PIRP Irp)

Variables
static LONG	QueueCount = 0
static WORKER_THREAD_ROUTINE	NtfsDoRequest

Macro Definition Documentation

NDEBUG

#define NDEBUG

Definition at line 31 of file dispatch.c.

Function Documentation

NtfsDispatch()

static NTSTATUS NtfsDispatch ( PNTFS_IRP_CONTEXT  IrpContext )

static

Definition at line 59 of file dispatch.c.

{
    PIRP Irp = IrpContext->Irp;
    NTSTATUS Status = STATUS_UNSUCCESSFUL;
    BOOLEAN TopLevel;
 
    TRACE_(NTFS, "NtfsDispatch()\n");
 
    FsRtlEnterFileSystem();
 
    TopLevel = NtfsIsIrpTopLevel(Irp);
 
    switch (IrpContext->MajorFunction)
    {
        case IRP_MJ_QUERY_VOLUME_INFORMATION:
            Status = NtfsQueryVolumeInformation(IrpContext);
            break;
 
        case IRP_MJ_SET_VOLUME_INFORMATION:
            Status = NtfsSetVolumeInformation(IrpContext);
            break;
 
        case IRP_MJ_QUERY_INFORMATION:
            Status = NtfsQueryInformation(IrpContext);
            break;
 
        case IRP_MJ_SET_INFORMATION:
            if (!NtfsGlobalData->EnableWriteSupport)
            {
                DPRINT1("NTFS write-support is EXPERIMENTAL and is disabled by default!\n");
                Status = STATUS_ACCESS_DENIED;
            }
            else
            {
                Status = NtfsSetInformation(IrpContext);
            }
            break;
 
        case IRP_MJ_DIRECTORY_CONTROL:
            Status = NtfsDirectoryControl(IrpContext);
            break;
 
        case IRP_MJ_READ:
            Status = NtfsRead(IrpContext);
            break;
 
        case IRP_MJ_DEVICE_CONTROL:
            Status = NtfsDeviceControl(IrpContext);
             break;
 
        case IRP_MJ_WRITE:
            if (!NtfsGlobalData->EnableWriteSupport)
            {
                DPRINT1("NTFS write-support is EXPERIMENTAL and is disabled by default!\n");
                Status = STATUS_ACCESS_DENIED;
            }
            else
            {
                Status = NtfsWrite(IrpContext);
            }
            break;
 
        case IRP_MJ_CLOSE:
            Status = NtfsClose(IrpContext);
            break;
 
        case IRP_MJ_CLEANUP:
            Status = NtfsCleanup(IrpContext);
            break;
 
        case IRP_MJ_CREATE:
            Status = NtfsCreate(IrpContext);
            break;
 
        case IRP_MJ_FILE_SYSTEM_CONTROL:
            Status = NtfsFileSystemControl(IrpContext);
            break;
 
        case IRP_MJ_FLUSH_BUFFERS:
            Status = NtfsFlushBuffers(IrpContext);
            break;
 
        case IRP_MJ_LOCK_CONTROL:
            Status = NtfsLockControl(IrpContext);
            break;
    }
 
    ASSERT((!(IrpContext->Flags & IRPCONTEXT_COMPLETE) && !(IrpContext->Flags & IRPCONTEXT_QUEUE)) ||
           ((IrpContext->Flags & IRPCONTEXT_COMPLETE) && !(IrpContext->Flags & IRPCONTEXT_QUEUE)) ||
           (!(IrpContext->Flags & IRPCONTEXT_COMPLETE) && (IrpContext->Flags & IRPCONTEXT_QUEUE)));
 
    if (IrpContext->Flags & IRPCONTEXT_COMPLETE)
    {
        Irp->IoStatus.Status = Status;
        IoCompleteRequest(Irp, IrpContext->PriorityBoost);
    }
 
    if (IrpContext->Flags & IRPCONTEXT_QUEUE)
    {
        /* Reset our status flags before queueing the IRP */
        IrpContext->Flags |= IRPCONTEXT_COMPLETE;
        IrpContext->Flags &= ~IRPCONTEXT_QUEUE;
        Status = NtfsQueueRequest(IrpContext);
    }
    else
    {
        ExFreeToNPagedLookasideList(&NtfsGlobalData->IrpContextLookasideList, IrpContext);
    }
 
    /* Cc and Mm set their own top level IRP around paging I/O, leave theirs alone */
    if (TopLevel)
        IoSetTopLevelIrp(NULL);
 
    FsRtlExitFileSystem();
 
    return Status;
}

Referenced by NtfsDoRequest(), and NtfsFsdDispatch().

NtfsDoRequest()

static VOID NTAPI NtfsDoRequest ( PVOID  IrpContext )

static

Definition at line 180 of file dispatch.c.

{
    InterlockedDecrement(&QueueCount);
    DPRINT("NtfsDoRequest(IrpContext %p), MajorFunction %x, %d\n",
           IrpContext, ((PNTFS_IRP_CONTEXT)IrpContext)->MajorFunction, QueueCount);
    NtfsDispatch((PNTFS_IRP_CONTEXT)IrpContext);
}

NtfsFsdDispatch()

NTSTATUS NTAPI NtfsFsdDispatch	(	PDEVICE_OBJECT	DeviceObject,
		PIRP	Irp
	)

Definition at line 197 of file dispatch.c.

{
    PNTFS_IRP_CONTEXT IrpContext = NULL;
    NTSTATUS Status;
 
    TRACE_(NTFS, "NtfsFsdDispatch()\n");
 
    IrpContext = NtfsAllocateIrpContext(DeviceObject, Irp);
    if (IrpContext == NULL)
    {
        Status = STATUS_INSUFFICIENT_RESOURCES;
        Irp->IoStatus.Status = Status;
        IoCompleteRequest(Irp, IO_NO_INCREMENT);
    }
    else
    {
        Status = NtfsDispatch(IrpContext);
    }
 
     return Status;
}

NtfsQueueRequest()

static NTSTATUS NtfsQueueRequest ( PNTFS_IRP_CONTEXT  IrpContext )

static

Definition at line 42 of file dispatch.c.

{
    InterlockedIncrement(&QueueCount);
    DPRINT("NtfsQueueRequest(IrpContext %p), %d\n", IrpContext, QueueCount);
 
    ASSERT(!(IrpContext->Flags & IRPCONTEXT_QUEUE) &&
           (IrpContext->Flags & IRPCONTEXT_COMPLETE));
    IrpContext->Flags |= IRPCONTEXT_CANWAIT;
    IoMarkIrpPending(IrpContext->Irp);
    ExInitializeWorkItem(&IrpContext->WorkQueueItem, NtfsDoRequest, IrpContext);
    ExQueueWorkItem(&IrpContext->WorkQueueItem, CriticalWorkQueue);
 
    return STATUS_PENDING;
}

Referenced by NtfsDispatch().

Variable Documentation

NtfsDoRequest

WORKER_THREAD_ROUTINE NtfsDoRequest

static

Definition at line 38 of file dispatch.c.

Referenced by NtfsQueueRequest().

QueueCount

LONG QueueCount = 0

static

Definition at line 34 of file dispatch.c.

Referenced by FxIoQueue::GetState(), NtfsDoRequest(), and NtfsQueueRequest().