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_;
    };
  }
}

#endif // _MADARA_UDP_TRANSPORT_READ_THREAD_H_