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.62 by pajs, Wed Apr 7 14:45:33 2004 UTC vs.
Revision 1.63 by tdb, Wed Apr 7 14:53:40 2004 UTC

# Line 84 | Line 84 | static void proc_state_destroy(sg_process_stats *s) {
84  
85   sg_process_stats *sg_get_process_stats(int *entries){
86          VECTOR_DECLARE_STATIC(proc_state, sg_process_stats, 64,
87 <                              proc_state_init, proc_state_destroy);
87 >                              proc_state_init, proc_state_destroy);
88          int proc_state_size = 0;
89          sg_process_stats *proc_state_ptr;
90   #ifdef ALLBSD
# Line 107 | Line 107 | sg_process_stats *sg_get_process_stats(int *entries){
107   #endif
108   #endif
109   #if defined(SOLARIS) || defined(LINUX)
110 <        DIR *proc_dir;
111 <        struct dirent *dir_entry;
112 <        char filename[MAX_FILE_LENGTH];
113 <        FILE *f;
110 >        DIR *proc_dir;
111 >        struct dirent *dir_entry;
112 >        char filename[MAX_FILE_LENGTH];
113 >        FILE *f;
114   #ifdef SOLARIS
115          psinfo_t process_info;
116   #endif
# Line 138 | Line 138 | sg_process_stats *sg_get_process_stats(int *entries){
138          fclose(f);
139   #endif
140  
141 <        if((proc_dir=opendir(PROC_LOCATION))==NULL){
142 <                return NULL;
143 <        }
141 >        if((proc_dir=opendir(PROC_LOCATION))==NULL){
142 >                return NULL;
143 >        }
144  
145 <        while((dir_entry=readdir(proc_dir))!=NULL){
146 <                if(atoi(dir_entry->d_name) == 0) continue;
145 >        while((dir_entry=readdir(proc_dir))!=NULL){
146 >                if(atoi(dir_entry->d_name) == 0) continue;
147  
148   #ifdef SOLARIS
149 <                snprintf(filename, MAX_FILE_LENGTH, "/proc/%s/psinfo", dir_entry->d_name);
149 >                snprintf(filename, MAX_FILE_LENGTH, "/proc/%s/psinfo", dir_entry->d_name);
150   #endif
151   #ifdef LINUX
152                  snprintf(filename, MAX_FILE_LENGTH, "/proc/%s/stat", dir_entry->d_name);
153   #endif
154 <                if((f=fopen(filename, "r"))==NULL){
155 <                        /* Open failed.. Process since vanished, or the path was too long.
156 <                         * Ah well, move onwards to the next one */
157 <                        continue;
158 <                }
154 >                if((f=fopen(filename, "r"))==NULL){
155 >                        /* Open failed.. Process since vanished, or the path was too long.
156 >                         * Ah well, move onwards to the next one */
157 >                        continue;
158 >                }
159   #ifdef SOLARIS
160 <                fread(&process_info, sizeof(psinfo_t), 1, f);
160 >                fread(&process_info, sizeof(psinfo_t), 1, f);
161   #endif
162  
163                  if (VECTOR_RESIZE(proc_state, proc_state_size + 1) < 0) {
# Line 178 | Line 178 | sg_process_stats *sg_get_process_stats(int *entries){
178                  proc_state_ptr->time_spent = process_info.pr_time.tv_sec;
179                  proc_state_ptr->cpu_percent = (process_info.pr_pctcpu * 100.0) / 0x8000;
180                  if (sg_update_string(&proc_state_ptr->process_name,
181 <                                     process_info.pr_fname) < 0) {
181 >                                     process_info.pr_fname) < 0) {
182                          return NULL;
183                  }
184                  if (sg_update_string(&proc_state_ptr->proctitle,
185 <                                     process_info.pr_psargs) < 0) {
185 >                                     process_info.pr_psargs) < 0) {
186                          return NULL;
187                  }
188  
189 <                if(process_info.pr_lwp.pr_state==1) proc_state_ptr->state = SG_PROCESS_STATE_SLEEPING;
190 <                if(process_info.pr_lwp.pr_state==2) proc_state_ptr->state = SG_PROCESS_STATE_RUNNING;
191 <                if(process_info.pr_lwp.pr_state==3) proc_state_ptr->state = SG_PROCESS_STATE_ZOMBIE;
192 <                if(process_info.pr_lwp.pr_state==4) proc_state_ptr->state = SG_PROCESS_STATE_STOPPED;
193 <                if(process_info.pr_lwp.pr_state==6) proc_state_ptr->state = SG_PROCESS_STATE_RUNNING;
189 >                if(process_info.pr_lwp.pr_state==1) proc_state_ptr->state = SG_PROCESS_STATE_SLEEPING;
190 >                if(process_info.pr_lwp.pr_state==2) proc_state_ptr->state = SG_PROCESS_STATE_RUNNING;
191 >                if(process_info.pr_lwp.pr_state==3) proc_state_ptr->state = SG_PROCESS_STATE_ZOMBIE;
192 >                if(process_info.pr_lwp.pr_state==4) proc_state_ptr->state = SG_PROCESS_STATE_STOPPED;
193 >                if(process_info.pr_lwp.pr_state==6) proc_state_ptr->state = SG_PROCESS_STATE_RUNNING;
194   #endif
195   #ifdef LINUX
196                  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));
# Line 207 | Line 207 | sg_process_stats *sg_get_process_stats(int *entries){
207                  if(ptr !=NULL) *ptr='\0';
208  
209                  if (sg_update_string(&proc_state_ptr->process_name,
210 <                                     &ps_name[1]) < 0) {
210 >                                     &ps_name[1]) < 0) {
211                          return NULL;
212                  }
213  
214                  /* cpu */
215                  proc_state_ptr->cpu_percent = (100.0 * (utime + stime)) / ((uptime * 100.0) - starttime);
216  
217 <                fclose(f);
217 >                fclose(f);
218  
219                  /* uid / gid */
220                  snprintf(filename, MAX_FILE_LENGTH, "/proc/%s/status", dir_entry->d_name);
221 <                if ((f=fopen(filename, "r")) == NULL) {
222 <                        /* Open failed.. Process since vanished, or the path was too long.
223 <                         * Ah well, move onwards to the next one */
224 <                        continue;
225 <                }
221 >                if ((f=fopen(filename, "r")) == NULL) {
222 >                        /* Open failed.. Process since vanished, or the path was too long.
223 >                         * Ah well, move onwards to the next one */
224 >                        continue;
225 >                }
226  
227                  if((ptr=sg_f_read_line(f, "Uid:"))==NULL){
228                          fclose(f);
# Line 231 | Line 231 | sg_process_stats *sg_get_process_stats(int *entries){
231                  sscanf(ptr, "Uid:\t%d\t%d\t%*d\t%*d\n", &(proc_state_ptr->uid), &(proc_state_ptr->euid));
232  
233                  if((ptr=sg_f_read_line(f, "Gid:"))==NULL){
234 <                        fclose(f);
235 <                        continue;
236 <                }
237 <                sscanf(ptr, "Gid:\t%d\t%d\t%*d\t%*d\n", &(proc_state_ptr->gid), &(proc_state_ptr->egid));
234 >                        fclose(f);
235 >                        continue;
236 >                }
237 >                sscanf(ptr, "Gid:\t%d\t%d\t%*d\t%*d\n", &(proc_state_ptr->gid), &(proc_state_ptr->egid));
238  
239                  fclose(f);
240  
241                  /* proctitle */
242                  snprintf(filename, MAX_FILE_LENGTH, "/proc/%s/cmdline", dir_entry->d_name);
243  
244 <                if((fn=open(filename, O_RDONLY)) == -1){
245 <                        /* Open failed.. Process since vanished, or the path was too long.
246 <                         * Ah well, move onwards to the next one */
247 <                        continue;
248 <                }
244 >                if((fn=open(filename, O_RDONLY)) == -1){
245 >                        /* Open failed.. Process since vanished, or the path was too long.
246 >                         * Ah well, move onwards to the next one */
247 >                        continue;
248 >                }
249  
250   #define READ_BLOCK_SIZE 128
251                  len = 0;
# Line 291 | Line 291 | sg_process_stats *sg_get_process_stats(int *entries){
291   #endif
292  
293                  proc_state_size++;
294 <        }
295 <        closedir(proc_dir);
294 >        }
295 >        closedir(proc_dir);
296   #endif
297  
298   #ifdef ALLBSD

Diff Legend

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