BT::PublisherZMQ Class Reference

#include <bt_zmq_publisher.h>

Inheritance diagram for BT::PublisherZMQ:

List of all members.

Classes
struct	Pimpl
Public Member Functions
	PublisherZMQ (TreeNode *root_node, int max_msg_per_second=25)
virtual	~PublisherZMQ ()
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
	)		[override, private, virtual]

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

(

)

[override, private, virtual]

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 [static, private]

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:

• bt_zmq_publisher.h
• bt_zmq_publisher.cpp