summaryrefslogtreecommitdiff
path: root/TAO/orbsvcs/tests/EC_Throughput/ECT_Throughput.h
diff options
context:
space:
mode:
Diffstat (limited to 'TAO/orbsvcs/tests/EC_Throughput/ECT_Throughput.h')
-rw-r--r--TAO/orbsvcs/tests/EC_Throughput/ECT_Throughput.h137
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 */