ProcessList.c 27.7 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
#ifndef ProcessList_cpuId
58
#define ProcessList_cpuId(pl, cpu) ((pl)->countCPUsFromZero ? (cpu) : (cpu)+1)
59
#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
typedef enum TreeStr_ {
   TREE_STR_HORZ,
   TREE_STR_VERT,
   TREE_STR_RTEE,
   TREE_STR_BEND,
   TREE_STR_TEND,
   TREE_STR_OPEN,
   TREE_STR_SHUT,
   TREE_STR_COUNT
} TreeStr;

typedef enum TreeType_ {
   TREE_TYPE_AUTO,
   TREE_TYPE_ASCII,
   TREE_TYPE_UTF8,
} TreeType;
Hisham Muhammad's avatar
Hisham Muhammad committed
77

78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
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
106
typedef struct ProcessList_ {
107
108
   Vector* processes;
   Vector* processes2;
Hisham Muhammad's avatar
Hisham Muhammad committed
109
110
111
   Hashtable* processTable;
   UsersTable* usersTable;

112
   int cpuCount;
Hisham Muhammad's avatar
Hisham Muhammad committed
113
   int totalTasks;
114
115
   int userlandThreads;
   int kernelThreads;
Hisham Muhammad's avatar
Hisham Muhammad committed
116
117
   int runningTasks;

118
   #ifdef HAVE_LIBHWLOC
119
120
121
   hwloc_topology_t topology;
   bool topologyOk;
   #endif
122
   CPUData* cpus;
123
124
125
126
127
128
129
130
131
132

   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
133
134
135
136
137
138

   ProcessField* fields;
   ProcessField sortKey;
   int direction;
   bool hideThreads;
   bool shadowOtherUsers;
Hisham Muhammad's avatar
Hisham Muhammad committed
139
140
   bool showThreadNames;
   bool showingThreadNames;
Hisham Muhammad's avatar
Hisham Muhammad committed
141
142
143
144
145
   bool hideKernelThreads;
   bool hideUserlandThreads;
   bool treeView;
   bool highlightBaseName;
   bool highlightMegabytes;
146
   bool highlightThreads;
147
   bool detailedCPUTime;
148
   bool countCPUsFromZero;
149
   const char **treeStr;
Hisham Muhammad's avatar
Hisham Muhammad committed
150
151

} ProcessList;
152

Hisham Muhammad's avatar
Hisham Muhammad committed
153
154
}*/

155
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
156

157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
const char *ProcessList_treeStrAscii[TREE_STR_COUNT] = {
   "-", // TREE_STR_HORZ
   "|", // TREE_STR_VERT
   "`", // TREE_STR_RTEE
   "`", // TREE_STR_BEND
   ",", // TREE_STR_TEND
   "+", // TREE_STR_OPEN
   "-", // TREE_STR_SHUT
};

const char *ProcessList_treeStrUtf8[TREE_STR_COUNT] = {
   "\xe2\x94\x80", // TREE_STR_HORZ ─
   "\xe2\x94\x82", // TREE_STR_VERT │
   "\xe2\x94\x9c", // TREE_STR_RTEE ├
   "\xe2\x94\x94", // TREE_STR_BEND └
   "\xe2\x94\x8c", // TREE_STR_TEND ┌
   "+",            // TREE_STR_OPEN +
   "\xe2\x94\x80", // TREE_STR_SHUT ─
};

