diff options
Diffstat (limited to 'TAO/orbsvcs/tests/EC_Throughput/ECT_Throughput.h')
-rw-r--r-- | TAO/orbsvcs/tests/EC_Throughput/ECT_Throughput.h | 137 |
1 files changed, 0 insertions, 137 deletions
diff --git a/TAO/orbsvcs/tests/EC_Throughput/ECT_Throughput.h b/TAO/orbsvcs/tests/EC_Throughput/ECT_Throughput.h deleted file mode 100644 index 47d1ff7dacd..00000000000 --- a/TAO/orbsvcs/tests/EC_Throughput/ECT_Throughput.h +++ /dev/null @@ -1,137 +0,0 @@ -/* -*- C++ -*- */ -// $Id$ -// -// ============================================================================ -// -// = DESCRIPTION -// This is a helper class for the throughput tests of the Event -// Channel. -// Used for the collocated test. -// -// ============================================================================ - -#ifndef ECT_THROUGHPUT_H -#define ECT_THROUGHPUT_H - -#include "ECT_Driver.h" -#include "ECT_Consumer.h" -#include "ECT_Supplier.h" - -#if !defined (ACE_LACKS_PRAGMA_ONCE) -# pragma once -#endif /* ACE_LACKS_PRAGMA_ONCE */ - -class ECT_Throughput : public ECT_Driver -{ - // - // = TITLE - // - // = DESCRIPTION - // -public: - ECT_Throughput (void); - - virtual ~ECT_Throughput (void); - - enum { - MAX_CONSUMERS = 16, - // Maximum number of consumers. - MAX_SUPPLIERS = 16 - // Maximum number of suppliers. - }; - - int run (int argc, char* argv[]); - // Execute the test. - - virtual void shutdown_consumer (void* consumer_cookie, - CORBA::Environment&); - // Callback method for consumers, each consumer will call this - // method once it receives all the shutdown events from the - // suppliers. - -private: - int parse_args (int argc, char* argv[]); - // parse the command line args - - void connect_consumers (RtecScheduler::Scheduler_ptr scheduler, - RtecEventChannelAdmin::EventChannel_ptr local_ec, - CORBA::Environment &_env); - void disconnect_consumers (CORBA::Environment &_env); - // Connect and disconnect the consumers. - - void connect_suppliers (RtecScheduler::Scheduler_ptr scheduler, - RtecEventChannelAdmin::EventChannel_ptr local_ec, - CORBA::Environment &_env); - void disconnect_suppliers (CORBA::Environment &_env); - // Connect the suppliers. - - void activate_suppliers (CORBA::Environment &_env); - // Activate the suppliers, i.e. they start generating events. - - void dump_results (void); - // Dump the results for each supplier. - -private: - Test_Consumer* consumers_[ECT_Throughput::MAX_CONSUMERS]; - // The consumer array. - - int n_consumers_; - // The number of consumers. - - Test_Supplier* suppliers_[ECT_Throughput::MAX_SUPPLIERS]; - // The suppliers array. - - int n_suppliers_; - // The number of suppliers. - - int burst_count_; - // How many bursts we will send from each supplier. - - int burst_size_; - // The number of events - - int event_size_; - // The size of the payload on each event. - - int burst_pause_; - // The time between each event burst, in microseconds. - - int consumer_type_start_; - int consumer_type_count_; - int consumer_type_shift_; - // The consumers subscribe to different sets of events, as follows: - // Consumer0: [start , start + count) - // Consumer1: [start + 1*shift, start + 1*shift + count) - // Consumer2: [start + 2*shift, start + 2*shift + count) - // And so on. - - int supplier_type_start_; - int supplier_type_count_; - int supplier_type_shift_; - // The suppliers generate different sets of events, as follows: - // Supplier0: [start , start + count) - // Supplier1: [start + 1*shift, start + 1*shift + count) - // Supplier2: [start + 2*shift, start + 2*shift + count) - // And so on. - - const char* pid_file_name_; - // The name of a file where the process stores its pid - - CORBA::ORB_var orb_; - // A reference to the ORB, to shut it down properly. - - ACE_SYNCH_MUTEX lock_; - int active_count_; - // How many consumers are still receiving events. - - int reactive_ec_; - // If not zero then we use a reactive EC. - - int new_ec_; - // If not zero then we use the new EC implementation - - int ec_concurrency_hwm_; - // Set the HWM for the concurrency in the EC. -}; - -#endif /* ECT_TRHOUGHPUT_H */ |