filtergraph.h

Go to the documentation of this file.

#pragma once
#include "filter_intf.h"
#include "runtime_behaviour.h"
#include "interface_binding.h"
#include "data_binding.h"
#include "named_graph_object.h"
#include "filtergraph_intf.h"
#include "graph.h"
 
namespace adtf
{
namespace streaming
{

class cFilterGraph :
    public ucom::catwo::object<
        IFilter,
        ant::IFilterGraph,
        graph<runtime_behaviour<interface_binding<ant::data_binding<named_graph_object<zebra::IFilterGraph>>>>>,
        base::ant::IConfiguration>
{
private:
    A_UTILS_D(cFilterGraph)
 
private:
    tFilterGraphState m_eState = tFilterGraphState::State_Constructed;
    bool m_bIsSubGraph = false;
 
public:
    cFilterGraph();
    ~cFilterGraph() override;
 
public: // implements IFilterGraph
    tResult SetState(tFilterGraphState eFilterState) override;
    tFilterGraphState GetState() const override;

    tResult AddConnection(const char* strName,
                          const char* strSourceName,
                          const char* strSourceConnector,
                          const char* strDestinationName,
                          const char* strDestinationConnector,
                          int32_t ui32OrderNumber,
                          bool bSync);
 
public:
    tResult AddNamedGraphObject(const ucom::ant::iobject_ptr<INamedGraphObject>& pItem,
                                int32_t ui32OrderNumber) override;
    using cGraph::RemoveNamedGraphObject;
    tResult RemoveNamedGraphObject(const ucom::ant::iobject_ptr<INamedGraphObject>& pItem) override;
 
    tResult SetParent(const ucom::ant::IObject* oParentObject) override;

    void SetConnectionCreationState(IFilterGraph::tFilterGraphState eState);

    void SetLegacyConnectionOrder(bool bLegacyOrder);

    void SetLegacyShutdownOrder(bool bLegacyOrder);

    void SetPostConnectionCallback(std::function<tResult()> fnCallback);

    tResult GetProperties(ucom::ant::iobject_ptr<const base::ant::IProperties>& pProperties) const override;
    tResult GetProperties(ucom::ant::iobject_ptr<base::ant::IProperties>& pProperties) override;
    tResult AttachConfiguration(const char* strName, base::ant::IConfiguration& oAttachedConfiguration) override;
    tResult DetachConfiguration(const char* strName) override;

    tResult
        AddPropertyLink(const char* strSourcePropertyName, const char* strTargetObject, const char* strTargetProperty);

    void DisableObjectInitializationUponAdd();
 
    tResult RegisterScopedMacroResolver(
        const ucom::ant::iobject_ptr<services::ant::IMacroResolver>& pScopedMacroResolver) noexcept;
    tResult GetScopedMacroResolver(
        ucom::ant::iobject_ptr<services::ant::IMacroResolver>& pScopedMacroResolver) const noexcept override;
 
protected:
    virtual tResult SetGraphObjectState(INamedGraphObject* pObject, IFilterGraph::tFilterGraphState eState) const;
 
private:
    tResult SetStateImpl(tFilterGraphState eOldState, tFilterGraphState eNewState, tFilterGraphState& eErrorNextState);
    void DestructAllObjects();
    void DestructObject(const ucom::ant::iobject_ptr<INamedGraphObject>& pObject);
};

tResult add_piped_connections(IFilterGraph& oGraph, adtf_util::cStringList lstObjectNames, bool bSync = true);

tResult add_paired_connections(IFilterGraph& oGraph, adtf_util::cStringList lstObjectNames, bool bSync = true);

tResult get_filter_graph_object(const IFilterGraph& oGraph, ucom::ant::iobject_ptr<ucom::ant::IObject>& pObject);

tResult get_filter_graph_objects(const IFilterGraph& oGraph, ucom::ant::iobject_enum<ucom::ant::IObject>& lstObjects);
 
} // namespace streaming
} // namespace adtf