Inheritance diagram for CPortPinWaveCyclic:

Collaboration diagram for CPortPinWaveCyclic:

[legend]

Public Member Functions
PVOID	operator new (size_t Size, POOL_TYPE PoolType, ULONG Tag)

STDMETHODIMP	QueryInterface (REFIID InterfaceId, PVOID *Interface)

	CPortPinWaveCyclic (IUnknown *OuterUnknown)

virtual	~CPortPinWaveCyclic ()

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

	STDMETHODIMP_ (ULONG) Release()

Public Attributes
	IMP_IPortPinWaveCyclic

	IMP_IServiceSink

Protected Member Functions
VOID	UpdateCommonBuffer (ULONG Position, ULONG MaxTransferCount)

VOID	UpdateCommonBufferOverlap (ULONG Position, ULONG MaxTransferCount)

VOID	GeneratePositionEvents (IN ULONGLONG OldOffset, IN ULONGLONG NewOffset)

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

virtual	~CUnknownImpl ()

Protected Attributes
IPortWaveCyclic *	m_Port

IPortFilterWaveCyclic *	m_Filter

KSPIN_DESCRIPTOR *	m_KsPinDescriptor

PMINIPORTWAVECYCLIC	m_Miniport

PSERVICEGROUP	m_ServiceGroup

PDMACHANNEL	m_DmaChannel

PMINIPORTWAVECYCLICSTREAM	m_Stream

KSSTATE	m_State

PKSDATAFORMAT	m_Format

PKSPIN_CONNECT	m_ConnectDetails

PVOID	m_CommonBuffer

ULONG	m_CommonBufferSize

ULONG	m_CommonBufferOffset

IIrpQueue *	m_IrpQueue

ULONG	m_FrameSize

BOOL	m_Capture

ULONG	m_TotalPackets

ULONG	m_StopCount

KSAUDIO_POSITION	m_Position

KSALLOCATOR_FRAMING	m_AllocatorFraming

PSUBDEVICE_DESCRIPTOR	m_Descriptor

KSPIN_LOCK	m_EventListLock

LIST_ENTRY	m_EventList

KSRESET	m_ResetState

ULONG	m_Delay

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

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

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

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

NTSTATUS NTAPI	PinWaveCyclicAddEndOfStreamEvent (IN PIRP Irp, IN PKSEVENTDATA EventData, IN PKSEVENT_ENTRY EventEntry)

NTSTATUS NTAPI	PinWaveCyclicAddLoopedStreamEvent (IN PIRP Irp, IN PKSEVENTDATA EventData, IN PKSEVENT_ENTRY EventEntry)

VOID CALLBACK	PinSetStateWorkerRoutine (IN PDEVICE_OBJECT DeviceObject, IN PVOID Context)

Detailed Description

Definition at line 14 of file pin_wavecyclic.cpp.

Constructor & Destructor Documentation

◆ CPortPinWaveCyclic()

CPortPinWaveCyclic::CPortPinWaveCyclic ( IUnknown * OuterUnknown )

inline

Definition at line 31 of file pin_wavecyclic.cpp.

                                               :
        m_Port(nullptr),
        m_Filter(nullptr),
        m_KsPinDescriptor(nullptr),
        m_Miniport(nullptr),
        m_ServiceGroup(nullptr),
        m_DmaChannel(nullptr),
        m_Stream(nullptr),
        m_State(KSSTATE_STOP),
        m_Format(nullptr),
        m_ConnectDetails(nullptr),
        m_CommonBuffer(nullptr),
        m_CommonBufferSize(0),
        m_CommonBufferOffset(0),
        m_IrpQueue(nullptr),
        m_FrameSize(0),
        m_Capture(FALSE),
        m_TotalPackets(0),
        m_StopCount(0),
        m_Position({0}),
        m_AllocatorFraming({{0}}),
        m_Descriptor(nullptr),
        m_EventListLock(0),
        m_EventList({nullptr}),
        m_ResetState(KSRESET_BEGIN),
        m_Delay(0)
    {
    }

