CPortPinWaveRT Class Reference

Inheritance diagram for CPortPinWaveRT:

Collaboration diagram for CPortPinWaveRT:

Public Member Functions
STDMETHODIMP	QueryInterface (REFIID InterfaceId, PVOID *Interface)
	STDMETHODIMP_ (ULONG) AddRef()
	STDMETHODIMP_ (ULONG) Release()
	CPortPinWaveRT (IUnknown *OuterUnknown)
virtual	~CPortPinWaveRT ()

Public Attributes
	IMP_IPortPinWaveRT

Protected Member Functions
NTSTATUS NTAPI	HandleKsProperty (IN PIRP Irp)
NTSTATUS NTAPI	HandleKsStream (IN PIRP Irp)
VOID NTAPI	SetStreamState (IN KSSTATE State)

Protected Attributes
IPortWaveRT *	m_Port
IPortFilterWaveRT *	m_Filter
KSPIN_DESCRIPTOR *	m_KsPinDescriptor
PMINIPORTWAVERT	m_Miniport
PMINIPORTWAVERTSTREAM	m_Stream
PPORTWAVERTSTREAM	m_PortStream
KSSTATE	m_State
PKSDATAFORMAT	m_Format
KSPIN_CONNECT *	m_ConnectDetails
PVOID	m_CommonBuffer
ULONG	m_CommonBufferSize
ULONG	m_CommonBufferOffset
IIrpQueue *	m_IrpQueue
BOOL	m_Capture
ULONG	m_TotalPackets
ULONG	m_PreCompleted
ULONG	m_PostCompleted
ULONGLONG	m_Delay
MEMORY_CACHING_TYPE	m_CacheType
PMDL	m_Mdl
LONG	m_Ref

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

Detailed Description

Definition at line 17 of file pin_wavert.cpp.

Constructor & Destructor Documentation

CPortPinWaveRT()

CPortPinWaveRT::CPortPinWaveRT ( IUnknown *  OuterUnknown )

inline

Definition at line 39 of file pin_wavert.cpp.

{}

~CPortPinWaveRT()

virtual CPortPinWaveRT::~CPortPinWaveRT ( )

inlinevirtual

Definition at line 40 of file pin_wavert.cpp.

{}

Member Function Documentation

HandleKsProperty()

NTSTATUS NTAPI CPortPinWaveRT::HandleKsProperty ( IN PIRP  Irp )

protected

Definition at line 128 of file pin_wavert.cpp.

