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_