UdpTransportReadThread.h

Go to the documentation of this file.

#ifndef _MADARA_UDP_TRANSPORT_READ_THREAD_H_
#define _MADARA_UDP_TRANSPORT_READ_THREAD_H_
 
#include <string>
 
#include "madara/utility/ScopedArray.h"
#include "madara/knowledge/ThreadSafeContext.h"
#include "madara/transport/BandwidthMonitor.h"
#include "madara/transport/QoSTransportSettings.h"
#include "madara/expression/ExpressionTree.h"
#include "madara/transport/Transport.h"
#include "madara/transport/MessageHeader.h"
#include "madara/transport/udp/UdpTransport.h"
#include "madara/threads/BaseThread.h"
#include "madara/Boost.h"
 
namespace madara
{
namespace transport
{
namespace asio = boost::asio;
namespace ip = boost::asio::ip;
using udp = boost::asio::ip::udp;
 
class UdpTransportReadThread : public threads::BaseThread
{
public:
  UdpTransportReadThread(UdpTransport& transport);
 
  void init(knowledge::KnowledgeBase& knowledge) override;
 
  void cleanup(void) override;
 
  void run(void) override;
 
  void rebroadcast(const char* print_prefix, MessageHeader* header,
      const knowledge::KnowledgeMap& records);
 
protected:
  UdpTransport& transport_;
 
  knowledge::ThreadSafeContext* context_ = nullptr;
 
#ifndef _MADARA_NO_KARL_
  madara::knowledge::CompiledExpression on_data_received_;
#endif  // _MADARA_NO_KARL_
 
  madara::utility::ScopedArray<char> buffer_;
 
  knowledge::containers::Integer received_packets_;
 
  knowledge::containers::Integer failed_receives_;
 
  knowledge::containers::Integer received_data_;
 
  knowledge::containers::Integer received_data_max_;
 
  knowledge::containers::Integer received_data_min_;
};
}
}
 
#endif  // _MADARA_UDP_TRANSPORT_READ_THREAD_H_