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.58 by pajs, Tue Apr 6 16:29:44 2004 UTC vs.
Revision 1.80 by ats, Sun Nov 7 12:32:24 2004 UTC

# Line 33 | Line 33
33   #include <stdlib.h>
34   #include <sys/types.h>
35   #include <dirent.h>
36 #include <string.h>
36   #endif
37 + #include <string.h>
38  
39   #ifdef SOLARIS
40   #include <procfs.h>
# 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 65 | Line 66
66   #include <limits.h>
67   #if (defined(FREEBSD) && !defined(FREEBSD5)) || defined(DFBSD)
68   #include <kvm.h>
68 #include <tools.h>
69   #endif
70   #include <unistd.h>
71   #ifdef NETBSD2
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 85 | 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 100 | 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 108 | 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 131 | 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 178 | 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->process_name = strdup(process_info.pr_fname);
198 <                proc_state_ptr->proctitle = strdup(process_info.pr_psargs);
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) {
200 >                        return NULL;
201 >                }
202 >                if (sg_update_string(&proc_state_ptr->proctitle,
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);
211                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 265 | 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 275 | 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 328 | Line 396 | sg_process_stats *sg_get_process_stats(int *entries){
396                  }
397  
398   #if defined(FREEBSD5) || defined(NETBSD) || defined(OPENBSD)
331                size = sizeof(buflen);
399  
400   #ifdef FREEBSD5
334                if(sysctlbyname("kern.ps_arg_cache_limit", &buflen, &size, NULL, 0) < 0) {
335                        return NULL;
336                }
337 #else
338                /* FIXME - this value can be too large on some of
339                   the BSD's, which causes sysctl not to return
340                   anything. Maybe we need something smaller? */
341                mib[1] = KERN_ARGMAX;
342
343                if(sysctl(mib, 2, &buflen, &size, NULL, 0) < 0) {
344                        return NULL;
345                }
346 #endif
347
348                proctitle = malloc(buflen);
349                if(proctitle == NULL) {
350                        return NULL;
351                }
352
353                size = buflen;
354
355 #ifdef FREEBSD5
401                  mib[2] = KERN_PROC_ARGS;
402                  mib[3] = kp_stats[i].ki_pid;
403   #else
# Line 362 | 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((long) 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((long) 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 379 | 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 396 | 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 492 | 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 545 | 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 587 | 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 +        while (1) {
689 +                num = pstat_getproc(pstat_procinfo, sizeof pstat_procinfo[0],
690 +                                    PROCESS_BATCH, procidx);
691 +                if (num == -1) {
692 +                        sg_set_error_with_errno(SG_ERROR_PSTAT,
693 +                                                "pstat_getproc");
694 +                        return NULL;
695 +                } else if (num == 0) {
696 +                        break;
697 +                }
698 +
699 +                for (i = 0; i < num; i++) {
700 +                        struct pst_status *pi = &pstat_procinfo[i];
701 +
702 +                        if (VECTOR_RESIZE(proc_state, proc_state_size + 1) < 0) {
703 +                                return NULL;
704 +                        }
705 +                        proc_state_ptr = proc_state+proc_state_size;
706 +        
707 +                        proc_state_ptr->pid = pi->pst_pid;
708 +                        proc_state_ptr->parent = pi->pst_ppid;
709 +                        proc_state_ptr->pgid = pi->pst_pgrp;
710 +                        proc_state_ptr->uid = pi->pst_uid;
711 +                        proc_state_ptr->euid = pi->pst_euid;
712 +                        proc_state_ptr->gid = pi->pst_gid;
713 +                        proc_state_ptr->egid = pi->pst_egid;
714 +                        proc_state_ptr->proc_size = (pi->pst_dsize + pi->pst_tsize + pi->pst_ssize) * pagesize;
715 +                        proc_state_ptr->proc_resident = pi->pst_rssize * pagesize;
716 +                        proc_state_ptr->time_spent = pi->pst_time;
717 +                        proc_state_ptr->cpu_percent = (pi->pst_pctcpu * 100.0) / 0x8000;
718 +                        proc_state_ptr->nice = pi->pst_nice;
719 +        
720 +                        if (sg_update_string(&proc_state_ptr->process_name,
721 +                                             pi->pst_ucomm) < 0) {
722 +                                return NULL;
723 +                        }
724 +                        if (sg_update_string(&proc_state_ptr->proctitle,
725 +                                             pi->pst_cmd) < 0) {
726 +                                return NULL;
727 +                        }
728 +        
729 +                        switch (pi->pst_stat) {
730 +                        case PS_SLEEP:
731 +                                proc_state_ptr->state = SG_PROCESS_STATE_SLEEPING;
732 +                                break;
733 +                        case PS_RUN:
734 +                                proc_state_ptr->state = SG_PROCESS_STATE_RUNNING;
735 +                                break;
736 +                        case PS_STOP:
737 +                                proc_state_ptr->state = SG_PROCESS_STATE_STOPPED;
738 +                                break;
739 +                        case PS_ZOMBIE:
740 +                                proc_state_ptr->state = SG_PROCESS_STATE_ZOMBIE;
741 +                                break;
742 +                        case PS_IDLE:
743 +                        case PS_OTHER:
744 +                                proc_state_ptr->state = SG_PROCESS_STATE_UNKNOWN;
745 +                                break;
746 +                        }
747 +        
748 +                        proc_state_size++;
749 +                }
750 +                procidx = pstat_procinfo[num - 1].pst_idx + 1;
751 +        }
752 + #endif
753 +
754   #ifdef CYGWIN
755 +        sg_set_error(SG_ERROR_UNSUPPORTED, "Cygwin");
756          return NULL;
757   #endif
758  
# Line 637 | Line 802 | sg_process_count *sg_get_process_count() {
802  
803          return &process_stat;
804   }
805 +
806 + int sg_process_compare_name(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 +        return strcmp(a->process_name, b->process_name);
811 + }
812 +
813 + int sg_process_compare_pid(const void *va, const void *vb) {
814 +        const sg_process_stats *a = (sg_process_stats *)va;
815 +        const sg_process_stats *b = (sg_process_stats *)vb;
816 +
817 +        if (a->pid < b->pid) {
818 +                return -1;
819 +        } else if (a->pid == b->pid) {
820 +                return 0;
821 +        } else {
822 +                return 1;
823 +        }
824 + }
825 +
826 + int sg_process_compare_uid(const void *va, const void *vb) {
827 +        const sg_process_stats *a = (sg_process_stats *)va;
828 +        const sg_process_stats *b = (sg_process_stats *)vb;
829 +
830 +        if (a->uid < b->uid) {
831 +                return -1;
832 +        } else if (a->uid == b->uid) {
833 +                return 0;
834 +        } else {
835 +                return 1;
836 +        }
837 + }
838 +
839 + int sg_process_compare_gid(const void *va, const void *vb) {
840 +        const sg_process_stats *a = (sg_process_stats *)va;
841 +        const sg_process_stats *b = (sg_process_stats *)vb;
842 +
843 +        if (a->gid < b->gid) {
844 +                return -1;
845 +        } else if (a->gid == b->gid) {
846 +                return 0;
847 +        } else {
848 +                return 1;
849 +        }
850 + }
851 +
852 + int sg_process_compare_size(const void *va, const void *vb) {
853 +        const sg_process_stats *a = (sg_process_stats *)va;
854 +        const sg_process_stats *b = (sg_process_stats *)vb;
855 +
856 +        if (a->proc_size < b->proc_size) {
857 +                return -1;
858 +        } else if (a->proc_size == b->proc_size) {
859 +                return 0;
860 +        } else {
861 +                return 1;
862 +        }
863 + }
864 +
865 + int sg_process_compare_res(const void *va, const void *vb) {
866 +        const sg_process_stats *a = (sg_process_stats *)va;
867 +        const sg_process_stats *b = (sg_process_stats *)vb;
868 +
869 +        if (a->proc_resident < b->proc_resident) {
870 +                return -1;
871 +        } else if (a->proc_resident == b->proc_resident) {
872 +                return 0;
873 +        } else {
874 +                return 1;
875 +        }
876 + }
877 +
878 + int sg_process_compare_cpu(const void *va, const void *vb) {
879 +        const sg_process_stats *a = (sg_process_stats *)va;
880 +        const sg_process_stats *b = (sg_process_stats *)vb;
881 +
882 +        if (a->cpu_percent < b->cpu_percent) {
883 +                return -1;
884 +        } else if (a->cpu_percent == b->cpu_percent) {
885 +                return 0;
886 +        } else {
887 +                return 1;
888 +        }
889 + }
890 +
891 + int sg_process_compare_time(const void *va, const void *vb) {
892 +        const sg_process_stats *a = (sg_process_stats *)va;
893 +        const sg_process_stats *b = (sg_process_stats *)vb;
894 +
895 +        if (a->time_spent < b->time_spent) {
896 +                return -1;
897 +        } else if (a->time_spent == b->time_spent) {
898 +                return 0;
899 +        } else {
900 +                return 1;
901 +        }
902 + }
903 +

Diff Legend

Removed lines
+ Added lines
< Changed lines
> Changed lines