Function FindPinIntefaceInGraph

common/DSUtilLite/DShowUtil.cpp:420–463

pPin - pin of our filter to start searching refiid - guid of the interface to find pUnknown - variable that'll receive the interface

// refiid - guid of the interface to find
// pUnknown - variable that'll receive the interface
HRESULT FindPinIntefaceInGraph(IPin *pPin, REFIID refiid, void **pUnknown)
{
    PIN_DIRECTION dir;
    pPin->QueryDirection(&dir);

    IPin *pOtherPin = nullptr;
    if (SUCCEEDED(pPin->ConnectedTo(&pOtherPin)) && pOtherPin)
    {
        IBaseFilter *pFilter = nullptr;
        HRESULT hrFilter = pOtherPin->QueryInterface(refiid, pUnknown);

        if (FAILED(hrFilter))
        {
            pFilter = GetFilterFromPin(pOtherPin);

            IEnumPins *pPinEnum = nullptr;
            pFilter->EnumPins(&pPinEnum);

            HRESULT hrPin = E_FAIL;
            for (IPin *pOtherPin2 = nullptr; pPinEnum->Next(1, &pOtherPin2, 0) == S_OK; pOtherPin2 = nullptr)
            {
                PIN_DIRECTION pinDir;
                pOtherPin2->QueryDirection(&pinDir);
                if (dir == pinDir)
                {
                    hrPin = FindPinIntefaceInGraph(pOtherPin2, refiid, pUnknown);
                }
                SafeRelease(&pOtherPin2);
                if (SUCCEEDED(hrPin))
                    break;
            }
            hrFilter = hrPin;
            SafeRelease(&pPinEnum);
        }
        SafeRelease(&pFilter);
        SafeRelease(&pOtherPin);

        if (SUCCEEDED(hrFilter))
        {
            return S_OK;
        }
    }
    return E_NOINTERFACE;
}

// pPin - pin of our filter to start searching
// guid - guid of the filter to find