DiscoveryStreamReader.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_DISCOVERY_STREAM_READER_HPP_
#define RTI_ROUTING_ADAPTER_DISCOVERY_STREAM_READER_HPP_

#include <stdlib.h>

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


namespace rti { namespace routing { namespace adapter {

class DiscoveryStreamReader : public StreamReader{

    using StreamReader::take;
    using StreamReader::return_loan;
    void take(
            std::vector<SamplePtr>& sample_seq,
            std::vector<InfoPtr>&) RTI_FINAL
    {
        take(sample_seq_);
        RTI_ROUTING_SAMPLE_VECTOR_COPY_PTRS(sample_seq, sample_seq_);
    }

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

    void read(
            std::vector<SamplePtr>&,
            std::vector<InfoPtr>&) RTI_FINAL
    {
    }

    void take(
            std::vector<SamplePtr>&,
            std::vector<InfoPtr>&,
            const SelectorState&) RTI_FINAL
    {
    }

    void read(
            std::vector<SamplePtr>&,
            std::vector<InfoPtr>&,
            const SelectorState&) RTI_FINAL
    {
    }

     virtual void* create_content_query(
            void *,
            const dds::topic::Filter&) RTI_FINAL
    {
        return NULL;
    }


    virtual void delete_content_query(void*) RTI_FINAL
    {

    }

    
public:

    virtual void take(
            std::vector<rti::routing::StreamInfo*>& sample_seq) = 0;

    virtual void return_loan(
            std::vector<rti::routing::StreamInfo*>& sample_seq) = 0;

    /*
     * @brief Virtual destructor
     */
    virtual ~DiscoveryStreamReader()
    {
    }   

private:
    std::vector<StreamInfo*> sample_seq_;
};

}}}

#endif // RTI_ROUTING_ADAPTER_DISCOVERY_STREAM_READER_HPP_