查找筛选器对等方

项目
03/13/2025

[与此页面关联的功能（DirectShow）是一项旧功能。它已被 MediaPlayer、IMFMediaEngine取代，并在媒体基金会音频/视频捕获。这些功能已针对 Windows 10 和 Windows 11 进行了优化。 Microsoft强烈建议新代码尽可能使用 MediaPlayer、IMFMediaEngine 和 Media Foundation 中的音频/视频捕获，而不是 DirectShow。 Microsoft建议重写使用旧 API 的现有代码，以尽可能使用新 API。]

给定筛选器后，可以通过查找它连接到的筛选器来遍历图形。首先枚举筛选器的引脚。对于每个引脚，请检查该引脚是否已连接到另一个引脚。如果是，请查询另一个引脚，以获取其拥有的筛选器。可以通过枚举筛选器的输入引脚或在下游方向枚举输出引脚，在上游方向遍历图形。

以下函数在上游或下游搜索连接的筛选器。它返回它找到的第一个匹配筛选器：

// Get the first upstream or downstream filter
HRESULT GetNextFilter(
    IBaseFilter *pFilter, // Pointer to the starting filter
    PIN_DIRECTION Dir,    // Direction to search (upstream or downstream)
    IBaseFilter **ppNext) // Receives a pointer to the next filter.
{
    if (!pFilter || !ppNext) return E_POINTER;

    IEnumPins *pEnum = 0;
    IPin *pPin = 0;
    HRESULT hr = pFilter->EnumPins(&pEnum);
    if (FAILED(hr)) return hr;
    while (S_OK == pEnum->Next(1, &pPin, 0))
    {
        // See if this pin matches the specified direction.
        PIN_DIRECTION ThisPinDir;
        hr = pPin->QueryDirection(&ThisPinDir);
        if (FAILED(hr))
        {
            // Something strange happened.
            hr = E_UNEXPECTED;
            pPin->Release();
            break;
        }
        if (ThisPinDir == Dir)
        {
            // Check if the pin is connected to another pin.
            IPin *pPinNext = 0;
            hr = pPin->ConnectedTo(&pPinNext);
            if (SUCCEEDED(hr))
            {
                // Get the filter that owns that pin.
                PIN_INFO PinInfo;
                hr = pPinNext->QueryPinInfo(&PinInfo);
                pPinNext->Release();
                pPin->Release();
                pEnum->Release();
                if (FAILED(hr) || (PinInfo.pFilter == NULL))
                {
                    // Something strange happened.
                    return E_UNEXPECTED;
                }
                // This is the filter we're looking for.
                *ppNext = PinInfo.pFilter; // Client must release.
                return S_OK;
            }
        }
        pPin->Release();
    }
    pEnum->Release();
    // Did not find a matching filter.
    return E_FAIL;
}

该函数调用 IBaseFilter：：EnumPins 来枚举第一个筛选器的引脚。对于每个引脚，它调用 IPin：：QueryDirection 来检查引脚是否与指定方向（输入或输出）匹配。如果是这样，该函数通过调用 IPin：：ConnectedTo 方法来确定该引脚是否已连接到另一个引脚。最后，它在连接的引脚上调用 IPin：：QueryPinInfo。此方法返回一个结构，其中包含指向该引脚拥有筛选器的指针，等等。此指针返回到 ppNext 参数中的调用方。调用方必须释放指针。

以下代码演示如何调用此函数：

IBaseFilter *pF; // Pointer to some filter.
IBaseFilter *pUpstream = NULL;
if (SUCCEEDED(GetNextFilter(pF, PINDIR_INPUT, &pUpstream)))
{
    // Use pUpstream ...
    pUpstream->Release();
}

筛选器可能以任一方向连接到两个或多个筛选器。例如，它可能是一个拆分器筛选器，其中下游有多个筛选器。或者，它可能是一个复用筛选器，其中包含多个从中上游的筛选器。因此，你可能想要将所有它们收集到列表中。

以下代码显示了实现此类函数的一种可能方法。它使用 DirectShow CGenericList 类;可以使用其他一些数据结构编写等效函数。

#include <streams.h>  // Link to the DirectShow base class library
// Define a typedef for a list of filters.
typedef CGenericList<IBaseFilter> CFilterList;

// Forward declaration. Adds a filter to the list unless it's a duplicate.
void AddFilterUnique(CFilterList &FilterList, IBaseFilter *pNew);

// Find all the immediate upstream or downstream peers of a filter.
HRESULT GetPeerFilters(
    IBaseFilter *pFilter, // Pointer to the starting filter
    PIN_DIRECTION Dir,    // Direction to search (upstream or downstream)
    CFilterList &FilterList)  // Collect the results in this list.
{
    if (!pFilter) return E_POINTER;

    IEnumPins *pEnum = 0;
    IPin *pPin = 0;
    HRESULT hr = pFilter->EnumPins(&pEnum);
    if (FAILED(hr)) return hr;
    while (S_OK == pEnum->Next(1, &pPin, 0))
    {
        // See if this pin matches the specified direction.
        PIN_DIRECTION ThisPinDir;
        hr = pPin->QueryDirection(&ThisPinDir);
        if (FAILED(hr))
        {
            // Something strange happened.
            hr = E_UNEXPECTED;
            pPin->Release();
            break;
        }
        if (ThisPinDir == Dir)
        {
            // Check if the pin is connected to another pin.
            IPin *pPinNext = 0;
            hr = pPin->ConnectedTo(&pPinNext);
            if (SUCCEEDED(hr))
            {
                // Get the filter that owns that pin.
                PIN_INFO PinInfo;
                hr = pPinNext->QueryPinInfo(&PinInfo);
                pPinNext->Release();
                if (FAILED(hr) || (PinInfo.pFilter == NULL))
                {
                    // Something strange happened.
                    pPin->Release();
                    pEnum->Release();
                    return E_UNEXPECTED;
                }
                // Insert the filter into the list.
                AddFilterUnique(FilterList, PinInfo.pFilter);
                PinInfo.pFilter->Release();
            }
        }
        pPin->Release();
    }
    pEnum->Release();
    return S_OK;
}
void AddFilterUnique(CFilterList &FilterList, IBaseFilter *pNew)
{
    if (pNew == NULL) return;

    POSITION pos = FilterList.GetHeadPosition();
    while (pos)
    {
        IBaseFilter *pF = FilterList.GetNext(pos);
        if (IsEqualObject(pF, pNew))
        {
            return;
        }
    }
    pNew->AddRef();  // The caller must release everything in the list.
    FilterList.AddTail(pNew);
}

为了使事情复杂化，筛选器可以有多个固定连接到同一个筛选器。为了避免将重复项放入列表中，请查询每个 IBaseFilter 指针以获取 IUnknown，并比较 IUnknown 指针。根据 COM 的规则，如果两个接口指针返回相同的 IUnknown 指针，则两个接口指针引用同一对象。在前面的示例中，AddFilterUnique 函数处理此详细信息。

以下示例演示如何使用 GetPeerFilters 函数：

IBaseFilter *pF; // Pointer to some filter.
CFilterList FList(NAME("MyList"));  // List to hold the downstream peers.
hr = GetPeerFilters(pF, PINDIR_OUTPUT, FList);
if (SUCCEEDED(hr))
{
    POSITION pos = FList.GetHeadPosition();
    while (pos)
    {
        IBaseFilter *pDownstream = FList.GetNext(pos);
        pDownstream->Release();
    }
}

常规 Graph-Building 技术

通过

查找筛选器对等方

反馈

其他资源

通过

查找筛选器对等方

相关主题

反馈

其他资源