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.82 by tdb, Mon Oct 9 14:47:58 2006 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 + #ifdef WIN32
82 + #include <windows.h>
83 + #include <psapi.h>
84 + #endif
85  
86   static void proc_state_init(sg_process_stats *s) {
87          s->process_name = NULL;
# Line 85 | Line 95 | static void proc_state_destroy(sg_process_stats *s) {
95  
96   sg_process_stats *sg_get_process_stats(int *entries){
97          VECTOR_DECLARE_STATIC(proc_state, sg_process_stats, 64,
98 <                              proc_state_init, proc_state_destroy);
98 >                              proc_state_init, proc_state_destroy);
99          int proc_state_size = 0;
100          sg_process_stats *proc_state_ptr;
101 + #ifdef HPUX
102 +        struct pst_status pstat_procinfo[PROCESS_BATCH];
103 +        long procidx = 0;
104 +        long long pagesize;
105 +        int num, i;
106 + #endif
107   #ifdef ALLBSD
108          int mib[4];
109          size_t size;
# Line 100 | Line 116 | sg_process_stats *sg_get_process_stats(int *entries){
116          int argslen = 0;
117   #else
118          long buflen;
119 <        char *p;
119 >        char *p, *proctitletmp;
120   #endif
121   #ifdef NETBSD2
122          int lwps;
# Line 108 | Line 124 | sg_process_stats *sg_get_process_stats(int *entries){
124   #endif
125   #endif
126   #if defined(SOLARIS) || defined(LINUX)
127 <        DIR *proc_dir;
128 <        struct dirent *dir_entry;
129 <        char filename[MAX_FILE_LENGTH];
130 <        FILE *f;
127 >        DIR *proc_dir;
128 >        struct dirent *dir_entry;
129 >        char filename[MAX_FILE_LENGTH];
130 >        FILE *f;
131   #ifdef SOLARIS
132          psinfo_t process_info;
133   #endif
# Line 127 | Line 143 | sg_process_stats *sg_get_process_stats(int *entries){
143          int len;
144          int rc;
145          time_t uptime;
146 +        long tickspersec;
147   #endif
148  
149   #ifdef LINUX
150          if ((f=fopen("/proc/uptime", "r")) == NULL) {
151 +                sg_set_error_with_errno(SG_ERROR_OPEN, "/proc/uptime");
152                  return NULL;
153          }
154          if((fscanf(f,"%lu %*d",&uptime)) != 1){
155 +                sg_set_error(SG_ERROR_PARSE, NULL);
156                  return NULL;
157          }
158          fclose(f);
159   #endif
160  
161 <        if((proc_dir=opendir(PROC_LOCATION))==NULL){
162 <                return NULL;
163 <        }
161 >        if((proc_dir=opendir(PROC_LOCATION))==NULL){
162 >                sg_set_error_with_errno(SG_ERROR_OPENDIR, PROC_LOCATION);
163 >                return NULL;
164 >        }
165  
166 <        while((dir_entry=readdir(proc_dir))!=NULL){
167 <                if(atoi(dir_entry->d_name) == 0) continue;
166 >        while((dir_entry=readdir(proc_dir))!=NULL){
167 >                if(atoi(dir_entry->d_name) == 0) continue;
168  
169   #ifdef SOLARIS
170 <                snprintf(filename, MAX_FILE_LENGTH, "/proc/%s/psinfo", dir_entry->d_name);
170 >                snprintf(filename, MAX_FILE_LENGTH, "/proc/%s/psinfo", dir_entry->d_name);
171   #endif
172   #ifdef LINUX
173                  snprintf(filename, MAX_FILE_LENGTH, "/proc/%s/stat", dir_entry->d_name);
174   #endif
175 <                if((f=fopen(filename, "r"))==NULL){
176 <                        /* Open failed.. Process since vanished, or the path was too long.
177 <                         * Ah well, move onwards to the next one */
178 <                        continue;
179 <                }
175 >                if((f=fopen(filename, "r"))==NULL){
176 >                        /* Open failed.. Process since vanished, or the path was too long.
177 >                         * Ah well, move onwards to the next one */
178 >                        continue;
179 >                }
180   #ifdef SOLARIS
181 <                fread(&process_info, sizeof(psinfo_t), 1, f);
181 >                fread(&process_info, sizeof(psinfo_t), 1, f);
182 >                fclose(f);
183   #endif
184  
185                  if (VECTOR_RESIZE(proc_state, proc_state_size + 1) < 0) {
# Line 178 | Line 199 | sg_process_stats *sg_get_process_stats(int *entries){
199                  proc_state_ptr->proc_resident = (process_info.pr_rssize) * 1024;
200                  proc_state_ptr->time_spent = process_info.pr_time.tv_sec;
201                  proc_state_ptr->cpu_percent = (process_info.pr_pctcpu * 100.0) / 0x8000;
202 <                proc_state_ptr->process_name = strdup(process_info.pr_fname);
203 <                proc_state_ptr->proctitle = strdup(process_info.pr_psargs);
202 >                proc_state_ptr->nice = (int)process_info.pr_lwp.pr_nice - 20;
203 >                if (sg_update_string(&proc_state_ptr->process_name,
204 >                                     process_info.pr_fname) < 0) {
205 >                        return NULL;
206 >                }
207 >                if (sg_update_string(&proc_state_ptr->proctitle,
208 >                                     process_info.pr_psargs) < 0) {
209 >                        return NULL;
210 >                }
211  
212 <                if(process_info.pr_lwp.pr_state==1) proc_state_ptr->state = SG_PROCESS_STATE_SLEEPING;
213 <                if(process_info.pr_lwp.pr_state==2) proc_state_ptr->state = SG_PROCESS_STATE_RUNNING;
214 <                if(process_info.pr_lwp.pr_state==3) proc_state_ptr->state = SG_PROCESS_STATE_ZOMBIE;
215 <                if(process_info.pr_lwp.pr_state==4) proc_state_ptr->state = SG_PROCESS_STATE_STOPPED;
216 <                if(process_info.pr_lwp.pr_state==6) proc_state_ptr->state = SG_PROCESS_STATE_RUNNING;
212 >                switch (process_info.pr_lwp.pr_state) {
213 >                case 1:
214 >                        proc_state_ptr->state = SG_PROCESS_STATE_SLEEPING;
215 >                        break;
216 >                case 2:
217 >                case 5:
218 >                        proc_state_ptr->state = SG_PROCESS_STATE_RUNNING;
219 >                        break;
220 >                case 3:
221 >                        proc_state_ptr->state = SG_PROCESS_STATE_ZOMBIE;
222 >                        break;
223 >                case 4:
224 >                        proc_state_ptr->state = SG_PROCESS_STATE_STOPPED;
225 >                        break;
226 >                }
227   #endif
228   #ifdef LINUX
229                  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));
230                  /* +3 becuase man page says "Resident  Set Size: number of pages the process has in real memory, minus 3 for administrative purposes." */
231                  proc_state_ptr->proc_resident = (proc_state_ptr->proc_resident + 3) * getpagesize();
232 <                if(s == 'S') proc_state_ptr->state = SG_PROCESS_STATE_SLEEPING;
233 <                if(s == 'R') proc_state_ptr->state = SG_PROCESS_STATE_RUNNING;
234 <                if(s == 'Z') proc_state_ptr->state = SG_PROCESS_STATE_ZOMBIE;
235 <                if(s == 'T') proc_state_ptr->state = SG_PROCESS_STATE_STOPPED;
236 <                if(s == 'D') proc_state_ptr->state = SG_PROCESS_STATE_STOPPED;
232 >                switch (s) {
233 >                case 'S':
234 >                        proc_state_ptr->state = SG_PROCESS_STATE_SLEEPING;
235 >                        break;
236 >                case 'R':
237 >                        proc_state_ptr->state = SG_PROCESS_STATE_RUNNING;
238 >                        break;
239 >                case 'Z':
240 >                        proc_state_ptr->state = SG_PROCESS_STATE_ZOMBIE;
241 >                        break;
242 >                case 'T':
243 >                case 'D':
244 >                        proc_state_ptr->state = SG_PROCESS_STATE_STOPPED;
245 >                        break;
246 >                }
247          
248                  /* pa_name[0] should = '(' */
249                  ptr = strchr(&ps_name[1], ')');
250                  if(ptr !=NULL) *ptr='\0';
251  
252                  if (sg_update_string(&proc_state_ptr->process_name,
253 <                                     &ps_name[1]) < 0) {
253 >                                     &ps_name[1]) < 0) {
254                          return NULL;
255                  }
256  
257                  /* cpu */
258                  proc_state_ptr->cpu_percent = (100.0 * (utime + stime)) / ((uptime * 100.0) - starttime);
259 <                printf("%s  ut: %lu st: %lu up: %lu start: %lu\n", proc_state_ptr->process_name, utime, stime, uptime , starttime);
259 >                tickspersec = sysconf (_SC_CLK_TCK);
260 >                if (tickspersec < 0) {
261 >                        proc_state_ptr->time_spent = 0;
262 >                }
263 >                else {
264 >                        proc_state_ptr->time_spent = (utime + stime) / tickspersec;
265 >                }
266  
267 <                fclose(f);
267 >                fclose(f);
268  
269 +                /* uid / gid */
270 +                snprintf(filename, MAX_FILE_LENGTH, "/proc/%s/status", dir_entry->d_name);
271 +                if ((f=fopen(filename, "r")) == NULL) {
272 +                        /* Open failed.. Process since vanished, or the path was too long.
273 +                         * Ah well, move onwards to the next one */
274 +                        continue;
275 +                }
276 +
277 +                if((ptr=sg_f_read_line(f, "Uid:"))==NULL){
278 +                        fclose(f);
279 +                        continue;
280 +                }
281 +                sscanf(ptr, "Uid:\t%d\t%d\t%*d\t%*d\n", &(proc_state_ptr->uid), &(proc_state_ptr->euid));
282 +
283 +                if((ptr=sg_f_read_line(f, "Gid:"))==NULL){
284 +                        fclose(f);
285 +                        continue;
286 +                }
287 +                sscanf(ptr, "Gid:\t%d\t%d\t%*d\t%*d\n", &(proc_state_ptr->gid), &(proc_state_ptr->egid));
288 +
289 +                fclose(f);
290 +
291                  /* proctitle */
292                  snprintf(filename, MAX_FILE_LENGTH, "/proc/%s/cmdline", dir_entry->d_name);
293  
294 <                if((fn=open(filename, O_RDONLY)) == -1){
295 <                        /* Open failed.. Process since vanished, or the path was too long.
296 <                         * Ah well, move onwards to the next one */
297 <                        continue;
298 <                }
294 >                if((fn=open(filename, O_RDONLY)) == -1){
295 >                        /* Open failed.. Process since vanished, or the path was too long.
296 >                         * Ah well, move onwards to the next one */
297 >                        continue;
298 >                }
299  
300   #define READ_BLOCK_SIZE 128
301                  len = 0;
# Line 265 | Line 341 | sg_process_stats *sg_get_process_stats(int *entries){
341   #endif
342  
343                  proc_state_size++;
344 <        }
345 <        closedir(proc_dir);
344 >        }
345 >        closedir(proc_dir);
346   #endif
347  
348   #ifdef ALLBSD
# Line 275 | Line 351 | sg_process_stats *sg_get_process_stats(int *entries){
351          mib[2] = KERN_PROC_ALL;
352  
353          if(sysctl(mib, 3, NULL, &size, NULL, 0) < 0) {
354 +                sg_set_error_with_errno(SG_ERROR_SYSCTL,
355 +                                        "CTL_KERN.KERN_PROC.KERN_PROC_ALL");
356                  return NULL;
357          }
358  
359          procs = size / sizeof(struct kinfo_proc);
360  
361 <        kp_stats = malloc(size);
361 >        kp_stats = sg_malloc(size);
362          if(kp_stats == NULL) {
363                  return NULL;
364          }
365          memset(kp_stats, 0, size);
366  
367          if(sysctl(mib, 3, kp_stats, &size, NULL, 0) < 0) {
368 +                sg_set_error_with_errno(SG_ERROR_SYSCTL,
369 +                                        "CTL_KERN.KERN_PROC.KERN_PROC_ALL");
370                  free(kp_stats);
371                  return NULL;
372          }
# Line 328 | Line 408 | sg_process_stats *sg_get_process_stats(int *entries){
408                  }
409  
410   #if defined(FREEBSD5) || defined(NETBSD) || defined(OPENBSD)
331                size = sizeof(buflen);
411  
412   #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
413                  mib[2] = KERN_PROC_ARGS;
414                  mib[3] = kp_stats[i].ki_pid;
415   #else
# Line 362 | Line 419 | sg_process_stats *sg_get_process_stats(int *entries){
419   #endif
420  
421                  free(proc_state_ptr->proctitle);
422 <                if(sysctl(mib, 4, proctitle, &size, NULL, 0) < 0) {
423 <                        free(proctitle);
424 <                        proc_state_ptr->proctitle = NULL;
425 <                }
426 <                else if(size > 0) {
427 <                        proc_state_ptr->proctitle = malloc(size+1);
422 >                proc_state_ptr->proctitle = NULL;
423 >
424 > /* Starting size - we'll double this straight away */
425 > #define PROCTITLE_START_SIZE 64
426 >                buflen = PROCTITLE_START_SIZE;
427 >                size = buflen;
428 >                proctitle = NULL;
429 >
430 >                do {
431 >                        if((long) size >= buflen) {
432 >                                buflen *= 2;
433 >                                size = buflen;
434 >                                proctitletmp = sg_realloc(proctitle, buflen);
435 >                                if(proctitletmp == NULL) {
436 >                                        free(proctitle);
437 >                                        proctitle = NULL;
438 >                                        proc_state_ptr->proctitle = NULL;
439 >                                        size = 0;
440 >                                        break;
441 >                                }
442 >                                proctitle = proctitletmp;
443 >                                bzero(proctitle, buflen);
444 >                        }
445 >
446 >                        if(sysctl(mib, 4, proctitle, &size, NULL, 0) < 0) {
447 >                                free(proctitle);
448 >                                proctitle = NULL;
449 >                                proc_state_ptr->proctitle = NULL;
450 >                                size = 0;
451 >                                break;
452 >                        }
453 >                } while((long) size >= buflen);
454 >
455 >                if(size > 0) {
456 >                        proc_state_ptr->proctitle = sg_malloc(size+1);
457                          if(proc_state_ptr->proctitle == NULL) {
458                                  return NULL;
459                          }
460                          p = proctitle;
461 + #ifdef OPENBSD
462 +                        /* On OpenBSD, this value has the argv pointers (which
463 +                         * are terminated by a NULL) at the front, so we have
464 +                         * to skip over them to get to the strings. */
465 +                        while (*(char ***)p != NULL) {
466 +                                p += sizeof(char **);
467 +                        }
468 +                        p += sizeof(char **);
469 + #endif
470                          proc_state_ptr->proctitle[0] = '\0';
471                          do {
472                                  sg_strlcat(proc_state_ptr->proctitle, p, size+1);
# Line 379 | Line 474 | sg_process_stats *sg_get_process_stats(int *entries){
474                                  p += strlen(p) + 1;
475                          } while (p < proctitle + size);
476                          free(proctitle);
477 +                        proctitle = NULL;
478                          /* remove trailing space */
479                          proc_state_ptr->proctitle[strlen(proc_state_ptr->proctitle)-1] = '\0';
480                  }
481                  else {
482 <                        free(proctitle);
482 >                        if(proctitle != NULL) {
483 >                                free(proctitle);
484 >                                proctitle = NULL;
485 >                        }
486                          proc_state_ptr->proctitle = NULL;
487                  }
488   #else
489                  free(proc_state_ptr->proctitle);
490 +                proc_state_ptr->proctitle = NULL;
491                  if(kvmd != NULL) {
492                          args = kvm_getargv(kvmd, &(kp_stats[i]), 0);
493                          if(args != NULL) {
# Line 396 | Line 496 | sg_process_stats *sg_get_process_stats(int *entries){
496                                          argslen += strlen(*argsp) + 1;
497                                          argsp++;
498                                  }
499 <                                proctitle = malloc(argslen + 1);
499 >                                proctitle = sg_malloc(argslen + 1);
500                                  proctitle[0] = '\0';
501                                  if(proctitle == NULL) {
502                                          return NULL;
# Line 492 | Line 592 | sg_process_stats *sg_get_process_stats(int *entries){
592                          mib[4] = 0;
593  
594                          if(sysctl(mib, 5, NULL, &size, NULL, 0) < 0) {
595 +                                sg_set_error_with_errno(SG_ERROR_SYSCTL, "CTL_KERN.KERN_LWP.pid.structsize.0");
596                                  return NULL;
597                          }
598  
599                          lwps = size / sizeof(struct kinfo_lwp);
600                          mib[4] = lwps;
601  
602 <                        kl_stats = malloc(size);
602 >                        kl_stats = sg_malloc(size);
603                          if(kl_stats == NULL) {
604                                  return NULL;
605                          }
606  
607                          if(sysctl(mib, 5, kl_stats, &size, NULL, 0) < 0) {
608 +                                sg_set_error_with_errno(SG_ERROR_SYSCTL, "CTL_KERN.KERN_LWP.pid.structsize.buffersize");
609                                  return NULL;
610                          }
611                  }
# Line 545 | Line 647 | sg_process_stats *sg_get_process_stats(int *entries){
647                          proc_state_ptr->state = SG_PROCESS_STATE_UNKNOWN;
648                          break;
649                  }
650 +
651 +                free(kl_stats);
652   #else
653   #ifdef FREEBSD5
654                  switch (kp_stats[i].ki_stat) {
# Line 587 | Line 691 | sg_process_stats *sg_get_process_stats(int *entries){
691          free(kp_stats);
692   #endif
693  
694 + #ifdef HPUX
695 +        if ((pagesize = sysconf(_SC_PAGESIZE)) == -1) {
696 +                sg_set_error_with_errno(SG_ERROR_SYSCONF, "_SC_PAGESIZE");
697 +                return NULL;
698 +        }
699 +
700 +        while (1) {
701 +                num = pstat_getproc(pstat_procinfo, sizeof pstat_procinfo[0],
702 +                                    PROCESS_BATCH, procidx);
703 +                if (num == -1) {
704 +                        sg_set_error_with_errno(SG_ERROR_PSTAT,
705 +                                                "pstat_getproc");
706 +                        return NULL;
707 +                } else if (num == 0) {
708 +                        break;
709 +                }
710 +
711 +                for (i = 0; i < num; i++) {
712 +                        struct pst_status *pi = &pstat_procinfo[i];
713 +
714 +                        if (VECTOR_RESIZE(proc_state, proc_state_size + 1) < 0) {
715 +                                return NULL;
716 +                        }
717 +                        proc_state_ptr = proc_state+proc_state_size;
718 +        
719 +                        proc_state_ptr->pid = pi->pst_pid;
720 +                        proc_state_ptr->parent = pi->pst_ppid;
721 +                        proc_state_ptr->pgid = pi->pst_pgrp;
722 +                        proc_state_ptr->uid = pi->pst_uid;
723 +                        proc_state_ptr->euid = pi->pst_euid;
724 +                        proc_state_ptr->gid = pi->pst_gid;
725 +                        proc_state_ptr->egid = pi->pst_egid;
726 +                        proc_state_ptr->proc_size = (pi->pst_dsize + pi->pst_tsize + pi->pst_ssize) * pagesize;
727 +                        proc_state_ptr->proc_resident = pi->pst_rssize * pagesize;
728 +                        proc_state_ptr->time_spent = pi->pst_time;
729 +                        proc_state_ptr->cpu_percent = (pi->pst_pctcpu * 100.0) / 0x8000;
730 +                        proc_state_ptr->nice = pi->pst_nice;
731 +        
732 +                        if (sg_update_string(&proc_state_ptr->process_name,
733 +                                             pi->pst_ucomm) < 0) {
734 +                                return NULL;
735 +                        }
736 +                        if (sg_update_string(&proc_state_ptr->proctitle,
737 +                                             pi->pst_cmd) < 0) {
738 +                                return NULL;
739 +                        }
740 +        
741 +                        switch (pi->pst_stat) {
742 +                        case PS_SLEEP:
743 +                                proc_state_ptr->state = SG_PROCESS_STATE_SLEEPING;
744 +                                break;
745 +                        case PS_RUN:
746 +                                proc_state_ptr->state = SG_PROCESS_STATE_RUNNING;
747 +                                break;
748 +                        case PS_STOP:
749 +                                proc_state_ptr->state = SG_PROCESS_STATE_STOPPED;
750 +                                break;
751 +                        case PS_ZOMBIE:
752 +                                proc_state_ptr->state = SG_PROCESS_STATE_ZOMBIE;
753 +                                break;
754 +                        case PS_IDLE:
755 +                        case PS_OTHER:
756 +                                proc_state_ptr->state = SG_PROCESS_STATE_UNKNOWN;
757 +                                break;
758 +                        }
759 +        
760 +                        proc_state_size++;
761 +                }
762 +                procidx = pstat_procinfo[num - 1].pst_idx + 1;
763 +        }
764 + #endif
765 +
766   #ifdef CYGWIN
767 +        sg_set_error(SG_ERROR_UNSUPPORTED, "Cygwin");
768          return NULL;
769   #endif
770 + #ifdef WIN32
771 +        /* FIXME The data needed for this is probably do able with the
772 +         * "performance registry". Although using this appears to be a black
773 +         * art and closely guarded secret.
774 +         * This is not directly used in ihost, so not considered a priority */
775 +        sg_set_error(SG_ERROR_UNSUPPORTED, "Win32");
776 +        return NULL;
777 + #endif
778  
779          *entries = proc_state_size;
780          return proc_state;
# Line 597 | Line 782 | sg_process_stats *sg_get_process_stats(int *entries){
782  
783   sg_process_count *sg_get_process_count() {
784          static sg_process_count process_stat;
785 + #ifndef WIN32
786          sg_process_stats *ps;
787          int ps_size, x;
788 + #else
789 +        DWORD aProcesses[1024];
790 +        DWORD cbNeeded;
791 + #endif
792  
793          process_stat.sleeping = 0;
794          process_stat.running = 0;
# Line 606 | Line 796 | sg_process_count *sg_get_process_count() {
796          process_stat.stopped = 0;
797          process_stat.total = 0;
798  
799 + #ifndef WIN32
800          ps = sg_get_process_stats(&ps_size);
801          if (ps == NULL) {
802                  return NULL;
# Line 634 | Line 825 | sg_process_count *sg_get_process_count() {
825          }
826  
827          process_stat.total = ps_size;
828 + #else
829 +        if (!EnumProcesses(aProcesses, sizeof(aProcesses), &cbNeeded))
830 +                return NULL;
831 +        process_stat.total = cbNeeded / sizeof(DWORD);
832 + #endif
833  
834          return &process_stat;
835   }
836 +
837 + int sg_process_compare_name(const void *va, const void *vb) {
838 +        const sg_process_stats *a = (sg_process_stats *)va;
839 +        const sg_process_stats *b = (sg_process_stats *)vb;
840 +
841 +        return strcmp(a->process_name, b->process_name);
842 + }
843 +
844 + int sg_process_compare_pid(const void *va, const void *vb) {
845 +        const sg_process_stats *a = (sg_process_stats *)va;
846 +        const sg_process_stats *b = (sg_process_stats *)vb;
847 +
848 +        if (a->pid < b->pid) {
849 +                return -1;
850 +        } else if (a->pid == b->pid) {
851 +                return 0;
852 +        } else {
853 +                return 1;
854 +        }
855 + }
856 +
857 + int sg_process_compare_uid(const void *va, const void *vb) {
858 +        const sg_process_stats *a = (sg_process_stats *)va;
859 +        const sg_process_stats *b = (sg_process_stats *)vb;
860 +
861 +        if (a->uid < b->uid) {
862 +                return -1;
863 +        } else if (a->uid == b->uid) {
864 +                return 0;
865 +        } else {
866 +                return 1;
867 +        }
868 + }
869 +
870 + int sg_process_compare_gid(const void *va, const void *vb) {
871 +        const sg_process_stats *a = (sg_process_stats *)va;
872 +        const sg_process_stats *b = (sg_process_stats *)vb;
873 +
874 +        if (a->gid < b->gid) {
875 +                return -1;
876 +        } else if (a->gid == b->gid) {
877 +                return 0;
878 +        } else {
879 +                return 1;
880 +        }
881 + }
882 +
883 + int sg_process_compare_size(const void *va, const void *vb) {
884 +        const sg_process_stats *a = (sg_process_stats *)va;
885 +        const sg_process_stats *b = (sg_process_stats *)vb;
886 +
887 +        if (a->proc_size < b->proc_size) {
888 +                return -1;
889 +        } else if (a->proc_size == b->proc_size) {
890 +                return 0;
891 +        } else {
892 +                return 1;
893 +        }
894 + }
895 +
896 + int sg_process_compare_res(const void *va, const void *vb) {
897 +        const sg_process_stats *a = (sg_process_stats *)va;
898 +        const sg_process_stats *b = (sg_process_stats *)vb;
899 +
900 +        if (a->proc_resident < b->proc_resident) {
901 +                return -1;
902 +        } else if (a->proc_resident == b->proc_resident) {
903 +                return 0;
904 +        } else {
905 +                return 1;
906 +        }
907 + }
908 +
909 + int sg_process_compare_cpu(const void *va, const void *vb) {
910 +        const sg_process_stats *a = (sg_process_stats *)va;
911 +        const sg_process_stats *b = (sg_process_stats *)vb;
912 +
913 +        if (a->cpu_percent < b->cpu_percent) {
914 +                return -1;
915 +        } else if (a->cpu_percent == b->cpu_percent) {
916 +                return 0;
917 +        } else {
918 +                return 1;
919 +        }
920 + }
921 +
922 + int sg_process_compare_time(const void *va, const void *vb) {
923 +        const sg_process_stats *a = (sg_process_stats *)va;
924 +        const sg_process_stats *b = (sg_process_stats *)vb;
925 +
926 +        if (a->time_spent < b->time_spent) {
927 +                return -1;
928 +        } else if (a->time_spent == b->time_spent) {
929 +                return 0;
930 +        } else {
931 +                return 1;
932 +        }
933 + }
934 +

Diff Legend

Removed lines
+ Added lines
< Changed lines
> Changed lines