| /* 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 |
| |
| #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, has_dsc8; |
| /* 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 ( IsEqualIID( &IID_IUnknown, riid ) || |
| IsEqualIID( &IID_IDirectSoundCaptureBuffer, riid ) || |
| (This->has_dsc8 && IsEqualIID( &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) |
| { |
| 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; |
| |
| while(1){ |
| HRESULT hr; |
| UINT32 packet_frames, packet_bytes, avail_bytes, skip_bytes = 0; |
| DWORD flags; |
| BYTE *buf; |
| |
| hr = IAudioCaptureClient_GetBuffer(device->capture, &buf, &packet_frames, |
| &flags, NULL, NULL); |
| if(FAILED(hr)){ |
| WARN("GetBuffer failed: %08x\n", hr); |
| return hr; |
| } |
| if(hr == AUDCLNT_S_BUFFER_EMPTY) |
| break; |
| |
| 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"); |
| else |
| This->device->capture_buffer->has_dsc8 = This->has_dsc8; |
| |
| 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; |
| } |
