SpliceSubscriberListener.h

Go to the documentation of this file.

#ifndef _SPLICE_SUBSCRIBER_LISTENER_H_
#define _SPLICE_SUBSCRIBER_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 SpliceSubscriberListener: public DDS::SubscriberListener
    {
    public:
      SpliceSubscriberListener (const std::string & id,
        knowledge::ThreadSafeContext & context);

      SpliceSubscriberListener (const SpliceSubscriberListener &ref);

      ~SpliceSubscriberListener();

      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);

      void on_data_on_readers (DDS::Subscriber_ptr sub);

    private:

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

    };  // End of class NDDSListener
  }
}

#endif // _SPLICE_SUBSCRIBER_LISTENER_H_