10 #ifndef HPP_RECORDER_DB_REPLAYPLUGIN_HPP_
11 #define HPP_RECORDER_DB_REPLAYPLUGIN_HPP_
13 #include "rti/routing/PropertySet.hpp"
14 #include "rti/routing/StreamInfo.hpp"
16 #include "StorageStreamInfoReader.hpp"
17 #include "rti/recording/storage/StorageStreamReader.hpp"
59 typedef void* SampleType;
60 typedef void* InfoType;
61 typedef std::vector<SampleType> SampleSeqType;
62 typedef std::vector<InfoType> InfoSeqType;
94 RTI_UNUSED_PARAMETER(properties);
121 const rti::routing::PropertySet& properties) = 0;
151 const rti::routing::StreamInfo& stream_info,
152 const rti::routing::PropertySet& properties) = 0;
169 #include "rti/recording/storage/detail/StorageReaderForwarder.hpp"
170 #include "rti/routing/ServiceProperty.hpp"
171 #include "rti/routing/detail/ForwarderUtils.hpp"
194 #define RTI_RECORDING_STORAGE_READER_CREATE_DECL(STORAGE_READER_CLASS) \
195 extern "C" RTI_USER_DLL_EXPORT \
196 struct RTI_RecordingServiceStorageReader * \
197 STORAGE_READER_CLASS ## _get_storage_reader( \
198 const struct RTI_RoutingServiceProperties *);
208 #define RTI_RECORDING_STORAGE_READER_CREATE_DEF(STORAGE_READER_CLASS) \
209 struct RTI_RecordingServiceStorageReader * \
210 STORAGE_READER_CLASS ## _get_storage_reader( \
211 const struct RTI_RoutingServiceProperties *native_properties) \
213 rti::routing::PropertySet properties; \
214 rti::routing::PropertyAdapter::add_properties_from_native( \
216 native_properties); \
217 return new rti::recording::storage::detail::StorageReaderForwarder( \
218 new STORAGE_READER_CLASS(properties)); \