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_ */