◆ ~CPortPinWaveCyclic()

virtual CPortPinWaveCyclic::~CPortPinWaveCyclic ( )

inlinevirtual

Definition at line 59 of file pin_wavecyclic.cpp.

59{}

Member Function Documentation

◆ GeneratePositionEvents()

VOID CPortPinWaveCyclic::GeneratePositionEvents	(	IN ULONGLONG	OldOffset,
		IN ULONGLONG	NewOffset
	)

protected

Definition at line 631 of file pin_wavecyclic.cpp.

{
    PLIST_ENTRY Entry;
    PKSEVENT_ENTRY EventEntry;
    PLOOPEDSTREAMING_EVENT_CONTEXT Context;
 
    // acquire event lock
    KeAcquireSpinLockAtDpcLevel(&m_EventListLock);
 
    // point to first entry
    Entry = m_EventList.Flink;
 
    while(Entry != &m_EventList)
    {
        // get event entry
        EventEntry = (PKSEVENT_ENTRY)CONTAINING_RECORD(Entry, KSEVENT_ENTRY, ListEntry);
 
        // get event entry context
        Context = (PLOOPEDSTREAMING_EVENT_CONTEXT)(EventEntry + 1);
 
        if (Context->bLoopedStreaming != FALSE)
        {
            if (NewOffset > OldOffset)
            {
                /* buffer progress no overlap */
                if (OldOffset < Context->Position && Context->Position <= NewOffset)
                {
                    /* when someone eventually fixes sprintf... */
                    DPRINT("Generating event at OldOffset %I64u\n", OldOffset);
                    DPRINT("Context->Position %I64u\n", Context->Position);
                    DPRINT("NewOffset %I64u\n", NewOffset);
                    /* generate event */
                    KsGenerateEvent(EventEntry);
                }
            }
            else
            {
                /* buffer wrap-arround */
                if (OldOffset < Context->Position || NewOffset > Context->Position)
                {
                    /* when someone eventually fixes sprintf... */
                    DPRINT("Generating event at OldOffset %I64u\n", OldOffset);
                    DPRINT("Context->Position %I64u\n", Context->Position);
                    DPRINT("NewOffset %I64u\n", NewOffset);
                    /* generate event */
                    KsGenerateEvent(EventEntry);
                }
            }
        }
 
        // move to next entry
        Entry = Entry->Flink;
    }
 
    // release lock
    KeReleaseSpinLockFromDpcLevel(&m_EventListLock);
}

◆ operator new()

PVOID CPortPinWaveCyclic::operator new	(	size_t	Size,
		POOL_TYPE	PoolType,
		ULONG	Tag
	)

inline

Definition at line 19 of file pin_wavecyclic.cpp.

    {
        return ExAllocatePoolWithTag(PoolType, Size, Tag);
    }

◆ QueryInterface()

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

Definition at line 195 of file pin_wavecyclic.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;
    }
 
    if (IsEqualGUIDAligned(refiid, IID_IServiceSink))
    {
        *Output = PVOID(PUNKNOWN(PSERVICESINK(this)));
        PUNKNOWN(*Output)->AddRef();
        return STATUS_SUCCESS;
    }
 
    return STATUS_UNSUCCESSFUL;
}

◆ UpdateCommonBuffer()

VOID CPortPinWaveCyclic::UpdateCommonBuffer	(	ULONG	Position,
		ULONG	MaxTransferCount
	)

protected

Definition at line 692 of file pin_wavecyclic.cpp.

