diff options
Diffstat (limited to 'superkaramba/src/memsensor.cpp')
| -rw-r--r-- | superkaramba/src/memsensor.cpp | 359 |
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 * + * karlsson.h@home.se * + * * + * 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" |