MADARA
3.4.1
|
ZMQ-based transport for knowledge. More...
#include <ZMQTransport.h>
Public Types | |
typedef std::vector< std::string > | HostsVector |
Used to define a vector of hosts to contact. More... | |
Public Member Functions | |
ZMQTransport (const std::string &id, madara::knowledge::ThreadSafeContext &context, TransportSettings &config, bool launch_transport) | |
Constructor. More... | |
virtual | ~ZMQTransport () |
Destructor. More... | |
int | check_transport (void) |
all subclasses should call this method at the beginning of send_data More... | |
virtual void | close (void) override |
Closes the transport. More... | |
void | invalidate_transport (void) |
Invalidates a transport to indicate it is shutting down. More... | |
long | prep_send (const knowledge::KnowledgeMap &orig_updates, const char *print_prefix) |
Preps a message for sending. More... | |
int | reliability (const int &setting) |
Sets the reliability setting. More... | |
int | reliability (void) const |
Accesses reliability setting. More... | |
long | send_data (const madara::knowledge::KnowledgeMap &updates) override |
Sends a list of knowledge updates to listeners. More... | |
TransportSettings & | settings (void) |
Getter for the transport settings. More... | |
virtual int | setup (void) override |
Initializes the transport. 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_ |
uint64_t | last_toi_sent_ = 0 |
Latest TOI the previous send operation included. 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... | |
BandwidthMonitor | receive_monitor_ |
monitor for receiving bandwidth usage More... | |
BandwidthMonitor | send_monitor_ |
monitor for sending bandwidth usage More... | |
QoSTransportSettings | settings_ |
volatile bool | shutting_down_ |
Private Attributes | |
knowledge::containers::Integer | failed_sends_ |
failed sends More... | |
knowledge::KnowledgeBase | knowledge_ |
knowledge base for threads to use More... | |
threads::Threader | read_threads_ |
threads for reading knowledge updates More... | |
knowledge::containers::Integer | sent_data_ |
sent data More... | |
knowledge::containers::Integer | sent_data_max_ |
max data sent More... | |
knowledge::containers::Integer | sent_data_min_ |
min data sent More... | |
knowledge::containers::Integer | sent_packets_ |
sent packets More... | |
void * | write_socket_ |
underlying socket for sending More... | |
ZMQ-based transport for knowledge.
This transport currently supports the following transport settings:
1) a single host:port pairing
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 43 of file ZMQTransport.h.
|
inherited |
Used to define a vector of hosts to contact.
Definition at line 51 of file Transport.h.
madara::transport::ZMQTransport::ZMQTransport | ( | 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 16 of file ZMQTransport.cpp.
|
virtual |
Destructor.
Definition at line 46 of file ZMQTransport.cpp.
|
inlineinherited |
all subclasses should call this method at the beginning of send_data
Definition at line 17 of file Transport.inl.
|
overridevirtual |
Closes the transport.
Reimplemented from madara::transport::Base.
Definition at line 54 of file ZMQTransport.cpp.
|
inlineinherited |
Invalidates a transport to indicate it is shutting down.
Definition at line 31 of file Transport.inl.
|
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 860 of file Transport.cpp.
int madara::transport::ZMQTransport::reliability | ( | const int & | setting | ) |
Sets the reliability setting.
Definition at line 94 of file ZMQTransport.cpp.
int madara::transport::ZMQTransport::reliability | ( | void | ) | const |
Accesses reliability setting.
Definition at line 89 of file ZMQTransport.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 253 of file ZMQTransport.cpp.
|
inlineinherited |
Getter for the transport settings.
Definition at line 40 of file Transport.inl.
|
overridevirtual |
Initializes the transport.
Reimplemented from madara::transport::Base.
Definition at line 99 of file ZMQTransport.cpp.
|
inlineinherited |
Validates a transport to indicate it is not shutting down.
Definition at line 6 of file Transport.inl.
|
protectedinherited |
buffer for sending
Definition at line 153 of file Transport.h.
|
protectedinherited |
Definition at line 135 of file Transport.h.
|
private |
failed sends
Definition at line 107 of file ZMQTransport.h.
|
protectedinherited |
Definition at line 127 of file Transport.h.
|
protectedinherited |
host:port identifier of this process
Definition at line 130 of file Transport.h.
|
protectedinherited |
Definition at line 125 of file Transport.h.
|
private |
knowledge base for threads to use
Definition at line 95 of file ZMQTransport.h.
|
protectedinherited |
Latest TOI the previous send operation included.
Definition at line 156 of file Transport.h.
|
protectedinherited |
data received rules, defined in Transport settings
Definition at line 139 of file Transport.h.
|
protectedinherited |
scheduler for dropping packets to simulate network issues
Definition at line 150 of file Transport.h.
|
private |
threads for reading knowledge updates
Definition at line 98 of file ZMQTransport.h.
|
protectedinherited |
monitor for receiving bandwidth usage
Definition at line 147 of file Transport.h.
|
protectedinherited |
monitor for sending bandwidth usage
Definition at line 144 of file Transport.h.
|
private |
sent data
Definition at line 110 of file ZMQTransport.h.
|
private |
max data sent
Definition at line 113 of file ZMQTransport.h.
|
private |
min data sent
Definition at line 116 of file ZMQTransport.h.
|
private |
sent packets
Definition at line 104 of file ZMQTransport.h.
|
protectedinherited |
Definition at line 132 of file Transport.h.
|
protectedinherited |
Definition at line 126 of file Transport.h.
|
private |
underlying socket for sending
Definition at line 101 of file ZMQTransport.h.