#include <bt_zmq_publisher.h>

Inheritance diagram for BT::PublisherZMQ:

Classes
struct	Pimpl

Public Member Functions
	PublisherZMQ (TreeNode *root_node, int max_msg_per_second=25)

virtual	~PublisherZMQ ()

Public Member Functions inherited from BT::StatusChangeLogger
bool	enabled () const

void	enableTransitionToIdle (bool enable)

void	setEnabled (bool enabled)

void	seTimestampType (TimestampType type)

bool	showsTransitionToIdle () const

	StatusChangeLogger (TreeNode *root_node)

virtual	~StatusChangeLogger ()=default

Private Member Functions
virtual void	callback (Duration timestamp, const TreeNode &node, NodeStatus prev_status, NodeStatus status) override

void	createStatusBuffer ()

virtual void	flush () override

Private Attributes
std::atomic_bool	active_server_

TimePoint	deadline_

std::chrono::microseconds	min_time_between_msgs_

std::mutex	mutex_

TreeNode *	root_node_

std::future< void >	send_future_

std::atomic_bool	send_pending_

std::vector< uint8_t >	status_buffer_

std::thread	thread_

std::vector< SerializedTransition >	transition_buffer_

std::vector< uint8_t >	tree_buffer_

Pimpl *	zmq_

Static Private Attributes
static std::atomic< bool >	ref_count

Detailed Description

Definition at line 11 of file bt_zmq_publisher.h.

Constructor & Destructor Documentation

BT::PublisherZMQ::PublisherZMQ	(	TreeNode *	root_node,
		int	max_msg_per_second = `25`
	)

Definition at line 24 of file bt_zmq_publisher.cpp.

BT::PublisherZMQ::~PublisherZMQ ( )

virtual

Definition at line 80 of file bt_zmq_publisher.cpp.

Member Function Documentation

void BT::PublisherZMQ::callback	(	Duration	timestamp,
		const TreeNode &	node,
		NodeStatus	prev_status,
		NodeStatus	status
	)

overrideprivatevirtual

Implements BT::StatusChangeLogger.

Definition at line 105 of file bt_zmq_publisher.cpp.

void BT::PublisherZMQ::createStatusBuffer ( )

private

Definition at line 93 of file bt_zmq_publisher.cpp.

void BT::PublisherZMQ::flush ( )

overrideprivatevirtual

Implements BT::StatusChangeLogger.

Definition at line 127 of file bt_zmq_publisher.cpp.

Member Data Documentation

std::atomic_bool BT::PublisherZMQ::active_server_

private

Definition at line 32 of file bt_zmq_publisher.h.

TimePoint BT::PublisherZMQ::deadline_

private

Definition at line 37 of file bt_zmq_publisher.h.

std::chrono::microseconds BT::PublisherZMQ::min_time_between_msgs_

private

Definition at line 30 of file bt_zmq_publisher.h.

std::mutex BT::PublisherZMQ::mutex_

private

Definition at line 38 of file bt_zmq_publisher.h.

std::atomic< bool > BT::PublisherZMQ::ref_count

staticprivate

Definition at line 13 of file bt_zmq_publisher.h.

TreeNode* BT::PublisherZMQ::root_node_

private

Definition at line 26 of file bt_zmq_publisher.h.

std::future<void> BT::PublisherZMQ::send_future_

private

Definition at line 41 of file bt_zmq_publisher.h.

std::atomic_bool BT::PublisherZMQ::send_pending_

private

Definition at line 39 of file bt_zmq_publisher.h.

std::vector<uint8_t> BT::PublisherZMQ::status_buffer_

private

Definition at line 28 of file bt_zmq_publisher.h.

std::thread BT::PublisherZMQ::thread_

private

Definition at line 33 of file bt_zmq_publisher.h.

std::vector<SerializedTransition> BT::PublisherZMQ::transition_buffer_

private

Definition at line 29 of file bt_zmq_publisher.h.

std::vector<uint8_t> BT::PublisherZMQ::tree_buffer_

private

Definition at line 27 of file bt_zmq_publisher.h.

Pimpl* BT::PublisherZMQ::zmq_

private

Definition at line 43 of file bt_zmq_publisher.h.

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

Classes

Public Member Functions

Private Member Functions

Private Attributes

Static Private Attributes

Detailed Description

Constructor & Destructor Documentation

Member Function Documentation

Member Data Documentation