pin_wavert.cpp File Reference

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

Include dependency graph for pin_wavert.cpp:

Go to the source code of this file.

Classes
class	CPortPinWaveRT
struct	SETSTREAM_CONTEXT

Macros
#define	NDEBUG

Typedefs
typedef struct SETSTREAM_CONTEXT *	PSETSTREAM_CONTEXT

Functions
VOID NTAPI	CloseStreamRoutine (IN PDEVICE_OBJECT DeviceObject, IN PVOID Context)
NTSTATUS	NewPortPinWaveRT (OUT IPortPinWaveRT **OutPin)

Macro Definition Documentation

NDEBUG

#define NDEBUG

Definition at line 11 of file pin_wavert.cpp.

Typedef Documentation

PSETSTREAM_CONTEXT

typedef struct SETSTREAM_CONTEXT * PSETSTREAM_CONTEXT

Function Documentation

CloseStreamRoutine()

VOID NTAPI CloseStreamRoutine	(	IN PDEVICE_OBJECT	DeviceObject,
		IN PVOID	Context
	)

Definition at line 359 of file pin_wavert.cpp.

{
    PMINIPORTWAVERTSTREAM Stream;
    NTSTATUS Status;
    ISubdevice *ISubDevice;
    PSUBDEVICE_DESCRIPTOR Descriptor;
    CPortPinWaveRT * This;
    PCLOSESTREAM_CONTEXT Ctx = (PCLOSESTREAM_CONTEXT)Context;
 
    This = (CPortPinWaveRT*)Ctx->Pin;
 
    if (This->m_Stream)
    {
        if (This->m_State != KSSTATE_STOP)
        {
            This->m_Stream->SetState(KSSTATE_STOP);
            KeStallExecutionProcessor(10);
        }
    }
 
    Status = This->m_Port->QueryInterface(IID_ISubdevice, (PVOID*)&ISubDevice);
    if (NT_SUCCESS(Status))
    {
        Status = ISubDevice->GetDescriptor(&Descriptor);
        if (NT_SUCCESS(Status))
        {
            Descriptor->Factory.Instances[This->m_ConnectDetails->PinId].CurrentPinInstanceCount--;
        }
        ISubDevice->Release();
    }
 
    if (This->m_Format)
    {
        FreeItem(This->m_Format, TAG_PORTCLASS);
        This->m_Format = NULL;
    }
 
    if (This->m_IrpQueue)
    {
        This->m_IrpQueue->Release();
    }
 
    // complete the irp
    Ctx->Irp->IoStatus.Information = 0;
    Ctx->Irp->IoStatus.Status = STATUS_SUCCESS;
    IoCompleteRequest(Ctx->Irp, IO_NO_INCREMENT);
 
    // free the work item
    IoFreeWorkItem(Ctx->WorkItem);
 
    // free work item ctx
    FreeItem(Ctx, TAG_PORTCLASS);
 
    if (This->m_Stream)
    {
        Stream = This->m_Stream;
        This->m_Stream = NULL;
        DPRINT("Closing stream at Irql %u\n", KeGetCurrentIrql());
        Stream->Release();
    }
}

NewPortPinWaveRT()

NTSTATUS NewPortPinWaveRT

(

OUT IPortPinWaveRT **

OutPin

)

Definition at line 670 of file pin_wavert.cpp.

{
    CPortPinWaveRT * This;
 
    This = new(NonPagedPool, TAG_PORTCLASS) CPortPinWaveRT(NULL);
    if (!This)
        return STATUS_INSUFFICIENT_RESOURCES;
 
    This->AddRef();
 
    // store result
    *OutPin = (PPORTPINWAVERT)This;
 
    return STATUS_SUCCESS;
}