Transformation.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_TRANSF_TRANSFORMATION_HPP_
#define RTI_ROUTING_TRANSF_TRANSFORMATION_HPP_

#include <vector>

#include <dds/core/xtypes/DynamicData.hpp>
#include <dds/sub/SampleInfo.hpp>
#include <rti/routing/UpdatableEntity.hpp>
#include <rti/routing/detail/ForwarderUtils.hpp>

namespace rti { namespace routing { namespace transf {

class Transformation : public UpdatableEntity{
public:         

    typedef void* SamplePtr;
    typedef void* InfoPtr;
    
    virtual void transform(
            std::vector<SamplePtr>& output_sample_seq,
            std::vector<InfoPtr>& output_info_seq,
            const std::vector<SamplePtr>& input_sample_seq,
            const std::vector<InfoPtr>& input_info_seq) = 0;

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

    
    virtual ~Transformation() {}
};


template <typename Data, typename Info>
class TypedTransformation : public Transformation {

public:

    typedef Data DataRep;
    typedef Info InfoRep;

    using Transformation::transform;
    using Transformation::return_loan;

    void transform(
            std::vector<SamplePtr>& output_sample_seq,
            std::vector<InfoPtr>& output_info_seq,
            const std::vector<SamplePtr>& input_sample_seq,
            const std::vector<InfoPtr>& input_info_seq) RTI_FINAL
    {
        RTI_ROUTING_SAMPLE_VECTOR_COPY_PTRS(in_sample_seq_, input_sample_seq);
        RTI_ROUTING_SAMPLE_VECTOR_COPY_PTRS(in_info_seq_, input_info_seq);
        transform(
                out_sample_seq_,
                out_info_seq_,
                in_sample_seq_,
                in_info_seq_);
        RTI_ROUTING_SAMPLE_VECTOR_COPY_PTRS(output_sample_seq, out_sample_seq_);
        RTI_ROUTING_SAMPLE_VECTOR_COPY_PTRS(output_info_seq, out_info_seq_);
    }

    void return_loan(
            std::vector<SamplePtr>& sample_seq,
            std::vector<InfoPtr>& info_seq) RTI_FINAL
    {
        RTI_ROUTING_SAMPLE_VECTOR_COPY_PTRS(out_sample_seq_, sample_seq);
        RTI_ROUTING_SAMPLE_VECTOR_COPY_PTRS(out_info_seq_, info_seq);
        return_loan(out_sample_seq_, out_info_seq_);
        out_sample_seq_.clear();
        out_info_seq_.clear();
    }

    virtual void transform(
            std::vector<Data*>& output_sample_seq,
            std::vector<Info*>& output_info_seq,
            const std::vector<Data*>& input_sample_seq,
            const std::vector<Info*>& input_info_seq) = 0;

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

    virtual ~TypedTransformation()
    {

    }
private:
    std::vector<Data*> in_sample_seq_;
    std::vector<Info*> in_info_seq_;
    std::vector<Data*> out_sample_seq_;
    std::vector<Info*> out_info_seq_;

};

typedef TypedTransformation<dds::core::xtypes::DynamicData, dds::sub::SampleInfo>
        DynamicDataTransformation;


}}}


#endif // RTI_ROUTING_TRANSF_TRANSFORMATION_HPP_