123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184 |
- #ifndef PUBLISHER_H_
- #define PUBLISHER_H_
- #include <fastrtps/fastrtps_dll.h>
- #include <fastdds/rtps/common/Guid.h>
- #include <fastdds/rtps/common/Time_t.h>
- #include <fastrtps/attributes/PublisherAttributes.h>
- #include <fastrtps/qos/DeadlineMissedStatus.h>
- #include <fastrtps/qos/LivelinessLostStatus.h>
- namespace eprosima {
- namespace fastrtps {
- namespace rtps {
- struct GUID_t;
- class WriteParams;
- class RTPSParticipant;
- }
- class Participant;
- class PublisherImpl;
- class RTPS_DllAPI Publisher
- {
- friend class PublisherImpl;
- virtual ~Publisher();
- public:
-
- Publisher(
- PublisherImpl* pimpl);
-
- bool write(
- void* sample);
-
- bool write(
- void* sample,
- rtps::WriteParams& wparams);
-
- fastrtps::rtps::InstanceHandle_t register_instance(
- void* instance);
-
- bool dispose(
- void* data,
- const rtps::InstanceHandle_t& handle);
-
- bool unregister_instance(
- void* instance,
- const rtps::InstanceHandle_t& handle);
-
- bool removeAllChange(
- size_t* removed = nullptr);
-
- bool wait_for_all_acked(
- const Duration_t& max_wait);
-
- const rtps::GUID_t& getGuid();
-
- const PublisherAttributes& getAttributes() const;
-
- bool updateAttributes(
- const PublisherAttributes& att);
-
- void get_offered_deadline_missed_status(
- OfferedDeadlineMissedStatus& status);
-
- void assert_liveliness();
-
- void get_liveliness_lost_status(
- LivelinessLostStatus& status);
- private:
- PublisherImpl* mp_impl;
- };
- }
- }
- #endif
|