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"
24 static const WCHAR wcsInputPinName
[] = {'i','n','p','u','t',' ','p','i','n',0};
25 static const IMediaSeekingVtbl Parser_Seeking_Vtbl
;
26 static const IPinVtbl Parser_OutputPin_Vtbl
;
27 static const IPinVtbl Parser_InputPin_Vtbl
;
29 static HRESULT WINAPI
Parser_ChangeStart(IMediaSeeking
*iface
);
30 static HRESULT WINAPI
Parser_ChangeStop(IMediaSeeking
*iface
);
31 static HRESULT WINAPI
Parser_ChangeRate(IMediaSeeking
*iface
);
32 static HRESULT WINAPI
Parser_OutputPin_DecideBufferSize(BaseOutputPin
*iface
, IMemAllocator
*pAlloc
, ALLOCATOR_PROPERTIES
*ppropInputRequest
);
33 static HRESULT WINAPI
Parser_OutputPin_GetMediaType(BasePin
*iface
, int iPosition
, AM_MEDIA_TYPE
*pmt
);
34 static HRESULT WINAPI
Parser_OutputPin_DecideAllocator(BaseOutputPin
*This
, IMemInputPin
*pPin
, IMemAllocator
**pAlloc
);
35 static HRESULT WINAPI
Parser_OutputPin_BreakConnect(BaseOutputPin
*This
);
37 static inline ParserImpl
*impl_from_IMediaSeeking( IMediaSeeking
*iface
)
39 return CONTAINING_RECORD(iface
, ParserImpl
, sourceSeeking
.IMediaSeeking_iface
);
42 static inline ParserImpl
*impl_from_IBaseFilter( IBaseFilter
*iface
)
44 return CONTAINING_RECORD(iface
, ParserImpl
, filter
.IBaseFilter_iface
);
47 static inline ParserImpl
*impl_from_BaseFilter( BaseFilter
*iface
)
49 return CONTAINING_RECORD(iface
, ParserImpl
, filter
);
53 static IPin
* WINAPI
Parser_GetPin(BaseFilter
*iface
, int pos
)
55 ParserImpl
*This
= impl_from_BaseFilter(iface
);
57 TRACE("Asking for pos %x\n", pos
);
59 /* Input pin also has a pin, hence the > and not >= */
60 if (pos
> This
->cStreams
|| pos
< 0)
63 IPin_AddRef(This
->ppPins
[pos
]);
64 return This
->ppPins
[pos
];
67 static LONG WINAPI
Parser_GetPinCount(BaseFilter
*iface
)
69 ParserImpl
*This
= impl_from_BaseFilter(iface
);
71 return This
->cStreams
;
74 static const BaseFilterFuncTable BaseFuncTable
= {
79 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
, STOPPROCESSPROC fnDone
, SourceSeeking_ChangeStop stop
, SourceSeeking_ChangeStart start
, SourceSeeking_ChangeRate rate
)
84 /* pTransformFilter is already allocated */
85 BaseFilter_Init(&pParser
->filter
, Parser_Vtbl
, pClsid
, (DWORD_PTR
)(__FILE__
": ParserImpl.csFilter"), &BaseFuncTable
);
87 pParser
->fnDisconnect
= fnDisconnect
;
89 pParser
->cStreams
= 0;
90 pParser
->ppPins
= CoTaskMemAlloc(1 * sizeof(IPin
*));
92 /* construct input pin */
93 piInput
.dir
= PINDIR_INPUT
;
94 piInput
.pFilter
= &pParser
->filter
.IBaseFilter_iface
;
95 lstrcpynW(piInput
.achName
, wcsInputPinName
, sizeof(piInput
.achName
) / sizeof(piInput
.achName
[0]));
98 start
= Parser_ChangeStart
;
101 stop
= Parser_ChangeStop
;
104 rate
= Parser_ChangeRate
;
106 SourceSeeking_Init(&pParser
->sourceSeeking
, &Parser_Seeking_Vtbl
, stop
, start
, rate
, &pParser
->filter
.csFilter
);
108 hr
= PullPin_Construct(&Parser_InputPin_Vtbl
, &piInput
, fnProcessSample
, (LPVOID
)pParser
, fnQueryAccept
, fnCleanup
, fnRequest
, fnDone
, &pParser
->filter
.csFilter
, (IPin
**)&pParser
->pInputPin
);
112 pParser
->ppPins
[0] = &pParser
->pInputPin
->pin
.IPin_iface
;
113 pParser
->pInputPin
->fnPreConnect
= fnPreConnect
;
117 CoTaskMemFree(pParser
->ppPins
);
118 BaseFilterImpl_Release(&pParser
->filter
.IBaseFilter_iface
);
119 CoTaskMemFree(pParser
);
125 HRESULT WINAPI
Parser_QueryInterface(IBaseFilter
* iface
, REFIID riid
, LPVOID
* ppv
)
127 ParserImpl
*This
= impl_from_IBaseFilter(iface
);
128 TRACE("(%s, %p)\n", qzdebugstr_guid(riid
), ppv
);
132 if ( IsEqualIID(riid
, &IID_IUnknown
)
133 || IsEqualIID(riid
, &IID_IPersist
)
134 || IsEqualIID(riid
, &IID_IMediaFilter
)
135 || IsEqualIID(riid
, &IID_IBaseFilter
) )
136 *ppv
= &This
->filter
.IBaseFilter_iface
;
140 IUnknown_AddRef((IUnknown
*)*ppv
);
144 if (!IsEqualIID(riid
, &IID_IPin
) && !IsEqualIID(riid
, &IID_IVideoWindow
))
145 FIXME("No interface for %s!\n", qzdebugstr_guid(riid
));
147 return E_NOINTERFACE
;
150 ULONG WINAPI
Parser_AddRef(IBaseFilter
* iface
)
152 return BaseFilterImpl_AddRef(iface
);
155 void Parser_Destroy(ParserImpl
*This
)
157 IPin
*connected
= NULL
;
161 assert(!This
->filter
.refCount
);
162 PullPin_WaitForStateChange(This
->pInputPin
, INFINITE
);
164 /* Don't need to clean up output pins, freeing input pin will do that */
165 IPin_ConnectedTo(&This
->pInputPin
->pin
.IPin_iface
, &connected
);
168 hr
= IPin_Disconnect(connected
);
170 IPin_Release(connected
);
171 hr
= IPin_Disconnect(&This
->pInputPin
->pin
.IPin_iface
);
174 pinref
= IPin_Release(&This
->pInputPin
->pin
.IPin_iface
);
177 /* Valgrind could find this, if I kill it here */
178 ERR("pinref should be null, is %u, destroying anyway\n", pinref
);
179 assert((LONG
)pinref
> 0);
182 pinref
= IPin_Release(&This
->pInputPin
->pin
.IPin_iface
);
185 CoTaskMemFree(This
->ppPins
);
186 BaseFilter_Destroy(&This
->filter
);
188 TRACE("Destroying parser\n");
192 ULONG WINAPI
Parser_Release(IBaseFilter
* iface
)
194 ParserImpl
*This
= impl_from_IBaseFilter(iface
);
195 ULONG refCount
= InterlockedDecrement(&This
->filter
.refCount
);
197 TRACE("(%p)->() Release from %d\n", This
, refCount
+ 1);
200 Parser_Destroy(This
);
205 /** IPersist methods **/
207 HRESULT WINAPI
Parser_GetClassID(IBaseFilter
* iface
, CLSID
* pClsid
)
209 ParserImpl
*This
= impl_from_IBaseFilter(iface
);
211 TRACE("(%p)\n", pClsid
);
213 *pClsid
= This
->filter
.clsid
;
218 /** IMediaFilter methods **/
220 HRESULT WINAPI
Parser_Stop(IBaseFilter
* iface
)
222 ParserImpl
*This
= impl_from_IBaseFilter(iface
);
223 PullPin
*pin
= impl_PullPin_from_IPin(This
->ppPins
[0]);
228 EnterCriticalSection(&pin
->thread_lock
);
230 IAsyncReader_BeginFlush(This
->pInputPin
->pReader
);
231 EnterCriticalSection(&This
->filter
.csFilter
);
233 if (This
->filter
.state
== State_Stopped
)
235 LeaveCriticalSection(&This
->filter
.csFilter
);
236 IAsyncReader_EndFlush(This
->pInputPin
->pReader
);
237 LeaveCriticalSection(&pin
->thread_lock
);
241 This
->filter
.state
= State_Stopped
;
243 for (i
= 1; i
< (This
->cStreams
+ 1); i
++)
245 BaseOutputPinImpl_Inactive((BaseOutputPin
*)This
->ppPins
[i
]);
248 LeaveCriticalSection(&This
->filter
.csFilter
);
250 PullPin_PauseProcessing(This
->pInputPin
);
251 PullPin_WaitForStateChange(This
->pInputPin
, INFINITE
);
252 IAsyncReader_EndFlush(This
->pInputPin
->pReader
);
254 LeaveCriticalSection(&pin
->thread_lock
);
258 HRESULT WINAPI
Parser_Pause(IBaseFilter
* iface
)
261 ParserImpl
*This
= impl_from_IBaseFilter(iface
);
262 PullPin
*pin
= impl_PullPin_from_IPin(This
->ppPins
[0]);
266 EnterCriticalSection(&pin
->thread_lock
);
267 EnterCriticalSection(&This
->filter
.csFilter
);
269 if (This
->filter
.state
== State_Paused
)
271 LeaveCriticalSection(&This
->filter
.csFilter
);
272 LeaveCriticalSection(&pin
->thread_lock
);
276 if (This
->filter
.state
== State_Stopped
)
278 LeaveCriticalSection(&This
->filter
.csFilter
);
279 hr
= IBaseFilter_Run(iface
, -1);
280 EnterCriticalSection(&This
->filter
.csFilter
);
284 This
->filter
.state
= State_Paused
;
286 LeaveCriticalSection(&This
->filter
.csFilter
);
287 LeaveCriticalSection(&pin
->thread_lock
);
292 HRESULT WINAPI
Parser_Run(IBaseFilter
* iface
, REFERENCE_TIME tStart
)
295 ParserImpl
*This
= impl_from_IBaseFilter(iface
);
296 PullPin
*pin
= impl_PullPin_from_IPin(This
->ppPins
[0]);
300 TRACE("(%s)\n", wine_dbgstr_longlong(tStart
));
302 EnterCriticalSection(&pin
->thread_lock
);
303 EnterCriticalSection(&This
->filter
.csFilter
);
305 HRESULT hr_any
= VFW_E_NOT_CONNECTED
;
307 This
->filter
.rtStreamStart
= tStart
;
308 if (This
->filter
.state
== State_Running
|| This
->filter
.state
== State_Paused
)
310 This
->filter
.state
= State_Running
;
311 LeaveCriticalSection(&This
->filter
.csFilter
);
312 LeaveCriticalSection(&pin
->thread_lock
);
316 for (i
= 1; i
< (This
->cStreams
+ 1); i
++)
318 hr
= BaseOutputPinImpl_Active((BaseOutputPin
*)This
->ppPins
[i
]);
326 LeaveCriticalSection(&This
->filter
.csFilter
);
327 hr
= PullPin_StartProcessing(This
->pInputPin
);
328 EnterCriticalSection(&This
->filter
.csFilter
);
332 This
->filter
.state
= State_Running
;
334 LeaveCriticalSection(&This
->filter
.csFilter
);
335 LeaveCriticalSection(&pin
->thread_lock
);
340 HRESULT WINAPI
Parser_GetState(IBaseFilter
* iface
, DWORD dwMilliSecsTimeout
, FILTER_STATE
*pState
)
342 ParserImpl
*This
= impl_from_IBaseFilter(iface
);
343 PullPin
*pin
= impl_PullPin_from_IPin(This
->ppPins
[0]);
346 TRACE("(%d, %p)\n", dwMilliSecsTimeout
, pState
);
348 EnterCriticalSection(&pin
->thread_lock
);
349 EnterCriticalSection(&This
->filter
.csFilter
);
351 *pState
= This
->filter
.state
;
353 LeaveCriticalSection(&This
->filter
.csFilter
);
355 if (This
->pInputPin
&& (PullPin_WaitForStateChange(This
->pInputPin
, dwMilliSecsTimeout
) == S_FALSE
))
356 hr
= VFW_S_STATE_INTERMEDIATE
;
357 LeaveCriticalSection(&pin
->thread_lock
);
362 HRESULT WINAPI
Parser_SetSyncSource(IBaseFilter
* iface
, IReferenceClock
*pClock
)
364 ParserImpl
*This
= impl_from_IBaseFilter(iface
);
365 PullPin
*pin
= impl_PullPin_from_IPin(This
->ppPins
[0]);
367 TRACE("(%p)\n", pClock
);
369 EnterCriticalSection(&pin
->thread_lock
);
370 BaseFilterImpl_SetSyncSource(iface
,pClock
);
371 LeaveCriticalSection(&pin
->thread_lock
);
376 HRESULT WINAPI
Parser_GetSyncSource(IBaseFilter
* iface
, IReferenceClock
**ppClock
)
378 return BaseFilterImpl_GetSyncSource(iface
, ppClock
);
381 /** IBaseFilter implementation **/
383 HRESULT WINAPI
Parser_EnumPins(IBaseFilter
* iface
, IEnumPins
**ppEnum
)
385 return BaseFilterImpl_EnumPins(iface
,ppEnum
);
388 HRESULT WINAPI
Parser_FindPin(IBaseFilter
* iface
, LPCWSTR Id
, IPin
**ppPin
)
390 FIXME("(%p)->(%s,%p)\n", iface
, debugstr_w(Id
), ppPin
);
392 /* FIXME: critical section */
397 HRESULT WINAPI
Parser_QueryFilterInfo(IBaseFilter
* iface
, FILTER_INFO
*pInfo
)
399 return BaseFilterImpl_QueryFilterInfo(iface
, pInfo
);
402 HRESULT WINAPI
Parser_JoinFilterGraph(IBaseFilter
* iface
, IFilterGraph
*pGraph
, LPCWSTR pName
)
404 return BaseFilterImpl_JoinFilterGraph(iface
, pGraph
, pName
);
407 HRESULT WINAPI
Parser_QueryVendorInfo(IBaseFilter
* iface
, LPWSTR
*pVendorInfo
)
409 return BaseFilterImpl_QueryVendorInfo(iface
, pVendorInfo
);
412 static const BaseOutputPinFuncTable output_BaseOutputFuncTable
= {
415 BaseOutputPinImpl_AttemptConnection
,
416 BasePinImpl_GetMediaTypeVersion
,
417 Parser_OutputPin_GetMediaType
419 Parser_OutputPin_DecideBufferSize
,
420 Parser_OutputPin_DecideAllocator
,
421 Parser_OutputPin_BreakConnect
424 HRESULT
Parser_AddPin(ParserImpl
* This
, const PIN_INFO
* piOutput
, ALLOCATOR_PROPERTIES
* props
, const AM_MEDIA_TYPE
* amt
)
429 ppOldPins
= This
->ppPins
;
431 This
->ppPins
= CoTaskMemAlloc((This
->cStreams
+ 2) * sizeof(IPin
*));
432 memcpy(This
->ppPins
, ppOldPins
, (This
->cStreams
+ 1) * sizeof(IPin
*));
434 hr
= BaseOutputPin_Construct(&Parser_OutputPin_Vtbl
, sizeof(Parser_OutputPin
), piOutput
, &output_BaseOutputFuncTable
, &This
->filter
.csFilter
, This
->ppPins
+ (This
->cStreams
+ 1));
438 IPin
*pPin
= This
->ppPins
[This
->cStreams
+ 1];
439 Parser_OutputPin
*pin
= unsafe_impl_Parser_OutputPin_from_IPin(pPin
);
440 pin
->pmt
= CoTaskMemAlloc(sizeof(AM_MEDIA_TYPE
));
441 CopyMediaType(pin
->pmt
, amt
);
442 pin
->dwSamplesProcessed
= 0;
444 pin
->pin
.pin
.pinInfo
.pFilter
= (LPVOID
)This
;
445 pin
->allocProps
= *props
;
447 BaseFilterImpl_IncrementPinVersion(&This
->filter
);
448 CoTaskMemFree(ppOldPins
);
452 CoTaskMemFree(This
->ppPins
);
453 This
->ppPins
= ppOldPins
;
454 ERR("Failed with error %x\n", hr
);
460 static HRESULT
Parser_RemoveOutputPins(ParserImpl
* This
)
462 /* NOTE: should be in critical section when calling this function */
465 IPin
** ppOldPins
= This
->ppPins
;
467 TRACE("(%p)\n", This
);
469 /* reduce the pin array down to 1 (just our input pin) */
470 This
->ppPins
= CoTaskMemAlloc(sizeof(IPin
*) * 1);
471 memcpy(This
->ppPins
, ppOldPins
, sizeof(IPin
*) * 1);
473 for (i
= 0; i
< This
->cStreams
; i
++)
475 hr
= ((BaseOutputPin
*)ppOldPins
[i
+ 1])->pFuncsTable
->pfnBreakConnect((BaseOutputPin
*)ppOldPins
[i
+ 1]);
476 TRACE("Disconnect: %08x\n", hr
);
477 IPin_Release(ppOldPins
[i
+ 1]);
480 BaseFilterImpl_IncrementPinVersion(&This
->filter
);
482 CoTaskMemFree(ppOldPins
);
487 static HRESULT WINAPI
Parser_ChangeStart(IMediaSeeking
*iface
)
489 FIXME("(%p) filter hasn't implemented start position change!\n", iface
);
493 static HRESULT WINAPI
Parser_ChangeStop(IMediaSeeking
*iface
)
495 FIXME("(%p) filter hasn't implemented stop position change!\n", iface
);
499 static HRESULT WINAPI
Parser_ChangeRate(IMediaSeeking
*iface
)
501 FIXME("(%p) filter hasn't implemented rate change!\n", iface
);
506 static HRESULT WINAPI
Parser_Seeking_QueryInterface(IMediaSeeking
* iface
, REFIID riid
, LPVOID
* ppv
)
508 ParserImpl
*This
= impl_from_IMediaSeeking(iface
);
510 return IBaseFilter_QueryInterface(&This
->filter
.IBaseFilter_iface
, riid
, ppv
);
513 static ULONG WINAPI
Parser_Seeking_AddRef(IMediaSeeking
* iface
)
515 ParserImpl
*This
= impl_from_IMediaSeeking(iface
);
517 return IBaseFilter_AddRef(&This
->filter
.IBaseFilter_iface
);
520 static ULONG WINAPI
Parser_Seeking_Release(IMediaSeeking
* iface
)
522 ParserImpl
*This
= impl_from_IMediaSeeking(iface
);
524 return IBaseFilter_Release(&This
->filter
.IBaseFilter_iface
);
527 static const IMediaSeekingVtbl Parser_Seeking_Vtbl
=
529 Parser_Seeking_QueryInterface
,
530 Parser_Seeking_AddRef
,
531 Parser_Seeking_Release
,
532 SourceSeekingImpl_GetCapabilities
,
533 SourceSeekingImpl_CheckCapabilities
,
534 SourceSeekingImpl_IsFormatSupported
,
535 SourceSeekingImpl_QueryPreferredFormat
,
536 SourceSeekingImpl_GetTimeFormat
,
537 SourceSeekingImpl_IsUsingTimeFormat
,
538 SourceSeekingImpl_SetTimeFormat
,
539 SourceSeekingImpl_GetDuration
,
540 SourceSeekingImpl_GetStopPosition
,
541 SourceSeekingImpl_GetCurrentPosition
,
542 SourceSeekingImpl_ConvertTimeFormat
,
543 SourceSeekingImpl_SetPositions
,
544 SourceSeekingImpl_GetPositions
,
545 SourceSeekingImpl_GetAvailable
,
546 SourceSeekingImpl_SetRate
,
547 SourceSeekingImpl_GetRate
,
548 SourceSeekingImpl_GetPreroll
551 static HRESULT WINAPI
Parser_OutputPin_DecideBufferSize(BaseOutputPin
*iface
, IMemAllocator
*pAlloc
, ALLOCATOR_PROPERTIES
*ppropInputRequest
)
553 Parser_OutputPin
*This
= (Parser_OutputPin
*)iface
;
554 ALLOCATOR_PROPERTIES actual
;
556 if (ppropInputRequest
->cbAlign
&& ppropInputRequest
->cbAlign
!= This
->allocProps
.cbAlign
)
557 FIXME("Requested Buffer cbAlign mismatch %i,%i\n",This
->allocProps
.cbAlign
, ppropInputRequest
->cbAlign
);
558 if (ppropInputRequest
->cbPrefix
)
559 FIXME("Requested Buffer cbPrefix mismatch %i,%i\n",This
->allocProps
.cbPrefix
, ppropInputRequest
->cbPrefix
);
560 if (ppropInputRequest
->cbBuffer
)
561 FIXME("Requested Buffer cbBuffer mismatch %i,%i\n",This
->allocProps
.cbBuffer
, ppropInputRequest
->cbBuffer
);
562 if (ppropInputRequest
->cBuffers
)
563 FIXME("Requested Buffer cBuffers mismatch %i,%i\n",This
->allocProps
.cBuffers
, ppropInputRequest
->cBuffers
);
565 return IMemAllocator_SetProperties(pAlloc
, &This
->allocProps
, &actual
);
568 static HRESULT WINAPI
Parser_OutputPin_GetMediaType(BasePin
*iface
, int iPosition
, AM_MEDIA_TYPE
*pmt
)
570 Parser_OutputPin
*This
= (Parser_OutputPin
*)iface
;
574 return VFW_S_NO_MORE_ITEMS
;
575 CopyMediaType(pmt
, This
->pmt
);
579 static HRESULT WINAPI
Parser_OutputPin_DecideAllocator(BaseOutputPin
*iface
, IMemInputPin
*pPin
, IMemAllocator
**pAlloc
)
581 Parser_OutputPin
*This
= (Parser_OutputPin
*)iface
;
588 hr
= IMemInputPin_NotifyAllocator(pPin
, This
->alloc
, This
->readonly
);
591 *pAlloc
= This
->alloc
;
592 IMemAllocator_AddRef(*pAlloc
);
596 hr
= VFW_E_NO_ALLOCATOR
;
601 static HRESULT WINAPI
Parser_OutputPin_BreakConnect(BaseOutputPin
*This
)
605 TRACE("(%p)->()\n", This
);
607 EnterCriticalSection(This
->pin
.pCritSec
);
608 if (!This
->pin
.pConnectedTo
|| !This
->pMemInputPin
)
609 hr
= VFW_E_NOT_CONNECTED
;
612 hr
= IPin_Disconnect(This
->pin
.pConnectedTo
);
613 IPin_Disconnect(&This
->pin
.IPin_iface
);
615 LeaveCriticalSection(This
->pin
.pCritSec
);
621 static HRESULT WINAPI
Parser_OutputPin_QueryInterface(IPin
* iface
, REFIID riid
, LPVOID
* ppv
)
623 Parser_OutputPin
*This
= unsafe_impl_Parser_OutputPin_from_IPin(iface
);
625 TRACE("(%s, %p)\n", qzdebugstr_guid(riid
), ppv
);
629 if (IsEqualIID(riid
, &IID_IUnknown
))
631 else if (IsEqualIID(riid
, &IID_IPin
))
633 /* The Parser filter does not support querying IMediaSeeking, return it directly */
634 else if (IsEqualIID(riid
, &IID_IMediaSeeking
))
635 *ppv
= &impl_from_IBaseFilter(This
->pin
.pin
.pinInfo
.pFilter
)->sourceSeeking
;
639 IUnknown_AddRef((IUnknown
*)(*ppv
));
643 FIXME("No interface for %s!\n", qzdebugstr_guid(riid
));
645 return E_NOINTERFACE
;
648 static ULONG WINAPI
Parser_OutputPin_Release(IPin
* iface
)
650 Parser_OutputPin
*This
= unsafe_impl_Parser_OutputPin_from_IPin(iface
);
651 ULONG refCount
= InterlockedDecrement(&This
->pin
.pin
.refCount
);
653 TRACE("(%p)->() Release from %d\n", iface
, refCount
+ 1);
657 FreeMediaType(This
->pmt
);
658 CoTaskMemFree(This
->pmt
);
659 FreeMediaType(&This
->pin
.pin
.mtCurrent
);
660 if (This
->pin
.pAllocator
)
661 IMemAllocator_Release(This
->pin
.pAllocator
);
668 static HRESULT WINAPI
Parser_OutputPin_Connect(IPin
* iface
, IPin
* pReceivePin
, const AM_MEDIA_TYPE
* pmt
)
670 Parser_OutputPin
*This
= unsafe_impl_Parser_OutputPin_from_IPin(iface
);
671 ParserImpl
*parser
= impl_from_IBaseFilter(This
->pin
.pin
.pinInfo
.pFilter
);
673 /* Set the allocator to our input pin's */
674 EnterCriticalSection(This
->pin
.pin
.pCritSec
);
675 This
->alloc
= parser
->pInputPin
->pAlloc
;
676 LeaveCriticalSection(This
->pin
.pin
.pCritSec
);
678 return BaseOutputPinImpl_Connect(iface
, pReceivePin
, pmt
);
681 static HRESULT WINAPI
Parser_OutputPin_QueryAccept(IPin
*iface
, const AM_MEDIA_TYPE
* pmt
)
683 Parser_OutputPin
*This
= unsafe_impl_Parser_OutputPin_from_IPin(iface
);
686 dump_AM_MEDIA_TYPE(pmt
);
688 return (memcmp(This
->pmt
, pmt
, sizeof(AM_MEDIA_TYPE
)) == 0);
691 static const IPinVtbl Parser_OutputPin_Vtbl
=
693 Parser_OutputPin_QueryInterface
,
695 Parser_OutputPin_Release
,
696 Parser_OutputPin_Connect
,
697 BaseOutputPinImpl_ReceiveConnection
,
698 BaseOutputPinImpl_Disconnect
,
699 BasePinImpl_ConnectedTo
,
700 BasePinImpl_ConnectionMediaType
,
701 BasePinImpl_QueryPinInfo
,
702 BasePinImpl_QueryDirection
,
704 Parser_OutputPin_QueryAccept
,
705 BasePinImpl_EnumMediaTypes
,
706 BasePinImpl_QueryInternalConnections
,
707 BaseOutputPinImpl_EndOfStream
,
708 BaseOutputPinImpl_BeginFlush
,
709 BaseOutputPinImpl_EndFlush
,
710 BasePinImpl_NewSegment
713 static HRESULT WINAPI
Parser_PullPin_QueryInterface(IPin
* iface
, REFIID riid
, LPVOID
* ppv
)
715 PullPin
*This
= impl_PullPin_from_IPin(iface
);
717 TRACE("(%p/%p)->(%s, %p)\n", This
, iface
, qzdebugstr_guid(riid
), ppv
);
722 * It is important to capture the request for the IMediaSeeking interface before it is passed
723 * on to PullPin_QueryInterface, this is necessary since the Parser filter does not support
724 * querying IMediaSeeking
726 if (IsEqualIID(riid
, &IID_IMediaSeeking
))
727 *ppv
= &impl_from_IBaseFilter(This
->pin
.pinInfo
.pFilter
)->sourceSeeking
;
731 IUnknown_AddRef((IUnknown
*)(*ppv
));
735 return PullPin_QueryInterface(iface
, riid
, ppv
);
738 static HRESULT WINAPI
Parser_PullPin_Disconnect(IPin
* iface
)
741 PullPin
*This
= impl_PullPin_from_IPin(iface
);
745 EnterCriticalSection(&This
->thread_lock
);
746 EnterCriticalSection(This
->pin
.pCritSec
);
748 if (This
->pin
.pConnectedTo
)
751 ParserImpl
*Parser
= impl_from_IBaseFilter(This
->pin
.pinInfo
.pFilter
);
753 LeaveCriticalSection(This
->pin
.pCritSec
);
754 hr
= IBaseFilter_GetState(This
->pin
.pinInfo
.pFilter
, INFINITE
, &state
);
755 EnterCriticalSection(This
->pin
.pCritSec
);
757 if (SUCCEEDED(hr
) && (state
== State_Stopped
) && SUCCEEDED(Parser
->fnDisconnect(Parser
)))
759 LeaveCriticalSection(This
->pin
.pCritSec
);
760 PullPin_Disconnect(iface
);
761 EnterCriticalSection(This
->pin
.pCritSec
);
762 hr
= Parser_RemoveOutputPins(impl_from_IBaseFilter(This
->pin
.pinInfo
.pFilter
));
765 hr
= VFW_E_NOT_STOPPED
;
770 LeaveCriticalSection(This
->pin
.pCritSec
);
771 LeaveCriticalSection(&This
->thread_lock
);
776 static HRESULT WINAPI
Parser_PullPin_ReceiveConnection(IPin
* iface
, IPin
* pReceivePin
, const AM_MEDIA_TYPE
* pmt
)
782 hr
= PullPin_ReceiveConnection(iface
, pReceivePin
, pmt
);
785 BasePin
*This
= (BasePin
*)iface
;
787 EnterCriticalSection(This
->pCritSec
);
788 Parser_RemoveOutputPins(impl_from_IBaseFilter(This
->pinInfo
.pFilter
));
789 LeaveCriticalSection(This
->pCritSec
);
795 static HRESULT WINAPI
Parser_PullPin_EnumMediaTypes(IPin
*iface
, IEnumMediaTypes
**ppEnum
)
797 BasePin
*This
= (BasePin
*)iface
;
799 TRACE("(%p/%p)->(%p)\n", This
, iface
, ppEnum
);
801 return EnumMediaTypes_Construct(This
, BasePinImpl_GetMediaType
, BasePinImpl_GetMediaTypeVersion
, ppEnum
);
804 static const IPinVtbl Parser_InputPin_Vtbl
=
806 Parser_PullPin_QueryInterface
,
809 BaseInputPinImpl_Connect
,
810 Parser_PullPin_ReceiveConnection
,
811 Parser_PullPin_Disconnect
,
812 BasePinImpl_ConnectedTo
,
813 BasePinImpl_ConnectionMediaType
,
814 BasePinImpl_QueryPinInfo
,
815 BasePinImpl_QueryDirection
,
818 Parser_PullPin_EnumMediaTypes
,
819 BasePinImpl_QueryInternalConnections
,