{
    ULONG BufferLength;
    ULONG BytesToCopy;
    ULONG BufferSize;
    ULONG Gap;
    PUCHAR Buffer;
    NTSTATUS Status;
 
    BufferLength = Position - m_CommonBufferOffset;
    BufferLength = min(BufferLength, MaxTransferCount);
 
    while(BufferLength)
    {
        Status = m_IrpQueue->GetMapping(&Buffer, &BufferSize);
        if (!NT_SUCCESS(Status))
        {
            Gap = Position - m_CommonBufferOffset;
            if (Gap > BufferLength)
            {
                // insert silence samples
                DPRINT("Inserting Silence Buffer Offset %lu GapLength %lu\n", m_CommonBufferOffset, BufferLength);
                m_Stream->Silence((PUCHAR)m_CommonBuffer + m_CommonBufferOffset, BufferLength);
 
                m_CommonBufferOffset += BufferLength;
            }
            break;
        }
 
        BytesToCopy = min(BufferLength, BufferSize);
 
        if (m_Capture)
        {
            m_DmaChannel->CopyFrom(Buffer, (PUCHAR)m_CommonBuffer + m_CommonBufferOffset, BytesToCopy);
        }
        else
        {
            m_DmaChannel->CopyTo((PUCHAR)m_CommonBuffer + m_CommonBufferOffset, Buffer, BytesToCopy);
        }
 
        m_IrpQueue->UpdateMapping(BytesToCopy);
        m_CommonBufferOffset += BytesToCopy;
 
        BufferLength -= BytesToCopy;
        m_Position.PlayOffset += BytesToCopy;
 
        if (m_ConnectDetails->Interface.Id == KSINTERFACE_STANDARD_LOOPED_STREAMING)
        {
            if (m_Position.WriteOffset)
            {
                // normalize position
                m_Position.PlayOffset = m_Position.PlayOffset % m_Position.WriteOffset;
            }
        }
    }
}

Referenced by UpdateCommonBufferOverlap().

◆ UpdateCommonBufferOverlap()

VOID CPortPinWaveCyclic::UpdateCommonBufferOverlap	(	ULONG	Position,
		ULONG	MaxTransferCount
	)

protected

Definition at line 752 of file pin_wavecyclic.cpp.

{
    ULONG BufferLength, Length, Gap;
    ULONG BytesToCopy;
    ULONG BufferSize;
    PUCHAR Buffer;
    NTSTATUS Status;
 
    BufferLength = Gap = m_CommonBufferSize - m_CommonBufferOffset;
    BufferLength = Length = min(BufferLength, MaxTransferCount);
    while(BufferLength)
    {
        Status = m_IrpQueue->GetMapping(&Buffer, &BufferSize);
        if (!NT_SUCCESS(Status))
        {
            Gap = m_CommonBufferSize - m_CommonBufferOffset + Position;
            if (Gap > BufferLength)
            {
                // insert silence samples
                DPRINT("Overlap Inserting Silence Buffer Size %lu Offset %lu Gap %lu Position %lu\n", m_CommonBufferSize, m_CommonBufferOffset, Gap, Position);
                m_Stream->Silence((PUCHAR)m_CommonBuffer + m_CommonBufferOffset, BufferLength);
 
                m_CommonBufferOffset += BufferLength;
            }
            break;
        }
 
        BytesToCopy = min(BufferLength, BufferSize);
 
        if (m_Capture)
        {
            m_DmaChannel->CopyFrom(Buffer,
                                             (PUCHAR)m_CommonBuffer + m_CommonBufferOffset,
                                             BytesToCopy);
        }
        else
        {
            m_DmaChannel->CopyTo((PUCHAR)m_CommonBuffer + m_CommonBufferOffset,
                                             Buffer,
                                             BytesToCopy);
        }
 
        m_IrpQueue->UpdateMapping(BytesToCopy);
        m_CommonBufferOffset += BytesToCopy;
        m_Position.PlayOffset += BytesToCopy;
 
        BufferLength -=BytesToCopy;
 
        if (m_ConnectDetails->Interface.Id == KSINTERFACE_STANDARD_LOOPED_STREAMING)
        {
            if (m_Position.WriteOffset)
            {
                // normalize position
                m_Position.PlayOffset = m_Position.PlayOffset % m_Position.WriteOffset;
            }
        }
    }
 
    if (Gap == Length)
    {
        m_CommonBufferOffset = 0;
 
        MaxTransferCount -= Length;
 
        if (MaxTransferCount)
        {
            UpdateCommonBuffer(Position, MaxTransferCount);
        }
    }
}

