pin_creation.h

Go to the documentation of this file.

#pragma once
#include "pin.h"
#include "samplewriter.h"
#include "samplereader.h"
 
#include <type_traits>
 
namespace adtf
{
namespace streaming
{
namespace ant
{

template<typename DATA_BINDING_IMPL_TYPE>
tResult create_pin(DATA_BINDING_IMPL_TYPE& oDataBindingImpl,
    cSampleWriter& oWriter,
    const char* strNameOfWriterAndPin,
    const ucom::iobject_ptr<const IStreamType>& pStreamType,
    ucom::iobject_ptr<IOutPin>& pPinCreated)
{
    oWriter.SetName(strNameOfWriterAndPin);
    oWriter.SetType(pStreamType);
 
    adtf::ucom::object_ptr<cOutPin> pOutPin = adtf::ucom::make_object_ptr<cOutPin>(strNameOfWriterAndPin);
    oWriter.ResetPin(pOutPin);
    adtf::ucom::object_ptr<IPin> pPin = pOutPin;
    RETURN_IF_FAILED(oDataBindingImpl.RegisterPin(pPin));
    pPinCreated.Reset(adtf::ucom::ucom_object_ptr_cast<IOutPin>(pPin));
    RETURN_NOERROR;
}

template<typename DATA_BINDING_IMPL_TYPE>
tResult create_pin(DATA_BINDING_IMPL_TYPE& oDataBindingImpl,
    cSampleWriter& oWriter,
    const char* strNameOfWriterAndPin,
    const adtf::ucom::iobject_ptr<const IStreamType>& pStreamType)
{
    adtf::ucom::object_ptr<IOutPin> pPinCreated;
    return create_pin(oDataBindingImpl, oWriter, strNameOfWriterAndPin, pStreamType, pPinCreated);
}

template<typename DATA_BINDING_IMPL_TYPE>
tResult create_pin(DATA_BINDING_IMPL_TYPE& oDataBindingImpl,
    cSampleWriter& oWriter,
    const char* strNameOfWriterAndPin,
    const adtf::ucom::iobject_ptr<IStreamType>& pStreamType)
{
    return create_pin(oDataBindingImpl, oWriter, strNameOfWriterAndPin, adtf::ucom::ucom_object_ptr_cast<const IStreamType>(pStreamType));
}

template<typename DATA_BINDING_IMPL_TYPE>
tResult create_pin(DATA_BINDING_IMPL_TYPE& oDataBindingImpl,
    cSampleReader& oReader,
    const char* strNameOfReaderAndPin,
    const ucom::iobject_ptr<const IStreamType>& pStreamType,
    ucom::iobject_ptr<IInPin>& pPinCreated)
{
    oReader.SetName(strNameOfReaderAndPin);
    oReader.SetType(pStreamType);
 
    adtf::ucom::object_ptr<cInPin> pInPin = adtf::ucom::make_object_ptr<cInPin>(strNameOfReaderAndPin);
    oReader.ResetPin(pInPin);
    adtf::ucom::object_ptr<IPin> pPin = pInPin;
    RETURN_IF_FAILED(oDataBindingImpl.RegisterPin(pPin));
    pPinCreated.Reset(adtf::ucom::ucom_object_ptr_cast<IInPin>(pPin));
    RETURN_NOERROR;
}

template<typename DATA_BINDING_IMPL_TYPE>
tResult create_pin(DATA_BINDING_IMPL_TYPE& oDataBindingImpl,
    cSampleReader& oReader,
    const char* strNameOfReaderAndPin,
    const ucom::iobject_ptr<const IStreamType>& pStreamType)
{
    adtf::ucom::object_ptr<IInPin> pPinCreated;
    return create_pin(oDataBindingImpl, oReader, strNameOfReaderAndPin, pStreamType, pPinCreated);
}
 

template<typename DATA_BINDING_IMPL_TYPE>
tResult create_pin(DATA_BINDING_IMPL_TYPE& oDataBindingImpl,
    cSampleReader& oReader,
    const char* strNameOfReaderAndPin,
    const adtf::ucom::iobject_ptr<IStreamType>& pStreamType)
{
    return create_pin(oDataBindingImpl, oReader, strNameOfReaderAndPin, adtf::ucom::ucom_object_ptr_cast<const IStreamType>(pStreamType));
}
} //namespace ant
 
namespace flash
{
 
template<typename DATA_BINDING_IMPL_TYPE, typename READER_OR_WRITER, typename PIN_INTERFACE>
tResult create_pin(DATA_BINDING_IMPL_TYPE& oDataBindingImpl,
                   READER_OR_WRITER& oStreamer,
                   ucom::ant::iobject_ptr<PIN_INTERFACE>& pCreatedPin)
{
    typedef typename std::conditional<std::is_base_of<flash::ISampleReader, READER_OR_WRITER>::value, quiet::cInPin, quiet::cOutPin>::type pin_type;
    adtf::util::cString strNameOfReaderAndPin;
    oStreamer.GetName(adtf_string_intf(strNameOfReaderAndPin));
 
    auto pInPin = adtf::ucom::make_object_ptr<pin_type>(strNameOfReaderAndPin);
    oStreamer.SetStreamerPin(ucom::ant::ucom_object_ptr_cast<flash::IStreamerPin>(pInPin));
    adtf::ucom::object_ptr<IPin> pPin = pInPin;
    RETURN_IF_FAILED(oDataBindingImpl.RegisterPin(pPin));
    return pCreatedPin.Reset(ucom::ant::ucom_object_ptr_cast<PIN_INTERFACE>(pPin));
}
 
template<typename DATA_BINDING_IMPL_TYPE, typename READER_OR_WRITER>
tResult create_pin(DATA_BINDING_IMPL_TYPE& oDataBindingImpl,
                   READER_OR_WRITER& oStreamer)
{
    typedef typename std::conditional<std::is_base_of<flash::ISampleReader, READER_OR_WRITER>::value, quiet::cInPin, quiet::cOutPin>::type pin_type;
    adtf::util::cString strNameOfReaderAndPin;
    oStreamer.GetName(adtf_string_intf(strNameOfReaderAndPin));
 
    auto pInPin = adtf::ucom::make_object_ptr<pin_type>(strNameOfReaderAndPin);
    oStreamer.SetStreamerPin(ucom::ant::ucom_object_ptr_cast<flash::IStreamerPin>(pInPin));
    adtf::ucom::object_ptr<IPin> pPin = pInPin;
    return oDataBindingImpl.RegisterPin(pPin);
}
 
template<typename DATA_BINDING_IMPL_TYPE, typename READER_OR_WRITER, typename PIN_INTERFACE>
tResult create_pin(DATA_BINDING_IMPL_TYPE& oDataBindingImpl,
                   READER_OR_WRITER& oStreamer,
                   const char* strNameOfReaderAndPin,
                   const ucom::iobject_ptr<const ant::IStreamType>& pStreamType,
                   ucom::ant::iobject_ptr<PIN_INTERFACE>& pCreatedPin)
{
    oStreamer.SetName(strNameOfReaderAndPin);
    oStreamer.SetType(pStreamType);
 
    return create_pin(oDataBindingImpl, oStreamer, pCreatedPin);
}
 
template<typename DATA_BINDING_IMPL_TYPE, typename READER_OR_WRITER>
tResult create_pin(DATA_BINDING_IMPL_TYPE& oDataBindingImpl,
                   READER_OR_WRITER& oStreamer,
                   const char* strNameOfReaderAndPin,
                   const ucom::ant::iobject_ptr<const ant::IStreamType>& pStreamType)
{
    oStreamer.SetName(strNameOfReaderAndPin);
    oStreamer.SetType(pStreamType);
 
    return create_pin(oDataBindingImpl, oStreamer);
}
 
}
 
using flash::create_pin;
 
} //namespace streaming
} //namespace adtf