Inheritance diagram for CPortPinWavePci:

Collaboration diagram for CPortPinWavePci:

[legend]

Public Member Functions
STDMETHODIMP	QueryInterface (REFIID InterfaceId, PVOID *Interface)

	CPortPinWavePci (IUnknown *OuterUnknown)

virtual	~CPortPinWavePci ()

Public Member Functions inherited from CUnknownImpl< IPortPinWavePci, IServiceSink, IPortWavePciStream >
	STDMETHODIMP_ (ULONG) AddRef()

	STDMETHODIMP_ (ULONG) Release()

Public Attributes
	IMP_IPortPinWavePci

	IMP_IServiceSink

	IMP_IPortWavePciStream

Protected Member Functions
NTSTATUS NTAPI	HandleKsProperty (IN PIRP Irp)

NTSTATUS NTAPI	HandleKsStream (IN PIRP Irp)

Protected Member Functions inherited from CUnknownImpl< IPortPinWavePci, IServiceSink, IPortWavePciStream >
	CUnknownImpl ()

virtual	~CUnknownImpl ()

Protected Attributes
IPortWavePci *	m_Port

IPortFilterWavePci *	m_Filter

KSPIN_DESCRIPTOR *	m_KsPinDescriptor

PMINIPORTWAVEPCI	m_Miniport

PSERVICEGROUP	m_ServiceGroup

PDMACHANNEL	m_DmaChannel

PMINIPORTWAVEPCISTREAM	m_Stream

KSSTATE	m_State

PKSDATAFORMAT	m_Format

KSPIN_CONNECT *	m_ConnectDetails

BOOL	m_Capture

PDEVICE_OBJECT	m_DeviceObject

IIrpQueue *	m_IrpQueue

ULONG	m_TotalPackets

KSAUDIO_POSITION	m_Position

ULONG	m_StopCount

BOOL	m_bUsePrefetch

ULONG	m_PrefetchOffset

SUBDEVICE_DESCRIPTOR	m_Descriptor

KSALLOCATOR_FRAMING	m_AllocatorFraming

Friends
NTSTATUS NTAPI	PinWavePciState (IN PIRP Irp, IN PKSIDENTIFIER Request, IN OUT PVOID Data)

NTSTATUS NTAPI	PinWavePciDataFormat (IN PIRP Irp, IN PKSIDENTIFIER Request, IN OUT PVOID Data)

NTSTATUS NTAPI	PinWavePciAudioPosition (IN PIRP Irp, IN PKSIDENTIFIER Request, IN OUT PVOID Data)

NTSTATUS NTAPI	PinWavePciAllocatorFraming (IN PIRP Irp, IN PKSIDENTIFIER Request, IN OUT PVOID Data)

Detailed Description

Definition at line 14 of file pin_wavepci.cpp.

Constructor & Destructor Documentation

◆ CPortPinWavePci()

CPortPinWavePci::CPortPinWavePci ( IUnknown * OuterUnknown )

inline

Definition at line 22 of file pin_wavepci.cpp.

22{}

◆ ~CPortPinWavePci()

virtual CPortPinWavePci::~CPortPinWavePci ( )

inlinevirtual

Definition at line 23 of file pin_wavepci.cpp.

23{}

Member Function Documentation

◆ HandleKsProperty()

NTSTATUS NTAPI CPortPinWavePci::HandleKsProperty ( IN PIRP Irp )

protected

Definition at line 472 of file pin_wavepci.cpp.