Friends And Related Function Documentation

◆ PinSetStateWorkerRoutine

VOID CALLBACK PinSetStateWorkerRoutine	(	IN PDEVICE_OBJECT	DeviceObject,
		IN PVOID	Context
	)

friend

Definition at line 404 of file pin_wavecyclic.cpp.

{
    PSETPIN_CONTEXT PinWorkContext = (PSETPIN_CONTEXT)Context;
    NTSTATUS Status;
 
    // try set stream
    Status = PinWorkContext->Pin->m_Stream->SetState(PinWorkContext->NewState);
 
    DPRINT1("Setting state %u %x\n", PinWorkContext->NewState, Status);
    if (NT_SUCCESS(Status))
    {
        // store new state
        PinWorkContext->Pin->m_State = PinWorkContext->NewState;
 
        if (PinWorkContext->Pin->m_ConnectDetails->Interface.Id == KSINTERFACE_STANDARD_LOOPED_STREAMING && PinWorkContext->Pin->m_State == KSSTATE_STOP)
        {
            /* FIXME complete pending irps with successful state */
            PinWorkContext->Pin->m_IrpQueue->CancelBuffers();
        }
        //HACK
        //PinWorkContext->Pin->m_IrpQueue->CancelBuffers();
    }
 
    // store result
    PinWorkContext->Irp->IoStatus.Information = sizeof(KSSTATE);
    PinWorkContext->Irp->IoStatus.Status = Status;
 
    // complete irp
    IoCompleteRequest(PinWorkContext->Irp, IO_NO_INCREMENT);
 
    // free work item
    IoFreeWorkItem(PinWorkContext->WorkItem);
 
    // free work context
    FreeItem(PinWorkContext, TAG_PORTCLASS);
 
}

◆ PinWaveCyclicAddEndOfStreamEvent

NTSTATUS NTAPI PinWaveCyclicAddEndOfStreamEvent	(	IN PIRP	Irp,
		IN PKSEVENTDATA	EventData,
		IN PKSEVENT_ENTRY	EventEntry
	)

friend

Definition at line 233 of file pin_wavecyclic.cpp.

{
    PENDOFSTREAM_EVENT_CONTEXT Entry;
    PSUBDEVICE_DESCRIPTOR Descriptor;
    CPortPinWaveCyclic *Pin;
 
    // 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 = (CPortPinWaveCyclic*)Descriptor->PortPin;
 
     // get extra size
    Entry = (PENDOFSTREAM_EVENT_CONTEXT)(EventEntry + 1);
 
    // not a looped event
    Entry->bLoopedStreaming = FALSE;
 
    // insert item
    (void)ExInterlockedInsertTailList(&Pin->m_EventList, &EventEntry->ListEntry, &Pin->m_EventListLock);
 
    // done
    return STATUS_SUCCESS;
}

◆ PinWaveCyclicAddLoopedStreamEvent

NTSTATUS NTAPI PinWaveCyclicAddLoopedStreamEvent	(	IN PIRP	Irp,
		IN PKSEVENTDATA	EventData,
		IN PKSEVENT_ENTRY	EventEntry
	)

friend

Definition at line 268 of file pin_wavecyclic.cpp.

