MADARA
3.2.3
|
UDP-based transport for knowledge. More...
#include <UdpRegistryClient.h>
Public Types | |
enum | { ERROR_UDP_NOT_STARTED = -1 } |
typedef std::vector< std::string > | HostsVector |
Used to define a vector of hosts to contact. More... | |
Public Member Functions | |
UdpRegistryClient (const std::string &id, madara::knowledge::ThreadSafeContext &context, TransportSettings &config, bool launch_transport) | |
Constructor. More... | |
int | check_transport (void) |
all subclasses should call this method at the beginning of send_data More... | |
void | close () override |
Closes this transport. More... | |
void | invalidate_transport (void) |
Invalidates a transport to indicate it is shutting down. More... | |
long | prep_send (const knowledge::VariableReferenceMap &orig_updates, const char *print_prefix) |
Preps a message for sending. More... | |
int | reliability (void) const |
Accesses reliability setting. More... | |
int | reliability (const int &setting) |
Sets the reliability setting. More... | |
long | send_data (const madara::knowledge::VariableReferenceMap &updates) override |
Sends a list of knowledge updates to listeners. More... | |
void | send_register (void) |
Sends register messages to all servers. More... | |
TransportSettings & | settings (void) |
Getter for the transport settings. More... | |
int | setup (void) override |
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... | |
Static Public Attributes | |
static const double | default_read_hertz |
static const int | PROFILES = 1 |
Protected Member Functions | |
virtual bool | pre_send_buffer (size_t addr_index) |
long | send_buffer (const udp::endpoint &target, const char *buf, size_t size) |
long | send_message (const char *buf, size_t size) |
int | setup_read_socket () override |
int | setup_read_thread (double hertz, const std::string &name) override |
virtual int | setup_read_threads () |
virtual int | setup_socket (udp::socket &socket) |
virtual int | setup_sockets () |
int | setup_write_socket () override |
Protected Attributes | |
std::vector< udp::endpoint > | addresses_ |
holds all multicast addresses we are sending to More... | |
madara::utility::ScopedArray< char > | buffer_ |
buffer for sending More... | |
madara::knowledge::ThreadSafeContext & | context_ |
knowledge::containers::Map | endpoints_ |
HostsVector | hosts |
const std::string | id_ |
host:port identifier of this process More... | |
asio::io_service | io_service_ |
Boost::ASIO IO context. More... | |
volatile bool | is_valid_ |
knowledge::KnowledgeBase | knowledge_ |
knowledge base for threads to use More... | |
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... | |
threads::Threader | read_threads_ |
threads for reading knowledge updates More... | |
BandwidthMonitor | receive_monitor_ |
monitor for receiving bandwidth usage More... | |
BandwidthMonitor | send_monitor_ |
monitor for sending bandwidth usage More... | |
std::vector< udp::endpoint > | servers_ |
registry servers More... | |
QoSTransportSettings | settings_ |
volatile bool | shutting_down_ |
udp::socket | socket_ {io_service_} |
underlying socket More... | |
UDP-based transport for knowledge.
This transport currently supports the following transport settings:
1) multiple host:port pairing with self first in vector
2) the reduced message header
3) the normal message header
4) domain differentiation
5) on data received logic
6) multi-assignment of records
7) rebroadcasting
Definition at line 31 of file UdpRegistryClient.h.
|
inherited |
Used to define a vector of hosts to contact.
Definition at line 51 of file Transport.h.
anonymous enum |
Enumerator | |
---|---|
ERROR_UDP_NOT_STARTED |
Definition at line 34 of file UdpRegistryClient.h.
madara::transport::UdpRegistryClient::UdpRegistryClient | ( | const std::string & | id, |
madara::knowledge::ThreadSafeContext & | context, | ||
TransportSettings & | config, | ||
bool | launch_transport | ||
) |
Constructor.
id | unique identifer - usually a combination of host:port |
context | knowledge context |
config | transport configuration settings |
launch_transport | whether or not to launch this transport |
Definition at line 13 of file UdpRegistryClient.cpp.
|
inlineinherited |
all subclasses should call this method at the beginning of send_data
Definition at line 18 of file Transport.inl.
|
overridevirtualinherited |
Closes this transport.
Reimplemented from madara::transport::Base.
Definition at line 38 of file BasicASIOTransport.cpp.
|
inlineinherited |
Invalidates a transport to indicate it is shutting down.
Definition at line 33 of file Transport.inl.
|
inlineprotectedvirtualinherited |
Reimplemented in madara::transport::MulticastTransport, and madara::transport::BroadcastTransport.
Definition at line 70 of file UdpTransport.h.
|
inherited |
Preps a message for sending.
orig_updates | updates before send filtering is applied |
print_prefix | prefix to include before every log message, e.g., "MyTransport::svc" |
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 812 of file Transport.cpp.
|
inherited |
Accesses reliability setting.
Definition at line 23 of file UdpTransport.cpp.
|
inherited |
Sets the reliability setting.
Definition at line 29 of file UdpTransport.cpp.
|
protectedinherited |
Definition at line 86 of file UdpTransport.cpp.
|
overridevirtual |
Sends a list of knowledge updates to listeners.
updates | listing of all updates that must be sent |
Implements madara::transport::Base.
Definition at line 117 of file UdpRegistryClient.cpp.
|
protectedinherited |
Definition at line 129 of file UdpTransport.cpp.
void madara::transport::UdpRegistryClient::send_register | ( | void | ) |
Sends register messages to all servers.
Definition at line 57 of file UdpRegistryClient.cpp.
|
inlineinherited |
Getter for the transport settings.
Definition at line 43 of file Transport.inl.
|
overridevirtual |
all subclasses should call this method at the end of its setup
Reimplemented from madara::transport::BasicASIOTransport.
Definition at line 25 of file UdpRegistryClient.cpp.
|
overrideprotectedvirtualinherited |
Reimplemented from madara::transport::BasicASIOTransport.
Definition at line 48 of file UdpTransport.cpp.
|
overrideprotectedvirtualinherited |
Implements madara::transport::BasicASIOTransport.
Definition at line 35 of file UdpTransport.cpp.
|
protectedvirtualinherited |
Definition at line 220 of file BasicASIOTransport.cpp.
|
protectedvirtualinherited |
Definition at line 123 of file BasicASIOTransport.cpp.
|
protectedvirtualinherited |
Definition at line 205 of file BasicASIOTransport.cpp.
|
overrideprotectedvirtualinherited |
Reimplemented from madara::transport::BasicASIOTransport.
Definition at line 76 of file UdpTransport.cpp.
|
inlineinherited |
Validates a transport to indicate it is not shutting down.
Definition at line 6 of file Transport.inl.
|
protectedinherited |
holds all multicast addresses we are sending to
Definition at line 59 of file BasicASIOTransport.h.
|
protectedinherited |
buffer for sending
Definition at line 154 of file Transport.h.
|
protectedinherited |
Definition at line 136 of file Transport.h.
|
staticinherited |
Definition at line 38 of file BasicASIOTransport.h.
|
protected |
Definition at line 69 of file UdpRegistryClient.h.
|
protectedinherited |
Definition at line 128 of file Transport.h.
|
protectedinherited |
host:port identifier of this process
Definition at line 131 of file Transport.h.
|
protectedinherited |
Boost::ASIO IO context.
Definition at line 53 of file BasicASIOTransport.h.
|
protectedinherited |
Definition at line 126 of file Transport.h.
|
protectedinherited |
knowledge base for threads to use
Definition at line 50 of file BasicASIOTransport.h.
|
protectedinherited |
data received rules, defined in Transport settings
Definition at line 140 of file Transport.h.
|
protectedinherited |
scheduler for dropping packets to simulate network issues
Definition at line 151 of file Transport.h.
|
static |
Definition at line 38 of file UdpRegistryClient.h.
|
protectedinherited |
threads for reading knowledge updates
Definition at line 56 of file BasicASIOTransport.h.
|
protectedinherited |
monitor for receiving bandwidth usage
Definition at line 148 of file Transport.h.
|
protectedinherited |
monitor for sending bandwidth usage
Definition at line 145 of file Transport.h.
|
protected |
registry servers
Definition at line 67 of file UdpRegistryClient.h.
|
protectedinherited |
Definition at line 133 of file Transport.h.
|
protectedinherited |
Definition at line 127 of file Transport.h.
|
protectedinherited |
underlying socket
Definition at line 62 of file BasicASIOTransport.h.