Hisham Muhammad's avatar
Hisham Muhammad committed
177
178
ProcessList* ProcessList_new(UsersTable* usersTable) {
   ProcessList* this;
179
   this = calloc(sizeof(ProcessList), 1);
180
   this->processes = Vector_new(PROCESS_CLASS, true, DEFAULT_SIZE, Process_compare);
181
   this->processTable = Hashtable_new(140, false);
Hisham Muhammad's avatar
Hisham Muhammad committed
182
183
184
   this->usersTable = usersTable;
   
   /* tree-view auxiliary buffers */
185
   this->processes2 = Vector_new(PROCESS_CLASS, true, DEFAULT_SIZE, Process_compare);
Hisham Muhammad's avatar
Hisham Muhammad committed
186
   
187
188
   FILE* file = fopen(PROCSTATFILE, "r");
   assert(file != NULL);
Hisham Muhammad's avatar
Hisham Muhammad committed
189
   char buffer[256];
190
   int cpus = -1;
Hisham Muhammad's avatar
Hisham Muhammad committed
191
   do {
192
      cpus++;
193
      fgets(buffer, 255, file);
Hisham Muhammad's avatar
Hisham Muhammad committed
194
   } while (String_startsWith(buffer, "cpu"));
195
   fclose(file);
196
   this->cpuCount = cpus - 1;
197

198
#ifdef HAVE_LIBHWLOC
199
200
201
202
203
204
205
   this->topologyOk = false;
   int topoErr = hwloc_topology_init(&this->topology);
   if (topoErr == 0) {
      topoErr = hwloc_topology_load(this->topology);
      this->topologyOk = true;
   }
#endif
206
   this->cpus = calloc(sizeof(CPUData), cpus);
207

208
209
210
   for (int i = 0; i < cpus; i++) {
      this->cpus[i].totalTime = 1;
      this->cpus[i].totalPeriod = 1;
Hisham Muhammad's avatar
Hisham Muhammad committed
211
212
213
   }

   this->fields = calloc(sizeof(ProcessField), LAST_PROCESSFIELD+1);
214
   // TODO: turn 'fields' into a Vector,
Hisham Muhammad's avatar
Hisham Muhammad committed
215
216
217
218
219
220
221
222
   // (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;
223
224
   this->showThreadNames = false;
   this->showingThreadNames = false;
Hisham Muhammad's avatar
Hisham Muhammad committed
225
226
227
228
229
   this->hideKernelThreads = false;
   this->hideUserlandThreads = false;
   this->treeView = false;
   this->highlightBaseName = false;
   this->highlightMegabytes = false;
230
   this->detailedCPUTime = false;
231
   this->countCPUsFromZero = false;
232
   this->treeStr = NULL;
Hisham Muhammad's avatar
Hisham Muhammad committed
233
234
235
236
237
238

   return this;
}

void ProcessList_delete(ProcessList* this) {
   Hashtable_delete(this->processTable);
239
240
   Vector_delete(this->processes);
   Vector_delete(this->processes2);
241
   free(this->cpus);
Hisham Muhammad's avatar
Hisham Muhammad committed
242
243
244
245
246
247
248
249
250
251
252
   free(this->fields);
   free(this);
}

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

253
254
void ProcessList_printHeader(ProcessList* this, RichString* header) {
   RichString_prune(header);
Hisham Muhammad's avatar
Hisham Muhammad committed
255
256
   ProcessField* fields = this->fields;
   for (int i = 0; fields[i]; i++) {
Hisham Muhammad's avatar
Hisham Muhammad committed
257
      const char* field = Process_fieldTitles[fields[i]];
Hisham Muhammad's avatar
Hisham Muhammad committed
258
      if (this->sortKey == fields[i])
259
         RichString_append(header, CRT_colors[PANEL_HIGHLIGHT_FOCUS], field);
Hisham Muhammad's avatar
Hisham Muhammad committed
260
      else
261
         RichString_append(header, CRT_colors[PANEL_HEADER_FOCUS], field);
Hisham Muhammad's avatar
Hisham Muhammad committed
262
263
264
   }
}

265
static void ProcessList_add(ProcessList* this, Process* p) {
266
267
   assert(Vector_indexOf(this->processes, p, Process_pidCompare) == -1);
   assert(Hashtable_get(this->processTable, p->pid) == NULL);
268
   
269
   Vector_add(this->processes, p);
Hisham Muhammad's avatar
Hisham Muhammad committed
270
   Hashtable_put(this->processTable, p->pid, p);
271
   
272
273
   assert(Vector_indexOf(this->processes, p, Process_pidCompare) != -1);
   assert(Hashtable_get(this->processTable, p->pid) != NULL);
274
   assert(Hashtable_count(this->processTable) == Vector_count(this->processes));
Hisham Muhammad's avatar
Hisham Muhammad committed
275
276
}

277
static void ProcessList_remove(ProcessList* this, Process* p) {
278
279
280
   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);
281
   assert(pp == p); (void)pp;
282
   unsigned int pid = p->pid;
Hisham Muhammad's avatar
Hisham Muhammad committed
283
284
285
   int idx = Vector_indexOf(this->processes, p, Process_pidCompare);
   assert(idx != -1);
   if (idx >= 0) Vector_remove(this->processes, idx);
286
   assert(Hashtable_get(this->processTable, pid) == NULL); (void)pid;
287
   assert(Hashtable_count(this->processTable) == Vector_count(this->processes));
Hisham Muhammad's avatar
Hisham Muhammad committed
288
289
}

Hisham Muhammad's avatar
Hisham Muhammad committed
290
291
Process* ProcessList_get(ProcessList* this, int idx) {
   return (Process*) (Vector_get(this->processes, idx));
Hisham Muhammad's avatar
Hisham Muhammad committed
292
293
294
}

int ProcessList_size(ProcessList* this) {
295
   return (Vector_size(this->processes));
Hisham Muhammad's avatar
Hisham Muhammad committed
296
297
}

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

301
   for (int i = Vector_size(this->processes) - 1; i >= 0; i--) {
302
      Process* process = (Process*) (Vector_get(this->processes, i));
303
      if (process->tgid == pid || (process->tgid == process->pid && process->ppid == pid)) {
Hisham Muhammad's avatar
Hisham Muhammad committed
304
         process = (Process*) (Vector_take(this->processes, i));
305
         Vector_add(children, process);
Hisham Muhammad's avatar
Hisham Muhammad committed
306
307
      }
   }
308
   int size = Vector_size(children);
Hisham Muhammad's avatar
Hisham Muhammad committed
309
   for (int i = 0; i < size; i++) {
310
      Process* process = (Process*) (Vector_get(children, i));
311
312
313
314
315
316
317
318
319
      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);
320
      ProcessList_buildTree(this, process->pid, level+1, (i < size - 1) ? nextIndent : indent, direction, show ? process->showChildren : false);
321
322
323
324
      if (i == size - 1)
         process->indent = -nextIndent;
      else
         process->indent = nextIndent;
Hisham Muhammad's avatar
Hisham Muhammad committed
325
   }
326
   Vector_delete(children);
Hisham Muhammad's avatar
Hisham Muhammad committed
327
328
329
330
}

void ProcessList_sort(ProcessList* this) {
   if (!this->treeView) {
331
      Vector_insertionSort(this->processes);
Hisham Muhammad's avatar
Hisham Muhammad committed
332
   } else {
333
      // Save settings
Hisham Muhammad's avatar
Hisham Muhammad committed
334
335
      int direction = this->direction;
      int sortKey = this->sortKey;
336
      // Sort by PID
Hisham Muhammad's avatar
Hisham Muhammad committed
337
338
      this->sortKey = PID;
      this->direction = 1;
339
      Vector_quickSort(this->processes);
340
      // Restore settings
Hisham Muhammad's avatar
Hisham Muhammad committed
341
342
      this->sortKey = sortKey;
      this->direction = direction;
343
      // Take PID 1 as root and add to the new listing
344
      int vsize = Vector_size(this->processes);
345
      Process* init = (Process*) (Vector_take(this->processes, 0));
346
347
348
      // 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
349
      init->indent = 0;
350
      Vector_add(this->processes2, init);
351
      // Recursively empty list
Hisham Muhammad's avatar
Hisham Muhammad committed
352
      ProcessList_buildTree(this, init->pid, 0, 0, direction, true);
353
      // Add leftovers
354
355
356
357
      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
358
         ProcessList_buildTree(this, p->pid, 0, 0, direction, p->showChildren);
359
360
361
      }
      assert(Vector_size(this->processes2) == vsize); (void)vsize;
      assert(Vector_size(this->processes) == 0);
362
      // Swap listings around
363
      Vector* t = this->processes;
Hisham Muhammad's avatar
Hisham Muhammad committed
364
365
366
367
368
      this->processes = this->processes2;
      this->processes2 = t;
   }
}

369
370
371
372
373
374
375
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
376
377
   static char buf[MAX_READ];

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

381
   assert(process->pid == atoi(buf));
Hisham Muhammad's avatar
Hisham Muhammad committed
382
   char *location = strchr(buf, ' ');
383
   if (!location) { fclose(file); return false; }
Hisham Muhammad's avatar
Hisham Muhammad committed
384
385
386

   location += 2;
   char *end = strrchr(location, ')');
387
   if (!end) { fclose(file); return false; }
Hisham Muhammad's avatar
Hisham Muhammad committed
388
389
390
391
392
   
   int commsize = end - location;
   memcpy(command, location, commsize);
   command[commsize] = '\0';
   location = end + 2;
393
394
395
396
397

   int num = sscanf(location, 
      "%c %d %u %u %u "
      "%d %lu "
      "%*u %*u %*u %*u "
398
      "%llu %llu %llu %llu "
399
400
      "%ld %ld %ld "
      "%*d %*u %*u %*d %*u %*u %*u %*u %*u %*u %*u %*u %*u %*u %*u %*u %*u "
401
      "%d %d",
402
403
404
405
406
407
408
      &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
409
410
}

411
412
413
static bool ProcessList_statProcessDir(Process* process, const char* dirname, char* name) {
   char filename[MAX_NAME+1];
   filename[MAX_NAME] = '\0';
414

415
   snprintf(filename, MAX_NAME, "%s/%s", dirname, name);
416
   struct stat sstat;
417
   int statok = stat(filename, &sstat);
418
419
   if (statok == -1)
      return false;
420
   process->st_uid = sstat.st_uid;
Hisham Muhammad's avatar
Hisham Muhammad committed
421
422
423
  
   struct tm date;
   time_t ctime = sstat.st_ctime;
424
   process->starttime_ctime = ctime;
Hisham Muhammad's avatar
Hisham Muhammad committed
425
   (void) localtime_r((time_t*) &ctime, &date);
426
   strftime(process->starttime_show, 7, ((ctime > time(NULL) - 86400) ? "%R " : "%b%d "), &date);
Hisham Muhammad's avatar
Hisham Muhammad committed
427
   
428
   return true;
Hisham Muhammad's avatar
Hisham Muhammad committed
429
430
}

431
#ifdef HAVE_TASKSTATS
432

433
434
435
static void ProcessList_readIoFile(Process* process, const char* dirname, char* name) {
   char filename[MAX_NAME+1];
   filename[MAX_NAME] = '\0';
436

437
438
439
440
441
442
443
444
445
446
447
448
449
   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)) {
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
      switch (buffer[0]) {
      case 'r':
         if (buffer[1] == 'c')
            sscanf(buffer, "rchar: %llu", &process->io_rchar);
         else 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;
         }
         break;
      case 'w':
         if (buffer[1] == 'c')
            sscanf(buffer, "wchar: %llu", &process->io_wchar);
         else 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;
         }
         break;
      case 's':
         if (buffer[5] == 'r')
            sscanf(buffer, "syscr: %llu", &process->io_syscr);
         else
            sscanf(buffer, "syscw: %llu", &process->io_syscw);
         break;
      case 'c':
         sscanf(buffer, "cancelled_write_bytes: %llu", &process->io_cancelled_write_bytes);
477
478
479
480
481
482
483
484
485
486
487
488
489
490
      }
   }
   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;

491
   int num = fscanf(file, "%32d %32d %32d %32d %32d %32d %32d",
492
493
494
495
496
497
498
499
500
501
502
503
504
505
506
507
508
509
510
511
512
       &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, 
513
514
515
516
517
518
519
      "%*32u %*32s %*1c %*32u %*32u %*32u %*32u %*32u %*32u %*32u "
      "%*32u %*32u %*32u %*32u %*32u %*32u %*32u %*32u "
      "%*32u %*32u %*32u %*32u %*32u %*32u %*32u %*32u "
      "%*32u %*32u %*32u %*32u %*32u %*32u %*32u %*32u "
      "%*32u %*32u %*32u %*32u %*32u %*32u %*32u %*32u "
      "%*32u %*32u %*32u %*32u %*32u %*32u %*32u "
      "%*32u %*32u %32u %32u",
520
521
522
523
524
525
526
527
528
529
530
531
532
533
534
535
536
537
538
539
      &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);
540
541
      int nFields;
      char** fields = String_split(trimmed, ':', &nFields);
542
      free(trimmed);
543
544
545
546
547
      if (nFields >= 3) {
         process->cgroup = strndup(fields[2] + 1, 10);
      } else {
         process->cgroup = strdup("");
      }
548
549
550
551
552
553
554
555
556
557
558
559
560
561
562
563
564
565
566
567
568
569
570
      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;
571
         }
572
573
574
575
576
577
578
      }
      #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;
579
580
         }
      }
581
      #endif
582
   }
583
   fclose(file);
584
}
585

586
587
#endif

588
589
590
591
592
593
594
595
596
597
598
599
600
601
602
603
604
605
606
607
608
609
610
611
612
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;
}


Hisham Muhammad's avatar
Hisham Muhammad committed
613
static bool ProcessList_processEntries(ProcessList* this, const char* dirname, Process* parent, double period) {
Hisham Muhammad's avatar
Hisham Muhammad committed
614
615
616
617
   DIR* dir;
   struct dirent* entry;

   dir = opendir(dirname);
618
   if (!dir) return false;
619
   int cpus = this->cpuCount;
620
621
   bool hideKernelThreads = this->hideKernelThreads;
   bool hideUserlandThreads = this->hideUserlandThreads;
Hisham Muhammad's avatar
Hisham Muhammad committed
622
623
624
   while ((entry = readdir(dir)) != NULL) {
      char* name = entry->d_name;
      // filename is a number: process directory
625
626
627
      int pid = atoi(name);
     
      if (parent && pid == parent->pid)
628
         continue;
Hisham Muhammad's avatar
Hisham Muhammad committed
629
630
631
632

      // 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
633
         pid = atoi(name + 1);
Hisham Muhammad's avatar
Hisham Muhammad committed
634
      }
635
636
      if (pid <= 0) 
         continue;
Hisham Muhammad's avatar
Hisham Muhammad committed
637

638
639
640
641
642
643
644
645
646
647
648
      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;
649
         process->tgid = parent ? parent->pid : pid;
650
      }
651

652
653
654
      char subdirname[MAX_NAME+1];
      snprintf(subdirname, MAX_NAME, "%s/%s/task", dirname, name);
      ProcessList_processEntries(this, subdirname, process, period);
655

656
657
658
      #ifdef HAVE_TASKSTATS
      ProcessList_readIoFile(process, dirname, name);
      #endif
659

660
661
      if (! ProcessList_readStatmFile(process, dirname, name))
         goto errorReadingProcess;
Hisham Muhammad's avatar
Hisham Muhammad committed
662

663
      process->show = ! ((hideKernelThreads && Process_isKernelThread(process)) || (hideUserlandThreads && Process_isUserlandThread(process)));
664

665
      char command[MAX_NAME+1];
Hisham Muhammad's avatar
Hisham Muhammad committed
666
      unsigned long long int lasttimes = (process->utime + process->stime);
667
668
669
670
671
      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;
Hisham Muhammad's avatar
Hisham Muhammad committed
672
      process->percent_mem = (process->m_resident * PAGE_SIZE_KB) / (double)(this->totalMem) * 100.0;
673

674
      if(!existingProcess) {
675

676
         if (! ProcessList_statProcessDir(process, dirname, name))
677
678
            goto errorReadingProcess;

679
680
         process->user = UsersTable_getRef(this->usersTable, process->st_uid);

681
682
683
         #ifdef HAVE_OPENVZ
         ProcessList_readOpenVZData(process, dirname, name);
         #endif
684

685
686
687
         #ifdef HAVE_CGROUP
         ProcessList_readCGroupFile(process, dirname, name);
         #endif
688
         
689
690
691
692
693
         #ifdef HAVE_VSERVER
         ProcessList_readVServerData(process, dirname, name);
         #endif
         
         if (! ProcessList_readCmdlineFile(process, dirname, name))
694
695
            goto errorReadingProcess;

696
697
         ProcessList_add(this, process);
      }
Hisham Muhammad's avatar
Hisham Muhammad committed
698

699
700
701
702
      if (process->state == 'Z') {
         free(process->comm);
         process->comm = String_copy(command);
      } else if (Process_isThread(process)) {
703
         if (this->showThreadNames || Process_isKernelThread(process) || process->state == 'Z') {
704
            free(process->comm);
Hisham Muhammad's avatar
Hisham Muhammad committed
705
            process->comm = String_copy(command);
706
707
708
         } else if (this->showingThreadNames) {
            if (! ProcessList_readCmdlineFile(process, dirname, name))
               goto errorReadingProcess;
Hisham Muhammad's avatar
Hisham Muhammad committed
709
         }
710
711
712
713
714
         if (Process_isKernelThread(process)) {
            this->kernelThreads++;
         } else {
            this->userlandThreads++;
         }
715
      }
Hisham Muhammad's avatar
Hisham Muhammad committed
716

717
718
719
720
      this->totalTasks++;
      if (process->state == 'R')
         this->runningTasks++;
      process->updated = true;
Hisham Muhammad's avatar
Hisham Muhammad committed
721

722
      continue;
Hisham Muhammad's avatar
Hisham Muhammad committed
723

724
725
726
727
728
      // Exception handler.
      errorReadingProcess: {
         if (process->comm) {
            free(process->comm);
            process->comm = NULL;
Hisham Muhammad's avatar
Hisham Muhammad committed
729
         }
730
731
732
733
         if (existingProcess)
            ProcessList_remove(this, process);
         else
            Process_delete((Object*)process);
Hisham Muhammad's avatar
Hisham Muhammad committed
734
735
736
      }
   }
   closedir(dir);
737
   return true;
Hisham Muhammad's avatar
Hisham Muhammad committed
738
739
740
}

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

744
745
   FILE* file = fopen(PROCMEMINFOFILE, "r");
   assert(file != NULL);
746
   int cpus = this->cpuCount;
Hisham Muhammad's avatar
Hisham Muhammad committed
747
748
   {
      char buffer[128];
749
      while (fgets(buffer, 128, file)) {
Hisham Muhammad's avatar
Hisham Muhammad committed
750
751
752
753
   
         switch (buffer[0]) {
         case 'M':
            if (String_startsWith(buffer, "MemTotal:"))
754
               sscanf(buffer, "MemTotal: %llu kB", &this->totalMem);
Hisham Muhammad's avatar
Hisham Muhammad committed
755
            else if (String_startsWith(buffer, "MemFree:"))
756
               sscanf(buffer, "MemFree: %llu kB", &this->freeMem);
Hisham Muhammad's avatar
Hisham Muhammad committed
757
            else if (String_startsWith(buffer, "MemShared:"))
758
               sscanf(buffer, "MemShared: %llu kB", &this->sharedMem);
Hisham Muhammad's avatar
Hisham Muhammad committed
759
760
761
            break;
         case 'B':
            if (String_startsWith(buffer, "Buffers:"))
762
               sscanf(buffer, "Buffers: %llu kB", &this->buffersMem);
Hisham Muhammad's avatar
Hisham Muhammad committed
763
764
765
            break;
         case 'C':
            if (String_startsWith(buffer, "Cached:"))
766
               sscanf(buffer, "Cached: %llu kB", &this->cachedMem);
Hisham Muhammad's avatar
Hisham Muhammad committed
767
768
769
            break;
         case 'S':
            if (String_startsWith(buffer, "SwapTotal:"))
770
               sscanf(buffer, "SwapTotal: %llu kB", &this->totalSwap);
Hisham Muhammad's avatar
Hisham Muhammad committed
771
            if (String_startsWith(buffer, "SwapFree:"))
772
               sscanf(buffer, "SwapFree: %llu kB", &swapFree);
Hisham Muhammad's avatar
Hisham Muhammad committed
773
774
            break;
         }
Hisham Muhammad's avatar
Hisham Muhammad committed
775
776
      }
   }
Hisham Muhammad's avatar
Hisham Muhammad committed
777

Hisham Muhammad's avatar
Hisham Muhammad committed
778
779
   this->usedMem = this->totalMem - this->freeMem;
   this->usedSwap = this->totalSwap - swapFree;
780
   fclose(file);
Hisham Muhammad's avatar
Hisham Muhammad committed
781

782
783
   file = fopen(PROCSTATFILE, "r");
   assert(file != NULL);
784
   for (int i = 0; i <= cpus; i++) {
Hisham Muhammad's avatar
Hisham Muhammad committed
785
786
      char buffer[256];
      int cpuid;
787
788
      unsigned long long int ioWait, irq, softIrq, steal, guest;
      ioWait = irq = softIrq = steal = guest = 0;
Hisham Muhammad's avatar
Hisham Muhammad committed
789
790
791
      // Dependending on your kernel version,
      // 5, 7 or 8 of these fields will be set.
      // The rest will remain at zero.
792
      fgets(buffer, 255, file);
Hisham Muhammad's avatar
Hisham Muhammad committed
793
      if (i == 0)
794
         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
795
      else {
796
         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
797
798
799
800
         assert(cpuid == i - 1);
      }
      // Fields existing on kernels >= 2.6
      // (and RHEL's patched kernel 2.4...)
801
      idlealltime = idletime + ioWait;
802
803
804
805
806
807
808
809
810
811
812
813
814
815
816
817
818
819
820
821
822
823
824
825
826
827
828
829
830
831
832
833
834
835
836
837
838
839
840
841
      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
842
   }
Hisham Muhammad's avatar
Hisham Muhammad committed
843
   double period = (double)this->cpus[0].totalPeriod / cpus; fclose(file);
Hisham Muhammad's avatar
Hisham Muhammad committed
844
845

   // mark all process as "dirty"
846
847
   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
848
849
850
851
      p->updated = false;
   }
   
   this->totalTasks = 0;
852
853
   this->userlandThreads = 0;
   this->kernelThreads = 0;
Hisham Muhammad's avatar
Hisham Muhammad committed
854
   this->runningTasks = 0;
855

856
   ProcessList_processEntries(this, PROCDIR, NULL, period);
Hisham Muhammad's avatar
Hisham Muhammad committed
857
858
   
   this->showingThreadNames = this->showThreadNames;
Hisham Muhammad's avatar
Hisham Muhammad committed
859
   
860
861
   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
862
863
864
865
866
867
868
      if (p->updated == false)
         ProcessList_remove(this, p);
      else
         p->updated = false;
   }

}
869
870
871
872
873
874
875
876
877
878
879
880
881
882

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;
}
883
884
885
886
887
888
889
890

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;
   }
}