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"

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

#include "ace/Synch.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