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 trigger_pipe_item<INamedGraphObject, IPin, 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 trigger_pipe_item<INamedGraphObject, IPin, 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 trigger_pipe_item<ant::INamedGraphObject, ant::IPin, flash::IStreamerPin, ant::IInPin>
{
public:
    cInPin();
    cInPin(const char* strName);
    ~cInPin();
 
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 trigger_pipe_item<ant::INamedGraphObject, ant::IPin, flash::IStreamerPin, ant::IOutPin>
{
public:
    cOutPin();
    cOutPin(const char* strName);
    ~cOutPin();
 
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 flash
 
namespace quiet
{
 
using flash::cInPin;
using flash::cOutPin;
using flash::cConfigurableInPin;
using flash::cConfigurableOutPin;
 
} // namespace quiet
 
using quiet::cInPin;
using quiet::cOutPin;
using quiet::cConfigurableInPin;
using quiet::cConfigurableOutPin;
 
} // namespace streaming
} // namespace adtf