SpliceTransportReadThread.h

Go to the documentation of this file.

#ifndef SPLICE_TRANSPORT_READ_THREAD_H
#define SPLICE_TRANSPORT_READ_THREAD_H
 
#include <string>
 
#include "madara/knowledge/ThreadSafeContext.h"
#include "madara/transport/Transport.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 "ccpp_dds_dcps.h"
#include "madara/transport/splice/ccpp_SpliceKnowledgeUpdate.h"
 
namespace madara
{
namespace transport
{
class SpliceReadThread : public threads::BaseThread
{
public:
  SpliceReadThread(const std::string& id, const TransportSettings& settings,
      knowledge::ThreadSafeContext& context,
      Knowledge::UpdateDataReader_ptr& update_reader,
      Knowledge::UpdateDataWriter_ptr& update_writer,
      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);
 
  ::std::vector< ::std::string> assignment_symbols_;
 
  const std::string id_;
 
  const QoSTransportSettings settings_;
 
  knowledge::ThreadSafeContext* context_;
 
  ::Knowledge::UpdateDataReader_var update_reader_;
 
  ::Knowledge::UpdateDataWriter_var update_writer_;
 
  knowledge::CompiledExpression on_data_received_;
 
  madara::utility::ScopedArray<char> buffer_;
 
  BandwidthMonitor& send_monitor_;
 
  BandwidthMonitor& receive_monitor_;
 
  PacketScheduler& packet_scheduler_;
};
}
}
 
#endif