diff options
Diffstat (limited to 'CIAO/connectors/dds4ccm/tests/SLOneByOne/Sender')
4 files changed, 0 insertions, 799 deletions
diff --git a/CIAO/connectors/dds4ccm/tests/SLOneByOne/Sender/SL_OneByOne_Sender.idl b/CIAO/connectors/dds4ccm/tests/SLOneByOne/Sender/SL_OneByOne_Sender.idl deleted file mode 100644 index 523b6d61086..00000000000 --- a/CIAO/connectors/dds4ccm/tests/SLOneByOne/Sender/SL_OneByOne_Sender.idl +++ /dev/null @@ -1,19 +0,0 @@ -/** - * @author Marijke Hengstmengel (mhengstmengel@remedy.nl) - */ - -#ifndef DDS_SL_ONEBYONE_SENDER_IDL -#define DDS_SL_ONEBYONE_SENDER_IDL - -#include "Connector/SL_OneByOne_Connector.idl" - -module SL_OneByOne -{ - component Sender - { - port SL_OneByOneConnector::DDS_Update test_topic_update; - provides CCM_DDS::ConnectorStatusListener test_topic_connector_status; - }; -}; - -#endif diff --git a/CIAO/connectors/dds4ccm/tests/SLOneByOne/Sender/SL_OneByOne_Sender.mpc b/CIAO/connectors/dds4ccm/tests/SLOneByOne/Sender/SL_OneByOne_Sender.mpc deleted file mode 100644 index e3710cc20e7..00000000000 --- a/CIAO/connectors/dds4ccm/tests/SLOneByOne/Sender/SL_OneByOne_Sender.mpc +++ /dev/null @@ -1,138 +0,0 @@ -// This file is generated with "generate_component_mpc.pl -p DDS_SL_OneByOne_Base -l ../lib -o ../lib -c controller -u DDS Sender" - -project(DDS_SL_OneByOne_Sender_idl_gen) : componentidldefaults, dds4ccm { - after += DDS_SL_OBO_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 { - SL_OneByOne_Sender.idl - } -} - -project(DDS_SL_OneByOne_Sender_lem_gen) : ciaoidldefaults, dds4ccm { - after += DDS_SL_OneByOne_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 { - SL_OneByOne_SenderE.idl - } -} - -project(DDS_SL_OneByOne_Sender_lem_stub) : ccm_svnt, dds4ccm_base { - after += DDS_SL_OneByOne_Sender_lem_gen DDS_SL_OneByOne_Sender_stub DDS_SL_OneByOne_Base_stub - libs += DDS_SL_OneByOne_Base_stub Sender_stub - libpaths += ../lib - libout = ../lib - includes += .. - sharedname = Sender_lem_stub - dynamicflags += SENDER_LEM_STUB_BUILD_DLL - - IDL_Files { - } - - Source_Files { - SL_OneByOne_SenderEC.cpp - } - - Header_Files { - SL_OneByOne_SenderEC.h - Sender_lem_stub_export.h - } - - Inline_Files { - SL_OneByOne_SenderEC.inl - } -} - -project(DDS_SL_OneByOne_Sender_stub) : ccm_stub, dds4ccm_base { - after += DDS_SL_OneByOne_Sender_idl_gen DDS_SL_OneByOne_Base_stub DDS_SL_OneByOne_Connector_stub - libs += DDS_SL_OneByOne_Base_stub DDS_SL_OneByOne_Connector_stub - includes += .. - libpaths += ../lib - libout = ../lib - sharedname = Sender_stub - dynamicflags += SENDER_STUB_BUILD_DLL - - IDL_Files { - } - - Source_Files { - SL_OneByOne_SenderC.cpp - } - - Header_Files { - SL_OneByOne_SenderC.h - Sender_stub_export.h - } - - Inline_Files { - SL_OneByOne_SenderC.inl - } -} - -project(DDS_SL_OneByOne_Sender_exec) : ciao_executor, dds4ccm_lem_stub { - after += DDS_SL_OneByOne_Sender_lem_stub DDS_SL_OneByOne_Sender_stub DDS_SL_OBO_Connector_lem_stub DDS_SL_OneByOne_Connector_stub - sharedname = Sender_exec - libs += Sender_stub Sender_lem_stub DDS_SL_OneByOne_Base_stub DDS_SL_OBO_Connector_lem_stub DDS_SL_OneByOne_Connector_stub - libpaths += ../lib - includes += .. - libout = ../lib - dynamicflags += SENDER_EXEC_BUILD_DLL - - IDL_Files { - } - - Source_Files { - SL_OneByOne_Sender_exec.cpp - } - - Header_Files { - SL_OneByOne_Sender_exec.h - Sender_exec_export.h - } - - Inline_Files { - } -} - - -project(DDS_SL_OneByOne_Sender_svnt) : ciao_servant, dds4ccm_lem_stub, dds4ccm_skel { - after += DDS_SL_OneByOne_Base_stub DDS_SL_OneByOne_Sender_lem_stub DDS_SL_OneByOne_Connector_stub DDS_SL_OneByOne_Connector_svnt DDS_SL_OBO_Connector_lem_stub - sharedname = Sender_svnt - libs += Sender_stub Sender_lem_stub \ - DDS_SL_OneByOne_Base_stub DDS_SL_OneByOne_Connector_stub DDS_SL_OneByOne_Connector_svnt DDS_SL_OBO_Connector_lem_stub - libpaths += ../lib - libout = ../lib - includes += .. - dynamicflags += SENDER_SVNT_BUILD_DLL - - IDL_Files { - } - - Source_Files { - SL_OneByOne_SenderS.cpp - SL_OneByOne_Sender_svnt.cpp - } - - Header_Files { - SL_OneByOne_SenderS.h - SL_OneByOne_Sender_svnt.h - Sender_svnt_export.h - } - - Inline_Files { - } -} - diff --git a/CIAO/connectors/dds4ccm/tests/SLOneByOne/Sender/SL_OneByOne_Sender_exec.cpp b/CIAO/connectors/dds4ccm/tests/SLOneByOne/Sender/SL_OneByOne_Sender_exec.cpp deleted file mode 100644 index 408858409d7..00000000000 --- a/CIAO/connectors/dds4ccm/tests/SLOneByOne/Sender/SL_OneByOne_Sender_exec.cpp +++ /dev/null @@ -1,482 +0,0 @@ -// -*- C++ -*- -#include "SL_OneByOne_Sender_exec.h" -#include "tao/ORB_Core.h" -#include "ace/Reactor.h" - -namespace CIAO_SL_OneByOne_Sender_Impl -{ - /** - * Write action generator - */ - pulse_Generator::pulse_Generator (Sender_exec_i &callback) - : pulse_callback_ (callback) - { - } - - int - pulse_Generator::handle_timeout (const ACE_Time_Value &, const void *) - { - // Notify the subscribers - this->pulse_callback_.tick (); - return 0; - } - - /** - * ConnectorStatusListener_exec_i - */ - - ConnectorStatusListener_exec_i::ConnectorStatusListener_exec_i ( - Sender_exec_i &callback) - : callback_ (callback) - { - } - - 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 (status_kind == ::DDS::PUBLICATION_MATCHED_STATUS) - { - this->callback_.start (); - } - } - - /** - * Component Executor Implementation Class: Sender_exec_i - */ - Sender_exec_i::Sender_exec_i (void) - : test_nr_(UPDATE_CREATE), - test_ok_(true) - { - ACE_NEW_THROW_EX (this->ticker_, - pulse_Generator (*this), - ::CORBA::NO_MEMORY ()); - } - - Sender_exec_i::~Sender_exec_i (void) - { - delete this->ticker_; - } - - ::CCM_DDS::CCM_ConnectorStatusListener_ptr - Sender_exec_i::get_test_topic_connector_status (void) - { - return new ConnectorStatusListener_exec_i (*this); - } - - // 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; - } - - CORBA::Boolean - Sender_exec_i::create_one (void) - { - TestTopic i = this->topic_seq_one_[0]; - try - { - ::SL_OneByOne::SL_OneByOneConnector::Updater_var updater = - this->ciao_context_->get_connection_test_topic_update_data (); - if (::CORBA::is_nil (updater.in ())) - { - ACE_ERROR ((LM_ERROR, "Sender_exec_i::create_one - " - "ERROR: Updater seems nil\n")); - return false; - } - updater->create_one (i); - ACE_DEBUG ((LM_DEBUG, ACE_TEXT ("SL_OneByOne: create_one with instance key <%C>\n"), - i.key.in ())); - } - catch (const CCM_DDS::AlreadyCreated &) - { - ACE_ERROR ((LM_ERROR, - ACE_TEXT ("Unexpected exception: AlreadyCreated with test updater create_one <%C>.\n"), - i.key.in ())); - return false; - } - catch (const CCM_DDS::InternalError& ) - { - ACE_ERROR ((LM_ERROR, - ACE_TEXT ("Internal Error while create_one for <%C>.\n"), - i.key.in ())); - return false; - } - return true; - } - - CORBA::Boolean - Sender_exec_i::update_one (void) - { - //update already created instance with handle nil - TestTopic i = this->topic_seq_one_[0]; - try - { - ::SL_OneByOne::SL_OneByOneConnector::Updater_var updater = - this->ciao_context_->get_connection_test_topic_update_data (); - if (::CORBA::is_nil (updater.in ())) - { - ACE_ERROR ((LM_ERROR, "Sender_exec_i::update_one - " - "ERROR: Updater seems nil\n")); - return false; - } - updater->update_one (i, DDS::HANDLE_NIL); - ACE_DEBUG ((LM_DEBUG, ACE_TEXT ("Updater: update_one with already existing instance with DDS::HANDLE_NIL, key <%C>\n"), - i.key.in ())); - } - catch (const CCM_DDS::NonExistent &) - { - ACE_ERROR ((LM_ERROR, ACE_TEXT ("Unexpected exception: NonExistent with test updater update_one <%C>.\n"), - i.key.in ())); - return false; - } - catch (const CCM_DDS::InternalError& ) - { - ACE_ERROR ((LM_ERROR, ACE_TEXT ("Internal Error while update_one for <%C>.\n"), - i.key.in ())); - return false; - } - return true; - } - - CORBA::Boolean - Sender_exec_i::delete_one (void) - { - //delete registered instance with DDS::HANDLE_NIL - TestTopic i = this->topic_seq_one_[0]; - try - { - ::SL_OneByOne::SL_OneByOneConnector::Updater_var updater = - this->ciao_context_->get_connection_test_topic_update_data (); - if (::CORBA::is_nil (updater.in ())) - { - ACE_ERROR ((LM_ERROR, "Sender_exec_i::delete_one - " - "ERROR: Updater seems nil\n")); - return false; - } - ACE_DEBUG ((LM_DEBUG, ACE_TEXT ("Updater: delete_one with registered instance with DDS::HANDLE_NIL, key <%C>\n"), - i.key.in ())); - updater->delete_one (i, DDS::HANDLE_NIL); - } - catch (const CCM_DDS::NonExistent &) - { - ACE_ERROR ((LM_ERROR, ACE_TEXT ("Unexpected exception: NonExistent with test updater delete_one <%C>.\n"), - i.key.in ())); - return false; - } - catch (const CCM_DDS::InternalError& ) - { - ACE_ERROR ((LM_ERROR, ACE_TEXT ("Internal Error while delete_one for <%C>.\n"), - i.key.in ())); - return false; - } - return true; - } - - CORBA::Boolean - Sender_exec_i::create_many (void) - { - //create many with no exception - try - { - ::SL_OneByOne::SL_OneByOneConnector::Updater_var updater = - this->ciao_context_->get_connection_test_topic_update_data (); - if (::CORBA::is_nil (updater.in ())) - { - ACE_ERROR ((LM_ERROR, "Sender_exec_i::create_many - " - "ERROR: Updater seems nil\n")); - return false; - } - ACE_DEBUG ((LM_DEBUG, ACE_TEXT ("create_many : <%u> samples\n"), - this->topic_seq_many_.length ())); - updater->create_many (this->topic_seq_many_); - } - catch (const CCM_DDS::NonExistent& ) - { - ACE_ERROR ((LM_ERROR, ACE_TEXT ("Unexpected exception: NonExistent with test updater create_many\n"))); - return false; - } - catch (const CCM_DDS::InternalError& ex) - { - ACE_ERROR ((LM_ERROR, ACE_TEXT ("ERROR: Internal Error ") - ACE_TEXT ("in updater: create_many: index <%d> - retval <%d>\n"), - ex.index, ex.error_code)); - return false; - - } - return true; - } - - CORBA::Boolean - Sender_exec_i::update_many (void) - { - try - { - ::SL_OneByOne::SL_OneByOneConnector::Updater_var updater = - this->ciao_context_->get_connection_test_topic_update_data (); - if (::CORBA::is_nil (updater.in ())) - { - ACE_ERROR ((LM_ERROR, "Sender_exec_i::update_many - " - "ERROR: Updater seems nil\n")); - return false; - } - updater->update_many (this->topic_seq_many_); - ACE_DEBUG ((LM_DEBUG, ACE_TEXT ("update_many : written <%u> samples\n"), - this->topic_seq_many_.length ())); - } - catch (const CCM_DDS::NonExistent& ) - { - ACE_ERROR ((LM_ERROR, ACE_TEXT ("Unexpected exception: NonExistent with test updater update_many.\n"))); - return false; - } - catch (const CCM_DDS::InternalError& ex) - { - ACE_ERROR ((LM_ERROR, ACE_TEXT ("ERROR: Internal Error ") - ACE_TEXT ("with update_many: index <%d> - retval <%d>\n"), - ex.index, ex.error_code)); - return false; - } - return true; - } - - CORBA::Boolean - Sender_exec_i::delete_many (void) - { - try - { - ::SL_OneByOne::SL_OneByOneConnector::Updater_var updater = - this->ciao_context_->get_connection_test_topic_update_data (); - if (::CORBA::is_nil (updater.in ())) - { - ACE_ERROR ((LM_ERROR, "Sender_exec_i::delete_many - " - "ERROR: Updater seems nil\n")); - return false; - } - ACE_DEBUG ((LM_DEBUG, ACE_TEXT ("delete_many : deleted <%u> samples\n"), - this->topic_seq_many_.length ())); - updater->delete_many (this->topic_seq_many_); - } - catch (const CCM_DDS::NonExistent& ) - { - ACE_ERROR ((LM_ERROR, ACE_TEXT ("Unexpected exception: NonExistent with test updater delete_many\n"))); - return false; - } - catch (const CCM_DDS::InternalError& ex) - { - ACE_ERROR ((LM_ERROR, ACE_TEXT ("ERROR: Internal Error ") - ACE_TEXT ("with test updater delete_many: index <%d> - retval <%d>\n"), - ex.index, ex.error_code)); - return false; - } - - return true; - } - - void - Sender_exec_i::add_instances_of_topic () - { - CORBA::UShort total = 3; - this->topic_seq_one_.length (total); - //sequence for tests with .._one - for (int i = 1; i < (total + 1); i++) - { - char key[7]; - TestTopic new_key; - ACE_OS::sprintf (key, "KEY_%d", i); - new_key.key = CORBA::string_dup(key); - new_key.x = i; - this->topic_seq_one_[i-1] = new_key; - } - //sequence for tests with .._many - this->topic_seq_many_.length (total); - for (int i = 1; i < (total + 1); i++) - { - char key[7]; - TestTopic new_key; - ACE_OS::sprintf (key, "many_%d", i); - new_key.key = CORBA::string_dup(key); - new_key.x = i; - this->topic_seq_many_[i-1] = new_key; - } - } - - void - Sender_exec_i::tick () - { - if(this->test_ok_.value()) - { - switch (this->test_nr_) - { - case UPDATE_CREATE: - this->test_ok_ = this->create_one(); - if(this->test_ok_.value()) - { - this->test_nr_ = UPDATE_ONE; - } - else - { - this->test_nr_ = END_TEST; - } - break; - case UPDATE_ONE: - this->test_ok_ = this->update_one(); - this->test_nr_ = DELETE_ONE; - break; - case DELETE_ONE: - this->test_ok_ = this->delete_one(); - this->test_nr_ = CREATE_MANY; - break; - case CREATE_MANY: - this->test_ok_ = this->create_many(); - if(this->test_ok_.value()) - { - this->test_nr_ = UPDATE_MANY; - } - else - { - this->test_nr_ = END_TEST; - } - this->test_nr_ = UPDATE_MANY; - break; - case UPDATE_MANY: - this->test_ok_ = this->update_many(); - this->test_nr_ = DELETE_MANY; - break; - case DELETE_MANY: - this->test_ok_ = this->delete_many(); - this->test_nr_ = END_TEST; - break; - default: - break; - } - } - } - void - Sender_exec_i::start (void) - { - long sec = 1L; - long const usec = 0L; - if (this->reactor ()->schedule_timer ( - this->ticker_, - 0, - ACE_Time_Value (sec, usec), - ACE_Time_Value (sec, usec)) == -1) - { - ACE_ERROR ((LM_ERROR, ACE_TEXT ("Sender_exec_i::start : ") - ACE_TEXT ("Error scheduling timer"))); - } - } - - void - Sender_exec_i::stop (void) - { - this->reactor ()->cancel_timer (this->ticker_); - ACE_DEBUG ((LM_DEBUG, ACE_TEXT ("Sender_exec_i::stop : Timer canceled.\n"))); - } - - - // Component attributes and port operations. - - // Operations from Components::SessionComponent. - - void - Sender_exec_i::set_session_context ( - ::Components::SessionContext_ptr ctx) - { - this->ciao_context_ = - ::SL_OneByOne::CCM_Sender_Context::_narrow (ctx); - - if ( ::CORBA::is_nil (this->ciao_context_.in ())) - { - throw ::CORBA::INTERNAL (); - } - } - - void - Sender_exec_i::configuration_complete (void) - { - /* Your code here. */ - } - - void - Sender_exec_i::ccm_activate (void) - { - this->add_instances_of_topic (); - } - - void - Sender_exec_i::ccm_passivate (void) - { - this->stop (); - } - - void - Sender_exec_i::ccm_remove (void) - { - /* Your code here. */ - } - - extern "C" SENDER_EXEC_Export ::Components::EnterpriseComponent_ptr - create_SL_OneByOne_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/SLOneByOne/Sender/SL_OneByOne_Sender_exec.h b/CIAO/connectors/dds4ccm/tests/SLOneByOne/Sender/SL_OneByOne_Sender_exec.h deleted file mode 100644 index 3fc8c6f80c7..00000000000 --- a/CIAO/connectors/dds4ccm/tests/SLOneByOne/Sender/SL_OneByOne_Sender_exec.h +++ /dev/null @@ -1,160 +0,0 @@ -// -*- C++ -*- -#ifndef CIAO_SL_ONEBYONE_SENDER_EXEC_FHYBU2_H_ -#define CIAO_SL_ONEBYONE_SENDER_EXEC_FHYBU2_H_ - -#include /**/ "ace/pre.h" - -#include "SL_OneByOne_SenderEC.h" - -#if !defined (ACE_LACKS_PRAGMA_ONCE) -# pragma once -#endif /* ACE_LACKS_PRAGMA_ONCE */ - -#include /**/ "Sender_exec_export.h" -#include "tao/LocalObject.h" - -namespace CIAO_SL_OneByOne_Sender_Impl -{ - typedef ACE_Atomic_Op <TAO_SYNCH_MUTEX, CORBA::Boolean > Atomic_Boolean; - - class Sender_exec_i; - - enum UPDATER_TEST { - UPDATE_CREATE, - UPDATE_ONE, - DELETE_ONE, - CREATE_MANY, - UPDATE_MANY, - DELETE_MANY, - END_TEST - }; - - /** - * Write action generator - */ - - class pulse_Generator : - public ACE_Event_Handler - { - public: - pulse_Generator (Sender_exec_i &callback); - virtual int handle_timeout (const ACE_Time_Value &tv, - const void *arg); - private: - Sender_exec_i &pulse_callback_; - }; - - /** - * ConnectorStatusListener_exec_i - */ - - class ConnectorStatusListener_exec_i - : public virtual ::CCM_DDS::CCM_ConnectorStatusListener, - public virtual ::CORBA::LocalObject - { - public: - ConnectorStatusListener_exec_i (Sender_exec_i &callback); - 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: - 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 ::CCM_DDS::CCM_ConnectorStatusListener_ptr - get_test_topic_connector_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. */ - void tick (void); - void start (void); - //@} - - private: - ::SL_OneByOne::CCM_Sender_Context_var ciao_context_; - - //@{ - /** Component attributes. */ - //@} - - //@{ - /** User defined members. */ - pulse_Generator * ticker_; - - UPDATER_TEST test_nr_; - Atomic_Boolean test_ok_; - TestTopicSeq topic_seq_one_; - TestTopicSeq topic_seq_many_; - - //@} - - //@{ - /** User defined private operations. */ - void stop (void); - void add_instances_of_topic (void); - CORBA::Boolean create_one (void); - CORBA::Boolean update_one (void); - CORBA::Boolean delete_one (void); - CORBA::Boolean create_many (void); - CORBA::Boolean update_many (void); - CORBA::Boolean delete_many (void); - - //@} - - /// Get the ACE_Reactor - ACE_Reactor* reactor (void); - }; - - extern "C" SENDER_EXEC_Export ::Components::EnterpriseComponent_ptr - create_SL_OneByOne_Sender_Impl (void); -} - -#include /**/ "ace/post.h" - -#endif /* ifndef */ |