#include <datastream_ROS.h>

Inheritance diagram for DataStreamROS:

Public Member Functions
virtual const std::vector< QAction * > &	availableActions () override

	DataStreamROS ()

virtual bool	isRunning () const override

virtual const char *	name () const override

virtual void	shutdown () override

virtual bool	start (QStringList *selected_datasources) override

virtual bool	xmlLoadState (const QDomElement &parent_element) override

virtual bool	xmlSaveState (QDomDocument &doc, QDomElement &parent_element) const override

virtual	~DataStreamROS () override

Public Member Functions inherited from PJ::DataStreamer
PlotDataMapRef &	dataMap ()

const PlotDataMapRef &	dataMap () const

	DataStreamer ()=default

std::mutex &	mutex ()

virtual std::pair< QAction *, int >	notificationAction ()

const ParserFactories *	parserFactories () const

void	setMaximumRangeX (double range)

void	setParserFactories (ParserFactories *parsers)

virtual	~DataStreamer ()=default

Public Member Functions inherited from PJ::PlotJugglerPlugin
virtual bool	isDebugPlugin ()

virtual QWidget *	optionsWidget ()

	PlotJugglerPlugin ()=default

QDomElement	xmlSaveState (QDomDocument &doc) const

Private Member Functions
void	extractInitialSamples ()

void	saveIntoRosbag ()

void	subscribe ()

void	timerCallback ()

void	topicCallback (const RosIntrospection::ShapeShifter::ConstPtr &msg, const std::string &topic_name)

Private Attributes
QAction *	_action_saveAny

QAction *	_action_saveIntoRosbag

std::vector< QAction * >	_available_actions

RosParserConfig	_config

bool	_first_warning

double	_initial_time

std::map< std::string, int >	_msg_index

ros::NodeHandlePtr	_node

std::unique_ptr< RosCompositeParser >	_parser

QTimer *	_periodic_timer

std::string	_prefix

double	_prev_clock_time

int	_received_msg_count

RosIntrospection::SubstitutionRuleMap	_rules

bool	_running

std::shared_ptr< ros::AsyncSpinner >	_spinner

std::map< std::string, ros::Subscriber >	_subscribers

std::unordered_map< std::string, PlotDataAny >	_user_defined_buffers

Additional Inherited Members
Signals inherited from PJ::DataStreamer
void	clearBuffers ()

void	closed ()

void	dataReceived ()

void	notificationsChanged (int active_notification_count)

void	removeGroup (std::string group_name)

Detailed Description

Definition at line 16 of file datastream_ROS.h.

Constructor & Destructor Documentation

◆ DataStreamROS()

DataStreamROS::DataStreamROS ( )

Definition at line 27 of file datastream_ROS.cpp.

◆ ~DataStreamROS()

DataStreamROS::~DataStreamROS ( )

overridevirtual

Definition at line 434 of file datastream_ROS.cpp.

Member Function Documentation

◆ availableActions()

const std::vector< QAction * > & DataStreamROS::availableActions ( )

overridevirtual

Reimplemented from PJ::PlotJugglerPlugin.

Definition at line 451 of file datastream_ROS.cpp.

◆ extractInitialSamples()

void DataStreamROS::extractInitialSamples ( )

private

Definition at line 169 of file datastream_ROS.cpp.

◆ isRunning()

bool DataStreamROS::isRunning ( ) const

overridevirtual

Implements PJ::DataStreamer.

Definition at line 409 of file datastream_ROS.cpp.

◆ name()

virtual const char* DataStreamROS::name ( ) const

inlineoverridevirtual

Implements PJ::PlotJugglerPlugin.

Definition at line 33 of file datastream_ROS.h.

◆ saveIntoRosbag()

void DataStreamROS::saveIntoRosbag ( )

private

Definition at line 244 of file datastream_ROS.cpp.

◆ shutdown()

void DataStreamROS::shutdown ( )

overridevirtual

Implements PJ::DataStreamer.

Definition at line 414 of file datastream_ROS.cpp.

◆ start()

bool DataStreamROS::start ( QStringList * selected_datasources )

overridevirtual

Implements PJ::DataStreamer.

Definition at line 330 of file datastream_ROS.cpp.

◆ subscribe()

void DataStreamROS::subscribe ( )

private

Definition at line 310 of file datastream_ROS.cpp.

◆ timerCallback()

