cpuUsage.cpp

Go to the documentation of this file.

 
#include <QSysInfo>
#include <QProcess>
#include <QThread>
 
#include "VFS.h"
#include "VFS_icons.h"
#include "utilities/rutils.h"
 
#include "cpuUsage.h"
 
cpuUsage::cpuUsage()
: VFS_application()
, _processors(1)
{
        _kernel = QSysInfo::kernelType().toLower();
        _processors = QThread::idealThreadCount();
 
        //VFS::LOG( "CPU usage kernel: "+_kernel, 0, "cpuusage");
 
        if (_kernel == "linux")
        {
                _scale = 100.0;
 
                //https://stackoverflow.com/questions/890894/portable-way-to-find-out-if-a-command-exists-c-c
                if (system("which sar > /dev/null 2>&1"))
                        VFS::WARN("For linux, the 'sar' command is used for cpuUsage.  This command is missing on this system.", 0, "cpuusage");
 
                if (system("which bc > /dev/null 2>&1"))
                        VFS::WARN("For linux, the 'bc' command is used for cpuUsage.  This command is missing on this system.", 0, "cpuusage");
        }
        else if (_kernel == "darwin")
        {
                _scale = _processors * 100.0;
        }
        else    //for windoze, etc
        {
                _scale = 100.0;
        }
}
 
cpuUsage::~cpuUsage()
{
}
 
void cpuUsage::initialize()
{
        startTimer(1000);
}
 
bool cpuUsage::isContainer()
{
        return false;
}
 
QByteArray cpuUsage::icon()
{
        return "data:image/svg+xml;utf8,<svg class=\"menuIcon\" xmlns=\"http://www.w3.org/2000/svg\" viewBox=\"0 0 32 32\"><g id=\"vfs\"><path d=\"M3,25.95a1,1,0,0,1-.55-1.84l6.16-4A1,1,0,0,1,9.48,20l5.38,2.11,2.51-9.21A1,1,0,0,1,19,12.47l6.29,6.15L28.68,4.87a1,1,0,1,1,1.94.47L26.85,20.8a1,1,0,0,1-1.67.48l-6.33-6.19L16.5,23.73a1,1,0,0,1-.52.63,1,1,0,0,1-.81,0L9.23,22.07,3.51,25.79A1,1,0,0,1,3,25.95Z\"/><circle fill=\"rgb(27,186,217)\" class=\"iconColor\" cx=\"18.38\" cy=\"13.71\" r=\"1.66\" transform=\"translate(-4.31 17.01) rotate(-45)\"/><circle fill=\"rgb(27,186,217)\" class=\"iconColor\" cx=\"29.65\" cy=\"5.11\" r=\"1.66\" transform=\"translate(5.08 22.46) rotate(-45)\"/><circle fill=\"rgb(27,186,217)\" class=\"iconColor\" cx=\"25.96\" cy=\"20.23\" r=\"1.66\" transform=\"translate(-6.7 24.29) rotate(-45)\"/><circle fill=\"rgb(27,186,217)\" class=\"iconColor\" cx=\"15.78\" cy=\"23.52\" r=\"1.66\" transform=\"translate(-12.01 18.05) rotate(-45)\"/><circle fill=\"rgb(27,186,217)\" class=\"iconColor\" cx=\"2.6\" cy=\"24.95\" r=\"1.66\" transform=\"translate(-16.88 9.14) rotate(-45)\"/><circle fill=\"rgb(27,186,217)\" class=\"iconColor\" cx=\"9.09\" cy=\"21.3\" r=\"1.66\" transform=\"translate(-12.4 12.67) rotate(-45)\"/></g></svg>";
        // return VFS_icons::get("graph");
}
 
void cpuUsage::metadata(VFS_request *r)
{
        QJsonObject a;
        a["type"] = "openLayout";
 
        r->_metadata["icon"] = QString(icon());
        r->_metadata["action"]  = a;
 
        QJsonObject l = rutils::jsonResource(":/admin/templates/basicLayout.json");
        l["icon"] = "@icon@";
        QJsonObject t;
        t["openLayout"] = l;
 
        r->_metadata["template"] = t;
        r->_metadata["where"] = "nearest";
        r->_metadata["type"] = "cpuUsage:cpuGraph.js";
        r->_success = true;
}
 
