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
) )
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
;
160 assert(!This
->filter
.refCount
);
161 PullPin_WaitForStateChange(This
->pInputPin
, INFINITE
);
163 /* Don't need to clean up output pins, freeing input pin will do that */
164 IPin_ConnectedTo(&This
->pInputPin
->pin
.IPin_iface
, &connected
);
167 assert(IPin_Disconnect(connected
) == S_OK
);
168 IPin_Release(connected
);
169 assert(IPin_Disconnect(&This
->pInputPin
->pin
.IPin_iface
) == S_OK
);
171 pinref
= IPin_Release(&This
->pInputPin
->pin
.IPin_iface
);
174 /* Valgrind could find this, if I kill it here */
175 ERR("pinref should be null, is %u, destroying anyway\n", pinref
);
176 assert((LONG
)pinref
> 0);
179 pinref
= IPin_Release(&This
->pInputPin
->pin
.IPin_iface
);
182 CoTaskMemFree(This
->ppPins
);
184 TRACE("Destroying parser\n");
188 ULONG WINAPI
Parser_Release(IBaseFilter
* iface
)
190 ParserImpl
*This
= impl_from_IBaseFilter(iface
);
191 ULONG refCount
= BaseFilterImpl_Release(iface
);
193 TRACE("(%p)->() Release from %d\n", This
, refCount
+ 1);
196 Parser_Destroy(This
);
201 /** IPersist methods **/
203 HRESULT WINAPI
Parser_GetClassID(IBaseFilter
* iface
, CLSID
* pClsid
)
205 ParserImpl
*This
= impl_from_IBaseFilter(iface
);
207 TRACE("(%p)\n", pClsid
);
209 *pClsid
= This
->filter
.clsid
;
214 /** IMediaFilter methods **/
216 HRESULT WINAPI
Parser_Stop(IBaseFilter
* iface
)
218 ParserImpl
*This
= impl_from_IBaseFilter(iface
);
219 PullPin
*pin
= impl_PullPin_from_IPin(This
->ppPins
[0]);
224 EnterCriticalSection(&pin
->thread_lock
);
226 IAsyncReader_BeginFlush(This
->pInputPin
->pReader
);
227 EnterCriticalSection(&This
->filter
.csFilter
);
229 if (This
->filter
.state
== State_Stopped
)
231 LeaveCriticalSection(&This
->filter
.csFilter
);
232 IAsyncReader_EndFlush(This
->pInputPin
->pReader
);
233 LeaveCriticalSection(&pin
->thread_lock
);
237 This
->filter
.state
= State_Stopped
;
239 for (i
= 1; i
< (This
->cStreams
+ 1); i
++)
241 BaseOutputPinImpl_Inactive((BaseOutputPin
*)This
->ppPins
[i
]);
244 LeaveCriticalSection(&This
->filter
.csFilter
);
246 PullPin_PauseProcessing(This
->pInputPin
);
247 PullPin_WaitForStateChange(This
->pInputPin
, INFINITE
);
248 IAsyncReader_EndFlush(This
->pInputPin
->pReader
);
250 LeaveCriticalSection(&pin
->thread_lock
);
254 HRESULT WINAPI
Parser_Pause(IBaseFilter
* iface
)
257 ParserImpl
*This
= impl_from_IBaseFilter(iface
);
258 PullPin
*pin
= impl_PullPin_from_IPin(This
->ppPins
[0]);
262 EnterCriticalSection(&pin
->thread_lock
);
263 EnterCriticalSection(&This
->filter
.csFilter
);
265 if (This
->filter
.state
== State_Paused
)
267 LeaveCriticalSection(&This
->filter
.csFilter
);
268 LeaveCriticalSection(&pin
->thread_lock
);
272 if (This
->filter
.state
== State_Stopped
)
274 LeaveCriticalSection(&This
->filter
.csFilter
);
275 hr
= IBaseFilter_Run(iface
, -1);
276 EnterCriticalSection(&This
->filter
.csFilter
);
280 This
->filter
.state
= State_Paused
;
282 LeaveCriticalSection(&This
->filter
.csFilter
);
283 LeaveCriticalSection(&pin
->thread_lock
);
288 HRESULT WINAPI
Parser_Run(IBaseFilter
* iface
, REFERENCE_TIME tStart
)
291 ParserImpl
*This
= impl_from_IBaseFilter(iface
);
292 PullPin
*pin
= impl_PullPin_from_IPin(This
->ppPins
[0]);
296 TRACE("(%s)\n", wine_dbgstr_longlong(tStart
));
298 EnterCriticalSection(&pin
->thread_lock
);
299 EnterCriticalSection(&This
->filter
.csFilter
);
301 HRESULT hr_any
= VFW_E_NOT_CONNECTED
;
303 This
->filter
.rtStreamStart
= tStart
;
304 if (This
->filter
.state
== State_Running
|| This
->filter
.state
== State_Paused
)
306 This
->filter
.state
= State_Running
;
307 LeaveCriticalSection(&This
->filter
.csFilter
);
308 LeaveCriticalSection(&pin
->thread_lock
);
312 for (i
= 1; i
< (This
->cStreams
+ 1); i
++)
314 hr
= BaseOutputPinImpl_Active((BaseOutputPin
*)This
->ppPins
[i
]);
322 LeaveCriticalSection(&This
->filter
.csFilter
);
323 hr
= PullPin_StartProcessing(This
->pInputPin
);
324 EnterCriticalSection(&This
->filter
.csFilter
);
328 This
->filter
.state
= State_Running
;
330 LeaveCriticalSection(&This
->filter
.csFilter
);
331 LeaveCriticalSection(&pin
->thread_lock
);
336 HRESULT WINAPI
Parser_GetState(IBaseFilter
* iface
, DWORD dwMilliSecsTimeout
, FILTER_STATE
*pState
)
338 ParserImpl
*This
= impl_from_IBaseFilter(iface
);
339 PullPin
*pin
= impl_PullPin_from_IPin(This
->ppPins
[0]);
342 TRACE("(%d, %p)\n", dwMilliSecsTimeout
, pState
);
344 EnterCriticalSection(&pin
->thread_lock
);
345 EnterCriticalSection(&This
->filter
.csFilter
);
347 *pState
= This
->filter
.state
;
349 LeaveCriticalSection(&This
->filter
.csFilter
);
351 if (This
->pInputPin
&& (PullPin_WaitForStateChange(This
->pInputPin
, dwMilliSecsTimeout
) == S_FALSE
))
352 hr
= VFW_S_STATE_INTERMEDIATE
;
353 LeaveCriticalSection(&pin
->thread_lock
);
358 HRESULT WINAPI
Parser_SetSyncSource(IBaseFilter
* iface
, IReferenceClock
*pClock
)
360 ParserImpl
*This
= impl_from_IBaseFilter(iface
);
361 PullPin
*pin
= impl_PullPin_from_IPin(This
->ppPins
[0]);
363 TRACE("(%p)\n", pClock
);
365 EnterCriticalSection(&pin
->thread_lock
);
366 BaseFilterImpl_SetSyncSource(iface
,pClock
);
367 LeaveCriticalSection(&pin
->thread_lock
);
372 HRESULT WINAPI
Parser_GetSyncSource(IBaseFilter
* iface
, IReferenceClock
**ppClock
)
374 return BaseFilterImpl_GetSyncSource(iface
, ppClock
);
377 /** IBaseFilter implementation **/
379 HRESULT WINAPI
Parser_EnumPins(IBaseFilter
* iface
, IEnumPins
**ppEnum
)
381 return BaseFilterImpl_EnumPins(iface
,ppEnum
);
384 HRESULT WINAPI
Parser_FindPin(IBaseFilter
* iface
, LPCWSTR Id
, IPin
**ppPin
)
386 FIXME("(%p)->(%s,%p)\n", iface
, debugstr_w(Id
), ppPin
);
388 /* FIXME: critical section */
393 HRESULT WINAPI
Parser_QueryFilterInfo(IBaseFilter
* iface
, FILTER_INFO
*pInfo
)
395 return BaseFilterImpl_QueryFilterInfo(iface
, pInfo
);
398 HRESULT WINAPI
Parser_JoinFilterGraph(IBaseFilter
* iface
, IFilterGraph
*pGraph
, LPCWSTR pName
)
400 return BaseFilterImpl_JoinFilterGraph(iface
, pGraph
, pName
);
403 HRESULT WINAPI
Parser_QueryVendorInfo(IBaseFilter
* iface
, LPWSTR
*pVendorInfo
)
405 return BaseFilterImpl_QueryVendorInfo(iface
, pVendorInfo
);
408 static const BaseOutputPinFuncTable output_BaseOutputFuncTable
= {
411 BaseOutputPinImpl_AttemptConnection
,
412 BasePinImpl_GetMediaTypeVersion
,
413 Parser_OutputPin_GetMediaType
415 Parser_OutputPin_DecideBufferSize
,
416 Parser_OutputPin_DecideAllocator
,
417 Parser_OutputPin_BreakConnect
420 HRESULT
Parser_AddPin(ParserImpl
* This
, const PIN_INFO
* piOutput
, ALLOCATOR_PROPERTIES
* props
, const AM_MEDIA_TYPE
* amt
)
425 ppOldPins
= This
->ppPins
;
427 This
->ppPins
= CoTaskMemAlloc((This
->cStreams
+ 2) * sizeof(IPin
*));
428 memcpy(This
->ppPins
, ppOldPins
, (This
->cStreams
+ 1) * sizeof(IPin
*));
430 hr
= BaseOutputPin_Construct(&Parser_OutputPin_Vtbl
, sizeof(Parser_OutputPin
), piOutput
, &output_BaseOutputFuncTable
, &This
->filter
.csFilter
, This
->ppPins
+ (This
->cStreams
+ 1));
434 IPin
*pPin
= This
->ppPins
[This
->cStreams
+ 1];
435 Parser_OutputPin
*pin
= unsafe_impl_Parser_OutputPin_from_IPin(pPin
);
436 pin
->pmt
= CoTaskMemAlloc(sizeof(AM_MEDIA_TYPE
));
437 CopyMediaType(pin
->pmt
, amt
);
438 pin
->dwSamplesProcessed
= 0;
440 pin
->pin
.pin
.pinInfo
.pFilter
= (LPVOID
)This
;
441 pin
->allocProps
= *props
;
443 BaseFilterImpl_IncrementPinVersion(&This
->filter
);
444 CoTaskMemFree(ppOldPins
);
448 CoTaskMemFree(This
->ppPins
);
449 This
->ppPins
= ppOldPins
;
450 ERR("Failed with error %x\n", hr
);
456 static HRESULT
Parser_RemoveOutputPins(ParserImpl
* This
)
458 /* NOTE: should be in critical section when calling this function */
461 IPin
** ppOldPins
= This
->ppPins
;
463 TRACE("(%p)\n", This
);
465 /* reduce the pin array down to 1 (just our input pin) */
466 This
->ppPins
= CoTaskMemAlloc(sizeof(IPin
*) * 1);
467 memcpy(This
->ppPins
, ppOldPins
, sizeof(IPin
*) * 1);
469 for (i
= 0; i
< This
->cStreams
; i
++)
471 hr
= ((BaseOutputPin
*)ppOldPins
[i
+ 1])->pFuncsTable
->pfnBreakConnect((BaseOutputPin
*)ppOldPins
[i
+ 1]);
472 TRACE("Disconnect: %08x\n", hr
);
473 IPin_Release(ppOldPins
[i
+ 1]);
476 BaseFilterImpl_IncrementPinVersion(&This
->filter
);
478 CoTaskMemFree(ppOldPins
);
483 static HRESULT WINAPI
Parser_ChangeStart(IMediaSeeking
*iface
)
485 FIXME("(%p) filter hasn't implemented start position change!\n", iface
);
489 static HRESULT WINAPI
Parser_ChangeStop(IMediaSeeking
*iface
)
491 FIXME("(%p) filter hasn't implemented stop position change!\n", iface
);
495 static HRESULT WINAPI
Parser_ChangeRate(IMediaSeeking
*iface
)
497 FIXME("(%p) filter hasn't implemented rate change!\n", iface
);
502 static HRESULT WINAPI
Parser_Seeking_QueryInterface(IMediaSeeking
* iface
, REFIID riid
, LPVOID
* ppv
)
504 ParserImpl
*This
= impl_from_IMediaSeeking(iface
);
506 return IUnknown_QueryInterface((IUnknown
*)This
, riid
, ppv
);
509 static ULONG WINAPI
Parser_Seeking_AddRef(IMediaSeeking
* iface
)
511 ParserImpl
*This
= impl_from_IMediaSeeking(iface
);
513 return IUnknown_AddRef((IUnknown
*)This
);
516 static ULONG WINAPI
Parser_Seeking_Release(IMediaSeeking
* iface
)
518 ParserImpl
*This
= impl_from_IMediaSeeking(iface
);
520 return IUnknown_Release((IUnknown
*)This
);
523 static const IMediaSeekingVtbl Parser_Seeking_Vtbl
=
525 Parser_Seeking_QueryInterface
,
526 Parser_Seeking_AddRef
,
527 Parser_Seeking_Release
,
528 SourceSeekingImpl_GetCapabilities
,
529 SourceSeekingImpl_CheckCapabilities
,
530 SourceSeekingImpl_IsFormatSupported
,
531 SourceSeekingImpl_QueryPreferredFormat
,
532 SourceSeekingImpl_GetTimeFormat
,
533 SourceSeekingImpl_IsUsingTimeFormat
,
534 SourceSeekingImpl_SetTimeFormat
,
535 SourceSeekingImpl_GetDuration
,
536 SourceSeekingImpl_GetStopPosition
,
537 SourceSeekingImpl_GetCurrentPosition
,
538 SourceSeekingImpl_ConvertTimeFormat
,
539 SourceSeekingImpl_SetPositions
,
540 SourceSeekingImpl_GetPositions
,
541 SourceSeekingImpl_GetAvailable
,
542 SourceSeekingImpl_SetRate
,
543 SourceSeekingImpl_GetRate
,
544 SourceSeekingImpl_GetPreroll
547 static HRESULT WINAPI
Parser_OutputPin_DecideBufferSize(BaseOutputPin
*iface
, IMemAllocator
*pAlloc
, ALLOCATOR_PROPERTIES
*ppropInputRequest
)
549 Parser_OutputPin
*This
= (Parser_OutputPin
*)iface
;
550 ALLOCATOR_PROPERTIES actual
;
552 if (ppropInputRequest
->cbAlign
&& ppropInputRequest
->cbAlign
!= This
->allocProps
.cbAlign
)
553 FIXME("Requested Buffer cbAlign mismatch %i,%i\n",This
->allocProps
.cbAlign
, ppropInputRequest
->cbAlign
);
554 if (ppropInputRequest
->cbPrefix
)
555 FIXME("Requested Buffer cbPrefix mismatch %i,%i\n",This
->allocProps
.cbPrefix
, ppropInputRequest
->cbPrefix
);
556 if (ppropInputRequest
->cbBuffer
)
557 FIXME("Requested Buffer cbBuffer mismatch %i,%i\n",This
->allocProps
.cbBuffer
, ppropInputRequest
->cbBuffer
);
558 if (ppropInputRequest
->cBuffers
)
559 FIXME("Requested Buffer cBuffers mismatch %i,%i\n",This
->allocProps
.cBuffers
, ppropInputRequest
->cBuffers
);
561 return IMemAllocator_SetProperties(pAlloc
, &This
->allocProps
, &actual
);
564 static HRESULT WINAPI
Parser_OutputPin_GetMediaType(BasePin
*iface
, int iPosition
, AM_MEDIA_TYPE
*pmt
)
566 Parser_OutputPin
*This
= (Parser_OutputPin
*)iface
;
570 return VFW_S_NO_MORE_ITEMS
;
571 CopyMediaType(pmt
, This
->pmt
);
575 static HRESULT WINAPI
Parser_OutputPin_DecideAllocator(BaseOutputPin
*iface
, IMemInputPin
*pPin
, IMemAllocator
**pAlloc
)
577 Parser_OutputPin
*This
= (Parser_OutputPin
*)iface
;
584 hr
= IMemInputPin_NotifyAllocator(pPin
, This
->alloc
, This
->readonly
);
587 *pAlloc
= This
->alloc
;
588 IMemAllocator_AddRef(*pAlloc
);
592 hr
= VFW_E_NO_ALLOCATOR
;
597 static HRESULT WINAPI
Parser_OutputPin_BreakConnect(BaseOutputPin
*This
)
601 TRACE("(%p)->()\n", This
);
603 EnterCriticalSection(This
->pin
.pCritSec
);
604 if (!This
->pin
.pConnectedTo
|| !This
->pMemInputPin
)
605 hr
= VFW_E_NOT_CONNECTED
;
608 hr
= IPin_Disconnect(This
->pin
.pConnectedTo
);
609 IPin_Disconnect(&This
->pin
.IPin_iface
);
611 LeaveCriticalSection(This
->pin
.pCritSec
);
617 static HRESULT WINAPI
Parser_OutputPin_QueryInterface(IPin
* iface
, REFIID riid
, LPVOID
* ppv
)
619 Parser_OutputPin
*This
= unsafe_impl_Parser_OutputPin_from_IPin(iface
);
621 TRACE("(%s, %p)\n", qzdebugstr_guid(riid
), ppv
);
625 if (IsEqualIID(riid
, &IID_IUnknown
))
627 else if (IsEqualIID(riid
, &IID_IPin
))
629 /* The Parser filter does not support querying IMediaSeeking, return it directly */
630 else if (IsEqualIID(riid
, &IID_IMediaSeeking
))
631 *ppv
= &impl_from_IBaseFilter(This
->pin
.pin
.pinInfo
.pFilter
)->sourceSeeking
;
635 IUnknown_AddRef((IUnknown
*)(*ppv
));
639 FIXME("No interface for %s!\n", qzdebugstr_guid(riid
));
641 return E_NOINTERFACE
;
644 static ULONG WINAPI
Parser_OutputPin_Release(IPin
* iface
)
646 Parser_OutputPin
*This
= unsafe_impl_Parser_OutputPin_from_IPin(iface
);
647 ULONG refCount
= InterlockedDecrement(&This
->pin
.pin
.refCount
);
649 TRACE("(%p)->() Release from %d\n", iface
, refCount
+ 1);
653 FreeMediaType(This
->pmt
);
654 CoTaskMemFree(This
->pmt
);
655 FreeMediaType(&This
->pin
.pin
.mtCurrent
);
656 if (This
->pin
.pAllocator
)
657 IMemAllocator_Release(This
->pin
.pAllocator
);
664 static HRESULT WINAPI
Parser_OutputPin_Connect(IPin
* iface
, IPin
* pReceivePin
, const AM_MEDIA_TYPE
* pmt
)
666 Parser_OutputPin
*This
= unsafe_impl_Parser_OutputPin_from_IPin(iface
);
667 ParserImpl
*parser
= impl_from_IBaseFilter(This
->pin
.pin
.pinInfo
.pFilter
);
669 /* Set the allocator to our input pin's */
670 EnterCriticalSection(This
->pin
.pin
.pCritSec
);
671 This
->alloc
= parser
->pInputPin
->pAlloc
;
672 LeaveCriticalSection(This
->pin
.pin
.pCritSec
);
674 return BaseOutputPinImpl_Connect(iface
, pReceivePin
, pmt
);
677 static HRESULT WINAPI
Parser_OutputPin_QueryAccept(IPin
*iface
, const AM_MEDIA_TYPE
* pmt
)
679 Parser_OutputPin
*This
= unsafe_impl_Parser_OutputPin_from_IPin(iface
);
682 dump_AM_MEDIA_TYPE(pmt
);
684 return (memcmp(This
->pmt
, pmt
, sizeof(AM_MEDIA_TYPE
)) == 0);
687 static const IPinVtbl Parser_OutputPin_Vtbl
=
689 Parser_OutputPin_QueryInterface
,
691 Parser_OutputPin_Release
,
692 Parser_OutputPin_Connect
,
693 BaseOutputPinImpl_ReceiveConnection
,
694 BaseOutputPinImpl_Disconnect
,
695 BasePinImpl_ConnectedTo
,
696 BasePinImpl_ConnectionMediaType
,
697 BasePinImpl_QueryPinInfo
,
698 BasePinImpl_QueryDirection
,
700 Parser_OutputPin_QueryAccept
,
701 BasePinImpl_EnumMediaTypes
,
702 BasePinImpl_QueryInternalConnections
,
703 BaseOutputPinImpl_EndOfStream
,
704 BaseOutputPinImpl_BeginFlush
,
705 BaseOutputPinImpl_EndFlush
,
706 BasePinImpl_NewSegment
709 static HRESULT WINAPI
Parser_PullPin_QueryInterface(IPin
* iface
, REFIID riid
, LPVOID
* ppv
)
711 PullPin
*This
= impl_PullPin_from_IPin(iface
);
713 TRACE("(%p/%p)->(%s, %p)\n", This
, iface
, qzdebugstr_guid(riid
), ppv
);
718 * It is important to capture the request for the IMediaSeeking interface before it is passed
719 * on to PullPin_QueryInterface, this is necessary since the Parser filter does not support
720 * querying IMediaSeeking
722 if (IsEqualIID(riid
, &IID_IMediaSeeking
))
723 *ppv
= &impl_from_IBaseFilter(This
->pin
.pinInfo
.pFilter
)->sourceSeeking
;
727 IUnknown_AddRef((IUnknown
*)(*ppv
));
731 return PullPin_QueryInterface(iface
, riid
, ppv
);
734 static HRESULT WINAPI
Parser_PullPin_Disconnect(IPin
* iface
)
737 PullPin
*This
= impl_PullPin_from_IPin(iface
);
741 EnterCriticalSection(&This
->thread_lock
);
742 EnterCriticalSection(This
->pin
.pCritSec
);
744 if (This
->pin
.pConnectedTo
)
747 ParserImpl
*Parser
= impl_from_IBaseFilter(This
->pin
.pinInfo
.pFilter
);
749 LeaveCriticalSection(This
->pin
.pCritSec
);
750 hr
= IBaseFilter_GetState(This
->pin
.pinInfo
.pFilter
, INFINITE
, &state
);
751 EnterCriticalSection(This
->pin
.pCritSec
);
753 if (SUCCEEDED(hr
) && (state
== State_Stopped
) && SUCCEEDED(Parser
->fnDisconnect(Parser
)))
755 LeaveCriticalSection(This
->pin
.pCritSec
);
756 PullPin_Disconnect(iface
);
757 EnterCriticalSection(This
->pin
.pCritSec
);
758 hr
= Parser_RemoveOutputPins(impl_from_IBaseFilter(This
->pin
.pinInfo
.pFilter
));
761 hr
= VFW_E_NOT_STOPPED
;
766 LeaveCriticalSection(This
->pin
.pCritSec
);
767 LeaveCriticalSection(&This
->thread_lock
);
772 static HRESULT WINAPI
Parser_PullPin_ReceiveConnection(IPin
* iface
, IPin
* pReceivePin
, const AM_MEDIA_TYPE
* pmt
)
778 hr
= PullPin_ReceiveConnection(iface
, pReceivePin
, pmt
);
781 BasePin
*This
= (BasePin
*)iface
;
783 EnterCriticalSection(This
->pCritSec
);
784 Parser_RemoveOutputPins(impl_from_IBaseFilter(This
->pinInfo
.pFilter
));
785 LeaveCriticalSection(This
->pCritSec
);
791 static HRESULT WINAPI
Parser_PullPin_EnumMediaTypes(IPin
*iface
, IEnumMediaTypes
**ppEnum
)
793 BasePin
*This
= (BasePin
*)iface
;
795 TRACE("(%p/%p)->(%p)\n", This
, iface
, ppEnum
);
797 return EnumMediaTypes_Construct(This
, BasePinImpl_GetMediaType
, BasePinImpl_GetMediaTypeVersion
, ppEnum
);
800 static const IPinVtbl Parser_InputPin_Vtbl
=
802 Parser_PullPin_QueryInterface
,
805 BaseInputPinImpl_Connect
,
806 Parser_PullPin_ReceiveConnection
,
807 Parser_PullPin_Disconnect
,
808 BasePinImpl_ConnectedTo
,
809 BasePinImpl_ConnectionMediaType
,
810 BasePinImpl_QueryPinInfo
,
811 BasePinImpl_QueryDirection
,
814 Parser_PullPin_EnumMediaTypes
,
815 BasePinImpl_QueryInternalConnections
,