123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189 |
- #ifndef _FASTDDS_RTPS_BUILTINPROTOCOLS_H_
- #define _FASTDDS_RTPS_BUILTINPROTOCOLS_H_
- #ifndef DOXYGEN_SHOULD_SKIP_THIS_PUBLIC
- #include <list>
- #include <fastdds/rtps/attributes/RTPSParticipantAttributes.h>
- #include <fastdds/rtps/network/NetworkFactory.h>
- namespace eprosima {
- namespace fastdds {
- namespace dds {
- namespace builtin {
- class TypeLookupManager;
- }
- class ReaderQos;
- class WriterQos;
- }
- }
- namespace fastrtps {
- class TopicAttributes;
- namespace rtps {
- class PDP;
- class WLP;
- class RTPSParticipantImpl;
- class RTPSWriter;
- class RTPSReader;
- class BuiltinProtocols
- {
- friend class RTPSParticipantImpl;
- private:
- BuiltinProtocols();
- virtual ~BuiltinProtocols();
- public:
-
- bool initBuiltinProtocols(
- RTPSParticipantImpl* p_part,
- BuiltinAttributes& attributes);
-
- bool updateMetatrafficLocators(
- LocatorList_t& loclist);
-
- void transform_server_remote_locators(
- NetworkFactory & nf);
-
- BuiltinAttributes m_att;
-
- RTPSParticipantImpl* mp_participantImpl;
-
- PDP* mp_PDP;
-
- WLP* mp_WLP;
-
- fastdds::dds::builtin::TypeLookupManager* tlm_;
-
- LocatorList_t m_metatrafficMulticastLocatorList;
-
- LocatorList_t m_metatrafficUnicastLocatorList;
-
- LocatorList_t m_initialPeersList;
-
- std::list<RemoteServerAttributes> m_DiscoveryServers;
-
- bool addLocalWriter(
- RTPSWriter* w,
- const TopicAttributes& topicAtt,
- const fastdds::dds::WriterQos& wqos);
-
- bool addLocalReader(
- RTPSReader* R,
- const TopicAttributes& topicAtt,
- const fastdds::dds::ReaderQos& rqos);
-
- bool updateLocalWriter(
- RTPSWriter* W,
- const TopicAttributes& topicAtt,
- const fastdds::dds::WriterQos& wqos);
-
- bool updateLocalReader(
- RTPSReader* R,
- const TopicAttributes& topicAtt,
- const fastdds::dds::ReaderQos& qos);
-
- bool removeLocalWriter(
- RTPSWriter* W);
-
- bool removeLocalReader(
- RTPSReader* R);
-
- void announceRTPSParticipantState();
-
- void stopRTPSParticipantAnnouncement();
-
- void resetRTPSParticipantAnnouncement();
- };
- }
- }
- }
- #endif
- #endif
|