Connection.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_CONNECTION_HPP_
#define RTI_ROUTING_ADAPTER_CONNECTION_HPP_

#include <rti/routing/PropertySet.hpp>
#include <rti/routing/UpdatableEntity.hpp>
#include <rti/routing/adapter/Session.hpp>
#include <rti/routing/adapter/StreamWriter.hpp>
#include <rti/routing/adapter/StreamReader.hpp>
#include <rti/routing/StreamInfo.hpp>
#include <rti/routing/adapter/DiscoveryStreamReader.hpp>
#include <rti/routing/adapter/StreamReaderListener.hpp>

namespace rti { namespace routing { namespace adapter {

class Connection : public UpdatableEntity {
    
public:
    virtual Session * create_session(
            const PropertySet& properties)
    {
        (void) properties;
        
        return NULL;
    }

    virtual void delete_session(Session *session)
    {
        (void) session;
    }

    virtual StreamWriter * create_stream_writer(
            Session *session,
            const StreamInfo& stream_info,
            const PropertySet& properties) = 0;

    virtual void delete_stream_writer(
            StreamWriter *stream_writer) = 0;

    virtual StreamReader * create_stream_reader(
            Session *session,
            const StreamInfo& stream_info,
            const PropertySet& properties,
            StreamReaderListener *listener) = 0;

    virtual void delete_stream_reader(
            StreamReader *stream_reader) = 0;
    
    virtual DiscoveryStreamReader * input_stream_discovery_reader() 
    {
        return NULL;
    }
    
    virtual DiscoveryStreamReader * output_stream_discovery_reader()
    {
        return NULL;
    }

    virtual ~Connection()
    {
    }

};

}}}

#endif // RTI_ROUTING_ADAPTER_CONNECTION_HPP_