void cpuUsage::read(VFS_request *r)
{
        QJsonObject c;
        for (int i=0;i<_cpuSamples.length();i++)
                c[QString::number(_cpuSamples[i].first)] = _cpuSamples[i].second;
 
        QJsonObject m;
        for (int i=0;i<_ramSamples.length();i++)
                m[QString::number(_ramSamples[i].first)] = _ramSamples[i].second;
 
        QJsonObject q;
        for (int i=0;i<_reqSamples.length();i++)
                q[QString::number(_reqSamples[i].first)] = _reqSamples[i].second;
 
        QJsonObject d;
        d["cpu"] = c;
        d["ram"] = m;
        d["req"] = q;
        d["max"] = MAX_SAMPLES;
 
        r->_data.setObject(d);
        r->_success = true;
        //VFS_application::read(r);
}
 
QString cpuUsage::code(QString nodename, QString libname, QString &error)
{
        if (libname == "cpuGraph.js")
                return rutils::resourceContents(":/admin/html/cpuGraph.js");
 
        if (libname == "cpuGraph.css")
                return rutils::resourceContents(":/admin/html/cpuGraph.css");
 
        return VFS_application::code(nodename,libname,error);
}
 
void cpuUsage::timerEvent(QTimerEvent *event)
{
        Q_UNUSED(event);
 
        //printf( "Timer ID: %d\n", event->timerId() );
 
        QDateTime now = QDateTime::currentDateTime();
        qint64 t = now.toMSecsSinceEpoch();
 
        getCPUSample(t);
        getRAMSample(t);
        getREQSample(t);
 
        QJsonObject _diff;
        _diff["uptime"] = VFS::uptimeString(false);
        _diff["cpu"] = _cpu_diff;
        _diff["ram"] = _ram_diff;
        _diff["req"] = _req_diff;
 
        VFS_request *d = createRequest( VFS_request::diff, "", "server", QJsonDocument(_diff) );
        emit diff(this,d);
        delete d;
 
        _cpu_diff = QJsonObject();
        _ram_diff = QJsonObject();
        _req_diff = QJsonObject();
}
 
void cpuUsage::getCPUSample(quint64 t)
{
        double p = runCommand("cpuusage").toDouble() / _scale;
 
        _cpuSamples << QPair<quint64,double> (t,p);
 
        _cpu_diff[QString::number(t)] = p;
 
        while ( _cpuSamples.length() > MAX_SAMPLES )
                _cpuSamples.removeFirst();
}
 
