/** * @file lltracerecording.h * @brief Sampling object for collecting runtime statistics originating from lltrace. * * $LicenseInfo:firstyear=2001&license=viewerlgpl$ * Second Life Viewer Source Code * Copyright (C) 2012, Linden Research, Inc. * * This library is free software; you can redistribute it and/or * modify it under the terms of the GNU Lesser General Public * License as published by the Free Software Foundation; * version 2.1 of the License only. * * This library is distributed in the hope that it will be useful, * but WITHOUT ANY WARRANTY; without even the implied warranty of * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU * Lesser General Public License for more details. * * You should have received a copy of the GNU Lesser General Public * License along with this library; if not, write to the Free Software * Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301 USA * * Linden Research, Inc., 945 Battery Street, San Francisco, CA 94111 USA * $/LicenseInfo$ */ #ifndef LL_LLTRACERECORDING_H #define LL_LLTRACERECORDING_H #include "stdtypes.h" #include "llpreprocessor.h" #include "lltimer.h" #include "lltraceaccumulators.h" #include "llpointer.h" #include #ifdef LL_WINDOWS #pragma warning(push) #pragma warning(disable : 4244) // possible loss of data on conversions #endif class LLStopWatchControlsMixinCommon { public: virtual ~LLStopWatchControlsMixinCommon() {} enum EPlayState { STOPPED, PAUSED, STARTED }; void start(); // moves to started state, resetting if stopped void stop(); // moves to stopped state void pause(); // moves to paused state, unless stopped void unpause(); // moves to started state if paused void resume(); // moves to started state, without resetting void restart(); // moves to started state, always resetting void reset(); // resets bool isStarted() const { return mPlayState == STARTED; } bool isPaused() const { return mPlayState == PAUSED; } bool isStopped() const { return mPlayState == STOPPED; } EPlayState getPlayState() const { return mPlayState; } // force play state to specific value by calling appropriate handle* methods void setPlayState(EPlayState state); protected: LLStopWatchControlsMixinCommon() : mPlayState(STOPPED) {} private: // override these methods to provide started/stopped semantics // activate behavior (without reset) virtual void handleStart() = 0; // deactivate behavior virtual void handleStop() = 0; // clear accumulated state, may be called while started virtual void handleReset() = 0; EPlayState mPlayState; }; template class LLStopWatchControlsMixin : public LLStopWatchControlsMixinCommon { public: typedef LLStopWatchControlsMixin self_t; virtual void splitTo(DERIVED& other) { EPlayState play_state = getPlayState(); stop(); other.reset(); handleSplitTo(other); other.setPlayState(play_state); } virtual void splitFrom(DERIVED& other) { static_cast(other).handleSplitTo(*static_cast(this)); } private: self_t& operator = (const self_t& other) { // don't do anything, derived class must implement logic } // atomically stop this object while starting the other // no data can be missed in between stop and start virtual void handleSplitTo(DERIVED& other) {}; }; namespace LLTrace { template class StatType; template class CountStatHandle; template class SampleStatHandle; template class EventStatHandle; template struct RelatedTypes { typedef F64 fractional_t; typedef T sum_t; }; template struct RelatedTypes > { typedef LLUnit::fractional_t, UNIT_T> fractional_t; typedef LLUnit::sum_t, UNIT_T> sum_t; }; template<> struct RelatedTypes { typedef F64 fractional_t; typedef S32 sum_t; }; class Recording : public LLStopWatchControlsMixin { public: Recording(EPlayState state = LLStopWatchControlsMixinCommon::STOPPED); Recording(const Recording& other); ~Recording(); Recording& operator = (const Recording& other); // accumulate data from subsequent, non-overlapping recording void appendRecording(Recording& other); // grab latest recorded data void update(); // ensure that buffers are exclusively owned by this recording void makeUnique() { mBuffers.makeUnique(); } // Timer accessors bool hasValue(const StatType& stat); F64Seconds getSum(const StatType& stat); F64Seconds getSum(const StatType& stat); S32 getSum(const StatType& stat); F64Seconds getPerSec(const StatType& stat); F64Seconds getPerSec(const StatType& stat); F32 getPerSec(const StatType& stat); // CountStatHandle accessors bool hasValue(const StatType& stat); F64 getSum(const StatType& stat); template typename RelatedTypes::sum_t getSum(const CountStatHandle& stat) { return (typename RelatedTypes::sum_t)getSum(static_cast&> (stat)); } F64 getPerSec(const StatType& stat); template typename RelatedTypes::fractional_t getPerSec(const CountStatHandle& stat) { return (typename RelatedTypes::fractional_t)getPerSec(static_cast&> (stat)); } S32 getSampleCount(const StatType& stat); // SampleStatHandle accessors bool hasValue(const StatType& stat); F64 getMin(const StatType& stat); template T getMin(const SampleStatHandle& stat) { return (T)getMin(static_cast&> (stat)); } F64 getMax(const StatType& stat); template T getMax(const SampleStatHandle& stat) { return (T)getMax(static_cast&> (stat)); } F64 getMean(const StatType& stat); template typename RelatedTypes::fractional_t getMean(SampleStatHandle& stat) { return (typename RelatedTypes::fractional_t)getMean(static_cast&> (stat)); } F64 getStandardDeviation(const StatType& stat); template typename RelatedTypes::fractional_t getStandardDeviation(const SampleStatHandle& stat) { return (typename RelatedTypes::fractional_t)getStandardDeviation(static_cast&> (stat)); } F64 getLastValue(const StatType& stat); template T getLastValue(const SampleStatHandle& stat) { return (T)getLastValue(static_cast&> (stat)); } S32 getSampleCount(const StatType& stat); // EventStatHandle accessors bool hasValue(const StatType& stat); F64 getSum(const StatType& stat); template typename RelatedTypes::sum_t getSum(const EventStatHandle& stat) { return (typename RelatedTypes::sum_t)getSum(static_cast&> (stat)); } F64 getMin(const StatType& stat); template T getMin(const EventStatHandle& stat) { return (T)getMin(static_cast&> (stat)); } F64 getMax(const StatType& stat); template T getMax(const EventStatHandle& stat) { return (T)getMax(static_cast&> (stat)); } F64 getMean(const StatType& stat); template typename RelatedTypes::fractional_t getMean(EventStatHandle& stat) { return (typename RelatedTypes::fractional_t)getMean(static_cast&> (stat)); } F64 getStandardDeviation(const StatType& stat); template typename RelatedTypes::fractional_t getStandardDeviation(const EventStatHandle& stat) { return (typename RelatedTypes::fractional_t)getStandardDeviation(static_cast&> (stat)); } F64 getLastValue(const StatType& stat); template T getLastValue(const EventStatHandle& stat) { return (T)getLastValue(static_cast&> (stat)); } S32 getSampleCount(const StatType& stat); F64Seconds getDuration() const { return mElapsedSeconds; } protected: friend class ThreadRecorder; // implementation for LLStopWatchControlsMixin /*virtual*/ void handleStart(); /*virtual*/ void handleStop(); /*virtual*/ void handleReset(); /*virtual*/ void handleSplitTo(Recording& other); // returns data for current thread class ThreadRecorder* getThreadRecorder(); LLTimer mSamplingTimer; F64Seconds mElapsedSeconds; LLCopyOnWritePointer mBuffers; AccumulatorBufferGroup* mActiveBuffers; }; class LL_COMMON_API PeriodicRecording : public LLStopWatchControlsMixin { public: PeriodicRecording(size_t num_periods, EPlayState state = STOPPED); ~PeriodicRecording(); void nextPeriod(); auto getNumRecordedPeriods() { // current period counts if not active return mNumRecordedPeriods + (isStarted() ? 0 : 1); } F64Seconds getDuration() const; void appendPeriodicRecording(PeriodicRecording& other); void appendRecording(Recording& recording); Recording& getLastRecording(); const Recording& getLastRecording() const; Recording& getCurRecording(); const Recording& getCurRecording() const; Recording& getPrevRecording(size_t offset); const Recording& getPrevRecording(size_t offset) const; Recording snapshotCurRecording() const; template auto getSampleCount(const StatType& stat, size_t num_periods = std::numeric_limits::max()) { LL_PROFILE_ZONE_SCOPED_CATEGORY_STATS; num_periods = llmin(num_periods, getNumRecordedPeriods()); size_t num_samples = 0; for (size_t i = 1; i <= num_periods; i++) { Recording& recording = getPrevRecording(i); num_samples += recording.getSampleCount(stat); } return num_samples; } // // PERIODIC MIN // // catch all for stats that have a defined sum template typename T::value_t getPeriodMin(const StatType& stat, size_t num_periods = std::numeric_limits::max()) { LL_PROFILE_ZONE_SCOPED_CATEGORY_STATS; num_periods = llmin(num_periods, getNumRecordedPeriods()); bool has_value = false; typename T::value_t min_val(std::numeric_limits::max()); for (size_t i = 1; i <= num_periods; i++) { Recording& recording = getPrevRecording(i); if (recording.hasValue(stat)) { min_val = llmin(min_val, recording.getSum(stat)); has_value = true; } } return has_value ? min_val : T::getDefaultValue(); } template T getPeriodMin(const CountStatHandle& stat, size_t num_periods = std::numeric_limits::max()) { LL_PROFILE_ZONE_SCOPED_CATEGORY_STATS; return T(getPeriodMin(static_cast&>(stat), num_periods)); } F64 getPeriodMin(const StatType& stat, size_t num_periods = std::numeric_limits::max()); template T getPeriodMin(const SampleStatHandle& stat, size_t num_periods = std::numeric_limits::max()) { LL_PROFILE_ZONE_SCOPED_CATEGORY_STATS; return T(getPeriodMin(static_cast&>(stat), num_periods)); } F64 getPeriodMin(const StatType& stat, size_t num_periods = std::numeric_limits::max()); template T getPeriodMin(const EventStatHandle& stat, size_t num_periods = std::numeric_limits::max()) { LL_PROFILE_ZONE_SCOPED_CATEGORY_STATS; return T(getPeriodMin(static_cast&>(stat), num_periods)); } template typename RelatedTypes::fractional_t getPeriodMinPerSec(const StatType& stat, size_t num_periods = std::numeric_limits::max()) { LL_PROFILE_ZONE_SCOPED_CATEGORY_STATS; num_periods = llmin(num_periods, getNumRecordedPeriods()); typename RelatedTypes::fractional_t min_val(std::numeric_limits::max()); for (size_t i = 1; i <= num_periods; i++) { Recording& recording = getPrevRecording(i); min_val = llmin(min_val, recording.getPerSec(stat)); } return (typename RelatedTypes::fractional_t) min_val; } template typename RelatedTypes::fractional_t getPeriodMinPerSec(const CountStatHandle& stat, size_t num_periods = std::numeric_limits::max()) { LL_PROFILE_ZONE_SCOPED_CATEGORY_STATS; return typename RelatedTypes::fractional_t(getPeriodMinPerSec(static_cast&>(stat), num_periods)); } // // PERIODIC MAX // // catch all for stats that have a defined sum template typename T::value_t getPeriodMax(const StatType& stat, size_t num_periods = std::numeric_limits::max()) { LL_PROFILE_ZONE_SCOPED_CATEGORY_STATS; num_periods = llmin(num_periods, getNumRecordedPeriods()); bool has_value = false; typename T::value_t max_val(std::numeric_limits::min()); for (size_t i = 1; i <= num_periods; i++) { Recording& recording = getPrevRecording(i); if (recording.hasValue(stat)) { max_val = llmax(max_val, recording.getSum(stat)); has_value = true; } } return has_value ? max_val : T::getDefaultValue(); } template T getPeriodMax(const CountStatHandle& stat, size_t num_periods = std::numeric_limits::max()) { LL_PROFILE_ZONE_SCOPED_CATEGORY_STATS; return T(getPeriodMax(static_cast&>(stat), num_periods)); } F64 getPeriodMax(const StatType& stat, size_t num_periods = std::numeric_limits::max()); template T getPeriodMax(const SampleStatHandle& stat, size_t num_periods = std::numeric_limits::max()) { LL_PROFILE_ZONE_SCOPED_CATEGORY_STATS; return T(getPeriodMax(static_cast&>(stat), num_periods)); } F64 getPeriodMax(const StatType& stat, size_t num_periods = std::numeric_limits::max()); template T getPeriodMax(const EventStatHandle& stat, size_t num_periods = std::numeric_limits::max()) { LL_PROFILE_ZONE_SCOPED_CATEGORY_STATS; return T(getPeriodMax(static_cast&>(stat), num_periods)); } template typename RelatedTypes::fractional_t getPeriodMaxPerSec(const StatType& stat, size_t num_periods = std::numeric_limits::max()) { LL_PROFILE_ZONE_SCOPED_CATEGORY_STATS; num_periods = llmin(num_periods, getNumRecordedPeriods()); F64 max_val = std::numeric_limits::min(); for (size_t i = 1; i <= num_periods; i++) { Recording& recording = getPrevRecording(i); max_val = llmax(max_val, recording.getPerSec(stat)); } return (typename RelatedTypes::fractional_t)max_val; } template typename RelatedTypes::fractional_t getPeriodMaxPerSec(const CountStatHandle& stat, size_t num_periods = std::numeric_limits::max()) { LL_PROFILE_ZONE_SCOPED_CATEGORY_STATS; return typename RelatedTypes::fractional_t(getPeriodMaxPerSec(static_cast&>(stat), num_periods)); } // // PERIODIC MEAN // // catch all for stats that have a defined sum template typename RelatedTypes::fractional_t getPeriodMean(const StatType& stat, size_t num_periods = std::numeric_limits::max()) { LL_PROFILE_ZONE_SCOPED_CATEGORY_STATS; num_periods = llmin(num_periods, getNumRecordedPeriods()); typename RelatedTypes::fractional_t mean(0); for (size_t i = 1; i <= num_periods; i++) { Recording& recording = getPrevRecording(i); if (recording.getDuration() > (F32Seconds)0.f) { mean += recording.getSum(stat); } } return (num_periods ? typename RelatedTypes::fractional_t(mean / num_periods) : typename RelatedTypes::fractional_t(NaN)); } template typename RelatedTypes::fractional_t getPeriodMean(const CountStatHandle& stat, size_t num_periods = std::numeric_limits::max()) { LL_PROFILE_ZONE_SCOPED_CATEGORY_STATS; return typename RelatedTypes::fractional_t(getPeriodMean(static_cast&>(stat), num_periods)); } F64 getPeriodMean(const StatType& stat, size_t num_periods = std::numeric_limits::max()); template typename RelatedTypes::fractional_t getPeriodMean(const SampleStatHandle& stat, size_t num_periods = std::numeric_limits::max()) { LL_PROFILE_ZONE_SCOPED_CATEGORY_STATS; return typename RelatedTypes::fractional_t(getPeriodMean(static_cast&>(stat), num_periods)); } F64 getPeriodMean(const StatType& stat, size_t num_periods = std::numeric_limits::max()); template typename RelatedTypes::fractional_t getPeriodMean(const EventStatHandle& stat, size_t num_periods = std::numeric_limits::max()) { LL_PROFILE_ZONE_SCOPED_CATEGORY_STATS; return typename RelatedTypes::fractional_t(getPeriodMean(static_cast&>(stat), num_periods)); } template typename RelatedTypes::fractional_t getPeriodMeanPerSec(const StatType& stat, size_t num_periods = std::numeric_limits::max()) { LL_PROFILE_ZONE_SCOPED_CATEGORY_STATS; num_periods = llmin(num_periods, getNumRecordedPeriods()); typename RelatedTypes::fractional_t mean = 0; for (size_t i = 1; i <= num_periods; i++) { Recording& recording = getPrevRecording(i); if (recording.getDuration() > (F32Seconds)0.f) { mean += recording.getPerSec(stat); } } return (num_periods ? typename RelatedTypes::fractional_t(mean / num_periods) : typename RelatedTypes::fractional_t(NaN)); } template typename RelatedTypes::fractional_t getPeriodMeanPerSec(const CountStatHandle& stat, size_t num_periods = std::numeric_limits::max()) { LL_PROFILE_ZONE_SCOPED_CATEGORY_STATS; return typename RelatedTypes::fractional_t(getPeriodMeanPerSec(static_cast&>(stat), num_periods)); } F64 getPeriodMedian( const StatType& stat, size_t num_periods = std::numeric_limits::max()); template typename RelatedTypes::fractional_t getPeriodMedianPerSec(const StatType& stat, size_t num_periods = std::numeric_limits::max()) { LL_PROFILE_ZONE_SCOPED_CATEGORY_STATS; num_periods = llmin(num_periods, getNumRecordedPeriods()); std::vector ::fractional_t> buf; for (size_t i = 1; i <= num_periods; i++) { Recording& recording = getPrevRecording(i); if (recording.getDuration() > (F32Seconds)0.f) { buf.push_back(recording.getPerSec(stat)); } } std::sort(buf.begin(), buf.end()); return typename RelatedTypes::fractional_t((buf.size() % 2 == 0) ? (buf[buf.size() / 2 - 1] + buf[buf.size() / 2]) / 2 : buf[buf.size() / 2]); } template typename RelatedTypes::fractional_t getPeriodMedianPerSec(const CountStatHandle& stat, size_t num_periods = std::numeric_limits::max()) { LL_PROFILE_ZONE_SCOPED_CATEGORY_STATS; return typename RelatedTypes::fractional_t(getPeriodMedianPerSec(static_cast&>(stat), num_periods)); } // // PERIODIC STANDARD DEVIATION // F64 getPeriodStandardDeviation(const StatType& stat, size_t num_periods = std::numeric_limits::max()); template typename RelatedTypes::fractional_t getPeriodStandardDeviation(const SampleStatHandle& stat, size_t num_periods = std::numeric_limits::max()) { LL_PROFILE_ZONE_SCOPED_CATEGORY_STATS; return typename RelatedTypes::fractional_t(getPeriodStandardDeviation(static_cast&>(stat), num_periods)); } F64 getPeriodStandardDeviation(const StatType& stat, size_t num_periods = std::numeric_limits::max()); template typename RelatedTypes::fractional_t getPeriodStandardDeviation(const EventStatHandle& stat, size_t num_periods = std::numeric_limits::max()) { LL_PROFILE_ZONE_SCOPED_CATEGORY_STATS; return typename RelatedTypes::fractional_t(getPeriodStandardDeviation(static_cast&>(stat), num_periods)); } private: // implementation for LLStopWatchControlsMixin /*virtual*/ void handleStart(); /*virtual*/ void handleStop(); /*virtual*/ void handleReset(); /*virtual*/ void handleSplitTo(PeriodicRecording& other); // helper methods for wraparound ring-buffer arithmetic inline size_t wrapi(size_t i) const { return i % mRecordingPeriods.size(); } inline size_t nexti(size_t i, size_t offset=1) const { return wrapi(i + offset); } inline size_t previ(size_t i, size_t offset=1) const { auto num_periods = mRecordingPeriods.size(); // constrain offset offset = llclamp(offset, 0, num_periods - 1); // add size() so expression can't go (unsigned) "negative" return wrapi(i + num_periods - offset); } inline void inci(size_t& i, size_t offset=1) const { i = nexti(i, offset); } private: std::vector mRecordingPeriods; const bool mAutoResize; size_t mCurPeriod; size_t mNumRecordedPeriods; }; PeriodicRecording& get_frame_recording(); class ExtendableRecording : public LLStopWatchControlsMixin { public: void extend(); Recording& getAcceptedRecording() { return mAcceptedRecording; } const Recording& getAcceptedRecording() const {return mAcceptedRecording;} Recording& getPotentialRecording() { return mPotentialRecording; } const Recording& getPotentialRecording() const { return mPotentialRecording;} private: // implementation for LLStopWatchControlsMixin /*virtual*/ void handleStart(); /*virtual*/ void handleStop(); /*virtual*/ void handleReset(); /*virtual*/ void handleSplitTo(ExtendableRecording& other); private: Recording mAcceptedRecording; Recording mPotentialRecording; }; class ExtendablePeriodicRecording : public LLStopWatchControlsMixin { public: ExtendablePeriodicRecording(); void extend(); PeriodicRecording& getResults() { return mAcceptedRecording; } const PeriodicRecording& getResults() const {return mAcceptedRecording;} void nextPeriod() { mPotentialRecording.nextPeriod(); } private: // implementation for LLStopWatchControlsMixin /*virtual*/ void handleStart(); /*virtual*/ void handleStop(); /*virtual*/ void handleReset(); /*virtual*/ void handleSplitTo(ExtendablePeriodicRecording& other); private: PeriodicRecording mAcceptedRecording; PeriodicRecording mPotentialRecording; }; } #ifdef LL_WINDOWS #pragma warning(pop) #endif #endif // LL_LLTRACERECORDING_H