pin.h

Go to the documentation of this file.

 
#pragma once
 
#include "named_graph_object.h"
#include "triggerpipe.h"
#include "pin_intf.h"
#include "inpin_intf.h"
#include "outpin_intf.h"
 
#include <adtfucom3/adtf_ucom3.h>
#include <adtfbase/runnable_intf.h>
 
#include <memory>
 
namespace adtf
{
namespace streaming
{
namespace ant
{
 
class cInPin :
    public ucom::catwo::object<IPin, named_graph_object<trigger_pipe_item<IInPin>>>
{
    A_UTILS_D(cInPin)
 
    public:
        cInPin();
        cInPin(const char* strName);
        virtual ~cInPin();
 
    public: //implements IPin
        tResult GetType(ucom::ant::iobject_ptr<const IStreamType>& pStreamType) const override;
 
        bool   IsConnected() const override;
        tResult SetActive() override;
        tResult SetInactive() override;
 
        tResult Disconnect() override;
        tResult GetSampleStream(ucom::ant::iobject_ptr<ISampleStream>& pSampleStream) const override;
    public: //implements IInPin
        tResult Connect(const ucom::ant::iobject_ptr<ISampleStream>& pSampleStream) override;
 
    public:
        tResult RegisterStreamer(ISampleReader& pStreamReader);
 
        tResult UnregisterStreamer(ISampleStreamer& pStreamReader);
 
 
 
};
 
class cOutPin :
    public ucom::catwo::object<IPin, named_graph_object<trigger_pipe_item<IOutPin>>>
{
    A_UTILS_D(cOutPin)
 
    public:
        cOutPin();
        cOutPin(const char* strName);
        virtual ~cOutPin();        
 
    public: //implements IPin
        tResult GetType(ucom::ant::iobject_ptr<const IStreamType>& pStreamType) const override;
 
        bool   IsConnected() const override;
        tResult SetActive() override;
        tResult SetInactive() override;
 
        tResult Disconnect();
        tResult GetSampleStream(ucom::ant::iobject_ptr<ISampleStream>& pSampleStream) const override;
 
    public: //implements IOutPin
        tResult Connect(const ucom::ant::iobject_ptr<ISampleStream>& pSampleStream) override;
 
    public:
        tResult RegisterStreamer(ISampleWriter& pStreamWriter);
        tResult UnregisterStreamer(ISampleStreamer& pStreamWriter);
 
};
 
class cConfigurableInPin:
    public ucom::catwo::object<cInPin, adtf::base::configuration<>>
{
    public:
        cConfigurableInPin() = default;
        cConfigurableInPin(const char* strName);
};
 
class cConfigurableOutPin:
    public ucom::catwo::object<cOutPin, adtf::base::configuration<>>
{
    public:
        cConfigurableOutPin() = default;
        cConfigurableOutPin(const char* strName);
};
 
 
 
} //namespace ant
 
namespace flash
{
 
class cInPin: public ucom::catwo::object<base::ant::IRunnable,
                                         ant::ITriggerPipeSource,
                                         ant::ITriggerPipeItem,
                                         ant::INamedGraphObject,
                                         ant::IPin,
                                         ant::IInPin,
                                         base::flash::IRunnable,
                                         flash::IStreamerPin>
{
    public:
        cInPin();
        cInPin(const char* strName);
        ~cInPin();
 
       ADTF_FLASH_TRIGGER_PIPE_ITEM_METHOD_DECLARATIONS
 
    public:
        tResult GetType(ucom::ant::iobject_ptr<const ant::IStreamType>& pStreamType) const override;
        bool   IsConnected() const override;
        tResult SetActive() override;
        tResult SetInactive() override;
        tResult Connect(const ucom::ant::iobject_ptr<ant::ISampleStream>& pSampleStream) override;
        tResult Disconnect() override;
        tResult GetSampleStream(ucom::ant::iobject_ptr<ant::ISampleStream>& pSampleStream) const override;
 
        tResult RegisterStreamer(flash::ISampleStreamer& oStreamer) override;
        tResult UnregisterStreamer(flash::ISampleStreamer& oStreamer) override;
 
    protected:
        class cImplementation;
        std::unique_ptr<cImplementation> m_pImplementation;
};
 
class cOutPin: public ucom::catwo::object<base::ant::IRunnable,
                                          ant::ITriggerPipeSource,
                                          ant::ITriggerPipeItem,
                                          ant::INamedGraphObject,
                                          ant::IPin,
                                          ant::IOutPin,
                                          base::flash::IRunnable,
                                          flash::IStreamerPin>
{
    public:
        cOutPin();
        cOutPin(const char* strName);
        ~cOutPin();
 
        ADTF_FLASH_TRIGGER_PIPE_ITEM_METHOD_DECLARATIONS
 
    public:
        tResult GetType(ucom::ant::iobject_ptr<const ant::IStreamType>& pStreamType) const override;
        bool   IsConnected() const override;
        tResult SetActive() override;
        tResult SetInactive() override;
        tResult Connect(const ucom::ant::iobject_ptr<ant::ISampleStream>& pSampleStream) override;
        tResult Disconnect() override;
        tResult GetSampleStream(ucom::ant::iobject_ptr<ant::ISampleStream>& pSampleStream) const override;
 
        tResult RegisterStreamer(flash::ISampleStreamer& oStreamer) override;
        tResult UnregisterStreamer(flash::ISampleStreamer& oStreamer) override;
 
    protected:
        class cImplementation;
        std::unique_ptr<cImplementation> m_pImplementation;
};
 
class cConfigurableInPin:
    public ucom::catwo::object<cInPin, adtf::base::configuration<>>
{
    public:
        cConfigurableInPin();
        cConfigurableInPin(const char* strName);
};
 
class cConfigurableOutPin:
    public ucom::catwo::object<cOutPin, adtf::base::configuration<>>
{
    public:
        cConfigurableOutPin();
        cConfigurableOutPin(const char* strName);
};
 
}
 
namespace quiet
{
 
class cInPin: public ucom::catwo::object<flash::cInPin,
                                         ITriggerPipeHierachy>
{
    public:
        cInPin();
        cInPin(const char* strName);
        ~cInPin();
 
        ADTF_QUIET_TRIGGER_PIPE_ITEM_METHOD_DECLARATIONS
};
 
class cOutPin: public ucom::catwo::object<flash::cOutPin,
                                          ITriggerPipeHierachy>
{
    public:
        cOutPin();
        cOutPin(const char* strName);
        ~cOutPin();
        ADTF_QUIET_TRIGGER_PIPE_ITEM_METHOD_DECLARATIONS
};
 
class cConfigurableInPin:
    public ucom::catwo::object<cInPin, adtf::base::configuration<>>
{
    public:
        cConfigurableInPin();
        cConfigurableInPin(const char* strName);
};
 
class cConfigurableOutPin:
    public ucom::catwo::object<cOutPin, adtf::base::configuration<>>
{
    public:
        cConfigurableOutPin();
        cConfigurableOutPin(const char* strName);
};
 
}
 
using quiet::cInPin;
using quiet::cOutPin;
using quiet::cConfigurableInPin;
using quiet::cConfigurableOutPin;
 
} //namespace streaming
} //namespace adtf