diff options
Diffstat (limited to 'TAO/orbsvcs/tests/EC_Throughput/ECT_Consumer.h')
| -rw-r--r-- | TAO/orbsvcs/tests/EC_Throughput/ECT_Consumer.h | 29 |
1 files changed, 8 insertions, 21 deletions
diff --git a/TAO/orbsvcs/tests/EC_Throughput/ECT_Consumer.h b/TAO/orbsvcs/tests/EC_Throughput/ECT_Consumer.h index e66f3185cbc..c59cee0a4dd 100644 --- a/TAO/orbsvcs/tests/EC_Throughput/ECT_Consumer.h +++ b/TAO/orbsvcs/tests/EC_Throughput/ECT_Consumer.h @@ -13,26 +13,24 @@ #ifndef ECT_CONSUMER_H #define ECT_CONSUMER_H -#include "ECT_Driver.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 "ace/Task.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, @@ -40,8 +38,8 @@ public: void connect (RtecScheduler::Scheduler_ptr scheduler, const char* name, - int type_start, - int type_count, + int event_a, + int event_b, RtecEventChannelAdmin::EventChannel_ptr ec, CORBA::Environment& _env); // This method connects the consumer to the EC. @@ -52,12 +50,6 @@ public: void dump_results (const char* name); // Print out the results - void accumulate (ECT_Driver::Throughput_Stats& stats) const; - // Add our throughput statistics to <stats> - - void accumulate (ECT_Driver::Latency_Stats& stats) const; - // Add our latency statistics to <stats> - virtual void push (const RtecEventComm::EventSet& events, CORBA::Environment &_env); virtual void disconnect_push_consumer (CORBA::Environment &); @@ -80,14 +72,9 @@ private: ACE_SYNCH_MUTEX lock_; int recv_count_; + ACE_High_Res_Timer timer_; // How many events we have received. - ECT_Driver::Throughput_Stats throughput_; - // Used for reporting stats. - - ECT_Driver::Latency_Stats latency_; - // Used for reporting stats. - int shutdown_count_; // How many shutdown events we have received. }; |