Thread for reading knowledge updates via waitsets. More...

#include <SpliceTransportReadThread.h>

Inheritance diagram for madara::transport::SpliceReadThread:

Public Member Functions
	SpliceReadThread (const std::string &id, const TransportSettings &settings, knowledge::ThreadSafeContext &context, Knowledge::UpdateDataReader_ptr &update_reader, Knowledge::UpdateDataWriter_ptr &update_writer, BandwidthMonitor &send_monitor, BandwidthMonitor &receive_monitor, PacketScheduler &packet_scheduler)
	Constructor. More...

void	cleanup (void)
	Cleanup function called by thread manager. More...

void	init (knowledge::KnowledgeBase &knowledge)
	Initializes MADARA context-related items. More...

void	rebroadcast (const char print_prefix, MessageHeader header, const knowledge::KnowledgeMap &records)
	Sends a rebroadcast packet. More...

void	run (void)
	The main loop internals for the read thread. More...

Public Attributes
::std::vector< ::std::string >	assignment_symbols_
	We currently allow multiassignments completely through the key. More...

madara::utility::ScopedArray< char >	buffer_
	buffer for receiving More...

knowledge::ThreadSafeContext *	context_
	The knowledge context that we will be updating. More...

const std::string	id_
	Unique identifier for this entity (e.g., host:port) More...

knowledge::CompiledExpression	on_data_received_
	data received rules, defined in Transport settings More...

PacketScheduler &	packet_scheduler_
	scheduler for mimicking target network conditions More...

BandwidthMonitor &	receive_monitor_
	monitor for receiving bandwidth usage More...

BandwidthMonitor &	send_monitor_
	monitor for sending bandwidth usage More...

const QoSTransportSettings	settings_
	Transport settings. More...

::Knowledge::UpdateDataReader_var	update_reader_
	The DDS data reader that we will take from. More...

::Knowledge::UpdateDataWriter_var	update_writer_
	The DDS data writer that we can write to. More...

Protected Member Functions
virtual void	init_control_vars (knowledge::KnowledgeBase &control)
	Initializes the thread implementation's control plane variables. More...

Protected Attributes
std::string	name
	The unique name of your thread. More...

madara::knowledge::containers::Integer	paused
	thread safe paused flag that may be set by the Threader More...

madara::knowledge::containers::Integer	terminated
	thread safe terminated flag that may be set by the Threader base More...

Detailed Description

Thread for reading knowledge updates via waitsets.

Definition at line 33 of file SpliceTransportReadThread.h.

Constructor & Destructor Documentation

◆ SpliceReadThread()

madara::transport::SpliceReadThread::SpliceReadThread	(	const std::string &	id,
		const TransportSettings &	settings,
		knowledge::ThreadSafeContext &	context,
		Knowledge::UpdateDataReader_ptr &	update_reader,
		Knowledge::UpdateDataWriter_ptr &	update_writer,
		BandwidthMonitor &	send_monitor,
		BandwidthMonitor &	receive_monitor,
		PacketScheduler &	packet_scheduler
	)

Constructor.

Parameters

id	unique identifier of this participant (e.g., host:port)
context	where to store and access knowledge
update_reader	reader created in

See also: SpliceDDSTransport

Parameters

update_writer writer created in

See also: SpliceDDSTransport

Parameters

settings	Transport settings
send_monitor	bandwidth monitor for enforcing send limits
receive_monitor	bandwidth monitor for enforcing receive limits
packet_scheduler	scheduler for mimicking network conditions

Definition at line 12 of file SpliceTransportReadThread.cpp.

Member Function Documentation

◆ cleanup()

void madara::transport::SpliceReadThread::cleanup ( void )

virtual

Cleanup function called by thread manager.

Reimplemented from madara::threads::BaseThread.

Definition at line 63 of file SpliceTransportReadThread.cpp.

◆ init()

void madara::transport::SpliceReadThread::init ( knowledge::KnowledgeBase & knowledge )

virtual

Initializes MADARA context-related items.

Parameters

knowledge context for querying current program state

Reimplemented from madara::threads::BaseThread.

Definition at line 30 of file SpliceTransportReadThread.cpp.

◆ init_control_vars()

virtual void madara::threads::BaseThread::init_control_vars ( knowledge::KnowledgeBase & control )

inlineprotectedvirtualinherited

Initializes the thread implementation's control plane variables.

Parameters

control the control plane between Threader and threads

Reimplemented in madara::threads::JavaThread.

Definition at line 78 of file BaseThread.h.

◆ rebroadcast()

void madara::transport::SpliceReadThread::rebroadcast	(	const char *	print_prefix,
		MessageHeader *	header,
		const knowledge::KnowledgeMap &	records
	)

Sends a rebroadcast packet.

Parameters

print_prefix	prefix to include before every log message, e.g., "MyTransport::svc"
header	header for the rebroadcasted packet
records	records to rebroadcast (already filtered for rebroadcast)

get current lamport clock.

Definition at line 65 of file SpliceTransportReadThread.cpp.