{
    PLOOPEDSTREAMING_POSITION_EVENT_DATA Data;
    PLOOPEDSTREAMING_EVENT_CONTEXT Entry;
    PSUBDEVICE_DESCRIPTOR Descriptor;
    CPortPinWaveCyclic *Pin;
 
    // get sub device descriptor
    Descriptor = (PSUBDEVICE_DESCRIPTOR)KSEVENT_ITEM_IRP_STORAGE(Irp);
 
    // sanity check
    PC_ASSERT(Descriptor);
    PC_ASSERT(Descriptor->PortPin);
    PC_ASSERT_IRQL(DISPATCH_LEVEL);
 
    // cast to pin impl
    Pin = (CPortPinWaveCyclic*)Descriptor->PortPin;
 
    // cast to looped event
    Data = (PLOOPEDSTREAMING_POSITION_EVENT_DATA)EventData;
 
    // get extra size
    Entry = (PLOOPEDSTREAMING_EVENT_CONTEXT)(EventEntry + 1);
 
    Entry->bLoopedStreaming = TRUE;
    Entry->Position = Data->Position;
 
    DPRINT1("Added event\n");
 
    // insert item
    (void)ExInterlockedInsertTailList(&Pin->m_EventList, &EventEntry->ListEntry, &Pin->m_EventListLock);
 
    // done
    return STATUS_SUCCESS;
}

◆ PinWaveCyclicAllocatorFraming

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

friend

Definition at line 309 of file pin_wavecyclic.cpp.

{
    CPortPinWaveCyclic *Pin;
    PSUBDEVICE_DESCRIPTOR Descriptor;
 
    // get sub device descriptor
    Descriptor = (PSUBDEVICE_DESCRIPTOR)KSEVENT_ITEM_IRP_STORAGE(Irp);
 
    // sanity check
    PC_ASSERT(Descriptor);
    PC_ASSERT(Descriptor->PortPin);
    PC_ASSERT_IRQL(DISPATCH_LEVEL);
 
    // cast to pin impl
    Pin = (CPortPinWaveCyclic*)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;
}

◆ PinWaveCyclicAudioPosition

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

friend

Definition at line 343 of file pin_wavecyclic.cpp.

{
    CPortPinWaveCyclic *Pin;
    PSUBDEVICE_DESCRIPTOR Descriptor;
    PKSAUDIO_POSITION Position;
 
    // 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 = (CPortPinWaveCyclic*)Descriptor->PortPin;
 
    //sanity check
    PC_ASSERT(Pin->m_Stream);
 
    if (Request->Flags & KSPROPERTY_TYPE_GET)
    {
        // FIXME non multithreading-safe
        // copy audio position
 
        Position = (PKSAUDIO_POSITION)Data;
 
        if (Pin->m_ConnectDetails->Interface.Id == KSINTERFACE_STANDARD_STREAMING)
        {
            RtlMoveMemory(Data, &Pin->m_Position, sizeof(KSAUDIO_POSITION));
            DPRINT("Play %lu Record %lu\n", Pin->m_Position.PlayOffset, Pin->m_Position.WriteOffset);
        }
        else if (Pin->m_ConnectDetails->Interface.Id == KSINTERFACE_STANDARD_LOOPED_STREAMING)
        {
            Position->PlayOffset = Pin->m_Position.PlayOffset;
            Position->WriteOffset = (ULONGLONG)Pin->m_IrpQueue->GetCurrentIrpOffset();
            DPRINT("Play %lu Write %lu\n", Position->PlayOffset, Position->WriteOffset);
        }
 
        Irp->IoStatus.Information = sizeof(KSAUDIO_POSITION);
        return STATUS_SUCCESS;
    }
 
    // not supported
    return STATUS_NOT_SUPPORTED;
}

◆ PinWaveCyclicDataFormat

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

friend

Definition at line 518 of file pin_wavecyclic.cpp.

{
    NTSTATUS Status = STATUS_UNSUCCESSFUL;
    CPortPinWaveCyclic *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 = (CPortPinWaveCyclic*)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_RUN);
        // 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;
}

◆ PinWaveCyclicState

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

friend

Definition at line 446 of file pin_wavecyclic.cpp.

