connect_pins.h

Go to the documentation of this file.

#pragma once
#include <adtfstreaming3/streammetatypeanonymous.h>
#include <adtfstreaming3/samplewriter.h>
#include <adtfstreaming3/samplereader.h>
#include <adtfstreaming3/data_binding_intf.h>
 
namespace adtf
{
namespace streaming
{
namespace testing
{
namespace ant
{
    tResult connect_pin(const adtf::ucom::ant::iobject_ptr<IOutPin>& pOutPin,
                        adtf::ucom::ant::iobject_ptr<ISampleStream>& pSampleStream,
                        bool bSync);
    tResult connect_pin(const adtf::ucom::ant::iobject_ptr<IOutPin>& pOutPin,
                        const adtf::ucom::ant::iobject_ptr<ISampleStream>& pSampleStream,
                        bool bSync);
 
    tResult connect_pin(const adtf::ucom::ant::iobject_ptr<IInPin>& pInPin,
                        adtf::ucom::ant::iobject_ptr<ISampleStream>& pSampleStream,
                        bool bSync);    
    tResult connect_pin(const adtf::ucom::ant::iobject_ptr<IInPin>& pInPin,
                        const adtf::ucom::ant::iobject_ptr<ISampleStream>& pSampleStream,
                        bool bSync);
 
    tResult connect_pins(const adtf::ucom::ant::iobject_ptr<IOutPin>& pOutPin,
                         const adtf::ucom::ant::iobject_ptr<IInPin>& pInPin,
                         bool bSync);
    tResult connect_pins(const adtf::ucom::ant::iobject_ptr<IOutPin>& pOutPin,
                         const adtf::ucom::ant::iobject_ptr<IInPin>& pInPin,
                         adtf::ucom::ant::iobject_ptr<ISampleStream>& pSampleStream,
                         bool bSync);
    tResult connect_pins(const adtf::ucom::ant::iobject_ptr<ISampleStream>& pForcedSampleStream,
                         const adtf::ucom::ant::iobject_ptr<IOutPin>& pOutPin,
                         const adtf::ucom::ant::iobject_ptr<IInPin>& pInPin,
                         bool bSync);
 
 
 
    class cSampleWriterTester : public streaming::ant::cSampleWriter
    {
    protected:
        adtf::ucom::object_ptr<adtf::streaming::ant::ISampleStream>       m_pSampleStream;
        adtf::ucom::object_ptr<adtf::streaming::ant::IInPin>              m_pInPin;
 
    public:
        cSampleWriterTester() = default;
        virtual ~cSampleWriterTester();
 
        tResult ConnectToPin(adtf::streaming::ant::IDataBinding& oDataBinding, const char* strPinName, bool bSync);
        tResult Disconnect();
 
        tResult Write(tTimeStamp tmTime, const void* pData, size_t szData);
        tResult RunTrigger(tTimeStamp tmTime);
 
        tResult GetSampleStream(adtf::ucom::object_ptr<adtf::streaming::ant::ISampleStream>& pSampleStream);
 
        tResult PrintTriggerPipe();
 
        tResult GetStreamError();
    };
 
    class cPinOutputTester: private streaming::ant::cDynamicSampleReader
    {
        public:
            std::vector<adtf::ucom::object_ptr<const adtf::streaming::ant::ISample>> m_oSamples;
            std::vector<adtf::ucom::object_ptr<const adtf::streaming::ant::IStreamType>> m_oTypes;
            std::vector<tTimeStamp> m_oTriggers;
 
        private:
            adtf::ucom::object_ptr<adtf::streaming::ant::ISampleStream> m_pSampleStream;
 
        public:
            ~cPinOutputTester();
            tResult Connect(adtf::streaming::ant::IDataBinding& oDataBinding, const char* strPinName);
            tResult Connect(const adtf::ucom::ant::iobject_ptr<adtf::streaming::ant::IOutPin>& pPin);
            tResult Push(const adtf::streaming::ant::IStreamItem& oItem, tTimeStamp tsTime) override;
 
    };
    
} //namespace ant
 
namespace flash
{
 
class cSampleWriterTester: public ant::cSampleWriterTester
{
    public:
        using ant::cSampleWriterTester::Write;
        using ant::cSampleWriterTester::RunTrigger;
 
        tResult Write(base::flash::tNanoSeconds tmTime, const void* pData, size_t szData);
        tResult RunTrigger(base::flash::tNanoSeconds tmTime);
};
 
}
 
namespace penguin
{

tResult connect_pins(const adtf::ucom::ant::iobject_ptr<adtf::ucom::ant::IObject>& pSource,
                     const char* strOutputPin,
                     const adtf::ucom::ant::iobject_ptr<adtf::ucom::ant::IObject>& pDestination,
                     const char* strInputPin,
                     bool bSync = true);

class cDisconnector
{
    public:
        cDisconnector(const adtf::ucom::ant::iobject_ptr<adtf::ucom::ant::IObject>& pObject,
                      const char* strPinName);

        cDisconnector(const adtf::ucom::ant::iobject_ptr<adtf::streaming::ant::IPin>& pPin);

        cDisconnector(const adtf::ucom::ant::iobject_ptr<adtf::streaming::ant::IInPin>& pPin);

        cDisconnector(const adtf::ucom::ant::iobject_ptr<adtf::streaming::ant::IOutPin>& pPin);
 
        cDisconnector(cDisconnector&&) = default;
        cDisconnector& operator=(cDisconnector&&) = default;

        ~cDisconnector();
 
    private:
        adtf::ucom::weak_object_ptr<adtf::streaming::IPin> m_pPin;
};
 
}
 
using ant::connect_pin;
using ant::connect_pins;
using penguin::connect_pins;
using flash::cSampleWriterTester;
using ant::cPinOutputTester;
using penguin::cDisconnector;
 
} //namespace testing
} //namespace streaming
} //namespace adtf