configurable_streamers.h

Go to the documentation of this file.

#pragma once
#include <adtfstreaming3/samplereader.h>
 
namespace adtf::filter
{
 
namespace wolverine
{

 
namespace detail
{
template<typename BaseStreamer>
class configurable_streamer : public BaseStreamer, public base::ant::IConfiguration
{
public:
    tResult SetStreamerPin(const ucom::ant::iobject_ptr<streaming::flash::IStreamerPin>& pStreamerPin) override
    {
        RETURN_IF_FAILED(BaseStreamer::SetStreamerPin(pStreamerPin));
        m_pPinConfiguration = ucom::ucom_cast<base::ant::IConfiguration*>(pStreamerPin.Get());
        RETURN_NOERROR;
    }
    tResult GetProperties(ucom::ant::iobject_ptr<const base::ant::IProperties>& pProperties) const override
    {
        RETURN_IF_FAILED(CheckState());
        m_pPinConfiguration->GetProperties(pProperties);
        RETURN_NOERROR;
    }
    tResult GetProperties(ucom::ant::iobject_ptr<base::ant::IProperties>& pProperties) override
    {
        RETURN_IF_FAILED(CheckState());
        m_pPinConfiguration->GetProperties(pProperties);
        RETURN_NOERROR;
    }
 
#if defined(_MSC_VER)
    #pragma warning(push)
    #pragma warning(disable : 4996)
#elif defined(__GNUC__)
    #pragma GCC diagnostic push
    #pragma GCC diagnostic ignored "-Wdeprecated-declarations"
#endif
 
    tResult AttachConfiguration(const char* strName, base::ant::IConfiguration& oAttachedConfiguration) override
    {
        RETURN_IF_FAILED(CheckState());
 
        m_pPinConfiguration->AttachConfiguration(strName, oAttachedConfiguration);
        RETURN_NOERROR;
    }
    tResult DetachConfiguration(const char* strName) override
    {
        RETURN_IF_FAILED(CheckState());
        m_pPinConfiguration->DetachConfiguration(strName);
        RETURN_NOERROR;
    }
 
#if defined(_MSC_VER)
    #pragma warning(pop)
#elif defined(__GNUC__)
    #pragma GCC diagnostic pop
#endif
 
private:
    tResult CheckState() const
    {
        if (!m_pPinConfiguration)
        {
            RETURN_ERROR_DESC(ERR_INVALID_STATE, "Streamer is not connected to a pin with a configuration interface.");
        }
 
        RETURN_NOERROR;
    }
    base::ant::IConfiguration* m_pPinConfiguration;
};
 
}


template <typename BaseReader = streaming::flash::cDynamicSampleReader>
using configurable_reader = detail::configurable_streamer<BaseReader>;

template <typename BaseWriter = streaming::flash::cSampleWriter>
using configurable_writer = detail::configurable_streamer<BaseWriter>;
 
} // namespace wolverine
 
using wolverine::configurable_reader;
using wolverine::configurable_writer;
 
} // namespace adtf::filter