diff options
Diffstat (limited to 'CIAO/connectors/dds4ccm/tests/InstanceHandle/Sender')
5 files changed, 0 insertions, 682 deletions
diff --git a/CIAO/connectors/dds4ccm/tests/InstanceHandle/Sender/.gitignore b/CIAO/connectors/dds4ccm/tests/InstanceHandle/Sender/.gitignore deleted file mode 100644 index 809d63704bc..00000000000 --- a/CIAO/connectors/dds4ccm/tests/InstanceHandle/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 -/Writer_SenderE.idl diff --git a/CIAO/connectors/dds4ccm/tests/InstanceHandle/Sender/Writer_Sender.idl b/CIAO/connectors/dds4ccm/tests/InstanceHandle/Sender/Writer_Sender.idl deleted file mode 100644 index 7f022778f2e..00000000000 --- a/CIAO/connectors/dds4ccm/tests/InstanceHandle/Sender/Writer_Sender.idl +++ /dev/null @@ -1,19 +0,0 @@ -/** - * @author Marcel Smit (msmit@remedy.nl) - */ - -#ifndef DDS_WRITER_ENTITY_SENDER_IDL -#define DDS_WRITER_ENTITY_SENDER_IDL - -#include "Connector/Writer_Connector.idl" - -module Writer -{ - component Sender - { - port WriterTestConnector::DDS_Write info_write; - attribute unsigned short keys; - }; -}; - -#endif /* DDS_WRITER_ENTITY_SENDER_IDL */ diff --git a/CIAO/connectors/dds4ccm/tests/InstanceHandle/Sender/Writer_Sender.mpc b/CIAO/connectors/dds4ccm/tests/InstanceHandle/Sender/Writer_Sender.mpc deleted file mode 100644 index a3867be6e49..00000000000 --- a/CIAO/connectors/dds4ccm/tests/InstanceHandle/Sender/Writer_Sender.mpc +++ /dev/null @@ -1,145 +0,0 @@ -// This file is generated with "generate_component_mpc.pl -p DDS_DDSInstanceHandleBase -l ../lib -o ../lib -c controller -u DDS Sender" - -project(DDS_DDSInstanceHandleSender_idl_gen) : componentidldefaults, dds4ccm { - after += DDS_InstanceHandleConnector_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 { - Writer_Sender.idl - } -} - -project(DDS_DDSInstanceHandleSender_lem_gen) : ciaoidldefaults, dds4ccm { - after += DDS_DDSInstanceHandleSender_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 { - Writer_SenderE.idl - } -} - -project(DDS_DDSInstanceHandleSender_lem_stub) : ccm_svnt, dds4ccm_base { - after += DDS_DDSInstanceHandleSender_lem_gen DDS_DDSInstanceHandleSender_stub \ - DDS_DDSInstanceHandleBase_stub - libs += DDS_DDSInstanceHandleBase_stub Sender_stub - libpaths += ../lib - libout = ../lib - includes += .. - sharedname = Sender_lem_stub - dynamicflags += SENDER_LEM_STUB_BUILD_DLL - - IDL_Files { - } - - Source_Files { - Writer_SenderEC.cpp - } - - Header_Files { - Writer_SenderEC.h - Sender_lem_stub_export.h - } - - Inline_Files { - Writer_SenderEC.inl - } -} - -project(DDS_DDSInstanceHandleSender_stub) : ccm_stub, dds4ccm_base { - after += DDS_DDSInstanceHandleSender_idl_gen DDS_DDSInstanceHandleBase_stub \ - DDS_InstanceHandleConnector_stub - libs += DDS_DDSInstanceHandleBase_stub DDS_InstanceHandleConnector_stub - includes += .. - libpaths += ../lib - libout = ../lib - sharedname = Sender_stub - dynamicflags += SENDER_STUB_BUILD_DLL - - IDL_Files { - } - - Source_Files { - Writer_SenderC.cpp - } - - Header_Files { - Writer_SenderC.h - Sender_stub_export.h - } - - Inline_Files { - Writer_SenderC.inl - } -} - -project(DDS_DDSInstanceHandleSender_exec) : ciao_executor, dds4ccm_impl { - after += DDS_DDSInstanceHandleSender_lem_stub DDS_DDSInstanceHandleSender_stub \ - DDS_InstanceHandleConnector_lem_stub DDS_InstanceHandleConnector_stub - sharedname = Sender_exec - libs += Sender_stub Sender_lem_stub DDS_DDSInstanceHandleBase_stub \ - DDS_InstanceHandleConnector_lem_stub DDS_InstanceHandleConnector_stub - libpaths += ../lib - includes += .. - libout = ../lib - dynamicflags += SENDER_EXEC_BUILD_DLL - - IDL_Files { - } - - Source_Files { - Writer_Sender_exec.cpp - } - - Header_Files { - Writer_Sender_exec.h - Sender_exec_export.h - } - - Inline_Files { - } -} - - -project(DDS_DDSInstanceHandleSender_svnt) : ciao_servant, dds4ccm_lem_stub, dds4ccm_skel { - after += DDS_DDSInstanceHandleBase_stub DDS_DDSInstanceHandleSender_lem_stub \ - DDS_InstanceHandleConnector_stub \ - DDS_InstanceHandleConnector_svnt DDS_InstanceHandleConnector_lem_stub - sharedname = Sender_svnt - libs += Sender_stub Sender_lem_stub DDS_DDSInstanceHandleBase_stub \ - DDS_InstanceHandleConnector_stub DDS_InstanceHandleConnector_svnt \ - DDS_InstanceHandleConnector_lem_stub - libpaths += ../lib - libout = ../lib - includes += .. - dynamicflags += SENDER_SVNT_BUILD_DLL - - IDL_Files { - } - - Source_Files { - Writer_SenderS.cpp - Writer_Sender_svnt.cpp - } - - Header_Files { - Writer_SenderS.h - Writer_Sender_svnt.h - Sender_svnt_export.h - } - - Inline_Files { - } -} - diff --git a/CIAO/connectors/dds4ccm/tests/InstanceHandle/Sender/Writer_Sender_exec.cpp b/CIAO/connectors/dds4ccm/tests/InstanceHandle/Sender/Writer_Sender_exec.cpp deleted file mode 100644 index 1016da9ffcf..00000000000 --- a/CIAO/connectors/dds4ccm/tests/InstanceHandle/Sender/Writer_Sender_exec.cpp +++ /dev/null @@ -1,368 +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_Sender_exec.h" -#include "tao/ORB_Core.h" -#include "ace/Reactor.h" - -#include "Connector/Writer_Connector_conn.h" -#include "dds4ccm/impl/Utils.h" -#if (CIAO_DDS4CCM_NDDS == 1) -# include "dds4ccm/impl/ndds/DataWriter_T.h" -#endif - -namespace CIAO_Writer_Sender_Impl -{ - /** - * Starter - */ - - StartHandler::StartHandler(Sender_exec_i &callback) - : callback_ (callback) - { - } - - int - StartHandler::handle_exception (ACE_HANDLE) - { - this->callback_.run (); - return 0; - } - - /** - * Component Executor Implementation Class: Sender_exec_i - */ - - Sender_exec_i::Sender_exec_i (void) - : keys_ (5), - dds_writer_ (0) - { - ACE_NEW_THROW_EX (this->rh_, - StartHandler (*this), - ::CORBA::NO_MEMORY ()); - } - - Sender_exec_i::~Sender_exec_i (void) - { - delete this->rh_; - } - - // Supported operations and attributes. - ACE_Reactor* - Sender_exec_i::reactor (void) - { - ACE_Reactor* reactor = 0; - ::CORBA::Object_var ccm_object = - this->ciao_context_->get_CCM_object(); - if (! ::CORBA::is_nil (ccm_object.in ())) - { - ::CORBA::ORB_var orb = ccm_object->_get_orb (); - if (! ::CORBA::is_nil (orb.in ())) - { - reactor = orb->orb_core ()->reactor (); - } - } - if (reactor == 0) - { - throw ::CORBA::INTERNAL (); - } - return reactor; - } - - void - Sender_exec_i::unregister_handles () - { - ::WriterTestConnector::Writer_var ccm_writer = - this->ciao_context_->get_connection_info_write_data (); - - for (Writer_Table::iterator i = this->ktests_.begin (); - i != this->ktests_.end (); - ++i) - { - try - { - ::DDS::InstanceHandle_t const hnd = this->handles_[i->first.c_str ()]; - ccm_writer->unregister_instance (i->second, hnd); - ACE_DEBUG ((LM_DEBUG, - ACE_TEXT ("Unregistered <%C> - valid ") - DDS_INSTANCE_HANDLE_FORMAT_SPECIFIER ACE_TEXT ("\n"), - i->first.c_str (), - DDS_INSTANCE_HANDLE_LOG(hnd))); - } - catch (...) - { - ACE_ERROR ((LM_ERROR, ACE_TEXT ("ERROR: ") - ACE_TEXT ("unknown exception caught during unregister_instance.\n"))); - } - } - } - - void - Sender_exec_i::register_handles () - { - ::WriterTestConnector::Writer_var ccm_writer = - this->ciao_context_->get_connection_info_write_data (); - Writer_Table::iterator i = this->ktests_.begin (); - for (i = this->ktests_.begin(); i != this->ktests_.end(); ++i) - { - DDS::InstanceHandle_t const hnd = - ccm_writer->register_instance (i->second); - if (hnd == ::DDS::HANDLE_NIL) - { - ACE_ERROR ((LM_ERROR, - ACE_TEXT ("ERROR: Unable to register handle for <%C>\n"), - i->first.c_str ())); - } - ACE_DEBUG ((LM_DEBUG, ACE_TEXT ("Registering instance for <%C>\n"), - i->second->key.in ())); - this->handles_[i->first.c_str ()] = hnd; - } - } - - void - Sender_exec_i::test_equality () - { -#if (CIAO_DDS4CCM_NDDS == 1) - Writer_Table::iterator i = this->ktests_.begin (); - for (i = this->ktests_.begin(); i != this->ktests_.end(); ++i) - { - ::DDS::InstanceHandle_t ccm_hnd = this->handles_[i->first.c_str ()]; - - DDS_InstanceHandle_t dds_hnd = - this->dds_writer_->lookup_instance (i->second); - ::DDS::InstanceHandle_t ccm_dds_hnd; - ccm_dds_hnd <<= dds_hnd; - if (ccm_hnd == ccm_dds_hnd) - { - ACE_DEBUG ((LM_DEBUG, "Sender_exec_i::test_equality - " - "== operator seems to work for CCM handles " - "for key <%C>\n", - i->first.c_str ())); - } - else - { - ACE_ERROR ((LM_ERROR, "ERROR: Sender_exec_i::test_equality - " - "== operator doesn't seem to work for CCM " - "handles for key <%C>\n", - i->first.c_str ())); - } - } -#endif - } - - void - Sender_exec_i::test_non_equality () - { -#if (CIAO_DDS4CCM_NDDS == 1) - Writer_Table::iterator i = this->ktests_.begin (); - for (i = this->ktests_.begin(); i != this->ktests_.end(); ++i) - { - ::DDS::InstanceHandle_t ccm_hnd = this->handles_[i->first.c_str ()]; - - Writer_Table::iterator unequal = i; - ++unequal; - if (unequal == this->ktests_.end ()) - { - unequal = this->ktests_.begin (); - } - - DDS_InstanceHandle_t const dds_hnd = - this->dds_writer_->lookup_instance (unequal->second); - DDS::InstanceHandle_t ccm_dds_hnd; - ccm_dds_hnd <<= dds_hnd; - if (ccm_dds_hnd != ccm_hnd) - { - ACE_DEBUG ((LM_DEBUG, "Sender_exec_i::test_equality - " - "!= operator seems to work for CCM " - "handles for key <%C>\n", - i->first.c_str ())); - } - else - { - ACE_ERROR ((LM_ERROR, "ERROR: Sender_exec_i::test_equality - " - "!= operator doesn't seem to work for CCM " - "handles for key <%C>\n", - i->first.c_str ())); - } - } - unregister_handles (); -#endif - } - - void - Sender_exec_i::run () - { - test_equality (); - test_non_equality (); - } - - void - Sender_exec_i::start (void) - { - this->reactor ()->notify (this->rh_); - } - - // Component attributes and port operations. - - ::CORBA::UShort - Sender_exec_i::keys (void) - { - return this->keys_; - } - - void - Sender_exec_i::keys ( - const ::CORBA::UShort keys) - { - this->keys_ = keys; - } - - // Operations from Components::SessionComponent. - - void - Sender_exec_i::set_session_context ( - ::Components::SessionContext_ptr ctx) - { - this->ciao_context_ = - ::Writer::CCM_Sender_Context::_narrow (ctx); - - if ( ::CORBA::is_nil (this->ciao_context_.in ())) - { - throw ::CORBA::INTERNAL (); - } - } - - void - Sender_exec_i::configuration_complete (void) - { -#if (CIAO_DDS4CCM_NDDS == 1) - typedef ::CIAO::NDDS::DDS_DataWriter_Base DataWriter_type; - - ::DDS::DataWriter_var dds_dw = - this->ciao_context_->get_connection_info_write_dds_entity (); - - ::CIAO::DDS4CCM::CCM_DataWriter * ccm_dw = - dynamic_cast < ::CIAO::DDS4CCM::CCM_DataWriter * > (dds_dw.in ()); - - if (ccm_dw) - { - - ::DDS::DataWriter_var tmp = ccm_dw->get_dds_entity (); - if (! ::CORBA::is_nil (tmp.in ())) - { - DataWriter_type * typed_ccm_dw = dynamic_cast <DataWriter_type *> (tmp.in ()); - if (typed_ccm_dw) - { - DDSDataWriter* dds_datawriter = typed_ccm_dw->get_rti_entity (); - if (dds_datawriter) - { - this->dds_writer_ = - ::CIAO_WriterTestConnector_DDS_Event_Impl::WriterTest_DDS_Traits::datawriter_type::narrow (dds_datawriter); - if (!this->dds_writer_) - { - ACE_ERROR ((LM_ERROR, "ERROR : Sender_exec_i::ccm_activate - " - "Error narrowing to a typed " - "DDS DataWriter.\n")); - throw ::CORBA::INTERNAL (); - } - } - else - { - ACE_ERROR ((LM_ERROR, "ERROR : Sender_exec_i::ccm_activate - " - "Error getting DDS DataWriter.\n")); - throw ::CORBA::INTERNAL (); - } - } - else - { - ACE_ERROR ((LM_ERROR, "ERROR : Sender_exec_i::ccm_activate - " - "Error casting DataWriter to typed DataWriter\n")); - throw ::CORBA::INTERNAL (); - } - } - else - { - ACE_ERROR ((LM_ERROR, "ERROR : Sender_exec_i::ccm_activate - " - "::DDS::DataWriter of CCM DataWriter seems nil\n")); - throw ::CORBA::INTERNAL (); - } - } - else - { - ACE_ERROR ((LM_ERROR, "ERROR : Sender_exec_i::configuration_complete - " - "Error casting DataWriter to CCM DataWriter\n")); - throw ::CORBA::INTERNAL (); - } -#endif - } - - void - Sender_exec_i::ccm_activate (void) - { - this->start (); - - ACE_GUARD_THROW_EX (TAO_SYNCH_MUTEX, _guard, - this->mutex_, CORBA::INTERNAL ()); - - for (CORBA::UShort i = 1; i < this->keys_ + 1; ++i) - { - char key[7]; - WriterTest *new_key = 0; - ACE_NEW_THROW_EX (new_key, - WriterTest, - ::CORBA::NO_MEMORY ()); - ACE_OS::sprintf (key, "KEY_%d", i); - new_key->key = CORBA::string_dup(key); - - this->ktests_[key] = new_key; - } - register_handles (); - } - - void - Sender_exec_i::ccm_passivate (void) - { - /* Your code here. */ - } - - void - Sender_exec_i::ccm_remove (void) - { - /* Your code here. */ - } - - extern "C" SENDER_EXEC_Export ::Components::EnterpriseComponent_ptr - create_Writer_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/InstanceHandle/Sender/Writer_Sender_exec.h b/CIAO/connectors/dds4ccm/tests/InstanceHandle/Sender/Writer_Sender_exec.h deleted file mode 100644 index e58efe30434..00000000000 --- a/CIAO/connectors/dds4ccm/tests/InstanceHandle/Sender/Writer_Sender_exec.h +++ /dev/null @@ -1,145 +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_SENDER_EXEC_TJDDGS_H_ -#define CIAO_WRITER_SENDER_EXEC_TJDDGS_H_ - -#include /**/ "ace/pre.h" - -#include "Writer_SenderEC.h" - -#if !defined (ACE_LACKS_PRAGMA_ONCE) -# pragma once -#endif /* ACE_LACKS_PRAGMA_ONCE */ - -#include /**/ "Sender_exec_export.h" -#include "tao/LocalObject.h" - -#include <map> - -class WriterTestDataWriter; - -namespace CIAO_Writer_Sender_Impl -{ - class Sender_exec_i; - - /** - * Starter - */ - - class StartHandler : - public ACE_Event_Handler - { - public: - StartHandler (Sender_exec_i &callback); - virtual int handle_exception (ACE_HANDLE fc = ACE_INVALID_HANDLE); - private: - Sender_exec_i &callback_; - }; - - /** - * Component Executor Implementation Class: Sender_exec_i - */ - - class Sender_exec_i - : public virtual Sender_Exec, - public virtual ::CORBA::LocalObject - { - public: - Sender_exec_i (void); - virtual ~Sender_exec_i (void); - - //@{ - /** Supported operations and attributes. */ - - //@} - - //@{ - /** Component attributes and port operations. */ - - virtual ::CORBA::UShort keys (void); - - virtual void keys (::CORBA::UShort keys); - //@} - - //@{ - /** 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. */ - void run (void); - - //@} - - private: - ::Writer::CCM_Sender_Context_var ciao_context_; - - //@{ - /** Component attributes. */ - - ::CORBA::UShort keys_; - //@} - - //@{ - /** User defined members. */ - StartHandler *rh_; - WriterTestDataWriter *dds_writer_; - - TAO_SYNCH_MUTEX mutex_; - typedef std::map<ACE_CString, WriterTest_var> Writer_Table; - Writer_Table ktests_; - - typedef std::map<ACE_CString, ::DDS::InstanceHandle_t> CCM_Handles; - CCM_Handles handles_; - - //@} - - //@{ - /** User defined private operations. */ - void start (void); - - void register_handles (void); - void unregister_handles (void); - void test_equality (void); - void test_non_equality (void); - - //@} - - /// Get the ACE_Reactor - ACE_Reactor* reactor (void); - }; - - extern "C" SENDER_EXEC_Export ::Components::EnterpriseComponent_ptr - create_Writer_Sender_Impl (void); -} - -#include /**/ "ace/post.h" - -#endif /* ifndef */ |