2 * Direct Sound Audio Renderer
4 * Copyright 2004 Christian Costa
6 * This library is free software; you can redistribute it and/or
7 * modify it under the terms of the GNU Lesser General Public
8 * License as published by the Free Software Foundation; either
9 * version 2.1 of the License, or (at your option) any later version.
11 * This library is distributed in the hope that it will be useful,
12 * but WITHOUT ANY WARRANTY; without even the implied warranty of
13 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
14 * Lesser General Public License for more details.
16 * You should have received a copy of the GNU Lesser General Public
17 * License along with this library; if not, write to the Free Software
18 * Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA 02110-1301, USA
23 #include "quartz_private.h"
24 #include "control_private.h"
38 #include "wine/unicode.h"
39 #include "wine/debug.h"
41 WINE_DEFAULT_DEBUG_CHANNEL(quartz);
43 static const WCHAR wcsInputPinName[] = {'i','n','p','u','t',' ','p','i','n',0};
45 static const IBaseFilterVtbl DSoundRender_Vtbl;
46 static const IPinVtbl DSoundRender_InputPin_Vtbl;
47 static const IMemInputPinVtbl MemInputPin_Vtbl;
48 static const IBasicAudioVtbl IBasicAudio_Vtbl;
50 typedef struct DSoundRenderImpl
52 const IBaseFilterVtbl * lpVtbl;
53 const IBasicAudioVtbl *IBasicAudio_vtbl;
56 CRITICAL_SECTION csFilter;
58 REFERENCE_TIME rtStreamStart;
59 IReferenceClock * pClock;
60 FILTER_INFO filterInfo;
66 LPDIRECTSOUNDBUFFER dsbuffer;
72 static HRESULT DSoundRender_InputPin_Construct(const PIN_INFO * pPinInfo, SAMPLEPROC pSampleProc, LPVOID pUserData, QUERYACCEPTPROC pQueryAccept, LPCRITICAL_SECTION pCritSec, IPin ** ppPin)
78 if (pPinInfo->dir != PINDIR_INPUT)
80 ERR("Pin direction(%x) != PINDIR_INPUT\n", pPinInfo->dir);
84 pPinImpl = CoTaskMemAlloc(sizeof(*pPinImpl));
89 if (SUCCEEDED(InputPin_Init(pPinInfo, pSampleProc, pUserData, pQueryAccept, pCritSec, pPinImpl)))
91 pPinImpl->pin.lpVtbl = &DSoundRender_InputPin_Vtbl;
92 pPinImpl->lpVtblMemInput = &MemInputPin_Vtbl;
94 *ppPin = (IPin *)(&pPinImpl->pin.lpVtbl);
101 #define DSBUFFERSIZE 8192
103 static HRESULT DSoundRender_CreateSoundBuffer(IBaseFilter * iface)
106 WAVEFORMATEX wav_fmt;
108 WAVEFORMATEX* format;
109 DSBUFFERDESC buf_desc;
110 DSoundRenderImpl *This = (DSoundRenderImpl *)iface;
112 hr = IPin_ConnectionMediaType(This->ppPins[0], &amt);
114 ERR("Unable to retrieve media type\n");
118 TRACE("MajorType %s\n", debugstr_guid(&amt.majortype));
119 TRACE("SubType %s\n", debugstr_guid(&amt.subtype));
120 TRACE("Format %s\n", debugstr_guid(&amt.formattype));
121 TRACE("Size %d\n", amt.cbFormat);
123 dump_AM_MEDIA_TYPE(&amt);
125 format = (WAVEFORMATEX*)amt.pbFormat;
126 TRACE("wFormatTag = %x %x\n", format->wFormatTag, WAVE_FORMAT_PCM);
127 TRACE("nChannels = %d\n", format->nChannels);
128 TRACE("nSamplesPerSec = %u\n", format->nSamplesPerSec);
129 TRACE("nAvgBytesPerSec = %u\n", format->nAvgBytesPerSec);
130 TRACE("nBlockAlign = %d\n", format->nBlockAlign);
131 TRACE("wBitsPerSample = %d\n", format->wBitsPerSample);
132 TRACE("cbSize = %d\n", format->cbSize);
134 hr = DirectSoundCreate(NULL, &This->dsound, NULL);
136 ERR("Cannot create Direct Sound object\n");
143 memset(&buf_desc,0,sizeof(DSBUFFERDESC));
144 buf_desc.dwSize = sizeof(DSBUFFERDESC);
145 buf_desc.dwBufferBytes = DSBUFFERSIZE;
146 buf_desc.lpwfxFormat = &wav_fmt;
147 hr = IDirectSound_CreateSoundBuffer(This->dsound, &buf_desc, &This->dsbuffer, NULL);
149 ERR("Can't create sound buffer !\n");
150 IDirectSound_Release(This->dsound);
159 static HRESULT DSoundRender_SendSampleData(DSoundRenderImpl* This, LPBYTE data, DWORD size)
162 LPBYTE lpbuf1 = NULL;
163 LPBYTE lpbuf2 = NULL;
167 DWORD play_pos,buf_free;
171 hr = IDirectSoundBuffer_GetCurrentPosition(This->dsbuffer, &play_pos, NULL);
174 ERR("Error GetCurrentPosition: %x\n", hr);
177 if (This->write_pos < play_pos)
178 buf_free = play_pos-This->write_pos;
180 buf_free = DSBUFFERSIZE - This->write_pos + play_pos;
182 /* This situation is ambiguous; Assume full when playing */
183 if(buf_free == DSBUFFERSIZE && This->started)
189 size2 = min(buf_free, size);
190 hr = IDirectSoundBuffer_Lock(This->dsbuffer, This->write_pos, size2, &lpbuf1, &dwsize1, &lpbuf2, &dwsize2, 0);
192 ERR("Unable to lock sound buffer! (%x)\n", hr);
195 /* TRACE("write_pos=%d, size=%d, sz1=%d, sz2=%d\n", This->write_pos, size2, dwsize1, dwsize2); */
197 memcpy(lpbuf1, data, dwsize1);
199 memcpy(lpbuf2, data + dwsize1, dwsize2);
201 hr = IDirectSoundBuffer_Unlock(This->dsbuffer, lpbuf1, dwsize1, lpbuf2, dwsize2);
203 ERR("Unable to unlock sound buffer! (%x)\n", hr);
206 hr = IDirectSoundBuffer_Play(This->dsbuffer, 0, 0, DSBPLAY_LOOPING);
208 This->started = TRUE;
210 ERR("Can't start playing! (%x)\n", hr);
212 size -= dwsize1 + dwsize2;
213 data += dwsize1 + dwsize2;
214 This->write_pos = (This->write_pos + dwsize1 + dwsize2) % DSBUFFERSIZE;
224 static HRESULT DSoundRender_Sample(LPVOID iface, IMediaSample * pSample)
226 DSoundRenderImpl *This = (DSoundRenderImpl *)iface;
227 LPBYTE pbSrcStream = NULL;
228 long cbSrcStream = 0;
229 REFERENCE_TIME tStart, tStop;
232 TRACE("%p %p\n", iface, pSample);
234 hr = IMediaSample_GetPointer(pSample, &pbSrcStream);
237 ERR("Cannot get pointer to sample data (%x)\n", hr);
241 hr = IMediaSample_GetTime(pSample, &tStart, &tStop);
243 ERR("Cannot get sample time (%x)\n", hr);
245 cbSrcStream = IMediaSample_GetActualDataLength(pSample);
247 TRACE("Sample data ptr = %p, size = %ld\n", pbSrcStream, cbSrcStream);
249 #if 0 /* For debugging purpose */
252 for(i = 0; i < cbSrcStream; i++)
254 if ((i!=0) && !(i%16))
256 TRACE("%02x ", pbSrcStream[i]);
264 hr = DSoundRender_CreateSoundBuffer(iface);
269 ERR("Unable to create DSound buffer\n");
274 hr = DSoundRender_SendSampleData(This, pbSrcStream, cbSrcStream);
279 static HRESULT DSoundRender_QueryAccept(LPVOID iface, const AM_MEDIA_TYPE * pmt)
281 WAVEFORMATEX* format = (WAVEFORMATEX*)pmt->pbFormat;
282 TRACE("wFormatTag = %x %x\n", format->wFormatTag, WAVE_FORMAT_PCM);
283 TRACE("nChannels = %d\n", format->nChannels);
284 TRACE("nSamplesPerSec = %d\n", format->nAvgBytesPerSec);
285 TRACE("nAvgBytesPerSec = %d\n", format->nAvgBytesPerSec);
286 TRACE("nBlockAlign = %d\n", format->nBlockAlign);
287 TRACE("wBitsPerSample = %d\n", format->wBitsPerSample);
289 if (IsEqualIID(&pmt->majortype, &MEDIATYPE_Audio) && IsEqualIID(&pmt->subtype, &MEDIASUBTYPE_PCM))
294 HRESULT DSoundRender_create(IUnknown * pUnkOuter, LPVOID * ppv)
298 DSoundRenderImpl * pDSoundRender;
300 TRACE("(%p, %p)\n", pUnkOuter, ppv);
305 return CLASS_E_NOAGGREGATION;
307 pDSoundRender = CoTaskMemAlloc(sizeof(DSoundRenderImpl));
309 pDSoundRender->lpVtbl = &DSoundRender_Vtbl;
310 pDSoundRender->IBasicAudio_vtbl = &IBasicAudio_Vtbl;
311 pDSoundRender->refCount = 1;
312 InitializeCriticalSection(&pDSoundRender->csFilter);
313 pDSoundRender->state = State_Stopped;
314 pDSoundRender->pClock = NULL;
315 pDSoundRender->init = FALSE;
316 pDSoundRender->started = FALSE;
317 ZeroMemory(&pDSoundRender->filterInfo, sizeof(FILTER_INFO));
319 pDSoundRender->ppPins = CoTaskMemAlloc(1 * sizeof(IPin *));
321 /* construct input pin */
322 piInput.dir = PINDIR_INPUT;
323 piInput.pFilter = (IBaseFilter *)pDSoundRender;
324 lstrcpynW(piInput.achName, wcsInputPinName, sizeof(piInput.achName) / sizeof(piInput.achName[0]));
325 hr = DSoundRender_InputPin_Construct(&piInput, DSoundRender_Sample, (LPVOID)pDSoundRender, DSoundRender_QueryAccept, &pDSoundRender->csFilter, (IPin **)&pDSoundRender->pInputPin);
329 pDSoundRender->ppPins[0] = (IPin *)pDSoundRender->pInputPin;
330 *ppv = (LPVOID)pDSoundRender;
334 CoTaskMemFree(pDSoundRender->ppPins);
335 DeleteCriticalSection(&pDSoundRender->csFilter);
336 CoTaskMemFree(pDSoundRender);
342 static HRESULT WINAPI DSoundRender_QueryInterface(IBaseFilter * iface, REFIID riid, LPVOID * ppv)
344 DSoundRenderImpl *This = (DSoundRenderImpl *)iface;
345 TRACE("(%p, %p)->(%s, %p)\n", This, iface, qzdebugstr_guid(riid), ppv);
349 if (IsEqualIID(riid, &IID_IUnknown))
351 else if (IsEqualIID(riid, &IID_IPersist))
353 else if (IsEqualIID(riid, &IID_IMediaFilter))
355 else if (IsEqualIID(riid, &IID_IBaseFilter))
357 else if (IsEqualIID(riid, &IID_IBaseFilter))
358 *ppv = (LPVOID)&(This->IBasicAudio_vtbl);
362 IUnknown_AddRef((IUnknown *)(*ppv));
366 FIXME("No interface for %s!\n", qzdebugstr_guid(riid));
368 return E_NOINTERFACE;
371 static ULONG WINAPI DSoundRender_AddRef(IBaseFilter * iface)
373 DSoundRenderImpl *This = (DSoundRenderImpl *)iface;
374 ULONG refCount = InterlockedIncrement(&This->refCount);
376 TRACE("(%p/%p)->() AddRef from %d\n", This, iface, refCount - 1);
381 static ULONG WINAPI DSoundRender_Release(IBaseFilter * iface)
383 DSoundRenderImpl *This = (DSoundRenderImpl *)iface;
384 ULONG refCount = InterlockedDecrement(&This->refCount);
386 TRACE("(%p/%p)->() Release from %d\n", This, iface, refCount + 1);
390 DeleteCriticalSection(&This->csFilter);
392 IReferenceClock_Release(This->pClock);
394 IPin_Release(This->ppPins[0]);
396 HeapFree(GetProcessHeap(), 0, This->ppPins);
398 This->IBasicAudio_vtbl = NULL;
400 TRACE("Destroying Audio Renderer\n");
409 /** IPersist methods **/
411 static HRESULT WINAPI DSoundRender_GetClassID(IBaseFilter * iface, CLSID * pClsid)
413 DSoundRenderImpl *This = (DSoundRenderImpl *)iface;
414 TRACE("(%p/%p)->(%p)\n", This, iface, pClsid);
416 *pClsid = CLSID_DSoundRender;
421 /** IMediaFilter methods **/
423 static HRESULT WINAPI DSoundRender_Stop(IBaseFilter * iface)
426 DSoundRenderImpl *This = (DSoundRenderImpl *)iface;
428 TRACE("(%p/%p)->()\n", This, iface);
430 EnterCriticalSection(&This->csFilter);
432 This->state = State_Stopped;
434 LeaveCriticalSection(&This->csFilter);
439 static HRESULT WINAPI DSoundRender_Pause(IBaseFilter * iface)
442 DSoundRenderImpl *This = (DSoundRenderImpl *)iface;
444 TRACE("(%p/%p)->()\n", This, iface);
446 EnterCriticalSection(&This->csFilter);
448 This->state = State_Paused;
450 LeaveCriticalSection(&This->csFilter);
455 static HRESULT WINAPI DSoundRender_Run(IBaseFilter * iface, REFERENCE_TIME tStart)
458 DSoundRenderImpl *This = (DSoundRenderImpl *)iface;
460 TRACE("(%p/%p)->(%s)\n", This, iface, wine_dbgstr_longlong(tStart));
462 EnterCriticalSection(&This->csFilter);
464 This->rtStreamStart = tStart;
465 This->state = State_Running;
467 LeaveCriticalSection(&This->csFilter);
472 static HRESULT WINAPI DSoundRender_GetState(IBaseFilter * iface, DWORD dwMilliSecsTimeout, FILTER_STATE *pState)
474 DSoundRenderImpl *This = (DSoundRenderImpl *)iface;
476 TRACE("(%p/%p)->(%d, %p)\n", This, iface, dwMilliSecsTimeout, pState);
478 EnterCriticalSection(&This->csFilter);
480 *pState = This->state;
482 LeaveCriticalSection(&This->csFilter);
487 static HRESULT WINAPI DSoundRender_SetSyncSource(IBaseFilter * iface, IReferenceClock *pClock)
489 DSoundRenderImpl *This = (DSoundRenderImpl *)iface;
491 TRACE("(%p/%p)->(%p)\n", This, iface, pClock);
493 EnterCriticalSection(&This->csFilter);
496 IReferenceClock_Release(This->pClock);
497 This->pClock = pClock;
499 IReferenceClock_AddRef(This->pClock);
501 LeaveCriticalSection(&This->csFilter);
506 static HRESULT WINAPI DSoundRender_GetSyncSource(IBaseFilter * iface, IReferenceClock **ppClock)
508 DSoundRenderImpl *This = (DSoundRenderImpl *)iface;
510 TRACE("(%p/%p)->(%p)\n", This, iface, ppClock);
512 EnterCriticalSection(&This->csFilter);
514 *ppClock = This->pClock;
515 IReferenceClock_AddRef(This->pClock);
517 LeaveCriticalSection(&This->csFilter);
522 /** IBaseFilter implementation **/
524 static HRESULT WINAPI DSoundRender_EnumPins(IBaseFilter * iface, IEnumPins **ppEnum)
527 DSoundRenderImpl *This = (DSoundRenderImpl *)iface;
529 TRACE("(%p/%p)->(%p)\n", This, iface, ppEnum);
531 epd.cPins = 1; /* input pin */
532 epd.ppPins = This->ppPins;
533 return IEnumPinsImpl_Construct(&epd, ppEnum);
536 static HRESULT WINAPI DSoundRender_FindPin(IBaseFilter * iface, LPCWSTR Id, IPin **ppPin)
538 DSoundRenderImpl *This = (DSoundRenderImpl *)iface;
540 TRACE("(%p/%p)->(%s,%p)\n", This, iface, debugstr_w(Id), ppPin);
542 FIXME("DSoundRender::FindPin(...)\n");
544 /* FIXME: critical section */
549 static HRESULT WINAPI DSoundRender_QueryFilterInfo(IBaseFilter * iface, FILTER_INFO *pInfo)
551 DSoundRenderImpl *This = (DSoundRenderImpl *)iface;
553 TRACE("(%p/%p)->(%p)\n", This, iface, pInfo);
555 strcpyW(pInfo->achName, This->filterInfo.achName);
556 pInfo->pGraph = This->filterInfo.pGraph;
559 IFilterGraph_AddRef(pInfo->pGraph);
564 static HRESULT WINAPI DSoundRender_JoinFilterGraph(IBaseFilter * iface, IFilterGraph *pGraph, LPCWSTR pName)
566 DSoundRenderImpl *This = (DSoundRenderImpl *)iface;
568 TRACE("(%p/%p)->(%p, %s)\n", This, iface, pGraph, debugstr_w(pName));
570 EnterCriticalSection(&This->csFilter);
573 strcpyW(This->filterInfo.achName, pName);
575 *This->filterInfo.achName = '\0';
576 This->filterInfo.pGraph = pGraph; /* NOTE: do NOT increase ref. count */
578 LeaveCriticalSection(&This->csFilter);
583 static HRESULT WINAPI DSoundRender_QueryVendorInfo(IBaseFilter * iface, LPWSTR *pVendorInfo)
585 DSoundRenderImpl *This = (DSoundRenderImpl *)iface;
586 TRACE("(%p/%p)->(%p)\n", This, iface, pVendorInfo);
590 static const IBaseFilterVtbl DSoundRender_Vtbl =
592 DSoundRender_QueryInterface,
594 DSoundRender_Release,
595 DSoundRender_GetClassID,
599 DSoundRender_GetState,
600 DSoundRender_SetSyncSource,
601 DSoundRender_GetSyncSource,
602 DSoundRender_EnumPins,
603 DSoundRender_FindPin,
604 DSoundRender_QueryFilterInfo,
605 DSoundRender_JoinFilterGraph,
606 DSoundRender_QueryVendorInfo
609 static HRESULT WINAPI DSoundRender_InputPin_EndOfStream(IPin * iface)
611 InputPin* This = (InputPin*)iface;
612 IMediaEventSink* pEventSink;
615 TRACE("(%p/%p)->()\n", This, iface);
617 hr = IFilterGraph_QueryInterface(((DSoundRenderImpl*)This->pin.pinInfo.pFilter)->filterInfo.pGraph, &IID_IMediaEventSink, (LPVOID*)&pEventSink);
620 /* FIXME: We should wait that all audio data has been played */
621 hr = IMediaEventSink_Notify(pEventSink, EC_COMPLETE, S_OK, 0);
622 IMediaEventSink_Release(pEventSink);
628 static const IPinVtbl DSoundRender_InputPin_Vtbl =
630 InputPin_QueryInterface,
634 InputPin_ReceiveConnection,
636 IPinImpl_ConnectedTo,
637 IPinImpl_ConnectionMediaType,
638 IPinImpl_QueryPinInfo,
639 IPinImpl_QueryDirection,
641 IPinImpl_QueryAccept,
642 IPinImpl_EnumMediaTypes,
643 IPinImpl_QueryInternalConnections,
644 DSoundRender_InputPin_EndOfStream,
650 static const IMemInputPinVtbl MemInputPin_Vtbl =
652 MemInputPin_QueryInterface,
655 MemInputPin_GetAllocator,
656 MemInputPin_NotifyAllocator,
657 MemInputPin_GetAllocatorRequirements,
659 MemInputPin_ReceiveMultiple,
660 MemInputPin_ReceiveCanBlock
663 /*** IUnknown methods ***/
664 static HRESULT WINAPI Basicaudio_QueryInterface(IBasicAudio *iface,
667 ICOM_THIS_MULTI(DSoundRenderImpl, IBasicAudio_vtbl, iface);
669 TRACE("(%p/%p)->(%s (%p), %p)\n", This, iface, debugstr_guid(riid), riid, ppvObj);
671 return DSoundRender_QueryInterface((IBaseFilter*)This, riid, ppvObj);
674 static ULONG WINAPI Basicaudio_AddRef(IBasicAudio *iface) {
675 ICOM_THIS_MULTI(DSoundRenderImpl, IBasicAudio_vtbl, iface);
677 TRACE("(%p/%p)->()\n", This, iface);
679 return DSoundRender_AddRef((IBaseFilter*)This);
682 static ULONG WINAPI Basicaudio_Release(IBasicAudio *iface) {
683 ICOM_THIS_MULTI(DSoundRenderImpl, IBasicAudio_vtbl, iface);
685 TRACE("(%p/%p)->()\n", This, iface);
687 return DSoundRender_Release((IBaseFilter*)This);
690 /*** IDispatch methods ***/
691 static HRESULT WINAPI Basicaudio_GetTypeInfoCount(IBasicAudio *iface,
693 ICOM_THIS_MULTI(DSoundRenderImpl, IBasicAudio_vtbl, iface);
695 TRACE("(%p/%p)->(%p): stub !!!\n", This, iface, pctinfo);
700 static HRESULT WINAPI Basicaudio_GetTypeInfo(IBasicAudio *iface,
703 ITypeInfo**ppTInfo) {
704 ICOM_THIS_MULTI(DSoundRenderImpl, IBasicAudio_vtbl, iface);
706 TRACE("(%p/%p)->(%d, %d, %p): stub !!!\n", This, iface, iTInfo, lcid, ppTInfo);
711 static HRESULT WINAPI Basicaudio_GetIDsOfNames(IBasicAudio *iface,
717 ICOM_THIS_MULTI(DSoundRenderImpl, IBasicAudio_vtbl, iface);
719 TRACE("(%p/%p)->(%s (%p), %p, %d, %d, %p): stub !!!\n", This, iface, debugstr_guid(riid), riid, rgszNames, cNames, lcid, rgDispId);
724 static HRESULT WINAPI Basicaudio_Invoke(IBasicAudio *iface,
729 DISPPARAMS*pDispParams,
733 ICOM_THIS_MULTI(DSoundRenderImpl, IBasicAudio_vtbl, iface);
735 TRACE("(%p/%p)->(%d, %s (%p), %d, %04x, %p, %p, %p, %p): stub !!!\n", This, iface, dispIdMember, debugstr_guid(riid), riid, lcid, wFlags, pDispParams, pVarResult, pExepInfo, puArgErr);
740 /*** IBasicAudio methods ***/
741 static HRESULT WINAPI Basicaudio_put_Volume(IBasicAudio *iface,
743 ICOM_THIS_MULTI(DSoundRenderImpl, IBasicAudio_vtbl, iface);
745 TRACE("(%p/%p)->(%ld): stub !!!\n", This, iface, lVolume);
750 static HRESULT WINAPI Basicaudio_get_Volume(IBasicAudio *iface,
752 ICOM_THIS_MULTI(DSoundRenderImpl, IBasicAudio_vtbl, iface);
754 TRACE("(%p/%p)->(%p): stub !!!\n", This, iface, plVolume);
759 static HRESULT WINAPI Basicaudio_put_Balance(IBasicAudio *iface,
761 ICOM_THIS_MULTI(DSoundRenderImpl, IBasicAudio_vtbl, iface);
763 TRACE("(%p/%p)->(%ld): stub !!!\n", This, iface, lBalance);
768 static HRESULT WINAPI Basicaudio_get_Balance(IBasicAudio *iface,
770 ICOM_THIS_MULTI(DSoundRenderImpl, IBasicAudio_vtbl, iface);
772 TRACE("(%p/%p)->(%p): stub !!!\n", This, iface, plBalance);
777 static const IBasicAudioVtbl IBasicAudio_Vtbl =
779 Basicaudio_QueryInterface,
782 Basicaudio_GetTypeInfoCount,
783 Basicaudio_GetTypeInfo,
784 Basicaudio_GetIDsOfNames,
786 Basicaudio_put_Volume,
787 Basicaudio_get_Volume,
788 Basicaudio_put_Balance,
789 Basicaudio_get_Balance