summaryrefslogtreecommitdiff
path: root/CIAO/connectors/dds4ccm/tests/DDSEntity/Receiver
diff options
context:
space:
mode:
authorJohnny Willemsen <jwillemsen@remedy.nl>2016-04-19 19:34:09 +0200
committerJohnny Willemsen <jwillemsen@remedy.nl>2016-04-19 19:34:09 +0200
commit67fe053a4b2cd800bb0c12f546420fb358b86608 (patch)
tree23a13116f12541b9eee310f575086c0b7a994ad7 /CIAO/connectors/dds4ccm/tests/DDSEntity/Receiver
parentfd904693d47bc0f9c3c110e1b6beff016581926d (diff)
downloadATCD-67fe053a4b2cd800bb0c12f546420fb358b86608.tar.gz
Remove CIAO/DAnCE here because they are migrated to their own repositories
Diffstat (limited to 'CIAO/connectors/dds4ccm/tests/DDSEntity/Receiver')
-rw-r--r--CIAO/connectors/dds4ccm/tests/DDSEntity/Receiver/.gitignore5
-rw-r--r--CIAO/connectors/dds4ccm/tests/DDSEntity/Receiver/Writer_Receiver.idl19
-rw-r--r--CIAO/connectors/dds4ccm/tests/DDSEntity/Receiver/Writer_Receiver.mpc138
-rw-r--r--CIAO/connectors/dds4ccm/tests/DDSEntity/Receiver/Writer_Receiver_exec.cpp308
-rw-r--r--CIAO/connectors/dds4ccm/tests/DDSEntity/Receiver/Writer_Receiver_exec.h169
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 */