1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465 |
- #ifndef _FASTDDS_RTPS_STATEFULPERSISTENTWRITER_H_
- #define _FASTDDS_RTPS_STATEFULPERSISTENTWRITER_H_
- #ifndef DOXYGEN_SHOULD_SKIP_THIS_PUBLIC
- #include <fastdds/rtps/writer/StatefulWriter.h>
- #include <fastdds/rtps/writer/PersistentWriter.h>
- namespace eprosima {
- namespace fastrtps{
- namespace rtps {
- class IPersistenceService;
- class StatefulPersistentWriter : public StatefulWriter, private PersistentWriter
- {
- friend class RTPSParticipantImpl;
- StatefulPersistentWriter(RTPSParticipantImpl*,GUID_t& guid,WriterAttributes& att,WriterHistory* hist,WriterListener* listen=nullptr, IPersistenceService* persistence = nullptr);
- public:
- virtual ~StatefulPersistentWriter();
-
- void unsent_change_added_to_history(
- CacheChange_t* p,
- const std::chrono::time_point<std::chrono::steady_clock>& max_blocking_time) override;
-
- bool change_removed_by_history(CacheChange_t* a_change) override;
- };
- }
- }
- }
- #endif
- #endif
|