1 files changed, 96 insertions, 0 deletions
diff --git a/CIAO/connectors/dds4ccm/impl/ndds/Writer_T.cpp b/CIAO/connectors/dds4ccm/impl/ndds/Writer_T.cpp
new file mode 100644
index 00000000000..e0a83492589
--- /dev/null
+++ b/CIAO/connectors/dds4ccm/impl/ndds/Writer_T.cpp
@@ -0,0 +1,96 @@
+// $Id$
+
+#include "dds4ccm/impl/ndds/DataWriter.h"
+#include "dds4ccm/impl/ndds/Utils.h"
+#include "dds4ccm/impl/ndds/Coherent_Changes_Guard.h"
+#include "dds4ccm/impl/ndds/InstanceHandle_t.h"
+#include "dds4ccm/impl/logger/Log_Macros.h"
+
+template <typename DDS_TYPE, typename CCM_TYPE >
+CIAO::DDS4CCM::Writer_T<DDS_TYPE, CCM_TYPE>::Writer_T (void)
+  : InstanceHandleManager_T<DDS_TYPE, CCM_TYPE, typename CCM_TYPE::writer_type> (),
+    is_coherent_write_ (false)
+{
+  DDS4CCM_TRACE ("CIAO::DDS4CCM::Writer_T::Writer_T");
+}
+
+template <typename DDS_TYPE, typename CCM_TYPE >
+CIAO::DDS4CCM::Writer_T<DDS_TYPE, CCM_TYPE>::~Writer_T (void)
+{
+  DDS4CCM_TRACE ("CIAO::DDS4CCM::Writer_T::~Writer_T");
+}
+
+template <typename DDS_TYPE, typename CCM_TYPE >
+void
+CIAO::DDS4CCM::Writer_T<DDS_TYPE, CCM_TYPE>::write_i (
+  const typename DDS_TYPE::value_type& datum,
+  const ::DDS::InstanceHandle_t& instance_handle,
+  ::CCM_DDS::DataNumber_t index)
+{
+  DDS4CCM_TRACE ("CIAO::DDS4CCM::Writer_T::write_i");
+
+  ::DDS_InstanceHandle_t handle = ::DDS_HANDLE_NIL;
+  handle <<= instance_handle;
+  DDS_ReturnCode_t const retval = this->impl ()->write (datum, handle);
+
+  if (retval != DDS_RETCODE_OK)
+    {
+      DDS4CCM_ERROR (1, (LM_ERROR, CLINFO "CIAO::DDS4CCM::Writer_T::write_i - "
+                   "Write unsuccessful, received error code %C\n",
+                   translate_retcode (retval)));
+      throw CCM_DDS::InternalError (retval, index);
+    }
+}
+
+template <typename DDS_TYPE, typename CCM_TYPE >
+void
+CIAO::DDS4CCM::Writer_T<DDS_TYPE, CCM_TYPE>::write_one (
+  const typename DDS_TYPE::value_type & an_instance,
+  const ::DDS::InstanceHandle_t & instance_handle)
+{
+  DDS4CCM_TRACE ("CIAO::DDS4CCM::Writer_T::write_one");
+
+  this->write_i (an_instance, instance_handle, 0);
+
+  DDS4CCM_DEBUG (9, (LM_TRACE, CLINFO "CIAO::DDS4CCM::Writer_T::write_one - "
+               "Write successful\n"));
+}
+
+template <typename DDS_TYPE, typename CCM_TYPE >
+void
+CIAO::DDS4CCM::Writer_T<DDS_TYPE, CCM_TYPE>::write_many (
+  const typename CCM_TYPE::seq_type& instances)
+{
+  DDS4CCM_TRACE ("CIAO::DDS4CCM::Writer_T::write_many");
+
+  Coherent_Changes_Guard guard (this->impl ()->get_publisher(),
+                                this->is_coherent_write_);
+
+  DDS4CCM_DEBUG (9, (LM_TRACE, CLINFO "CIAO::DDS4CCM::Writer_T::write_many - "
+               "Preparing to write to DDS\n"));
+
+  for (typename CCM_TYPE::seq_type::size_type index = 0;
+       index < instances.length();
+       index++)
+    {
+      this->write_i (instances[index], ::DDS::HANDLE_NIL, index);
+    }
+
+  DDS4CCM_DEBUG (9, (LM_TRACE, CLINFO "CIAO::DDS4CCM::Writer_T::write_many - "
+               "Write successful\n"));
+}
+
+template <typename DDS_TYPE, typename CCM_TYPE >
+::CORBA::Boolean
+CIAO::DDS4CCM::Writer_T<DDS_TYPE, CCM_TYPE>::is_coherent_write (void)
+{
+  return this->is_coherent_write_;
+}
+
+template <typename DDS_TYPE, typename CCM_TYPE >
+void
+CIAO::DDS4CCM::Writer_T<DDS_TYPE, CCM_TYPE>::is_coherent_write (
+  ::CORBA::Boolean value)
+{
+  this->is_coherent_write_ = value;
+}