diff options
Diffstat (limited to 'CIAO/connectors/dds4ccm/tests/VariousTopicsState/Sender/VTopics_Sender_exec.cpp')
-rw-r--r-- | CIAO/connectors/dds4ccm/tests/VariousTopicsState/Sender/VTopics_Sender_exec.cpp | 138 |
1 files changed, 0 insertions, 138 deletions
diff --git a/CIAO/connectors/dds4ccm/tests/VariousTopicsState/Sender/VTopics_Sender_exec.cpp b/CIAO/connectors/dds4ccm/tests/VariousTopicsState/Sender/VTopics_Sender_exec.cpp deleted file mode 100644 index be057adabaf..00000000000 --- a/CIAO/connectors/dds4ccm/tests/VariousTopicsState/Sender/VTopics_Sender_exec.cpp +++ /dev/null @@ -1,138 +0,0 @@ -// -*- C++ -*- - -//Test different topic types, with DDS_STATE connector, look for 'PUBLICATION_MATCHED_STATUS -#include "VTopics_Sender_exec.h" -#include "dds4ccm/impl/Utils.h" - -namespace CIAO_VTopics_Sender_Impl -{ - //============================================================ - // ConnectorStatusListener_exec_i - //============================================================ - ConnectorStatusListener_exec_i::ConnectorStatusListener_exec_i ( - Atomic_Boolean &publication_matched) - : publication_matched_ (publication_matched) - { - } - - ConnectorStatusListener_exec_i::~ConnectorStatusListener_exec_i (void) - { - } - - void ConnectorStatusListener_exec_i::on_inconsistent_topic( - ::DDS::Topic_ptr /*the_topic*/, - const DDS::InconsistentTopicStatus & /*status*/) - { - } - - void ConnectorStatusListener_exec_i::on_requested_incompatible_qos ( - ::DDS::DataReader_ptr /*the_reader*/, - const DDS::RequestedIncompatibleQosStatus & /*status*/) - { - } - - void ConnectorStatusListener_exec_i::on_sample_rejected ( - ::DDS::DataReader_ptr /*the_reader*/, - const DDS::SampleRejectedStatus & /*status*/) - { - } - - void ConnectorStatusListener_exec_i::on_offered_deadline_missed ( - ::DDS::DataWriter_ptr /*the_writer*/, - const DDS::OfferedDeadlineMissedStatus & /*status*/) - { - } - - void ConnectorStatusListener_exec_i::on_offered_incompatible_qos ( - ::DDS::DataWriter_ptr /*the_writer*/, - const DDS::OfferedIncompatibleQosStatus & /*status*/) - { - } - - void ConnectorStatusListener_exec_i::on_unexpected_status ( - ::DDS::Entity_ptr the_entity, - ::DDS::StatusKind status_kind) - { - if (! ::CORBA::is_nil (the_entity) && - status_kind == DDS::PUBLICATION_MATCHED_STATUS) - { - this->publication_matched_ = true; - } - } - //============================================================ - // Component Executor Implementation Class: Sender_exec_i - //============================================================ - - Sender_exec_i::Sender_exec_i (void) - : publication_matched_ (false) - { - } - - Sender_exec_i::~Sender_exec_i (void) - { - } - - ::CCM_DDS::CCM_ConnectorStatusListener_ptr - Sender_exec_i::get_connector_status (void) - { - return new ConnectorStatusListener_exec_i (this->publication_matched_); - } - - // Supported operations and attributes. - void - Sender_exec_i::set_session_context (::Components::SessionContext_ptr ctx) - { - this->context_ = ::VTopics::CCM_Sender_Context::_narrow (ctx); - - if ( ::CORBA::is_nil (this->context_.in ())) - { - throw ::CORBA::INTERNAL (); - } - } - - void - Sender_exec_i::configuration_complete (void) - { - } - - void - Sender_exec_i::ccm_activate (void) - { - } - - void - Sender_exec_i::ccm_passivate (void) - { - } - - void - Sender_exec_i::ccm_remove (void) - { - if(!this->publication_matched_.value ()) - { - ACE_ERROR ((LM_ERROR, ACE_TEXT ("ERROR: did not receive the expected ") - ACE_TEXT ("states 'PUBLICATION_MATCHED_STATUS' ") - ACE_TEXT ("in Sender\n") - )); - } - else - { - ACE_DEBUG ((LM_DEBUG, ACE_TEXT ("Received the expected ") - ACE_TEXT ("'PUBLICATION_MATCHED_STATUS' ") - ACE_TEXT ("in Sender\n") - )); - } - } - - extern "C" SENDER_EXEC_Export ::Components::EnterpriseComponent_ptr - create_VTopics_Sender_Impl (void) - { - ::Components::EnterpriseComponent_ptr retval = - ::Components::EnterpriseComponent::_nil (); - ACE_NEW_NORETURN ( - retval, - Sender_exec_i); - - return retval; - } -} |