streaming3/include/adtfstreaming3/runner.h

Go to the documentation of this file.

 
#pragma once
 
#include "triggerpipe.h"
#include "runner_intf.h"
#include "reference_clock_intf.h"
 
#include <adtfucom3/adtf_ucom3.h>
 
namespace adtf
{
namespace streaming
{
namespace ant
{   
    class cRunner: public named_graph_object<trigger_pipe_item<IRunner>>
    {
        private:
            typedef named_graph_object<trigger_pipe_item<IRunner>> base_type;
            std::shared_ptr<base::runnable<base::IRunnable::RUN_TRIGGER>> m_pInternalRunnable;
 
        public:
            cRunner() = default;
            cRunner(const char* strName)
            {
                SetName(strName);
            }
            cRunner(const char* strName, base::IRunnable& oRunnable): cRunner(strName)
            {
                SetRunnable(oRunnable);
            }
 
            cRunner(const char* strName, base::IRunnable::tRunFunction oRunFunc): cRunner(strName)
            {
                m_pInternalRunnable.reset(new base::runnable<base::IRunnable::RUN_TRIGGER>(oRunFunc));
                trigger_pipe_item::SetRunnable(*m_pInternalRunnable.get());
            }
            void SetRunnable(adtf::base::ant::IRunnable& oRunnable)
            {
                trigger_pipe_item::SetRunnable(oRunnable);
                if (m_pInternalRunnable)
                {
                    m_pInternalRunnable.reset();
                }
            }
 
            tResult SetName(const char* strName) override
            {
                RETURN_IF_FAILED(base_type::SetName(strName));
                return SetFullName(get_named_graph_object_full_name(*this));
            }
 
            tResult SetParent(const ucom::ant::IObject* oParentObject) override
            {
                RETURN_IF_FAILED(base_type::SetParent(oParentObject));
                return SetFullName(get_named_graph_object_full_name(*this));
            }
    };
 
} //namespace ant
 
namespace flash
{
 
class cRunner: public ucom::catwo::object<base::ant::IRunnable,
                                          ant::ITriggerPipeSource,
                                          ant::ITriggerPipeItem,
                                          ant::INamedGraphObject,
                                          ant::IRunner,
                                          base::flash::IRunnable>
{
    public:
        cRunner();
 
        ~cRunner() override;
 
        cRunner(const char* strName);
 
        cRunner(const char* strName, base::flash::IRunnable& oRunnable);
 
        cRunner(const char* strName, base::ant::IRunnable& oRunnable);
 
        cRunner(const char* strName, base::flash::IRunnable::tRunFunction oRunFunc);
 
        cRunner(const char* strName, base::ant::IRunnable::tRunFunction oRunFunc);
 
        void SetRunnable(base::flash::IRunnable& oRunnable);
        void SetRunnable(base::ant::IRunnable& oRunnable);
 
        void SetRunnable(base::flash::IRunnable::tRunFunction oRunFunc);
        void SetRunnable(base::ant::IRunnable::tRunFunction oRunFunc);
 
        ADTF_FLASH_TRIGGER_PIPE_ITEM_METHOD_DECLARATIONS
 
    protected:
        class cImplementation;
        std::unique_ptr<cImplementation> m_pImplementation;
};
 
}
 
namespace lucky
{
 
class cActiveRunner:
    public ucom::catwo::object<ucom::ant::cClassInfo,
                               ant::INamedGraphObject,
                               ant::ITriggerPipeSource,
                               ant::IActiveRunner,
                               base::ant::configuration<>>
{
    public:
        cActiveRunner();
 
        ~cActiveRunner() override;
 
 
        tResult GetName(base::ant::IString&& strName) const override;
        tResult SetName(const char* strName) override;
        tResult SetParent(const ucom::ant::IObject* pParentObject) override;
        tResult GetParent(const ucom::ant::IObject*& pParentObject) const override;
 
        tResult RegisterSubItem(const adtf::ucom::ant::iobject_ptr<ITriggerPipeItem>& pSubRun,
                                tPriority ui32Prio) override;
        tResult UnregisterSubItem(const adtf::ucom::ant::iobject_ptr<ITriggerPipeItem>& pSubRun) override;
        tResult ChangePriority(const adtf::ucom::ant::iobject_ptr<ITriggerPipeItem>& pSubRun,
                               tPriority ui32Prio) override;
        tResult GetSubItems(adtf::ucom::ant::iobject_enum<const ITriggerPipeItem>& lstSubItems) const override;
 
    protected:
        void Trigger(base::flash::tNanoSeconds tmTimeOfTrigger);
 
        void Trigger();
 
    protected:
        class cImplementation;
        std::unique_ptr<cImplementation> m_pImplementation;
};
 
}
 
namespace quiet
{
 
class cRunner: public ucom::catwo::object<flash::cRunner,
                                          ITriggerPipeHierachy>
{
    public:
        cRunner();
 
        ~cRunner() override;
 
        cRunner(const char* strName);
 
        cRunner(const char* strName, base::flash::IRunnable& oRunnable);
 
        cRunner(const char* strName, base::ant::IRunnable& oRunnable);
 
        cRunner(const char* strName, base::flash::IRunnable::tRunFunction oRunFunc);
 
        cRunner(const char* strName, base::ant::IRunnable::tRunFunction oRunFunc);
 
        ADTF_QUIET_TRIGGER_PIPE_ITEM_METHOD_DECLARATIONS
};
 
}
 
namespace spider
{
 
class cActiveRunner:
    public ucom::catwo::object<ucom::ant::cClassInfo,
                               ant::INamedGraphObject,
                               ant::ITriggerPipeSource,
                               ant::IActiveRunner,
                               spider::IActiveRunner,
                               base::ant::configuration<>>
{
    public:
        cActiveRunner();
 
        ~cActiveRunner() override;
 
 
        tResult GetName(base::ant::IString&& strName) const override;
        tResult SetName(const char* strName) override;
        tResult SetParent(const ucom::ant::IObject* pParentObject) override;
        tResult GetParent(const ucom::ant::IObject*& pParentObject) const override;
 
        tResult RegisterSubItem(const adtf::ucom::ant::iobject_ptr<ITriggerPipeItem>& pSubRun,
                                tPriority ui32Prio) override;
        tResult UnregisterSubItem(const adtf::ucom::ant::iobject_ptr<ITriggerPipeItem>& pSubRun) override;
        tResult ChangePriority(const adtf::ucom::ant::iobject_ptr<ITriggerPipeItem>& pSubRun,
                               tPriority ui32Prio) override;
        tResult GetSubItems(adtf::ucom::ant::iobject_enum<const ITriggerPipeItem>& lstSubItems) const override;
 
        tResult WaitForDeactivation() override
        {
            RETURN_NOERROR;
        }
 
    protected:
        void Trigger(base::flash::tNanoSeconds tmTimeOfTrigger);
 
        void Trigger();
 
    protected:
        class cImplementation;
        std::unique_ptr<cImplementation> m_pImplementation;
};
 
}
 
using quiet::cRunner;
using spider::cActiveRunner;
 
} //namespace streaming
} //namespace adtf