DrvHostAudioWasApi.cpp@ 89382

最後變更在這個檔案從89382是 89325,由 vboxsync 提交於 4 年前
DrvHostAudioWasApi: Must use GetCurrentPadding instead of GetNextPacketSize in drvHostAudioWasHA_StreamGetReadable or we'll never get out of pre-buffering (not yet committed). Fixed a wrong loop condition in drvHostAudioWasHa_StreamCapture. bugref:9890
屬性 svn:eol-style 設為 `native` 屬性 svn:keywords 設為 `Author Date Id Revision`
檔案大小: 121.8 KB

行
1	/* $Id: DrvHostAudioWasApi.cpp 89325 2021-05-28 00:15:46Z vboxsync $ */
2	/** @file
3	* Host audio driver - Windows Audio Session API.
4	*/
5
6	/*
7	* Copyright (C) 2021 Oracle Corporation
8	*
9	* This file is part of VirtualBox Open Source Edition (OSE), as
10	* available from http://www.alldomusa.eu.org. This file is free software;
11	* you can redistribute it and/or modify it under the terms of the GNU
12	* General Public License (GPL) as published by the Free Software
13	* Foundation, in version 2 as it comes in the "COPYING" file of the
14	* VirtualBox OSE distribution. VirtualBox OSE is distributed in the
15	* hope that it will be useful, but WITHOUT ANY WARRANTY of any kind.
16	*/
17
18
19	/*********************************************************************************************************************************
20	* Header Files *
21	*********************************************************************************************************************************/
22	#define LOG_GROUP LOG_GROUP_DRV_HOST_AUDIO
23	/#define INITGUID - defined in VBoxhostAudioDSound.cpp already /
24	#include <VBox/log.h>
25	#include <iprt/win/windows.h>
26	#include <Mmdeviceapi.h>
27	#include <iprt/win/audioclient.h>
28	#include <functiondiscoverykeys_devpkey.h>
29	#include <AudioSessionTypes.h>
30	#ifndef AUDCLNT_STREAMFLAGS_SRC_DEFAULT_QUALITY
31	# define AUDCLNT_STREAMFLAGS_SRC_DEFAULT_QUALITY UINT32_C(0x08000000)
32	#endif
33	#ifndef AUDCLNT_STREAMFLAGS_AUTOCONVERTPCM
34	# define AUDCLNT_STREAMFLAGS_AUTOCONVERTPCM UINT32_C(0x80000000)
35	#endif
36
37	#include <VBox/vmm/pdmaudioinline.h>
38	#include <VBox/vmm/pdmaudiohostenuminline.h>
39
40	#include <iprt/rand.h>
41	#include <iprt/semaphore.h>
42	#include <iprt/utf16.h>
43	#include <iprt/uuid.h>
44
45	#include <new> /* std::bad_alloc */
46
47	#include "VBoxDD.h"
48
49
50	/*********************************************************************************************************************************
51	* Defined Constants And Macros *
52	*********************************************************************************************************************************/
53	/** Max GetCurrentPadding value we accept (to make sure it's safe to convert to bytes). */
54	#define VBOX_WASAPI_MAX_PADDING UINT32_C(0x007fffff)
55
56	/** Maximum number of cached device configs in each direction.
57	* The number 4 was picked at random. */
58	#define VBOX_WASAPI_MAX_TOTAL_CONFIG_ENTRIES 4
59
60	#if 0
61	/** @name WM_DRVHOSTAUDIOWAS_XXX - Worker thread messages.
62	* @{ */
63	#define WM_DRVHOSTAUDIOWAS_PURGE_CACHE (WM_APP + 3)
64	/** @} */
65	#endif
66
67
68	/** @name DRVHOSTAUDIOWAS_DO_XXX - Worker thread operations.
69	* @{ */
70	#define DRVHOSTAUDIOWAS_DO_PURGE_CACHE ((uintptr_t)0x49f37300 + 1)
71	#define DRVHOSTAUDIOWAS_DO_PRUNE_CACHE ((uintptr_t)0x49f37300 + 2)
72	#define DRVHOSTAUDIOWAS_DO_STREAM_DEV_SWITCH ((uintptr_t)0x49f37300 + 3)
73	/** @} */
74
75
76	/*********************************************************************************************************************************
77	* Structures and Typedefs *
78	*********************************************************************************************************************************/
79	class DrvHostAudioWasMmNotifyClient;
80
81	/** Pointer to the cache entry for a host audio device (+dir). */
82	typedef struct DRVHOSTAUDIOWASCACHEDEV *PDRVHOSTAUDIOWASCACHEDEV;
83
84	/**
85	* Cached pre-initialized audio client for a device.
86	*
87	* The activation and initialization of an IAudioClient has been observed to be
88	* very very slow (> 100 ms) and not suitable to be done on an EMT. So, we'll
89	* pre-initialize the device clients at construction time and when the default
90	* device changes to try avoid this problem.
91	*
92	* A client is returned to the cache after we're done with it, provided it still
93	* works fine.
94	*/
95	typedef struct DRVHOSTAUDIOWASCACHEDEVCFG
96	{
97	/** Entry in DRVHOSTAUDIOWASCACHEDEV::ConfigList. */
98	RTLISTNODE ListEntry;
99	/** The device. */
100	PDRVHOSTAUDIOWASCACHEDEV pDevEntry;
101	/** The cached audio client. */
102	IAudioClient *pIAudioClient;
103	/** Output streams: The render client interface. */
104	IAudioRenderClient *pIAudioRenderClient;
105	/** Input streams: The capture client interface. */
106	IAudioCaptureClient *pIAudioCaptureClient;
107	/** The configuration. */
108	PDMAUDIOPCMPROPS Props;
109	/** The buffer size in frames. */
110	uint32_t cFramesBufferSize;
111	/** The device/whatever period in frames. */
112	uint32_t cFramesPeriod;
113	/** The setup status code.
114	* This is set to VERR_AUDIO_STREAM_INIT_IN_PROGRESS while the asynchronous
115	* initialization is still running. */
116	int volatile rcSetup;
117	/** Creation timestamp (just for reference). */
118	uint64_t nsCreated;
119	/** Init complete timestamp (just for reference). */
120	uint64_t nsInited;
121	/** When it was last used. */
122	uint64_t nsLastUsed;
123	/** The stringified properties. */
124	char szProps[32];
125	} DRVHOSTAUDIOWASCACHEDEVCFG;
126	/** Pointer to a pre-initialized audio client. */
127	typedef DRVHOSTAUDIOWASCACHEDEVCFG *PDRVHOSTAUDIOWASCACHEDEVCFG;
128
129	/**
130	* Per audio device (+ direction) cache entry.
131	*/
132	typedef struct DRVHOSTAUDIOWASCACHEDEV
133	{
134	/** Entry in DRVHOSTAUDIOWAS::CacheHead. */
135	RTLISTNODE ListEntry;
136	/** The MM device associated with the stream. */
137	IMMDevice *pIDevice;
138	/** The direction of the device. */
139	PDMAUDIODIR enmDir;
140	#if 0 /* According to https://social.msdn.microsoft.com/Forums/en-US/1d974d90-6636-4121-bba3-a8861d9ab92a,
141	these were always support just missing from the SDK. */
142	/** Support for AUDCLNT_STREAMFLAGS_AUTOCONVERTPCM: -1=unknown, 0=no, 1=yes. */
143	int8_t fSupportsAutoConvertPcm;
144	/** Support for AUDCLNT_STREAMFLAGS_SRC_DEFAULT_QUALITY: -1=unknown, 0=no, 1=yes. */
145	int8_t fSupportsSrcDefaultQuality;
146	#endif
147	/** List of cached configurations (DRVHOSTAUDIOWASCACHEDEVCFG). */
148	RTLISTANCHOR ConfigList;
149	/** The device ID length in RTUTF16 units. */
150	size_t cwcDevId;
151	/** The device ID. */
152	RTUTF16 wszDevId[RT_FLEXIBLE_ARRAY];
153	} DRVHOSTAUDIOWASCACHEDEV;
154
155
156	/**
157	* Data for a WASABI stream.
158	*/
159	typedef struct DRVHOSTAUDIOWASSTREAM
160	{
161	/** Common part. */
162	PDMAUDIOBACKENDSTREAM Core;
163
164	/** Entry in DRVHOSTAUDIOWAS::StreamHead. */
165	RTLISTNODE ListEntry;
166	/** The stream's acquired configuration. */
167	PDMAUDIOSTREAMCFG Cfg;
168	/** Cache entry to be relased when destroying the stream. */
169	PDRVHOSTAUDIOWASCACHEDEVCFG pDevCfg;
170
171	/** Set if the stream is enabled. */
172	bool fEnabled;
173	/** Set if the stream is started (playing/capturing). */
174	bool fStarted;
175	/** Set if the stream is draining (output only). */
176	bool fDraining;
177	/** Set if we should restart the stream on resume (saved pause state). */
178	bool fRestartOnResume;
179	/** Set if we're switching to a new output/input device. */
180	bool fSwitchingDevice;
181
182	/** The RTTimeMilliTS() deadline for the draining of this stream (output). */
183	uint64_t msDrainDeadline;
184	/** Internal stream offset (bytes). */
185	uint64_t offInternal;
186	/** The RTTimeMilliTS() at the end of the last transfer. */
187	uint64_t msLastTransfer;
188
189	/** Input: Current capture buffer (advanced as we read). */
190	uint8_t *pbCapture;
191	/** Input: The number of bytes left in the current capture buffer. */
192	uint32_t cbCapture;
193	/** Input: The full size of what pbCapture is part of (for ReleaseBuffer). */
194	uint32_t cFramesCaptureToRelease;
195
196	/** Critical section protecting: . */
197	RTCRITSECT CritSect;
198	/** Buffer that drvHostWasStreamStatusString uses. */
199	char szStatus[128];
200	} DRVHOSTAUDIOWASSTREAM;
201	/** Pointer to a WASABI stream. */
202	typedef DRVHOSTAUDIOWASSTREAM *PDRVHOSTAUDIOWASSTREAM;
203
204
205	/**
206	* WASAPI-specific device entry.
207	*/
208	typedef struct DRVHOSTAUDIOWASDEV
209	{
210	/** The core structure. */
211	PDMAUDIOHOSTDEV Core;
212	/** The device ID (flexible length). */
213	RTUTF16 wszDevId[RT_FLEXIBLE_ARRAY];
214	} DRVHOSTAUDIOWASDEV;
215	/** Pointer to a DirectSound device entry. */
216	typedef DRVHOSTAUDIOWASDEV *PDRVHOSTAUDIOWASDEV;
217
218
219	/**
220	* Data for a WASAPI host audio instance.
221	*/
222	typedef struct DRVHOSTAUDIOWAS
223	{
224	/** The audio host audio interface we export. */
225	PDMIHOSTAUDIO IHostAudio;
226	/** Pointer to the PDM driver instance. */
227	PPDMDRVINS pDrvIns;
228	/** Audio device enumerator instance that we use for getting the default
229	* devices (or specific ones if overriden by config). Also used for
230	* implementing enumeration. */
231	IMMDeviceEnumerator *pIEnumerator;
232	/** The upwards interface. */
233	PPDMIHOSTAUDIOPORT pIHostAudioPort;
234	/** The output device ID, NULL for default. */
235	PRTUTF16 pwszOutputDevId;
236	/** The input device ID, NULL for default. */
237	PRTUTF16 pwszInputDevId;
238
239	/** Pointer to the MM notification client instance. */
240	DrvHostAudioWasMmNotifyClient *pNotifyClient;
241	/** The input device to use. This can be NULL if there wasn't a suitable one
242	* around when we last looked or if it got removed/disabled/whatever.
243	* All access must be done inside the pNotifyClient critsect. */
244	IMMDevice *pIDeviceInput;
245	/** The output device to use. This can be NULL if there wasn't a suitable one
246	* around when we last looked or if it got removed/disabled/whatever.
247	* All access must be done inside the pNotifyClient critsect. */
248	IMMDevice *pIDeviceOutput;
249
250	/** List of streams (DRVHOSTAUDIOWASSTREAM).
251	* Requires CritSect ownership. */
252	RTLISTANCHOR StreamHead;
253	/** Serializing access to StreamHead. */
254	RTCRITSECTRW CritSectStreamList;
255
256	/** List of cached devices (DRVHOSTAUDIOWASCACHEDEV).
257	* Protected by CritSectCache */
258	RTLISTANCHOR CacheHead;
259	/** Serializing access to CacheHead. */
260	RTCRITSECT CritSectCache;
261	/** Semaphore for signalling that cache purge is done and that the destructor
262	* can do cleanups. */
263	RTSEMEVENTMULTI hEvtCachePurge;
264	/** Total number of device config entire for capturing.
265	* This includes in-use ones. */
266	uint32_t volatile cCacheEntriesIn;
267	/** Total number of device config entire for playback.
268	* This includes in-use ones. */
269	uint32_t volatile cCacheEntriesOut;
270
271	#if 0
272	/** The worker thread. */
273	RTTHREAD hWorkerThread;
274	/** The TID of the worker thread (for posting messages to it). */
275	DWORD idWorkerThread;
276	/** The fixed wParam value for the worker thread. */
277	WPARAM uWorkerThreadFixedParam;
278	#endif
279	} DRVHOSTAUDIOWAS;
280	/** Pointer to the data for a WASAPI host audio driver instance. */
281	typedef DRVHOSTAUDIOWAS *PDRVHOSTAUDIOWAS;
282
283
284
285
286	/**
287	* Gets the stream status.
288	*
289	* @returns Pointer to stream status string.
290	* @param pStreamWas The stream to get the status for.
291	*/
292	static const char *drvHostWasStreamStatusString(PDRVHOSTAUDIOWASSTREAM pStreamWas)
293	{
294	static RTSTRTUPLE const s_aEnable[2] =
295	{
296	{ RT_STR_TUPLE("DISABLED") },
297	{ RT_STR_TUPLE("ENABLED ") },
298	};
299	PCRTSTRTUPLE pTuple = &s_aEnable[pStreamWas->fEnabled];
300	memcpy(pStreamWas->szStatus, pTuple->psz, pTuple->cch);
301	size_t off = pTuple->cch;
302
303	static RTSTRTUPLE const s_aStarted[2] =
304	{
305	{ RT_STR_TUPLE(" STOPPED") },
306	{ RT_STR_TUPLE(" STARTED") },
307	};
308	pTuple = &s_aStarted[pStreamWas->fStarted];
309	memcpy(&pStreamWas->szStatus[off], pTuple->psz, pTuple->cch);
310	off += pTuple->cch;
311
312	static RTSTRTUPLE const s_aDraining[2] =
313	{
314	{ RT_STR_TUPLE("") },
315	{ RT_STR_TUPLE(" DRAINING") },
316	};
317	pTuple = &s_aDraining[pStreamWas->fDraining];
318	memcpy(&pStreamWas->szStatus[off], pTuple->psz, pTuple->cch);
319	off += pTuple->cch;
320
321	Assert(off < sizeof(pStreamWas->szStatus));
322	pStreamWas->szStatus[off] = '\0';
323	return pStreamWas->szStatus;
324	}
325
326
327	/*********************************************************************************************************************************
328	* IMMNotificationClient implementation
329	*********************************************************************************************************************************/
330	/**
331	* Multimedia notification client.
332	*
333	* We want to know when the default device changes so we can switch running
334	* streams to use the new one and so we can pre-activate it in preparation
335	* for new streams.
336	*/
337	class DrvHostAudioWasMmNotifyClient : public IMMNotificationClient
338	{
339	private:
340	/** Reference counter. */
341	uint32_t volatile m_cRefs;
342	/** The WASAPI host audio driver instance data.
343	* @note This can be NULL. Only access after entering critical section. */
344	PDRVHOSTAUDIOWAS m_pDrvWas;
345	/** Critical section serializing access to m_pDrvWas. */
346	RTCRITSECT m_CritSect;
347
348	public:
349	/**
350	* @throws int on critical section init failure.
351	*/
352	DrvHostAudioWasMmNotifyClient(PDRVHOSTAUDIOWAS a_pDrvWas)
353	: m_cRefs(1)
354	, m_pDrvWas(a_pDrvWas)
355	{
356	int rc = RTCritSectInit(&m_CritSect);
357	AssertRCStmt(rc, throw(rc));
358	}
359
360	virtual ~DrvHostAudioWasMmNotifyClient() RT_NOEXCEPT
361	{
362	RTCritSectDelete(&m_CritSect);
363	}
364
365	/**
366	* Called by drvHostAudioWasDestruct to set m_pDrvWas to NULL.
367	*/
368	void notifyDriverDestroyed() RT_NOEXCEPT
369	{
370	RTCritSectEnter(&m_CritSect);
371	m_pDrvWas = NULL;
372	RTCritSectLeave(&m_CritSect);
373	}
374
375	/**
376	* Enters the notification critsect for getting at the IMMDevice members in
377	* PDMHOSTAUDIOWAS.
378	*/
379	void lockEnter() RT_NOEXCEPT
380	{
381	RTCritSectEnter(&m_CritSect);
382	}
383
384	/**
385	* Leaves the notification critsect.
386	*/
387	void lockLeave() RT_NOEXCEPT
388	{
389	RTCritSectLeave(&m_CritSect);
390	}
391
392	/** @name IUnknown interface
393	* @{ */
394	IFACEMETHODIMP_(ULONG) AddRef()
395	{
396	uint32_t cRefs = ASMAtomicIncU32(&m_cRefs);
397	AssertMsg(cRefs < 64, ("%#x\n", cRefs));
398	Log6Func(("returns %u\n", cRefs));
399	return cRefs;
400	}
401
402	IFACEMETHODIMP_(ULONG) Release()
403	{
404	uint32_t cRefs = ASMAtomicDecU32(&m_cRefs);
405	AssertMsg(cRefs < 64, ("%#x\n", cRefs));
406	if (cRefs == 0)
407	delete this;
408	Log6Func(("returns %u\n", cRefs));
409	return cRefs;
410	}
411
412	IFACEMETHODIMP QueryInterface(const IID &rIID, void **ppvInterface)
413	{
414	if (IsEqualIID(rIID, IID_IUnknown))
415	ppvInterface = static_cast<IUnknown >(this);
416	else if (IsEqualIID(rIID, __uuidof(IMMNotificationClient)))
417	ppvInterface = static_cast<IMMNotificationClient >(this);
418	else
419	{
420	LogFunc(("Unknown rIID={%RTuuid}\n", &rIID));
421	*ppvInterface = NULL;
422	return E_NOINTERFACE;
423	}
424	Log6Func(("returns S_OK + %p\n", *ppvInterface));
425	return S_OK;
426	}
427	/** @} */
428
429	/** @name IMMNotificationClient interface
430	* @{ */
431	IFACEMETHODIMP OnDeviceStateChanged(LPCWSTR pwszDeviceId, DWORD dwNewState)
432	{
433	RT_NOREF(pwszDeviceId, dwNewState);
434	Log7Func(("pwszDeviceId=%ls dwNewState=%u (%#x)\n", pwszDeviceId, dwNewState, dwNewState));
435
436	/*
437	* Just trigger device re-enumeration.
438	*/
439	notifyDeviceChanges();
440
441	/** @todo do we need to check for our devices here too? Not when using a
442	* default device. But when using a specific device, we could perhaps
443	* re-init the stream when dwNewState indicates precense. We might
444	* also take action when a devices ceases to be operating, but again
445	* only for non-default devices, probably... */
446
447	return S_OK;
448	}
449
450	IFACEMETHODIMP OnDeviceAdded(LPCWSTR pwszDeviceId)
451	{
452	RT_NOREF(pwszDeviceId);
453	Log7Func(("pwszDeviceId=%ls\n", pwszDeviceId));
454
455	/*
456	* Is this a device we're interested in? Grab the enumerator if it is.
457	*/
458	bool fOutput = false;
459	IMMDeviceEnumerator *pIEnumerator = NULL;
460	RTCritSectEnter(&m_CritSect);
461	if ( m_pDrvWas != NULL
462	&& ( (fOutput = RTUtf16ICmp(m_pDrvWas->pwszOutputDevId, pwszDeviceId) == 0)
463	\|\| RTUtf16ICmp(m_pDrvWas->pwszInputDevId, pwszDeviceId) == 0))
464	{
465	pIEnumerator = m_pDrvWas->pIEnumerator;
466	if (pIEnumerator /* paranoia */)
467	pIEnumerator->AddRef();
468	}
469	RTCritSectLeave(&m_CritSect);
470	if (pIEnumerator)
471	{
472	/*
473	* Get the device and update it.
474	*/
475	IMMDevice *pIDevice = NULL;
476	HRESULT hrc = pIEnumerator->GetDevice(pwszDeviceId, &pIDevice);
477	if (SUCCEEDED(hrc))
478	setDevice(fOutput, pIDevice, pwszDeviceId, __PRETTY_FUNCTION__);
479	else
480	LogRelMax(64, ("WasAPI: Failed to get %s device '%ls' (OnDeviceAdded): %Rhrc\n",
481	fOutput ? "output" : "input", pwszDeviceId, hrc));
482	pIEnumerator->Release();
483
484	/*
485	* Trigger device re-enumeration.
486	*/
487	notifyDeviceChanges();
488	}
489	return S_OK;
490	}
491
492	IFACEMETHODIMP OnDeviceRemoved(LPCWSTR pwszDeviceId)
493	{
494	RT_NOREF(pwszDeviceId);
495	Log7Func(("pwszDeviceId=%ls\n", pwszDeviceId));
496
497	/*
498	* Is this a device we're interested in? Then set it to NULL.
499	*/
500	bool fOutput = false;
501	RTCritSectEnter(&m_CritSect);
502	if ( m_pDrvWas != NULL
503	&& ( (fOutput = RTUtf16ICmp(m_pDrvWas->pwszOutputDevId, pwszDeviceId) == 0)
504	\|\| RTUtf16ICmp(m_pDrvWas->pwszInputDevId, pwszDeviceId) == 0))
505	{
506	RTCritSectLeave(&m_CritSect);
507	setDevice(fOutput, NULL, pwszDeviceId, __PRETTY_FUNCTION__);
508	}
509	else
510	RTCritSectLeave(&m_CritSect);
511
512	/*
513	* Trigger device re-enumeration.
514	*/
515	notifyDeviceChanges();
516	return S_OK;
517	}
518
519	IFACEMETHODIMP OnDefaultDeviceChanged(EDataFlow enmFlow, ERole enmRole, LPCWSTR pwszDefaultDeviceId)
520	{
521	/*
522	* Are we interested in this device? If so grab the enumerator.
523	*/
524	IMMDeviceEnumerator *pIEnumerator = NULL;
525	RTCritSectEnter(&m_CritSect);
526	if ( m_pDrvWas != NULL
527	&& ( (enmFlow == eRender && enmRole == eMultimedia && !m_pDrvWas->pwszOutputDevId)
528	\|\| (enmFlow == eCapture && enmRole == eMultimedia && !m_pDrvWas->pwszInputDevId)))
529	{
530	pIEnumerator = m_pDrvWas->pIEnumerator;
531	if (pIEnumerator /* paranoia */)
532	pIEnumerator->AddRef();
533	}
534	RTCritSectLeave(&m_CritSect);
535	if (pIEnumerator)
536	{
537	/*
538	* Get the device and update it.
539	*/
540	IMMDevice *pIDevice = NULL;
541	HRESULT hrc = pIEnumerator->GetDefaultAudioEndpoint(enmFlow, enmRole, &pIDevice);
542	if (SUCCEEDED(hrc))
543	setDevice(enmFlow == eRender, pIDevice, pwszDefaultDeviceId, __PRETTY_FUNCTION__);
544	else
545	LogRelMax(64, ("WasAPI: Failed to get default %s device (OnDefaultDeviceChange): %Rhrc\n",
546	enmFlow == eRender ? "output" : "input", hrc));
547	pIEnumerator->Release();
548
549	/*
550	* Trigger device re-enumeration.
551	*/
552	notifyDeviceChanges();
553	}
554
555	Log7Func(("enmFlow=%d enmRole=%d pwszDefaultDeviceId=%ls\n", enmFlow, enmRole, pwszDefaultDeviceId));
556	return S_OK;
557	}
558
559	IFACEMETHODIMP OnPropertyValueChanged(LPCWSTR pwszDeviceId, const PROPERTYKEY Key)
560	{
561	RT_NOREF(pwszDeviceId, Key);
562	Log7Func(("pwszDeviceId=%ls Key={%RTuuid, %u (%#x)}\n", pwszDeviceId, &Key.fmtid, Key.pid, Key.pid));
563	return S_OK;
564	}
565	/** @} */
566
567	private:
568	/**
569	* Sets DRVHOSTAUDIOWAS::pIDeviceOutput or DRVHOSTAUDIOWAS::pIDeviceInput to @a pIDevice.
570	*/
571	void setDevice(bool fOutput, IMMDevice pIDevice, LPCWSTR pwszDeviceId, const char pszCaller)
572	{
573	RT_NOREF(pszCaller, pwszDeviceId);
574
575	RTCritSectEnter(&m_CritSect);
576
577	/*
578	* Update our internal device reference.
579	*/
580	if (m_pDrvWas)
581	{
582	if (fOutput)
583	{
584	Log7((LOG_FN_FMT ": Changing output device from %p to %p (%ls)\n",
585	pszCaller, m_pDrvWas->pIDeviceOutput, pIDevice, pwszDeviceId));
586	if (m_pDrvWas->pIDeviceOutput)
587	m_pDrvWas->pIDeviceOutput->Release();
588	m_pDrvWas->pIDeviceOutput = pIDevice;
589	}
590	else
591	{
592	Log7((LOG_FN_FMT ": Changing input device from %p to %p (%ls)\n",
593	pszCaller, m_pDrvWas->pIDeviceInput, pIDevice, pwszDeviceId));
594	if (m_pDrvWas->pIDeviceInput)
595	m_pDrvWas->pIDeviceInput->Release();
596	m_pDrvWas->pIDeviceInput = pIDevice;
597	}
598	}
599	else if (pIDevice)
600	pIDevice->Release();
601
602	/*
603	* Tell DrvAudio that the device has changed for one of the directions.
604	*
605	* We have to exit the critsect when doing so, or we'll create a locking
606	* order violation. So, try make sure the VM won't be destroyed while
607	* till DrvAudio have entered its critical section...
608	*/
609	if (m_pDrvWas)
610	{
611	PPDMIHOSTAUDIOPORT const pIHostAudioPort = m_pDrvWas->pIHostAudioPort;
612	if (pIHostAudioPort)
613	{
614	VMSTATE const enmVmState = PDMDrvHlpVMState(m_pDrvWas->pDrvIns);
615	if (enmVmState < VMSTATE_POWERING_OFF)
616	{
617	RTCritSectLeave(&m_CritSect);
618	pIHostAudioPort->pfnNotifyDeviceChanged(pIHostAudioPort, fOutput ? PDMAUDIODIR_OUT : PDMAUDIODIR_IN, NULL);
619	return;
620	}
621	LogFlowFunc(("Ignoring change: enmVmState=%d\n", enmVmState));
622	}
623	}
624
625	RTCritSectLeave(&m_CritSect);
626	}
627
628	/**
629	* Tell DrvAudio to re-enumerate devices when it get a chance.
630	*
631	* We exit the critsect here too before calling DrvAudio just to be on the safe
632	* side (see setDevice()), even though the current DrvAudio code doesn't take
633	* any critsects.
634	*/
635	void notifyDeviceChanges(void)
636	{
637	RTCritSectEnter(&m_CritSect);
638	if (m_pDrvWas)
639	{
640	PPDMIHOSTAUDIOPORT const pIHostAudioPort = m_pDrvWas->pIHostAudioPort;
641	if (pIHostAudioPort)
642	{
643	VMSTATE const enmVmState = PDMDrvHlpVMState(m_pDrvWas->pDrvIns);
644	if (enmVmState < VMSTATE_POWERING_OFF)
645	{
646	RTCritSectLeave(&m_CritSect);
647	pIHostAudioPort->pfnNotifyDevicesChanged(pIHostAudioPort);
648	return;
649	}
650	LogFlowFunc(("Ignoring change: enmVmState=%d\n", enmVmState));
651	}
652	}
653	RTCritSectLeave(&m_CritSect);
654	}
655	};
656
657
658	/*********************************************************************************************************************************
659	* Pre-configured audio client cache. *
660	*********************************************************************************************************************************/
661	#define WAS_CACHE_MAX_ENTRIES_SAME_DEVICE 2
662
663	/**
664	* Converts from PDM stream config to windows WAVEFORMATEX struct.
665	*
666	* @param pProps The PDM audio PCM properties to convert from.
667	* @param pFmt The windows structure to initialize.
668	*/
669	static void drvHostAudioWasWaveFmtExFromProps(PCPDMAUDIOPCMPROPS pProps, PWAVEFORMATEX pFmt)
670	{
671	RT_ZERO(*pFmt);
672	pFmt->wFormatTag = WAVE_FORMAT_PCM;
673	pFmt->nChannels = PDMAudioPropsChannels(pProps);
674	pFmt->wBitsPerSample = PDMAudioPropsSampleBits(pProps);
675	pFmt->nSamplesPerSec = PDMAudioPropsHz(pProps);
676	pFmt->nBlockAlign = PDMAudioPropsFrameSize(pProps);
677	pFmt->nAvgBytesPerSec = PDMAudioPropsFramesToBytes(pProps, PDMAudioPropsHz(pProps));
678	pFmt->cbSize = 0; /* No extra data specified. */
679	}
680
681
682	#if 0 /* unused */
683	/**
684	* Converts from windows WAVEFORMATEX and stream props to PDM audio properties.
685	*
686	* @returns VINF_SUCCESS on success, VERR_AUDIO_STREAM_COULD_NOT_CREATE if not
687	* supported.
688	* @param pProps The output properties structure.
689	* @param pFmt The windows wave format structure.
690	* @param pszStream The stream name for error logging.
691	* @param pwszDevId The device ID for error logging.
692	*/
693	static int drvHostAudioWasCacheWaveFmtExToProps(PPDMAUDIOPCMPROPS pProps, WAVEFORMATEX const *pFmt,
694	const char *pszStream, PCRTUTF16 pwszDevId)
695	{
696	if (pFmt->wFormatTag == WAVE_FORMAT_PCM)
697	{
698	if ( pFmt->wBitsPerSample == 8
699	\|\| pFmt->wBitsPerSample == 16
700	\|\| pFmt->wBitsPerSample == 32)
701	{
702	if (pFmt->nChannels > 0 && pFmt->nChannels < 16)
703	{
704	if (pFmt->nSamplesPerSec >= 4096 && pFmt->nSamplesPerSec <= 768000)
705	{
706	PDMAudioPropsInit(pProps, pFmt->wBitsPerSample / 8, true /fSigned/, pFmt->nChannels, pFmt->nSamplesPerSec);
707	if (PDMAudioPropsFrameSize(pProps) == pFmt->nBlockAlign)
708	return VINF_SUCCESS;
709	}
710	}
711	}
712	}
713	LogRelMax(64, ("WasAPI: Error! Unsupported stream format for '%s' suggested by '%ls':\n"
714	"WasAPI: wFormatTag = %RU16 (expected %d)\n"
715	"WasAPI: nChannels = %RU16 (expected 1..15)\n"
716	"WasAPI: nSamplesPerSec = %RU32 (expected 4096..768000)\n"
717	"WasAPI: nAvgBytesPerSec = %RU32\n"
718	"WasAPI: nBlockAlign = %RU16\n"
719	"WasAPI: wBitsPerSample = %RU16 (expected 8, 16, or 32)\n"
720	"WasAPI: cbSize = %RU16\n",
721	pszStream, pwszDevId, pFmt->wFormatTag, WAVE_FORMAT_PCM, pFmt->nChannels, pFmt->nSamplesPerSec, pFmt->nAvgBytesPerSec,
722	pFmt->nBlockAlign, pFmt->wBitsPerSample, pFmt->cbSize));
723	return VERR_AUDIO_STREAM_COULD_NOT_CREATE;
724	}
725	#endif
726
727
728	/**
729	* Destroys a devie config cache entry.
730	*
731	* @param pThis The WASAPI host audio driver instance data.
732	* @param pDevCfg Device config entry. Must not be in the list.
733	*/
734	static void drvHostAudioWasCacheDestroyDevConfig(PDRVHOSTAUDIOWAS pThis, PDRVHOSTAUDIOWASCACHEDEVCFG pDevCfg)
735	{
736	if (pDevCfg->pDevEntry->enmDir == PDMAUDIODIR_IN)
737	ASMAtomicDecU32(&pThis->cCacheEntriesIn);
738	else
739	ASMAtomicDecU32(&pThis->cCacheEntriesOut);
740
741	uint32_t cTypeClientRefs = 0;
742	if (pDevCfg->pIAudioCaptureClient)
743	{
744	cTypeClientRefs = pDevCfg->pIAudioCaptureClient->Release();
745	pDevCfg->pIAudioCaptureClient = NULL;
746	}
747
748	if (pDevCfg->pIAudioRenderClient)
749	{
750	cTypeClientRefs = pDevCfg->pIAudioRenderClient->Release();
751	pDevCfg->pIAudioRenderClient = NULL;
752	}
753
754	uint32_t cClientRefs = 0;
755	if (pDevCfg->pIAudioClient /* paranoia */)
756	{
757	cClientRefs = pDevCfg->pIAudioClient->Release();
758	pDevCfg->pIAudioClient = NULL;
759	}
760
761	Log8Func(("Destroying cache config entry: '%ls: %s' - cClientRefs=%u cTypeClientRefs=%u\n",
762	pDevCfg->pDevEntry->wszDevId, pDevCfg->szProps, cClientRefs, cTypeClientRefs));
763	RT_NOREF(cClientRefs, cTypeClientRefs);
764
765	pDevCfg->pDevEntry = NULL;
766	RTMemFree(pDevCfg);
767	}
768
769
770	/**
771	* Destroys a device cache entry.
772	*
773	* @param pThis The WASAPI host audio driver instance data.
774	* @param pDevEntry The device entry. Must not be in the cache!
775	*/
776	static void drvHostAudioWasCacheDestroyDevEntry(PDRVHOSTAUDIOWAS pThis, PDRVHOSTAUDIOWASCACHEDEV pDevEntry)
777	{
778	Log8Func(("Destroying cache entry: %p - '%ls'\n", pDevEntry, pDevEntry->wszDevId));
779
780	PDRVHOSTAUDIOWASCACHEDEVCFG pDevCfg, pDevCfgNext;
781	RTListForEachSafe(&pDevEntry->ConfigList, pDevCfg, pDevCfgNext, DRVHOSTAUDIOWASCACHEDEVCFG, ListEntry)
782	{
783	drvHostAudioWasCacheDestroyDevConfig(pThis, pDevCfg);
784	}
785
786	uint32_t cDevRefs = 0;
787	if (pDevEntry->pIDevice /* paranoia */)
788	{
789	cDevRefs = pDevEntry->pIDevice->Release();
790	pDevEntry->pIDevice = NULL;
791	}
792
793	pDevEntry->cwcDevId = 0;
794	pDevEntry->wszDevId[0] = '\0';
795	RTMemFree(pDevEntry);
796	Log8Func(("Destroyed cache entry: %p cDevRefs=%u\n", pDevEntry, cDevRefs));
797	}
798
799
800	/**
801	* Prunes the cache.
802	*/
803	static void drvHostAudioWasCachePrune(PDRVHOSTAUDIOWAS pThis)
804	{
805	/*
806	* Prune each direction separately.
807	*/
808	struct
809	{
810	PDMAUDIODIR enmDir;
811	uint32_t volatile *pcEntries;
812	} aWork[] = { { PDMAUDIODIR_IN, &pThis->cCacheEntriesIn }, { PDMAUDIODIR_OUT, &pThis->cCacheEntriesOut }, };
813	for (uint32_t iWork = 0; iWork < RT_ELEMENTS(aWork); iWork++)
814	{
815	/*
816	* Remove the least recently used entry till we're below the threshold
817	* or there are no more inactive entries.
818	*/
819	LogFlowFunc(("iWork=%u cEntries=%u\n", iWork, *aWork[iWork].pcEntries));
820	while (*aWork[iWork].pcEntries > VBOX_WASAPI_MAX_TOTAL_CONFIG_ENTRIES)
821	{
822	RTCritSectEnter(&pThis->CritSectCache);
823	PDRVHOSTAUDIOWASCACHEDEVCFG pLeastRecentlyUsed = NULL;
824	PDRVHOSTAUDIOWASCACHEDEV pDevEntry;
825	RTListForEach(&pThis->CacheHead, pDevEntry, DRVHOSTAUDIOWASCACHEDEV, ListEntry)
826	{
827	if (pDevEntry->enmDir == aWork[iWork].enmDir)
828	{
829	PDRVHOSTAUDIOWASCACHEDEVCFG pHeadCfg = RTListGetFirst(&pDevEntry->ConfigList,
830	DRVHOSTAUDIOWASCACHEDEVCFG, ListEntry);
831	if ( pHeadCfg
832	&& (!pLeastRecentlyUsed \|\| pHeadCfg->nsLastUsed < pLeastRecentlyUsed->nsLastUsed))
833	pLeastRecentlyUsed = pHeadCfg;
834	}
835	}
836	if (pLeastRecentlyUsed)
837	RTListNodeRemove(&pLeastRecentlyUsed->ListEntry);
838	RTCritSectLeave(&pThis->CritSectCache);
839
840	if (!pLeastRecentlyUsed)
841	break;
842	drvHostAudioWasCacheDestroyDevConfig(pThis, pLeastRecentlyUsed);
843	}
844	}
845	}
846
847
848	/**
849	* Purges all the entries in the cache.
850	*/
851	static void drvHostAudioWasCachePurge(PDRVHOSTAUDIOWAS pThis, bool fOnWorker)
852	{
853	for (;;)
854	{
855	RTCritSectEnter(&pThis->CritSectCache);
856	PDRVHOSTAUDIOWASCACHEDEV pDevEntry = RTListRemoveFirst(&pThis->CacheHead, DRVHOSTAUDIOWASCACHEDEV, ListEntry);
857	RTCritSectLeave(&pThis->CritSectCache);
858	if (!pDevEntry)
859	break;
860	drvHostAudioWasCacheDestroyDevEntry(pThis, pDevEntry);
861	}
862
863	if (fOnWorker)
864	{
865	int rc = RTSemEventMultiSignal(pThis->hEvtCachePurge);
866	AssertRC(rc);
867	}
868	}
869
870
871	/**
872	* Looks up a specific configuration.
873	*
874	* @returns Pointer to the device config (removed from cache) on success. NULL
875	* if no matching config found.
876	* @param pDevEntry Where to perform the lookup.
877	* @param pProps The config properties to match.
878	*/
879	static PDRVHOSTAUDIOWASCACHEDEVCFG
880	drvHostAudioWasCacheLookupLocked(PDRVHOSTAUDIOWASCACHEDEV pDevEntry, PCPDMAUDIOPCMPROPS pProps)
881	{
882	PDRVHOSTAUDIOWASCACHEDEVCFG pDevCfg;
883	RTListForEach(&pDevEntry->ConfigList, pDevCfg, DRVHOSTAUDIOWASCACHEDEVCFG, ListEntry)
884	{
885	if (PDMAudioPropsAreEqual(&pDevCfg->Props, pProps))
886	{
887	RTListNodeRemove(&pDevCfg->ListEntry);
888	pDevCfg->nsLastUsed = RTTimeNanoTS();
889	return pDevCfg;
890	}
891	}
892	return NULL;
893	}
894
895
896	/**
897	* Initializes a device config entry.
898	*
899	* This is usually done on the worker thread.
900	*
901	* @returns VBox status code.
902	* @param pDevCfg The device configuration entry to initialize.
903	*/
904	static int drvHostAudioWasCacheInitConfig(PDRVHOSTAUDIOWASCACHEDEVCFG pDevCfg)
905	{
906	/*
907	* Assert some sanity given that we migth be called on the worker thread
908	* and pDevCfg being a message parameter.
909	*/
910	AssertPtrReturn(pDevCfg, VERR_INTERNAL_ERROR_2);
911	AssertReturn(pDevCfg->rcSetup == VERR_AUDIO_STREAM_INIT_IN_PROGRESS, VERR_INTERNAL_ERROR_2);
912	AssertReturn(pDevCfg->pIAudioClient == NULL, VERR_INTERNAL_ERROR_2);
913	AssertReturn(pDevCfg->pIAudioCaptureClient == NULL, VERR_INTERNAL_ERROR_2);
914	AssertReturn(pDevCfg->pIAudioRenderClient == NULL, VERR_INTERNAL_ERROR_2);
915	AssertReturn(PDMAudioPropsAreValid(&pDevCfg->Props), VERR_INTERNAL_ERROR_2);
916
917	PDRVHOSTAUDIOWASCACHEDEV pDevEntry = pDevCfg->pDevEntry;
918	AssertPtrReturn(pDevEntry, VERR_INTERNAL_ERROR_2);
919	AssertPtrReturn(pDevEntry->pIDevice, VERR_INTERNAL_ERROR_2);
920	AssertReturn(pDevEntry->enmDir == PDMAUDIODIR_IN \|\| pDevEntry->enmDir == PDMAUDIODIR_OUT, VERR_INTERNAL_ERROR_2);
921
922	/*
923	* First we need an IAudioClient interface for calling IsFormatSupported
924	* on so we can get guidance as to what to do next.
925	*
926	* Initially, I thought the AUDCLNT_STREAMFLAGS_AUTOCONVERTPCM was not
927	* supported all the way back to Vista and that we'd had to try different
928	* things here to get the most optimal format. However, according to
929	* https://social.msdn.microsoft.com/Forums/en-US/1d974d90-6636-4121-bba3-a8861d9ab92a
930	* it is supported, just maybe missing from the SDK or something...
931	*
932	* I'll leave the IsFormatSupported call here as it gives us a clue as to
933	* what exactly the WAS needs to convert our audio stream into/from.
934	*/
935	Log8Func(("Activating an IAudioClient for '%ls' ...\n", pDevEntry->wszDevId));
936	IAudioClient *pIAudioClient = NULL;
937	HRESULT hrc = pDevEntry->pIDevice->Activate(__uuidof(IAudioClient), CLSCTX_ALL,
938	NULL /pActivationParams/, (void **)&pIAudioClient);
939	Log8Func(("Activate('%ls', IAudioClient) -> %Rhrc\n", pDevEntry->wszDevId, hrc));
940	if (FAILED(hrc))
941	{
942	LogRelMax(64, ("WasAPI: Activate(%ls, IAudioClient) failed: %Rhrc\n", pDevEntry->wszDevId, hrc));
943	pDevCfg->nsInited = RTTimeNanoTS();
944	pDevCfg->nsLastUsed = pDevCfg->nsInited;
945	return pDevCfg->rcSetup = VERR_AUDIO_STREAM_COULD_NOT_CREATE;
946	}
947
948	WAVEFORMATEX WaveFmtEx;
949	drvHostAudioWasWaveFmtExFromProps(&pDevCfg->Props, &WaveFmtEx);
950
951	PWAVEFORMATEX pClosestMatch = NULL;
952	hrc = pIAudioClient->IsFormatSupported(AUDCLNT_SHAREMODE_SHARED, &WaveFmtEx, &pClosestMatch);
953
954	/*
955	* If the format is supported, go ahead and initialize the client instance.
956	*/
957	if (SUCCEEDED(hrc))
958	{
959	if (hrc == S_OK)
960	Log8Func(("IsFormatSupport(,%s,) -> S_OK + %p: requested format is supported\n", pDevCfg->szProps, pClosestMatch));
961	else
962	Log8Func(("IsFormatSupport(,%s,) -> %Rhrc + %p: %uch S%u %uHz\n", pDevCfg->szProps, hrc, pClosestMatch,
963	pClosestMatch ? pClosestMatch->nChannels : 0, pClosestMatch ? pClosestMatch->wBitsPerSample : 0,
964	pClosestMatch ? pClosestMatch->nSamplesPerSec : 0));
965
966	REFERENCE_TIME const cBufferSizeInNtTicks = PDMAudioPropsFramesToNtTicks(&pDevCfg->Props, pDevCfg->cFramesBufferSize);
967	uint32_t fInitFlags = AUDCLNT_STREAMFLAGS_AUTOCONVERTPCM
968	\| AUDCLNT_STREAMFLAGS_SRC_DEFAULT_QUALITY;
969	hrc = pIAudioClient->Initialize(AUDCLNT_SHAREMODE_SHARED, fInitFlags, cBufferSizeInNtTicks,
970	0 /cPeriodicityInNtTicks/, &WaveFmtEx, NULL /pAudioSessionGuid/);
971	Log8Func(("Initialize(,%x, %RI64, %s,) -> %Rhrc\n", fInitFlags, cBufferSizeInNtTicks, pDevCfg->szProps, hrc));
972	if (SUCCEEDED(hrc))
973	{
974	/*
975	* The direction specific client interface.
976	*/
977	if (pDevEntry->enmDir == PDMAUDIODIR_IN)
978	hrc = pIAudioClient->GetService(__uuidof(IAudioCaptureClient), (void **)&pDevCfg->pIAudioCaptureClient);
979	else
980	hrc = pIAudioClient->GetService(__uuidof(IAudioRenderClient), (void **)&pDevCfg->pIAudioRenderClient);
981	Log8Func(("GetService -> %Rhrc + %p\n", hrc, pDevEntry->enmDir == PDMAUDIODIR_IN
982	? (void )pDevCfg->pIAudioCaptureClient : (void )pDevCfg->pIAudioRenderClient));
983	if (SUCCEEDED(hrc))
984	{
985	/*
986	* Obtain the actual stream format and buffer config.
987	*/
988	UINT32 cFramesBufferSize = 0;
989	REFERENCE_TIME cDefaultPeriodInNtTicks = 0;
990	REFERENCE_TIME cMinimumPeriodInNtTicks = 0;
991	REFERENCE_TIME cLatencyinNtTicks = 0;
992	hrc = pIAudioClient->GetBufferSize(&cFramesBufferSize);
993	if (SUCCEEDED(hrc))
994	{
995	hrc = pIAudioClient->GetDevicePeriod(&cDefaultPeriodInNtTicks, &cMinimumPeriodInNtTicks);
996	if (SUCCEEDED(hrc))
997	{
998	hrc = pIAudioClient->GetStreamLatency(&cLatencyinNtTicks);
999	if (SUCCEEDED(hrc))
1000	{
1001	LogRel2(("WasAPI: Aquired buffer parameters for %s:\n"
1002	"WasAPI: cFramesBufferSize = %RU32\n"
1003	"WasAPI: cDefaultPeriodInNtTicks = %RI64\n"
1004	"WasAPI: cMinimumPeriodInNtTicks = %RI64\n"
1005	"WasAPI: cLatencyinNtTicks = %RI64\n",
1006	pDevCfg->szProps, cFramesBufferSize, cDefaultPeriodInNtTicks,
1007	cMinimumPeriodInNtTicks, cLatencyinNtTicks));
1008
1009	pDevCfg->pIAudioClient = pIAudioClient;
1010	pDevCfg->cFramesBufferSize = cFramesBufferSize;
1011	pDevCfg->cFramesPeriod = PDMAudioPropsNanoToFrames(&pDevCfg->Props,
1012	cDefaultPeriodInNtTicks * 100);
1013	pDevCfg->nsInited = RTTimeNanoTS();
1014	pDevCfg->nsLastUsed = pDevCfg->nsInited;
1015	pDevCfg->rcSetup = VINF_SUCCESS;
1016
1017	if (pClosestMatch)
1018	CoTaskMemFree(pClosestMatch);
1019	Log8Func(("returns VINF_SUCCESS (%p (%s) inited in %'RU64 ns)\n",
1020	pDevCfg, pDevCfg->szProps, pDevCfg->nsInited - pDevCfg->nsCreated));
1021	return VINF_SUCCESS;
1022	}
1023	LogRelMax(64, ("WasAPI: GetStreamLatency failed: %Rhrc\n", hrc));
1024	}
1025	else
1026	LogRelMax(64, ("WasAPI: GetDevicePeriod failed: %Rhrc\n", hrc));
1027	}
1028	else
1029	LogRelMax(64, ("WasAPI: GetBufferSize failed: %Rhrc\n", hrc));
1030
1031	if (pDevCfg->pIAudioCaptureClient)
1032	{
1033	pDevCfg->pIAudioCaptureClient->Release();
1034	pDevCfg->pIAudioCaptureClient = NULL;
1035	}
1036
1037	if (pDevCfg->pIAudioRenderClient)
1038	{
1039	pDevCfg->pIAudioRenderClient->Release();
1040	pDevCfg->pIAudioRenderClient = NULL;
1041	}
1042	}
1043	else
1044	LogRelMax(64, ("WasAPI: IAudioClient::GetService(%s) failed: %Rhrc\n", pDevCfg->szProps, hrc));
1045	}
1046	else
1047	LogRelMax(64, ("WasAPI: IAudioClient::Initialize(%s) failed: %Rhrc\n", pDevCfg->szProps, hrc));
1048	}
1049	else
1050	LogRelMax(64,("WasAPI: IAudioClient::IsFormatSupport(,%s,) failed: %Rhrc\n", pDevCfg->szProps, hrc));
1051
1052	pIAudioClient->Release();
1053	if (pClosestMatch)
1054	CoTaskMemFree(pClosestMatch);
1055	pDevCfg->nsInited = RTTimeNanoTS();
1056	pDevCfg->nsLastUsed = 0;
1057	Log8Func(("returns VERR_AUDIO_STREAM_COULD_NOT_CREATE (inited in %'RU64 ns)\n", pDevCfg->nsInited - pDevCfg->nsCreated));
1058	return pDevCfg->rcSetup = VERR_AUDIO_STREAM_COULD_NOT_CREATE;
1059	}
1060
1061
1062	/**
1063	* Worker for drvHostAudioWasCacheLookupOrCreate.
1064	*
1065	* If lookup fails, a new entry will be created.
1066	*
1067	* @note Called holding the lock, returning without holding it!
1068	*/
1069	static int drvHostAudioWasCacheLookupOrCreateConfig(PDRVHOSTAUDIOWAS pThis, PDRVHOSTAUDIOWASCACHEDEV pDevEntry,
1070	PCPDMAUDIOSTREAMCFG pCfgReq, bool fOnWorker,
1071	PDRVHOSTAUDIOWASCACHEDEVCFG *ppDevCfg)
1072	{
1073	/*
1074	* Check if we've got a matching config.
1075	*/
1076	PDRVHOSTAUDIOWASCACHEDEVCFG pDevCfg = drvHostAudioWasCacheLookupLocked(pDevEntry, &pCfgReq->Props);
1077	if (pDevCfg)
1078	{
1079	*ppDevCfg = pDevCfg;
1080	RTCritSectLeave(&pThis->CritSectCache);
1081	Log8Func(("Config cache hit '%s' on '%ls': %p\n", pDevCfg->szProps, pDevEntry->wszDevId, pDevCfg));
1082	return VINF_SUCCESS;
1083	}
1084
1085	RTCritSectLeave(&pThis->CritSectCache);
1086
1087	/*
1088	* Allocate an device config entry and hand the creation task over to the
1089	* worker thread, unless we're already on it.
1090	*/
1091	pDevCfg = (PDRVHOSTAUDIOWASCACHEDEVCFG)RTMemAllocZ(sizeof(*pDevCfg));
1092	AssertReturn(pDevCfg, VERR_NO_MEMORY);
1093	RTListInit(&pDevCfg->ListEntry);
1094	pDevCfg->pDevEntry = pDevEntry;
1095	pDevCfg->rcSetup = VERR_AUDIO_STREAM_INIT_IN_PROGRESS;
1096	pDevCfg->Props = pCfgReq->Props;
1097	pDevCfg->cFramesBufferSize = pCfgReq->Backend.cFramesBufferSize;
1098	PDMAudioPropsToString(&pDevCfg->Props, pDevCfg->szProps, sizeof(pDevCfg->szProps));
1099	pDevCfg->nsCreated = RTTimeNanoTS();
1100	pDevCfg->nsLastUsed = pDevCfg->nsCreated;
1101
1102	uint32_t cCacheEntries;
1103	if (pDevCfg->pDevEntry->enmDir == PDMAUDIODIR_IN)
1104	cCacheEntries = ASMAtomicIncU32(&pThis->cCacheEntriesIn);
1105	else
1106	cCacheEntries = ASMAtomicIncU32(&pThis->cCacheEntriesOut);
1107	if (cCacheEntries > VBOX_WASAPI_MAX_TOTAL_CONFIG_ENTRIES)
1108	{
1109	LogFlowFunc(("Trigger cache pruning.\n"));
1110	int rc2 = pThis->pIHostAudioPort->pfnDoOnWorkerThread(pThis->pIHostAudioPort, NULL /pStream/,
1111	DRVHOSTAUDIOWAS_DO_PRUNE_CACHE, NULL /pvUser/);
1112	AssertRCStmt(rc2, drvHostAudioWasCachePrune(pThis));
1113	}
1114
1115	if (!fOnWorker)
1116	{
1117	*ppDevCfg = pDevCfg;
1118	LogFlowFunc(("Doing the rest of the work on %p via pfnStreamInitAsync...\n", pDevCfg));
1119	return VINF_AUDIO_STREAM_ASYNC_INIT_NEEDED;
1120	}
1121
1122	/*
1123	* Initialize the entry on the calling thread.
1124	*/
1125	int rc = drvHostAudioWasCacheInitConfig(pDevCfg);
1126	AssertRC(pDevCfg->rcSetup == rc);
1127	if (RT_SUCCESS(rc))
1128	rc = pDevCfg->rcSetup; /* paranoia */
1129	if (RT_SUCCESS(rc))
1130	{
1131	*ppDevCfg = pDevCfg;
1132	LogFlowFunc(("Returning %p\n", pDevCfg));
1133	return VINF_SUCCESS;
1134	}
1135	RTMemFree(pDevCfg);
1136	*ppDevCfg = NULL;
1137	return rc;
1138	}
1139
1140
1141	/**
1142	* Looks up the given device + config combo in the cache, creating a new entry
1143	* if missing.
1144	*
1145	* @returns VBox status code.
1146	* @retval VINF_AUDIO_STREAM_ASYNC_INIT_NEEDED if @a fOnWorker is @c false and
1147	* we created a new entry that needs initalization by calling
1148	* drvHostAudioWasCacheInitConfig() on it.
1149	* @param pThis The WASAPI host audio driver instance data.
1150	* @param pIDevice The device to look up.
1151	* @param pCfgReq The configuration to look up.
1152	* @param fOnWorker Set if we're on a worker thread, otherwise false. When
1153	* set to @c true, VINF_AUDIO_STREAM_ASYNC_INIT_NEEDED will
1154	* not be returned and a new entry will be fully
1155	* initialized before returning.
1156	* @param ppDevCfg Where to return the requested device config.
1157	*/
1158	static int drvHostAudioWasCacheLookupOrCreate(PDRVHOSTAUDIOWAS pThis, IMMDevice *pIDevice, PCPDMAUDIOSTREAMCFG pCfgReq,
1159	bool fOnWorker, PDRVHOSTAUDIOWASCACHEDEVCFG *ppDevCfg)
1160	{
1161	*ppDevCfg = NULL;
1162
1163	/*
1164	* Get the device ID so we can perform the lookup.
1165	*/
1166	int rc = VERR_AUDIO_STREAM_COULD_NOT_CREATE;
1167	LPWSTR pwszDevId = NULL;
1168	HRESULT hrc = pIDevice->GetId(&pwszDevId);
1169	if (SUCCEEDED(hrc))
1170	{
1171	size_t cwcDevId = RTUtf16Len(pwszDevId);
1172
1173	/*
1174	* The cache has two levels, so first the device entry.
1175	*/
1176	PDRVHOSTAUDIOWASCACHEDEV pDevEntry;
1177	RTCritSectEnter(&pThis->CritSectCache);
1178	RTListForEach(&pThis->CacheHead, pDevEntry, DRVHOSTAUDIOWASCACHEDEV, ListEntry)
1179	{
1180	if ( pDevEntry->cwcDevId == cwcDevId
1181	&& pDevEntry->enmDir == pCfgReq->enmDir
1182	&& RTUtf16Cmp(pDevEntry->wszDevId, pwszDevId) == 0)
1183	{
1184	CoTaskMemFree(pwszDevId);
1185	Log8Func(("Cache hit for device '%ls': %p\n", pDevEntry->wszDevId, pDevEntry));
1186	return drvHostAudioWasCacheLookupOrCreateConfig(pThis, pDevEntry, pCfgReq, fOnWorker, ppDevCfg);
1187	}
1188	}
1189	RTCritSectLeave(&pThis->CritSectCache);
1190
1191	/*
1192	* Device not in the cache, add it.
1193	*/
1194	pDevEntry = (PDRVHOSTAUDIOWASCACHEDEV)RTMemAllocZVar(RT_UOFFSETOF_DYN(DRVHOSTAUDIOWASCACHEDEV, wszDevId[cwcDevId + 1]));
1195	if (pDevEntry)
1196	{
1197	pIDevice->AddRef();
1198	pDevEntry->pIDevice = pIDevice;
1199	pDevEntry->enmDir = pCfgReq->enmDir;
1200	pDevEntry->cwcDevId = cwcDevId;
1201	#if 0
1202	pDevEntry->fSupportsAutoConvertPcm = -1;
1203	pDevEntry->fSupportsSrcDefaultQuality = -1;
1204	#endif
1205	RTListInit(&pDevEntry->ConfigList);
1206	memcpy(pDevEntry->wszDevId, pwszDevId, cwcDevId * sizeof(RTUTF16));
1207	pDevEntry->wszDevId[cwcDevId] = '\0';
1208
1209	CoTaskMemFree(pwszDevId);
1210	pwszDevId = NULL;
1211
1212	/*
1213	* Before adding the device, check that someone didn't race us adding it.
1214	*/
1215	RTCritSectEnter(&pThis->CritSectCache);
1216	PDRVHOSTAUDIOWASCACHEDEV pDevEntry2;
1217	RTListForEach(&pThis->CacheHead, pDevEntry2, DRVHOSTAUDIOWASCACHEDEV, ListEntry)
1218	{
1219	if ( pDevEntry2->cwcDevId == cwcDevId
1220	&& pDevEntry2->enmDir == pCfgReq->enmDir
1221	&& RTUtf16Cmp(pDevEntry2->wszDevId, pDevEntry->wszDevId) == 0)
1222	{
1223	pIDevice->Release();
1224	RTMemFree(pDevEntry);
1225	pDevEntry = NULL;
1226
1227	Log8Func(("Lost race adding device '%ls': %p\n", pDevEntry2->wszDevId, pDevEntry2));
1228	return drvHostAudioWasCacheLookupOrCreateConfig(pThis, pDevEntry2, pCfgReq, fOnWorker, ppDevCfg);
1229	}
1230	}
1231	RTListPrepend(&pThis->CacheHead, &pDevEntry->ListEntry);
1232
1233	Log8Func(("Added device '%ls' to cache: %p\n", pDevEntry->wszDevId, pDevEntry));
1234	return drvHostAudioWasCacheLookupOrCreateConfig(pThis, pDevEntry, pCfgReq, fOnWorker, ppDevCfg);
1235	}
1236	CoTaskMemFree(pwszDevId);
1237	}
1238	else
1239	LogRelMax(64, ("WasAPI: GetId failed (lookup): %Rhrc\n", hrc));
1240	return rc;
1241	}
1242
1243
1244	/**
1245	* Return the given config to the cache.
1246	*
1247	* @param pThis The WASAPI host audio driver instance data.
1248	* @param pDevCfg The device config to put back.
1249	*/
1250	static void drvHostAudioWasCachePutBack(PDRVHOSTAUDIOWAS pThis, PDRVHOSTAUDIOWASCACHEDEVCFG pDevCfg)
1251	{
1252	/*
1253	* Reset the audio client to see that it works and to make sure it's in a sensible state.
1254	*/
1255	HRESULT hrc = pDevCfg->pIAudioClient ? pDevCfg->pIAudioClient->Reset()
1256	: pDevCfg->rcSetup == VERR_AUDIO_STREAM_INIT_IN_PROGRESS ? S_OK : E_FAIL;
1257	if (SUCCEEDED(hrc))
1258	{
1259	Log8Func(("Putting %p/'%s' back\n", pDevCfg, pDevCfg->szProps));
1260	RTCritSectEnter(&pThis->CritSectCache);
1261	RTListAppend(&pDevCfg->pDevEntry->ConfigList, &pDevCfg->ListEntry);
1262	uint32_t const cEntries = pDevCfg->pDevEntry->enmDir == PDMAUDIODIR_IN ? pThis->cCacheEntriesIn : pThis->cCacheEntriesOut;
1263	RTCritSectLeave(&pThis->CritSectCache);
1264
1265	/* Trigger pruning if we're over the threshold. */
1266	if (cEntries > VBOX_WASAPI_MAX_TOTAL_CONFIG_ENTRIES)
1267	{
1268	LogFlowFunc(("Trigger cache pruning.\n"));
1269	int rc2 = pThis->pIHostAudioPort->pfnDoOnWorkerThread(pThis->pIHostAudioPort, NULL /pStream/,
1270	DRVHOSTAUDIOWAS_DO_PRUNE_CACHE, NULL /pvUser/);
1271	AssertRCStmt(rc2, drvHostAudioWasCachePrune(pThis));
1272	}
1273	}
1274	else
1275	{
1276	Log8Func(("IAudioClient::Reset failed (%Rhrc) on %p/'%s', destroying it.\n", hrc, pDevCfg, pDevCfg->szProps));
1277	drvHostAudioWasCacheDestroyDevConfig(pThis, pDevCfg);
1278	}
1279	}
1280
1281
1282	static void drvHostWasCacheConfigHinting(PDRVHOSTAUDIOWAS pThis, PPDMAUDIOSTREAMCFG pCfgReq, bool fOnWorker)
1283	{
1284	/*
1285	* Get the device.
1286	*/
1287	pThis->pNotifyClient->lockEnter();
1288	IMMDevice *pIDevice = pCfgReq->enmDir == PDMAUDIODIR_IN ? pThis->pIDeviceInput : pThis->pIDeviceOutput;
1289	if (pIDevice)
1290	pIDevice->AddRef();
1291	pThis->pNotifyClient->lockLeave();
1292	if (pIDevice)
1293	{
1294	/*
1295	* Look up the config and put it back.
1296	*/
1297	PDRVHOSTAUDIOWASCACHEDEVCFG pDevCfg = NULL;
1298	int rc = drvHostAudioWasCacheLookupOrCreate(pThis, pIDevice, pCfgReq, fOnWorker, &pDevCfg);
1299	LogFlowFunc(("pDevCfg=%p rc=%Rrc\n", pDevCfg, rc));
1300	if (pDevCfg && RT_SUCCESS(rc))
1301	drvHostAudioWasCachePutBack(pThis, pDevCfg);
1302	pIDevice->Release();
1303	}
1304	}
1305
1306
1307	/**
1308	* Prefills the cache.
1309	*
1310	* @param pThis The WASAPI host audio driver instance data.
1311	*/
1312	static void drvHostAudioWasCacheFill(PDRVHOSTAUDIOWAS pThis)
1313	{
1314	#if 0 /* we don't have the buffer config nor do we really know which frequences to expect */
1315	Log8Func(("enter\n"));
1316	struct
1317	{
1318	PCRTUTF16 pwszDevId;
1319	PDMAUDIODIR enmDir;
1320	} aToCache[] =
1321	{
1322	{ pThis->pwszInputDevId, PDMAUDIODIR_IN },
1323	{ pThis->pwszOutputDevId, PDMAUDIODIR_OUT }
1324	};
1325	for (unsigned i = 0; i < RT_ELEMENTS(aToCache); i++)
1326	{
1327	PCRTUTF16 pwszDevId = aToCache[i].pwszDevId;
1328	IMMDevice *pIDevice = NULL;
1329	HRESULT hrc;
1330	if (pwszDevId)
1331	hrc = pThis->pIEnumerator->GetDevice(pwszDevId, &pIDevice);
1332	else
1333	{
1334	hrc = pThis->pIEnumerator->GetDefaultAudioEndpoint(aToCache[i].enmDir == PDMAUDIODIR_IN ? eCapture : eRender,
1335	eMultimedia, &pIDevice);
1336	pwszDevId = aToCache[i].enmDir == PDMAUDIODIR_IN ? L"{Default-In}" : L"{Default-Out}";
1337	}
1338	if (SUCCEEDED(hrc))
1339	{
1340	PDMAUDIOSTREAMCFG Cfg = { aToCache[i].enmDir, { PDMAUDIOPLAYBACKDST_INVALID },
1341	PDMAUDIOPCMPROPS_INITIALIZER(2, true, 2, 44100, false) };
1342	Cfg.Backend.cFramesBufferSize = PDMAudioPropsMilliToFrames(&Cfg.Props, 300);
1343	PDRVHOSTAUDIOWASCACHEDEVCFG pDevCfg = drvHostAudioWasCacheLookupOrCreate(pThis, pIDevice, &Cfg);
1344	if (pDevCfg)
1345	drvHostAudioWasCachePutBack(pThis, pDevCfg);
1346
1347	pIDevice->Release();
1348	}
1349	else
1350	LogRelMax(64, ("WasAPI: Failed to open audio device '%ls' (pre-caching): %Rhrc\n", pwszDevId, hrc));
1351	}
1352	Log8Func(("leave\n"));
1353	#else
1354	RT_NOREF(pThis);
1355	#endif
1356	}
1357
1358
1359	/*********************************************************************************************************************************
1360	* Worker thread *
1361	*********************************************************************************************************************************/
1362	#if 0
1363
1364	/**
1365	* @callback_method_impl{FNRTTHREAD,
1366	* Asynchronous thread for setting up audio client configs.}
1367	*/
1368	static DECLCALLBACK(int) drvHostWasWorkerThread(RTTHREAD hThreadSelf, void *pvUser)
1369	{
1370	PDRVHOSTAUDIOWAS pThis = (PDRVHOSTAUDIOWAS)pvUser;
1371
1372	/*
1373	* We need to set the thread ID so others can post us thread messages.
1374	* And before we signal that we're ready, make sure we've got a message queue.
1375	*/
1376	pThis->idWorkerThread = GetCurrentThreadId();
1377	LogFunc(("idWorkerThread=%#x (%u)\n", pThis->idWorkerThread, pThis->idWorkerThread));
1378
1379	MSG Msg;
1380	PeekMessageW(&Msg, NULL, WM_USER, WM_USER, PM_NOREMOVE);
1381
1382	int rc = RTThreadUserSignal(hThreadSelf);
1383	AssertRC(rc);
1384
1385	/*
1386	* Message loop.
1387	*/
1388	BOOL fRet;
1389	while ((fRet = GetMessageW(&Msg, NULL, 0, 0)) != FALSE)
1390	{
1391	if (fRet != -1)
1392	{
1393	TranslateMessage(&Msg);
1394	Log9Func(("Msg: time=%u: msg=%#x l=%p w=%p for hwnd=%p\n", Msg.time, Msg.message, Msg.lParam, Msg.wParam, Msg.hwnd));
1395	switch (Msg.message)
1396	{
1397	case WM_DRVHOSTAUDIOWAS_PURGE_CACHE:
1398	{
1399	AssertMsgBreak(Msg.wParam == pThis->uWorkerThreadFixedParam, ("%p\n", Msg.wParam));
1400	AssertBreak(Msg.hwnd == NULL);
1401	AssertBreak(Msg.lParam == 0);
1402
1403	drvHostAudioWasCachePurge(pThis, false /fOnWorker/);
1404	break;
1405	}
1406
1407	default:
1408	break;
1409	}
1410	DispatchMessageW(&Msg);
1411	}
1412	else
1413	AssertMsgFailed(("GetLastError()=%u\n", GetLastError()));
1414	}
1415
1416	LogFlowFunc(("Pre-quit cache purge...\n"));
1417	drvHostAudioWasCachePurge(pThis, false /fOnWorker/);
1418
1419	LogFunc(("Quits\n"));
1420	return VINF_SUCCESS;
1421	}
1422	#endif
1423
1424
1425	/*********************************************************************************************************************************
1426	* PDMIHOSTAUDIO *
1427	*********************************************************************************************************************************/
1428
1429	/**
1430	* @interface_method_impl{PDMIHOSTAUDIO,pfnGetConfig}
1431	*/
1432	static DECLCALLBACK(int) drvHostAudioWasHA_GetConfig(PPDMIHOSTAUDIO pInterface, PPDMAUDIOBACKENDCFG pBackendCfg)
1433	{
1434	RT_NOREF(pInterface);
1435	AssertPtrReturn(pInterface, VERR_INVALID_POINTER);
1436	AssertPtrReturn(pBackendCfg, VERR_INVALID_POINTER);
1437
1438
1439	/*
1440	* Fill in the config structure.
1441	*/
1442	RTStrCopy(pBackendCfg->szName, sizeof(pBackendCfg->szName), "WasAPI");
1443	pBackendCfg->cbStream = sizeof(DRVHOSTAUDIOWASSTREAM);
1444	pBackendCfg->fFlags = PDMAUDIOBACKEND_F_ASYNC_HINT;
1445	pBackendCfg->cMaxStreamsIn = UINT32_MAX;
1446	pBackendCfg->cMaxStreamsOut = UINT32_MAX;
1447
1448	return VINF_SUCCESS;
1449	}
1450
1451
1452	/**
1453	* Queries information for @a pDevice and adds an entry to the enumeration.
1454	*
1455	* @returns VBox status code.
1456	* @param pDevEnm The enumeration to add the device to.
1457	* @param pIDevice The device.
1458	* @param enmType The type of device.
1459	* @param fDefault Whether it's the default device.
1460	*/
1461	static int drvHostWasEnumAddDev(PPDMAUDIOHOSTENUM pDevEnm, IMMDevice *pIDevice, EDataFlow enmType, bool fDefault)
1462	{
1463	int rc = VINF_SUCCESS; /* ignore most errors */
1464	RT_NOREF(fDefault); /** @todo default device marking/skipping. */
1465
1466	/*
1467	* Gather the necessary properties.
1468	*/
1469	IPropertyStore *pProperties = NULL;
1470	HRESULT hrc = pIDevice->OpenPropertyStore(STGM_READ, &pProperties);
1471	if (SUCCEEDED(hrc))
1472	{
1473	/* Get the friendly name (string). */
1474	PROPVARIANT VarName;
1475	PropVariantInit(&VarName);
1476	hrc = pProperties->GetValue(PKEY_Device_FriendlyName, &VarName);
1477	if (SUCCEEDED(hrc))
1478	{
1479	/* Get the device ID (string). */
1480	LPWSTR pwszDevId = NULL;
1481	hrc = pIDevice->GetId(&pwszDevId);
1482	if (SUCCEEDED(hrc))
1483	{
1484	size_t const cwcDevId = RTUtf16Len(pwszDevId);
1485
1486	/* Get the device format (blob). */
1487	PROPVARIANT VarFormat;
1488	PropVariantInit(&VarFormat);
1489	hrc = pProperties->GetValue(PKEY_AudioEngine_DeviceFormat, &VarFormat);
1490	if (SUCCEEDED(hrc))
1491	{
1492	WAVEFORMATEX const * const pFormat = (WAVEFORMATEX const *)VarFormat.blob.pBlobData;
1493	AssertPtr(pFormat);
1494
1495	/*
1496	* Create a enumeration entry for it.
1497	*/
1498	size_t const cbDev = RT_ALIGN_Z( RT_OFFSETOF(DRVHOSTAUDIOWASDEV, wszDevId)
1499	+ (cwcDevId + 1) * sizeof(RTUTF16),
1500	64);
1501	PDRVHOSTAUDIOWASDEV pDev = (PDRVHOSTAUDIOWASDEV)PDMAudioHostDevAlloc(cbDev);
1502	if (pDev)
1503	{
1504	pDev->Core.enmType = PDMAUDIODEVICETYPE_BUILTIN;
1505	pDev->Core.enmUsage = enmType == eRender ? PDMAUDIODIR_OUT : PDMAUDIODIR_IN;
1506	if (fDefault)
1507	pDev->Core.fFlags = enmType == eRender ? PDMAUDIOHOSTDEV_F_DEFAULT_OUT : PDMAUDIOHOSTDEV_F_DEFAULT_IN;
1508	if (enmType == eRender)
1509	pDev->Core.cMaxOutputChannels = pFormat->nChannels;
1510	else
1511	pDev->Core.cMaxInputChannels = pFormat->nChannels;
1512
1513	memcpy(pDev->wszDevId, pwszDevId, cwcDevId * sizeof(RTUTF16));
1514	pDev->wszDevId[cwcDevId] = '\0';
1515
1516	char *pszName;
1517	rc = RTUtf16ToUtf8(VarName.pwszVal, &pszName);
1518	if (RT_SUCCESS(rc))
1519	{
1520	RTStrCopy(pDev->Core.szName, sizeof(pDev->Core.szName), pszName);
1521	RTStrFree(pszName);
1522
1523	rc = RTUtf16ToUtf8(pDev->wszDevId, &pDev->Core.pszId);
1524	if (RT_SUCCESS(rc))
1525	{
1526	pDev->Core.fFlags \|= PDMAUDIOHOSTDEV_F_ID_ALLOC;
1527	PDMAudioHostEnumAppend(pDevEnm, &pDev->Core);
1528	}
1529	else
1530	PDMAudioHostDevFree(&pDev->Core);
1531	}
1532	else
1533	PDMAudioHostDevFree(&pDev->Core);
1534	}
1535	else
1536	rc = VERR_NO_MEMORY;
1537	PropVariantClear(&VarFormat);
1538	}
1539	else
1540	LogFunc(("Failed to get PKEY_AudioEngine_DeviceFormat: %Rhrc\n", hrc));
1541	CoTaskMemFree(pwszDevId);
1542	}
1543	else
1544	LogFunc(("Failed to get the device ID: %Rhrc\n", hrc));
1545	PropVariantClear(&VarName);
1546	}
1547	else
1548	LogFunc(("Failed to get PKEY_Device_FriendlyName: %Rhrc\n", hrc));
1549	pProperties->Release();
1550	}
1551	else
1552	LogFunc(("OpenPropertyStore failed: %Rhrc\n", hrc));
1553
1554	if (hrc == E_OUTOFMEMORY && RT_SUCCESS_NP(rc))
1555	rc = VERR_NO_MEMORY;
1556	return rc;
1557	}
1558
1559
1560	/**
1561	* Does a (Re-)enumeration of the host's playback + capturing devices.
1562	*
1563	* @return VBox status code.
1564	* @param pThis The WASAPI host audio driver instance data.
1565	* @param pDevEnm Where to store the enumerated devices.
1566	*/
1567	static int drvHostWasEnumerateDevices(PDRVHOSTAUDIOWAS pThis, PPDMAUDIOHOSTENUM pDevEnm)
1568	{
1569	LogRel2(("WasAPI: Enumerating devices ...\n"));
1570
1571	int rc = VINF_SUCCESS;
1572	for (unsigned idxPass = 0; idxPass < 2 && RT_SUCCESS(rc); idxPass++)
1573	{
1574	EDataFlow const enmType = idxPass == 0 ? EDataFlow::eRender : EDataFlow::eCapture;
1575
1576	/* Get the default device first. */
1577	IMMDevice *pIDefaultDevice = NULL;
1578	HRESULT hrc = pThis->pIEnumerator->GetDefaultAudioEndpoint(enmType, eMultimedia, &pIDefaultDevice);
1579	if (SUCCEEDED(hrc))
1580	rc = drvHostWasEnumAddDev(pDevEnm, pIDefaultDevice, enmType, true);
1581	else
1582	pIDefaultDevice = NULL;
1583
1584	/* Enumerate the devices. */
1585	IMMDeviceCollection *pCollection = NULL;
1586	hrc = pThis->pIEnumerator->EnumAudioEndpoints(enmType, DEVICE_STATE_ACTIVE /\| DEVICE_STATE_UNPLUGGED?/, &pCollection);
1587	if (SUCCEEDED(hrc) && pCollection != NULL)
1588	{
1589	UINT cDevices = 0;
1590	hrc = pCollection->GetCount(&cDevices);
1591	if (SUCCEEDED(hrc))
1592	{
1593	for (UINT idxDevice = 0; idxDevice < cDevices && RT_SUCCESS(rc); idxDevice++)
1594	{
1595	IMMDevice *pIDevice = NULL;
1596	hrc = pCollection->Item(idxDevice, &pIDevice);
1597	if (SUCCEEDED(hrc) && pIDevice)
1598	{
1599	if (pIDevice != pIDefaultDevice)
1600	rc = drvHostWasEnumAddDev(pDevEnm, pIDevice, enmType, false);
1601	pIDevice->Release();
1602	}
1603	}
1604	}
1605	pCollection->Release();
1606	}
1607	else
1608	LogRelMax(10, ("EnumAudioEndpoints(%s) failed: %Rhrc\n", idxPass == 0 ? "output" : "input", hrc));
1609
1610	if (pIDefaultDevice)
1611	pIDefaultDevice->Release();
1612	}
1613
1614	LogRel2(("WasAPI: Enumerating devices done - %u device (%Rrc)\n", pDevEnm->cDevices, rc));
1615	return rc;
1616	}
1617
1618
1619	/**
1620	* @interface_method_impl{PDMIHOSTAUDIO,pfnGetDevices}
1621	*/
1622	static DECLCALLBACK(int) drvHostAudioWasHA_GetDevices(PPDMIHOSTAUDIO pInterface, PPDMAUDIOHOSTENUM pDeviceEnum)
1623	{
1624	PDRVHOSTAUDIOWAS pThis = RT_FROM_MEMBER(pInterface, DRVHOSTAUDIOWAS, IHostAudio);
1625	AssertPtrReturn(pDeviceEnum, VERR_INVALID_POINTER);
1626
1627	PDMAudioHostEnumInit(pDeviceEnum);
1628	int rc = drvHostWasEnumerateDevices(pThis, pDeviceEnum);
1629	if (RT_FAILURE(rc))
1630	PDMAudioHostEnumDelete(pDeviceEnum);
1631
1632	LogFlowFunc(("Returning %Rrc\n", rc));
1633	return rc;
1634	}
1635
1636
1637	/**
1638	* @interface_method_impl{PDMIHOSTAUDIO,pfnGetStatus}
1639	*/
1640	static DECLCALLBACK(PDMAUDIOBACKENDSTS) drvHostAudioWasHA_GetStatus(PPDMIHOSTAUDIO pInterface, PDMAUDIODIR enmDir)
1641	{
1642	RT_NOREF(pInterface, enmDir);
1643	return PDMAUDIOBACKENDSTS_RUNNING;
1644	}
1645
1646
1647	/**
1648	* Performs the actual switching of device config.
1649	*
1650	* Worker for drvHostAudioWasDoStreamDevSwitch() and
1651	* drvHostAudioWasHA_StreamNotifyDeviceChanged().
1652	*/
1653	static void drvHostAudioWasCompleteStreamDevSwitch(PDRVHOSTAUDIOWAS pThis, PDRVHOSTAUDIOWASSTREAM pStreamWas,
1654	PDRVHOSTAUDIOWASCACHEDEVCFG pDevCfg)
1655	{
1656	RTCritSectEnter(&pStreamWas->CritSect);
1657
1658	/* Do the switch. */
1659	PDRVHOSTAUDIOWASCACHEDEVCFG pDevCfgOld = pStreamWas->pDevCfg;
1660	pStreamWas->pDevCfg = pDevCfg;
1661
1662	/* The new stream is neither started nor draining. */
1663	pStreamWas->fStarted = false;
1664	pStreamWas->fDraining = false;
1665
1666	/* Device switching is done now. */
1667	pStreamWas->fSwitchingDevice = false;
1668
1669	/* Stop the old stream or Reset() will fail when putting it back into the cache. */
1670	if (pStreamWas->fEnabled && pDevCfgOld->pIAudioClient)
1671	pDevCfgOld->pIAudioClient->Stop();
1672
1673	RTCritSectLeave(&pStreamWas->CritSect);
1674
1675	/* Notify DrvAudio. */
1676	pThis->pIHostAudioPort->pfnStreamNotifyDeviceChanged(pThis->pIHostAudioPort, &pStreamWas->Core, false /fReInit/);
1677
1678	/* Put the old config back into the cache. */
1679	drvHostAudioWasCachePutBack(pThis, pDevCfgOld);
1680
1681	LogFlowFunc(("returns with '%s' state: %s\n", pStreamWas->Cfg.szName, drvHostWasStreamStatusString(pStreamWas) ));
1682	}
1683
1684
1685	/**
1686	* Called on a worker thread to initialize a new device config and switch the
1687	* given stream to using it.
1688	*
1689	* @sa drvHostAudioWasHA_StreamNotifyDeviceChanged
1690	*/
1691	static void drvHostAudioWasDoStreamDevSwitch(PDRVHOSTAUDIOWAS pThis, PDRVHOSTAUDIOWASSTREAM pStreamWas,
1692	PDRVHOSTAUDIOWASCACHEDEVCFG pDevCfg)
1693	{
1694	/*
1695	* Do the initializing.
1696	*/
1697	int rc = drvHostAudioWasCacheInitConfig(pDevCfg);
1698	if (RT_SUCCESS(rc))
1699	drvHostAudioWasCompleteStreamDevSwitch(pThis, pStreamWas, pDevCfg);
1700	else
1701	{
1702	LogRelMax(64, ("WasAPI: Failed to set up new device config '%ls:%s' for stream '%s': %Rrc\n",
1703	pDevCfg->pDevEntry->wszDevId, pDevCfg->szProps, pStreamWas->Cfg.szName, rc));
1704	drvHostAudioWasCacheDestroyDevConfig(pThis, pDevCfg);
1705	pThis->pIHostAudioPort->pfnStreamNotifyDeviceChanged(pThis->pIHostAudioPort, &pStreamWas->Core, true /fReInit/);
1706	}
1707	}
1708
1709
1710	/**
1711	* @interface_method_impl{PDMIHOSTAUDIO,pfnDoOnWorkerThread}
1712	*/
1713	static DECLCALLBACK(void) drvHostAudioWasHA_DoOnWorkerThread(PPDMIHOSTAUDIO pInterface, PPDMAUDIOBACKENDSTREAM pStream,
1714	uintptr_t uUser, void *pvUser)
1715	{
1716	PDRVHOSTAUDIOWAS pThis = RT_FROM_MEMBER(pInterface, DRVHOSTAUDIOWAS, IHostAudio);
1717	LogFlowFunc(("uUser=%#zx pStream=%p pvUser=%p\n", uUser, pStream, pvUser));
1718
1719	switch (uUser)
1720	{
1721	case DRVHOSTAUDIOWAS_DO_PURGE_CACHE:
1722	Assert(pStream == NULL);
1723	Assert(pvUser == NULL);
1724	drvHostAudioWasCachePurge(pThis, true /fOnWorker/);
1725	break;
1726
1727	case DRVHOSTAUDIOWAS_DO_PRUNE_CACHE:
1728	Assert(pStream == NULL);
1729	Assert(pvUser == NULL);
1730	drvHostAudioWasCachePrune(pThis);
1731	break;
1732
1733	case DRVHOSTAUDIOWAS_DO_STREAM_DEV_SWITCH:
1734	AssertPtr(pStream);
1735	AssertPtr(pvUser);
1736	drvHostAudioWasDoStreamDevSwitch(pThis, (PDRVHOSTAUDIOWASSTREAM)pStream, (PDRVHOSTAUDIOWASCACHEDEVCFG)pvUser);
1737	break;
1738
1739	default:
1740	AssertMsgFailedBreak(("%#zx\n", uUser));
1741	}
1742	}
1743
1744
1745	/**
1746	* @interface_method_impl{PDMIHOSTAUDIO,pfnStreamConfigHint}
1747	*
1748	* @note This is called on a DrvAudio worker thread.
1749	*/
1750	static DECLCALLBACK(void) drvHostAudioWasHA_StreamConfigHint(PPDMIHOSTAUDIO pInterface, PPDMAUDIOSTREAMCFG pCfg)
1751	{
1752	#if 0 /* disable to test async stream creation. */
1753	PDRVHOSTAUDIOWAS pThis = RT_FROM_MEMBER(pInterface, DRVHOSTAUDIOWAS, IHostAudio);
1754	LogFlowFunc(("pCfg=%p\n", pCfg));
1755
1756	drvHostWasCacheConfigHinting(pThis, pCfg);
1757	#else
1758	RT_NOREF(pInterface, pCfg);
1759	#endif
1760	}
1761
1762
1763	/**
1764	* @interface_method_impl{PDMIHOSTAUDIO,pfnStreamCreate}
1765	*/
1766	static DECLCALLBACK(int) drvHostAudioWasHA_StreamCreate(PPDMIHOSTAUDIO pInterface, PPDMAUDIOBACKENDSTREAM pStream,
1767	PPDMAUDIOSTREAMCFG pCfgReq, PPDMAUDIOSTREAMCFG pCfgAcq)
1768	{
1769	PDRVHOSTAUDIOWAS pThis = RT_FROM_MEMBER(pInterface, DRVHOSTAUDIOWAS, IHostAudio);
1770	PDRVHOSTAUDIOWASSTREAM pStreamWas = (PDRVHOSTAUDIOWASSTREAM)pStream;
1771	AssertPtrReturn(pStreamWas, VERR_INVALID_POINTER);
1772	AssertPtrReturn(pCfgReq, VERR_INVALID_POINTER);
1773	AssertPtrReturn(pCfgAcq, VERR_INVALID_POINTER);
1774	AssertReturn(pCfgReq->enmDir == PDMAUDIODIR_IN \|\| pCfgReq->enmDir == PDMAUDIODIR_OUT, VERR_INVALID_PARAMETER);
1775	Assert(PDMAudioStrmCfgEquals(pCfgReq, pCfgAcq));
1776
1777	const char * const pszStreamType = pCfgReq->enmDir == PDMAUDIODIR_IN ? "capture" : "playback"; RT_NOREF(pszStreamType);
1778	LogFlowFunc(("enmPath=%s '%s'\n", PDMAudioPathGetName(pCfgReq->enmPath), pCfgReq->szName));
1779	#if defined(RTLOG_REL_ENABLED) \|\| defined(LOG_ENABLED)
1780	char szTmp[64];
1781	#endif
1782	LogRel2(("WasAPI: Opening %s stream '%s' (%s)\n", pCfgReq->szName, pszStreamType,
1783	PDMAudioPropsToString(&pCfgReq->Props, szTmp, sizeof(szTmp))));
1784
1785	RTListInit(&pStreamWas->ListEntry);
1786
1787	/*
1788	* Do configuration conversion.
1789	*/
1790	WAVEFORMATEX WaveFmtX;
1791	drvHostAudioWasWaveFmtExFromProps(&pCfgReq->Props, &WaveFmtX);
1792	LogRel2(("WasAPI: Requested %s format for '%s':\n"
1793	"WasAPI: wFormatTag = %RU16\n"
1794	"WasAPI: nChannels = %RU16\n"
1795	"WasAPI: nSamplesPerSec = %RU32\n"
1796	"WasAPI: nAvgBytesPerSec = %RU32\n"
1797	"WasAPI: nBlockAlign = %RU16\n"
1798	"WasAPI: wBitsPerSample = %RU16\n"
1799	"WasAPI: cbSize = %RU16\n"
1800	"WasAPI: cBufferSizeInNtTicks = %RU64\n",
1801	pszStreamType, pCfgReq->szName, WaveFmtX.wFormatTag, WaveFmtX.nChannels, WaveFmtX.nSamplesPerSec,
1802	WaveFmtX.nAvgBytesPerSec, WaveFmtX.nBlockAlign, WaveFmtX.wBitsPerSample, WaveFmtX.cbSize,
1803	PDMAudioPropsFramesToNtTicks(&pCfgReq->Props, pCfgReq->Backend.cFramesBufferSize) ));
1804
1805	/*
1806	* Get the device we're supposed to use.
1807	* (We cache this as it takes ~2ms to get the default device on a random W10 19042 system.)
1808	*/
1809	pThis->pNotifyClient->lockEnter();
1810	IMMDevice *pIDevice = pCfgReq->enmDir == PDMAUDIODIR_IN ? pThis->pIDeviceInput : pThis->pIDeviceOutput;
1811	if (pIDevice)
1812	pIDevice->AddRef();
1813	pThis->pNotifyClient->lockLeave();
1814
1815	PRTUTF16 pwszDevId = pCfgReq->enmDir == PDMAUDIODIR_IN ? pThis->pwszInputDevId : pThis->pwszOutputDevId;
1816	PRTUTF16 const pwszDevIdDesc = pwszDevId ? pwszDevId : pCfgReq->enmDir == PDMAUDIODIR_IN ? L"{Default-In}" : L"{Default-Out}";
1817	if (!pIDevice)
1818	{
1819	/** @todo we can eliminate this too... */
1820	HRESULT hrc;
1821	if (pwszDevId)
1822	hrc = pThis->pIEnumerator->GetDevice(pwszDevId, &pIDevice);
1823	else
1824	hrc = pThis->pIEnumerator->GetDefaultAudioEndpoint(pCfgReq->enmDir == PDMAUDIODIR_IN ? eCapture : eRender,
1825	eMultimedia, &pIDevice);
1826	LogFlowFunc(("Got device %p (%Rhrc)\n", pIDevice, hrc));
1827	if (FAILED(hrc))
1828	{
1829	LogRelMax(64, ("WasAPI: Failed to open audio %s device '%ls': %Rhrc\n", pszStreamType, pwszDevIdDesc, hrc));
1830	return VERR_AUDIO_STREAM_COULD_NOT_CREATE;
1831	}
1832	}
1833
1834	/*
1835	* Ask the cache to retrieve or instantiate the requested configuration.
1836	*/
1837	/** @todo make it return a status code too and retry if the default device
1838	* was invalidated/changed while we where working on it here. */
1839	PDRVHOSTAUDIOWASCACHEDEVCFG pDevCfg = NULL;
1840	int rc = drvHostAudioWasCacheLookupOrCreate(pThis, pIDevice, pCfgReq, false /fOnWorker/, &pDevCfg);
1841
1842	pIDevice->Release();
1843	pIDevice = NULL;
1844
1845	if (pDevCfg && RT_SUCCESS(rc))
1846	{
1847	pStreamWas->pDevCfg = pDevCfg;
1848
1849	pCfgAcq->Props = pDevCfg->Props;
1850	pCfgAcq->Backend.cFramesBufferSize = pDevCfg->cFramesBufferSize;
1851	pCfgAcq->Backend.cFramesPeriod = pDevCfg->cFramesPeriod;
1852	pCfgAcq->Backend.cFramesPreBuffering = pCfgReq->Backend.cFramesPreBuffering * pDevCfg->cFramesBufferSize
1853	/ RT_MAX(pCfgReq->Backend.cFramesBufferSize, 1);
1854
1855	PDMAudioStrmCfgCopy(&pStreamWas->Cfg, pCfgAcq);
1856
1857	/* Finally, the critical section. */
1858	int rc2 = RTCritSectInit(&pStreamWas->CritSect);
1859	if (RT_SUCCESS(rc2))
1860	{
1861	RTCritSectRwEnterExcl(&pThis->CritSectStreamList);
1862	RTListAppend(&pThis->StreamHead, &pStreamWas->ListEntry);
1863	RTCritSectRwLeaveExcl(&pThis->CritSectStreamList);
1864
1865	if (pStreamWas->pDevCfg->pIAudioClient != NULL)
1866	{
1867	LogFlowFunc(("returns VINF_SUCCESS\n", rc));
1868	return VINF_SUCCESS;
1869	}
1870	LogFlowFunc(("returns VINF_AUDIO_STREAM_ASYNC_INIT_NEEDED\n", rc));
1871	return VINF_AUDIO_STREAM_ASYNC_INIT_NEEDED;
1872	}
1873
1874	LogRelMax(64, ("WasAPI: Failed to create critical section for stream.\n"));
1875	drvHostAudioWasCachePutBack(pThis, pDevCfg);
1876	pStreamWas->pDevCfg = NULL;
1877	}
1878	else
1879	LogRelMax(64, ("WasAPI: Failed to setup %s on audio device '%ls' (%Rrc).\n", pszStreamType, pwszDevIdDesc, rc));
1880
1881	LogFlowFunc(("returns %Rrc\n", rc));
1882	return rc;
1883	}
1884
1885
1886	/**
1887	* @interface_method_impl{PDMIHOSTAUDIO,pfnStreamInitAsync}
1888	*/
1889	static DECLCALLBACK(int) drvHostAudioWasHA_StreamInitAsync(PPDMIHOSTAUDIO pInterface, PPDMAUDIOBACKENDSTREAM pStream,
1890	bool fDestroyed)
1891	{
1892	RT_NOREF(pInterface);
1893	PDRVHOSTAUDIOWASSTREAM pStreamWas = (PDRVHOSTAUDIOWASSTREAM)pStream;
1894	AssertPtrReturn(pStreamWas, VERR_INVALID_POINTER);
1895	LogFlowFunc(("Stream '%s'%s\n", pStreamWas->Cfg.szName, fDestroyed ? " - destroyed!" : ""));
1896
1897	/*
1898	* Assert sane preconditions for this call.
1899	*/
1900	AssertPtrReturn(pStreamWas->Core.pStream, VERR_INTERNAL_ERROR);
1901	AssertPtrReturn(pStreamWas->pDevCfg, VERR_INTERNAL_ERROR_2);
1902	AssertPtrReturn(pStreamWas->pDevCfg->pDevEntry, VERR_INTERNAL_ERROR_3);
1903	AssertPtrReturn(pStreamWas->pDevCfg->pDevEntry->pIDevice, VERR_INTERNAL_ERROR_4);
1904	AssertReturn(pStreamWas->pDevCfg->pDevEntry->enmDir == pStreamWas->Core.pStream->enmDir, VERR_INTERNAL_ERROR_4);
1905	AssertReturn(pStreamWas->pDevCfg->pIAudioClient == NULL, VERR_INTERNAL_ERROR_5);
1906	AssertReturn(pStreamWas->pDevCfg->pIAudioRenderClient == NULL, VERR_INTERNAL_ERROR_5);
1907	AssertReturn(pStreamWas->pDevCfg->pIAudioCaptureClient == NULL, VERR_INTERNAL_ERROR_5);
1908
1909	/*
1910	* Do the job.
1911	*/
1912	int rc;
1913	if (!fDestroyed)
1914	rc = drvHostAudioWasCacheInitConfig(pStreamWas->pDevCfg);
1915	else
1916	{
1917	AssertReturn(pStreamWas->pDevCfg->rcSetup == VERR_AUDIO_STREAM_INIT_IN_PROGRESS, VERR_INTERNAL_ERROR_2);
1918	pStreamWas->pDevCfg->rcSetup = VERR_WRONG_ORDER;
1919	rc = VINF_SUCCESS;
1920	}
1921
1922	LogFlowFunc(("returns %Rrc (%s)\n", rc, pStreamWas->Cfg.szName));
1923	return rc;
1924	}
1925
1926
1927	/**
1928	* @interface_method_impl{PDMIHOSTAUDIO,pfnStreamDestroy}
1929	*/
1930	static DECLCALLBACK(int) drvHostAudioWasHA_StreamDestroy(PPDMIHOSTAUDIO pInterface, PPDMAUDIOBACKENDSTREAM pStream,
1931	bool fImmediate)
1932	{
1933	PDRVHOSTAUDIOWAS pThis = RT_FROM_MEMBER(pInterface, DRVHOSTAUDIOWAS, IHostAudio);
1934	PDRVHOSTAUDIOWASSTREAM pStreamWas = (PDRVHOSTAUDIOWASSTREAM)pStream;
1935	AssertPtrReturn(pStreamWas, VERR_INVALID_POINTER);
1936	LogFlowFunc(("Stream '%s'\n", pStreamWas->Cfg.szName));
1937	RT_NOREF(fImmediate);
1938	HRESULT hrc;
1939
1940	if (RTCritSectIsInitialized(&pStreamWas->CritSect))
1941	{
1942	RTCritSectRwEnterExcl(&pThis->CritSectStreamList);
1943	RTListNodeRemove(&pStreamWas->ListEntry);
1944	RTCritSectRwLeaveExcl(&pThis->CritSectStreamList);
1945
1946	RTCritSectDelete(&pStreamWas->CritSect);
1947	}
1948
1949	if (pStreamWas->fStarted && pStreamWas->pDevCfg && pStreamWas->pDevCfg->pIAudioClient)
1950	{
1951	hrc = pStreamWas->pDevCfg->pIAudioClient->Stop();
1952	LogFunc(("Stop('%s') -> %Rhrc\n", pStreamWas->Cfg.szName, hrc));
1953	pStreamWas->fStarted = false;
1954	}
1955
1956	if (pStreamWas->cFramesCaptureToRelease)
1957	{
1958	hrc = pStreamWas->pDevCfg->pIAudioCaptureClient->ReleaseBuffer(0);
1959	Log4Func(("Releasing capture buffer (%#x frames): %Rhrc\n", pStreamWas->cFramesCaptureToRelease, hrc));
1960	pStreamWas->cFramesCaptureToRelease = 0;
1961	pStreamWas->pbCapture = NULL;
1962	pStreamWas->cbCapture = 0;
1963	}
1964
1965	if (pStreamWas->pDevCfg)
1966	{
1967	drvHostAudioWasCachePutBack(pThis, pStreamWas->pDevCfg);
1968	pStreamWas->pDevCfg = NULL;
1969	}
1970
1971	LogFlowFunc(("returns\n"));
1972	return VINF_SUCCESS;
1973	}
1974
1975
1976	/**
1977	* @interface_method_impl{PDMIHOSTAUDIO,pfnStreamNotifyDeviceChanged}
1978	*/
1979	static DECLCALLBACK(void) drvHostAudioWasHA_StreamNotifyDeviceChanged(PPDMIHOSTAUDIO pInterface,
1980	PPDMAUDIOBACKENDSTREAM pStream, void *pvUser)
1981	{
1982	PDRVHOSTAUDIOWAS pThis = RT_FROM_MEMBER(pInterface, DRVHOSTAUDIOWAS, IHostAudio);
1983	PDRVHOSTAUDIOWASSTREAM pStreamWas = (PDRVHOSTAUDIOWASSTREAM)pStream;
1984	LogFlowFunc(("pStreamWas=%p (%s)\n", pStreamWas, pStreamWas->Cfg.szName));
1985	RT_NOREF(pvUser);
1986
1987	/*
1988	* See if we've got a cached config for the new device around.
1989	* We ignore this entirely, for now at least, if the device was
1990	* disconnected and there is no replacement.
1991	*/
1992	pThis->pNotifyClient->lockEnter();
1993	IMMDevice *pIDevice = pStreamWas->Cfg.enmDir == PDMAUDIODIR_IN ? pThis->pIDeviceInput : pThis->pIDeviceOutput;
1994	if (pIDevice)
1995	pIDevice->AddRef();
1996	pThis->pNotifyClient->lockLeave();
1997	if (pIDevice)
1998	{
1999	PDRVHOSTAUDIOWASCACHEDEVCFG pDevCfg = NULL;
2000	int rc = drvHostAudioWasCacheLookupOrCreate(pThis, pIDevice, &pStreamWas->Cfg, false /fOnWorker/, &pDevCfg);
2001
2002	pIDevice->Release();
2003	pIDevice = NULL;
2004
2005	/*
2006	* If we have a working audio client, just do the switch.
2007	*/
2008	if (RT_SUCCESS(rc) && pDevCfg->pIAudioClient)
2009	{
2010	LogFlowFunc(("New device config is ready already!\n"));
2011	Assert(rc == VINF_SUCCESS);
2012	drvHostAudioWasCompleteStreamDevSwitch(pThis, pStreamWas, pDevCfg);
2013	}
2014	/*
2015	* Otherwise create one asynchronously on a worker thread.
2016	*/
2017	else if (RT_SUCCESS(rc))
2018	{
2019	LogFlowFunc(("New device config needs async init ...\n"));
2020	Assert(rc == VINF_AUDIO_STREAM_ASYNC_INIT_NEEDED);
2021
2022	RTCritSectEnter(&pStreamWas->CritSect);
2023	pStreamWas->fSwitchingDevice = true;
2024	RTCritSectLeave(&pStreamWas->CritSect);
2025
2026	pThis->pIHostAudioPort->pfnStreamNotifyPreparingDeviceSwitch(pThis->pIHostAudioPort, &pStreamWas->Core);
2027
2028	rc = pThis->pIHostAudioPort->pfnDoOnWorkerThread(pThis->pIHostAudioPort, &pStreamWas->Core,
2029	DRVHOSTAUDIOWAS_DO_STREAM_DEV_SWITCH, pDevCfg);
2030	AssertRCStmt(rc, drvHostAudioWasDoStreamDevSwitch(pThis, pStreamWas, pDevCfg));
2031	}
2032	else
2033	{
2034	LogRelMax(64, ("WasAPI: Failed to create new device config '%ls:%s' for stream '%s': %Rrc\n",
2035	pDevCfg->pDevEntry->wszDevId, pDevCfg->szProps, pStreamWas->Cfg.szName, rc));
2036
2037	pThis->pIHostAudioPort->pfnStreamNotifyDeviceChanged(pThis->pIHostAudioPort, &pStreamWas->Core, true /fReInit/);
2038	}
2039	}
2040	else
2041	LogFlowFunc(("no new device, leaving it as-is\n"));
2042	}
2043
2044
2045	/**
2046	* Wrapper for starting a stream.
2047	*
2048	* @returns VBox status code.
2049	* @param pThis The WASAPI host audio driver instance data.
2050	* @param pStreamWas The stream.
2051	* @param pszOperation The operation we're doing.
2052	*/
2053	static int drvHostAudioWasStreamStartWorker(PDRVHOSTAUDIOWAS pThis, PDRVHOSTAUDIOWASSTREAM pStreamWas, const char *pszOperation)
2054	{
2055	HRESULT hrc = pStreamWas->pDevCfg->pIAudioClient->Start();
2056	LogFlow(("%s: Start(%s) returns %Rhrc\n", pszOperation, pStreamWas->Cfg.szName, hrc));
2057	AssertStmt(hrc != AUDCLNT_E_NOT_STOPPED, hrc = S_OK);
2058	if (SUCCEEDED(hrc))
2059	{
2060	pStreamWas->fStarted = true;
2061	return VINF_SUCCESS;
2062	}
2063
2064	/** @todo try re-setup the stuff on AUDCLNT_E_DEVICEINVALIDATED.
2065	* Need some way of telling the caller (e.g. playback, capture) so they can
2066	* retry what they're doing */
2067	RT_NOREF(pThis);
2068
2069	pStreamWas->fStarted = false;
2070	LogRelMax(64, ("WasAPI: Starting '%s' failed (%s): %Rhrc\n", pStreamWas->Cfg.szName, pszOperation, hrc));
2071	return VERR_AUDIO_STREAM_NOT_READY;
2072	}
2073
2074
2075	/**
2076	* @ interface_method_impl{PDMIHOSTAUDIO,pfnStreamEnable}
2077	*/
2078	static DECLCALLBACK(int) drvHostAudioWasHA_StreamEnable(PPDMIHOSTAUDIO pInterface, PPDMAUDIOBACKENDSTREAM pStream)
2079	{
2080	PDRVHOSTAUDIOWAS pThis = RT_FROM_MEMBER(pInterface, DRVHOSTAUDIOWAS, IHostAudio);
2081	PDRVHOSTAUDIOWASSTREAM pStreamWas = (PDRVHOSTAUDIOWASSTREAM)pStream;
2082	LogFlowFunc(("Stream '%s' {%s}\n", pStreamWas->Cfg.szName, drvHostWasStreamStatusString(pStreamWas)));
2083	HRESULT hrc;
2084	RTCritSectEnter(&pStreamWas->CritSect);
2085
2086	Assert(!pStreamWas->fEnabled);
2087	Assert(!pStreamWas->fStarted);
2088
2089	/*
2090	* We always reset the buffer before enabling the stream (normally never necessary).
2091	*/
2092	if (pStreamWas->cFramesCaptureToRelease)
2093	{
2094	hrc = pStreamWas->pDevCfg->pIAudioCaptureClient->ReleaseBuffer(pStreamWas->cFramesCaptureToRelease);
2095	Log4Func(("Releasing capture buffer (%#x frames): %Rhrc\n", pStreamWas->cFramesCaptureToRelease, hrc));
2096	pStreamWas->cFramesCaptureToRelease = 0;
2097	pStreamWas->pbCapture = NULL;
2098	pStreamWas->cbCapture = 0;
2099	}
2100
2101	hrc = pStreamWas->pDevCfg->pIAudioClient->Reset();
2102	if (FAILED(hrc))
2103	LogRelMax(64, ("WasAPI: Stream reset failed when enabling '%s': %Rhrc\n", pStreamWas->Cfg.szName, hrc));
2104	pStreamWas->offInternal = 0;
2105	pStreamWas->fDraining = false;
2106	pStreamWas->fEnabled = true;
2107	pStreamWas->fRestartOnResume = false;
2108
2109	/*
2110	* Input streams will start capturing, while output streams will only start
2111	* playing once we get some audio data to play.
2112	*/
2113	int rc = VINF_SUCCESS;
2114	if (pStreamWas->Cfg.enmDir == PDMAUDIODIR_IN)
2115	rc = drvHostAudioWasStreamStartWorker(pThis, pStreamWas, "enable");
2116	else
2117	Assert(pStreamWas->Cfg.enmDir == PDMAUDIODIR_OUT);
2118
2119	RTCritSectLeave(&pStreamWas->CritSect);
2120	LogFlowFunc(("returns %Rrc\n", rc));
2121	return rc;
2122	}
2123
2124
2125	/**
2126	* @ interface_method_impl{PDMIHOSTAUDIO,pfnStreamDisable}
2127	*/
2128	static DECLCALLBACK(int) drvHostAudioWasHA_StreamDisable(PPDMIHOSTAUDIO pInterface, PPDMAUDIOBACKENDSTREAM pStream)
2129	{
2130	RT_NOREF(pInterface);
2131	PDRVHOSTAUDIOWASSTREAM pStreamWas = (PDRVHOSTAUDIOWASSTREAM)pStream;
2132	LogFlowFunc(("cMsLastTransfer=%RI64 ms, stream '%s' {%s} \n",
2133	pStreamWas->msLastTransfer ? RTTimeMilliTS() - pStreamWas->msLastTransfer : -1,
2134	pStreamWas->Cfg.szName, drvHostWasStreamStatusString(pStreamWas) ));
2135	RTCritSectEnter(&pStreamWas->CritSect);
2136
2137	/*
2138	* Always try stop it (draining or no).
2139	*/
2140	pStreamWas->fEnabled = false;
2141	pStreamWas->fRestartOnResume = false;
2142	Assert(!pStreamWas->fDraining \|\| pStreamWas->Cfg.enmDir == PDMAUDIODIR_OUT);
2143
2144	int rc = VINF_SUCCESS;
2145	if (pStreamWas->fStarted)
2146	{
2147	HRESULT hrc = pStreamWas->pDevCfg->pIAudioClient->Stop();
2148	LogFlowFunc(("Stop(%s) returns %Rhrc\n", pStreamWas->Cfg.szName, hrc));
2149	if (FAILED(hrc))
2150	{
2151	LogRelMax(64, ("WasAPI: Stopping '%s' failed (disable): %Rhrc\n", pStreamWas->Cfg.szName, hrc));
2152	rc = VERR_GENERAL_FAILURE;
2153	}
2154	pStreamWas->fStarted = false;
2155	pStreamWas->fDraining = false;
2156	}
2157
2158	RTCritSectLeave(&pStreamWas->CritSect);
2159	LogFlowFunc(("returns %Rrc {%s}\n", rc, drvHostWasStreamStatusString(pStreamWas)));
2160	return rc;
2161	}
2162
2163
2164	/**
2165	* @ interface_method_impl{PDMIHOSTAUDIO,pfnStreamPause}
2166	*
2167	* @note Basically the same as drvHostAudioWasHA_StreamDisable, just w/o the
2168	* buffer resetting and fEnabled change.
2169	*/
2170	static DECLCALLBACK(int) drvHostAudioWasHA_StreamPause(PPDMIHOSTAUDIO pInterface, PPDMAUDIOBACKENDSTREAM pStream)
2171	{
2172	RT_NOREF(pInterface);
2173	PDRVHOSTAUDIOWASSTREAM pStreamWas = (PDRVHOSTAUDIOWASSTREAM)pStream;
2174	LogFlowFunc(("cMsLastTransfer=%RI64 ms, stream '%s' {%s} \n",
2175	pStreamWas->msLastTransfer ? RTTimeMilliTS() - pStreamWas->msLastTransfer : -1,
2176	pStreamWas->Cfg.szName, drvHostWasStreamStatusString(pStreamWas) ));
2177	RTCritSectEnter(&pStreamWas->CritSect);
2178
2179	/*
2180	* Unless we're draining the stream, stop it if it's started.
2181	*/
2182	int rc = VINF_SUCCESS;
2183	if (pStreamWas->fStarted && !pStreamWas->fDraining)
2184	{
2185	pStreamWas->fRestartOnResume = true;
2186
2187	HRESULT hrc = pStreamWas->pDevCfg->pIAudioClient->Stop();
2188	LogFlowFunc(("Stop(%s) returns %Rhrc\n", pStreamWas->Cfg.szName, hrc));
2189	if (FAILED(hrc))
2190	{
2191	LogRelMax(64, ("WasAPI: Stopping '%s' failed (pause): %Rhrc\n", pStreamWas->Cfg.szName, hrc));
2192	rc = VERR_GENERAL_FAILURE;
2193	}
2194	pStreamWas->fStarted = false;
2195	}
2196	else
2197	{
2198	pStreamWas->fRestartOnResume = false;
2199	if (pStreamWas->fDraining)
2200	{
2201	LogFunc(("Stream '%s' is draining\n", pStreamWas->Cfg.szName));
2202	Assert(pStreamWas->fStarted);
2203	}
2204	}
2205
2206	RTCritSectLeave(&pStreamWas->CritSect);
2207	LogFlowFunc(("returns %Rrc {%s}\n", rc, drvHostWasStreamStatusString(pStreamWas)));
2208	return rc;
2209	}
2210
2211
2212	/**
2213	* @ interface_method_impl{PDMIHOSTAUDIO,pfnStreamResume}
2214	*/
2215	static DECLCALLBACK(int) drvHostAudioWasHA_StreamResume(PPDMIHOSTAUDIO pInterface, PPDMAUDIOBACKENDSTREAM pStream)
2216	{
2217	PDRVHOSTAUDIOWAS pThis = RT_FROM_MEMBER(pInterface, DRVHOSTAUDIOWAS, IHostAudio);
2218	PDRVHOSTAUDIOWASSTREAM pStreamWas = (PDRVHOSTAUDIOWASSTREAM)pStream;
2219	LogFlowFunc(("Stream '%s' {%s}\n", pStreamWas->Cfg.szName, drvHostWasStreamStatusString(pStreamWas)));
2220	RTCritSectEnter(&pStreamWas->CritSect);
2221
2222	/*
2223	* Resume according to state saved by drvHostAudioWasHA_StreamPause.
2224	*/
2225	int rc;
2226	if (pStreamWas->fRestartOnResume)
2227	rc = drvHostAudioWasStreamStartWorker(pThis, pStreamWas, "resume");
2228	else
2229	rc = VINF_SUCCESS;
2230	pStreamWas->fRestartOnResume = false;
2231
2232	RTCritSectLeave(&pStreamWas->CritSect);
2233	LogFlowFunc(("returns %Rrc {%s}\n", rc, drvHostWasStreamStatusString(pStreamWas)));
2234	return rc;
2235	}
2236
2237
2238	/**
2239	* @ interface_method_impl{PDMIHOSTAUDIO,pfnStreamDrain}
2240	*/
2241	static DECLCALLBACK(int) drvHostAudioWasHA_StreamDrain(PPDMIHOSTAUDIO pInterface, PPDMAUDIOBACKENDSTREAM pStream)
2242	{
2243	RT_NOREF(pInterface);
2244	PDRVHOSTAUDIOWASSTREAM pStreamWas = (PDRVHOSTAUDIOWASSTREAM)pStream;
2245	AssertReturn(pStreamWas->Cfg.enmDir == PDMAUDIODIR_OUT, VERR_INVALID_PARAMETER);
2246	LogFlowFunc(("cMsLastTransfer=%RI64 ms, stream '%s' {%s} \n",
2247	pStreamWas->msLastTransfer ? RTTimeMilliTS() - pStreamWas->msLastTransfer : -1,
2248	pStreamWas->Cfg.szName, drvHostWasStreamStatusString(pStreamWas) ));
2249
2250	/*
2251	* If the stram was started, calculate when the buffered data has finished
2252	* playing and switch to drain mode. DrvAudio will keep on calling
2253	* pfnStreamPlay with an empty buffer while we're draining, so we'll use
2254	* that for checking the deadline and finally stopping the stream.
2255	*/
2256	RTCritSectEnter(&pStreamWas->CritSect);
2257	int rc = VINF_SUCCESS;
2258	if (pStreamWas->fStarted)
2259	{
2260	if (!pStreamWas->fDraining)
2261	{
2262	uint64_t const msNow = RTTimeMilliTS();
2263	uint64_t msDrainDeadline = 0;
2264	UINT32 cFramesPending = 0;
2265	HRESULT hrc = pStreamWas->pDevCfg->pIAudioClient->GetCurrentPadding(&cFramesPending);
2266	if (SUCCEEDED(hrc))
2267	msDrainDeadline = msNow
2268	+ PDMAudioPropsFramesToMilli(&pStreamWas->Cfg.Props,
2269	RT_MIN(cFramesPending,
2270	pStreamWas->Cfg.Backend.cFramesBufferSize * 2))
2271	+ 1 /fudge/;
2272	else
2273	{
2274	msDrainDeadline = msNow;
2275	LogRelMax(64, ("WasAPI: GetCurrentPadding fail on '%s' when starting draining: %Rhrc\n",
2276	pStreamWas->Cfg.szName, hrc));
2277	}
2278	pStreamWas->msDrainDeadline = msDrainDeadline;
2279	pStreamWas->fDraining = true;
2280	}
2281	else
2282	LogFlowFunc(("Already draining '%s' ...\n", pStreamWas->Cfg.szName));
2283	}
2284	else
2285	{
2286	LogFlowFunc(("Drain requested for '%s', but not started playback...\n", pStreamWas->Cfg.szName));
2287	AssertStmt(!pStreamWas->fDraining, pStreamWas->fDraining = false);
2288	}
2289	RTCritSectLeave(&pStreamWas->CritSect);
2290
2291	LogFlowFunc(("returns %Rrc {%s}\n", rc, drvHostWasStreamStatusString(pStreamWas)));
2292	return rc;
2293	}
2294
2295
2296	/**
2297	* @interface_method_impl{PDMIHOSTAUDIO,pfnStreamControl}
2298	*/
2299	static DECLCALLBACK(int) drvHostAudioWasHA_StreamControl(PPDMIHOSTAUDIO pInterface,
2300	PPDMAUDIOBACKENDSTREAM pStream, PDMAUDIOSTREAMCMD enmStreamCmd)
2301	{
2302	/** @todo r=bird: I'd like to get rid of this pfnStreamControl method,
2303	* replacing it with individual StreamXxxx methods. That would save us
2304	* potentally huge switches and more easily see which drivers implement
2305	* which operations (grep for pfnStreamXxxx). */
2306	switch (enmStreamCmd)
2307	{
2308	case PDMAUDIOSTREAMCMD_ENABLE:
2309	return drvHostAudioWasHA_StreamEnable(pInterface, pStream);
2310	case PDMAUDIOSTREAMCMD_DISABLE:
2311	return drvHostAudioWasHA_StreamDisable(pInterface, pStream);
2312	case PDMAUDIOSTREAMCMD_PAUSE:
2313	return drvHostAudioWasHA_StreamPause(pInterface, pStream);
2314	case PDMAUDIOSTREAMCMD_RESUME:
2315	return drvHostAudioWasHA_StreamResume(pInterface, pStream);
2316	case PDMAUDIOSTREAMCMD_DRAIN:
2317	return drvHostAudioWasHA_StreamDrain(pInterface, pStream);
2318
2319	case PDMAUDIOSTREAMCMD_END:
2320	case PDMAUDIOSTREAMCMD_32BIT_HACK:
2321	case PDMAUDIOSTREAMCMD_INVALID:
2322	/* no default*/
2323	break;
2324	}
2325	return VERR_NOT_SUPPORTED;
2326	}
2327
2328
2329	/**
2330	* @interface_method_impl{PDMIHOSTAUDIO,pfnStreamGetReadable}
2331	*/
2332	static DECLCALLBACK(uint32_t) drvHostAudioWasHA_StreamGetReadable(PPDMIHOSTAUDIO pInterface, PPDMAUDIOBACKENDSTREAM pStream)
2333	{
2334	RT_NOREF(pInterface);
2335	PDRVHOSTAUDIOWASSTREAM pStreamWas = (PDRVHOSTAUDIOWASSTREAM)pStream;
2336	AssertPtrReturn(pStreamWas, 0);
2337	Assert(pStreamWas->Cfg.enmDir == PDMAUDIODIR_IN);
2338
2339	uint32_t cbReadable = 0;
2340	RTCritSectEnter(&pStreamWas->CritSect);
2341
2342	if (pStreamWas->pDevCfg->pIAudioCaptureClient /* paranoia */)
2343	{
2344	UINT32 cFramesPending = 0;
2345	HRESULT hrc = pStreamWas->pDevCfg->pIAudioClient->GetCurrentPadding(&cFramesPending);
2346	if (SUCCEEDED(hrc))
2347	{
2348	/* An unreleased buffer is included in the pending frame count, so subtract
2349	whatever we've got hanging around since the previous pfnStreamCapture call. */
2350	AssertMsgStmt(cFramesPending >= pStreamWas->cFramesCaptureToRelease,
2351	("%#x vs %#x\n", cFramesPending, pStreamWas->cFramesCaptureToRelease),
2352	cFramesPending = pStreamWas->cFramesCaptureToRelease);
2353	cFramesPending -= pStreamWas->cFramesCaptureToRelease;
2354
2355	/* Add what we've got left in said buffer. */
2356	uint32_t cFramesCurPacket = PDMAudioPropsBytesToFrames(&pStreamWas->Cfg.Props, pStreamWas->cbCapture);
2357	cFramesPending += cFramesCurPacket;
2358
2359	/* Paranoia: Make sure we don't exceed the buffer size. */
2360	AssertMsgStmt(cFramesPending <= pStreamWas->Cfg.Backend.cFramesBufferSize,
2361	("cFramesPending=%#x cFramesCaptureToRelease=%#x cFramesCurPacket=%#x cFramesBufferSize=%#x\n",
2362	cFramesPending, pStreamWas->cFramesCaptureToRelease, cFramesCurPacket,
2363	pStreamWas->Cfg.Backend.cFramesBufferSize),
2364	cFramesPending = pStreamWas->Cfg.Backend.cFramesBufferSize);
2365
2366	cbReadable = PDMAudioPropsFramesToBytes(&pStreamWas->Cfg.Props, cFramesPending);
2367	}
2368	else
2369	LogRelMax(64, ("WasAPI: GetCurrentPadding failed on '%s': %Rhrc\n", pStreamWas->Cfg.szName, hrc));
2370	}
2371
2372	RTCritSectLeave(&pStreamWas->CritSect);
2373
2374	LogFlowFunc(("returns %#x (%u) {%s}\n", cbReadable, cbReadable, drvHostWasStreamStatusString(pStreamWas)));
2375	return cbReadable;
2376	}
2377
2378
2379	/**
2380	* @interface_method_impl{PDMIHOSTAUDIO,pfnStreamGetWritable}
2381	*/
2382	static DECLCALLBACK(uint32_t) drvHostAudioWasHA_StreamGetWritable(PPDMIHOSTAUDIO pInterface, PPDMAUDIOBACKENDSTREAM pStream)
2383	{
2384	RT_NOREF(pInterface);
2385	PDRVHOSTAUDIOWASSTREAM pStreamWas = (PDRVHOSTAUDIOWASSTREAM)pStream;
2386	AssertPtrReturn(pStreamWas, 0);
2387	LogFlowFunc(("Stream '%s' {%s}\n", pStreamWas->Cfg.szName, drvHostWasStreamStatusString(pStreamWas)));
2388	Assert(pStreamWas->Cfg.enmDir == PDMAUDIODIR_OUT);
2389
2390	uint32_t cbWritable = 0;
2391	RTCritSectEnter(&pStreamWas->CritSect);
2392
2393	if ( pStreamWas->Cfg.enmDir == PDMAUDIODIR_OUT
2394	&& pStreamWas->pDevCfg->pIAudioClient /* paranoia */)
2395	{
2396	UINT32 cFramesPending = 0;
2397	HRESULT hrc = pStreamWas->pDevCfg->pIAudioClient->GetCurrentPadding(&cFramesPending);
2398	if (SUCCEEDED(hrc))
2399	{
2400	if (cFramesPending < pStreamWas->Cfg.Backend.cFramesBufferSize)
2401	cbWritable = PDMAudioPropsFramesToBytes(&pStreamWas->Cfg.Props,
2402	pStreamWas->Cfg.Backend.cFramesBufferSize - cFramesPending);
2403	else if (cFramesPending > pStreamWas->Cfg.Backend.cFramesBufferSize)
2404	{
2405	LogRelMax(64, ("WasAPI: Warning! GetCurrentPadding('%s') return too high: cFramesPending=%#x > cFramesBufferSize=%#x\n",
2406	pStreamWas->Cfg.szName, cFramesPending, pStreamWas->Cfg.Backend.cFramesBufferSize));
2407	AssertMsgFailed(("cFramesPending=%#x > cFramesBufferSize=%#x\n",
2408	cFramesPending, pStreamWas->Cfg.Backend.cFramesBufferSize));
2409	}
2410	}
2411	else
2412	LogRelMax(64, ("WasAPI: GetCurrentPadding failed on '%s': %Rhrc\n", pStreamWas->Cfg.szName, hrc));
2413	}
2414
2415	RTCritSectLeave(&pStreamWas->CritSect);
2416
2417	LogFlowFunc(("returns %#x (%u) {%s}\n", cbWritable, cbWritable, drvHostWasStreamStatusString(pStreamWas)));
2418	return cbWritable;
2419	}
2420
2421
2422	/**
2423	* @interface_method_impl{PDMIHOSTAUDIO,pfnStreamGetPending}
2424	*/
2425	static DECLCALLBACK(uint32_t) drvHostAudioWasHA_StreamGetPending(PPDMIHOSTAUDIO pInterface, PPDMAUDIOBACKENDSTREAM pStream)
2426	{
2427	RT_NOREF(pInterface);
2428	PDRVHOSTAUDIOWASSTREAM pStreamWas = (PDRVHOSTAUDIOWASSTREAM)pStream;
2429	AssertPtrReturn(pStreamWas, 0);
2430	LogFlowFunc(("Stream '%s' {%s}\n", pStreamWas->Cfg.szName, drvHostWasStreamStatusString(pStreamWas)));
2431	AssertReturn(pStreamWas->Cfg.enmDir == PDMAUDIODIR_OUT, 0);
2432
2433	uint32_t cbPending = 0;
2434	RTCritSectEnter(&pStreamWas->CritSect);
2435
2436	if ( pStreamWas->Cfg.enmDir == PDMAUDIODIR_OUT
2437	&& pStreamWas->pDevCfg->pIAudioClient /* paranoia */)
2438	{
2439	if (pStreamWas->fStarted)
2440	{
2441	UINT32 cFramesPending = 0;
2442	HRESULT hrc = pStreamWas->pDevCfg->pIAudioClient->GetCurrentPadding(&cFramesPending);
2443	if (SUCCEEDED(hrc))
2444	{
2445	AssertMsg(cFramesPending <= pStreamWas->Cfg.Backend.cFramesBufferSize,
2446	("cFramesPending=%#x cFramesBufferSize=%#x\n",
2447	cFramesPending, pStreamWas->Cfg.Backend.cFramesBufferSize));
2448	cbPending = PDMAudioPropsFramesToBytes(&pStreamWas->Cfg.Props, RT_MIN(cFramesPending, VBOX_WASAPI_MAX_PADDING));
2449	}
2450	else
2451	LogRelMax(64, ("WasAPI: GetCurrentPadding failed on '%s': %Rhrc\n", pStreamWas->Cfg.szName, hrc));
2452	}
2453	}
2454
2455	RTCritSectLeave(&pStreamWas->CritSect);
2456
2457	LogFlowFunc(("returns %#x (%u) {%s}\n", cbPending, cbPending, drvHostWasStreamStatusString(pStreamWas)));
2458	return cbPending;
2459	}
2460
2461
2462	/**
2463	* @interface_method_impl{PDMIHOSTAUDIO,pfnStreamGetState}
2464	*/
2465	static DECLCALLBACK(PDMHOSTAUDIOSTREAMSTATE) drvHostAudioWasHA_StreamGetState(PPDMIHOSTAUDIO pInterface,
2466	PPDMAUDIOBACKENDSTREAM pStream)
2467	{
2468	RT_NOREF(pInterface);
2469	PDRVHOSTAUDIOWASSTREAM pStreamWas = (PDRVHOSTAUDIOWASSTREAM)pStream;
2470	AssertPtrReturn(pStreamWas, PDMHOSTAUDIOSTREAMSTATE_INVALID);
2471
2472	PDMHOSTAUDIOSTREAMSTATE enmState;
2473	AssertPtr(pStreamWas->pDevCfg);
2474	if (pStreamWas->pDevCfg /paranoia/)
2475	{
2476	if (RT_SUCCESS(pStreamWas->pDevCfg->rcSetup))
2477	{
2478	if (!pStreamWas->fDraining)
2479	enmState = PDMHOSTAUDIOSTREAMSTATE_OKAY;
2480	else
2481	{
2482	Assert(pStreamWas->Cfg.enmDir == PDMAUDIODIR_OUT);
2483	enmState = PDMHOSTAUDIOSTREAMSTATE_DRAINING;
2484	}
2485	}
2486	else if ( pStreamWas->pDevCfg->rcSetup == VERR_AUDIO_STREAM_INIT_IN_PROGRESS
2487	\|\| pStreamWas->fSwitchingDevice )
2488	enmState = PDMHOSTAUDIOSTREAMSTATE_INITIALIZING;
2489	else
2490	enmState = PDMHOSTAUDIOSTREAMSTATE_NOT_WORKING;
2491	}
2492	else if (pStreamWas->fSwitchingDevice)
2493	enmState = PDMHOSTAUDIOSTREAMSTATE_INITIALIZING;
2494	else
2495	enmState = PDMHOSTAUDIOSTREAMSTATE_NOT_WORKING;
2496
2497	LogFlowFunc(("returns %d for '%s' {%s}\n", enmState, pStreamWas->Cfg.szName, drvHostWasStreamStatusString(pStreamWas)));
2498	return enmState;
2499	}
2500
2501
2502	/**
2503	* @interface_method_impl{PDMIHOSTAUDIO,pfnStreamPlay}
2504	*/
2505	static DECLCALLBACK(int) drvHostAudioWasHA_StreamPlay(PPDMIHOSTAUDIO pInterface, PPDMAUDIOBACKENDSTREAM pStream,
2506	const void pvBuf, uint32_t cbBuf, uint32_t pcbWritten)
2507	{
2508	PDRVHOSTAUDIOWAS pThis = RT_FROM_MEMBER(pInterface, DRVHOSTAUDIOWAS, IHostAudio);
2509	PDRVHOSTAUDIOWASSTREAM pStreamWas = (PDRVHOSTAUDIOWASSTREAM)pStream;
2510	AssertPtrReturn(pStreamWas, VERR_INVALID_POINTER);
2511	AssertPtrReturn(pcbWritten, VERR_INVALID_POINTER);
2512	if (cbBuf)
2513	AssertPtrReturn(pvBuf, VERR_INVALID_POINTER);
2514	Assert(PDMAudioPropsIsSizeAligned(&pStreamWas->Cfg.Props, cbBuf));
2515
2516	RTCritSectEnter(&pStreamWas->CritSect);
2517	if (pStreamWas->fEnabled)
2518	{ /* likely */ }
2519	else
2520	{
2521	RTCritSectLeave(&pStreamWas->CritSect);
2522	*pcbWritten = 0;
2523	LogFunc(("Skipping %#x byte write to disabled stream {%s}\n", cbBuf, drvHostWasStreamStatusString(pStreamWas)));
2524	return VINF_SUCCESS;
2525	}
2526	Log4Func(("cbBuf=%#x stream '%s' {%s}\n", cbBuf, pStreamWas->Cfg.szName, drvHostWasStreamStatusString(pStreamWas) ));
2527
2528	/*
2529	* Transfer loop.
2530	*/
2531	int rc = VINF_SUCCESS;
2532	uint32_t cReInits = 0;
2533	uint32_t cbWritten = 0;
2534	while (cbBuf > 0)
2535	{
2536	AssertBreakStmt(pStreamWas->pDevCfg && pStreamWas->pDevCfg->pIAudioRenderClient && pStreamWas->pDevCfg->pIAudioClient,
2537	rc = VERR_AUDIO_STREAM_NOT_READY);
2538
2539	/*
2540	* Figure out how much we can possibly write.
2541	*/
2542	UINT32 cFramesPending = 0;
2543	uint32_t cbWritable = 0;
2544	HRESULT hrc = pStreamWas->pDevCfg->pIAudioClient->GetCurrentPadding(&cFramesPending);
2545	if (SUCCEEDED(hrc))
2546	cbWritable = PDMAudioPropsFramesToBytes(&pStreamWas->Cfg.Props,
2547	pStreamWas->Cfg.Backend.cFramesBufferSize
2548	- RT_MIN(cFramesPending, pStreamWas->Cfg.Backend.cFramesBufferSize));
2549	else
2550	{
2551	LogRelMax(64, ("WasAPI: GetCurrentPadding(%s) failed during playback: %Rhrc (@%#RX64)\n",
2552	pStreamWas->Cfg.szName, hrc, pStreamWas->offInternal));
2553	/** @todo reinit on AUDCLNT_E_DEVICEINVALIDATED? */
2554	rc = VERR_AUDIO_STREAM_NOT_READY;
2555	break;
2556	}
2557	if (cbWritable <= PDMAudioPropsFrameSize(&pStreamWas->Cfg.Props))
2558	break;
2559
2560	uint32_t const cbToWrite = PDMAudioPropsFloorBytesToFrame(&pStreamWas->Cfg.Props, RT_MIN(cbWritable, cbBuf));
2561	uint32_t const cFramesToWrite = PDMAudioPropsBytesToFrames(&pStreamWas->Cfg.Props, cbToWrite);
2562	Assert(PDMAudioPropsFramesToBytes(&pStreamWas->Cfg.Props, cFramesToWrite) == cbToWrite);
2563	Log3Func(("@%#RX64: cFramesPending=%#x -> cbWritable=%#x cbToWrite=%#x cFramesToWrite=%#x {%s}\n",
2564	pStreamWas->offInternal, cFramesPending, cbWritable, cbToWrite, cFramesToWrite,
2565	drvHostWasStreamStatusString(pStreamWas) ));
2566
2567	/*
2568	* Get the buffer, copy the data into it, and relase it back to the WAS machinery.
2569	*/
2570	BYTE *pbData = NULL;
2571	hrc = pStreamWas->pDevCfg->pIAudioRenderClient->GetBuffer(cFramesToWrite, &pbData);
2572	if (SUCCEEDED(hrc))
2573	{
2574	memcpy(pbData, pvBuf, cbToWrite);
2575	hrc = pStreamWas->pDevCfg->pIAudioRenderClient->ReleaseBuffer(cFramesToWrite, 0 /fFlags/);
2576	if (SUCCEEDED(hrc))
2577	{
2578	/*
2579	* Before we advance the buffer position (so we can resubmit it
2580	* after re-init), make sure we've successfully started stream.
2581	*/
2582	if (pStreamWas->fStarted)
2583	{ }
2584	else
2585	{
2586	rc = drvHostAudioWasStreamStartWorker(pThis, pStreamWas, "play");
2587	if (rc == VINF_SUCCESS)
2588	{ /* likely */ }
2589	else if (RT_SUCCESS(rc) && ++cReInits < 5)
2590	continue; /* re-submit buffer after re-init */
2591	else
2592	break;
2593	}
2594
2595	/* advance. */
2596	pvBuf = (uint8_t *)pvBuf + cbToWrite;
2597	cbBuf -= cbToWrite;
2598	cbWritten += cbToWrite;
2599	pStreamWas->offInternal += cbToWrite;
2600	}
2601	else
2602	{
2603	LogRelMax(64, ("WasAPI: ReleaseBuffer(%#x) failed on '%s' during playback: %Rhrc (@%#RX64)\n",
2604	cFramesToWrite, pStreamWas->Cfg.szName, hrc, pStreamWas->offInternal));
2605	/** @todo reinit on AUDCLNT_E_DEVICEINVALIDATED? */
2606	rc = VERR_AUDIO_STREAM_NOT_READY;
2607	break;
2608	}
2609	}
2610	else
2611	{
2612	LogRelMax(64, ("WasAPI: GetBuffer(%#x) failed on '%s' during playback: %Rhrc (@%#RX64)\n",
2613	cFramesToWrite, pStreamWas->Cfg.szName, hrc, pStreamWas->offInternal));
2614	/** @todo reinit on AUDCLNT_E_DEVICEINVALIDATED? */
2615	rc = VERR_AUDIO_STREAM_NOT_READY;
2616	break;
2617	}
2618	}
2619
2620	/*
2621	* Do draining deadline processing.
2622	*/
2623	uint64_t const msNow = RTTimeMilliTS();
2624	if ( !pStreamWas->fDraining
2625	\|\| msNow < pStreamWas->msDrainDeadline)
2626	{ /* likely */ }
2627	else
2628	{
2629	LogRel2(("WasAPI: Stopping draining of '%s' {%s} ...\n", pStreamWas->Cfg.szName, drvHostWasStreamStatusString(pStreamWas)));
2630	HRESULT hrc = pStreamWas->pDevCfg->pIAudioClient->Stop();
2631	if (FAILED(hrc))
2632	LogRelMax(64, ("WasAPI: Failed to stop draining stream '%s': %Rhrc\n", pStreamWas->Cfg.szName, hrc));
2633	pStreamWas->fDraining = false;
2634	pStreamWas->fStarted = false;
2635	}
2636
2637	/*
2638	* Done.
2639	*/
2640	uint64_t const msPrev = pStreamWas->msLastTransfer;
2641	if (cbWritten)
2642	pStreamWas->msLastTransfer = msNow;
2643
2644	RTCritSectLeave(&pStreamWas->CritSect);
2645
2646	*pcbWritten = cbWritten;
2647	if (RT_SUCCESS(rc) \|\| !cbWritten)
2648	{ }
2649	else
2650	{
2651	LogFlowFunc(("Suppressing %Rrc to report %#x bytes written\n", rc, cbWritten));
2652	rc = VINF_SUCCESS;
2653	}
2654	LogFlowFunc(("@%#RX64: rc=%Rrc cbWritten=%RU32 cMsDelta=%RU64 (%RU64 -> %RU64) {%s}\n", pStreamWas->offInternal, rc, cbWritten,
2655	msPrev ? msNow - msPrev : 0, msPrev, pStreamWas->msLastTransfer, drvHostWasStreamStatusString(pStreamWas) ));
2656	return rc;
2657	}
2658
2659
2660	/**
2661	* @interface_method_impl{PDMIHOSTAUDIO,pfnStreamCapture}
2662	*/
2663	static DECLCALLBACK(int) drvHostAudioWasHA_StreamCapture(PPDMIHOSTAUDIO pInterface, PPDMAUDIOBACKENDSTREAM pStream,
2664	void pvBuf, uint32_t cbBuf, uint32_t pcbRead)
2665	{
2666	RT_NOREF(pInterface); //PDRVHOSTAUDIOWAS pThis = RT_FROM_MEMBER(pInterface, DRVHOSTAUDIOWAS, IHostAudio);
2667	PDRVHOSTAUDIOWASSTREAM pStreamWas = (PDRVHOSTAUDIOWASSTREAM)pStream;
2668	AssertPtrReturn(pStreamWas, 0);
2669	AssertPtrReturn(pvBuf, VERR_INVALID_POINTER);
2670	AssertReturn(cbBuf, VERR_INVALID_PARAMETER);
2671	AssertPtrReturn(pcbRead, VERR_INVALID_POINTER);
2672	Assert(PDMAudioPropsIsSizeAligned(&pStreamWas->Cfg.Props, cbBuf));
2673
2674	RTCritSectEnter(&pStreamWas->CritSect);
2675	if (pStreamWas->fEnabled)
2676	{ /* likely */ }
2677	else
2678	{
2679	RTCritSectLeave(&pStreamWas->CritSect);
2680	*pcbRead = 0;
2681	LogFunc(("Skipping %#x byte read from disabled stream {%s}\n", cbBuf, drvHostWasStreamStatusString(pStreamWas)));
2682	return VINF_SUCCESS;
2683	}
2684	Log4Func(("cbBuf=%#x stream '%s' {%s}\n", cbBuf, pStreamWas->Cfg.szName, drvHostWasStreamStatusString(pStreamWas) ));
2685
2686
2687	/*
2688	* Transfer loop.
2689	*/
2690	int rc = VINF_SUCCESS;
2691	uint32_t cbRead = 0;
2692	uint32_t const cbFrame = PDMAudioPropsFrameSize(&pStreamWas->Cfg.Props);
2693	while (cbBuf >= cbFrame)
2694	{
2695	AssertBreakStmt(pStreamWas->pDevCfg->pIAudioCaptureClient && pStreamWas->pDevCfg->pIAudioClient, rc = VERR_AUDIO_STREAM_NOT_READY);
2696
2697	/*
2698	* Anything pending from last call?
2699	* (This is rather similar to the Pulse interface.)
2700	*/
2701	if (pStreamWas->cFramesCaptureToRelease)
2702	{
2703	uint32_t const cbToCopy = RT_MIN(pStreamWas->cbCapture, cbBuf);
2704	memcpy(pvBuf, pStreamWas->pbCapture, cbToCopy);
2705	pvBuf = (uint8_t *)pvBuf + cbToCopy;
2706	cbBuf -= cbToCopy;
2707	cbRead += cbToCopy;
2708	pStreamWas->offInternal += cbToCopy;
2709	pStreamWas->pbCapture += cbToCopy;
2710	pStreamWas->cbCapture -= cbToCopy;
2711	if (!pStreamWas->cbCapture)
2712	{
2713	HRESULT hrc = pStreamWas->pDevCfg->pIAudioCaptureClient->ReleaseBuffer(pStreamWas->cFramesCaptureToRelease);
2714	Log4Func(("@%#RX64: Releasing capture buffer (%#x frames): %Rhrc\n",
2715	pStreamWas->offInternal, pStreamWas->cFramesCaptureToRelease, hrc));
2716	if (SUCCEEDED(hrc))
2717	{
2718	pStreamWas->cFramesCaptureToRelease = 0;
2719	pStreamWas->pbCapture = NULL;
2720	}
2721	else
2722	{
2723	LogRelMax(64, ("WasAPI: ReleaseBuffer(%s) failed during capture: %Rhrc (@%#RX64)\n",
2724	pStreamWas->Cfg.szName, hrc, pStreamWas->offInternal));
2725	/** @todo reinit on AUDCLNT_E_DEVICEINVALIDATED? */
2726	rc = VERR_AUDIO_STREAM_NOT_READY;
2727	break;
2728	}
2729	}
2730	if (cbBuf < cbFrame)
2731	break;
2732	}
2733
2734	/*
2735	* Figure out if there is any data available to be read now. (Docs hint that we can not
2736	* skip this and go straight for GetBuffer or we risk getting unwritten buffer space back).
2737	*/
2738	UINT32 cFramesCaptured = 0;
2739	HRESULT hrc = pStreamWas->pDevCfg->pIAudioCaptureClient->GetNextPacketSize(&cFramesCaptured);
2740	if (SUCCEEDED(hrc))
2741	{
2742	if (!cFramesCaptured)
2743	break;
2744	}
2745	else
2746	{
2747	LogRelMax(64, ("WasAPI: GetNextPacketSize(%s) failed during capture: %Rhrc (@%#RX64)\n",
2748	pStreamWas->Cfg.szName, hrc, pStreamWas->offInternal));
2749	/** @todo reinit on AUDCLNT_E_DEVICEINVALIDATED? */
2750	rc = VERR_AUDIO_STREAM_NOT_READY;
2751	break;
2752	}
2753
2754	/*
2755	* Get the buffer.
2756	*/
2757	cFramesCaptured = 0;
2758	UINT64 uQpsNtTicks = 0;
2759	UINT64 offDevice = 0;
2760	DWORD fBufFlags = 0;
2761	BYTE *pbData = NULL;
2762	hrc = pStreamWas->pDevCfg->pIAudioCaptureClient->GetBuffer(&pbData, &cFramesCaptured, &fBufFlags, &offDevice, &uQpsNtTicks);
2763	Log4Func(("@%#RX64: GetBuffer -> %Rhrc pbData=%p cFramesCaptured=%#x fBufFlags=%#x offDevice=%#RX64 uQpcNtTicks=%#RX64\n",
2764	pStreamWas->offInternal, hrc, pbData, cFramesCaptured, fBufFlags, offDevice, uQpsNtTicks));
2765	if (SUCCEEDED(hrc))
2766	{
2767	Assert(cFramesCaptured < VBOX_WASAPI_MAX_PADDING);
2768	pStreamWas->pbCapture = pbData;
2769	pStreamWas->cFramesCaptureToRelease = cFramesCaptured;
2770	pStreamWas->cbCapture = PDMAudioPropsFramesToBytes(&pStreamWas->Cfg.Props, cFramesCaptured);
2771	/* Just loop and re-use the copying code above. Can optimize later. */
2772	}
2773	else
2774	{
2775	LogRelMax(64, ("WasAPI: GetBuffer() failed on '%s' during capture: %Rhrc (@%#RX64)\n",
2776	pStreamWas->Cfg.szName, hrc, pStreamWas->offInternal));
2777	/** @todo reinit on AUDCLNT_E_DEVICEINVALIDATED? */
2778	rc = VERR_AUDIO_STREAM_NOT_READY;
2779	break;
2780	}
2781	}
2782
2783	/*
2784	* Done.
2785	*/
2786	uint64_t const msPrev = pStreamWas->msLastTransfer;
2787	uint64_t const msNow = RTTimeMilliTS();
2788	if (cbRead)
2789	pStreamWas->msLastTransfer = msNow;
2790
2791	RTCritSectLeave(&pStreamWas->CritSect);
2792
2793	*pcbRead = cbRead;
2794	if (RT_SUCCESS(rc) \|\| !cbRead)
2795	{ }
2796	else
2797	{
2798	LogFlowFunc(("Suppressing %Rrc to report %#x bytes read\n", rc, cbRead));
2799	rc = VINF_SUCCESS;
2800	}
2801	LogFlowFunc(("@%#RX64: rc=%Rrc cbRead=%#RX32 cMsDelta=%RU64 (%RU64 -> %RU64) {%s}\n", pStreamWas->offInternal, rc, cbRead,
2802	msPrev ? msNow - msPrev : 0, msPrev, pStreamWas->msLastTransfer, drvHostWasStreamStatusString(pStreamWas) ));
2803	return rc;
2804	}
2805
2806
2807	/*********************************************************************************************************************************
2808	* PDMDRVINS::IBase Interface *
2809	*********************************************************************************************************************************/
2810
2811	/**
2812	* @callback_method_impl{PDMIBASE,pfnQueryInterface}
2813	*/
2814	static DECLCALLBACK(void ) drvHostAudioWasQueryInterface(PPDMIBASE pInterface, const char pszIID)
2815	{
2816	PPDMDRVINS pDrvIns = PDMIBASE_2_PDMDRV(pInterface);
2817	PDRVHOSTAUDIOWAS pThis = PDMINS_2_DATA(pDrvIns, PDRVHOSTAUDIOWAS);
2818
2819	PDMIBASE_RETURN_INTERFACE(pszIID, PDMIBASE, &pDrvIns->IBase);
2820	PDMIBASE_RETURN_INTERFACE(pszIID, PDMIHOSTAUDIO, &pThis->IHostAudio);
2821	return NULL;
2822	}
2823
2824
2825	/*********************************************************************************************************************************
2826	* PDMDRVREG Interface *
2827	*********************************************************************************************************************************/
2828
2829	/**
2830	* @callback_method_impl{FNPDMDRVDESTRUCT, pfnDestruct}
2831	*/
2832	static DECLCALLBACK(void) drvHostAudioWasPowerOff(PPDMDRVINS pDrvIns)
2833	{
2834	PDRVHOSTAUDIOWAS pThis = PDMINS_2_DATA(pDrvIns, PDRVHOSTAUDIOWAS);
2835
2836	/*
2837	* Start purging the cache asynchronously before we get to destruct.
2838	* This might speed up VM shutdown a tiny fraction and also stress
2839	* the shutting down of the thread pool a little.
2840	*/
2841	#if 0
2842	if (pThis->hWorkerThread != NIL_RTTHREAD)
2843	{
2844	BOOL fRc = PostThreadMessageW(pThis->idWorkerThread, WM_DRVHOSTAUDIOWAS_PURGE_CACHE, pThis->uWorkerThreadFixedParam, 0);
2845	LogFlowFunc(("Posted WM_DRVHOSTAUDIOWAS_PURGE_CACHE: %d\n", fRc));
2846	Assert(fRc); RT_NOREF(fRc);
2847	}
2848	#else
2849	if (!RTListIsEmpty(&pThis->CacheHead) && pThis->pIHostAudioPort)
2850	{
2851	int rc = RTSemEventMultiCreate(&pThis->hEvtCachePurge);
2852	if (RT_SUCCESS(rc))
2853	{
2854	rc = pThis->pIHostAudioPort->pfnDoOnWorkerThread(pThis->pIHostAudioPort, NULL/pStream/,
2855	DRVHOSTAUDIOWAS_DO_PURGE_CACHE, NULL /pvUser/);
2856	if (RT_FAILURE(rc))
2857	{
2858	LogFunc(("pfnDoOnWorkerThread/DRVHOSTAUDIOWAS_DO_PURGE_CACHE failed: %Rrc\n", rc));
2859	RTSemEventMultiDestroy(pThis->hEvtCachePurge);
2860	pThis->hEvtCachePurge = NIL_RTSEMEVENTMULTI;
2861	}
2862	}
2863	}
2864	#endif
2865
2866	/*
2867	* Deregister the notification client to reduce the risk of notifications
2868	* comming in while we're being detatched or the VM is being destroyed.
2869	*/
2870	if (pThis->pNotifyClient)
2871	{
2872	pThis->pNotifyClient->notifyDriverDestroyed();
2873	pThis->pIEnumerator->UnregisterEndpointNotificationCallback(pThis->pNotifyClient);
2874	pThis->pNotifyClient->Release();
2875	pThis->pNotifyClient = NULL;
2876	}
2877	}
2878
2879
2880	/**
2881	* @callback_method_impl{FNPDMDRVDESTRUCT, pfnDestruct}
2882	*/
2883	static DECLCALLBACK(void) drvHostAudioWasDestruct(PPDMDRVINS pDrvIns)
2884	{
2885	PDRVHOSTAUDIOWAS pThis = PDMINS_2_DATA(pDrvIns, PDRVHOSTAUDIOWAS);
2886	PDMDRV_CHECK_VERSIONS_RETURN_VOID(pDrvIns);
2887	LogFlowFuncEnter();
2888
2889	/*
2890	* Release the notification client first.
2891	*/
2892	if (pThis->pNotifyClient)
2893	{
2894	pThis->pNotifyClient->notifyDriverDestroyed();
2895	pThis->pIEnumerator->UnregisterEndpointNotificationCallback(pThis->pNotifyClient);
2896	pThis->pNotifyClient->Release();
2897	pThis->pNotifyClient = NULL;
2898	}
2899
2900	#if 0
2901	if (pThis->hWorkerThread != NIL_RTTHREAD)
2902	{
2903	BOOL fRc = PostThreadMessageW(pThis->idWorkerThread, WM_QUIT, 0, 0);
2904	Assert(fRc); RT_NOREF(fRc);
2905
2906	int rc = RTThreadWait(pThis->hWorkerThread, RT_MS_15SEC, NULL);
2907	AssertRC(rc);
2908	}
2909	#endif
2910
2911	if (RTCritSectIsInitialized(&pThis->CritSectCache))
2912	{
2913	drvHostAudioWasCachePurge(pThis, false /fOnWorker/);
2914	if (pThis->hEvtCachePurge != NIL_RTSEMEVENTMULTI)
2915	RTSemEventMultiWait(pThis->hEvtCachePurge, RT_MS_30SEC);
2916	RTCritSectDelete(&pThis->CritSectCache);
2917	}
2918
2919	if (pThis->hEvtCachePurge != NIL_RTSEMEVENTMULTI)
2920	{
2921	RTSemEventMultiDestroy(pThis->hEvtCachePurge);
2922	pThis->hEvtCachePurge = NIL_RTSEMEVENTMULTI;
2923	}
2924
2925	if (pThis->pIEnumerator)
2926	{
2927	uint32_t cRefs = pThis->pIEnumerator->Release(); RT_NOREF(cRefs);
2928	LogFlowFunc(("cRefs=%d\n", cRefs));
2929	}
2930
2931	if (pThis->pIDeviceOutput)
2932	{
2933	pThis->pIDeviceOutput->Release();
2934	pThis->pIDeviceOutput = NULL;
2935	}
2936
2937	if (pThis->pIDeviceInput)
2938	{
2939	pThis->pIDeviceInput->Release();
2940	pThis->pIDeviceInput = NULL;
2941	}
2942
2943
2944	if (RTCritSectRwIsInitialized(&pThis->CritSectStreamList))
2945	RTCritSectRwDelete(&pThis->CritSectStreamList);
2946
2947	LogFlowFuncLeave();
2948	}
2949
2950
2951	/**
2952	* @callback_method_impl{FNPDMDRVCONSTRUCT, pfnConstruct}
2953	*/
2954	static DECLCALLBACK(int) drvHostAudioWasConstruct(PPDMDRVINS pDrvIns, PCFGMNODE pCfg, uint32_t fFlags)
2955	{
2956	PDMDRV_CHECK_VERSIONS_RETURN(pDrvIns);
2957	PDRVHOSTAUDIOWAS pThis = PDMINS_2_DATA(pDrvIns, PDRVHOSTAUDIOWAS);
2958	RT_NOREF(fFlags, pCfg);
2959
2960	/*
2961	* Init basic data members and interfaces.
2962	*/
2963	pThis->pDrvIns = pDrvIns;
2964	pThis->hEvtCachePurge = NIL_RTSEMEVENTMULTI;
2965	#if 0
2966	pThis->hWorkerThread = NIL_RTTHREAD;
2967	pThis->idWorkerThread = 0;
2968	#endif
2969	RTListInit(&pThis->StreamHead);
2970	RTListInit(&pThis->CacheHead);
2971	/* IBase */
2972	pDrvIns->IBase.pfnQueryInterface = drvHostAudioWasQueryInterface;
2973	/* IHostAudio */
2974	pThis->IHostAudio.pfnGetConfig = drvHostAudioWasHA_GetConfig;
2975	pThis->IHostAudio.pfnGetDevices = drvHostAudioWasHA_GetDevices;
2976	pThis->IHostAudio.pfnSetDevice = NULL;
2977	pThis->IHostAudio.pfnGetStatus = drvHostAudioWasHA_GetStatus;
2978	pThis->IHostAudio.pfnDoOnWorkerThread = drvHostAudioWasHA_DoOnWorkerThread;
2979	pThis->IHostAudio.pfnStreamConfigHint = drvHostAudioWasHA_StreamConfigHint;
2980	pThis->IHostAudio.pfnStreamCreate = drvHostAudioWasHA_StreamCreate;
2981	pThis->IHostAudio.pfnStreamInitAsync = drvHostAudioWasHA_StreamInitAsync;
2982	pThis->IHostAudio.pfnStreamDestroy = drvHostAudioWasHA_StreamDestroy;
2983	pThis->IHostAudio.pfnStreamNotifyDeviceChanged = drvHostAudioWasHA_StreamNotifyDeviceChanged;
2984	pThis->IHostAudio.pfnStreamControl = drvHostAudioWasHA_StreamControl;
2985	pThis->IHostAudio.pfnStreamGetReadable = drvHostAudioWasHA_StreamGetReadable;
2986	pThis->IHostAudio.pfnStreamGetWritable = drvHostAudioWasHA_StreamGetWritable;
2987	pThis->IHostAudio.pfnStreamGetPending = drvHostAudioWasHA_StreamGetPending;
2988	pThis->IHostAudio.pfnStreamGetState = drvHostAudioWasHA_StreamGetState;
2989	pThis->IHostAudio.pfnStreamPlay = drvHostAudioWasHA_StreamPlay;
2990	pThis->IHostAudio.pfnStreamCapture = drvHostAudioWasHA_StreamCapture;
2991
2992	/*
2993	* Validate and read the configuration.
2994	*/
2995	PDMDRV_VALIDATE_CONFIG_RETURN(pDrvIns, "VmName\|VmUuid", "");
2996	/** @todo make it possible to override the default device selection. */
2997
2998	AssertMsgReturn(PDMDrvHlpNoAttach(pDrvIns) == VERR_PDM_NO_ATTACHED_DRIVER,
2999	("Configuration error: Not possible to attach anything to this driver!\n"),
3000	VERR_PDM_DRVINS_NO_ATTACH);
3001
3002	/*
3003	* Initialize the critical sections early.
3004	*/
3005	int rc = RTCritSectRwInit(&pThis->CritSectStreamList);
3006	AssertRCReturn(rc, rc);
3007
3008	rc = RTCritSectInit(&pThis->CritSectCache);
3009	AssertRCReturn(rc, rc);
3010
3011	/*
3012	* Create an enumerator instance that we can get the default devices from
3013	* as well as do enumeration thru.
3014	*/
3015	HRESULT hrc = CoCreateInstance(__uuidof(MMDeviceEnumerator), 0, CLSCTX_ALL, __uuidof(IMMDeviceEnumerator),
3016	(void **)&pThis->pIEnumerator);
3017	if (FAILED(hrc))
3018	{
3019	pThis->pIEnumerator = NULL;
3020	LogRel(("WasAPI: Failed to create an MMDeviceEnumerator object: %Rhrc\n", hrc));
3021	return VERR_AUDIO_BACKEND_INIT_FAILED;
3022	}
3023	AssertPtr(pThis->pIEnumerator);
3024
3025	/*
3026	* Resolve the interface to the driver above us.
3027	*/
3028	pThis->pIHostAudioPort = PDMIBASE_QUERY_INTERFACE(pDrvIns->pUpBase, PDMIHOSTAUDIOPORT);
3029	AssertPtrReturn(pThis->pIHostAudioPort, VERR_PDM_MISSING_INTERFACE_ABOVE);
3030
3031	/*
3032	* Instantiate and register the notification client with the enumerator.
3033	*
3034	* Failure here isn't considered fatal at this time as we'll just miss
3035	* default device changes.
3036	*/
3037	try
3038	{
3039	pThis->pNotifyClient = new DrvHostAudioWasMmNotifyClient(pThis);
3040	}
3041	catch (std::bad_alloc &)
3042	{
3043	return VERR_NO_MEMORY;
3044	}
3045	catch (int rcXcpt)
3046	{
3047	return rcXcpt;
3048	}
3049	hrc = pThis->pIEnumerator->RegisterEndpointNotificationCallback(pThis->pNotifyClient);
3050	AssertMsg(SUCCEEDED(hrc), ("%Rhrc\n", hrc));
3051	if (FAILED(hrc))
3052	{
3053	LogRel(("WasAPI: RegisterEndpointNotificationCallback failed: %Rhrc (ignored)\n"
3054	"WasAPI: Warning! Will not be able to detect default device changes!\n"));
3055	pThis->pNotifyClient->notifyDriverDestroyed();
3056	pThis->pNotifyClient->Release();
3057	pThis->pNotifyClient = NULL;
3058	}
3059
3060	/*
3061	* Retrieve the input and output device.
3062	*/
3063	IMMDevice *pIDeviceInput = NULL;
3064	if (pThis->pwszInputDevId)
3065	hrc = pThis->pIEnumerator->GetDevice(pThis->pwszInputDevId, &pIDeviceInput);
3066	else
3067	hrc = pThis->pIEnumerator->GetDefaultAudioEndpoint(eCapture, eMultimedia, &pIDeviceInput);
3068	if (SUCCEEDED(hrc))
3069	LogFlowFunc(("pIDeviceInput=%p\n", pIDeviceInput));
3070	else
3071	{
3072	LogRel(("WasAPI: Failed to get audio input device '%ls': %Rhrc\n",
3073	pThis->pwszInputDevId ? pThis->pwszInputDevId : L"{Default}", hrc));
3074	pIDeviceInput = NULL;
3075	}
3076
3077	IMMDevice *pIDeviceOutput = NULL;
3078	if (pThis->pwszOutputDevId)
3079	hrc = pThis->pIEnumerator->GetDevice(pThis->pwszOutputDevId, &pIDeviceOutput);
3080	else
3081	hrc = pThis->pIEnumerator->GetDefaultAudioEndpoint(eRender, eMultimedia, &pIDeviceOutput);
3082	if (SUCCEEDED(hrc))
3083	LogFlowFunc(("pIDeviceOutput=%p\n", pIDeviceOutput));
3084	else
3085	{
3086	LogRel(("WasAPI: Failed to get audio output device '%ls': %Rhrc\n",
3087	pThis->pwszOutputDevId ? pThis->pwszOutputDevId : L"{Default}", hrc));
3088	pIDeviceOutput = NULL;
3089	}
3090
3091	/* Carefully place them in the instance data: */
3092	pThis->pNotifyClient->lockEnter();
3093
3094	if (pThis->pIDeviceInput)
3095	pThis->pIDeviceInput->Release();
3096	pThis->pIDeviceInput = pIDeviceInput;
3097
3098	if (pThis->pIDeviceOutput)
3099	pThis->pIDeviceOutput->Release();
3100	pThis->pIDeviceOutput = pIDeviceOutput;
3101
3102	pThis->pNotifyClient->lockLeave();
3103
3104	#if 0
3105	/*
3106	* Create the worker thread. This thread has a message loop and will be
3107	* signalled by DrvHostAudioWasMmNotifyClient while the VM is paused/whatever,
3108	* so better make it a regular thread rather than PDM thread.
3109	*/
3110	pThis->uWorkerThreadFixedParam = (WPARAM)RTRandU64();
3111	rc = RTThreadCreateF(&pThis->hWorkerThread, drvHostWasWorkerThread, pThis, 0 /cbStack/, RTTHREADTYPE_DEFAULT,
3112	RTTHREADFLAGS_WAITABLE \| RTTHREADFLAGS_COM_MTA, "WasWork%u", pDrvIns->iInstance);
3113	AssertRCReturn(rc, rc);
3114
3115	rc = RTThreadUserWait(pThis->hWorkerThread, RT_MS_10SEC);
3116	AssertRC(rc);
3117	#endif
3118
3119	/*
3120	* Prime the cache.
3121	*/
3122	drvHostAudioWasCacheFill(pThis);
3123
3124	return VINF_SUCCESS;
3125	}
3126
3127
3128	/**
3129	* PDM driver registration for WasAPI.
3130	*/
3131	const PDMDRVREG g_DrvHostAudioWas =
3132	{
3133	/* u32Version */
3134	PDM_DRVREG_VERSION,
3135	/* szName */
3136	"HostAudioWas",
3137	/* szRCMod */
3138	"",
3139	/* szR0Mod */
3140	"",
3141	/* pszDescription */
3142	"Windows Audio Session API (WASAPI) host audio driver",
3143	/* fFlags */
3144	PDM_DRVREG_FLAGS_HOST_BITS_DEFAULT,
3145	/* fClass. */
3146	PDM_DRVREG_CLASS_AUDIO,
3147	/* cMaxInstances */
3148	~0U,
3149	/* cbInstance */
3150	sizeof(DRVHOSTAUDIOWAS),
3151	/* pfnConstruct */
3152	drvHostAudioWasConstruct,
3153	/* pfnDestruct */
3154	drvHostAudioWasDestruct,
3155	/* pfnRelocate */
3156	NULL,
3157	/* pfnIOCtl */
3158	NULL,
3159	/* pfnPowerOn */
3160	NULL,
3161	/* pfnReset */
3162	NULL,
3163	/* pfnSuspend */
3164	NULL,
3165	/* pfnResume */
3166	NULL,
3167	/* pfnAttach */
3168	NULL,
3169	/* pfnDetach */
3170	NULL,
3171	/* pfnPowerOff */
3172	drvHostAudioWasPowerOff,
3173	/* pfnSoftReset */
3174	NULL,
3175	/* u32EndVersion */
3176	PDM_DRVREG_VERSION
3177	};
3178

注意: 瀏覽 TracBrowser 來幫助您使用儲存庫瀏覽器

source: vbox/trunk/src/VBox/Devices/Audio/DrvHostAudioWasApi.cpp@ 89382

以其他格式下載: