ZMQTransport.h

Go to the documentation of this file.

#ifndef _MADARA_ZEROMQ_TRANSPORT_H_
#define _MADARA_ZEROMQ_TRANSPORT_H_
 
#include <string>
 
#include "madara/MadaraExport.h"
#include "madara/utility/ScopedArray.h"
#include "madara/transport/QoSTransportSettings.h"
#include "madara/transport/Transport.h"
#include "madara/knowledge/KnowledgeBase.h"
 
#include <zmq.h>
 
#include "madara/knowledge/KnowledgeRecord.h"
#include "madara/expression/ExpressionTree.h"
#include "madara/transport/BandwidthMonitor.h"
#include "madara/threads/Threader.h"
 
namespace madara
{
namespace transport
{
class MADARA_EXPORT ZMQTransport : public Base
{
public:
  ZMQTransport(const std::string& id,
      madara::knowledge::ThreadSafeContext& context, TransportSettings& config,
      bool launch_transport);
 
  virtual ~ZMQTransport();
 
  long send_data(
      const madara::knowledge::KnowledgeMap& updates) override;
 
  virtual void close(void) override;
 
  int reliability(void) const;
 
  int reliability(const int& setting);
 
  virtual int setup(void) override;
 
private:
  knowledge::KnowledgeBase knowledge_;
 
  threads::Threader read_threads_;
 
  void* write_socket_;
 
  knowledge::containers::Integer sent_packets_;
 
  knowledge::containers::Integer failed_sends_;
 
  knowledge::containers::Integer sent_data_;
 
  knowledge::containers::Integer sent_data_max_;
 
  knowledge::containers::Integer sent_data_min_;
};
}
}
 
#endif  // _MADARA_ZEROMQ_TRANSPORT_H_