{
    PKSPROPERTY Property;
    NTSTATUS Status;
    UNICODE_STRING GuidString;
    PIO_STACK_LOCATION IoStack;

    IoStack = IoGetCurrentIrpStackLocation(Irp);

    DPRINT("IPortPinWave_HandleKsProperty entered\n");

    if (IoStack->Parameters.DeviceIoControl.InputBufferLength < sizeof(KSPROPERTY))
    {
        Irp->IoStatus.Information = 0;
        Irp->IoStatus.Status = STATUS_INVALID_PARAMETER;
        IoCompleteRequest(Irp, IO_NO_INCREMENT);
        return STATUS_INVALID_PARAMETER;
    }

    Property = (PKSPROPERTY)IoStack->Parameters.DeviceIoControl.Type3InputBuffer;

    if (IsEqualGUIDAligned(Property->Set, KSPROPSETID_Connection))
    {
        if (Property->Id == KSPROPERTY_CONNECTION_STATE)
        {
            PKSSTATE State = (PKSSTATE)Irp->UserBuffer;

            if (IoStack->Parameters.DeviceIoControl.OutputBufferLength < sizeof(KSSTATE))
            {
                Irp->IoStatus.Information = sizeof(KSSTATE);
                Irp->IoStatus.Status = STATUS_BUFFER_TOO_SMALL;
                IoCompleteRequest(Irp, IO_NO_INCREMENT);
                return STATUS_BUFFER_TOO_SMALL;
            }

            if (Property->Flags & KSPROPERTY_TYPE_SET)
            {
                Status = STATUS_UNSUCCESSFUL;
                Irp->IoStatus.Information = 0;

                if (m_Stream)
                {
                    Status = m_Stream->SetState(*State);

                    DPRINT("Setting state %u %x\n", *State, Status);
                    if (NT_SUCCESS(Status))
                    {
                        m_State = *State;
                    }
                }
                Irp->IoStatus.Status = Status;
                IoCompleteRequest(Irp, IO_NO_INCREMENT);
                return Status;
            }
            else if (Property->Flags & KSPROPERTY_TYPE_GET)
            {
                *State = m_State;
                Irp->IoStatus.Information = sizeof(KSSTATE);
                Irp->IoStatus.Status = STATUS_SUCCESS;
                IoCompleteRequest(Irp, IO_NO_INCREMENT);
                return STATUS_SUCCESS;
            }
        }
        else if (Property->Id == KSPROPERTY_CONNECTION_DATAFORMAT)
        {
            PKSDATAFORMAT DataFormat = (PKSDATAFORMAT)Irp->UserBuffer;
            if (Property->Flags & KSPROPERTY_TYPE_SET)
            {
                PKSDATAFORMAT NewDataFormat;
                if (!RtlCompareMemory(DataFormat, m_Format, DataFormat->FormatSize))
                {
                    Irp->IoStatus.Information = DataFormat->FormatSize;
                    Irp->IoStatus.Status = STATUS_SUCCESS;
                    IoCompleteRequest(Irp, IO_NO_INCREMENT);
                    return STATUS_SUCCESS;
                }

                NewDataFormat = (PKSDATAFORMAT)AllocateItem(NonPagedPool, DataFormat->FormatSize, TAG_PORTCLASS);
                if (!NewDataFormat)
                {
                    Irp->IoStatus.Information = 0;
                    Irp->IoStatus.Status = STATUS_NO_MEMORY;
                    IoCompleteRequest(Irp, IO_NO_INCREMENT);
                    return STATUS_NO_MEMORY;
                }
                RtlMoveMemory(NewDataFormat, DataFormat, DataFormat->FormatSize);

                if (m_Stream)
                {
#if 0
                    ASSERT(KeGetCurrentIrql() == PASSIVE_LEVEL);
                    ASSERT(NewDataFormat->FormatSize == sizeof(KSDATAFORMAT_WAVEFORMATEX));
                    ASSERT(IsEqualGUIDAligned(&((PKSDATAFORMAT_WAVEFORMATEX)NewDataFormat)->DataFormat.MajorFormat, &KSDATAFORMAT_TYPE_AUDIO));
                    ASSERT(IsEqualGUIDAligned(&((PKSDATAFORMAT_WAVEFORMATEX)NewDataFormat)->DataFormat.SubFormat, &KSDATAFORMAT_SUBTYPE_PCM));
                    ASSERT(IsEqualGUIDAligned(&((PKSDATAFORMAT_WAVEFORMATEX)NewDataFormat)->DataFormat.Specifier, &KSDATAFORMAT_SPECIFIER_WAVEFORMATEX));

                    ASSERT(m_State == KSSTATE_STOP);
#endif
                    DPRINT("NewDataFormat: Channels %u Bits %u Samples %u\n", ((PKSDATAFORMAT_WAVEFORMATEX)NewDataFormat)->WaveFormatEx.nChannels,
                                                                                 ((PKSDATAFORMAT_WAVEFORMATEX)NewDataFormat)->WaveFormatEx.wBitsPerSample,
                                                                                 ((PKSDATAFORMAT_WAVEFORMATEX)NewDataFormat)->WaveFormatEx.nSamplesPerSec);

                    Status = m_Stream->SetFormat(NewDataFormat);
                    if (NT_SUCCESS(Status))
                    {
                        if (m_Format)
                            FreeItem(m_Format, TAG_PORTCLASS);

                        m_Format = NewDataFormat;
                        Irp->IoStatus.Information = DataFormat->FormatSize;
                        Irp->IoStatus.Status = STATUS_SUCCESS;
                        IoCompleteRequest(Irp, IO_NO_INCREMENT);
                        return STATUS_SUCCESS;
                    }
                }
                DPRINT("Failed to set format\n");
                Irp->IoStatus.Information = 0;
                Irp->IoStatus.Status = STATUS_UNSUCCESSFUL;
                IoCompleteRequest(Irp, IO_NO_INCREMENT);
                return STATUS_UNSUCCESSFUL;
            }
            else if (Property->Flags & KSPROPERTY_TYPE_GET)
            {
                if (!m_Format)
                {
                    DPRINT("No format\n");
                    Irp->IoStatus.Information = 0;
                    Irp->IoStatus.Status = STATUS_UNSUCCESSFUL;
                    IoCompleteRequest(Irp, IO_NO_INCREMENT);
                    return STATUS_UNSUCCESSFUL;
                }
                if (m_Format->FormatSize > IoStack->Parameters.DeviceIoControl.OutputBufferLength)
                {
                    Irp->IoStatus.Information = m_Format->FormatSize;
                    Irp->IoStatus.Status = STATUS_BUFFER_TOO_SMALL;
                    IoCompleteRequest(Irp, IO_NO_INCREMENT);
                    return STATUS_BUFFER_TOO_SMALL;
                }

                RtlMoveMemory(DataFormat, m_Format, m_Format->FormatSize);
                Irp->IoStatus.Information = DataFormat->FormatSize;
                Irp->IoStatus.Status = STATUS_SUCCESS;
                IoCompleteRequest(Irp, IO_NO_INCREMENT);
                return STATUS_SUCCESS;
            }
        }

    }
    RtlStringFromGUID(Property->Set, &GuidString);
    DPRINT("Unhandled property Set |%S| Id %u Flags %x\n", GuidString.Buffer, Property->Id, Property->Flags);
    RtlFreeUnicodeString(&GuidString);

    Irp->IoStatus.Status = STATUS_NOT_IMPLEMENTED;
    Irp->IoStatus.Information = 0;
    IoCompleteRequest(Irp, IO_NO_INCREMENT);
    return STATUS_NOT_IMPLEMENTED;
}

