summaryrefslogtreecommitdiff
path: root/TAO/orbsvcs/performance-tests/RTEvent/lib/Consumer.h
diff options
context:
space:
mode:
authorWilliam R. Otte <wotte@dre.vanderbilt.edu>2006-07-24 15:50:11 +0000
committerWilliam R. Otte <wotte@dre.vanderbilt.edu>2006-07-24 15:50:11 +0000
commit6b846cf03c0bcbd8c276cb0af61a181e5f98eaae (patch)
treeda50d054f9c761c3f6a5923f6979e93306c56d68 /TAO/orbsvcs/performance-tests/RTEvent/lib/Consumer.h
parent0e555b9150d38e3b3473ba325b56db2642e6352b (diff)
downloadATCD-6b846cf03c0bcbd8c276cb0af61a181e5f98eaae.tar.gz
Repo restructuring
Diffstat (limited to 'TAO/orbsvcs/performance-tests/RTEvent/lib/Consumer.h')
-rw-r--r--TAO/orbsvcs/performance-tests/RTEvent/lib/Consumer.h88
1 files changed, 0 insertions, 88 deletions
diff --git a/TAO/orbsvcs/performance-tests/RTEvent/lib/Consumer.h b/TAO/orbsvcs/performance-tests/RTEvent/lib/Consumer.h
deleted file mode 100644
index f9206fe4ba2..00000000000
--- a/TAO/orbsvcs/performance-tests/RTEvent/lib/Consumer.h
+++ /dev/null
@@ -1,88 +0,0 @@
-/**
- * @file Consumer.h
- *
- * $Id$
- *
- */
-
-#ifndef TAO_PERF_RTEC_CONSUMER_H
-#define TAO_PERF_RTEC_CONSUMER_H
-
-#include "rtec_perf_export.h"
-#include "orbsvcs/RtecEventCommS.h"
-#include "orbsvcs/RtecEventChannelAdminC.h"
-
-#include "ace/Sample_History.h"
-
-#if !defined (ACE_LACKS_PRAGMA_ONCE)
-# pragma once
-#endif /* ACE_LACKS_PRAGMA_ONCE */
-
-/**
- * @class Consumer
- *
- * @brief Implement a simple consumer to keep track of the latency
- *
- */
-class TAO_RTEC_Perf_Export Consumer
- : public virtual POA_RtecEventComm::PushConsumer
-
-{
-public:
- /// Constructor
- Consumer (CORBA::Long experiment_id,
- CORBA::Long event_type,
- CORBA::ULong iterations,
- CORBA::Long workload_in_usecs,
- ACE_UINT32 gsf,
- PortableServer::POA_ptr poa);
-
- /// Connect to the event channel
- void connect (RtecEventChannelAdmin::EventChannel_ptr ec
- ACE_ENV_ARG_DECL);
-
- /// Disconnect from the event channel
- void disconnect (ACE_ENV_SINGLE_ARG_DECL);
-
- /// Access the history of samples
- ACE_Sample_History &sample_history (void);
-
- //@{
- /** @name The RtecEventComm::PushConsumer methods
- */
- virtual void push (const RtecEventComm::EventSet& events
- ACE_ENV_ARG_DECL)
- ACE_THROW_SPEC ((CORBA::SystemException));
- virtual void disconnect_push_consumer (ACE_ENV_SINGLE_ARG_DECL_NOT_USED)
- ACE_THROW_SPEC ((CORBA::SystemException));
- virtual PortableServer::POA_ptr _default_POA (ACE_ENV_SINGLE_ARG_DECL_NOT_USED)
- ACE_THROW_SPEC ((CORBA::SystemException));
- //@}
-
-private:
- /// Synchronize access to the internal data
- TAO_SYNCH_MUTEX mutex_;
-
- /// The proxy this object is connected to
- RtecEventChannelAdmin::ProxyPushSupplier_var proxy_supplier_;
-
- /// The experiment id
- CORBA::Long experiment_id_;
-
- /// The event type
- CORBA::Long event_type_;
-
- /// The history of latency samples
- ACE_Sample_History sample_history_;
-
- /// The time spent processing each event, in microseconds
- CORBA::ULong workload_in_usecs_;
-
- /// The global scale factor for the high resolution timers
- ACE_UINT32 gsf_;
-
- /// The default poa
- PortableServer::POA_var default_POA_;
-};
-
-#endif /* TAO_PERF_RTEC_CONSUMER_H */