10 #include "rti/routing/StreamInfo.hpp"
11 #include "rti/routing/PropertySet.hpp"
13 #include "rti/recording/storage/StorageStreamWriter.hpp"
14 #include "rti/recording/storage/StorageDiscoveryStreamWriter.hpp"
15 #include "dds/dds.hpp"
17 #ifndef HPP_RTI_RECORDING_STORAGE_STORAGEWRITER_HPP_
18 #define HPP_RTI_RECORDING_STORAGE_STORAGEWRITER_HPP_
27 namespace rti {
namespace recording {
namespace storage {
69 RTI_UNUSED_PARAMETER(properties);
93 const rti::routing::StreamInfo& stream_info,
94 const rti::routing::PropertySet& properties) = 0;
150 #include "rti/recording/storage/detail/StorageWriterForwarder.hpp"
151 #include "rti/routing/ServiceProperty.hpp"
152 #include "rti/routing/detail/ForwarderUtils.hpp"
175 #define RTI_RECORDING_STORAGE_WRITER_CREATE_DECL(STORAGE_WRITER_CLASS) \
176 extern "C" RTI_USER_DLL_EXPORT \
177 struct RTI_RecordingServiceStorageWriter * \
178 STORAGE_WRITER_CLASS ## _get_storage_writer( \
179 const struct RTI_RoutingServiceProperties *);
189 #define RTI_RECORDING_STORAGE_WRITER_CREATE_DEF(STORAGE_WRITER_CLASS) \
190 struct RTI_RecordingServiceStorageWriter * \
191 STORAGE_WRITER_CLASS ## _get_storage_writer( \
192 const struct RTI_RoutingServiceProperties *native_properties) \
194 rti::routing::PropertySet properties; \
195 rti::routing::PropertyAdapter::add_properties_from_native( \
197 native_properties); \
198 return new rti::recording::storage::detail::StorageWriterForwarder( \
199 new STORAGE_WRITER_CLASS(properties)); \