{
    NTSTATUS Status = STATUS_UNSUCCESSFUL;
    CPortPinWaveCyclic *Pin;
    PSUBDEVICE_DESCRIPTOR Descriptor;
    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 = (CPortPinWaveCyclic*)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_Stream->Silence(Pin->m_CommonBuffer, Pin->m_CommonBufferSize);
                Pin->m_IrpQueue->CancelBuffers();
                Pin->m_Position.PlayOffset = 0;
                Pin->m_Position.WriteOffset = 0;
            }
            else if (Pin->m_State == KSSTATE_STOP)
            {
                Pin->m_Stream->Silence(Pin->m_CommonBuffer, Pin->m_CommonBufferSize);
                Pin->m_IrpQueue->CancelBuffers();
                Pin->m_Position.PlayOffset = 0;
                Pin->m_Position.WriteOffset = 0;
            }
            // 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_IPortPinWaveCyclic

CPortPinWaveCyclic::IMP_IPortPinWaveCyclic

Definition at line 29 of file pin_wavecyclic.cpp.

◆ IMP_IServiceSink

CPortPinWaveCyclic::IMP_IServiceSink

Definition at line 30 of file pin_wavecyclic.cpp.

◆ m_AllocatorFraming

KSALLOCATOR_FRAMING CPortPinWaveCyclic::m_AllocatorFraming

protected

Definition at line 98 of file pin_wavecyclic.cpp.

◆ m_Capture

BOOL CPortPinWaveCyclic::m_Capture

protected

Definition at line 93 of file pin_wavecyclic.cpp.

Referenced by UpdateCommonBuffer(), and UpdateCommonBufferOverlap().

◆ m_CommonBuffer

PVOID CPortPinWaveCyclic::m_CommonBuffer

protected

Definition at line 86 of file pin_wavecyclic.cpp.

Referenced by UpdateCommonBuffer(), and UpdateCommonBufferOverlap().

◆ m_CommonBufferOffset

ULONG CPortPinWaveCyclic::m_CommonBufferOffset

protected

Definition at line 88 of file pin_wavecyclic.cpp.

Referenced by UpdateCommonBuffer(), and UpdateCommonBufferOverlap().

◆ m_CommonBufferSize

ULONG CPortPinWaveCyclic::m_CommonBufferSize

protected

Definition at line 87 of file pin_wavecyclic.cpp.

Referenced by UpdateCommonBufferOverlap().

◆ m_ConnectDetails

PKSPIN_CONNECT CPortPinWaveCyclic::m_ConnectDetails

protected

Definition at line 84 of file pin_wavecyclic.cpp.

Referenced by UpdateCommonBuffer(), and UpdateCommonBufferOverlap().

◆ m_Delay

ULONG CPortPinWaveCyclic::m_Delay

protected

Definition at line 106 of file pin_wavecyclic.cpp.

◆ m_Descriptor

PSUBDEVICE_DESCRIPTOR CPortPinWaveCyclic::m_Descriptor

protected

Definition at line 99 of file pin_wavecyclic.cpp.

◆ m_DmaChannel

PDMACHANNEL CPortPinWaveCyclic::m_DmaChannel

protected

Definition at line 80 of file pin_wavecyclic.cpp.

Referenced by UpdateCommonBuffer(), and UpdateCommonBufferOverlap().

◆ m_EventList

LIST_ENTRY CPortPinWaveCyclic::m_EventList

protected

Definition at line 102 of file pin_wavecyclic.cpp.

Referenced by GeneratePositionEvents().

◆ m_EventListLock

KSPIN_LOCK CPortPinWaveCyclic::m_EventListLock

protected

Definition at line 101 of file pin_wavecyclic.cpp.

Referenced by GeneratePositionEvents().

◆ m_Filter

IPortFilterWaveCyclic* CPortPinWaveCyclic::m_Filter

protected

Definition at line 76 of file pin_wavecyclic.cpp.

◆ m_Format

PKSDATAFORMAT CPortPinWaveCyclic::m_Format

protected

Definition at line 83 of file pin_wavecyclic.cpp.

◆ m_FrameSize

