Apollo
6.0
Open source self driving car software
|
#include <rtps_dispatcher.h>
Public Member Functions | |
virtual | ~RtpsDispatcher () |
void | Shutdown () override |
template<typename MessageT > | |
void | AddListener (const RoleAttributes &self_attr, const MessageListener< MessageT > &listener) |
template<typename MessageT > | |
void | AddListener (const RoleAttributes &self_attr, const RoleAttributes &opposite_attr, const MessageListener< MessageT > &listener) |
void | set_participant (const ParticipantPtr &participant) |
![]() | |
Dispatcher () | |
virtual | ~Dispatcher () |
template<typename MessageT > | |
void | AddListener (const RoleAttributes &self_attr, const MessageListener< MessageT > &listener) |
template<typename MessageT > | |
void | AddListener (const RoleAttributes &self_attr, const RoleAttributes &opposite_attr, const MessageListener< MessageT > &listener) |
template<typename MessageT > | |
void | RemoveListener (const RoleAttributes &self_attr) |
template<typename MessageT > | |
void | RemoveListener (const RoleAttributes &self_attr, const RoleAttributes &opposite_attr) |
bool | HasChannel (uint64_t channel_id) |
Additional Inherited Members | |
![]() | |
std::atomic< bool > | is_shutdown_ |
AtomicHashMap< uint64_t, ListenerHandlerBasePtr > | msg_listeners_ |
base::AtomicRWLock | rw_lock_ |
|
virtual |
void apollo::cyber::transport::RtpsDispatcher::AddListener | ( | const RoleAttributes & | self_attr, |
const MessageListener< MessageT > & | listener | ||
) |
void apollo::cyber::transport::RtpsDispatcher::AddListener | ( | const RoleAttributes & | self_attr, |
const RoleAttributes & | opposite_attr, | ||
const MessageListener< MessageT > & | listener | ||
) |
|
inline |
|
overridevirtual |
Reimplemented from apollo::cyber::transport::Dispatcher.