ViewVC Help
View File | Revision Log | Show Annotations | Revision Graph | Root Listing
root/i-scream/projects/libstatgrab/src/libstatgrab/process_stats.c
Revision: 1.55
Committed: Tue Apr 6 13:40:41 2004 UTC (20 years, 1 month ago) by tdb
Content type: text/plain
Branch: MAIN
Changes since 1.54: +79 -1 lines
Log Message:
Fix process stats on NetBSD 2.0 (beta).
Also fix the 5-processes-workaround Adam committed yesterday on the rest
of the BSD's (not just FreeBSD5).

File Contents

# User Rev Content
1 tdb 1.17 /*
2 pajs 1.1 * i-scream central monitoring system
3 tdb 1.8 * http://www.i-scream.org
4 tdb 1.17 * Copyright (C) 2000-2004 i-scream
5 pajs 1.1 *
6 tdb 1.17 * This library is free software; you can redistribute it and/or
7     * modify it under the terms of the GNU Lesser General Public
8     * License as published by the Free Software Foundation; either
9     * version 2.1 of the License, or (at your option) any later version.
10 pajs 1.1 *
11 tdb 1.17 * This library is distributed in the hope that it will be useful,
12 pajs 1.1 * but WITHOUT ANY WARRANTY; without even the implied warranty of
13 tdb 1.17 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
14     * Lesser General Public License for more details.
15 pajs 1.1 *
16 tdb 1.17 * You should have received a copy of the GNU Lesser General Public
17     * License along with this library; if not, write to the Free Software
18     * Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA
19     * 02111-1307 USA
20 tdb 1.18 *
21 tdb 1.55 * $Id: process_stats.c,v 1.54 2004/04/05 19:55:27 ats Exp $
22 pajs 1.1 */
23    
24     #ifdef HAVE_CONFIG_H
25     #include "config.h"
26     #endif
27    
28 pajs 1.6 #include "statgrab.h"
29 ats 1.48 #include "tools.h"
30     #include "vector.h"
31 pajs 1.6 #if defined(SOLARIS) || defined(LINUX)
32 pajs 1.1 #include <stdio.h>
33     #include <stdlib.h>
34 pajs 1.5 #include <sys/types.h>
35     #include <dirent.h>
36     #include <string.h>
37 pajs 1.6 #endif
38 pajs 1.1
39     #ifdef SOLARIS
40     #include <procfs.h>
41     #include <limits.h>
42 pajs 1.5 #define PROC_LOCATION "/proc"
43     #define MAX_FILE_LENGTH PATH_MAX
44     #endif
45     #ifdef LINUX
46 ats 1.16 #include <limits.h>
47 pajs 1.25 #include <unistd.h>
48     #include <sys/stat.h>
49     #include <fcntl.h>
50 pajs 1.1 #define PROC_LOCATION "/proc"
51     #define MAX_FILE_LENGTH PATH_MAX
52     #endif
53 ats 1.13 #ifdef ALLBSD
54 tdb 1.19 #include <stdlib.h>
55 pajs 1.6 #include <sys/param.h>
56     #include <sys/sysctl.h>
57 tdb 1.22 #if defined(FREEBSD) || defined(DFBSD)
58     #include <sys/user.h>
59     #else
60 tdb 1.19 #include <sys/proc.h>
61 ats 1.13 #endif
62 tdb 1.29 #include <string.h>
63     #include <paths.h>
64     #include <fcntl.h>
65     #include <limits.h>
66 tdb 1.41 #if (defined(FREEBSD) && !defined(FREEBSD5)) || defined(DFBSD)
67 tdb 1.29 #include <kvm.h>
68 tdb 1.43 #include <tools.h>
69 pajs 1.6 #endif
70 tdb 1.41 #include <unistd.h>
71 tdb 1.55 #ifdef NETBSD2
72     #include <sys/lwp.h>
73     #endif
74 tdb 1.41 #endif
75 pajs 1.1
76 ats 1.52 static void proc_state_init(sg_process_stats *s) {
77 ats 1.48 s->process_name = NULL;
78     s->proctitle = NULL;
79     }
80    
81 ats 1.52 static void proc_state_destroy(sg_process_stats *s) {
82 ats 1.48 free(s->process_name);
83     free(s->proctitle);
84     }
85    
86 ats 1.52 sg_process_stats *sg_get_process_stats(int *entries){
87     VECTOR_DECLARE_STATIC(proc_state, sg_process_stats, 64,
88 ats 1.48 proc_state_init, proc_state_destroy);
89     int proc_state_size = 0;
90 ats 1.52 sg_process_stats *proc_state_ptr;
91 tdb 1.26 #ifdef ALLBSD
92 tdb 1.37 int mib[4];
93 tdb 1.26 size_t size;
94     struct kinfo_proc *kp_stats;
95 tdb 1.41 int procs, i;
96 tdb 1.45 char *proctitle;
97 tdb 1.41 #if (defined(FREEBSD) && !defined(FREEBSD5)) || defined(DFBSD)
98 tdb 1.42 kvm_t *kvmd;
99 tdb 1.50 char **args, **argsp;
100     int argslen = 0;
101 tdb 1.41 #else
102 tdb 1.37 long buflen;
103     char *p;
104     #endif
105 tdb 1.55 #ifdef NETBSD2
106     int lwps;
107     struct kinfo_lwp *kl_stats;
108     #endif
109 tdb 1.26 #endif
110 pajs 1.24 #if defined(SOLARIS) || defined(LINUX)
111 pajs 1.23 DIR *proc_dir;
112     struct dirent *dir_entry;
113     char filename[MAX_FILE_LENGTH];
114     FILE *f;
115 pajs 1.24 #ifdef SOLARIS
116 pajs 1.5 psinfo_t process_info;
117 pajs 1.24 #endif
118 pajs 1.25 #ifdef LINUX
119     char s;
120     /* If someone has a executable of 4k filename length, they deserve to get it truncated :) */
121     char ps_name[4096];
122     char *ptr;
123 ats 1.48 VECTOR_DECLARE_STATIC(psargs, char, 128, NULL, NULL);
124 pajs 1.25 unsigned long stime, utime;
125     int x;
126     int fn;
127 ats 1.48 int len;
128     int rc;
129 pajs 1.25 #endif
130 pajs 1.1
131 pajs 1.23 if((proc_dir=opendir(PROC_LOCATION))==NULL){
132 ats 1.52 return NULL;
133 pajs 1.23 }
134    
135     while((dir_entry=readdir(proc_dir))!=NULL){
136     if(atoi(dir_entry->d_name) == 0) continue;
137    
138 pajs 1.24 #ifdef SOLARIS
139 pajs 1.23 snprintf(filename, MAX_FILE_LENGTH, "/proc/%s/psinfo", dir_entry->d_name);
140 pajs 1.24 #endif
141 pajs 1.25 #ifdef LINUX
142     snprintf(filename, MAX_FILE_LENGTH, "/proc/%s/stat", dir_entry->d_name);
143     #endif
144 pajs 1.23 if((f=fopen(filename, "r"))==NULL){
145     /* Open failed.. Process since vanished, or the path was too long.
146     * Ah well, move onwards to the next one */
147     continue;
148     }
149 pajs 1.24 #ifdef SOLARIS
150 pajs 1.23 fread(&process_info, sizeof(psinfo_t), 1, f);
151 pajs 1.25 #endif
152 pajs 1.1
153 ats 1.48 if (VECTOR_RESIZE(proc_state, proc_state_size + 1) < 0) {
154 ats 1.52 return NULL;
155 ats 1.48 }
156 pajs 1.23 proc_state_ptr = proc_state+proc_state_size;
157 ats 1.48
158 pajs 1.25 #ifdef SOLARIS
159 pajs 1.23 proc_state_ptr->pid = process_info.pr_pid;
160     proc_state_ptr->parent = process_info.pr_ppid;
161     proc_state_ptr->pgid = process_info.pr_pgid;
162     proc_state_ptr->uid = process_info.pr_uid;
163     proc_state_ptr->euid = process_info.pr_euid;
164     proc_state_ptr->gid = process_info.pr_gid;
165     proc_state_ptr->egid = process_info.pr_egid;
166     proc_state_ptr->proc_size = (process_info.pr_size) * 1024;
167     proc_state_ptr->proc_resident = (process_info.pr_rssize) * 1024;
168     proc_state_ptr->time_spent = process_info.pr_time.tv_sec;
169     proc_state_ptr->cpu_percent = (process_info.pr_pctcpu * 100.0) / 0x8000;
170     proc_state_ptr->process_name = strdup(process_info.pr_fname);
171     proc_state_ptr->proctitle = strdup(process_info.pr_psargs);
172 pajs 1.24
173 ats 1.52 if(process_info.pr_lwp.pr_state==1) proc_state_ptr->state = SG_PROCESS_STATE_SLEEPING;
174     if(process_info.pr_lwp.pr_state==2) proc_state_ptr->state = SG_PROCESS_STATE_RUNNING;
175     if(process_info.pr_lwp.pr_state==3) proc_state_ptr->state = SG_PROCESS_STATE_ZOMBIE;
176     if(process_info.pr_lwp.pr_state==4) proc_state_ptr->state = SG_PROCESS_STATE_STOPPED;
177     if(process_info.pr_lwp.pr_state==6) proc_state_ptr->state = SG_PROCESS_STATE_RUNNING;
178 pajs 1.25 #endif
179     #ifdef LINUX
180 ats 1.38 x = fscanf(f, "%d %4096s %c %d %d %*d %*d %*d %*u %*u %*u %*u %*u %lu %lu %*d %*d %*d %d %*d %*d %*u %llu %llu %*u %*u %*u %*u %*u %*u %*u %*u %*u %*u %*u %*u %*u %*d %*d\n", &(proc_state_ptr->pid), ps_name, &s, &(proc_state_ptr->parent), &(proc_state_ptr->pgid), &utime, &stime, &(proc_state_ptr->nice), &(proc_state_ptr->proc_size), &(proc_state_ptr->proc_resident));
181 pajs 1.25 proc_state_ptr->proc_resident = proc_state_ptr->proc_resident * getpagesize();
182 ats 1.52 if(s == 'S') proc_state_ptr->state = SG_PROCESS_STATE_SLEEPING;
183     if(s == 'R') proc_state_ptr->state = SG_PROCESS_STATE_RUNNING;
184     if(s == 'Z') proc_state_ptr->state = SG_PROCESS_STATE_ZOMBIE;
185     if(s == 'T') proc_state_ptr->state = SG_PROCESS_STATE_STOPPED;
186     if(s == 'D') proc_state_ptr->state = SG_PROCESS_STATE_STOPPED;
187 pajs 1.25
188     /* pa_name[0] should = '(' */
189     ptr = strchr(&ps_name[1], ')');
190     if(ptr !=NULL) *ptr='\0';
191 ats 1.48
192 ats 1.52 if (sg_update_string(&proc_state_ptr->process_name,
193 ats 1.53 &ps_name[1]) < 0) {
194 ats 1.52 return NULL;
195 ats 1.48 }
196 pajs 1.25
197     /* Need to do cpu */
198    
199    
200 ats 1.48 fclose(f);
201    
202 pajs 1.25 /* proctitle */
203     snprintf(filename, MAX_FILE_LENGTH, "/proc/%s/cmdline", dir_entry->d_name);
204    
205     if((fn=open(filename, O_RDONLY)) == -1){
206     /* Open failed.. Process since vanished, or the path was too long.
207     * Ah well, move onwards to the next one */
208     continue;
209     }
210 ats 1.48
211     #define READ_BLOCK_SIZE 128
212     len = 0;
213     do {
214 ats 1.53 if (VECTOR_RESIZE(psargs, len + READ_BLOCK_SIZE) < 0) {
215 ats 1.52 return NULL;
216 ats 1.48 }
217     rc = read(fn, psargs + len, READ_BLOCK_SIZE);
218     if (rc > 0) {
219     len += rc;
220     }
221     } while (rc == READ_BLOCK_SIZE);
222     close(fn);
223    
224     if (rc == -1) {
225     /* Read failed; move on. */
226     continue;
227 pajs 1.25 }
228    
229 ats 1.48 /* Turn \0s into spaces within the command line. */
230 pajs 1.25 ptr = psargs;
231 ats 1.48 for(x = 0; x < len; x++) {
232 pajs 1.25 if (*ptr == '\0') *ptr = ' ';
233     ptr++;
234     }
235    
236 ats 1.53 if (len == 0) {
237     /* We want psargs to be NULL. */
238     if (VECTOR_RESIZE(psargs, 0) < 0) {
239     return NULL;
240     }
241     } else {
242     /* Not empty, so append a \0. */
243     if (VECTOR_RESIZE(psargs, len + 1) < 0) {
244     return NULL;
245     }
246     psargs[len] = '\0';
247     }
248    
249     if (sg_update_string(&proc_state_ptr->proctitle, psargs) < 0) {
250 ats 1.52 return NULL;
251 ats 1.48 }
252 pajs 1.24 #endif
253 pajs 1.23
254     proc_state_size++;
255     }
256     closedir(proc_dir);
257 tdb 1.26 #endif
258    
259     #ifdef ALLBSD
260 tdb 1.36 mib[0] = CTL_KERN;
261     mib[1] = KERN_PROC;
262     mib[2] = KERN_PROC_ALL;
263    
264     if(sysctl(mib, 3, NULL, &size, NULL, 0) < 0) {
265 ats 1.52 return NULL;
266 tdb 1.36 }
267    
268     procs = size / sizeof(struct kinfo_proc);
269    
270     kp_stats = malloc(size);
271     if(kp_stats == NULL) {
272 ats 1.52 return NULL;
273 tdb 1.36 }
274 ats 1.54 memset(kp_stats, 0, size);
275 tdb 1.36
276     if(sysctl(mib, 3, kp_stats, &size, NULL, 0) < 0) {
277     free(kp_stats);
278 ats 1.52 return NULL;
279 tdb 1.36 }
280 tdb 1.33
281 tdb 1.37 #if (defined(FREEBSD) && !defined(FREEBSD5)) || defined(DFBSD)
282 ats 1.52 kvmd = sg_get_kvm2();
283 tdb 1.33 #endif
284 tdb 1.26
285     for (i = 0; i < procs; i++) {
286 ats 1.48 const char *name;
287 ats 1.54
288 tdb 1.55 #ifdef FREEBSD5
289 ats 1.54 if (kp_stats[i].ki_stat == 0) {
290 tdb 1.55 #else
291     if (kp_stats[i].kp_proc.p_stat == 0) {
292     #endif
293 ats 1.54 /* FreeBSD 5 deliberately overallocates the array that
294     * the sysctl returns, so we'll get a few junk
295     * processes on the end that we have to ignore. (Search
296     * for "overestimate by 5 procs" in
297     * src/sys/kern/kern_proc.c for more details.) */
298     continue;
299     }
300 ats 1.48
301     if (VECTOR_RESIZE(proc_state, proc_state_size + 1) < 0) {
302 ats 1.52 return NULL;
303 tdb 1.29 }
304 tdb 1.26 proc_state_ptr = proc_state+proc_state_size;
305 tdb 1.30
306     #ifdef FREEBSD5
307 ats 1.48 name = kp_stats[i].ki_comm;
308 tdb 1.35 #elif defined(DFBSD)
309 ats 1.48 name = kp_stats[i].kp_thread.td_comm;
310 tdb 1.30 #else
311 ats 1.48 name = kp_stats[i].kp_proc.p_comm;
312 tdb 1.30 #endif
313 ats 1.53 if (sg_update_string(&proc_state_ptr->process_name, name) < 0) {
314 ats 1.52 return NULL;
315 ats 1.48 }
316 tdb 1.29
317 tdb 1.37 #if defined(FREEBSD5) || defined(NETBSD) || defined(OPENBSD)
318     size = sizeof(buflen);
319    
320     #ifdef FREEBSD5
321     if(sysctlbyname("kern.ps_arg_cache_limit", &buflen, &size, NULL, 0) < 0) {
322 ats 1.52 return NULL;
323 tdb 1.37 }
324     #else
325     mib[1] = KERN_ARGMAX;
326    
327     if(sysctl(mib, 2, &buflen, &size, NULL, 0) < 0) {
328 ats 1.52 return NULL;
329 tdb 1.37 }
330     #endif
331    
332     proctitle = malloc(buflen);
333     if(proctitle == NULL) {
334 ats 1.52 return NULL;
335 tdb 1.37 }
336    
337     size = buflen;
338    
339     #ifdef FREEBSD5
340     mib[2] = KERN_PROC_ARGS;
341     mib[3] = kp_stats[i].ki_pid;
342     #else
343     mib[1] = KERN_PROC_ARGS;
344     mib[2] = kp_stats[i].kp_proc.p_pid;
345     mib[3] = KERN_PROC_ARGV;
346     #endif
347    
348 ats 1.48 free(proc_state_ptr->proctitle);
349 tdb 1.37 if(sysctl(mib, 4, proctitle, &size, NULL, 0) < 0) {
350     free(proctitle);
351     proc_state_ptr->proctitle = NULL;
352     }
353     else if(size > 0) {
354 tdb 1.44 proc_state_ptr->proctitle = malloc(size+1);
355 tdb 1.37 if(proc_state_ptr->proctitle == NULL) {
356 ats 1.52 return NULL;
357 tdb 1.29 }
358 tdb 1.37 p = proctitle;
359 ats 1.49 proc_state_ptr->proctitle[0] = '\0';
360 tdb 1.37 do {
361 ats 1.52 sg_strlcat(proc_state_ptr->proctitle, p, size+1);
362     sg_strlcat(proc_state_ptr->proctitle, " ", size+1);
363 tdb 1.37 p += strlen(p) + 1;
364     } while (p < proctitle + size);
365     free(proctitle);
366 tdb 1.45 /* remove trailing space */
367     proc_state_ptr->proctitle[strlen(proc_state_ptr->proctitle)-1] = '\0';
368 tdb 1.37 }
369     else {
370     free(proctitle);
371     proc_state_ptr->proctitle = NULL;
372     }
373     #else
374 ats 1.48 free(proc_state_ptr->proctitle);
375 tdb 1.37 if(kvmd != NULL) {
376     args = kvm_getargv(kvmd, &(kp_stats[i]), 0);
377     if(args != NULL) {
378 tdb 1.50 argsp = args;
379     while(*argsp != NULL) {
380 tdb 1.51 argslen += strlen(*argsp) + 1;
381     argsp++;
382 tdb 1.50 }
383     proctitle = malloc(argslen + 1);
384     proctitle[0] = '\0';
385 tdb 1.37 if(proctitle == NULL) {
386 ats 1.52 return NULL;
387 tdb 1.37 }
388     while(*args != NULL) {
389 ats 1.52 sg_strlcat(proctitle, *args, argslen + 1);
390     sg_strlcat(proctitle, " ", argslen + 1);
391 tdb 1.37 args++;
392 tdb 1.29 }
393 tdb 1.37 /* remove trailing space */
394 tdb 1.45 proctitle[strlen(proctitle)-1] = '\0';
395 tdb 1.37 proc_state_ptr->proctitle = proctitle;
396     }
397     else {
398     proc_state_ptr->proctitle = NULL;
399 tdb 1.29 }
400     }
401     else {
402 tdb 1.37 proc_state_ptr->proctitle = NULL;
403 tdb 1.29 }
404 tdb 1.37 #endif
405 tdb 1.26
406 tdb 1.30 #ifdef FREEBSD5
407 tdb 1.26 proc_state_ptr->pid = kp_stats[i].ki_pid;
408     proc_state_ptr->parent = kp_stats[i].ki_ppid;
409     proc_state_ptr->pgid = kp_stats[i].ki_pgid;
410 tdb 1.30 #else
411     proc_state_ptr->pid = kp_stats[i].kp_proc.p_pid;
412     proc_state_ptr->parent = kp_stats[i].kp_eproc.e_ppid;
413     proc_state_ptr->pgid = kp_stats[i].kp_eproc.e_pgid;
414     #endif
415 tdb 1.26
416 tdb 1.30 #ifdef FREEBSD5
417 tdb 1.26 proc_state_ptr->uid = kp_stats[i].ki_ruid;
418     proc_state_ptr->euid = kp_stats[i].ki_uid;
419     proc_state_ptr->gid = kp_stats[i].ki_rgid;
420     proc_state_ptr->egid = kp_stats[i].ki_svgid;
421 tdb 1.35 #elif defined(DFBSD)
422     proc_state_ptr->uid = kp_stats[i].kp_eproc.e_ucred.cr_ruid;
423     proc_state_ptr->euid = kp_stats[i].kp_eproc.e_ucred.cr_svuid;
424     proc_state_ptr->gid = kp_stats[i].kp_eproc.e_ucred.cr_rgid;
425     proc_state_ptr->egid = kp_stats[i].kp_eproc.e_ucred.cr_svgid;
426 tdb 1.30 #else
427     proc_state_ptr->uid = kp_stats[i].kp_eproc.e_pcred.p_ruid;
428     proc_state_ptr->euid = kp_stats[i].kp_eproc.e_pcred.p_svuid;
429     proc_state_ptr->gid = kp_stats[i].kp_eproc.e_pcred.p_rgid;
430     proc_state_ptr->egid = kp_stats[i].kp_eproc.e_pcred.p_svgid;
431     #endif
432 tdb 1.26
433 tdb 1.30 #ifdef FREEBSD5
434 tdb 1.26 proc_state_ptr->proc_size = kp_stats[i].ki_size;
435     /* This is in pages */
436 tdb 1.30 proc_state_ptr->proc_resident =
437     kp_stats[i].ki_rssize * getpagesize();
438 tdb 1.28 /* This is in microseconds */
439 tdb 1.26 proc_state_ptr->time_spent = kp_stats[i].ki_runtime / 1000000;
440 tdb 1.30 proc_state_ptr->cpu_percent =
441     ((double)kp_stats[i].ki_pctcpu / FSCALE) * 100.0;
442 tdb 1.26 proc_state_ptr->nice = kp_stats[i].ki_nice;
443 tdb 1.30 #else
444     proc_state_ptr->proc_size =
445     kp_stats[i].kp_eproc.e_vm.vm_map.size;
446     /* This is in pages */
447     proc_state_ptr->proc_resident =
448     kp_stats[i].kp_eproc.e_vm.vm_rssize * getpagesize();
449 tdb 1.34 #if defined(NETBSD) || defined(OPENBSD)
450 tdb 1.33 proc_state_ptr->time_spent =
451     kp_stats[i].kp_proc.p_rtime.tv_sec;
452 tdb 1.35 #elif defined(DFBSD)
453     proc_state_ptr->time_spent =
454     ( kp_stats[i].kp_thread.td_uticks +
455     kp_stats[i].kp_thread.td_sticks +
456     kp_stats[i].kp_thread.td_iticks ) / 1000000;
457 tdb 1.33 #else
458 tdb 1.36 /* This is in microseconds */
459 tdb 1.30 proc_state_ptr->time_spent =
460     kp_stats[i].kp_proc.p_runtime / 1000000;
461 tdb 1.33 #endif
462 tdb 1.30 proc_state_ptr->cpu_percent =
463     ((double)kp_stats[i].kp_proc.p_pctcpu / FSCALE) * 100.0;
464     proc_state_ptr->nice = kp_stats[i].kp_proc.p_nice;
465     #endif
466 tdb 1.26
467 tdb 1.55 #ifdef NETBSD2
468     {
469     size_t size;
470     int mib[5];
471    
472     mib[0] = CTL_KERN;
473     mib[1] = KERN_LWP;
474     mib[2] = kp_stats[i].kp_proc.p_pid;
475     mib[3] = sizeof(struct kinfo_lwp);
476     mib[4] = 0;
477    
478     if(sysctl(mib, 5, NULL, &size, NULL, 0) < 0) {
479     return NULL;
480     }
481    
482     lwps = size / sizeof(struct kinfo_lwp);
483     mib[4] = lwps;
484    
485     kl_stats = malloc(size);
486     if(kl_stats == NULL) {
487     return NULL;
488     }
489    
490     if(sysctl(mib, 5, kl_stats, &size, NULL, 0) < 0) {
491     return NULL;
492     }
493     }
494    
495     switch(kp_stats[i].kp_proc.p_stat) {
496     case SIDL:
497     proc_state_ptr->state = SG_PROCESS_STATE_RUNNING;
498     break;
499     case SACTIVE:
500     {
501     int i;
502    
503     for(i = 0; i < lwps; i++) {
504     switch(kl_stats[i].l_stat) {
505     case LSONPROC:
506     case LSRUN:
507     proc_state_ptr->state = SG_PROCESS_STATE_RUNNING;
508     goto end;
509     case LSSLEEP:
510     proc_state_ptr->state = SG_PROCESS_STATE_SLEEPING;
511     goto end;
512     case LSSTOP:
513     case LSSUSPENDED:
514     proc_state_ptr->state = SG_PROCESS_STATE_STOPPED;
515     goto end;
516     }
517     proc_state_ptr->state = SG_PROCESS_STATE_UNKNOWN;
518     }
519     end: ;
520     }
521     break;
522     case SSTOP:
523     proc_state_ptr->state = SG_PROCESS_STATE_STOPPED;
524     break;
525     case SZOMB:
526     proc_state_ptr->state = SG_PROCESS_STATE_ZOMBIE;
527     break;
528     default:
529     proc_state_ptr->state = SG_PROCESS_STATE_UNKNOWN;
530     break;
531     }
532     #else
533 tdb 1.30 #ifdef FREEBSD5
534 tdb 1.26 switch (kp_stats[i].ki_stat) {
535 tdb 1.30 #else
536     switch (kp_stats[i].kp_proc.p_stat) {
537     #endif
538 tdb 1.26 case SIDL:
539     case SRUN:
540     #ifdef SONPROC
541     case SONPROC: /* NetBSD */
542     #endif
543 ats 1.52 proc_state_ptr->state = SG_PROCESS_STATE_RUNNING;
544 tdb 1.26 break;
545     case SSLEEP:
546     #ifdef SWAIT
547     case SWAIT: /* FreeBSD 5 */
548     #endif
549     #ifdef SLOCK
550     case SLOCK: /* FreeBSD 5 */
551     #endif
552 ats 1.52 proc_state_ptr->state = SG_PROCESS_STATE_SLEEPING;
553 tdb 1.26 break;
554     case SSTOP:
555 ats 1.52 proc_state_ptr->state = SG_PROCESS_STATE_STOPPED;
556 tdb 1.26 break;
557     case SZOMB:
558     #ifdef SDEAD
559     case SDEAD: /* OpenBSD & NetBSD */
560     #endif
561 ats 1.52 proc_state_ptr->state = SG_PROCESS_STATE_ZOMBIE;
562 tdb 1.31 break;
563     default:
564 ats 1.52 proc_state_ptr->state = SG_PROCESS_STATE_UNKNOWN;
565 tdb 1.26 break;
566     }
567 tdb 1.55 #endif
568 tdb 1.26 proc_state_size++;
569     }
570    
571     free(kp_stats);
572 tdb 1.47 #endif
573    
574     #ifdef CYGWIN
575 ats 1.52 return NULL;
576 tdb 1.26 #endif
577    
578 ats 1.52 *entries = proc_state_size;
579     return proc_state;
580 tdb 1.27 }
581    
582 ats 1.52 sg_process_count *sg_get_process_count() {
583     static sg_process_count process_stat;
584     sg_process_stats *ps;
585 tdb 1.27 int ps_size, x;
586    
587 tdb 1.30 process_stat.sleeping = 0;
588     process_stat.running = 0;
589     process_stat.zombie = 0;
590     process_stat.stopped = 0;
591     process_stat.total = 0;
592 tdb 1.27
593 ats 1.52 ps = sg_get_process_stats(&ps_size);
594     if (ps == NULL) {
595 tdb 1.32 return NULL;
596     }
597 tdb 1.27
598     for(x = 0; x < ps_size; x++) {
599     switch (ps->state) {
600 ats 1.52 case SG_PROCESS_STATE_RUNNING:
601 tdb 1.27 process_stat.running++;
602     break;
603 ats 1.52 case SG_PROCESS_STATE_SLEEPING:
604 tdb 1.27 process_stat.sleeping++;
605     break;
606 ats 1.52 case SG_PROCESS_STATE_STOPPED:
607 tdb 1.27 process_stat.stopped++;
608     break;
609 ats 1.52 case SG_PROCESS_STATE_ZOMBIE:
610 tdb 1.27 process_stat.zombie++;
611 ats 1.40 break;
612     default:
613 ats 1.52 /* currently no mapping for SG_PROCESS_STATE_UNKNOWN in
614     * sg_process_count */
615 tdb 1.27 break;
616     }
617     ps++;
618     }
619    
620     process_stat.total = ps_size;
621    
622     return &process_stat;
623 pajs 1.23 }