TAO/examples/RTCORBA/Activity/Task_Stats.h

   1 /* -*- C++ -*- */
   2 //=============================================================================
   3 /**
   4  *  @file Task_Stats.h
   5  *
   6  *  Utility Stats class that maintains the readings.
   7  *
   8  *  @author Pradeep Gore <pradeep@cs.wustl.edu>
   9  */
  10 //=============================================================================
  11 #ifndef TASK_STATS_H
  12 #define TASK_STATS_H
  13
  14 #include "ace/OS_NS_time.h"
  15 #include "ace/Singleton.h"
  16 #include "tao/orbconf.h"
  17 #include "tao/debug.h"
  18 #include "ace/High_Res_Timer.h"
  19
  20 /**
  21  * @class Base_Time
  22  *
  23  * @brief maintains readings recorded by tasks.
  24  */
  25 class Base_Time
  26 {
  27  public:
  28   Base_Time (void);
  29   ACE_hrtime_t base_time_;
  30 };
  31
  32 typedef ACE_Singleton<Base_Time, TAO_SYNCH_MUTEX> BASE_TIME;
  33
  34 /**
  35  * @class Task_Stats
  36  *
  37  * @brief maintains readings recorded by tasks.
  38  */
  39 class Task_Stats
  40 {
  41  public:
  42   /// Constructor
  43   Task_Stats (size_t max_samples);
  44
  45   /// Destructor
  46   ~Task_Stats (void);
  47
  48   /// Init
  49   int init (void);
  50
  51   /// Set the base time value.
  52   void base_time (ACE_hrtime_t time);
  53
  54   /// Set the end time value.
  55   void end_time (ACE_hrtime_t time);
  56
  57   /// Record a sample
  58   int sample (ACE_UINT64 inv_start_time, ACE_UINT64 inv_end_time);
  59
  60   void dump_samples (const ACE_TCHAR *file_name, const ACE_TCHAR *msg,
  61                      ACE_High_Res_Timer::global_scale_factor_type scale_factor);
  62  protected:
  63   void dump_latency_stats (ACE_TCHAR *out_msg,
  64                            ACE_High_Res_Timer::global_scale_factor_type sf);
  65
  66   /// Base and end times
  67   ACE_hrtime_t base_time_;
  68   ACE_hrtime_t end_time_;
  69
  70   /// The maximum number of samples
  71   ACE_UINT32 max_samples_;
  72
  73   /// The number of samples
  74   ACE_UINT32 samples_count_;
  75
  76   /// The samples : the time of invocation. and the recorded exec. time .
  77   ACE_UINT64 *time_inv_;
  78   ACE_UINT64 *time_exec_;
  79
  80   /// The minimum value
  81   ACE_UINT64 exec_time_min_;
  82
  83   /// The number of the sample that had the minimum value
  84   ACE_UINT32 exec_time_min_at_;
  85
  86   /// The maximum value
  87   ACE_UINT64 exec_time_max_;
  88
  89   /// The number of the sample that had the maximum value
  90   ACE_UINT32 exec_time_max_at_;
  91
  92   /// The sum of all the values
  93   ACE_UINT64 sum_;
  94
  95   /// The sum of the square of all the values
  96   ACE_UINT64 sum2_;
  97 };
  98
  99 #if defined (__ACE_INLINE__)
 100 #include "Task_Stats.inl"
 101 #endif /* __ACE_INLINE__ */
 102
 103 #endif /* TASK_STATS_H */