GAMS  1.4.0
gams::transports::RosBridgeReadThread Class Reference

A custom read thread generated by gpc.pl. More...

#include <RosBridgeReadThread.h>

Inheritance diagram for gams::transports::RosBridgeReadThread:

Public Member Functions

 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...
 

Private Attributes

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_
 

Detailed Description

A custom read thread generated by gpc.pl.

Definition at line 32 of file RosBridgeReadThread.h.

Constructor & Destructor Documentation

◆ 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 
)

Default constructor.

◆ ~RosBridgeReadThread()

virtual gams::transports::RosBridgeReadThread::~RosBridgeReadThread ( )
virtual

Destructor.

Member Function Documentation

◆ init()

virtual void gams::transports::RosBridgeReadThread::init ( madara::knowledge::KnowledgeBase &  knowledge)
virtual

Initializes thread with MADARA context.

Parameters
contextcontext 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.

Member Data Documentation

◆ buffer_

madara::utility::ScopedArray<char> gams::transports::RosBridgeReadThread::buffer_
private

buffer for sending

Definition at line 79 of file RosBridgeReadThread.h.

◆ context_

madara::knowledge::ThreadSafeContext* gams::transports::RosBridgeReadThread::context_
private

data plane if we want to access the knowledge base

Definition at line 70 of file RosBridgeReadThread.h.

◆ id_

const std::string gams::transports::RosBridgeReadThread::id_
private

the unique id of this agent(probably a host:port pairing)

Definition at line 73 of file RosBridgeReadThread.h.

◆ message_count_

unsigned int gams::transports::RosBridgeReadThread::message_count_
private

Definition at line 102 of file RosBridgeReadThread.h.

◆ on_data_received_

madara::knowledge::CompiledExpression gams::transports::RosBridgeReadThread::on_data_received_
private

data received rules, defined in Transport settings

Definition at line 82 of file RosBridgeReadThread.h.

◆ packet_scheduler_

madara::transport::PacketScheduler& gams::transports::RosBridgeReadThread::packet_scheduler_
private

a specialty packet scheduler for experimental drop policies

Definition at line 91 of file RosBridgeReadThread.h.

◆ parser_

gams::utility::ros::RosParser* gams::transports::RosBridgeReadThread::parser_
private

Definition at line 95 of file RosBridgeReadThread.h.

◆ receive_monitor_

madara::transport::BandwidthMonitor& gams::transports::RosBridgeReadThread::receive_monitor_
private

monitor the bandwidth used by others

Definition at line 88 of file RosBridgeReadThread.h.

◆ send_monitor_

madara::transport::BandwidthMonitor& gams::transports::RosBridgeReadThread::send_monitor_
private

monitor the bandwidth used for sending

Definition at line 85 of file RosBridgeReadThread.h.

◆ settings_

madara::transport::QoSTransportSettings gams::transports::RosBridgeReadThread::settings_
private

the transport settings being used

Definition at line 76 of file RosBridgeReadThread.h.

◆ subscribers_

std::vector<ros::Subscriber> gams::transports::RosBridgeReadThread::subscribers_
private

Definition at line 93 of file RosBridgeReadThread.h.

◆ topic_map_

std::map<std::string,std::string> gams::transports::RosBridgeReadThread::topic_map_
private

Definition at line 100 of file RosBridgeReadThread.h.

◆ topics_

std::vector<std::string> gams::transports::RosBridgeReadThread::topics_
private

Definition at line 98 of file RosBridgeReadThread.h.


The documentation for this class was generated from the following file: