ProcessList.c 26 KB
Newer Older
Hisham Muhammad's avatar
Hisham Muhammad committed
1
2
3
4
5
6
7
/*
htop - ProcessList.c
(C) 2004,2005 Hisham H. Muhammad
Released under the GNU GPL, see the COPYING file
in the source distribution for its full text.
*/

8
9
10
11
12
#ifndef CONFIG_H
#define CONFIG_H
#include "config.h"
#endif

Hisham Muhammad's avatar
Hisham Muhammad committed
13
14
#include "ProcessList.h"
#include "Process.h"
15
#include "Vector.h"
Hisham Muhammad's avatar
Hisham Muhammad committed
16
17
#include "UsersTable.h"
#include "Hashtable.h"
18
#include "String.h"
Hisham Muhammad's avatar
Hisham Muhammad committed
19
20
21
22
23
24
25
26
27
28

#include <sys/types.h>
#include <sys/stat.h>
#include <unistd.h>
#include <dirent.h>
#include <stdlib.h>
#include <stdio.h>
#include <signal.h>
#include <stdbool.h>
#include <sys/utsname.h>
Hisham Muhammad's avatar
Hisham Muhammad committed
29
#include <stdarg.h>
Hisham Muhammad's avatar
Hisham Muhammad committed
30
#include <math.h>
Hisham Muhammad's avatar
Hisham Muhammad committed
31
32
33
34
35

#include "debug.h"
#include <assert.h>

/*{
36

Hisham Muhammad's avatar
Hisham Muhammad committed
37
38
39
40
41
#ifndef PROCDIR
#define PROCDIR "/proc"
#endif

#ifndef PROCSTATFILE
42
#define PROCSTATFILE PROCDIR "/stat"
Hisham Muhammad's avatar
Hisham Muhammad committed
43
44
45
#endif

#ifndef PROCMEMINFOFILE
46
#define PROCMEMINFOFILE PROCDIR "/meminfo"
Hisham Muhammad's avatar
Hisham Muhammad committed
47
48
49
#endif

#ifndef MAX_NAME
Hisham Muhammad's avatar
Hisham Muhammad committed
50
51
52
53
#define MAX_NAME 128
#endif

#ifndef MAX_READ
54
#define MAX_READ 2048
Hisham Muhammad's avatar
Hisham Muhammad committed
55
56
#endif

57
58
59
#ifndef ProcessList_cpuId
#define ProcessList_cpuId(pl, cpu) ((pl)->countCPUsFromZero ? (cpu)-1 : (cpu))
#endif
Hisham Muhammad's avatar
Hisham Muhammad committed
60
61
62
63
}*/

/*{

64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
typedef struct CPUData_ {
   unsigned long long int totalTime;
   unsigned long long int userTime;
   unsigned long long int systemTime;
   unsigned long long int systemAllTime;
   unsigned long long int idleAllTime;
   unsigned long long int idleTime;
   unsigned long long int niceTime;
   unsigned long long int ioWaitTime;
   unsigned long long int irqTime;
   unsigned long long int softIrqTime;
   unsigned long long int stealTime;
   unsigned long long int guestTime;
   
   unsigned long long int totalPeriod;
   unsigned long long int userPeriod;
   unsigned long long int systemPeriod;
   unsigned long long int systemAllPeriod;
   unsigned long long int idleAllPeriod;
   unsigned long long int idlePeriod;
   unsigned long long int nicePeriod;
   unsigned long long int ioWaitPeriod;
   unsigned long long int irqPeriod;
   unsigned long long int softIrqPeriod;
   unsigned long long int stealPeriod;
   unsigned long long int guestPeriod;
} CPUData;

Hisham Muhammad's avatar
Hisham Muhammad committed
92
typedef struct ProcessList_ {
93
94
   Vector* processes;
   Vector* processes2;
Hisham Muhammad's avatar
Hisham Muhammad committed
95
96
97
   Hashtable* processTable;
   UsersTable* usersTable;

98
   int cpuCount;
Hisham Muhammad's avatar
Hisham Muhammad committed
99
   int totalTasks;
100
101
   int userlandThreads;
   int kernelThreads;
Hisham Muhammad's avatar
Hisham Muhammad committed
102
103
   int runningTasks;

104
   CPUData* cpus;
105
106
107
108
109
110
111
112
113
114

   unsigned long long int totalMem;
   unsigned long long int usedMem;
   unsigned long long int freeMem;
   unsigned long long int sharedMem;
   unsigned long long int buffersMem;
   unsigned long long int cachedMem;
   unsigned long long int totalSwap;
   unsigned long long int usedSwap;
   unsigned long long int freeSwap;
Hisham Muhammad's avatar
Hisham Muhammad committed
115
116
117
118
119
120

   ProcessField* fields;
   ProcessField sortKey;
   int direction;
   bool hideThreads;
   bool shadowOtherUsers;
Hisham Muhammad's avatar
Hisham Muhammad committed
121
122
   bool showThreadNames;
   bool showingThreadNames;
Hisham Muhammad's avatar
Hisham Muhammad committed
123
124
125
126
127
   bool hideKernelThreads;
   bool hideUserlandThreads;
   bool treeView;
   bool highlightBaseName;
   bool highlightMegabytes;
128
   bool highlightThreads;
129
   bool detailedCPUTime;
130
   bool countCPUsFromZero;
Hisham Muhammad's avatar
Hisham Muhammad committed
131
132
133
134

} ProcessList;
}*/

135
static ProcessField defaultHeaders[] = { PID, USER, PRIORITY, NICE, M_SIZE, M_RESIDENT, M_SHARE, STATE, PERCENT_CPU, PERCENT_MEM, TIME, COMM, 0 };
Hisham Muhammad's avatar
Hisham Muhammad committed
136
137
138

ProcessList* ProcessList_new(UsersTable* usersTable) {
   ProcessList* this;
139
   this = calloc(sizeof(ProcessList), 1);
140
   this->processes = Vector_new(PROCESS_CLASS, true, DEFAULT_SIZE, Process_compare);
141
   this->processTable = Hashtable_new(70, false);
142
   assert(Hashtable_count(this->processTable) == Vector_count(this->processes));
Hisham Muhammad's avatar
Hisham Muhammad committed
143
144
145
   this->usersTable = usersTable;
   
   /* tree-view auxiliary buffers */
146
   this->processes2 = Vector_new(PROCESS_CLASS, true, DEFAULT_SIZE, Process_compare);
Hisham Muhammad's avatar
Hisham Muhammad committed
147
   
148
149
   FILE* file = fopen(PROCSTATFILE, "r");
   assert(file != NULL);
Hisham Muhammad's avatar
Hisham Muhammad committed
150
   char buffer[256];
151
   int cpus = -1;
Hisham Muhammad's avatar
Hisham Muhammad committed
152
   do {
153
      cpus++;
154
      fgets(buffer, 255, file);
Hisham Muhammad's avatar
Hisham Muhammad committed
155
   } while (String_startsWith(buffer, "cpu"));
156
   fclose(file);
157
   this->cpuCount = cpus - 1;
158
   
159
   this->cpus = calloc(sizeof(CPUData), cpus);
160

161
162
163
   for (int i = 0; i < cpus; i++) {
      this->cpus[i].totalTime = 1;
      this->cpus[i].totalPeriod = 1;
Hisham Muhammad's avatar
Hisham Muhammad committed
164
165
166
   }

   this->fields = calloc(sizeof(ProcessField), LAST_PROCESSFIELD+1);
167
   // TODO: turn 'fields' into a Vector,
Hisham Muhammad's avatar
Hisham Muhammad committed
168
169
170
171
172
173
174
175
   // (and ProcessFields into proper objects).
   for (int i = 0; defaultHeaders[i]; i++) {
      this->fields[i] = defaultHeaders[i];
   }
   this->sortKey = PERCENT_CPU;
   this->direction = 1;
   this->hideThreads = false;
   this->shadowOtherUsers = false;
176
177
   this->showThreadNames = false;
   this->showingThreadNames = false;
Hisham Muhammad's avatar
Hisham Muhammad committed
178
179
180
181
182
   this->hideKernelThreads = false;
   this->hideUserlandThreads = false;
   this->treeView = false;
   this->highlightBaseName = false;
   this->highlightMegabytes = false;
183
   this->detailedCPUTime = false;
184
   this->countCPUsFromZero = false;
Hisham Muhammad's avatar
Hisham Muhammad committed
185
186
187
188
189
190

   return this;
}

void ProcessList_delete(ProcessList* this) {
   Hashtable_delete(this->processTable);
191
192
   Vector_delete(this->processes);
   Vector_delete(this->processes2);
193
   free(this->cpus);
Hisham Muhammad's avatar
Hisham Muhammad committed
194
195
196
197
198
199
200
201
202
203
204
   free(this->fields);
   free(this);
}

void ProcessList_invertSortOrder(ProcessList* this) {
   if (this->direction == 1)
      this->direction = -1;
   else
      this->direction = 1;
}

205
206
void ProcessList_printHeader(ProcessList* this, RichString* header) {
   RichString_prune(header);
Hisham Muhammad's avatar
Hisham Muhammad committed
207
208
   ProcessField* fields = this->fields;
   for (int i = 0; fields[i]; i++) {
Hisham Muhammad's avatar
Hisham Muhammad committed
209
      const char* field = Process_fieldTitles[fields[i]];
Hisham Muhammad's avatar
Hisham Muhammad committed
210
      if (this->sortKey == fields[i])
211
         RichString_append(header, CRT_colors[PANEL_HIGHLIGHT_FOCUS], field);
Hisham Muhammad's avatar
Hisham Muhammad committed
212
      else
213
         RichString_append(header, CRT_colors[PANEL_HEADER_FOCUS], field);
Hisham Muhammad's avatar
Hisham Muhammad committed
214
215
216
   }
}

217
static void ProcessList_add(ProcessList* this, Process* p) {
218
219
   assert(Vector_indexOf(this->processes, p, Process_pidCompare) == -1);
   assert(Hashtable_get(this->processTable, p->pid) == NULL);
220
   
221
   Vector_add(this->processes, p);
Hisham Muhammad's avatar
Hisham Muhammad committed
222
   Hashtable_put(this->processTable, p->pid, p);
223
   
224
225
   assert(Vector_indexOf(this->processes, p, Process_pidCompare) != -1);
   assert(Hashtable_get(this->processTable, p->pid) != NULL);
226
   assert(Hashtable_count(this->processTable) == Vector_count(this->processes));
Hisham Muhammad's avatar
Hisham Muhammad committed
227
228
}

229
static void ProcessList_remove(ProcessList* this, Process* p) {
230
231
232
   assert(Vector_indexOf(this->processes, p, Process_pidCompare) != -1);
   assert(Hashtable_get(this->processTable, p->pid) != NULL);
   Process* pp = Hashtable_remove(this->processTable, p->pid);
233
   assert(pp == p); (void)pp;
234
   unsigned int pid = p->pid;
Hisham Muhammad's avatar
Hisham Muhammad committed
235
236
237
   int idx = Vector_indexOf(this->processes, p, Process_pidCompare);
   assert(idx != -1);
   if (idx >= 0) Vector_remove(this->processes, idx);
238
   assert(Hashtable_get(this->processTable, pid) == NULL); (void)pid;
239
   assert(Hashtable_count(this->processTable) == Vector_count(this->processes));
Hisham Muhammad's avatar
Hisham Muhammad committed
240
241
}

Hisham Muhammad's avatar
Hisham Muhammad committed
242
243
Process* ProcessList_get(ProcessList* this, int idx) {
   return (Process*) (Vector_get(this->processes, idx));
Hisham Muhammad's avatar
Hisham Muhammad committed
244
245
246
}

int ProcessList_size(ProcessList* this) {
247
   return (Vector_size(this->processes));
Hisham Muhammad's avatar
Hisham Muhammad committed
248
249
}

Hisham Muhammad's avatar
Hisham Muhammad committed
250
static void ProcessList_buildTree(ProcessList* this, pid_t pid, int level, int indent, int direction, bool show) {
251
   Vector* children = Vector_new(PROCESS_CLASS, false, DEFAULT_SIZE, Process_compare);
Hisham Muhammad's avatar
Hisham Muhammad committed
252

253
   for (int i = Vector_size(this->processes) - 1; i >= 0; i--) {
254
      Process* process = (Process*) (Vector_get(this->processes, i));
255
      if (process->tgid == pid || (process->tgid == process->pid && process->ppid == pid)) {
Hisham Muhammad's avatar
Hisham Muhammad committed
256
         process = (Process*) (Vector_take(this->processes, i));
257
         Vector_add(children, process);
Hisham Muhammad's avatar
Hisham Muhammad committed
258
259
      }
   }
260
   int size = Vector_size(children);
Hisham Muhammad's avatar
Hisham Muhammad committed
261
   for (int i = 0; i < size; i++) {
262
      Process* process = (Process*) (Vector_get(children, i));
263
264
265
266
267
268
269
270
271
      if (!show)
         process->show = false;
      int s = this->processes2->items;
      if (direction == 1)
         Vector_add(this->processes2, process);
      else
         Vector_insert(this->processes2, 0, process);
      assert(this->processes2->items == s+1); (void)s;
      int nextIndent = indent | (1 << level);
272
      ProcessList_buildTree(this, process->pid, level+1, (i < size - 1) ? nextIndent : indent, direction, show ? process->showChildren : false);
273
      process->indent = nextIndent;
Hisham Muhammad's avatar
Hisham Muhammad committed
274
   }
275
   Vector_delete(children);
Hisham Muhammad's avatar
Hisham Muhammad committed
276
277
278
279
}

void ProcessList_sort(ProcessList* this) {
   if (!this->treeView) {
280
      Vector_sort(this->processes);
Hisham Muhammad's avatar
Hisham Muhammad committed
281
   } else {
282
      // Save settings
Hisham Muhammad's avatar
Hisham Muhammad committed
283
284
      int direction = this->direction;
      int sortKey = this->sortKey;
285
      // Sort by PID
Hisham Muhammad's avatar
Hisham Muhammad committed
286
287
      this->sortKey = PID;
      this->direction = 1;
288
      Vector_sort(this->processes);
289
      // Restore settings
Hisham Muhammad's avatar
Hisham Muhammad committed
290
291
      this->sortKey = sortKey;
      this->direction = direction;
292
      // Take PID 1 as root and add to the new listing
293
      int vsize = Vector_size(this->processes);
294
      Process* init = (Process*) (Vector_take(this->processes, 0));
295
296
297
      // This assertion crashes on hardened kernels.
      // I wonder how well tree view works on those systems.
      // assert(init->pid == 1);
Hisham Muhammad's avatar
Hisham Muhammad committed
298
      init->indent = 0;
299
      Vector_add(this->processes2, init);
300
      // Recursively empty list
Hisham Muhammad's avatar
Hisham Muhammad committed
301
      ProcessList_buildTree(this, init->pid, 0, 0, direction, true);
302
      // Add leftovers
303
304
305
306
      while (Vector_size(this->processes)) {
         Process* p = (Process*) (Vector_take(this->processes, 0));
         p->indent = 0;
         Vector_add(this->processes2, p);
Hisham Muhammad's avatar
Hisham Muhammad committed
307
         ProcessList_buildTree(this, p->pid, 0, 0, direction, p->showChildren);
308
309
310
      }
      assert(Vector_size(this->processes2) == vsize); (void)vsize;
      assert(Vector_size(this->processes) == 0);
311
      // Swap listings around
312
      Vector* t = this->processes;
Hisham Muhammad's avatar
Hisham Muhammad committed
313
314
315
316
317
      this->processes = this->processes2;
      this->processes2 = t;
   }
}

318
319
320
321
322
323
324
static bool ProcessList_readStatFile(Process *process, const char* dirname, const char* name, char* command) {
   char filename[MAX_NAME+1];
   snprintf(filename, MAX_NAME, "%s/%s/stat", dirname, name);
   FILE* file = fopen(filename, "r");
   if (!file)
      return false;

Hisham Muhammad's avatar
Hisham Muhammad committed
325
326
   static char buf[MAX_READ];

327
328
   int size = fread(buf, 1, MAX_READ, file);
   if (!size) { fclose(file); return false; }
Hisham Muhammad's avatar
Hisham Muhammad committed
329

330
   assert(process->pid == atoi(buf));
Hisham Muhammad's avatar
Hisham Muhammad committed
331
   char *location = strchr(buf, ' ');
332
   if (!location) { fclose(file); return false; }
Hisham Muhammad's avatar
Hisham Muhammad committed
333
334
335

   location += 2;
   char *end = strrchr(location, ')');
336
   if (!end) { fclose(file); return false; }
Hisham Muhammad's avatar
Hisham Muhammad committed
337
338
339
340
341
   
   int commsize = end - location;
   memcpy(command, location, commsize);
   command[commsize] = '\0';
   location = end + 2;
342
343
344
345
346

   int num = sscanf(location, 
      "%c %d %u %u %u "
      "%d %lu "
      "%*u %*u %*u %*u "
347
      "%llu %llu %llu %llu "
348
349
      "%ld %ld %ld "
      "%*d %*u %*u %*d %*u %*u %*u %*u %*u %*u %*u %*u %*u %*u %*u %*u %*u "
350
      "%d %d",
351
352
353
354
355
356
357
      &process->state, &process->ppid, &process->pgrp, &process->session, &process->tty_nr, 
      &process->tpgid, &process->flags,
      &process->utime, &process->stime, &process->cutime, &process->cstime, 
      &process->priority, &process->nice, &process->nlwp,
      &process->exit_signal, &process->processor);
   fclose(file);
   return (num == 16);
Hisham Muhammad's avatar
Hisham Muhammad committed
358
359
}

360
361
362
static bool ProcessList_statProcessDir(Process* process, const char* dirname, char* name) {
   char filename[MAX_NAME+1];
   filename[MAX_NAME] = '\0';
363

364
   snprintf(filename, MAX_NAME, "%s/%s", dirname, name);
365
   struct stat sstat;
366
   int statok = stat(filename, &sstat);
367
368
   if (statok == -1)
      return false;
369
   process->st_uid = sstat.st_uid;
Hisham Muhammad's avatar
Hisham Muhammad committed
370
371
372
  
   struct tm date;
   time_t ctime = sstat.st_ctime;
373
   process->starttime_ctime = ctime;
Hisham Muhammad's avatar
Hisham Muhammad committed
374
   (void) localtime_r((time_t*) &ctime, &date);
375
   strftime(process->starttime_show, 7, ((ctime > time(NULL) - 86400) ? "%R " : "%b%d "), &date);
Hisham Muhammad's avatar
Hisham Muhammad committed
376
   
377
   return true;
Hisham Muhammad's avatar
Hisham Muhammad committed
378
379
}

380
#ifdef HAVE_TASKSTATS
381

382
383
384
static void ProcessList_readIoFile(Process* process, const char* dirname, char* name) {
   char filename[MAX_NAME+1];
   filename[MAX_NAME] = '\0';
385

386
387
388
389
390
391
392
393
394
395
396
397
398
399
400
401
402
403
404
405
406
407
408
409
410
411
412
413
414
415
416
417
418
419
420
421
422
423
424
425
426
427
428
429
430
431
432
433
434
435
436
437
438
439
440
441
442
443
444
445
446
447
448
449
450
451
452
453
454
455
456
457
458
459
460
461
462
463
464
465
466
467
468
469
470
471
472
473
474
475
476
477
478
479
480
481
482
483
484
485
486
487
488
489
490
491
492
493
494
495
496
497
498
499
500
501
502
503
504
   snprintf(filename, MAX_NAME, "%s/%s/io", dirname, name);
   FILE* file = fopen(filename, "r");
   if (!file)
      return;
   
   char buffer[256];
   buffer[255] = '\0';
   struct timeval tv;
   gettimeofday(&tv,NULL);
   unsigned long long now = tv.tv_sec*1000+tv.tv_usec/1000;
   unsigned long long last_read = process->io_read_bytes;
   unsigned long long last_write = process->io_write_bytes;
   while (fgets(buffer, 255, file)) {
      if (sscanf(buffer, "rchar: %llu", &process->io_rchar)) continue;
      if (sscanf(buffer, "wchar: %llu", &process->io_wchar)) continue;
      if (sscanf(buffer, "syscr: %llu", &process->io_syscr)) continue;
      if (sscanf(buffer, "syscw: %llu", &process->io_syscw)) continue;
      if (sscanf(buffer, "read_bytes: %llu", &process->io_read_bytes)) {
         process->io_rate_read_bps = 
            ((double)(process->io_read_bytes - last_read))/(((double)(now - process->io_rate_read_time))/1000);
         process->io_rate_read_time = now;
         continue;
      }
      if (sscanf(buffer, "write_bytes: %llu", &process->io_write_bytes)) {
         process->io_rate_write_bps = 
            ((double)(process->io_write_bytes - last_write))/(((double)(now - process->io_rate_write_time))/1000);
         process->io_rate_write_time = now;
         continue;
      }
      sscanf(buffer, "cancelled_write_bytes: %llu", &process->io_cancelled_write_bytes);
   }
   fclose(file);
}

#endif

static bool ProcessList_readStatmFile(Process* process, const char* dirname, const char* name) {
   char filename[MAX_NAME+1];
   snprintf(filename, MAX_NAME, "%s/%s/statm", dirname, name);
   FILE* file = fopen(filename, "r");
   if (!file)
      return false;

   int num = fscanf(file, "%d %d %d %d %d %d %d",
       &process->m_size, &process->m_resident, &process->m_share, 
       &process->m_trs, &process->m_lrs, &process->m_drs, 
       &process->m_dt);
   fclose(file);
   return (num == 7);
}

#ifdef HAVE_OPENVZ

static void ProcessList_readOpenVZData(Process* process, const char* dirname, const char* name) {
   if (access("/proc/vz", R_OK) != 0) {
      process->vpid = process->pid;
      process->ctid = 0;
      return;
   }
   char filename[MAX_NAME+1];
   snprintf(filename, MAX_NAME, "%s/%s/stat", dirname, name);
   FILE* file = fopen(filename, "r");
   if (!file) 
      return;
   fscanf(file, 
      "%*u %*s %*c %*u %*u %*u %*u %*u %*u %*u "
      "%*u %*u %*u %*u %*u %*u %*u %*u "
      "%*u %*u %*u %*u %*u %*u %*u %*u "
      "%*u %*u %*u %*u %*u %*u %*u %*u "
      "%*u %*u %*u %*u %*u %*u %*u %*u "
      "%*u %*u %*u %*u %*u %*u %*u "
      "%*u %*u %u %u",
      &process->vpid, &process->ctid);
   fclose(file);
}

#endif

#ifdef HAVE_CGROUP

static void ProcessList_readCGroupFile(Process* process, const char* dirname, const char* name) {
   char filename[MAX_NAME+1];
   snprintf(filename, MAX_NAME, "%s/%s/cgroup", dirname, name);
   FILE* file = fopen(filename, "r");
   if (!file) {
      process->cgroup = strdup("");
      return;
   }
   char buffer[256];
   char *ok = fgets(buffer, 255, file);
   if (ok) {
      char* trimmed = String_trim(buffer);
      char** fields = String_split(trimmed, ':');
      free(trimmed);

      process->cgroup = strndup(fields[2] + 1, 10);
      String_freeArray(fields);
   }
   fclose(file);
}

#endif

#ifdef HAVE_VSERVER

static void ProcessList_readVServerData(Process* process, const char* dirname, const char* name) {
   char filename[MAX_NAME+1];
   snprintf(filename, MAX_NAME, "%s/%s/status", dirname, name);
   FILE* file = fopen(filename, "r");
   if (!file)
      return;
   char buffer[256];
   process->vxid = 0;
   while (fgets(buffer, 255, file)) {
      if (String_startsWith(buffer, "VxID:")) {
         int vxid;
         int ok = sscanf(buffer, "VxID:\t%d", &vxid);
         if (ok >= 1) {
            process->vxid = vxid;
505
         }
506
507
508
509
510
511
512
      }
      #if defined HAVE_ANCIENT_VSERVER
      else if (String_startsWith(buffer, "s_context:")) {
         int vxid;
         int ok = sscanf(buffer, "s_context:\t%d", &vxid);
         if (ok >= 1) {
            process->vxid = vxid;
513
514
         }
      }
515
      #endif
516
   }
517
   fclose(file);
518
}
519

520
521
#endif

522
523
524
525
526
527
528
529
530
531
532
533
534
535
536
537
538
539
540
541
542
543
544
545
546
547
static bool ProcessList_readCmdlineFile(Process* process, const char* dirname, const char* name) {
   if (Process_isKernelThread(process))
      return true;
   char filename[MAX_NAME+1];
   snprintf(filename, MAX_NAME, "%s/%s/cmdline", dirname, name);
   FILE* file = fopen(filename, "r");
   if (!file)
      return false;
         
   char command[4096+1]; // max cmdline length on Linux
   int amtRead = fread(command, 1, sizeof(command) - 1, file);
   if (amtRead > 0) {
      for (int i = 0; i < amtRead; i++)
         if (command[i] == '\0' || command[i] == '\n') {
            command[i] = ' ';
         }
   }
   command[amtRead] = '\0';
   fclose(file);
   free(process->comm);
   process->comm = String_copy(command);
   return true;
}


static bool ProcessList_processEntries(ProcessList* this, const char* dirname, Process* parent, float period) {
Hisham Muhammad's avatar
Hisham Muhammad committed
548
549
550
551
   DIR* dir;
   struct dirent* entry;

   dir = opendir(dirname);
552
   if (!dir) return false;
553
   int cpus = this->cpuCount;
554
555
   bool hideKernelThreads = this->hideKernelThreads;
   bool hideUserlandThreads = this->hideUserlandThreads;
Hisham Muhammad's avatar
Hisham Muhammad committed
556
557
558
   while ((entry = readdir(dir)) != NULL) {
      char* name = entry->d_name;
      // filename is a number: process directory
559
560
561
      int pid = atoi(name);
     
      if (parent && pid == parent->pid)
562
         continue;
Hisham Muhammad's avatar
Hisham Muhammad committed
563
564
565
566

      // The RedHat kernel hides threads with a dot.
      // I believe this is non-standard.
      if ((!this->hideThreads) && pid == 0 && name[0] == '.') {
Hisham Muhammad's avatar
Hisham Muhammad committed
567
         pid = atoi(name + 1);
Hisham Muhammad's avatar
Hisham Muhammad committed
568
      }
569
570
      if (pid <= 0) 
         continue;
Hisham Muhammad's avatar
Hisham Muhammad committed
571

572
573
574
575
576
577
578
579
580
581
582
      Process* process = NULL;
      Process* existingProcess = (Process*) Hashtable_get(this->processTable, pid);

      if (existingProcess) {
         assert(Vector_indexOf(this->processes, existingProcess, Process_pidCompare) != -1);
         process = existingProcess;
         assert(process->pid == pid);
      } else {
         process = Process_new(this);
         assert(process->comm == NULL);
         process->pid = pid;
583
         process->tgid = parent ? parent->pid : pid;
584
      }
585

586
587
588
      char subdirname[MAX_NAME+1];
      snprintf(subdirname, MAX_NAME, "%s/%s/task", dirname, name);
      ProcessList_processEntries(this, subdirname, process, period);
589

590
591
592
      #ifdef HAVE_TASKSTATS
      ProcessList_readIoFile(process, dirname, name);
      #endif
593

594
595
      if (! ProcessList_readStatmFile(process, dirname, name))
         goto errorReadingProcess;
Hisham Muhammad's avatar
Hisham Muhammad committed
596

597
      process->show = ! ((hideKernelThreads && Process_isKernelThread(process)) || (hideUserlandThreads && Process_isUserlandThread(process)));
598

599
600
601
602
603
604
605
606
      char command[MAX_NAME+1];
      int lasttimes = (process->utime + process->stime);
      if (! ProcessList_readStatFile(process, dirname, name, command))
         goto errorReadingProcess;
      int percent_cpu = (process->utime + process->stime - lasttimes) / period * 100.0;
      process->percent_cpu = MAX(MIN(percent_cpu, cpus*100.0), 0.0);
      if (isnan(process->percent_cpu)) process->percent_cpu = 0.0;
      process->percent_mem = (process->m_resident * PAGE_SIZE_KB) / (float)(this->totalMem) * 100.0;
607

608
      if(!existingProcess) {
609

610
         if (! ProcessList_statProcessDir(process, dirname, name))
611
612
            goto errorReadingProcess;

613
614
         process->user = UsersTable_getRef(this->usersTable, process->st_uid);

615
616
617
         #ifdef HAVE_OPENVZ
         ProcessList_readOpenVZData(process, dirname, name);
         #endif
618

619
620
621
         #ifdef HAVE_CGROUP
         ProcessList_readCGroupFile(process, dirname, name);
         #endif
622
         
623
624
625
626
627
         #ifdef HAVE_VSERVER
         ProcessList_readVServerData(process, dirname, name);
         #endif
         
         if (! ProcessList_readCmdlineFile(process, dirname, name))
628
629
            goto errorReadingProcess;

630
631
         ProcessList_add(this, process);
      }
Hisham Muhammad's avatar
Hisham Muhammad committed
632

633
634
635
636
      if (process->state == 'Z') {
         free(process->comm);
         process->comm = String_copy(command);
      } else if (Process_isThread(process)) {
637
         if (this->showThreadNames || Process_isKernelThread(process) || process->state == 'Z') {
638
            free(process->comm);
Hisham Muhammad's avatar
Hisham Muhammad committed
639
            process->comm = String_copy(command);
640
641
642
         } else if (this->showingThreadNames) {
            if (! ProcessList_readCmdlineFile(process, dirname, name))
               goto errorReadingProcess;
Hisham Muhammad's avatar
Hisham Muhammad committed
643
         }
644
645
646
647
648
         if (Process_isKernelThread(process)) {
            this->kernelThreads++;
         } else {
            this->userlandThreads++;
         }
649
      }
Hisham Muhammad's avatar
Hisham Muhammad committed
650

651
652
653
654
      this->totalTasks++;
      if (process->state == 'R')
         this->runningTasks++;
      process->updated = true;
Hisham Muhammad's avatar
Hisham Muhammad committed
655

656
      continue;
Hisham Muhammad's avatar
Hisham Muhammad committed
657

658
659
660
661
662
      // Exception handler.
      errorReadingProcess: {
         if (process->comm) {
            free(process->comm);
            process->comm = NULL;
Hisham Muhammad's avatar
Hisham Muhammad committed
663
         }
664
665
666
667
         if (existingProcess)
            ProcessList_remove(this, process);
         else
            Process_delete((Object*)process);
Hisham Muhammad's avatar
Hisham Muhammad committed
668
669
670
      }
   }
   closedir(dir);
671
   return true;
Hisham Muhammad's avatar
Hisham Muhammad committed
672
673
674
}

void ProcessList_scan(ProcessList* this) {
675
   unsigned long long int usertime, nicetime, systemtime, systemalltime, idlealltime, idletime, totaltime, virtalltime;
Hisham Muhammad's avatar
Hisham Muhammad committed
676
   unsigned long long int swapFree = 0;
Hisham Muhammad's avatar
Hisham Muhammad committed
677

678
679
   FILE* file = fopen(PROCMEMINFOFILE, "r");
   assert(file != NULL);
680
   int cpus = this->cpuCount;
Hisham Muhammad's avatar
Hisham Muhammad committed
681
682
   {
      char buffer[128];
683
      while (fgets(buffer, 128, file)) {
Hisham Muhammad's avatar
Hisham Muhammad committed
684
685
686
687
   
         switch (buffer[0]) {
         case 'M':
            if (String_startsWith(buffer, "MemTotal:"))
688
               sscanf(buffer, "MemTotal: %llu kB", &this->totalMem);
Hisham Muhammad's avatar
Hisham Muhammad committed
689
            else if (String_startsWith(buffer, "MemFree:"))
690
               sscanf(buffer, "MemFree: %llu kB", &this->freeMem);
Hisham Muhammad's avatar
Hisham Muhammad committed
691
            else if (String_startsWith(buffer, "MemShared:"))
692
               sscanf(buffer, "MemShared: %llu kB", &this->sharedMem);
Hisham Muhammad's avatar
Hisham Muhammad committed
693
694
695
            break;
         case 'B':
            if (String_startsWith(buffer, "Buffers:"))
696
               sscanf(buffer, "Buffers: %llu kB", &this->buffersMem);
Hisham Muhammad's avatar
Hisham Muhammad committed
697
698
699
            break;
         case 'C':
            if (String_startsWith(buffer, "Cached:"))
700
               sscanf(buffer, "Cached: %llu kB", &this->cachedMem);
Hisham Muhammad's avatar
Hisham Muhammad committed
701
702
703
            break;
         case 'S':
            if (String_startsWith(buffer, "SwapTotal:"))
704
               sscanf(buffer, "SwapTotal: %llu kB", &this->totalSwap);
Hisham Muhammad's avatar
Hisham Muhammad committed
705
            if (String_startsWith(buffer, "SwapFree:"))
706
               sscanf(buffer, "SwapFree: %llu kB", &swapFree);
Hisham Muhammad's avatar
Hisham Muhammad committed
707
708
            break;
         }
Hisham Muhammad's avatar
Hisham Muhammad committed
709
710
      }
   }
Hisham Muhammad's avatar
Hisham Muhammad committed
711

Hisham Muhammad's avatar
Hisham Muhammad committed
712
713
   this->usedMem = this->totalMem - this->freeMem;
   this->usedSwap = this->totalSwap - swapFree;
714
   fclose(file);
Hisham Muhammad's avatar
Hisham Muhammad committed
715

716
717
   file = fopen(PROCSTATFILE, "r");
   assert(file != NULL);
718
   for (int i = 0; i <= cpus; i++) {
Hisham Muhammad's avatar
Hisham Muhammad committed
719
720
      char buffer[256];
      int cpuid;
721
722
      unsigned long long int ioWait, irq, softIrq, steal, guest;
      ioWait = irq = softIrq = steal = guest = 0;
Hisham Muhammad's avatar
Hisham Muhammad committed
723
724
725
      // Dependending on your kernel version,
      // 5, 7 or 8 of these fields will be set.
      // The rest will remain at zero.
726
      fgets(buffer, 255, file);
Hisham Muhammad's avatar
Hisham Muhammad committed
727
      if (i == 0)
728
         sscanf(buffer, "cpu  %llu %llu %llu %llu %llu %llu %llu %llu %llu", &usertime, &nicetime, &systemtime, &idletime, &ioWait, &irq, &softIrq, &steal, &guest);
Hisham Muhammad's avatar
Hisham Muhammad committed
729
      else {
730
         sscanf(buffer, "cpu%d %llu %llu %llu %llu %llu %llu %llu %llu %llu", &cpuid, &usertime, &nicetime, &systemtime, &idletime, &ioWait, &irq, &softIrq, &steal, &guest);
Hisham Muhammad's avatar
Hisham Muhammad committed
731
732
733
734
         assert(cpuid == i - 1);
      }
      // Fields existing on kernels >= 2.6
      // (and RHEL's patched kernel 2.4...)
735
      idlealltime = idletime + ioWait;
736
737
738
739
740
741
742
743
744
745
746
747
748
749
750
751
752
753
754
755
756
757
758
759
760
761
762
763
764
765
766
767
768
769
770
771
772
773
774
775
      systemalltime = systemtime + irq + softIrq;
      virtalltime = steal + guest;
      totaltime = usertime + nicetime + systemalltime + idlealltime + virtalltime;
      CPUData* cpuData = &(this->cpus[i]);
      assert (usertime >= cpuData->userTime);
      assert (nicetime >= cpuData->niceTime);
      assert (systemtime >= cpuData->systemTime);
      assert (idletime >= cpuData->idleTime);
      assert (totaltime >= cpuData->totalTime);
      assert (systemalltime >= cpuData->systemAllTime);
      assert (idlealltime >= cpuData->idleAllTime);
      assert (ioWait >= cpuData->ioWaitTime);
      assert (irq >= cpuData->irqTime);
      assert (softIrq >= cpuData->softIrqTime);
      assert (steal >= cpuData->stealTime);
      assert (guest >= cpuData->guestTime);
      cpuData->userPeriod = usertime - cpuData->userTime;
      cpuData->nicePeriod = nicetime - cpuData->niceTime;
      cpuData->systemPeriod = systemtime - cpuData->systemTime;
      cpuData->systemAllPeriod = systemalltime - cpuData->systemAllTime;
      cpuData->idleAllPeriod = idlealltime - cpuData->idleAllTime;
      cpuData->idlePeriod = idletime - cpuData->idleTime;
      cpuData->ioWaitPeriod = ioWait - cpuData->ioWaitTime;
      cpuData->irqPeriod = irq - cpuData->irqTime;
      cpuData->softIrqPeriod = softIrq - cpuData->softIrqTime;
      cpuData->stealPeriod = steal - cpuData->stealTime;
      cpuData->guestPeriod = guest - cpuData->guestTime;
      cpuData->totalPeriod = totaltime - cpuData->totalTime;
      cpuData->userTime = usertime;
      cpuData->niceTime = nicetime;
      cpuData->systemTime = systemtime;
      cpuData->systemAllTime = systemalltime;
      cpuData->idleAllTime = idlealltime;
      cpuData->idleTime = idletime;
      cpuData->ioWaitTime = ioWait;
      cpuData->irqTime = irq;
      cpuData->softIrqTime = softIrq;
      cpuData->stealTime = steal;
      cpuData->guestTime = guest;
      cpuData->totalTime = totaltime;
Hisham Muhammad's avatar
Hisham Muhammad committed
776
   }
777
   float period = (float)this->cpus[0].totalPeriod / cpus; fclose(file);
Hisham Muhammad's avatar
Hisham Muhammad committed
778
779

   // mark all process as "dirty"
780
781
   for (int i = 0; i < Vector_size(this->processes); i++) {
      Process* p = (Process*) Vector_get(this->processes, i);
Hisham Muhammad's avatar
Hisham Muhammad committed
782
783
784
785
      p->updated = false;
   }
   
   this->totalTasks = 0;
786
787
   this->userlandThreads = 0;
   this->kernelThreads = 0;
Hisham Muhammad's avatar
Hisham Muhammad committed
788
   this->runningTasks = 0;
789

790
   ProcessList_processEntries(this, PROCDIR, NULL, period);
Hisham Muhammad's avatar
Hisham Muhammad committed
791
792
   
   this->showingThreadNames = this->showThreadNames;
Hisham Muhammad's avatar
Hisham Muhammad committed
793
   
794
795
   for (int i = Vector_size(this->processes) - 1; i >= 0; i--) {
      Process* p = (Process*) Vector_get(this->processes, i);
Hisham Muhammad's avatar
Hisham Muhammad committed
796
797
798
799
800
801
802
      if (p->updated == false)
         ProcessList_remove(this, p);
      else
         p->updated = false;
   }

}
803
804
805
806
807
808
809
810
811
812
813
814
815
816

ProcessField ProcessList_keyAt(ProcessList* this, int at) {
   int x = 0;
   ProcessField* fields = this->fields;
   ProcessField field;
   for (int i = 0; (field = fields[i]); i++) {
      int len = strlen(Process_fieldTitles[field]);
      if (at >= x && at <= x + len) {
         return field;
      }
      x += len;
   }
   return COMM;
}
817
818
819
820
821
822
823
824

void ProcessList_expandTree(ProcessList* this) {
   int size = Vector_size(this->processes);
   for (int i = 0; i < size; i++) {
      Process* process = (Process*) Vector_get(this->processes, i);
      process->showChildren = true;
   }
}