AddIncomingMessages(SynMessageList &messages) | chrono::synchrono::SynCommunicator | |
AddOutgoingMessages(SynMessageList &messages) | chrono::synchrono::SynCommunicator | |
AddQuitMessage() | chrono::synchrono::SynCommunicator | |
Barrier() override | chrono::synchrono::SynDDSCommunicator | virtual |
Barrier(unsigned int num_participants) | chrono::synchrono::SynDDSCommunicator | |
CreatePublisher(std::shared_ptr< SynDDSTopic > topic, bool is_managed=false, eprosima::fastdds::dds::DataWriterQos *write_qos=nullptr) | chrono::synchrono::SynDDSCommunicator | |
CreatePublisher(const std::string &topic_name, eprosima::fastdds::dds::TopicDataType *data_type, bool is_managed=false) | chrono::synchrono::SynDDSCommunicator | |
CreateSubscriber(std::shared_ptr< SynDDSTopic > topic, std::function< void(void *)> callback, void *message, bool is_synchronous=true, bool is_managed=false, eprosima::fastdds::dds::DataReaderQos *read_qos=nullptr) | chrono::synchrono::SynDDSCommunicator | |
CreateSubscriber(const std::string &topic_name, eprosima::fastdds::dds::TopicDataType *data_type, std::function< void(void *)> callback, void *message, bool is_synchronous=true, bool is_managed=false) | chrono::synchrono::SynDDSCommunicator | |
CreateTopic(const std::string &topic_name, eprosima::fastdds::dds::TopicDataType *data_type, const std::string &topic_prefix) | chrono::synchrono::SynDDSCommunicator | |
CreateTopic(const std::string &topic_name, eprosima::fastdds::dds::TopicDataType *data_type) | chrono::synchrono::SynDDSCommunicator | |
GetMatchedParticipantNames() | chrono::synchrono::SynDDSCommunicator | |
GetMessages() | chrono::synchrono::SynCommunicator | inlinevirtual |
Initialize() override | chrono::synchrono::SynDDSCommunicator | virtual |
m_flatbuffers_manager | chrono::synchrono::SynCommunicator | protected |
m_incoming_messages | chrono::synchrono::SynCommunicator | protected |
m_initialized | chrono::synchrono::SynCommunicator | protected |
m_prefix (defined in chrono::synchrono::SynDDSCommunicator) | chrono::synchrono::SynDDSCommunicator | |
ProcessBuffer(std::vector< uint8_t > &data) | chrono::synchrono::SynCommunicator | |
Reset() | chrono::synchrono::SynCommunicator | |
Synchronize() override | chrono::synchrono::SynDDSCommunicator | virtual |
SynCommunicator() | chrono::synchrono::SynCommunicator | |
SynDDSCommunicator(int node_id, const std::string &prefix=default_prefix) (defined in chrono::synchrono::SynDDSCommunicator) | chrono::synchrono::SynDDSCommunicator | |
SynDDSCommunicator(const std::string &name, const std::string &prefix=default_prefix) | chrono::synchrono::SynDDSCommunicator | |
SynDDSCommunicator(eprosima::fastdds::dds::DomainParticipantQos &qos, const std::string &prefix=default_prefix) | chrono::synchrono::SynDDSCommunicator | |
~SynCommunicator() | chrono::synchrono::SynCommunicator | virtual |
~SynDDSCommunicator() | chrono::synchrono::SynDDSCommunicator | virtual |