diff options
author | msmit <msmit@remedy.nl> | 2010-11-30 09:56:21 +0000 |
---|---|---|
committer | msmit <msmit@remedy.nl> | 2010-11-30 09:56:21 +0000 |
commit | 56c2b5bd64fa95a7bdd29aaa237eedee1e1eb037 (patch) | |
tree | a0f1c37154df453bc74f73ee5c1e47d2410cb40d /CIAO/connectors/dds4ccm/tests/QueryCondition/ReadGet/Receiver | |
parent | a8b119c8c16274fefb3d0949f6ec4c286a7249fd (diff) | |
download | ATCD-56c2b5bd64fa95a7bdd29aaa237eedee1e1eb037.tar.gz |
Tue Nov 30 09:56:39 UTC 2010 Marcel Smit <msmit@remedy.nl>
* connectors/dds4ccm/impl/ConditionManager.cpp:
Removed unnecessary checks for nil pointers.
* connectors/dds4ccm/tests/QueryCondition/ReadGet/Receiver/ReadGet_Test_Receiver.mpc:
* connectors/dds4ccm/tests/QueryCondition/ReadGet/Receiver/ReadGet_Test_Receiver_exec.h:
* connectors/dds4ccm/tests/QueryCondition/ReadGet/Receiver/ReadGet_Test_Receiver_exec.cpp:
* connectors/dds4ccm/tests/QueryCondition/ReadGet/Sender/ReadGet_Test_Sender_exec.h:
* connectors/dds4ccm/tests/QueryCondition/ReadGet/Sender/ReadGet_Test_Sender_exec.cpp:
* connectors/dds4ccm/tests/Reader/Receiver/Reader_Test_Receiver.mpc:
* connectors/dds4ccm/tests/Reader/Receiver/Reader_Test_Receiver_exec.h:
* connectors/dds4ccm/tests/Reader/Receiver/Reader_Test_Receiver_exec.cpp:
* connectors/dds4ccm/tests/Reader/Sender/Reader_Test_Sender.mpc:
* connectors/dds4ccm/tests/Reader/Sender/Reader_Test_Sender_exec.h:
* connectors/dds4ccm/tests/Reader/Sender/Reader_Test_Sender_exec.cpp:
Rewritten, using the generated executor files.
Diffstat (limited to 'CIAO/connectors/dds4ccm/tests/QueryCondition/ReadGet/Receiver')
3 files changed, 375 insertions, 100 deletions
diff --git a/CIAO/connectors/dds4ccm/tests/QueryCondition/ReadGet/Receiver/ReadGet_Test_Receiver.mpc b/CIAO/connectors/dds4ccm/tests/QueryCondition/ReadGet/Receiver/ReadGet_Test_Receiver.mpc index 6b074df52d9..d23c076ce5c 100755 --- a/CIAO/connectors/dds4ccm/tests/QueryCondition/ReadGet/Receiver/ReadGet_Test_Receiver.mpc +++ b/CIAO/connectors/dds4ccm/tests/QueryCondition/ReadGet/Receiver/ReadGet_Test_Receiver.mpc @@ -10,7 +10,8 @@ project(QC_ReadGet_Test_Receiver_idl_gen) : componentidldefaults, dds4ccm { -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.. + -Wb,exec_export_include=Receiver_exec_export.h \ + -I.. IDL_Files { ReadGet_Test_Receiver.idl diff --git a/CIAO/connectors/dds4ccm/tests/QueryCondition/ReadGet/Receiver/ReadGet_Test_Receiver_exec.cpp b/CIAO/connectors/dds4ccm/tests/QueryCondition/ReadGet/Receiver/ReadGet_Test_Receiver_exec.cpp index 21f3e89f771..9695ee4cc0f 100644 --- a/CIAO/connectors/dds4ccm/tests/QueryCondition/ReadGet/Receiver/ReadGet_Test_Receiver_exec.cpp +++ b/CIAO/connectors/dds4ccm/tests/QueryCondition/ReadGet/Receiver/ReadGet_Test_Receiver_exec.cpp @@ -1,15 +1,33 @@ // -*- C++ -*- -// // $Id$ -#include "ReadGet_Test_Receiver_exec.h" +/** + * 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.cs.wustl.edu/~schmidt/TAO.html + **/ -#include "ace/OS_NS_unistd.h" +#include "ReadGet_Test_Receiver_exec.h" #include "tao/ORB_Core.h" #include "ace/Reactor.h" -#include "ace/Log_Msg.h" - -#include "dds4ccm/impl/dds4ccm_conf.h" #define QUERY "( (iteration > %0) AND (iteration < %1) )" @@ -38,10 +56,11 @@ namespace CIAO_ReadGet_Test_Receiver_Impl { - //============================================================ - // read_action_Generator - //============================================================ - read_action_Generator::read_action_Generator (Receiver_exec_i &callback, int run) + /** + * Read Action Generator + */ + read_action_Generator::read_action_Generator (Receiver_exec_i &callback, + int run) : callback_ (callback), run_ (run) { @@ -63,45 +82,116 @@ namespace CIAO_ReadGet_Test_Receiver_Impl return 0; } - //============================================================ - // Starter_exec_i - //============================================================ - Starter_exec_i::Starter_exec_i (Receiver_exec_i & callback) - : callback_ (callback) + /** + * Facet Executor Implementation Class: get_port_status_exec_i + */ + + get_port_status_exec_i::get_port_status_exec_i ( + ::ReadGet_Test::CCM_Receiver_Context_ptr ctx) + : ciao_context_ ( + ::ReadGet_Test::CCM_Receiver_Context::_duplicate (ctx)) + { + } + + get_port_status_exec_i::~get_port_status_exec_i (void) + { + } + + // Operations from ::CCM_DDS::PortStatusListener + + void + get_port_status_exec_i::on_requested_deadline_missed (::DDS::DataReader_ptr /* the_reader */, + const ::DDS::RequestedDeadlineMissedStatus & /* status */) + { + /* Your code here. */ + } + + void + get_port_status_exec_i::on_sample_lost (::DDS::DataReader_ptr /* the_reader */, + const ::DDS::SampleLostStatus & /* status */) + { + /* Your code here. */ + } + + /** + * Facet Executor Implementation Class: check_port_status_exec_i + */ + + check_port_status_exec_i::check_port_status_exec_i ( + ::ReadGet_Test::CCM_Receiver_Context_ptr ctx) + : ciao_context_ ( + ::ReadGet_Test::CCM_Receiver_Context::_duplicate (ctx)) + { + } + + check_port_status_exec_i::~check_port_status_exec_i (void) + { + } + + // Operations from ::CCM_DDS::PortStatusListener + + void + check_port_status_exec_i::on_requested_deadline_missed (::DDS::DataReader_ptr /* the_reader */, + const ::DDS::RequestedDeadlineMissedStatus & /* status */) + { + /* Your code here. */ + } + + void + check_port_status_exec_i::on_sample_lost (::DDS::DataReader_ptr /* the_reader */, + const ::DDS::SampleLostStatus & /* status */) + { + /* Your code here. */ + } + + /** + * Facet Executor Implementation Class: reader_start_exec_i + */ + + reader_start_exec_i::reader_start_exec_i ( + ::ReadGet_Test::CCM_Receiver_Context_ptr ctx, + Receiver_exec_i &callback) + : ciao_context_ ( + ::ReadGet_Test::CCM_Receiver_Context::_duplicate (ctx)) + , callback_ (callback) { } - Starter_exec_i::~Starter_exec_i (void) + reader_start_exec_i::~reader_start_exec_i (void) { } + // Operations from ::ReadGetStarter + void - Starter_exec_i::set_reader_properties (CORBA::UShort nr_keys, - CORBA::UShort nr_iterations) + reader_start_exec_i::set_reader_properties (::CORBA::UShort nr_keys, + ::CORBA::UShort nr_iterations) { this->callback_.keys (nr_keys); this->callback_.iterations (nr_iterations); } void - Starter_exec_i::start_read (CORBA::UShort run) + reader_start_exec_i::start_read (::CORBA::UShort run) { this->callback_.start_read (run); } - //============================================================ - // Receiver_exec_i - //============================================================ + /** + * Component Executor Implementation Class: Receiver_exec_i + */ + Receiver_exec_i::Receiver_exec_i (void) - : iterations_ (20), - keys_ (5), - current_min_iteration_ (ACE_OS::atoi (MIN_ITERATION_1)), - current_max_iteration_ (ACE_OS::atoi (MAX_ITERATION_1)), - ticker_ (0), - samples_expected_getter_ (0), - samples_received_getter_ (0), - samples_expected_reader_ (0), - samples_received_reader_ (0) + : iterations_ (20) + , keys_ (5) + , current_min_iteration_ (ACE_OS::atoi (MIN_ITERATION_1)) + , current_max_iteration_ (ACE_OS::atoi (MAX_ITERATION_1)) + , ticker_ (0) + , samples_expected_getter_ (0) + , samples_received_getter_ (0) + , samples_expected_reader_ (0) + , samples_received_reader_ (0) + { } @@ -109,12 +199,33 @@ namespace CIAO_ReadGet_Test_Receiver_Impl { } + // Supported operations and attributes. + ACE_Reactor* + Receiver_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; + } bool Receiver_exec_i::check_last () { ::ReadGet_Test::QueryConditionTestConnector::Reader_var reader = - this->context_->get_connection_get_port_data (); + this->ciao_context_->get_connection_get_port_data (); try { @@ -180,7 +291,7 @@ namespace CIAO_ReadGet_Test_Receiver_Impl Receiver_exec_i::read_all (void) { ::ReadGet_Test::QueryConditionTestConnector::Reader_var reader = - this->context_->get_connection_get_port_data (); + this->ciao_context_->get_connection_get_port_data (); QueryConditionTestSeq queryfiltertest_info_seq; ::CCM_DDS::ReadInfoSeq readinfo_seq; @@ -201,7 +312,7 @@ namespace CIAO_ReadGet_Test_Receiver_Impl Receiver_exec_i::get_all (void) { ::ReadGet_Test::QueryConditionTestConnector::Getter_var getter = - this->context_->get_connection_get_port_fresh_data (); + this->ciao_context_->get_connection_get_port_fresh_data (); if (::CORBA::is_nil (getter.in ())) { @@ -243,7 +354,7 @@ namespace CIAO_ReadGet_Test_Receiver_Impl Receiver_exec_i::check_all (void) { ::ReadGet_Test::QueryConditionTestConnector::Reader_var reader = - this->context_->get_connection_check_port_data (); + this->ciao_context_->get_connection_check_port_data (); QueryConditionTestSeq queryfiltertest_info_seq; ::CCM_DDS::ReadInfoSeq readinfo_seq; @@ -329,7 +440,7 @@ namespace CIAO_ReadGet_Test_Receiver_Impl { ::CCM_DDS::QueryFilter_var query; ::ReadGet_Test::QueryConditionTestConnector::Reader_var reader = - this->context_->get_connection_get_port_data (); + this->ciao_context_->get_connection_get_port_data (); try { @@ -358,7 +469,7 @@ namespace CIAO_ReadGet_Test_Receiver_Impl { ::CCM_DDS::QueryFilter_var filter; ::ReadGet_Test::QueryConditionTestConnector::Reader_var reader = - this->context_->get_connection_get_port_data (); + this->ciao_context_->get_connection_get_port_data (); try { filter = reader->query (); @@ -435,7 +546,7 @@ namespace CIAO_ReadGet_Test_Receiver_Impl try { ::ReadGet_Test::QueryConditionTestConnector::Reader_var reader = - this->context_->get_connection_get_port_data (); + this->ciao_context_->get_connection_get_port_data (); ::CCM_DDS::QueryFilter filter; filter.expression = CORBA::string_dup (QUERY); @@ -471,8 +582,7 @@ namespace CIAO_ReadGet_Test_Receiver_Impl { ACE_DEBUG ((LM_DEBUG, "Set filter\n")); ::ReadGet_Test::QueryConditionTestConnector::Reader_var reader = - this->context_->get_connection_get_port_data (); - + this->ciao_context_->get_connection_get_port_data (); ::CCM_DDS::QueryFilter filter; filter.expression = CORBA::string_dup (QUERY); filter.parameters.length (2); @@ -485,8 +595,7 @@ namespace CIAO_ReadGet_Test_Receiver_Impl Receiver_exec_i::start_read (CORBA::UShort run) { this->ticker_ = new read_action_Generator (*this, run); - if (this->context_->get_CCM_object()->_get_orb ()->orb_core ()->reactor ()->schedule_timer ( - this->ticker_, + if (this->reactor ()->schedule_timer (this->ticker_, 0, ACE_Time_Value(1, 0), ACE_Time_Value(1, 0)) == -1) @@ -500,7 +609,7 @@ namespace CIAO_ReadGet_Test_Receiver_Impl { if (this->ticker_) { - this->context_->get_CCM_object()->_get_orb ()->orb_core ()->reactor ()->cancel_timer (this->ticker_); + this->reactor ()->cancel_timer (this->ticker_); delete this->ticker_; this->ticker_ = 0; } @@ -549,33 +658,79 @@ namespace CIAO_ReadGet_Test_Receiver_Impl this->samples_expected_reader_ = (this->keys_) * SAMPLES_PER_KEY_READER; } - // Port operations. + // Component attributes and port operations. + ::CCM_DDS::CCM_PortStatusListener_ptr Receiver_exec_i::get_get_port_status (void) { - return ::CCM_DDS::CCM_PortStatusListener::_nil (); + if ( ::CORBA::is_nil (this->ciao_get_port_status_.in ())) + { + get_port_status_exec_i *tmp = 0; + ACE_NEW_RETURN ( + tmp, + get_port_status_exec_i ( + this->ciao_context_.in ()), + ::CCM_DDS::CCM_PortStatusListener::_nil ()); + + this->ciao_get_port_status_ = tmp; + } + + return + ::CCM_DDS::CCM_PortStatusListener::_duplicate ( + this->ciao_get_port_status_.in ()); } ::CCM_DDS::CCM_PortStatusListener_ptr Receiver_exec_i::get_check_port_status (void) { - return ::CCM_DDS::CCM_PortStatusListener::_nil (); + if ( ::CORBA::is_nil (this->ciao_check_port_status_.in ())) + { + check_port_status_exec_i *tmp = 0; + ACE_NEW_RETURN ( + tmp, + check_port_status_exec_i ( + this->ciao_context_.in ()), + ::CCM_DDS::CCM_PortStatusListener::_nil ()); + + this->ciao_check_port_status_ = tmp; + } + + return + ::CCM_DDS::CCM_PortStatusListener::_duplicate ( + this->ciao_check_port_status_.in ()); } ::CCM_ReadGetStarter_ptr - Receiver_exec_i::get_reader_start () + Receiver_exec_i::get_reader_start (void) { - return new Starter_exec_i (*this); + if ( ::CORBA::is_nil (this->ciao_reader_start_.in ())) + { + reader_start_exec_i *tmp = 0; + ACE_NEW_RETURN ( + tmp, + reader_start_exec_i ( + this->ciao_context_.in (), + *this), + ::CCM_ReadGetStarter::_nil ()); + + this->ciao_reader_start_ = tmp; + } + + return + ::CCM_ReadGetStarter::_duplicate ( + this->ciao_reader_start_.in ()); } // Operations from Components::SessionComponent. + void Receiver_exec_i::set_session_context ( ::Components::SessionContext_ptr ctx) { - this->context_ = + this->ciao_context_ = ::ReadGet_Test::CCM_Receiver_Context::_narrow (ctx); - if ( ::CORBA::is_nil (this->context_.in ())) + + if ( ::CORBA::is_nil (this->ciao_context_.in ())) { throw ::CORBA::INTERNAL (); } @@ -584,13 +739,14 @@ namespace CIAO_ReadGet_Test_Receiver_Impl void Receiver_exec_i::configuration_complete (void) { + /* Your code here. */ } void Receiver_exec_i::ccm_activate (void) { ::ReadGet_Test::QueryConditionTestConnector::Getter_var getter = - this->context_->get_connection_get_port_fresh_data (); + this->ciao_context_->get_connection_get_port_fresh_data (); DDS::Duration_t to; to.sec = 5; to.nanosec = 0; @@ -602,15 +758,15 @@ namespace CIAO_ReadGet_Test_Receiver_Impl { ACE_ERROR ((LM_ERROR, "ERROR: Unable to set time out.\n")); } - this->restarter_ = this->context_->get_connection_writer_restart (); -} + this->restarter_ = this->ciao_context_->get_connection_writer_restart (); + } void Receiver_exec_i::ccm_passivate (void) { if (this->ticker_) { - this->context_->get_CCM_object()->_get_orb ()->orb_core ()->reactor ()->cancel_timer (this->ticker_); + this->reactor ()->cancel_timer (this->ticker_); delete this->ticker_; this->ticker_ = 0; } @@ -666,4 +822,3 @@ namespace CIAO_ReadGet_Test_Receiver_Impl return retval; } } - diff --git a/CIAO/connectors/dds4ccm/tests/QueryCondition/ReadGet/Receiver/ReadGet_Test_Receiver_exec.h b/CIAO/connectors/dds4ccm/tests/QueryCondition/ReadGet/Receiver/ReadGet_Test_Receiver_exec.h index 34ea6e07c53..9de8de6fb8a 100644 --- a/CIAO/connectors/dds4ccm/tests/QueryCondition/ReadGet/Receiver/ReadGet_Test_Receiver_exec.h +++ b/CIAO/connectors/dds4ccm/tests/QueryCondition/ReadGet/Receiver/ReadGet_Test_Receiver_exec.h @@ -1,26 +1,50 @@ // -*- C++ -*- // $Id$ -#ifndef CIAO_RECEIVER_EXEC_H_ -#define CIAO_RECEIVER_EXEC_H_ +/** + * 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.cs.wustl.edu/~schmidt/TAO.html + **/ +#ifndef CIAO_READGET_TEST_RECEIVER_EXEC_WOPYWH_H_ +#define CIAO_READGET_TEST_RECEIVER_EXEC_WOPYWH_H_ + +#include /**/ "ace/pre.h" #include "ReadGet_Test_ReceiverEC.h" -#include /**/ "Receiver_exec_export.h" - #if !defined (ACE_LACKS_PRAGMA_ONCE) # pragma once #endif /* ACE_LACKS_PRAGMA_ONCE */ +#include /**/ "Receiver_exec_export.h" #include "tao/LocalObject.h" namespace CIAO_ReadGet_Test_Receiver_Impl { class Receiver_exec_i; - //============================================================ - // read_action_Generator - //============================================================ + /** + * Read action generator + */ class read_action_Generator : public ACE_Event_Handler { @@ -38,29 +62,100 @@ namespace CIAO_ReadGet_Test_Receiver_Impl }; - //============================================================ - // Starter_exec_i - //============================================================ - class Starter_exec_i + + /** + * Provider Executor Implementation Class: get_port_status_exec_i + */ + + class get_port_status_exec_i + : public virtual ::CCM_DDS::CCM_PortStatusListener, + public virtual ::CORBA::LocalObject + { + public: + get_port_status_exec_i ( + ::ReadGet_Test::CCM_Receiver_Context_ptr ctx); + virtual ~get_port_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: + ::ReadGet_Test::CCM_Receiver_Context_var ciao_context_; + }; + + /** + * Provider Executor Implementation Class: check_port_status_exec_i + */ + + class check_port_status_exec_i + : public virtual ::CCM_DDS::CCM_PortStatusListener, + public virtual ::CORBA::LocalObject + { + public: + check_port_status_exec_i ( + ::ReadGet_Test::CCM_Receiver_Context_ptr ctx); + virtual ~check_port_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: + ::ReadGet_Test::CCM_Receiver_Context_var ciao_context_; + }; + + /** + * Provider Executor Implementation Class: reader_start_exec_i + */ + + class reader_start_exec_i : public virtual ::CCM_ReadGetStarter, public virtual ::CORBA::LocalObject { public: - Starter_exec_i (Receiver_exec_i & callback); - virtual ~Starter_exec_i (void); + reader_start_exec_i ( + ::ReadGet_Test::CCM_Receiver_Context_ptr ctx, + Receiver_exec_i &callback); + virtual ~reader_start_exec_i (void); + + //@{ + /** Operations and attributes from ::ReadGetStarter. */ + + virtual + void set_reader_properties (::CORBA::UShort nr_keys, + ::CORBA::UShort nr_iterations); - virtual void set_reader_properties (CORBA::UShort nr_keys, - CORBA::UShort nr_iterations); - virtual void start_read (CORBA::UShort run); + virtual + void start_read (::CORBA::UShort run); + //@} private: + ::ReadGet_Test::CCM_Receiver_Context_var ciao_context_; Receiver_exec_i &callback_; }; - //============================================================ - // Receiver_exec_i - //============================================================ - class RECEIVER_EXEC_Export Receiver_exec_i + /** + * Component Executor Implementation Class: Receiver_exec_i + */ + + class Receiver_exec_i : public virtual Receiver_Exec, public virtual ::CORBA::LocalObject { @@ -68,15 +163,13 @@ namespace CIAO_ReadGet_Test_Receiver_Impl Receiver_exec_i (void); virtual ~Receiver_exec_i (void); - // Supported operations and attributes. - void iterations (CORBA::UShort iterations); - void keys (::CORBA::UShort keys); + //@{ + /** Supported operations and attributes. */ - // Component attributes. + //@} - // Port operations. - virtual ::CCM_ReadGetStarter_ptr - get_reader_start (); + //@{ + /** Component attributes and port operations. */ virtual ::CCM_DDS::CCM_PortStatusListener_ptr get_get_port_status (void); @@ -84,38 +177,58 @@ namespace CIAO_ReadGet_Test_Receiver_Impl virtual ::CCM_DDS::CCM_PortStatusListener_ptr get_check_port_status (void); - bool check_last (); - void start_read (CORBA::UShort run); - void run (CORBA::UShort run); - - // Operations from Components::SessionComponent. - virtual void - set_session_context ( - ::Components::SessionContext_ptr ctx); + virtual ::CCM_ReadGetStarter_ptr + get_reader_start (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 iterations (CORBA::UShort iterations); + void keys (::CORBA::UShort keys); + + bool check_last (void); + void start_read (::CORBA::UShort run); + void run (::CORBA::UShort run); + //@} private: - ::ReadGet_Test::CCM_Receiver_Context_var context_; + ::ReadGet_Test::CCM_Receiver_Context_var ciao_context_; + //@{ + /** Component attributes. */ + ::CCM_DDS::CCM_PortStatusListener_var ciao_get_port_status_; + ::CCM_DDS::CCM_PortStatusListener_var ciao_check_port_status_; + ::CCM_ReadGetStarter_var ciao_reader_start_; + //@} + + //@{ + /** User defined members. */ ReadGetRestarter_var restarter_; - CORBA::UShort iterations_; - CORBA::UShort keys_; + ::CORBA::UShort iterations_; + ::CORBA::UShort keys_; int current_min_iteration_; int current_max_iteration_; read_action_Generator *ticker_; - CORBA::ULong samples_expected_getter_; - CORBA::ULong samples_received_getter_; - CORBA::ULong samples_expected_reader_; - CORBA::ULong samples_received_reader_; + ::CORBA::ULong samples_expected_getter_; + ::CORBA::ULong samples_received_getter_; + ::CORBA::ULong samples_expected_reader_; + ::CORBA::ULong samples_received_reader_; + //@} + //@{ + /** User defined private operations. */ void test_all (void); void read_all (void); void get_all (void); @@ -126,11 +239,17 @@ namespace CIAO_ReadGet_Test_Receiver_Impl void test_exception (void); void test_set_query_parameters (void); void set_filter (void); + + //@} + + /// Get the ACE_Reactor + ACE_Reactor* reactor (void); }; extern "C" RECEIVER_EXEC_Export ::Components::EnterpriseComponent_ptr create_ReadGet_Test_Receiver_Impl (void); } -#endif /* ifndef */ +#include /**/ "ace/post.h" +#endif /* ifndef */ |