StreamWriter.hpp

/*
 * (c) Copyright, Real-Time Innovations, 2017.
 * All rights reserved.
 *
 * No duplications, whole or partial, manual or electronic, may be made
 * without express written permission.  Any such copies, or
 * revisions thereof, must display this notice unaltered.
 * This code contains trade secrets of Real-Time Innovations, Inc.
 */

#ifndef RTI_ROUTING_ADAPTER_STREAM_WRITER_HPP_
#define RTI_ROUTING_ADAPTER_STREAM_WRITER_HPP_

#include <vector>

#include <rti/routing/UpdatableEntity.hpp>
#include <rti/routing/detail/ForwarderUtils.hpp>

namespace rti { namespace routing { namespace adapter {

class StreamWriter : public UpdatableEntity {

public:
    
    typedef void* SamplePtr;
    typedef void* InfoPtr;

    virtual int write(
            const std::vector<SamplePtr>& sample_seq,
            const std::vector<InfoPtr>& info_seq) = 0;

    virtual ~StreamWriter()
    {
    }
};

template <typename Data, typename Info>
class TStreamWriter : public StreamWriter {
    
public:

    typedef Data DataRep;
    typedef DataRep* DataRepPtr;
    typedef Info InfoRep;
    typedef InfoRep* InfoRepPtr;

    int write(
            const std::vector<SamplePtr>& sample_seq,
            const std::vector<InfoPtr>& info_seq) RTI_FINAL
    {
        RTI_ROUTING_SAMPLE_VECTOR_COPY_PTRS(sample_seq_, sample_seq);
        RTI_ROUTING_SAMPLE_VECTOR_COPY_PTRS(info_seq_, info_seq);
        
        return write(sample_seq_, info_seq_);
    }

    virtual int write(
            const std::vector<Data*>& sample_seq,
            const std::vector<Info*>& info_seq) = 0;

    virtual ~TStreamWriter()
    {
    }

private:
    std::vector<Data*> sample_seq_;
    std::vector<Info*> info_seq_;
};


typedef TStreamWriter<dds::core::xtypes::DynamicData, dds::sub::SampleInfo>
        DynamicDataStreamWriter;

}}}

#endif // RTI_ROUTING_ADAPTER_STREAM_WRITER_HPP_