2 * Parser (Base for parsers and splitters)
4 * Copyright 2003 Robert Shearman
5 * Copyright 2004-2005 Christian Costa
7 * This library is free software; you can redistribute it and/or
8 * modify it under the terms of the GNU Lesser General Public
9 * License as published by the Free Software Foundation; either
10 * version 2.1 of the License, or (at your option) any later version.
12 * This library is distributed in the hope that it will be useful,
13 * but WITHOUT ANY WARRANTY; without even the implied warranty of
14 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
15 * Lesser General Public License for more details.
17 * You should have received a copy of the GNU Lesser General Public
18 * License along with this library; if not, write to the Free Software
19 * Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA 02110-1301, USA
22 #include "quartz_private.h"
23 #include "control_private.h"
29 #include "wine/unicode.h"
30 #include "wine/debug.h"
37 WINE_DEFAULT_DEBUG_CHANNEL(quartz);
39 static const WCHAR wcsInputPinName[] = {'i','n','p','u','t',' ','p','i','n',0};
40 static const IMediaSeekingVtbl Parser_Seeking_Vtbl;
41 static const IPinVtbl Parser_OutputPin_Vtbl;
42 static const IPinVtbl Parser_InputPin_Vtbl;
44 static HRESULT Parser_OutputPin_QueryAccept(LPVOID iface, const AM_MEDIA_TYPE * pmt);
45 static HRESULT Parser_ChangeCurrent(IBaseFilter *iface);
46 static HRESULT Parser_ChangeStop(IBaseFilter *iface);
47 static HRESULT Parser_ChangeRate(IBaseFilter *iface);
49 static inline ParserImpl *impl_from_IMediaSeeking( IMediaSeeking *iface )
51 return (ParserImpl *)((char*)iface - FIELD_OFFSET(ParserImpl, mediaSeeking.lpVtbl));
55 HRESULT Parser_Create(ParserImpl* pParser, const IBaseFilterVtbl *Parser_Vtbl, const CLSID* pClsid, PFN_PROCESS_SAMPLE fnProcessSample, PFN_QUERY_ACCEPT fnQueryAccept, PFN_PRE_CONNECT fnPreConnect, PFN_CLEANUP fnCleanup, PFN_DISCONNECT fnDisconnect, REQUESTPROC fnRequest, CHANGEPROC stop, CHANGEPROC current, CHANGEPROC rate)
60 /* pTransformFilter is already allocated */
61 pParser->clsid = *pClsid;
62 pParser->lpVtbl = Parser_Vtbl;
63 pParser->refCount = 1;
64 InitializeCriticalSection(&pParser->csFilter);
65 pParser->csFilter.DebugInfo->Spare[0] = (DWORD_PTR)(__FILE__ ": ParserImpl.csFilter");
66 pParser->state = State_Stopped;
67 pParser->pClock = NULL;
68 pParser->fnDisconnect = fnDisconnect;
69 ZeroMemory(&pParser->filterInfo, sizeof(FILTER_INFO));
71 pParser->cStreams = 0;
72 pParser->ppPins = CoTaskMemAlloc(1 * sizeof(IPin *));
74 /* construct input pin */
75 piInput.dir = PINDIR_INPUT;
76 piInput.pFilter = (IBaseFilter *)pParser;
77 lstrcpynW(piInput.achName, wcsInputPinName, sizeof(piInput.achName) / sizeof(piInput.achName[0]));
80 current = Parser_ChangeCurrent;
83 stop = Parser_ChangeStop;
86 rate = Parser_ChangeRate;
88 MediaSeekingImpl_Init((IBaseFilter*)pParser, stop, current, rate, &pParser->mediaSeeking, &pParser->csFilter);
89 pParser->mediaSeeking.lpVtbl = &Parser_Seeking_Vtbl;
91 hr = PullPin_Construct(&Parser_InputPin_Vtbl, &piInput, fnProcessSample, (LPVOID)pParser, fnQueryAccept, fnCleanup, fnRequest, &pParser->csFilter, (IPin **)&pParser->pInputPin);
95 pParser->ppPins[0] = (IPin *)pParser->pInputPin;
96 pParser->pInputPin->fnPreConnect = fnPreConnect;
100 CoTaskMemFree(pParser->ppPins);
101 pParser->csFilter.DebugInfo->Spare[0] = 0;
102 DeleteCriticalSection(&pParser->csFilter);
103 CoTaskMemFree(pParser);
109 HRESULT WINAPI Parser_QueryInterface(IBaseFilter * iface, REFIID riid, LPVOID * ppv)
111 ParserImpl *This = (ParserImpl *)iface;
112 TRACE("(%s, %p)\n", qzdebugstr_guid(riid), ppv);
116 if (IsEqualIID(riid, &IID_IUnknown))
118 else if (IsEqualIID(riid, &IID_IPersist))
120 else if (IsEqualIID(riid, &IID_IMediaFilter))
122 else if (IsEqualIID(riid, &IID_IBaseFilter))
124 else if (IsEqualIID(riid, &IID_IMediaSeeking))
125 *ppv = (LPVOID)&This->mediaSeeking;
129 IUnknown_AddRef((IUnknown *)(*ppv));
133 if (!IsEqualIID(riid, &IID_IPin) && !IsEqualIID(riid, &IID_IVideoWindow))
134 FIXME("No interface for %s!\n", qzdebugstr_guid(riid));
136 return E_NOINTERFACE;
139 ULONG WINAPI Parser_AddRef(IBaseFilter * iface)
141 ParserImpl *This = (ParserImpl *)iface;
142 ULONG refCount = InterlockedIncrement(&This->refCount);
144 TRACE("(%p/%p)->() AddRef from %d\n", This, iface, refCount - 1);
149 void Parser_Destroy(ParserImpl *This)
151 IPin *connected = NULL;
154 IReferenceClock_Release(This->pClock);
156 /* Don't need to clean up output pins, freeing input pin will do that */
157 IPin_ConnectedTo((IPin *)This->pInputPin, &connected);
160 IPin_Disconnect(connected);
161 IPin_Release(connected);
162 IPin_Disconnect((IPin *)This->pInputPin);
164 IPin_Release((IPin *)This->pInputPin);
165 CoTaskMemFree(This->ppPins);
168 This->csFilter.DebugInfo->Spare[0] = 0;
169 DeleteCriticalSection(&This->csFilter);
171 TRACE("Destroying parser\n");
175 ULONG WINAPI Parser_Release(IBaseFilter * iface)
177 ParserImpl *This = (ParserImpl *)iface;
178 ULONG refCount = InterlockedDecrement(&This->refCount);
180 TRACE("(%p)->() Release from %d\n", This, refCount + 1);
183 Parser_Destroy(This);
188 /** IPersist methods **/
190 HRESULT WINAPI Parser_GetClassID(IBaseFilter * iface, CLSID * pClsid)
192 ParserImpl *This = (ParserImpl *)iface;
194 TRACE("(%p)\n", pClsid);
196 *pClsid = This->clsid;
201 /** IMediaFilter methods **/
203 HRESULT WINAPI Parser_Stop(IBaseFilter * iface)
206 ParserImpl *This = (ParserImpl *)iface;
207 PullPin *pin = (PullPin *)This->ppPins[0];
211 EnterCriticalSection(&pin->thread_lock);
212 EnterCriticalSection(&This->csFilter);
214 if (This->state == State_Stopped)
216 LeaveCriticalSection(&This->csFilter);
217 LeaveCriticalSection(&pin->thread_lock);
220 This->state = State_Stopped;
222 LeaveCriticalSection(&This->csFilter);
224 hr = PullPin_StopProcessing(This->pInputPin);
225 LeaveCriticalSection(&pin->thread_lock);
229 HRESULT WINAPI Parser_Pause(IBaseFilter * iface)
232 ParserImpl *This = (ParserImpl *)iface;
233 PullPin *pin = (PullPin *)This->ppPins[0];
237 EnterCriticalSection(&pin->thread_lock);
238 EnterCriticalSection(&This->csFilter);
240 if (This->state == State_Paused)
242 LeaveCriticalSection(&This->csFilter);
243 LeaveCriticalSection(&pin->thread_lock);
247 if (This->state == State_Stopped)
249 LeaveCriticalSection(&This->csFilter);
250 hr = IBaseFilter_Run(iface, -1);
251 EnterCriticalSection(&This->csFilter);
254 This->state = State_Paused;
256 LeaveCriticalSection(&This->csFilter);
258 hr = PullPin_PauseProcessing(This->pInputPin);
259 LeaveCriticalSection(&pin->thread_lock);
264 HRESULT WINAPI Parser_Run(IBaseFilter * iface, REFERENCE_TIME tStart)
267 ParserImpl *This = (ParserImpl *)iface;
268 PullPin *pin = (PullPin *)This->ppPins[0];
272 TRACE("(%s)\n", wine_dbgstr_longlong(tStart));
274 EnterCriticalSection(&pin->thread_lock);
275 EnterCriticalSection(&This->csFilter);
277 if (This->state == State_Running)
279 LeaveCriticalSection(&This->csFilter);
280 LeaveCriticalSection(&pin->thread_lock);
284 This->rtStreamStart = tStart;
286 if (SUCCEEDED(hr) && (This->state == State_Stopped))
288 LeaveCriticalSection(&This->csFilter);
289 hr = PullPin_InitProcessing(This->pInputPin);
290 EnterCriticalSection(&This->csFilter);
294 for (i = 1; i < (This->cStreams + 1); i++)
296 OutputPin_CommitAllocator((OutputPin *)This->ppPins[i]);
303 LeaveCriticalSection(&This->csFilter);
304 hr = PullPin_StartProcessing(This->pInputPin);
305 EnterCriticalSection(&This->csFilter);
309 This->state = State_Running;
311 LeaveCriticalSection(&This->csFilter);
312 LeaveCriticalSection(&pin->thread_lock);
317 HRESULT WINAPI Parser_GetState(IBaseFilter * iface, DWORD dwMilliSecsTimeout, FILTER_STATE *pState)
319 ParserImpl *This = (ParserImpl *)iface;
320 PullPin *pin = (PullPin *)This->ppPins[0];
323 TRACE("(%d, %p)\n", dwMilliSecsTimeout, pState);
325 EnterCriticalSection(&pin->thread_lock);
326 EnterCriticalSection(&This->csFilter);
328 *pState = This->state;
330 LeaveCriticalSection(&This->csFilter);
332 if (This->pInputPin && (PullPin_WaitForStateChange(This->pInputPin, dwMilliSecsTimeout) == S_FALSE))
333 hr = VFW_S_STATE_INTERMEDIATE;
334 LeaveCriticalSection(&pin->thread_lock);
339 HRESULT WINAPI Parser_SetSyncSource(IBaseFilter * iface, IReferenceClock *pClock)
341 ParserImpl *This = (ParserImpl *)iface;
342 PullPin *pin = (PullPin *)This->ppPins[0];
344 TRACE("(%p)\n", pClock);
346 EnterCriticalSection(&pin->thread_lock);
347 EnterCriticalSection(&This->csFilter);
350 IReferenceClock_Release(This->pClock);
351 This->pClock = pClock;
353 IReferenceClock_AddRef(This->pClock);
355 LeaveCriticalSection(&This->csFilter);
356 LeaveCriticalSection(&pin->thread_lock);
361 HRESULT WINAPI Parser_GetSyncSource(IBaseFilter * iface, IReferenceClock **ppClock)
363 ParserImpl *This = (ParserImpl *)iface;
365 TRACE("(%p)\n", ppClock);
367 EnterCriticalSection(&This->csFilter);
369 *ppClock = This->pClock;
371 IReferenceClock_AddRef(This->pClock);
373 LeaveCriticalSection(&This->csFilter);
378 /** IBaseFilter implementation **/
380 HRESULT WINAPI Parser_EnumPins(IBaseFilter * iface, IEnumPins **ppEnum)
383 ParserImpl *This = (ParserImpl *)iface;
385 TRACE("(%p)\n", ppEnum);
387 epd.cPins = This->cStreams + 1; /* +1 for input pin */
388 epd.ppPins = This->ppPins;
389 return IEnumPinsImpl_Construct(&epd, ppEnum);
392 HRESULT WINAPI Parser_FindPin(IBaseFilter * iface, LPCWSTR Id, IPin **ppPin)
394 FIXME("(%p)->(%s,%p)\n", iface, debugstr_w(Id), ppPin);
396 /* FIXME: critical section */
401 HRESULT WINAPI Parser_QueryFilterInfo(IBaseFilter * iface, FILTER_INFO *pInfo)
403 ParserImpl *This = (ParserImpl *)iface;
405 TRACE("(%p)\n", pInfo);
407 strcpyW(pInfo->achName, This->filterInfo.achName);
408 pInfo->pGraph = This->filterInfo.pGraph;
411 IFilterGraph_AddRef(pInfo->pGraph);
416 HRESULT WINAPI Parser_JoinFilterGraph(IBaseFilter * iface, IFilterGraph *pGraph, LPCWSTR pName)
419 ParserImpl *This = (ParserImpl *)iface;
421 TRACE("(%p, %s)\n", pGraph, debugstr_w(pName));
423 EnterCriticalSection(&This->csFilter);
426 strcpyW(This->filterInfo.achName, pName);
428 *This->filterInfo.achName = '\0';
429 This->filterInfo.pGraph = pGraph; /* NOTE: do NOT increase ref. count */
431 LeaveCriticalSection(&This->csFilter);
436 HRESULT WINAPI Parser_QueryVendorInfo(IBaseFilter * iface, LPWSTR *pVendorInfo)
438 TRACE("(%p)\n", pVendorInfo);
442 HRESULT Parser_AddPin(ParserImpl * This, const PIN_INFO * piOutput, ALLOCATOR_PROPERTIES * props, const AM_MEDIA_TYPE * amt)
447 ppOldPins = This->ppPins;
449 This->ppPins = CoTaskMemAlloc((This->cStreams + 2) * sizeof(IPin *));
450 memcpy(This->ppPins, ppOldPins, (This->cStreams + 1) * sizeof(IPin *));
452 hr = OutputPin_Construct(&Parser_OutputPin_Vtbl, sizeof(Parser_OutputPin), piOutput, props, NULL, Parser_OutputPin_QueryAccept, &This->csFilter, This->ppPins + This->cStreams + 1);
456 IPin *pPin = This->ppPins[This->cStreams + 1];
457 Parser_OutputPin *pin = (Parser_OutputPin *)pPin;
458 pin->pmt = CoTaskMemAlloc(sizeof(AM_MEDIA_TYPE));
459 CopyMediaType(pin->pmt, amt);
460 pin->dwSamplesProcessed = 0;
462 pin->pin.pin.pUserData = (LPVOID)This->ppPins[This->cStreams + 1];
463 pin->pin.pin.pinInfo.pFilter = (LPVOID)This;
464 pin->pin.custom_allocator = 1;
466 CoTaskMemFree(ppOldPins);
470 CoTaskMemFree(This->ppPins);
471 This->ppPins = ppOldPins;
472 ERR("Failed with error %x\n", hr);
478 static HRESULT Parser_RemoveOutputPins(ParserImpl * This)
480 /* NOTE: should be in critical section when calling this function */
483 IPin ** ppOldPins = This->ppPins;
485 /* reduce the pin array down to 1 (just our input pin) */
486 This->ppPins = CoTaskMemAlloc(sizeof(IPin *) * 1);
487 memcpy(This->ppPins, ppOldPins, sizeof(IPin *) * 1);
489 for (i = 0; i < This->cStreams; i++)
491 OutputPin_DeliverDisconnect((OutputPin *)ppOldPins[i + 1]);
492 IPin_Release(ppOldPins[i + 1]);
496 CoTaskMemFree(ppOldPins);
501 static HRESULT Parser_ChangeCurrent(IBaseFilter *iface)
503 FIXME("(%p) filter hasn't implemented current position change!\n", iface);
507 static HRESULT Parser_ChangeStop(IBaseFilter *iface)
509 FIXME("(%p) filter hasn't implemented stop position change!\n", iface);
513 static HRESULT Parser_ChangeRate(IBaseFilter *iface)
515 FIXME("(%p) filter hasn't implemented rate change!\n", iface);
520 static HRESULT WINAPI Parser_Seeking_QueryInterface(IMediaSeeking * iface, REFIID riid, LPVOID * ppv)
522 ParserImpl *This = impl_from_IMediaSeeking(iface);
524 return IUnknown_QueryInterface((IUnknown *)This, riid, ppv);
527 static ULONG WINAPI Parser_Seeking_AddRef(IMediaSeeking * iface)
529 ParserImpl *This = impl_from_IMediaSeeking(iface);
531 return IUnknown_AddRef((IUnknown *)This);
534 static ULONG WINAPI Parser_Seeking_Release(IMediaSeeking * iface)
536 ParserImpl *This = impl_from_IMediaSeeking(iface);
538 return IUnknown_Release((IUnknown *)This);
541 static const IMediaSeekingVtbl Parser_Seeking_Vtbl =
543 Parser_Seeking_QueryInterface,
544 Parser_Seeking_AddRef,
545 Parser_Seeking_Release,
546 MediaSeekingImpl_GetCapabilities,
547 MediaSeekingImpl_CheckCapabilities,
548 MediaSeekingImpl_IsFormatSupported,
549 MediaSeekingImpl_QueryPreferredFormat,
550 MediaSeekingImpl_GetTimeFormat,
551 MediaSeekingImpl_IsUsingTimeFormat,
552 MediaSeekingImpl_SetTimeFormat,
553 MediaSeekingImpl_GetDuration,
554 MediaSeekingImpl_GetStopPosition,
555 MediaSeekingImpl_GetCurrentPosition,
556 MediaSeekingImpl_ConvertTimeFormat,
557 MediaSeekingImpl_SetPositions,
558 MediaSeekingImpl_GetPositions,
559 MediaSeekingImpl_GetAvailable,
560 MediaSeekingImpl_SetRate,
561 MediaSeekingImpl_GetRate,
562 MediaSeekingImpl_GetPreroll
565 static HRESULT WINAPI Parser_OutputPin_QueryInterface(IPin * iface, REFIID riid, LPVOID * ppv)
567 Parser_OutputPin *This = (Parser_OutputPin *)iface;
569 TRACE("(%s, %p)\n", qzdebugstr_guid(riid), ppv);
573 if (IsEqualIID(riid, &IID_IUnknown))
574 *ppv = (LPVOID)iface;
575 else if (IsEqualIID(riid, &IID_IPin))
576 *ppv = (LPVOID)iface;
577 else if (IsEqualIID(riid, &IID_IMediaSeeking))
579 return IBaseFilter_QueryInterface(This->pin.pin.pinInfo.pFilter, &IID_IMediaSeeking, ppv);
584 IUnknown_AddRef((IUnknown *)(*ppv));
588 FIXME("No interface for %s!\n", qzdebugstr_guid(riid));
590 return E_NOINTERFACE;
593 static ULONG WINAPI Parser_OutputPin_Release(IPin * iface)
595 Parser_OutputPin *This = (Parser_OutputPin *)iface;
596 ULONG refCount = InterlockedDecrement(&This->pin.pin.refCount);
598 TRACE("(%p)->() Release from %d\n", iface, refCount + 1);
602 FreeMediaType(This->pmt);
603 CoTaskMemFree(This->pmt);
604 FreeMediaType(&This->pin.pin.mtCurrent);
611 static HRESULT WINAPI Parser_OutputPin_EnumMediaTypes(IPin * iface, IEnumMediaTypes ** ppEnum)
613 ENUMMEDIADETAILS emd;
614 Parser_OutputPin *This = (Parser_OutputPin *)iface;
616 TRACE("(%p)\n", ppEnum);
618 /* override this method to allow enumeration of your types */
620 emd.pMediaTypes = This->pmt;
622 return IEnumMediaTypesImpl_Construct(&emd, ppEnum);
625 static HRESULT WINAPI Parser_OutputPin_Connect(IPin * iface, IPin * pReceivePin, const AM_MEDIA_TYPE * pmt)
627 Parser_OutputPin *This = (Parser_OutputPin *)iface;
628 ParserImpl *parser = (ParserImpl *)This->pin.pin.pinInfo.pFilter;
630 /* Set the allocator to our input pin's */
631 EnterCriticalSection(This->pin.pin.pCritSec);
632 This->pin.alloc = parser->pInputPin->pAlloc;
633 LeaveCriticalSection(This->pin.pin.pCritSec);
635 return OutputPin_Connect(iface, pReceivePin, pmt);
638 static HRESULT Parser_OutputPin_QueryAccept(LPVOID iface, const AM_MEDIA_TYPE * pmt)
640 Parser_OutputPin *This = (Parser_OutputPin *)iface;
643 dump_AM_MEDIA_TYPE(pmt);
645 return (memcmp(This->pmt, pmt, sizeof(AM_MEDIA_TYPE)) == 0);
648 static const IPinVtbl Parser_OutputPin_Vtbl =
650 Parser_OutputPin_QueryInterface,
652 Parser_OutputPin_Release,
653 Parser_OutputPin_Connect,
654 OutputPin_ReceiveConnection,
655 OutputPin_Disconnect,
656 IPinImpl_ConnectedTo,
657 IPinImpl_ConnectionMediaType,
658 IPinImpl_QueryPinInfo,
659 IPinImpl_QueryDirection,
661 IPinImpl_QueryAccept,
662 Parser_OutputPin_EnumMediaTypes,
663 IPinImpl_QueryInternalConnections,
664 OutputPin_EndOfStream,
665 OutputPin_BeginFlush,
670 static HRESULT WINAPI Parser_PullPin_Disconnect(IPin * iface)
673 IPinImpl *This = (IPinImpl *)iface;
677 EnterCriticalSection(This->pCritSec);
679 if (This->pConnectedTo)
681 PullPin *ppin = (PullPin *)This;
683 ParserImpl *Parser = (ParserImpl *)This->pinInfo.pFilter;
685 hr = IBaseFilter_GetState(This->pinInfo.pFilter, 0, &state);
687 if (SUCCEEDED(hr) && (state == State_Stopped) && SUCCEEDED(Parser->fnDisconnect(Parser)))
689 IPin_Release(This->pConnectedTo);
690 This->pConnectedTo = NULL;
691 if (FAILED(hr = IMemAllocator_Decommit(ppin->pAlloc)))
692 ERR("Allocator decommit failed with error %x. Possible memory leak\n", hr);
693 hr = Parser_RemoveOutputPins((ParserImpl *)This->pinInfo.pFilter);
696 hr = VFW_E_NOT_STOPPED;
701 LeaveCriticalSection(This->pCritSec);
706 HRESULT WINAPI Parser_PullPin_ReceiveConnection(IPin * iface, IPin * pReceivePin, const AM_MEDIA_TYPE * pmt)
712 hr = PullPin_ReceiveConnection(iface, pReceivePin, pmt);
715 IPinImpl *This = (IPinImpl *)iface;
717 EnterCriticalSection(This->pCritSec);
718 Parser_RemoveOutputPins((ParserImpl *)This->pinInfo.pFilter);
719 LeaveCriticalSection(This->pCritSec);
725 static const IPinVtbl Parser_InputPin_Vtbl =
727 PullPin_QueryInterface,
731 Parser_PullPin_ReceiveConnection,
732 Parser_PullPin_Disconnect,
733 IPinImpl_ConnectedTo,
734 IPinImpl_ConnectionMediaType,
735 IPinImpl_QueryPinInfo,
736 IPinImpl_QueryDirection,
738 IPinImpl_QueryAccept,
739 IPinImpl_EnumMediaTypes,
740 IPinImpl_QueryInternalConnections,