dep/ACE_wrappers/ace/Metrics_Cache_T.inl

   1 // -*- C++ -*-
   2 //
   3 // $Id: Metrics_Cache_T.inl 80826 2008-03-04 14:51:23Z wotte $
   4
   5 #ifndef ACE_METRICS_CACHE_T_INL
   6 #define ACE_METRICS_CACHE_T_INL
   7
   8 ACE_BEGIN_VERSIONED_NAMESPACE_DECL
   9
  10 /////////////////////////////
  11 // Class ACE_Metrics_Cache //
  12 /////////////////////////////
  13
  14
  15 template <class ACE_LOCK, class ALLOCATOR>
  16 ACE_INLINE void
  17 ACE_Metrics_Cache<ACE_LOCK, ALLOCATOR>::report_enqueue_start (u_long i)
  18 {
  19   if (i < this->probe_set_size_)
  20     {
  21       u_long & count =
  22         this->enqueue_count_ [this->supplier_index_] [i];
  23       ++count;
  24
  25       if (! this->interval_initialized_)
  26         {
  27           this->interval_initialized_ = 1;
  28           ACE_hrtime_t hrtime_now = ACE_OS::gethrtime ();
  29           ACE_High_Res_Timer::hrtime_to_tv (this->interval_start_,
  30                                                     hrtime_now);
  31           this->interval_end_.set (this->interval_start_.sec(),
  32                                    this->interval_start_.usec());
  33         }
  34
  35       // Take the metrics timeprobe last, to avoid measuring the above
  36       // metrics processing.
  37       ACE_Metrics_Timeprobe<ACE_LOCK, ALLOCATOR> * probe =
  38         this->enqueue_probes_ [this->supplier_index_][i];
  39       probe->
  40         timeprobe (ACE_Metrics_Timeprobe<ACE_LOCK, ALLOCATOR>::WORK_START);
  41     }
  42 }
  43
  44
  45 template <class ACE_LOCK, class ALLOCATOR>
  46 ACE_INLINE void
  47 ACE_Metrics_Cache<ACE_LOCK, ALLOCATOR>::report_enqueue_stop (u_long i)
  48 {
  49   if (i < this->probe_set_size_)
  50     {
  51       // Take the metrics timeprobe first, to avoid measuring the below
  52       // metrics processing.
  53       ACE_Metrics_Timeprobe<ACE_LOCK, ALLOCATOR> * probe =
  54         this->enqueue_probes_ [this->supplier_index_][i];
  55       probe->
  56         timeprobe (ACE_Metrics_Timeprobe<ACE_LOCK, ALLOCATOR>::WORK_STOP);
  57
  58       ACE_hrtime_t hrtime_now = ACE_OS::gethrtime ();
  59       ACE_High_Res_Timer::hrtime_to_tv (this->interval_end_,
  60                                             hrtime_now);
  61
  62       u_long & count = enqueue_count_ [this->supplier_index_][i];
  63       ++count;
  64     }
  65
  66 }
  67
  68
  69 template <class ACE_LOCK, class ALLOCATOR>
  70 ACE_INLINE void
  71 ACE_Metrics_Cache<ACE_LOCK, ALLOCATOR>::report_enqueue_suspend (u_long i)
  72 {
  73   if (i < this->probe_set_size_)
  74     {
  75       ACE_Metrics_Timeprobe<ACE_LOCK, ALLOCATOR> * probe =
  76         this->enqueue_probes_ [this->supplier_index_][i];
  77       probe->
  78         timeprobe (ACE_Metrics_Timeprobe<ACE_LOCK, ALLOCATOR>::WORK_SUSPEND);
  79       u_long & count =
  80         this->enqueue_count_ [this->supplier_index_] [i];
  81       ++count;
  82     }
  83 }
  84
  85
  86 template <class ACE_LOCK, class ALLOCATOR>
  87 ACE_INLINE void
  88 ACE_Metrics_Cache<ACE_LOCK, ALLOCATOR>::report_enqueue_resume (u_long i)
  89 {
  90   if (i < this->probe_set_size_)
  91     {
  92       u_long & count =
  93         this->enqueue_count_ [this->supplier_index_] [i];
  94       ++count;
  95       ACE_Metrics_Timeprobe<ACE_LOCK, ALLOCATOR> * probe =
  96         this->enqueue_probes_ [this->supplier_index_][i];
  97       probe->
  98         timeprobe (ACE_Metrics_Timeprobe<ACE_LOCK, ALLOCATOR>::WORK_RESUME);
  99     }
 100 }
 101
 102
 103 template <class ACE_LOCK, class ALLOCATOR>
 104 ACE_INLINE void
 105 ACE_Metrics_Cache<ACE_LOCK, ALLOCATOR>::report_dequeue_start (u_long i)
 106 {
 107   if (i < this->probe_set_size_)
 108     {
 109       u_long & count =
 110         this->dequeue_count_ [this->supplier_index_] [i];
 111       ++count;
 112
 113       if (! this->interval_initialized_)
 114         {
 115           this->interval_initialized_ = 1;
 116           ACE_hrtime_t hrtime_now = ACE_OS::gethrtime ();
 117           ACE_High_Res_Timer::hrtime_to_tv (this->interval_start_,
 118                                                     hrtime_now);
 119           this->interval_end_.set (this->interval_start_.sec(),
 120                                    this->interval_start_.usec());
 121         }
 122
 123       // Take the metrics timeprobe last, to avoid measuring the above
 124       // metrics processing.
 125       ACE_Metrics_Timeprobe<ACE_LOCK, ALLOCATOR> * probe =
 126         this->dequeue_probes_ [this->supplier_index_][i];
 127       probe->
 128         timeprobe (ACE_Metrics_Timeprobe<ACE_LOCK, ALLOCATOR>::WORK_START);
 129     }
 130 }
 131
 132
 133 template <class ACE_LOCK, class ALLOCATOR>
 134 ACE_INLINE void
 135 ACE_Metrics_Cache<ACE_LOCK, ALLOCATOR>::report_dequeue_stop (u_long i)
 136 {
 137   if (i < this->probe_set_size_)
 138     {
 139       // Take the metrics timeprobe first, to avoid measuring the
 140       // metrics processing below.
 141       ACE_Metrics_Timeprobe<ACE_LOCK, ALLOCATOR> * probe =
 142         this->dequeue_probes_ [this->supplier_index_][i];
 143
 144       probe->timeprobe (ACE_Metrics_Timeprobe<ACE_LOCK, ALLOCATOR>::WORK_STOP);
 145
 146       ACE_hrtime_t hrtime_now = ACE_OS::gethrtime ();
 147       ACE_High_Res_Timer::hrtime_to_tv (this->interval_end_,
 148                                                     hrtime_now);
 149
 150       u_long & count = dequeue_count_ [this->supplier_index_] [i];
 151       ++count;
 152     }
 153 }
 154
 155
 156 template <class ACE_LOCK, class ALLOCATOR>
 157 ACE_INLINE void
 158 ACE_Metrics_Cache<ACE_LOCK, ALLOCATOR>::report_dequeue_suspend (u_long i)
 159 {
 160   if (i < this->probe_set_size_)
 161     {
 162       u_long & count =
 163         this->dequeue_count_ [this->supplier_index_] [i];
 164       ++count;
 165       ACE_Metrics_Timeprobe<ACE_LOCK, ALLOCATOR> * probe =
 166         this->dequeue_probes_ [this->supplier_index_][i];
 167       probe->
 168         timeprobe (ACE_Metrics_Timeprobe<ACE_LOCK, ALLOCATOR>::WORK_SUSPEND);
 169     }
 170 }
 171
 172
 173 template <class ACE_LOCK, class ALLOCATOR>
 174 ACE_INLINE void
 175 ACE_Metrics_Cache<ACE_LOCK, ALLOCATOR>::report_dequeue_resume (u_long i)
 176 {
 177   if (i < this->probe_set_size_)
 178     {
 179       u_long & count =
 180         this->dequeue_count_ [this->supplier_index_] [i];
 181       ++count;
 182       ACE_Metrics_Timeprobe<ACE_LOCK, ALLOCATOR> * probe =
 183         this->dequeue_probes_ [this->supplier_index_][i];
 184       probe->
 185         timeprobe (ACE_Metrics_Timeprobe<ACE_LOCK, ALLOCATOR>::WORK_RESUME);
 186     }
 187 }
 188
 189
 190 template <class ACE_LOCK, class ALLOCATOR>
 191 ACE_INLINE void
 192 ACE_Metrics_Cache<ACE_LOCK, ALLOCATOR>::reset_base_statistics ()
 193 {
 194   this->interval_initialized_ = 0;
 195   this->interval_start_.set (0, 0);
 196   this->interval_end_.set (0, 0);
 197
 198   for (u_int i = 0; i < this->probe_set_size_; ++i)
 199     {
 200       this->enqueue_count_ [this->consumer_index_] [i] = 0;
 201       this->dequeue_count_ [this->consumer_index_] [i] = 0;
 202
 203       ACE_Metrics_Timeprobe<ACE_LOCK, ALLOCATOR> * probe =
 204         this->enqueue_probes_ [this->consumer_index_][i];
 205       probe->reset ();
 206       probe =
 207         this->dequeue_probes_ [this->consumer_index_][i];
 208       probe->reset ();
 209     }
 210 }
 211
 212
 213 // Flips the supplier and consumer positions.
 214
 215 template <class ACE_LOCK, class ALLOCATOR>
 216 ACE_INLINE void
 217 ACE_Metrics_Cache<ACE_LOCK, ALLOCATOR>::flip_supplier_and_consumer ()
 218 {
 219   int temp = consumer_index_;
 220   consumer_index_ = supplier_index_;
 221   supplier_index_ = temp;
 222 }
 223
 224 template <class ACE_LOCK, class ALLOCATOR>
 225 ACE_INLINE void
 226 ACE_Metrics_Cache<ACE_LOCK, ALLOCATOR>::metrics_enabled(int enabled)
 227 {
 228    metrics_enabled_ = enabled;
 229 }
 230
 231 template <class ACE_LOCK, class ALLOCATOR>
 232 ACE_INLINE int
 233 ACE_Metrics_Cache<ACE_LOCK, ALLOCATOR>::metrics_enabled(void) const
 234 {
 235    return metrics_enabled_;
 236 }
 237
 238 ACE_END_VERSIONED_NAMESPACE_DECL
 239
 240 #endif /* ACE_METRICS_CACHE_T_INL */