Fri Oct 29 11:57:32 UTC 2010 Marcel Smit <msmit@remedy.nl>

        * connectors/dds4ccm/impl/Coherent_Changes_Guard.h:
        * connectors/dds4ccm/impl/ConditionManager_T.h:
        * connectors/dds4ccm/impl/ConditionManager_T.cpp:
        * connectors/dds4ccm/impl/ContentFilterSetting.h:
        * connectors/dds4ccm/impl/DDSDataReaderListener_T.h:
        * connectors/dds4ccm/impl/DDSDataReaderListener_T.cpp:
        * connectors/dds4ccm/impl/DDSDataWriterListener_T.h:
        * connectors/dds4ccm/impl/DDSDataWriterListener_T.cpp:
        * connectors/dds4ccm/impl/DDSDomainParticipantListener.h:
        * connectors/dds4ccm/impl/DDSDomainParticipantListener.cpp:
        * connectors/dds4ccm/impl/DDSPublisherListener_T.h:
        * connectors/dds4ccm/impl/DDSPublisherListener_T.cpp:
        * connectors/dds4ccm/impl/DDSSubscriberListener_T.h:
        * connectors/dds4ccm/impl/DDSSubscriberListener_T.cpp:
        * connectors/dds4ccm/impl/DDSTopicListener_T.h:
        * connectors/dds4ccm/impl/DDSTopicListener_T.cpp:
        * connectors/dds4ccm/impl/DDS_Base_Connector_T.h:
        * connectors/dds4ccm/impl/DDS_Base_Connector_T.cpp:
        * connectors/dds4ccm/impl/DDS_State_Connector_T.cpp:
        * connectors/dds4ccm/impl/DDS_Subscriber_Base_T.h:
        * connectors/dds4ccm/impl/DDS_Subscriber_Base_T.cpp:
        * connectors/dds4ccm/impl/DDS_TopicBase_Connector_T.h:
        * connectors/dds4ccm/impl/DDS_TopicBase_Connector_T.cpp:
        * connectors/dds4ccm/impl/DDS_Update_T.h:
        * connectors/dds4ccm/impl/DDS_Update_T.cpp:
        * connectors/dds4ccm/impl/DDS_Write_T.h:
        * connectors/dds4ccm/impl/DDS_Write_T.cpp:
        * connectors/dds4ccm/impl/DataReaderListener_T.cpp:
        * connectors/dds4ccm/impl/DataReaderStateListener_T.cpp:
        * connectors/dds4ccm/impl/DataWriterListener_T.cpp:
        * connectors/dds4ccm/impl/Getter_T.h:
        * connectors/dds4ccm/impl/Getter_T.cpp:
        * connectors/dds4ccm/impl/InstanceHandleManager_T.h:
        * connectors/dds4ccm/impl/InstanceHandleManager_T.cpp:
        * connectors/dds4ccm/impl/PublisherListener_T.h:
        * connectors/dds4ccm/impl/Reader_T.h:
        * connectors/dds4ccm/impl/Reader_T.cpp:
        * connectors/dds4ccm/impl/TopicListener_T.cpp:
        * connectors/dds4ccm/impl/Updater_T.cpp:
        * connectors/dds4ccm/impl/Writer_T.cpp:
        * connectors/dds4ccm/impl/dds4ccm_conf.h:
        * connectors/dds4ccm/impl/dds4ccm_impl.mpc:

        * connectors/dds4ccm/impl/ndds/DataWriter_T.h:
        * connectors/dds4ccm/impl/ndds/DataWriter_T.cpp:
        * connectors/dds4ccm/impl/ndds/SubscriberListener_T.h:
        * connectors/dds4ccm/impl/ndds/SubscriberListener_T.cpp:
        * connectors/dds4ccm/impl/ndds/Subscriber_T.h:
        * connectors/dds4ccm/impl/ndds/Subscriber_T.cpp:

        * connectors/dds4ccm/impl/ndds/convertors/BuiltinTopicKey_t.h:
        * connectors/dds4ccm/impl/ndds/convertors/DataReaderQos.h:
        * connectors/dds4ccm/impl/ndds/convertors/DataWriterQos.h:
        * connectors/dds4ccm/impl/ndds/convertors/DeadlineQosPolicy.h:
        * connectors/dds4ccm/impl/ndds/convertors/DestinationOrderQosPolicy.h:
        * connectors/dds4ccm/impl/ndds/convertors/DomainParticipantFactoryQos.h:
        * connectors/dds4ccm/impl/ndds/convertors/DomainParticipantQos.h:
        * connectors/dds4ccm/impl/ndds/convertors/DurabilityQosPolicy.h:
        * connectors/dds4ccm/impl/ndds/convertors/DurabilityServiceQosPolicy.h:
        * connectors/dds4ccm/impl/ndds/convertors/Duration_t.h:
        * connectors/dds4ccm/impl/ndds/convertors/EntityFactoryQosPolicy.h:
        * connectors/dds4ccm/impl/ndds/convertors/GroupDataQosPolicy.h:
        * connectors/dds4ccm/impl/ndds/convertors/HistoryQosPolicy.h:
        * connectors/dds4ccm/impl/ndds/convertors/InconsistentTopicStatus.h:
        * connectors/dds4ccm/impl/ndds/convertors/InstanceHandleSeq.h:
        * connectors/dds4ccm/impl/ndds/convertors/InstanceHandle_t.h:
        * connectors/dds4ccm/impl/ndds/convertors/LatencyBudgetQosPolicy.h:
        * connectors/dds4ccm/impl/ndds/convertors/LifespanQosPolicy.h:
        * connectors/dds4ccm/impl/ndds/convertors/LivelinessChangedStatus.h:
        * connectors/dds4ccm/impl/ndds/convertors/LivelinessLostStatus.h:
        * connectors/dds4ccm/impl/ndds/convertors/LivelinessQosPolicy.h:
        * connectors/dds4ccm/impl/ndds/convertors/OctetSeq.h:
        * connectors/dds4ccm/impl/ndds/convertors/OfferedDeadlineMissedStatus.h:
        * connectors/dds4ccm/impl/ndds/convertors/OfferedIncompatibleQosStatus.h:
        * connectors/dds4ccm/impl/ndds/convertors/OwnershipQosPolicy.h:
        * connectors/dds4ccm/impl/ndds/convertors/OwnershipStrengthQosPolicy.h:
        * connectors/dds4ccm/impl/ndds/convertors/ParticipantBuiltinTopicData.h:
        * connectors/dds4ccm/impl/ndds/convertors/PartitionQosPolicy.h:
        * connectors/dds4ccm/impl/ndds/convertors/PresentationQosPolicy.h:
        * connectors/dds4ccm/impl/ndds/convertors/PublicationBuiltinTopicData.h:
        * connectors/dds4ccm/impl/ndds/convertors/PublicationMatchedStatus.h:
        * connectors/dds4ccm/impl/ndds/convertors/PublisherQos.h:
        * connectors/dds4ccm/impl/ndds/convertors/QosPolicyCountSeq.h:
        * connectors/dds4ccm/impl/ndds/convertors/ReaderDataLifecycleQosPolicy.h:
        * connectors/dds4ccm/impl/ndds/convertors/ReliabilityQosPolicy.h:
        * connectors/dds4ccm/impl/ndds/convertors/ReliableReaderActivityChangedStatus.h:
        * connectors/dds4ccm/impl/ndds/convertors/ReliableWriterCacheChangedStatus.h:
        * connectors/dds4ccm/impl/ndds/convertors/RequestedDeadlineMissedStatus.h:
        * connectors/dds4ccm/impl/ndds/convertors/RequestedIncompatibleQosStatus.h:
        * connectors/dds4ccm/impl/ndds/convertors/ResourceLimitsQosPolicy.h:
        * connectors/dds4ccm/impl/ndds/convertors/SampleInfo.h:
        * connectors/dds4ccm/impl/ndds/convertors/SampleLostStatus.h:
        * connectors/dds4ccm/impl/ndds/convertors/SampleRejectedStatus.h:
        * connectors/dds4ccm/impl/ndds/convertors/StringSeq.h:
        * connectors/dds4ccm/impl/ndds/convertors/SubscriberQos.h:
        * connectors/dds4ccm/impl/ndds/convertors/SubscriptionBuiltinTopicData.h:
        * connectors/dds4ccm/impl/ndds/convertors/SubscriptionMatchedStatus.h:
        * connectors/dds4ccm/impl/ndds/convertors/TimeBasedFilterQosPolicy.h:
        * connectors/dds4ccm/impl/ndds/convertors/Time_t.h:
        * connectors/dds4ccm/impl/ndds/convertors/TopicBuiltinTopicData.h:
        * connectors/dds4ccm/impl/ndds/convertors/TopicDataQosPolicy.h:
        * connectors/dds4ccm/impl/ndds/convertors/TopicQos.h:
        * connectors/dds4ccm/impl/ndds/convertors/TransportPriorityQosPolicy.h:
        * connectors/dds4ccm/impl/ndds/convertors/UserDataQosPolicy.h:
        * connectors/dds4ccm/impl/ndds/convertors/WriterDataLifecycleQosPolicy.h:

        * connectors/dds4ccm/impl/ndds/dds4ccm_dds_ndds_export.h:
        * connectors/dds4ccm/impl/ndds/dds4ccm_ndds.mpc:

        * connectors/dds4ccm/impl/ContentFilteredTopic_T.h:
        * connectors/dds4ccm/impl/ContentFilteredTopic_T.cpp:
        * connectors/dds4ccm/impl/DataReader.h:
        * connectors/dds4ccm/impl/DataReader.cpp:
        * connectors/dds4ccm/impl/DataReader_T.h:
        * connectors/dds4ccm/impl/DataReader_T.cpp:
        * connectors/dds4ccm/impl/DataWriter.h:
        * connectors/dds4ccm/impl/DataWriter.cpp:
        * connectors/dds4ccm/impl/DataWriter_T.h:
        * connectors/dds4ccm/impl/DataWriter_T.cpp:
        * connectors/dds4ccm/impl/DomainParticipantFactory_T.h:
        * connectors/dds4ccm/impl/DomainParticipantFactory_T.cpp:
        * connectors/dds4ccm/impl/DomainParticipantListener.h:
        * connectors/dds4ccm/impl/DomainParticipantListener.cpp:
        * connectors/dds4ccm/impl/Publisher_T.h:
        * connectors/dds4ccm/impl/Publisher_T.cpp:
        * connectors/dds4ccm/impl/QueryCondition_T.h:
        * connectors/dds4ccm/impl/QueryCondition_T.cpp:
        * connectors/dds4ccm/impl/ReadCondition_T.h:
        * connectors/dds4ccm/impl/ReadCondition_T.cpp:
        * connectors/dds4ccm/impl/StatusCondition.h:
        * connectors/dds4ccm/impl/StatusCondition.cpp:
        * connectors/dds4ccm/impl/SubscriberListener_T.h:
        * connectors/dds4ccm/impl/SubscriberListener_T.cpp:
        * connectors/dds4ccm/impl/Subscriber_T.h:
        * connectors/dds4ccm/impl/Subscriber_T.cpp:
        * connectors/dds4ccm/impl/TopicDescription_T.h:
        * connectors/dds4ccm/impl/TopicDescription_T.cpp:
        * connectors/dds4ccm/impl/Topic_T.h:
        * connectors/dds4ccm/impl/Topic_T.cpp:

        * connectors/dds4ccm/impl/ndds/BuiltinTopicKey_t.h:
        * connectors/dds4ccm/impl/ndds/DataReaderQos.h:
        * connectors/dds4ccm/impl/ndds/DataWriterQos.h:
        * connectors/dds4ccm/impl/ndds/DeadlineQosPolicy.h:
        * connectors/dds4ccm/impl/ndds/DestinationOrderQosPolicy.h:
        * connectors/dds4ccm/impl/ndds/DomainParticipantFactoryQos.h:
        * connectors/dds4ccm/impl/ndds/DomainParticipantQos.h:
        * connectors/dds4ccm/impl/ndds/DurabilityQosPolicy.h:
        * connectors/dds4ccm/impl/ndds/DurabilityServiceQosPolicy.h:
        * connectors/dds4ccm/impl/ndds/Duration_t.h:
        * connectors/dds4ccm/impl/ndds/EntityFactoryQosPolicy.h:
        * connectors/dds4ccm/impl/ndds/GroupDataQosPolicy.h:
        * connectors/dds4ccm/impl/ndds/HistoryQosPolicy.h:
        * connectors/dds4ccm/impl/ndds/InconsistentTopicStatus.h:
        * connectors/dds4ccm/impl/ndds/InstanceHandleSeq.h:
        * connectors/dds4ccm/impl/ndds/InstanceHandle_t.h:
        * connectors/dds4ccm/impl/ndds/LatencyBudgetQosPolicy.h:
        * connectors/dds4ccm/impl/ndds/LifespanQosPolicy.h:
        * connectors/dds4ccm/impl/ndds/LivelinessChangedStatus.h:
        * connectors/dds4ccm/impl/ndds/LivelinessLostStatus.h:
        * connectors/dds4ccm/impl/ndds/LivelinessQosPolicy.h:
        * connectors/dds4ccm/impl/ndds/OctetSeq.h:
        * connectors/dds4ccm/impl/ndds/OfferedDeadlineMissedStatus.h:
        * connectors/dds4ccm/impl/ndds/OfferedIncompatibleQosStatus.h:
        * connectors/dds4ccm/impl/ndds/OwnershipQosPolicy.h:
        * connectors/dds4ccm/impl/ndds/OwnershipStrengthQosPolicy.h:
        * connectors/dds4ccm/impl/ndds/ParticipantBuiltinTopicData.h:
        * connectors/dds4ccm/impl/ndds/PartitionQosPolicy.h:
        * connectors/dds4ccm/impl/ndds/PresentationQosPolicy.h:
        * connectors/dds4ccm/impl/ndds/PublicationBuiltinTopicData.h:
        * connectors/dds4ccm/impl/ndds/PublicationMatchedStatus.h:
        * connectors/dds4ccm/impl/ndds/PublisherQos.h:
        * connectors/dds4ccm/impl/ndds/QosPolicyCountSeq.h:
        * connectors/dds4ccm/impl/ndds/ReaderDataLifecycleQosPolicy.h:
        * connectors/dds4ccm/impl/ndds/ReliabilityQosPolicy.h:
        * connectors/dds4ccm/impl/ndds/ReliableReaderActivityChangedStatus.h:
        * connectors/dds4ccm/impl/ndds/ReliableWriterCacheChangedStatus.h:
        * connectors/dds4ccm/impl/ndds/RequestedDeadlineMissedStatus.h:
        * connectors/dds4ccm/impl/ndds/RequestedIncompatibleQosStatus.h:
        * connectors/dds4ccm/impl/ndds/ResourceLimitsQosPolicy.h:
        * connectors/dds4ccm/impl/ndds/SampleInfo.h:
        * connectors/dds4ccm/impl/ndds/SampleLostStatus.h:
        * connectors/dds4ccm/impl/ndds/SampleRejectedStatus.h:
        * connectors/dds4ccm/impl/ndds/StringSeq.h:
        * connectors/dds4ccm/impl/ndds/SubscriberQos.h:
        * connectors/dds4ccm/impl/ndds/SubscriptionBuiltinTopicData.h:
        * connectors/dds4ccm/impl/ndds/SubscriptionMatchedStatus.h:
        * connectors/dds4ccm/impl/ndds/TimeBasedFilterQosPolicy.h:
        * connectors/dds4ccm/impl/ndds/Time_t.h:
        * connectors/dds4ccm/impl/ndds/TopicBuiltinTopicData.h:
        * connectors/dds4ccm/impl/ndds/TopicDataQosPolicy.h:
        * connectors/dds4ccm/impl/ndds/TopicQos.h:
        * connectors/dds4ccm/impl/ndds/TransportPriorityQosPolicy.h:
        * connectors/dds4ccm/impl/ndds/UserDataQosPolicy.h:
        * connectors/dds4ccm/impl/ndds/WriterDataLifecycleQosPolicy.h:
          Rename and move action in order to provide re-useable code.

