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.60 by ats, Wed Apr 7 10:27:53 2004 UTC vs.
Revision 1.77 by ats, Sat Nov 6 15:10:07 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 71 | Line 72
72   #include <sys/lwp.h>
73   #endif
74   #endif
75 + #ifdef HPUX
76 + #include <sys/param.h>
77 + #include <sys/pstat.h>
78 + #include <unistd.h>
79 + #define PROCESS_BATCH 30
80 + #endif
81  
82   static void proc_state_init(sg_process_stats *s) {
83          s->process_name = NULL;
# Line 84 | Line 91 | static void proc_state_destroy(sg_process_stats *s) {
91  
92   sg_process_stats *sg_get_process_stats(int *entries){
93          VECTOR_DECLARE_STATIC(proc_state, sg_process_stats, 64,
94 <                              proc_state_init, proc_state_destroy);
94 >                              proc_state_init, proc_state_destroy);
95          int proc_state_size = 0;
96          sg_process_stats *proc_state_ptr;
97 + #ifdef HPUX
98 +        struct pst_status pstat_procinfo[PROCESS_BATCH];
99 +        long procidx = 0;
100 +        long long pagesize;
101 +        int num, i;
102 + #endif
103   #ifdef ALLBSD
104          int mib[4];
105          size_t size;
# Line 99 | Line 112 | sg_process_stats *sg_get_process_stats(int *entries){
112          int argslen = 0;
113   #else
114          long buflen;
115 <        char *p;
115 >        char *p, *proctitletmp;
116   #endif
117   #ifdef NETBSD2
118          int lwps;
# Line 107 | Line 120 | sg_process_stats *sg_get_process_stats(int *entries){
120   #endif
121   #endif
122   #if defined(SOLARIS) || defined(LINUX)
123 <        DIR *proc_dir;
124 <        struct dirent *dir_entry;
125 <        char filename[MAX_FILE_LENGTH];
126 <        FILE *f;
123 >        DIR *proc_dir;
124 >        struct dirent *dir_entry;
125 >        char filename[MAX_FILE_LENGTH];
126 >        FILE *f;
127   #ifdef SOLARIS
128          psinfo_t process_info;
129   #endif
# Line 130 | Line 143 | sg_process_stats *sg_get_process_stats(int *entries){
143  
144   #ifdef LINUX
145          if ((f=fopen("/proc/uptime", "r")) == NULL) {
146 +                sg_set_error_with_errno(SG_ERROR_OPEN, "/proc/uptime");
147                  return NULL;
148          }
149          if((fscanf(f,"%lu %*d",&uptime)) != 1){
150 +                sg_set_error(SG_ERROR_PARSE, NULL);
151                  return NULL;
152          }
153          fclose(f);
154   #endif
155  
156 <        if((proc_dir=opendir(PROC_LOCATION))==NULL){
157 <                return NULL;
158 <        }
156 >        if((proc_dir=opendir(PROC_LOCATION))==NULL){
157 >                sg_set_error_with_errno(SG_ERROR_OPENDIR, PROC_LOCATION);
158 >                return NULL;
159 >        }
160  
161 <        while((dir_entry=readdir(proc_dir))!=NULL){
162 <                if(atoi(dir_entry->d_name) == 0) continue;
161 >        while((dir_entry=readdir(proc_dir))!=NULL){
162 >                if(atoi(dir_entry->d_name) == 0) continue;
163  
164   #ifdef SOLARIS
165 <                snprintf(filename, MAX_FILE_LENGTH, "/proc/%s/psinfo", dir_entry->d_name);
165 >                snprintf(filename, MAX_FILE_LENGTH, "/proc/%s/psinfo", dir_entry->d_name);
166   #endif
167   #ifdef LINUX
168                  snprintf(filename, MAX_FILE_LENGTH, "/proc/%s/stat", dir_entry->d_name);
169   #endif
170 <                if((f=fopen(filename, "r"))==NULL){
171 <                        /* Open failed.. Process since vanished, or the path was too long.
172 <                         * Ah well, move onwards to the next one */
173 <                        continue;
174 <                }
170 >                if((f=fopen(filename, "r"))==NULL){
171 >                        /* Open failed.. Process since vanished, or the path was too long.
172 >                         * Ah well, move onwards to the next one */
173 >                        continue;
174 >                }
175   #ifdef SOLARIS
176 <                fread(&process_info, sizeof(psinfo_t), 1, f);
176 >                fread(&process_info, sizeof(psinfo_t), 1, f);
177 >                fclose(f);
178   #endif
179  
180                  if (VECTOR_RESIZE(proc_state, proc_state_size + 1) < 0) {
# Line 177 | Line 194 | sg_process_stats *sg_get_process_stats(int *entries){
194                  proc_state_ptr->proc_resident = (process_info.pr_rssize) * 1024;
195                  proc_state_ptr->time_spent = process_info.pr_time.tv_sec;
196                  proc_state_ptr->cpu_percent = (process_info.pr_pctcpu * 100.0) / 0x8000;
197 +                proc_state_ptr->nice = (int)process_info.pr_lwp.pr_nice - 20;
198                  if (sg_update_string(&proc_state_ptr->process_name,
199 <                                     process_info.pr_fname) < 0) {
199 >                                     process_info.pr_fname) < 0) {
200                          return NULL;
201                  }
202                  if (sg_update_string(&proc_state_ptr->proctitle,
203 <                                     process_info.pr_psargs) < 0) {
203 >                                     process_info.pr_psargs) < 0) {
204                          return NULL;
205                  }
206  
207 <                if(process_info.pr_lwp.pr_state==1) proc_state_ptr->state = SG_PROCESS_STATE_SLEEPING;
208 <                if(process_info.pr_lwp.pr_state==2) proc_state_ptr->state = SG_PROCESS_STATE_RUNNING;
209 <                if(process_info.pr_lwp.pr_state==3) proc_state_ptr->state = SG_PROCESS_STATE_ZOMBIE;
210 <                if(process_info.pr_lwp.pr_state==4) proc_state_ptr->state = SG_PROCESS_STATE_STOPPED;
211 <                if(process_info.pr_lwp.pr_state==6) proc_state_ptr->state = SG_PROCESS_STATE_RUNNING;
207 >                switch (process_info.pr_lwp.pr_state) {
208 >                case 1:
209 >                        proc_state_ptr->state = SG_PROCESS_STATE_SLEEPING;
210 >                        break;
211 >                case 2:
212 >                case 5:
213 >                        proc_state_ptr->state = SG_PROCESS_STATE_RUNNING;
214 >                        break;
215 >                case 3:
216 >                        proc_state_ptr->state = SG_PROCESS_STATE_ZOMBIE;
217 >                        break;
218 >                case 4:
219 >                        proc_state_ptr->state = SG_PROCESS_STATE_STOPPED;
220 >                        break;
221 >                }
222   #endif
223   #ifdef LINUX
224                  x = fscanf(f, "%d %4096s %c %d %d %*d %*d %*d %*u %*u %*u %*u %*u %lu %lu %*d %*d %*d %d %*d %*d %lu %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), &starttime, &(proc_state_ptr->proc_size), &(proc_state_ptr->proc_resident));
225                  /* +3 becuase man page says "Resident  Set Size: number of pages the process has in real memory, minus 3 for administrative purposes." */
226                  proc_state_ptr->proc_resident = (proc_state_ptr->proc_resident + 3) * getpagesize();
227 <                if(s == 'S') proc_state_ptr->state = SG_PROCESS_STATE_SLEEPING;
228 <                if(s == 'R') proc_state_ptr->state = SG_PROCESS_STATE_RUNNING;
229 <                if(s == 'Z') proc_state_ptr->state = SG_PROCESS_STATE_ZOMBIE;
230 <                if(s == 'T') proc_state_ptr->state = SG_PROCESS_STATE_STOPPED;
231 <                if(s == 'D') proc_state_ptr->state = SG_PROCESS_STATE_STOPPED;
227 >                switch (s) {
228 >                case 'S':
229 >                        proc_state_ptr->state = SG_PROCESS_STATE_SLEEPING;
230 >                        break;
231 >                case 'R':
232 >                        proc_state_ptr->state = SG_PROCESS_STATE_RUNNING;
233 >                        break;
234 >                case 'Z':
235 >                        proc_state_ptr->state = SG_PROCESS_STATE_ZOMBIE;
236 >                        break;
237 >                case 'T':
238 >                case 'D':
239 >                        proc_state_ptr->state = SG_PROCESS_STATE_STOPPED;
240 >                        break;
241 >                }
242          
243                  /* pa_name[0] should = '(' */
244                  ptr = strchr(&ps_name[1], ')');
245                  if(ptr !=NULL) *ptr='\0';
246  
247                  if (sg_update_string(&proc_state_ptr->process_name,
248 <                                     &ps_name[1]) < 0) {
248 >                                     &ps_name[1]) < 0) {
249                          return NULL;
250                  }
251  
252                  /* cpu */
253                  proc_state_ptr->cpu_percent = (100.0 * (utime + stime)) / ((uptime * 100.0) - starttime);
216                printf("%s  ut: %lu st: %lu up: %lu start: %lu\n", proc_state_ptr->process_name, utime, stime, uptime , starttime);
254  
255 <                fclose(f);
255 >                fclose(f);
256  
257 +                /* uid / gid */
258 +                snprintf(filename, MAX_FILE_LENGTH, "/proc/%s/status", dir_entry->d_name);
259 +                if ((f=fopen(filename, "r")) == NULL) {
260 +                        /* Open failed.. Process since vanished, or the path was too long.
261 +                         * Ah well, move onwards to the next one */
262 +                        continue;
263 +                }
264 +
265 +                if((ptr=sg_f_read_line(f, "Uid:"))==NULL){
266 +                        fclose(f);
267 +                        continue;
268 +                }
269 +                sscanf(ptr, "Uid:\t%d\t%d\t%*d\t%*d\n", &(proc_state_ptr->uid), &(proc_state_ptr->euid));
270 +
271 +                if((ptr=sg_f_read_line(f, "Gid:"))==NULL){
272 +                        fclose(f);
273 +                        continue;
274 +                }
275 +                sscanf(ptr, "Gid:\t%d\t%d\t%*d\t%*d\n", &(proc_state_ptr->gid), &(proc_state_ptr->egid));
276 +
277 +                fclose(f);
278 +
279                  /* proctitle */
280                  snprintf(filename, MAX_FILE_LENGTH, "/proc/%s/cmdline", dir_entry->d_name);
281  
282 <                if((fn=open(filename, O_RDONLY)) == -1){
283 <                        /* Open failed.. Process since vanished, or the path was too long.
284 <                         * Ah well, move onwards to the next one */
285 <                        continue;
286 <                }
282 >                if((fn=open(filename, O_RDONLY)) == -1){
283 >                        /* Open failed.. Process since vanished, or the path was too long.
284 >                         * Ah well, move onwards to the next one */
285 >                        continue;
286 >                }
287  
288   #define READ_BLOCK_SIZE 128
289                  len = 0;
# Line 270 | Line 329 | sg_process_stats *sg_get_process_stats(int *entries){
329   #endif
330  
331                  proc_state_size++;
332 <        }
333 <        closedir(proc_dir);
332 >        }
333 >        closedir(proc_dir);
334   #endif
335  
336   #ifdef ALLBSD
# Line 280 | Line 339 | sg_process_stats *sg_get_process_stats(int *entries){
339          mib[2] = KERN_PROC_ALL;
340  
341          if(sysctl(mib, 3, NULL, &size, NULL, 0) < 0) {
342 +                sg_set_error_with_errno(SG_ERROR_SYSCTL,
343 +                                        "CTL_KERN.KERN_PROC.KERN_PROC_ALL");
344                  return NULL;
345          }
346  
347          procs = size / sizeof(struct kinfo_proc);
348  
349 <        kp_stats = malloc(size);
349 >        kp_stats = sg_malloc(size);
350          if(kp_stats == NULL) {
351                  return NULL;
352          }
353          memset(kp_stats, 0, size);
354  
355          if(sysctl(mib, 3, kp_stats, &size, NULL, 0) < 0) {
356 +                sg_set_error_with_errno(SG_ERROR_SYSCTL,
357 +                                        "CTL_KERN.KERN_PROC.KERN_PROC_ALL");
358                  free(kp_stats);
359                  return NULL;
360          }
# Line 333 | Line 396 | sg_process_stats *sg_get_process_stats(int *entries){
396                  }
397  
398   #if defined(FREEBSD5) || defined(NETBSD) || defined(OPENBSD)
336                size = sizeof(buflen);
399  
400   #ifdef FREEBSD5
339                if(sysctlbyname("kern.ps_arg_cache_limit", &buflen, &size, NULL, 0) < 0) {
340                        return NULL;
341                }
342 #else
343                /* FIXME - this value can be too large on some of
344                   the BSD's, which causes sysctl not to return
345                   anything. Maybe we need something smaller? */
346                mib[1] = KERN_ARGMAX;
347
348                if(sysctl(mib, 2, &buflen, &size, NULL, 0) < 0) {
349                        return NULL;
350                }
351 #endif
352
353                proctitle = malloc(buflen);
354                if(proctitle == NULL) {
355                        return NULL;
356                }
357
358                size = buflen;
359
360 #ifdef FREEBSD5
401                  mib[2] = KERN_PROC_ARGS;
402                  mib[3] = kp_stats[i].ki_pid;
403   #else
# Line 367 | Line 407 | sg_process_stats *sg_get_process_stats(int *entries){
407   #endif
408  
409                  free(proc_state_ptr->proctitle);
410 <                if(sysctl(mib, 4, proctitle, &size, NULL, 0) < 0) {
411 <                        free(proctitle);
412 <                        proc_state_ptr->proctitle = NULL;
413 <                }
414 <                else if(size > 0) {
415 <                        proc_state_ptr->proctitle = malloc(size+1);
410 >                proc_state_ptr->proctitle = NULL;
411 >
412 > /* Starting size - we'll double this straight away */
413 > #define PROCTITLE_START_SIZE 64
414 >                buflen = PROCTITLE_START_SIZE;
415 >                size = buflen;
416 >                proctitle = NULL;
417 >
418 >                do {
419 >                        if(size >= buflen) {
420 >                                buflen *= 2;
421 >                                size = buflen;
422 >                                proctitletmp = sg_realloc(proctitle, buflen);
423 >                                if(proctitletmp == NULL) {
424 >                                        free(proctitle);
425 >                                        proctitle = NULL;
426 >                                        proc_state_ptr->proctitle = NULL;
427 >                                        size = 0;
428 >                                        break;
429 >                                }
430 >                                proctitle = proctitletmp;
431 >                                bzero(proctitle, buflen);
432 >                        }
433 >
434 >                        if(sysctl(mib, 4, proctitle, &size, NULL, 0) < 0) {
435 >                                free(proctitle);
436 >                                proctitle = NULL;
437 >                                proc_state_ptr->proctitle = NULL;
438 >                                size = 0;
439 >                                break;
440 >                        }
441 >                } while(size >= buflen);
442 >
443 >                if(size > 0) {
444 >                        proc_state_ptr->proctitle = sg_malloc(size+1);
445                          if(proc_state_ptr->proctitle == NULL) {
446                                  return NULL;
447                          }
448                          p = proctitle;
449 + #ifdef OPENBSD
450 +                        /* On OpenBSD, this value has the argv pointers (which
451 +                         * are terminated by a NULL) at the front, so we have
452 +                         * to skip over them to get to the strings. */
453 +                        while (*(char ***)p != NULL) {
454 +                                p += sizeof(char **);
455 +                        }
456 +                        p += sizeof(char **);
457 + #endif
458                          proc_state_ptr->proctitle[0] = '\0';
459                          do {
460                                  sg_strlcat(proc_state_ptr->proctitle, p, size+1);
# Line 384 | Line 462 | sg_process_stats *sg_get_process_stats(int *entries){
462                                  p += strlen(p) + 1;
463                          } while (p < proctitle + size);
464                          free(proctitle);
465 +                        proctitle = NULL;
466                          /* remove trailing space */
467                          proc_state_ptr->proctitle[strlen(proc_state_ptr->proctitle)-1] = '\0';
468                  }
469                  else {
470 <                        free(proctitle);
470 >                        if(proctitle != NULL) {
471 >                                free(proctitle);
472 >                                proctitle = NULL;
473 >                        }
474                          proc_state_ptr->proctitle = NULL;
475                  }
476   #else
477                  free(proc_state_ptr->proctitle);
478 +                proc_state_ptr->proctitle = NULL;
479                  if(kvmd != NULL) {
480                          args = kvm_getargv(kvmd, &(kp_stats[i]), 0);
481                          if(args != NULL) {
# Line 401 | Line 484 | sg_process_stats *sg_get_process_stats(int *entries){
484                                          argslen += strlen(*argsp) + 1;
485                                          argsp++;
486                                  }
487 <                                proctitle = malloc(argslen + 1);
487 >                                proctitle = sg_malloc(argslen + 1);
488                                  proctitle[0] = '\0';
489                                  if(proctitle == NULL) {
490                                          return NULL;
# Line 497 | Line 580 | sg_process_stats *sg_get_process_stats(int *entries){
580                          mib[4] = 0;
581  
582                          if(sysctl(mib, 5, NULL, &size, NULL, 0) < 0) {
583 +                                sg_set_error_with_errno(SG_ERROR_SYSCTL, "CTL_KERN.KERN_LWP.pid.structsize.0");
584                                  return NULL;
585                          }
586  
587                          lwps = size / sizeof(struct kinfo_lwp);
588                          mib[4] = lwps;
589  
590 <                        kl_stats = malloc(size);
590 >                        kl_stats = sg_malloc(size);
591                          if(kl_stats == NULL) {
592                                  return NULL;
593                          }
594  
595                          if(sysctl(mib, 5, kl_stats, &size, NULL, 0) < 0) {
596 +                                sg_set_error_with_errno(SG_ERROR_SYSCTL, "CTL_KERN.KERN_LWP.pid.structsize.buffersize");
597                                  return NULL;
598                          }
599                  }
# Line 550 | Line 635 | sg_process_stats *sg_get_process_stats(int *entries){
635                          proc_state_ptr->state = SG_PROCESS_STATE_UNKNOWN;
636                          break;
637                  }
638 +
639 +                free(kl_stats);
640   #else
641   #ifdef FREEBSD5
642                  switch (kp_stats[i].ki_stat) {
# Line 592 | Line 679 | sg_process_stats *sg_get_process_stats(int *entries){
679          free(kp_stats);
680   #endif
681  
682 + #ifdef HPUX
683 +        if ((pagesize = sysconf(_SC_PAGESIZE)) == -1) {
684 +                sg_set_error_with_errno(SG_ERROR_SYSCONF, "_SC_PAGESIZE");
685 +                return NULL;
686 +        }
687 +
688 +        do {
689 +                num = pstat_getproc(pstat_procinfo, sizeof pstat_procinfo[0],
690 +                                    PROCESS_BATCH, procidx);
691 +
692 +                for (i = 0; i < num; i++) {
693 +                        struct pst_status *pi = &pstat_procinfo[i];
694 +
695 +                        if (VECTOR_RESIZE(proc_state, proc_state_size + 1) < 0) {
696 +                                return NULL;
697 +                        }
698 +                        proc_state_ptr = proc_state+proc_state_size;
699 +        
700 +                        proc_state_ptr->pid = pi->pst_pid;
701 +                        proc_state_ptr->parent = pi->pst_ppid;
702 +                        proc_state_ptr->pgid = pi->pst_pgrp;
703 +                        proc_state_ptr->uid = pi->pst_uid;
704 +                        proc_state_ptr->euid = pi->pst_euid;
705 +                        proc_state_ptr->gid = pi->pst_gid;
706 +                        proc_state_ptr->egid = pi->pst_egid;
707 +                        proc_state_ptr->proc_size = (pi->pst_dsize + pi->pst_tsize + pi->pst_ssize) * pagesize;
708 +                        proc_state_ptr->proc_resident = pi->pst_rssize * pagesize;
709 +                        proc_state_ptr->time_spent = pi->pst_time;
710 +                        proc_state_ptr->cpu_percent = (pi->pst_pctcpu * 100.0) / 0x8000;
711 +                        proc_state_ptr->nice = pi->pst_nice;
712 +        
713 +                        if (sg_update_string(&proc_state_ptr->process_name,
714 +                                             pi->pst_ucomm) < 0) {
715 +                                return NULL;
716 +                        }
717 +                        if (sg_update_string(&proc_state_ptr->proctitle,
718 +                                             pi->pst_cmd) < 0) {
719 +                                return NULL;
720 +                        }
721 +        
722 +                        switch (pi->pst_stat) {
723 +                        case PS_SLEEP:
724 +                                proc_state_ptr->state = SG_PROCESS_STATE_SLEEPING;
725 +                                break;
726 +                        case PS_RUN:
727 +                                proc_state_ptr->state = SG_PROCESS_STATE_RUNNING;
728 +                                break;
729 +                        case PS_STOP:
730 +                                proc_state_ptr->state = SG_PROCESS_STATE_STOPPED;
731 +                                break;
732 +                        case PS_ZOMBIE:
733 +                                proc_state_ptr->state = SG_PROCESS_STATE_ZOMBIE;
734 +                                break;
735 +                        case PS_IDLE:
736 +                        case PS_OTHER:
737 +                                proc_state_ptr->state = SG_PROCESS_STATE_UNKNOWN;
738 +                                break;
739 +                        }
740 +        
741 +                        proc_state_size++;
742 +                }
743 +                procidx = pstat_procinfo[n - 1].pst_idx + 1;
744 +        } while (num > 0);
745 + #endif
746 +
747   #ifdef CYGWIN
748 +        sg_set_error(SG_ERROR_UNSUPPORTED, "Cygwin");
749          return NULL;
750   #endif
751  
# Line 642 | Line 795 | sg_process_count *sg_get_process_count() {
795  
796          return &process_stat;
797   }
798 +
799 + int sg_process_compare_name(const void *va, const void *vb) {
800 +        const sg_process_stats *a = (sg_process_stats *)va;
801 +        const sg_process_stats *b = (sg_process_stats *)vb;
802 +
803 +        return strcmp(a->process_name, b->process_name);
804 + }
805 +
806 + int sg_process_compare_pid(const void *va, const void *vb) {
807 +        const sg_process_stats *a = (sg_process_stats *)va;
808 +        const sg_process_stats *b = (sg_process_stats *)vb;
809 +
810 +        if (a->pid < b->pid) {
811 +                return -1;
812 +        } else if (a->pid == b->pid) {
813 +                return 0;
814 +        } else {
815 +                return 1;
816 +        }
817 + }
818 +
819 + int sg_process_compare_uid(const void *va, const void *vb) {
820 +        const sg_process_stats *a = (sg_process_stats *)va;
821 +        const sg_process_stats *b = (sg_process_stats *)vb;
822 +
823 +        if (a->uid < b->uid) {
824 +                return -1;
825 +        } else if (a->uid == b->uid) {
826 +                return 0;
827 +        } else {
828 +                return 1;
829 +        }
830 + }
831 +
832 + int sg_process_compare_gid(const void *va, const void *vb) {
833 +        const sg_process_stats *a = (sg_process_stats *)va;
834 +        const sg_process_stats *b = (sg_process_stats *)vb;
835 +
836 +        if (a->gid < b->gid) {
837 +                return -1;
838 +        } else if (a->gid == b->gid) {
839 +                return 0;
840 +        } else {
841 +                return 1;
842 +        }
843 + }
844 +
845 + int sg_process_compare_size(const void *va, const void *vb) {
846 +        const sg_process_stats *a = (sg_process_stats *)va;
847 +        const sg_process_stats *b = (sg_process_stats *)vb;
848 +
849 +        if (a->proc_size < b->proc_size) {
850 +                return -1;
851 +        } else if (a->proc_size == b->proc_size) {
852 +                return 0;
853 +        } else {
854 +                return 1;
855 +        }
856 + }
857 +
858 + int sg_process_compare_res(const void *va, const void *vb) {
859 +        const sg_process_stats *a = (sg_process_stats *)va;
860 +        const sg_process_stats *b = (sg_process_stats *)vb;
861 +
862 +        if (a->proc_resident < b->proc_resident) {
863 +                return -1;
864 +        } else if (a->proc_resident == b->proc_resident) {
865 +                return 0;
866 +        } else {
867 +                return 1;
868 +        }
869 + }
870 +
871 + int sg_process_compare_cpu(const void *va, const void *vb) {
872 +        const sg_process_stats *a = (sg_process_stats *)va;
873 +        const sg_process_stats *b = (sg_process_stats *)vb;
874 +
875 +        if (a->cpu_percent < b->cpu_percent) {
876 +                return -1;
877 +        } else if (a->cpu_percent == b->cpu_percent) {
878 +                return 0;
879 +        } else {
880 +                return 1;
881 +        }
882 + }
883 +
884 + int sg_process_compare_time(const void *va, const void *vb) {
885 +        const sg_process_stats *a = (sg_process_stats *)va;
886 +        const sg_process_stats *b = (sg_process_stats *)vb;
887 +
888 +        if (a->time_spent < b->time_spent) {
889 +                return -1;
890 +        } else if (a->time_spent == b->time_spent) {
891 +                return 0;
892 +        } else {
893 +                return 1;
894 +        }
895 + }
896 +

Diff Legend

Removed lines
+ Added lines
< Changed lines
> Changed lines