diff options
Diffstat (limited to 'CIAO/connectors/dds4ccm/impl/ndds/Topic.cpp')
| -rw-r--r-- | CIAO/connectors/dds4ccm/impl/ndds/Topic.cpp | 204 |
1 files changed, 0 insertions, 204 deletions
diff --git a/CIAO/connectors/dds4ccm/impl/ndds/Topic.cpp b/CIAO/connectors/dds4ccm/impl/ndds/Topic.cpp deleted file mode 100644 index c1a625ceb25..00000000000 --- a/CIAO/connectors/dds4ccm/impl/ndds/Topic.cpp +++ /dev/null @@ -1,204 +0,0 @@ -#include "dds4ccm/impl/ndds/Topic.h" -#include "dds4ccm/impl/ndds/StatusCondition.h" -#include "dds4ccm/impl/ndds/TopicListener.h" - -#include "dds4ccm/impl/ndds/convertors/InstanceHandle_t.h" -#include "dds4ccm/impl/ndds/convertors/InconsistentTopicStatus.h" -#include "dds4ccm/impl/ndds/convertors/TopicQos.h" - -#include "dds4ccm/impl/logger/Log_Macros.h" - -namespace CIAO -{ - namespace NDDS - { - DDS_Topic_i::DDS_Topic_i (::DDSTopic* topic, - ::DDS::DomainParticipant_ptr dp) - : rti_entity_ (topic), - dp_ (::DDS::DomainParticipant::_duplicate (dp)) - { - DDS4CCM_TRACE ("DDS_Topic_i::DDS_Topic_i"); - } - - DDS_Topic_i::~DDS_Topic_i (void) - { - DDS4CCM_TRACE ("DDS_Topic_i::~DDS_Topic_i"); - } - - ::DDS::ReturnCode_t - DDS_Topic_i::set_qos (const ::DDS::TopicQos &qos) - { - DDS4CCM_TRACE ("DDS_Topic_i::set_qos"); - ::DDS_TopicQos ccm_dds_qos; - DDS_ReturnCode_t const retcode = this->rti_entity ()->get_qos (ccm_dds_qos); - if (retcode != DDS_RETCODE_OK) - { - DDS4CCM_ERROR (DDS4CCM_LOG_LEVEL_ERROR, (LM_ERROR, DDS4CCM_INFO - "DDS_Topic_i" - "::set_qos - " - "Error: Unable to retrieve topic qos\n")); - return retcode; - } - ccm_dds_qos <<= qos; - return this->rti_entity ()->get_qos (ccm_dds_qos); - } - - ::DDS::ReturnCode_t - DDS_Topic_i::get_qos (::DDS::TopicQos &qos) - { - DDS4CCM_TRACE ("DDS_Topic_i::get_qos"); - ::DDS_TopicQos ccm_dds_qos; - ccm_dds_qos <<= qos; - ::DDS_ReturnCode_t const retval = this->rti_entity ()->get_qos (ccm_dds_qos); - qos <<= ccm_dds_qos; - return retval; - } - - ::DDS::ReturnCode_t - DDS_Topic_i::set_listener ( - ::DDS::TopicListener_ptr a_listener, - ::DDS::StatusMask mask) - { - DDS4CCM_TRACE ("DDS_Topic_i::set_listener"); - - // Retrieve the previously set listener - DDSTopicListener *old_listener = this->rti_entity ()->get_listener (); - - DDSTopicListener *listener = 0; - if (! ::CORBA::is_nil (a_listener)) - { - ACE_NEW_THROW_EX (listener, - DDS_TopicListener_i ( - this, - a_listener), - ::CORBA::NO_MEMORY ()); - } - - ::DDS::ReturnCode_t const retcode = - this->rti_entity ()->set_listener (listener, mask); - - if (retcode != ::DDS::RETCODE_OK) - { - delete listener; - } - else - { - this->topic_listener_ = ::DDS::TopicListener::_duplicate (a_listener); - delete old_listener; - } - - return retcode; - } - - ::DDS::TopicListener_ptr - DDS_Topic_i::get_listener (void) - { - DDS4CCM_TRACE ("DDS_Topic_i::get_listener"); - - return ::DDS::TopicListener::_duplicate (this->topic_listener_.in ()); - } - - ::DDS::ReturnCode_t - DDS_Topic_i::get_inconsistent_topic_status ( - ::DDS::InconsistentTopicStatus & a_status) - { - DDS4CCM_TRACE ("DDS_Topic_i::get_inconsistent_topic_status"); - - DDS_InconsistentTopicStatus ddsstatus; - ::DDS::ReturnCode_t const retval = - this->rti_entity ()->get_inconsistent_topic_status (ddsstatus); - a_status <<= ddsstatus; - return retval; - } - - ::DDS::ReturnCode_t - DDS_Topic_i::enable (void) - { - DDS4CCM_TRACE ("DDS_Topic_i::enable"); - - return this->rti_entity ()->enable (); - } - - ::DDS::StatusCondition_ptr - DDS_Topic_i::get_statuscondition (void) - { - DDS4CCM_TRACE ("DDS_Topic_i::get_statuscondition"); - - ::DDS::StatusCondition_var retval; - DDSStatusCondition* sc = this->rti_entity ()->get_statuscondition (); - ACE_NEW_THROW_EX (retval, - DDS_StatusCondition_i (sc, this->dp_.in ()), - ::CORBA::NO_MEMORY ()); - return retval._retn (); - } - - ::DDS::StatusMask - DDS_Topic_i::get_status_changes (void) - { - DDS4CCM_TRACE ("DDS_Topic_i::get_status_changes"); - - return this->rti_entity ()->get_status_changes (); - } - - ::DDS::InstanceHandle_t - DDS_Topic_i::get_instance_handle (void) - { - DDS4CCM_TRACE ("DDS_Topic_i::get_instance_handle"); - - ::DDS_InstanceHandle_t const rtihandle = - this->rti_entity ()->get_instance_handle (); - ::DDS::InstanceHandle_t handle; - handle <<= rtihandle; - return handle; - } - - char * - DDS_Topic_i::get_type_name (void) - { - DDS4CCM_TRACE ("DDS_Topic_i::get_type_name"); - - return CORBA::string_dup (this->rti_entity ()->get_type_name ()); - } - - char * - DDS_Topic_i::get_name (void) - { - DDS4CCM_TRACE ("DDS_Topic_i::get_name"); - - return CORBA::string_dup (this->rti_entity ()->get_name ()); - } - - ::DDS::DomainParticipant_ptr - DDS_Topic_i::get_participant (void) - { - DDS4CCM_TRACE ("DDS_Topic_i::get_participant"); - - return ::DDS::DomainParticipant::_duplicate (this->dp_.in ()); - } - - DDSTopic * - DDS_Topic_i::get_rti_entity (void) - { - return this->rti_entity_; - } - - void - DDS_Topic_i::set_rti_entity (::DDSTopic* topic) - { - this->rti_entity_ = topic; - } - - DDSTopic * - DDS_Topic_i::rti_entity (void) - { - if (!this->rti_entity_) - { - DDS4CCM_DEBUG (DDS4CCM_LOG_LEVEL_ACTION, (LM_DEBUG, - "DDS_Topic_i::rti_entity - " - "Throwing BAD_INV_ORDER.\n")); - throw ::CORBA::BAD_INV_ORDER (); - } - return this->rti_entity_; - } - } -} |