Apollo
6.0
Open source self driving car software
|
Topology Manager of Node related. More...
#include <node_manager.h>
Public Types | |
using | RoleAttrVec = std::vector< RoleAttributes > |
using | NodeWarehouse = SingleValueWarehouse |
![]() | |
using | ChangeSignal = base::Signal< const ChangeMsg & > |
using | ChangeFunc = std::function< void(const ChangeMsg &)> |
using | ChangeConnection = base::Connection< const ChangeMsg & > |
using | RtpsParticipant = eprosima::fastrtps::Participant |
using | RtpsPublisherAttr = eprosima::fastrtps::PublisherAttributes |
using | RtpsSubscriberAttr = eprosima::fastrtps::SubscriberAttributes |
Public Member Functions | |
NodeManager () | |
Construct a new Node Manager object. More... | |
virtual | ~NodeManager () |
Destroy the Node Manager object. More... | |
bool | HasNode (const std::string &node_name) |
Checkout whether we have node_name in topology. More... | |
void | GetNodes (RoleAttrVec *nodes) |
Get the Nodes object. More... | |
![]() | |
Manager () | |
Construct a new Manager object. More... | |
virtual | ~Manager () |
Destroy the Manager object. More... | |
bool | StartDiscovery (RtpsParticipant *participant) |
Startup topology discovery. More... | |
void | StopDiscovery () |
Stop topology discovery. More... | |
virtual void | Shutdown () |
Shutdown module. More... | |
bool | Join (const RoleAttributes &attr, RoleType role, bool need_publish=true) |
Join the topology. More... | |
bool | Leave (const RoleAttributes &attr, RoleType role) |
Leave the topology. More... | |
ChangeConnection | AddChangeListener (const ChangeFunc &func) |
Add topology change listener, when topology changed, func will be called. More... | |
void | RemoveChangeListener (const ChangeConnection &conn) |
Remove our listener for topology change. More... | |
Friends | |
class | TopologyManager |
Additional Inherited Members | |
![]() | |
bool | CreatePublisher (RtpsParticipant *participant) |
bool | CreateSubscriber (RtpsParticipant *participant) |
virtual bool | NeedPublish (const ChangeMsg &msg) const |
void | Convert (const RoleAttributes &attr, RoleType role, OperateType opt, ChangeMsg *msg) |
void | Notify (const ChangeMsg &msg) |
bool | Publish (const ChangeMsg &msg) |
void | OnRemoteChange (const std::string &msg_str) |
bool | IsFromSameProcess (const ChangeMsg &msg) |
![]() | |
std::atomic< bool > | is_shutdown_ |
std::atomic< bool > | is_discovery_started_ |
int | allowed_role_ |
ChangeType | change_type_ |
std::string | host_name_ |
int | process_id_ |
std::string | channel_name_ |
eprosima::fastrtps::Publisher * | publisher_ |
std::mutex | lock_ |
eprosima::fastrtps::Subscriber * | subscriber_ |
SubscriberListener * | listener_ |
ChangeSignal | signal_ |
using apollo::cyber::service_discovery::NodeManager::RoleAttrVec = std::vector<RoleAttributes> |
|
virtual |
void apollo::cyber::service_discovery::NodeManager::GetNodes | ( | RoleAttrVec * | nodes | ) |
Get the Nodes object.
nodes | result RoleAttr vector |
bool apollo::cyber::service_discovery::NodeManager::HasNode | ( | const std::string & | node_name | ) |
Checkout whether we have node_name
in topology.
node_name | Node's name we want to inquire |
|
friend |