StorageWriter.hpp

Go to the documentation of this file.

/*
 * (c) Copyright, Real-Time Innovations, 2016-.
 * 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.
 */

#include "rti/routing/StreamInfo.hpp"
#include "rti/routing/PropertySet.hpp"

#include "rti/recording/storage/StorageStreamWriter.hpp"
#include "rti/recording/storage/StorageDiscoveryStreamWriter.hpp"
#include "dds/dds.hpp"

#ifndef HPP_RTI_RECORDING_STORAGE_STORAGEWRITER_HPP_
#define HPP_RTI_RECORDING_STORAGE_STORAGEWRITER_HPP_

namespace rti { namespace recording { namespace storage {

class StorageWriter {
public:

    StorageWriter(const rti::routing::PropertySet& properties)
    {
        RTI_UNUSED_PARAMETER(properties);
    }

    virtual ~StorageWriter() {}

    virtual StorageStreamWriter * create_stream_writer(
            const rti::routing::StreamInfo& stream_info,
            const rti::routing::PropertySet& properties) = 0;

    virtual ParticipantStorageWriter * create_participant_writer()
    {
        return NULL;
    }

    virtual PublicationStorageWriter * create_publication_writer()
    {
        return NULL;
    }

    virtual SubscriptionStorageWriter * create_subscription_writer()
    {
        return NULL;
    }

    virtual void delete_stream_writer(StorageStreamWriter *writer) = 0;

private:

    StorageWriter() {}
};

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

#include "rti/recording/storage/detail/StorageWriterForwarder.hpp"
#include "rti/routing/ServiceProperty.hpp"
#include "rti/routing/detail/ForwarderUtils.hpp"

#define RTI_RECORDING_STORAGE_WRITER_CREATE_DECL(STORAGE_WRITER_CLASS) \
extern "C" RTI_USER_DLL_EXPORT \
struct RTI_RecordingServiceStorageWriter * \
STORAGE_WRITER_CLASS ## _get_storage_writer( \
        const struct RTI_RoutingServiceProperties *);

#define RTI_RECORDING_STORAGE_WRITER_CREATE_DEF(STORAGE_WRITER_CLASS) \
struct RTI_RecordingServiceStorageWriter * \
STORAGE_WRITER_CLASS ## _get_storage_writer( \
        const struct RTI_RoutingServiceProperties *native_properties) \
{ \
    rti::routing::PropertySet properties; \
    rti::routing::PropertyAdapter::add_properties_from_native( \
            properties, \
            native_properties); \
    return new rti::recording::storage::detail::StorageWriterForwarder( \
            new STORAGE_WRITER_CLASS(properties)); \
}

#endif /* HPP_RTI_RECORDING_STORAGE_STORAGEWRITER_HPP_ */