branching/taggingtest_branch_one

1 files changed, 75 insertions, 0 deletions

diff --git a/modules/CIAO/connectors/dds4ccm/impl/ndds/DataWriterListener_T.cpp b/modules/CIAO/connectors/dds4ccm/impl/ndds/DataWriterListener_T.cpp
new file mode 100644
index 00000000000..42316df8d3f
--- /dev/null
+++ b/modules/CIAO/connectors/dds4ccm/impl/ndds/DataWriterListener_T.cpp
@@ -0,0 +1,75 @@
+// $Id$
+#include "dds4ccm/impl/ndds/Utils.h"
+
+#include "dds4ccm/impl/ndds/DataWriter.h"
+#include "ciao/Logger/Log_Macros.h"
+
+// Implementation skeleton constructor
+template <typename DDS_TYPE, typename CCM_TYPE>
+CIAO::DDS4CCM::DataWriterListener_T<DDS_TYPE, CCM_TYPE>::DataWriterListener_T (
+      typename CCM_TYPE::context_type::_ptr_type context,
+      ACE_Atomic_Op <TAO_SYNCH_MUTEX, bool> &enabled)
+      : context_ (CCM_TYPE::context_type::_duplicate (context)),
+        info_out_connector_status_ (CCM_DDS::ConnectorStatusListener::_duplicate (context->get_connection_error_listener ())),
+        enable_ (enabled)
+{
+  CIAO_TRACE ("CIAO::DDS4CCM::DataWriterListener_T::DataWriterListener_T");
+}
+
+// Implementation skeleton destructor
+template <typename DDS_TYPE, typename CCM_TYPE>
+CIAO::DDS4CCM::DataWriterListener_T<DDS_TYPE, CCM_TYPE>::~DataWriterListener_T (void)
+{
+  CIAO_TRACE ("CIAO::DDS4CCM::DataWriterListener_T::~DataWriterListener_T");
+}
+
+template <typename DDS_TYPE, typename CCM_TYPE>
+void
+CIAO::DDS4CCM::DataWriterListener_T<DDS_TYPE, CCM_TYPE>::on_offered_deadline_missed (
+                                              ::DDS::DataWriter_ptr the_Writer,
+                                               const ::DDS::OfferedDeadlineMissedStatus & status)
+{
+  this->info_out_connector_status_->on_offered_deadline_missed (the_Writer, status);
+}
+
+template <typename DDS_TYPE, typename CCM_TYPE>
+void
+CIAO::DDS4CCM::DataWriterListener_T<DDS_TYPE, CCM_TYPE>::on_offered_incompatible_qos (
+                                  ::DDS::DataWriter_ptr the_Writer,
+                                  const ::DDS::OfferedIncompatibleQosStatus & status)
+{
+  this->info_out_connector_status_->on_offered_incompatible_qos (the_Writer, status);
+}
+
+template <typename DDS_TYPE, typename CCM_TYPE>
+void
+CIAO::DDS4CCM::DataWriterListener_T<DDS_TYPE, CCM_TYPE>::on_liveliness_lost (
+                                ::DDS::DataWriter_ptr the_Writer,
+                                const ::DDS::LivelinessLostStatus &)
+{
+  this->info_out_connector_status_->on_unexpected_status (the_Writer, ::DDS::LIVELINESS_LOST_STATUS);
+}
+
+template <typename DDS_TYPE, typename CCM_TYPE>
+void
+CIAO::DDS4CCM::DataWriterListener_T<DDS_TYPE, CCM_TYPE>::on_publication_matched (
+                                ::DDS::DataWriter_ptr the_Writer,
+                                const ::DDS::PublicationMatchedStatus &)
+{
+  this->info_out_connector_status_->on_unexpected_status (the_Writer, ::DDS::PUBLICATION_MATCHED_STATUS);
+}
+
+template <typename DDS_TYPE, typename CCM_TYPE>
+bool
+CIAO::DDS4CCM::DataWriterListener_T<DDS_TYPE, CCM_TYPE>::enabled (void) const
+{
+  return this->enabled_;
+}
+
+template <typename DDS_TYPE, typename CCM_TYPE>
+void
+CIAO::DDS4CCM::DataWriterListener_T<DDS_TYPE, CCM_TYPE>::enabled (bool enabled)
+{
+  this->enabled_ = enabled;
+}
+