BT::PublisherZMQ Class Reference

#include <bt_zmq_publisher.h>

Inheritance diagram for BT::PublisherZMQ:

Classes
struct	Pimpl

Public Member Functions
	PublisherZMQ (const BT::Tree &tree, unsigned max_msg_per_second=25, unsigned publisher_port=1666, unsigned server_port=1667)
virtual	~PublisherZMQ ()
Public Member Functions inherited from BT::StatusChangeLogger
bool	enabled () const
void	enableTransitionToIdle (bool enable)
void	setEnabled (bool enabled)
void	setTimestampType (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_
std::future< void >	send_future_
std::atomic_bool	send_pending_
std::vector< uint8_t >	status_buffer_
std::thread	thread_
std::vector< SerializedTransition >	transition_buffer_
const BT::Tree &	tree_
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	(	const BT::Tree &	tree,
		unsigned	max_msg_per_second = 25,
		unsigned	publisher_port = 1666,
		unsigned	server_port = 1667
	)

Definition at line 24 of file bt_zmq_publisher.cpp.

BT::PublisherZMQ::~PublisherZMQ ( )

virtual

Definition at line 91 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 117 of file bt_zmq_publisher.cpp.

void BT::PublisherZMQ::createStatusBuffer ( )

private

Definition at line 105 of file bt_zmq_publisher.cpp.

void BT::PublisherZMQ::flush ( )

overrideprivatevirtual

Implements BT::StatusChangeLogger.

Definition at line 139 of file bt_zmq_publisher.cpp.

Member Data Documentation

std::atomic_bool BT::PublisherZMQ::active_server_

private

Definition at line 35 of file bt_zmq_publisher.h.

TimePoint BT::PublisherZMQ::deadline_

private

Definition at line 40 of file bt_zmq_publisher.h.

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

private

Definition at line 33 of file bt_zmq_publisher.h.

std::mutex BT::PublisherZMQ::mutex_

private

Definition at line 41 of file bt_zmq_publisher.h.

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

staticprivate

Definition at line 13 of file bt_zmq_publisher.h.

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

private

Definition at line 44 of file bt_zmq_publisher.h.

std::atomic_bool BT::PublisherZMQ::send_pending_

private

Definition at line 42 of file bt_zmq_publisher.h.

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

private

Definition at line 31 of file bt_zmq_publisher.h.

std::thread BT::PublisherZMQ::thread_

private

Definition at line 36 of file bt_zmq_publisher.h.

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

private

Definition at line 32 of file bt_zmq_publisher.h.

const BT::Tree& BT::PublisherZMQ::tree_

private

Definition at line 29 of file bt_zmq_publisher.h.

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

private

Definition at line 30 of file bt_zmq_publisher.h.

Pimpl* BT::PublisherZMQ::zmq_

private

Definition at line 46 of file bt_zmq_publisher.h.

---

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

• bt_zmq_publisher.h
• bt_zmq_publisher.cpp