ACE/ace/Basic_Stats.cpp

   1 #include "ace/Basic_Stats.h"
   2 #include "ace/Log_Category.h"
   3
   4 #if !defined (__ACE_INLINE__)
   5 #include "ace/Basic_Stats.inl"
   6 #endif /* __ACE_INLINE__ */
   7
   8 ACE_BEGIN_VERSIONED_NAMESPACE_DECL
   9
  10 void
  11 ACE_Basic_Stats::accumulate (const ACE_Basic_Stats &rhs)
  12 {
  13   if (rhs.samples_count_ == 0)
  14     return;
  15
  16   if (this->samples_count_ == 0)
  17     {
  18       this->min_ = rhs.min_;
  19       this->min_at_ = rhs.min_at_;
  20
  21       this->max_ = rhs.max_;
  22       this->max_at_ = rhs.max_at_;
  23     }
  24   else
  25     {
  26       if (this->min_ > rhs.min_)
  27         {
  28           this->min_ = rhs.min_;
  29           this->min_at_ = rhs.min_at_;
  30         }
  31       if (this->max_ < rhs.max_)
  32         {
  33           this->max_ = rhs.max_;
  34           this->max_at_ = rhs.max_at_;
  35         }
  36     }
  37
  38   this->samples_count_ += rhs.samples_count_;
  39   this->sum_ += rhs.sum_;
  40 }
  41
  42 void
  43 ACE_Basic_Stats::dump_results (
  44   const ACE_TCHAR *msg,
  45   ACE_Basic_Stats::scale_factor_type sf) const
  46 {
  47 #ifndef ACE_NLOGGING
  48   if (this->samples_count () == 0u)
  49     {
  50       ACELIB_DEBUG ((LM_DEBUG,
  51                   ACE_TEXT ("%s : no data collected\n"), msg));
  52       return;
  53     }
  54
  55   ACE_UINT64 avg = this->sum_ / this->samples_count_;
  56
  57   ACE_UINT64 l_min = this->min_ / sf;
  58   ACE_UINT64 l_max = this->max_ / sf;
  59   ACE_UINT64 l_avg = avg / sf;
  60
  61   ACELIB_DEBUG ((LM_DEBUG,
  62               ACE_TEXT ("%s latency   : %Q[%d]/%Q/%Q[%d] (min/avg/max)\n"),
  63               msg,
  64               l_min, this->min_at_,
  65               l_avg,
  66               l_max, this->max_at_));
  67
  68 #else
  69   ACE_UNUSED_ARG (msg);
  70   ACE_UNUSED_ARG (sf);
  71 #endif /* ACE_NLOGGING */
  72 }
  73
  74 ACE_END_VERSIONED_NAMESPACE_DECL