1 files changed, 103 insertions, 0 deletions
diff --git a/modules/CIAO/connectors/dds4ccm/impl/ndds/Updater_T.cpp b/modules/CIAO/connectors/dds4ccm/impl/ndds/Updater_T.cpp
new file mode 100644
index 00000000000..9b829692743
--- /dev/null
+++ b/modules/CIAO/connectors/dds4ccm/impl/ndds/Updater_T.cpp
@@ -0,0 +1,103 @@
+// $Id$
+#include "dds4ccm/impl/ndds/DataWriter.h"
+#include "dds4ccm/impl/ndds/Utils.h"
+#include "dds4ccm/impl/ndds/Coherent_Changes_Guard.h"
+
+#include "ciao/Logger/Log_Macros.h"
+
+template <typename DDS_TYPE, typename CCM_TYPE >
+CIAO::DDS4CCM::RTI::Updater_T<DDS_TYPE, CCM_TYPE>::Updater_T (::DDS::DataWriter_ptr dw)
+  : impl_ (0),
+    is_lifecycle_checked_ (false),
+    is_coherent_write_ (false)
+{
+  CIAO_TRACE ("CIAO::DDS4CCM::RTI::Updater_T::Updater_T");
+
+  RTI_DataWriter_i *rdu = dynamic_cast <RTI_DataWriter_i *> (dw);
+
+  if (!rdu)
+    {
+      CIAO_ERROR ((LM_ERROR, CLINFO "CIAO::DDS4CCM::RTI::Updater_T::Updater - "
+                   "Unable to cast provided DataUpdater to servant\n"));
+      throw CORBA::INTERNAL ();
+    }
+
+  this->impl_ =  DDS_TYPE::data_writer::narrow (rdu->get_datawriter ());
+
+  if (!this->impl_)
+    {
+      CIAO_ERROR ((LM_ERROR, CLINFO "CIAO::DDS4CCM::RTI::Updater_T::Updater_T - "
+                   "Unable to narrow the provided updater entity to the specific "
+                   "type necessary to update messages\n"));
+      throw CORBA::INTERNAL ();
+    }
+}
+
+// Implementation skeleton destructor
+template <typename DDS_TYPE, typename CCM_TYPE >
+CIAO::DDS4CCM::RTI::Updater_T<DDS_TYPE, CCM_TYPE>::~Updater_T (void)
+{
+  CIAO_TRACE ("CIAO::DDS4CCM::RTI::Updater_T::~Updater_T");
+}
+
+template <typename DDS_TYPE, typename CCM_TYPE >
+bool
+CIAO::DDS4CCM::RTI::Updater_T<DDS_TYPE, CCM_TYPE>::is_lifecycle_checked ()
+{
+  CIAO_TRACE ("CIAO::DDS4CCM::RTI::Updater_T::~is_lifecycle_checked");
+  return this->is_lifecycle_checked_;
+}
+
+template <typename DDS_TYPE, typename CCM_TYPE >
+void
+CIAO::DDS4CCM::RTI::Updater_T<DDS_TYPE, CCM_TYPE>::create (
+            const typename DDS_TYPE::value_type & an_instance)
+{
+  CIAO_TRACE ("CIAO::DDS4CCM::RTI::Updater_T::create");
+
+  DDS_InstanceHandle_t hnd = this->impl_->lookup_instance (an_instance);
+  if (this->is_lifecycle_checked_ &&
+      !DDS_InstanceHandle_equals (&hnd, & ::DDS_HANDLE_NIL))
+    {
+      throw CCM_DDS::AlreadyCreated (0);
+    }
+  this->impl_->register_instance (an_instance);
+}
+
+template <typename DDS_TYPE, typename CCM_TYPE >
+void
+CIAO::DDS4CCM::RTI::Updater_T<DDS_TYPE, CCM_TYPE>::update (
+            const typename DDS_TYPE::value_type & an_instance)
+{
+  CIAO_TRACE ("CIAO::DDS4CCM::RTI::Updater_T::update");
+
+  DDS_InstanceHandle_t hnd = this->impl_->lookup_instance (an_instance);
+  if (this->is_lifecycle_checked_ && DDS_InstanceHandle_equals (&hnd, &::DDS_HANDLE_NIL))
+    throw CCM_DDS::NonExistent (0);
+  ::DDS::ReturnCode_t const result  = this->impl_->write (an_instance, hnd);
+  if (result != DDS_RETCODE_OK)
+    {
+      ACE_ERROR ((LM_ERROR, ACE_TEXT ("CIAO::DDS4CCM::RTI::Updater_T::update : ")
+                            ACE_TEXT ("Unable to update data, error %d.\n"), result));
+      throw CCM_DDS::InternalError (result, 0);
+    }
+}
+
+template <typename DDS_TYPE, typename CCM_TYPE >
+void
+CIAO::DDS4CCM::RTI::Updater_T<DDS_TYPE, CCM_TYPE>::_cxx_delete (const typename DDS_TYPE::value_type & an_instance)
+{
+  CIAO_TRACE ("CIAO::DDS4CCM::RTI::Updater_T::_cxx_delete");
+
+  DDS_InstanceHandle_t hnd = this->impl_->lookup_instance (an_instance);
+  if (this->is_lifecycle_checked_ && DDS_InstanceHandle_equals (&hnd, & ::DDS_HANDLE_NIL))
+    throw CCM_DDS::NonExistent (0);
+  ::DDS::ReturnCode_t const result  = this->impl_->unregister_instance (an_instance, hnd);
+  if (result != DDS_RETCODE_OK)
+    {
+      ACE_ERROR ((LM_ERROR, ACE_TEXT ("CIAO::DDS4CCM::RTI::Updater_T::_cxx_delete ")
+                            ACE_TEXT ("Unable to unregister instance, error %d.\n"), result));
+      throw CCM_DDS::InternalError (result, 0);
+    }
+}
+