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.64 by pajs, Wed Apr 7 15:46:34 2004 UTC vs.
Revision 1.71 by tdb, Thu Apr 8 17:20:51 2004 UTC

# Line 51 | Line 51
51   #define MAX_FILE_LENGTH PATH_MAX
52   #endif
53   #ifdef ALLBSD
54 + #include <errno.h>
55   #include <stdlib.h>
56   #include <sys/param.h>
57   #include <sys/sysctl.h>
# Line 99 | Line 100 | sg_process_stats *sg_get_process_stats(int *entries){
100          int argslen = 0;
101   #else
102          long buflen;
103 <        char *p;
103 >        char *p, *proctitletmp;
104   #endif
105   #ifdef NETBSD2
106          int lwps;
# Line 130 | Line 131 | sg_process_stats *sg_get_process_stats(int *entries){
131  
132   #ifdef LINUX
133          if ((f=fopen("/proc/uptime", "r")) == NULL) {
134 +                sg_set_error(SG_ERROR_OPEN, "/proc/uptime");
135                  return NULL;
136          }
137          if((fscanf(f,"%lu %*d",&uptime)) != 1){
138 +                sg_set_error(SG_ERROR_PARSE, NULL);
139                  return NULL;
140          }
141          fclose(f);
142   #endif
143  
144          if((proc_dir=opendir(PROC_LOCATION))==NULL){
145 +                sg_set_error(SG_ERROR_OPENDIR, PROC_LOCATION);
146                  return NULL;
147          }
148  
# Line 303 | Line 307 | sg_process_stats *sg_get_process_stats(int *entries){
307          mib[2] = KERN_PROC_ALL;
308  
309          if(sysctl(mib, 3, NULL, &size, NULL, 0) < 0) {
310 +                sg_set_error(SG_ERROR_SYSCTL, "CTL_KERN.KERN_PROC.KERN_PROC_ALL");
311                  return NULL;
312          }
313  
# Line 315 | Line 320 | sg_process_stats *sg_get_process_stats(int *entries){
320          memset(kp_stats, 0, size);
321  
322          if(sysctl(mib, 3, kp_stats, &size, NULL, 0) < 0) {
323 +                sg_set_error(SG_ERROR_SYSCTL, "CTL_KERN.KERN_PROC.KERN_PROC_ALL");
324                  free(kp_stats);
325                  return NULL;
326          }
# Line 356 | Line 362 | sg_process_stats *sg_get_process_stats(int *entries){
362                  }
363  
364   #if defined(FREEBSD5) || defined(NETBSD) || defined(OPENBSD)
359                size = sizeof(buflen);
365  
366   #ifdef FREEBSD5
362                if(sysctlbyname("kern.ps_arg_cache_limit", &buflen, &size, NULL, 0) < 0) {
363                        return NULL;
364                }
365 #else
366                /* FIXME - this value can be too large on some of
367                   the BSD's, which causes sysctl not to return
368                   anything. Maybe we need something smaller? */
369                mib[1] = KERN_ARGMAX;
370
371                if(sysctl(mib, 2, &buflen, &size, NULL, 0) < 0) {
372                        return NULL;
373                }
374 #endif
375
376                proctitle = sg_malloc(buflen);
377                if(proctitle == NULL) {
378                        return NULL;
379                }
380
381                size = buflen;
382
383 #ifdef FREEBSD5
367                  mib[2] = KERN_PROC_ARGS;
368                  mib[3] = kp_stats[i].ki_pid;
369   #else
# Line 390 | Line 373 | sg_process_stats *sg_get_process_stats(int *entries){
373   #endif
374  
375                  free(proc_state_ptr->proctitle);
376 <                if(sysctl(mib, 4, proctitle, &size, NULL, 0) < 0) {
377 <                        free(proctitle);
378 <                        proc_state_ptr->proctitle = NULL;
379 <                }
380 <                else if(size > 0) {
376 >                proc_state_ptr->proctitle = NULL;
377 >
378 > /* Starting size - we'll double this straight away */
379 > #define PROCTITLE_START_SIZE 64
380 >                buflen = PROCTITLE_START_SIZE;
381 >                size = buflen;
382 >                proctitle = NULL;
383 >
384 >                do {
385 >                        if(size >= buflen) {
386 >                                buflen *= 2;
387 >                                size = buflen;
388 >                                proctitletmp = sg_realloc(proctitle, buflen);
389 >                                if(proctitletmp == NULL) {
390 >                                        free(proctitle);
391 >                                        proctitle = NULL;
392 >                                        proc_state_ptr->proctitle = NULL;
393 >                                        size = 0;
394 >                                        break;
395 >                                }
396 >                                proctitle = proctitletmp;
397 >                                bzero(proctitle, buflen);
398 >                        }
399 >
400 >                        if(sysctl(mib, 4, proctitle, &size, NULL, 0) < 0) {
401 >                                free(proctitle);
402 >                                proctitle = NULL;
403 >                                proc_state_ptr->proctitle = NULL;
404 >                                size = 0;
405 >                                break;
406 >                        }
407 >                } while(size >= buflen);
408 >
409 >                if(size > 0) {
410                          proc_state_ptr->proctitle = sg_malloc(size+1);
411                          if(proc_state_ptr->proctitle == NULL) {
412                                  return NULL;
# Line 407 | Line 419 | sg_process_stats *sg_get_process_stats(int *entries){
419                                  p += strlen(p) + 1;
420                          } while (p < proctitle + size);
421                          free(proctitle);
422 +                        proctitle = NULL;
423                          /* remove trailing space */
424                          proc_state_ptr->proctitle[strlen(proc_state_ptr->proctitle)-1] = '\0';
425                  }
426                  else {
427 <                        free(proctitle);
427 >                        if(proctitle != NULL) {
428 >                                free(proctitle);
429 >                                proctitle = NULL;
430 >                        }
431                          proc_state_ptr->proctitle = NULL;
432                  }
433   #else
434                  free(proc_state_ptr->proctitle);
435 +                proc_state_ptr->proctitle = NULL;
436                  if(kvmd != NULL) {
437                          args = kvm_getargv(kvmd, &(kp_stats[i]), 0);
438                          if(args != NULL) {
# Line 520 | Line 537 | sg_process_stats *sg_get_process_stats(int *entries){
537                          mib[4] = 0;
538  
539                          if(sysctl(mib, 5, NULL, &size, NULL, 0) < 0) {
540 +                                sg_set_error(SG_ERROR_SYSCTL, "CTL_KERN.KERN_LWP.pid.structsize.0");
541                                  return NULL;
542                          }
543  
# Line 532 | Line 550 | sg_process_stats *sg_get_process_stats(int *entries){
550                          }
551  
552                          if(sysctl(mib, 5, kl_stats, &size, NULL, 0) < 0) {
553 +                                sg_set_error(SG_ERROR_SYSCTL, "CTL_KERN.KERN_LWP.pid.structsize.buffersize");
554                                  return NULL;
555                          }
556                  }
# Line 616 | Line 635 | sg_process_stats *sg_get_process_stats(int *entries){
635   #endif
636  
637   #ifdef CYGWIN
638 +        sg_set_error(SG_ERROR_UNSUPPORTED, "Cygwin");
639          return NULL;
640   #endif
641  
# Line 665 | Line 685 | sg_process_count *sg_get_process_count() {
685  
686          return &process_stat;
687   }
688 +
689 + int sg_process_compare_name(const void *va, const void *vb) {
690 +        const sg_process_stats *a = (sg_process_stats *)va;
691 +        const sg_process_stats *b = (sg_process_stats *)vb;
692 +
693 +        return strcmp(a->process_name, b->process_name);
694 + }
695 +
696 + int sg_process_compare_pid(const void *va, const void *vb) {
697 +        const sg_process_stats *a = (sg_process_stats *)va;
698 +        const sg_process_stats *b = (sg_process_stats *)vb;
699 +
700 +        if (a->pid < b->pid) {
701 +                return -1;
702 +        } else if (a->pid == b->pid) {
703 +                return 0;
704 +        } else {
705 +                return 1;
706 +        }
707 + }
708 +
709 + int sg_process_compare_uid(const void *va, const void *vb) {
710 +        const sg_process_stats *a = (sg_process_stats *)va;
711 +        const sg_process_stats *b = (sg_process_stats *)vb;
712 +
713 +        if (a->uid < b->uid) {
714 +                return -1;
715 +        } else if (a->uid == b->uid) {
716 +                return 0;
717 +        } else {
718 +                return 1;
719 +        }
720 + }
721 +
722 + int sg_process_compare_gid(const void *va, const void *vb) {
723 +        const sg_process_stats *a = (sg_process_stats *)va;
724 +        const sg_process_stats *b = (sg_process_stats *)vb;
725 +
726 +        if (a->gid < b->gid) {
727 +                return -1;
728 +        } else if (a->gid == b->gid) {
729 +                return 0;
730 +        } else {
731 +                return 1;
732 +        }
733 + }
734 +
735 + int sg_process_compare_size(const void *va, const void *vb) {
736 +        const sg_process_stats *a = (sg_process_stats *)va;
737 +        const sg_process_stats *b = (sg_process_stats *)vb;
738 +
739 +        if (a->proc_size < b->proc_size) {
740 +                return -1;
741 +        } else if (a->proc_size == b->proc_size) {
742 +                return 0;
743 +        } else {
744 +                return 1;
745 +        }
746 + }
747 +
748 + int sg_process_compare_res(const void *va, const void *vb) {
749 +        const sg_process_stats *a = (sg_process_stats *)va;
750 +        const sg_process_stats *b = (sg_process_stats *)vb;
751 +
752 +        if (a->proc_resident < b->proc_resident) {
753 +                return -1;
754 +        } else if (a->proc_resident == b->proc_resident) {
755 +                return 0;
756 +        } else {
757 +                return 1;
758 +        }
759 + }
760 +
761 + int sg_process_compare_cpu(const void *va, const void *vb) {
762 +        const sg_process_stats *a = (sg_process_stats *)va;
763 +        const sg_process_stats *b = (sg_process_stats *)vb;
764 +
765 +        if (a->cpu_percent < b->cpu_percent) {
766 +                return -1;
767 +        } else if (a->cpu_percent == b->cpu_percent) {
768 +                return 0;
769 +        } else {
770 +                return 1;
771 +        }
772 + }
773 +
774 + int sg_process_compare_time(const void *va, const void *vb) {
775 +        const sg_process_stats *a = (sg_process_stats *)va;
776 +        const sg_process_stats *b = (sg_process_stats *)vb;
777 +
778 +        if (a->time_spent < b->time_spent) {
779 +                return -1;
780 +        } else if (a->time_spent == b->time_spent) {
781 +                return 0;
782 +        } else {
783 +                return 1;
784 +        }
785 + }
786 +

Diff Legend

Removed lines
+ Added lines
< Changed lines
> Changed lines