HandleKsStream()

NTSTATUS NTAPI CPortPinWaveRT::HandleKsStream ( IN PIRP  Irp )

protected

Definition at line 289 of file pin_wavert.cpp.

{
    DPRINT("IPortPinWaveRT_HandleKsStream entered State %u Stream %p is UNIMPLEMENTED\n", m_State, m_Stream);

    return STATUS_PENDING;
}

QueryInterface()

NTSTATUS NTAPI CPortPinWaveRT::QueryInterface	(	REFIID	InterfaceId,
		PVOID *	Interface
	)

Definition at line 93 of file pin_wavert.cpp.

{
    DPRINT("IServiceSink_fnQueryInterface entered\n");

    if (IsEqualGUIDAligned(refiid, IID_IIrpTarget) || 
        IsEqualGUIDAligned(refiid, IID_IUnknown))
    {
        *Output = PVOID(PUNKNOWN((IIrpTarget*)this));
        PUNKNOWN(*Output)->AddRef();
        return STATUS_SUCCESS;
    }
    return STATUS_UNSUCCESSFUL;
}

SetStreamState()

VOID NTAPI CPortPinWaveRT::SetStreamState ( IN KSSTATE  State )

protected

STDMETHODIMP_() [1/2]

CPortPinWaveRT::STDMETHODIMP_ ( ULONG  )

inline

Definition at line 22 of file pin_wavert.cpp.

    {
        InterlockedIncrement(&m_Ref);
        return m_Ref;
    }

STDMETHODIMP_() [2/2]

CPortPinWaveRT::STDMETHODIMP_ ( ULONG  )

inline

