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