mirror of
https://github.com/reactos/wine.git
synced 2024-12-15 23:57:33 +00:00
1455 lines
44 KiB
C
1455 lines
44 KiB
C
/* DirectSoundCapture
|
|
*
|
|
* Copyright 1998 Marcus Meissner
|
|
* Copyright 1998 Rob Riggs
|
|
* Copyright 2000-2001 TransGaming Technologies, Inc.
|
|
*
|
|
* This library is free software; you can redistribute it and/or
|
|
* modify it under the terms of the GNU Lesser General Public
|
|
* License as published by the Free Software Foundation; either
|
|
* version 2.1 of the License, or (at your option) any later version.
|
|
*
|
|
* This library is distributed in the hope that it will be useful,
|
|
* but WITHOUT ANY WARRANTY; without even the implied warranty of
|
|
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
|
|
* Lesser General Public License for more details.
|
|
*
|
|
* You should have received a copy of the GNU Lesser General Public
|
|
* License along with this library; if not, write to the Free Software
|
|
* Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA 02110-1301, USA
|
|
*/
|
|
/*
|
|
* TODO:
|
|
* Implement FX support.
|
|
* Implement both IDirectSoundCaptureBuffer and IDirectSoundCaptureBuffer8
|
|
* Make DirectSoundCaptureCreate and DirectSoundCaptureCreate8 behave differently
|
|
*/
|
|
|
|
#include <stdarg.h>
|
|
|
|
#define COBJMACROS
|
|
#define NONAMELESSSTRUCT
|
|
#define NONAMELESSUNION
|
|
#include "windef.h"
|
|
#include "winbase.h"
|
|
#include "winuser.h"
|
|
#include "mmsystem.h"
|
|
#include "mmddk.h"
|
|
#include "winternl.h"
|
|
#include "winnls.h"
|
|
#include "wine/debug.h"
|
|
#include "dsound.h"
|
|
#include "dsound_private.h"
|
|
|
|
WINE_DEFAULT_DEBUG_CHANNEL(dsound);
|
|
|
|
typedef struct DirectSoundCaptureDevice DirectSoundCaptureDevice;
|
|
|
|
/* IDirectSoundCaptureBuffer implementation structure */
|
|
typedef struct IDirectSoundCaptureBufferImpl
|
|
{
|
|
IDirectSoundCaptureBuffer8 IDirectSoundCaptureBuffer8_iface;
|
|
IDirectSoundNotify IDirectSoundNotify_iface;
|
|
LONG numIfaces; /* "in use interfaces" refcount */
|
|
LONG ref, refn;
|
|
/* IDirectSoundCaptureBuffer fields */
|
|
DirectSoundCaptureDevice *device;
|
|
DSCBUFFERDESC *pdscbd;
|
|
DWORD flags;
|
|
/* IDirectSoundNotify fields */
|
|
DSBPOSITIONNOTIFY *notifies;
|
|
int nrofnotifies;
|
|
HANDLE thread;
|
|
HANDLE sleepev;
|
|
} IDirectSoundCaptureBufferImpl;
|
|
|
|
/* DirectSoundCaptureDevice implementation structure */
|
|
struct DirectSoundCaptureDevice
|
|
{
|
|
GUID guid;
|
|
LONG ref;
|
|
DSCCAPS drvcaps;
|
|
BYTE *buffer;
|
|
DWORD buflen, write_pos_bytes;
|
|
WAVEFORMATEX *pwfx;
|
|
IDirectSoundCaptureBufferImpl *capture_buffer;
|
|
DWORD state;
|
|
CRITICAL_SECTION lock;
|
|
IMMDevice *mmdevice;
|
|
IAudioClient *client;
|
|
IAudioCaptureClient *capture;
|
|
struct list entry;
|
|
};
|
|
|
|
static DWORD WINAPI DSOUND_capture_thread(void *user);
|
|
|
|
static void capturebuffer_destroy(IDirectSoundCaptureBufferImpl *This)
|
|
{
|
|
if (This->device->state == STATE_CAPTURING)
|
|
This->device->state = STATE_STOPPING;
|
|
|
|
if(This->thread){
|
|
SetEvent(This->sleepev);
|
|
WaitForSingleObject(This->thread, INFINITE);
|
|
CloseHandle(This->thread);
|
|
}
|
|
CloseHandle(This->sleepev);
|
|
|
|
HeapFree(GetProcessHeap(),0, This->pdscbd);
|
|
|
|
if (This->device->client) {
|
|
IAudioClient_Release(This->device->client);
|
|
This->device->client = NULL;
|
|
}
|
|
|
|
if (This->device->capture) {
|
|
IAudioCaptureClient_Release(This->device->capture);
|
|
This->device->capture = NULL;
|
|
}
|
|
|
|
/* remove from DirectSoundCaptureDevice */
|
|
This->device->capture_buffer = NULL;
|
|
|
|
HeapFree(GetProcessHeap(), 0, This->notifies);
|
|
HeapFree(GetProcessHeap(), 0, This);
|
|
TRACE("(%p) released\n", This);
|
|
}
|
|
|
|
/*******************************************************************************
|
|
* IDirectSoundNotify
|
|
*/
|
|
static inline struct IDirectSoundCaptureBufferImpl *impl_from_IDirectSoundNotify(IDirectSoundNotify *iface)
|
|
{
|
|
return CONTAINING_RECORD(iface, IDirectSoundCaptureBufferImpl, IDirectSoundNotify_iface);
|
|
}
|
|
|
|
static HRESULT WINAPI IDirectSoundNotifyImpl_QueryInterface(IDirectSoundNotify *iface, REFIID riid,
|
|
void **ppobj)
|
|
{
|
|
IDirectSoundCaptureBufferImpl *This = impl_from_IDirectSoundNotify(iface);
|
|
|
|
TRACE("(%p,%s,%p)\n", This, debugstr_guid(riid), ppobj);
|
|
|
|
return IDirectSoundCaptureBuffer_QueryInterface(&This->IDirectSoundCaptureBuffer8_iface, riid, ppobj);
|
|
}
|
|
|
|
static ULONG WINAPI IDirectSoundNotifyImpl_AddRef(IDirectSoundNotify *iface)
|
|
{
|
|
IDirectSoundCaptureBufferImpl *This = impl_from_IDirectSoundNotify(iface);
|
|
ULONG ref = InterlockedIncrement(&This->refn);
|
|
|
|
TRACE("(%p) ref was %d\n", This, ref - 1);
|
|
|
|
if(ref == 1)
|
|
InterlockedIncrement(&This->numIfaces);
|
|
|
|
return ref;
|
|
}
|
|
|
|
static ULONG WINAPI IDirectSoundNotifyImpl_Release(IDirectSoundNotify *iface)
|
|
{
|
|
IDirectSoundCaptureBufferImpl *This = impl_from_IDirectSoundNotify(iface);
|
|
ULONG ref = InterlockedDecrement(&This->refn);
|
|
|
|
TRACE("(%p) ref was %d\n", This, ref + 1);
|
|
|
|
if (!ref && !InterlockedDecrement(&This->numIfaces))
|
|
capturebuffer_destroy(This);
|
|
|
|
return ref;
|
|
}
|
|
|
|
static HRESULT WINAPI IDirectSoundNotifyImpl_SetNotificationPositions(IDirectSoundNotify *iface,
|
|
DWORD howmuch, const DSBPOSITIONNOTIFY *notify)
|
|
{
|
|
IDirectSoundCaptureBufferImpl *This = impl_from_IDirectSoundNotify(iface);
|
|
TRACE("(%p,0x%08x,%p)\n",This,howmuch,notify);
|
|
|
|
if (howmuch > 0 && notify == NULL) {
|
|
WARN("invalid parameter: notify == NULL\n");
|
|
return DSERR_INVALIDPARAM;
|
|
}
|
|
|
|
if (TRACE_ON(dsound)) {
|
|
unsigned int i;
|
|
for (i=0;i<howmuch;i++)
|
|
TRACE("notify at %d to %p\n",
|
|
notify[i].dwOffset,notify[i].hEventNotify);
|
|
}
|
|
|
|
if (howmuch > 0) {
|
|
/* Make an internal copy of the caller-supplied array.
|
|
* Replace the existing copy if one is already present. */
|
|
if (This->notifies)
|
|
This->notifies = HeapReAlloc(GetProcessHeap(), HEAP_ZERO_MEMORY, This->notifies,
|
|
howmuch * sizeof(DSBPOSITIONNOTIFY));
|
|
else
|
|
This->notifies = HeapAlloc(GetProcessHeap(), HEAP_ZERO_MEMORY,
|
|
howmuch * sizeof(DSBPOSITIONNOTIFY));
|
|
|
|
if (!This->notifies) {
|
|
WARN("out of memory\n");
|
|
return DSERR_OUTOFMEMORY;
|
|
}
|
|
CopyMemory(This->notifies, notify, howmuch * sizeof(DSBPOSITIONNOTIFY));
|
|
This->nrofnotifies = howmuch;
|
|
} else {
|
|
HeapFree(GetProcessHeap(), 0, This->notifies);
|
|
This->notifies = NULL;
|
|
This->nrofnotifies = 0;
|
|
}
|
|
|
|
return S_OK;
|
|
}
|
|
|
|
static const IDirectSoundNotifyVtbl dscnvt =
|
|
{
|
|
IDirectSoundNotifyImpl_QueryInterface,
|
|
IDirectSoundNotifyImpl_AddRef,
|
|
IDirectSoundNotifyImpl_Release,
|
|
IDirectSoundNotifyImpl_SetNotificationPositions
|
|
};
|
|
|
|
|
|
static const char * const captureStateString[] = {
|
|
"STATE_STOPPED",
|
|
"STATE_STARTING",
|
|
"STATE_CAPTURING",
|
|
"STATE_STOPPING"
|
|
};
|
|
|
|
|
|
/*******************************************************************************
|
|
* IDirectSoundCaptureBuffer
|
|
*/
|
|
static inline IDirectSoundCaptureBufferImpl *impl_from_IDirectSoundCaptureBuffer8(IDirectSoundCaptureBuffer8 *iface)
|
|
{
|
|
return CONTAINING_RECORD(iface, IDirectSoundCaptureBufferImpl, IDirectSoundCaptureBuffer8_iface);
|
|
}
|
|
|
|
static HRESULT WINAPI IDirectSoundCaptureBufferImpl_QueryInterface(IDirectSoundCaptureBuffer8 *iface,
|
|
REFIID riid, void **ppobj)
|
|
{
|
|
IDirectSoundCaptureBufferImpl *This = impl_from_IDirectSoundCaptureBuffer8(iface);
|
|
|
|
TRACE( "(%p,%s,%p)\n", This, debugstr_guid(riid), ppobj );
|
|
|
|
if (ppobj == NULL) {
|
|
WARN("invalid parameter\n");
|
|
return E_INVALIDARG;
|
|
}
|
|
|
|
*ppobj = NULL;
|
|
|
|
if ( IsEqualGUID( &IID_IDirectSoundCaptureBuffer, riid ) ||
|
|
IsEqualGUID( &IID_IDirectSoundCaptureBuffer8, riid ) ) {
|
|
IDirectSoundCaptureBuffer8_AddRef(iface);
|
|
*ppobj = iface;
|
|
return S_OK;
|
|
}
|
|
|
|
if ( IsEqualGUID( &IID_IDirectSoundNotify, riid ) ) {
|
|
IDirectSoundNotify_AddRef(&This->IDirectSoundNotify_iface);
|
|
*ppobj = &This->IDirectSoundNotify_iface;
|
|
return S_OK;
|
|
}
|
|
|
|
FIXME("(%p,%s,%p) unsupported GUID\n", This, debugstr_guid(riid), ppobj);
|
|
return E_NOINTERFACE;
|
|
}
|
|
|
|
static ULONG WINAPI IDirectSoundCaptureBufferImpl_AddRef(IDirectSoundCaptureBuffer8 *iface)
|
|
{
|
|
IDirectSoundCaptureBufferImpl *This = impl_from_IDirectSoundCaptureBuffer8(iface);
|
|
ULONG ref = InterlockedIncrement(&This->ref);
|
|
|
|
TRACE("(%p) ref was %d\n", This, ref - 1);
|
|
|
|
if(ref == 1)
|
|
InterlockedIncrement(&This->numIfaces);
|
|
|
|
return ref;
|
|
}
|
|
|
|
static ULONG WINAPI IDirectSoundCaptureBufferImpl_Release(IDirectSoundCaptureBuffer8 *iface)
|
|
{
|
|
IDirectSoundCaptureBufferImpl *This = impl_from_IDirectSoundCaptureBuffer8(iface);
|
|
ULONG ref = InterlockedDecrement(&This->ref);
|
|
|
|
TRACE("(%p) ref was %d\n", This, ref + 1);
|
|
|
|
if (!ref && !InterlockedDecrement(&This->numIfaces))
|
|
capturebuffer_destroy(This);
|
|
|
|
return ref;
|
|
}
|
|
|
|
static HRESULT WINAPI IDirectSoundCaptureBufferImpl_GetCaps(IDirectSoundCaptureBuffer8 *iface,
|
|
DSCBCAPS *lpDSCBCaps)
|
|
{
|
|
IDirectSoundCaptureBufferImpl *This = impl_from_IDirectSoundCaptureBuffer8(iface);
|
|
TRACE( "(%p,%p)\n", This, lpDSCBCaps );
|
|
|
|
if (lpDSCBCaps == NULL) {
|
|
WARN("invalid parameter: lpDSCBCaps == NULL\n");
|
|
return DSERR_INVALIDPARAM;
|
|
}
|
|
|
|
if (lpDSCBCaps->dwSize < sizeof(DSCBCAPS)) {
|
|
WARN("invalid parameter: lpDSCBCaps->dwSize = %d\n", lpDSCBCaps->dwSize);
|
|
return DSERR_INVALIDPARAM;
|
|
}
|
|
|
|
if (This->device == NULL) {
|
|
WARN("invalid parameter: This->device == NULL\n");
|
|
return DSERR_INVALIDPARAM;
|
|
}
|
|
|
|
lpDSCBCaps->dwSize = sizeof(DSCBCAPS);
|
|
lpDSCBCaps->dwFlags = This->flags;
|
|
lpDSCBCaps->dwBufferBytes = This->pdscbd->dwBufferBytes;
|
|
lpDSCBCaps->dwReserved = 0;
|
|
|
|
TRACE("returning DS_OK\n");
|
|
return DS_OK;
|
|
}
|
|
|
|
static HRESULT WINAPI IDirectSoundCaptureBufferImpl_GetCurrentPosition(IDirectSoundCaptureBuffer8 *iface,
|
|
DWORD *lpdwCapturePosition, DWORD *lpdwReadPosition)
|
|
{
|
|
IDirectSoundCaptureBufferImpl *This = impl_from_IDirectSoundCaptureBuffer8(iface);
|
|
|
|
TRACE( "(%p,%p,%p)\n", This, lpdwCapturePosition, lpdwReadPosition );
|
|
|
|
if (This->device == NULL) {
|
|
WARN("invalid parameter: This->device == NULL\n");
|
|
return DSERR_INVALIDPARAM;
|
|
}
|
|
|
|
EnterCriticalSection(&This->device->lock);
|
|
|
|
if (!This->device->client) {
|
|
LeaveCriticalSection(&This->device->lock);
|
|
WARN("no driver\n");
|
|
return DSERR_NODRIVER;
|
|
}
|
|
|
|
if(lpdwCapturePosition)
|
|
*lpdwCapturePosition = This->device->write_pos_bytes;
|
|
|
|
if(lpdwReadPosition)
|
|
*lpdwReadPosition = This->device->write_pos_bytes;
|
|
|
|
LeaveCriticalSection(&This->device->lock);
|
|
|
|
TRACE("cappos=%d readpos=%d\n", (lpdwCapturePosition?*lpdwCapturePosition:-1), (lpdwReadPosition?*lpdwReadPosition:-1));
|
|
TRACE("returning DS_OK\n");
|
|
|
|
return DS_OK;
|
|
}
|
|
|
|
static HRESULT WINAPI IDirectSoundCaptureBufferImpl_GetFormat(IDirectSoundCaptureBuffer8 *iface,
|
|
WAVEFORMATEX *lpwfxFormat, DWORD dwSizeAllocated, DWORD *lpdwSizeWritten)
|
|
{
|
|
IDirectSoundCaptureBufferImpl *This = impl_from_IDirectSoundCaptureBuffer8(iface);
|
|
HRESULT hres = DS_OK;
|
|
|
|
TRACE("(%p,%p,0x%08x,%p)\n", This, lpwfxFormat, dwSizeAllocated, lpdwSizeWritten);
|
|
|
|
if (This->device == NULL) {
|
|
WARN("invalid parameter: This->device == NULL\n");
|
|
return DSERR_INVALIDPARAM;
|
|
}
|
|
|
|
if (dwSizeAllocated > (sizeof(WAVEFORMATEX) + This->device->pwfx->cbSize))
|
|
dwSizeAllocated = sizeof(WAVEFORMATEX) + This->device->pwfx->cbSize;
|
|
|
|
if (lpwfxFormat) { /* NULL is valid (just want size) */
|
|
CopyMemory(lpwfxFormat, This->device->pwfx, dwSizeAllocated);
|
|
if (lpdwSizeWritten)
|
|
*lpdwSizeWritten = dwSizeAllocated;
|
|
} else {
|
|
if (lpdwSizeWritten)
|
|
*lpdwSizeWritten = sizeof(WAVEFORMATEX) + This->device->pwfx->cbSize;
|
|
else {
|
|
TRACE("invalid parameter: lpdwSizeWritten = NULL\n");
|
|
hres = DSERR_INVALIDPARAM;
|
|
}
|
|
}
|
|
|
|
TRACE("returning %08x\n", hres);
|
|
return hres;
|
|
}
|
|
|
|
static HRESULT WINAPI IDirectSoundCaptureBufferImpl_GetStatus(IDirectSoundCaptureBuffer8 *iface,
|
|
DWORD *lpdwStatus)
|
|
{
|
|
IDirectSoundCaptureBufferImpl *This = impl_from_IDirectSoundCaptureBuffer8(iface);
|
|
|
|
TRACE( "(%p, %p), thread is %04x\n", This, lpdwStatus, GetCurrentThreadId() );
|
|
|
|
if (This->device == NULL) {
|
|
WARN("invalid parameter: This->device == NULL\n");
|
|
return DSERR_INVALIDPARAM;
|
|
}
|
|
|
|
if (lpdwStatus == NULL) {
|
|
WARN("invalid parameter: lpdwStatus == NULL\n");
|
|
return DSERR_INVALIDPARAM;
|
|
}
|
|
|
|
*lpdwStatus = 0;
|
|
EnterCriticalSection(&(This->device->lock));
|
|
|
|
TRACE("old This->device->state=%s, old lpdwStatus=%08x\n",
|
|
captureStateString[This->device->state],*lpdwStatus);
|
|
if ((This->device->state == STATE_STARTING) ||
|
|
(This->device->state == STATE_CAPTURING)) {
|
|
*lpdwStatus |= DSCBSTATUS_CAPTURING;
|
|
if (This->flags & DSCBSTART_LOOPING)
|
|
*lpdwStatus |= DSCBSTATUS_LOOPING;
|
|
}
|
|
TRACE("new This->device->state=%s, new lpdwStatus=%08x\n",
|
|
captureStateString[This->device->state],*lpdwStatus);
|
|
LeaveCriticalSection(&(This->device->lock));
|
|
|
|
TRACE("status=%x\n", *lpdwStatus);
|
|
TRACE("returning DS_OK\n");
|
|
return DS_OK;
|
|
}
|
|
|
|
static HRESULT WINAPI IDirectSoundCaptureBufferImpl_Initialize(IDirectSoundCaptureBuffer8 *iface,
|
|
IDirectSoundCapture *lpDSC, const DSCBUFFERDESC *lpcDSCBDesc)
|
|
{
|
|
IDirectSoundCaptureBufferImpl *This = impl_from_IDirectSoundCaptureBuffer8(iface);
|
|
|
|
FIXME( "(%p,%p,%p): stub\n", This, lpDSC, lpcDSCBDesc );
|
|
|
|
return DS_OK;
|
|
}
|
|
|
|
static HRESULT WINAPI IDirectSoundCaptureBufferImpl_Lock(IDirectSoundCaptureBuffer8 *iface,
|
|
DWORD dwReadCusor, DWORD dwReadBytes, void **lplpvAudioPtr1, DWORD *lpdwAudioBytes1,
|
|
void **lplpvAudioPtr2, DWORD *lpdwAudioBytes2, DWORD dwFlags)
|
|
{
|
|
IDirectSoundCaptureBufferImpl *This = impl_from_IDirectSoundCaptureBuffer8(iface);
|
|
HRESULT hres = DS_OK;
|
|
|
|
TRACE( "(%p,%08u,%08u,%p,%p,%p,%p,0x%08x) at %d\n", This, dwReadCusor,
|
|
dwReadBytes, lplpvAudioPtr1, lpdwAudioBytes1, lplpvAudioPtr2,
|
|
lpdwAudioBytes2, dwFlags, GetTickCount() );
|
|
|
|
if (This->device == NULL) {
|
|
WARN("invalid parameter: This->device == NULL\n");
|
|
return DSERR_INVALIDPARAM;
|
|
}
|
|
|
|
if (lplpvAudioPtr1 == NULL) {
|
|
WARN("invalid parameter: lplpvAudioPtr1 == NULL\n");
|
|
return DSERR_INVALIDPARAM;
|
|
}
|
|
|
|
if (lpdwAudioBytes1 == NULL) {
|
|
WARN("invalid parameter: lpdwAudioBytes1 == NULL\n");
|
|
return DSERR_INVALIDPARAM;
|
|
}
|
|
|
|
EnterCriticalSection(&(This->device->lock));
|
|
|
|
if (This->device->client) {
|
|
*lplpvAudioPtr1 = This->device->buffer + dwReadCusor;
|
|
if ( (dwReadCusor + dwReadBytes) > This->device->buflen) {
|
|
*lpdwAudioBytes1 = This->device->buflen - dwReadCusor;
|
|
if (lplpvAudioPtr2)
|
|
*lplpvAudioPtr2 = This->device->buffer;
|
|
if (lpdwAudioBytes2)
|
|
*lpdwAudioBytes2 = dwReadBytes - *lpdwAudioBytes1;
|
|
} else {
|
|
*lpdwAudioBytes1 = dwReadBytes;
|
|
if (lplpvAudioPtr2)
|
|
*lplpvAudioPtr2 = 0;
|
|
if (lpdwAudioBytes2)
|
|
*lpdwAudioBytes2 = 0;
|
|
}
|
|
} else {
|
|
TRACE("invalid call\n");
|
|
hres = DSERR_INVALIDCALL; /* DSERR_NODRIVER ? */
|
|
}
|
|
|
|
LeaveCriticalSection(&(This->device->lock));
|
|
|
|
TRACE("returning %08x\n", hres);
|
|
return hres;
|
|
}
|
|
|
|
static HRESULT WINAPI IDirectSoundCaptureBufferImpl_Start(IDirectSoundCaptureBuffer8 *iface,
|
|
DWORD dwFlags)
|
|
{
|
|
IDirectSoundCaptureBufferImpl *This = impl_from_IDirectSoundCaptureBuffer8(iface);
|
|
HRESULT hres;
|
|
|
|
TRACE( "(%p,0x%08x)\n", This, dwFlags );
|
|
|
|
if (This->device == NULL) {
|
|
WARN("invalid parameter: This->device == NULL\n");
|
|
return DSERR_INVALIDPARAM;
|
|
}
|
|
|
|
if ( !This->device->client ) {
|
|
WARN("no driver\n");
|
|
return DSERR_NODRIVER;
|
|
}
|
|
|
|
EnterCriticalSection(&(This->device->lock));
|
|
|
|
if (This->device->state == STATE_STOPPED)
|
|
This->device->state = STATE_STARTING;
|
|
else if (This->device->state == STATE_STOPPING)
|
|
This->device->state = STATE_CAPTURING;
|
|
else
|
|
goto out;
|
|
TRACE("new This->device->state=%s\n",captureStateString[This->device->state]);
|
|
This->flags = dwFlags;
|
|
|
|
if (This->device->buffer)
|
|
FillMemory(This->device->buffer, This->device->buflen, (This->device->pwfx->wBitsPerSample == 8) ? 128 : 0);
|
|
|
|
hres = IAudioClient_Start(This->device->client);
|
|
if(FAILED(hres)){
|
|
WARN("Start failed: %08x\n", hres);
|
|
LeaveCriticalSection(&This->device->lock);
|
|
return hres;
|
|
}
|
|
|
|
out:
|
|
LeaveCriticalSection(&This->device->lock);
|
|
|
|
TRACE("returning DS_OK\n");
|
|
return DS_OK;
|
|
}
|
|
|
|
static HRESULT WINAPI IDirectSoundCaptureBufferImpl_Stop(IDirectSoundCaptureBuffer8 *iface)
|
|
{
|
|
IDirectSoundCaptureBufferImpl *This = impl_from_IDirectSoundCaptureBuffer8(iface);
|
|
HRESULT hres;
|
|
|
|
TRACE("(%p)\n", This);
|
|
|
|
if (This->device == NULL) {
|
|
WARN("invalid parameter: This->device == NULL\n");
|
|
return DSERR_INVALIDPARAM;
|
|
}
|
|
|
|
EnterCriticalSection(&(This->device->lock));
|
|
|
|
TRACE("old This->device->state=%s\n",captureStateString[This->device->state]);
|
|
if (This->device->state == STATE_CAPTURING)
|
|
This->device->state = STATE_STOPPING;
|
|
else if (This->device->state == STATE_STARTING)
|
|
This->device->state = STATE_STOPPED;
|
|
TRACE("new This->device->state=%s\n",captureStateString[This->device->state]);
|
|
|
|
if(This->device->client){
|
|
hres = IAudioClient_Stop(This->device->client);
|
|
if(FAILED(hres)){
|
|
LeaveCriticalSection(&This->device->lock);
|
|
return hres;
|
|
}
|
|
}
|
|
|
|
LeaveCriticalSection(&(This->device->lock));
|
|
|
|
TRACE("returning DS_OK\n");
|
|
return DS_OK;
|
|
}
|
|
|
|
static HRESULT WINAPI IDirectSoundCaptureBufferImpl_Unlock(IDirectSoundCaptureBuffer8 *iface,
|
|
void *lpvAudioPtr1, DWORD dwAudioBytes1, void *lpvAudioPtr2, DWORD dwAudioBytes2)
|
|
{
|
|
IDirectSoundCaptureBufferImpl *This = impl_from_IDirectSoundCaptureBuffer8(iface);
|
|
HRESULT hres = DS_OK;
|
|
|
|
TRACE( "(%p,%p,%08u,%p,%08u)\n", This, lpvAudioPtr1, dwAudioBytes1,
|
|
lpvAudioPtr2, dwAudioBytes2 );
|
|
|
|
if (lpvAudioPtr1 == NULL) {
|
|
WARN("invalid parameter: lpvAudioPtr1 == NULL\n");
|
|
return DSERR_INVALIDPARAM;
|
|
}
|
|
|
|
if (!This->device->client) {
|
|
WARN("invalid call\n");
|
|
hres = DSERR_INVALIDCALL;
|
|
}
|
|
|
|
TRACE("returning %08x\n", hres);
|
|
return hres;
|
|
}
|
|
|
|
static HRESULT WINAPI IDirectSoundCaptureBufferImpl_GetObjectInPath(IDirectSoundCaptureBuffer8 *iface,
|
|
REFGUID rguidObject, DWORD dwIndex, REFGUID rguidInterface, void **ppObject)
|
|
{
|
|
IDirectSoundCaptureBufferImpl *This = impl_from_IDirectSoundCaptureBuffer8(iface);
|
|
|
|
FIXME( "(%p,%s,%u,%s,%p): stub\n", This, debugstr_guid(rguidObject),
|
|
dwIndex, debugstr_guid(rguidInterface), ppObject );
|
|
|
|
if (!ppObject)
|
|
return DSERR_INVALIDPARAM;
|
|
|
|
*ppObject = NULL;
|
|
return DSERR_CONTROLUNAVAIL;
|
|
}
|
|
|
|
static HRESULT WINAPI IDirectSoundCaptureBufferImpl_GetFXStatus(IDirectSoundCaptureBuffer8 *iface,
|
|
DWORD dwFXCount, DWORD *pdwFXStatus)
|
|
{
|
|
IDirectSoundCaptureBufferImpl *This = impl_from_IDirectSoundCaptureBuffer8(iface);
|
|
|
|
FIXME( "(%p,%u,%p): stub\n", This, dwFXCount, pdwFXStatus );
|
|
|
|
return DS_OK;
|
|
}
|
|
|
|
static const IDirectSoundCaptureBuffer8Vtbl dscbvt =
|
|
{
|
|
/* IUnknown methods */
|
|
IDirectSoundCaptureBufferImpl_QueryInterface,
|
|
IDirectSoundCaptureBufferImpl_AddRef,
|
|
IDirectSoundCaptureBufferImpl_Release,
|
|
|
|
/* IDirectSoundCaptureBuffer methods */
|
|
IDirectSoundCaptureBufferImpl_GetCaps,
|
|
IDirectSoundCaptureBufferImpl_GetCurrentPosition,
|
|
IDirectSoundCaptureBufferImpl_GetFormat,
|
|
IDirectSoundCaptureBufferImpl_GetStatus,
|
|
IDirectSoundCaptureBufferImpl_Initialize,
|
|
IDirectSoundCaptureBufferImpl_Lock,
|
|
IDirectSoundCaptureBufferImpl_Start,
|
|
IDirectSoundCaptureBufferImpl_Stop,
|
|
IDirectSoundCaptureBufferImpl_Unlock,
|
|
|
|
/* IDirectSoundCaptureBuffer methods */
|
|
IDirectSoundCaptureBufferImpl_GetObjectInPath,
|
|
IDirectSoundCaptureBufferImpl_GetFXStatus
|
|
};
|
|
|
|
static void capture_CheckNotify(IDirectSoundCaptureBufferImpl *This, DWORD from, DWORD len)
|
|
{
|
|
int i;
|
|
for (i = 0; i < This->nrofnotifies; ++i) {
|
|
LPDSBPOSITIONNOTIFY event = This->notifies + i;
|
|
DWORD offset = event->dwOffset;
|
|
TRACE("checking %d, position %d, event = %p\n", i, offset, event->hEventNotify);
|
|
|
|
if (offset == DSBPN_OFFSETSTOP) {
|
|
if (!from && !len) {
|
|
SetEvent(event->hEventNotify);
|
|
TRACE("signalled event %p (%d)\n", event->hEventNotify, i);
|
|
return;
|
|
}
|
|
else return;
|
|
}
|
|
|
|
if (offset >= from && offset < (from + len))
|
|
{
|
|
TRACE("signalled event %p (%d)\n", event->hEventNotify, i);
|
|
SetEvent(event->hEventNotify);
|
|
}
|
|
}
|
|
}
|
|
|
|
static HRESULT IDirectSoundCaptureBufferImpl_Create(
|
|
DirectSoundCaptureDevice *device,
|
|
IDirectSoundCaptureBufferImpl ** ppobj,
|
|
LPCDSCBUFFERDESC lpcDSCBufferDesc)
|
|
{
|
|
LPWAVEFORMATEX wfex;
|
|
IDirectSoundCaptureBufferImpl *This;
|
|
TRACE( "(%p,%p,%p)\n", device, ppobj, lpcDSCBufferDesc);
|
|
|
|
if (ppobj == NULL) {
|
|
WARN("invalid parameter: ppobj == NULL\n");
|
|
return DSERR_INVALIDPARAM;
|
|
}
|
|
|
|
*ppobj = NULL;
|
|
|
|
if (!device) {
|
|
WARN("not initialized\n");
|
|
return DSERR_UNINITIALIZED;
|
|
}
|
|
|
|
if (lpcDSCBufferDesc == NULL) {
|
|
WARN("invalid parameter: lpcDSCBufferDesc == NULL\n");
|
|
return DSERR_INVALIDPARAM;
|
|
}
|
|
|
|
if ( ((lpcDSCBufferDesc->dwSize != sizeof(DSCBUFFERDESC)) &&
|
|
(lpcDSCBufferDesc->dwSize != sizeof(DSCBUFFERDESC1))) ||
|
|
(lpcDSCBufferDesc->dwBufferBytes == 0) ||
|
|
(lpcDSCBufferDesc->lpwfxFormat == NULL) ) { /* FIXME: DSERR_BADFORMAT ? */
|
|
WARN("invalid lpcDSCBufferDesc\n");
|
|
return DSERR_INVALIDPARAM;
|
|
}
|
|
|
|
wfex = lpcDSCBufferDesc->lpwfxFormat;
|
|
|
|
TRACE("(formattag=0x%04x,chans=%d,samplerate=%d,"
|
|
"bytespersec=%d,blockalign=%d,bitspersamp=%d,cbSize=%d)\n",
|
|
wfex->wFormatTag, wfex->nChannels, wfex->nSamplesPerSec,
|
|
wfex->nAvgBytesPerSec, wfex->nBlockAlign,
|
|
wfex->wBitsPerSample, wfex->cbSize);
|
|
|
|
device->pwfx = DSOUND_CopyFormat(wfex);
|
|
if ( device->pwfx == NULL )
|
|
return DSERR_OUTOFMEMORY;
|
|
|
|
This = HeapAlloc(GetProcessHeap(),HEAP_ZERO_MEMORY,
|
|
sizeof(IDirectSoundCaptureBufferImpl));
|
|
|
|
if ( This == NULL ) {
|
|
WARN("out of memory\n");
|
|
return DSERR_OUTOFMEMORY;
|
|
} else {
|
|
HRESULT err = DS_OK;
|
|
LPBYTE newbuf;
|
|
DWORD buflen;
|
|
|
|
This->numIfaces = 0;
|
|
This->ref = 0;
|
|
This->refn = 0;
|
|
This->device = device;
|
|
This->device->capture_buffer = This;
|
|
This->nrofnotifies = 0;
|
|
|
|
This->pdscbd = HeapAlloc(GetProcessHeap(),HEAP_ZERO_MEMORY,
|
|
lpcDSCBufferDesc->dwSize);
|
|
if (This->pdscbd)
|
|
CopyMemory(This->pdscbd, lpcDSCBufferDesc, lpcDSCBufferDesc->dwSize);
|
|
else {
|
|
WARN("no memory\n");
|
|
This->device->capture_buffer = 0;
|
|
HeapFree( GetProcessHeap(), 0, This );
|
|
return DSERR_OUTOFMEMORY;
|
|
}
|
|
|
|
This->IDirectSoundCaptureBuffer8_iface.lpVtbl = &dscbvt;
|
|
This->IDirectSoundNotify_iface.lpVtbl = &dscnvt;
|
|
|
|
err = IMMDevice_Activate(device->mmdevice, &IID_IAudioClient,
|
|
CLSCTX_INPROC_SERVER, NULL, (void**)&device->client);
|
|
if(FAILED(err)){
|
|
WARN("Activate failed: %08x\n", err);
|
|
HeapFree(GetProcessHeap(), 0, This->pdscbd);
|
|
This->device->capture_buffer = 0;
|
|
HeapFree( GetProcessHeap(), 0, This );
|
|
return err;
|
|
}
|
|
|
|
err = IAudioClient_Initialize(device->client,
|
|
AUDCLNT_SHAREMODE_SHARED, AUDCLNT_STREAMFLAGS_NOPERSIST | AUDCLNT_STREAMFLAGS_EVENTCALLBACK,
|
|
200 * 100000, 0, device->pwfx, NULL);
|
|
if(FAILED(err)){
|
|
WARN("Initialize failed: %08x\n", err);
|
|
IAudioClient_Release(device->client);
|
|
device->client = NULL;
|
|
HeapFree(GetProcessHeap(), 0, This->pdscbd);
|
|
This->device->capture_buffer = 0;
|
|
HeapFree( GetProcessHeap(), 0, This );
|
|
if(err == AUDCLNT_E_UNSUPPORTED_FORMAT)
|
|
return DSERR_BADFORMAT;
|
|
return err;
|
|
}
|
|
|
|
This->sleepev = CreateEventW(NULL, 0, 0, NULL);
|
|
|
|
err = IAudioClient_SetEventHandle(device->client, This->sleepev);
|
|
if(FAILED(err)){
|
|
WARN("SetEventHandle failed: %08x\n", err);
|
|
IAudioClient_Release(device->client);
|
|
device->client = NULL;
|
|
CloseHandle(This->sleepev);
|
|
HeapFree(GetProcessHeap(), 0, This->pdscbd);
|
|
This->device->capture_buffer = 0;
|
|
HeapFree( GetProcessHeap(), 0, This );
|
|
return err;
|
|
}
|
|
|
|
err = IAudioClient_GetService(device->client, &IID_IAudioCaptureClient,
|
|
(void**)&device->capture);
|
|
if(FAILED(err)){
|
|
WARN("GetService failed: %08x\n", err);
|
|
IAudioClient_Release(device->client);
|
|
device->client = NULL;
|
|
CloseHandle(This->sleepev);
|
|
HeapFree(GetProcessHeap(), 0, This->pdscbd);
|
|
This->device->capture_buffer = 0;
|
|
HeapFree( GetProcessHeap(), 0, This );
|
|
return err;
|
|
}
|
|
|
|
buflen = lpcDSCBufferDesc->dwBufferBytes;
|
|
TRACE("desired buflen=%d, old buffer=%p\n", buflen, device->buffer);
|
|
if (device->buffer)
|
|
newbuf = HeapReAlloc(GetProcessHeap(),0,device->buffer,buflen);
|
|
else
|
|
newbuf = HeapAlloc(GetProcessHeap(),0,buflen);
|
|
if (newbuf == NULL) {
|
|
IAudioClient_Release(device->client);
|
|
device->client = NULL;
|
|
IAudioCaptureClient_Release(device->capture);
|
|
device->capture = NULL;
|
|
CloseHandle(This->sleepev);
|
|
HeapFree(GetProcessHeap(), 0, This->pdscbd);
|
|
This->device->capture_buffer = 0;
|
|
HeapFree( GetProcessHeap(), 0, This );
|
|
return DSERR_OUTOFMEMORY;
|
|
}
|
|
device->buffer = newbuf;
|
|
device->buflen = buflen;
|
|
This->thread = CreateThread(NULL, 0, DSOUND_capture_thread, This, 0, NULL);
|
|
}
|
|
|
|
IDirectSoundCaptureBuffer_AddRef(&This->IDirectSoundCaptureBuffer8_iface);
|
|
*ppobj = This;
|
|
|
|
TRACE("returning DS_OK\n");
|
|
return DS_OK;
|
|
}
|
|
|
|
|
|
/*******************************************************************************
|
|
* DirectSoundCaptureDevice
|
|
*/
|
|
static HRESULT DirectSoundCaptureDevice_Create(
|
|
DirectSoundCaptureDevice ** ppDevice)
|
|
{
|
|
DirectSoundCaptureDevice * device;
|
|
TRACE("(%p)\n", ppDevice);
|
|
|
|
/* Allocate memory */
|
|
device = HeapAlloc(GetProcessHeap(), HEAP_ZERO_MEMORY, sizeof(DirectSoundCaptureDevice));
|
|
|
|
if (device == NULL) {
|
|
WARN("out of memory\n");
|
|
return DSERR_OUTOFMEMORY;
|
|
}
|
|
|
|
device->ref = 1;
|
|
device->state = STATE_STOPPED;
|
|
|
|
InitializeCriticalSection( &(device->lock) );
|
|
device->lock.DebugInfo->Spare[0] = (DWORD_PTR)(__FILE__ ": DirectSoundCaptureDevice.lock");
|
|
|
|
*ppDevice = device;
|
|
|
|
return DS_OK;
|
|
}
|
|
|
|
static ULONG DirectSoundCaptureDevice_Release(
|
|
DirectSoundCaptureDevice * device)
|
|
{
|
|
ULONG ref = InterlockedDecrement(&(device->ref));
|
|
TRACE("(%p) ref was %d\n", device, ref + 1);
|
|
|
|
if (!ref) {
|
|
TRACE("deleting object\n");
|
|
|
|
EnterCriticalSection(&DSOUND_capturers_lock);
|
|
list_remove(&device->entry);
|
|
LeaveCriticalSection(&DSOUND_capturers_lock);
|
|
|
|
if (device->capture_buffer)
|
|
IDirectSoundCaptureBufferImpl_Release(&device->capture_buffer->IDirectSoundCaptureBuffer8_iface);
|
|
|
|
if(device->mmdevice)
|
|
IMMDevice_Release(device->mmdevice);
|
|
HeapFree(GetProcessHeap(), 0, device->pwfx);
|
|
device->lock.DebugInfo->Spare[0] = 0;
|
|
DeleteCriticalSection( &(device->lock) );
|
|
HeapFree(GetProcessHeap(), 0, device);
|
|
TRACE("(%p) released\n", device);
|
|
}
|
|
return ref;
|
|
}
|
|
|
|
static HRESULT DSOUND_capture_data(DirectSoundCaptureDevice *device)
|
|
{
|
|
HRESULT hr;
|
|
UINT32 packet_frames, packet_bytes, avail_bytes, skip_bytes = 0;
|
|
DWORD flags;
|
|
BYTE *buf;
|
|
|
|
if(!device->capture_buffer || device->state == STATE_STOPPED)
|
|
return S_FALSE;
|
|
|
|
if(device->state == STATE_STOPPING){
|
|
device->state = STATE_STOPPED;
|
|
return S_FALSE;
|
|
}
|
|
|
|
if(device->state == STATE_STARTING)
|
|
device->state = STATE_CAPTURING;
|
|
|
|
hr = IAudioCaptureClient_GetBuffer(device->capture, &buf, &packet_frames,
|
|
&flags, NULL, NULL);
|
|
if(FAILED(hr)){
|
|
WARN("GetBuffer failed: %08x\n", hr);
|
|
return hr;
|
|
}
|
|
|
|
packet_bytes = packet_frames * device->pwfx->nBlockAlign;
|
|
if(packet_bytes > device->buflen){
|
|
TRACE("audio glitch: dsound buffer too small for data\n");
|
|
skip_bytes = packet_bytes - device->buflen;
|
|
packet_bytes = device->buflen;
|
|
}
|
|
|
|
avail_bytes = device->buflen - device->write_pos_bytes;
|
|
if(avail_bytes > packet_bytes)
|
|
avail_bytes = packet_bytes;
|
|
|
|
memcpy(device->buffer + device->write_pos_bytes, buf + skip_bytes, avail_bytes);
|
|
capture_CheckNotify(device->capture_buffer, device->write_pos_bytes, avail_bytes);
|
|
|
|
packet_bytes -= avail_bytes;
|
|
if(packet_bytes > 0){
|
|
if(device->capture_buffer->flags & DSCBSTART_LOOPING){
|
|
memcpy(device->buffer, buf + skip_bytes + avail_bytes, packet_bytes);
|
|
capture_CheckNotify(device->capture_buffer, 0, packet_bytes);
|
|
}else{
|
|
device->state = STATE_STOPPED;
|
|
capture_CheckNotify(device->capture_buffer, 0, 0);
|
|
}
|
|
}
|
|
|
|
device->write_pos_bytes += avail_bytes + packet_bytes;
|
|
device->write_pos_bytes %= device->buflen;
|
|
|
|
hr = IAudioCaptureClient_ReleaseBuffer(device->capture, packet_frames);
|
|
if(FAILED(hr)){
|
|
WARN("ReleaseBuffer failed: %08x\n", hr);
|
|
return hr;
|
|
}
|
|
|
|
return S_OK;
|
|
}
|
|
|
|
static DWORD WINAPI DSOUND_capture_thread(void *user)
|
|
{
|
|
IDirectSoundCaptureBufferImpl *buffer = user;
|
|
HRESULT hr;
|
|
DWORD ret, wait_ms;
|
|
REFERENCE_TIME period;
|
|
|
|
hr = IAudioClient_GetDevicePeriod(buffer->device->client, &period, NULL);
|
|
if(FAILED(hr)){
|
|
WARN("GetDevicePeriod failed: %08x\n", hr);
|
|
wait_ms = 5;
|
|
}else
|
|
wait_ms = MulDiv(5, period, 10000);
|
|
|
|
while(buffer->ref){
|
|
ret = WaitForSingleObject(buffer->sleepev, wait_ms);
|
|
|
|
if(!buffer->device->ref)
|
|
break;
|
|
|
|
if(ret == WAIT_OBJECT_0){
|
|
EnterCriticalSection(&buffer->device->lock);
|
|
|
|
DSOUND_capture_data(buffer->device);
|
|
|
|
LeaveCriticalSection(&buffer->device->lock);
|
|
}else if(ret != WAIT_TIMEOUT)
|
|
WARN("WaitForSingleObject failed: %u\n", GetLastError());
|
|
}
|
|
|
|
return 0;
|
|
}
|
|
|
|
static struct _TestFormat {
|
|
DWORD flag;
|
|
DWORD rate;
|
|
DWORD depth;
|
|
WORD channels;
|
|
} formats_to_test[] = {
|
|
{ WAVE_FORMAT_1M08, 11025, 8, 1 },
|
|
{ WAVE_FORMAT_1M16, 11025, 16, 1 },
|
|
{ WAVE_FORMAT_1S08, 11025, 8, 2 },
|
|
{ WAVE_FORMAT_1S16, 11025, 16, 2 },
|
|
{ WAVE_FORMAT_2M08, 22050, 8, 1 },
|
|
{ WAVE_FORMAT_2M16, 22050, 16, 1 },
|
|
{ WAVE_FORMAT_2S08, 22050, 8, 2 },
|
|
{ WAVE_FORMAT_2S16, 22050, 16, 2 },
|
|
{ WAVE_FORMAT_4M08, 44100, 8, 1 },
|
|
{ WAVE_FORMAT_4M16, 44100, 16, 1 },
|
|
{ WAVE_FORMAT_4S08, 44100, 8, 2 },
|
|
{ WAVE_FORMAT_4S16, 44100, 16, 2 },
|
|
{ WAVE_FORMAT_48M08, 48000, 8, 1 },
|
|
{ WAVE_FORMAT_48M16, 48000, 16, 1 },
|
|
{ WAVE_FORMAT_48S08, 48000, 8, 2 },
|
|
{ WAVE_FORMAT_48S16, 48000, 16, 2 },
|
|
{ WAVE_FORMAT_96M08, 96000, 8, 1 },
|
|
{ WAVE_FORMAT_96M16, 96000, 16, 1 },
|
|
{ WAVE_FORMAT_96S08, 96000, 8, 2 },
|
|
{ WAVE_FORMAT_96S16, 96000, 16, 2 },
|
|
{0}
|
|
};
|
|
|
|
static HRESULT DirectSoundCaptureDevice_Initialize(
|
|
DirectSoundCaptureDevice ** ppDevice,
|
|
LPCGUID lpcGUID)
|
|
{
|
|
HRESULT hr;
|
|
GUID devGUID;
|
|
IMMDevice *mmdevice;
|
|
struct _TestFormat *fmt;
|
|
DirectSoundCaptureDevice *device;
|
|
IAudioClient *client;
|
|
|
|
TRACE("(%p, %s)\n", ppDevice, debugstr_guid(lpcGUID));
|
|
|
|
/* Default device? */
|
|
if ( !lpcGUID || IsEqualGUID(lpcGUID, &GUID_NULL) )
|
|
lpcGUID = &DSDEVID_DefaultCapture;
|
|
|
|
if(IsEqualGUID(lpcGUID, &DSDEVID_DefaultPlayback) ||
|
|
IsEqualGUID(lpcGUID, &DSDEVID_DefaultVoicePlayback))
|
|
return DSERR_NODRIVER;
|
|
|
|
if (GetDeviceID(lpcGUID, &devGUID) != DS_OK) {
|
|
WARN("invalid parameter: lpcGUID\n");
|
|
return DSERR_INVALIDPARAM;
|
|
}
|
|
|
|
hr = get_mmdevice(eCapture, &devGUID, &mmdevice);
|
|
if(FAILED(hr))
|
|
return hr;
|
|
|
|
EnterCriticalSection(&DSOUND_capturers_lock);
|
|
|
|
hr = DirectSoundCaptureDevice_Create(&device);
|
|
if (hr != DS_OK) {
|
|
WARN("DirectSoundCaptureDevice_Create failed\n");
|
|
LeaveCriticalSection(&DSOUND_capturers_lock);
|
|
return hr;
|
|
}
|
|
|
|
device->guid = devGUID;
|
|
|
|
device->mmdevice = mmdevice;
|
|
|
|
device->drvcaps.dwFlags = 0;
|
|
|
|
device->drvcaps.dwFormats = 0;
|
|
device->drvcaps.dwChannels = 0;
|
|
hr = IMMDevice_Activate(mmdevice, &IID_IAudioClient,
|
|
CLSCTX_INPROC_SERVER, NULL, (void**)&client);
|
|
if(FAILED(hr)){
|
|
device->lock.DebugInfo->Spare[0] = 0;
|
|
DeleteCriticalSection(&device->lock);
|
|
HeapFree(GetProcessHeap(), 0, device);
|
|
LeaveCriticalSection(&DSOUND_capturers_lock);
|
|
return DSERR_NODRIVER;
|
|
}
|
|
|
|
for(fmt = formats_to_test; fmt->flag; ++fmt){
|
|
if(DSOUND_check_supported(client, fmt->rate, fmt->depth, fmt->channels)){
|
|
device->drvcaps.dwFormats |= fmt->flag;
|
|
if(fmt->channels > device->drvcaps.dwChannels)
|
|
device->drvcaps.dwChannels = fmt->channels;
|
|
}
|
|
}
|
|
IAudioClient_Release(client);
|
|
|
|
list_add_tail(&DSOUND_capturers, &device->entry);
|
|
|
|
*ppDevice = device;
|
|
|
|
LeaveCriticalSection(&DSOUND_capturers_lock);
|
|
|
|
return S_OK;
|
|
}
|
|
|
|
|
|
/*****************************************************************************
|
|
* IDirectSoundCapture implementation structure
|
|
*/
|
|
typedef struct IDirectSoundCaptureImpl
|
|
{
|
|
IUnknown IUnknown_inner;
|
|
IDirectSoundCapture IDirectSoundCapture_iface;
|
|
LONG ref, refdsc, numIfaces;
|
|
IUnknown *outer_unk; /* internal */
|
|
DirectSoundCaptureDevice *device;
|
|
BOOL has_dsc8;
|
|
} IDirectSoundCaptureImpl;
|
|
|
|
static void capture_destroy(IDirectSoundCaptureImpl *This)
|
|
{
|
|
if (This->device)
|
|
DirectSoundCaptureDevice_Release(This->device);
|
|
HeapFree(GetProcessHeap(),0,This);
|
|
TRACE("(%p) released\n", This);
|
|
}
|
|
|
|
/*******************************************************************************
|
|
* IUnknown Implementation for DirectSoundCapture
|
|
*/
|
|
static inline IDirectSoundCaptureImpl *impl_from_IUnknown(IUnknown *iface)
|
|
{
|
|
return CONTAINING_RECORD(iface, IDirectSoundCaptureImpl, IUnknown_inner);
|
|
}
|
|
|
|
static HRESULT WINAPI IUnknownImpl_QueryInterface(IUnknown *iface, REFIID riid, void **ppv)
|
|
{
|
|
IDirectSoundCaptureImpl *This = impl_from_IUnknown(iface);
|
|
|
|
TRACE("(%p,%s,%p)\n", This, debugstr_guid(riid), ppv);
|
|
|
|
if (!ppv) {
|
|
WARN("invalid parameter\n");
|
|
return E_INVALIDARG;
|
|
}
|
|
*ppv = NULL;
|
|
|
|
if (IsEqualIID(riid, &IID_IUnknown))
|
|
*ppv = &This->IUnknown_inner;
|
|
else if (IsEqualIID(riid, &IID_IDirectSoundCapture))
|
|
*ppv = &This->IDirectSoundCapture_iface;
|
|
else {
|
|
WARN("unknown IID %s\n", debugstr_guid(riid));
|
|
return E_NOINTERFACE;
|
|
}
|
|
|
|
IUnknown_AddRef((IUnknown*)*ppv);
|
|
return S_OK;
|
|
}
|
|
|
|
static ULONG WINAPI IUnknownImpl_AddRef(IUnknown *iface)
|
|
{
|
|
IDirectSoundCaptureImpl *This = impl_from_IUnknown(iface);
|
|
ULONG ref = InterlockedIncrement(&This->ref);
|
|
|
|
TRACE("(%p) ref=%d\n", This, ref);
|
|
|
|
if(ref == 1)
|
|
InterlockedIncrement(&This->numIfaces);
|
|
return ref;
|
|
}
|
|
|
|
static ULONG WINAPI IUnknownImpl_Release(IUnknown *iface)
|
|
{
|
|
IDirectSoundCaptureImpl *This = impl_from_IUnknown(iface);
|
|
ULONG ref = InterlockedDecrement(&This->ref);
|
|
|
|
TRACE("(%p) ref=%d\n", This, ref);
|
|
|
|
if (!ref && !InterlockedDecrement(&This->numIfaces))
|
|
capture_destroy(This);
|
|
return ref;
|
|
}
|
|
|
|
static const IUnknownVtbl unk_vtbl =
|
|
{
|
|
IUnknownImpl_QueryInterface,
|
|
IUnknownImpl_AddRef,
|
|
IUnknownImpl_Release
|
|
};
|
|
|
|
/***************************************************************************
|
|
* IDirectSoundCaptureImpl
|
|
*/
|
|
static inline struct IDirectSoundCaptureImpl *impl_from_IDirectSoundCapture(IDirectSoundCapture *iface)
|
|
{
|
|
return CONTAINING_RECORD(iface, struct IDirectSoundCaptureImpl, IDirectSoundCapture_iface);
|
|
}
|
|
|
|
static HRESULT WINAPI IDirectSoundCaptureImpl_QueryInterface(IDirectSoundCapture *iface,
|
|
REFIID riid, void **ppv)
|
|
{
|
|
IDirectSoundCaptureImpl *This = impl_from_IDirectSoundCapture(iface);
|
|
TRACE("(%p,%s,%p)\n", iface, debugstr_guid(riid), ppv);
|
|
return IUnknown_QueryInterface(This->outer_unk, riid, ppv);
|
|
}
|
|
|
|
static ULONG WINAPI IDirectSoundCaptureImpl_AddRef(IDirectSoundCapture *iface)
|
|
{
|
|
IDirectSoundCaptureImpl *This = impl_from_IDirectSoundCapture(iface);
|
|
ULONG ref = InterlockedIncrement(&This->refdsc);
|
|
|
|
TRACE("(%p) ref=%d\n", This, ref);
|
|
|
|
if(ref == 1)
|
|
InterlockedIncrement(&This->numIfaces);
|
|
return ref;
|
|
}
|
|
|
|
static ULONG WINAPI IDirectSoundCaptureImpl_Release(IDirectSoundCapture *iface)
|
|
{
|
|
IDirectSoundCaptureImpl *This = impl_from_IDirectSoundCapture(iface);
|
|
ULONG ref = InterlockedDecrement(&This->refdsc);
|
|
|
|
TRACE("(%p) ref=%d\n", This, ref);
|
|
|
|
if (!ref && !InterlockedDecrement(&This->numIfaces))
|
|
capture_destroy(This);
|
|
return ref;
|
|
}
|
|
|
|
static HRESULT WINAPI IDirectSoundCaptureImpl_CreateCaptureBuffer(IDirectSoundCapture *iface,
|
|
LPCDSCBUFFERDESC lpcDSCBufferDesc, IDirectSoundCaptureBuffer **lplpDSCaptureBuffer,
|
|
IUnknown *pUnk)
|
|
{
|
|
IDirectSoundCaptureImpl *This = impl_from_IDirectSoundCapture(iface);
|
|
HRESULT hr;
|
|
|
|
TRACE( "(%p,%p,%p,%p)\n",iface,lpcDSCBufferDesc,lplpDSCaptureBuffer,pUnk);
|
|
|
|
if (pUnk) {
|
|
WARN("invalid parameter: pUnk != NULL\n");
|
|
return DSERR_NOAGGREGATION;
|
|
}
|
|
|
|
if (lpcDSCBufferDesc == NULL) {
|
|
WARN("invalid parameter: lpcDSCBufferDesc == NULL)\n");
|
|
return DSERR_INVALIDPARAM;
|
|
}
|
|
|
|
if (lplpDSCaptureBuffer == NULL) {
|
|
WARN("invalid parameter: lplpDSCaptureBuffer == NULL\n");
|
|
return DSERR_INVALIDPARAM;
|
|
}
|
|
|
|
/* FIXME: We can only have one buffer so what do we do here? */
|
|
if (This->device->capture_buffer) {
|
|
WARN("invalid parameter: already has buffer\n");
|
|
return DSERR_INVALIDPARAM; /* DSERR_GENERIC ? */
|
|
}
|
|
|
|
hr = IDirectSoundCaptureBufferImpl_Create(This->device,
|
|
(IDirectSoundCaptureBufferImpl **)lplpDSCaptureBuffer, lpcDSCBufferDesc);
|
|
|
|
if (hr != DS_OK)
|
|
WARN("IDirectSoundCaptureBufferImpl_Create failed\n");
|
|
|
|
return hr;
|
|
}
|
|
|
|
static HRESULT WINAPI IDirectSoundCaptureImpl_GetCaps(IDirectSoundCapture *iface,
|
|
LPDSCCAPS lpDSCCaps)
|
|
{
|
|
IDirectSoundCaptureImpl *This = impl_from_IDirectSoundCapture(iface);
|
|
|
|
TRACE("(%p,%p)\n",This,lpDSCCaps);
|
|
|
|
if (This->device == NULL) {
|
|
WARN("not initialized\n");
|
|
return DSERR_UNINITIALIZED;
|
|
}
|
|
|
|
if (lpDSCCaps== NULL) {
|
|
WARN("invalid parameter: lpDSCCaps== NULL\n");
|
|
return DSERR_INVALIDPARAM;
|
|
}
|
|
|
|
if (lpDSCCaps->dwSize < sizeof(*lpDSCCaps)) {
|
|
WARN("invalid parameter: lpDSCCaps->dwSize = %d\n", lpDSCCaps->dwSize);
|
|
return DSERR_INVALIDPARAM;
|
|
}
|
|
|
|
lpDSCCaps->dwFlags = This->device->drvcaps.dwFlags;
|
|
lpDSCCaps->dwFormats = This->device->drvcaps.dwFormats;
|
|
lpDSCCaps->dwChannels = This->device->drvcaps.dwChannels;
|
|
|
|
TRACE("(flags=0x%08x,format=0x%08x,channels=%d)\n",lpDSCCaps->dwFlags,
|
|
lpDSCCaps->dwFormats, lpDSCCaps->dwChannels);
|
|
|
|
return DS_OK;
|
|
}
|
|
|
|
static HRESULT WINAPI IDirectSoundCaptureImpl_Initialize(IDirectSoundCapture *iface,
|
|
LPCGUID lpcGUID)
|
|
{
|
|
IDirectSoundCaptureImpl *This = impl_from_IDirectSoundCapture(iface);
|
|
|
|
TRACE("(%p,%s)\n", This, debugstr_guid(lpcGUID));
|
|
|
|
if (This->device != NULL) {
|
|
WARN("already initialized\n");
|
|
return DSERR_ALREADYINITIALIZED;
|
|
}
|
|
return DirectSoundCaptureDevice_Initialize(&This->device, lpcGUID);
|
|
}
|
|
|
|
static const IDirectSoundCaptureVtbl dscvt =
|
|
{
|
|
/* IUnknown methods */
|
|
IDirectSoundCaptureImpl_QueryInterface,
|
|
IDirectSoundCaptureImpl_AddRef,
|
|
IDirectSoundCaptureImpl_Release,
|
|
|
|
/* IDirectSoundCapture methods */
|
|
IDirectSoundCaptureImpl_CreateCaptureBuffer,
|
|
IDirectSoundCaptureImpl_GetCaps,
|
|
IDirectSoundCaptureImpl_Initialize
|
|
};
|
|
|
|
HRESULT IDirectSoundCaptureImpl_Create(IUnknown *outer_unk, REFIID riid, void **ppv, BOOL has_dsc8)
|
|
{
|
|
IDirectSoundCaptureImpl *obj;
|
|
HRESULT hr;
|
|
|
|
TRACE("(%s, %p)\n", debugstr_guid(riid), ppv);
|
|
|
|
*ppv = NULL;
|
|
obj = HeapAlloc(GetProcessHeap(), 0, sizeof(*obj));
|
|
if (obj == NULL) {
|
|
WARN("out of memory\n");
|
|
return DSERR_OUTOFMEMORY;
|
|
}
|
|
|
|
setup_dsound_options();
|
|
|
|
obj->IUnknown_inner.lpVtbl = &unk_vtbl;
|
|
obj->IDirectSoundCapture_iface.lpVtbl = &dscvt;
|
|
obj->ref = 1;
|
|
obj->refdsc = 0;
|
|
obj->numIfaces = 1;
|
|
obj->device = NULL;
|
|
obj->has_dsc8 = has_dsc8;
|
|
|
|
/* COM aggregation supported only internally */
|
|
if (outer_unk)
|
|
obj->outer_unk = outer_unk;
|
|
else
|
|
obj->outer_unk = &obj->IUnknown_inner;
|
|
|
|
hr = IUnknown_QueryInterface(&obj->IUnknown_inner, riid, ppv);
|
|
IUnknown_Release(&obj->IUnknown_inner);
|
|
|
|
return hr;
|
|
}
|
|
|
|
HRESULT DSOUND_CaptureCreate(REFIID riid, void **ppv)
|
|
{
|
|
return IDirectSoundCaptureImpl_Create(NULL, riid, ppv, FALSE);
|
|
}
|
|
|
|
HRESULT DSOUND_CaptureCreate8(REFIID riid, void **ppv)
|
|
{
|
|
return IDirectSoundCaptureImpl_Create(NULL, riid, ppv, TRUE);
|
|
}
|
|
|
|
/***************************************************************************
|
|
* DirectSoundCaptureCreate [DSOUND.6]
|
|
*
|
|
* Create and initialize a DirectSoundCapture interface.
|
|
*
|
|
* PARAMS
|
|
* lpcGUID [I] Address of the GUID that identifies the sound capture device.
|
|
* lplpDSC [O] Address of a variable to receive the interface pointer.
|
|
* pUnkOuter [I] Must be NULL.
|
|
*
|
|
* RETURNS
|
|
* Success: DS_OK
|
|
* Failure: DSERR_NOAGGREGATION, DSERR_ALLOCATED, DSERR_INVALIDPARAM,
|
|
* DSERR_OUTOFMEMORY
|
|
*
|
|
* NOTES
|
|
* lpcGUID must be one of the values returned from DirectSoundCaptureEnumerate
|
|
* or NULL for the default device or DSDEVID_DefaultCapture or
|
|
* DSDEVID_DefaultVoiceCapture.
|
|
*
|
|
* DSERR_ALLOCATED is returned for sound devices that do not support full duplex.
|
|
*/
|
|
HRESULT WINAPI DirectSoundCaptureCreate(LPCGUID lpcGUID, IDirectSoundCapture **ppDSC,
|
|
IUnknown *pUnkOuter)
|
|
{
|
|
HRESULT hr;
|
|
IDirectSoundCapture *pDSC;
|
|
|
|
TRACE("(%s,%p,%p)\n", debugstr_guid(lpcGUID), ppDSC, pUnkOuter);
|
|
|
|
if (ppDSC == NULL) {
|
|
WARN("invalid parameter: ppDSC == NULL\n");
|
|
return DSERR_INVALIDPARAM;
|
|
}
|
|
|
|
if (pUnkOuter) {
|
|
WARN("invalid parameter: pUnkOuter != NULL\n");
|
|
return DSERR_NOAGGREGATION;
|
|
}
|
|
|
|
hr = DSOUND_CaptureCreate(&IID_IDirectSoundCapture, (void**)&pDSC);
|
|
if (hr == DS_OK) {
|
|
hr = IDirectSoundCapture_Initialize(pDSC, lpcGUID);
|
|
if (hr != DS_OK) {
|
|
IDirectSoundCapture_Release(pDSC);
|
|
pDSC = 0;
|
|
}
|
|
}
|
|
|
|
*ppDSC = pDSC;
|
|
|
|
return hr;
|
|
}
|
|
|
|
/***************************************************************************
|
|
* DirectSoundCaptureCreate8 [DSOUND.12]
|
|
*
|
|
* Create and initialize a DirectSoundCapture interface.
|
|
*
|
|
* PARAMS
|
|
* lpcGUID [I] Address of the GUID that identifies the sound capture device.
|
|
* lplpDSC [O] Address of a variable to receive the interface pointer.
|
|
* pUnkOuter [I] Must be NULL.
|
|
*
|
|
* RETURNS
|
|
* Success: DS_OK
|
|
* Failure: DSERR_NOAGGREGATION, DSERR_ALLOCATED, DSERR_INVALIDPARAM,
|
|
* DSERR_OUTOFMEMORY
|
|
*
|
|
* NOTES
|
|
* lpcGUID must be one of the values returned from DirectSoundCaptureEnumerate
|
|
* or NULL for the default device or DSDEVID_DefaultCapture or
|
|
* DSDEVID_DefaultVoiceCapture.
|
|
*
|
|
* DSERR_ALLOCATED is returned for sound devices that do not support full duplex.
|
|
*/
|
|
HRESULT WINAPI DirectSoundCaptureCreate8(
|
|
LPCGUID lpcGUID,
|
|
LPDIRECTSOUNDCAPTURE8 *ppDSC8,
|
|
LPUNKNOWN pUnkOuter)
|
|
{
|
|
HRESULT hr;
|
|
LPDIRECTSOUNDCAPTURE8 pDSC8;
|
|
TRACE("(%s,%p,%p)\n", debugstr_guid(lpcGUID), ppDSC8, pUnkOuter);
|
|
|
|
if (ppDSC8 == NULL) {
|
|
WARN("invalid parameter: ppDSC8 == NULL\n");
|
|
return DSERR_INVALIDPARAM;
|
|
}
|
|
|
|
if (pUnkOuter) {
|
|
WARN("invalid parameter: pUnkOuter != NULL\n");
|
|
*ppDSC8 = NULL;
|
|
return DSERR_NOAGGREGATION;
|
|
}
|
|
|
|
hr = DSOUND_CaptureCreate8(&IID_IDirectSoundCapture8, (void**)&pDSC8);
|
|
if (hr == DS_OK) {
|
|
hr = IDirectSoundCapture_Initialize(pDSC8, lpcGUID);
|
|
if (hr != DS_OK) {
|
|
IDirectSoundCapture_Release(pDSC8);
|
|
pDSC8 = 0;
|
|
}
|
|
}
|
|
|
|
*ppDSC8 = pDSC8;
|
|
|
|
return hr;
|
|
}
|