A custom read thread generated by gpc.pl.
More...
#include <RosBridgeReadThread.h>
|
| RosBridgeReadThread (const std::string &id, const madara::transport::TransportSettings &settings, madara::transport::BandwidthMonitor &send_monitor, madara::transport::BandwidthMonitor &receive_monitor, madara::transport::PacketScheduler &packet_scheduler, std::vector< std::string > topics, std::map< std::string, std::string > topic_map) |
| Default constructor. More...
|
|
virtual | ~RosBridgeReadThread () |
| Destructor. More...
|
|
virtual void | init (madara::knowledge::KnowledgeBase &knowledge) |
| Initializes thread with MADARA context. More...
|
|
unsigned int | message_count () |
|
void | messageCallback (const topic_tools::ShapeShifter::ConstPtr &msg, const std::string &topic_name) |
|
virtual void | run (void) |
| Executes the main thread logic. More...
|
|
|
madara::utility::ScopedArray< char > | buffer_ |
| buffer for sending More...
|
|
madara::knowledge::ThreadSafeContext * | context_ |
| data plane if we want to access the knowledge base More...
|
|
const std::string | id_ |
| the unique id of this agent(probably a host:port pairing) More...
|
|
unsigned int | message_count_ |
|
madara::knowledge::CompiledExpression | on_data_received_ |
| data received rules, defined in Transport settings More...
|
|
madara::transport::PacketScheduler & | packet_scheduler_ |
| a specialty packet scheduler for experimental drop policies More...
|
|
gams::utility::ros::RosParser * | parser_ |
|
madara::transport::BandwidthMonitor & | receive_monitor_ |
| monitor the bandwidth used by others More...
|
|
madara::transport::BandwidthMonitor & | send_monitor_ |
| monitor the bandwidth used for sending More...
|
|
madara::transport::QoSTransportSettings | settings_ |
| the transport settings being used More...
|
|
std::vector< ros::Subscriber > | subscribers_ |
|
std::map< std::string, std::string > | topic_map_ |
|
std::vector< std::string > | topics_ |
|
A custom read thread generated by gpc.pl.
Definition at line 32 of file RosBridgeReadThread.h.
◆ RosBridgeReadThread()
gams::transports::RosBridgeReadThread::RosBridgeReadThread |
( |
const std::string & |
id, |
|
|
const madara::transport::TransportSettings & |
settings, |
|
|
madara::transport::BandwidthMonitor & |
send_monitor, |
|
|
madara::transport::BandwidthMonitor & |
receive_monitor, |
|
|
madara::transport::PacketScheduler & |
packet_scheduler, |
|
|
std::vector< std::string > |
topics, |
|
|
std::map< std::string, std::string > |
topic_map |
|
) |
| |
◆ ~RosBridgeReadThread()
virtual gams::transports::RosBridgeReadThread::~RosBridgeReadThread |
( |
| ) |
|
|
virtual |
◆ init()
virtual void gams::transports::RosBridgeReadThread::init |
( |
madara::knowledge::KnowledgeBase & |
knowledge | ) |
|
|
virtual |
Initializes thread with MADARA context.
- Parameters
-
context | context for querying current program state |
◆ message_count()
unsigned int gams::transports::RosBridgeReadThread::message_count |
( |
| ) |
|
◆ messageCallback()
void gams::transports::RosBridgeReadThread::messageCallback |
( |
const topic_tools::ShapeShifter::ConstPtr & |
msg, |
|
|
const std::string & |
topic_name |
|
) |
| |
◆ run()
virtual void gams::transports::RosBridgeReadThread::run |
( |
void |
| ) |
|
|
virtual |
Executes the main thread logic.
◆ buffer_
madara::utility::ScopedArray<char> gams::transports::RosBridgeReadThread::buffer_ |
|
private |
◆ context_
madara::knowledge::ThreadSafeContext* gams::transports::RosBridgeReadThread::context_ |
|
private |
◆ id_
const std::string gams::transports::RosBridgeReadThread::id_ |
|
private |
◆ message_count_
unsigned int gams::transports::RosBridgeReadThread::message_count_ |
|
private |
◆ on_data_received_
madara::knowledge::CompiledExpression gams::transports::RosBridgeReadThread::on_data_received_ |
|
private |
◆ packet_scheduler_
madara::transport::PacketScheduler& gams::transports::RosBridgeReadThread::packet_scheduler_ |
|
private |
◆ parser_
gams::utility::ros::RosParser* gams::transports::RosBridgeReadThread::parser_ |
|
private |
◆ receive_monitor_
madara::transport::BandwidthMonitor& gams::transports::RosBridgeReadThread::receive_monitor_ |
|
private |
◆ send_monitor_
madara::transport::BandwidthMonitor& gams::transports::RosBridgeReadThread::send_monitor_ |
|
private |
◆ settings_
madara::transport::QoSTransportSettings gams::transports::RosBridgeReadThread::settings_ |
|
private |
◆ subscribers_
std::vector<ros::Subscriber> gams::transports::RosBridgeReadThread::subscribers_ |
|
private |
◆ topic_map_
std::map<std::string,std::string> gams::transports::RosBridgeReadThread::topic_map_ |
|
private |
◆ topics_
std::vector<std::string> gams::transports::RosBridgeReadThread::topics_ |
|
private |
The documentation for this class was generated from the following file: