diff options
Diffstat (limited to 'CIAO/connectors/dds4ccm/tests/CollocatedPubSub/SubComponent')
4 files changed, 0 insertions, 503 deletions
diff --git a/CIAO/connectors/dds4ccm/tests/CollocatedPubSub/SubComponent/Sub_Component.idl b/CIAO/connectors/dds4ccm/tests/CollocatedPubSub/SubComponent/Sub_Component.idl deleted file mode 100644 index 791e62294f0..00000000000 --- a/CIAO/connectors/dds4ccm/tests/CollocatedPubSub/SubComponent/Sub_Component.idl +++ /dev/null @@ -1,13 +0,0 @@ -#ifndef SUB_COMPONENT_ -#define SUB_COMPONENT_ - -#include <Components.idl> -#include "Connector/Collocated_Connector.idl" - -module CoPubSub { - component Sub_comp { - port Test_conn::DDS_Listen TestSub; - }; -}; - -#endif // SUB_COMPONENT_ diff --git a/CIAO/connectors/dds4ccm/tests/CollocatedPubSub/SubComponent/Sub_Component.mpc b/CIAO/connectors/dds4ccm/tests/CollocatedPubSub/SubComponent/Sub_Component.mpc deleted file mode 100644 index 371880ecee3..00000000000 --- a/CIAO/connectors/dds4ccm/tests/CollocatedPubSub/SubComponent/Sub_Component.mpc +++ /dev/null @@ -1,143 +0,0 @@ -project(SubComponent_idl_gen) : componentidldefaults, dds4ccm { - after += Collocated_Connector_idl_gen DDS_Starter_idl_gen - custom_only = 1 - idlflags += -Wb,stub_export_macro=PUBSUB_COMPONENT_STUB_Export \ - -Wb,stub_export_include=Sub_Component_stub_export.h \ - -Wb,skel_export_macro=PUBSUB_COMPONENT_SVNT_Export \ - -Wb,skel_export_include=Sub_Component_svnt_export.h \ - -Wb,svnt_export_macro=PUBSUB_COMPONENT_SVNT_Export \ - -Wb,svnt_export_include=Sub_Component_svnt_export.h \ - -Wb,exec_export_macro=PUBSUB_COMPONENT_EXEC_Export \ - -Wb,exec_export_include=Sub_Component_exec_export.h \ - -I .. - - IDL_Files { - Sub_Component.idl - } -} - -project(SubComponent_lem_gen) : ciaoidldefaults, dds4ccm { - after += SubComponent_idl_gen - custom_only = 1 - idlflags += -Wb,stub_export_macro=PUBSUB_COMPONENT_LEM_STUB_Export \ - -Wb,stub_export_include=SubComponent_lem_stub_export.h \ - -SS -Gxhst -I $CIAO_ROOT/connectors -I .. - - IDL_Files { - Sub_ComponentE.idl - } -} - -project(SubComponent_lem_stub) : ccm_svnt, dds4ccm_base { - after += SubComponent_lem_gen SubComponent_stub \ - Collocated_Base_stub - libs += Collocated_Base_stub - libpaths += ../lib - libout = ../lib - includes += .. - sharedname = Sub_Component_lem_stub - dynamicflags += PUBSUB_COMPONENT_LEM_STUB_BUILD_DLL - - IDL_Files { - } - - Source_Files { - Sub_ComponentEC.cpp - } - - Header_Files { - Sub_ComponentEC.h - Sub_Component_lem_stub_export.h - } - - Inline_Files { - Sub_ComponentEC.inl - } -} - -project(SubComponent_stub) : ccm_stub, dds4ccm_base { - after += SubComponent_idl_gen Collocated_Base_stub \ - Collocated_Connector_stub - libs += Collocated_Base_stub Collocated_Connector_stub - includes += .. - libpaths += ../lib - libout = ../lib - sharedname = Sub_Component_stub - dynamicflags += PUBSUB_COMPONENT_STUB_BUILD_DLL - - IDL_Files { - } - - Source_Files { - Sub_ComponentC.cpp - } - - Header_Files { - Sub_ComponentC.h - Sub_Component_stub_export.h - } - - Inline_Files { - Sub_ComponentC.inl - } -} - -project(SubComponent_exec) : ciao_executor, dds4ccm_lem_stub { - after += SubComponent_lem_stub SubComponent_stub \ - Collocated_Connector_lem_stub Collocated_Connector_stub - sharedname = Sub_Component_exec - libs += Sub_Component_stub Sub_Component_lem_stub Collocated_Base_stub \ - Collocated_Connector_lem_stub Collocated_Connector_stub - libpaths += ../lib - includes += .. - libout = ../lib - dynamicflags += PUBSUB_COMPONENT_EXEC_BUILD_DLL - - IDL_Files { - } - - Source_Files { - Sub_Component_exec.cpp - } - - Header_Files { - Sub_Component_exec.h - Sub_Component_exec_export.h - } - - Inline_Files { - } -} - - -project(SubComponent_svnt) : ciao_servant, dds4ccm_lem_stub, dds4ccm_skel { - after += Collocated_Base_stub SubComponent_lem_stub \ - Collocated_Connector_stub \ - Collocated_Connector_svnt Collocated_Connector_lem_stub - sharedname = Sub_Component_svnt - libs += Sub_Component_stub Sub_Component_lem_stub Collocated_Base_stub \ - Collocated_Connector_stub Collocated_Connector_svnt \ - Collocated_Connector_lem_stub - libpaths += ../lib - libout = ../lib - includes += .. - dynamicflags += PUBSUB_COMPONENT_SVNT_BUILD_DLL - - IDL_Files { - } - - Source_Files { - Sub_ComponentS.cpp - Sub_Component_svnt.cpp - } - - Header_Files { - Sub_ComponentS.h - Sub_Component_svnt.h - Sub_Component_svnt_export.h - } - - Inline_Files { - } -} - diff --git a/CIAO/connectors/dds4ccm/tests/CollocatedPubSub/SubComponent/Sub_Component_exec.cpp b/CIAO/connectors/dds4ccm/tests/CollocatedPubSub/SubComponent/Sub_Component_exec.cpp deleted file mode 100644 index a644b08d8cd..00000000000 --- a/CIAO/connectors/dds4ccm/tests/CollocatedPubSub/SubComponent/Sub_Component_exec.cpp +++ /dev/null @@ -1,199 +0,0 @@ -// -*- C++ -*- -#include "Sub_Component_exec.h" - -namespace CIAO_CoPubSub_Sub_comp_Impl -{ - - /** - * Facet Executor Implementation Class: TestSub_data_listener_exec_i - */ - - TestSub_data_listener_exec_i::TestSub_data_listener_exec_i ( - ::CoPubSub::CCM_Sub_comp_Context_ptr ctx) - : ciao_context_ ( - ::CoPubSub::CCM_Sub_comp_Context::_duplicate (ctx)) - { - } - - TestSub_data_listener_exec_i::~TestSub_data_listener_exec_i (void) - { - } - - // Operations from ::CoPubSub::Test_conn::Listener - - void - TestSub_data_listener_exec_i::on_one_data ( - const ::CoPubSub::Test_msg & datum, - const ::CCM_DDS::ReadInfo & /* info */) - { - ACE_DEBUG ((LM_DEBUG, "TestSub_data_listener_exec_i::on_one_data - " - "New data received: <%C> - <%d>\n", - datum.hello.in (), datum.msgId)); - } - - void - TestSub_data_listener_exec_i::on_many_data ( - const ::CoPubSub::Test_msgSeq & /* data */, - const ::CCM_DDS::ReadInfoSeq & /* infos */) - { - /* Your code here. */ - } - - /** - * Facet Executor Implementation Class: TestSub_status_exec_i - */ - - TestSub_status_exec_i::TestSub_status_exec_i ( - ::CoPubSub::CCM_Sub_comp_Context_ptr ctx) - : ciao_context_ ( - ::CoPubSub::CCM_Sub_comp_Context::_duplicate (ctx)) - { - } - - TestSub_status_exec_i::~TestSub_status_exec_i (void) - { - } - - // Operations from ::CCM_DDS::PortStatusListener - - void - TestSub_status_exec_i::on_requested_deadline_missed ( - ::DDS::DataReader_ptr /* the_reader */, - const ::DDS::RequestedDeadlineMissedStatus & /* status */) - { - /* Your code here. */ - } - - void - TestSub_status_exec_i::on_sample_lost ( - ::DDS::DataReader_ptr /* the_reader */, - const ::DDS::SampleLostStatus & /* status */) - { - /* Your code here. */ - } - - /** - * Component Executor Implementation Class: Sub_comp_exec_i - */ - - Sub_comp_exec_i::Sub_comp_exec_i (void){ - } - - Sub_comp_exec_i::~Sub_comp_exec_i (void) - { - } - - // Supported operations and attributes. - - // Component attributes and port operations. - - ::CoPubSub::Test_conn::CCM_Listener_ptr - Sub_comp_exec_i::get_TestSub_data_listener (void) - { - if ( ::CORBA::is_nil (this->ciao_TestSub_data_listener_.in ())) - { - TestSub_data_listener_exec_i *tmp = 0; - ACE_NEW_RETURN ( - tmp, - TestSub_data_listener_exec_i ( - this->ciao_context_.in ()), - ::CoPubSub::Test_conn::CCM_Listener::_nil ()); - - this->ciao_TestSub_data_listener_ = tmp; - } - - return - ::CoPubSub::Test_conn::CCM_Listener::_duplicate ( - this->ciao_TestSub_data_listener_.in ()); - } - - ::CCM_DDS::CCM_PortStatusListener_ptr - Sub_comp_exec_i::get_TestSub_status (void) - { - if ( ::CORBA::is_nil (this->ciao_TestSub_status_.in ())) - { - TestSub_status_exec_i *tmp = 0; - ACE_NEW_RETURN ( - tmp, - TestSub_status_exec_i ( - this->ciao_context_.in ()), - ::CCM_DDS::CCM_PortStatusListener::_nil ()); - - this->ciao_TestSub_status_ = tmp; - } - - return - ::CCM_DDS::CCM_PortStatusListener::_duplicate ( - this->ciao_TestSub_status_.in ()); - } - - // Operations from Components::SessionComponent. - - void - Sub_comp_exec_i::set_session_context ( - ::Components::SessionContext_ptr ctx) - { - this->ciao_context_ = - ::CoPubSub::CCM_Sub_comp_Context::_narrow (ctx); - - if ( ::CORBA::is_nil (this->ciao_context_.in ())) - { - throw ::CORBA::INTERNAL (); - } - } - - void - Sub_comp_exec_i::configuration_complete (void) - { - /* Your code here. */ - } - - void - Sub_comp_exec_i::ccm_activate (void) - { - CCM_DDS::DataListenerControl_var control = - ciao_context_->get_connection_TestSub_data_control(); - - if (! CORBA::is_nil(control.in())) - { - try - { - control->mode(CCM_DDS::ONE_BY_ONE); - } - catch (const CORBA::Exception & ex) - { - ex._tao_print_exception("Sub_comp_exec_i::ccm_activate - ERROR: "); - } - } - else - { - ACE_ERROR ((LM_ERROR, "Sub_comp_exec_i::ccm_activate - " - "ERROR: Listener control is nil.\n")); - } - } - - void - Sub_comp_exec_i::ccm_passivate (void) - { - /* Your code here. */ - } - - void - Sub_comp_exec_i::ccm_remove (void) - { - /* Your code here. */ - } - - extern "C" PUBSUB_COMPONENT_EXEC_Export ::Components::EnterpriseComponent_ptr - create_CoPubSub_Sub_comp_Impl (void) - { - ::Components::EnterpriseComponent_ptr retval = - ::Components::EnterpriseComponent::_nil (); - - ACE_NEW_NORETURN ( - retval, - Sub_comp_exec_i); - - return retval; - } -} diff --git a/CIAO/connectors/dds4ccm/tests/CollocatedPubSub/SubComponent/Sub_Component_exec.h b/CIAO/connectors/dds4ccm/tests/CollocatedPubSub/SubComponent/Sub_Component_exec.h deleted file mode 100644 index 4b6c45083f7..00000000000 --- a/CIAO/connectors/dds4ccm/tests/CollocatedPubSub/SubComponent/Sub_Component_exec.h +++ /dev/null @@ -1,148 +0,0 @@ -// -*- C++ -*- -#ifndef CIAO_SUB_COMPONENT_EXEC_SXAYYT_H_ -#define CIAO_SUB_COMPONENT_EXEC_SXAYYT_H_ - -#include /**/ "ace/pre.h" - -#include "Sub_ComponentEC.h" - -#if !defined (ACE_LACKS_PRAGMA_ONCE) -# pragma once -#endif /* ACE_LACKS_PRAGMA_ONCE */ - -#include /**/ "Sub_Component_exec_export.h" -#include "tao/LocalObject.h" - -namespace CIAO_CoPubSub_Sub_comp_Impl -{ - - /** - * Provider Executor Implementation Class: TestSub_data_listener_exec_i - */ - - class TestSub_data_listener_exec_i - : public virtual ::CoPubSub::Test_conn::CCM_Listener, - public virtual ::CORBA::LocalObject - { - public: - TestSub_data_listener_exec_i ( - ::CoPubSub::CCM_Sub_comp_Context_ptr ctx); - virtual ~TestSub_data_listener_exec_i (void); - - /** @name Operations and attributes from CoPubSub::Test_conn::Listener */ - //@{ - - virtual - void on_one_data ( - const ::CoPubSub::Test_msg & datum, - const ::CCM_DDS::ReadInfo & info); - - virtual - void on_many_data ( - const ::CoPubSub::Test_msgSeq & data, - const ::CCM_DDS::ReadInfoSeq & infos); - //@} - - private: - ::CoPubSub::CCM_Sub_comp_Context_var ciao_context_; - }; - - /** - * Provider Executor Implementation Class: TestSub_status_exec_i - */ - - class TestSub_status_exec_i - : public virtual ::CCM_DDS::CCM_PortStatusListener, - public virtual ::CORBA::LocalObject - { - public: - TestSub_status_exec_i ( - ::CoPubSub::CCM_Sub_comp_Context_ptr ctx); - virtual ~TestSub_status_exec_i (void); - - /** @name Operations and attributes from CCM_DDS::PortStatusListener */ - //@{ - - virtual - void on_requested_deadline_missed ( - ::DDS::DataReader_ptr the_reader, - const ::DDS::RequestedDeadlineMissedStatus & status); - - virtual - void on_sample_lost ( - ::DDS::DataReader_ptr the_reader, - const ::DDS::SampleLostStatus & status); - //@} - - private: - ::CoPubSub::CCM_Sub_comp_Context_var ciao_context_; - }; - - /** - * Component Executor Implementation Class: Sub_comp_exec_i - */ - - class Sub_comp_exec_i - : public virtual Sub_comp_Exec, - public virtual ::CORBA::LocalObject - { - public: - Sub_comp_exec_i (void); - virtual ~Sub_comp_exec_i (void); - - /** @name Supported operations and attributes. */ - //@{ - - //@} - - /** @name Component attributes and port operations. */ - //@{ - - virtual ::CoPubSub::Test_conn::CCM_Listener_ptr - get_TestSub_data_listener (void); - - virtual ::CCM_DDS::CCM_PortStatusListener_ptr - get_TestSub_status (void); - //@} - - /** @name Operations from Components::SessionComponent. */ - //@{ - 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); - //@} - - /** @name User defined public operations. */ - //@{ - - //@} - - private: - ::CoPubSub::CCM_Sub_comp_Context_var ciao_context_; - - /** @name Component attributes. */ - //@{ - ::CoPubSub::Test_conn::CCM_Listener_var ciao_TestSub_data_listener_; - ::CCM_DDS::CCM_PortStatusListener_var ciao_TestSub_status_; - //@} - - /** @name User defined members. */ - //@{ - - //@} - - /** @name User defined private operations. */ - //@{ - - //@} - }; - - extern "C" PUBSUB_COMPONENT_EXEC_Export ::Components::EnterpriseComponent_ptr - create_CoPubSub_Sub_comp_Impl (void); -} - -#include /**/ "ace/post.h" - -#endif /* ifndef */ |