cpumonitor.h

Go to the documentation of this file.

 
#pragma once
 
 
#include <promeki/config.h>
#if PROMEKI_ENABLE_CORE
#include <functional>
 
#include <promeki/function.h>
#include <promeki/atomic.h>
#include <promeki/duration.h>
#include <promeki/list.h>
#include <promeki/mutex.h>
#include <promeki/namespace.h>
#include <promeki/string.h>
#include <promeki/thread.h>
#include <promeki/threadpool.h>
 
PROMEKI_NAMESPACE_BEGIN
 
class CpuMonitor : public Thread {
        public:
                struct ThreadSample {
                                uint64_t tid = 0;             
                                String   name;                
                                double   userPercent = 0.0;   
                                double   systemPercent = 0.0; 
                                double   totalPercent = 0.0;  
                                Duration cpuTimeDelta;        
                };
 
                struct Report {
                                Duration           wallElapsed;        
                                double             processPercent = 0.0; 
                                List<ThreadSample> threads;            
                };
 
                using ReportFunction = Function<void(const Report &)>;
 
                static constexpr int64_t DefaultIntervalSec = 5;
 
                static constexpr size_t DefaultTopN = 8;
 
                CpuMonitor();
 
                ~CpuMonitor() override;
 
                CpuMonitor(const CpuMonitor &) = delete;
                CpuMonitor &operator=(const CpuMonitor &) = delete;
 
                Error start(const Duration &interval);
 
                void stop();
 
                bool isRunning() const { return Thread::isRunning(); }
 
                void setInterval(const Duration &d);
 
                Duration interval() const;
 
                void setReportFunction(ReportFunction fn);
 
                static String formatReport(const Report &r, size_t topN = DefaultTopN);
 
                void setPoolReportEnabled(bool enabled);
 
                bool isPoolReportEnabled() const;
 
                static String formatPoolReport(const String &poolName, const Duration &wallElapsed,
                                               const List<ThreadPool::WorkStats> &stats,
                                               size_t                             topN = DefaultTopN);
 
        protected:
                void run() override;
 
        private:
                struct ThreadCpuTimes {
                                uint64_t tid = 0;
                                String   name;
                                int64_t  utimeTicks = 0;
                                int64_t  stimeTicks = 0;
                };
 
                List<ThreadCpuTimes> readThreadCpuTimes() const;
 
                Atomic<int64_t> _intervalNs;
                Atomic<bool>    _stopRequested;
                Atomic<bool>    _poolReportEnabled;
                mutable Mutex   _fnMutex;
                ReportFunction  _reportFn;
};
 
PROMEKI_NAMESPACE_END
 
#endif // PROMEKI_ENABLE_CORE