diff options
Diffstat (limited to 'portaudio/src/hostapi/wdmks/pa_win_wdmks.c')
| -rw-r--r-- | portaudio/src/hostapi/wdmks/pa_win_wdmks.c | 6807 |
1 files changed, 0 insertions, 6807 deletions
diff --git a/portaudio/src/hostapi/wdmks/pa_win_wdmks.c b/portaudio/src/hostapi/wdmks/pa_win_wdmks.c deleted file mode 100644 index 161c264..0000000 --- a/portaudio/src/hostapi/wdmks/pa_win_wdmks.c +++ /dev/null @@ -1,6807 +0,0 @@ -/* -* $Id$ -* PortAudio Windows WDM-KS interface -* -* Author: Andrew Baldwin, Robert Bielik (WaveRT) -* Based on the Open Source API proposed by Ross Bencina -* Copyright (c) 1999-2004 Andrew Baldwin, Ross Bencina, Phil Burk -* -* Permission is hereby granted, free of charge, to any person obtaining -* a copy of this software and associated documentation files -* (the "Software"), to deal in the Software without restriction, -* including without limitation the rights to use, copy, modify, merge, -* publish, distribute, sublicense, and/or sell copies of the Software, -* and to permit persons to whom the Software is furnished to do so, -* subject to the following conditions: -* -* The above copyright notice and this permission notice shall be -* included in all copies or substantial portions of the Software. -* -* THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, -* EXPRESS OR IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF -* MERCHANTABILITY, FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. -* IN NO EVENT SHALL THE AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR -* ANY CLAIM, DAMAGES OR OTHER LIABILITY, WHETHER IN AN ACTION OF -* CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN CONNECTION -* WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE. -*/ - -/* -* The text above constitutes the entire PortAudio license; however, -* the PortAudio community also makes the following non-binding requests: -* -* Any person wishing to distribute modifications to the Software is -* requested to send the modifications to the original developer so that -* they can be incorporated into the canonical version. It is also -* requested that these non-binding requests be included along with the -* license above. -*/ - -/** @file -@ingroup hostapi_src -@brief Portaudio WDM-KS host API. - -@note This is the implementation of the Portaudio host API using the -Windows WDM/Kernel Streaming API in order to enable very low latency -playback and recording on all modern Windows platforms (e.g. 2K, XP, Vista, Win7) -Note: This API accesses the device drivers below the usual KMIXER -component which is normally used to enable multi-client mixing and -format conversion. That means that it will lock out all other users -of a device for the duration of active stream using those devices -*/ - -#include <stdio.h> - -#if (defined(_WIN32) && (defined(_MSC_VER) && (_MSC_VER >= 1200))) /* MSC version 6 and above */ -#pragma comment( lib, "setupapi.lib" ) -#endif - -/* Debugging/tracing support */ - -#define PA_LOGE_ -#define PA_LOGL_ - -#ifdef __GNUC__ -#include <initguid.h> -#define _WIN32_WINNT 0x0501 -#define WINVER 0x0501 -#endif - -#include <string.h> /* strlen() */ -#include <assert.h> -#include <wchar.h> /* iswspace() */ - -#include "pa_util.h" -#include "pa_allocation.h" -#include "pa_hostapi.h" -#include "pa_stream.h" -#include "pa_cpuload.h" -#include "pa_process.h" -#include "portaudio.h" -#include "pa_debugprint.h" -#include "pa_memorybarrier.h" -#include "pa_ringbuffer.h" -#include "pa_trace.h" -#include "pa_win_waveformat.h" - -#include "pa_win_wdmks.h" - -#ifndef DRV_QUERYDEVICEINTERFACE -#define DRV_QUERYDEVICEINTERFACE (DRV_RESERVED + 12) -#endif -#ifndef DRV_QUERYDEVICEINTERFACESIZE -#define DRV_QUERYDEVICEINTERFACESIZE (DRV_RESERVED + 13) -#endif - -#include <windows.h> -#ifndef __GNUC__ /* Fix for ticket #257: MinGW-w64: Inclusion of <winioctl.h> triggers multiple redefinition errors. */ -#include <winioctl.h> -#endif -#include <process.h> - -#include <math.h> - -#ifdef _MSC_VER -#define snprintf _snprintf -#define vsnprintf _vsnprintf -#endif - -/* The PA_HP_TRACE macro is used in RT parts, so it can be switched off without affecting -the rest of the debug tracing */ -#if 1 -#define PA_HP_TRACE(x) PaUtil_AddHighSpeedLogMessage x ; -#else -#define PA_HP_TRACE(x) -#endif - -/* A define that selects whether the resulting pin names are chosen from pin category -instead of the available pin names, who sometimes can be quite cheesy, like "Volume control". -Default is to use the pin category. -*/ -#ifndef PA_WDMKS_USE_CATEGORY_FOR_PIN_NAMES -#define PA_WDMKS_USE_CATEGORY_FOR_PIN_NAMES 1 -#endif - -#ifdef __GNUC__ -#undef PA_LOGE_ -#define PA_LOGE_ PA_DEBUG(("%s {\n",__FUNCTION__)) -#undef PA_LOGL_ -#define PA_LOGL_ PA_DEBUG(("} %s\n",__FUNCTION__)) -/* These defines are set in order to allow the WIndows DirectX -* headers to compile with a GCC compiler such as MinGW -* NOTE: The headers may generate a few warning in GCC, but -* they should compile */ -#define _INC_MMSYSTEM -#define _INC_MMREG -#define _NTRTL_ /* Turn off default definition of DEFINE_GUIDEX */ -#define DEFINE_GUID_THUNK(name,guid) DEFINE_GUID(name,guid) -#define DEFINE_GUIDEX(n) DEFINE_GUID_THUNK( n, STATIC_##n ) -#if !defined( DEFINE_WAVEFORMATEX_GUID ) -#define DEFINE_WAVEFORMATEX_GUID(x) (USHORT)(x), 0x0000, 0x0010, 0x80, 0x00, 0x00, 0xaa, 0x00, 0x38, 0x9b, 0x71 -#endif -#define WAVE_FORMAT_ADPCM 0x0002 -#define WAVE_FORMAT_IEEE_FLOAT 0x0003 -#define WAVE_FORMAT_ALAW 0x0006 -#define WAVE_FORMAT_MULAW 0x0007 -#define WAVE_FORMAT_MPEG 0x0050 -#define WAVE_FORMAT_DRM 0x0009 -#define DYNAMIC_GUID_THUNK(l,w1,w2,b1,b2,b3,b4,b5,b6,b7,b8) {l,w1,w2,{b1,b2,b3,b4,b5,b6,b7,b8}} -#define DYNAMIC_GUID(data) DYNAMIC_GUID_THUNK(data) -#endif - -/* use CreateThread for CYGWIN/Windows Mobile, _beginthreadex for all others */ -#if !defined(__CYGWIN__) && !defined(_WIN32_WCE) -#define CREATE_THREAD_FUNCTION (HANDLE)_beginthreadex -#define PA_THREAD_FUNC static unsigned WINAPI -#else -#define CREATE_THREAD_FUNCTION CreateThread -#define PA_THREAD_FUNC static DWORD WINAPI -#endif - -#ifdef _MSC_VER -#define NOMMIDS -#define DYNAMIC_GUID(data) {data} -#define _NTRTL_ /* Turn off default definition of DEFINE_GUIDEX */ -#undef DEFINE_GUID -#if defined(__clang__) || (defined(_MSVC_TRADITIONAL) && !_MSVC_TRADITIONAL) /* clang-cl and new msvc preprocessor: avoid too many arguments error */ - #define DEFINE_GUID(n, ...) EXTERN_C const GUID n = {__VA_ARGS__} - #define DEFINE_GUID_THUNK(n, ...) DEFINE_GUID(n, __VA_ARGS__) - #define DEFINE_GUIDEX(n) DEFINE_GUID_THUNK(n, STATIC_##n) -#else - #define DEFINE_GUID(n, data) EXTERN_C const GUID n = {data} - #define DEFINE_GUID_THUNK(n, data) DEFINE_GUID(n, data) - #define DEFINE_GUIDEX(n) DEFINE_GUID_THUNK(n, STATIC_##n) -#endif /* __clang__, !_MSVC_TRADITIONAL */ -#endif - -#include <setupapi.h> - -#ifndef EXTERN_C -#define EXTERN_C extern -#endif - -#if defined(__GNUC__) - -/* For MinGW we reference mingw-include files supplied with WASAPI */ -#define WINBOOL BOOL - -#include "../wasapi/mingw-include/ks.h" -#include "../wasapi/mingw-include/ksmedia.h" - -#else - -#include <mmreg.h> -#include <ks.h> - -/* Note that Windows SDK V6.0A or later is needed for WaveRT specific structs to be present in - ksmedia.h. Also make sure that the SDK include path is before other include paths (that may contain - an "old" ksmedia.h), so the proper ksmedia.h is used */ -#include <ksmedia.h> - -#endif - -#include <assert.h> -#include <stdio.h> - -/* These next definitions allow the use of the KSUSER DLL */ -typedef /*KSDDKAPI*/ DWORD WINAPI KSCREATEPIN(HANDLE, PKSPIN_CONNECT, ACCESS_MASK, PHANDLE); -extern HMODULE DllKsUser; -extern KSCREATEPIN* FunctionKsCreatePin; - -/* These definitions allows the use of AVRT.DLL on Vista and later OSs */ -typedef enum _PA_AVRT_PRIORITY -{ - PA_AVRT_PRIORITY_LOW = -1, - PA_AVRT_PRIORITY_NORMAL, - PA_AVRT_PRIORITY_HIGH, - PA_AVRT_PRIORITY_CRITICAL -} PA_AVRT_PRIORITY, *PPA_AVRT_PRIORITY; - -typedef struct -{ - HINSTANCE hInstance; - - HANDLE (WINAPI *AvSetMmThreadCharacteristics) (LPCSTR, LPDWORD); - BOOL (WINAPI *AvRevertMmThreadCharacteristics) (HANDLE); - BOOL (WINAPI *AvSetMmThreadPriority) (HANDLE, PA_AVRT_PRIORITY); -} PaWinWDMKSAvRtEntryPoints; - -static PaWinWDMKSAvRtEntryPoints paWinWDMKSAvRtEntryPoints = {0}; - -/* An unspecified channel count (-1) is not treated correctly, so we replace it with -* an arbitrarily large number */ -#define MAXIMUM_NUMBER_OF_CHANNELS 256 - -/* Forward definition to break circular type reference between pin and filter */ -struct __PaWinWdmFilter; -typedef struct __PaWinWdmFilter PaWinWdmFilter; - -struct __PaWinWdmPin; -typedef struct __PaWinWdmPin PaWinWdmPin; - -struct __PaWinWdmStream; -typedef struct __PaWinWdmStream PaWinWdmStream; - -/* Function prototype for getting audio position */ -typedef PaError (*FunctionGetPinAudioPosition)(PaWinWdmPin*, unsigned long*); - -/* Function prototype for memory barrier */ -typedef void (*FunctionMemoryBarrier)(void); - -struct __PaProcessThreadInfo; -typedef struct __PaProcessThreadInfo PaProcessThreadInfo; - -typedef PaError (*FunctionPinHandler)(PaProcessThreadInfo* pInfo, unsigned eventIndex); - -typedef enum __PaStreamStartEnum -{ - StreamStart_kOk, - StreamStart_kFailed, - StreamStart_kCnt -} PaStreamStartEnum; - -/* Multiplexed input structure. -* Very often several physical inputs are multiplexed through a MUX node (represented in the topology filter) */ -typedef struct __PaWinWdmMuxedInput -{ - wchar_t friendlyName[MAX_PATH]; - ULONG muxPinId; - ULONG muxNodeId; - ULONG endpointPinId; -} PaWinWdmMuxedInput; - -/* The Pin structure -* A pin is an input or output node, e.g. for audio flow */ -struct __PaWinWdmPin -{ - HANDLE handle; - PaWinWdmMuxedInput** inputs; - unsigned inputCount; - wchar_t friendlyName[MAX_PATH]; - - PaWinWdmFilter* parentFilter; - PaWDMKSSubType pinKsSubType; - unsigned long pinId; - unsigned long endpointPinId; /* For output pins */ - KSPIN_CONNECT* pinConnect; - unsigned long pinConnectSize; - KSDATAFORMAT_WAVEFORMATEX* ksDataFormatWfx; - KSPIN_COMMUNICATION communication; - KSDATARANGE* dataRanges; - KSMULTIPLE_ITEM* dataRangesItem; - KSPIN_DATAFLOW dataFlow; - KSPIN_CINSTANCES instances; - unsigned long frameSize; - int maxChannels; - unsigned long formats; - int defaultSampleRate; - ULONG *positionRegister; /* WaveRT */ - ULONG hwLatency; /* WaveRT */ - FunctionMemoryBarrier fnMemBarrier; /* WaveRT */ - FunctionGetPinAudioPosition fnAudioPosition; /* WaveRT */ - FunctionPinHandler fnEventHandler; - FunctionPinHandler fnSubmitHandler; -}; - -/* The Filter structure -* A filter has a number of pins and a "friendly name" */ -struct __PaWinWdmFilter -{ - HANDLE handle; - PaWinWDMKSDeviceInfo devInfo; /* This will hold information that is exposed in PaDeviceInfo */ - - DWORD deviceNode; - int pinCount; - PaWinWdmPin** pins; - PaWinWdmFilter* topologyFilter; - wchar_t friendlyName[MAX_PATH]; - int validPinCount; - int usageCount; - KSMULTIPLE_ITEM* connections; - KSMULTIPLE_ITEM* nodes; - int filterRefCount; -}; - - -typedef struct __PaWinWdmDeviceInfo -{ - PaDeviceInfo inheritedDeviceInfo; - char compositeName[MAX_PATH]; /* Composite name consists of pin name + device name in utf8 */ - PaWinWdmFilter* filter; - unsigned long pin; - int muxPosition; /* Used only for input devices */ - int endpointPinId; -} -PaWinWdmDeviceInfo; - -/* PaWinWdmHostApiRepresentation - host api datastructure specific to this implementation */ -typedef struct __PaWinWdmHostApiRepresentation -{ - PaUtilHostApiRepresentation inheritedHostApiRep; - PaUtilStreamInterface callbackStreamInterface; - PaUtilStreamInterface blockingStreamInterface; - - PaUtilAllocationGroup* allocations; - int deviceCount; -} -PaWinWdmHostApiRepresentation; - -typedef struct __DATAPACKET -{ - KSSTREAM_HEADER Header; - OVERLAPPED Signal; -} DATAPACKET; - -typedef struct __PaIOPacket -{ - DATAPACKET* packet; - unsigned startByte; - unsigned lengthBytes; -} PaIOPacket; - -typedef struct __PaWinWdmIOInfo -{ - PaWinWdmPin* pPin; - char* hostBuffer; - unsigned hostBufferSize; - unsigned framesPerBuffer; - unsigned bytesPerFrame; - unsigned bytesPerSample; - unsigned noOfPackets; /* Only used in WaveCyclic */ - HANDLE *events; /* noOfPackets handles (WaveCyclic) 1 (WaveRT) */ - DATAPACKET *packets; /* noOfPackets packets (WaveCyclic) 2 (WaveRT) */ - /* WaveRT polled mode */ - unsigned lastPosition; - unsigned pollCntr; -} PaWinWdmIOInfo; - -/* PaWinWdmStream - a stream data structure specifically for this implementation */ -struct __PaWinWdmStream -{ - PaUtilStreamRepresentation streamRepresentation; - PaWDMKSSpecificStreamInfo hostApiStreamInfo; /* This holds info that is exposed through PaStreamInfo */ - PaUtilCpuLoadMeasurer cpuLoadMeasurer; - PaUtilBufferProcessor bufferProcessor; - -#if PA_TRACE_REALTIME_EVENTS - LogHandle hLog; -#endif - - PaUtilAllocationGroup* allocGroup; - PaWinWdmIOInfo capture; - PaWinWdmIOInfo render; - int streamStarted; - int streamActive; - int streamStop; - int streamAbort; - int oldProcessPriority; - HANDLE streamThread; - HANDLE eventAbort; - HANDLE eventStreamStart[StreamStart_kCnt]; /* 0 = OK, 1 = Failed */ - PaError threadResult; - PaStreamFlags streamFlags; - - /* Capture ring buffer */ - PaUtilRingBuffer ringBuffer; - char* ringBufferData; - - /* These values handle the case where the user wants to use fewer - * channels than the device has */ - int userInputChannels; - int deviceInputChannels; - int userOutputChannels; - int deviceOutputChannels; -}; - -/* Gather all processing variables in a struct */ -struct __PaProcessThreadInfo -{ - PaWinWdmStream *stream; - PaStreamCallbackTimeInfo ti; - PaStreamCallbackFlags underover; - int cbResult; - volatile int pending; - volatile int priming; - volatile int pinsStarted; - unsigned long timeout; - unsigned captureHead; - unsigned captureTail; - unsigned renderHead; - unsigned renderTail; - PaIOPacket capturePackets[4]; - PaIOPacket renderPackets[4]; -}; - -/* Used for transferring device infos during scanning / rescanning */ -typedef struct __PaWinWDMScanDeviceInfosResults -{ - PaDeviceInfo **deviceInfos; - PaDeviceIndex defaultInputDevice; - PaDeviceIndex defaultOutputDevice; -} PaWinWDMScanDeviceInfosResults; - -static const unsigned cPacketsArrayMask = 3; - -HMODULE DllKsUser = NULL; -KSCREATEPIN* FunctionKsCreatePin = NULL; - -/* prototypes for functions declared in this file */ - -#ifdef __cplusplus -extern "C" -{ -#endif /* __cplusplus */ - - PaError PaWinWdm_Initialize( PaUtilHostApiRepresentation **hostApi, PaHostApiIndex index ); - -#ifdef __cplusplus -} -#endif /* __cplusplus */ - -/* Low level I/O functions */ -static PaError WdmSyncIoctl(HANDLE handle, - unsigned long ioctlNumber, - void* inBuffer, - unsigned long inBufferCount, - void* outBuffer, - unsigned long outBufferCount, - unsigned long* bytesReturned); - -static PaError WdmGetPropertySimple(HANDLE handle, - const GUID* const guidPropertySet, - unsigned long property, - void* value, - unsigned long valueCount); - -static PaError WdmSetPropertySimple(HANDLE handle, - const GUID* const guidPropertySet, - unsigned long property, - void* value, - unsigned long valueCount, - void* instance, - unsigned long instanceCount); - -static PaError WdmGetPinPropertySimple(HANDLE handle, - unsigned long pinId, - const GUID* const guidPropertySet, - unsigned long property, - void* value, - unsigned long valueCount, - unsigned long* byteCount); - -static PaError WdmGetPinPropertyMulti(HANDLE handle, - unsigned long pinId, - const GUID* const guidPropertySet, - unsigned long property, - KSMULTIPLE_ITEM** ksMultipleItem); - -static PaError WdmGetPropertyMulti(HANDLE handle, - const GUID* const guidPropertySet, - unsigned long property, - KSMULTIPLE_ITEM** ksMultipleItem); - -static PaError WdmSetMuxNodeProperty(HANDLE handle, - ULONG nodeId, - ULONG pinId); - - -/** Pin management functions */ -static PaWinWdmPin* PinNew(PaWinWdmFilter* parentFilter, unsigned long pinId, PaError* error); -static void PinFree(PaWinWdmPin* pin); -static void PinClose(PaWinWdmPin* pin); -static PaError PinInstantiate(PaWinWdmPin* pin); -/*static PaError PinGetState(PaWinWdmPin* pin, KSSTATE* state); NOT USED */ -static PaError PinSetState(PaWinWdmPin* pin, KSSTATE state); -static PaError PinSetFormat(PaWinWdmPin* pin, const WAVEFORMATEX* format); -static PaError PinIsFormatSupported(PaWinWdmPin* pin, const WAVEFORMATEX* format); -/* WaveRT support */ -static PaError PinQueryNotificationSupport(PaWinWdmPin* pPin, BOOL* pbResult); -static PaError PinGetBuffer(PaWinWdmPin* pPin, void** pBuffer, DWORD* pRequestedBufSize, BOOL* pbCallMemBarrier); -static PaError PinRegisterPositionRegister(PaWinWdmPin* pPin); -static PaError PinRegisterNotificationHandle(PaWinWdmPin* pPin, HANDLE handle); -static PaError PinUnregisterNotificationHandle(PaWinWdmPin* pPin, HANDLE handle); -static PaError PinGetHwLatency(PaWinWdmPin* pPin, ULONG* pFifoSize, ULONG* pChipsetDelay, ULONG* pCodecDelay); -static PaError PinGetAudioPositionMemoryMapped(PaWinWdmPin* pPin, ULONG* pPosition); -static PaError PinGetAudioPositionViaIOCTLRead(PaWinWdmPin* pPin, ULONG* pPosition); -static PaError PinGetAudioPositionViaIOCTLWrite(PaWinWdmPin* pPin, ULONG* pPosition); - -/* Filter management functions */ -static PaWinWdmFilter* FilterNew(PaWDMKSType type, DWORD devNode, const wchar_t* filterName, const wchar_t* friendlyName, PaError* error); -static PaError FilterInitializePins(PaWinWdmFilter* filter); -static void FilterFree(PaWinWdmFilter* filter); -static void FilterAddRef(PaWinWdmFilter* filter); -static PaWinWdmPin* FilterCreatePin( - PaWinWdmFilter* filter, - int pinId, - const WAVEFORMATEX* wfex, - PaError* error); -static PaError FilterUse(PaWinWdmFilter* filter); -static void FilterRelease(PaWinWdmFilter* filter); - -/* Hot plug functions */ -static BOOL IsDeviceTheSame(const PaWinWdmDeviceInfo* pDev1, - const PaWinWdmDeviceInfo* pDev2); - -/* Interface functions */ -static void Terminate( struct PaUtilHostApiRepresentation *hostApi ); -static PaError IsFormatSupported( -struct PaUtilHostApiRepresentation *hostApi, - const PaStreamParameters *inputParameters, - const PaStreamParameters *outputParameters, - double sampleRate ); - -static PaError ScanDeviceInfos( struct PaUtilHostApiRepresentation *hostApi, PaHostApiIndex index, void **newDeviceInfos, int *newDeviceCount ); -static PaError CommitDeviceInfos( struct PaUtilHostApiRepresentation *hostApi, PaHostApiIndex index, void *deviceInfos, int deviceCount ); -static PaError DisposeDeviceInfos( struct PaUtilHostApiRepresentation *hostApi, void *deviceInfos, int deviceCount ); - -static PaError OpenStream( -struct PaUtilHostApiRepresentation *hostApi, - PaStream** s, - const PaStreamParameters *inputParameters, - const PaStreamParameters *outputParameters, - double sampleRate, - unsigned long framesPerBuffer, - PaStreamFlags streamFlags, - PaStreamCallback *streamCallback, - void *userData ); -static PaError CloseStream( PaStream* stream ); -static PaError StartStream( PaStream *stream ); -static PaError StopStream( PaStream *stream ); -static PaError AbortStream( PaStream *stream ); -static PaError IsStreamStopped( PaStream *s ); -static PaError IsStreamActive( PaStream *stream ); -static PaTime GetStreamTime( PaStream *stream ); -static double GetStreamCpuLoad( PaStream* stream ); -static PaError ReadStream( - PaStream* stream, - void *buffer, - unsigned long frames ); -static PaError WriteStream( - PaStream* stream, - const void *buffer, - unsigned long frames ); -static signed long GetStreamReadAvailable( PaStream* stream ); -static signed long GetStreamWriteAvailable( PaStream* stream ); - -/* Utility functions */ -static unsigned long GetWfexSize(const WAVEFORMATEX* wfex); -static PaWinWdmFilter** BuildFilterList(int* filterCount, int* noOfPaDevices, PaError* result); -static BOOL PinWrite(HANDLE h, DATAPACKET* p); -static BOOL PinRead(HANDLE h, DATAPACKET* p); -static void DuplicateFirstChannelInt16(void* buffer, int channels, int samples); -static void DuplicateFirstChannelInt24(void* buffer, int channels, int samples); -PA_THREAD_FUNC ProcessingThread(void*); - -/* Pin handler functions */ -static PaError PaPinCaptureEventHandler_WaveCyclic(PaProcessThreadInfo* pInfo, unsigned eventIndex); -static PaError PaPinCaptureSubmitHandler_WaveCyclic(PaProcessThreadInfo* pInfo, unsigned eventIndex); - -static PaError PaPinRenderEventHandler_WaveCyclic(PaProcessThreadInfo* pInfo, unsigned eventIndex); -static PaError PaPinRenderSubmitHandler_WaveCyclic(PaProcessThreadInfo* pInfo, unsigned eventIndex); - -static PaError PaPinCaptureEventHandler_WaveRTEvent(PaProcessThreadInfo* pInfo, unsigned eventIndex); -static PaError PaPinCaptureEventHandler_WaveRTPolled(PaProcessThreadInfo* pInfo, unsigned eventIndex); -static PaError PaPinCaptureSubmitHandler_WaveRTEvent(PaProcessThreadInfo* pInfo, unsigned eventIndex); -static PaError PaPinCaptureSubmitHandler_WaveRTPolled(PaProcessThreadInfo* pInfo, unsigned eventIndex); - -static PaError PaPinRenderEventHandler_WaveRTEvent(PaProcessThreadInfo* pInfo, unsigned eventIndex); -static PaError PaPinRenderEventHandler_WaveRTPolled(PaProcessThreadInfo* pInfo, unsigned eventIndex); -static PaError PaPinRenderSubmitHandler_WaveRTEvent(PaProcessThreadInfo* pInfo, unsigned eventIndex); -static PaError PaPinRenderSubmitHandler_WaveRTPolled(PaProcessThreadInfo* pInfo, unsigned eventIndex); - -/* Function bodies */ - -#if defined(_DEBUG) && defined(PA_ENABLE_DEBUG_OUTPUT) -#define PA_WDMKS_SET_TREF -static PaTime tRef = 0; - -static void PaWinWdmDebugPrintf(const char* fmt, ...) -{ - va_list list; - char buffer[1024]; - PaTime t = PaUtil_GetTime() - tRef; - va_start(list, fmt); - _vsnprintf(buffer, 1023, fmt, list); - va_end(list); - PaUtil_DebugPrint("%6.3lf: %s", t, buffer); -} - -#ifdef PA_DEBUG -#undef PA_DEBUG -#define PA_DEBUG(x) PaWinWdmDebugPrintf x ; -#endif -#endif - -static BOOL IsDeviceTheSame(const PaWinWdmDeviceInfo* pDev1, - const PaWinWdmDeviceInfo* pDev2) -{ - if (pDev1 == NULL || pDev2 == NULL) - return FALSE; - - if (pDev1 == pDev2) - return TRUE; - - if (strcmp(pDev1->compositeName, pDev2->compositeName) == 0) - return TRUE; - - return FALSE; -} - -static BOOL IsEarlierThanVista() -{ -/* -NOTE: GetVersionEx() is deprecated as of Windows 8.1 and can not be used to reliably detect -versions of Windows higher than Windows 8 (due to manifest requirements for reporting higher versions). -Microsoft recommends switching to VerifyVersionInfo (available on Win 2k and later), however GetVersionEx -is faster, for now we just disable the deprecation warning. -See: https://msdn.microsoft.com/en-us/library/windows/desktop/ms724451(v=vs.85).aspx -See: http://www.codeproject.com/Articles/678606/Part-Overcoming-Windows-s-deprecation-of-GetVe -*/ -#pragma warning (disable : 4996) /* use of GetVersionEx */ - - OSVERSIONINFO osvi; - osvi.dwOSVersionInfoSize = sizeof(osvi); - if (GetVersionEx(&osvi) && osvi.dwMajorVersion<6) - { - return TRUE; - } - return FALSE; - -#pragma warning (default : 4996) -} - - - -static void MemoryBarrierDummy(void) -{ - /* Do nothing */ -} - -static void MemoryBarrierRead(void) -{ - PaUtil_ReadMemoryBarrier(); -} - -static void MemoryBarrierWrite(void) -{ - PaUtil_WriteMemoryBarrier(); -} - -static unsigned long GetWfexSize(const WAVEFORMATEX* wfex) -{ - if( wfex->wFormatTag == WAVE_FORMAT_PCM ) - { - return sizeof( WAVEFORMATEX ); - } - else - { - return (sizeof( WAVEFORMATEX ) + wfex->cbSize); - } -} - -static void PaWinWDM_SetLastErrorInfo(long errCode, const char* fmt, ...) -{ - va_list list; - char buffer[1024]; - va_start(list, fmt); - _vsnprintf(buffer, 1023, fmt, list); - va_end(list); - PaUtil_SetLastHostErrorInfo(paWDMKS, errCode, buffer); -} - -/* -Low level pin/filter access functions -*/ -static PaError WdmSyncIoctl( - HANDLE handle, - unsigned long ioctlNumber, - void* inBuffer, - unsigned long inBufferCount, - void* outBuffer, - unsigned long outBufferCount, - unsigned long* bytesReturned) -{ - PaError result = paNoError; - unsigned long dummyBytesReturned = 0; - BOOL bRes; - - if( !bytesReturned ) - { - /* Use a dummy as the caller hasn't supplied one */ - bytesReturned = &dummyBytesReturned; - } - - bRes = DeviceIoControl(handle, ioctlNumber, inBuffer, inBufferCount, outBuffer, outBufferCount, bytesReturned, NULL); - if (!bRes) - { - unsigned long error = GetLastError(); - if ( !(((error == ERROR_INSUFFICIENT_BUFFER ) || ( error == ERROR_MORE_DATA )) && - ( ioctlNumber == IOCTL_KS_PROPERTY ) && - ( outBufferCount == 0 ) ) ) - { - KSPROPERTY* ksProperty = (KSPROPERTY*)inBuffer; - - PaWinWDM_SetLastErrorInfo(result, "WdmSyncIoctl: DeviceIoControl GLE = 0x%08X (prop_set = {%08X-%04X-%04X-%02X%02X-%02X%02X%02X%02X%02X%02X}, prop_id = %u)", - error, - ksProperty->Set.Data1, ksProperty->Set.Data2, ksProperty->Set.Data3, - ksProperty->Set.Data4[0], ksProperty->Set.Data4[1], - ksProperty->Set.Data4[2], ksProperty->Set.Data4[3], - ksProperty->Set.Data4[4], ksProperty->Set.Data4[5], - ksProperty->Set.Data4[6], ksProperty->Set.Data4[7], - ksProperty->Id - ); - result = paUnanticipatedHostError; - } - } - return result; -} - -static PaError WdmGetPropertySimple(HANDLE handle, - const GUID* const guidPropertySet, - unsigned long property, - void* value, - unsigned long valueCount) -{ - PaError result; - KSPROPERTY ksProperty; - - ksProperty.Set = *guidPropertySet; - ksProperty.Id = property; - ksProperty.Flags = KSPROPERTY_TYPE_GET; - - result = WdmSyncIoctl( - handle, - IOCTL_KS_PROPERTY, - &ksProperty, - sizeof(KSPROPERTY), - value, - valueCount, - NULL); - - return result; -} - -static PaError WdmSetPropertySimple( - HANDLE handle, - const GUID* const guidPropertySet, - unsigned long property, - void* value, - unsigned long valueCount, - void* instance, - unsigned long instanceCount) -{ - PaError result; - KSPROPERTY* ksProperty; - unsigned long propertyCount = 0; - - propertyCount = sizeof(KSPROPERTY) + instanceCount; - ksProperty = (KSPROPERTY*)_alloca( propertyCount ); - if( !ksProperty ) - { - return paInsufficientMemory; - } - - ksProperty->Set = *guidPropertySet; - ksProperty->Id = property; - ksProperty->Flags = KSPROPERTY_TYPE_SET; - - if( instance ) - { - memcpy((void*)((char*)ksProperty + sizeof(KSPROPERTY)), instance, instanceCount); - } - - result = WdmSyncIoctl( - handle, - IOCTL_KS_PROPERTY, - ksProperty, - propertyCount, - value, - valueCount, - NULL); - - return result; -} - -static PaError WdmGetPinPropertySimple( - HANDLE handle, - unsigned long pinId, - const GUID* const guidPropertySet, - unsigned long property, - void* value, - unsigned long valueCount, - unsigned long *byteCount) -{ - PaError result; - - KSP_PIN ksPProp; - ksPProp.Property.Set = *guidPropertySet; - ksPProp.Property.Id = property; - ksPProp.Property.Flags = KSPROPERTY_TYPE_GET; - ksPProp.PinId = pinId; - ksPProp.Reserved = 0; - - result = WdmSyncIoctl( - handle, - IOCTL_KS_PROPERTY, - &ksPProp, - sizeof(KSP_PIN), - value, - valueCount, - byteCount); - - return result; -} - -static PaError WdmGetPinPropertyMulti( - HANDLE handle, - unsigned long pinId, - const GUID* const guidPropertySet, - unsigned long property, - KSMULTIPLE_ITEM** ksMultipleItem) -{ - PaError result; - unsigned long multipleItemSize = 0; - KSP_PIN ksPProp; - - ksPProp.Property.Set = *guidPropertySet; - ksPProp.Property.Id = property; - ksPProp.Property.Flags = KSPROPERTY_TYPE_GET; - ksPProp.PinId = pinId; - ksPProp.Reserved = 0; - - result = WdmSyncIoctl( - handle, - IOCTL_KS_PROPERTY, - &ksPProp.Property, - sizeof(KSP_PIN), - NULL, - 0, - &multipleItemSize); - if( result != paNoError ) - { - return result; - } - - *ksMultipleItem = (KSMULTIPLE_ITEM*)PaUtil_AllocateMemory( multipleItemSize ); - if( !*ksMultipleItem ) - { - return paInsufficientMemory; - } - - result = WdmSyncIoctl( - handle, - IOCTL_KS_PROPERTY, - &ksPProp, - sizeof(KSP_PIN), - (void*)*ksMultipleItem, - multipleItemSize, - NULL); - - if( result != paNoError ) - { - PaUtil_FreeMemory( ksMultipleItem ); - } - - return result; -} - -static PaError WdmGetPropertyMulti(HANDLE handle, - const GUID* const guidPropertySet, - unsigned long property, - KSMULTIPLE_ITEM** ksMultipleItem) -{ - PaError result; - unsigned long multipleItemSize = 0; - KSPROPERTY ksProp; - - ksProp.Set = *guidPropertySet; - ksProp.Id = property; - ksProp.Flags = KSPROPERTY_TYPE_GET; - - result = WdmSyncIoctl( - handle, - IOCTL_KS_PROPERTY, - &ksProp, - sizeof(KSPROPERTY), - NULL, - 0, - &multipleItemSize); - if( result != paNoError ) - { - return result; - } - - *ksMultipleItem = (KSMULTIPLE_ITEM*)PaUtil_AllocateMemory( multipleItemSize ); - if( !*ksMultipleItem ) - { - return paInsufficientMemory; - } - - result = WdmSyncIoctl( - handle, - IOCTL_KS_PROPERTY, - &ksProp, - sizeof(KSPROPERTY), - (void*)*ksMultipleItem, - multipleItemSize, - NULL); - - if( result != paNoError ) - { - PaUtil_FreeMemory( ksMultipleItem ); - } - - return result; -} - -static PaError WdmSetMuxNodeProperty(HANDLE handle, - ULONG nodeId, - ULONG pinId) -{ - PaError result = paNoError; - KSNODEPROPERTY prop; - prop.Property.Set = KSPROPSETID_Audio; - prop.Property.Id = KSPROPERTY_AUDIO_MUX_SOURCE; - prop.Property.Flags = KSPROPERTY_TYPE_SET | KSPROPERTY_TYPE_TOPOLOGY; - prop.NodeId = nodeId; - prop.Reserved = 0; - - result = WdmSyncIoctl(handle, IOCTL_KS_PROPERTY, &prop, sizeof(KSNODEPROPERTY), &pinId, sizeof(ULONG), NULL); - - return result; -} - -/* Used when traversing topology for outputs */ -static const KSTOPOLOGY_CONNECTION* GetConnectionTo(const KSTOPOLOGY_CONNECTION* pFrom, PaWinWdmFilter* filter, int muxIdx) -{ - unsigned i; - const KSTOPOLOGY_CONNECTION* retval = NULL; - const KSTOPOLOGY_CONNECTION* connections = (const KSTOPOLOGY_CONNECTION*)(filter->connections + 1); - (void)muxIdx; - PA_DEBUG(("GetConnectionTo: Checking %u connections... (pFrom = %p)", filter->connections->Count, pFrom)); - for (i = 0; i < filter->connections->Count; ++i) - { - const KSTOPOLOGY_CONNECTION* pConn = connections + i; - if (pConn == pFrom) - continue; - - if (pConn->FromNode == pFrom->ToNode) - { - retval = pConn; - break; - } - } - PA_DEBUG(("GetConnectionTo: Returning %p\n", retval)); - return retval; -} - -/* Used when traversing topology for inputs */ -static const KSTOPOLOGY_CONNECTION* GetConnectionFrom(const KSTOPOLOGY_CONNECTION* pTo, PaWinWdmFilter* filter, int muxIdx) -{ - unsigned i; - const KSTOPOLOGY_CONNECTION* retval = NULL; - const KSTOPOLOGY_CONNECTION* connections = (const KSTOPOLOGY_CONNECTION*)(filter->connections + 1); - int muxCntr = 0; - PA_DEBUG(("GetConnectionFrom: Checking %u connections... (pTo = %p)\n", filter->connections->Count, pTo)); - for (i = 0; i < filter->connections->Count; ++i) - { - const KSTOPOLOGY_CONNECTION* pConn = connections + i; - if (pConn == pTo) - continue; - - if (pConn->ToNode == pTo->FromNode) - { - if (muxIdx >= 0) - { - if (muxCntr < muxIdx) - { - ++muxCntr; - continue; - } - } - retval = pConn; - break; - } - } - PA_DEBUG(("GetConnectionFrom: Returning %p\n", retval)); - return retval; -} - -static ULONG GetNumberOfConnectionsTo(const KSTOPOLOGY_CONNECTION* pTo, PaWinWdmFilter* filter) -{ - ULONG retval = 0; - unsigned i; - const KSTOPOLOGY_CONNECTION* connections = (const KSTOPOLOGY_CONNECTION*)(filter->connections + 1); - PA_DEBUG(("GetNumberOfConnectionsTo: Checking %u connections...\n", filter->connections->Count)); - for (i = 0; i < filter->connections->Count; ++i) - { - const KSTOPOLOGY_CONNECTION* pConn = connections + i; - if (pConn->ToNode == pTo->FromNode && - (pTo->FromNode != KSFILTER_NODE || pConn->ToNodePin == pTo->FromNodePin)) - { - ++retval; - } - } - PA_DEBUG(("GetNumberOfConnectionsTo: Returning %d\n", retval)); - return retval; -} - -typedef const KSTOPOLOGY_CONNECTION *(*TFnGetConnection)(const KSTOPOLOGY_CONNECTION*, PaWinWdmFilter*, int); - -static const KSTOPOLOGY_CONNECTION* FindStartConnectionFrom(ULONG startPin, PaWinWdmFilter* filter) -{ - unsigned i; - const KSTOPOLOGY_CONNECTION* connections = (const KSTOPOLOGY_CONNECTION*)(filter->connections + 1); - PA_DEBUG(("FindStartConnectionFrom: Startpin %u, Checking %u connections...\n", startPin, filter->connections->Count)); - for (i = 0; i < filter->connections->Count; ++i) - { - const KSTOPOLOGY_CONNECTION* pConn = connections + i; - if (pConn->ToNode == KSFILTER_NODE && pConn->ToNodePin == startPin) - { - PA_DEBUG(("FindStartConnectionFrom: returning %p\n", pConn)); - return pConn; - } - } - - /* Some devices may report topologies that leave pins unconnected. This may be by design or driver installation - issues. Pass the error condition back to caller. */ - PA_DEBUG(("FindStartConnectionFrom: returning NULL\n")); - return 0; -} - -static const KSTOPOLOGY_CONNECTION* FindStartConnectionTo(ULONG startPin, PaWinWdmFilter* filter) -{ - unsigned i; - const KSTOPOLOGY_CONNECTION* connections = (const KSTOPOLOGY_CONNECTION*)(filter->connections + 1); - PA_DEBUG(("FindStartConnectionTo: Startpin %u, Checking %u connections...\n", startPin, filter->connections->Count)); - for (i = 0; i < filter->connections->Count; ++i) - { - const KSTOPOLOGY_CONNECTION* pConn = connections + i; - if (pConn->FromNode == KSFILTER_NODE && pConn->FromNodePin == startPin) - { - PA_DEBUG(("FindStartConnectionTo: returning %p\n", pConn)); - return pConn; - } - } - - /* Unconnected pin. Inform caller. */ - PA_DEBUG(("FindStartConnectionTo: returning NULL\n")); - return 0; -} - -static ULONG GetConnectedPin(ULONG startPin, BOOL forward, PaWinWdmFilter* filter, int muxPosition, ULONG *muxInputPinId, ULONG *muxNodeId) -{ - int limit=1000; - const KSTOPOLOGY_CONNECTION *conn = NULL; - TFnGetConnection fnGetConnection = forward ? GetConnectionTo : GetConnectionFrom ; - PA_LOGE_; - while (1) - { - limit--; - if (limit == 0) { - PA_DEBUG(("GetConnectedPin: LOOP LIMIT REACHED\n")); - break; - } - - if (conn == NULL) - { - conn = forward ? FindStartConnectionTo(startPin, filter) : FindStartConnectionFrom(startPin, filter); - } - else - { - conn = fnGetConnection(conn, filter, -1); - } - - /* Handling case of erroneous connection list */ - if (conn == NULL) - { - break; - } - - if (forward ? conn->ToNode == KSFILTER_NODE : conn->FromNode == KSFILTER_NODE) - { - return forward ? conn->ToNodePin : conn->FromNodePin; - } - else - { - PA_DEBUG(("GetConnectedPin: count=%d, forward=%d, muxPosition=%d\n", filter->nodes->Count, forward, muxPosition)); - if (filter->nodes->Count > 0 && !forward && muxPosition >= 0) - { - const GUID* nodes = (const GUID*)(filter->nodes + 1); - if (IsEqualGUID(&nodes[conn->FromNode], &KSNODETYPE_MUX)) - { - ULONG nConn = GetNumberOfConnectionsTo(conn, filter); - conn = fnGetConnection(conn, filter, muxPosition); - if (conn == NULL) - { - break; - } - if (muxInputPinId != 0) - { - *muxInputPinId = conn->ToNodePin; - } - if (muxNodeId != 0) - { - *muxNodeId = conn->ToNode; - } - } - } - } - } - PA_LOGL_; - return KSFILTER_NODE; -} - -static void DumpConnectionsAndNodes(PaWinWdmFilter* filter) -{ - unsigned i; - const KSTOPOLOGY_CONNECTION* connections = (const KSTOPOLOGY_CONNECTION*)(filter->connections + 1); - const GUID* nodes = (const GUID*)(filter->nodes + 1); - - PA_LOGE_; - PA_DEBUG(("DumpConnectionsAndNodes: connections=%d, nodes=%d\n", filter->connections->Count, filter->nodes->Count)); - - for (i=0; i < filter->connections->Count; ++i) - { - const KSTOPOLOGY_CONNECTION* pConn = connections + i; - PA_DEBUG((" Connection: %u - FromNode=%u,FromPin=%u -> ToNode=%u,ToPin=%u\n", - i, - pConn->FromNode, pConn->FromNodePin, - pConn->ToNode, pConn->ToNodePin - )); - } - - for (i=0; i < filter->nodes->Count; ++i) - { - const GUID* pConn = nodes + i; - PA_DEBUG((" Node: %d - {%08X-%04X-%04X-%02X%02X-%02X%02X%02X%02X%02X%02X}\n", - i, - pConn->Data1, pConn->Data2, pConn->Data3, - pConn->Data4[0], pConn->Data4[1], - pConn->Data4[2], pConn->Data4[3], - pConn->Data4[4], pConn->Data4[5], - pConn->Data4[6], pConn->Data4[7] - )); - } - PA_LOGL_; - -} - -typedef struct __PaUsbTerminalGUIDToName -{ - USHORT usbGUID; - wchar_t name[64]; -} PaUsbTerminalGUIDToName; - -static const PaUsbTerminalGUIDToName kNames[] = -{ - /* Types copied from: http://msdn.microsoft.com/en-us/library/ff537742(v=vs.85).aspx */ - /* Input terminal types */ - { 0x0201, L"Microphone" }, - { 0x0202, L"Desktop Microphone" }, - { 0x0203, L"Personal Microphone" }, - { 0x0204, L"Omni Directional Microphone" }, - { 0x0205, L"Microphone Array" }, - { 0x0206, L"Processing Microphone Array" }, - /* Output terminal types */ - { 0x0301, L"Speakers" }, - { 0x0302, L"Headphones" }, - { 0x0303, L"Head Mounted Display Audio" }, - { 0x0304, L"Desktop Speaker" }, - { 0x0305, L"Room Speaker" }, - { 0x0306, L"Communication Speaker" }, - { 0x0307, L"LFE Speakers" }, - /* External terminal types */ - { 0x0601, L"Analog" }, - { 0x0602, L"Digital" }, - { 0x0603, L"Line" }, - { 0x0604, L"Audio" }, - { 0x0605, L"SPDIF" }, -}; - -static const unsigned kNamesCnt = sizeof(kNames)/sizeof(PaUsbTerminalGUIDToName); - -static int PaUsbTerminalGUIDToNameCmp(const void* lhs, const void* rhs) -{ - const PaUsbTerminalGUIDToName* pL = (const PaUsbTerminalGUIDToName*)lhs; - const PaUsbTerminalGUIDToName* pR = (const PaUsbTerminalGUIDToName*)rhs; - return ((int)(pL->usbGUID) - (int)(pR->usbGUID)); -} - -static PaError GetNameFromCategory(const GUID* pGUID, BOOL input, wchar_t* name, unsigned length) -{ - PaError result = paUnanticipatedHostError; - USHORT usbTerminalGUID = (USHORT)(pGUID->Data1 - 0xDFF219E0); - - PA_LOGE_; - if (input && usbTerminalGUID >= 0x301 && usbTerminalGUID < 0x400) - { - /* Output terminal name for an input !? Set it to Line! */ - usbTerminalGUID = 0x603; - } - if (!input && usbTerminalGUID >= 0x201 && usbTerminalGUID < 0x300) - { - /* Input terminal name for an output !? Set it to Line! */ - usbTerminalGUID = 0x603; - } - if (usbTerminalGUID >= 0x201 && usbTerminalGUID < 0x713) - { - PaUsbTerminalGUIDToName s = { usbTerminalGUID }; - const PaUsbTerminalGUIDToName* ptr = bsearch( - &s, - kNames, - kNamesCnt, - sizeof(PaUsbTerminalGUIDToName), - PaUsbTerminalGUIDToNameCmp - ); - if (ptr != 0) - { - PA_DEBUG(("GetNameFromCategory: USB GUID %04X -> '%S'\n", usbTerminalGUID, ptr->name)); - - if (name != NULL && length > 0) - { - int n = _snwprintf(name, length, L"%s", ptr->name); - if (usbTerminalGUID >= 0x601 && usbTerminalGUID < 0x700) - { - _snwprintf(name + n, length - n, L" %s", (input ? L"In":L"Out")); - } - } - result = paNoError; - } - } - else - { - PaWinWDM_SetLastErrorInfo(result, "GetNameFromCategory: usbTerminalGUID = %04X ", usbTerminalGUID); - } - PA_LOGL_; - return result; -} - -static BOOL IsFrequencyWithinRange(const KSDATARANGE_AUDIO* range, int frequency) -{ - if (frequency < (int)range->MinimumSampleFrequency) - return FALSE; - if (frequency > (int)range->MaximumSampleFrequency) - return FALSE; - return TRUE; -} - -static BOOL IsBitsWithinRange(const KSDATARANGE_AUDIO* range, int noOfBits) -{ - if (noOfBits < (int)range->MinimumBitsPerSample) - return FALSE; - if (noOfBits > (int)range->MaximumBitsPerSample) - return FALSE; - return TRUE; -} - -/* Note: Somewhat different order compared to WMME implementation, as we want to focus on fidelity first */ -static const int defaultSampleRateSearchOrder[] = -{ 44100, 48000, 88200, 96000, 192000, 32000, 24000, 22050, 16000, 12000, 11025, 9600, 8000 }; -static const int defaultSampleRateSearchOrderCount = sizeof(defaultSampleRateSearchOrder)/sizeof(defaultSampleRateSearchOrder[0]); - -static int DefaultSampleFrequencyIndex(const KSDATARANGE_AUDIO* range) -{ - int i; - - for(i=0; i < defaultSampleRateSearchOrderCount; ++i) - { - int currentFrequency = defaultSampleRateSearchOrder[i]; - - if (IsFrequencyWithinRange(range, currentFrequency)) - { - return i; - } - } - - return -1; -} - -/* -Create a new pin object belonging to a filter -The pin object holds all the configuration information about the pin -before it is opened, and then the handle of the pin after is opened -*/ -static PaWinWdmPin* PinNew(PaWinWdmFilter* parentFilter, unsigned long pinId, PaError* error) -{ - PaWinWdmPin* pin; - PaError result; - unsigned long i; - KSMULTIPLE_ITEM* item = NULL; - KSIDENTIFIER* identifier; - KSDATARANGE* dataRange; - const ULONG streamingId = (parentFilter->devInfo.streamingType == Type_kWaveRT) ? KSINTERFACE_STANDARD_LOOPED_STREAMING : KSINTERFACE_STANDARD_STREAMING; - int defaultSampleRateIndex = defaultSampleRateSearchOrderCount; - - PA_LOGE_; - PA_DEBUG(("PinNew: Creating pin %d:\n",pinId)); - - /* Allocate the new PIN object */ - pin = (PaWinWdmPin*)PaUtil_AllocateMemory( sizeof(PaWinWdmPin) ); - if( !pin ) - { - result = paInsufficientMemory; - goto error; - } - - /* Zero the pin object */ - /* memset( (void*)pin, 0, sizeof(PaWinWdmPin) ); */ - - pin->parentFilter = parentFilter; - pin->pinId = pinId; - - /* Allocate a connect structure */ - pin->pinConnectSize = sizeof(KSPIN_CONNECT) + sizeof(KSDATAFORMAT_WAVEFORMATEX); - pin->pinConnect = (KSPIN_CONNECT*)PaUtil_AllocateMemory( pin->pinConnectSize ); - if( !pin->pinConnect ) - { - result = paInsufficientMemory; - goto error; - } - - /* Configure the connect structure with default values */ - pin->pinConnect->Interface.Set = KSINTERFACESETID_Standard; - pin->pinConnect->Interface.Id = streamingId; - pin->pinConnect->Interface.Flags = 0; - pin->pinConnect->Medium.Set = KSMEDIUMSETID_Standard; - pin->pinConnect->Medium.Id = KSMEDIUM_TYPE_ANYINSTANCE; - pin->pinConnect->Medium.Flags = 0; - pin->pinConnect->PinId = pinId; - pin->pinConnect->PinToHandle = NULL; - pin->pinConnect->Priority.PriorityClass = KSPRIORITY_NORMAL; - pin->pinConnect->Priority.PrioritySubClass = 1; - pin->ksDataFormatWfx = (KSDATAFORMAT_WAVEFORMATEX*)(pin->pinConnect + 1); - pin->ksDataFormatWfx->DataFormat.FormatSize = sizeof(KSDATAFORMAT_WAVEFORMATEX); - pin->ksDataFormatWfx->DataFormat.Flags = 0; - pin->ksDataFormatWfx->DataFormat.Reserved = 0; - pin->ksDataFormatWfx->DataFormat.MajorFormat = KSDATAFORMAT_TYPE_AUDIO; - pin->ksDataFormatWfx->DataFormat.SubFormat = KSDATAFORMAT_SUBTYPE_PCM; - pin->ksDataFormatWfx->DataFormat.Specifier = KSDATAFORMAT_SPECIFIER_WAVEFORMATEX; - - pin->frameSize = 0; /* Unknown until we instantiate pin */ - - /* Get the COMMUNICATION property */ - result = WdmGetPinPropertySimple( - parentFilter->handle, - pinId, - &KSPROPSETID_Pin, - KSPROPERTY_PIN_COMMUNICATION, - &pin->communication, - sizeof(KSPIN_COMMUNICATION), - NULL); - if( result != paNoError ) - goto error; - - if( /*(pin->communication != KSPIN_COMMUNICATION_SOURCE) &&*/ - (pin->communication != KSPIN_COMMUNICATION_SINK) && - (pin->communication != KSPIN_COMMUNICATION_BOTH) ) - { - PA_DEBUG(("PinNew: Not source/sink\n")); - result = paInvalidDevice; - goto error; - } - - /* Get dataflow information */ - result = WdmGetPinPropertySimple( - parentFilter->handle, - pinId, - &KSPROPSETID_Pin, - KSPROPERTY_PIN_DATAFLOW, - &pin->dataFlow, - sizeof(KSPIN_DATAFLOW), - NULL); - - if( result != paNoError ) - goto error; - - /* Get the INTERFACE property list */ - result = WdmGetPinPropertyMulti( - parentFilter->handle, - pinId, - &KSPROPSETID_Pin, - KSPROPERTY_PIN_INTERFACES, - &item); - - if( result != paNoError ) - goto error; - - identifier = (KSIDENTIFIER*)(item+1); - - /* Check that at least one interface is STANDARD_STREAMING */ - result = paUnanticipatedHostError; - for( i = 0; i < item->Count; i++ ) - { - if( IsEqualGUID(&identifier[i].Set, &KSINTERFACESETID_Standard) && ( identifier[i].Id == streamingId ) ) - { - result = paNoError; - break; - } - } - - if( result != paNoError ) - { - PA_DEBUG(("PinNew: No %s streaming\n", streamingId==KSINTERFACE_STANDARD_LOOPED_STREAMING?"looped":"standard")); - goto error; - } - - /* Don't need interfaces any more */ - PaUtil_FreeMemory( item ); - item = NULL; - - /* Get the MEDIUM properties list */ - result = WdmGetPinPropertyMulti( - parentFilter->handle, - pinId, - &KSPROPSETID_Pin, - KSPROPERTY_PIN_MEDIUMS, - &item); - - if( result != paNoError ) - goto error; - - identifier = (KSIDENTIFIER*)(item+1); /* Not actually necessary... */ - - /* Check that at least one medium is STANDARD_DEVIO */ - result = paUnanticipatedHostError; - for( i = 0; i < item->Count; i++ ) - { - if( IsEqualGUID(&identifier[i].Set, &KSMEDIUMSETID_Standard) && ( identifier[i].Id == KSMEDIUM_STANDARD_DEVIO ) ) - { - result = paNoError; - break; - } - } - - if( result != paNoError ) - { - PA_DEBUG(("No standard devio\n")); - goto error; - } - /* Don't need mediums any more */ - PaUtil_FreeMemory( item ); - item = NULL; - - /* Get DATARANGES */ - result = WdmGetPinPropertyMulti( - parentFilter->handle, - pinId, - &KSPROPSETID_Pin, - KSPROPERTY_PIN_DATARANGES, - &pin->dataRangesItem); - - if( result != paNoError ) - goto error; - - pin->dataRanges = (KSDATARANGE*)(pin->dataRangesItem +1); - - /* Check that at least one datarange supports audio */ - result = paUnanticipatedHostError; - dataRange = pin->dataRanges; - pin->maxChannels = 0; - pin->defaultSampleRate = 0; - pin->formats = 0; - PA_DEBUG(("PinNew: Checking %u no of dataranges...\n", pin->dataRangesItem->Count)); - for( i = 0; i < pin->dataRangesItem->Count; i++) - { - PA_DEBUG(("PinNew: DR major format %x\n",*(unsigned long*)(&(dataRange->MajorFormat)))); - /* Check that subformat is WAVEFORMATEX, PCM or WILDCARD */ - if( IS_VALID_WAVEFORMATEX_GUID(&dataRange->SubFormat) || - IsEqualGUID(&dataRange->SubFormat, &KSDATAFORMAT_SUBTYPE_PCM) || - IsEqualGUID(&dataRange->SubFormat, &KSDATAFORMAT_SUBTYPE_IEEE_FLOAT) || - IsEqualGUID(&dataRange->SubFormat, &KSDATAFORMAT_SUBTYPE_WILDCARD) || - IsEqualGUID(&dataRange->MajorFormat, &KSDATAFORMAT_TYPE_AUDIO) ) - { - int defaultIndex; - result = paNoError; - /* Record the maximum possible channels with this pin */ - if( ((KSDATARANGE_AUDIO*)dataRange)->MaximumChannels == (ULONG) -1 ) - { - pin->maxChannels = MAXIMUM_NUMBER_OF_CHANNELS; - } - else if( (int) ((KSDATARANGE_AUDIO*)dataRange)->MaximumChannels > pin->maxChannels ) - { - pin->maxChannels = (int) ((KSDATARANGE_AUDIO*)dataRange)->MaximumChannels; - } - PA_DEBUG(("PinNew: MaxChannel: %d\n",pin->maxChannels)); - - /* Record the formats (bit depths) that are supported */ - if( IsBitsWithinRange((KSDATARANGE_AUDIO*)dataRange, 8) ) - { - pin->formats |= paInt8; - PA_DEBUG(("PinNew: Format PCM 8 bit supported\n")); - } - if( IsBitsWithinRange((KSDATARANGE_AUDIO*)dataRange, 16) ) - { - pin->formats |= paInt16; - PA_DEBUG(("PinNew: Format PCM 16 bit supported\n")); - } - if( IsBitsWithinRange((KSDATARANGE_AUDIO*)dataRange, 24) ) - { - pin->formats |= paInt24; - PA_DEBUG(("PinNew: Format PCM 24 bit supported\n")); - } - if( IsBitsWithinRange((KSDATARANGE_AUDIO*)dataRange, 32) ) - { - if (IsEqualGUID(&dataRange->SubFormat, &KSDATAFORMAT_SUBTYPE_IEEE_FLOAT)) - { - pin->formats |= paFloat32; - PA_DEBUG(("PinNew: Format IEEE float 32 bit supported\n")); - } - else - { - pin->formats |= paInt32; - PA_DEBUG(("PinNew: Format PCM 32 bit supported\n")); - } - } - - defaultIndex = DefaultSampleFrequencyIndex((KSDATARANGE_AUDIO*)dataRange); - if (defaultIndex >= 0 && defaultIndex < defaultSampleRateIndex) - { - defaultSampleRateIndex = defaultIndex; - } - } - dataRange = (KSDATARANGE*)( ((char*)dataRange) + dataRange->FormatSize); - } - - if( result != paNoError ) - goto error; - - /* If none of the frequencies searched for are present, there's something seriously wrong */ - if (defaultSampleRateIndex == defaultSampleRateSearchOrderCount) - { - PA_DEBUG(("PinNew: No default sample rate found, skipping pin!\n")); - PaWinWDM_SetLastErrorInfo(paUnanticipatedHostError, "PinNew: No default sample rate found"); - result = paUnanticipatedHostError; - goto error; - } - - /* Set the default sample rate */ - pin->defaultSampleRate = defaultSampleRateSearchOrder[defaultSampleRateIndex]; - PA_DEBUG(("PinNew: Default sample rate = %d Hz\n", pin->defaultSampleRate)); - - /* Get instance information */ - result = WdmGetPinPropertySimple( - parentFilter->handle, - pinId, - &KSPROPSETID_Pin, - KSPROPERTY_PIN_CINSTANCES, - &pin->instances, - sizeof(KSPIN_CINSTANCES), - NULL); - - if( result != paNoError ) - goto error; - - /* If WaveRT, check if pin supports notification mode */ - if (parentFilter->devInfo.streamingType == Type_kWaveRT) - { - BOOL bSupportsNotification = FALSE; - if (PinQueryNotificationSupport(pin, &bSupportsNotification) == paNoError) - { - pin->pinKsSubType = bSupportsNotification ? SubType_kNotification : SubType_kPolled; - } - } - - /* Query pin name (which means we need to traverse to non IRP pin, via physical connection to topology filter pin, through - its nodes to the endpoint pin, and get that ones name... phew...) */ - PA_DEBUG(("PinNew: Finding topology pin...\n")); - - { - ULONG topoPinId = GetConnectedPin(pinId, (pin->dataFlow == KSPIN_DATAFLOW_IN), parentFilter, -1, NULL, NULL); - const wchar_t kInputName[] = L"Input"; - const wchar_t kOutputName[] = L"Output"; - - if (topoPinId != KSFILTER_NODE) - { - /* Get physical connection for topo pin */ - unsigned long cbBytes = 0; - PA_DEBUG(("PinNew: Getting physical connection...\n")); - result = WdmGetPinPropertySimple(parentFilter->handle, - topoPinId, - &KSPROPSETID_Pin, - KSPROPERTY_PIN_PHYSICALCONNECTION, - 0, - 0, - &cbBytes - ); - - if (result != paNoError) - { - /* No physical connection -> there is no topology filter! So we get the name of the pin! */ - PA_DEBUG(("PinNew: No physical connection! Getting the pin name\n")); - result = WdmGetPinPropertySimple(parentFilter->handle, - topoPinId, - &KSPROPSETID_Pin, - KSPROPERTY_PIN_NAME, - pin->friendlyName, - MAX_PATH, - NULL); - if (result != paNoError) - { - GUID category = {0}; - - /* Get pin category information */ - result = WdmGetPinPropertySimple(parentFilter->handle, - topoPinId, - &KSPROPSETID_Pin, - KSPROPERTY_PIN_CATEGORY, - &category, - sizeof(GUID), - NULL); - - if (result == paNoError) - { - result = GetNameFromCategory(&category, (pin->dataFlow == KSPIN_DATAFLOW_OUT), pin->friendlyName, MAX_PATH); - } - } - - /* Make sure pin gets a name here... */ - if (wcslen(pin->friendlyName) == 0) - { - wcscpy(pin->friendlyName, (pin->dataFlow == KSPIN_DATAFLOW_IN) ? kOutputName : kInputName); -#ifdef UNICODE - PA_DEBUG(("PinNew: Setting pin friendly name to '%s'\n", pin->friendlyName)); -#else - PA_DEBUG(("PinNew: Setting pin friendly name to '%S'\n", pin->friendlyName)); -#endif - } - - /* This is then == the endpoint pin */ - pin->endpointPinId = (pin->dataFlow == KSPIN_DATAFLOW_IN) ? pinId : topoPinId; - } - else - { - KSPIN_PHYSICALCONNECTION* pc = (KSPIN_PHYSICALCONNECTION*)PaUtil_AllocateMemory(cbBytes + 2); - ULONG pcPin; - wchar_t symbLinkName[MAX_PATH]; - PA_DEBUG(("PinNew: Physical connection found!\n")); - if (pc == NULL) - { - result = paInsufficientMemory; - goto error; - } - result = WdmGetPinPropertySimple(parentFilter->handle, - topoPinId, - &KSPROPSETID_Pin, - KSPROPERTY_PIN_PHYSICALCONNECTION, - pc, - cbBytes, - NULL - ); - - pcPin = pc->Pin; - wcsncpy(symbLinkName, pc->SymbolicLinkName, MAX_PATH); - PaUtil_FreeMemory( pc ); - - if (result != paNoError) - { - /* Shouldn't happen, but fail if it does */ - PA_DEBUG(("PinNew: failed to retrieve physical connection!\n")); - goto error; - } - - if (symbLinkName[1] == TEXT('?')) - { - symbLinkName[1] = TEXT('\\'); - } - - if (pin->parentFilter->topologyFilter == NULL) - { - PA_DEBUG(("PinNew: Creating topology filter '%S'\n", symbLinkName)); - - pin->parentFilter->topologyFilter = FilterNew(Type_kNotUsed, 0, symbLinkName, L"", &result); - if (pin->parentFilter->topologyFilter == NULL) - { - PA_DEBUG(("PinNew: Failed creating topology filter\n")); - result = paUnanticipatedHostError; - PaWinWDM_SetLastErrorInfo(result, "Failed to create topology filter '%S'", symbLinkName); - goto error; - } - - /* Copy info so we have it in device info */ - wcsncpy(pin->parentFilter->devInfo.topologyPath, symbLinkName, MAX_PATH); - } - else - { - /* Must be the same */ - assert(wcscmp(symbLinkName, pin->parentFilter->topologyFilter->devInfo.filterPath) == 0); - } - - PA_DEBUG(("PinNew: Opening topology filter...")); - - result = FilterUse(pin->parentFilter->topologyFilter); - if (result == paNoError) - { - unsigned long endpointPinId; - - if (pin->dataFlow == KSPIN_DATAFLOW_IN) - { - /* The "endpointPinId" is what WASAPI looks at for pin names */ - GUID category = {0}; - - PA_DEBUG(("PinNew: Checking for output endpoint pin id...\n")); - - endpointPinId = GetConnectedPin(pcPin, TRUE, pin->parentFilter->topologyFilter, -1, NULL, NULL); - - if (endpointPinId == KSFILTER_NODE) - { - result = paUnanticipatedHostError; - PaWinWDM_SetLastErrorInfo(result, "Failed to get endpoint pin ID on topology filter!"); - goto error; - } - - PA_DEBUG(("PinNew: Found endpoint pin id %u\n", endpointPinId)); - - /* Get pin category information */ - result = WdmGetPinPropertySimple(pin->parentFilter->topologyFilter->handle, - endpointPinId, - &KSPROPSETID_Pin, - KSPROPERTY_PIN_CATEGORY, - &category, - sizeof(GUID), - NULL); - - if (result == paNoError) - { -#if !PA_WDMKS_USE_CATEGORY_FOR_PIN_NAMES - wchar_t pinName[MAX_PATH]; - - PA_DEBUG(("PinNew: Getting pin name property...")); - - /* Ok, try pin name also, and favor that if available */ - result = WdmGetPinPropertySimple(pin->parentFilter->topologyFilter->handle, - endpointPinId, - &KSPROPSETID_Pin, - KSPROPERTY_PIN_NAME, - pinName, - MAX_PATH, - NULL); - - if (result == paNoError && wcslen(pinName)>0) - { - wcsncpy(pin->friendlyName, pinName, MAX_PATH); - } - else -#endif - { - result = GetNameFromCategory(&category, (pin->dataFlow == KSPIN_DATAFLOW_OUT), pin->friendlyName, MAX_PATH); - } - } - - /* Make sure we get a name for the pin */ - if (wcslen(pin->friendlyName) == 0) - { - wcscpy(pin->friendlyName, kOutputName); - } -#ifdef UNICODE - PA_DEBUG(("PinNew: Pin name '%s'\n", pin->friendlyName)); -#else - PA_DEBUG(("PinNew: Pin name '%S'\n", pin->friendlyName)); -#endif - - /* Set endpoint pin ID (this is the topology INPUT pin, since portmixer will always traverse the - filter in audio streaming direction, see http://msdn.microsoft.com/en-us/library/windows/hardware/ff536331(v=vs.85).aspx - for more information) - */ - pin->endpointPinId = pcPin; - } - else - { - unsigned muxCount = 0; - int muxPos = 0; - /* Max 64 multiplexer inputs... sanity check :) */ - for (i = 0; i < 64; ++i) - { - ULONG muxNodeIdTest = (unsigned)-1; - PA_DEBUG(("PinNew: Checking for input endpoint pin id (%d)...\n", i)); - - endpointPinId = GetConnectedPin(pcPin, - FALSE, - pin->parentFilter->topologyFilter, - (int)i, - NULL, - &muxNodeIdTest); - - if (endpointPinId == KSFILTER_NODE) - { - /* We're done */ - PA_DEBUG(("PinNew: Done with inputs.\n", endpointPinId)); - break; - } - else - { - /* The "endpointPinId" is what WASAPI looks at for pin names */ - GUID category = {0}; - - PA_DEBUG(("PinNew: Found endpoint pin id %u\n", endpointPinId)); - - /* Get pin category information */ - result = WdmGetPinPropertySimple(pin->parentFilter->topologyFilter->handle, - endpointPinId, - &KSPROPSETID_Pin, - KSPROPERTY_PIN_CATEGORY, - &category, - sizeof(GUID), - NULL); - - if (result == paNoError) - { - if (muxNodeIdTest == (unsigned)-1) - { - /* Ok, try pin name, and favor that if available */ - result = WdmGetPinPropertySimple(pin->parentFilter->topologyFilter->handle, - endpointPinId, - &KSPROPSETID_Pin, - KSPROPERTY_PIN_NAME, - pin->friendlyName, - MAX_PATH, - NULL); - - if (result != paNoError) - { - result = GetNameFromCategory(&category, TRUE, pin->friendlyName, MAX_PATH); - } - break; - } - else - { - result = GetNameFromCategory(&category, TRUE, NULL, 0); - - if (result == paNoError) - { - ++muxCount; - } - } - } - else - { - PA_DEBUG(("PinNew: Failed to get pin category")); - } - } - } - - if (muxCount == 0) - { - pin->endpointPinId = endpointPinId; - /* Make sure we get a name for the pin */ - if (wcslen(pin->friendlyName) == 0) - { - wcscpy(pin->friendlyName, kInputName); - } -#ifdef UNICODE - PA_DEBUG(("PinNew: Input friendly name '%s'\n", pin->friendlyName)); -#else - PA_DEBUG(("PinNew: Input friendly name '%S'\n", pin->friendlyName)); -#endif - } - else // muxCount > 0 - { - PA_DEBUG(("PinNew: Setting up %u inputs\n", muxCount)); - - /* Now we redo the operation once known how many multiplexer positions there are */ - pin->inputs = (PaWinWdmMuxedInput**)PaUtil_AllocateMemory(muxCount * sizeof(PaWinWdmMuxedInput*)); - if (pin->inputs == NULL) - { - FilterRelease(pin->parentFilter->topologyFilter); - result = paInsufficientMemory; - goto error; - } - pin->inputCount = muxCount; - - for (i = 0; i < muxCount; ++muxPos) - { - PA_DEBUG(("PinNew: Setting up input %u...\n", i)); - - if (pin->inputs[i] == NULL) - { - pin->inputs[i] = (PaWinWdmMuxedInput*)PaUtil_AllocateMemory(sizeof(PaWinWdmMuxedInput)); - if (pin->inputs[i] == NULL) - { - FilterRelease(pin->parentFilter->topologyFilter); - result = paInsufficientMemory; - goto error; - } - } - - endpointPinId = GetConnectedPin(pcPin, - FALSE, - pin->parentFilter->topologyFilter, - muxPos, - &pin->inputs[i]->muxPinId, - &pin->inputs[i]->muxNodeId); - - if (endpointPinId != KSFILTER_NODE) - { - /* The "endpointPinId" is what WASAPI looks at for pin names */ - GUID category = {0}; - - /* Set input endpoint ID */ - pin->inputs[i]->endpointPinId = endpointPinId; - - /* Get pin category information */ - result = WdmGetPinPropertySimple(pin->parentFilter->topologyFilter->handle, - endpointPinId, - &KSPROPSETID_Pin, - KSPROPERTY_PIN_CATEGORY, - &category, - sizeof(GUID), - NULL); - - if (result == paNoError) - { - /* Try pin name first, and if that is not defined, use category instead */ - result = WdmGetPinPropertySimple(pin->parentFilter->topologyFilter->handle, - endpointPinId, - &KSPROPSETID_Pin, - KSPROPERTY_PIN_NAME, - pin->inputs[i]->friendlyName, - MAX_PATH, - NULL); - - if (result != paNoError) - { - result = GetNameFromCategory(&category, TRUE, pin->inputs[i]->friendlyName, MAX_PATH); - if (result != paNoError) - { - /* Only specify name, let name hash in ScanDeviceInfos fix postfix enumerators */ - wcscpy(pin->inputs[i]->friendlyName, kInputName); - } - } -#ifdef UNICODE - PA_DEBUG(("PinNew: Input (%u) friendly name '%s'\n", i, pin->inputs[i]->friendlyName)); -#else - PA_DEBUG(("PinNew: Input (%u) friendly name '%S'\n", i, pin->inputs[i]->friendlyName)); -#endif - ++i; - } - } - else - { - /* Unconnected pin */ - goto error; - } - } - } - } - } - } - } - else - { - PA_DEBUG(("PinNew: No topology pin id found. Bad...\n")); - /* No TOPO pin id ??? This is bad. Ok, so we just say it is an input or output... */ - wcscpy(pin->friendlyName, (pin->dataFlow == KSPIN_DATAFLOW_IN) ? kOutputName : kInputName); - } - } - - /* Release topology filter if it has been used */ - if (pin->parentFilter->topologyFilter && pin->parentFilter->topologyFilter->handle != NULL) - { - PA_DEBUG(("PinNew: Releasing topology filter...\n")); - FilterRelease(pin->parentFilter->topologyFilter); - } - - /* Success */ - *error = paNoError; - PA_DEBUG(("Pin created successfully\n")); - PA_LOGL_; - return pin; - -error: - PA_DEBUG(("PinNew: Error %d\n", result)); - /* - Error cleanup - */ - - if (pin->parentFilter->topologyFilter && pin->parentFilter->topologyFilter->handle != NULL) - { - FilterRelease(pin->parentFilter->topologyFilter); - } - - PaUtil_FreeMemory( item ); - PinFree(pin); - - *error = result; - PA_LOGL_; - return NULL; -} - -/* -Safely free all resources associated with the pin -*/ -static void PinFree(PaWinWdmPin* pin) -{ - unsigned i; - PA_LOGE_; - if( pin ) - { - PinClose(pin); - if( pin->pinConnect ) - { - PaUtil_FreeMemory( pin->pinConnect ); - } - if( pin->dataRangesItem ) - { - PaUtil_FreeMemory( pin->dataRangesItem ); - } - if( pin->inputs ) - { - for (i = 0; i < pin->inputCount; ++i) - { - PaUtil_FreeMemory( pin->inputs[i] ); - } - PaUtil_FreeMemory( pin->inputs ); - } - PaUtil_FreeMemory( pin ); - } - PA_LOGL_; -} - -/* -If the pin handle is open, close it -*/ -static void PinClose(PaWinWdmPin* pin) -{ - PA_LOGE_; - if( pin == NULL ) - { - PA_DEBUG(("Closing NULL pin!")); - PA_LOGL_; - return; - } - if( pin->handle != NULL ) - { - PinSetState( pin, KSSTATE_PAUSE ); - PinSetState( pin, KSSTATE_STOP ); - CloseHandle( pin->handle ); - pin->handle = NULL; - FilterRelease(pin->parentFilter); - } - PA_LOGL_; -} - -/* -Set the state of this (instantiated) pin -*/ -static PaError PinSetState(PaWinWdmPin* pin, KSSTATE state) -{ - PaError result = paNoError; - KSPROPERTY prop; - - PA_LOGE_; - prop.Set = KSPROPSETID_Connection; - prop.Id = KSPROPERTY_CONNECTION_STATE; - prop.Flags = KSPROPERTY_TYPE_SET; - - if( pin == NULL ) - return paInternalError; - if( pin->handle == NULL ) - return paInternalError; - - result = WdmSyncIoctl(pin->handle, IOCTL_KS_PROPERTY, &prop, sizeof(KSPROPERTY), &state, sizeof(KSSTATE), NULL); - - PA_LOGL_; - return result; -} - -static PaError PinInstantiate(PaWinWdmPin* pin) -{ - PaError result; - unsigned long createResult; - KSALLOCATOR_FRAMING ksaf; - KSALLOCATOR_FRAMING_EX ksafex; - - PA_LOGE_; - - if( pin == NULL ) - return paInternalError; - if(!pin->pinConnect) - return paInternalError; - - FilterUse(pin->parentFilter); - - createResult = FunctionKsCreatePin( - pin->parentFilter->handle, - pin->pinConnect, - GENERIC_WRITE | GENERIC_READ, - &pin->handle - ); - - PA_DEBUG(("Pin create result = 0x%08x\n",createResult)); - if( createResult != ERROR_SUCCESS ) - { - FilterRelease(pin->parentFilter); - pin->handle = NULL; - switch (createResult) - { - case ERROR_INVALID_PARAMETER: - /* First case when pin actually don't support the format */ - return paSampleFormatNotSupported; - case ERROR_BAD_COMMAND: - /* Case when pin is occupied (by another application) */ - return paDeviceUnavailable; - default: - /* All other cases */ - return paInvalidDevice; - } - } - - if (pin->parentFilter->devInfo.streamingType == Type_kWaveCyclic) - { - /* Framing size query only valid for WaveCyclic devices */ - result = WdmGetPropertySimple( - pin->handle, - &KSPROPSETID_Connection, - KSPROPERTY_CONNECTION_ALLOCATORFRAMING, - &ksaf, - sizeof(ksaf)); - - if( result != paNoError ) - { - result = WdmGetPropertySimple( - pin->handle, - &KSPROPSETID_Connection, - KSPROPERTY_CONNECTION_ALLOCATORFRAMING_EX, - &ksafex, - sizeof(ksafex)); - if( result == paNoError ) - { - pin->frameSize = ksafex.FramingItem[0].FramingRange.Range.MinFrameSize; - } - } - else - { - pin->frameSize = ksaf.FrameSize; - } - } - - PA_LOGL_; - - return paNoError; -} - -static PaError PinSetFormat(PaWinWdmPin* pin, const WAVEFORMATEX* format) -{ - unsigned long size; - void* newConnect; - - PA_LOGE_; - - if( pin == NULL ) - return paInternalError; - if( format == NULL ) - return paInternalError; - - size = GetWfexSize(format) + sizeof(KSPIN_CONNECT) + sizeof(KSDATAFORMAT_WAVEFORMATEX) - sizeof(WAVEFORMATEX); - - if( pin->pinConnectSize != size ) - { - newConnect = PaUtil_AllocateMemory( size ); - if( newConnect == NULL ) - return paInsufficientMemory; - memcpy( newConnect, (void*)pin->pinConnect, min(pin->pinConnectSize,size) ); - PaUtil_FreeMemory( pin->pinConnect ); - pin->pinConnect = (KSPIN_CONNECT*)newConnect; - pin->pinConnectSize = size; - pin->ksDataFormatWfx = (KSDATAFORMAT_WAVEFORMATEX*)((KSPIN_CONNECT*)newConnect + 1); - pin->ksDataFormatWfx->DataFormat.FormatSize = size - sizeof(KSPIN_CONNECT); - } - - memcpy( (void*)&(pin->ksDataFormatWfx->WaveFormatEx), format, GetWfexSize(format) ); - pin->ksDataFormatWfx->DataFormat.SampleSize = (unsigned short)(format->nChannels * (format->wBitsPerSample / 8)); - - PA_LOGL_; - - return paNoError; -} - -static PaError PinIsFormatSupported(PaWinWdmPin* pin, const WAVEFORMATEX* format) -{ - KSDATARANGE_AUDIO* dataRange; - unsigned long count; - GUID guid = DYNAMIC_GUID( DEFINE_WAVEFORMATEX_GUID(format->wFormatTag) ); - PaError result = paInvalidDevice; - const WAVEFORMATEXTENSIBLE* pFormatExt = (format->wFormatTag == WAVE_FORMAT_EXTENSIBLE) ? (const WAVEFORMATEXTENSIBLE*)format : 0; - - PA_LOGE_; - - if( pFormatExt != 0 ) - { - guid = pFormatExt->SubFormat; - } - dataRange = (KSDATARANGE_AUDIO*)pin->dataRanges; - for(count = 0; - count<pin->dataRangesItem->Count; - count++, - dataRange = (KSDATARANGE_AUDIO*)( ((char*)dataRange) + dataRange->DataRange.FormatSize)) /* Need to update dataRange here, due to 'continue' !! */ - { - /* Check major format*/ - if (!(IsEqualGUID(&(dataRange->DataRange.MajorFormat), &KSDATAFORMAT_TYPE_AUDIO) || - IsEqualGUID(&(dataRange->DataRange.MajorFormat), &KSDATAFORMAT_TYPE_WILDCARD))) - { - continue; - } - - /* This is an audio or wildcard datarange... */ - if (! (IsEqualGUID(&(dataRange->DataRange.SubFormat), &KSDATAFORMAT_SUBTYPE_WILDCARD) || - IsEqualGUID(&(dataRange->DataRange.SubFormat), &KSDATAFORMAT_SUBTYPE_PCM) || - IsEqualGUID(&(dataRange->DataRange.SubFormat), &guid) )) - { - continue; - } - - /* Check specifier... */ - if (! (IsEqualGUID(&(dataRange->DataRange.Specifier), &KSDATAFORMAT_SPECIFIER_WILDCARD) || - IsEqualGUID(&(dataRange->DataRange.Specifier), &KSDATAFORMAT_SPECIFIER_WAVEFORMATEX)) ) - { - continue; - } - - PA_DEBUG(("Pin:%x, DataRange:%d\n",(void*)pin,count)); - PA_DEBUG(("\tFormatSize:%d, SampleSize:%d\n",dataRange->DataRange.FormatSize,dataRange->DataRange.SampleSize)); - PA_DEBUG(("\tMaxChannels:%d\n",dataRange->MaximumChannels)); - PA_DEBUG(("\tBits:%d-%d\n",dataRange->MinimumBitsPerSample,dataRange->MaximumBitsPerSample)); - PA_DEBUG(("\tSampleRate:%d-%d\n",dataRange->MinimumSampleFrequency,dataRange->MaximumSampleFrequency)); - - if( dataRange->MaximumChannels != (ULONG)-1 && - dataRange->MaximumChannels < format->nChannels ) - { - result = paInvalidChannelCount; - continue; - } - - if (pFormatExt != 0) - { - if (!IsBitsWithinRange(dataRange, pFormatExt->Samples.wValidBitsPerSample)) - { - result = paSampleFormatNotSupported; - continue; - } - } - else - { - if (!IsBitsWithinRange(dataRange, format->wBitsPerSample)) - { - result = paSampleFormatNotSupported; - continue; - } - } - - if (!IsFrequencyWithinRange(dataRange, format->nSamplesPerSec)) - { - result = paInvalidSampleRate; - continue; - } - - /* Success! */ - result = paNoError; - break; - } - - PA_LOGL_; - return result; -} - -static PaError PinQueryNotificationSupport(PaWinWdmPin* pPin, BOOL* pbResult) -{ - PaError result = paNoError; - KSPROPERTY propIn; - - PA_LOGE_; - - propIn.Set = KSPROPSETID_RtAudio; - propIn.Id = 8; /* = KSPROPERTY_RTAUDIO_QUERY_NOTIFICATION_SUPPORT */ - propIn.Flags = KSPROPERTY_TYPE_GET; - - result = WdmSyncIoctl(pPin->handle, IOCTL_KS_PROPERTY, - &propIn, - sizeof(KSPROPERTY), - pbResult, - sizeof(BOOL), - NULL); - - if (result != paNoError) - { - PA_DEBUG(("Failed PinQueryNotificationSupport\n")); - } - - PA_LOGL_; - return result; -} - -static PaError PinGetBufferWithNotification(PaWinWdmPin* pPin, void** pBuffer, DWORD* pRequestedBufSize, BOOL* pbCallMemBarrier) -{ - PaError result = paNoError; - KSRTAUDIO_BUFFER_PROPERTY_WITH_NOTIFICATION propIn; - KSRTAUDIO_BUFFER propOut; - - PA_LOGE_; - - propIn.BaseAddress = 0; - propIn.NotificationCount = 2; - propIn.RequestedBufferSize = *pRequestedBufSize; - propIn.Property.Set = KSPROPSETID_RtAudio; - propIn.Property.Id = KSPROPERTY_RTAUDIO_BUFFER_WITH_NOTIFICATION; - propIn.Property.Flags = KSPROPERTY_TYPE_GET; - - result = WdmSyncIoctl(pPin->handle, IOCTL_KS_PROPERTY, - &propIn, - sizeof(KSRTAUDIO_BUFFER_PROPERTY_WITH_NOTIFICATION), - &propOut, - sizeof(KSRTAUDIO_BUFFER), - NULL); - - if (result == paNoError) - { - *pBuffer = propOut.BufferAddress; - *pRequestedBufSize = propOut.ActualBufferSize; - *pbCallMemBarrier = propOut.CallMemoryBarrier; - } - else - { - PA_DEBUG(("Failed to get buffer with notification\n")); - } - - PA_LOGL_; - return result; -} - -static PaError PinGetBufferWithoutNotification(PaWinWdmPin* pPin, void** pBuffer, DWORD* pRequestedBufSize, BOOL* pbCallMemBarrier) -{ - PaError result = paNoError; - KSRTAUDIO_BUFFER_PROPERTY propIn; - KSRTAUDIO_BUFFER propOut; - - PA_LOGE_; - - propIn.BaseAddress = NULL; - propIn.RequestedBufferSize = *pRequestedBufSize; - propIn.Property.Set = KSPROPSETID_RtAudio; - propIn.Property.Id = KSPROPERTY_RTAUDIO_BUFFER; - propIn.Property.Flags = KSPROPERTY_TYPE_GET; - - result = WdmSyncIoctl(pPin->handle, IOCTL_KS_PROPERTY, - &propIn, - sizeof(KSRTAUDIO_BUFFER_PROPERTY), - &propOut, - sizeof(KSRTAUDIO_BUFFER), - NULL); - - if (result == paNoError) - { - *pBuffer = propOut.BufferAddress; - *pRequestedBufSize = propOut.ActualBufferSize; - *pbCallMemBarrier = propOut.CallMemoryBarrier; - } - else - { - PA_DEBUG(("Failed to get buffer without notification\n")); - } - - PA_LOGL_; - return result; -} - -/* greatest common divisor - PGCD in French */ -static unsigned long PaWinWDMGCD( unsigned long a, unsigned long b ) -{ - return (b==0) ? a : PaWinWDMGCD( b, a%b); -} - - -/* This function will handle getting the cyclic buffer from a WaveRT driver. Certain WaveRT drivers needs to have -requested buffer size on multiples of 128 bytes: - -*/ -static PaError PinGetBuffer(PaWinWdmPin* pPin, void** pBuffer, DWORD* pRequestedBufSize, BOOL* pbCallMemBarrier) -{ - PaError result = paNoError; - int limit = 1000; - PA_LOGE_; - - while (1) - { - limit--; - if (limit == 0) { - PA_DEBUG(("PinGetBuffer: LOOP LIMIT REACHED\n")); - break; - } - - if (pPin->pinKsSubType != SubType_kPolled) - { - /* In case of unknown (or notification), we try both modes */ - result = PinGetBufferWithNotification(pPin, pBuffer, pRequestedBufSize, pbCallMemBarrier); - if (result == paNoError) - { - PA_DEBUG(("PinGetBuffer: SubType_kNotification\n")); - pPin->pinKsSubType = SubType_kNotification; - break; - } - } - - result = PinGetBufferWithoutNotification(pPin, pBuffer, pRequestedBufSize, pbCallMemBarrier); - if (result == paNoError) - { - PA_DEBUG(("PinGetBuffer: SubType_kPolled\n")); - pPin->pinKsSubType = SubType_kPolled; - break; - } - - /* Check if requested size is on a 128 byte boundary */ - if (((*pRequestedBufSize) % 128UL) == 0) - { - PA_DEBUG(("Buffer size on 128 byte boundary, still fails :(\n")); - /* Ok, can't do much more */ - break; - } - else - { - /* Compute LCM so we know which sizes are on a 128 byte boundary */ - const unsigned gcd = PaWinWDMGCD(128UL, pPin->ksDataFormatWfx->WaveFormatEx.nBlockAlign); - const unsigned lcm = (128UL * pPin->ksDataFormatWfx->WaveFormatEx.nBlockAlign) / gcd; - DWORD dwOldSize = *pRequestedBufSize; - - /* Align size to (next larger) LCM byte boundary, and then we try again. Note that LCM is not necessarily a - power of 2. */ - *pRequestedBufSize = ((*pRequestedBufSize + lcm - 1) / lcm) * lcm; - - PA_DEBUG(("Adjusting buffer size from %u to %u bytes (128 byte boundary, LCM=%u)\n", dwOldSize, *pRequestedBufSize, lcm)); - } - } - - PA_LOGL_; - - return result; -} - -static PaError PinRegisterPositionRegister(PaWinWdmPin* pPin) -{ - PaError result = paNoError; - KSRTAUDIO_HWREGISTER_PROPERTY propIn; - KSRTAUDIO_HWREGISTER propOut; - - PA_LOGE_; - - propIn.BaseAddress = NULL; - propIn.Property.Set = KSPROPSETID_RtAudio; - propIn.Property.Id = KSPROPERTY_RTAUDIO_POSITIONREGISTER; - propIn.Property.Flags = KSPROPERTY_TYPE_SET; - - result = WdmSyncIoctl(pPin->handle, IOCTL_KS_PROPERTY, - &propIn, - sizeof(KSRTAUDIO_HWREGISTER_PROPERTY), - &propOut, - sizeof(KSRTAUDIO_HWREGISTER), - NULL); - - if (result == paNoError) - { - pPin->positionRegister = (ULONG*)propOut.Register; - } - else - { - PA_DEBUG(("Failed to register position register\n")); - } - - PA_LOGL_; - - return result; -} - -static PaError PinRegisterNotificationHandle(PaWinWdmPin* pPin, HANDLE handle) -{ - PaError result = paNoError; - KSRTAUDIO_NOTIFICATION_EVENT_PROPERTY prop; - - PA_LOGE_; - - prop.NotificationEvent = handle; - prop.Property.Set = KSPROPSETID_RtAudio; - prop.Property.Id = KSPROPERTY_RTAUDIO_REGISTER_NOTIFICATION_EVENT; - prop.Property.Flags = KSPROPERTY_TYPE_SET; - - result = WdmSyncIoctl(pPin->handle, - IOCTL_KS_PROPERTY, - &prop, - sizeof(KSRTAUDIO_NOTIFICATION_EVENT_PROPERTY), - &prop, - sizeof(KSRTAUDIO_NOTIFICATION_EVENT_PROPERTY), - NULL); - - if (result != paNoError) { - PA_DEBUG(("Failed to register notification handle 0x%08X\n", handle)); - } - - PA_LOGL_; - - return result; -} - -static PaError PinUnregisterNotificationHandle(PaWinWdmPin* pPin, HANDLE handle) -{ - PaError result = paNoError; - KSRTAUDIO_NOTIFICATION_EVENT_PROPERTY prop; - - PA_LOGE_; - - if (handle != NULL) - { - prop.NotificationEvent = handle; - prop.Property.Set = KSPROPSETID_RtAudio; - prop.Property.Id = KSPROPERTY_RTAUDIO_UNREGISTER_NOTIFICATION_EVENT; - prop.Property.Flags = KSPROPERTY_TYPE_SET; - - result = WdmSyncIoctl(pPin->handle, - IOCTL_KS_PROPERTY, - &prop, - sizeof(KSRTAUDIO_NOTIFICATION_EVENT_PROPERTY), - &prop, - sizeof(KSRTAUDIO_NOTIFICATION_EVENT_PROPERTY), - NULL); - - if (result != paNoError) { - PA_DEBUG(("Failed to unregister notification handle 0x%08X\n", handle)); - } - } - PA_LOGL_; - - return result; -} - -static PaError PinGetHwLatency(PaWinWdmPin* pPin, ULONG* pFifoSize, ULONG* pChipsetDelay, ULONG* pCodecDelay) -{ - PaError result = paNoError; - KSPROPERTY propIn; - KSRTAUDIO_HWLATENCY propOut; - - PA_LOGE_; - - propIn.Set = KSPROPSETID_RtAudio; - propIn.Id = KSPROPERTY_RTAUDIO_HWLATENCY; - propIn.Flags = KSPROPERTY_TYPE_GET; - - result = WdmSyncIoctl(pPin->handle, IOCTL_KS_PROPERTY, - &propIn, - sizeof(KSPROPERTY), - &propOut, - sizeof(KSRTAUDIO_HWLATENCY), - NULL); - - if (result == paNoError) - { - *pFifoSize = propOut.FifoSize; - *pChipsetDelay = propOut.ChipsetDelay; - *pCodecDelay = propOut.CodecDelay; - } - else - { - PA_DEBUG(("Failed to retrieve hardware FIFO size!\n")); - } - - PA_LOGL_; - - return result; -} - -/* This one is used for WaveRT */ -static PaError PinGetAudioPositionMemoryMapped(PaWinWdmPin* pPin, ULONG* pPosition) -{ - *pPosition = (*pPin->positionRegister); - return paNoError; -} - -/* This one also, but in case the driver hasn't implemented memory mapped access to the position register */ -static PaError PinGetAudioPositionViaIOCTLRead(PaWinWdmPin* pPin, ULONG* pPosition) -{ - PaError result = paNoError; - KSPROPERTY propIn; - KSAUDIO_POSITION propOut; - - PA_LOGE_; - - propIn.Set = KSPROPSETID_Audio; - propIn.Id = KSPROPERTY_AUDIO_POSITION; - propIn.Flags = KSPROPERTY_TYPE_GET; - - result = WdmSyncIoctl(pPin->handle, - IOCTL_KS_PROPERTY, - &propIn, sizeof(KSPROPERTY), - &propOut, sizeof(KSAUDIO_POSITION), - NULL); - - if (result == paNoError) - { - *pPosition = (ULONG)(propOut.PlayOffset); - } - else - { - PA_DEBUG(("Failed to get audio play position!\n")); - } - - PA_LOGL_; - - return result; - -} - -/* This one also, but in case the driver hasn't implemented memory mapped access to the position register */ -static PaError PinGetAudioPositionViaIOCTLWrite(PaWinWdmPin* pPin, ULONG* pPosition) -{ - PaError result = paNoError; - KSPROPERTY propIn; - KSAUDIO_POSITION propOut; - - PA_LOGE_; - - propIn.Set = KSPROPSETID_Audio; - propIn.Id = KSPROPERTY_AUDIO_POSITION; - propIn.Flags = KSPROPERTY_TYPE_GET; - - result = WdmSyncIoctl(pPin->handle, - IOCTL_KS_PROPERTY, - &propIn, sizeof(KSPROPERTY), - &propOut, sizeof(KSAUDIO_POSITION), - NULL); - - if (result == paNoError) - { - *pPosition = (ULONG)(propOut.WriteOffset); - } - else - { - PA_DEBUG(("Failed to get audio write position!\n")); - } - - PA_LOGL_; - - return result; - -} - -/***********************************************************************************************/ - -/** -* Create a new filter object. -*/ -static PaWinWdmFilter* FilterNew( PaWDMKSType type, DWORD devNode, const wchar_t* filterName, const wchar_t* friendlyName, PaError* error ) -{ - PaWinWdmFilter* filter = 0; - PaError result; - - /* Allocate the new filter object */ - filter = (PaWinWdmFilter*)PaUtil_AllocateMemory( sizeof(PaWinWdmFilter) ); - if( !filter ) - { - result = paInsufficientMemory; - goto error; - } - - PA_DEBUG(("FilterNew: Creating filter '%S'\n", friendlyName)); - - /* Set type flag */ - filter->devInfo.streamingType = type; - - /* Store device node */ - filter->deviceNode = devNode; - - /* Zero the filter object - done by AllocateMemory */ - /* memset( (void*)filter, 0, sizeof(PaWinWdmFilter) ); */ - - /* Copy the filter name */ - wcsncpy(filter->devInfo.filterPath, filterName, MAX_PATH); - - /* Copy the friendly name */ - wcsncpy(filter->friendlyName, friendlyName, MAX_PATH); - - PA_DEBUG(("FilterNew: Opening filter...\n", friendlyName)); - - /* Open the filter handle */ - result = FilterUse(filter); - if( result != paNoError ) - { - goto error; - } - - /* Get pin count */ - result = WdmGetPinPropertySimple - ( - filter->handle, - 0, - &KSPROPSETID_Pin, - KSPROPERTY_PIN_CTYPES, - &filter->pinCount, - sizeof(filter->pinCount), - NULL); - - if( result != paNoError) - { - goto error; - } - - /* Get connections & nodes for filter */ - result = WdmGetPropertyMulti( - filter->handle, - &KSPROPSETID_Topology, - KSPROPERTY_TOPOLOGY_CONNECTIONS, - &filter->connections); - - if( result != paNoError) - { - goto error; - } - - result = WdmGetPropertyMulti( - filter->handle, - &KSPROPSETID_Topology, - KSPROPERTY_TOPOLOGY_NODES, - &filter->nodes); - - if( result != paNoError) - { - goto error; - } - - /* For debugging purposes */ - DumpConnectionsAndNodes(filter); - - /* Get product GUID (it might not be supported) */ - { - KSCOMPONENTID compId; - if (WdmGetPropertySimple(filter->handle, &KSPROPSETID_General, KSPROPERTY_GENERAL_COMPONENTID, &compId, sizeof(KSCOMPONENTID)) == paNoError) - { - filter->devInfo.deviceProductGuid = compId.Product; - } - } - - /* This section is not executed for topology filters */ - if (type != Type_kNotUsed) - { - /* Initialize the pins */ - result = FilterInitializePins(filter); - - if( result != paNoError) - { - goto error; - } - } - - /* Close the filter handle for now - * It will be opened later when needed */ - FilterRelease(filter); - - *error = paNoError; - return filter; - -error: - PA_DEBUG(("FilterNew: Error %d\n", result)); - /* - Error cleanup - */ - FilterFree(filter); - - *error = result; - return NULL; -} - -/** -* Add reference to filter -*/ -static void FilterAddRef( PaWinWdmFilter* filter ) -{ - if (filter != 0) - { - filter->filterRefCount++; - } -} - - -/** -* Initialize the pins of the filter. This is separated from FilterNew because this might fail if there is another -* process using the pin(s). -*/ -PaError FilterInitializePins( PaWinWdmFilter* filter ) -{ - PaError result = paNoError; - int pinId; - - if (filter->devInfo.streamingType == Type_kNotUsed) - return paNoError; - - if (filter->pins != NULL) - return paNoError; - - /* Allocate pointer array to hold the pins */ - filter->pins = (PaWinWdmPin**)PaUtil_AllocateMemory( sizeof(PaWinWdmPin*) * filter->pinCount ); - if( !filter->pins ) - { - result = paInsufficientMemory; - goto error; - } - - /* Create all the pins we can */ - for(pinId = 0; pinId < filter->pinCount; pinId++) - { - /* Create the pin with this Id */ - PaWinWdmPin* newPin; - newPin = PinNew(filter, pinId, &result); - if( result == paInsufficientMemory ) - goto error; - if( newPin != NULL ) - { - filter->pins[pinId] = newPin; - ++filter->validPinCount; - } - else - { - filter->pins[pinId] = 0; - } - } - - if (filter->validPinCount == 0) - { - result = paDeviceUnavailable; - goto error; - } - - return paNoError; - -error: - - if (filter->pins) - { - for (pinId = 0; pinId < filter->pinCount; ++pinId) - { - if (filter->pins[pinId]) - { - PinFree(filter->pins[pinId]); - filter->pins[pinId] = 0; - } - } - PaUtil_FreeMemory( filter->pins ); - filter->pins = 0; - } - - return result; -} - - -/** -* Free a previously created filter -*/ -static void FilterFree(PaWinWdmFilter* filter) -{ - PA_LOGL_; - if( filter ) - { - if (--filter->filterRefCount > 0) - { - /* Ok, a stream has a ref count to this filter */ - return; - } - - if ( filter->topologyFilter ) - { - FilterFree(filter->topologyFilter); - filter->topologyFilter = 0; - } - if ( filter->pins ) - { - int pinId; - for( pinId = 0; pinId < filter->pinCount; pinId++ ) - PinFree(filter->pins[pinId]); - PaUtil_FreeMemory( filter->pins ); - filter->pins = 0; - } - if( filter->connections ) - { - PaUtil_FreeMemory(filter->connections); - filter->connections = 0; - } - if( filter->nodes ) - { - PaUtil_FreeMemory(filter->nodes); - filter->nodes = 0; - } - if( filter->handle ) - CloseHandle( filter->handle ); - PaUtil_FreeMemory( filter ); - } - PA_LOGE_; -} - -/** -* Reopen the filter handle if necessary so it can be used -**/ -static PaError FilterUse(PaWinWdmFilter* filter) -{ - assert( filter ); - - PA_LOGE_; - if( filter->handle == NULL ) - { - /* Open the filter */ - filter->handle = CreateFileW( - filter->devInfo.filterPath, - GENERIC_READ | GENERIC_WRITE, - 0, - NULL, - OPEN_EXISTING, - FILE_ATTRIBUTE_NORMAL | FILE_FLAG_OVERLAPPED, - NULL); - - if( filter->handle == NULL ) - { - return paDeviceUnavailable; - } - } - filter->usageCount++; - PA_LOGL_; - return paNoError; -} - -/** -* Release the filter handle if nobody is using it -**/ -static void FilterRelease(PaWinWdmFilter* filter) -{ - assert( filter ); - assert( filter->usageCount > 0 ); - - PA_LOGE_; - /* Check first topology filter, if used */ - if (filter->topologyFilter != NULL && filter->topologyFilter->handle != NULL) - { - FilterRelease(filter->topologyFilter); - } - - filter->usageCount--; - if( filter->usageCount == 0 ) - { - if( filter->handle != NULL ) - { - CloseHandle( filter->handle ); - filter->handle = NULL; - } - } - PA_LOGL_; -} - -/** -* Create a render or playback pin using the supplied format -**/ -static PaWinWdmPin* FilterCreatePin(PaWinWdmFilter* filter, - int pinId, - const WAVEFORMATEX* wfex, - PaError* error) -{ - PaError result = paNoError; - PaWinWdmPin* pin = NULL; - assert( filter ); - assert( pinId < filter->pinCount ); - pin = filter->pins[pinId]; - assert( pin ); - result = PinSetFormat(pin,wfex); - if( result == paNoError ) - { - result = PinInstantiate(pin); - } - *error = result; - return result == paNoError ? pin : 0; -} - -static const wchar_t kUsbPrefix[] = L"\\\\?\\USB"; - -static BOOL IsUSBDevice(const wchar_t* devicePath) -{ - /* Alex Lessard pointed out that different devices might present the device path with - lower case letters. */ - return (_wcsnicmp(devicePath, kUsbPrefix, sizeof(kUsbPrefix)/sizeof(kUsbPrefix[0]) ) == 0); -} - -/* This should make it more language tolerant, I hope... */ -static const wchar_t kUsbNamePrefix[] = L"USB Audio"; - -static BOOL IsNameUSBAudioDevice(const wchar_t* friendlyName) -{ - return (_wcsnicmp(friendlyName, kUsbNamePrefix, sizeof(kUsbNamePrefix)/sizeof(kUsbNamePrefix[0])) == 0); -} - -typedef enum _tag_EAlias -{ - Alias_kRender = (1<<0), - Alias_kCapture = (1<<1), - Alias_kRealtime = (1<<2), -} EAlias; - -/* Trim whitespace from string */ -static void TrimString(wchar_t* str, size_t length) -{ - wchar_t* s = str; - wchar_t* e = 0; - - /* Find start of string */ - while (iswspace(*s)) ++s; - e=s+min(length,wcslen(s))-1; - - /* Find end of string */ - while(e>s && iswspace(*e)) --e; - ++e; - - length = e - s; - memmove(str, s, length * sizeof(wchar_t)); - str[length] = 0; -} - -/** -* Build the list of available filters -* Use the SetupDi API to enumerate all devices in the KSCATEGORY_AUDIO which -* have a KSCATEGORY_RENDER or KSCATEGORY_CAPTURE alias. For each of these -* devices initialise a PaWinWdmFilter structure by calling our NewFilter() -* function. We enumerate devices twice, once to count how many there are, -* and once to initialize the PaWinWdmFilter structures. -* -* Vista and later: Also check KSCATEGORY_REALTIME for WaveRT devices. -*/ -//PaError BuildFilterList( PaWinWdmHostApiRepresentation* wdmHostApi, int* noOfPaDevices ) -PaWinWdmFilter** BuildFilterList( int* pFilterCount, int* pNoOfPaDevices, PaError* pResult ) -{ - PaWinWdmFilter** ppFilters = NULL; - HDEVINFO handle = NULL; - int device; - int invalidDevices; - int slot; - SP_DEVICE_INTERFACE_DATA interfaceData; - SP_DEVICE_INTERFACE_DATA aliasData; - SP_DEVINFO_DATA devInfoData; - int noError; - const int sizeInterface = sizeof(SP_DEVICE_INTERFACE_DETAIL_DATA) + (MAX_PATH * sizeof(WCHAR)); - unsigned char interfaceDetailsArray[sizeof(SP_DEVICE_INTERFACE_DETAIL_DATA) + (MAX_PATH * sizeof(WCHAR))]; - SP_DEVICE_INTERFACE_DETAIL_DATA_W* devInterfaceDetails = (SP_DEVICE_INTERFACE_DETAIL_DATA_W*)interfaceDetailsArray; - const GUID* category = (const GUID*)&KSCATEGORY_AUDIO; - const GUID* alias_render = (const GUID*)&KSCATEGORY_RENDER; - const GUID* alias_capture = (const GUID*)&KSCATEGORY_CAPTURE; - const GUID* category_realtime = (const GUID*)&KSCATEGORY_REALTIME; - DWORD aliasFlags; - PaWDMKSType streamingType; - int filterCount = 0; - int noOfPaDevices = 0; - - PA_LOGE_; - - assert(pFilterCount != NULL); - assert(pNoOfPaDevices != NULL); - assert(pResult != NULL); - - devInterfaceDetails->cbSize = sizeof(SP_DEVICE_INTERFACE_DETAIL_DATA_W); - *pFilterCount = 0; - *pNoOfPaDevices = 0; - - /* Open a handle to search for devices (filters) */ - handle = SetupDiGetClassDevs(category,NULL,NULL,DIGCF_PRESENT | DIGCF_DEVICEINTERFACE); - if( handle == INVALID_HANDLE_VALUE ) - { - *pResult = paUnanticipatedHostError; - return NULL; - } - PA_DEBUG(("Setup called\n")); - - /* First let's count the number of devices so we can allocate a list */ - invalidDevices = 0; - for( device = 0;;device++ ) - { - interfaceData.cbSize = sizeof(SP_DEVICE_INTERFACE_DATA); - interfaceData.Reserved = 0; - aliasData.cbSize = sizeof(SP_DEVICE_INTERFACE_DATA); - aliasData.Reserved = 0; - noError = SetupDiEnumDeviceInterfaces(handle,NULL,category,device,&interfaceData); - PA_DEBUG(("Enum called\n")); - if( !noError ) - break; /* No more devices */ - - /* Check this one has the render or capture alias */ - aliasFlags = 0; - noError = SetupDiGetDeviceInterfaceAlias(handle,&interfaceData,alias_render,&aliasData); - PA_DEBUG(("noError = %d\n",noError)); - if(noError) - { - if(aliasData.Flags && (!(aliasData.Flags & SPINT_REMOVED))) - { - PA_DEBUG(("Device %d has render alias\n",device)); - aliasFlags |= Alias_kRender; /* Has render alias */ - } - else - { - PA_DEBUG(("Device %d has no render alias\n",device)); - } - } - noError = SetupDiGetDeviceInterfaceAlias(handle,&interfaceData,alias_capture,&aliasData); - if(noError) - { - if(aliasData.Flags && (!(aliasData.Flags & SPINT_REMOVED))) - { - PA_DEBUG(("Device %d has capture alias\n",device)); - aliasFlags |= Alias_kCapture; /* Has capture alias */ - } - else - { - PA_DEBUG(("Device %d has no capture alias\n",device)); - } - } - if(!aliasFlags) - invalidDevices++; /* This was not a valid capture or render audio device */ - } - /* Remember how many there are */ - filterCount = device-invalidDevices; - - PA_DEBUG(("Interfaces found: %d\n",device-invalidDevices)); - - /* Now allocate the list of pointers to devices */ - ppFilters = (PaWinWdmFilter**)PaUtil_AllocateMemory( sizeof(PaWinWdmFilter*) * filterCount); - if( ppFilters == 0 ) - { - if(handle != NULL) - SetupDiDestroyDeviceInfoList(handle); - *pResult = paInsufficientMemory; - return NULL; - } - - /* Now create filter objects for each interface found */ - slot = 0; - for( device = 0;;device++ ) - { - interfaceData.cbSize = sizeof(SP_DEVICE_INTERFACE_DATA); - interfaceData.Reserved = 0; - aliasData.cbSize = sizeof(SP_DEVICE_INTERFACE_DATA); - aliasData.Reserved = 0; - devInfoData.cbSize = sizeof(SP_DEVINFO_DATA); - devInfoData.Reserved = 0; - streamingType = Type_kWaveCyclic; - - noError = SetupDiEnumDeviceInterfaces(handle,NULL,category,device,&interfaceData); - if( !noError ) - break; /* No more devices */ - - /* Check this one has the render or capture alias */ - aliasFlags = 0; - noError = SetupDiGetDeviceInterfaceAlias(handle,&interfaceData,alias_render,&aliasData); - if(noError) - { - if(aliasData.Flags && (!(aliasData.Flags & SPINT_REMOVED))) - { - PA_DEBUG(("Device %d has render alias\n",device)); - aliasFlags |= Alias_kRender; /* Has render alias */ - } - } - noError = SetupDiGetDeviceInterfaceAlias(handle,&interfaceData,alias_capture,&aliasData); - if(noError) - { - if(aliasData.Flags && (!(aliasData.Flags & SPINT_REMOVED))) - { - PA_DEBUG(("Device %d has capture alias\n",device)); - aliasFlags |= Alias_kCapture; /* Has capture alias */ - } - } - if(!aliasFlags) - { - continue; /* This was not a valid capture or render audio device */ - } - else - { - /* Check if filter is WaveRT, if not it is a WaveCyclic */ - noError = SetupDiGetDeviceInterfaceAlias(handle,&interfaceData,category_realtime,&aliasData); - if (noError) - { - PA_DEBUG(("Device %d has realtime alias\n",device)); - aliasFlags |= Alias_kRealtime; - streamingType = Type_kWaveRT; - } - } - - noError = SetupDiGetDeviceInterfaceDetailW(handle,&interfaceData,devInterfaceDetails,sizeInterface,NULL,&devInfoData); - if( noError ) - { - DWORD type; - WCHAR friendlyName[MAX_PATH] = {0}; - DWORD sizeFriendlyName; - PaWinWdmFilter* newFilter = 0; - - PaError result = paNoError; - /* Try to get the "friendly name" for this interface */ - sizeFriendlyName = sizeof(friendlyName); - - if (IsEarlierThanVista() && IsUSBDevice(devInterfaceDetails->DevicePath)) - { - /* XP and USB audio device needs to look elsewhere, otherwise it'll only be a "USB Audio Device". Not - very literate. */ - if (!SetupDiGetDeviceRegistryPropertyW(handle, - &devInfoData, - SPDRP_LOCATION_INFORMATION, - &type, - (BYTE*)friendlyName, - sizeof(friendlyName), - NULL)) - { - friendlyName[0] = 0; - } - } - - if (friendlyName[0] == 0 || IsNameUSBAudioDevice(friendlyName)) - { - /* Fix contributed by Ben Allison - * Removed KEY_SET_VALUE from flags on following call - * as its causes failure when running without admin rights - * and it was not required */ - HKEY hkey=SetupDiOpenDeviceInterfaceRegKey(handle,&interfaceData,0,KEY_QUERY_VALUE); - if(hkey!=INVALID_HANDLE_VALUE) - { - noError = RegQueryValueExW(hkey,L"FriendlyName",0,&type,(BYTE*)friendlyName,&sizeFriendlyName); - if( noError == ERROR_SUCCESS ) - { - PA_DEBUG(("Interface %d, Name: %s\n",device,friendlyName)); - RegCloseKey(hkey); - } - else - { - friendlyName[0] = 0; - } - } - } - - TrimString(friendlyName, sizeFriendlyName); - - newFilter = FilterNew(streamingType, - devInfoData.DevInst, - devInterfaceDetails->DevicePath, - friendlyName, - &result); - - if( result == paNoError ) - { - int pin; - unsigned filterIOs = 0; - - /* Increment number of "devices" */ - for (pin = 0; pin < newFilter->pinCount; ++pin) - { - PaWinWdmPin* pPin = newFilter->pins[pin]; - if (pPin == NULL) - continue; - - filterIOs += max(1, pPin->inputCount); - } - - noOfPaDevices += filterIOs; - - PA_DEBUG(("Filter (%s) created with %d valid pins (total I/Os: %u)\n", ((newFilter->devInfo.streamingType==Type_kWaveRT)?"WaveRT":"WaveCyclic"), newFilter->validPinCount, filterIOs)); - - assert(slot < filterCount); - - ppFilters[slot] = newFilter; - - slot++; - } - else - { - PA_DEBUG(("Filter NOT created\n")); - /* As there are now less filters than we initially thought - * we must reduce the count by one */ - filterCount--; - } - } - } - - /* Clean up */ - if(handle != NULL) - SetupDiDestroyDeviceInfoList(handle); - - *pFilterCount = filterCount; - *pNoOfPaDevices = noOfPaDevices; - - return ppFilters; -} - -typedef struct PaNameHashIndex -{ - unsigned index; - unsigned count; - ULONG hash; - struct PaNameHashIndex *next; -} PaNameHashIndex; - -typedef struct PaNameHashObject -{ - PaNameHashIndex* list; - PaUtilAllocationGroup* allocGroup; -} PaNameHashObject; - -static ULONG GetNameHash(const wchar_t* str, const BOOL input) -{ - /* This is to make sure that a name that exists as both input & output won't get the same hash value */ - const ULONG fnv_prime = (input ? 0x811C9DD7 : 0x811FEB0B); - ULONG hash = 0; - for(; *str != 0; str++) - { - hash *= fnv_prime; - hash ^= (*str); - } - assert(hash != 0); - return hash; -} - -static PaError CreateHashEntry(PaNameHashObject* obj, const wchar_t* name, const BOOL input) -{ - ULONG hash = GetNameHash(name, input); - PaNameHashIndex * pLast = NULL; - PaNameHashIndex * p = obj->list; - while (p != 0) - { - if (p->hash == hash) - { - break; - } - pLast = p; - p = p->next; - } - if (p == NULL) - { - p = (PaNameHashIndex*)PaUtil_GroupAllocateMemory(obj->allocGroup, sizeof(PaNameHashIndex)); - if (p == NULL) - { - return paInsufficientMemory; - } - p->hash = hash; - p->count = 1; - if (pLast != 0) - { - assert(pLast->next == 0); - pLast->next = p; - } - if (obj->list == 0) - { - obj->list = p; - } - } - else - { - ++p->count; - } - return paNoError; -} - -static PaError InitNameHashObject(PaNameHashObject* obj, PaWinWdmFilter* pFilter) -{ - int i; - - obj->allocGroup = PaUtil_CreateAllocationGroup(); - if (obj->allocGroup == NULL) - { - return paInsufficientMemory; - } - - for (i = 0; i < pFilter->pinCount; ++i) - { - unsigned m; - PaWinWdmPin* pin = pFilter->pins[i]; - - if (pin == NULL) - continue; - - for (m = 0; m < max(1, pin->inputCount); ++m) - { - const BOOL isInput = (pin->dataFlow == KSPIN_DATAFLOW_OUT); - const wchar_t* name = (pin->inputs == NULL) ? pin->friendlyName : pin->inputs[m]->friendlyName; - - PaError result = CreateHashEntry(obj, name, isInput); - - if (result != paNoError) - { - return result; - } - } - } - return paNoError; -} - -static void DeinitNameHashObject(PaNameHashObject* obj) -{ - assert(obj != 0); - PaUtil_FreeAllAllocations(obj->allocGroup); - PaUtil_DestroyAllocationGroup(obj->allocGroup); - memset(obj, 0, sizeof(PaNameHashObject)); -} - -static unsigned GetNameIndex(PaNameHashObject* obj, const wchar_t* name, const BOOL input) -{ - ULONG hash = GetNameHash(name, input); - PaNameHashIndex* p = obj->list; - while (p != NULL) - { - if (p->hash == hash) - { - if (p->count > 1) - { - return (++p->index); - } - else - { - return 0; - } - } - - p = p->next; - } - // Should never get here!! - assert(FALSE); - return 0; -} - -static PaError ScanDeviceInfos( struct PaUtilHostApiRepresentation *hostApi, PaHostApiIndex hostApiIndex, void **scanResults, int *newDeviceCount ) -{ - PaWinWdmHostApiRepresentation *wdmHostApi = (PaWinWdmHostApiRepresentation*)hostApi; - PaError result = paNoError; - PaWinWdmFilter** ppFilters = 0; - PaWinWDMScanDeviceInfosResults *outArgument = 0; - int filterCount = 0; - int totalDeviceCount = 0; - int idxDevice = 0; - DWORD defaultInDevPathSize = 0; - DWORD defaultOutDevPathSize = 0; - wchar_t* defaultInDevPath = 0; - wchar_t* defaultOutDevPath = 0; - - ppFilters = BuildFilterList( &filterCount, &totalDeviceCount, &result ); - if( result != paNoError ) - { - goto error; - } - - // Get hold of default device paths for capture & playback - if( waveInMessage(0, DRV_QUERYDEVICEINTERFACESIZE, (DWORD_PTR)&defaultInDevPathSize, 0 ) == MMSYSERR_NOERROR ) - { - defaultInDevPath = (wchar_t *)PaUtil_AllocateMemory((defaultInDevPathSize + 1) * sizeof(wchar_t)); - waveInMessage(0, DRV_QUERYDEVICEINTERFACE, (DWORD_PTR)defaultInDevPath, defaultInDevPathSize); - } - if( waveOutMessage(0, DRV_QUERYDEVICEINTERFACESIZE, (DWORD_PTR)&defaultOutDevPathSize, 0 ) == MMSYSERR_NOERROR ) - { - defaultOutDevPath = (wchar_t *)PaUtil_AllocateMemory((defaultOutDevPathSize + 1) * sizeof(wchar_t)); - waveOutMessage(0, DRV_QUERYDEVICEINTERFACE, (DWORD_PTR)defaultOutDevPath, defaultOutDevPathSize); - } - - if( totalDeviceCount > 0 ) - { - PaWinWdmDeviceInfo *deviceInfoArray = 0; - int idxFilter; - int i; - unsigned devIsDefaultIn = 0, devIsDefaultOut = 0; - - /* Allocate the out param for all the info we need */ - outArgument = (PaWinWDMScanDeviceInfosResults *) PaUtil_GroupAllocateMemory( - wdmHostApi->allocations, sizeof(PaWinWDMScanDeviceInfosResults) ); - if( !outArgument ) - { - result = paInsufficientMemory; - goto error; - } - - outArgument->defaultInputDevice = paNoDevice; - outArgument->defaultOutputDevice = paNoDevice; - - outArgument->deviceInfos = (PaDeviceInfo**)PaUtil_GroupAllocateMemory( - wdmHostApi->allocations, sizeof(PaDeviceInfo*) * totalDeviceCount ); - if( !outArgument->deviceInfos ) - { - result = paInsufficientMemory; - goto error; - } - - /* allocate all device info structs in a contiguous block */ - deviceInfoArray = (PaWinWdmDeviceInfo*)PaUtil_GroupAllocateMemory( - wdmHostApi->allocations, sizeof(PaWinWdmDeviceInfo) * totalDeviceCount ); - if( !deviceInfoArray ) - { - result = paInsufficientMemory; - goto error; - } - - /* Make sure all items in array */ - for( i = 0 ; i < totalDeviceCount; ++i ) - { - PaDeviceInfo *deviceInfo = &deviceInfoArray[i].inheritedDeviceInfo; - deviceInfo->structVersion = 2; - deviceInfo->hostApi = hostApiIndex; - deviceInfo->name = 0; - outArgument->deviceInfos[ i ] = deviceInfo; - } - - idxDevice = 0; - for (idxFilter = 0; idxFilter < filterCount; ++idxFilter) - { - PaNameHashObject nameHash = {0}; - PaWinWdmFilter* pFilter = ppFilters[idxFilter]; - if( pFilter == NULL ) - continue; - - if (InitNameHashObject(&nameHash, pFilter) != paNoError) - { - DeinitNameHashObject(&nameHash); - continue; - } - - devIsDefaultIn = (defaultInDevPath && (_wcsicmp(pFilter->devInfo.filterPath, defaultInDevPath) == 0)); - devIsDefaultOut = (defaultOutDevPath && (_wcsicmp(pFilter->devInfo.filterPath, defaultOutDevPath) == 0)); - - for (i = 0; i < pFilter->pinCount; ++i) - { - unsigned m; - ULONG nameIndex = 0; - ULONG nameIndexHash = 0; - PaWinWdmPin* pin = pFilter->pins[i]; - - if (pin == NULL) - continue; - - for (m = 0; m < max(1, pin->inputCount); ++m) - { - PaWinWdmDeviceInfo *wdmDeviceInfo = (PaWinWdmDeviceInfo *)outArgument->deviceInfos[idxDevice]; - PaDeviceInfo *deviceInfo = &wdmDeviceInfo->inheritedDeviceInfo; - wchar_t localCompositeName[MAX_PATH]; - unsigned nameIndex = 0; - const BOOL isInput = (pin->dataFlow == KSPIN_DATAFLOW_OUT); - - wdmDeviceInfo->filter = pFilter; - - deviceInfo->structVersion = 2; - deviceInfo->hostApi = hostApiIndex; - deviceInfo->name = wdmDeviceInfo->compositeName; - /* deviceInfo->hostApiSpecificDeviceInfo = &pFilter->devInfo; */ - - wdmDeviceInfo->pin = pin->pinId; - - /* Get the name of the "device" */ - if (pin->inputs == NULL) - { - wcsncpy(localCompositeName, pin->friendlyName, MAX_PATH); - wdmDeviceInfo->muxPosition = -1; - wdmDeviceInfo->endpointPinId = pin->endpointPinId; - } - else - { - PaWinWdmMuxedInput* input = pin->inputs[m]; - wcsncpy(localCompositeName, input->friendlyName, MAX_PATH); - wdmDeviceInfo->muxPosition = (int)m; - wdmDeviceInfo->endpointPinId = input->endpointPinId; - } - - { - /* Get base length */ - size_t n = wcslen(localCompositeName); - - /* Check if there are more entries with same name (which might very well be the case), if there - are, the name will be postfixed with an index. */ - nameIndex = GetNameIndex(&nameHash, localCompositeName, isInput); - if (nameIndex > 0) - { - /* This name has multiple instances, so we post fix with a number */ - n += _snwprintf(localCompositeName + n, MAX_PATH - n, L" %u", nameIndex); - } - /* Postfix with filter name */ - _snwprintf(localCompositeName + n, MAX_PATH - n, L" (%s)", pFilter->friendlyName); - } - - /* Convert wide char string to utf-8 */ - WideCharToMultiByte(CP_UTF8, 0, localCompositeName, -1, wdmDeviceInfo->compositeName, MAX_PATH, NULL, NULL); - - /* NB! WDM/KS has no concept of a full-duplex device, each pin is either an input or an output */ - if (isInput) - { - /* INPUT ! */ - deviceInfo->maxInputChannels = pin->maxChannels; - deviceInfo->maxOutputChannels = 0; - - /* RoBi NB: Due to the fact that input audio endpoints in Vista (& later OSs) can be the same device, but with - different input mux settings, there might be a discrepancy between the default input device chosen, and - that which will be used by Portaudio. Not much to do about that unfortunately. - */ - if ((defaultInDevPath == 0 || devIsDefaultIn) && - outArgument->defaultInputDevice == paNoDevice) - { - outArgument->defaultInputDevice = idxDevice; - } - } - else - { - /* OUTPUT ! */ - deviceInfo->maxInputChannels = 0; - deviceInfo->maxOutputChannels = pin->maxChannels; - - if ((defaultOutDevPath == 0 || devIsDefaultOut) && - outArgument->defaultOutputDevice == paNoDevice) - { - outArgument->defaultOutputDevice = idxDevice; - } - } - - /* These low values are not very useful because - * a) The lowest latency we end up with can depend on many factors such - * as the device buffer sizes/granularities, sample rate, channels and format - * b) We cannot know the device buffer sizes until we try to open/use it at - * a particular setting - * So: we give 512x48000Hz frames as the default low input latency - **/ - switch (pFilter->devInfo.streamingType) - { - case Type_kWaveCyclic: - if (IsEarlierThanVista()) - { - /* XP doesn't tolerate low latency, unless the Process Priority Class is set to REALTIME_PRIORITY_CLASS - through SetPriorityClass, then 10 ms is quite feasible. However, one should then bear in mind that ALL of - the process is running in REALTIME_PRIORITY_CLASS, which might not be appropriate for an application with - a GUI . In this case it is advisable to separate the audio engine in another process and use IPC to communicate - with it. */ - deviceInfo->defaultLowInputLatency = 0.02; - deviceInfo->defaultLowOutputLatency = 0.02; - } - else - { - /* This is a conservative estimate. Most WaveCyclic drivers will limit the available latency, but f.i. my Edirol - PCR-A30 can reach 3 ms latency easily... */ - deviceInfo->defaultLowInputLatency = 0.01; - deviceInfo->defaultLowOutputLatency = 0.01; - } - deviceInfo->defaultHighInputLatency = (4096.0/48000.0); - deviceInfo->defaultHighOutputLatency = (4096.0/48000.0); - deviceInfo->defaultSampleRate = (double)(pin->defaultSampleRate); - break; - case Type_kWaveRT: - /* This is also a conservative estimate, based on WaveRT polled mode. In polled mode, the latency will be dictated - by the buffer size given by the driver. */ - deviceInfo->defaultLowInputLatency = 0.01; - deviceInfo->defaultLowOutputLatency = 0.01; - deviceInfo->defaultHighInputLatency = 0.04; - deviceInfo->defaultHighOutputLatency = 0.04; - deviceInfo->defaultSampleRate = (double)(pin->defaultSampleRate); - break; - default: - assert(0); - break; - } - - /* Add reference to filter */ - FilterAddRef(wdmDeviceInfo->filter); - - assert(idxDevice < totalDeviceCount); - ++idxDevice; - } - } - - /* If no one has add ref'd the filter, drop it */ - if (pFilter->filterRefCount == 0) - { - FilterFree(pFilter); - } - - /* Deinitialize name hash object */ - DeinitNameHashObject(&nameHash); - } - } - - *scanResults = outArgument; - *newDeviceCount = idxDevice; - return result; - -error: - result = DisposeDeviceInfos(hostApi, outArgument, totalDeviceCount); - - return result; -} - -static PaError CommitDeviceInfos( struct PaUtilHostApiRepresentation *hostApi, PaHostApiIndex index, void *scanResults, int deviceCount ) -{ - PaWinWdmHostApiRepresentation *wdmHostApi = (PaWinWdmHostApiRepresentation*)hostApi; - - hostApi->info.deviceCount = 0; - hostApi->info.defaultInputDevice = paNoDevice; - hostApi->info.defaultOutputDevice = paNoDevice; - - /* Free any old memory which might be in the device info */ - if( hostApi->deviceInfos ) - { - PaWinWDMScanDeviceInfosResults* localScanResults = (PaWinWDMScanDeviceInfosResults*)PaUtil_GroupAllocateMemory( - wdmHostApi->allocations, sizeof(PaWinWDMScanDeviceInfosResults)); - localScanResults->deviceInfos = hostApi->deviceInfos; - - DisposeDeviceInfos(hostApi, &localScanResults, hostApi->info.deviceCount); - - hostApi->deviceInfos = NULL; - } - - if( scanResults != NULL ) - { - PaWinWDMScanDeviceInfosResults *scanDeviceInfosResults = ( PaWinWDMScanDeviceInfosResults * ) scanResults; - - if( deviceCount > 0 ) - { - /* use the array allocated in ScanDeviceInfos() as our deviceInfos */ - hostApi->deviceInfos = scanDeviceInfosResults->deviceInfos; - - hostApi->info.defaultInputDevice = scanDeviceInfosResults->defaultInputDevice; - hostApi->info.defaultOutputDevice = scanDeviceInfosResults->defaultOutputDevice; - - hostApi->info.deviceCount = deviceCount; - } - - PaUtil_GroupFreeMemory( wdmHostApi->allocations, scanDeviceInfosResults ); - } - - return paNoError; - -} - -static PaError DisposeDeviceInfos( struct PaUtilHostApiRepresentation *hostApi, void *scanResults, int deviceCount ) -{ - PaWinWdmHostApiRepresentation *winDsHostApi = (PaWinWdmHostApiRepresentation*)hostApi; - - if( scanResults != NULL ) - { - PaWinWDMScanDeviceInfosResults *scanDeviceInfosResults = ( PaWinWDMScanDeviceInfosResults * ) scanResults; - - if( scanDeviceInfosResults->deviceInfos ) - { - int i; - for (i = 0; i < deviceCount; ++i) - { - PaWinWdmDeviceInfo* pDevice = (PaWinWdmDeviceInfo*)scanDeviceInfosResults->deviceInfos[i]; - if (pDevice->filter != 0) - { - FilterFree(pDevice->filter); - } - } - - PaUtil_GroupFreeMemory( winDsHostApi->allocations, scanDeviceInfosResults->deviceInfos[0] ); /* all device info structs are allocated in a block so we can destroy them here */ - PaUtil_GroupFreeMemory( winDsHostApi->allocations, scanDeviceInfosResults->deviceInfos ); - } - - PaUtil_GroupFreeMemory( winDsHostApi->allocations, scanDeviceInfosResults ); - } - - return paNoError; - -} - -PaError PaWinWdm_Initialize( PaUtilHostApiRepresentation **hostApi, PaHostApiIndex hostApiIndex ) -{ - PaError result = paNoError; - int deviceCount = 0; - void *scanResults = 0; - PaWinWdmHostApiRepresentation *wdmHostApi = NULL; - - PA_LOGE_; - -#ifdef PA_WDMKS_SET_TREF - tRef = PaUtil_GetTime(); -#endif - - /* - Attempt to load the KSUSER.DLL without which we cannot create pins - We will unload this on termination - */ - if(DllKsUser == NULL) - { - DllKsUser = LoadLibrary(TEXT("ksuser.dll")); - if(DllKsUser == NULL) - goto error; - } - FunctionKsCreatePin = (KSCREATEPIN*)GetProcAddress(DllKsUser, "KsCreatePin"); - if(FunctionKsCreatePin == NULL) - goto error; - - /* Attempt to load AVRT.DLL, if we can't, then we'll just use time critical prio instead... */ - if(paWinWDMKSAvRtEntryPoints.hInstance == NULL) - { - paWinWDMKSAvRtEntryPoints.hInstance = LoadLibrary(TEXT("avrt.dll")); - if (paWinWDMKSAvRtEntryPoints.hInstance != NULL) - { - paWinWDMKSAvRtEntryPoints.AvSetMmThreadCharacteristics = - (HANDLE(WINAPI*)(LPCSTR,LPDWORD))GetProcAddress(paWinWDMKSAvRtEntryPoints.hInstance,"AvSetMmThreadCharacteristicsA"); - paWinWDMKSAvRtEntryPoints.AvRevertMmThreadCharacteristics = - (BOOL(WINAPI*)(HANDLE))GetProcAddress(paWinWDMKSAvRtEntryPoints.hInstance, "AvRevertMmThreadCharacteristics"); - paWinWDMKSAvRtEntryPoints.AvSetMmThreadPriority = - (BOOL(WINAPI*)(HANDLE,PA_AVRT_PRIORITY))GetProcAddress(paWinWDMKSAvRtEntryPoints.hInstance, "AvSetMmThreadPriority"); - } - } - - wdmHostApi = (PaWinWdmHostApiRepresentation*)PaUtil_AllocateMemory( sizeof(PaWinWdmHostApiRepresentation) ); - if( !wdmHostApi ) - { - result = paInsufficientMemory; - goto error; - } - - wdmHostApi->allocations = PaUtil_CreateAllocationGroup(); - if( !wdmHostApi->allocations ) - { - result = paInsufficientMemory; - goto error; - } - - *hostApi = &wdmHostApi->inheritedHostApiRep; - (*hostApi)->info.structVersion = 1; - (*hostApi)->info.type = paWDMKS; - (*hostApi)->info.name = "Windows WDM-KS"; - - /* these are all updated by CommitDeviceInfos() */ - (*hostApi)->info.deviceCount = 0; - (*hostApi)->info.defaultInputDevice = paNoDevice; - (*hostApi)->info.defaultOutputDevice = paNoDevice; - (*hostApi)->deviceInfos = 0; - - result = ScanDeviceInfos(&wdmHostApi->inheritedHostApiRep, hostApiIndex, &scanResults, &deviceCount); - if (result != paNoError) - { - goto error; - } - - CommitDeviceInfos(&wdmHostApi->inheritedHostApiRep, hostApiIndex, scanResults, deviceCount); - - (*hostApi)->Terminate = Terminate; - (*hostApi)->OpenStream = OpenStream; - (*hostApi)->IsFormatSupported = IsFormatSupported; - /* In preparation for hotplug - (*hostApi)->ScanDeviceInfos = ScanDeviceInfos; - (*hostApi)->CommitDeviceInfos = CommitDeviceInfos; - (*hostApi)->DisposeDeviceInfos = DisposeDeviceInfos; - */ - PaUtil_InitializeStreamInterface( &wdmHostApi->callbackStreamInterface, CloseStream, StartStream, - StopStream, AbortStream, IsStreamStopped, IsStreamActive, - GetStreamTime, GetStreamCpuLoad, - PaUtil_DummyRead, PaUtil_DummyWrite, - PaUtil_DummyGetReadAvailable, PaUtil_DummyGetWriteAvailable ); - - PaUtil_InitializeStreamInterface( &wdmHostApi->blockingStreamInterface, CloseStream, StartStream, - StopStream, AbortStream, IsStreamStopped, IsStreamActive, - GetStreamTime, PaUtil_DummyGetCpuLoad, - ReadStream, WriteStream, GetStreamReadAvailable, GetStreamWriteAvailable ); - - PA_LOGL_; - return result; - -error: - Terminate( (PaUtilHostApiRepresentation*)wdmHostApi ); - - PA_LOGL_; - return result; -} - - -static void Terminate( struct PaUtilHostApiRepresentation *hostApi ) -{ - PaWinWdmHostApiRepresentation *wdmHostApi = (PaWinWdmHostApiRepresentation*)hostApi; - PA_LOGE_; - - /* Do not unload the libraries */ - if( DllKsUser != NULL ) - { - FreeLibrary( DllKsUser ); - DllKsUser = NULL; - } - - if( paWinWDMKSAvRtEntryPoints.hInstance != NULL ) - { - FreeLibrary( paWinWDMKSAvRtEntryPoints.hInstance ); - paWinWDMKSAvRtEntryPoints.hInstance = NULL; - } - - if( wdmHostApi) - { - PaWinWDMScanDeviceInfosResults* localScanResults = (PaWinWDMScanDeviceInfosResults*)PaUtil_GroupAllocateMemory( - wdmHostApi->allocations, sizeof(PaWinWDMScanDeviceInfosResults)); - localScanResults->deviceInfos = hostApi->deviceInfos; - DisposeDeviceInfos(hostApi, localScanResults, hostApi->info.deviceCount); - - if( wdmHostApi->allocations ) - { - PaUtil_FreeAllAllocations( wdmHostApi->allocations ); - PaUtil_DestroyAllocationGroup( wdmHostApi->allocations ); - } - PaUtil_FreeMemory( wdmHostApi ); - } - PA_LOGL_; -} - -static PaError IsFormatSupported( struct PaUtilHostApiRepresentation *hostApi, - const PaStreamParameters *inputParameters, - const PaStreamParameters *outputParameters, - double sampleRate ) -{ - int inputChannelCount, outputChannelCount; - PaSampleFormat inputSampleFormat, outputSampleFormat; - PaWinWdmHostApiRepresentation *wdmHostApi = (PaWinWdmHostApiRepresentation*)hostApi; - PaWinWdmFilter* pFilter; - int result = paFormatIsSupported; - WAVEFORMATEXTENSIBLE wfx; - PaWinWaveFormatChannelMask channelMask; - - PA_LOGE_; - - if( inputParameters ) - { - PaWinWdmDeviceInfo* pDeviceInfo = (PaWinWdmDeviceInfo*)wdmHostApi->inheritedHostApiRep.deviceInfos[inputParameters->device]; - PaWinWdmPin* pin; - unsigned fmt; - unsigned long testFormat = 0; - unsigned validBits = 0; - - inputChannelCount = inputParameters->channelCount; - inputSampleFormat = inputParameters->sampleFormat; - - /* all standard sample formats are supported by the buffer adapter, - this implementation doesn't support any custom sample formats */ - if( inputSampleFormat & paCustomFormat ) - { - PaWinWDM_SetLastErrorInfo(paSampleFormatNotSupported, "IsFormatSupported: Custom input format not supported"); - return paSampleFormatNotSupported; - } - - /* unless alternate device specification is supported, reject the use of - paUseHostApiSpecificDeviceSpecification */ - - if( inputParameters->device == paUseHostApiSpecificDeviceSpecification ) - { - PaWinWDM_SetLastErrorInfo(paInvalidDevice, "IsFormatSupported: paUseHostApiSpecificDeviceSpecification not supported"); - return paInvalidDevice; - } - - /* check that input device can support inputChannelCount */ - if( inputChannelCount > hostApi->deviceInfos[ inputParameters->device ]->maxInputChannels ) - { - PaWinWDM_SetLastErrorInfo(paInvalidChannelCount, "IsFormatSupported: Invalid input channel count"); - return paInvalidChannelCount; - } - - /* validate inputStreamInfo */ - if( inputParameters->hostApiSpecificStreamInfo ) - { - PaWinWDM_SetLastErrorInfo(paIncompatibleHostApiSpecificStreamInfo, "Host API stream info not supported"); - return paIncompatibleHostApiSpecificStreamInfo; /* this implementation doesn't use custom stream info */ - } - - pFilter = pDeviceInfo->filter; - pin = pFilter->pins[pDeviceInfo->pin]; - - /* Find out the testing format */ - for (fmt = paFloat32; fmt <= paUInt8; fmt <<= 1) - { - if ((fmt & pin->formats) != 0) - { - /* Found a matching format! */ - testFormat = fmt; - break; - } - } - if (testFormat == 0) - { - PaWinWDM_SetLastErrorInfo(result, "IsFormatSupported(capture) failed: no testformat found!"); - return paUnanticipatedHostError; - } - - /* Due to special considerations, WaveRT devices with paInt24 should be tested with paInt32 and - valid bits = 24 (instead of 24 bit samples) */ - if (pFilter->devInfo.streamingType == Type_kWaveRT && testFormat == paInt24) - { - PA_DEBUG(("IsFormatSupported (capture): WaveRT overriding testFormat paInt24 with paInt32 (24 valid bits)")); - testFormat = paInt32; - validBits = 24; - } - - /* Check that the input format is supported */ - channelMask = PaWin_DefaultChannelMask(inputChannelCount); - PaWin_InitializeWaveFormatExtensible((PaWinWaveFormat*)&wfx, - inputChannelCount, - testFormat, - PaWin_SampleFormatToLinearWaveFormatTag(testFormat), - sampleRate, - channelMask ); - if (validBits != 0) - { - wfx.Samples.wValidBitsPerSample = validBits; - } - - result = PinIsFormatSupported(pin, (const WAVEFORMATEX*)&wfx); - if( result != paNoError ) - { - /* Try a WAVE_FORMAT_PCM instead */ - PaWin_InitializeWaveFormatEx((PaWinWaveFormat*)&wfx, - inputChannelCount, - testFormat, - PaWin_SampleFormatToLinearWaveFormatTag(testFormat), - sampleRate); - - if (validBits != 0) - { - wfx.Samples.wValidBitsPerSample = validBits; - } - - result = PinIsFormatSupported(pin, (const WAVEFORMATEX*)&wfx); - if( result != paNoError ) - { - PaWinWDM_SetLastErrorInfo(result, "IsFormatSupported(capture) failed: sr=%u,ch=%u,bits=%u", wfx.Format.nSamplesPerSec, wfx.Format.nChannels, wfx.Format.wBitsPerSample); - return result; - } - } - } - else - { - inputChannelCount = 0; - } - - if( outputParameters ) - { - PaWinWdmDeviceInfo* pDeviceInfo = (PaWinWdmDeviceInfo*)wdmHostApi->inheritedHostApiRep.deviceInfos[outputParameters->device]; - PaWinWdmPin* pin; - unsigned fmt; - unsigned long testFormat = 0; - unsigned validBits = 0; - - outputChannelCount = outputParameters->channelCount; - outputSampleFormat = outputParameters->sampleFormat; - - /* all standard sample formats are supported by the buffer adapter, - this implementation doesn't support any custom sample formats */ - if( outputSampleFormat & paCustomFormat ) - { - PaWinWDM_SetLastErrorInfo(paSampleFormatNotSupported, "IsFormatSupported: Custom output format not supported"); - return paSampleFormatNotSupported; - } - - /* unless alternate device specification is supported, reject the use of - paUseHostApiSpecificDeviceSpecification */ - - if( outputParameters->device == paUseHostApiSpecificDeviceSpecification ) - { - PaWinWDM_SetLastErrorInfo(paInvalidDevice, "IsFormatSupported: paUseHostApiSpecificDeviceSpecification not supported"); - return paInvalidDevice; - } - - /* check that output device can support outputChannelCount */ - if( outputChannelCount > hostApi->deviceInfos[ outputParameters->device ]->maxOutputChannels ) - { - PaWinWDM_SetLastErrorInfo(paInvalidChannelCount, "Invalid output channel count"); - return paInvalidChannelCount; - } - - /* validate outputStreamInfo */ - if( outputParameters->hostApiSpecificStreamInfo ) - { - PaWinWDM_SetLastErrorInfo(paIncompatibleHostApiSpecificStreamInfo, "Host API stream info not supported"); - return paIncompatibleHostApiSpecificStreamInfo; /* this implementation doesn't use custom stream info */ - } - - pFilter = pDeviceInfo->filter; - pin = pFilter->pins[pDeviceInfo->pin]; - - /* Find out the testing format */ - for (fmt = paFloat32; fmt <= paUInt8; fmt <<= 1) - { - if ((fmt & pin->formats) != 0) - { - /* Found a matching format! */ - testFormat = fmt; - break; - } - } - if (testFormat == 0) - { - PaWinWDM_SetLastErrorInfo(result, "IsFormatSupported(render) failed: no testformat found!"); - return paUnanticipatedHostError; - } - - /* Due to special considerations, WaveRT devices with paInt24 should be tested with paInt32 and - valid bits = 24 (instead of 24 bit samples) */ - if (pFilter->devInfo.streamingType == Type_kWaveRT && testFormat == paInt24) - { - PA_DEBUG(("IsFormatSupported (render): WaveRT overriding testFormat paInt24 with paInt32 (24 valid bits)")); - testFormat = paInt32; - validBits = 24; - } - - /* Check that the output format is supported */ - channelMask = PaWin_DefaultChannelMask(outputChannelCount); - PaWin_InitializeWaveFormatExtensible((PaWinWaveFormat*)&wfx, - outputChannelCount, - testFormat, - PaWin_SampleFormatToLinearWaveFormatTag(testFormat), - sampleRate, - channelMask ); - - if (validBits != 0) - { - wfx.Samples.wValidBitsPerSample = validBits; - } - - result = PinIsFormatSupported(pin, (const WAVEFORMATEX*)&wfx); - if( result != paNoError ) - { - /* Try a WAVE_FORMAT_PCM instead */ - PaWin_InitializeWaveFormatEx((PaWinWaveFormat*)&wfx, - outputChannelCount, - testFormat, - PaWin_SampleFormatToLinearWaveFormatTag(testFormat), - sampleRate); - - if (validBits != 0) - { - wfx.Samples.wValidBitsPerSample = validBits; - } - - result = PinIsFormatSupported(pin, (const WAVEFORMATEX*)&wfx); - if( result != paNoError ) - { - PaWinWDM_SetLastErrorInfo(result, "IsFormatSupported(render) failed: %u,%u,%u", wfx.Format.nSamplesPerSec, wfx.Format.nChannels, wfx.Format.wBitsPerSample); - return result; - } - } - - } - else - { - outputChannelCount = 0; - } - - /* - IMPLEMENT ME: - - - if a full duplex stream is requested, check that the combination - of input and output parameters is supported if necessary - - - check that the device supports sampleRate - - Because the buffer adapter handles conversion between all standard - sample formats, the following checks are only required if paCustomFormat - is implemented, or under some other unusual conditions. - - - check that input device can support inputSampleFormat, or that - we have the capability to convert from inputSampleFormat to - a native format - - - check that output device can support outputSampleFormat, or that - we have the capability to convert from outputSampleFormat to - a native format - */ - if((inputChannelCount == 0)&&(outputChannelCount == 0)) - { - PaWinWDM_SetLastErrorInfo(paSampleFormatNotSupported, "No input or output channels defined"); - result = paSampleFormatNotSupported; /* Not right error */ - } - - PA_LOGL_; - return result; -} - -static void ResetStreamEvents(PaWinWdmStream* stream) -{ - unsigned i; - ResetEvent(stream->eventAbort); - ResetEvent(stream->eventStreamStart[StreamStart_kOk]); - ResetEvent(stream->eventStreamStart[StreamStart_kFailed]); - - for (i=0; i<stream->capture.noOfPackets; ++i) - { - if (stream->capture.events && stream->capture.events[i]) - { - ResetEvent(stream->capture.events[i]); - } - } - - for (i=0; i<stream->render.noOfPackets; ++i) - { - if (stream->render.events && stream->render.events[i]) - { - ResetEvent(stream->render.events[i]); - } - } -} - -static void CloseStreamEvents(PaWinWdmStream* stream) -{ - unsigned i; - PaWinWdmIOInfo* ios[2] = { &stream->capture, &stream->render }; - - if (stream->eventAbort) - { - CloseHandle(stream->eventAbort); - stream->eventAbort = 0; - } - if (stream->eventStreamStart[StreamStart_kOk]) - { - CloseHandle(stream->eventStreamStart[StreamStart_kOk]); - } - if (stream->eventStreamStart[StreamStart_kFailed]) - { - CloseHandle(stream->eventStreamStart[StreamStart_kFailed]); - } - - for (i = 0; i < 2; ++i) - { - unsigned j; - /* Unregister notification handles for WaveRT */ - if (ios[i]->pPin && ios[i]->pPin->parentFilter->devInfo.streamingType == Type_kWaveRT && - ios[i]->pPin->pinKsSubType == SubType_kNotification && - ios[i]->events != 0) - { - PinUnregisterNotificationHandle(ios[i]->pPin, ios[i]->events[0]); - } - - for (j=0; j < ios[i]->noOfPackets; ++j) - { - if (ios[i]->events && ios[i]->events[j]) - { - CloseHandle(ios[i]->events[j]); - ios[i]->events[j] = 0; - } - } - } -} - -static unsigned NextPowerOf2(unsigned val) -{ - val--; - val = (val >> 1) | val; - val = (val >> 2) | val; - val = (val >> 4) | val; - val = (val >> 8) | val; - val = (val >> 16) | val; - return ++val; -} - -static PaError ValidateSpecificStreamParameters( - const PaStreamParameters *streamParameters, - const PaWinWDMKSInfo *streamInfo, - unsigned isInput) -{ - if( streamInfo ) - { - if( streamInfo->size != sizeof( PaWinWDMKSInfo ) - || streamInfo->version != 1 ) - { - PA_DEBUG(("Stream parameters: size or version not correct")); - return paIncompatibleHostApiSpecificStreamInfo; - } - - if (!!(streamInfo->flags & ~(paWinWDMKSOverrideFramesize | paWinWDMKSUseGivenChannelMask))) - { - PA_DEBUG(("Stream parameters: non supported flags set")); - return paIncompatibleHostApiSpecificStreamInfo; - } - - if (streamInfo->noOfPackets != 0 && - (streamInfo->noOfPackets < 2 || streamInfo->noOfPackets > 8)) - { - PA_DEBUG(("Stream parameters: noOfPackets %u out of range [2,8]", streamInfo->noOfPackets)); - return paIncompatibleHostApiSpecificStreamInfo; - } - - if (streamInfo->flags & paWinWDMKSUseGivenChannelMask) - { - if (isInput) - { - PA_DEBUG(("Stream parameters: Channels mask setting not supported for input stream")); - return paIncompatibleHostApiSpecificStreamInfo; - } - - if (streamInfo->channelMask & PAWIN_SPEAKER_RESERVED) - { - PA_DEBUG(("Stream parameters: Given channels mask 0x%08X not supported", streamInfo->channelMask)); - return paIncompatibleHostApiSpecificStreamInfo; - } - } - - } - - return paNoError; -} - - - - -/* see pa_hostapi.h for a list of validity guarantees made about OpenStream parameters */ - -static PaError OpenStream( struct PaUtilHostApiRepresentation *hostApi, - PaStream** s, - const PaStreamParameters *inputParameters, - const PaStreamParameters *outputParameters, - double sampleRate, - unsigned long framesPerUserBuffer, - PaStreamFlags streamFlags, - PaStreamCallback *streamCallback, - void *userData ) -{ - PaError result = paNoError; - PaWinWdmHostApiRepresentation *wdmHostApi = (PaWinWdmHostApiRepresentation*)hostApi; - PaWinWdmStream *stream = 0; - /* unsigned long framesPerHostBuffer; these may not be equivalent for all implementations */ - PaSampleFormat inputSampleFormat, outputSampleFormat; - PaSampleFormat hostInputSampleFormat, hostOutputSampleFormat; - int userInputChannels,userOutputChannels; - WAVEFORMATEXTENSIBLE wfx; - - PA_LOGE_; - PA_DEBUG(("OpenStream:sampleRate = %f\n",sampleRate)); - PA_DEBUG(("OpenStream:framesPerBuffer = %lu\n",framesPerUserBuffer)); - - if( inputParameters ) - { - userInputChannels = inputParameters->channelCount; - inputSampleFormat = inputParameters->sampleFormat; - - /* unless alternate device specification is supported, reject the use of - paUseHostApiSpecificDeviceSpecification */ - - if( inputParameters->device == paUseHostApiSpecificDeviceSpecification ) - { - PaWinWDM_SetLastErrorInfo(paInvalidDevice, "paUseHostApiSpecificDeviceSpecification(in) not supported"); - return paInvalidDevice; - } - - /* check that input device can support stream->userInputChannels */ - if( userInputChannels > hostApi->deviceInfos[ inputParameters->device ]->maxInputChannels ) - { - PaWinWDM_SetLastErrorInfo(paInvalidChannelCount, "Invalid input channel count"); - return paInvalidChannelCount; - } - - /* validate inputStreamInfo */ - result = ValidateSpecificStreamParameters(inputParameters, inputParameters->hostApiSpecificStreamInfo, 1 ); - if(result != paNoError) - { - PaWinWDM_SetLastErrorInfo(result, "Host API stream info not supported (in)"); - return result; /* this implementation doesn't use custom stream info */ - } - } - else - { - userInputChannels = 0; - inputSampleFormat = paInt16; /* Suppress 'uninitialised var' warnings. */ - } - - if( outputParameters ) - { - userOutputChannels = outputParameters->channelCount; - outputSampleFormat = outputParameters->sampleFormat; - - /* unless alternate device specification is supported, reject the use of - paUseHostApiSpecificDeviceSpecification */ - - if( outputParameters->device == paUseHostApiSpecificDeviceSpecification ) - { - PaWinWDM_SetLastErrorInfo(paInvalidDevice, "paUseHostApiSpecificDeviceSpecification(out) not supported"); - return paInvalidDevice; - } - - /* check that output device can support stream->userInputChannels */ - if( userOutputChannels > hostApi->deviceInfos[ outputParameters->device ]->maxOutputChannels ) - { - PaWinWDM_SetLastErrorInfo(paInvalidChannelCount, "Invalid output channel count"); - return paInvalidChannelCount; - } - - /* validate outputStreamInfo */ - result = ValidateSpecificStreamParameters( outputParameters, outputParameters->hostApiSpecificStreamInfo, 0 ); - if (result != paNoError) - { - PaWinWDM_SetLastErrorInfo(result, "Host API stream info not supported (out)"); - return result; /* this implementation doesn't use custom stream info */ - } - } - else - { - userOutputChannels = 0; - outputSampleFormat = paInt16; /* Suppress 'uninitialized var' warnings. */ - } - - /* validate platform specific flags */ - if( (streamFlags & paPlatformSpecificFlags) != 0 ) - { - PaWinWDM_SetLastErrorInfo(paInvalidFlag, "Invalid flag supplied"); - return paInvalidFlag; /* unexpected platform specific flag */ - } - - stream = (PaWinWdmStream*)PaUtil_AllocateMemory( sizeof(PaWinWdmStream) ); - if( !stream ) - { - result = paInsufficientMemory; - goto error; - } - - /* Create allocation group */ - stream->allocGroup = PaUtil_CreateAllocationGroup(); - if( !stream->allocGroup ) - { - result = paInsufficientMemory; - goto error; - } - - /* Zero the stream object */ - /* memset((void*)stream,0,sizeof(PaWinWdmStream)); */ - - if( streamCallback ) - { - PaUtil_InitializeStreamRepresentation( &stream->streamRepresentation, - &wdmHostApi->callbackStreamInterface, streamCallback, userData ); - } - else - { - /* PaUtil_InitializeStreamRepresentation( &stream->streamRepresentation, - &wdmHostApi->blockingStreamInterface, streamCallback, userData ); */ - - /* We don't support the blocking API yet */ - PA_DEBUG(("Blocking API not supported yet!\n")); - PaWinWDM_SetLastErrorInfo(paUnanticipatedHostError, "Blocking API not supported yet"); - result = paUnanticipatedHostError; - goto error; - } - - PaUtil_InitializeCpuLoadMeasurer( &stream->cpuLoadMeasurer, sampleRate ); - - /* Instantiate the input pin if necessary */ - if(userInputChannels > 0) - { - PaWinWdmFilter* pFilter; - PaWinWdmDeviceInfo* pDeviceInfo; - PaWinWdmPin* pPin; - unsigned validBitsPerSample = 0; - PaWinWaveFormatChannelMask channelMask = PaWin_DefaultChannelMask( userInputChannels ); - - result = paSampleFormatNotSupported; - pDeviceInfo = (PaWinWdmDeviceInfo*)wdmHostApi->inheritedHostApiRep.deviceInfos[inputParameters->device]; - pFilter = pDeviceInfo->filter; - pPin = pFilter->pins[pDeviceInfo->pin]; - - stream->userInputChannels = userInputChannels; - - hostInputSampleFormat = PaUtil_SelectClosestAvailableFormat( pPin->formats, inputSampleFormat ); - if (hostInputSampleFormat == paSampleFormatNotSupported) - { - result = paUnanticipatedHostError; - PaWinWDM_SetLastErrorInfo(result, "PU_SCAF(%X,%X) failed (input)", pPin->formats, inputSampleFormat); - goto error; - } - else if (pFilter->devInfo.streamingType == Type_kWaveRT && hostInputSampleFormat == paInt24) - { - /* For WaveRT, we choose 32 bit format instead of paInt24, since we MIGHT need to align buffer on a - 128 byte boundary (see PinGetBuffer) */ - hostInputSampleFormat = paInt32; - /* But we'll tell the driver that it's 24 bit in 32 bit container */ - validBitsPerSample = 24; - } - - while (hostInputSampleFormat <= paUInt8) - { - unsigned channelsToProbe = stream->userInputChannels; - /* Some or all KS devices can only handle the exact number of channels - * they specify. But PortAudio clients expect to be able to - * at least specify mono I/O on a multi-channel device - * If this is the case, then we will do the channel mapping internally - * The following loop tests this case - **/ - while (1) - { - PaWin_InitializeWaveFormatExtensible((PaWinWaveFormat*)&wfx, - channelsToProbe, - hostInputSampleFormat, - PaWin_SampleFormatToLinearWaveFormatTag(hostInputSampleFormat), - sampleRate, - channelMask ); - stream->capture.bytesPerFrame = wfx.Format.nBlockAlign; - if (validBitsPerSample != 0) - { - wfx.Samples.wValidBitsPerSample = validBitsPerSample; - } - stream->capture.pPin = FilterCreatePin(pFilter, pPin->pinId, (WAVEFORMATEX*)&wfx, &result); - stream->deviceInputChannels = channelsToProbe; - - if( result != paNoError && result != paDeviceUnavailable ) - { - /* Try a WAVE_FORMAT_PCM instead */ - PaWin_InitializeWaveFormatEx((PaWinWaveFormat*)&wfx, - channelsToProbe, - hostInputSampleFormat, - PaWin_SampleFormatToLinearWaveFormatTag(hostInputSampleFormat), - sampleRate); - if (validBitsPerSample != 0) - { - wfx.Samples.wValidBitsPerSample = validBitsPerSample; - } - stream->capture.pPin = FilterCreatePin(pFilter, pPin->pinId, (const WAVEFORMATEX*)&wfx, &result); - } - - if (result == paDeviceUnavailable) goto occupied; - - if (result == paNoError) - { - /* We're done */ - break; - } - - if (channelsToProbe < (unsigned)pPin->maxChannels) - { - /* Go to next multiple of 2 */ - channelsToProbe = min((((channelsToProbe>>1)+1)<<1), (unsigned)pPin->maxChannels); - continue; - } - - break; - } - - if (result == paNoError) - { - /* We're done */ - break; - } - - /* Go to next format in line with lower resolution */ - hostInputSampleFormat <<= 1; - } - - if(stream->capture.pPin == NULL) - { - PaWinWDM_SetLastErrorInfo(result, "Failed to create capture pin: sr=%u,ch=%u,bits=%u,align=%u", - wfx.Format.nSamplesPerSec, wfx.Format.nChannels, wfx.Format.wBitsPerSample, wfx.Format.nBlockAlign); - goto error; - } - - /* Select correct mux input on MUX node of topology filter */ - if (pDeviceInfo->muxPosition >= 0) - { - assert(pPin->parentFilter->topologyFilter != NULL); - - result = FilterUse(pPin->parentFilter->topologyFilter); - if (result != paNoError) - { - PaWinWDM_SetLastErrorInfo(result, "Failed to open topology filter"); - goto error; - } - - result = WdmSetMuxNodeProperty(pPin->parentFilter->topologyFilter->handle, - pPin->inputs[pDeviceInfo->muxPosition]->muxNodeId, - pPin->inputs[pDeviceInfo->muxPosition]->muxPinId); - - FilterRelease(pPin->parentFilter->topologyFilter); - - if(result != paNoError) - { - PaWinWDM_SetLastErrorInfo(result, "Failed to set topology mux node"); - goto error; - } - } - - stream->capture.bytesPerSample = stream->capture.bytesPerFrame / stream->deviceInputChannels; - stream->capture.pPin->frameSize /= stream->capture.bytesPerFrame; - PA_DEBUG(("Capture pin frames: %d\n",stream->capture.pPin->frameSize)); - } - else - { - hostInputSampleFormat = (PaSampleFormat)0; /* Avoid uninitialized variable warning */ - - stream->capture.pPin = NULL; - stream->capture.bytesPerFrame = 0; - } - - /* Instantiate the output pin if necessary */ - if(userOutputChannels > 0) - { - PaWinWdmFilter* pFilter; - PaWinWdmDeviceInfo* pDeviceInfo; - PaWinWdmPin* pPin; - PaWinWDMKSInfo* pInfo = (PaWinWDMKSInfo*)(outputParameters->hostApiSpecificStreamInfo); - unsigned validBitsPerSample = 0; - PaWinWaveFormatChannelMask channelMask = PaWin_DefaultChannelMask( userOutputChannels ); - if (pInfo && (pInfo->flags & paWinWDMKSUseGivenChannelMask)) - { - PA_DEBUG(("Using channelMask 0x%08X instead of default 0x%08X\n", - pInfo->channelMask, - channelMask)); - channelMask = pInfo->channelMask; - } - - result = paSampleFormatNotSupported; - pDeviceInfo = (PaWinWdmDeviceInfo*)wdmHostApi->inheritedHostApiRep.deviceInfos[outputParameters->device]; - pFilter = pDeviceInfo->filter; - pPin = pFilter->pins[pDeviceInfo->pin]; - - stream->userOutputChannels = userOutputChannels; - - hostOutputSampleFormat = PaUtil_SelectClosestAvailableFormat( pPin->formats, outputSampleFormat ); - if (hostOutputSampleFormat == paSampleFormatNotSupported) - { - result = paUnanticipatedHostError; - PaWinWDM_SetLastErrorInfo(result, "PU_SCAF(%X,%X) failed (output)", pPin->formats, hostOutputSampleFormat); - goto error; - } - else if (pFilter->devInfo.streamingType == Type_kWaveRT && hostOutputSampleFormat == paInt24) - { - /* For WaveRT, we choose 32 bit format instead of paInt24, since we MIGHT need to align buffer on a - 128 byte boundary (see PinGetBuffer) */ - hostOutputSampleFormat = paInt32; - /* But we'll tell the driver that it's 24 bit in 32 bit container */ - validBitsPerSample = 24; - } - - while (hostOutputSampleFormat <= paUInt8) - { - unsigned channelsToProbe = stream->userOutputChannels; - /* Some or all KS devices can only handle the exact number of channels - * they specify. But PortAudio clients expect to be able to - * at least specify mono I/O on a multi-channel device - * If this is the case, then we will do the channel mapping internally - * The following loop tests this case - **/ - while (1) - { - PaWin_InitializeWaveFormatExtensible((PaWinWaveFormat*)&wfx, - channelsToProbe, - hostOutputSampleFormat, - PaWin_SampleFormatToLinearWaveFormatTag(hostOutputSampleFormat), - sampleRate, - channelMask ); - stream->render.bytesPerFrame = wfx.Format.nBlockAlign; - if (validBitsPerSample != 0) - { - wfx.Samples.wValidBitsPerSample = validBitsPerSample; - } - stream->render.pPin = FilterCreatePin(pFilter, pPin->pinId, (WAVEFORMATEX*)&wfx, &result); - stream->deviceOutputChannels = channelsToProbe; - - if( result != paNoError && result != paDeviceUnavailable ) - { - PaWin_InitializeWaveFormatEx((PaWinWaveFormat*)&wfx, - channelsToProbe, - hostOutputSampleFormat, - PaWin_SampleFormatToLinearWaveFormatTag(hostOutputSampleFormat), - sampleRate); - if (validBitsPerSample != 0) - { - wfx.Samples.wValidBitsPerSample = validBitsPerSample; - } - stream->render.pPin = FilterCreatePin(pFilter, pPin->pinId, (const WAVEFORMATEX*)&wfx, &result); - } - - if (result == paDeviceUnavailable) goto occupied; - - if (result == paNoError) - { - /* We're done */ - break; - } - - if (channelsToProbe < (unsigned)pPin->maxChannels) - { - /* Go to next multiple of 2 */ - channelsToProbe = min((((channelsToProbe>>1)+1)<<1), (unsigned)pPin->maxChannels); - continue; - } - - break; - }; - - if (result == paNoError) - { - /* We're done */ - break; - } - - /* Go to next format in line with lower resolution */ - hostOutputSampleFormat <<= 1; - } - - if(stream->render.pPin == NULL) - { - PaWinWDM_SetLastErrorInfo(result, "Failed to create render pin: sr=%u,ch=%u,bits=%u,align=%u", - wfx.Format.nSamplesPerSec, wfx.Format.nChannels, wfx.Format.wBitsPerSample, wfx.Format.nBlockAlign); - goto error; - } - - stream->render.bytesPerSample = stream->render.bytesPerFrame / stream->deviceOutputChannels; - stream->render.pPin->frameSize /= stream->render.bytesPerFrame; - PA_DEBUG(("Render pin frames: %d\n",stream->render.pPin->frameSize)); - } - else - { - hostOutputSampleFormat = (PaSampleFormat)0; /* Avoid uninitialized variable warning */ - - stream->render.pPin = NULL; - stream->render.bytesPerFrame = 0; - } - - /* Calculate the framesPerHostXxxxBuffer size based upon the suggested latency values */ - /* Record the buffer length */ - if(inputParameters) - { - /* Calculate the frames from the user's value - add a bit to round up */ - stream->capture.framesPerBuffer = (unsigned long)((inputParameters->suggestedLatency*sampleRate)+0.0001); - if(stream->capture.framesPerBuffer > (unsigned long)sampleRate) - { /* Upper limit is 1 second */ - stream->capture.framesPerBuffer = (unsigned long)sampleRate; - } - else if(stream->capture.framesPerBuffer < stream->capture.pPin->frameSize) - { - stream->capture.framesPerBuffer = stream->capture.pPin->frameSize; - } - PA_DEBUG(("Input frames chosen:%ld\n",stream->capture.framesPerBuffer)); - - /* Setup number of packets to use */ - stream->capture.noOfPackets = 2; - - if (inputParameters->hostApiSpecificStreamInfo) - { - PaWinWDMKSInfo* pInfo = (PaWinWDMKSInfo*)inputParameters->hostApiSpecificStreamInfo; - - if (stream->capture.pPin->parentFilter->devInfo.streamingType == Type_kWaveCyclic && - pInfo->noOfPackets != 0) - { - stream->capture.noOfPackets = pInfo->noOfPackets; - } - } - } - - if(outputParameters) - { - /* Calculate the frames from the user's value - add a bit to round up */ - stream->render.framesPerBuffer = (unsigned long)((outputParameters->suggestedLatency*sampleRate)+0.0001); - if(stream->render.framesPerBuffer > (unsigned long)sampleRate) - { /* Upper limit is 1 second */ - stream->render.framesPerBuffer = (unsigned long)sampleRate; - } - else if(stream->render.framesPerBuffer < stream->render.pPin->frameSize) - { - stream->render.framesPerBuffer = stream->render.pPin->frameSize; - } - PA_DEBUG(("Output frames chosen:%ld\n",stream->render.framesPerBuffer)); - - /* Setup number of packets to use */ - stream->render.noOfPackets = 2; - - if (outputParameters->hostApiSpecificStreamInfo) - { - PaWinWDMKSInfo* pInfo = (PaWinWDMKSInfo*)outputParameters->hostApiSpecificStreamInfo; - - if (stream->render.pPin->parentFilter->devInfo.streamingType == Type_kWaveCyclic && - pInfo->noOfPackets != 0) - { - stream->render.noOfPackets = pInfo->noOfPackets; - } - } - } - - /* Host buffer size is bound to the largest of the input and output frame sizes */ - result = PaUtil_InitializeBufferProcessor( &stream->bufferProcessor, - stream->userInputChannels, inputSampleFormat, hostInputSampleFormat, - stream->userOutputChannels, outputSampleFormat, hostOutputSampleFormat, - sampleRate, streamFlags, framesPerUserBuffer, - max(stream->capture.framesPerBuffer, stream->render.framesPerBuffer), - paUtilBoundedHostBufferSize, - streamCallback, userData ); - if( result != paNoError ) - { - PaWinWDM_SetLastErrorInfo(result, "PaUtil_InitializeBufferProcessor failed: ich=%u, isf=%u, hisf=%u, och=%u, osf=%u, hosf=%u, sr=%lf, flags=0x%X, fpub=%u, fphb=%u", - stream->userInputChannels, inputSampleFormat, hostInputSampleFormat, - stream->userOutputChannels, outputSampleFormat, hostOutputSampleFormat, - sampleRate, streamFlags, framesPerUserBuffer, - max(stream->capture.framesPerBuffer, stream->render.framesPerBuffer)); - goto error; - } - - /* Allocate/get all the buffers for host I/O */ - if (stream->userInputChannels > 0) - { - stream->streamRepresentation.streamInfo.inputLatency = stream->capture.framesPerBuffer / sampleRate; - - switch (stream->capture.pPin->parentFilter->devInfo.streamingType) - { - case Type_kWaveCyclic: - { - unsigned size = stream->capture.noOfPackets * stream->capture.framesPerBuffer * stream->capture.bytesPerFrame; - /* Allocate input host buffer */ - stream->capture.hostBuffer = (char*)PaUtil_GroupAllocateMemory(stream->allocGroup, size); - PA_DEBUG(("Input buffer allocated (size = %u)\n", size)); - if( !stream->capture.hostBuffer ) - { - PA_DEBUG(("Cannot allocate host input buffer!\n")); - PaWinWDM_SetLastErrorInfo(paInsufficientMemory, "Failed to allocate input buffer"); - result = paInsufficientMemory; - goto error; - } - stream->capture.hostBufferSize = size; - PA_DEBUG(("Input buffer start = %p (size=%u)\n",stream->capture.hostBuffer, stream->capture.hostBufferSize)); - stream->capture.pPin->fnEventHandler = PaPinCaptureEventHandler_WaveCyclic; - stream->capture.pPin->fnSubmitHandler = PaPinCaptureSubmitHandler_WaveCyclic; - } - break; - case Type_kWaveRT: - { - const DWORD dwTotalSize = 2 * stream->capture.framesPerBuffer * stream->capture.bytesPerFrame; - DWORD dwRequestedSize = dwTotalSize; - BOOL bCallMemoryBarrier = FALSE; - ULONG hwFifoLatency = 0; - ULONG dummy; - result = PinGetBuffer(stream->capture.pPin, (void**)&stream->capture.hostBuffer, &dwRequestedSize, &bCallMemoryBarrier); - if (!result) - { - PA_DEBUG(("Input buffer start = %p, size = %u\n", stream->capture.hostBuffer, dwRequestedSize)); - if (dwRequestedSize != dwTotalSize) - { - PA_DEBUG(("Buffer length changed by driver from %u to %u !\n", dwTotalSize, dwRequestedSize)); - /* Recalculate to what the driver has given us */ - stream->capture.framesPerBuffer = dwRequestedSize / (2 * stream->capture.bytesPerFrame); - } - stream->capture.hostBufferSize = dwRequestedSize; - - if (stream->capture.pPin->pinKsSubType == SubType_kPolled) - { - stream->capture.pPin->fnEventHandler = PaPinCaptureEventHandler_WaveRTPolled; - stream->capture.pPin->fnSubmitHandler = PaPinCaptureSubmitHandler_WaveRTPolled; - } - else - { - stream->capture.pPin->fnEventHandler = PaPinCaptureEventHandler_WaveRTEvent; - stream->capture.pPin->fnSubmitHandler = PaPinCaptureSubmitHandler_WaveRTEvent; - } - - stream->capture.pPin->fnMemBarrier = bCallMemoryBarrier ? MemoryBarrierRead : MemoryBarrierDummy; - } - else - { - PA_DEBUG(("Failed to get input buffer (WaveRT)\n")); - PaWinWDM_SetLastErrorInfo(paUnanticipatedHostError, "Failed to get input buffer (WaveRT)"); - result = paUnanticipatedHostError; - goto error; - } - - /* Get latency */ - result = PinGetHwLatency(stream->capture.pPin, &hwFifoLatency, &dummy, &dummy); - if (result == paNoError) - { - stream->capture.pPin->hwLatency = hwFifoLatency; - - /* Add HW latency into total input latency */ - stream->streamRepresentation.streamInfo.inputLatency += ((hwFifoLatency / stream->capture.bytesPerFrame) / sampleRate); - } - else - { - PA_DEBUG(("Failed to get size of FIFO hardware buffer (is set to zero)\n")); - stream->capture.pPin->hwLatency = 0; - } - } - break; - default: - /* Undefined wave type!! */ - assert(0); - result = paInternalError; - PaWinWDM_SetLastErrorInfo(result, "Wave type %u ??", stream->capture.pPin->parentFilter->devInfo.streamingType); - goto error; - } - } - else - { - stream->capture.hostBuffer = 0; - } - - if (stream->userOutputChannels > 0) - { - stream->streamRepresentation.streamInfo.outputLatency = stream->render.framesPerBuffer / sampleRate; - - switch (stream->render.pPin->parentFilter->devInfo.streamingType) - { - case Type_kWaveCyclic: - { - unsigned size = stream->render.noOfPackets * stream->render.framesPerBuffer * stream->render.bytesPerFrame; - /* Allocate output device buffer */ - stream->render.hostBuffer = (char*)PaUtil_GroupAllocateMemory(stream->allocGroup, size); - PA_DEBUG(("Output buffer allocated (size = %u)\n", size)); - if( !stream->render.hostBuffer ) - { - PA_DEBUG(("Cannot allocate host output buffer!\n")); - PaWinWDM_SetLastErrorInfo(paInsufficientMemory, "Failed to allocate output buffer"); - result = paInsufficientMemory; - goto error; - } - stream->render.hostBufferSize = size; - PA_DEBUG(("Output buffer start = %p (size=%u)\n",stream->render.hostBuffer, stream->render.hostBufferSize)); - - stream->render.pPin->fnEventHandler = PaPinRenderEventHandler_WaveCyclic; - stream->render.pPin->fnSubmitHandler = PaPinRenderSubmitHandler_WaveCyclic; - } - break; - case Type_kWaveRT: - { - const DWORD dwTotalSize = 2 * stream->render.framesPerBuffer * stream->render.bytesPerFrame; - DWORD dwRequestedSize = dwTotalSize; - BOOL bCallMemoryBarrier = FALSE; - ULONG hwFifoLatency = 0; - ULONG dummy; - result = PinGetBuffer(stream->render.pPin, (void**)&stream->render.hostBuffer, &dwRequestedSize, &bCallMemoryBarrier); - if (!result) - { - PA_DEBUG(("Output buffer start = %p, size = %u, membarrier = %u\n", stream->render.hostBuffer, dwRequestedSize, bCallMemoryBarrier)); - if (dwRequestedSize != dwTotalSize) - { - PA_DEBUG(("Buffer length changed by driver from %u to %u !\n", dwTotalSize, dwRequestedSize)); - /* Recalculate to what the driver has given us */ - stream->render.framesPerBuffer = dwRequestedSize / (2 * stream->render.bytesPerFrame); - } - stream->render.hostBufferSize = dwRequestedSize; - - if (stream->render.pPin->pinKsSubType == SubType_kPolled) - { - stream->render.pPin->fnEventHandler = PaPinRenderEventHandler_WaveRTPolled; - stream->render.pPin->fnSubmitHandler = PaPinRenderSubmitHandler_WaveRTPolled; - } - else - { - stream->render.pPin->fnEventHandler = PaPinRenderEventHandler_WaveRTEvent; - stream->render.pPin->fnSubmitHandler = PaPinRenderSubmitHandler_WaveRTEvent; - } - - stream->render.pPin->fnMemBarrier = bCallMemoryBarrier ? MemoryBarrierWrite : MemoryBarrierDummy; - } - else - { - PA_DEBUG(("Failed to get output buffer (with notification)\n")); - PaWinWDM_SetLastErrorInfo(paUnanticipatedHostError, "Failed to get output buffer (with notification)"); - result = paUnanticipatedHostError; - goto error; - } - - /* Get latency */ - result = PinGetHwLatency(stream->render.pPin, &hwFifoLatency, &dummy, &dummy); - if (result == paNoError) - { - stream->render.pPin->hwLatency = hwFifoLatency; - - /* Add HW latency into total output latency */ - stream->streamRepresentation.streamInfo.outputLatency += ((hwFifoLatency / stream->render.bytesPerFrame) / sampleRate); - } - else - { - PA_DEBUG(("Failed to get size of FIFO hardware buffer (is set to zero)\n")); - stream->render.pPin->hwLatency = 0; - } - } - break; - default: - /* Undefined wave type!! */ - assert(0); - result = paInternalError; - PaWinWDM_SetLastErrorInfo(result, "Wave type %u ??", stream->capture.pPin->parentFilter->devInfo.streamingType); - goto error; - } - } - else - { - stream->render.hostBuffer = 0; - } - - stream->streamRepresentation.streamInfo.sampleRate = sampleRate; - - PA_DEBUG(("BytesPerInputFrame = %d\n",stream->capture.bytesPerFrame)); - PA_DEBUG(("BytesPerOutputFrame = %d\n",stream->render.bytesPerFrame)); - - /* memset(stream->hostBuffer,0,size); */ - - /* Abort */ - stream->eventAbort = CreateEvent(NULL, TRUE, FALSE, NULL); - if (stream->eventAbort == 0) - { - result = paInsufficientMemory; - goto error; - } - stream->eventStreamStart[0] = CreateEvent(NULL, TRUE, FALSE, NULL); - if (stream->eventStreamStart[0] == 0) - { - result = paInsufficientMemory; - goto error; - } - stream->eventStreamStart[1] = CreateEvent(NULL, TRUE, FALSE, NULL); - if (stream->eventStreamStart[1] == 0) - { - result = paInsufficientMemory; - goto error; - } - - if(stream->userInputChannels > 0) - { - const unsigned bufferSizeInBytes = stream->capture.framesPerBuffer * stream->capture.bytesPerFrame; - const unsigned ringBufferFrameSize = NextPowerOf2( 1024 + 2 * max(stream->capture.framesPerBuffer, stream->render.framesPerBuffer) ); - - stream->capture.events = (HANDLE*)PaUtil_GroupAllocateMemory(stream->allocGroup, stream->capture.noOfPackets * sizeof(HANDLE)); - if (stream->capture.events == NULL) - { - result = paInsufficientMemory; - goto error; - } - - stream->capture.packets = (DATAPACKET*)PaUtil_GroupAllocateMemory(stream->allocGroup, stream->capture.noOfPackets * sizeof(DATAPACKET)); - if (stream->capture.packets == NULL) - { - result = paInsufficientMemory; - goto error; - } - - switch(stream->capture.pPin->parentFilter->devInfo.streamingType) - { - case Type_kWaveCyclic: - { - /* WaveCyclic case */ - unsigned i; - for (i = 0; i < stream->capture.noOfPackets; ++i) - { - /* Set up the packets */ - DATAPACKET *p = stream->capture.packets + i; - - /* Record event */ - stream->capture.events[i] = CreateEvent(NULL, TRUE, FALSE, NULL); - - p->Signal.hEvent = stream->capture.events[i]; - p->Header.Data = stream->capture.hostBuffer + (i*bufferSizeInBytes); - p->Header.FrameExtent = bufferSizeInBytes; - p->Header.DataUsed = 0; - p->Header.Size = sizeof(p->Header); - p->Header.PresentationTime.Numerator = 1; - p->Header.PresentationTime.Denominator = 1; - } - } - break; - case Type_kWaveRT: - { - /* Set up the "packets" */ - DATAPACKET *p = stream->capture.packets + 0; - - /* Record event: WaveRT has a single event for 2 notification per buffer */ - stream->capture.events[0] = CreateEvent(NULL, FALSE, FALSE, NULL); - - p->Header.Data = stream->capture.hostBuffer; - p->Header.FrameExtent = bufferSizeInBytes; - p->Header.DataUsed = 0; - p->Header.Size = sizeof(p->Header); - p->Header.PresentationTime.Numerator = 1; - p->Header.PresentationTime.Denominator = 1; - - ++p; - p->Header.Data = stream->capture.hostBuffer + bufferSizeInBytes; - p->Header.FrameExtent = bufferSizeInBytes; - p->Header.DataUsed = 0; - p->Header.Size = sizeof(p->Header); - p->Header.PresentationTime.Numerator = 1; - p->Header.PresentationTime.Denominator = 1; - - if (stream->capture.pPin->pinKsSubType == SubType_kNotification) - { - result = PinRegisterNotificationHandle(stream->capture.pPin, stream->capture.events[0]); - - if (result != paNoError) - { - PA_DEBUG(("Failed to register capture notification handle\n")); - PaWinWDM_SetLastErrorInfo(paUnanticipatedHostError, "Failed to register capture notification handle"); - result = paUnanticipatedHostError; - goto error; - } - } - - result = PinRegisterPositionRegister(stream->capture.pPin); - - if (result != paNoError) - { - unsigned long pos = 0xdeadc0de; - PA_DEBUG(("Failed to register capture position register, using PinGetAudioPositionViaIOCTLWrite\n")); - stream->capture.pPin->fnAudioPosition = PinGetAudioPositionViaIOCTLWrite; - /* Test position function */ - result = (stream->capture.pPin->fnAudioPosition)(stream->capture.pPin, &pos); - if (result != paNoError || pos != 0x0) - { - PA_DEBUG(("Failed to read capture position register (IOCTL)\n")); - PaWinWDM_SetLastErrorInfo(paUnanticipatedHostError, "Failed to read capture position register (IOCTL)"); - result = paUnanticipatedHostError; - goto error; - } - } - else - { - stream->capture.pPin->fnAudioPosition = PinGetAudioPositionMemoryMapped; - } - } - break; - default: - /* Undefined wave type!! */ - assert(0); - result = paInternalError; - PaWinWDM_SetLastErrorInfo(result, "Wave type %u ??", stream->capture.pPin->parentFilter->devInfo.streamingType); - goto error; - } - - /* Setup the input ring buffer here */ - stream->ringBufferData = (char*)PaUtil_GroupAllocateMemory(stream->allocGroup, ringBufferFrameSize * stream->capture.bytesPerFrame); - if (stream->ringBufferData == NULL) - { - result = paInsufficientMemory; - goto error; - } - PaUtil_InitializeRingBuffer(&stream->ringBuffer, stream->capture.bytesPerFrame, ringBufferFrameSize, stream->ringBufferData); - } - if(stream->userOutputChannels > 0) - { - const unsigned bufferSizeInBytes = stream->render.framesPerBuffer * stream->render.bytesPerFrame; - - stream->render.events = (HANDLE*)PaUtil_GroupAllocateMemory(stream->allocGroup, stream->render.noOfPackets * sizeof(HANDLE)); - if (stream->render.events == NULL) - { - result = paInsufficientMemory; - goto error; - } - - stream->render.packets = (DATAPACKET*)PaUtil_GroupAllocateMemory(stream->allocGroup, stream->render.noOfPackets * sizeof(DATAPACKET)); - if (stream->render.packets == NULL) - { - result = paInsufficientMemory; - goto error; - } - - switch(stream->render.pPin->parentFilter->devInfo.streamingType) - { - case Type_kWaveCyclic: - { - /* WaveCyclic case */ - unsigned i; - for (i = 0; i < stream->render.noOfPackets; ++i) - { - /* Set up the packets */ - DATAPACKET *p = stream->render.packets + i; - - /* Playback event */ - stream->render.events[i] = CreateEvent(NULL, TRUE, FALSE, NULL); - - /* In this case, we just use the packets as ptr to the device buffer */ - p->Signal.hEvent = stream->render.events[i]; - p->Header.Data = stream->render.hostBuffer + (i*bufferSizeInBytes); - p->Header.FrameExtent = bufferSizeInBytes; - p->Header.DataUsed = bufferSizeInBytes; - p->Header.Size = sizeof(p->Header); - p->Header.PresentationTime.Numerator = 1; - p->Header.PresentationTime.Denominator = 1; - } - } - break; - case Type_kWaveRT: - { - /* WaveRT case */ - - /* Set up the "packets" */ - DATAPACKET *p = stream->render.packets; - - /* The only playback event */ - stream->render.events[0] = CreateEvent(NULL, FALSE, FALSE, NULL); - - /* In this case, we just use the packets as ptr to the device buffer */ - p->Header.Data = stream->render.hostBuffer; - p->Header.FrameExtent = stream->render.framesPerBuffer*stream->render.bytesPerFrame; - p->Header.DataUsed = stream->render.framesPerBuffer*stream->render.bytesPerFrame; - p->Header.Size = sizeof(p->Header); - p->Header.PresentationTime.Numerator = 1; - p->Header.PresentationTime.Denominator = 1; - - ++p; - p->Header.Data = stream->render.hostBuffer + stream->render.framesPerBuffer*stream->render.bytesPerFrame; - p->Header.FrameExtent = stream->render.framesPerBuffer*stream->render.bytesPerFrame; - p->Header.DataUsed = stream->render.framesPerBuffer*stream->render.bytesPerFrame; - p->Header.Size = sizeof(p->Header); - p->Header.PresentationTime.Numerator = 1; - p->Header.PresentationTime.Denominator = 1; - - if (stream->render.pPin->pinKsSubType == SubType_kNotification) - { - result = PinRegisterNotificationHandle(stream->render.pPin, stream->render.events[0]); - - if (result != paNoError) - { - PA_DEBUG(("Failed to register rendering notification handle\n")); - PaWinWDM_SetLastErrorInfo(paUnanticipatedHostError, "Failed to register rendering notification handle"); - result = paUnanticipatedHostError; - goto error; - } - } - - result = PinRegisterPositionRegister(stream->render.pPin); - - if (result != paNoError) - { - unsigned long pos = 0xdeadc0de; - PA_DEBUG(("Failed to register rendering position register, using PinGetAudioPositionViaIOCTLRead\n")); - stream->render.pPin->fnAudioPosition = PinGetAudioPositionViaIOCTLRead; - /* Test position function */ - result = (stream->render.pPin->fnAudioPosition)(stream->render.pPin, &pos); - if (result != paNoError || pos != 0x0) - { - PA_DEBUG(("Failed to read render position register (IOCTL)\n")); - PaWinWDM_SetLastErrorInfo(paUnanticipatedHostError, "Failed to read render position register (IOCTL)"); - result = paUnanticipatedHostError; - goto error; - } - } - else - { - stream->render.pPin->fnAudioPosition = PinGetAudioPositionMemoryMapped; - } - } - break; - default: - /* Undefined wave type!! */ - assert(0); - result = paInternalError; - PaWinWDM_SetLastErrorInfo(result, "Wave type %u ??", stream->capture.pPin->parentFilter->devInfo.streamingType); - goto error; - } - } - - stream->streamStarted = 0; - stream->streamActive = 0; - stream->streamStop = 0; - stream->streamAbort = 0; - stream->streamFlags = streamFlags; - stream->oldProcessPriority = REALTIME_PRIORITY_CLASS; - - /* Increase ref count on filters in use, so that a CommitDeviceInfos won't delete them */ - if (stream->capture.pPin != 0) - { - FilterAddRef(stream->capture.pPin->parentFilter); - } - if (stream->render.pPin != 0) - { - FilterAddRef(stream->render.pPin->parentFilter); - } - - /* Ok, now update our host API specific stream info */ - if (stream->userInputChannels) - { - PaWinWdmDeviceInfo *pDeviceInfo = (PaWinWdmDeviceInfo*)wdmHostApi->inheritedHostApiRep.deviceInfos[inputParameters->device]; - - stream->hostApiStreamInfo.input.device = Pa_HostApiDeviceIndexToDeviceIndex(Pa_HostApiTypeIdToHostApiIndex(paWDMKS), inputParameters->device); - stream->hostApiStreamInfo.input.channels = stream->deviceInputChannels; - stream->hostApiStreamInfo.input.muxNodeId = -1; - if (stream->capture.pPin->inputs) - { - stream->hostApiStreamInfo.input.muxNodeId = stream->capture.pPin->inputs[pDeviceInfo->muxPosition]->muxNodeId; - } - stream->hostApiStreamInfo.input.endpointPinId = pDeviceInfo->endpointPinId; - stream->hostApiStreamInfo.input.framesPerHostBuffer = stream->capture.framesPerBuffer; - stream->hostApiStreamInfo.input.streamingSubType = stream->capture.pPin->pinKsSubType; - } - else - { - stream->hostApiStreamInfo.input.device = paNoDevice; - } - if (stream->userOutputChannels) - { - stream->hostApiStreamInfo.output.device = Pa_HostApiDeviceIndexToDeviceIndex(Pa_HostApiTypeIdToHostApiIndex(paWDMKS), outputParameters->device); - stream->hostApiStreamInfo.output.channels = stream->deviceOutputChannels; - stream->hostApiStreamInfo.output.framesPerHostBuffer = stream->render.framesPerBuffer; - stream->hostApiStreamInfo.output.endpointPinId = stream->render.pPin->endpointPinId; - stream->hostApiStreamInfo.output.streamingSubType = stream->render.pPin->pinKsSubType; - } - else - { - stream->hostApiStreamInfo.output.device = paNoDevice; - } - /*stream->streamRepresentation.streamInfo.hostApiTypeId = paWDMKS; - stream->streamRepresentation.streamInfo.hostApiSpecificStreamInfo = &stream->hostApiStreamInfo;*/ - stream->streamRepresentation.streamInfo.structVersion = 2; - - *s = (PaStream*)stream; - - PA_LOGL_; - return result; - -occupied: - /* Ok, someone else is hogging the pin, bail out */ - assert (result == paDeviceUnavailable); - PaWinWDM_SetLastErrorInfo(result, "Device is occupied"); - -error: - PaUtil_TerminateBufferProcessor( &stream->bufferProcessor ); - - CloseStreamEvents(stream); - - if (stream->allocGroup) - { - PaUtil_FreeAllAllocations(stream->allocGroup); - PaUtil_DestroyAllocationGroup(stream->allocGroup); - stream->allocGroup = 0; - } - - if(stream->render.pPin) - PinClose(stream->render.pPin); - if(stream->capture.pPin) - PinClose(stream->capture.pPin); - - PaUtil_FreeMemory( stream ); - - PA_LOGL_; - return result; -} - -/* -When CloseStream() is called, the multi-api layer ensures that -the stream has already been stopped or aborted. -*/ -static PaError CloseStream( PaStream* s ) -{ - PaError result = paNoError; - PaWinWdmStream *stream = (PaWinWdmStream*)s; - - PA_LOGE_; - - assert(!stream->streamStarted); - assert(!stream->streamActive); - - PaUtil_TerminateBufferProcessor( &stream->bufferProcessor ); - PaUtil_TerminateStreamRepresentation( &stream->streamRepresentation ); - - CloseStreamEvents(stream); - - if (stream->allocGroup) - { - PaUtil_FreeAllAllocations(stream->allocGroup); - PaUtil_DestroyAllocationGroup(stream->allocGroup); - stream->allocGroup = 0; - } - - if(stream->render.pPin) - { - PinClose(stream->render.pPin); - } - if(stream->capture.pPin) - { - PinClose(stream->capture.pPin); - } - - if (stream->render.pPin) - { - FilterFree(stream->render.pPin->parentFilter); - } - if (stream->capture.pPin) - { - FilterFree(stream->capture.pPin->parentFilter); - } - - PaUtil_FreeMemory( stream ); - - PA_LOGL_; - return result; -} - -/* -Write the supplied packet to the pin -Asynchronous -Should return paNoError on success -*/ -static PaError PinWrite(HANDLE h, DATAPACKET* p) -{ - PaError result = paNoError; - unsigned long cbReturned = 0; - BOOL fRes = DeviceIoControl(h, - IOCTL_KS_WRITE_STREAM, - NULL, - 0, - &p->Header, - p->Header.Size, - &cbReturned, - &p->Signal); - if (!fRes) - { - unsigned long error = GetLastError(); - if (error != ERROR_IO_PENDING) - { - result = paInternalError; - } - } - return result; -} - -/* -Read to the supplied packet from the pin -Asynchronous -Should return paNoError on success -*/ -static PaError PinRead(HANDLE h, DATAPACKET* p) -{ - PaError result = paNoError; - unsigned long cbReturned = 0; - BOOL fRes = DeviceIoControl(h, - IOCTL_KS_READ_STREAM, - NULL, - 0, - &p->Header, - p->Header.Size, - &cbReturned, - &p->Signal); - if (!fRes) - { - unsigned long error = GetLastError(); - if (error != ERROR_IO_PENDING) - { - result = paInternalError; - } - } - return result; -} - -/* -Copy the first interleaved channel of 16 bit data to the other channels -*/ -static void DuplicateFirstChannelInt16(void* buffer, int channels, int samples) -{ - unsigned short* data = (unsigned short*)buffer; - int channel; - unsigned short sourceSample; - while( samples-- ) - { - sourceSample = *data++; - channel = channels-1; - while( channel-- ) - { - *data++ = sourceSample; - } - } -} - -/* -Copy the first interleaved channel of 24 bit data to the other channels -*/ -static void DuplicateFirstChannelInt24(void* buffer, int channels, int samples) -{ - unsigned char* data = (unsigned char*)buffer; - int channel; - unsigned char sourceSample[3]; - while( samples-- ) - { - sourceSample[0] = data[0]; - sourceSample[1] = data[1]; - sourceSample[2] = data[2]; - data += 3; - channel = channels-1; - while( channel-- ) - { - data[0] = sourceSample[0]; - data[1] = sourceSample[1]; - data[2] = sourceSample[2]; - data += 3; - } - } -} - -/* -Copy the first interleaved channel of 32 bit data to the other channels -*/ -static void DuplicateFirstChannelInt32(void* buffer, int channels, int samples) -{ - unsigned long* data = (unsigned long*)buffer; - int channel; - unsigned long sourceSample; - while( samples-- ) - { - sourceSample = *data++; - channel = channels-1; - while( channel-- ) - { - *data++ = sourceSample; - } - } -} - -/* -Increase the priority of the calling thread to RT -*/ -static HANDLE BumpThreadPriority() -{ - HANDLE hThread = GetCurrentThread(); - DWORD dwTask = 0; - HANDLE hAVRT = NULL; - - /* If we have access to AVRT.DLL (Vista and later), use it */ - if (paWinWDMKSAvRtEntryPoints.AvSetMmThreadCharacteristics != NULL) - { - hAVRT = paWinWDMKSAvRtEntryPoints.AvSetMmThreadCharacteristics("Pro Audio", &dwTask); - if (hAVRT != NULL && hAVRT != INVALID_HANDLE_VALUE) - { - BOOL bret = paWinWDMKSAvRtEntryPoints.AvSetMmThreadPriority(hAVRT, PA_AVRT_PRIORITY_CRITICAL); - if (!bret) - { - PA_DEBUG(("Set mm thread prio to critical failed!\n")); - } - else - { - return hAVRT; - } - } - else - { - PA_DEBUG(("Set mm thread characteristic to 'Pro Audio' failed, reverting to SetThreadPriority\n")); - } - } - - /* For XP and earlier, or if AvSetMmThreadCharacteristics fails (MMCSS disabled ?) */ - if (timeBeginPeriod(1) != TIMERR_NOERROR) { - PA_DEBUG(("timeBeginPeriod(1) failed!\n")); - } - - if (!SetThreadPriority(hThread, THREAD_PRIORITY_TIME_CRITICAL)) { - PA_DEBUG(("SetThreadPriority failed!\n")); - } - - return hAVRT; -} - -/* -Decrease the priority of the calling thread to normal -*/ -static void DropThreadPriority(HANDLE hAVRT) -{ - HANDLE hThread = GetCurrentThread(); - - if (hAVRT != NULL) - { - paWinWDMKSAvRtEntryPoints.AvSetMmThreadPriority(hAVRT, PA_AVRT_PRIORITY_NORMAL); - paWinWDMKSAvRtEntryPoints.AvRevertMmThreadCharacteristics(hAVRT); - return; - } - - SetThreadPriority(hThread, THREAD_PRIORITY_NORMAL); - timeEndPeriod(1); -} - -static PaError PreparePinForStart(PaWinWdmPin* pin) -{ - PaError result; - result = PinSetState(pin, KSSTATE_ACQUIRE); - if (result != paNoError) - { - goto error; - } - result = PinSetState(pin, KSSTATE_PAUSE); - if (result != paNoError) - { - goto error; - } - return result; - -error: - PinSetState(pin, KSSTATE_STOP); - return result; -} - -static PaError PreparePinsForStart(PaProcessThreadInfo* pInfo) -{ - PaError result = paNoError; - /* Submit buffers */ - if (pInfo->stream->capture.pPin) - { - if ((result = PreparePinForStart(pInfo->stream->capture.pPin)) != paNoError) - { - goto error; - } - - if (pInfo->stream->capture.pPin->parentFilter->devInfo.streamingType == Type_kWaveCyclic) - { - unsigned i; - for(i=0; i < pInfo->stream->capture.noOfPackets; ++i) - { - if ((result = PinRead(pInfo->stream->capture.pPin->handle, pInfo->stream->capture.packets + i)) != paNoError) - { - goto error; - } - ++pInfo->pending; - } - } - else - { - pInfo->pending = 2; - } - } - - if(pInfo->stream->render.pPin) - { - if ((result = PreparePinForStart(pInfo->stream->render.pPin)) != paNoError) - { - goto error; - } - - pInfo->priming += pInfo->stream->render.noOfPackets; - ++pInfo->pending; - SetEvent(pInfo->stream->render.events[0]); - if (pInfo->stream->render.pPin->parentFilter->devInfo.streamingType == Type_kWaveCyclic) - { - unsigned i; - for(i=1; i < pInfo->stream->render.noOfPackets; ++i) - { - SetEvent(pInfo->stream->render.events[i]); - ++pInfo->pending; - } - } - } - -error: - PA_DEBUG(("PreparePinsForStart = %d\n", result)); - return result; -} - -static PaError StartPin(PaWinWdmPin* pin) -{ - return PinSetState(pin, KSSTATE_RUN); -} - -static PaError StartPins(PaProcessThreadInfo* pInfo) -{ - PaError result = paNoError; - /* Start the pins as synced as possible */ - if (pInfo->stream->capture.pPin) - { - result = StartPin(pInfo->stream->capture.pPin); - } - if(pInfo->stream->render.pPin) - { - result = StartPin(pInfo->stream->render.pPin); - } - PA_DEBUG(("StartPins = %d\n", result)); - return result; -} - - -static PaError StopPin(PaWinWdmPin* pin) -{ - PinSetState(pin, KSSTATE_PAUSE); - PinSetState(pin, KSSTATE_STOP); - return paNoError; -} - - -static PaError StopPins(PaProcessThreadInfo* pInfo) -{ - PaError result = paNoError; - if(pInfo->stream->render.pPin) - { - StopPin(pInfo->stream->render.pPin); - } - if(pInfo->stream->capture.pPin) - { - StopPin(pInfo->stream->capture.pPin); - } - return result; -} - -typedef void (*TSetInputFrameCount)(PaUtilBufferProcessor*, unsigned long); -typedef void (*TSetInputChannel)(PaUtilBufferProcessor*, unsigned int, void *, unsigned int); -static const TSetInputFrameCount fnSetInputFrameCount[2] = { PaUtil_SetInputFrameCount, PaUtil_Set2ndInputFrameCount }; -static const TSetInputChannel fnSetInputChannel[2] = { PaUtil_SetInputChannel, PaUtil_Set2ndInputChannel }; - -static PaError PaDoProcessing(PaProcessThreadInfo* pInfo) -{ - PaError result = paNoError; - int i, framesProcessed = 0, doChannelCopy = 0; - ring_buffer_size_t inputFramesAvailable = PaUtil_GetRingBufferReadAvailable(&pInfo->stream->ringBuffer); - - /* Do necessary buffer processing (which will invoke user callback if necessary) */ - if (pInfo->cbResult == paContinue && - (pInfo->renderHead != pInfo->renderTail || inputFramesAvailable)) - { - unsigned processFullDuplex = pInfo->stream->capture.pPin && pInfo->stream->render.pPin && (!pInfo->priming); - - PA_HP_TRACE((pInfo->stream->hLog, "DoProcessing: InputFrames=%u", inputFramesAvailable)); - - PaUtil_BeginCpuLoadMeasurement( &pInfo->stream->cpuLoadMeasurer ); - - pInfo->ti.currentTime = PaUtil_GetTime(); - - PaUtil_BeginBufferProcessing(&pInfo->stream->bufferProcessor, &pInfo->ti, pInfo->underover); - pInfo->underover = 0; /* Reset the (under|over)flow status */ - - if (pInfo->renderTail != pInfo->renderHead) - { - DATAPACKET* packet = pInfo->renderPackets[pInfo->renderTail & cPacketsArrayMask].packet; - - assert(packet != 0); - assert(packet->Header.Data != 0); - - PaUtil_SetOutputFrameCount(&pInfo->stream->bufferProcessor, pInfo->stream->render.framesPerBuffer); - - for(i=0;i<pInfo->stream->userOutputChannels;i++) - { - /* Only write the user output channels. Leave the rest blank */ - PaUtil_SetOutputChannel(&pInfo->stream->bufferProcessor, - i, - ((unsigned char*)(packet->Header.Data))+(i*pInfo->stream->render.bytesPerSample), - pInfo->stream->deviceOutputChannels); - } - - /* We will do a copy to the other channels after the data has been written */ - doChannelCopy = ( pInfo->stream->userOutputChannels == 1 ); - } - - if (inputFramesAvailable && (!pInfo->stream->userOutputChannels || inputFramesAvailable >= (int)pInfo->stream->render.framesPerBuffer)) - { - unsigned wrapCntr = 0; - void* data[2] = {0}; - ring_buffer_size_t size[2] = {0}; - - /* If full-duplex, we just extract output buffer number of frames */ - if (pInfo->stream->userOutputChannels) - { - inputFramesAvailable = min(inputFramesAvailable, (int)pInfo->stream->render.framesPerBuffer); - } - - inputFramesAvailable = PaUtil_GetRingBufferReadRegions(&pInfo->stream->ringBuffer, - inputFramesAvailable, - &data[0], - &size[0], - &data[1], - &size[1]); - - for (wrapCntr = 0; wrapCntr < 2; ++wrapCntr) - { - if (size[wrapCntr] == 0) - break; - - fnSetInputFrameCount[wrapCntr](&pInfo->stream->bufferProcessor, size[wrapCntr]); - for(i=0;i<pInfo->stream->userInputChannels;i++) - { - /* Only read as many channels as the user wants */ - fnSetInputChannel[wrapCntr](&pInfo->stream->bufferProcessor, - i, - ((unsigned char*)(data[wrapCntr]))+(i*pInfo->stream->capture.bytesPerSample), - pInfo->stream->deviceInputChannels); - } - } - } - else - { - /* We haven't consumed anything from the ring buffer... */ - inputFramesAvailable = 0; - /* If we have full-duplex, this is at startup, so mark no-input! */ - if (pInfo->stream->userOutputChannels>0 && pInfo->stream->userInputChannels>0) - { - PA_HP_TRACE((pInfo->stream->hLog, "Input startup, marking no input.")); - PaUtil_SetNoInput(&pInfo->stream->bufferProcessor); - } - } - - if (processFullDuplex) /* full duplex */ - { - /* Only call the EndBufferProcessing function when the total input frames == total output frames */ - const unsigned long totalInputFrameCount = pInfo->stream->bufferProcessor.hostInputFrameCount[0] + pInfo->stream->bufferProcessor.hostInputFrameCount[1]; - const unsigned long totalOutputFrameCount = pInfo->stream->bufferProcessor.hostOutputFrameCount[0] + pInfo->stream->bufferProcessor.hostOutputFrameCount[1]; - - if(totalInputFrameCount == totalOutputFrameCount && totalOutputFrameCount != 0) - { - framesProcessed = PaUtil_EndBufferProcessing(&pInfo->stream->bufferProcessor, &pInfo->cbResult); - } - else - { - framesProcessed = 0; - } - } - else - { - framesProcessed = PaUtil_EndBufferProcessing(&pInfo->stream->bufferProcessor, &pInfo->cbResult); - } - - PA_HP_TRACE((pInfo->stream->hLog, "Frames processed: %u %s", framesProcessed, (pInfo->priming ? "(priming)":""))); - - if( doChannelCopy ) - { - DATAPACKET* packet = pInfo->renderPackets[pInfo->renderTail & cPacketsArrayMask].packet; - /* Copy the first output channel to the other channels */ - switch (pInfo->stream->render.bytesPerSample) - { - case 2: - DuplicateFirstChannelInt16(packet->Header.Data, pInfo->stream->deviceOutputChannels, pInfo->stream->render.framesPerBuffer); - break; - case 3: - DuplicateFirstChannelInt24(packet->Header.Data, pInfo->stream->deviceOutputChannels, pInfo->stream->render.framesPerBuffer); - break; - case 4: - DuplicateFirstChannelInt32(packet->Header.Data, pInfo->stream->deviceOutputChannels, pInfo->stream->render.framesPerBuffer); - break; - default: - assert(0); /* Unsupported format! */ - break; - } - } - PaUtil_EndCpuLoadMeasurement( &pInfo->stream->cpuLoadMeasurer, framesProcessed ); - - if (inputFramesAvailable) - { - PaUtil_AdvanceRingBufferReadIndex(&pInfo->stream->ringBuffer, inputFramesAvailable); - } - - if (pInfo->renderTail != pInfo->renderHead) - { - if (!pInfo->stream->streamStop) - { - result = pInfo->stream->render.pPin->fnSubmitHandler(pInfo, pInfo->renderTail); - if (result != paNoError) - { - PA_HP_TRACE((pInfo->stream->hLog, "Capture submit handler failed with result %d", result)); - return result; - } - } - pInfo->renderTail++; - if (!pInfo->pinsStarted && pInfo->priming == 0) - { - /* We start the pins here to allow "prime time" */ - if ((result = StartPins(pInfo)) == paNoError) - { - PA_HP_TRACE((pInfo->stream->hLog, "Starting pins!")); - pInfo->pinsStarted = 1; - } - } - } - } - - return result; -} - -static VOID CALLBACK TimerAPCWaveRTPolledMode( - LPVOID lpArgToCompletionRoutine, - DWORD dwTimerLowValue, - DWORD dwTimerHighValue) -{ - HANDLE* pHandles = (HANDLE*)lpArgToCompletionRoutine; - if (pHandles[0]) SetEvent(pHandles[0]); - if (pHandles[1]) SetEvent(pHandles[1]); -} - -static DWORD GetCurrentTimeInMillisecs() -{ - return timeGetTime(); -} - -PA_THREAD_FUNC ProcessingThread(void* pParam) -{ - PaError result = paNoError; - HANDLE hAVRT = NULL; - HANDLE hTimer = NULL; - HANDLE *handleArray = NULL; - HANDLE timerEventHandles[2] = {0}; - unsigned noOfHandles = 0; - unsigned captureEvents = 0; - unsigned renderEvents = 0; - unsigned timerPeriod = 0; - DWORD timeStamp[2] = {0}; - - PaProcessThreadInfo info; - memset(&info, 0, sizeof(PaProcessThreadInfo)); - info.stream = (PaWinWdmStream*)pParam; - - info.stream->threadResult = paNoError; - - PA_LOGE_; - - info.ti.inputBufferAdcTime = 0.0; - info.ti.currentTime = 0.0; - info.ti.outputBufferDacTime = 0.0; - - PA_DEBUG(("In buffer len: %.3f ms\n",(2000*info.stream->capture.framesPerBuffer) / info.stream->streamRepresentation.streamInfo.sampleRate)); - PA_DEBUG(("Out buffer len: %.3f ms\n",(2000*info.stream->render.framesPerBuffer) / info.stream->streamRepresentation.streamInfo.sampleRate)); - info.timeout = (DWORD)max( - (2000*info.stream->render.framesPerBuffer/info.stream->streamRepresentation.streamInfo.sampleRate + 0.5), - (2000*info.stream->capture.framesPerBuffer/info.stream->streamRepresentation.streamInfo.sampleRate + 0.5)); - info.timeout = max(info.timeout*8, 100); - timerPeriod = info.timeout; - PA_DEBUG(("Timeout = %ld ms\n",info.timeout)); - - /* Allocate handle array */ - handleArray = (HANDLE*)PaUtil_AllocateMemory((info.stream->capture.noOfPackets + info.stream->render.noOfPackets + 1) * sizeof(HANDLE)); - - /* Setup handle array for WFMO */ - if (info.stream->capture.pPin != 0) - { - handleArray[noOfHandles++] = info.stream->capture.events[0]; - if (info.stream->capture.pPin->parentFilter->devInfo.streamingType == Type_kWaveCyclic) - { - unsigned i; - for(i=1; i < info.stream->capture.noOfPackets; ++i) - { - handleArray[noOfHandles++] = info.stream->capture.events[i]; - } - } - captureEvents = noOfHandles; - renderEvents = noOfHandles; - } - - if (info.stream->render.pPin != 0) - { - handleArray[noOfHandles++] = info.stream->render.events[0]; - if (info.stream->render.pPin->parentFilter->devInfo.streamingType == Type_kWaveCyclic) - { - unsigned i; - for(i=1; i < info.stream->render.noOfPackets; ++i) - { - handleArray[noOfHandles++] = info.stream->render.events[i]; - } - } - renderEvents = noOfHandles; - } - handleArray[noOfHandles++] = info.stream->eventAbort; - assert(noOfHandles <= (info.stream->capture.noOfPackets + info.stream->render.noOfPackets + 1)); - - /* Prepare render and capture pins */ - if ((result = PreparePinsForStart(&info)) != paNoError) - { - PA_DEBUG(("Failed to prepare device(s)!\n")); - goto error; - } - - /* Init high speed logger */ - if (PaUtil_InitializeHighSpeedLog(&info.stream->hLog, 1000000) != paNoError) - { - PA_DEBUG(("Failed to init high speed logger!\n")); - goto error; - } - - /* Heighten priority here */ - hAVRT = BumpThreadPriority(); - - /* If input only, we start the pins immediately */ - if (info.stream->render.pPin == 0) - { - if ((result = StartPins(&info)) != paNoError) - { - PA_DEBUG(("Failed to start device(s)!\n")); - goto error; - } - info.pinsStarted = 1; - } - - /* Handle WaveRT polled mode */ - { - const unsigned fs = (unsigned)info.stream->streamRepresentation.streamInfo.sampleRate; - if (info.stream->capture.pPin != 0 && info.stream->capture.pPin->pinKsSubType == SubType_kPolled) - { - timerEventHandles[0] = info.stream->capture.events[0]; - timerPeriod = min(timerPeriod, (1000*info.stream->capture.framesPerBuffer)/fs); - } - - if (info.stream->render.pPin != 0 && info.stream->render.pPin->pinKsSubType == SubType_kPolled) - { - timerEventHandles[1] = info.stream->render.events[0]; - timerPeriod = min(timerPeriod, (1000*info.stream->render.framesPerBuffer)/fs); - } - - if (timerEventHandles[0] || timerEventHandles[1]) - { - LARGE_INTEGER dueTime = {0}; - - timerPeriod=max(timerPeriod/5,1); - PA_DEBUG(("Timer event handles=0x%04X,0x%04X period=%u ms", timerEventHandles[0], timerEventHandles[1], timerPeriod)); - hTimer = CreateWaitableTimer(0, FALSE, NULL); - if (hTimer == NULL) - { - result = paUnanticipatedHostError; - goto error; - } - /* invoke first timeout immediately */ - if (!SetWaitableTimer(hTimer, &dueTime, timerPeriod, TimerAPCWaveRTPolledMode, timerEventHandles, FALSE)) - { - result = paUnanticipatedHostError; - goto error; - } - PA_DEBUG(("Waitable timer started, period = %u ms\n", timerPeriod)); - } - } - - /* Mark stream as active */ - info.stream->streamActive = 1; - info.stream->threadResult = paNoError; - - /* Up and running... */ - SetEvent(info.stream->eventStreamStart[StreamStart_kOk]); - - /* Take timestamp here */ - timeStamp[0] = timeStamp[1] = GetCurrentTimeInMillisecs(); - - while(!info.stream->streamAbort) - { - unsigned doProcessing = 1; - unsigned wait = WaitForMultipleObjects(noOfHandles, handleArray, FALSE, 0); - unsigned eventSignalled = wait - WAIT_OBJECT_0; - DWORD dwCurrentTime = 0; - - if (wait == WAIT_FAILED) - { - PA_DEBUG(("Wait failed = %ld! \n",wait)); - break; - } - if (wait == WAIT_TIMEOUT) - { - wait = WaitForMultipleObjectsEx(noOfHandles, handleArray, FALSE, 50, TRUE); - eventSignalled = wait - WAIT_OBJECT_0; - } - else - { - if (eventSignalled < captureEvents) - { - if (PaUtil_GetRingBufferWriteAvailable(&info.stream->ringBuffer) == 0) - { - PA_HP_TRACE((info.stream->hLog, "!!!!! Input overflow !!!!!")); - info.underover |= paInputOverflow; - } - } - else if (eventSignalled < renderEvents) - { - if (!info.priming && info.renderHead - info.renderTail > 1) - { - PA_HP_TRACE((info.stream->hLog, "!!!!! Output underflow !!!!!")); - info.underover |= paOutputUnderflow; - } - } - } - - /* Get event time */ - dwCurrentTime = GetCurrentTimeInMillisecs(); - - /* Since we can mix capture/render devices between WaveCyclic, WaveRT polled and WaveRT notification (3x3 combinations), - we can't rely on the timeout of WFMO to check for device timeouts, we need to keep tally. */ - if (info.stream->capture.pPin && (dwCurrentTime - timeStamp[0]) >= info.timeout) - { - PA_DEBUG(("Timeout for capture device (%u ms)!", info.timeout, (dwCurrentTime - timeStamp[0]))); - result = paTimedOut; - break; - } - if (info.stream->render.pPin && (dwCurrentTime - timeStamp[1]) >= info.timeout) - { - PA_DEBUG(("Timeout for render device (%u ms)!", info.timeout, (dwCurrentTime - timeStamp[1]))); - result = paTimedOut; - break; - } - - if (wait == WAIT_IO_COMPLETION) - { - /* Waitable timer has fired! */ - PA_HP_TRACE((info.stream->hLog, "WAIT_IO_COMPLETION")); - continue; - } - - if (wait == WAIT_TIMEOUT) - { - continue; - } - else - { - if (eventSignalled < captureEvents) - { - if (info.stream->capture.pPin->fnEventHandler(&info, eventSignalled) == paNoError) - { - timeStamp[0] = dwCurrentTime; - - /* Since we use the ring buffer, we can submit the buffers directly */ - if (!info.stream->streamStop) - { - result = info.stream->capture.pPin->fnSubmitHandler(&info, info.captureTail); - if (result != paNoError) - { - PA_HP_TRACE((info.stream->hLog, "Capture submit handler failed with result %d", result)); - break; - } - } - ++info.captureTail; - /* If full-duplex, let _only_ render event trigger processing. We still need the stream stop - handling working, so let that be processed anyways... */ - if (info.stream->userOutputChannels > 0) - { - doProcessing = 0; - } - } - } - else if (eventSignalled < renderEvents) - { - timeStamp[1] = dwCurrentTime; - eventSignalled -= captureEvents; - info.stream->render.pPin->fnEventHandler(&info, eventSignalled); - } - else - { - assert(info.stream->streamAbort); - PA_HP_TRACE((info.stream->hLog, "Stream abort!")); - continue; - } - } - - /* Handle processing */ - if (doProcessing) - { - result = PaDoProcessing(&info); - if (result != paNoError) - { - PA_HP_TRACE((info.stream->hLog, "PaDoProcessing failed!")); - break; - } - } - - if(info.stream->streamStop && info.cbResult != paComplete) - { - PA_HP_TRACE((info.stream->hLog, "Stream stop! pending=%d",info.pending)); - info.cbResult = paComplete; /* Stop, but play remaining buffers */ - } - - if(info.pending<=0) - { - PA_HP_TRACE((info.stream->hLog, "pending==0 finished...")); - break; - } - if((!info.stream->render.pPin)&&(info.cbResult!=paContinue)) - { - PA_HP_TRACE((info.stream->hLog, "record only cbResult=%d...",info.cbResult)); - break; - } - } - - PA_DEBUG(("Finished processing loop\n")); - - info.stream->threadResult = result; - goto bailout; - -error: - PA_DEBUG(("Error starting processing thread\n")); - /* Set the "error" event together with result */ - info.stream->threadResult = result; - SetEvent(info.stream->eventStreamStart[StreamStart_kFailed]); - -bailout: - if (hTimer) - { - PA_DEBUG(("Waitable timer stopped\n", timerPeriod)); - CancelWaitableTimer(hTimer); - CloseHandle(hTimer); - hTimer = 0; - } - - if (info.pinsStarted) - { - StopPins(&info); - } - - /* Lower prio here */ - DropThreadPriority(hAVRT); - - if (handleArray != NULL) - { - PaUtil_FreeMemory(handleArray); - } - -#if PA_TRACE_REALTIME_EVENTS - if (info.stream->hLog) - { - PA_DEBUG(("Dumping highspeed trace...\n")); - PaUtil_DumpHighSpeedLog(info.stream->hLog, "hp_trace.log"); - PaUtil_DiscardHighSpeedLog(info.stream->hLog); - info.stream->hLog = 0; - } -#endif - info.stream->streamActive = 0; - - if((!info.stream->streamStop)&&(!info.stream->streamAbort)) - { - /* Invoke the user stream finished callback */ - /* Only do it from here if not being stopped/aborted by user */ - if( info.stream->streamRepresentation.streamFinishedCallback != 0 ) - info.stream->streamRepresentation.streamFinishedCallback( info.stream->streamRepresentation.userData ); - } - info.stream->streamStop = 0; - info.stream->streamAbort = 0; - - PA_LOGL_; - return 0; -} - - -static PaError StartStream( PaStream *s ) -{ - PaError result = paNoError; - PaWinWdmStream *stream = (PaWinWdmStream*)s; - - PA_LOGE_; - - if (stream->streamThread != NULL) - { - return paStreamIsNotStopped; - } - - stream->streamStop = 0; - stream->streamAbort = 0; - - ResetStreamEvents(stream); - - PaUtil_ResetBufferProcessor( &stream->bufferProcessor ); - - stream->oldProcessPriority = GetPriorityClass(GetCurrentProcess()); - /* Uncomment the following line to enable dynamic boosting of the process - * priority to real time for best low latency support - * Disabled by default because RT processes can easily block the OS */ - /*ret = SetPriorityClass(GetCurrentProcess(),REALTIME_PRIORITY_CLASS); - PA_DEBUG(("Class ret = %d;",ret));*/ - - stream->streamThread = CREATE_THREAD_FUNCTION (NULL, 0, ProcessingThread, stream, CREATE_SUSPENDED, NULL); - if(stream->streamThread == NULL) - { - result = paInsufficientMemory; - goto end; - } - ResumeThread(stream->streamThread); - - switch (WaitForMultipleObjects(2, stream->eventStreamStart, FALSE, 5000)) - { - case WAIT_OBJECT_0 + StreamStart_kOk: - PA_DEBUG(("Processing thread started!\n")); - result = paNoError; - /* streamActive is set in processing thread */ - stream->streamStarted = 1; - break; - case WAIT_OBJECT_0 + StreamStart_kFailed: - PA_DEBUG(("Processing thread start failed! (result=%d)\n", stream->threadResult)); - result = stream->threadResult; - /* Wait for the stream to really exit */ - WaitForSingleObject(stream->streamThread, 200); - CloseHandle(stream->streamThread); - stream->streamThread = 0; - break; - case WAIT_TIMEOUT: - default: - result = paTimedOut; - PaWinWDM_SetLastErrorInfo(result, "Failed to start processing thread (timeout)!"); - break; - } - -end: - PA_LOGL_; - return result; -} - - -static PaError StopStream( PaStream *s ) -{ - PaError result = paNoError; - PaWinWdmStream *stream = (PaWinWdmStream*)s; - BOOL doCb = FALSE; - - PA_LOGE_; - - if(stream->streamActive) - { - DWORD dwExitCode; - doCb = TRUE; - stream->streamStop = 1; - if (GetExitCodeThread(stream->streamThread, &dwExitCode) && dwExitCode == STILL_ACTIVE) - { - if (WaitForSingleObject(stream->streamThread, INFINITE) != WAIT_OBJECT_0) - { - PA_DEBUG(("StopStream: stream thread terminated\n")); - TerminateThread(stream->streamThread, -1); - result = paTimedOut; - } - } - else - { - PA_DEBUG(("StopStream: GECT says not active, but streamActive is not false ??")); - result = paUnanticipatedHostError; - PaWinWDM_SetLastErrorInfo(result, "StopStream: GECT says not active, but streamActive = %d", stream->streamActive); - } - } - else - { - if (stream->threadResult != paNoError) - { - PA_DEBUG(("StopStream: Stream not active (%d)\n", stream->threadResult)); - result = stream->threadResult; - stream->threadResult = paNoError; - } - } - - if (stream->streamThread != NULL) - { - CloseHandle(stream->streamThread); - stream->streamThread = 0; - } - stream->streamStarted = 0; - stream->streamActive = 0; - - if(doCb) - { - /* Do user callback now after all state has been reset */ - /* This means it should be safe for the called function */ - /* to invoke e.g. StartStream */ - if( stream->streamRepresentation.streamFinishedCallback != 0 ) - stream->streamRepresentation.streamFinishedCallback( stream->streamRepresentation.userData ); - } - - PA_LOGL_; - return result; -} - -static PaError AbortStream( PaStream *s ) -{ - PaError result = paNoError; - PaWinWdmStream *stream = (PaWinWdmStream*)s; - int doCb = 0; - - PA_LOGE_; - - if(stream->streamActive) - { - doCb = 1; - stream->streamAbort = 1; - SetEvent(stream->eventAbort); /* Signal immediately */ - if (WaitForSingleObject(stream->streamThread, 10000) != WAIT_OBJECT_0) - { - TerminateThread(stream->streamThread, -1); - result = paTimedOut; - - PA_DEBUG(("AbortStream: stream thread terminated\n")); - } - assert(!stream->streamActive); - } - CloseHandle(stream->streamThread); - stream->streamThread = NULL; - stream->streamStarted = 0; - - if(doCb) - { - /* Do user callback now after all state has been reset */ - /* This means it should be safe for the called function */ - /* to invoke e.g. StartStream */ - if( stream->streamRepresentation.streamFinishedCallback != 0 ) - stream->streamRepresentation.streamFinishedCallback( stream->streamRepresentation.userData ); - } - - stream->streamActive = 0; - stream->streamStarted = 0; - - PA_LOGL_; - return result; -} - - -static PaError IsStreamStopped( PaStream *s ) -{ - PaWinWdmStream *stream = (PaWinWdmStream*)s; - int result = 0; - - PA_LOGE_; - - if(!stream->streamStarted) - result = 1; - - PA_LOGL_; - return result; -} - - -static PaError IsStreamActive( PaStream *s ) -{ - PaWinWdmStream *stream = (PaWinWdmStream*)s; - int result = 0; - - PA_LOGE_; - - if(stream->streamActive) - result = 1; - - PA_LOGL_; - return result; -} - - -static PaTime GetStreamTime( PaStream* s ) -{ - PA_LOGE_; - PA_LOGL_; - (void)s; - return PaUtil_GetTime(); -} - - -static double GetStreamCpuLoad( PaStream* s ) -{ - PaWinWdmStream *stream = (PaWinWdmStream*)s; - double result; - PA_LOGE_; - result = PaUtil_GetCpuLoad( &stream->cpuLoadMeasurer ); - PA_LOGL_; - return result; -} - - -/* -As separate stream interfaces are used for blocking and callback -streams, the following functions can be guaranteed to only be called -for blocking streams. -*/ - -static PaError ReadStream( PaStream* s, - void *buffer, - unsigned long frames ) -{ - PaWinWdmStream *stream = (PaWinWdmStream*)s; - - PA_LOGE_; - - /* suppress unused variable warnings */ - (void) buffer; - (void) frames; - (void) stream; - - /* IMPLEMENT ME, see portaudio.h for required behavior*/ - PA_LOGL_; - return paInternalError; -} - - -static PaError WriteStream( PaStream* s, - const void *buffer, - unsigned long frames ) -{ - PaWinWdmStream *stream = (PaWinWdmStream*)s; - - PA_LOGE_; - - /* suppress unused variable warnings */ - (void) buffer; - (void) frames; - (void) stream; - - /* IMPLEMENT ME, see portaudio.h for required behavior*/ - PA_LOGL_; - return paInternalError; -} - - -static signed long GetStreamReadAvailable( PaStream* s ) -{ - PaWinWdmStream *stream = (PaWinWdmStream*)s; - - PA_LOGE_; - - /* suppress unused variable warnings */ - (void) stream; - - /* IMPLEMENT ME, see portaudio.h for required behavior*/ - PA_LOGL_; - return 0; -} - - -static signed long GetStreamWriteAvailable( PaStream* s ) -{ - PaWinWdmStream *stream = (PaWinWdmStream*)s; - - PA_LOGE_; - /* suppress unused variable warnings */ - (void) stream; - - /* IMPLEMENT ME, see portaudio.h for required behavior*/ - PA_LOGL_; - return 0; -} - -/***************************************************************************************/ -/* Event and submit handlers for WaveCyclic */ -/***************************************************************************************/ - -static PaError PaPinCaptureEventHandler_WaveCyclic(PaProcessThreadInfo* pInfo, unsigned eventIndex) -{ - PaError result = paNoError; - ring_buffer_size_t frameCount; - DATAPACKET* packet = pInfo->stream->capture.packets + eventIndex; - - assert( eventIndex < pInfo->stream->capture.noOfPackets ); - - if (packet->Header.DataUsed == 0) - { - PA_HP_TRACE((pInfo->stream->hLog, ">>> Capture bogus event (no data): idx=%u", eventIndex)); - - /* Bogus event, reset! This is to handle the behavior of this USB mic: http://shop.xtz.se/measurement-system/microphone-to-dirac-live-room-correction-suite - on startup of streaming, where it erroneously sets the event without the corresponding buffer being filled (DataUsed == 0) */ - ResetEvent(packet->Signal.hEvent); - - result = -1; /* Only need this to be NOT paNoError */ - } - else - { - pInfo->capturePackets[pInfo->captureHead & cPacketsArrayMask].packet = packet; - - frameCount = PaUtil_WriteRingBuffer(&pInfo->stream->ringBuffer, packet->Header.Data, pInfo->stream->capture.framesPerBuffer); - - PA_HP_TRACE((pInfo->stream->hLog, ">>> Capture event: idx=%u (frames=%u)", eventIndex, frameCount)); - ++pInfo->captureHead; - } - - --pInfo->pending; /* This needs to be done in either case */ - return result; -} - -static PaError PaPinCaptureSubmitHandler_WaveCyclic(PaProcessThreadInfo* pInfo, unsigned eventIndex) -{ - PaError result = paNoError; - DATAPACKET* packet = pInfo->capturePackets[pInfo->captureTail & cPacketsArrayMask].packet; - pInfo->capturePackets[pInfo->captureTail & cPacketsArrayMask].packet = 0; - assert(packet != 0); - PA_HP_TRACE((pInfo->stream->hLog, "Capture submit: %u", eventIndex)); - packet->Header.DataUsed = 0; /* Reset for reuse */ - packet->Header.OptionsFlags = 0; /* Reset for reuse. Required for e.g. Focusrite Scarlett 2i4 (1st Gen) see #310 */ - ResetEvent(packet->Signal.hEvent); - result = PinRead(pInfo->stream->capture.pPin->handle, packet); - ++pInfo->pending; - return result; -} - -static PaError PaPinRenderEventHandler_WaveCyclic(PaProcessThreadInfo* pInfo, unsigned eventIndex) -{ - assert( eventIndex < pInfo->stream->render.noOfPackets ); - - pInfo->renderPackets[pInfo->renderHead & cPacketsArrayMask].packet = pInfo->stream->render.packets + eventIndex; - PA_HP_TRACE((pInfo->stream->hLog, "<<< Render event : idx=%u head=%u", eventIndex, pInfo->renderHead)); - ++pInfo->renderHead; - --pInfo->pending; - return paNoError; -} - -static PaError PaPinRenderSubmitHandler_WaveCyclic(PaProcessThreadInfo* pInfo, unsigned eventIndex) -{ - PaError result = paNoError; - DATAPACKET* packet = pInfo->renderPackets[pInfo->renderTail & cPacketsArrayMask].packet; - pInfo->renderPackets[pInfo->renderTail & cPacketsArrayMask].packet = 0; - assert(packet != 0); - - PA_HP_TRACE((pInfo->stream->hLog, "Render submit : %u idx=%u", pInfo->renderTail, (unsigned)(packet - pInfo->stream->render.packets))); - ResetEvent(packet->Signal.hEvent); - result = PinWrite(pInfo->stream->render.pPin->handle, packet); - /* Reset event, just in case we have an analogous situation to capture (see PaPinCaptureSubmitHandler_WaveCyclic) */ - ++pInfo->pending; - if (pInfo->priming) - { - --pInfo->priming; - } - return result; -} - -/***************************************************************************************/ -/* Event and submit handlers for WaveRT */ -/***************************************************************************************/ - -static PaError PaPinCaptureEventHandler_WaveRTEvent(PaProcessThreadInfo* pInfo, unsigned eventIndex) -{ - unsigned long pos; - unsigned realInBuf; - unsigned frameCount; - PaWinWdmIOInfo* pCapture = &pInfo->stream->capture; - const unsigned halfInputBuffer = pCapture->hostBufferSize >> 1; - PaWinWdmPin* pin = pCapture->pPin; - DATAPACKET* packet = 0; - - /* Get hold of current ADC position */ - pin->fnAudioPosition(pin, &pos); - /* Wrap it (robi: why not use hw latency compensation here ?? because pos then gets _way_ off from - where it should be, i.e. at beginning or half buffer position. Why? No idea.) */ - - pos %= pCapture->hostBufferSize; - /* Then realInBuf will point to "other" half of double buffer */ - realInBuf = pos < halfInputBuffer ? 1U : 0U; - - packet = pInfo->stream->capture.packets + realInBuf; - - /* Call barrier (or dummy) */ - pin->fnMemBarrier(); - - /* Put it in queue */ - frameCount = PaUtil_WriteRingBuffer(&pInfo->stream->ringBuffer, packet->Header.Data, pCapture->framesPerBuffer); - - pInfo->capturePackets[pInfo->captureHead & cPacketsArrayMask].packet = packet; - - PA_HP_TRACE((pInfo->stream->hLog, "Capture event (WaveRT): idx=%u head=%u (pos = %4.1lf%%, frames=%u)", realInBuf, pInfo->captureHead, (pos * 100.0 / pCapture->hostBufferSize), frameCount)); - - ++pInfo->captureHead; - --pInfo->pending; - - return paNoError; -} - -static PaError PaPinCaptureEventHandler_WaveRTPolled(PaProcessThreadInfo* pInfo, unsigned eventIndex) -{ - unsigned long pos; - unsigned bytesToRead; - PaWinWdmIOInfo* pCapture = &pInfo->stream->capture; - const unsigned halfInputBuffer = pCapture->hostBufferSize>>1; - PaWinWdmPin* pin = pInfo->stream->capture.pPin; - - /* Get hold of current ADC position */ - pin->fnAudioPosition(pin, &pos); - /* Wrap it (robi: why not use hw latency compensation here ?? because pos then gets _way_ off from - where it should be, i.e. at beginning or half buffer position. Why? No idea.) */ - /* Compensate for HW FIFO to get to last read buffer position */ - pos += pin->hwLatency; - pos %= pCapture->hostBufferSize; - /* Need to align position on frame boundary */ - pos &= ~(pCapture->bytesPerFrame - 1); - - /* Call barrier (or dummy) */ - pin->fnMemBarrier(); - - /* Put it in "queue" */ - bytesToRead = (pCapture->hostBufferSize + pos - pCapture->lastPosition) % pCapture->hostBufferSize; - if (bytesToRead > 0) - { - unsigned frameCount = PaUtil_WriteRingBuffer(&pInfo->stream->ringBuffer, - pCapture->hostBuffer + pCapture->lastPosition, - bytesToRead / pCapture->bytesPerFrame); - - pCapture->lastPosition = (pCapture->lastPosition + frameCount * pCapture->bytesPerFrame) % pCapture->hostBufferSize; - - PA_HP_TRACE((pInfo->stream->hLog, "Capture event (WaveRTPolled): pos = %4.1lf%%, framesRead=%u", (pos * 100.0 / pCapture->hostBufferSize), frameCount)); - ++pInfo->captureHead; - --pInfo->pending; - } - return paNoError; -} - -static PaError PaPinCaptureSubmitHandler_WaveRTEvent(PaProcessThreadInfo* pInfo, unsigned eventIndex) -{ - pInfo->capturePackets[pInfo->captureTail & cPacketsArrayMask].packet = 0; - ++pInfo->pending; - return paNoError; -} - -static PaError PaPinCaptureSubmitHandler_WaveRTPolled(PaProcessThreadInfo* pInfo, unsigned eventIndex) -{ - pInfo->capturePackets[pInfo->captureTail & cPacketsArrayMask].packet = 0; - ++pInfo->pending; - return paNoError; -} - -static PaError PaPinRenderEventHandler_WaveRTEvent(PaProcessThreadInfo* pInfo, unsigned eventIndex) -{ - unsigned long pos; - unsigned realOutBuf; - PaWinWdmIOInfo* pRender = &pInfo->stream->render; - const unsigned halfOutputBuffer = pRender->hostBufferSize >> 1; - PaWinWdmPin* pin = pInfo->stream->render.pPin; - PaIOPacket* ioPacket = &pInfo->renderPackets[pInfo->renderHead & cPacketsArrayMask]; - - /* Get hold of current DAC position */ - pin->fnAudioPosition(pin, &pos); - /* Compensate for HW FIFO to get to last read buffer position */ - pos += pin->hwLatency; - /* Wrap it */ - pos %= pRender->hostBufferSize; - /* And align it, not sure its really needed though */ - pos &= ~(pRender->bytesPerFrame - 1); - /* Then realOutBuf will point to "other" half of double buffer */ - realOutBuf = pos < halfOutputBuffer ? 1U : 0U; - - if (pInfo->priming) - { - realOutBuf = pInfo->renderHead & 0x1; - } - ioPacket->packet = pInfo->stream->render.packets + realOutBuf; - ioPacket->startByte = realOutBuf * halfOutputBuffer; - ioPacket->lengthBytes = halfOutputBuffer; - - PA_HP_TRACE((pInfo->stream->hLog, "Render event (WaveRT) : idx=%u head=%u (pos = %4.1lf%%)", realOutBuf, pInfo->renderHead, (pos * 100.0 / pRender->hostBufferSize) )); - - ++pInfo->renderHead; - --pInfo->pending; - return paNoError; -} - -static PaError PaPinRenderEventHandler_WaveRTPolled(PaProcessThreadInfo* pInfo, unsigned eventIndex) -{ - unsigned long pos; - unsigned realOutBuf; - unsigned bytesToWrite; - - PaWinWdmIOInfo* pRender = &pInfo->stream->render; - const unsigned halfOutputBuffer = pRender->hostBufferSize >> 1; - PaWinWdmPin* pin = pInfo->stream->render.pPin; - PaIOPacket* ioPacket = &pInfo->renderPackets[pInfo->renderHead & cPacketsArrayMask]; - - /* Get hold of current DAC position */ - pin->fnAudioPosition(pin, &pos); - /* Compensate for HW FIFO to get to last read buffer position */ - pos += pin->hwLatency; - /* Wrap it */ - pos %= pRender->hostBufferSize; - /* And align it, not sure its really needed though */ - pos &= ~(pRender->bytesPerFrame - 1); - - if (pInfo->priming) - { - realOutBuf = pInfo->renderHead & 0x1; - ioPacket->packet = pInfo->stream->render.packets + realOutBuf; - ioPacket->startByte = realOutBuf * halfOutputBuffer; - ioPacket->lengthBytes = halfOutputBuffer; - ++pInfo->renderHead; - --pInfo->pending; - } - else - { - bytesToWrite = (pRender->hostBufferSize + pos - pRender->lastPosition) % pRender->hostBufferSize; - ++pRender->pollCntr; - if (bytesToWrite >= halfOutputBuffer) - { - realOutBuf = (pos < halfOutputBuffer) ? 1U : 0U; - ioPacket->packet = pInfo->stream->render.packets + realOutBuf; - pRender->lastPosition = realOutBuf ? 0U : halfOutputBuffer; - ioPacket->startByte = realOutBuf * halfOutputBuffer; - ioPacket->lengthBytes = halfOutputBuffer; - ++pInfo->renderHead; - --pInfo->pending; - PA_HP_TRACE((pInfo->stream->hLog, "Render event (WaveRTPolled) : idx=%u head=%u (pos = %4.1lf%%, cnt=%u)", realOutBuf, pInfo->renderHead, (pos * 100.0 / pRender->hostBufferSize), pRender->pollCntr)); - pRender->pollCntr = 0; - } - } - return paNoError; -} - -static PaError PaPinRenderSubmitHandler_WaveRTEvent(PaProcessThreadInfo* pInfo, unsigned eventIndex) -{ - PaWinWdmPin* pin = pInfo->stream->render.pPin; - pInfo->renderPackets[pInfo->renderTail & cPacketsArrayMask].packet = 0; - /* Call barrier (if needed) */ - pin->fnMemBarrier(); - PA_HP_TRACE((pInfo->stream->hLog, "Render submit (WaveRT) : submit=%u", pInfo->renderTail)); - ++pInfo->pending; - if (pInfo->priming) - { - --pInfo->priming; - if (pInfo->priming) - { - PA_HP_TRACE((pInfo->stream->hLog, "Setting WaveRT event for priming (2)")); - SetEvent(pInfo->stream->render.events[0]); - } - } - return paNoError; -} - -static PaError PaPinRenderSubmitHandler_WaveRTPolled(PaProcessThreadInfo* pInfo, unsigned eventIndex) -{ - PaWinWdmPin* pin = pInfo->stream->render.pPin; - pInfo->renderPackets[pInfo->renderTail & cPacketsArrayMask].packet = 0; - /* Call barrier (if needed) */ - pin->fnMemBarrier(); - PA_HP_TRACE((pInfo->stream->hLog, "Render submit (WaveRTPolled) : submit=%u", pInfo->renderTail)); - ++pInfo->pending; - if (pInfo->priming) - { - --pInfo->priming; - if (pInfo->priming) - { - PA_HP_TRACE((pInfo->stream->hLog, "Setting WaveRT event for priming (2)")); - SetEvent(pInfo->stream->render.events[0]); - } - } - return paNoError; -} |