summaryrefslogtreecommitdiff
path: root/CIAO/connectors/dds4ccm/impl/Writer_T.cpp
diff options
context:
space:
mode:
authorJohnny Willemsen <jwillemsen@remedy.nl>2010-06-28 09:22:52 +0000
committerJohnny Willemsen <jwillemsen@remedy.nl>2010-06-28 09:22:52 +0000
commit18589430f13824474850a87691aa82a0971f9323 (patch)
treea750e46b8ec1f9c742b28352cfb6e56ea30ce20a /CIAO/connectors/dds4ccm/impl/Writer_T.cpp
parent8cee71e721db849145c38369af4f6e0a74f42804 (diff)
downloadATCD-18589430f13824474850a87691aa82a0971f9323.tar.gz
Mon Jun 28 09:18:43 UTC 2010 Johnny Willemsen <jwillemsen@remedy.nl>
* DAnCE/LocalityManager/Interceptors/Error_Interceptors.mpc: Fixed fuzz * connectors/dds4ccm/impl/ContentFilteredTopic_T.h: * connectors/dds4ccm/impl/ContentFilteredTopic_T.cpp: * 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/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_Event_Connector_T.h: * connectors/dds4ccm/impl/DDS_Event_Connector_T.cpp: * connectors/dds4ccm/impl/DDS_Get_T.h: * connectors/dds4ccm/impl/DDS_Get_T.cpp: * connectors/dds4ccm/impl/DDS_Listen_T.h: * connectors/dds4ccm/impl/DDS_Listen_T.cpp: * connectors/dds4ccm/impl/DDS_Read_T.h: * connectors/dds4ccm/impl/DDS_Read_T.cpp: * connectors/dds4ccm/impl/DDS_StateListen_T.h: * connectors/dds4ccm/impl/DDS_StateListen_T.cpp: * connectors/dds4ccm/impl/DDS_State_Connector_T.h: * 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/DataReaderHandler_T.h: * connectors/dds4ccm/impl/DataReaderHandler_T.cpp: * connectors/dds4ccm/impl/DataReaderListener_T.h: * connectors/dds4ccm/impl/DataReaderListener_T.cpp: * connectors/dds4ccm/impl/DataReaderStateListener_T.h: * connectors/dds4ccm/impl/DataReaderStateListener_T.cpp: * connectors/dds4ccm/impl/DataReader_T.h: * connectors/dds4ccm/impl/DataReader_T.cpp: * connectors/dds4ccm/impl/DataWriterListener_T.h: * connectors/dds4ccm/impl/DataWriterListener_T.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_T.h: * connectors/dds4ccm/impl/DomainParticipantListener_T.cpp: * connectors/dds4ccm/impl/DomainParticipant_T.h: * connectors/dds4ccm/impl/DomainParticipant_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/PortStatusListener_T.h: * connectors/dds4ccm/impl/PortStatusListener_T.cpp: * connectors/dds4ccm/impl/PublisherListener_T.h: * connectors/dds4ccm/impl/PublisherListener_T.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/Reader_T.h: * connectors/dds4ccm/impl/Reader_T.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/TopicListener_T.h: * connectors/dds4ccm/impl/TopicListener_T.cpp: * connectors/dds4ccm/impl/Topic_T.h: * connectors/dds4ccm/impl/Topic_T.cpp: * connectors/dds4ccm/impl/Updater_T.h: * connectors/dds4ccm/impl/Updater_T.cpp: * connectors/dds4ccm/impl/Writer_T.h: * connectors/dds4ccm/impl/Writer_T.cpp: * connectors/dds4ccm/impl/dds4ccm_conf.h: * connectors/dds4ccm/tests/PSAT/DDS_PSAT_Connector_T.h: Added a vendor traits to the template. The idea is that when other DDS vendors need to be integrated, the default implementation will assume DDS and DDS4CCM have the same IDL to C++ mapping, if there are differences for a certain vendor, use partial template specialization to change methods for a certain vendor. This keeps the core clean and adding more vendors doesn't make the core unreadable. Currently the core is just for RTI DDS, integrating a second vendor will mean part of the code has to be moved to a RTI partial template specialization
Diffstat (limited to 'CIAO/connectors/dds4ccm/impl/Writer_T.cpp')
-rw-r--r--CIAO/connectors/dds4ccm/impl/Writer_T.cpp38
1 files changed, 19 insertions, 19 deletions
diff --git a/CIAO/connectors/dds4ccm/impl/Writer_T.cpp b/CIAO/connectors/dds4ccm/impl/Writer_T.cpp
index 784938637ef..21a9b6571c1 100644
--- a/CIAO/connectors/dds4ccm/impl/Writer_T.cpp
+++ b/CIAO/connectors/dds4ccm/impl/Writer_T.cpp
@@ -7,23 +7,23 @@
#include "dds4ccm/impl/ndds/InstanceHandle_t.h"
#include "dds4ccm/impl/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> (),
+template <typename DDS_TYPE, typename CCM_TYPE, DDS4CCM_Vendor VENDOR_TYPE>
+CIAO::DDS4CCM::Writer_T<DDS_TYPE, CCM_TYPE, VENDOR_TYPE>::Writer_T (void)
+ : InstanceHandleManager_T<DDS_TYPE, CCM_TYPE, typename CCM_TYPE::writer_type, VENDOR_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)
+template <typename DDS_TYPE, typename CCM_TYPE, DDS4CCM_Vendor VENDOR_TYPE>
+CIAO::DDS4CCM::Writer_T<DDS_TYPE, CCM_TYPE, VENDOR_TYPE>::~Writer_T (void)
{
DDS4CCM_TRACE ("CIAO::DDS4CCM::Writer_T::~Writer_T");
}
-template <typename DDS_TYPE, typename CCM_TYPE >
+template <typename DDS_TYPE, typename CCM_TYPE, DDS4CCM_Vendor VENDOR_TYPE>
void
-CIAO::DDS4CCM::Writer_T<DDS_TYPE, CCM_TYPE>::write_i (
+CIAO::DDS4CCM::Writer_T<DDS_TYPE, CCM_TYPE, VENDOR_TYPE>::write_i (
const typename DDS_TYPE::value_type& datum,
const ::DDS::InstanceHandle_t& instance_handle,
::CCM_DDS::DataNumber_t index)
@@ -43,9 +43,9 @@ CIAO::DDS4CCM::Writer_T<DDS_TYPE, CCM_TYPE>::write_i (
}
}
-template <typename DDS_TYPE, typename CCM_TYPE >
+template <typename DDS_TYPE, typename CCM_TYPE, DDS4CCM_Vendor VENDOR_TYPE>
void
-CIAO::DDS4CCM::Writer_T<DDS_TYPE, CCM_TYPE>::write_one (
+CIAO::DDS4CCM::Writer_T<DDS_TYPE, CCM_TYPE, VENDOR_TYPE>::write_one (
const typename DDS_TYPE::value_type & an_instance,
const ::DDS::InstanceHandle_t & instance_handle)
{
@@ -57,9 +57,9 @@ CIAO::DDS4CCM::Writer_T<DDS_TYPE, CCM_TYPE>::write_one (
"Write successful\n"));
}
-template <typename DDS_TYPE, typename CCM_TYPE >
+template <typename DDS_TYPE, typename CCM_TYPE, DDS4CCM_Vendor VENDOR_TYPE>
void
-CIAO::DDS4CCM::Writer_T<DDS_TYPE, CCM_TYPE>::write_many (
+CIAO::DDS4CCM::Writer_T<DDS_TYPE, CCM_TYPE, VENDOR_TYPE>::write_many (
const typename CCM_TYPE::seq_type& instances)
{
DDS4CCM_TRACE ("CIAO::DDS4CCM::Writer_T::write_many");
@@ -81,31 +81,31 @@ CIAO::DDS4CCM::Writer_T<DDS_TYPE, CCM_TYPE>::write_many (
"Write successful\n"));
}
-template <typename DDS_TYPE, typename CCM_TYPE >
+template <typename DDS_TYPE, typename CCM_TYPE, DDS4CCM_Vendor VENDOR_TYPE>
::CORBA::Boolean
-CIAO::DDS4CCM::Writer_T<DDS_TYPE, CCM_TYPE>::is_coherent_write (void)
+CIAO::DDS4CCM::Writer_T<DDS_TYPE, CCM_TYPE, VENDOR_TYPE>::is_coherent_write (void)
{
return this->is_coherent_write_;
}
-template <typename DDS_TYPE, typename CCM_TYPE >
+template <typename DDS_TYPE, typename CCM_TYPE, DDS4CCM_Vendor VENDOR_TYPE>
void
-CIAO::DDS4CCM::Writer_T<DDS_TYPE, CCM_TYPE>::is_coherent_write (
+CIAO::DDS4CCM::Writer_T<DDS_TYPE, CCM_TYPE, VENDOR_TYPE>::is_coherent_write (
::CORBA::Boolean value)
{
this->is_coherent_write_ = value;
}
-template <typename DDS_TYPE, typename CCM_TYPE>
+template <typename DDS_TYPE, typename CCM_TYPE, DDS4CCM_Vendor VENDOR_TYPE>
::CORBA::Object_ptr
-CIAO::DDS4CCM::Writer_T<DDS_TYPE, CCM_TYPE>::_get_component (void)
+CIAO::DDS4CCM::Writer_T<DDS_TYPE, CCM_TYPE, VENDOR_TYPE>::_get_component (void)
{
return CCM_TYPE::base_type::_duplicate (this->component_.in ());
}
-template <typename DDS_TYPE, typename CCM_TYPE>
+template <typename DDS_TYPE, typename CCM_TYPE, DDS4CCM_Vendor VENDOR_TYPE>
void
-CIAO::DDS4CCM::Writer_T<DDS_TYPE, CCM_TYPE>::_set_component (
+CIAO::DDS4CCM::Writer_T<DDS_TYPE, CCM_TYPE, VENDOR_TYPE>::_set_component (
typename CCM_TYPE::base_type::_ptr_type component)
{
this->component_ = CCM_TYPE::base_type::_duplicate (component);