irpstream.cpp File Reference

#include "private.hpp"
#include <debug.h>

Include dependency graph for irpstream.cpp:

Go to the source code of this file.

Classes
class	CIrpQueue
struct	KSSTREAM_TAG
struct	KSSTREAM_DATA

Macros
#define	NDEBUG
#define	STREAM_DATA_OFFSET   (0)

Typedefs
typedef struct KSSTREAM_TAG *	PKSSTREAM_TAG
typedef struct KSSTREAM_DATA *	PKSSTREAM_DATA

Functions
static PIRP	RemoveHeadList_IRP (IN OUT PLIST_ENTRY QueueHead)
NTSTATUS NTAPI	NewIrpQueue (IN IIrpQueue **Queue)

Macro Definition Documentation

NDEBUG

#define NDEBUG

Definition at line 11 of file irpstream.cpp.

STREAM_DATA_OFFSET

#define STREAM_DATA_OFFSET   (0)

Definition at line 84 of file irpstream.cpp.

Typedef Documentation

PKSSTREAM_DATA

typedef struct KSSTREAM_DATA * PKSSTREAM_DATA

PKSSTREAM_TAG

typedef struct KSSTREAM_TAG * PKSSTREAM_TAG

Function Documentation

NewIrpQueue()

NTSTATUS NTAPI NewIrpQueue

(

IN IIrpQueue **

Queue

)

Definition at line 864 of file irpstream.cpp.

{
    CIrpQueue *This = new(NonPagedPool, TAG_PORTCLASS)CIrpQueue(NULL);
    if (!This)
        return STATUS_INSUFFICIENT_RESOURCES;
 
    This->AddRef();
 
    *Queue = (IIrpQueue*)This;
    return STATUS_SUCCESS;
}

RemoveHeadList_IRP()

static PIRP RemoveHeadList_IRP ( IN OUT PLIST_ENTRY  QueueHead )

static

Definition at line 16 of file irpstream.cpp.

{
    PIRP Irp;
    PLIST_ENTRY CurEntry;
 
    for (CurEntry = QueueHead->Flink; CurEntry != QueueHead; CurEntry = CurEntry->Flink)
    {
        /* Get the IRP offset */
        Irp = (PIRP)CONTAINING_RECORD(CurEntry, IRP, Tail.Overlay.ListEntry);
 
        /* Remove the cancel routine */
        if (IoSetCancelRoutine(Irp, NULL))
        {
            /* Remove the IRP from the list and return it */
            RemoveEntryList(&Irp->Tail.Overlay.ListEntry);
            return Irp;
        }
    }
 
    /* no non canceled irp has been found */
    return NULL;
}