Base class from which all transports must be derived. More...

#include <Transport.h>

Inheritance diagram for madara::transport::Base:

[legend]

Collaboration diagram for madara::transport::Base:

[legend]

Public Types
typedef std::vector< std::string >	HostsVector
	Used to define a vector of hosts to contact. More...

Public Member Functions
	Base (const std::string &id, TransportSettings &new_settings, knowledge::ThreadSafeContext &context)
	Constructor. More...

virtual	~Base ()
	Destructor. More...

int	check_transport (void)
	all subclasses should call this method at the beginning of send_data More...

virtual void	close (void)
	Closes this transport. More...

void	invalidate_transport (void)
	Invalidates a transport to indicate it is shutting down. More...

long	prep_send (const madara::knowledge::KnowledgeRecords &orig_updates, const char *print_prefix)
	Preps a message for sending. More...

virtual long	send_data (const madara::knowledge::KnowledgeRecords &)=0
	Sends a list of updates to the domain. More...

TransportSettings &	settings (void)
	Getter for the transport settings. More...

virtual int	setup (void)
	all subclasses should call this method at the end of its setup More...

int	validate_transport (void)
	Validates a transport to indicate it is not shutting down. More...

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

madara::knowledge::ThreadSafeContext &	context_

HostsVector	hosts

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

volatile bool	is_valid_

ACE_Thread_Mutex	mutex_

madara::expression::ExpressionTree	on_data_received_
	data received rules, defined in Transport settings More...

PacketScheduler	packet_scheduler_
	scheduler for dropping packets to simulate network issues More...

BandwidthMonitor	receive_monitor_
	monitor for receiving bandwidth usage More...

BandwidthMonitor	send_monitor_
	monitor for sending bandwidth usage More...

QoSTransportSettings	settings_

volatile bool	shutting_down_

Condition	valid_setup_

Detailed Description

Base class from which all transports must be derived.

To support knowledge updates, only the send_multiassignment method is currently required to be extended as the set, evaluate, and wait methods all call send_multiassignment. For example transport,

See also: madara::transport::MulticastTransport.

Definition at line 62 of file Transport.h.

Member Typedef Documentation

typedef std::vector<std::string> madara::transport::Base::HostsVector

Used to define a vector of hosts to contact.

Definition at line 68 of file Transport.h.

Constructor & Destructor Documentation

madara::transport::Base::Base	(	const std::string &	id,
		TransportSettings &	new_settings,
		knowledge::ThreadSafeContext &	context
	)

Constructor.

Parameters

id	unique identifier (generally host:port)
new_settings	settings to apply to the transport
context	the knowledge record context

Definition at line 9 of file Transport.cpp.

madara::transport::Base::~Base ( )

virtual

Destructor.

Definition at line 28 of file Transport.cpp.

Member Function Documentation

int madara::transport::Base::check_transport ( void )

inline

all subclasses should call this method at the beginning of send_data

Definition at line 19 of file Transport.inl.

void madara::transport::Base::close ( void )

virtual

Closes this transport.

Reimplemented in madara::transport::UdpRegistryClient, madara::transport::SpliceDDSTransport, madara::transport::UdpTransport, madara::transport::UdpRegistryServer, madara::transport::ZMQTransport, madara::transport::MulticastTransport, madara::transport::BroadcastTransport, madara::transport::TcpTransport, and madara::transport::NddsTransport.

Definition at line 106 of file Transport.cpp.

void madara::transport::Base::invalidate_transport ( void )

inline

Invalidates a transport to indicate it is shutting down.

Definition at line 34 of file Transport.inl.

long madara::transport::Base::prep_send	(	const madara::knowledge::KnowledgeRecords &	orig_updates,
		const char *	print_prefix
	)

Preps a message for sending.

Parameters

orig_updates	updates before send filtering is applied
print_prefix	prefix to include before every log message, e.g., "MyTransport::svc"

Returns: -1 Transport is shutting down
-2 Transport is invalid
-3 Unable to allocate send buffer
0 No message to send > 0 size of buffered message