{
    //PKSPROPERTY Property;
    NTSTATUS Status;
    //UNICODE_STRING GuidString;
    PIO_STACK_LOCATION IoStack;
 
    //DPRINT("IPortPinWave_HandleKsProperty entered\n");
 
    IoStack = IoGetCurrentIrpStackLocation(Irp);
 
    if (IoStack->Parameters.DeviceIoControl.IoControlCode != IOCTL_KS_PROPERTY)
    {
        //DPRINT("Unhandled function %lx Length %x\n", IoStack->Parameters.DeviceIoControl.IoControlCode, IoStack->Parameters.DeviceIoControl.InputBufferLength);
 
        Irp->IoStatus.Status = STATUS_SUCCESS;
 
        IoCompleteRequest(Irp, IO_NO_INCREMENT);
        return STATUS_SUCCESS;
    }
 
    Status = PcHandlePropertyWithTable(Irp,  m_Descriptor.FilterPropertySetCount, m_Descriptor.FilterPropertySet, &m_Descriptor);
 
    if (Status == STATUS_NOT_FOUND)
    {
        //Property = (PKSPROPERTY)IoStack->Parameters.DeviceIoControl.Type3InputBuffer;
#if 0
        RtlStringFromGUID(Property->Set, &GuidString);
        //DPRINT("Unhandled property Set |%S| Id %u Flags %x\n", GuidString.Buffer, Property->Id, Property->Flags);
        RtlFreeUnicodeString(&GuidString);
#endif
    }
 
    if (Status != STATUS_PENDING)
    {
        Irp->IoStatus.Status = Status;
        IoCompleteRequest(Irp, IO_NO_INCREMENT);
    }
 
    return Status;
}

◆ HandleKsStream()

NTSTATUS NTAPI CPortPinWavePci::HandleKsStream ( IN PIRP Irp )

protected

Definition at line 517 of file pin_wavepci.cpp.

{
    NTSTATUS Status;
    ULONG Data = 0;
    InterlockedIncrement((PLONG)&m_TotalPackets);
 
    DPRINT("IPortPinWaveCyclic_HandleKsStream entered Total %u State %x MinData %u\n", m_TotalPackets, m_State, m_IrpQueue->NumData());
 
    Status = m_IrpQueue->AddMapping(Irp, &Data);
 
    if (NT_SUCCESS(Status))
    {
        if (m_Capture)
            m_Position.WriteOffset += Data;
        else
            m_Position.PlayOffset += Data;
 
        if (m_State == KSSTATE_RUN)
        {
            // notify stream of new mapping
            m_Stream->MappingAvailable();
        }
 
        return STATUS_PENDING;
    }
 
    return Status;
}

◆ QueryInterface()

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

Definition at line 370 of file pin_wavepci.cpp.

{
    //DPRINT("CPortPinWavePci::QueryInterface entered\n");
 
    if (IsEqualGUIDAligned(refiid, IID_IIrpTarget) ||
        IsEqualGUIDAligned(refiid, IID_IUnknown))
    {
        *Output = PVOID(PUNKNOWN((IIrpTarget*)this));
        PUNKNOWN(*Output)->AddRef();
        return STATUS_SUCCESS;
    }
 
    if (IsEqualGUIDAligned(refiid, IID_IServiceSink))
    {
        *Output = PVOID(PSERVICESINK(this));
        PUNKNOWN(*Output)->AddRef();
        return STATUS_SUCCESS;
    }
 
    if (IsEqualGUIDAligned(refiid, IID_IPortWavePciStream))
    {
        *Output = PVOID(PPORTWAVEPCISTREAM(this));
        PUNKNOWN(*Output)->AddRef();
        return STATUS_SUCCESS;
    }
 
    return STATUS_UNSUCCESSFUL;
}

Friends And Related Function Documentation

◆ PinWavePciAllocatorFraming

NTSTATUS NTAPI PinWavePciAllocatorFraming	(	IN PIRP	Irp,
		IN PKSIDENTIFIER	Request,
		IN OUT PVOID	Data
	)

friend

Definition at line 95 of file pin_wavepci.cpp.

