1 files changed, 182 insertions, 0 deletions
diff --git a/TAO/local/tests/Utilization.h b/TAO/local/tests/Utilization.h
new file mode 100644
index 00000000000..b1394a1c975
--- /dev/null
+++ b/TAO/local/tests/Utilization.h
@@ -0,0 +1,182 @@
+/* -*- C++ -*- */
+// $Id$
+//
+// ============================================================================
+//
+// = LIBRARY
+//    ACE Event Service Benchmarks
+// 
+// = FILENAME
+//    Utilization.h
+//
+// = AUTHOR
+//    David Levine (levine@cs.wustl.edu) and
+//    Tim Harrison (harrison@cs.wustl.edu)
+//
+// = DESCRIPTION
+//
+// ============================================================================
+
+#if !defined (UTILIZATION_H)
+#define UTILIZATION_H
+
+#include "RtecEvenCommS.h"
+
+class Utilization_Consumer : public POA_RtecEventComm::PushConsumer
+// = TITLE
+//    Utilization Consumer
+//
+// = DESCRIPTION
+//    Simple example of a consumer that registers for supplier
+//    notifications.
+{
+public:
+  Utilization_Consumer (const int measure_jitter = 0);
+  // Construction.  The default of not measuring jitter provides
+  // a "null" push routine, for measuring aggregate timing.
+
+  int open_consumer (const char *my_name, const char *supplier_name);
+  // Uses the name server to obtain a reference to the <supplier_name>
+  // and registers with channel to receive notifications from the
+  // supplier.  Also registers to receive shutdown messages from the
+  // supplier.  Stores <my_name> for printing out messages.  Returns 0
+  // on success, -1 on failure.
+
+  virtual void disconnect_push_consumer (CORBA::Environment &);
+  // The channel is disconnecting.
+
+  const char *entry_point () /* const */ { return rt_info_->entry_point (); }
+
+  void print_stats () /* const */;
+  // Print timing statistics.
+
+// (not protected to allow short-circuiting) protected:
+  virtual void push (const RtecEventComm::EventSet &events,
+		     CORBA::Environment &);
+  // If the <events>[0] is a notification, prints out the data from
+  // the supplier.  If its a shutdown message, the consumer
+  // disconnects from the channel.
+
+protected:
+  void shutdown (void);
+  // Disconnect from the Event Service.
+
+  // = Event channel adminstration references.
+  RtecEventChannelAdmin::EventChannel_ptr channel_admin_;
+  RtecEventChannelAdmin::ConsumerAdmin_ptr consumer_admin_;
+  RtecEventChannelAdmin::ProxyPushSupplier_ptr suppliers_;
+
+private:
+  ACE_Scheduler::RT_Info* rt_info_;
+
+  int measure_jitter_;
+
+  ACE_hrtime_t iterations_;
+  ACE_Time_Value min_utilization_;
+  ACE_Time_Value max_utilization_;
+  ACE_Time_Value total_utilization_;
+  u_long total_pushes_;
+  // Registers and counters for keeping track of utilization statistics.
+};
+
+// ************************************************************
+
+class Utilization_Supplier : public POA_RtecEventComm::PushSupplier, public POA_RtecEventComm::PushConsumer
+// = TITLE
+//    Utilization Supplier
+//
+// = DESCRIPTION
+//    Generates event nofications and a shutdown message.
+{
+public:
+  Utilization_Supplier (const u_int total_messages,
+                    const int timestamp = 0);
+  // Construction.  Requires the total number of messages to be
+  // sent.  If the timestamp flag is enabled, then events are
+  // timestamped, e.g., for use in measuring jitter.
+  
+  int open_supplier (const char *name, int master);
+  // Registers with the name server under the given <name>.  Also
+  // connects to the Event Channel as a supplier of notifications and
+  // shutdown messages.  If <master> != 0, then the supplier will
+  // destroy the channel upon shutting down. Returns 0 on success, -1
+  // on failure.
+
+  virtual void disconnect_push_supplier (CORBA::Environment &);
+  // The channel is disconnecting.
+
+  virtual void disconnect_push_consumer (CORBA::Environment &);
+  // The channel is disconnecting.
+
+  int start_generating_events (void);
+  // Called when the supplier should start generating events.
+  // Registers with the Event Channel to receive timeouts every .25
+  // seconds.  Will generate some number of events and then send a
+  // shutdown message.  Returns 0 on success, -1 on failure.
+
+  const char *entry_point () /* const */ { return rt_info_->entry_point (); }
+
+  void print_stats () /* const */;
+  // Print timing statistics.
+
+protected:
+  void push (const RtecEventComm::EventSet &events,
+	     CORBA::Environment &);
+  // Takes a timestamp and then pushes event_ to all consumers, either
+  // directly, or via a channel.
+
+  void shutdown (void);
+  // Disconnect from the Event Service.
+
+  // = Event Channel adminstration references.
+  RtecEventChannelAdmin::EventChannel_ptr channel_admin_;
+  RtecEventChannelAdmin::ConsumerAdmin_ptr consumer_admin_;
+  RtecEventChannelAdmin::ProxyPushConsumer_ptr consumers_;
+  RtecEventChannelAdmin::SupplierAdmin_ptr supplier_admin_;
+  RtecEventChannelAdmin::ProxyPushSupplier_ptr suppliers_;
+
+private:
+  ACE_Scheduler::RT_Info_ptr rt_info_;
+
+  u_int total_messages_;
+  // How many events to push before ending the test.
+
+  int timestamp_;
+  // Flag indicating whether or not to timestamp outgoing events.
+
+  u_int total_sent_;
+  // How many events we've pushed.
+
+  ACE_Time_Value test_start_time_;
+  ACE_Time_Value test_stop_time_;
+  // Start/stop times, marking the time period when events are
+  // sent to consumers.
+
+  int master_;
+};
+
+
+class Scavenger : public ACE_Task<ACE_NULL_SYNCH>
+// = TITLE
+//    Scavenger
+//
+// = DESCRIPTION
+//    Soaks up all unused CPU cycles.
+{
+public:
+  Scavenger (const int priority);
+  virtual ~Scavenger ();
+
+  int open (void *);
+  int svc (void);
+  void print_status ();
+
+private:
+  int priority_;
+  ACE_hrtime_t iterations_;
+
+  // not implemented . . .
+  Scavenger ();
+};
+
+#endif /* UTILIZATION_H */