File indexing completed on 2024-04-28 16:49:57

 /*
     SPDX-FileCopyrightText: 2007 Manolo Valdes <nolis71cu@gmail.com>
 
     SPDX-License-Identifier: LGPL-2.0-or-later
 */
 
 #include "process.h"
 #include "processes_local_p.h"
 
 #include <KLocalizedString>
 
 #include <QSet>
 
 #include <sys/param.h>
 #include <sys/resource.h>
 #include <sys/sysctl.h>
 #include <sys/types.h>
 #include <sys/user.h>
 #if defined(__DragonFly__)
 #include <err.h>
 #include <sys/resourcevar.h>
 #endif
 #include <signal.h>
 #include <stdlib.h>
 #include <unistd.h>
 
 namespace KSysGuard
 {
 class ProcessesLocal::Private
 {
 public:
     Private()
     {
         ;
     }
     ~Private()
     {
         ;
     }
     inline bool readProc(long pid, struct kinfo_proc *p);
     inline void readProcStatus(struct kinfo_proc *p, Process *process);
     inline void readProcStat(struct kinfo_proc *p, Process *process);
     inline void readProcStatm(struct kinfo_proc *p, Process *process);
     inline bool readProcCmdline(long pid, Process *process);
 };
 
 bool ProcessesLocal::Private::readProc(long pid, struct kinfo_proc *p)
 {
     int mib[4];
     size_t len;
 
     mib[0] = CTL_KERN;
     mib[1] = KERN_PROC;
     mib[2] = KERN_PROC_PID;
     mib[3] = pid;
 
     len = sizeof(struct kinfo_proc);
     if (sysctl(mib, 4, p, &len, NULL, 0) == -1 || !len)
         return false;
     return true;
 }
 
 void ProcessesLocal::Private::readProcStatus(struct kinfo_proc *p, Process *process)
 {
     process->setUid(0);
     process->setGid(0);
     process->setTracerpid(-1);
 
 #if defined(__FreeBSD__) && __FreeBSD_version >= 500015
     process->setUid(p->ki_uid);
     process->setGid(p->ki_pgid);
     process->setName(QString(p->ki_comm ? p->ki_comm : "????"));
 #elif defined(__DragonFly__) && __DragonFly_version >= 190000
     process->setUid(p->kp_uid);
     process->setGid(p->kp_pgid);
     process->setName(QString(p->kp_comm ? p->kp_comm : "????"));
 #else
     process->setUid(p->kp_eproc.e_ucred.cr_uid);
     process->setGid(p->kp_eproc.e_pgid);
 #endif
 }
 
 void ProcessesLocal::Private::readProcStat(struct kinfo_proc *p, Process *ps)
 {
     int status;
     struct rusage pru;
 #if defined(__FreeBSD__) && __FreeBSD_version >= 500015
     ps->setUserTime(p->ki_runtime / 10000);
     ps->setNiceLevel(p->ki_nice);
     ps->setVmSize(p->ki_size);
     ps->setVmRSS(p->ki_rssize * getpagesize());
     status = p->ki_stat;
 #elif defined(__DragonFly__) && __DragonFly_version >= 190000
     if (!getrusage(p->kp_pid, &pru)) {
         errx(1, "failed to get rusage info");
     }
     ps->setUserTime(pru.ru_utime.tv_usec / 1000); /*p_runtime / 1000*/
     ps->setNiceLevel(p->kp_nice);
     ps->setVmSize(p->kp_vm_map_size);
     ps->setVmRSS(p->kp_vm_rssize * getpagesize());
     status = p->kp_stat;
 #else
     ps->setUserTime(p->kp_proc.p_rtime.tv_sec * 100 + p->kp_proc.p_rtime.tv_usec / 100);
     ps->setNiceLevel(p->kp_proc.p_nice);
     ps->setVmSize(p->kp_eproc.e_vm.vm_map.size);
     ps->setVmRSS(p->kp_eproc.e_vm.vm_rssize * getpagesize());
     status = p->kp_proc.p_stat;
 #endif
     ps->setSysTime(0);
 
     // "idle","run","sleep","stop","zombie"
     switch (status) {
     case '0':
         ps->setStatus(Process::DiskSleep);
         break;
     case '1':
         ps->setStatus(Process::Running);
         break;
     case '2':
         ps->setStatus(Process::Sleeping);
         break;
     case '3':
         ps->setStatus(Process::Stopped);
         break;
     case '4':
         ps->setStatus(Process::Zombie);
         break;
     default:
         ps->setStatus(Process::OtherStatus);
         break;
     }
 }
 
 void ProcessesLocal::Private::readProcStatm(struct kinfo_proc *p, Process *process)
 {
     // TODO
 
     //     unsigned long shared;
     //     process->setVmURSS(process->vmRSS - (shared * sysconf(_SC_PAGESIZE) / 1024));
 }
 
 bool ProcessesLocal::Private::readProcCmdline(long pid, Process *process)
 {
     int mib[4];
     struct kinfo_proc p;
     size_t buflen = 256;
     char buf[256];
 
     mib[0] = CTL_KERN;
     mib[1] = KERN_PROC;
     mib[2] = KERN_PROC_ARGS;
     mib[3] = pid;
 
     if (sysctl(mib, 4, buf, &buflen, NULL, 0) == -1 || !buflen)
         return false;
     QString command = QString(buf);
 
     // cmdline separates parameters with the NULL character
     command.replace('\0', ' ');
     process->setCommand(command.trimmed());
 
     return true;
 }
 
 ProcessesLocal::ProcessesLocal()
     : d(new Private())
 {
 }
 
 long ProcessesLocal::getParentPid(long pid)
 {
     Q_ASSERT(pid != 0);
     long long ppid = -1;
     struct kinfo_proc p;
     if (d->readProc(pid, &p)) {
 #if defined(__FreeBSD__) && __FreeBSD_version >= 500015
         ppid = p.ki_ppid;
 #elif defined(__DragonFly__) && __DragonFly_version >= 190000
         ppid = p.kp_ppid;
 #else
         ppid = p.kp_eproc.e_ppid;
 #endif
     }
     return ppid;
 }
 
 bool ProcessesLocal::updateProcessInfo(long pid, Process *process)
 {
     struct kinfo_proc p;
     if (!d->readProc(pid, &p))
         return false;
     d->readProcStat(&p, process);
     d->readProcStatus(&p, process);
     d->readProcStatm(&p, process);
     if (!d->readProcCmdline(pid, process))
         return false;
 
     return true;
 }
 
 QSet<long> ProcessesLocal::getAllPids()
 {
     QSet<long> pids;
     int mib[3];
     size_t len;
     size_t num;
     struct kinfo_proc *p;
 
     mib[0] = CTL_KERN;
     mib[1] = KERN_PROC;
     mib[2] = KERN_PROC_ALL;
     sysctl(mib, 3, NULL, &len, NULL, 0);
     p = (kinfo_proc *)malloc(len);
     sysctl(mib, 3, p, &len, NULL, 0);
 
     for (num = 0; num < len / sizeof(struct kinfo_proc); num++)
 #if defined(__FreeBSD__) && __FreeBSD_version >= 500015
         pids.insert(p[num].ki_pid);
 #elif defined(__DragonFly__) && __DragonFly_version >= 190000
         pids.insert(p[num].kp_pid);
 #else
         pids.insert(p[num].kp_proc.p_pid);
 #endif
     free(p);
     return pids;
 }
 
 Processes::Error ProcessesLocal::sendSignal(long pid, int sig)
 {
     if (kill((pid_t)pid, sig)) {
         // Kill failed
         return Processes::Unknown;
     }
     return Processes::NoError;
 }
 
 Processes::Error ProcessesLocal::setNiceness(long pid, int priority)
 {
     if (setpriority(PRIO_PROCESS, pid, priority)) {
         // set niceness failed
         return Processes::Unknown;
     }
     return Processes::NoError;
 }
 
 Processes::Error ProcessesLocal::setScheduler(long pid, int priorityClass, int priority)
 {
     if (priorityClass == KSysGuard::Process::Other || priorityClass == KSysGuard::Process::Batch)
         priority = 0;
     if (pid <= 0)
         return Processes::InvalidPid; // check the parameters
     return Processes::NotSupported;
 }
 
 Processes::Error ProcessesLocal::setIoNiceness(long pid, int priorityClass, int priority)
 {
     return Processes::NotSupported; // Not yet supported
 }
 
 bool ProcessesLocal::supportsIoNiceness()
 {
     return false;
 }
 
 long long ProcessesLocal::totalPhysicalMemory()
 {
     static int physmem_mib[] = {CTL_HW, HW_PHYSMEM};
     /* get the page size with "getpagesize" and calculate pageshift from
      * it */
     int pagesize = ::getpagesize();
     int pageshift = 0;
     while (pagesize > 1) {
         pageshift++;
         pagesize >>= 1;
     }
     size_t Total = 0;
     size_t size = sizeof(Total);
     sysctl(physmem_mib, 2, &Total, &size, NULL, 0);
     return Total /= 1024;
 }
 
 long int KSysGuard::ProcessesLocal::numberProcessorCores()
 {
     int mib[2];
     int ncpu;
     size_t len;
 
     mib[0] = CTL_HW;
     mib[1] = HW_NCPU;
     len = sizeof(ncpu);
 
     if (sysctl(mib, 2, &ncpu, &len, NULL, 0) == -1 || !len)
         return 1;
     return len;
 }
 ProcessesLocal::~ProcessesLocal()
 {
     delete d;
 }
 
 }