{
    CPortPinWavePci *Pin;
    PSUBDEVICE_DESCRIPTOR Descriptor;
 
    // get sub device descriptor
    Descriptor = (PSUBDEVICE_DESCRIPTOR)KSPROPERTY_ITEM_IRP_STORAGE(Irp);
 
    // sanity check
    PC_ASSERT(Descriptor);
    PC_ASSERT(Descriptor->PortPin);
    PC_ASSERT_IRQL(DISPATCH_LEVEL);
 
    // cast to pin impl
    Pin = (CPortPinWavePci*)Descriptor->PortPin;
 
    if (Request->Flags & KSPROPERTY_TYPE_GET)
    {
        // copy pin framing
        RtlMoveMemory(Data, &Pin->m_AllocatorFraming, sizeof(KSALLOCATOR_FRAMING));
 
        Irp->IoStatus.Information = sizeof(KSALLOCATOR_FRAMING);
        return STATUS_SUCCESS;
    }
 
    // not supported
    return STATUS_NOT_SUPPORTED;
}

◆ PinWavePciAudioPosition

NTSTATUS NTAPI PinWavePciAudioPosition	(	IN PIRP	Irp,
		IN PKSIDENTIFIER	Request,
		IN OUT PVOID	Data
	)

friend

Definition at line 129 of file pin_wavepci.cpp.

{
    CPortPinWavePci *Pin;
    PSUBDEVICE_DESCRIPTOR Descriptor;
 
    // get sub device descriptor
    Descriptor = (PSUBDEVICE_DESCRIPTOR)KSPROPERTY_ITEM_IRP_STORAGE(Irp);
 
    // sanity check
    PC_ASSERT(Descriptor);
    PC_ASSERT(Descriptor->PortPin);
    PC_ASSERT_IRQL(DISPATCH_LEVEL);
 
    // cast to pin impl
    Pin = (CPortPinWavePci*)Descriptor->PortPin;
 
    //sanity check
    PC_ASSERT(Pin->m_Stream);
 
    if (Request->Flags & KSPROPERTY_TYPE_GET)
    {
        // FIXME non multithreading-safe
        // copy audio position
        RtlMoveMemory(Data, &Pin->m_Position, sizeof(KSAUDIO_POSITION));
 
        DPRINT("Play %lu Record %lu\n", Pin->m_Position.PlayOffset, Pin->m_Position.WriteOffset);
        Irp->IoStatus.Information = sizeof(KSAUDIO_POSITION);
        return STATUS_SUCCESS;
    }
 
    // not supported
    return STATUS_NOT_SUPPORTED;
}

◆ PinWavePciDataFormat

NTSTATUS NTAPI PinWavePciDataFormat	(	IN PIRP	Irp,
		IN PKSIDENTIFIER	Request,
		IN OUT PVOID	Data
	)

friend

Definition at line 254 of file pin_wavepci.cpp.

