[ViewVC] Diff of: i-scream/projects/libstatgrab/src/libstatgrab/process

Comparing projects/libstatgrab/src/libstatgrab/process_stats.c (file contents):
Revision 1.25 by pajs, Tue Mar 30 13:41:31 2004 UTC vs.
Revision 1.32 by tdb, Sun Apr 4 11:02:30 2004 UTC

+#else
+#include <sys/proc.h>
+#endif
-+
+#include <string.h>
-+
+#include <paths.h>
-+
+#include <fcntl.h>
-+
+#include <limits.h>
-+
+#include <kvm.h>
+#endif
+int get_proc_snapshot(proc_state_t **ps){
+        proc_state_t *proc_state = NULL;
+        proc_state_t *proc_state_ptr;
+        int proc_state_size = 0;
-+
+#ifdef ALLBSD
-+
+        int mib[3];
-+
+        size_t size;
-+
+        struct kinfo_proc *kp_stats;
-+
+        int procs, i, alloc;
-+
+        static kvm_t *kvmd;
-+
+        char **args;
-+
+        char *proctitle;
-+
+#endif
+#if defined(SOLARIS) || defined(LINUX)
+        DIR *proc_dir;
+        struct dirent *dir_entry;
+#endif
+                proc_state_size++;
-–
+#endif
-–
+                fclose(f);
+        closedir(proc_dir);
-<
+        *ps = proc_state;
->
+#endif
-+
+#ifdef ALLBSD
-+
+        kvmd = kvm_openfiles(_PATH_DEVNULL, _PATH_DEVNULL, NULL, O_RDONLY, NULL);
-+
-+
+        if(kvmd == NULL) return NULL;
-+
-+
+        kp_stats = kvm_getprocs(kvmd, KERN_PROC_ALL, 0, &procs);
-+
-+
+        if (kp_stats == NULL || procs < 0) {
-+
+                return NULL;
-+
+        }
-+
-+
+        for (i = 0; i < procs; i++) {
-+
+                /* replace with something more sensible */
-+
+                proc_state = realloc(proc_state,
-+
+                                (1+proc_state_size)*sizeof(proc_state_t));
-+
+                if(proc_state == NULL ) {
-+
+                        return NULL;
-+
+                }
-+
+                proc_state_ptr = proc_state+proc_state_size;
-+
-+
+#ifdef FREEBSD5
-+
+                proc_state_ptr->process_name =
-+
+                        strdup(kp_stats[i].ki_comm);
-+
+#else
-+
+                proc_state_ptr->process_name =
-+
+                        strdup(kp_stats[i].kp_proc.p_comm);
-+
+#endif
-+
-+
+                args = kvm_getargv(kvmd, &(kp_stats[i]), 0);
-+
+                if(args != NULL) {
-+
+                        alloc = 1;
-+
+                        proctitle = malloc(alloc);
-+
+                        if(proctitle == NULL) {
-+
+                                return NULL;
-+
+                        }
-+
+                        while(*args != NULL) {
-+
+                                if(strlen(proctitle) + strlen(*args) >= alloc) {
-+
+                                        alloc = (alloc + strlen(*args)) << 1;
-+
+                                        proctitle = realloc(proctitle, alloc);
-+
+                                        if(proctitle == NULL) {
-+
+                                                return NULL;
-+
+                                        }
-+
+                                }
-+
+                                strncat(proctitle, *args, strlen(*args));
-+
+                                strncat(proctitle, " ", 1);
-+
+                                args++;
-+
+                        }
-+
+                        /* remove trailing space */
-+
+                        proctitle[strlen(proctitle)-1] = NULL;
-+
+                        proc_state_ptr->proctitle = proctitle;
-+
+                }
-+
+                else {
-+
+                        proc_state_ptr->proctitle =
-+
+                                malloc(strlen(proc_state_ptr->process_name)+4);
-+
+                        if(proc_state_ptr->proctitle == NULL) {
-+
+                                return NULL;
-+
+                        }
-+
+                        sprintf(proc_state_ptr->proctitle, " (%s)",
-+
+                                proc_state_ptr->process_name);
-+
+                }
-+
-+
+#ifdef FREEBSD5
-+
+                proc_state_ptr->pid = kp_stats[i].ki_pid;
-+
+                proc_state_ptr->parent = kp_stats[i].ki_ppid;
-+
+                proc_state_ptr->pgid = kp_stats[i].ki_pgid;
-+
+#else
-+
+                proc_state_ptr->pid = kp_stats[i].kp_proc.p_pid;
-+
+                proc_state_ptr->parent = kp_stats[i].kp_eproc.e_ppid;
-+
+                proc_state_ptr->pgid = kp_stats[i].kp_eproc.e_pgid;
-+
+#endif
-+
-+
+#ifdef FREEBSD5
-+
+                proc_state_ptr->uid = kp_stats[i].ki_ruid;
-+
+                proc_state_ptr->euid = kp_stats[i].ki_uid;
-+
+                proc_state_ptr->gid = kp_stats[i].ki_rgid;
-+
+                proc_state_ptr->egid = kp_stats[i].ki_svgid;
-+
+#else
-+
+                proc_state_ptr->uid = kp_stats[i].kp_eproc.e_pcred.p_ruid;
-+
+                proc_state_ptr->euid = kp_stats[i].kp_eproc.e_pcred.p_svuid;
-+
+                proc_state_ptr->gid = kp_stats[i].kp_eproc.e_pcred.p_rgid;
-+
+                proc_state_ptr->egid = kp_stats[i].kp_eproc.e_pcred.p_svgid;
-+
+#endif
-+
-+
+#ifdef FREEBSD5
-+
+                proc_state_ptr->proc_size = kp_stats[i].ki_size;
-+
+                /* This is in pages */
-+
+                proc_state_ptr->proc_resident =
-+
+                        kp_stats[i].ki_rssize * getpagesize();
-+
+                /* This is in microseconds */
-+
+                proc_state_ptr->time_spent = kp_stats[i].ki_runtime / 1000000;
-+
+                proc_state_ptr->cpu_percent =
-+
+                        ((double)kp_stats[i].ki_pctcpu / FSCALE) * 100.0;
-+
+                proc_state_ptr->nice = kp_stats[i].ki_nice;
-+
+#else
-+
+                proc_state_ptr->proc_size =
-+
+                        kp_stats[i].kp_eproc.e_vm.vm_map.size;
-+
+                /* This is in pages */
-+
+                proc_state_ptr->proc_resident =
-+
+                        kp_stats[i].kp_eproc.e_vm.vm_rssize * getpagesize();
-+
+                /* This is in microseconds */
-+
+                proc_state_ptr->time_spent =
-+
+                        kp_stats[i].kp_proc.p_runtime / 1000000;
-+
+                proc_state_ptr->cpu_percent =
-+
+                        ((double)kp_stats[i].kp_proc.p_pctcpu / FSCALE) * 100.0;
-+
+                proc_state_ptr->nice = kp_stats[i].kp_proc.p_nice;
-+
+#endif
-+
-+
+#ifdef FREEBSD5
-+
+                switch (kp_stats[i].ki_stat) {
-+
+#else
-+
+                switch (kp_stats[i].kp_proc.p_stat) {
-+
+#endif
-+
+                case SIDL:
-+
+                case SRUN:
-+
+#ifdef SONPROC
-+
+                case SONPROC: /* NetBSD */
-+
+#endif
-+
+                        proc_state_ptr->state = RUNNING;
-+
+                        break;
-+
+                case SSLEEP:
-+
+#ifdef SWAIT
-+
+                case SWAIT: /* FreeBSD 5 */
-+
+#endif
-+
+#ifdef SLOCK
-+
+                case SLOCK: /* FreeBSD 5 */
-+
+#endif
-+
+                        proc_state_ptr->state = SLEEPING;
-+
+                        break;
-+
+                case SSTOP:
-+
+                        proc_state_ptr->state = STOPPED;
-+
+                        break;
-+
+                case SZOMB:
-+
+#ifdef SDEAD
-+
+                case SDEAD: /* OpenBSD & NetBSD */
-+
+#endif
-+
+                        proc_state_ptr->state = ZOMBIE;
-+
+                        break;
-+
+                default:
-+
+                        proc_state_ptr->state = UNKNOWN;
-+
+                        break;
-+
+                }
-+
+                proc_state_size++;
-+
+        }
-+
-+
+        free(kp_stats);
-+
+#endif
-+
-+
+        *ps = proc_state;
+        return proc_state_size;
-+
+process_stat_t *get_process_stats() {
-+
+        static process_stat_t process_stat;
-+
+        proc_state_t *ps;
-+
+        int ps_size, x;
-+
-+
+        process_stat.sleeping = 0;
-+
+        process_stat.running = 0;
-+
+        process_stat.zombie = 0;
-+
+        process_stat.stopped = 0;
-+
+        process_stat.total = 0;
-+
-+
+        ps_size = get_proc_snapshot(&ps);
-+
-+
+        if(ps_size == NULL) {
-+
+                return NULL;
-+
+        }
-+
-+
+        for(x = 0; x < ps_size; x++) {
-+
+                switch (ps->state) {
-+
+                /* currently no mapping for UNKNOWN in process_stat_t */
-+
+                case RUNNING:
-+
+                        process_stat.running++;
-+
+                        break;
-+
+                case SLEEPING:
-+
+                        process_stat.sleeping++;
-+
+                        break;
-+
+                case STOPPED:
-+
+                        process_stat.stopped++;
-+
+                        break;
-+
+                case ZOMBIE:
-+
+                        process_stat.zombie++;
-+
+                        break;
-+
+                }
-+
+                ps++;
-+
+        }
-+
-+
+        process_stat.total = ps_size;
-+
-+
+        return &process_stat;
-+
+}

Diff Legend

-–
+Removed lines
-+
+Added lines
-<
+Changed lines
->
+Changed lines

Comparing projects/libstatgrab/src/libstatgrab/process_stats.c (file contents): Revision 1.25 by pajs, Tue Mar 30 13:41:31 2004 UTC vs. Revision 1.32 by tdb, Sun Apr 4 11:02:30 2004 UTC

Diff Legend

Comparing projects/libstatgrab/src/libstatgrab/process_stats.c (file contents):
Revision 1.25 by pajs, Tue Mar 30 13:41:31 2004 UTC vs.
Revision 1.32 by tdb, Sun Apr 4 11:02:30 2004 UTC