diff options
Diffstat (limited to 'TAO/orbsvcs/tests/CosEC_Basic')
| -rw-r--r-- | TAO/orbsvcs/tests/CosEC_Basic/CosECConsumer.cpp | 82 | ||||
| -rw-r--r-- | TAO/orbsvcs/tests/CosEC_Basic/CosECConsumer.h | 64 | ||||
| -rw-r--r-- | TAO/orbsvcs/tests/CosEC_Basic/CosECSupplier.cpp | 80 | ||||
| -rw-r--r-- | TAO/orbsvcs/tests/CosEC_Basic/CosECSupplier.h | 61 | ||||
| -rw-r--r-- | TAO/orbsvcs/tests/CosEC_Basic/CosEC_Basic.cpp | 226 | ||||
| -rw-r--r-- | TAO/orbsvcs/tests/CosEC_Basic/CosEC_Basic.h | 110 | ||||
| -rw-r--r-- | TAO/orbsvcs/tests/CosEC_Basic/Makefile | 35 | ||||
| -rw-r--r-- | TAO/orbsvcs/tests/CosEC_Basic/README | 26 |
8 files changed, 0 insertions, 684 deletions
diff --git a/TAO/orbsvcs/tests/CosEC_Basic/CosECConsumer.cpp b/TAO/orbsvcs/tests/CosEC_Basic/CosECConsumer.cpp deleted file mode 100644 index a3b69b11354..00000000000 --- a/TAO/orbsvcs/tests/CosEC_Basic/CosECConsumer.cpp +++ /dev/null @@ -1,82 +0,0 @@ -/* -*- C++ -*- */ -// $Id$ - -#include "CosECConsumer.h" - -void -CosECConsumer::open (CosEventChannelAdmin::EventChannel_ptr event_channel, - CORBA::Environment& TAO_TRY_ENV) -{ - // = Connect as a consumer. - this->consumer_admin_ = - event_channel->for_consumers (TAO_TRY_ENV); - TAO_CHECK_ENV_RETURN_VOID (TAO_TRY_ENV); -} - -void -CosECConsumer::close (CORBA::Environment &TAO_TRY_ENV) -{ - this->disconnect (TAO_TRY_ENV); - this->consumer_admin_ = - CosEventChannelAdmin::ConsumerAdmin::_nil (); -} - -void -CosECConsumer::connect (CORBA::Environment &TAO_TRY_ENV) -{ - if (CORBA::is_nil (this->consumer_admin_.in ())) - return; - - CosEventComm::PushConsumer_var objref = - this->_this (TAO_TRY_ENV); - TAO_CHECK_ENV_RETURN_VOID (TAO_TRY_ENV); - - this->supplier_proxy_ = - this->consumer_admin_->obtain_push_supplier (TAO_TRY_ENV); - TAO_CHECK_ENV_RETURN_VOID (TAO_TRY_ENV); - - this->supplier_proxy_->connect_push_consumer (objref.in (), - TAO_TRY_ENV); - TAO_CHECK_ENV_RETURN_VOID (TAO_TRY_ENV); -} - -void -CosECConsumer::disconnect (CORBA::Environment &TAO_TRY_ENV) -{ - if (CORBA::is_nil (this->supplier_proxy_.in ()) - || CORBA::is_nil (this->consumer_admin_.in ())) - return; - - this->supplier_proxy_->disconnect_push_supplier (TAO_TRY_ENV); - TAO_CHECK_ENV_RETURN_VOID (TAO_TRY_ENV); - - this->supplier_proxy_ = - CosEventChannelAdmin::ProxyPushSupplier::_nil (); -} - -void -CosECConsumer::push (const CORBA::Any &data, - CORBA::Environment &TAO_TRY_ENV) -{ - ACE_DEBUG ((LM_DEBUG, - "in CosECConsumer::push\n")); -} - -void -CosECConsumer::disconnect_push_consumer (CORBA::Environment &TAO_TRY_ENV) -{ - // Deactivate this object. - - PortableServer::POA_var poa = - this->_default_POA (TAO_TRY_ENV); - TAO_CHECK_ENV_RETURN_VOID (TAO_TRY_ENV); - - PortableServer::ObjectId_var id = - poa->servant_to_id (this, - TAO_TRY_ENV); - TAO_CHECK_ENV_RETURN_VOID (TAO_TRY_ENV); - - poa->deactivate_object (id.in (), - TAO_TRY_ENV); - TAO_CHECK_ENV_RETURN_VOID (TAO_TRY_ENV); -} diff --git a/TAO/orbsvcs/tests/CosEC_Basic/CosECConsumer.h b/TAO/orbsvcs/tests/CosEC_Basic/CosECConsumer.h deleted file mode 100644 index ff9fefb9092..00000000000 --- a/TAO/orbsvcs/tests/CosEC_Basic/CosECConsumer.h +++ /dev/null @@ -1,64 +0,0 @@ -/* -*- C++ -*- */ -// $Id$ - -// ============================================================================ -// -// = FILENAME -// CosECConsumer.h -// -// = AUTHOR -// Pradeep Gore <pradeep@cs.wustl.edu> -// -// = DESCRIPTION -// Defines a simple Push Consumer. -// -// ============================================================================ - -#ifndef COSECCONSUMER_H_ -#define COSECCONSUMER_H_ - -#include "orbsvcs/CosEventCommC.h" -#include "orbsvcs/CosEventChannelAdminC.h" -#include "orbsvcs/CosEventCommS.h" -#include "orbsvcs/CosEventChannelAdminS.h" - -class CosECConsumer : public POA_CosEventComm::PushConsumer -{ - // = TITLE - // CosECConsumer - // - // = DESCRIPTION - // The CosECConsumer is a simple PushConsumer that connects to the - // CosEC and receives events from it. - -public: - void open (CosEventChannelAdmin::EventChannel_ptr event_channel, - CORBA::Environment& TAO_TRY_ENV); - // This method connects the consumer to the EC. - - void close (CORBA::Environment &TAO_TRY_ENV); - // Disconnect from the EC. - - void connect (CORBA::Environment &TAO_TRY_ENV); - // Connect the CosECConsumer to the EventChannel. - - void disconnect (CORBA::Environment &TAO_TRY_ENV); - // Disconnect from the supplier, but do not forget about it or close - // it. - - virtual void push (const CORBA::Any &data, - CORBA::Environment &TAO_TRY_ENV); - // push the event to the consumer. - - virtual void disconnect_push_consumer (CORBA::Environment &TAO_TRY_ENV); - // disconnect the consumer from the EC. - -private: - CosEventChannelAdmin::ProxyPushSupplier_var supplier_proxy_; - // We talk to the EC using this proxy. - - CosEventChannelAdmin::ConsumerAdmin_var consumer_admin_; - // We talk to the EC using this proxy. -}; - -#endif /* COSECCONSUMER_H_ */ diff --git a/TAO/orbsvcs/tests/CosEC_Basic/CosECSupplier.cpp b/TAO/orbsvcs/tests/CosEC_Basic/CosECSupplier.cpp deleted file mode 100644 index 30731b04f33..00000000000 --- a/TAO/orbsvcs/tests/CosEC_Basic/CosECSupplier.cpp +++ /dev/null @@ -1,80 +0,0 @@ -/* -*- C++ -*- */ -// $Id$ - -#include "CosECSupplier.h" - -void -CosECSupplier::open (CosEventChannelAdmin::EventChannel_ptr event_channel, - CORBA::Environment& TAO_TRY_ENV) -{ - // = Connect as a consumer. - this->supplier_admin_ = - event_channel->for_suppliers (TAO_TRY_ENV); - TAO_CHECK_ENV_RETURN_VOID (TAO_TRY_ENV); -} - -void -CosECSupplier::close (CORBA::Environment &TAO_TRY_ENV) -{ - this->disconnect (TAO_TRY_ENV); - this->supplier_admin_ = - CosEventChannelAdmin::SupplierAdmin::_nil (); -} - -void -CosECSupplier::connect (CORBA::Environment &TAO_TRY_ENV) -{ - if (CORBA::is_nil (this->supplier_admin_.in ())) - return; - - this->consumer_proxy_ = - this->supplier_admin_->obtain_push_consumer (TAO_TRY_ENV); - TAO_CHECK_ENV_RETURN_VOID (TAO_TRY_ENV); - - CosEventComm::PushSupplier_var objref = this->_this (TAO_TRY_ENV); - TAO_CHECK_ENV_RETURN_VOID (TAO_TRY_ENV); - - this->consumer_proxy_->connect_push_supplier (objref.in (), - TAO_TRY_ENV); - TAO_CHECK_ENV_RETURN_VOID (TAO_TRY_ENV); -} - -void -CosECSupplier::disconnect (CORBA::Environment &TAO_TRY_ENV) -{ - if (CORBA::is_nil (this->consumer_proxy_.in ()) - || CORBA::is_nil (this->supplier_admin_.in ())) - return; - - this->consumer_proxy_->disconnect_push_consumer (TAO_TRY_ENV); - TAO_CHECK_ENV_RETURN_VOID (TAO_TRY_ENV); - - this->consumer_proxy_ = - CosEventChannelAdmin::ProxyPushConsumer::_nil (); -} - -void -CosECSupplier::send_event (const CORBA::Any & data, - CORBA::Environment &TAO_TRY_ENV) -{ - this->consumer_proxy_->push (data, TAO_TRY_ENV); -} - -void -CosECSupplier::disconnect_push_supplier (CORBA::Environment &TAO_TRY_ENV) -{ - // Deactivate this object. - - PortableServer::POA_var poa = - this->_default_POA (TAO_TRY_ENV); - TAO_CHECK_ENV_RETURN_VOID (TAO_TRY_ENV); - - PortableServer::ObjectId_var id = - poa->servant_to_id (this, - TAO_TRY_ENV); - TAO_CHECK_ENV_RETURN_VOID (TAO_TRY_ENV); - - poa->deactivate_object (id.in (), - TAO_TRY_ENV); - TAO_CHECK_ENV_RETURN_VOID (TAO_TRY_ENV); -} diff --git a/TAO/orbsvcs/tests/CosEC_Basic/CosECSupplier.h b/TAO/orbsvcs/tests/CosEC_Basic/CosECSupplier.h deleted file mode 100644 index f7a6d4339bf..00000000000 --- a/TAO/orbsvcs/tests/CosEC_Basic/CosECSupplier.h +++ /dev/null @@ -1,61 +0,0 @@ -/* -*- C++ -*- */ -// $Id$ - -// ============================================================================ -// -// = FILENAME -// CosECSupplier.h -// -// = AUTHOR -// Pradeep Gore <pradeep@cs.wustl.edu> -// -// = DESCRIPTION -// Defines a simple Push Supplier. -// -// ============================================================================ - -#ifndef COSECSUPPLIER_H_ -#define COSECSUPPLIER_H_ - -#include "orbsvcs/CosEventCommC.h" -#include "orbsvcs/CosEventChannelAdminC.h" -#include "orbsvcs/CosEventCommS.h" -#include "orbsvcs/CosEventChannelAdminS.h" - -class CosECSupplier : public POA_CosEventComm::PushSupplier -{ - // = TITLE - // CosECSupplier - // - // = DESCRIPTION - // The CosECSupplier is a simple Push Supplier that connects to - // the CosEC and sends events to it. -public: - void open (CosEventChannelAdmin::EventChannel_ptr event_channel, - CORBA::Environment &TAO_TRY_ENV); - // This method connects the supplier to the EC. - - void close (CORBA::Environment &TAO_TRY_ENV); - // Disconnect from the EC. - - void connect (CORBA::Environment &TAO_TRY_ENV); - - void disconnect (CORBA::Environment &TAO_TRY_ENV); - // Disconnect from the EC, but do not forget about it or close it. - - void send_event (const CORBA::Any &data, - CORBA::Environment &TAO_TRY_ENV); - // Send one event. - - virtual void disconnect_push_supplier (CORBA::Environment &); - // The POA_CosEventComm::PushSupplier method. - -private: - CosEventChannelAdmin::ProxyPushConsumer_var consumer_proxy_; - // We talk to the EC using this proxy. - - CosEventChannelAdmin::SupplierAdmin_var supplier_admin_; - // We talk to the EC using this proxy. -}; - -#endif /* COSECSUPPLIER_H_ */ diff --git a/TAO/orbsvcs/tests/CosEC_Basic/CosEC_Basic.cpp b/TAO/orbsvcs/tests/CosEC_Basic/CosEC_Basic.cpp deleted file mode 100644 index 17358a94bb1..00000000000 --- a/TAO/orbsvcs/tests/CosEC_Basic/CosEC_Basic.cpp +++ /dev/null @@ -1,226 +0,0 @@ -/* -*- C++ -*- */ -// $Id$ - -#include "CosEC_Basic.h" - -int -main (int argc, char *argv []) -{ - CosEC_Basic basic; - - if (basic.init (argc, argv) == -1) - ACE_ERROR_RETURN ((LM_ERROR, - " (%P|%t) CosEC_Basic::init failed.\n"), - -1); - basic.run (); - basic.shutdown (); - return 0; -} - -CosEC_Basic::CosEC_Basic (void) - : ec_impl_ (0, - ACE_DEFAULT_EVENT_CHANNEL_TYPE, - &module_factory_) -{ - // No-Op. -} - -CosEC_Basic::~CosEC_Basic (void) -{ - // No-Op. -} - -int -CosEC_Basic::init_ORB (int argc, char *argv []) -{ - TAO_TRY - { - this->orb_ = CORBA::ORB_init (argc, - argv, - "", - TAO_TRY_ENV); - TAO_CHECK_ENV_RETURN (TAO_TRY_ENV, -1); - - CORBA::Object_var poa_object = - this->orb_->resolve_initial_references("RootPOA", - TAO_TRY_ENV); - if (CORBA::is_nil (poa_object.in ())) - ACE_ERROR_RETURN ((LM_ERROR, - " (%P|%t) Unable to initialize the POA.\n"), - -1); - - PortableServer::POA_var root_poa = - PortableServer::POA::_narrow (poa_object.in (), - TAO_TRY_ENV); - TAO_CHECK_ENV_RETURN (TAO_TRY_ENV, -1); - - PortableServer::POAManager_var poa_manager = - root_poa->the_POAManager (TAO_TRY_ENV); - TAO_CHECK_ENV_RETURN (TAO_TRY_ENV, -1); - - poa_manager->activate (TAO_TRY_ENV); - TAO_CHECK_ENV_RETURN (TAO_TRY_ENV, -1); - - return 0; - } - TAO_CATCHANY - { - TAO_TRY_ENV.print_exception ("Exception in CosEC_Basic::init_ORB"); - return -1; - } - TAO_ENDTRY; -} - -int -CosEC_Basic::init_RtEC (void) -{ - TAO_TRY - { - this->scheduler_ = - this->scheduler_impl_._this (TAO_TRY_ENV); - TAO_CHECK_ENV_RETURN (TAO_TRY_ENV, -1); - - CORBA::String_var str = - this->orb_->object_to_string (this->scheduler_.in (), - TAO_TRY_ENV); - TAO_CHECK_ENV_RETURN (TAO_TRY_ENV, -1); - - ACE_DEBUG ((LM_DEBUG, - "EC_Basic: The (local) scheduler IOR is <%s>\n", - str.in ())); - - if (ACE_Scheduler_Factory::server (this->scheduler_.in ()) == -1) - return -1; - - this->rtec_ = this->ec_impl_._this (TAO_TRY_ENV); - TAO_CHECK_ENV_RETURN (TAO_TRY_ENV, -1); - - str = this->orb_->object_to_string (this->rtec_.in (), - TAO_TRY_ENV); - TAO_CHECK_ENV_RETURN (TAO_TRY_ENV, -1); - - ACE_DEBUG ((LM_DEBUG, - "EC_Basic: The RTEC IOR is <%s>\n", - str.in ())); - - this->ec_impl_.activate (); - - return 0; - } - TAO_CATCHANY - { - TAO_TRY_ENV.print_exception ("Exception in CosEC_Basic::init_RtEC"); - return -1; - } - TAO_ENDTRY; -} - -int -CosEC_Basic::init_CosEC (void) -{ - TAO_TRY - { - // Setup the QOS params.. - this->supplier_qos_.insert (1, - ACE_ES_EVENT_ANY, - this->scheduler_->create ("supplier", - TAO_TRY_ENV), - 1); - - this->consumer_qos_.start_disjunction_group (); - this->consumer_qos_.insert_source (1, - this->scheduler_->create ("consumer", - TAO_TRY_ENV)); - TAO_CHECK_ENV_RETURN (TAO_TRY_ENV, -1); - - const RtecEventChannelAdmin::ConsumerQOS &consumerqos = - this->consumer_qos_.get_ConsumerQOS (); - - const RtecEventChannelAdmin::SupplierQOS &supplierqos = - this->supplier_qos_.get_SupplierQOS (); - - if (this->ec_i_.init (consumerqos, - supplierqos, - this->rtec_, - TAO_TRY_ENV) != 0) - return -1; - - TAO_CHECK_ENV_RETURN (TAO_TRY_ENV, -1); - - this->cos_ec_ = this->ec_i_._this (TAO_TRY_ENV); - TAO_CHECK_ENV_RETURN (TAO_TRY_ENV, -1); - - return 0; - } - TAO_CATCHANY - { - TAO_TRY_ENV.print_exception ("Exception in CosEC_Basic::init_CosEC"); - return -1; - } - TAO_ENDTRY; -} - -int -CosEC_Basic::init (int argc, char *argv []) -{ - if (init_ORB (argc, argv) == -1 - || init_RtEC () == -1 - || init_CosEC () == -1) - return -1; - else - return 0; -} - -void -CosEC_Basic::shutdown (void) -{ - TAO_TRY - { - this->supplier_.close (TAO_TRY_ENV); - this->consumer_.close (TAO_TRY_ENV); - - this->cos_ec_->destroy (TAO_TRY_ENV); - this->ec_impl_.shutdown (); - } - TAO_CATCHANY - { - TAO_TRY_ENV.print_exception ("Exception in CosEC_Basic::finish"); - } - TAO_ENDTRY; -} - -void -CosEC_Basic::run (void) -{ - TAO_TRY - { - // Create an Any type to pass to the Cos EC. - CORBA_Any cany; - cany <<= CORBA::Long (50); - CORBA::Any any; - cany >>= any; - - this->consumer_.open (this->cos_ec_, - TAO_TRY_ENV); - TAO_CHECK_ENV_RETURN_VOID (TAO_TRY_ENV); - - this->consumer_.connect (TAO_TRY_ENV); - TAO_CHECK_ENV_RETURN_VOID (TAO_TRY_ENV); - - this->supplier_.open (this->cos_ec_, - TAO_TRY_ENV); - TAO_CHECK_ENV_RETURN_VOID (TAO_TRY_ENV); - - this->supplier_.connect (TAO_TRY_ENV); - TAO_CHECK_ENV_RETURN_VOID (TAO_TRY_ENV); - - this->supplier_.send_event (any, - TAO_TRY_ENV); - TAO_CHECK_ENV_RETURN_VOID (TAO_TRY_ENV); - } - TAO_CATCHANY - { - TAO_TRY_ENV.print_exception ("exception in CosEC_Basic::runtest\n"); - } - TAO_ENDTRY; -} diff --git a/TAO/orbsvcs/tests/CosEC_Basic/CosEC_Basic.h b/TAO/orbsvcs/tests/CosEC_Basic/CosEC_Basic.h deleted file mode 100644 index 96a2011c042..00000000000 --- a/TAO/orbsvcs/tests/CosEC_Basic/CosEC_Basic.h +++ /dev/null @@ -1,110 +0,0 @@ -/* -*- C++ -*- */ -// $Id$ - -// ============================================================================ -// -// = FILENAME -// CosEC_Basic.h -// -// = AUTHOR -// Pradeep Gore <pradeep@cs.wustl.edu> -// -// = DESCRIPTION -// This is a simple test class for the standard Cos Event Channel. -// -// ============================================================================ - -#ifndef COSECBASIC_H -#define COSECBASIC_H - -#include "orbsvcs/Event_Utilities.h" -#include "orbsvcs/Event_Service_Constants.h" -#include "orbsvcs/Scheduler_Factory.h" -#include "orbsvcs/Time_Utilities.h" -#include "orbsvcs/RtecEventChannelAdminC.h" -#include "orbsvcs/Sched/Config_Scheduler.h" -#include "orbsvcs/Runtime_Scheduler.h" -#include "orbsvcs/Event/Event_Channel.h" -#include "orbsvcs/Event/Module_Factory.h" -#include "orbsvcs/CosEvent/EventChannel_i.h" -#include "CosECConsumer.h" -#include "CosECSupplier.h" - -class CosEC_Basic -{ - // = TITLE - // class CosEC_Basic - // - // = DESCRIPTION - // Creates a CORBA Standard Event Channel (COSEC) implemented with - // TAO's Real-time Event Channel (RtEC) and sends an event across. -public: - // = Initialization and termination methods. - CosEC_Basic (void); - // Constructor. - - ~CosEC_Basic (void); - // Destructor. - - int init (int argc, char *argv[]); - // Starts up an ORB, a Rtec and the CosEC. - // Returns 0 on success, -1 on error. - - void run (void); - // Connects a consumer and a supplier to the CosEC and sends 1 event - // across. - - void shutdown (void); - // Closes down the Rtec and CosEC. - -private: - int init_ORB (int argc, char *argv[]); - // initializes the ORB. - // Returns 0 on success, -1 on error. - - int init_RtEC (void); - // initializes the Real Time EC. - // Returns 0 on success, -1 on error. - - int init_CosEC (void); - // initializes the COS EC. - // Returns 0 on success, -1 on error. - - CORBA::ORB_var orb_; - // The ORB that we use. - - TAO_Reactive_Module_Factory module_factory_; - // The Module_Factory required by the Rtec. - - ACE_Config_Scheduler scheduler_impl_; - // Scheduler used by the Rtec. - - RtecScheduler::Scheduler_var scheduler_; - // Reference to the Scheduler after activating it in the ORB. - - ACE_EventChannel ec_impl_; - // The servant object of the Rtec. - - RtecEventChannelAdmin::EventChannel_var rtec_; - // Reference to the Rtec returned after activating it in the ORB. - - ACE_ConsumerQOS_Factory consumer_qos_; - // The Consumer QOS. - - ACE_SupplierQOS_Factory supplier_qos_; - // The Supplier QOS. - - EventChannel_i ec_i_; - // The servant object of the COS Event Channel. - - CosEventChannelAdmin::EventChannel_ptr cos_ec_; - // Reference to the CosEC returned after activating it in the ORB. - - CosECConsumer consumer_; - // The Cos Consumer that will receive the event. - - CosECSupplier supplier_; - // The Cos Supplier that will supply the event. -}; - -#endif /* COSECBASIC_H */ diff --git a/TAO/orbsvcs/tests/CosEC_Basic/Makefile b/TAO/orbsvcs/tests/CosEC_Basic/Makefile deleted file mode 100644 index 977c8ad430d..00000000000 --- a/TAO/orbsvcs/tests/CosEC_Basic/Makefile +++ /dev/null @@ -1,35 +0,0 @@ -# $Id$ - -BIN = CosEC_Basic - -SRC = $(BIN:%=%$(VAR).cpp) \ - CosECConsumer.cpp \ - CosECSupplier.cpp - -LDLIBS= -lorbsvcs -lTAO - -ifndef TAO_ROOT -TAO_ROOT = $(ACE_ROOT)/TAO -endif - -CPPFLAGS += -I$(TAO_ROOT)/orbsvcs \ - -I$(TAO_ROOT) - -#---------------------------------------------------------------------------- -# Include macros and targets -#---------------------------------------------------------------------------- - -include $(ACE_ROOT)/include/makeinclude/wrapper_macros.GNU -include $(ACE_ROOT)/include/makeinclude/macros.GNU -include $(ACE_ROOT)/include/makeinclude/rules.common.GNU -include $(ACE_ROOT)/include/makeinclude/rules.nonested.GNU -include $(ACE_ROOT)/include/makeinclude/rules.local.GNU -include $(ACE_ROOT)/include/makeinclude/rules.bin.GNU - -#### Local rules and variables... - -#---------------------------------------------------------------------------- -# Dependencies -#---------------------------------------------------------------------------- - -# DO NOT DELETE THIS LINE -- g++dep uses it. diff --git a/TAO/orbsvcs/tests/CosEC_Basic/README b/TAO/orbsvcs/tests/CosEC_Basic/README deleted file mode 100644 index 291ec0fa208..00000000000 --- a/TAO/orbsvcs/tests/CosEC_Basic/README +++ /dev/null @@ -1,26 +0,0 @@ -$Id$ - -The Cos_ECBasic test shows how to: - - . Create a standard Cos Event Channel, - . Write simple COS compliant consumers and suppliers, - . Connect consumers and suppliers to the COSEC, - . Send and receive events form the EC. - -For initialization, the CosEC_Basic test first creates and initializes -a TAO real-time EC (Rtec). Then, it initializes QOS parameters for -the Supplier and Consumers and then initializes a COSEC (Corba Object -Service compliant Event Channel). - -To test the COSEC the test initializes a Supplier and a Consumer , -connects them to the COSEC. The Supplier then sends an event to the -channel which is delivered to the Consumer via the <push> method. -This method then prints a message to show that an event was delivered -to the Consumer. - -Finally the Rtec and COSEC are shutdown to finish the test. - -NOTE: please do not attempt to compile this test till I've integrated -the COSEC code into orbsvcs. - -- Pradeep <pradeep@cs.wustl.edu> |