Thread for reading knowledge updates through a Multicast datagram socket. More...

Inheritance diagram for madara::transport::BroadcastTransportReadThread:

Collaboration diagram for madara::transport::BroadcastTransportReadThread:

[legend]

Public Member Functions
	BroadcastTransportReadThread (const TransportSettings &settings, const std::string &id, const ACE_INET_Addr &address, ACE_SOCK_Dgram_Bcast &socket, 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...

Protected Member Functions
virtual void	init_control_vars (knowledge::KnowledgeBase &control)
	Initializes the Java 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...

Private Attributes
ACE_INET_Addr	address_
	The broadcast address we are subscribing to. More...

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

knowledge::ThreadSafeContext *	context_
	knowledge context More...

const std::string	id_
	host:port identifier of this process More...

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

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

const QoSTransportSettings *	qos_settings_
	pointer to qos_settings (if applicable) More...

ACE_SOCK_Dgram	read_socket_
	The broadcast socket we are reading from. More...

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

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

const TransportSettings &	settings_
	Transport settings. More...

ACE_SOCK_Dgram_Bcast	write_socket_
	underlying socket for rebroadcasting More...

Detailed Description

Thread for reading knowledge updates through a Multicast datagram socket.

Constructor & Destructor Documentation

madara::transport::BroadcastTransportReadThread::BroadcastTransportReadThread	(	const TransportSettings &	settings,
		const std::string &	id,
		const ACE_INET_Addr &	address,
		ACE_SOCK_Dgram_Bcast &	socket,
		BandwidthMonitor &	send_monitor,
		BandwidthMonitor &	receive_monitor,
		PacketScheduler &	packet_scheduler
	)

Constructor.

Parameters

settings	Transport settings
id	host:port identifier of this process, to allow for rejection of duplicates
address	the ACE socket address to read from
socket	socket for sending
send_monitor	bandwidth monitor for enforcing send limits
receive_monitor	bandwidth monitor for enforcing receive limits
packet_scheduler	scheduler for mimicking network conditions

void madara::transport::BroadcastTransportReadThread::cleanup ( void )

virtual

Cleanup function called by thread manager.

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

virtual

Initializes MADARA context-related items.

Parameters

knowledge context for querying current program state

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

inlineprotectedvirtualinherited

Initializes the Java thread implementation's control plane variables.

Parameters

control the control plane between Threader and threads

Definition at line 86 of file BaseThread.h.

void madara::transport::BroadcastTransportReadThread::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)

void madara::transport::BroadcastTransportReadThread::run ( void )

virtual

The main loop internals for the read thread.