void cpuUsage::getRAMSample(quint64 t)
{
        double p = runCommand("ramusage").toDouble();
        //printf("ram: %f\n",p);
 
        _ramSamples << QPair<quint64,double> (t,p);
 
        _ram_diff[QString::number(t)] = p;
 
        while ( _ramSamples.length() > MAX_SAMPLES )
                _ramSamples.removeFirst();
}
 
 
void cpuUsage::getREQSample(quint64 t)
{
        quint32 s = VFS_request::getSample();
        quint32 r = VFS_request::_refcount;
 
        _reqSamples << QPair<quint64,quint32> (t,s);
 
        _req_diff[QString::number(t)] = (qint64) (s+r);
        //_req_diff[QString::number(t)] = (qint64) (r);
 
        while ( _reqSamples.length() > MAX_SAMPLES )
                _reqSamples.removeFirst();
 
        //fixme: this should always report 0 for r
        //printf("ref: %d %ld\n",s,r);
 
        //if (r > 20)
        //      VFS::WARN( QString("The outstanding VFS_request::_refcount is more than 20 (%1).  Suspect a memory leak somehwere in a plugin due to VFS_requests failing to delete.\nUse valgrind to debug this, as well as set the #define DEBUG_DANGLING_REQUESTS in VFS_node.h to true.  Ideally this value would be 0.").arg(r) );
}
 
 
QString cpuUsage::runCommand(QString which)
{
        // https://stackoverflow.com/questions/30855440/how-to-get-cpu-utilization-in-in-terminal-mac
        // `ps -A -o %cpu | awk '{s+=$1} END {print s "%"}'`
 
        // https://stackoverflow.com/questions/6481005/how-to-obtain-the-number-of-cpus-cores-in-linux-from-the-command-line
        // `grep -c ^processor /proc/cpuinfo`
 
        // https://stackoverflow.com/questions/8122277/getting-memory-information-with-qt
        // https://www.cyberciti.biz/faq/unix-command-to-find-cpu-utilization/
 
        QString command = "";
 
        if (_kernel == "linux")
        {
                //if (which == "cpucount")
                //      command = "grep -c ^processor /proc/cpuinfo";
 
                if (which == "cpuusage")
                        //command = "ps -A -o %cpu | awk '{s+=$1} END {print s \"\"}'";
                        command = "sar -u 1 1 | grep verage | perl -pe \"s/\\s+/+/g\" | cut -f 3,5 -d '+' | bc -l";
                        //command = "ps -A -o %cpu | awk '{s+=$1} END {print s}'";
 
 
                if (which == "ramusage")
                        // free -b | grep Mem | perl -pe "s/\s+/ /g" | cut -f 2,4 -d " " | perl -pe "s/\s+/ \/ /" | perl -pe "s/(.*)/scale=20; 1-1\/(\1)/" | bc
                        command = "free -b | grep Mem | perl -pe \"s/\\s+/ /g\" | cut -f 2,4 -d \" \" | perl -pe \"s/\\s+/ \\/ /\" | perl -pe \"s/(.*)/scale=20; 1-1\\/(\\1)/\" | bc -l";
        }
 
        if (_kernel == "darwin")
        {
                if (which == "cpuusage")
                        //command = "ps -A -o %cpu | awk '{s+=$1} END {print s \"\"}'";
                        command = "ps -A -o %cpu | awk '{s+=$1} END {print s}'";
                        //command = "bash -c 'ps -A -o %cpu'";
 
                if (which == "ramusage")
                {       // sysctl hw.physmem hw.memsize | cut -f 2 -d " " | perl -pe "s/\n/ /" | perl -pe "s/(\d+)[^\d]*(\d+)/\1 \/ \2\n/" | bc -l
                        //command = "sysctl hw.physmem hw.memsize | cut -f 2 -d \" \" | perl -pe \"s/\\n/ /\" | perl -pe \"s/(\\d+)[^\\d]*(\\d+)/scale=20; \\1 \\/ \\2\\n/\" | bc -l";
                        //command = "memory_pressure | grep percentage | perl -pe \"s/([^\\d]*)(\\d+)([^\\d]*)/scale=20; \2 \\/ 100\\n/\" | bc -l";
 
                        // memory_pressure  | grep percentage | perl -pe "s/([^\d]*)(\d+)([^\d]*)/scale=20; \2 \/ 100.0\n/" | bc -l
                        command = "memory_pressure | grep percentage | perl -pe \"s/([^\\d]*)(\\d+)([^\\d]*)/scale=20; \\2 \\/ 100\\n/\" | bc -l";
                }
        }
 
        if (!command.isEmpty())
        {
                QProcess process;
                process.start("bash", QStringList() << "-c" << command);
                process.waitForFinished(5000); // will wait for 5 seconds to finish
 
                QString stdout = process.readAllStandardOutput();
                QString stderr = process.readAllStandardError();
 
                //printf("stdout: %s\n",qUtf8Printable(stdout));
                //printf("stderr: %s\n",qUtf8Printable(stderr));
 
                return stdout;
        }
 
        VFS::ERROR( QString("Unsupported OS or selector: %1 %2.  Can't return command.").arg(_kernel).arg(which) );
 
        return "";
}