{
    NTSTATUS Status = STATUS_UNSUCCESSFUL;
    CPortPinWavePci *Pin;
    PSUBDEVICE_DESCRIPTOR Descriptor;
    PIO_STACK_LOCATION IoStack;
 
    // get current irp stack location
    IoStack = IoGetCurrentIrpStackLocation(Irp);
 
    // get sub device descriptor
    Descriptor = (PSUBDEVICE_DESCRIPTOR)KSPROPERTY_ITEM_IRP_STORAGE(Irp);
 
    // sanity check
    PC_ASSERT(Descriptor);
    PC_ASSERT(Descriptor->PortPin);
 
    // cast to pin impl
    Pin = (CPortPinWavePci*)Descriptor->PortPin;
 
    //sanity check
    PC_ASSERT(Pin->m_Stream);
    PC_ASSERT(Pin->m_Format);
 
    if (Request->Flags & KSPROPERTY_TYPE_SET)
    {
        // try to change data format
        PKSDATAFORMAT NewDataFormat, DataFormat = (PKSDATAFORMAT)Irp->UserBuffer;
        ULONG Size = min(Pin->m_Format->FormatSize, DataFormat->FormatSize);
 
        if (RtlCompareMemory(DataFormat, Pin->m_Format, Size) == Size)
        {
            // format is identical
            Irp->IoStatus.Information = DataFormat->FormatSize;
            return STATUS_SUCCESS;
        }
 
        // new change request
        PC_ASSERT(Pin->m_State == KSSTATE_STOP);
        // FIXME queue a work item when Irql != PASSIVE_LEVEL
        PC_ASSERT(KeGetCurrentIrql() == PASSIVE_LEVEL);
 
        // allocate new data format
        NewDataFormat = (PKSDATAFORMAT)AllocateItem(NonPagedPool, DataFormat->FormatSize, TAG_PORTCLASS);
        if (!NewDataFormat)
        {
            // not enough memory
            return STATUS_NO_MEMORY;
        }
 
        // copy new data format
        RtlMoveMemory(NewDataFormat, DataFormat, DataFormat->FormatSize);
 
        // set new format
        Status = Pin->m_Stream->SetFormat(NewDataFormat);
        if (NT_SUCCESS(Status))
        {
            // free old format
            FreeItem(Pin->m_Format, TAG_PORTCLASS);
 
            // store new format
            Pin->m_Format = NewDataFormat;
            Irp->IoStatus.Information = NewDataFormat->FormatSize;
 
#if 0
            PC_ASSERT(NewDataFormat->FormatSize == sizeof(KSDATAFORMAT_WAVEFORMATEX));
            PC_ASSERT(IsEqualGUIDAligned(((PKSDATAFORMAT_WAVEFORMATEX)NewDataFormat)->DataFormat.MajorFormat, KSDATAFORMAT_TYPE_AUDIO));
            PC_ASSERT(IsEqualGUIDAligned(((PKSDATAFORMAT_WAVEFORMATEX)NewDataFormat)->DataFormat.SubFormat, KSDATAFORMAT_SUBTYPE_PCM));
            PC_ASSERT(IsEqualGUIDAligned(((PKSDATAFORMAT_WAVEFORMATEX)NewDataFormat)->DataFormat.Specifier, KSDATAFORMAT_SPECIFIER_WAVEFORMATEX));
 
            DPRINT("NewDataFormat: Channels %u Bits %u Samples %u\n", ((PKSDATAFORMAT_WAVEFORMATEX)NewDataFormat)->WaveFormatEx.nChannels,
                                                                       ((PKSDATAFORMAT_WAVEFORMATEX)NewDataFormat)->WaveFormatEx.wBitsPerSample,
                                                                       ((PKSDATAFORMAT_WAVEFORMATEX)NewDataFormat)->WaveFormatEx.nSamplesPerSec);
#endif
 
        }
        else
        {
            // failed to set format
            FreeItem(NewDataFormat, TAG_PORTCLASS);
        }
 
        // done
        return Status;
    }
    else if (Request->Flags & KSPROPERTY_TYPE_GET)
    {
        // get current data format
        PC_ASSERT(Pin->m_Format);
 
        if (Pin->m_Format->FormatSize > IoStack->Parameters.DeviceIoControl.OutputBufferLength)
        {
            // buffer too small
            Irp->IoStatus.Information = Pin->m_Format->FormatSize;
            return STATUS_MORE_ENTRIES;
        }
        // copy data format
        RtlMoveMemory(Data, Pin->m_Format, Pin->m_Format->FormatSize);
        // store result size
        Irp->IoStatus.Information = Pin->m_Format->FormatSize;
 
        // done
        return STATUS_SUCCESS;
    }
 
    // unsupported request
    return STATUS_NOT_SUPPORTED;
}

◆ PinWavePciState

NTSTATUS NTAPI PinWavePciState	(	IN PIRP	Irp,
		IN PKSIDENTIFIER	Request,
		IN OUT PVOID	Data
	)

friend

Definition at line 168 of file pin_wavepci.cpp.

