diff options
Diffstat (limited to 'TAO/orbsvcs/tests/EC_Throughput/ECT_Consumer.h')
-rw-r--r-- | TAO/orbsvcs/tests/EC_Throughput/ECT_Consumer.h | 86 |
1 files changed, 0 insertions, 86 deletions
diff --git a/TAO/orbsvcs/tests/EC_Throughput/ECT_Consumer.h b/TAO/orbsvcs/tests/EC_Throughput/ECT_Consumer.h deleted file mode 100644 index 8b33409dd5b..00000000000 --- a/TAO/orbsvcs/tests/EC_Throughput/ECT_Consumer.h +++ /dev/null @@ -1,86 +0,0 @@ -/* -*- C++ -*- */ -// $Id$ -// -// ============================================================================ -// -// = DESCRIPTION -// This test to measure how many events per minute can the EC -// process, it also serves as an example how how to encode complex -// data types in a octet sequence. -// -// ============================================================================ - -#ifndef ECT_CONSUMER_H -#define ECT_CONSUMER_H - -#include "ace/Task.h" - -#if !defined (ACE_LACKS_PRAGMA_ONCE) -# pragma once -#endif /* ACE_LACKS_PRAGMA_ONCE */ - -#include "ace/High_Res_Timer.h" -#include "orbsvcs/Channel_Clients_T.h" - -#include "ECT_Driver.h" - -class Test_Consumer : public POA_RtecEventComm::PushConsumer -{ - // = TITLE - // Receive the events. - // - // = DESCRIPTION - // This class is a consumer of events. It subscribes for a - // continous ranges of event types, this permits studying the - // effect of the number of subscriptions for each particular kind - // of event on the EC. - // -public: - Test_Consumer (ECT_Driver* driver, - void* cookie, - int n_suppliers); - - void connect (RtecScheduler::Scheduler_ptr scheduler, - const char* name, - int type_start, - int type_count, - RtecEventChannelAdmin::EventChannel_ptr ec, - CORBA::Environment& _env); - // This method connects the consumer to the EC. - - void disconnect (CORBA::Environment &_env); - // Disconnect from the EC. - - void dump_results (const char* name); - // Print out the results - - virtual void push (const RtecEventComm::EventSet& events, - CORBA::Environment &_env); - virtual void disconnect_push_consumer (CORBA::Environment &); - // The skeleton methods. - -private: - ECT_Driver* driver_; - // The main driver for the test. - - void* cookie_; - // A magic cookie passed by the driver that we pass back in our - // callbacks. - - int n_suppliers_; - // The number of suppliers that are feeding this consumer, we - // terminate once we receive a shutdown event from each supplier. - - RtecEventChannelAdmin::ProxyPushSupplier_var supplier_proxy_; - // We talk to the EC using this proxy. - - ACE_SYNCH_MUTEX lock_; - int recv_count_; - ACE_High_Res_Timer timer_; - // How many events we have received. - - int shutdown_count_; - // How many shutdown events we have received. -}; - -#endif /* ECT_CONSUMER_H */ |