10 #include "rti/recording/PropertySet.hpp" 11 #include "rti/recording/StreamInfo.hpp" 12 #include "rti/recording/storage/StorageStreamWriter.hpp" 13 #include "rti/recording/storage/StorageDiscoveryStreamWriter.hpp" 14 #include "dds/dds.hpp" 16 #ifndef HPP_RTI_RECORDING_STORAGE_STORAGEWRITER_HPP_ 17 #define HPP_RTI_RECORDING_STORAGE_STORAGEWRITER_HPP_ 26 namespace rti {
namespace recording {
namespace storage {
68 RTI_UNUSED_PARAMETER(properties);
92 const rti::recording::StreamInfo& stream_info,
93 const rti::recording::PropertySet& properties) = 0;
149 #include "rti/recording/storage/detail/StorageWriterForwarder.hpp" 150 #include "rti/routing/ServiceProperty.hpp" 151 #include "rti/routing/detail/ForwarderUtils.hpp" 174 #define RTI_RECORDING_STORAGE_WRITER_CREATE_DECL(STORAGE_WRITER_CLASS) \ 175 extern "C" RTI_USER_DLL_EXPORT \ 176 struct RTI_RecordingServiceStorageWriter * \ 177 STORAGE_WRITER_CLASS ## _get_storage_writer( \ 178 const struct RTI_RoutingServiceProperties *); 188 #define RTI_RECORDING_STORAGE_WRITER_CREATE_DEF(STORAGE_WRITER_CLASS) \ 189 struct RTI_RecordingServiceStorageWriter * \ 190 STORAGE_WRITER_CLASS ## _get_storage_writer( \ 191 const struct RTI_RoutingServiceProperties *native_properties) \ 193 rti::recording::PropertySet properties; \ 194 rti::routing::PropertyAdapter::add_properties_from_native( \ 196 native_properties); \ 197 return new rti::recording::storage::detail::StorageWriterForwarder( \ 198 new STORAGE_WRITER_CLASS(properties)); \ Storage writer.
Definition: StorageWriter.hpp:36
virtual ParticipantStorageWriter * create_participant_writer()
RTI Recording Service calls this to create a stream writer for the DDS built-in topic DCPSParticipant...
Definition: StorageWriter.hpp:103
virtual SubscriptionStorageWriter * create_subscription_writer()
RTI Recording Service calls this to create a stream writer for the DDS built-in topic DCPSSubscriptio...
Definition: StorageWriter.hpp:129
virtual StorageStreamWriter * create_stream_writer(const rti::recording::StreamInfo &stream_info, const rti::recording::PropertySet &properties)=0
RTI Recording Service calls this to create a user-data stream writer. The built-in DDS discovery topi...
Storage stream writer.
Definition: StorageStreamWriter.hpp:28
StorageWriter(const rti::recording::PropertySet &properties)
Constructor.
Definition: StorageWriter.hpp:66
virtual ~StorageWriter()
Virtual destructor.
Definition: StorageWriter.hpp:74
virtual PublicationStorageWriter * create_publication_writer()
RTI Recording Service calls this to create a stream writer for the DDS built-in topic DCPSPublication...
Definition: StorageWriter.hpp:116
A templatized wrapping implementation of StorageStreamWriter, providing a strongly-typed interface re...
Definition: StorageStreamWriter.hpp:65
The RTI namespace.
Definition: RecordingServiceImpl.hpp:22
virtual void delete_stream_writer(StorageStreamWriter *writer)=0
RTI Recording Service calls this to delete a stream writer. This method should be able to work with a...