{
    NTSTATUS Status = STATUS_UNSUCCESSFUL;
    CPortPinWavePci *Pin;
    PSUBDEVICE_DESCRIPTOR Descriptor;
    PVOID FirstTag, LastTag;
    ULONG MappingsRevoked;
    PKSSTATE State = (PKSSTATE)Data;
 
    // get sub device descriptor
    Descriptor = (PSUBDEVICE_DESCRIPTOR)KSPROPERTY_ITEM_IRP_STORAGE(Irp);
 
    // sanity check
    PC_ASSERT(Descriptor);
    PC_ASSERT(Descriptor->PortPin);
    PC_ASSERT_IRQL(DISPATCH_LEVEL);
 
    // cast to pin impl
    Pin = (CPortPinWavePci*)Descriptor->PortPin;
 
    //sanity check
    PC_ASSERT(Pin->m_Stream);
 
    if (Request->Flags & KSPROPERTY_TYPE_SET)
    {
        // try set stream
        Status = Pin->m_Stream->SetState(*State);
 
        DPRINT("Setting state %u %x\n", *State, Status);
        if (NT_SUCCESS(Status))
        {
            // store new state
            Pin->m_State = *State;
            if (Pin->m_ConnectDetails->Interface.Id == KSINTERFACE_STANDARD_LOOPED_STREAMING && Pin->m_State == KSSTATE_STOP)
            {
                // FIXME
                // complete with successful state
                Pin->m_IrpQueue->CancelBuffers();
                while(Pin->m_IrpQueue->GetAcquiredTagRange(&FirstTag, &LastTag))
                {
                    Status = Pin->m_Stream->RevokeMappings(FirstTag, LastTag, &MappingsRevoked);
                    DPRINT("RevokeMappings Status %lx MappingsRevoked: %lu\n", Status, MappingsRevoked);
                    KeStallExecutionProcessor(10);
                }
                Pin->m_Position.PlayOffset = 0;
                Pin->m_Position.WriteOffset = 0;
            }
            else if (Pin->m_State == KSSTATE_STOP)
            {
                Pin->m_IrpQueue->CancelBuffers();
                while(Pin->m_IrpQueue->GetAcquiredTagRange(&FirstTag, &LastTag))
                {
                    Status = Pin->m_Stream->RevokeMappings(FirstTag, LastTag, &MappingsRevoked);
                    DPRINT("RevokeMappings Status %lx MappingsRevoked: %lu\n", Status, MappingsRevoked);
                    KeStallExecutionProcessor(10);
                }
                Pin->m_Position.PlayOffset = 0;
                Pin->m_Position.WriteOffset = 0;
            }
            // store result
            Irp->IoStatus.Information = sizeof(KSSTATE);
 
        }
        // store result
        Irp->IoStatus.Information = sizeof(KSSTATE);
        return Status;
    }
    else if (Request->Flags & KSPROPERTY_TYPE_GET)
    {
        // get current stream state
        *State = Pin->m_State;
        // store result
        Irp->IoStatus.Information = sizeof(KSSTATE);
 
        return STATUS_SUCCESS;
    }
 
    // unsupported request
    return STATUS_NOT_SUPPORTED;
}

Member Data Documentation

◆ IMP_IPortPinWavePci

CPortPinWavePci::IMP_IPortPinWavePci

Definition at line 19 of file pin_wavepci.cpp.

◆ IMP_IPortWavePciStream

CPortPinWavePci::IMP_IPortWavePciStream

Definition at line 21 of file pin_wavepci.cpp.

◆ IMP_IServiceSink

CPortPinWavePci::IMP_IServiceSink

Definition at line 20 of file pin_wavepci.cpp.

◆ m_AllocatorFraming

KSALLOCATOR_FRAMING CPortPinWavePci::m_AllocatorFraming

protected

Definition at line 54 of file pin_wavepci.cpp.

◆ m_bUsePrefetch

BOOL CPortPinWavePci::m_bUsePrefetch

protected

Definition at line 50 of file pin_wavepci.cpp.

◆ m_Capture

BOOL CPortPinWavePci::m_Capture

protected

Definition at line 42 of file pin_wavepci.cpp.

Referenced by HandleKsStream().

◆ m_ConnectDetails

KSPIN_CONNECT* CPortPinWavePci::m_ConnectDetails

protected

Definition at line 40 of file pin_wavepci.cpp.

◆ m_Descriptor

SUBDEVICE_DESCRIPTOR CPortPinWavePci::m_Descriptor

