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
{

class cRunner : public trigger_pipe_item<INamedGraphObject, IRunner>
{
public:
    cRunner();

    ~cRunner() override;

    cRunner(const char* strName);

    cRunner(const char* strName, base::ant::IRunnable& oRunnable);

    explicit cRunner(const char* strName, base::flash::IRunnable& oRunnable);

    template<typename CALLABLE>
    cRunner(const char* strName, CALLABLE&& oCallable): cRunner(strName)
    {
        SetCallable(std::forward<CALLABLE>(oCallable));
    }

    void SetRunnable(base::ant::IRunnable& oRunnable);

    void SetRunnable(base::flash::IRunnable& oRunnable);

    void SetRunnable(base::ant::IRunnable::tRunFunction fcRunFunction);

    void SetRunnable(base::flash::IRunnable::tRunFunction fcRunFunction);

    template<typename CALLABLE>
    void SetCallable(CALLABLE&& oCallable)
    {
        trigger_pipe_item::SetCallable(std::forward<CALLABLE>(oCallable));
    }
};

class cActiveRunner :
    public trigger_pipe_source<INamedGraphObject,
                               ucom::ant::cClassInfo,
                               base::ant::configuration<>,
                               ant::IActiveRunner,
                               spider::IActiveRunner>
{
public:
    cActiveRunner();

    ~cActiveRunner() override;

    tResult SetName(const char* strName) override;
    tResult SetParent(const ucom::ant::IObject* pParentObject) override;

    tResult WaitForDeactivation() override
    {
        RETURN_NOERROR;
    }
 
protected:
    void Trigger(base::flash::tNanoSeconds tmTimeOfTrigger);

    void Trigger();
 
private:
    void CreateErrorHandler();
 
private:
    ucom::object_ptr<services::IReferenceClock> m_pClock;
    base::cErrorChecker m_oErrorChecker;
};
 
} // namespace streaming
} // namespace adtf