diff options
Diffstat (limited to 'ace/Metrics_Cache_T.i')
| -rw-r--r-- | ace/Metrics_Cache_T.i | 274 |
1 files changed, 274 insertions, 0 deletions
diff --git a/ace/Metrics_Cache_T.i b/ace/Metrics_Cache_T.i new file mode 100644 index 00000000000..f1952d93419 --- /dev/null +++ b/ace/Metrics_Cache_T.i @@ -0,0 +1,274 @@ +// $Id$ + +#ifndef METRICS_CACHE_T_I +#define METRICS_CACHE_T_I + +///////////////////////////// +// Class ACE_Metrics_Cache // +///////////////////////////// + + +template <class ACE_LOCK, class ALLOCATOR> +ACE_INLINE void +ACE_Metrics_Cache<ACE_LOCK, ALLOCATOR>::report_enqueue_start (u_int i) +{ + if (i < this->probe_set_size_) + { + u_long & count = +// Modified by BRM. This should work for ACE_Based_Pointers as well. +// this->enqueue_count_ [this->supplier_index_].addr() [i]; + this->enqueue_count_ [this->supplier_index_] [i]; + ++count; + + if (! this->interval_initialized_) + { + this->interval_initialized_ = 1; + ACE_hrtime_t hrtime_now = ACE_OS::gethrtime (); + ACE_High_Res_Timer::hrtime_to_tv (this->interval_start_, + hrtime_now); + this->interval_end_.set (this->interval_start_.sec(), + this->interval_start_.usec()); + } + + // Take the metrics timeprobe last, to avoid measuring the above + // metrics processing. + ACE_Metrics_Timeprobe<ACE_LOCK, ALLOCATOR> * probe = +// Modified by BRM. This should work for ACE_Based_Pointers as well. +// this->enqueue_probes_ [this->supplier_index_].addr () [i].addr (); + this->enqueue_probes_ [this->supplier_index_][i]; + probe-> + timeprobe (ACE_Metrics_Timeprobe<ACE_LOCK, ALLOCATOR>::WORK_START); + } +} + + +template <class ACE_LOCK, class ALLOCATOR> +ACE_INLINE void +ACE_Metrics_Cache<ACE_LOCK, ALLOCATOR>::report_enqueue_stop (u_int i) +{ + if (i < this->probe_set_size_) + { + // Take the metrics timeprobe first, to avoid measuring the below + // metrics processing. + ACE_Metrics_Timeprobe<ACE_LOCK, ALLOCATOR> * probe = +// Modified by BRM. This should work for ACE_Based_Pointers as well. +// this->enqueue_probes_ [this->supplier_index_].addr () [i].addr (); + this->enqueue_probes_ [this->supplier_index_][i]; + probe-> + timeprobe (ACE_Metrics_Timeprobe<ACE_LOCK, ALLOCATOR>::WORK_STOP); + + ACE_hrtime_t hrtime_now = ACE_OS::gethrtime (); + ACE_High_Res_Timer::hrtime_to_tv (this->interval_end_, + hrtime_now); + +// Modified by BRM. This should work for ACE_Based_Pointers as well. +// u_long & count = enqueue_count_ [this->supplier_index_].addr() [i]; + u_long & count = enqueue_count_ [this->supplier_index_][i]; + ++count; + } + +} + + +template <class ACE_LOCK, class ALLOCATOR> +ACE_INLINE void +ACE_Metrics_Cache<ACE_LOCK, ALLOCATOR>::report_enqueue_suspend (u_int i) +{ + if (i < this->probe_set_size_) + { + ACE_Metrics_Timeprobe<ACE_LOCK, ALLOCATOR> * probe = +// Modified by BRM. This should work for ACE_Based_Pointers as well. +// this->enqueue_probes_ [this->supplier_index_].addr () [i].addr (); + this->enqueue_probes_ [this->supplier_index_][i]; + probe-> + timeprobe (ACE_Metrics_Timeprobe<ACE_LOCK, ALLOCATOR>::WORK_SUSPEND); + u_long & count = +// Modified by BRM. This should work for ACE_Based_Pointers as well. +// this->enqueue_count_ [this->supplier_index_].addr() [i]; + this->enqueue_count_ [this->supplier_index_] [i]; + ++count; + } +} + + +template <class ACE_LOCK, class ALLOCATOR> +ACE_INLINE void +ACE_Metrics_Cache<ACE_LOCK, ALLOCATOR>::report_enqueue_resume (u_int i) +{ + if (i < this->probe_set_size_) + { + u_long & count = +// Modified by BRM. This should work for ACE_Based_Pointers as well. +// this->enqueue_count_ [this->supplier_index_].addr() [i]; + this->enqueue_count_ [this->supplier_index_] [i]; + ++count; + ACE_Metrics_Timeprobe<ACE_LOCK, ALLOCATOR> * probe = +// Modified by BRM. This should work for ACE_Based_Pointers as well. +// this->enqueue_probes_ [this->supplier_index_].addr () [i].addr (); + this->enqueue_probes_ [this->supplier_index_][i]; + probe-> + timeprobe (ACE_Metrics_Timeprobe<ACE_LOCK, ALLOCATOR>::WORK_RESUME); + } +} + + +template <class ACE_LOCK, class ALLOCATOR> +ACE_INLINE void +ACE_Metrics_Cache<ACE_LOCK, ALLOCATOR>::report_dequeue_start (u_int i) +{ + if (i < this->probe_set_size_) + { + u_long & count = +// Modified by BRM. This should work for ACE_Based_Pointers as well. +// this->dequeue_count_ [this->supplier_index_].addr() [i]; + this->dequeue_count_ [this->supplier_index_] [i]; + ++count; + + if (! this->interval_initialized_) + { + this->interval_initialized_ = 1; + ACE_hrtime_t hrtime_now = ACE_OS::gethrtime (); + ACE_High_Res_Timer::hrtime_to_tv (this->interval_start_, + hrtime_now); + this->interval_end_.set (this->interval_start_.sec(), + this->interval_start_.usec()); + } + + // Take the metrics timeprobe last, to avoid measuring the above + // metrics processing. + ACE_Metrics_Timeprobe<ACE_LOCK, ALLOCATOR> * probe = +// Modified by BRM. This should work for ACE_Based_Pointers as well. +// this->dequeue_probes_ [this->supplier_index_].addr () [i].addr (); + this->dequeue_probes_ [this->supplier_index_][i]; + probe-> + timeprobe (ACE_Metrics_Timeprobe<ACE_LOCK, ALLOCATOR>::WORK_START); + } +} + + +template <class ACE_LOCK, class ALLOCATOR> +ACE_INLINE void +ACE_Metrics_Cache<ACE_LOCK, ALLOCATOR>::report_dequeue_stop (u_int i) +{ + if (i < this->probe_set_size_) + { + // Take the metrics timeprobe first, to avoid measuring the + // metrics processing below. + ACE_Metrics_Timeprobe<ACE_LOCK, ALLOCATOR> * probe = +// Modified by BRM. This should work for ACE_Based_Pointers as well. +// this->dequeue_probes_ [this->supplier_index_].addr () [i].addr (); + this->dequeue_probes_ [this->supplier_index_][i]; + + probe->timeprobe (ACE_Metrics_Timeprobe<ACE_LOCK, ALLOCATOR>::WORK_STOP); + + ACE_hrtime_t hrtime_now = ACE_OS::gethrtime (); + ACE_High_Res_Timer::hrtime_to_tv (this->interval_end_, + hrtime_now); + +// Modified by BRM. This should work for ACE_Based_Pointers as well. +// u_long & count = dequeue_count_ [this->supplier_index_].addr() [i]; + u_long & count = dequeue_count_ [this->supplier_index_] [i]; + ++count; + } +} + + +template <class ACE_LOCK, class ALLOCATOR> +ACE_INLINE void +ACE_Metrics_Cache<ACE_LOCK, ALLOCATOR>::report_dequeue_suspend (u_int i) +{ + if (i < this->probe_set_size_) + { + u_long & count = +// Modified by BRM. This should work for ACE_Based_Pointers as well. +// this->dequeue_count_ [this->supplier_index_].addr() [i]; + this->dequeue_count_ [this->supplier_index_] [i]; + ++count; + ACE_Metrics_Timeprobe<ACE_LOCK, ALLOCATOR> * probe = +// Modified by BRM. This should work for ACE_Based_Pointers as well. +// this->dequeue_probes_ [this->supplier_index_].addr () [i].addr (); + this->dequeue_probes_ [this->supplier_index_][i]; + probe-> + timeprobe (ACE_Metrics_Timeprobe<ACE_LOCK, ALLOCATOR>::WORK_SUSPEND); + } +} + + +template <class ACE_LOCK, class ALLOCATOR> +ACE_INLINE void +ACE_Metrics_Cache<ACE_LOCK, ALLOCATOR>::report_dequeue_resume (u_int i) +{ + if (i < this->probe_set_size_) + { + u_long & count = +// Modified by BRM. This should work for ACE_Based_Pointers as well. +// this->dequeue_count_ [this->supplier_index_].addr() [i]; + this->dequeue_count_ [this->supplier_index_] [i]; + ++count; + ACE_Metrics_Timeprobe<ACE_LOCK, ALLOCATOR> * probe = +// Modified by BRM. This should work for ACE_Based_Pointers as well. +// this->dequeue_probes_ [this->supplier_index_].addr () [i].addr (); + this->dequeue_probes_ [this->supplier_index_][i]; + probe-> + timeprobe (ACE_Metrics_Timeprobe<ACE_LOCK, ALLOCATOR>::WORK_RESUME); + } +} + + +template <class ACE_LOCK, class ALLOCATOR> +ACE_INLINE void +ACE_Metrics_Cache<ACE_LOCK, ALLOCATOR>::reset_base_statistics () +{ + this->interval_initialized_ = 0; + this->interval_start_.set (0, 0); + this->interval_end_.set (0, 0); + + for (u_int i = 0; i < this->probe_set_size_; ++i) + { +// Modified by BRM. This should work for ACE_Based_Pointers as well. +// this->enqueue_count_ [this->consumer_index_].addr() [i] = 0; + this->enqueue_count_ [this->consumer_index_] [i] = 0; +// Modified by BRM. This should work for ACE_Based_Pointers as well. +// this->dequeue_count_ [this->consumer_index_].addr() [i] = 0; + this->dequeue_count_ [this->consumer_index_] [i] = 0; + + ACE_Metrics_Timeprobe<ACE_LOCK, ALLOCATOR> * probe = +// Modified by BRM. This should work for ACE_Based_Pointers as well. +// this->enqueue_probes_ [this->consumer_index_].addr () [i].addr (); + this->enqueue_probes_ [this->consumer_index_][i]; + probe->reset (); + probe = +// Modified by BRM. This should work for ACE_Based_Pointers as well. +// this->dequeue_probes_ [this->consumer_index_].addr () [i].addr (); + this->dequeue_probes_ [this->consumer_index_][i]; + probe->reset (); + } +} + + +// Flips the supplier and consumer positions. + +template <class ACE_LOCK, class ALLOCATOR> +ACE_INLINE void +ACE_Metrics_Cache<ACE_LOCK, ALLOCATOR>::flip_supplier_and_consumer () +{ + int temp = consumer_index_; + consumer_index_ = supplier_index_; + supplier_index_ = temp; +} + +template <class ACE_LOCK, class ALLOCATOR> +ACE_INLINE void +ACE_Metrics_Cache<ACE_LOCK, ALLOCATOR>::metrics_enabled(int enabled) +{ + metrics_enabled_ = enabled; +} + +template <class ACE_LOCK, class ALLOCATOR> +ACE_INLINE int +ACE_Metrics_Cache<ACE_LOCK, ALLOCATOR>::metrics_enabled(void) const +{ + return metrics_enabled_; +} + +#endif /* METRICS_CACHE_T_I */ |