filter the updates according to the filters specified by the user in QoSTransportSettings (if applicable)

size = buffer[0] (unsigned 64 bit) transport id = buffer[8] (8 byte) domain = buffer[16] (32 byte domain name) originator = buffer[48] (64 byte originator host:port) type = buffer[112] (unsigned 32 bit type of message–usually MULTIASSIGN) updates = buffer[116] (unsigned 32 bit number of updates) quality = buffer[120] (unsigned 32 bit quality of message) clock = buffer[124] (unsigned 64 bit clock for this message) ttl = buffer[132] (the new knowledge starts here) knowledge = buffer[133] (the new knowledge starts here)

Definition at line 815 of file Transport.cpp.

virtual long madara::transport::Base::send_data ( const madara::knowledge::KnowledgeRecords & )

pure virtual

Sends a list of updates to the domain.

This function must be implemented by your transport

Returns: result of operation or -1 if we are shutting down

Implemented in madara::transport::UdpRegistryClient, madara::transport::UdpTransport, madara::transport::ZMQTransport, madara::transport::MulticastTransport, madara::transport::BroadcastTransport, madara::transport::UdpRegistryServer, madara::transport::SpliceDDSTransport, madara::transport::TcpTransport, and madara::transport::NddsTransport.

madara::transport::TransportSettings & madara::transport::Base::settings ( void )

inline

Getter for the transport settings.

Returns: the current transport settings

Definition at line 45 of file Transport.inl.

int madara::transport::Base::setup ( void )

virtual

all subclasses should call this method at the end of its setup

Reimplemented in madara::transport::SpliceDDSTransport, madara::transport::UdpRegistryClient, madara::transport::ZMQTransport, madara::transport::MulticastTransport, madara::transport::BroadcastTransport, madara::transport::UdpTransport, madara::transport::UdpRegistryServer, madara::transport::NddsTransport, and madara::transport::TcpTransport.

Definition at line 33 of file Transport.cpp.

int madara::transport::Base::validate_transport ( void )

inline

Validates a transport to indicate it is not shutting down.

Definition at line 6 of file Transport.inl.

Member Data Documentation

madara::utility::ScopedArray<char> madara::transport::Base::buffer_

protected

buffer for sending

Definition at line 209 of file Transport.h.

madara::knowledge::ThreadSafeContext& madara::transport::Base::context_

protected

Definition at line 191 of file Transport.h.

HostsVector madara::transport::Base::hosts

protected

Definition at line 181 of file Transport.h.

const std::string madara::transport::Base::id_

protected

host:port identifier of this process

Definition at line 186 of file Transport.h.

volatile bool madara::transport::Base::is_valid_

protected

Definition at line 179 of file Transport.h.

ACE_Thread_Mutex madara::transport::Base::mutex_

protected

Definition at line 182 of file Transport.h.

madara::expression::ExpressionTree madara::transport::Base::on_data_received_

protected

data received rules, defined in Transport settings

Definition at line 195 of file Transport.h.

PacketScheduler madara::transport::Base::packet_scheduler_

protected

scheduler for dropping packets to simulate network issues

Definition at line 206 of file Transport.h.

BandwidthMonitor madara::transport::Base::receive_monitor_

protected

monitor for receiving bandwidth usage

Definition at line 203 of file Transport.h.

BandwidthMonitor madara::transport::Base::send_monitor_

protected

monitor for sending bandwidth usage

Definition at line 200 of file Transport.h.

QoSTransportSettings madara::transport::Base::settings_

protected

Definition at line 188 of file Transport.h.

volatile bool madara::transport::Base::shutting_down_

protected

Definition at line 180 of file Transport.h.

Condition madara::transport::Base::valid_setup_

protected

Definition at line 183 of file Transport.h.

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

include/madara/transport/Transport.h
include/madara/transport/Transport.cpp
include/madara/transport/Transport.inl

Public Types

Public Member Functions

Protected Attributes

Detailed Description

Member Typedef Documentation

Constructor & Destructor Documentation

Member Function Documentation

Member Data Documentation