1 files changed, 39 insertions, 0 deletions

diff --git a/CIAO/connectors/dds4ccm/impl/ndds/DataWriter.cpp b/CIAO/connectors/dds4ccm/impl/ndds/DataWriter.cpp
new file mode 100644
index 00000000000..dc61a8ebceb
--- /dev/null
+++ b/CIAO/connectors/dds4ccm/impl/ndds/DataWriter.cpp
@@ -0,0 +1,39 @@
+// $Id$
+
+#include "DataWriter.h"
+
+#include "dds4ccm/impl/Log_Macros.h"
+
+namespace CIAO
+{
+  namespace DDS4CCM
+  {
+    CCM_DDS_DataWriter_Base::CCM_DDS_DataWriter_Base (DDSDataWriter * dw)
+      : impl_ (dw)
+    {
+    }
+
+    DDSDataWriter *
+    CCM_DDS_DataWriter_Base::get_impl (void)
+    {
+      return this->impl_;
+    }
+
+    void
+    CCM_DDS_DataWriter_Base::set_impl (DDSDataWriter * dw)
+    {
+      // Set a pointer to this class for the listener to use.
+      this->impl_ = dw;
+    }
+
+    DDSDataWriter *
+    CCM_DDS_DataWriter_Base::impl (void)
+    {
+      if (!this->impl_)
+        {
+          throw ::CORBA::BAD_INV_ORDER ();
+        }
+      return this->impl_;
+    }
+  }
+}