12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758 |
- #ifndef _FASTDDS_RTPS_STATEFULPERSISTENTREADER_H_
- #define _FASTDDS_RTPS_STATEFULPERSISTENTREADER_H_
- #ifndef DOXYGEN_SHOULD_SKIP_THIS_PUBLIC
- #include <fastdds/rtps/reader/StatefulReader.h>
- namespace eprosima {
- namespace fastrtps{
- namespace rtps {
- class IPersistenceService;
- class StatefulPersistentReader : public StatefulReader
- {
- friend class RTPSParticipantImpl;
- StatefulPersistentReader(RTPSParticipantImpl*, GUID_t& guid,
- ReaderAttributes& att, ReaderHistory* hist, ReaderListener* listen,
- IPersistenceService* persistence);
- public:
- virtual ~StatefulPersistentReader();
- protected:
- virtual void set_last_notified(const GUID_t& persistence_guid, const SequenceNumber_t& seq) override;
- private:
- IPersistenceService* persistence_;
- std::string persistence_guid_;
- };
- }
- }
- }
- #endif
- #endif
|