reactos/lib/3rdparty/strmbase/filter.c

   1 /*
   2  * Generic Implementation of IBaseFilter Interface
   3  *
   4  * Copyright 2010 Aric Stewart, CodeWeavers
   5  *
   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.
  10  *
  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.
  15  *
  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
  19  */
  20
  21 #include "strmbase_private.h"
  22
  23 static inline BaseFilter *impl_from_IBaseFilter(IBaseFilter *iface)
  24 {
  25     return CONTAINING_RECORD(iface, BaseFilter, IBaseFilter_iface);
  26 }
  27
  28 HRESULT WINAPI BaseFilterImpl_QueryInterface(IBaseFilter * iface, REFIID riid, LPVOID * ppv)
  29 {
  30     BaseFilter *This = impl_from_IBaseFilter(iface);
  31     TRACE("(%p)->(%s, %p)\n", iface, debugstr_guid(riid), ppv);
  32
  33     *ppv = NULL;
  34
  35     if (IsEqualIID(riid, &IID_IUnknown))
  36         *ppv = This;
  37     else if (IsEqualIID(riid, &IID_IPersist))
  38         *ppv = This;
  39     else if (IsEqualIID(riid, &IID_IMediaFilter))
  40         *ppv = This;
  41     else if (IsEqualIID(riid, &IID_IBaseFilter))
  42         *ppv = This;
  43
  44     if (*ppv)
  45     {
  46         IUnknown_AddRef((IUnknown *)(*ppv));
  47         return S_OK;
  48     }
  49
  50     return E_NOINTERFACE;
  51 }
  52
  53 ULONG WINAPI BaseFilterImpl_AddRef(IBaseFilter * iface)
  54 {
  55     BaseFilter *This = impl_from_IBaseFilter(iface);
  56     ULONG refCount = InterlockedIncrement(&This->refCount);
  57
  58     TRACE("(%p)->() AddRef from %d\n", This, refCount - 1);
  59
  60     return refCount;
  61 }
  62
  63 ULONG WINAPI BaseFilterImpl_Release(IBaseFilter * iface)
  64 {
  65     BaseFilter *This = impl_from_IBaseFilter(iface);
  66     ULONG refCount = InterlockedDecrement(&This->refCount);
  67
  68     TRACE("(%p)->() Release from %d\n", This, refCount + 1);
  69
  70     if (!refCount)
  71     {
  72         if (This->pClock)
  73             IReferenceClock_Release(This->pClock);
  74
  75         This->IBaseFilter_iface.lpVtbl = NULL;
  76         This->csFilter.DebugInfo->Spare[0] = 0;
  77         DeleteCriticalSection(&This->csFilter);
  78     }
  79
  80     return refCount;
  81 }
  82
  83 HRESULT WINAPI BaseFilterImpl_GetClassID(IBaseFilter * iface, CLSID * pClsid)
  84 {
  85     BaseFilter *This = impl_from_IBaseFilter(iface);
  86     TRACE("(%p)->(%p)\n", This, pClsid);
  87
  88     *pClsid = This->clsid;
  89
  90     return S_OK;
  91 }
  92
  93 HRESULT WINAPI BaseFilterImpl_GetState(IBaseFilter * iface, DWORD dwMilliSecsTimeout, FILTER_STATE *pState )
  94 {
  95     BaseFilter *This = impl_from_IBaseFilter(iface);
  96     TRACE("(%p)->(%d, %p)\n", This, dwMilliSecsTimeout, pState);
  97
  98     EnterCriticalSection(&This->csFilter);
  99     {
 100         *pState = This->state;
 101     }
 102     LeaveCriticalSection(&This->csFilter);
 103
 104     return S_OK;
 105 }
 106
 107 HRESULT WINAPI BaseFilterImpl_SetSyncSource(IBaseFilter * iface, IReferenceClock *pClock)
 108 {
 109     BaseFilter *This = impl_from_IBaseFilter(iface);
 110     TRACE("(%p)->(%p)\n", This, pClock);
 111
 112     EnterCriticalSection(&This->csFilter);
 113     {
 114         if (This->pClock)
 115             IReferenceClock_Release(This->pClock);
 116         This->pClock = pClock;
 117         if (This->pClock)
 118             IReferenceClock_AddRef(This->pClock);
 119     }
 120     LeaveCriticalSection(&This->csFilter);
 121
 122     return S_OK;
 123 }
 124
 125 HRESULT WINAPI BaseFilterImpl_GetSyncSource(IBaseFilter * iface, IReferenceClock **ppClock)
 126 {
 127     BaseFilter *This = impl_from_IBaseFilter(iface);
 128     TRACE("(%p)->(%p)\n", This, ppClock);
 129
 130     EnterCriticalSection(&This->csFilter);
 131     {
 132         *ppClock = This->pClock;
 133         if (This->pClock)
 134             IReferenceClock_AddRef(This->pClock);
 135     }
 136     LeaveCriticalSection(&This->csFilter);
 137
 138     return S_OK;
 139 }
 140
 141 HRESULT WINAPI BaseFilterImpl_EnumPins(IBaseFilter * iface, IEnumPins **ppEnum)
 142 {
 143     BaseFilter *This = impl_from_IBaseFilter(iface);
 144
 145     TRACE("(%p)->(%p)\n", iface, ppEnum);
 146
 147     return EnumPins_Construct(This, This->pFuncsTable->pfnGetPin, This->pFuncsTable->pfnGetPinCount, BaseFilterImpl_GetPinVersion, ppEnum);
 148 }
 149
 150
 151 HRESULT WINAPI BaseFilterImpl_QueryFilterInfo(IBaseFilter * iface, FILTER_INFO *pInfo)
 152 {
 153     BaseFilter *This = impl_from_IBaseFilter(iface);
 154     TRACE("(%p)->(%p)\n", This, pInfo);
 155
 156     strcpyW(pInfo->achName, This->filterInfo.achName);
 157     pInfo->pGraph = This->filterInfo.pGraph;
 158
 159     if (pInfo->pGraph)
 160         IFilterGraph_AddRef(pInfo->pGraph);
 161
 162     return S_OK;
 163 }
 164
 165 HRESULT WINAPI BaseFilterImpl_JoinFilterGraph(IBaseFilter * iface, IFilterGraph *pGraph, LPCWSTR pName )
 166 {
 167     HRESULT hr = S_OK;
 168     BaseFilter *This = impl_from_IBaseFilter(iface);
 169
 170     TRACE("(%p)->(%p, %s)\n", This, pGraph, debugstr_w(pName));
 171
 172     EnterCriticalSection(&This->csFilter);
 173     {
 174         if (pName)
 175             strcpyW(This->filterInfo.achName, pName);
 176         else
 177             *This->filterInfo.achName = '\0';
 178         This->filterInfo.pGraph = pGraph; /* NOTE: do NOT increase ref. count */
 179     }
 180     LeaveCriticalSection(&This->csFilter);
 181
 182     return hr;
 183 }
 184
 185 HRESULT WINAPI BaseFilterImpl_QueryVendorInfo(IBaseFilter * iface, LPWSTR *pVendorInfo)
 186 {
 187     TRACE("(%p)->(%p)\n", iface, pVendorInfo);
 188     return E_NOTIMPL;
 189 }
 190
 191 LONG WINAPI BaseFilterImpl_GetPinVersion(BaseFilter * This)
 192 {
 193     TRACE("(%p)\n", This);
 194     return This->pinVersion;
 195 }
 196
 197 VOID WINAPI BaseFilterImpl_IncrementPinVersion(BaseFilter * This)
 198 {
 199     InterlockedIncrement(&This->pinVersion);
 200     TRACE("(%p) -> New pinVersion %i\n", This,This->pinVersion);
 201 }
 202
 203 HRESULT WINAPI BaseFilter_Init(BaseFilter * This, const IBaseFilterVtbl *Vtbl, const CLSID *pClsid, DWORD_PTR DebugInfo, const BaseFilterFuncTable* pBaseFuncsTable)
 204 {
 205     This->IBaseFilter_iface.lpVtbl = Vtbl;
 206     This->refCount = 1;
 207     InitializeCriticalSection(&This->csFilter);
 208     This->state = State_Stopped;
 209     This->rtStreamStart = 0;
 210     This->pClock = NULL;
 211     ZeroMemory(&This->filterInfo, sizeof(FILTER_INFO));
 212     This->clsid = *pClsid;
 213     This->csFilter.DebugInfo->Spare[0] = DebugInfo;
 214     This->pinVersion = 1;
 215
 216     This->pFuncsTable = pBaseFuncsTable;
 217
 218     return S_OK;
 219 }