StorageReader.hpp

Go to the documentation of this file.

/*
 * (c) Copyright, Real-Time Innovations, 2018-.
 * 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 HPP_RECORDER_DB_REPLAYPLUGIN_HPP_
#define HPP_RECORDER_DB_REPLAYPLUGIN_HPP_

#include "dds/dds.hpp"
#include "rti/recording/PropertySet.hpp"
#include "rti/recording/StreamInfo.hpp"

#include "StorageStreamInfoReader.hpp"
#include "rti/recording/storage/StorageStreamReader.hpp"

namespace rti {

namespace recording {

namespace storage {

class StorageReader {
public:

    typedef void* SampleType;
    typedef void* InfoType;
    typedef std::vector<SampleType> SampleSeqType;
    typedef std::vector<InfoType> InfoSeqType;

    StorageReader(const rti::recording::PropertySet& properties)
    {
        RTI_UNUSED_PARAMETER(properties);
    }

    virtual ~StorageReader()
    {
    }

    virtual StorageStreamInfoReader * create_stream_info_reader(
            const rti::recording::PropertySet& properties) = 0;

    virtual void delete_stream_info_reader(
            StorageStreamInfoReader *stream_info_reader) = 0;

    virtual StorageStreamReader * create_stream_reader(
            const rti::recording::StreamInfo& stream_info,
            const rti::recording::PropertySet& properties) = 0;

    virtual void delete_stream_reader(StorageStreamReader *stream_reader) = 0;

private:

    StorageReader() {}

};

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

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

#define RTI_RECORDING_STORAGE_READER_CREATE_DECL(STORAGE_READER_CLASS) \
extern "C" RTI_USER_DLL_EXPORT \
struct RTI_RecordingServiceStorageReader * \
STORAGE_READER_CLASS ## _get_storage_reader( \
        const struct RTI_RoutingServiceProperties *);

#define RTI_RECORDING_STORAGE_READER_CREATE_DEF(STORAGE_READER_CLASS) \
struct RTI_RecordingServiceStorageReader * \
STORAGE_READER_CLASS ## _get_storage_reader( \
        const struct RTI_RoutingServiceProperties *native_properties) \
{ \
    rti::recording::PropertySet properties; \
    rti::routing::PropertyAdapter::add_properties_from_native( \
            properties, \
            native_properties); \
    return new rti::recording::storage::detail::StorageReaderForwarder( \
            new STORAGE_READER_CLASS(properties)); \
}

#endif /* HPP_RECORDER_DB_REPLAYPLUGIN_HPP_ */