StorageStreamWriter.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_RECORDING_STORAGE_STORAGESTREAMWRITER_HPP_
#define RTI_RECORDING_STORAGE_STORAGESTREAMWRITER_HPP_

#include <vector>

#include "dds/dds.hpp"

#include "rti/routing/detail/ForwarderUtils.hpp"

namespace rti { namespace recording { namespace storage {

class StorageStreamWriter {
public:

    typedef void* SamplePtr;
    typedef void* InfoPtr;

    virtual ~StorageStreamWriter() {}

    virtual void store(
            const std::vector<SamplePtr>& sample_seq,
            const std::vector<InfoPtr>& info_seq) = 0;
};


template <typename Data, typename Info>
class TStorageStreamWriter : public StorageStreamWriter {
public:

   typedef Data DataRep;
   typedef Info InfoRep;

   using StorageStreamWriter::store;

   void store(
           const std::vector<SamplePtr>& sample_seq,
           const std::vector<InfoPtr>& info_seq)
   {
       RTI_ROUTING_SAMPLE_VECTOR_COPY_PTRS(sample_seq_, sample_seq);
       RTI_ROUTING_SAMPLE_VECTOR_COPY_PTRS(info_seq_, info_seq);

       store(sample_seq_, info_seq_);
   }

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

   virtual ~TStorageStreamWriter()
   {
   }

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

};

typedef TStorageStreamWriter<
        dds::core::xtypes::DynamicData,
        dds::sub::SampleInfo> DynamicDataStorageStreamWriter;


} } } // namespace rti::recording::storage

#endif /* HPP_RTI_RECORDING_STORAGE_STORAGESTREAMWRITER_HPP_ */