ViewVC Help
View File | Revision Log | Show Annotations | Revision Graph | Root Listing
root/i-scream/projects/libstatgrab/src/libstatgrab/process_stats.c
(Generate patch)

Comparing projects/libstatgrab/src/libstatgrab/process_stats.c (file contents):
Revision 1.27 by tdb, Fri Apr 2 21:20:23 2004 UTC vs.
Revision 1.34 by tdb, Sun Apr 4 11:46:08 2004 UTC

# Line 57 | Line 57
57   #else
58   #include <sys/proc.h>
59   #endif
60 + #include <string.h>
61 + #include <paths.h>
62 + #include <fcntl.h>
63 + #include <limits.h>
64 + #include <kvm.h>
65   #endif
66  
67   int get_proc_snapshot(proc_state_t **ps){
# Line 67 | Line 72 | int get_proc_snapshot(proc_state_t **ps){
72          int mib[3];
73          size_t size;
74          struct kinfo_proc *kp_stats;
75 <        int procs, i;
75 >        int procs, i, alloc;
76 >        static kvm_t *kvmd;
77 >        char **args;
78 >        char *proctitle;
79   #endif
80   #if defined(SOLARIS) || defined(LINUX)
81          DIR *proc_dir;
# Line 199 | Line 207 | int get_proc_snapshot(proc_state_t **ps){
207   #endif
208  
209   #ifdef ALLBSD
202 –        mib[0] = CTL_KERN;
203 –        mib[1] = KERN_PROC;
204 –        mib[2] = KERN_PROC_ALL;
210  
211 <        if (sysctl(mib, 3, NULL, &size, NULL, 0) < 0) {
212 <                return NULL;
213 <        }
211 > #if defined(NETBSD) || defined(OPENBSD)
212 >        kvmd = kvm_openfiles(NULL, NULL, NULL, O_RDONLY, NULL);
213 > #else
214 >        kvmd = kvm_openfiles(_PATH_DEVNULL, _PATH_DEVNULL, NULL, O_RDONLY, NULL);
215 > #endif
216  
217 <        procs = size / sizeof(struct kinfo_proc);
217 >        if(kvmd == NULL) return NULL;
218  
219 <        kp_stats = malloc(size);
213 <        if (kp_stats == NULL) {
214 <                return NULL;
215 <        }
219 >        kp_stats = kvm_getprocs(kvmd, KERN_PROC_ALL, 0, &procs);
220  
221 <        if (sysctl(mib, 3, kp_stats, &size, NULL, 0) < 0) {
218 <                free(kp_stats);
221 >        if (kp_stats == NULL || procs < 0) {
222                  return NULL;
223          }
224  
225          for (i = 0; i < procs; i++) {
226 <                proc_state = realloc(proc_state, (1+proc_state_size)*sizeof(proc_state_t));
226 >                /* replace with something more sensible */
227 >                proc_state = realloc(proc_state,
228 >                                (1+proc_state_size)*sizeof(proc_state_t));
229 >                if(proc_state == NULL ) {
230 >                        return NULL;
231 >                }
232                  proc_state_ptr = proc_state+proc_state_size;
225 –                
226 –                proc_state_ptr->process_name = strdup(kp_stats[i].ki_comm);
227 –                /* Seems we don't have access to that bit of memory */
228 –                /*proc_state_ptr->proctitle = strdup(kp_stats[i].ki_args->ar_args);*/
233  
234 + #ifdef FREEBSD5
235 +                proc_state_ptr->process_name =
236 +                        strdup(kp_stats[i].ki_comm);
237 + #else
238 +                proc_state_ptr->process_name =
239 +                        strdup(kp_stats[i].kp_proc.p_comm);
240 + #endif
241 +
242 +                args = kvm_getargv(kvmd, &(kp_stats[i]), 0);
243 +                if(args != NULL) {
244 +                        alloc = 1;
245 +                        proctitle = malloc(alloc);
246 +                        if(proctitle == NULL) {
247 +                                return NULL;
248 +                        }
249 +                        while(*args != NULL) {
250 +                                if(strlen(proctitle) + strlen(*args) >= alloc) {
251 +                                        alloc = (alloc + strlen(*args)) << 1;
252 +                                        proctitle = realloc(proctitle, alloc);
253 +                                        if(proctitle == NULL) {
254 +                                                return NULL;
255 +                                        }
256 +                                }
257 +                                strncat(proctitle, *args, strlen(*args));
258 +                                strncat(proctitle, " ", 1);
259 +                                args++;
260 +                        }
261 +                        /* remove trailing space */
262 +                        proctitle[strlen(proctitle)-1] = NULL;
263 +                        proc_state_ptr->proctitle = proctitle;
264 +                }
265 +                else {
266 +                        proc_state_ptr->proctitle =
267 +                                malloc(strlen(proc_state_ptr->process_name)+4);
268 +                        if(proc_state_ptr->proctitle == NULL) {
269 +                                return NULL;
270 +                        }
271 +                        sprintf(proc_state_ptr->proctitle, " (%s)",
272 +                                proc_state_ptr->process_name);
273 +                }
274 +
275 + #ifdef FREEBSD5
276                  proc_state_ptr->pid = kp_stats[i].ki_pid;
277                  proc_state_ptr->parent = kp_stats[i].ki_ppid;
278                  proc_state_ptr->pgid = kp_stats[i].ki_pgid;
279 + #else
280 +                proc_state_ptr->pid = kp_stats[i].kp_proc.p_pid;
281 +                proc_state_ptr->parent = kp_stats[i].kp_eproc.e_ppid;
282 +                proc_state_ptr->pgid = kp_stats[i].kp_eproc.e_pgid;
283 + #endif
284  
285 + #ifdef FREEBSD5
286                  proc_state_ptr->uid = kp_stats[i].ki_ruid;
287                  proc_state_ptr->euid = kp_stats[i].ki_uid;
288                  proc_state_ptr->gid = kp_stats[i].ki_rgid;
289                  proc_state_ptr->egid = kp_stats[i].ki_svgid;
290 + #else
291 +                proc_state_ptr->uid = kp_stats[i].kp_eproc.e_pcred.p_ruid;
292 +                proc_state_ptr->euid = kp_stats[i].kp_eproc.e_pcred.p_svuid;
293 +                proc_state_ptr->gid = kp_stats[i].kp_eproc.e_pcred.p_rgid;
294 +                proc_state_ptr->egid = kp_stats[i].kp_eproc.e_pcred.p_svgid;
295 + #endif
296  
297 + #ifdef FREEBSD5
298                  proc_state_ptr->proc_size = kp_stats[i].ki_size;
299                  /* This is in pages */
300 <                proc_state_ptr->proc_resident = kp_stats[i].ki_rssize * getpagesize();
301 <                /* This seems to be in microseconds */
300 >                proc_state_ptr->proc_resident =
301 >                        kp_stats[i].ki_rssize * getpagesize();
302 >                /* This is in microseconds */
303                  proc_state_ptr->time_spent = kp_stats[i].ki_runtime / 1000000;
304 <                proc_state_ptr->cpu_percent = kp_stats[i].ki_pctcpu;
304 >                proc_state_ptr->cpu_percent =
305 >                        ((double)kp_stats[i].ki_pctcpu / FSCALE) * 100.0;
306                  proc_state_ptr->nice = kp_stats[i].ki_nice;
307 + #else
308 +                proc_state_ptr->proc_size =
309 +                        kp_stats[i].kp_eproc.e_vm.vm_map.size;
310 +                /* This is in pages */
311 +                proc_state_ptr->proc_resident =
312 +                        kp_stats[i].kp_eproc.e_vm.vm_rssize * getpagesize();
313 +                /* This is in microseconds */
314 + #if defined(NETBSD) || defined(OPENBSD)
315 +                proc_state_ptr->time_spent =
316 +                        kp_stats[i].kp_proc.p_rtime.tv_sec;
317 + #else
318 +                proc_state_ptr->time_spent =
319 +                        kp_stats[i].kp_proc.p_runtime / 1000000;
320 + #endif
321 +                proc_state_ptr->cpu_percent =
322 +                        ((double)kp_stats[i].kp_proc.p_pctcpu / FSCALE) * 100.0;
323 +                proc_state_ptr->nice = kp_stats[i].kp_proc.p_nice;
324 + #endif
325  
326 + #ifdef FREEBSD5
327                  switch (kp_stats[i].ki_stat) {
328 + #else
329 +                switch (kp_stats[i].kp_proc.p_stat) {
330 + #endif
331                  case SIDL:
332                  case SRUN:
333   #ifdef SONPROC
# Line 270 | Line 353 | int get_proc_snapshot(proc_state_t **ps){
353   #endif
354                          proc_state_ptr->state = ZOMBIE;
355                          break;
356 +                default:
357 +                        proc_state_ptr->state = UNKNOWN;
358 +                        break;
359                  }
360                  proc_state_size++;
361          }
# Line 286 | Line 372 | process_stat_t *get_process_stats() {
372          proc_state_t *ps;
373          int ps_size, x;
374  
375 <        process_stat.sleeping=0;
376 <        process_stat.running=0;
377 <        process_stat.zombie=0;
378 <        process_stat.stopped=0;
379 <        process_stat.total=0;
375 >        process_stat.sleeping = 0;
376 >        process_stat.running = 0;
377 >        process_stat.zombie = 0;
378 >        process_stat.stopped = 0;
379 >        process_stat.total = 0;
380  
381          ps_size = get_proc_snapshot(&ps);
382  
383 +        if(ps_size == NULL) {
384 +                return NULL;
385 +        }
386 +
387          for(x = 0; x < ps_size; x++) {
388                  switch (ps->state) {
389 +                /* currently no mapping for UNKNOWN in process_stat_t */
390                  case RUNNING:
391                          process_stat.running++;
392                          break;

Diff Legend

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