+++ /dev/null
-/*
- * COPYRIGHT: See COPYING in the top level directory
- * PROJECT: ReactOS WDM Streaming ActiveMovie Proxy
- * FILE: dll/directx/ksproxy/input_pin.cpp
- * PURPOSE: InputPin of Proxy Filter
- *
- * PROGRAMMERS: Johannes Anderwald (johannes.anderwald@reactos.org)
- */
-#include "precomp.h"
-
-const GUID IID_IKsPinPipe = {0xe539cd90, 0xa8b4, 0x11d1, {0x81, 0x89, 0x00, 0xa0, 0xc9, 0x06, 0x28, 0x02}};
-const GUID IID_IKsPinEx = {0x7bb38260L, 0xd19c, 0x11d2, {0xb3, 0x8a, 0x00, 0xa0, 0xc9, 0x5e, 0xc2, 0x2e}};
-
-KSPIN_INTERFACE StandardPinInterface =
-{
- {STATIC_KSINTERFACESETID_Standard},
- KSINTERFACE_STANDARD_STREAMING,
- 0
-};
-
-KSPIN_MEDIUM StandardPinMedium =
-{
- {STATIC_KSMEDIUMSETID_Standard},
- KSMEDIUM_TYPE_ANYINSTANCE,
- 0
-};
-
-class CInputPin : public IPin,
- public IKsPropertySet,
- public IKsControl,
- public IKsObject,
- public IKsPinEx,
- public IMemInputPin,
- public IKsPinPipe,
- public IKsPinFactory,
- public IStreamBuilder,
- public IKsAggregateControl,
- public IQualityControl,
- public ISpecifyPropertyPages
-{
-public:
- typedef std::vector<IUnknown *>ProxyPluginVector;
-
- STDMETHODIMP QueryInterface( REFIID InterfaceId, PVOID* Interface);
-
- STDMETHODIMP_(ULONG) AddRef()
- {
- InterlockedIncrement(&m_Ref);
- return m_Ref;
- }
- STDMETHODIMP_(ULONG) Release()
- {
- InterlockedDecrement(&m_Ref);
- if (!m_Ref)
- {
- delete this;
- return 0;
- }
- return m_Ref;
- }
-
- //IKsPinPipe
- HRESULT STDMETHODCALLTYPE KsGetPinFramingCache(PKSALLOCATOR_FRAMING_EX *FramingEx, PFRAMING_PROP FramingProp, FRAMING_CACHE_OPS Option);
- HRESULT STDMETHODCALLTYPE KsSetPinFramingCache(PKSALLOCATOR_FRAMING_EX FramingEx, PFRAMING_PROP FramingProp, FRAMING_CACHE_OPS Option);
- IPin* STDMETHODCALLTYPE KsGetConnectedPin();
- IKsAllocatorEx* STDMETHODCALLTYPE KsGetPipe(KSPEEKOPERATION Operation);
- HRESULT STDMETHODCALLTYPE KsSetPipe(IKsAllocatorEx *KsAllocator);
- ULONG STDMETHODCALLTYPE KsGetPipeAllocatorFlag();
- HRESULT STDMETHODCALLTYPE KsSetPipeAllocatorFlag(ULONG Flag);
- GUID STDMETHODCALLTYPE KsGetPinBusCache();
- HRESULT STDMETHODCALLTYPE KsSetPinBusCache(GUID Bus);
- PWCHAR STDMETHODCALLTYPE KsGetPinName();
- PWCHAR STDMETHODCALLTYPE KsGetFilterName();
-
- //IPin methods
- HRESULT STDMETHODCALLTYPE Connect(IPin *pReceivePin, const AM_MEDIA_TYPE *pmt);
- HRESULT STDMETHODCALLTYPE ReceiveConnection(IPin *pConnector, const AM_MEDIA_TYPE *pmt);
- HRESULT STDMETHODCALLTYPE Disconnect();
- HRESULT STDMETHODCALLTYPE ConnectedTo(IPin **pPin);
- HRESULT STDMETHODCALLTYPE ConnectionMediaType(AM_MEDIA_TYPE *pmt);
- HRESULT STDMETHODCALLTYPE QueryPinInfo(PIN_INFO *pInfo);
- HRESULT STDMETHODCALLTYPE QueryDirection(PIN_DIRECTION *pPinDir);
- HRESULT STDMETHODCALLTYPE QueryId(LPWSTR *Id);
- HRESULT STDMETHODCALLTYPE QueryAccept(const AM_MEDIA_TYPE *pmt);
- HRESULT STDMETHODCALLTYPE EnumMediaTypes(IEnumMediaTypes **ppEnum);
- HRESULT STDMETHODCALLTYPE QueryInternalConnections(IPin **apPin, ULONG *nPin);
- HRESULT STDMETHODCALLTYPE EndOfStream();
- HRESULT STDMETHODCALLTYPE BeginFlush();
- HRESULT STDMETHODCALLTYPE EndFlush();
- HRESULT STDMETHODCALLTYPE NewSegment(REFERENCE_TIME tStart, REFERENCE_TIME tStop, double dRate);
-
- // ISpecifyPropertyPages
- HRESULT STDMETHODCALLTYPE GetPages(CAUUID *pPages);
-
- //IKsObject methods
- HANDLE STDMETHODCALLTYPE KsGetObjectHandle();
-
- //IKsPropertySet
- HRESULT STDMETHODCALLTYPE Set(REFGUID guidPropSet, DWORD dwPropID, LPVOID pInstanceData, DWORD cbInstanceData, LPVOID pPropData, DWORD cbPropData);
- HRESULT STDMETHODCALLTYPE Get(REFGUID guidPropSet, DWORD dwPropID, LPVOID pInstanceData, DWORD cbInstanceData, LPVOID pPropData, DWORD cbPropData, DWORD *pcbReturned);
- HRESULT STDMETHODCALLTYPE QuerySupported(REFGUID guidPropSet, DWORD dwPropID, DWORD *pTypeSupport);
-
- //IKsControl
- HRESULT STDMETHODCALLTYPE KsProperty(PKSPROPERTY Property, ULONG PropertyLength, LPVOID PropertyData, ULONG DataLength, ULONG* BytesReturned);
- HRESULT STDMETHODCALLTYPE KsMethod(PKSMETHOD Method, ULONG MethodLength, LPVOID MethodData, ULONG DataLength, ULONG* BytesReturned);
- HRESULT STDMETHODCALLTYPE KsEvent(PKSEVENT Event, ULONG EventLength, LPVOID EventData, ULONG DataLength, ULONG* BytesReturned);
-
- //IKsPin
- HRESULT STDMETHODCALLTYPE KsQueryMediums(PKSMULTIPLE_ITEM* MediumList);
- HRESULT STDMETHODCALLTYPE KsQueryInterfaces(PKSMULTIPLE_ITEM* InterfaceList);
- HRESULT STDMETHODCALLTYPE KsCreateSinkPinHandle(KSPIN_INTERFACE& Interface, KSPIN_MEDIUM& Medium);
- HRESULT STDMETHODCALLTYPE KsGetCurrentCommunication(KSPIN_COMMUNICATION *Communication, KSPIN_INTERFACE *Interface, KSPIN_MEDIUM *Medium);
- HRESULT STDMETHODCALLTYPE KsPropagateAcquire();
- HRESULT STDMETHODCALLTYPE KsDeliver(IMediaSample* Sample, ULONG Flags);
- HRESULT STDMETHODCALLTYPE KsMediaSamplesCompleted(PKSSTREAM_SEGMENT StreamSegment);
- IMemAllocator * STDMETHODCALLTYPE KsPeekAllocator(KSPEEKOPERATION Operation);
- HRESULT STDMETHODCALLTYPE KsReceiveAllocator(IMemAllocator *MemAllocator);
- HRESULT STDMETHODCALLTYPE KsRenegotiateAllocator();
- LONG STDMETHODCALLTYPE KsIncrementPendingIoCount();
- LONG STDMETHODCALLTYPE KsDecrementPendingIoCount();
- HRESULT STDMETHODCALLTYPE KsQualityNotify(ULONG Proportion, REFERENCE_TIME TimeDelta);
- // IKsPinEx
- VOID STDMETHODCALLTYPE KsNotifyError(IMediaSample* Sample, HRESULT hr);
-
- //IMemInputPin
- HRESULT STDMETHODCALLTYPE GetAllocator(IMemAllocator **ppAllocator);
- HRESULT STDMETHODCALLTYPE NotifyAllocator(IMemAllocator *pAllocator, BOOL bReadOnly);
- HRESULT STDMETHODCALLTYPE GetAllocatorRequirements(ALLOCATOR_PROPERTIES *pProps);
- HRESULT STDMETHODCALLTYPE Receive(IMediaSample *pSample);
- HRESULT STDMETHODCALLTYPE ReceiveMultiple(IMediaSample **pSamples, long nSamples, long *nSamplesProcessed);
- HRESULT STDMETHODCALLTYPE ReceiveCanBlock( void);
-
- //IKsPinFactory
- HRESULT STDMETHODCALLTYPE KsPinFactory(ULONG* PinFactory);
-
- //IStreamBuilder
- HRESULT STDMETHODCALLTYPE Render(IPin *ppinOut, IGraphBuilder *pGraph);
- HRESULT STDMETHODCALLTYPE Backout(IPin *ppinOut, IGraphBuilder *pGraph);
-
- //IKsAggregateControl
- HRESULT STDMETHODCALLTYPE KsAddAggregate(IN REFGUID AggregateClass);
- HRESULT STDMETHODCALLTYPE KsRemoveAggregate(REFGUID AggregateClass);
-
- //IQualityControl
- HRESULT STDMETHODCALLTYPE Notify(IBaseFilter *pSelf, Quality q);
- HRESULT STDMETHODCALLTYPE SetSink(IQualityControl *piqc);
-
- //---------------------------------------------------------------
- HRESULT STDMETHODCALLTYPE CheckFormat(const AM_MEDIA_TYPE *pmt);
- HRESULT STDMETHODCALLTYPE CreatePin(const AM_MEDIA_TYPE *pmt);
- HRESULT STDMETHODCALLTYPE CreatePinHandle(PKSPIN_MEDIUM Medium, PKSPIN_INTERFACE Interface, const AM_MEDIA_TYPE *pmt);
- HRESULT STDMETHODCALLTYPE GetSupportedSets(LPGUID * pOutGuid, PULONG NumGuids);
- HRESULT STDMETHODCALLTYPE LoadProxyPlugins(LPGUID pGuids, ULONG NumGuids);
- CInputPin(IBaseFilter * ParentFilter, LPCWSTR PinName, ULONG PinId, KSPIN_COMMUNICATION Communication);
- virtual ~CInputPin(){};
-
-protected:
- LONG m_Ref;
- IBaseFilter * m_ParentFilter;
- LPCWSTR m_PinName;
- HANDLE m_hPin;
- ULONG m_PinId;
- IMemAllocator * m_MemAllocator;
- LONG m_IoCount;
- KSPIN_COMMUNICATION m_Communication;
- KSPIN_INTERFACE m_Interface;
- KSPIN_MEDIUM m_Medium;
- AM_MEDIA_TYPE m_MediaFormat;
- IPin * m_Pin;
- BOOL m_ReadOnly;
- IKsInterfaceHandler * m_InterfaceHandler;
- IKsAllocatorEx * m_KsAllocatorEx;
- ULONG m_PipeAllocatorFlag;
- BOOL m_bPinBusCacheInitialized;
- GUID m_PinBusCache;
- LPWSTR m_FilterName;
- FRAMING_PROP m_FramingProp[4];
- PKSALLOCATOR_FRAMING_EX m_FramingEx[4];
- ProxyPluginVector m_Plugins;
-};
-
-CInputPin::CInputPin(
- IBaseFilter * ParentFilter,
- LPCWSTR PinName,
- ULONG PinId,
- KSPIN_COMMUNICATION Communication) : m_Ref(0),
- m_ParentFilter(ParentFilter),
- m_PinName(PinName),
- m_hPin(INVALID_HANDLE_VALUE),
- m_PinId(PinId),
- m_MemAllocator(0),
- m_IoCount(0),
- m_Communication(Communication),
- m_Pin(0),
- m_ReadOnly(0),
- m_InterfaceHandler(0),
- m_KsAllocatorEx(0),
- m_PipeAllocatorFlag(0),
- m_bPinBusCacheInitialized(0),
- m_FilterName(0),
- m_Plugins()
-{
- ZeroMemory(m_FramingProp, sizeof(m_FramingProp));
- ZeroMemory(m_FramingEx, sizeof(m_FramingEx));
-
- HRESULT hr;
- IKsObject * KsObjectParent;
- HANDLE hFilter;
-
- hr = m_ParentFilter->QueryInterface(IID_IKsObject, (LPVOID*)&KsObjectParent);
- assert(hr == S_OK);
-
- hFilter = KsObjectParent->KsGetObjectHandle();
- assert(hFilter);
-
- KsObjectParent->Release();
-
-
- ZeroMemory(&m_MediaFormat, sizeof(AM_MEDIA_TYPE));
- hr = KsGetMediaType(0, &m_MediaFormat, hFilter, m_PinId);
- assert(hr == S_OK);
-}
-
-HRESULT
-STDMETHODCALLTYPE
-CInputPin::QueryInterface(
- IN REFIID refiid,
- OUT PVOID* Output)
-{
- WCHAR Buffer[100];
-
- *Output = NULL;
-
- if (IsEqualGUID(refiid, IID_IUnknown) ||
- IsEqualGUID(refiid, IID_IPin))
- {
- *Output = PVOID(this);
- reinterpret_cast<IUnknown*>(*Output)->AddRef();
- return NOERROR;
- }
- else if (IsEqualGUID(refiid, IID_IMemInputPin))
- {
- if (m_hPin == INVALID_HANDLE_VALUE)
- {
- HRESULT hr = CreatePin(&m_MediaFormat);
- if (FAILED(hr))
- return hr;
- }
-
- *Output = (IMemInputPin*)(this);
- reinterpret_cast<IMemInputPin*>(*Output)->AddRef();
- return NOERROR;
- }
- else if (IsEqualGUID(refiid, IID_IKsObject))
- {
- *Output = (IKsObject*)(this);
- reinterpret_cast<IKsObject*>(*Output)->AddRef();
- return NOERROR;
- }
- else if (IsEqualGUID(refiid, IID_IKsPropertySet))
- {
- if (m_hPin == INVALID_HANDLE_VALUE)
- {
- HRESULT hr = CreatePin(&m_MediaFormat);
- if (FAILED(hr))
- return hr;
- }
-
- *Output = (IKsPropertySet*)(this);
- reinterpret_cast<IKsPropertySet*>(*Output)->AddRef();
- return NOERROR;
- }
- else if (IsEqualGUID(refiid, IID_IKsControl))
- {
- *Output = (IKsControl*)(this);
- reinterpret_cast<IKsControl*>(*Output)->AddRef();
- return NOERROR;
- }
- else if (IsEqualGUID(refiid, IID_IKsPin) ||
- IsEqualGUID(refiid, IID_IKsPinEx))
- {
- *Output = (IKsPinEx*)(this);
- reinterpret_cast<IKsPinEx*>(*Output)->AddRef();
- return NOERROR;
- }
- else if (IsEqualGUID(refiid, IID_IKsPinPipe))
- {
- *Output = (IKsPinPipe*)(this);
- reinterpret_cast<IKsPinPipe*>(*Output)->AddRef();
- return NOERROR;
- }
- else if (IsEqualGUID(refiid, IID_IKsPinFactory))
- {
- *Output = (IKsPinFactory*)(this);
- reinterpret_cast<IKsPinFactory*>(*Output)->AddRef();
- return NOERROR;
- }
-#if 0
- else if (IsEqualGUID(refiid, IID_IStreamBuilder))
- {
- *Output = (IStreamBuilder*)(this);
- reinterpret_cast<IStreamBuilder*>(*Output)->AddRef();
- return NOERROR;
- }
-#endif
- else if (IsEqualGUID(refiid, IID_IKsAggregateControl))
- {
- *Output = (IKsAggregateControl*)(this);
- reinterpret_cast<IKsAggregateControl*>(*Output)->AddRef();
- return NOERROR;
- }
- else if (IsEqualGUID(refiid, IID_IQualityControl))
- {
- *Output = (IQualityControl*)(this);
- reinterpret_cast<IQualityControl*>(*Output)->AddRef();
- return NOERROR;
- }
- else if (IsEqualGUID(refiid, IID_ISpecifyPropertyPages))
- {
- *Output = (ISpecifyPropertyPages*)(this);
- reinterpret_cast<ISpecifyPropertyPages*>(*Output)->AddRef();
- return NOERROR;
- }
-
- LPOLESTR lpstr;
- StringFromCLSID(refiid, &lpstr);
- swprintf(Buffer, L"CInputPin::QueryInterface: NoInterface for %s\n", lpstr);
- OutputDebugStringW(Buffer);
- CoTaskMemFree(lpstr);
-
- return E_NOINTERFACE;
-}
-//-------------------------------------------------------------------
-// IQualityControl interface
-//
-HRESULT
-STDMETHODCALLTYPE
-CInputPin::Notify(
- IBaseFilter *pSelf,
- Quality q)
-{
-#ifdef KSPROXY_TRACE
- OutputDebugStringW(L"CInputPin::Notify NotImplemented\n");
-#endif
-
- return E_NOTIMPL;
-}
-
-HRESULT
-STDMETHODCALLTYPE
-CInputPin::SetSink(
- IQualityControl *piqc)
-{
-#ifdef KSPROXY_TRACE
- OutputDebugStringW(L"CInputPin::SetSink NotImplemented\n");
-#endif
-
- return E_NOTIMPL;
-}
-
-
-//-------------------------------------------------------------------
-// IKsAggregateControl interface
-//
-HRESULT
-STDMETHODCALLTYPE
-CInputPin::KsAddAggregate(
- IN REFGUID AggregateClass)
-{
-#ifdef KSPROXY_TRACE
- OutputDebugStringW(L"CInputPin::KsAddAggregate NotImplemented\n");
-#endif
-
- return E_NOTIMPL;
-}
-
-HRESULT
-STDMETHODCALLTYPE
-CInputPin::KsRemoveAggregate(
- REFGUID AggregateClass)
-{
-#ifdef KSPROXY_TRACE
- OutputDebugStringW(L"CInputPin::KsRemoveAggregate NotImplemented\n");
-#endif
-
- return E_NOTIMPL;
-}
-
-//-------------------------------------------------------------------
-// IStreamBuilder
-//
-
-HRESULT
-STDMETHODCALLTYPE
-CInputPin::Render(
- IPin *ppinOut,
- IGraphBuilder *pGraph)
-{
- OutputDebugStringW(L"CInputPin::Render\n");
- return S_OK;
-}
-
-HRESULT
-STDMETHODCALLTYPE
-CInputPin::Backout(
- IPin *ppinOut,
- IGraphBuilder *pGraph)
-{
-#ifdef KSPROXY_TRACE
- OutputDebugStringW(L"CInputPin::Backout\n");
-#endif
-
- return S_OK;
-}
-
-//-------------------------------------------------------------------
-// IKsPinFactory
-//
-
-HRESULT
-STDMETHODCALLTYPE
-CInputPin::KsPinFactory(
- ULONG* PinFactory)
-{
-#ifdef KSPROXY_TRACE
- OutputDebugStringW(L"CInputPin::KsPinFactory\n");
-#endif
-
- *PinFactory = m_PinId;
- return S_OK;
-}
-
-//-------------------------------------------------------------------
-// IKsPinPipe
-//
-
-HRESULT
-STDMETHODCALLTYPE
-CInputPin::KsGetPinFramingCache(
- PKSALLOCATOR_FRAMING_EX *FramingEx,
- PFRAMING_PROP FramingProp,
- FRAMING_CACHE_OPS Option)
-{
- if (Option > Framing_Cache_Write || Option < Framing_Cache_ReadLast)
- {
- // invalid argument
- return E_INVALIDARG;
- }
-
- // get framing properties
- *FramingProp = m_FramingProp[Option];
- *FramingEx = m_FramingEx[Option];
-
- return NOERROR;
-}
-
-HRESULT
-STDMETHODCALLTYPE
-CInputPin::KsSetPinFramingCache(
- PKSALLOCATOR_FRAMING_EX FramingEx,
- PFRAMING_PROP FramingProp,
- FRAMING_CACHE_OPS Option)
-{
- ULONG Index;
- ULONG RefCount = 0;
-
- if (m_FramingEx[Option])
- {
- for(Index = 1; Index < 4; Index++)
- {
- if (m_FramingEx[Index] == m_FramingEx[Option])
- RefCount++;
- }
-
- if (RefCount == 1)
- {
- // existing framing is only used once
- CoTaskMemFree(m_FramingEx[Option]);
- }
- }
-
- // store framing
- m_FramingEx[Option] = FramingEx;
- m_FramingProp[Option] = *FramingProp;
-
- return S_OK;
-}
-
-IPin*
-STDMETHODCALLTYPE
-CInputPin::KsGetConnectedPin()
-{
- return m_Pin;
-}
-
-IKsAllocatorEx*
-STDMETHODCALLTYPE
-CInputPin::KsGetPipe(
- KSPEEKOPERATION Operation)
-{
- if (Operation == KsPeekOperation_AddRef)
- {
- if (m_KsAllocatorEx)
- m_KsAllocatorEx->AddRef();
- }
- return m_KsAllocatorEx;
-}
-
-HRESULT
-STDMETHODCALLTYPE
-CInputPin::KsSetPipe(
- IKsAllocatorEx *KsAllocator)
-{
- if (KsAllocator)
- KsAllocator->AddRef();
-
- if (m_KsAllocatorEx)
- m_KsAllocatorEx->Release();
-
- m_KsAllocatorEx = KsAllocator;
- return NOERROR;
-}
-
-ULONG
-STDMETHODCALLTYPE
-CInputPin::KsGetPipeAllocatorFlag()
-{
- return m_PipeAllocatorFlag;
-}
-
-
-HRESULT
-STDMETHODCALLTYPE
-CInputPin::KsSetPipeAllocatorFlag(
- ULONG Flag)
-{
- m_PipeAllocatorFlag = Flag;
- return NOERROR;
-}
-
-GUID
-STDMETHODCALLTYPE
-CInputPin::KsGetPinBusCache()
-{
- if (!m_bPinBusCacheInitialized)
- {
- CopyMemory(&m_PinBusCache, &m_Medium.Set, sizeof(GUID));
- m_bPinBusCacheInitialized = TRUE;
- }
-
- return m_PinBusCache;
-}
-
-HRESULT
-STDMETHODCALLTYPE
-CInputPin::KsSetPinBusCache(
- GUID Bus)
-{
- CopyMemory(&m_PinBusCache, &Bus, sizeof(GUID));
- return NOERROR;
-}
-
-PWCHAR
-STDMETHODCALLTYPE
-CInputPin::KsGetPinName()
-{
- return (PWCHAR)m_PinName;
-}
-
-
-PWCHAR
-STDMETHODCALLTYPE
-CInputPin::KsGetFilterName()
-{
- return m_FilterName;
-}
-
-//-------------------------------------------------------------------
-// ISpecifyPropertyPages
-//
-
-HRESULT
-STDMETHODCALLTYPE
-CInputPin::GetPages(CAUUID *pPages)
-{
- if (!pPages)
- return E_POINTER;
-
- pPages->cElems = 0;
- pPages->pElems = NULL;
-
- return S_OK;
-}
-
-//-------------------------------------------------------------------
-// IMemInputPin
-//
-
-
-HRESULT
-STDMETHODCALLTYPE
-CInputPin::GetAllocator(IMemAllocator **ppAllocator)
-{
-#ifdef KSPROXY_TRACE
- OutputDebugStringW(L"CInputPin::GetAllocator\n");
-#endif
-
- return VFW_E_NO_ALLOCATOR;
-}
-
-HRESULT
-STDMETHODCALLTYPE
-CInputPin::NotifyAllocator(IMemAllocator *pAllocator, BOOL bReadOnly)
-{
- HRESULT hr;
- ALLOCATOR_PROPERTIES Properties;
-
- hr = pAllocator->GetProperties(&Properties);
-
-#ifdef KSPROXY_TRACE
- WCHAR Buffer[100];
- swprintf(Buffer, L"CInputPin::NotifyAllocator hr %lx bReadOnly, %u cbAlign %u cbBuffer %u cbPrefix %u cBuffers %u\n", hr, bReadOnly, Properties.cbAlign, Properties.cbBuffer, Properties.cbPrefix, Properties.cBuffers);
- OutputDebugStringW(Buffer);
-#endif
-
- if (pAllocator)
- {
- pAllocator->AddRef();
- }
-
- if (m_MemAllocator)
- {
- m_MemAllocator->Release();
- }
-
- m_MemAllocator = pAllocator;
- m_ReadOnly = bReadOnly;
- return NOERROR;
-}
-
-HRESULT
-STDMETHODCALLTYPE
-CInputPin::GetAllocatorRequirements(ALLOCATOR_PROPERTIES *pProps)
-{
- KSALLOCATOR_FRAMING Framing;
- KSPROPERTY Property;
- HRESULT hr;
- ULONG BytesReturned;
-
- Property.Set = KSPROPSETID_Connection;
- Property.Id = KSPROPERTY_CONNECTION_ALLOCATORFRAMING;
- Property.Flags = KSPROPERTY_TYPE_SET;
-
- hr = KsProperty(&Property, sizeof(KSPROPERTY), (PVOID)&Framing, sizeof(KSALLOCATOR_FRAMING), &BytesReturned);
- if (SUCCEEDED(hr))
- {
- pProps->cBuffers = Framing.Frames;
- pProps->cbBuffer = Framing.FrameSize;
- pProps->cbAlign = Framing.FileAlignment;
- pProps->cbPrefix = 0;
- }
- else
- hr = E_NOTIMPL;
-
-#ifdef KSPROXY_TRACE
- WCHAR Buffer[100];
- swprintf(Buffer, L"CInputPin::GetAllocatorRequirements hr %lx m_hPin %p cBuffers %u cbBuffer %u cbAlign %u cbPrefix %u\n", hr, m_hPin, pProps->cBuffers, pProps->cbBuffer, pProps->cbAlign, pProps->cbPrefix);
- OutputDebugStringW(Buffer);
-#endif
-
- return hr;
-}
-
-HRESULT
-STDMETHODCALLTYPE
-CInputPin::Receive(IMediaSample *pSample)
-{
-#ifdef KSPROXY_TRACE
- OutputDebugStringW(L"CInputPin::Receive NotImplemented\n");
-#endif
-
- return E_NOTIMPL;
-}
-
-HRESULT
-STDMETHODCALLTYPE
-CInputPin::ReceiveMultiple(IMediaSample **pSamples, long nSamples, long *nSamplesProcessed)
-{
-#ifdef KSPROXY_TRACE
- OutputDebugStringW(L"CInputPin::ReceiveMultiple NotImplemented\n");
-#endif
-
- return E_NOTIMPL;
-}
-
-HRESULT
-STDMETHODCALLTYPE
-CInputPin::ReceiveCanBlock( void)
-{
-#ifdef KSPROXY_TRACE
- OutputDebugStringW(L"CInputPin::ReceiveCanBlock NotImplemented\n");
-#endif
-
- return S_FALSE;
-}
-
-//-------------------------------------------------------------------
-// IKsPin
-//
-
-HRESULT
-STDMETHODCALLTYPE
-CInputPin::KsQueryMediums(
- PKSMULTIPLE_ITEM* MediumList)
-{
- HRESULT hr;
- IKsObject * KsObjectParent;
- HANDLE hFilter;
-
- hr = m_ParentFilter->QueryInterface(IID_IKsObject, (LPVOID*)&KsObjectParent);
- if (FAILED(hr))
- return hr;
-
- hFilter = KsObjectParent->KsGetObjectHandle();
-
- KsObjectParent->Release();
-
- if (!hFilter)
- return E_HANDLE;
-
- return KsGetMultiplePinFactoryItems(hFilter, m_PinId, KSPROPERTY_PIN_MEDIUMS, (PVOID*)MediumList);
-}
-
-HRESULT
-STDMETHODCALLTYPE
-CInputPin::KsQueryInterfaces(
- PKSMULTIPLE_ITEM* InterfaceList)
-{
- HRESULT hr;
- IKsObject * KsObjectParent;
- HANDLE hFilter;
-
- hr = m_ParentFilter->QueryInterface(IID_IKsObject, (LPVOID*)&KsObjectParent);
- if (FAILED(hr))
- return hr;
-
- hFilter = KsObjectParent->KsGetObjectHandle();
-
- KsObjectParent->Release();
-
- if (!hFilter)
- return E_HANDLE;
-
- return KsGetMultiplePinFactoryItems(hFilter, m_PinId, KSPROPERTY_PIN_INTERFACES, (PVOID*)InterfaceList);
-}
-
-HRESULT
-STDMETHODCALLTYPE
-CInputPin::KsCreateSinkPinHandle(
- KSPIN_INTERFACE& Interface,
- KSPIN_MEDIUM& Medium)
-{
- return CreatePin(&m_MediaFormat);
-}
-
-HRESULT
-STDMETHODCALLTYPE
-CInputPin::KsGetCurrentCommunication(
- KSPIN_COMMUNICATION *Communication,
- KSPIN_INTERFACE *Interface,
- KSPIN_MEDIUM *Medium)
-{
- if (Communication)
- {
- *Communication = m_Communication;
- }
-
- if (Interface)
- {
- if (!m_hPin)
- return VFW_E_NOT_CONNECTED;
-
- CopyMemory(Interface, &m_Interface, sizeof(KSPIN_INTERFACE));
- }
-
- if (Medium)
- {
- if (!m_hPin)
- return VFW_E_NOT_CONNECTED;
-
- CopyMemory(Medium, &m_Medium, sizeof(KSPIN_MEDIUM));
- }
- return NOERROR;
-}
-
-HRESULT
-STDMETHODCALLTYPE
-CInputPin::KsPropagateAcquire()
-{
- KSPROPERTY Property;
- KSSTATE State;
- ULONG BytesReturned;
- HRESULT hr;
-
- assert(m_hPin != INVALID_HANDLE_VALUE);
-
- Property.Set = KSPROPSETID_Connection;
- Property.Id = KSPROPERTY_CONNECTION_STATE;
- Property.Flags = KSPROPERTY_TYPE_SET;
-
- State = KSSTATE_ACQUIRE;
-
- hr = KsProperty(&Property, sizeof(KSPROPERTY), (LPVOID)&State, sizeof(KSSTATE), &BytesReturned);
-
- //TODO
- //propagate to connected pin on the pipe
-
- return hr;
-}
-
-HRESULT
-STDMETHODCALLTYPE
-CInputPin::KsDeliver(
- IMediaSample* Sample,
- ULONG Flags)
-{
- return E_FAIL;
-}
-
-HRESULT
-STDMETHODCALLTYPE
-CInputPin::KsMediaSamplesCompleted(PKSSTREAM_SEGMENT StreamSegment)
-{
- return NOERROR;
-}
-
-IMemAllocator *
-STDMETHODCALLTYPE
-CInputPin::KsPeekAllocator(KSPEEKOPERATION Operation)
-{
- if (Operation == KsPeekOperation_AddRef)
- {
- // add reference on allocator
- m_MemAllocator->AddRef();
- }
-
- return m_MemAllocator;
-}
-
-HRESULT
-STDMETHODCALLTYPE
-CInputPin::KsReceiveAllocator(IMemAllocator *MemAllocator)
-{
-
- if (MemAllocator)
- {
- MemAllocator->AddRef();
- }
-
- if (m_MemAllocator)
- {
- m_MemAllocator->Release();
- }
-
- m_MemAllocator = MemAllocator;
- return NOERROR;
-}
-
-HRESULT
-STDMETHODCALLTYPE
-CInputPin::KsRenegotiateAllocator()
-{
- return E_FAIL;
-}
-
-LONG
-STDMETHODCALLTYPE
-CInputPin::KsIncrementPendingIoCount()
-{
- return InterlockedIncrement((volatile LONG*)&m_IoCount);
-}
-
-LONG
-STDMETHODCALLTYPE
-CInputPin::KsDecrementPendingIoCount()
-{
- return InterlockedDecrement((volatile LONG*)&m_IoCount);
-}
-
-HRESULT
-STDMETHODCALLTYPE
-CInputPin::KsQualityNotify(
- ULONG Proportion,
- REFERENCE_TIME TimeDelta)
-{
-#ifdef KSPROXY_TRACE
- OutputDebugStringW(L"CInputPin::KsQualityNotify NotImplemented\n");
-#endif
-
- return E_NOTIMPL;
-}
-
-//-------------------------------------------------------------------
-// IKsPinEx
-//
-
-VOID
-STDMETHODCALLTYPE
-CInputPin::KsNotifyError(
- IMediaSample* Sample,
- HRESULT hr)
-{
-#ifdef KSPROXY_TRACE
- OutputDebugStringW(L"CInputPin::KsNotifyError NotImplemented\n");
-#endif
-}
-
-
-//-------------------------------------------------------------------
-// IKsControl
-//
-HRESULT
-STDMETHODCALLTYPE
-CInputPin::KsProperty(
- PKSPROPERTY Property,
- ULONG PropertyLength,
- LPVOID PropertyData,
- ULONG DataLength,
- ULONG* BytesReturned)
-{
- assert(m_hPin != INVALID_HANDLE_VALUE);
- return KsSynchronousDeviceControl(m_hPin, IOCTL_KS_PROPERTY, (PVOID)Property, PropertyLength, (PVOID)PropertyData, DataLength, BytesReturned);
-}
-
-HRESULT
-STDMETHODCALLTYPE
-CInputPin::KsMethod(
- PKSMETHOD Method,
- ULONG MethodLength,
- LPVOID MethodData,
- ULONG DataLength,
- ULONG* BytesReturned)
-{
- assert(m_hPin != INVALID_HANDLE_VALUE);
- return KsSynchronousDeviceControl(m_hPin, IOCTL_KS_METHOD, (PVOID)Method, MethodLength, (PVOID)MethodData, DataLength, BytesReturned);
-}
-
-HRESULT
-STDMETHODCALLTYPE
-CInputPin::KsEvent(
- PKSEVENT Event,
- ULONG EventLength,
- LPVOID EventData,
- ULONG DataLength,
- ULONG* BytesReturned)
-{
- assert(m_hPin != INVALID_HANDLE_VALUE);
-
- if (EventLength)
- return KsSynchronousDeviceControl(m_hPin, IOCTL_KS_ENABLE_EVENT, (PVOID)Event, EventLength, (PVOID)EventData, DataLength, BytesReturned);
- else
- return KsSynchronousDeviceControl(m_hPin, IOCTL_KS_DISABLE_EVENT, (PVOID)Event, EventLength, NULL, 0, BytesReturned);
-}
-
-
-//-------------------------------------------------------------------
-// IKsPropertySet
-//
-HRESULT
-STDMETHODCALLTYPE
-CInputPin::Set(
- REFGUID guidPropSet,
- DWORD dwPropID,
- LPVOID pInstanceData,
- DWORD cbInstanceData,
- LPVOID pPropData,
- DWORD cbPropData)
-{
- ULONG BytesReturned;
-
- if (cbInstanceData)
- {
- PKSPROPERTY Property = (PKSPROPERTY)CoTaskMemAlloc(sizeof(KSPROPERTY) + cbInstanceData);
- if (!Property)
- return E_OUTOFMEMORY;
-
- Property->Set = guidPropSet;
- Property->Id = dwPropID;
- Property->Flags = KSPROPERTY_TYPE_SET;
-
- CopyMemory((Property+1), pInstanceData, cbInstanceData);
-
- HRESULT hr = KsProperty(Property, sizeof(KSPROPERTY) + cbInstanceData, pPropData, cbPropData, &BytesReturned);
- CoTaskMemFree(Property);
- return hr;
- }
- else
- {
- KSPROPERTY Property;
-
- Property.Set = guidPropSet;
- Property.Id = dwPropID;
- Property.Flags = KSPROPERTY_TYPE_SET;
-
- HRESULT hr = KsProperty(&Property, sizeof(KSPROPERTY), pPropData, cbPropData, &BytesReturned);
- return hr;
- }
-}
-
-HRESULT
-STDMETHODCALLTYPE
-CInputPin::Get(
- REFGUID guidPropSet,
- DWORD dwPropID,
- LPVOID pInstanceData,
- DWORD cbInstanceData,
- LPVOID pPropData,
- DWORD cbPropData,
- DWORD *pcbReturned)
-{
- ULONG BytesReturned;
-
- if (cbInstanceData)
- {
- PKSPROPERTY Property = (PKSPROPERTY)CoTaskMemAlloc(sizeof(KSPROPERTY) + cbInstanceData);
- if (!Property)
- return E_OUTOFMEMORY;
-
- Property->Set = guidPropSet;
- Property->Id = dwPropID;
- Property->Flags = KSPROPERTY_TYPE_GET;
-
- CopyMemory((Property+1), pInstanceData, cbInstanceData);
-
- HRESULT hr = KsProperty(Property, sizeof(KSPROPERTY) + cbInstanceData, pPropData, cbPropData, &BytesReturned);
- CoTaskMemFree(Property);
- return hr;
- }
- else
- {
- KSPROPERTY Property;
-
- Property.Set = guidPropSet;
- Property.Id = dwPropID;
- Property.Flags = KSPROPERTY_TYPE_GET;
-
- HRESULT hr = KsProperty(&Property, sizeof(KSPROPERTY), pPropData, cbPropData, &BytesReturned);
- return hr;
- }
-}
-
-HRESULT
-STDMETHODCALLTYPE
-CInputPin::QuerySupported(
- REFGUID guidPropSet,
- DWORD dwPropID,
- DWORD *pTypeSupport)
-{
- KSPROPERTY Property;
- ULONG BytesReturned;
-
- Property.Set = guidPropSet;
- Property.Id = dwPropID;
- Property.Flags = KSPROPERTY_TYPE_SETSUPPORT;
-
- return KsProperty(&Property, sizeof(KSPROPERTY), pTypeSupport, sizeof(DWORD), &BytesReturned);
-}
-
-
-//-------------------------------------------------------------------
-// IKsObject
-//
-HANDLE
-STDMETHODCALLTYPE
-CInputPin::KsGetObjectHandle()
-{
- assert(m_hPin);
- return m_hPin;
-}
-
-//-------------------------------------------------------------------
-// IPin interface
-//
-HRESULT
-STDMETHODCALLTYPE
-CInputPin::Connect(IPin *pReceivePin, const AM_MEDIA_TYPE *pmt)
-{
-#ifdef KSPROXY_TRACE
- OutputDebugStringW(L"CInputPin::Connect NotImplemented\n");
-#endif
- return NOERROR;
-}
-
-HRESULT
-STDMETHODCALLTYPE
-CInputPin::ReceiveConnection(IPin *pConnector, const AM_MEDIA_TYPE *pmt)
-{
- HRESULT hr;
-
- if (m_Pin)
- {
- // already connected
- return VFW_E_ALREADY_CONNECTED;
- }
-
- // first check format
- hr = CheckFormat(pmt);
- if (FAILED(hr))
- {
- // format is not supported
- return hr;
- }
-
- hr = CreatePin(pmt);
- if (FAILED(hr))
- {
- return hr;
- }
-
- m_Pin = pConnector;
- m_Pin->AddRef();
-
- return S_OK;
-}
-HRESULT
-STDMETHODCALLTYPE
-CInputPin::Disconnect( void)
-{
- if (!m_Pin)
- {
- // pin was not connected
- return S_FALSE;
- }
-
- //FIXME
- //check if filter is active
-
- m_Pin->Release();
- m_Pin = NULL;
-
-#ifdef KSPROXY_TRACE
- OutputDebugStringW(L"CInputPin::Disconnect\n");
-#endif
-
- return S_OK;
-}
-HRESULT
-STDMETHODCALLTYPE
-CInputPin::ConnectedTo(IPin **pPin)
-{
- if (!pPin)
- return E_POINTER;
-
- if (m_Pin)
- {
- // increment reference count
- m_Pin->AddRef();
- *pPin = m_Pin;
- return S_OK;
- }
-
- *pPin = NULL;
- return VFW_E_NOT_CONNECTED;
-}
-HRESULT
-STDMETHODCALLTYPE
-CInputPin::ConnectionMediaType(AM_MEDIA_TYPE *pmt)
-{
- if (!m_Pin)
- return VFW_E_NOT_CONNECTED;
-
-#ifdef KSPROXY_TRACE
- OutputDebugStringW(L"CInputPin::ConnectionMediaType NotImplemented\n");
-#endif
-
- return E_NOTIMPL;
-}
-HRESULT
-STDMETHODCALLTYPE
-CInputPin::QueryPinInfo(PIN_INFO *pInfo)
-{
- wcscpy(pInfo->achName, m_PinName);
- pInfo->dir = PINDIR_INPUT;
- pInfo->pFilter = m_ParentFilter;
- m_ParentFilter->AddRef();
-
- return S_OK;
-}
-HRESULT
-STDMETHODCALLTYPE
-CInputPin::QueryDirection(PIN_DIRECTION *pPinDir)
-{
- if (pPinDir)
- {
- *pPinDir = PINDIR_INPUT;
- return S_OK;
- }
-
- return E_POINTER;
-}
-HRESULT
-STDMETHODCALLTYPE
-CInputPin::QueryId(LPWSTR *Id)
-{
- *Id = (LPWSTR)CoTaskMemAlloc((wcslen(m_PinName)+1)*sizeof(WCHAR));
- if (!*Id)
- return E_OUTOFMEMORY;
-
- wcscpy(*Id, m_PinName);
- return S_OK;
-}
-
-HRESULT
-STDMETHODCALLTYPE
-CInputPin::QueryAccept(
- const AM_MEDIA_TYPE *pmt)
-{
- return CheckFormat(pmt);
-}
-HRESULT
-STDMETHODCALLTYPE
-CInputPin::EnumMediaTypes(IEnumMediaTypes **ppEnum)
-{
- HRESULT hr;
- ULONG MediaTypeCount = 0, Index;
- AM_MEDIA_TYPE * MediaTypes;
- IKsObject * KsObjectParent;
- HANDLE hFilter;
-
- hr = m_ParentFilter->QueryInterface(IID_IKsObject, (LPVOID*)&KsObjectParent);
- if (FAILED(hr))
- return hr;
-
- hFilter = KsObjectParent->KsGetObjectHandle();
-
- KsObjectParent->Release();
-
- if (!hFilter)
- return E_HANDLE;
-
-
- // query media type count
- hr = KsGetMediaTypeCount(hFilter, m_PinId, &MediaTypeCount);
- if (FAILED(hr) || !MediaTypeCount)
- return hr;
-
- // allocate media types
- MediaTypes = (AM_MEDIA_TYPE*)CoTaskMemAlloc(sizeof(AM_MEDIA_TYPE) * MediaTypeCount);
- if (!MediaTypes)
- {
- // not enough memory
- return E_OUTOFMEMORY;
- }
-
- // zero media types
- ZeroMemory(MediaTypes, sizeof(AM_MEDIA_TYPE) * MediaTypeCount);
-
- for(Index = 0; Index < MediaTypeCount; Index++)
- {
- // get media type
- hr = KsGetMediaType(Index, &MediaTypes[Index], hFilter, m_PinId);
- if (FAILED(hr))
- {
- // failed
- CoTaskMemFree(MediaTypes);
- return hr;
- }
- }
-
- return CEnumMediaTypes_fnConstructor(MediaTypeCount, MediaTypes, IID_IEnumMediaTypes, (void**)ppEnum);
-}
-
-HRESULT
-STDMETHODCALLTYPE
-CInputPin::QueryInternalConnections(IPin **apPin, ULONG *nPin)
-{
-#ifdef KSPROXY_TRACE
- OutputDebugStringW(L"CInputPin::QueryInternalConnections NotImplemented\n");
-#endif
- return E_NOTIMPL;
-}
-HRESULT
-STDMETHODCALLTYPE
-CInputPin::EndOfStream( void)
-{
-#ifdef KSPROXY_TRACE
- OutputDebugStringW(L"CInputPin::EndOfStream NotImplemented\n");
-#endif
- return E_NOTIMPL;
-}
-HRESULT
-STDMETHODCALLTYPE
-CInputPin::BeginFlush( void)
-{
-#ifdef KSPROXY_TRACE
- OutputDebugStringW(L"CInputPin::BeginFlush NotImplemented\n");
-#endif
- return E_NOTIMPL;
-}
-HRESULT
-STDMETHODCALLTYPE
-CInputPin::EndFlush( void)
-{
-#ifdef KSPROXY_TRACE
- OutputDebugStringW(L"CInputPin::EndFlush NotImplemented\n");
-#endif
- return E_NOTIMPL;
-}
-HRESULT
-STDMETHODCALLTYPE
-CInputPin::NewSegment(REFERENCE_TIME tStart, REFERENCE_TIME tStop, double dRate)
-{
-#ifdef KSPROXY_TRACE
- OutputDebugStringW(L"CInputPin::NewSegment NotImplemented\n");
-#endif
- return E_NOTIMPL;
-}
-
-
-//-------------------------------------------------------------------
-HRESULT
-STDMETHODCALLTYPE
-CInputPin::CheckFormat(
- const AM_MEDIA_TYPE *pmt)
-{
- PKSMULTIPLE_ITEM MultipleItem;
- PKSDATAFORMAT DataFormat;
- HRESULT hr;
- IKsObject * KsObjectParent;
- HANDLE hFilter;
-
- if (!pmt)
- return E_POINTER;
-
- hr = m_ParentFilter->QueryInterface(IID_IKsObject, (LPVOID*)&KsObjectParent);
- if (FAILED(hr))
- return hr;
-
- hFilter = KsObjectParent->KsGetObjectHandle();
-
- KsObjectParent->Release();
-
- if (!hFilter)
- return E_HANDLE;
-
-
- hr = KsGetMultiplePinFactoryItems(hFilter, m_PinId, KSPROPERTY_PIN_DATARANGES, (PVOID*)&MultipleItem);
- if (FAILED(hr))
- return S_FALSE;
-
- DataFormat = (PKSDATAFORMAT)(MultipleItem + 1);
- for(ULONG Index = 0; Index < MultipleItem->Count; Index++)
- {
- if (IsEqualGUID(pmt->majortype, DataFormat->MajorFormat) &&
- IsEqualGUID(pmt->subtype, DataFormat->SubFormat) &&
- IsEqualGUID(pmt->formattype, DataFormat->Specifier))
- {
- // format is supported
- CoTaskMemFree(MultipleItem);
-#ifdef KSPROXY_TRACE
- OutputDebugStringW(L"CInputPin::CheckFormat format OK\n");
-#endif
- return S_OK;
- }
- DataFormat = (PKSDATAFORMAT)((ULONG_PTR)DataFormat + DataFormat->FormatSize);
- }
- //format is not supported
- CoTaskMemFree(MultipleItem);
- return S_FALSE;
-}
-
-HRESULT
-STDMETHODCALLTYPE
-CInputPin::CreatePin(
- const AM_MEDIA_TYPE *pmt)
-{
- PKSMULTIPLE_ITEM MediumList;
- PKSMULTIPLE_ITEM InterfaceList;
- PKSPIN_MEDIUM Medium;
- PKSPIN_INTERFACE Interface;
- IKsInterfaceHandler * InterfaceHandler;
- HRESULT hr;
-
- // query for pin medium
- hr = KsQueryMediums(&MediumList);
- if (FAILED(hr))
- return hr;
-
- // query for pin interface
- hr = KsQueryInterfaces(&InterfaceList);
- if (FAILED(hr))
- {
- // failed
- CoTaskMemFree(MediumList);
- return hr;
- }
-
- if (MediumList->Count)
- {
- //use first available medium
- Medium = (PKSPIN_MEDIUM)(MediumList + 1);
- }
- else
- {
- // default to standard medium
- Medium = &StandardPinMedium;
- }
-
- if (InterfaceList->Count)
- {
- //use first available interface
- Interface = (PKSPIN_INTERFACE)(InterfaceList + 1);
- }
- else
- {
- // default to standard interface
- Interface = &StandardPinInterface;
- }
-
- if (m_Communication != KSPIN_COMMUNICATION_BRIDGE && m_Communication != KSPIN_COMMUNICATION_NONE)
- {
- if (!m_InterfaceHandler)
- {
- // now load the IKsInterfaceHandler plugin
- hr = CoCreateInstance(Interface->Set, NULL, CLSCTX_INPROC_SERVER, IID_IKsInterfaceHandler, (void**)&InterfaceHandler);
- if (FAILED(hr))
- {
- // failed to load interface handler plugin
-#ifdef KSPROXY_TRACE
- OutputDebugStringW(L"CInputPin::CreatePin failed to load InterfaceHandlerPlugin\n");
-#endif
- CoTaskMemFree(MediumList);
- CoTaskMemFree(InterfaceList);
-
- return hr;
- }
-
- // now set the pin
- hr = InterfaceHandler->KsSetPin((IKsPin*)this);
- if (FAILED(hr))
- {
- // failed to load interface handler plugin
-#ifdef KSPROXY_TRACE
- OutputDebugStringW(L"CInputPin::CreatePin failed to initialize InterfaceHandlerPlugin\n");
-#endif
- InterfaceHandler->Release();
- CoTaskMemFree(MediumList);
- CoTaskMemFree(InterfaceList);
- return hr;
- }
-
- // store interface handler
- m_InterfaceHandler = InterfaceHandler;
- }
-
- // now create pin
- hr = CreatePinHandle(Medium, Interface, pmt);
- if (FAILED(hr))
- {
- m_InterfaceHandler->Release();
- m_InterfaceHandler = InterfaceHandler;
- }
- }
- else
- {
-#ifdef KSPROXY_TRACE
- WCHAR Buffer[100];
- swprintf(Buffer, L"CInputPin::CreatePin unexpected communication %u %s\n", m_Communication, m_PinName);
- OutputDebugStringW(Buffer);
-#endif
- hr = E_FAIL;
- }
-
- // free medium / interface / dataformat
- CoTaskMemFree(MediumList);
- CoTaskMemFree(InterfaceList);
-
- return hr;
-}
-
-HRESULT
-STDMETHODCALLTYPE
-CInputPin::CreatePinHandle(
- PKSPIN_MEDIUM Medium,
- PKSPIN_INTERFACE Interface,
- const AM_MEDIA_TYPE *pmt)
-{
- PKSPIN_CONNECT PinConnect;
- PKSDATAFORMAT DataFormat;
- ULONG Length;
- HRESULT hr;
- IKsObject * KsObjectParent;
- HANDLE hFilter;
-
- if (!pmt)
- return E_POINTER;
-
- hr = m_ParentFilter->QueryInterface(IID_IKsObject, (LPVOID*)&KsObjectParent);
- if (FAILED(hr))
- return hr;
-
- hFilter = KsObjectParent->KsGetObjectHandle();
-
- KsObjectParent->Release();
-
- if (!hFilter)
- return E_HANDLE;
-
-
- if (m_hPin != INVALID_HANDLE_VALUE)
- {
- // pin already exists
- //CloseHandle(m_hPin);
- //m_hPin = INVALID_HANDLE_VALUE;
- return S_OK;
- }
-
-
- // calc format size
- Length = sizeof(KSPIN_CONNECT) + sizeof(KSDATAFORMAT) + pmt->cbFormat;
-
- // allocate pin connect
- PinConnect = (PKSPIN_CONNECT)CoTaskMemAlloc(Length);
- if (!PinConnect)
- {
- // failed
- return E_OUTOFMEMORY;
- }
-
- // setup request
- CopyMemory(&PinConnect->Interface, Interface, sizeof(KSPIN_INTERFACE));
- CopyMemory(&PinConnect->Medium, Medium, sizeof(KSPIN_MEDIUM));
- PinConnect->PinId = m_PinId;
- PinConnect->PinToHandle = NULL;
- PinConnect->Priority.PriorityClass = KSPRIORITY_NORMAL;
- PinConnect->Priority.PrioritySubClass = KSPRIORITY_NORMAL;
-
- // get dataformat offset
- DataFormat = (PKSDATAFORMAT)(PinConnect + 1);
-
- // copy data format
- DataFormat->FormatSize = sizeof(KSDATAFORMAT) + pmt->cbFormat;
- DataFormat->Flags = 0;
- DataFormat->SampleSize = pmt->lSampleSize;
- DataFormat->Reserved = 0;
- CopyMemory(&DataFormat->MajorFormat, &pmt->majortype, sizeof(GUID));
- CopyMemory(&DataFormat->SubFormat, &pmt->subtype, sizeof(GUID));
- CopyMemory(&DataFormat->Specifier, &pmt->formattype, sizeof(GUID));
-
- if (pmt->cbFormat)
- {
- // copy extended format
- CopyMemory((DataFormat + 1), pmt->pbFormat, pmt->cbFormat);
- }
-
- // create pin
- hr = KsCreatePin(hFilter, PinConnect, GENERIC_WRITE, &m_hPin);
-
- if (SUCCEEDED(hr))
- {
- // store current interface / medium
- CopyMemory(&m_Medium, Medium, sizeof(KSPIN_MEDIUM));
- CopyMemory(&m_Interface, Interface, sizeof(KSPIN_INTERFACE));
- CopyMemory(&m_MediaFormat, pmt, sizeof(AM_MEDIA_TYPE));
-
-#ifdef KSPROXY_TRACE
- LPOLESTR pMajor, pSub, pFormat;
- StringFromIID(m_MediaFormat.majortype, &pMajor);
- StringFromIID(m_MediaFormat.subtype , &pSub);
- StringFromIID(m_MediaFormat.formattype, &pFormat);
-
- WCHAR Buffer[200];
- swprintf(Buffer, L"CInputPin::CreatePinHandle Major %s SubType %s Format %s pbFormat %p cbFormat %u\n", pMajor, pSub, pFormat, pmt->pbFormat, pmt->cbFormat);
- CoTaskMemFree(pMajor);
- CoTaskMemFree(pSub);
- CoTaskMemFree(pFormat);
- OutputDebugStringW(Buffer);
-#endif
-
- if (pmt->cbFormat)
- {
- m_MediaFormat.pbFormat = (BYTE*)CoTaskMemAlloc(pmt->cbFormat);
- if (!m_MediaFormat.pbFormat)
- {
- CoTaskMemFree(PinConnect);
- m_MediaFormat.pbFormat = NULL;
- m_MediaFormat.cbFormat = 0;
- return E_OUTOFMEMORY;
- }
- CopyMemory(m_MediaFormat.pbFormat, pmt->pbFormat, pmt->cbFormat);
- }
-
- LPGUID pGuid;
- ULONG NumGuids = 0;
-
- // get all supported sets
- hr = GetSupportedSets(&pGuid, &NumGuids);
- if (FAILED(hr))
- {
-#ifdef KSPROXY_TRACE
- OutputDebugStringW(L"CInputPin::CreatePinHandle GetSupportedSets failed\n");
-#endif
- return hr;
- }
-
- // load all proxy plugins
- hr = LoadProxyPlugins(pGuid, NumGuids);
- if (FAILED(hr))
- {
-#ifdef KSPROXY_TRACE
- OutputDebugStringW(L"CInputPin::CreatePinHandle LoadProxyPlugins failed\n");
-#endif
- return hr;
- }
-
- // free sets
- CoTaskMemFree(pGuid);
-
-
- //TODO
- // connect pin pipes
-
- }
-
- // free pin connect
- CoTaskMemFree(PinConnect);
-
- return hr;
-}
-
-HRESULT
-STDMETHODCALLTYPE
-CInputPin::GetSupportedSets(
- LPGUID * pOutGuid,
- PULONG NumGuids)
-{
- KSPROPERTY Property;
- LPGUID pGuid;
- ULONG NumProperty = 0;
- ULONG NumMethods = 0;
- ULONG NumEvents = 0;
- ULONG Length;
- ULONG BytesReturned;
- HRESULT hr;
-
- Property.Set = GUID_NULL;
- Property.Id = 0;
- Property.Flags = KSPROPERTY_TYPE_SETSUPPORT;
-
- KsSynchronousDeviceControl(m_hPin, IOCTL_KS_PROPERTY, (PVOID)&Property, sizeof(KSPROPERTY), NULL, 0, &NumProperty);
- KsSynchronousDeviceControl(m_hPin, IOCTL_KS_METHOD, (PVOID)&Property, sizeof(KSPROPERTY), NULL, 0, &NumMethods);
- KsSynchronousDeviceControl(m_hPin, IOCTL_KS_ENABLE_EVENT, (PVOID)&Property, sizeof(KSPROPERTY), NULL, 0, &NumEvents);
-
- Length = NumProperty + NumMethods + NumEvents;
-
- assert(Length);
-
- // allocate guid buffer
- pGuid = (LPGUID)CoTaskMemAlloc(Length);
- if (!pGuid)
- {
- // failed
- return E_OUTOFMEMORY;
- }
-
- NumProperty /= sizeof(GUID);
- NumMethods /= sizeof(GUID);
- NumEvents /= sizeof(GUID);
-
-#ifdef KSPROXY_TRACE
- WCHAR Buffer[200];
- swprintf(Buffer, L"CInputPin::GetSupportedSets NumProperty %lu NumMethods %lu NumEvents %lu\n", NumProperty, NumMethods, NumEvents);
- OutputDebugStringW(Buffer);
-#endif
-
- // get all properties
- hr = KsSynchronousDeviceControl(m_hPin, IOCTL_KS_PROPERTY, (PVOID)&Property, sizeof(KSPROPERTY), (PVOID)pGuid, Length, &BytesReturned);
- if (FAILED(hr))
- {
- CoTaskMemFree(pGuid);
- return E_FAIL;
- }
- Length -= BytesReturned;
-
- // get all methods
- if (Length && NumMethods)
- {
- hr = KsSynchronousDeviceControl(m_hPin, IOCTL_KS_METHOD, (PVOID)&Property, sizeof(KSPROPERTY), (PVOID)&pGuid[NumProperty], Length, &BytesReturned);
- if (FAILED(hr))
- {
- CoTaskMemFree(pGuid);
- return E_FAIL;
- }
- Length -= BytesReturned;
- }
-
- // get all events
- if (Length && NumEvents)
- {
- hr = KsSynchronousDeviceControl(m_hPin, IOCTL_KS_ENABLE_EVENT, (PVOID)&Property, sizeof(KSPROPERTY), (PVOID)&pGuid[NumProperty+NumMethods], Length, &BytesReturned);
- if (FAILED(hr))
- {
- CoTaskMemFree(pGuid);
- return E_FAIL;
- }
- Length -= BytesReturned;
- }
-
- *pOutGuid = pGuid;
- *NumGuids = NumProperty+NumEvents+NumMethods;
- return S_OK;
-}
-
-HRESULT
-STDMETHODCALLTYPE
-CInputPin::LoadProxyPlugins(
- LPGUID pGuids,
- ULONG NumGuids)
-{
- ULONG Index;
- LPOLESTR pStr;
- HKEY hKey, hSubKey;
- HRESULT hr;
- IUnknown * pUnknown;
-
- if (RegOpenKeyExW(HKEY_LOCAL_MACHINE, L"SYSTEM\\CurrentControlSet\\Control\\MediaInterfaces", 0, KEY_READ, &hKey) != ERROR_SUCCESS)
- {
- OutputDebugStringW(L"CInputPin::LoadProxyPlugins failed to open MediaInterfaces key\n");
- return E_FAIL;
- }
-
- // enumerate all sets
- for(Index = 0; Index < NumGuids; Index++)
- {
- // convert to string
- hr = StringFromCLSID(pGuids[Index], &pStr);
- if (FAILED(hr))
- return E_FAIL;
-
- // now try open class key
- if (RegOpenKeyExW(hKey, pStr, 0, KEY_READ, &hSubKey) != ERROR_SUCCESS)
- {
- // no plugin for that set exists
- CoTaskMemFree(pStr);
- continue;
- }
-
- // try load plugin
- hr = CoCreateInstance(pGuids[Index], (IBaseFilter*)this, CLSCTX_INPROC_SERVER, IID_IUnknown, (void**)&pUnknown);
- if (SUCCEEDED(hr))
- {
- // store plugin
- m_Plugins.push_back(pUnknown);
- }
- // close key
- RegCloseKey(hSubKey);
- }
-
- // close media interfaces key
- RegCloseKey(hKey);
- return S_OK;
-}
-
-HRESULT
-WINAPI
-CInputPin_Constructor(
- IBaseFilter * ParentFilter,
- LPCWSTR PinName,
- HANDLE hFilter,
- ULONG PinId,
- KSPIN_COMMUNICATION Communication,
- REFIID riid,
- LPVOID * ppv)
-{
- CInputPin * handler = new CInputPin(ParentFilter, PinName, PinId, Communication);
-
- if (!handler)
- return E_OUTOFMEMORY;
-
- if (FAILED(handler->QueryInterface(riid, ppv)))
- {
- /* not supported */
- delete handler;
- return E_NOINTERFACE;
- }
-
- return S_OK;
-}
projects / reactos.git / blobdiff