Go to the source code of this file.
|
| madara |
| Copyright (c) 2015 Carnegie Mellon University.
|
|
| madara::transport |
| Provides the network transport layer for knowledge bases to communicate within and across agents.
|
|
|
int | madara::transport::prep_rebroadcast (knowledge::ThreadSafeContext &context, char *buffer, int64_t &buffer_remaining, const QoSTransportSettings &settings, const char *print_prefix, MessageHeader *header, const knowledge::KnowledgeMap &records, PacketScheduler &packet_scheduler) |
| Preps a buffer for rebroadcasting records to other agents on the network. More...
|
|
int | madara::transport::process_received_update (const char *buffer, uint32_t bytes_read, const std::string &id, knowledge::ThreadSafeContext &context, const QoSTransportSettings &settings, BandwidthMonitor &send_monitor, BandwidthMonitor &receive_monitor, knowledge::KnowledgeMap &rebroadcast_records, knowledge::CompiledExpression &on_data_received,const char *print_prefix, const char *remote_host, MessageHeader *&header) |
| Processes a received update, updates monitors, fills rebroadcast records according to settings filters, and performs the bulk of the logic required for a receiver thread. More...
|
|