ZMQTransportReadThread.h

Go to the documentation of this file.

#ifndef _MADARA_ZEROMQ_TRANSPORT_READ_THREAD_H_
#define _MADARA_ZEROMQ_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/threads/BaseThread.h"

#include "ace/Task.h"
#include "ace/Mutex.h"
#include "ace/Barrier.h"
#include "ace/Atomic_Op_T.h"
#include "ace/Thread_Mutex.h"

#include <zmq.h>

#include "ace/Synch.h"
 
namespace madara
{
  namespace transport
  {
    class ZMQTransportReadThread : public threads::BaseThread
    {
    public:
      ZMQTransportReadThread (
        const TransportSettings & settings,
        const std::string & id,
        void * write_socket,
        BandwidthMonitor & send_monitor,
        BandwidthMonitor & receive_monitor,
        PacketScheduler & packet_scheduler);
     
      void init (knowledge::KnowledgeBase & knowledge);

      void cleanup (void);

      void run (void);

      void rebroadcast (
        const char * print_prefix,
        MessageHeader * header,
        const knowledge::KnowledgeMap& records);

    private:
      const QoSTransportSettings  settings_;

      const std::string          id_;

      knowledge::ThreadSafeContext * context_;

      void * write_socket_;

      void * read_socket_;
      
#ifndef _MADARA_NO_KARL_
      madara::knowledge::CompiledExpression  on_data_received_;
#endif // _MADARA_NO_KARL_

      madara::utility::ScopedArray <char>      buffer_;
      
      BandwidthMonitor   &   send_monitor_;
      
      BandwidthMonitor   &   receive_monitor_;

      PacketScheduler    &   packet_scheduler_;
    };
  }
}

#endif // _MADARA_ZEROMQ_TRANSPORT_READ_THREAD_H_