streaming_graph.h

Go to the documentation of this file.

 
#pragma once
#include "named_graph_object.h"
#include "graph.h"
#include "filtergraph_intf.h"
#include "streaming_graph_intf.h"
#include "streaming_source_intf.h"
 
#include <optional>
 
 
namespace adtf
{
namespace streaming
{
namespace ant
{
 
class cStreamingGraph : public named_graph_object<graph<IStreamingGraph>>
{
 
    private:
        ucom::ant::object_ptr<IFilterGraph> m_pFilterGraph;
        IStreamingGraph::tStreamingState m_eStreamingState = IStreamingGraph::tStreamingState::State_Constructed;
 
        tResult SetStateImpl(tStreamingState eFromState,
                             tStreamingState eToState,
                             tStreamingState& eErrorState,
                             std::optional<IFilterGraph::tFilterGraphState> eFilterGraphSubState) const;
 
    public:
        virtual ~cStreamingGraph();
 
        tResult AddNamedGraphObject(const ucom::ant::iobject_ptr<INamedGraphObject>& pItem,
                                    int32_t ui32OrderNumber) override;
        using   cGraph::RemoveNamedGraphObject;
        tResult RemoveNamedGraphObject(const ucom::ant::iobject_ptr<INamedGraphObject>& pGraphObject) override;
 
        tResult AddStreamIn(const char* strName,
                            const char* strSampleStreamSource,
                            const char* strSampleStreamPin,
                            const char* strAlias);
        tResult AddStreamOut(const char* strName,
                             const char* strSampleStreamSink,
                             const char* strSampleStreamPin,
                             const char* strAlias);
 
        tResult AddStreamInterfaceIn(const char* strName,
                            const char* strSampleStreamSource,
                            const char* strSampleStreamPin,
                            const char* strBindingProxy);
        tResult AddStreamInterfaceOut(const char* strName,
                            const char* strBindingProxy,
                            const char* strSampleStreamSink,
                            const char* strSampleStreamPin);
 
        tResult AddConnection(const char* strName,
                              const char* strSourceName,
                              const char* strSourceConnector,
                              const char* strDestinationName,
                              const char* strDestinationConnector,
                              int32_t ui32OrderNumber,
                              bool bSync);
 
    public:
        tResult SetState(tStreamingState eState) override;
        tStreamingState GetState() override;
 
    public:
        tResult SetFiltergraphSubState(IFilterGraph::tFilterGraphState eFilterGraphState);
 
    private:
        
        tResult RegisterFilterGraph(IFilterGraph& oFiltergraph);
        tResult UnregisterFilterGraph(IFilterGraph* oFiltergraph);
 
        template<typename T>
        tResult AddStreamPort(const adtf_util::cString& strPrefix,
                              const ucom::object_ptr<T>& pPort,
                              uint8_t eCat);
 
 
        template<typename T>
        tResult AddStreamInterfacePort(const adtf_util::cString& strPrefix,
            const ucom::object_ptr<T>& pPort,
            uint8_t eCat);
        
        tResult RegisterFiltergraphStreamPorts(const adtf_util::cString& strPrefix,
                                               IFilterGraph& oFiltergraph);
 
        void DestructAllObjects();
        void DestructObject(ucom::ant::object_ptr<IStreamingService> pService);
 
        tResult Init() const;
        tResult Shutdown(std::optional<IFilterGraph::tFilterGraphState> eFilterGraphSubState) const;
        tResult StartStreaming() const;
        tResult StopStreaming() const;
        
};
 
tResult get_streaming_graph_object(const IStreamingGraph& oGraph, ucom::ant::iobject_ptr<ucom::ant::IObject>& pObject);
 
tResult get_streaming_graph_objects(const IStreamingGraph& oGraph, ucom::ant::iobject_enum<ucom::ant::IObject>& lstObjects);
 
}
 
using ant::cStreamingGraph;
using ant::get_streaming_graph_object;
using ant::get_streaming_graph_objects;
}
 
}