void DataStreamROS::timerCallback ( )

private

Definition at line 202 of file datastream_ROS.cpp.

◆ topicCallback()

void DataStreamROS::topicCallback	(	const RosIntrospection::ShapeShifter::ConstPtr &	msg,
		const std::string &	topic_name
	)

private

Definition at line 61 of file datastream_ROS.cpp.

◆ xmlLoadState()

bool DataStreamROS::xmlLoadState ( const QDomElement & parent_element )

overridevirtual

Reimplemented from PJ::PlotJugglerPlugin.

Definition at line 445 of file datastream_ROS.cpp.

◆ xmlSaveState()

bool DataStreamROS::xmlSaveState	(	QDomDocument &	doc,
		QDomElement &	parent_element
	)		const

overridevirtual

Reimplemented from PJ::PlotJugglerPlugin.

Definition at line 439 of file datastream_ROS.cpp.

Member Data Documentation

◆ _action_saveAny

QAction* DataStreamROS::_action_saveAny

private

Definition at line 72 of file datastream_ROS.h.

◆ _action_saveIntoRosbag

QAction* DataStreamROS::_action_saveIntoRosbag

private

Definition at line 70 of file datastream_ROS.h.

◆ _available_actions

std::vector<QAction*> DataStreamROS::_available_actions

private

Definition at line 74 of file datastream_ROS.h.

◆ _config

RosParserConfig DataStreamROS::_config

private

Definition at line 78 of file datastream_ROS.h.

◆ _first_warning

bool DataStreamROS::_first_warning

private

Definition at line 54 of file datastream_ROS.h.

◆ _initial_time

double DataStreamROS::_initial_time

private

Definition at line 58 of file datastream_ROS.h.

◆ _msg_index

std::map<std::string, int> DataStreamROS::_msg_index

private

Definition at line 76 of file datastream_ROS.h.

◆ _node

ros::NodeHandlePtr DataStreamROS::_node

private

Definition at line 62 of file datastream_ROS.h.

◆ _parser

std::unique_ptr<RosCompositeParser> DataStreamROS::_parser

private

Definition at line 80 of file datastream_ROS.h.

◆ _periodic_timer

QTimer* DataStreamROS::_periodic_timer

private

Definition at line 82 of file datastream_ROS.h.

◆ _prefix

std::string DataStreamROS::_prefix

private

Definition at line 60 of file datastream_ROS.h.

◆ _prev_clock_time

double DataStreamROS::_prev_clock_time

private

Definition at line 84 of file datastream_ROS.h.

◆ _received_msg_count

int DataStreamROS::_received_msg_count

private

Definition at line 68 of file datastream_ROS.h.

◆ _rules

RosIntrospection::SubstitutionRuleMap DataStreamROS::_rules

private

Definition at line 66 of file datastream_ROS.h.

◆ _running

bool DataStreamROS::_running

private

Definition at line 53 of file datastream_ROS.h.

◆ _spinner

std::shared_ptr<ros::AsyncSpinner> DataStreamROS::_spinner

private

Definition at line 56 of file datastream_ROS.h.

◆ _subscribers

std::map<std::string, ros::Subscriber> DataStreamROS::_subscribers

private

Definition at line 64 of file datastream_ROS.h.

◆ _user_defined_buffers

std::unordered_map<std::string, PlotDataAny> DataStreamROS::_user_defined_buffers

private

Definition at line 86 of file datastream_ROS.h.

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

Public Member Functions

Private Member Functions

Private Attributes

Additional Inherited Members

Detailed Description

Constructor & Destructor Documentation

◆ DataStreamROS()

◆ ~DataStreamROS()

Member Function Documentation

◆ availableActions()

◆ extractInitialSamples()

◆ isRunning()

◆ name()

◆ saveIntoRosbag()

◆ shutdown()

◆ start()

◆ subscribe()

◆ timerCallback()

◆ topicCallback()

◆ xmlLoadState()

◆ xmlSaveState()

Member Data Documentation

◆ _action_saveAny

◆ _action_saveIntoRosbag

◆ _available_actions

◆ _config

◆ _first_warning

◆ _initial_time

◆ _msg_index

◆ _node

◆ _parser

◆ _periodic_timer

◆ _prefix

◆ _prev_clock_time

◆ _received_msg_count

◆ _rules

◆ _running

◆ _spinner

◆ _subscribers

◆ _user_defined_buffers