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...
|
| |