diff options
Diffstat (limited to 'ACE/performance-tests/Server_Concurrency/Latency_Stats.h')
| -rw-r--r-- | ACE/performance-tests/Server_Concurrency/Latency_Stats.h | 219 |
1 files changed, 219 insertions, 0 deletions
diff --git a/ACE/performance-tests/Server_Concurrency/Latency_Stats.h b/ACE/performance-tests/Server_Concurrency/Latency_Stats.h new file mode 100644 index 00000000000..2b0694b7ea7 --- /dev/null +++ b/ACE/performance-tests/Server_Concurrency/Latency_Stats.h @@ -0,0 +1,219 @@ +// $Id$ + +class Latency_Stats +{ +public: + Latency_Stats (void); + + void dump_results (const ACE_TCHAR* test_name, + const ACE_TCHAR* sub_test); + + void sample (ACE_hrtime_t sample); + + void accumulate (const Latency_Stats& stats); + // Useful to merge several Latency_Stats. + +private: + u_long n_; + ACE_hrtime_t sum_; + ACE_hrtime_t sum2_; + ACE_hrtime_t min_; + ACE_hrtime_t max_; +}; + +inline +Latency_Stats::Latency_Stats (void) + : n_ (0), + sum_ (0), + sum2_ (0), + min_ (0), + max_ (0) +{ +} + +inline void +Latency_Stats::sample (ACE_hrtime_t sample) +{ + this->sum_ += sample; +#ifndef ACE_LACKS_LONGLONG_T + this->sum2_ += sample * sample; +#else + // possible loss of precision here due to lack of 64bit support + this->sum2_ += sample * sample.lo(); +#endif + if (this->n_ == 0) + { + this->min_ = sample; + this->max_ = sample; + } + if (this->min_ > sample) + this->min_ = sample; + if (this->max_ < sample) + this->max_ = sample; + this->n_++; +} + +inline void +Latency_Stats::dump_results (const ACE_TCHAR *test_name, + const ACE_TCHAR *sub_test) +{ + if (this->n_ < 1) + return; + + ACE_hrtime_t avg = this->sum_ / this->n_; +#ifndef ACE_LACKS_LONGLONG_T + ACE_hrtime_t dev = + this->sum2_ / this->n_ - avg*avg; +#else + ACE_hrtime_t dev = + this->sum2_ / this->n_ - avg.lo()*avg.lo(); +#endif + ACE_UINT32 gsf = ACE_High_Res_Timer::global_scale_factor (); + + double min_usec = ACE_CU64_TO_CU32 (this->min_) / gsf; + double max_usec = ACE_CU64_TO_CU32 (this->max_) / gsf; + double avg_usec = ACE_CU64_TO_CU32 (avg) / gsf; + double dev_usec = ACE_CU64_TO_CU32 (dev) / (gsf * gsf); + ACE_DEBUG ((LM_DEBUG, + "%s/%s: %.2f/%.2f/%.2f/%.2f (min/avg/max/var^2) [usecs]\n", + test_name, sub_test, + min_usec, avg_usec, max_usec, dev_usec)); +} + +inline void +Latency_Stats::accumulate (const Latency_Stats& rhs) +{ + if (rhs.n_ == 0) + return; + + if (this->n_ == 0) + { + this->n_ = rhs.n_; + this->min_ = rhs.min_; + this->max_ = rhs.max_; + this->sum_ = rhs.sum_; + this->sum2_ = rhs.sum2_; + return; + } + + if (this->min_ > rhs.min_) + this->min_ = rhs.min_; + if (this->max_ < rhs.max_) + this->max_ = rhs.max_; + + this->sum_ += rhs.sum_; + this->sum2_ += rhs.sum2_; + this->n_ += rhs.n_; +} + +class Throughput_Stats +{ +public: + Throughput_Stats (void); + + void dump_results (const ACE_TCHAR* test_name, + const ACE_TCHAR* sub_test); + + void sample (void); + // An event has been received + + void accumulate (const Throughput_Stats& stats); + // Useful to merge several Throughput_Stats. + +private: + u_long n_; + ACE_hrtime_t start_; + ACE_hrtime_t stop_; +}; + +inline void +Throughput_Stats::accumulate (const Throughput_Stats& rhs) +{ + if (rhs.n_ == 0) + return; + + if (this->n_ == 0) + { + this->start_ = rhs.start_; + this->stop_ = rhs.stop_; + this->n_ = rhs.n_; + return; + } + + if (this->start_ > rhs.start_) + this->start_ = rhs.start_; + + if (this->stop_ < rhs.stop_) + this->stop_ = rhs.stop_; + + this->n_ += rhs.n_; +} + +inline void +Throughput_Stats::dump_results (const ACE_TCHAR *test_name, + const ACE_TCHAR *subtest) +{ + if (this->n_ == 0) + { + ACE_DEBUG ((LM_DEBUG, + "%s/%s: no events recorded\n", + test_name, subtest)); + return; + } + + ACE_Time_Value tv; + ACE_High_Res_Timer::hrtime_to_tv (tv, this->stop_ - this->start_); + + double f = 1.0/(tv.sec () + tv.usec () / 1000000.0); + double events_per_second = this->n_ * f; + + ACE_DEBUG ((LM_DEBUG, + "%s/%s: " + "%d / %d.%06.6d = %.3f events/second\n", + test_name, subtest, + this->n_, + tv.sec (), tv.usec (), + events_per_second)); +} + +inline +Throughput_Stats::Throughput_Stats (void) + : n_ (0), + start_ (), + stop_ () +{ +} + +inline void +Throughput_Stats::sample (void) +{ + if (this->n_ == 0) + { + this->start_ = ACE_OS::gethrtime (); + } + this->n_++; + this->stop_ = ACE_OS::gethrtime (); +} + +inline void +move_to_rt_class (void) +{ + // Enable FIFO scheduling, e.g., RT scheduling class on Solaris. + int priority = + (ACE_Sched_Params::priority_min (ACE_SCHED_FIFO) + + ACE_Sched_Params::priority_max (ACE_SCHED_FIFO)) / 2; + + int result = ACE_OS::sched_params (ACE_Sched_Params (ACE_SCHED_FIFO, + priority, + ACE_SCOPE_PROCESS)); + if (result == 0) + { + result = ACE_OS::thr_setprio (priority); + } + + if (result != 0) + { + ACE_DEBUG ((LM_DEBUG, + "Cannot move program to realtime class.\n")); + } +} |