diff options
Diffstat (limited to 'CIAO/connectors/dds4ccm/impl/DDS_Event_Connector_T.cpp')
| -rw-r--r-- | CIAO/connectors/dds4ccm/impl/DDS_Event_Connector_T.cpp | 572 |
1 files changed, 0 insertions, 572 deletions
diff --git a/CIAO/connectors/dds4ccm/impl/DDS_Event_Connector_T.cpp b/CIAO/connectors/dds4ccm/impl/DDS_Event_Connector_T.cpp deleted file mode 100644 index 34a86e07f1d..00000000000 --- a/CIAO/connectors/dds4ccm/impl/DDS_Event_Connector_T.cpp +++ /dev/null @@ -1,572 +0,0 @@ -// -*- C++ -*- -#include "dds4ccm/impl/DataReaderListener_T.h" -#include "dds4ccm/impl/Writer_T.h" -#include "dds4ccm/impl/Getter_T.h" -#include "dds4ccm/impl/Reader_T.h" -#include "dds4ccm/impl/DataListenerControl_T.h" - -#include "dds4ccm/impl/logger/Log_Macros.h" -#include "dds4ccm/impl/dds4ccm_conf.h" - -template <typename CCM_TYPE, typename DDS_TYPE, bool FIXED, typename SEQ_TYPE> -DDS_Event_Connector_T<CCM_TYPE, DDS_TYPE, FIXED, SEQ_TYPE>::DDS_Event_Connector_T (void) : - TopicBaseConnector (), - supplier_obtained_ (false), - push_consumer_obtained_ (false), - pull_consumer_obtained_ (false), - supplier_ (), - push_consumer_ (), - pull_consumer_ () -{ -} - -template <typename CCM_TYPE, typename DDS_TYPE, bool FIXED, typename SEQ_TYPE> -DDS_Event_Connector_T<CCM_TYPE, DDS_TYPE, FIXED, SEQ_TYPE>::~DDS_Event_Connector_T (void) -{ -} - -template <typename CCM_TYPE, typename DDS_TYPE, bool FIXED, typename SEQ_TYPE> -typename CCM_TYPE::supplier_traits::data_type::_ptr_type -DDS_Event_Connector_T<CCM_TYPE, DDS_TYPE, FIXED, SEQ_TYPE>::get_supplier_data (void) -{ - DDS4CCM_TRACE ("DDS_Event_Connector_T<CCM_TYPE, DDS_TYPE, FIXED, SEQ_TYPE>::get_supplier_data"); - - this->supplier_obtained_ = true; - this->supplier_.set_component (this); - this->init_publisher_ |= this->supplier_obtained_; - return this->supplier_.get_data (); -} - -template <typename CCM_TYPE, typename DDS_TYPE, bool FIXED, typename SEQ_TYPE> -typename CCM_TYPE::supplier_traits::dds_entity_type::_ptr_type -DDS_Event_Connector_T<CCM_TYPE, DDS_TYPE, FIXED, SEQ_TYPE>::get_supplier_dds_entity (void) -{ - DDS4CCM_TRACE ("DDS_Event_Connector_T<CCM_TYPE, DDS_TYPE, FIXED, SEQ_TYPE>::get_supplier_dds_entity"); - - this->supplier_obtained_ = true; - this->supplier_.set_component (this); - this->init_publisher_ |= this->supplier_obtained_; - return this->supplier_.get_dds_entity (); -} - -template <typename CCM_TYPE, typename DDS_TYPE, bool FIXED, typename SEQ_TYPE> -typename CCM_TYPE::pull_consumer_traits::fresh_data_type::_ptr_type -DDS_Event_Connector_T<CCM_TYPE, DDS_TYPE, FIXED, SEQ_TYPE>::get_pull_consumer_fresh_data (void) -{ - DDS4CCM_TRACE ("DDS_Event_Connector_T<CCM_TYPE, DDS_TYPE, FIXED, SEQ_TYPE>::get_pull_consumer_fresh_data"); - - this->pull_consumer_obtained_ = true; - this->pull_consumer_.set_component (this); - this->init_subscriber_ |= this->pull_consumer_obtained_; - return this->pull_consumer_.get_fresh_data (); -} - -template <typename CCM_TYPE, typename DDS_TYPE, bool FIXED, typename SEQ_TYPE> -typename CCM_TYPE::push_consumer_traits::data_type::_ptr_type -DDS_Event_Connector_T<CCM_TYPE, DDS_TYPE, FIXED, SEQ_TYPE>::get_push_consumer_data (void) -{ - DDS4CCM_TRACE ("DDS_Event_Connector_T<CCM_TYPE, DDS_TYPE, FIXED, SEQ_TYPE>::get_push_consumer_data"); - - this->push_consumer_obtained_ = true; - this->push_consumer_.set_component (this); - this->init_subscriber_ |= this->push_consumer_obtained_; - return this->push_consumer_.get_data (); -} - -template <typename CCM_TYPE, typename DDS_TYPE, bool FIXED, typename SEQ_TYPE> -typename CCM_TYPE::pull_consumer_traits::data_type::_ptr_type -DDS_Event_Connector_T<CCM_TYPE, DDS_TYPE, FIXED, SEQ_TYPE>::get_pull_consumer_data (void) -{ - DDS4CCM_TRACE ("DDS_Event_Connector_T<CCM_TYPE, DDS_TYPE, FIXED, SEQ_TYPE>::get_pull_consumer_data"); - - this->pull_consumer_obtained_ = true; - this->pull_consumer_.set_component (this); - this->init_subscriber_ |= this->pull_consumer_obtained_; - return this->pull_consumer_.get_data (); -} - -template <typename CCM_TYPE, typename DDS_TYPE, bool FIXED, typename SEQ_TYPE> -::CCM_DDS::CCM_ContentFilterSetting_ptr -DDS_Event_Connector_T<CCM_TYPE, DDS_TYPE, FIXED, SEQ_TYPE>::get_pull_consumer_filter_config (void) -{ - DDS4CCM_TRACE ("DDS_Event_Connector_T<CCM_TYPE, DDS_TYPE, FIXED, SEQ_TYPE>::get_pull_consumer_filter_config"); - - this->pull_consumer_obtained_ = true; - this->pull_consumer_.set_component (this); - this->init_subscriber_ |= this->pull_consumer_obtained_; - return this->pull_consumer_.get_filter_config (); -} - -template <typename CCM_TYPE, typename DDS_TYPE, bool FIXED, typename SEQ_TYPE> -::CCM_DDS::CCM_DataListenerControl_ptr -DDS_Event_Connector_T<CCM_TYPE, DDS_TYPE, FIXED, SEQ_TYPE>::get_push_consumer_data_control (void) -{ - DDS4CCM_TRACE ("DDS_Event_Connector_T<CCM_TYPE, DDS_TYPE, FIXED, SEQ_TYPE>::get_push_consumer_data_control"); - - this->push_consumer_obtained_ = true; - this->push_consumer_.set_component (this); - this->init_subscriber_ |= this->push_consumer_obtained_; - return this->push_consumer_.get_data_control (); -} - -template <typename CCM_TYPE, typename DDS_TYPE, bool FIXED, typename SEQ_TYPE> -::DDS::CCM_DataReader_ptr -DDS_Event_Connector_T<CCM_TYPE, DDS_TYPE, FIXED, SEQ_TYPE>::get_pull_consumer_dds_entity (void) -{ - DDS4CCM_TRACE ("DDS_Event_Connector_T<CCM_TYPE, DDS_TYPE, FIXED, SEQ_TYPE>::get_pull_consumer_dds_entity"); - - this->pull_consumer_obtained_ = true; - this->pull_consumer_.set_component (this); - this->init_subscriber_ |= this->pull_consumer_obtained_; - return this->pull_consumer_.get_dds_entity (); -} - -template <typename CCM_TYPE, typename DDS_TYPE, bool FIXED, typename SEQ_TYPE> -::CCM_DDS::QueryFilter* -DDS_Event_Connector_T<CCM_TYPE, DDS_TYPE, FIXED, SEQ_TYPE>::pull_consumer_filter (void) -{ - DDS4CCM_TRACE ("DDS_Event_Connector_T<CCM_TYPE, DDS_TYPE, FIXED, SEQ_TYPE>::pull_consumer_filter"); - - return this->pull_consumer_.filter (); -} - -template <typename CCM_TYPE, typename DDS_TYPE, bool FIXED, typename SEQ_TYPE> -void -DDS_Event_Connector_T<CCM_TYPE, DDS_TYPE, FIXED, SEQ_TYPE>::pull_consumer_filter ( - const ::CCM_DDS::QueryFilter & filter) -{ - DDS4CCM_TRACE ("DDS_Event_Connector_T<CCM_TYPE, DDS_TYPE, FIXED, SEQ_TYPE>::pull_consumer_filter"); - - this->pull_consumer_.filter (filter); -} - -template <typename CCM_TYPE, typename DDS_TYPE, bool FIXED, typename SEQ_TYPE> -::DDS::CCM_DataReader_ptr -DDS_Event_Connector_T<CCM_TYPE, DDS_TYPE, FIXED, SEQ_TYPE>::get_push_consumer_dds_entity (void) -{ - DDS4CCM_TRACE ("DDS_Event_Connector_T<CCM_TYPE, DDS_TYPE, FIXED, SEQ_TYPE>::get_push_consumer_dds_entity"); - - this->push_consumer_obtained_ = true; - this->push_consumer_.set_component (this); - this->init_subscriber_ |= this->push_consumer_obtained_; - return this->push_consumer_.get_dds_entity (); -} - -template <typename CCM_TYPE, typename DDS_TYPE, bool FIXED, typename SEQ_TYPE> -::CCM_DDS::CCM_ContentFilterSetting_ptr -DDS_Event_Connector_T<CCM_TYPE, DDS_TYPE, FIXED, SEQ_TYPE>::get_push_consumer_filter_config (void) -{ - DDS4CCM_TRACE ("DDS_Event_Connector_T<CCM_TYPE, DDS_TYPE, FIXED, SEQ_TYPE>::get_push_consumer_filter_config"); - - this->push_consumer_obtained_ = true; - this->push_consumer_.set_component (this); - this->init_subscriber_ |= this->push_consumer_obtained_; - return this->push_consumer_.get_filter_config (); -} - -template <typename CCM_TYPE, typename DDS_TYPE, bool FIXED, typename SEQ_TYPE> -::CCM_DDS::QueryFilter* -DDS_Event_Connector_T<CCM_TYPE, DDS_TYPE, FIXED, SEQ_TYPE>::push_consumer_filter (void) -{ - DDS4CCM_TRACE ("DDS_Event_Connector_T<CCM_TYPE, DDS_TYPE, FIXED, SEQ_TYPE>::push_consumer_filter"); - - return this->push_consumer_.filter (); -} - -template <typename CCM_TYPE, typename DDS_TYPE, bool FIXED, typename SEQ_TYPE> -void -DDS_Event_Connector_T<CCM_TYPE, DDS_TYPE, FIXED, SEQ_TYPE>::push_consumer_filter ( - const ::CCM_DDS::QueryFilter & filter) -{ - DDS4CCM_TRACE ("DDS_Event_Connector_T<CCM_TYPE, DDS_TYPE, FIXED, SEQ_TYPE>::push_consumer_filter"); - - this->push_consumer_.filter (filter); -} - -template <typename CCM_TYPE, typename DDS_TYPE, bool FIXED, typename SEQ_TYPE> -void -DDS_Event_Connector_T<CCM_TYPE, DDS_TYPE, FIXED, SEQ_TYPE>::topic_name ( - const char * topic_name) -{ - DDS4CCM_TRACE ("DDS_Event_Connector_T<CCM_TYPE, DDS_TYPE, FIXED, SEQ_TYPE>::topic_name"); - - if (this->stop_dds (topic_name)) - { - DDS4CCM_DEBUG (DDS4CCM_LOG_LEVEL_ACTION, (LM_DEBUG, DDS4CCM_INFO - "DDS_Event_Connector_T::topic_name - " - "Stopping DDS=>switching to new topic <%C>.\n", - topic_name)); - this->ccm_passivate (); - this->do_ccm_remove (); - - if (ACE_OS::strlen (topic_name) > 0) - { - DDS4CCM_DEBUG (DDS4CCM_LOG_LEVEL_ACTION, (LM_DEBUG, DDS4CCM_INFO - "DDS_Event_Connector_T::topic_name - " - "DDS is down. Setting new to <%C>.\n", - topic_name)); - - TopicBaseConnector::topic_name (topic_name); - - DDS4CCM_DEBUG (DDS4CCM_LOG_LEVEL_ACTION, (LM_DEBUG, DDS4CCM_INFO - "DDS_Event_Connector_T::topic_name - " - "Initialize DDS again for topic <%C>.\n", - topic_name)); - - this->do_configuration_complete (); - this->do_ccm_activate (); - - DDS4CCM_DEBUG (DDS4CCM_LOG_LEVEL_ACTION, (LM_DEBUG, DDS4CCM_INFO - "DDS_Event_Connector_T::topic_name - " - "DDS up and running for topic <%C>.\n", - topic_name)); - } - else - { - DDS4CCM_DEBUG (DDS4CCM_LOG_LEVEL_ACTION, (LM_DEBUG, DDS4CCM_INFO - "DDS_Event_Connector_T::topic_name - " - "DDS is down.\n")); - TopicBaseConnector::topic_name (topic_name); - } - } - else if (this->late_binded (topic_name)) - { - this->do_configuration_complete (); - this->do_ccm_activate (); - } -} - -template <typename CCM_TYPE, typename DDS_TYPE, bool FIXED, typename SEQ_TYPE> -char * -DDS_Event_Connector_T<CCM_TYPE, DDS_TYPE, FIXED, SEQ_TYPE>::topic_name (void) -{ - DDS4CCM_TRACE ("DDS_Event_Connector_T<CCM_TYPE, DDS_TYPE, FIXED, SEQ_TYPE>::topic_name"); - - return TopicBaseConnector::topic_name (); -} - -template <typename CCM_TYPE, typename DDS_TYPE, bool FIXED, typename SEQ_TYPE> -void -DDS_Event_Connector_T<CCM_TYPE, DDS_TYPE, FIXED, SEQ_TYPE>::do_configuration_complete (void) -{ - DDS4CCM_TRACE ("DDS_Event_Connector_T<CCM_TYPE, DDS_TYPE, FIXED, SEQ_TYPE>::do_configuration_complete"); - - typename CCM_TYPE::push_consumer_traits::data_listener_type::_var_type - push_consumer_data_listener = - this->context_->get_connection_push_consumer_data_listener (); - - this->push_consumer_obtained_ |= - ! ::CORBA::is_nil (push_consumer_data_listener.in ()); - ::CCM_DDS::PortStatusListener_var push_consumer_psl = - this->context_->get_connection_push_consumer_status (); - this->push_consumer_obtained_ |= ! ::CORBA::is_nil (push_consumer_psl.in ()); - this->init_subscriber_ |= this->push_consumer_obtained_; - - ::CCM_DDS::PortStatusListener_var pull_consumer_psl = - this->context_->get_connection_pull_consumer_status (); - this->pull_consumer_obtained_ |= - ! ::CORBA::is_nil (pull_consumer_psl.in ()); - this->init_subscriber_ |= this->pull_consumer_obtained_; - - TopicBaseConnector::configuration_complete (); - - if (this->push_consumer_obtained_) - { - DDS4CCM_DEBUG (DDS4CCM_LOG_LEVEL_ACTION, (LM_DEBUG, DDS4CCM_INFO - "DDS_Event_Connector_T<CCM_TYPE, DDS_TYPE, FIXED, SEQ_TYPE>" - "::configuration_complete - " - "Creating push consumer port.\n")); - this->push_consumer_.configuration_complete ( - this->topic_.in (), - this->subscriber_.in (), - this->qos_profile_.in (), - this->qos_xml_); - } - else - { - DDS4CCM_DEBUG (DDS4CCM_LOG_LEVEL_ACTION, (LM_DEBUG, DDS4CCM_INFO - "DDS_Event_Connector_T<CCM_TYPE, DDS_TYPE, FIXED, SEQ_TYPE>" - "::configuration_complete - " - "No need to create push consumer port.\n")); - } - - if (this->supplier_obtained_) - { - DDS4CCM_DEBUG (DDS4CCM_LOG_LEVEL_ACTION, (LM_DEBUG, DDS4CCM_INFO - "DDS_Event_Connector_T<CCM_TYPE, DDS_TYPE, FIXED, SEQ_TYPE>" - "::configuration_complete - " - "Creating supplier port.\n")); - this->supplier_.configuration_complete( - this->topic_.in (), - this->publisher_.in (), - this->qos_profile_.in (), - this->qos_xml_); - } - else - { - DDS4CCM_DEBUG (DDS4CCM_LOG_LEVEL_ACTION, (LM_DEBUG, DDS4CCM_INFO - "DDS_Event_Connector_T<CCM_TYPE, DDS_TYPE, FIXED, SEQ_TYPE>" - "::configuration_complete - " - "No need to create supplier port.\n")); - } - - if (this->pull_consumer_obtained_) - { - DDS4CCM_DEBUG (DDS4CCM_LOG_LEVEL_ACTION, (LM_DEBUG, DDS4CCM_INFO - "DDS_Event_Connector_T<CCM_TYPE, DDS_TYPE, FIXED, SEQ_TYPE>" - "::configuration_complete - " - "Creating pull consumer port.\n")); - this->pull_consumer_.configuration_complete ( - this->topic_.in (), - this->subscriber_.in (), - this->qos_profile_.in (), - this->qos_xml_); - } - else - { - DDS4CCM_DEBUG (DDS4CCM_LOG_LEVEL_ACTION, (LM_DEBUG, DDS4CCM_INFO - "DDS_Event_Connector_T<CCM_TYPE, DDS_TYPE, FIXED, SEQ_TYPE>" - "::configuration_complete - " - "No need to create pull consumer port.\n")); - } -} - -template <typename CCM_TYPE, typename DDS_TYPE, bool FIXED, typename SEQ_TYPE> -void -DDS_Event_Connector_T<CCM_TYPE, DDS_TYPE, FIXED, SEQ_TYPE>::configuration_complete (void) -{ - DDS4CCM_TRACE ("DDS_Event_Connector_T<CCM_TYPE, DDS_TYPE, FIXED, SEQ_TYPE>::configuration_complete"); - - try - { - if (!this->late_binding ()) - { - this->do_configuration_complete (); - } - } - catch (const ::CCM_DDS::InternalError &ex) - { - DDS4CCM_PRINT_INTERNAL_EXCEPTION ( - DDS4CCM_LOG_LEVEL_ERROR, - ::CIAO::DDS4CCM::translate_retcode (ex.error_code), - "DDS_Event_Connector_T::configuration_complete"); - throw ::CORBA::INTERNAL (); - } - catch (const ::CORBA::Exception& ex) - { - DDS4CCM_PRINT_CORBA_EXCEPTION ( - DDS4CCM_LOG_LEVEL_ERROR, - ex, - "DDS_Event_Connector_T::configuration_complete"); - throw; - } - catch (...) - { - DDS4CCM_ERROR (DDS4CCM_LOG_LEVEL_ERROR, (LM_ERROR, DDS4CCM_INFO - "DDS_Event_Connector_T::configuration_complete - " - "Caught unexpected exception.\n")); - throw ::CORBA::INTERNAL (); - } -} - -template <typename CCM_TYPE, typename DDS_TYPE, bool FIXED, typename SEQ_TYPE> -void -DDS_Event_Connector_T<CCM_TYPE, DDS_TYPE, FIXED, SEQ_TYPE>::do_ccm_activate (void) -{ - ACE_Reactor *reactor = this->reactor (); - - TopicBaseConnector::ccm_activate (); - - if (this->push_consumer_obtained_) - { - typename CCM_TYPE::push_consumer_traits::data_listener_type::_var_type push_consumer_data_listener = - this->context_->get_connection_push_consumer_data_listener (); - ::CCM_DDS::PortStatusListener_var push_consumer_psl = - this->context_->get_connection_push_consumer_status (); - - this->push_consumer_.activate ( - push_consumer_data_listener.in (), - push_consumer_psl.in (), - reactor); - } - - if (this->supplier_obtained_) - { - this->supplier_.activate (); - } - - if (this->pull_consumer_obtained_) - { - ::CCM_DDS::PortStatusListener_var pull_consumer_psl = - this->context_->get_connection_pull_consumer_status (); - - this->pull_consumer_.activate ( - pull_consumer_psl.in (), - reactor); - } -} - -template <typename CCM_TYPE, typename DDS_TYPE, bool FIXED, typename SEQ_TYPE> -void -DDS_Event_Connector_T<CCM_TYPE, DDS_TYPE, FIXED, SEQ_TYPE>::ccm_activate (void) -{ - DDS4CCM_TRACE ("DDS_Event_Connector_T<CCM_TYPE, DDS_TYPE, FIXED, SEQ_TYPE>::ccm_activate"); - - try - { - if (!this->late_binding ()) - { - this->do_ccm_activate (); - } - } - catch (const ::CCM_DDS::InternalError &ex) - { - DDS4CCM_PRINT_INTERNAL_EXCEPTION ( - DDS4CCM_LOG_LEVEL_ERROR, - ::CIAO::DDS4CCM::translate_retcode (ex.error_code), - "DDS_Event_Connector_T::ccm_activate"); - throw ::CORBA::INTERNAL (); - } - catch (const ::CORBA::Exception& ex) - { - DDS4CCM_PRINT_CORBA_EXCEPTION ( - DDS4CCM_LOG_LEVEL_ERROR, - ex, - "DDS_Event_Connector_T::ccm_activate"); - throw; - } - catch (...) - { - DDS4CCM_ERROR (DDS4CCM_LOG_LEVEL_ERROR, (LM_ERROR, DDS4CCM_INFO - "DDS_Event_Connector_T::ccm_activate - " - "Caught unexpected exception.\n")); - throw ::CORBA::INTERNAL (); - } -} - -template <typename CCM_TYPE, typename DDS_TYPE, bool FIXED, typename SEQ_TYPE> -void -DDS_Event_Connector_T<CCM_TYPE, DDS_TYPE, FIXED, SEQ_TYPE>::ccm_passivate (void) -{ - DDS4CCM_TRACE ("DDS_Event_Connector_T<CCM_TYPE, DDS_TYPE, FIXED, SEQ_TYPE>::ccm_passivate"); - - try - { - if (ACE_OS::strlen (this->topic_name_) != 0) - { - if (this->push_consumer_obtained_) - { - this->push_consumer_.passivate (); - } - - if (this->supplier_obtained_) - { - this->supplier_.passivate (); - } - - if (this->pull_consumer_obtained_) - { - this->pull_consumer_.passivate (); - } - TopicBaseConnector::ccm_passivate (); - } - } - catch (const ::CCM_DDS::InternalError &ex) - { - DDS4CCM_PRINT_INTERNAL_EXCEPTION ( - DDS4CCM_LOG_LEVEL_ERROR, - ::CIAO::DDS4CCM::translate_retcode (ex.error_code), - "DDS_Event_Connector_T::ccm_passivate"); - throw ::CORBA::INTERNAL (); - } - catch (const ::CORBA::Exception& ex) - { - DDS4CCM_PRINT_CORBA_EXCEPTION ( - DDS4CCM_LOG_LEVEL_ERROR, - ex, - "DDS_Event_Connector_T::ccm_passivate"); - throw; - } - catch (...) - { - DDS4CCM_ERROR (DDS4CCM_LOG_LEVEL_ERROR, (LM_ERROR, DDS4CCM_INFO - "DDS_Event_Connector_T::ccm_passivate - " - "Caught unexpected exception.\n")); - throw ::CORBA::INTERNAL (); - } -} - - -template <typename CCM_TYPE, typename DDS_TYPE, bool FIXED, typename SEQ_TYPE> -void -DDS_Event_Connector_T<CCM_TYPE, DDS_TYPE, FIXED, SEQ_TYPE>::do_ccm_remove (void) -{ - DDS4CCM_TRACE ("DDS_Event_Connector_T<CCM_TYPE, DDS_TYPE, FIXED, SEQ_TYPE>::do_ccm_remove"); - try - { - if (ACE_OS::strlen (this->topic_name_) != 0) - { - if (this->push_consumer_obtained_) - { - this->push_consumer_.remove (this->subscriber_.in ()); - } - - if (this->supplier_obtained_) - { - this->supplier_.remove (this->publisher_.in ()); - } - - if (this->pull_consumer_obtained_) - { - this->pull_consumer_.remove (this->subscriber_.in ()); - } - TopicBaseConnector::ccm_remove (); - } - } - catch (const ::CCM_DDS::InternalError &ex) - { - DDS4CCM_PRINT_INTERNAL_EXCEPTION ( - DDS4CCM_LOG_LEVEL_ERROR, - ::CIAO::DDS4CCM::translate_retcode (ex.error_code), - "DDS_Event_Connector_T::do_ccm_remove"); - throw ::CORBA::INTERNAL (); - } - catch (const ::CORBA::Exception& ex) - { - DDS4CCM_PRINT_CORBA_EXCEPTION ( - DDS4CCM_LOG_LEVEL_ERROR, - ex, - "DDS_Event_Connector_T::do_ccm_remove"); - throw; - } - catch (...) - { - DDS4CCM_ERROR (DDS4CCM_LOG_LEVEL_ERROR, (LM_ERROR, DDS4CCM_INFO - "DDS_Event_Connector_T::do_ccm_remove - " - "Caught unexpected exception.\n")); - throw ::CORBA::INTERNAL (); - } -} - -template <typename CCM_TYPE, typename DDS_TYPE, bool FIXED, typename SEQ_TYPE> -void -DDS_Event_Connector_T<CCM_TYPE, DDS_TYPE, FIXED, SEQ_TYPE>::ccm_remove (void) -{ - DDS4CCM_TRACE ("DDS_Event_Connector_T<CCM_TYPE, DDS_TYPE, FIXED, SEQ_TYPE>::ccm_remove"); - if (this->push_consumer_obtained_) - { - this->push_consumer_.set_component (::CORBA::Object::_nil ()); - } - - if (this->supplier_obtained_) - { - this->supplier_.set_component (::CORBA::Object::_nil ()); - } - - if (this->pull_consumer_obtained_) - { - this->pull_consumer_.set_component (::CORBA::Object::_nil ()); - } - - this->do_ccm_remove (); -} |