protected

Definition at line 52 of file pin_wavepci.cpp.

Referenced by HandleKsProperty().

◆ m_DeviceObject

PDEVICE_OBJECT CPortPinWavePci::m_DeviceObject

protected

Definition at line 43 of file pin_wavepci.cpp.

◆ m_DmaChannel

PDMACHANNEL CPortPinWavePci::m_DmaChannel

protected

Definition at line 36 of file pin_wavepci.cpp.

◆ m_Filter

IPortFilterWavePci* CPortPinWavePci::m_Filter

protected

Definition at line 32 of file pin_wavepci.cpp.

◆ m_Format

PKSDATAFORMAT CPortPinWavePci::m_Format

protected

Definition at line 39 of file pin_wavepci.cpp.

◆ m_IrpQueue

IIrpQueue* CPortPinWavePci::m_IrpQueue

protected

Definition at line 44 of file pin_wavepci.cpp.

Referenced by HandleKsStream().

◆ m_KsPinDescriptor

KSPIN_DESCRIPTOR* CPortPinWavePci::m_KsPinDescriptor

protected

Definition at line 33 of file pin_wavepci.cpp.

◆ m_Miniport

PMINIPORTWAVEPCI CPortPinWavePci::m_Miniport

protected

Definition at line 34 of file pin_wavepci.cpp.

◆ m_Port

IPortWavePci* CPortPinWavePci::m_Port

protected

Definition at line 31 of file pin_wavepci.cpp.

◆ m_Position

KSAUDIO_POSITION CPortPinWavePci::m_Position

protected

Definition at line 47 of file pin_wavepci.cpp.

Referenced by HandleKsStream().

◆ m_PrefetchOffset

ULONG CPortPinWavePci::m_PrefetchOffset

protected

Definition at line 51 of file pin_wavepci.cpp.

◆ m_ServiceGroup

PSERVICEGROUP CPortPinWavePci::m_ServiceGroup

protected

Definition at line 35 of file pin_wavepci.cpp.

◆ m_State

KSSTATE CPortPinWavePci::m_State

protected

Definition at line 38 of file pin_wavepci.cpp.

Referenced by HandleKsStream().

◆ m_StopCount

ULONG CPortPinWavePci::m_StopCount

protected

Definition at line 48 of file pin_wavepci.cpp.

◆ m_Stream

PMINIPORTWAVEPCISTREAM CPortPinWavePci::m_Stream

protected

Definition at line 37 of file pin_wavepci.cpp.

Referenced by HandleKsStream().

◆ m_TotalPackets

ULONG CPortPinWavePci::m_TotalPackets

protected

Definition at line 46 of file pin_wavepci.cpp.

Referenced by HandleKsStream().

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

drivers/wdm/audio/backpln/portcls/pin_wavepci.cpp

Public Member Functions

Public Attributes

Protected Member Functions

Protected Attributes

Friends

Detailed Description

Constructor & Destructor Documentation

◆ CPortPinWavePci()

◆ ~CPortPinWavePci()

Member Function Documentation

◆ HandleKsProperty()

◆ HandleKsStream()

◆ QueryInterface()

Friends And Related Function Documentation

◆ PinWavePciAllocatorFraming

◆ PinWavePciAudioPosition

◆ PinWavePciDataFormat

◆ PinWavePciState

Member Data Documentation

◆ IMP_IPortPinWavePci

◆ IMP_IPortWavePciStream

◆ IMP_IServiceSink

◆ m_AllocatorFraming

◆ m_bUsePrefetch

◆ m_Capture

◆ m_ConnectDetails

◆ m_Descriptor

◆ m_DeviceObject

◆ m_DmaChannel

◆ m_Filter

◆ m_Format

◆ m_IrpQueue

◆ m_KsPinDescriptor

◆ m_Miniport

◆ m_Port

◆ m_Position

◆ m_PrefetchOffset

◆ m_ServiceGroup

◆ m_State

◆ m_StopCount

◆ m_Stream

◆ m_TotalPackets