ULONG CPortPinWaveCyclic::m_FrameSize

protected

Definition at line 92 of file pin_wavecyclic.cpp.

◆ m_IrpQueue

IIrpQueue* CPortPinWaveCyclic::m_IrpQueue

protected

Definition at line 90 of file pin_wavecyclic.cpp.

Referenced by UpdateCommonBuffer(), and UpdateCommonBufferOverlap().

◆ m_KsPinDescriptor

KSPIN_DESCRIPTOR* CPortPinWaveCyclic::m_KsPinDescriptor

protected

Definition at line 77 of file pin_wavecyclic.cpp.

◆ m_Miniport

PMINIPORTWAVECYCLIC CPortPinWaveCyclic::m_Miniport

protected

Definition at line 78 of file pin_wavecyclic.cpp.

◆ m_Port

IPortWaveCyclic* CPortPinWaveCyclic::m_Port

protected

Definition at line 75 of file pin_wavecyclic.cpp.

◆ m_Position

KSAUDIO_POSITION CPortPinWaveCyclic::m_Position

protected

Definition at line 97 of file pin_wavecyclic.cpp.

Referenced by UpdateCommonBuffer(), and UpdateCommonBufferOverlap().

◆ m_ResetState

KSRESET CPortPinWaveCyclic::m_ResetState

protected

Definition at line 104 of file pin_wavecyclic.cpp.

◆ m_ServiceGroup

PSERVICEGROUP CPortPinWaveCyclic::m_ServiceGroup

protected

Definition at line 79 of file pin_wavecyclic.cpp.

◆ m_State

KSSTATE CPortPinWaveCyclic::m_State

protected

Definition at line 82 of file pin_wavecyclic.cpp.

◆ m_StopCount

ULONG CPortPinWaveCyclic::m_StopCount

protected

Definition at line 96 of file pin_wavecyclic.cpp.

◆ m_Stream

PMINIPORTWAVECYCLICSTREAM CPortPinWaveCyclic::m_Stream

protected

Definition at line 81 of file pin_wavecyclic.cpp.

Referenced by UpdateCommonBuffer(), and UpdateCommonBufferOverlap().

◆ m_TotalPackets

ULONG CPortPinWaveCyclic::m_TotalPackets

protected

Definition at line 95 of file pin_wavecyclic.cpp.

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

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

Public Member Functions

Public Attributes

Protected Member Functions

Protected Attributes

Friends

Detailed Description

Constructor & Destructor Documentation

◆ CPortPinWaveCyclic()

◆ ~CPortPinWaveCyclic()

Member Function Documentation

◆ GeneratePositionEvents()

◆ operator new()

◆ QueryInterface()

◆ UpdateCommonBuffer()

◆ UpdateCommonBufferOverlap()

Friends And Related Function Documentation

◆ PinSetStateWorkerRoutine

◆ PinWaveCyclicAddEndOfStreamEvent

◆ PinWaveCyclicAddLoopedStreamEvent

◆ PinWaveCyclicAllocatorFraming

◆ PinWaveCyclicAudioPosition

◆ PinWaveCyclicDataFormat

◆ PinWaveCyclicState

Member Data Documentation

◆ IMP_IPortPinWaveCyclic

◆ IMP_IServiceSink

◆ m_AllocatorFraming

◆ m_Capture

◆ m_CommonBuffer

◆ m_CommonBufferOffset

◆ m_CommonBufferSize

◆ m_ConnectDetails

◆ m_Delay

◆ m_Descriptor

◆ m_DmaChannel

◆ m_EventList

◆ m_EventListLock

◆ m_Filter

◆ m_Format

◆ m_FrameSize

◆ m_IrpQueue

◆ m_KsPinDescriptor

◆ m_Miniport

◆ m_Port

◆ m_Position

◆ m_ResetState

◆ m_ServiceGroup

◆ m_State

◆ m_StopCount

◆ m_Stream

◆ m_TotalPackets