request_forwarding.h

Go to the documentation of this file.

#pragma once
#include <adtfucom3/adtf_ucom3.h>
#include <adtfstreaming3/samplewriter.h>
#include <adtfstreaming3/samplereader.h>
 
namespace adtf
{
namespace streaming
{
namespace vision
{
class cRequestForwardingWriter : public adtf::streaming::flash::cSampleWriter
{
public:
    tResult SetSource(const adtf::ucom::iobject_ptr<adtf::streaming::IBindingProxy>& pSource);
 
    // ISampleStreamer implementation
    tResult BeginStreaming(adtf::streaming::ISampleStream& oSampleStream) override;
    tResult EndStreaming() override;
 
private:
    tResult AttachRouting();
    adtf::ucom::object_ptr<adtf::streaming::IBindingProxy> m_pDestinationProxy;
    adtf::ucom::weak_object_ptr<adtf::streaming::IBindingProxy> m_pSourceProxy;
};

template<typename BaseReader = adtf::streaming::flash::cDynamicSampleReader>
class request_forwarding_reader : public BaseReader
{
public:
    void AddWriter(cRequestForwardingWriter* pWriter)
    {
        m_oWriters.push_back(pWriter);
    }
 
    // ISampleStreamer implementation
    tResult BeginStreaming(adtf::streaming::ISampleStream& oSampleStream) override
    {
        if (auto pHollowStream = adtf::ucom::ucom_cast<IInternalBindingProxy*>(&oSampleStream))
        {
            adtf::ucom::object_ptr<IBindingProxy> pProxy;
            if (IS_OK(pHollowStream->GetInternalBindingProxy(pProxy)))
            {
                for (auto pWriter : m_oWriters)
                {
                    RETURN_IF_FAILED(pWriter->SetSource(pProxy));
                }
            }
        }
 
        return BaseReader::BeginStreaming(oSampleStream);
    }
 
private:
    std::vector<cRequestForwardingWriter*> m_oWriters;
};
 
} // namespace vision
 
using vision::cRequestForwardingWriter;
using vision::request_forwarding_reader;
 
} // namespace streaming
} // namespace adtf