diff options
author | Johnny Willemsen <jwillemsen@remedy.nl> | 2016-04-19 19:34:09 +0200 |
---|---|---|
committer | Johnny Willemsen <jwillemsen@remedy.nl> | 2016-04-19 19:34:09 +0200 |
commit | 67fe053a4b2cd800bb0c12f546420fb358b86608 (patch) | |
tree | 23a13116f12541b9eee310f575086c0b7a994ad7 /CIAO/connectors/dds4ccm/tests/DDSEntity/Receiver | |
parent | fd904693d47bc0f9c3c110e1b6beff016581926d (diff) | |
download | ATCD-67fe053a4b2cd800bb0c12f546420fb358b86608.tar.gz |
Remove CIAO/DAnCE here because they are migrated to their own repositories
Diffstat (limited to 'CIAO/connectors/dds4ccm/tests/DDSEntity/Receiver')
5 files changed, 0 insertions, 639 deletions
diff --git a/CIAO/connectors/dds4ccm/tests/DDSEntity/Receiver/.gitignore b/CIAO/connectors/dds4ccm/tests/DDSEntity/Receiver/.gitignore deleted file mode 100644 index f2f7d84b894..00000000000 --- a/CIAO/connectors/dds4ccm/tests/DDSEntity/Receiver/.gitignore +++ /dev/null @@ -1,5 +0,0 @@ -/Receiver_exec_export.h -/Receiver_lem_stub_export.h -/Receiver_stub_export.h -/Receiver_svnt_export.h -/Writer_ReceiverE.idl diff --git a/CIAO/connectors/dds4ccm/tests/DDSEntity/Receiver/Writer_Receiver.idl b/CIAO/connectors/dds4ccm/tests/DDSEntity/Receiver/Writer_Receiver.idl deleted file mode 100644 index 344e3826c91..00000000000 --- a/CIAO/connectors/dds4ccm/tests/DDSEntity/Receiver/Writer_Receiver.idl +++ /dev/null @@ -1,19 +0,0 @@ -/** - * @file - * @author Marcel Smit (msmit@remedy.nl) - */ - -#ifndef RECEIVER_IDL -#define RECEIVER_IDL - -#include "Connector/Writer_Connector.idl" - -module Writer -{ - component Receiver - { - port WriterTestConnector::DDS_Listen info_out; - }; -}; - -#endif diff --git a/CIAO/connectors/dds4ccm/tests/DDSEntity/Receiver/Writer_Receiver.mpc b/CIAO/connectors/dds4ccm/tests/DDSEntity/Receiver/Writer_Receiver.mpc deleted file mode 100644 index 399ff061ff2..00000000000 --- a/CIAO/connectors/dds4ccm/tests/DDSEntity/Receiver/Writer_Receiver.mpc +++ /dev/null @@ -1,138 +0,0 @@ -project(DDS_DDSWriterEntityReceiver_idl_gen) : componentidldefaults, dds4ccm { - custom_only = 1 - after += DDS_DDSWriterEntityConnector_idl_gen - idlflags += -Wb,stub_export_macro=RECEIVER_STUB_Export \ - -Wb,stub_export_include=Receiver_stub_export.h \ - -Wb,skel_export_macro=RECEIVER_SVNT_Export \ - -Wb,skel_export_include=Receiver_svnt_export.h \ - -Wb,svnt_export_macro=RECEIVER_SVNT_Export \ - -Wb,svnt_export_include=Receiver_svnt_export.h \ - -Wb,exec_export_macro=RECEIVER_EXEC_Export \ - -Wb,exec_export_include=Receiver_exec_export.h \ - -I.. - - IDL_Files { - Writer_Receiver.idl - } -} - -project(DDS_DDSWriterEntityReceiver_lem_gen) : ciaoidldefaults, dds4ccm { - after += DDS_DDSWriterEntityReceiver_idl_gen - custom_only = 1 - idlflags += -Wb,stub_export_macro=RECEIVER_LEM_STUB_Export \ - -Wb,stub_export_include=Receiver_lem_stub_export.h \ - -SS -Gxhst -I.. - - IDL_Files { - Writer_ReceiverE.idl - } -} - -project(DDS_DDSWriterEntityReceiver_lem_stub) : ccm_svnt, dds4ccm_base { - after += DDS_DDSWriterEntityReceiver_lem_gen DDS_DDSWriterEntityReceiver_stub DDS_DDSWriterEntityConnector_stub DDS_DDSWriterEntityBase_stub - libs += Receiver_stub DDS_DDSWriterEntityConnector_stub DDS_DDSWriterEntityBase_stub - libpaths += ../lib - libout = ../lib - includes += .. - sharedname = Receiver_lem_stub - dynamicflags += RECEIVER_LEM_STUB_BUILD_DLL - - IDL_Files { - } - - Source_Files { - Writer_ReceiverEC.cpp - } - - Header_Files { - Writer_ReceiverEC.h - Receiver_lem_stub_export.h - } - - Inline_Files { - Writer_ReceiverEC.inl - } -} - -project(DDS_DDSWriterEntityReceiver_stub) : ccm_stub, dds4ccm_base { - after += DDS_DDSWriterEntityReceiver_idl_gen DDS_DDSWriterEntityConnector_stub DDS_DDSWriterEntityBase_stub DDS_DDSWriterEntityConnector_lem_gen - libs += DDS_DDSWriterEntityConnector_stub DDS_DDSWriterEntityBase_stub - libpaths += ../lib - libout = ../lib - includes += .. - sharedname = Receiver_stub - dynamicflags += RECEIVER_STUB_BUILD_DLL - - IDL_Files { - } - - Source_Files { - Writer_ReceiverC.cpp - } - - Header_Files { - Writer_ReceiverC.h - Receiver_stub_export.h - } - - Inline_Files { - Writer_ReceiverC.inl - } -} - -project(DDS_DDSWriterEntityReceiver_exec) : ciao_executor, dds4ccm_impl { - after += DDS_DDSWriterEntityReceiver_lem_stub DDS_DDSWriterEntityReceiver_stub DDS_DDSWriterEntityBase_stub DDS_DDSWriterEntityConnector_stub DDS_DDSWriterEntityConnector_lem_stub - sharedname = Receiver_exec - libs += Receiver_stub Receiver_lem_stub DDS_DDSWriterEntityBase_stub DDS_DDSWriterEntityConnector_stub DDS_DDSWriterEntityConnector_lem_stub - libpaths += ../lib - libout = ../lib - includes += .. - dynamicflags += RECEIVER_EXEC_BUILD_DLL - requires += dds4ccm_ndds - - IDL_Files { - } - - Source_Files { - Writer_Receiver_exec.cpp - } - - Header_Files { - Writer_Receiver_exec.h - Receiver_exec_export.h - } - - Inline_Files { - } -} - - -project(DDS_DDSWriterEntityReceiver_svnt) : ciao_servant, dds4ccm_lem_stub, dds4ccm_skel { - after += DDS_DDSWriterEntityReceiver_lem_stub DDS_DDSWriterEntityBase_stub DDS_DDSWriterEntityConnector_stub DDS_DDSWriterEntityConnector_svnt DDS_DDSWriterEntityReceiver_exec DDS_DDSWriterEntityConnector_lem_stub - sharedname = Receiver_svnt - libs += Receiver_stub Receiver_lem_stub DDS_DDSWriterEntityBase_stub DDS_DDSWriterEntityConnector_stub DDS_DDSWriterEntityConnector_svnt Receiver_exec DDS_DDSWriterEntityConnector_lem_stub - libpaths += ../lib - libout = ../lib - includes += .. - dynamicflags += RECEIVER_SVNT_BUILD_DLL - requires += dds4ccm_ndds - - IDL_Files { - } - - Source_Files { - Writer_ReceiverS.cpp - Writer_Receiver_svnt.cpp - } - - Header_Files { - Writer_ReceiverS.h - Writer_Receiver_svnt.h - Receiver_svnt_export.h - } - - Inline_Files { - } -} - - diff --git a/CIAO/connectors/dds4ccm/tests/DDSEntity/Receiver/Writer_Receiver_exec.cpp b/CIAO/connectors/dds4ccm/tests/DDSEntity/Receiver/Writer_Receiver_exec.cpp deleted file mode 100644 index 616c6e25646..00000000000 --- a/CIAO/connectors/dds4ccm/tests/DDSEntity/Receiver/Writer_Receiver_exec.cpp +++ /dev/null @@ -1,308 +0,0 @@ -// -*- C++ -*- -/** - * Code generated by the The ACE ORB (TAO) IDL Compiler v1.8.3 - * TAO and the TAO IDL Compiler have been developed by: - * Center for Distributed Object Computing - * Washington University - * St. Louis, MO - * USA - * http://www.cs.wustl.edu/~schmidt/doc-center.html - * and - * Distributed Object Computing Laboratory - * University of California at Irvine - * Irvine, CA - * USA - * and - * Institute for Software Integrated Systems - * Vanderbilt University - * Nashville, TN - * USA - * http://www.isis.vanderbilt.edu/ - * - * Information about TAO is available at: - * http://www.dre.vanderbilt.edu/~schmidt/TAO.html - **/ - -#include "Writer_Receiver_exec.h" -#include "tao/ORB_Core.h" -#include "ace/Reactor.h" - -#include "Connector/Writer_Connector_conn.h" -#include <dds4ccm/impl/CCM_DataReader.h> - -namespace CIAO_Writer_Receiver_Impl -{ - - /** - * Facet Executor Implementation Class: info_out_data_listener_exec_i - */ - - info_out_data_listener_exec_i::info_out_data_listener_exec_i ( - ::Writer::CCM_Receiver_Context_ptr ctx) - : ciao_context_ ( - ::Writer::CCM_Receiver_Context::_duplicate (ctx)) - { - } - - info_out_data_listener_exec_i::~info_out_data_listener_exec_i (void) - { - } - - // Operations from ::WriterTestConnector::Listener - - void - info_out_data_listener_exec_i::on_one_data (const ::WriterTest & datum, - const ::CCM_DDS::ReadInfo & /* info */) - { - ACE_DEBUG ((LM_DEBUG, ACE_TEXT ("WriterTest_Listener: ") - ACE_TEXT ("received writer info for <%C> at %u\n"), - datum.key.in (), - datum.iteration)); - } - - void - info_out_data_listener_exec_i::on_many_data (const ::WriterTestSeq & data, - const ::CCM_DDS::ReadInfoSeq & /* infos */) - { - for (CORBA::ULong i = 0; i < data.length (); ++i) - { - ACE_DEBUG ((LM_DEBUG, ACE_TEXT ("WriterTest_Listener: ") - ACE_TEXT ("received writer info for <%C> at %u\n"), - data[i].key.in (), - data[i].iteration)); - } - } - - /** - * Facet Executor Implementation Class: info_out_status_exec_i - */ - - info_out_status_exec_i::info_out_status_exec_i ( - ::Writer::CCM_Receiver_Context_ptr ctx) - : ciao_context_ ( - ::Writer::CCM_Receiver_Context::_duplicate (ctx)) - { - } - - info_out_status_exec_i::~info_out_status_exec_i (void) - { - } - - // Operations from ::CCM_DDS::PortStatusListener - - void - info_out_status_exec_i::on_requested_deadline_missed (::DDS::DataReader_ptr /* the_reader */, - const ::DDS::RequestedDeadlineMissedStatus & /* status */) - { - /* Your code here. */ - } - - void - info_out_status_exec_i::on_sample_lost (::DDS::DataReader_ptr /* the_reader */, - const ::DDS::SampleLostStatus & /* status */) - { - /* Your code here. */ - } - - /** - * Component Executor Implementation Class: Receiver_exec_i - */ - - Receiver_exec_i::Receiver_exec_i (void){ - } - - Receiver_exec_i::~Receiver_exec_i (void) - { - } - - // Supported operations and attributes. - - // Component attributes and port operations. - - ::WriterTestConnector::CCM_Listener_ptr - Receiver_exec_i::get_info_out_data_listener (void) - { - if ( ::CORBA::is_nil (this->ciao_info_out_data_listener_.in ())) - { - info_out_data_listener_exec_i *tmp = 0; - ACE_NEW_RETURN ( - tmp, - info_out_data_listener_exec_i ( - this->ciao_context_.in ()), - ::WriterTestConnector::CCM_Listener::_nil ()); - - this->ciao_info_out_data_listener_ = tmp; - } - - return - ::WriterTestConnector::CCM_Listener::_duplicate ( - this->ciao_info_out_data_listener_.in ()); - } - - ::CCM_DDS::CCM_PortStatusListener_ptr - Receiver_exec_i::get_info_out_status (void) - { - if ( ::CORBA::is_nil (this->ciao_info_out_status_.in ())) - { - info_out_status_exec_i *tmp = 0; - ACE_NEW_RETURN ( - tmp, - info_out_status_exec_i ( - this->ciao_context_.in ()), - ::CCM_DDS::CCM_PortStatusListener::_nil ()); - - this->ciao_info_out_status_ = tmp; - } - - return - ::CCM_DDS::CCM_PortStatusListener::_duplicate ( - this->ciao_info_out_status_.in ()); - } - - // Operations from Components::SessionComponent. - - void - Receiver_exec_i::set_session_context ( - ::Components::SessionContext_ptr ctx) - { - this->ciao_context_ = - ::Writer::CCM_Receiver_Context::_narrow (ctx); - - if ( ::CORBA::is_nil (this->ciao_context_.in ())) - { - throw ::CORBA::INTERNAL (); - } - } - - void - Receiver_exec_i::configuration_complete (void) - { - /* Your code here. */ - } - - void - Receiver_exec_i::ccm_activate (void) - { - WriterTestDataReader * reader = 0; - - ::DDS::DataReader_var dds_dr = - this->ciao_context_->get_connection_info_out_dds_entity (); - - if (::CORBA::is_nil (dds_dr.in ())) - { - ACE_ERROR ((LM_ERROR, "ERROR : Receiver_exec_i::ccm_activate - " - "Datareader connection is NIL.\n")); - throw ::CORBA::INTERNAL (); - } - - ::CIAO::DDS4CCM::CCM_DataReader * ccm_dr = - dynamic_cast < ::CIAO::DDS4CCM::CCM_DataReader * > (dds_dr.in ()); - - if (ccm_dr) - { - typedef ::CIAO::NDDS::DDS_DataReader_Base DataReader_type; - - ::DDS::DataReader_var tmp = ccm_dr->get_dds_entity (); - if (! ::CORBA::is_nil (tmp.in ())) - { - DataReader_type * typed_ccm_dr = - dynamic_cast <DataReader_type*> (tmp.in ()); - if (typed_ccm_dr) - { - DDSDataReader* dds_reader = typed_ccm_dr->get_rti_entity (); - if (dds_reader) - { - reader = ::CIAO_WriterTestConnector_DDS_Event_Impl - ::WriterTest_DDS_Traits - ::datareader_type::narrow (dds_reader); - if (!reader) - { - ACE_ERROR ((LM_ERROR, "ERROR : Receiver_exec_i::ccm_activate - " - "Error narrowing to a typed " - "DDS DataReader.\n")); - throw ::CORBA::INTERNAL (); - } - } - else - { - ACE_ERROR ((LM_ERROR, "ERROR : Receiver_exec_i::ccm_activate - " - "Error getting DDS Datareader.\n")); - throw ::CORBA::INTERNAL (); - } - } - else - { - ACE_ERROR ((LM_ERROR, "ERROR : Receiver_exec_i::ccm_activate - " - "Error casting DataReader to typed DataReader\n")); - throw ::CORBA::INTERNAL (); - } - } - else - { - ACE_ERROR ((LM_ERROR, "ERROR : Receiver_exec_i::ccm_activate - " - "::DDS::DataReader of CCM DataReader seems nil\n")); - throw ::CORBA::INTERNAL (); - } - } - else - { - ACE_ERROR ((LM_ERROR, "ERROR : Receiver_exec_i::ccm_activate - " - "Error casting DDS::DataReader to CCM_DataReader\n")); - throw ::CORBA::INTERNAL (); - } - - ::CIAO_WriterTestConnector_DDS_Event_Impl::WriterTest_DDS_Traits::dds_seq_type - data; - ::CIAO_WriterTestConnector_DDS_Event_Impl::WriterTest_DDS_Traits::sampleinfo_seq_type - sample_info_seq; - - ::DDS::ReturnCode_t const result = reader->take ( - data, - sample_info_seq, - 1, - 0); - - ACE_DEBUG ((LM_DEBUG, "Take returned %C with %d samples\n", - ::CIAO::DDS4CCM::translate_retcode (result), data.length ())); - - ::DDS::ReturnCode_t const result_loan = reader->return_loan (data, sample_info_seq); - - ACE_DEBUG ((LM_DEBUG, "Return loan returned %C\n", - ::CIAO::DDS4CCM::translate_retcode (result_loan))); - - ::CCM_DDS::DataListenerControl_var lc = - this->ciao_context_->get_connection_info_out_data_control (); - - if (::CORBA::is_nil (lc.in ())) - { - ACE_ERROR ((LM_INFO, ACE_TEXT ("Error: Listener control receptacle is null!\n"))); - throw ::CORBA::INTERNAL (); - } - lc->mode (::CCM_DDS::ONE_BY_ONE); - } - - void - Receiver_exec_i::ccm_passivate (void) - { - /* Your code here. */ - } - - void - Receiver_exec_i::ccm_remove (void) - { - /* Your code here. */ - } - - extern "C" RECEIVER_EXEC_Export ::Components::EnterpriseComponent_ptr - create_Writer_Receiver_Impl (void) - { - ::Components::EnterpriseComponent_ptr retval = - ::Components::EnterpriseComponent::_nil (); - - ACE_NEW_NORETURN ( - retval, - Receiver_exec_i); - - return retval; - } -} diff --git a/CIAO/connectors/dds4ccm/tests/DDSEntity/Receiver/Writer_Receiver_exec.h b/CIAO/connectors/dds4ccm/tests/DDSEntity/Receiver/Writer_Receiver_exec.h deleted file mode 100644 index 82201909a1b..00000000000 --- a/CIAO/connectors/dds4ccm/tests/DDSEntity/Receiver/Writer_Receiver_exec.h +++ /dev/null @@ -1,169 +0,0 @@ -// -*- C++ -*- -/** - * Code generated by the The ACE ORB (TAO) IDL Compiler v1.8.3 - * TAO and the TAO IDL Compiler have been developed by: - * Center for Distributed Object Computing - * Washington University - * St. Louis, MO - * USA - * http://www.cs.wustl.edu/~schmidt/doc-center.html - * and - * Distributed Object Computing Laboratory - * University of California at Irvine - * Irvine, CA - * USA - * and - * Institute for Software Integrated Systems - * Vanderbilt University - * Nashville, TN - * USA - * http://www.isis.vanderbilt.edu/ - * - * Information about TAO is available at: - * http://www.dre.vanderbilt.edu/~schmidt/TAO.html - **/ -#ifndef CIAO_WRITER_RECEIVER_EXEC_VZNVAP_H_ -#define CIAO_WRITER_RECEIVER_EXEC_VZNVAP_H_ - -#include /**/ "ace/pre.h" - -#include "Writer_ReceiverEC.h" - -#if !defined (ACE_LACKS_PRAGMA_ONCE) -# pragma once -#endif /* ACE_LACKS_PRAGMA_ONCE */ - -#include /**/ "Receiver_exec_export.h" -#include "tao/LocalObject.h" - -class WriterTestDataReader; - -namespace CIAO_Writer_Receiver_Impl -{ - - /** - * Provider Executor Implementation Class: info_out_data_listener_exec_i - */ - - class info_out_data_listener_exec_i - : public virtual ::WriterTestConnector::CCM_Listener, - public virtual ::CORBA::LocalObject - { - public: - info_out_data_listener_exec_i ( - ::Writer::CCM_Receiver_Context_ptr ctx); - virtual ~info_out_data_listener_exec_i (void); - - //@{ - /** Operations and attributes from WriterTestConnector::Listener. */ - - virtual - void on_one_data (const ::WriterTest & datum, - const ::CCM_DDS::ReadInfo & info); - - virtual - void on_many_data (const ::WriterTestSeq & data, - const ::CCM_DDS::ReadInfoSeq & infos); - //@} - - private: - ::Writer::CCM_Receiver_Context_var ciao_context_; - }; - - /** - * Provider Executor Implementation Class: info_out_status_exec_i - */ - - class info_out_status_exec_i - : public virtual ::CCM_DDS::CCM_PortStatusListener, - public virtual ::CORBA::LocalObject - { - public: - info_out_status_exec_i ( - ::Writer::CCM_Receiver_Context_ptr ctx); - virtual ~info_out_status_exec_i (void); - - //@{ - /** 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: - ::Writer::CCM_Receiver_Context_var ciao_context_; - }; - - /** - * Component Executor Implementation Class: Receiver_exec_i - */ - - class Receiver_exec_i - : public virtual Receiver_Exec, - public virtual ::CORBA::LocalObject - { - public: - Receiver_exec_i (void); - virtual ~Receiver_exec_i (void); - - //@{ - /** Supported operations and attributes. */ - - //@} - - //@{ - /** Component attributes and port operations. */ - - virtual ::WriterTestConnector::CCM_Listener_ptr - get_info_out_data_listener (void); - - virtual ::CCM_DDS::CCM_PortStatusListener_ptr - get_info_out_status (void); - //@} - - //@{ - /** 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); - //@} - - //@{ - /** User defined public operations. */ - - //@} - - private: - ::Writer::CCM_Receiver_Context_var ciao_context_; - - //@{ - /** Component attributes. */ - ::WriterTestConnector::CCM_Listener_var ciao_info_out_data_listener_; - ::CCM_DDS::CCM_PortStatusListener_var ciao_info_out_status_; - //@} - - //@{ - /** User defined members. */ - - //@} - - //@{ - /** User defined private operations. */ - - //@} - }; - - extern "C" RECEIVER_EXEC_Export ::Components::EnterpriseComponent_ptr - create_Writer_Receiver_Impl (void); -} - -#include /**/ "ace/post.h" - -#endif /* ifndef */ |