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
) &&
145 !IsEqualIID(riid
, &IID_IVideoWindow
) &&
146 !IsEqualIID(riid
, &IID_IAMFilterMiscFlags
))
148 FIXME("No interface for %s!\n", qzdebugstr_guid(riid
));
151 return E_NOINTERFACE
;
154 ULONG WINAPI
Parser_AddRef(IBaseFilter
* iface
)
156 return BaseFilterImpl_AddRef(iface
);
159 void Parser_Destroy(ParserImpl
*This
)
161 IPin
*connected
= NULL
;
165 assert(!This
->filter
.refCount
);
166 PullPin_WaitForStateChange(This
->pInputPin
, INFINITE
);
168 /* Don't need to clean up output pins, freeing input pin will do that */
169 IPin_ConnectedTo(&This
->pInputPin
->pin
.IPin_iface
, &connected
);
172 hr
= IPin_Disconnect(connected
);
174 IPin_Release(connected
);
175 hr
= IPin_Disconnect(&This
->pInputPin
->pin
.IPin_iface
);
178 pinref
= IPin_Release(&This
->pInputPin
->pin
.IPin_iface
);
181 /* Valgrind could find this, if I kill it here */
182 ERR("pinref should be null, is %u, destroying anyway\n", pinref
);
183 assert((LONG
)pinref
> 0);
186 pinref
= IPin_Release(&This
->pInputPin
->pin
.IPin_iface
);
189 CoTaskMemFree(This
->ppPins
);
190 BaseFilter_Destroy(&This
->filter
);
192 TRACE("Destroying parser\n");
196 ULONG WINAPI
Parser_Release(IBaseFilter
* iface
)
198 ParserImpl
*This
= impl_from_IBaseFilter(iface
);
199 ULONG refCount
= InterlockedDecrement(&This
->filter
.refCount
);
201 TRACE("(%p)->() Release from %d\n", This
, refCount
+ 1);
204 Parser_Destroy(This
);
209 /** IPersist methods **/
211 HRESULT WINAPI
Parser_GetClassID(IBaseFilter
* iface
, CLSID
* pClsid
)
213 ParserImpl
*This
= impl_from_IBaseFilter(iface
);
215 TRACE("(%p)\n", pClsid
);
217 *pClsid
= This
->filter
.clsid
;
222 /** IMediaFilter methods **/
224 HRESULT WINAPI
Parser_Stop(IBaseFilter
* iface
)
226 ParserImpl
*This
= impl_from_IBaseFilter(iface
);
227 PullPin
*pin
= impl_PullPin_from_IPin(This
->ppPins
[0]);
232 EnterCriticalSection(&pin
->thread_lock
);
234 IAsyncReader_BeginFlush(This
->pInputPin
->pReader
);
235 EnterCriticalSection(&This
->filter
.csFilter
);
237 if (This
->filter
.state
== State_Stopped
)
239 LeaveCriticalSection(&This
->filter
.csFilter
);
240 IAsyncReader_EndFlush(This
->pInputPin
->pReader
);
241 LeaveCriticalSection(&pin
->thread_lock
);
245 This
->filter
.state
= State_Stopped
;
247 for (i
= 1; i
< (This
->cStreams
+ 1); i
++)
249 BaseOutputPinImpl_Inactive((BaseOutputPin
*)This
->ppPins
[i
]);
252 LeaveCriticalSection(&This
->filter
.csFilter
);
254 PullPin_PauseProcessing(This
->pInputPin
);
255 PullPin_WaitForStateChange(This
->pInputPin
, INFINITE
);
256 IAsyncReader_EndFlush(This
->pInputPin
->pReader
);
258 LeaveCriticalSection(&pin
->thread_lock
);
262 HRESULT WINAPI
Parser_Pause(IBaseFilter
* iface
)
265 ParserImpl
*This
= impl_from_IBaseFilter(iface
);
266 PullPin
*pin
= impl_PullPin_from_IPin(This
->ppPins
[0]);
270 EnterCriticalSection(&pin
->thread_lock
);
271 EnterCriticalSection(&This
->filter
.csFilter
);
273 if (This
->filter
.state
== State_Paused
)
275 LeaveCriticalSection(&This
->filter
.csFilter
);
276 LeaveCriticalSection(&pin
->thread_lock
);
280 if (This
->filter
.state
== State_Stopped
)
282 LeaveCriticalSection(&This
->filter
.csFilter
);
283 hr
= IBaseFilter_Run(iface
, -1);
284 EnterCriticalSection(&This
->filter
.csFilter
);
288 This
->filter
.state
= State_Paused
;
290 LeaveCriticalSection(&This
->filter
.csFilter
);
291 LeaveCriticalSection(&pin
->thread_lock
);
296 HRESULT WINAPI
Parser_Run(IBaseFilter
* iface
, REFERENCE_TIME tStart
)
299 ParserImpl
*This
= impl_from_IBaseFilter(iface
);
300 PullPin
*pin
= impl_PullPin_from_IPin(This
->ppPins
[0]);
304 TRACE("(%s)\n", wine_dbgstr_longlong(tStart
));
306 EnterCriticalSection(&pin
->thread_lock
);
307 EnterCriticalSection(&This
->filter
.csFilter
);
309 HRESULT hr_any
= VFW_E_NOT_CONNECTED
;
311 This
->filter
.rtStreamStart
= tStart
;
312 if (This
->filter
.state
== State_Running
|| This
->filter
.state
== State_Paused
)
314 This
->filter
.state
= State_Running
;
315 LeaveCriticalSection(&This
->filter
.csFilter
);
316 LeaveCriticalSection(&pin
->thread_lock
);
320 for (i
= 1; i
< (This
->cStreams
+ 1); i
++)
322 hr
= BaseOutputPinImpl_Active((BaseOutputPin
*)This
->ppPins
[i
]);
330 LeaveCriticalSection(&This
->filter
.csFilter
);
331 hr
= PullPin_StartProcessing(This
->pInputPin
);
332 EnterCriticalSection(&This
->filter
.csFilter
);
336 This
->filter
.state
= State_Running
;
338 LeaveCriticalSection(&This
->filter
.csFilter
);
339 LeaveCriticalSection(&pin
->thread_lock
);
344 HRESULT WINAPI
Parser_GetState(IBaseFilter
* iface
, DWORD dwMilliSecsTimeout
, FILTER_STATE
*pState
)
346 ParserImpl
*This
= impl_from_IBaseFilter(iface
);
347 PullPin
*pin
= impl_PullPin_from_IPin(This
->ppPins
[0]);
350 TRACE("(%d, %p)\n", dwMilliSecsTimeout
, pState
);
352 EnterCriticalSection(&pin
->thread_lock
);
353 EnterCriticalSection(&This
->filter
.csFilter
);
355 *pState
= This
->filter
.state
;
357 LeaveCriticalSection(&This
->filter
.csFilter
);
359 if (This
->pInputPin
&& (PullPin_WaitForStateChange(This
->pInputPin
, dwMilliSecsTimeout
) == S_FALSE
))
360 hr
= VFW_S_STATE_INTERMEDIATE
;
361 LeaveCriticalSection(&pin
->thread_lock
);
366 HRESULT WINAPI
Parser_SetSyncSource(IBaseFilter
* iface
, IReferenceClock
*pClock
)
368 ParserImpl
*This
= impl_from_IBaseFilter(iface
);
369 PullPin
*pin
= impl_PullPin_from_IPin(This
->ppPins
[0]);
371 TRACE("(%p)\n", pClock
);
373 EnterCriticalSection(&pin
->thread_lock
);
374 BaseFilterImpl_SetSyncSource(iface
,pClock
);
375 LeaveCriticalSection(&pin
->thread_lock
);
380 HRESULT WINAPI
Parser_GetSyncSource(IBaseFilter
* iface
, IReferenceClock
**ppClock
)
382 return BaseFilterImpl_GetSyncSource(iface
, ppClock
);
385 /** IBaseFilter implementation **/
387 HRESULT WINAPI
Parser_EnumPins(IBaseFilter
* iface
, IEnumPins
**ppEnum
)
389 return BaseFilterImpl_EnumPins(iface
,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 return BaseFilterImpl_QueryFilterInfo(iface
, pInfo
);
406 HRESULT WINAPI
Parser_JoinFilterGraph(IBaseFilter
* iface
, IFilterGraph
*pGraph
, LPCWSTR pName
)
408 return BaseFilterImpl_JoinFilterGraph(iface
, pGraph
, pName
);
411 HRESULT WINAPI
Parser_QueryVendorInfo(IBaseFilter
* iface
, LPWSTR
*pVendorInfo
)
413 return BaseFilterImpl_QueryVendorInfo(iface
, pVendorInfo
);
416 static const BaseOutputPinFuncTable output_BaseOutputFuncTable
= {
419 BaseOutputPinImpl_AttemptConnection
,
420 BasePinImpl_GetMediaTypeVersion
,
421 Parser_OutputPin_GetMediaType
423 Parser_OutputPin_DecideBufferSize
,
424 Parser_OutputPin_DecideAllocator
,
425 Parser_OutputPin_BreakConnect
428 HRESULT
Parser_AddPin(ParserImpl
* This
, const PIN_INFO
* piOutput
, ALLOCATOR_PROPERTIES
* props
, const AM_MEDIA_TYPE
* amt
)
433 ppOldPins
= This
->ppPins
;
435 This
->ppPins
= CoTaskMemAlloc((This
->cStreams
+ 2) * sizeof(IPin
*));
436 memcpy(This
->ppPins
, ppOldPins
, (This
->cStreams
+ 1) * sizeof(IPin
*));
438 hr
= BaseOutputPin_Construct(&Parser_OutputPin_Vtbl
, sizeof(Parser_OutputPin
), piOutput
, &output_BaseOutputFuncTable
, &This
->filter
.csFilter
, This
->ppPins
+ (This
->cStreams
+ 1));
442 IPin
*pPin
= This
->ppPins
[This
->cStreams
+ 1];
443 Parser_OutputPin
*pin
= unsafe_impl_Parser_OutputPin_from_IPin(pPin
);
444 pin
->pmt
= CoTaskMemAlloc(sizeof(AM_MEDIA_TYPE
));
445 CopyMediaType(pin
->pmt
, amt
);
446 pin
->dwSamplesProcessed
= 0;
448 pin
->pin
.pin
.pinInfo
.pFilter
= (LPVOID
)This
;
449 pin
->allocProps
= *props
;
451 BaseFilterImpl_IncrementPinVersion(&This
->filter
);
452 CoTaskMemFree(ppOldPins
);
456 CoTaskMemFree(This
->ppPins
);
457 This
->ppPins
= ppOldPins
;
458 ERR("Failed with error %x\n", hr
);
464 static HRESULT
Parser_RemoveOutputPins(ParserImpl
* This
)
466 /* NOTE: should be in critical section when calling this function */
469 IPin
** ppOldPins
= This
->ppPins
;
471 TRACE("(%p)\n", This
);
473 /* reduce the pin array down to 1 (just our input pin) */
474 This
->ppPins
= CoTaskMemAlloc(sizeof(IPin
*) * 1);
475 memcpy(This
->ppPins
, ppOldPins
, sizeof(IPin
*) * 1);
477 for (i
= 0; i
< This
->cStreams
; i
++)
479 hr
= ((BaseOutputPin
*)ppOldPins
[i
+ 1])->pFuncsTable
->pfnBreakConnect((BaseOutputPin
*)ppOldPins
[i
+ 1]);
480 TRACE("Disconnect: %08x\n", hr
);
481 IPin_Release(ppOldPins
[i
+ 1]);
484 BaseFilterImpl_IncrementPinVersion(&This
->filter
);
486 CoTaskMemFree(ppOldPins
);
491 static HRESULT WINAPI
Parser_ChangeStart(IMediaSeeking
*iface
)
493 FIXME("(%p) filter hasn't implemented start position change!\n", iface
);
497 static HRESULT WINAPI
Parser_ChangeStop(IMediaSeeking
*iface
)
499 FIXME("(%p) filter hasn't implemented stop position change!\n", iface
);
503 static HRESULT WINAPI
Parser_ChangeRate(IMediaSeeking
*iface
)
505 FIXME("(%p) filter hasn't implemented rate change!\n", iface
);
510 static HRESULT WINAPI
Parser_Seeking_QueryInterface(IMediaSeeking
* iface
, REFIID riid
, LPVOID
* ppv
)
512 ParserImpl
*This
= impl_from_IMediaSeeking(iface
);
514 return IBaseFilter_QueryInterface(&This
->filter
.IBaseFilter_iface
, riid
, ppv
);
517 static ULONG WINAPI
Parser_Seeking_AddRef(IMediaSeeking
* iface
)
519 ParserImpl
*This
= impl_from_IMediaSeeking(iface
);
521 return IBaseFilter_AddRef(&This
->filter
.IBaseFilter_iface
);
524 static ULONG WINAPI
Parser_Seeking_Release(IMediaSeeking
* iface
)
526 ParserImpl
*This
= impl_from_IMediaSeeking(iface
);
528 return IBaseFilter_Release(&This
->filter
.IBaseFilter_iface
);
531 static const IMediaSeekingVtbl Parser_Seeking_Vtbl
=
533 Parser_Seeking_QueryInterface
,
534 Parser_Seeking_AddRef
,
535 Parser_Seeking_Release
,
536 SourceSeekingImpl_GetCapabilities
,
537 SourceSeekingImpl_CheckCapabilities
,
538 SourceSeekingImpl_IsFormatSupported
,
539 SourceSeekingImpl_QueryPreferredFormat
,
540 SourceSeekingImpl_GetTimeFormat
,
541 SourceSeekingImpl_IsUsingTimeFormat
,
542 SourceSeekingImpl_SetTimeFormat
,
543 SourceSeekingImpl_GetDuration
,
544 SourceSeekingImpl_GetStopPosition
,
545 SourceSeekingImpl_GetCurrentPosition
,
546 SourceSeekingImpl_ConvertTimeFormat
,
547 SourceSeekingImpl_SetPositions
,
548 SourceSeekingImpl_GetPositions
,
549 SourceSeekingImpl_GetAvailable
,
550 SourceSeekingImpl_SetRate
,
551 SourceSeekingImpl_GetRate
,
552 SourceSeekingImpl_GetPreroll
555 static HRESULT WINAPI
Parser_OutputPin_DecideBufferSize(BaseOutputPin
*iface
, IMemAllocator
*pAlloc
, ALLOCATOR_PROPERTIES
*ppropInputRequest
)
557 Parser_OutputPin
*This
= (Parser_OutputPin
*)iface
;
558 ALLOCATOR_PROPERTIES actual
;
560 if (ppropInputRequest
->cbAlign
&& ppropInputRequest
->cbAlign
!= This
->allocProps
.cbAlign
)
561 FIXME("Requested Buffer cbAlign mismatch %i,%i\n",This
->allocProps
.cbAlign
, ppropInputRequest
->cbAlign
);
562 if (ppropInputRequest
->cbPrefix
)
563 FIXME("Requested Buffer cbPrefix mismatch %i,%i\n",This
->allocProps
.cbPrefix
, ppropInputRequest
->cbPrefix
);
564 if (ppropInputRequest
->cbBuffer
)
565 FIXME("Requested Buffer cbBuffer mismatch %i,%i\n",This
->allocProps
.cbBuffer
, ppropInputRequest
->cbBuffer
);
566 if (ppropInputRequest
->cBuffers
)
567 FIXME("Requested Buffer cBuffers mismatch %i,%i\n",This
->allocProps
.cBuffers
, ppropInputRequest
->cBuffers
);
569 return IMemAllocator_SetProperties(pAlloc
, &This
->allocProps
, &actual
);
572 static HRESULT WINAPI
Parser_OutputPin_GetMediaType(BasePin
*iface
, int iPosition
, AM_MEDIA_TYPE
*pmt
)
574 Parser_OutputPin
*This
= (Parser_OutputPin
*)iface
;
578 return VFW_S_NO_MORE_ITEMS
;
579 CopyMediaType(pmt
, This
->pmt
);
583 static HRESULT WINAPI
Parser_OutputPin_DecideAllocator(BaseOutputPin
*iface
, IMemInputPin
*pPin
, IMemAllocator
**pAlloc
)
585 Parser_OutputPin
*This
= (Parser_OutputPin
*)iface
;
592 hr
= IMemInputPin_NotifyAllocator(pPin
, This
->alloc
, This
->readonly
);
595 *pAlloc
= This
->alloc
;
596 IMemAllocator_AddRef(*pAlloc
);
600 hr
= VFW_E_NO_ALLOCATOR
;
605 static HRESULT WINAPI
Parser_OutputPin_BreakConnect(BaseOutputPin
*This
)
609 TRACE("(%p)->()\n", This
);
611 EnterCriticalSection(This
->pin
.pCritSec
);
612 if (!This
->pin
.pConnectedTo
|| !This
->pMemInputPin
)
613 hr
= VFW_E_NOT_CONNECTED
;
616 hr
= IPin_Disconnect(This
->pin
.pConnectedTo
);
617 IPin_Disconnect(&This
->pin
.IPin_iface
);
619 LeaveCriticalSection(This
->pin
.pCritSec
);
625 static HRESULT WINAPI
Parser_OutputPin_QueryInterface(IPin
* iface
, REFIID riid
, LPVOID
* ppv
)
627 Parser_OutputPin
*This
= unsafe_impl_Parser_OutputPin_from_IPin(iface
);
629 TRACE("(%s, %p)\n", qzdebugstr_guid(riid
), ppv
);
633 if (IsEqualIID(riid
, &IID_IUnknown
))
635 else if (IsEqualIID(riid
, &IID_IPin
))
637 /* The Parser filter does not support querying IMediaSeeking, return it directly */
638 else if (IsEqualIID(riid
, &IID_IMediaSeeking
))
639 *ppv
= &impl_from_IBaseFilter(This
->pin
.pin
.pinInfo
.pFilter
)->sourceSeeking
;
643 IUnknown_AddRef((IUnknown
*)(*ppv
));
647 FIXME("No interface for %s!\n", qzdebugstr_guid(riid
));
649 return E_NOINTERFACE
;
652 static ULONG WINAPI
Parser_OutputPin_Release(IPin
* iface
)
654 Parser_OutputPin
*This
= unsafe_impl_Parser_OutputPin_from_IPin(iface
);
655 ULONG refCount
= InterlockedDecrement(&This
->pin
.pin
.refCount
);
657 TRACE("(%p)->() Release from %d\n", iface
, refCount
+ 1);
661 FreeMediaType(This
->pmt
);
662 CoTaskMemFree(This
->pmt
);
663 FreeMediaType(&This
->pin
.pin
.mtCurrent
);
664 if (This
->pin
.pAllocator
)
665 IMemAllocator_Release(This
->pin
.pAllocator
);
672 static HRESULT WINAPI
Parser_OutputPin_Connect(IPin
* iface
, IPin
* pReceivePin
, const AM_MEDIA_TYPE
* pmt
)
674 Parser_OutputPin
*This
= unsafe_impl_Parser_OutputPin_from_IPin(iface
);
675 ParserImpl
*parser
= impl_from_IBaseFilter(This
->pin
.pin
.pinInfo
.pFilter
);
677 /* Set the allocator to our input pin's */
678 EnterCriticalSection(This
->pin
.pin
.pCritSec
);
679 This
->alloc
= parser
->pInputPin
->pAlloc
;
680 LeaveCriticalSection(This
->pin
.pin
.pCritSec
);
682 return BaseOutputPinImpl_Connect(iface
, pReceivePin
, pmt
);
685 static HRESULT WINAPI
Parser_OutputPin_QueryAccept(IPin
*iface
, const AM_MEDIA_TYPE
* pmt
)
687 Parser_OutputPin
*This
= unsafe_impl_Parser_OutputPin_from_IPin(iface
);
690 dump_AM_MEDIA_TYPE(pmt
);
692 return (memcmp(This
->pmt
, pmt
, sizeof(AM_MEDIA_TYPE
)) == 0);
695 static const IPinVtbl Parser_OutputPin_Vtbl
=
697 Parser_OutputPin_QueryInterface
,
699 Parser_OutputPin_Release
,
700 Parser_OutputPin_Connect
,
701 BaseOutputPinImpl_ReceiveConnection
,
702 BaseOutputPinImpl_Disconnect
,
703 BasePinImpl_ConnectedTo
,
704 BasePinImpl_ConnectionMediaType
,
705 BasePinImpl_QueryPinInfo
,
706 BasePinImpl_QueryDirection
,
708 Parser_OutputPin_QueryAccept
,
709 BasePinImpl_EnumMediaTypes
,
710 BasePinImpl_QueryInternalConnections
,
711 BaseOutputPinImpl_EndOfStream
,
712 BaseOutputPinImpl_BeginFlush
,
713 BaseOutputPinImpl_EndFlush
,
714 BasePinImpl_NewSegment
717 static HRESULT WINAPI
Parser_PullPin_QueryInterface(IPin
* iface
, REFIID riid
, LPVOID
* ppv
)
719 PullPin
*This
= impl_PullPin_from_IPin(iface
);
721 TRACE("(%p/%p)->(%s, %p)\n", This
, iface
, qzdebugstr_guid(riid
), ppv
);
726 * It is important to capture the request for the IMediaSeeking interface before it is passed
727 * on to PullPin_QueryInterface, this is necessary since the Parser filter does not support
728 * querying IMediaSeeking
730 if (IsEqualIID(riid
, &IID_IMediaSeeking
))
731 *ppv
= &impl_from_IBaseFilter(This
->pin
.pinInfo
.pFilter
)->sourceSeeking
;
735 IUnknown_AddRef((IUnknown
*)(*ppv
));
739 return PullPin_QueryInterface(iface
, riid
, ppv
);
742 static HRESULT WINAPI
Parser_PullPin_Disconnect(IPin
* iface
)
745 PullPin
*This
= impl_PullPin_from_IPin(iface
);
749 EnterCriticalSection(&This
->thread_lock
);
750 EnterCriticalSection(This
->pin
.pCritSec
);
752 if (This
->pin
.pConnectedTo
)
755 ParserImpl
*Parser
= impl_from_IBaseFilter(This
->pin
.pinInfo
.pFilter
);
757 LeaveCriticalSection(This
->pin
.pCritSec
);
758 hr
= IBaseFilter_GetState(This
->pin
.pinInfo
.pFilter
, INFINITE
, &state
);
759 EnterCriticalSection(This
->pin
.pCritSec
);
761 if (SUCCEEDED(hr
) && (state
== State_Stopped
) && SUCCEEDED(Parser
->fnDisconnect(Parser
)))
763 LeaveCriticalSection(This
->pin
.pCritSec
);
764 PullPin_Disconnect(iface
);
765 EnterCriticalSection(This
->pin
.pCritSec
);
766 hr
= Parser_RemoveOutputPins(impl_from_IBaseFilter(This
->pin
.pinInfo
.pFilter
));
769 hr
= VFW_E_NOT_STOPPED
;
774 LeaveCriticalSection(This
->pin
.pCritSec
);
775 LeaveCriticalSection(&This
->thread_lock
);
780 static HRESULT WINAPI
Parser_PullPin_ReceiveConnection(IPin
* iface
, IPin
* pReceivePin
, const AM_MEDIA_TYPE
* pmt
)
786 hr
= PullPin_ReceiveConnection(iface
, pReceivePin
, pmt
);
789 BasePin
*This
= (BasePin
*)iface
;
791 EnterCriticalSection(This
->pCritSec
);
792 Parser_RemoveOutputPins(impl_from_IBaseFilter(This
->pinInfo
.pFilter
));
793 LeaveCriticalSection(This
->pCritSec
);
799 static HRESULT WINAPI
Parser_PullPin_EnumMediaTypes(IPin
*iface
, IEnumMediaTypes
**ppEnum
)
801 BasePin
*This
= (BasePin
*)iface
;
803 TRACE("(%p/%p)->(%p)\n", This
, iface
, ppEnum
);
805 return EnumMediaTypes_Construct(This
, BasePinImpl_GetMediaType
, BasePinImpl_GetMediaTypeVersion
, ppEnum
);
808 static const IPinVtbl Parser_InputPin_Vtbl
=
810 Parser_PullPin_QueryInterface
,
813 BaseInputPinImpl_Connect
,
814 Parser_PullPin_ReceiveConnection
,
815 Parser_PullPin_Disconnect
,
816 BasePinImpl_ConnectedTo
,
817 BasePinImpl_ConnectionMediaType
,
818 BasePinImpl_QueryPinInfo
,
819 BasePinImpl_QueryDirection
,
822 Parser_PullPin_EnumMediaTypes
,
823 BasePinImpl_QueryInternalConnections
,