1 files changed, 106 insertions, 0 deletions
diff --git a/CIAO/connectors/dds4ccm/impl/ndds/DataWriterListener.cpp b/CIAO/connectors/dds4ccm/impl/ndds/DataWriterListener.cpp
new file mode 100644
index 00000000000..041092a4324
--- /dev/null
+++ b/CIAO/connectors/dds4ccm/impl/ndds/DataWriterListener.cpp
@@ -0,0 +1,106 @@
+// $Id$
+
+#include "DataWriterListener.h"
+#include "DataWriter.h"
+#include "PublicationMatchedStatus.h"
+#include "LivelinessLostStatus.h"
+#include "OfferedIncompatibleQosStatus.h"
+#include "OfferedDeadlineMissedStatus.h"
+
+namespace CIAO
+{
+  namespace DDS4CCM
+  {
+    CCM_DDS_DataWriterListener_i::CCM_DDS_DataWriterListener_i (::DDS::DataWriterListener_ptr s)
+      : impl_ (::DDS::DataWriterListener::_duplicate (s))
+    {
+    }
+
+    CCM_DDS_DataWriterListener_i::~CCM_DDS_DataWriterListener_i (void)
+    {
+    }
+
+    void
+    CCM_DDS_DataWriterListener_i::on_offered_deadline_missed (
+      ::DDSDataWriter *the_writer,
+      const ::DDS_OfferedDeadlineMissedStatus & status)
+    {
+      ::DDS::DataWriter_var dds_writer = ::DDS::DataWriter::_nil ();
+#if defined (CIAO_DDS4CCM_NDDS) && (CIAO_DDS4CCM_NDDS==1)
+      ::DDS::OfferedDeadlineMissedStatus ddsstatus;
+      ddsstatus <<= status;
+      ACE_NEW (dds_writer, 
+               CCM_DDS_DataWriter_i (the_writer));
+      this->impl_->on_offered_deadline_missed (dds_writer.in (), ddsstatus);
+#else
+      ACE_NEW (dds_writer, 
+               CCM_DDS_DataWriter_i (the_writer));
+      this->impl_->on_offered_deadline_missed (dds_writer.in (), status);
+#endif
+    }
+
+    void
+    CCM_DDS_DataWriterListener_i::on_offered_incompatible_qos (
+      ::DDSDataWriter *the_writer,
+      const ::DDS_OfferedIncompatibleQosStatus & status)
+    {
+      ::DDS::DataWriter_var dds_writer = ::DDS::DataWriter::_nil ();
+#if defined (CIAO_DDS4CCM_NDDS) && (CIAO_DDS4CCM_NDDS==1)
+      ::DDS::OfferedIncompatibleQosStatus ddsstatus;
+      ddsstatus <<= status;
+      ACE_NEW (dds_writer, 
+               CCM_DDS_DataWriter_i (the_writer));
+      this->impl_->on_offered_incompatible_qos (dds_writer.in (), ddsstatus);
+#else
+      ACE_NEW (dds_writer, 
+               CCM_DDS_DataWriter_i (the_writer));
+      this->impl_->on_offered_incompatible_qos (dds_writer.in (), status);
+#endif
+    }
+
+    void
+    CCM_DDS_DataWriterListener_i::on_liveliness_lost (
+      ::DDSDataWriter *the_writer,
+      const ::DDS_LivelinessLostStatus & status)
+    {
+      ::DDS::DataWriter_var dds_writer = ::DDS::DataWriter::_nil ();
+#if defined (CIAO_DDS4CCM_NDDS) && (CIAO_DDS4CCM_NDDS==1)
+      ::DDS::LivelinessLostStatus ddsstatus;
+      ddsstatus <<= status;
+      ACE_NEW (dds_writer, 
+               CCM_DDS_DataWriter_i (the_writer));
+      this->impl_->on_liveliness_lost (dds_writer.in (), ddsstatus);
+#else
+      ACE_NEW (dds_writer, 
+               CCM_DDS_DataWriter_i (the_writer));
+      this->impl_->on_liveliness_lost (dds_writer.in (), status);
+#endif
+    }
+
+    void
+    CCM_DDS_DataWriterListener_i::on_publication_matched (
+      ::DDSDataWriter *the_writer,
+      const ::DDS_PublicationMatchedStatus & status)
+    {
+      ::DDS::DataWriter_var dds_writer = ::DDS::DataWriter::_nil ();
+#if defined (CIAO_DDS4CCM_NDDS) && (CIAO_DDS4CCM_NDDS==1)
+      ::DDS::PublicationMatchedStatus ddsstatus;
+      ddsstatus <<= status;
+      ACE_NEW (dds_writer, 
+               CCM_DDS_DataWriter_i (the_writer));
+      this->impl_->on_publication_matched (dds_writer.in (), ddsstatus);
+#else
+      ACE_NEW (dds_writer, 
+               CCM_DDS_DataWriter_i (the_writer));
+      this->impl_->on_publication_matched (dds_writer.in (), status);
+#endif
+    }
+
+    ::DDS::DataWriterListener_ptr
+    CCM_DDS_DataWriterListener_i::get_datawriterlistener (void)
+    {
+      return ::DDS::DataWriterListener::_duplicate (this->impl_.in ());
+    }
+  }
+}
+