SpliceDataReaderListener.h

Go to the documentation of this file.

#ifndef SPLICE_DATAREADER_LISTENER_H
#define SPLICE_DATAREADER_LISTENER_H

#include <string>

#include "madara/knowledge/ThreadSafeContext.h"
#include "madara/transport/Transport.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 SpliceDataReaderListener: public DDS::DataReaderListener
    {
    public:
      SpliceDataReaderListener (const std::string & id,
        knowledge::ThreadSafeContext & context);

      SpliceDataReaderListener (const SpliceDataReaderListener &ref);

      ~SpliceDataReaderListener();

      void handle_assignment (Knowledge::Update & data);
      void handle_multiassignment (Knowledge::Update & data);

    public:
      void on_requested_deadline_missed (DDS::DataReader_ptr,
        const DDS::RequestedDeadlineMissedStatus & status);
      
      void on_requested_incompatible_qos (DDS::DataReader_ptr,
        const DDS::RequestedIncompatibleQosStatus & status);
      
      void on_sample_rejected (DDS::DataReader_ptr,
        const DDS::SampleRejectedStatus & status);

      void on_liveliness_changed (DDS::DataReader_ptr,
        const DDS::LivelinessChangedStatus & status);

      void on_sample_lost (DDS::DataReader_ptr,
        const DDS::SampleLostStatus & status);

      void on_subscription_matched (DDS::DataReader_ptr reader,
        const DDS::SubscriptionMatchedStatus & status);

      void on_data_available(DDS::DataReader_ptr reader);
    private:

      // NDDS variables
      const std::string id_;
      knowledge::ThreadSafeContext & context_;

    };  // End of class NDDSListener
  }
}

#endif // SPLICE_DATAREADER_LISTENER_H