diff options
author | Johnny Willemsen <jwillemsen@remedy.nl> | 2010-06-28 09:22:52 +0000 |
---|---|---|
committer | Johnny Willemsen <jwillemsen@remedy.nl> | 2010-06-28 09:22:52 +0000 |
commit | 18589430f13824474850a87691aa82a0971f9323 (patch) | |
tree | a750e46b8ec1f9c742b28352cfb6e56ea30ce20a /CIAO/connectors/dds4ccm/impl/Writer_T.cpp | |
parent | 8cee71e721db849145c38369af4f6e0a74f42804 (diff) | |
download | ATCD-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.cpp | 38 |
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); |