Copy the KDE 3.5 branch to branches/trinity for new KDE 3.5 features.

BUG:215923


git-svn-id: svn://anonsvn.kde.org/home/kde/branches/trinity/kdeutils@1054174 283d02a7-25f6-0310-bc7c-ecb5cbfe19da

1 files changed, 359 insertions, 0 deletions

diff --git a/superkaramba/src/memsensor.cpp b/superkaramba/src/memsensor.cpp
new file mode 100644
index 0000000..21d9f35
--- /dev/null
+++ b/superkaramba/src/memsensor.cpp
@@ -0,0 +1,359 @@
+/***************************************************************************
+ *   Copyright (C) 2003 by Hans Karlsson                                   *
+ *   [email protected]                                                      *
+ *                                                                         *
+ *   This program is free software; you can redistribute it and/or modify  *
+ *   it under the terms of the GNU General Public License as published by  *
+ *   the Free Software Foundation; either version 2 of the License, or     *
+ *   (at your option) any later version.                                   *
+ ***************************************************************************/
+#include "memsensor.h"
+#include <qfile.h>
+#include <qglobal.h>
+#include <qtextstream.h>
+#include <qstring.h>
+#include <qregexp.h>
+
+#ifdef Q_OS_FREEBSD
+#include <sys/time.h>
+#include <sys/param.h>
+#include <sys/sysctl.h>
+#include <sys/resource.h>
+#include <unistd.h>
+#include <kvm.h>
+#include <sys/file.h>
+#include <osreldate.h>
+#endif
+
+#if defined(Q_OS_NETBSD)
+#include <sys/param.h>
+#include <sys/sysctl.h>
+#include <sys/sched.h>
+#include <sys/swap.h>
+#endif
+
+#include <kprocio.h>
+
+#if defined Q_OS_FREEBSD || defined(Q_OS_NETBSD)
+/* define pagetok in terms of pageshift */
+#define pagetok(size) ((size) << pageshift)
+#endif
+
+MemSensor::MemSensor(int msec) : Sensor(msec)
+{
+#if defined Q_OS_FREEBSD || defined(Q_OS_NETBSD)
+   /* get the page size with "getpagesize" and calculate pageshift from it */
+    int pagesize = getpagesize();
+    pageshift = 0;
+    while (pagesize > 1)
+    {
+        pageshift++;
+        pagesize >>= 1;
+    }
+
+    /* we only need the amount of log(2)1024 for our conversion */
+    pageshift -= 10;
+# if defined(Q_OS_FREEBSD) && defined(__FreeBSD_version) && __FreeBSD_version >= 500018
+    kd = kvm_open("/dev/null", "/dev/null", "/dev/null", O_RDONLY, "kvm_open");
+# elif defined Q_OS_FREEBSD
+    connect(&ksp, SIGNAL(receivedStdout(KProcess *, char *, int )),
+            this,SLOT(receivedStdout(KProcess *, char *, int )));
+    connect(&ksp, SIGNAL(processExited(KProcess *)),
+            this,SLOT(processExited( KProcess * )));
+
+    swapTotal = swapUsed = 0;
+
+    MaxSet = false;
+
+    readValues();
+# endif
+#else
+    readValues();
+#endif
+}
+
+MemSensor::~MemSensor()
+{}
+
+#ifdef Q_OS_FREEBSD
+void MemSensor::receivedStdout(KProcess *, char *buffer, int len )
+{
+    buffer[len] = 0;
+    sensorResult += QString( QCString(buffer) );
+}
+#else
+void MemSensor::receivedStdout(KProcess *, char *, int)
+{
+}
+#endif
+
+void MemSensor::processExited(KProcess *)
+{
+#ifdef Q_OS_FREEBSD
+    QStringList stringList = QStringList::split('\n',sensorResult);
+    sensorResult = "";
+    QStringList itemsList = QStringList::split(' ', stringList[1]);
+
+    swapUsed = itemsList[2].toInt();
+    swapTotal = itemsList[1].toInt();
+#endif
+}
+
+int MemSensor::getMemTotal()
+{
+#if defined Q_OS_FREEBSD || defined(Q_OS_NETBSD)
+    static int mem = 0;
+    size_t size = sizeof(mem);
+
+    sysctlbyname("hw.physmem", &mem, &size, NULL, 0);
+    return (mem / 1024);
+#else
+    QRegExp rx( "MemTotal:\\s*(\\d+)" );
+    rx.search( meminfo );
+    return ( rx.cap(1).toInt() );
+#endif
+}
+
+int MemSensor::getMemFree()
+{
+#ifdef Q_OS_FREEBSD
+    static int mem = 0;
+    size_t size = sizeof(mem);
+
+    sysctlbyname("vm.stats.vm.v_free_count", &mem, &size, NULL, 0);
+    return (pagetok(mem));
+#elif defined(Q_OS_NETBSD)
+    struct uvmexp_sysctl uvmexp;
+    int mib[2];
+    size_t ssize;
+    mib[0] = CTL_VM;
+    mib[1] = VM_UVMEXP2;
+    ssize = sizeof(uvmexp);
+    sysctl(mib,2,&uvmexp,&ssize,NULL,0);
+    return pagetok(uvmexp.free);
+#else
+    QRegExp rx( "MemFree:\\s*(\\d+)" );
+    rx.search( meminfo );
+    return ( rx.cap(1).toInt() );
+#endif
+}
+
+int MemSensor::getBuffers()
+{
+#ifdef Q_OS_FREEBSD
+    static int mem = 0;
+    size_t size = sizeof(mem);
+
+    sysctlbyname("vfs.bufspace", &mem, &size, NULL, 0);
+    return (mem / 1024);
+#elif defined(Q_OS_NETBSD)
+    static int buf_mem = 0;
+    size_t size = sizeof(buf_mem);
+
+    sysctlbyname("vm.bufmem", &buf_mem, &size, NULL, 0);
+    return (buf_mem / 1024);
+#else
+    QRegExp rx( "Buffers:\\s*(\\d+)" );
+    rx.search( meminfo );
+    return ( rx.cap(1).toInt() );
+#endif
+}
+
+int MemSensor::getCached()
+{
+#ifdef Q_OS_FREEBSD
+    static int mem = 0;
+    size_t size = sizeof(mem);
+
+    sysctlbyname("vm.stats.vm.v_cache_count", &mem, &size, NULL, 0);
+    return (pagetok(mem));
+#elif defined(Q_OS_NETBSD)
+    return 0;
+#else
+    QRegExp rx1( "Cached:\\s*(\\d+)" );
+    QRegExp rx2( "SwapCached:\\s*(\\d+)" );
+    rx1.search( meminfo );
+    rx2.search( meminfo );
+    return ( rx1.cap(1).toInt() + rx2.cap(1).toInt() );
+#endif
+}
+
+
+int MemSensor::getSwapTotal()
+{
+#ifdef Q_OS_FREEBSD
+# if defined(__FreeBSD_version) && __FreeBSD_version >= 500018
+    int n = -1;
+    int pagesize = getpagesize();
+    int retavail = 0;
+
+    if (kd != NULL)
+        n = kvm_getswapinfo(kd, &swapinfo, 1, 0);
+
+    if (n < 0 || swapinfo.ksw_total == 0)
+        return(0);
+
+    retavail = swapinfo.ksw_total * pagesize / 1024;
+
+    return(retavail);
+#else
+    return(swapTotal);
+# endif
+#elif defined(Q_OS_NETBSD)
+    struct uvmexp_sysctl uvmexp;
+    int STotal = 0;
+    int pagesize = 1;
+    int mib[2];
+    size_t ssize;
+    mib[0] = CTL_VM;
+    mib[1] = VM_UVMEXP;
+    ssize = sizeof(uvmexp);
+
+    if (sysctl(mib,2,&uvmexp,&ssize,NULL,0) != -1) {
+	pagesize = uvmexp.pagesize;
+	STotal = (pagesize*uvmexp.swpages) >> 10;
+    }
+    return STotal;
+#else
+    QRegExp rx( "SwapTotal:\\s*(\\d+)" );
+    rx.search( meminfo );
+    return ( rx.cap(1).toInt() );
+#endif
+}
+
+int MemSensor::getSwapFree()
+{
+#ifdef Q_OS_FREEBSD
+# if defined(__FreeBSD_version) && __FreeBSD_version >= 500018
+    int n = -1;
+    int pagesize = getpagesize();
+    int retfree = 0;
+
+    if (kd != NULL)
+        n = kvm_getswapinfo(kd, &swapinfo, 1, 0);
+    if (n < 0 || swapinfo.ksw_total == 0)
+        return(0);
+
+    retfree = (swapinfo.ksw_total - swapinfo.ksw_used) * pagesize / 1024;
+
+    return(retfree);
+# else
+    return(swapTotal - swapUsed);
+# endif
+#elif defined(Q_OS_NETBSD)
+    struct uvmexp_sysctl uvmexp;
+    int STotal = 0;
+    int SFree = 0;
+    int SUsed = 0;
+    int pagesize = 1;
+    int mib[2];
+    size_t ssize;
+    mib[0] = CTL_VM;
+    mib[1] = VM_UVMEXP;
+    ssize = sizeof(uvmexp);
+
+    if (sysctl(mib,2,&uvmexp,&ssize,NULL,0) != -1) {
+	pagesize = uvmexp.pagesize;
+	STotal = (pagesize*uvmexp.swpages) >> 10;
+	SUsed = (pagesize*uvmexp.swpginuse) >> 10;
+	SFree = STotal - SUsed;
+    }
+    return SFree;
+#else
+    QRegExp rx( "SwapFree:\\s*(\\d+)" );
+    rx.search( meminfo );
+    return ( rx.cap(1).toInt() );
+#endif
+}
+
+void MemSensor::readValues()
+{
+#if defined Q_OS_FREEBSD || defined(Q_OS_NETBSD)
+# if defined(Q_OS_FREEBSD) && !(defined(__FreeBSD_version) && __FreeBSD_version >= 500018)
+    ksp.clearArguments();
+    ksp << "swapinfo";
+    ksp.start( KProcess::NotifyOnExit,KProcIO::Stdout);
+# endif
+#else
+    QFile file("/proc/meminfo");
+    QString line;
+    if ( file.open(IO_ReadOnly | IO_Translate) )
+    {
+        QTextStream t( &file );        // use a text stream
+        meminfo = t.read();
+        file.close();
+    }
+#endif
+}
+
+void MemSensor::update()
+{
+    readValues();
+    QString format;
+    SensorParams *sp;
+    Meter *meter;
+    QObjectListIt it( *objList );
+#if defined(Q_OS_FREEBSD) && !(defined(__FreeBSD_version) && __FreeBSD_version >= 500018)
+    bool set = false;
+#endif
+    int totalMem = getMemTotal();
+    int usedMem = totalMem - getMemFree();
+    int usedMemNoBuffers =  usedMem - getBuffers() - getCached();
+    int totalSwap = getSwapTotal();
+    int usedSwap = totalSwap - getSwapFree();
+
+    while (it != 0)
+    {
+        sp = (SensorParams*)(*it);
+#if defined(Q_OS_FREEBSD) && !(defined(__FreeBSD_version) && __FreeBSD_version >= 500018)
+        if ( (!MaxSet) && (totalSwap > 0) ) {
+           setMaxValue(sp);
+           bool set = true;
+        }
+#endif
+        meter = sp->getMeter();
+        format = sp->getParam("FORMAT");
+        if (format.length() == 0 )
+        {
+            format = "%um";
+        }
+
+        format.replace( QRegExp("%fmb", false), QString::number( (int)(( totalMem - usedMemNoBuffers)/1024.0+0.5)));
+        format.replace( QRegExp("%fm", false), QString::number( (int)( ( totalMem - usedMem  )/1024.0+0.5) ));
+
+        format.replace( QRegExp("%umb", false), QString::number( (int)((usedMemNoBuffers)/1024.0+0.5)));
+        format.replace( QRegExp("%um", false), QString::number( (int)((usedMem)/1024.0+0.5 )));
+
+        format.replace( QRegExp("%tm", false), QString::number( (int)( (totalMem)/1024.0+0.5)));
+
+        format.replace( QRegExp("%fs", false), QString::number( (int)((totalSwap - usedSwap)/1024.0+0.5)));
+        format.replace( QRegExp("%us", false), QString::number( (int)(usedSwap/1024.0+0.5)));
+        format.replace( QRegExp("%ts", false), QString::number( (int)(totalSwap/1024.0+0.5)));
+
+        meter->setValue(format);
+        ++it;
+    }
+#if defined(Q_OS_FREEBSD) && !(defined(__FreeBSD_version) && __FreeBSD_version >= 500018)
+    if (set)
+        MaxSet = true;
+#endif
+}
+
+void MemSensor::setMaxValue( SensorParams *sp )
+{
+    Meter *meter;
+    meter = sp->getMeter();
+    QString f;
+    f = sp->getParam("FORMAT");
+
+    if (f.length() == 0 )
+    {
+        f = "%um";
+    }
+    if( f=="%fm" || f== "%um" || f=="%fmb" || f=="%umb" )
+        meter->setMax( getMemTotal() / 1024 );
+    if( f=="%fs" || f== "%us" )
+        meter->setMax( getSwapTotal() / 1024 );
+}
+
+#include "memsensor.moc"