msfssup.c File Reference

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

Include dependency graph for msfssup.c:

Go to the source code of this file.

Macros
#define	NDEBUG

Functions
VOID NTAPI	MsfsInsertIrp (PIO_CSQ Csq, PIRP Irp)
VOID NTAPI	MsfsRemoveIrp (PIO_CSQ Csq, PIRP Irp)
PIRP NTAPI	MsfsPeekNextIrp (PIO_CSQ Csq, PIRP Irp, PVOID PeekContext)
VOID NTAPI	MsfsAcquireLock (PIO_CSQ Csq, PKIRQL Irql)
VOID NTAPI	MsfsReleaseLock (PIO_CSQ Csq, KIRQL Irql)
VOID NTAPI	MsfsCompleteCanceledIrp (PIO_CSQ Csq, PIRP Irp)
VOID NTAPI	MsfsTimeout (PKDPC Dpc, PVOID DeferredContext, PVOID SystemArgument1, PVOID SystemArgument2)

Macro Definition Documentation

NDEBUG

#define NDEBUG

Definition at line 12 of file msfssup.c.

Function Documentation

MsfsAcquireLock()

VOID NTAPI MsfsAcquireLock	(	PIO_CSQ	Csq,
		PKIRQL	Irql
	)

Definition at line 80 of file msfssup.c.

{
    PMSFS_FCB Fcb;
 
    Fcb = CONTAINING_RECORD(Csq, MSFS_FCB, CancelSafeQueue);
    KeAcquireSpinLock(&Fcb->QueueLock, Irql);
}

MsfsCompleteCanceledIrp()

VOID NTAPI MsfsCompleteCanceledIrp	(	PIO_CSQ	Csq,
		PIRP	Irp
	)

Definition at line 99 of file msfssup.c.

{
 
    UNREFERENCED_PARAMETER(Csq);
 
    Irp->IoStatus.Status = STATUS_CANCELLED;
    Irp->IoStatus.Information = 0;
    IoCompleteRequest(Irp, IO_NO_INCREMENT);
}

MsfsInsertIrp()

VOID NTAPI MsfsInsertIrp	(	PIO_CSQ	Csq,
		PIRP	Irp
	)

Definition at line 18 of file msfssup.c.

{
    PMSFS_FCB Fcb;
 
    Fcb = CONTAINING_RECORD(Csq, MSFS_FCB, CancelSafeQueue);
    InsertTailList(&Fcb->PendingIrpQueue, &Irp->Tail.Overlay.ListEntry);
}

MsfsPeekNextIrp()

PIRP NTAPI MsfsPeekNextIrp	(	PIO_CSQ	Csq,
		PIRP	Irp,
		PVOID	PeekContext
	)

Definition at line 35 of file msfssup.c.

{
    PMSFS_FCB Fcb;
    PIRP NextIrp = NULL;
    PLIST_ENTRY NextEntry, ListHead;
    PIO_STACK_LOCATION Stack;
 
    Fcb = CONTAINING_RECORD(Csq, MSFS_FCB, CancelSafeQueue);
 
    ListHead = &Fcb->PendingIrpQueue;
 
    if (Irp == NULL)
    {
        NextEntry = ListHead->Flink;
    }
    else
    {
        NextEntry = Irp->Tail.Overlay.ListEntry.Flink;
    }
 
    for (; NextEntry != ListHead; NextEntry = NextEntry->Flink)
    {
        NextIrp = CONTAINING_RECORD(NextEntry, IRP, Tail.Overlay.ListEntry);
 
        Stack = IoGetCurrentIrpStackLocation(NextIrp);
 
        if (PeekContext)
        {
            if (Stack->FileObject == (PFILE_OBJECT)PeekContext)
            {
                break;
            }
        }
        else
        {
            break;
        }
 
        NextIrp = NULL;
    }
 
    return NextIrp;
}

MsfsReleaseLock()

VOID NTAPI MsfsReleaseLock	(	PIO_CSQ	Csq,
		KIRQL	Irql
	)

Definition at line 90 of file msfssup.c.

{
    PMSFS_FCB Fcb;
 
    Fcb = CONTAINING_RECORD(Csq, MSFS_FCB, CancelSafeQueue);
    KeReleaseSpinLock(&Fcb->QueueLock, Irql);
}

MsfsRemoveIrp()

VOID NTAPI MsfsRemoveIrp	(	PIO_CSQ	Csq,
		PIRP	Irp
	)

Definition at line 27 of file msfssup.c.

{
    UNREFERENCED_PARAMETER(Csq);
 
    RemoveEntryList(&Irp->Tail.Overlay.ListEntry);
}

MsfsTimeout()

VOID NTAPI MsfsTimeout	(	PKDPC	Dpc,
		PVOID	DeferredContext,
		PVOID	SystemArgument1,
		PVOID	SystemArgument2
	)

Definition at line 110 of file msfssup.c.

{
    PMSFS_DPC_CTX Context;
    PIRP Irp;
 
    Context = (PMSFS_DPC_CTX)DeferredContext;
 
    /* Try to get the IRP */
    Irp = IoCsqRemoveIrp(Context->Csq, &Context->CsqContext);
    if (Irp != NULL)
    {
        /* It timed out, complete it (it's ours) and free context */
        Irp->IoStatus.Status = STATUS_IO_TIMEOUT;
        IoCompleteRequest(Irp, IO_NO_INCREMENT);
        ExFreePoolWithTag(Context, 'NFsM');
    }
    else
    {
        /* We were racing with writing and failed, signal we're done */
        KeSetEvent(&Context->Event, IO_NO_INCREMENT, FALSE);
    }
}