Thread for reading registry updates through a UDP socket. More...

Inheritance diagram for madara::transport::UdpRegistryServerReadThread:

Collaboration diagram for madara::transport::UdpRegistryServerReadThread:

[legend]

Public Member Functions
	UdpRegistryServerReadThread (const TransportSettings &settings, const std::string &id, std::map< std::string, ACE_INET_Addr > &addresses, ACE_SOCK_Dgram &write_socket, ACE_SOCK_Dgram &read_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 to all peers. 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
std::map< std::string, ACE_INET_Addr > &	addresses_
	internet addresses of our peers 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...

ACE_SOCK_Dgram &	read_socket_
	The 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 QoSTransportSettings	settings_
	Transport settings. More...

ACE_SOCK_Dgram &	write_socket_
	The socket we are writing to. More...

Detailed Description

Thread for reading registry updates through a UDP socket.

Constructor & Destructor Documentation

madara::transport::UdpRegistryServerReadThread::UdpRegistryServerReadThread	(	const TransportSettings &	settings,
		const std::string &	id,
		std::map< std::string, ACE_INET_Addr > &	addresses,
		ACE_SOCK_Dgram &	write_socket,
		ACE_SOCK_Dgram &	read_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
addresses	the ACE socket addresses to communicate with
write_socket	socket for sending
read_socket	socket for receiving
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::UdpRegistryServerReadThread::cleanup ( void )

virtual

Cleanup function called by thread manager.

void madara::transport::UdpRegistryServerReadThread::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::UdpRegistryServerReadThread::rebroadcast	(	const char *	print_prefix,
		MessageHeader *	header,
		const knowledge::KnowledgeMap &	records
	)

Sends a rebroadcast packet to all peers.

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::UdpRegistryServerReadThread::run ( void )

virtual

The main loop internals for the read thread.