Inheritance diagram for CPortPinWaveRT:

Collaboration diagram for CPortPinWaveRT:

[legend]

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.

39 {}

◆ ~CPortPinWaveRT()

virtual CPortPinWaveRT::~CPortPinWaveRT ( )

inlinevirtual

Definition at line 40 of file pin_wavert.cpp.

40 {}

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 374 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

Public Member Functions

Public Attributes

Protected Member Functions

Protected Attributes

Friends

Detailed Description

Constructor & Destructor Documentation

◆ CPortPinWaveRT()

◆ ~CPortPinWaveRT()

Member Function Documentation

◆ HandleKsProperty()

◆ HandleKsStream()

◆ QueryInterface()

◆ SetStreamState()

◆ STDMETHODIMP_() [1/2]

◆ STDMETHODIMP_() [2/2]

Friends And Related Function Documentation

◆ CloseStreamRoutine

◆ SetStreamWorkerRoutine

Member Data Documentation

◆ IMP_IPortPinWaveRT

◆ m_CacheType

◆ m_Capture

◆ m_CommonBuffer

◆ m_CommonBufferOffset

◆ m_CommonBufferSize

◆ m_ConnectDetails

◆ m_Delay

◆ m_Filter

◆ m_Format

◆ m_IrpQueue

◆ m_KsPinDescriptor

◆ m_Mdl

◆ m_Miniport

◆ m_Port

◆ m_PortStream

◆ m_PostCompleted

◆ m_PreCompleted

◆ m_Ref

◆ m_State

◆ m_Stream

◆ m_TotalPackets