diff options
Diffstat (limited to 'CIAO/connectors/dds4ccm/tests/VariousTopicsEvent/Sender')
5 files changed, 0 insertions, 413 deletions
diff --git a/CIAO/connectors/dds4ccm/tests/VariousTopicsEvent/Sender/.gitignore b/CIAO/connectors/dds4ccm/tests/VariousTopicsEvent/Sender/.gitignore deleted file mode 100644 index abf3e87655b..00000000000 --- a/CIAO/connectors/dds4ccm/tests/VariousTopicsEvent/Sender/.gitignore +++ /dev/null @@ -1,5 +0,0 @@ -/Sender_exec_export.h -/Sender_lem_stub_export.h -/Sender_stub_export.h -/Sender_svnt_export.h -/VTopic_SenderE.idl diff --git a/CIAO/connectors/dds4ccm/tests/VariousTopicsEvent/Sender/VTopic_Sender.idl b/CIAO/connectors/dds4ccm/tests/VariousTopicsEvent/Sender/VTopic_Sender.idl deleted file mode 100644 index 1f865a9eee5..00000000000 --- a/CIAO/connectors/dds4ccm/tests/VariousTopicsEvent/Sender/VTopic_Sender.idl +++ /dev/null @@ -1,19 +0,0 @@ -/** - * @author Marijke Hengstmengel (mhengstmengel@remedy.nl) - */ - -#ifndef DDS_VTOPIC_SENDER_IDL -#define DDS_VTOPIC_SENDER_IDL - -#include "Connector/VTopic_Connector.idl" - -module VTopic -{ - component Sender - { - port TestTopicConnector::DDS_Write info_write; - provides CCM_DDS::ConnectorStatusListener connector_status; - }; -}; - -#endif diff --git a/CIAO/connectors/dds4ccm/tests/VariousTopicsEvent/Sender/VTopic_Sender.mpc b/CIAO/connectors/dds4ccm/tests/VariousTopicsEvent/Sender/VTopic_Sender.mpc deleted file mode 100644 index 875462836f2..00000000000 --- a/CIAO/connectors/dds4ccm/tests/VariousTopicsEvent/Sender/VTopic_Sender.mpc +++ /dev/null @@ -1,169 +0,0 @@ -// This file is generated with "generate_component_mpc.pl -p DDS_VTopic_Base -l ../lib -o ../lib -c controller -u DDS Sender" - -project(DDS_VTopic_Sender_idl_gen) : componentidldefaults, dds4ccm { - after += DDS_VTopic_Connector_idl_gen - custom_only = 1 - idlflags += -Wb,stub_export_macro=SENDER_STUB_Export \ - -Wb,stub_export_include=Sender_stub_export.h \ - -Wb,skel_export_macro=SENDER_SVNT_Export \ - -Wb,skel_export_include=Sender_svnt_export.h \ - -Wb,svnt_export_macro=SENDER_SVNT_Export \ - -Wb,svnt_export_include=Sender_svnt_export.h \ - -Wb,exec_export_macro=SENDER_EXEC_Export \ - -Wb,exec_export_include=Sender_exec_export.h \ - -I .. - - IDL_Files { - VTopic_Sender.idl - } -} - -project(DDS_VTopic_Sender_lem_gen) : ciaoidldefaults, dds4ccm { - after += DDS_VTopic_Sender_idl_gen - custom_only = 1 - idlflags += -Wb,stub_export_macro=SENDER_LEM_STUB_Export \ - -Wb,stub_export_include=Sender_lem_stub_export.h \ - -SS -Gxhst -I $CIAO_ROOT/connectors -I .. - - IDL_Files { - VTopic_SenderE.idl - } -} - -project(DDS_VTopic_Sender_lem_stub) : ccm_svnt, dds4ccm_base { - after += DDS_VTopic_Sender_lem_gen DDS_VTopic_Sender_stub DDS_VTopic_Base_stub - libs += DDS_VTopic_Base_stub Sender_stub - libpaths += ../lib - libout = ../lib - includes += .. - sharedname = Sender_lem_stub - dynamicflags += SENDER_LEM_STUB_BUILD_DLL - - IDL_Files { - } - - Source_Files { - VTopic_SenderEC.cpp - } - - Header_Files { - VTopic_SenderEC.h - Sender_lem_stub_export.h - } - - Inline_Files { - VTopic_SenderEC.inl - } -} - -project(DDS_VTopic_Sender_stub) : ccm_stub, dds4ccm_base { - after += DDS_VTopic_Sender_idl_gen DDS_VTopic_Base_stub \ - DDS_VTopic_Connector_lem_stub DDS_VTopic_Connector_stub \ - DDS_VT_String_Connector_lem_stub DDS_VT_String_Connector_stub \ - DDS_VT_Array_Connector_lem_stub DDS_VT_Array_Connector_stub \ - DDS_VT_Valuetype_Connector_lem_stub DDS_VT_Valuetype_Connector_stub \ - DDS_VT_Union_Connector_lem_stub DDS_VT_Union_Connector_stub \ - DDS_VT_Seq_Connector_lem_stub DDS_VT_Seq_Connector_stub - libs += DDS_VTopic_Base_stub DDS_VTopic_Connector_stub \ - DDS_VT_Array_Connector_stub DDS_VT_String_Connector_stub \ - DDS_VT_Seq_Connector_stub DDS_VT_Valuetype_Connector_stub \ - DDS_VT_Union_Connector_stub - includes += .. - libpaths += ../lib - libout = ../lib - sharedname = Sender_stub - dynamicflags += SENDER_STUB_BUILD_DLL - - IDL_Files { - } - - Source_Files { - VTopic_SenderC.cpp - } - - Header_Files { - VTopic_SenderC.h - Sender_stub_export.h - } - - Inline_Files { - VTopic_SenderC.inl - } -} - -project(DDS_VTopic_Sender_exec) : ciao_executor, dds4ccm_lem_stub { - after += DDS_VTopic_Sender_lem_stub DDS_VTopic_Sender_stub \ - DDS_VTopic_Connector_lem_stub DDS_VTopic_Connector_stub \ - DDS_VT_Array_Connector_lem_stub DDS_VT_Array_Connector_stub \ - DDS_VT_Valuetype_Connector_lem_stub DDS_VT_Valuetype_Connector_stub \ - DDS_VT_Union_Connector_lem_stub DDS_VT_Union_Connector_stub \ - DDS_VT_String_Connector_lem_stub DDS_VT_String_Connector_stub \ - DDS_VT_Seq_Connector_lem_stub DDS_VT_Seq_Connector_stub - sharedname = Sender_exec - libs += Sender_stub Sender_lem_stub DDS_VTopic_Base_stub \ - DDS_VTopic_Connector_lem_stub DDS_VTopic_Connector_stub \ - DDS_VT_Array_Connector_stub DDS_VT_String_Connector_stub \ - DDS_VT_Seq_Connector_stub DDS_VT_Valuetype_Connector_stub \ - DDS_VT_Union_Connector_stub - libpaths += ../lib - includes += .. - libout = ../lib - dynamicflags += SENDER_EXEC_BUILD_DLL - - IDL_Files { - } - - Source_Files { - VTopic_Sender_exec.cpp - } - - Header_Files { - VTopic_Sender_exec.h - Sender_exec_export.h - } - - Inline_Files { - } -} - - -project(DDS_VTopic_Sender_svnt) : ciao_servant, dds4ccm_lem_stub, dds4ccm_skel { - after += DDS_VTopic_Base_stub DDS_VTopic_Sender_lem_stub \ - DDS_VTopic_Connector_stub DDS_VTopic_Connector_svnt DDS_VTopic_Connector_lem_stub \ - DDS_VT_Array_Connector_stub DDS_VT_Array_Connector_svnt DDS_VT_Array_Connector_lem_stub \ - DDS_VT_Valuetype_Connector_stub DDS_VT_Valuetype_Connector_svnt DDS_VT_Valuetype_Connector_lem_stub \ - DDS_VT_Union_Connector_stub DDS_VT_Union_Connector_svnt DDS_VT_Union_Connector_lem_stub \ - DDS_VT_String_Connector_stub DDS_VT_String_Connector_svnt DDS_VT_String_Connector_lem_stub \ - DDS_VT_Seq_Connector_stub DDS_VT_Seq_Connector_svnt DDS_VT_Seq_Connector_lem_stub - sharedname = Sender_svnt - libs += Sender_stub Sender_lem_stub \ - DDS_VTopic_Base_stub \ - DDS_VTopic_Connector_stub DDS_VTopic_Connector_svnt \ - DDS_VT_Array_Connector_stub DDS_VT_Array_Connector_svnt \ - DDS_VT_Valuetype_Connector_stub DDS_VT_Valuetype_Connector_svnt \ - DDS_VT_Union_Connector_stub DDS_VT_Union_Connector_svnt \ - DDS_VT_String_Connector_stub DDS_VT_String_Connector_svnt \ - DDS_VT_Seq_Connector_stub DDS_VT_Seq_Connector_svnt - libpaths += ../lib - libout = ../lib - includes += .. - dynamicflags += SENDER_SVNT_BUILD_DLL - - IDL_Files { - } - - Source_Files { - VTopic_SenderS.cpp - VTopic_Sender_svnt.cpp - } - - Header_Files { - VTopic_SenderS.h - VTopic_Sender_svnt.h - Sender_svnt_export.h - } - - Inline_Files { - } -} - diff --git a/CIAO/connectors/dds4ccm/tests/VariousTopicsEvent/Sender/VTopic_Sender_exec.cpp b/CIAO/connectors/dds4ccm/tests/VariousTopicsEvent/Sender/VTopic_Sender_exec.cpp deleted file mode 100644 index 9bfe71d10d6..00000000000 --- a/CIAO/connectors/dds4ccm/tests/VariousTopicsEvent/Sender/VTopic_Sender_exec.cpp +++ /dev/null @@ -1,139 +0,0 @@ -// -*- C++ -*- - -//Test different topic types, with DDS_EVENT connectors, look for 'PUBLICATION_MATCHED_STATUS -#include "VTopic_Sender_exec.h" -#include "ace/Log_Msg.h" -#include "dds4ccm/impl/Utils.h" - -namespace CIAO_VTopic_Sender_Impl -{ - //============================================================ - // Facet Executor Implementation Class: ConnectorStatusListener_exec_i - //============================================================ - ConnectorStatusListener_exec_i::ConnectorStatusListener_exec_i ( - Atomic_Boolean &publication_matched) - : publication_matched_ (publication_matched) - { - } - - ConnectorStatusListener_exec_i::~ConnectorStatusListener_exec_i (void) - { - } - - // Operations from ::CCM_DDS::ConnectorStatusListener - 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_ = ::VTopic::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' in Sender\n") - )); - } - else - { - ACE_DEBUG ((LM_DEBUG, ACE_TEXT ("Received the expected ") - ACE_TEXT ("'PUBLICATION_MATCHED_STATUS' in Sender\n") - )); - } - } - - extern "C" SENDER_EXEC_Export ::Components::EnterpriseComponent_ptr - create_VTopic_Sender_Impl (void) - { - ::Components::EnterpriseComponent_ptr retval = - ::Components::EnterpriseComponent::_nil (); - ACE_NEW_NORETURN ( - retval, - Sender_exec_i); - - return retval; - } -} diff --git a/CIAO/connectors/dds4ccm/tests/VariousTopicsEvent/Sender/VTopic_Sender_exec.h b/CIAO/connectors/dds4ccm/tests/VariousTopicsEvent/Sender/VTopic_Sender_exec.h deleted file mode 100644 index 501bb50c7f8..00000000000 --- a/CIAO/connectors/dds4ccm/tests/VariousTopicsEvent/Sender/VTopic_Sender_exec.h +++ /dev/null @@ -1,81 +0,0 @@ -// -*- C++ -*- -#ifndef CIAO_SENDER_EXEC_H_ -#define CIAO_SENDER_EXEC_H_ - -#include "VTopic_SenderEC.h" - -#include /**/ "Sender_exec_export.h" - -#if !defined (ACE_LACKS_PRAGMA_ONCE) -# pragma once -#endif /* ACE_LACKS_PRAGMA_ONCE */ - -#include "tao/LocalObject.h" - -namespace CIAO_VTopic_Sender_Impl -{ - typedef ACE_Atomic_Op <TAO_SYNCH_MUTEX, CORBA::Boolean > Atomic_Boolean; - - class Sender_exec_i; - - class SENDER_EXEC_Export ConnectorStatusListener_exec_i - : public virtual ::CCM_DDS::CCM_ConnectorStatusListener, - public virtual ::CORBA::LocalObject - { - public: - ConnectorStatusListener_exec_i (Atomic_Boolean &); - virtual ~ConnectorStatusListener_exec_i (void); - - virtual - void on_inconsistent_topic (::DDS::Topic_ptr the_topic, - const DDS::InconsistentTopicStatus & status); - virtual - void on_requested_incompatible_qos (::DDS::DataReader_ptr the_reader, - const DDS::RequestedIncompatibleQosStatus & status); - virtual - void on_sample_rejected (::DDS::DataReader_ptr the_reader, - const DDS::SampleRejectedStatus & status); - virtual - void on_offered_deadline_missed (::DDS::DataWriter_ptr the_writer, - const DDS::OfferedDeadlineMissedStatus & status); - virtual - void on_offered_incompatible_qos (::DDS::DataWriter_ptr the_writer, - const DDS::OfferedIncompatibleQosStatus & status); - virtual - void on_unexpected_status (::DDS::Entity_ptr the_entity, - ::DDS::StatusKind status_kind); - private: - Atomic_Boolean &publication_matched_; - }; - - class Sender_exec_i - : public virtual Sender_Exec, - public virtual ::CORBA::LocalObject - { - public: - Sender_exec_i (void); - virtual ~Sender_exec_i (void); - - virtual void set_session_context (::Components::SessionContext_ptr ctx); - - virtual void configuration_complete (void); - virtual void ccm_activate (void); - virtual void ccm_passivate (void); - virtual void ccm_remove (void); - - // Port operations. - virtual ::CCM_DDS::CCM_ConnectorStatusListener_ptr - get_connector_status(void); - - private: - ::VTopic::CCM_Sender_Context_var context_; - - Atomic_Boolean publication_matched_; -}; - - extern "C" SENDER_EXEC_Export ::Components::EnterpriseComponent_ptr - create_VTopic_Sender_Impl (void); - -} - -#endif /* ifndef */ |