Definition at line 27 of file pin_wavert.cpp.

    {
        InterlockedDecrement(&m_Ref);

        if (!m_Ref)
        {
            delete this;
            return 0;
        }
        return m_Ref;
    }

Friends And Related Function Documentation

CloseStreamRoutine

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

friend

Definition at line 382 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();
    }
}

SetStreamWorkerRoutine

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

friend

Member Data Documentation

IMP_IPortPinWaveRT

CPortPinWaveRT::IMP_IPortPinWaveRT

Definition at line 38 of file pin_wavert.cpp.

m_CacheType

MEMORY_CACHING_TYPE CPortPinWaveRT::m_CacheType

protected

Definition at line 68 of file pin_wavert.cpp.

m_Capture

BOOL CPortPinWaveRT::m_Capture

protected

Definition at line 60 of file pin_wavert.cpp.

m_CommonBuffer

PVOID CPortPinWaveRT::m_CommonBuffer

protected

Definition at line 54 of file pin_wavert.cpp.

m_CommonBufferOffset

ULONG CPortPinWaveRT::m_CommonBufferOffset

protected

Definition at line 56 of file pin_wavert.cpp.

m_CommonBufferSize

ULONG CPortPinWaveRT::m_CommonBufferSize

protected

Definition at line 55 of file pin_wavert.cpp.

m_ConnectDetails

KSPIN_CONNECT* CPortPinWaveRT::m_ConnectDetails

protected

Definition at line 52 of file pin_wavert.cpp.

m_Delay

ULONGLONG CPortPinWaveRT::m_Delay

protected

Definition at line 66 of file pin_wavert.cpp.

m_Filter

IPortFilterWaveRT* CPortPinWaveRT::m_Filter

protected

Definition at line 45 of file pin_wavert.cpp.

m_Format

PKSDATAFORMAT CPortPinWaveRT::m_Format

protected

Definition at line 51 of file pin_wavert.cpp.

Referenced by HandleKsProperty().

m_IrpQueue

IIrpQueue* CPortPinWaveRT::m_IrpQueue

protected

Definition at line 58 of file pin_wavert.cpp.

m_KsPinDescriptor

KSPIN_DESCRIPTOR* CPortPinWaveRT::m_KsPinDescriptor

protected

Definition at line 46 of file pin_wavert.cpp.

m_Mdl

PMDL CPortPinWaveRT::m_Mdl

protected

Definition at line 69 of file pin_wavert.cpp.

m_Miniport

PMINIPORTWAVERT CPortPinWaveRT::m_Miniport

protected

Definition at line 47 of file pin_wavert.cpp.

m_Port

IPortWaveRT* CPortPinWaveRT::m_Port

protected

Definition at line 44 of file pin_wavert.cpp.

m_PortStream

PPORTWAVERTSTREAM CPortPinWaveRT::m_PortStream

protected

Definition at line 49 of file pin_wavert.cpp.

m_PostCompleted

ULONG CPortPinWaveRT::m_PostCompleted

protected

Definition at line 64 of file pin_wavert.cpp.

m_PreCompleted

ULONG CPortPinWaveRT::m_PreCompleted

protected

Definition at line 63 of file pin_wavert.cpp.

m_Ref

LONG CPortPinWaveRT::m_Ref

protected

Definition at line 71 of file pin_wavert.cpp.

Referenced by STDMETHODIMP_().

m_State

KSSTATE CPortPinWaveRT::m_State

protected

Definition at line 50 of file pin_wavert.cpp.

Referenced by HandleKsProperty(), and HandleKsStream().

m_Stream

PMINIPORTWAVERTSTREAM CPortPinWaveRT::m_Stream

protected

Definition at line 48 of file pin_wavert.cpp.

Referenced by HandleKsProperty(), and HandleKsStream().

m_TotalPackets

ULONG CPortPinWaveRT::m_TotalPackets

protected

Definition at line 62 of file pin_wavert.cpp.

---

The documentation for this class was generated from the following file:

• drivers/wdm/audio/backpln/portcls/pin_wavert.cpp