| @@ -1,60 +1,330 @@ |
| /* |
| * A tiny 'top' utility. |
| * |
| - | * This is written specifically for the linux /proc/<PID>/status |
| - | * file format, but it checks that the file actually conforms to the |
| - | * format that this utility expects. |
| - | |
| - | * This reads the PIDs of all processes at startup and then shows the |
| - | * status of those processes at given intervals. User can give |
| - | * maximum number of processes to show. If a process exits, it's PID |
| - | * is shown as 'EXIT'. If new processes are started while this works, |
| - | * it doesn't add them to the list of shown processes. |
| + | * This is written specifically for the linux /proc/<PID>/stat(m) |
| + | * files format. |
| + | |
| + | * This reads the PIDs of all processes and their status and shows |
| + | * the status of processes (first ones that fit to screen) at given |
| + | * intervals. |
| * |
| * NOTES: |
| * - At startup this changes to /proc, all the reads are then |
| * relative to that. |
| - | * - Includes code from the scandir() manual page. |
| - | * |
| - | * TODO: |
| - | * - ppid, uid etc could be read only once when program starts |
| - | * and rest of the information could be gotten from the |
| - | * /proc/<PID>/statm file. |
| - | * - Add process CPU and memory usage *percentages*. |
| * |
| * (C) Eero Tamminen <oak at welho dot com> |
| + | * |
| + | * Rewroted by Vladimir Oleynik (C) 2002 <[email protected]> |
| + | */ |
| + | |
| + | /* Original code Copyrights */ |
| + | /* |
| + | * Copyright (c) 1992 Branko Lankester |
| + | * Copyright (c) 1992 Roger Binns |
| + | * Copyright (C) 1994-1996 Charles L. Blake. |
| + | * Copyright (C) 1992-1998 Michael K. Johnson |
| + | * May be distributed under the conditions of the |
| + | * GNU Library General Public License |
| */ |
| + | |
| + | #include <sys/types.h> |
| #include <stdio.h> |
| #include <stdlib.h> |
| #include <unistd.h> |
| #include <dirent.h> |
| #include <string.h> |
| #include <sys/ioctl.h> |
| + | #include <sys/stat.h> |
| + | /* get page info */ |
| + | #include <asm/page.h> |
| #include "busybox.h" |
| |
| + | //#define FEATURE_CPU_USAGE_PERCENTAGE /* + 2k */ |
| + | |
| + | #ifdef FEATURE_CPU_USAGE_PERCENTAGE |
| + | #include <time.h> |
| + | #include <sys/time.h> |
| + | #include <fcntl.h> |
| + | #include <netinet/in.h> /* htons */ |
| + | #endif |
| + | |
| |
| - | /* process information taken from /proc, |
| - | * The code takes into account how long the fields below are, |
| - | * starting from copying the file from 'status' file to displaying it! |
| - | */ |
| typedef struct { |
| - | char uid[6]; /* User ID */ |
| - | char pid[6]; /* Pid */ |
| - | char ppid[6]; /* Parent Pid */ |
| - | char name[12]; /* Name */ |
| - | char cmd[20]; /* command line[read/show size] */ |
| - | char state[2]; /* State: S, W... */ |
| - | char size[9]; /* VmSize */ |
| - | char lck[9]; /* VmLck */ |
| - | char rss[9]; /* VmRSS */ |
| - | char data[9]; /* VmData */ |
| - | char stk[9]; /* VmStk */ |
| - | char exe[9]; /* VmExe */ |
| - | char lib[9]; /* VmLib */ |
| + | int pid; |
| + | char user[9]; |
| + | char state[4]; |
| + | unsigned long rss; |
| + | int ppid; |
| + | #ifdef FEATURE_CPU_USAGE_PERCENTAGE |
| + | unsigned pcpu; |
| + | unsigned long stime, utime; |
| + | #endif |
| + | char *cmd; |
| + | |
| + | /* basename of executable file in call to exec(2), |
| + | size from kernel headers */ |
| + | char short_cmd[16]; |
| } status_t; |
| |
| + | typedef int (*cmp_t)(status_t *P, status_t *Q); |
| + | |
| + | static status_t *top; /* Hehe */ |
| + | static int ntop; |
| + | |
| + | |
| + | static int pid_sort (status_t *P, status_t *Q) |
| + | { |
| + | int p = P->pid; |
| + | int q = Q->pid; |
| + | |
| + | if( p < q ) return -1; |
| + | if( p > q ) return 1; |
| + | return 0; |
| + | } |
| + | |
| + | static int mem_sort (status_t *P, status_t *Q) |
| + | { |
| + | long p = P->rss; |
| + | long q = Q->rss; |
| + | |
| + | if( p > q ) return -1; |
| + | if( p < q ) return 1; |
| + | return 0; |
| + | } |
| + | |
| + | #ifdef FEATURE_CPU_USAGE_PERCENTAGE |
| + | |
| + | #define sort_depth 3 |
| + | static cmp_t sort_function[sort_depth]; |
| + | |
| + | static int pcpu_sort (status_t *P, status_t *Q) |
| + | { |
| + | int p = P->pcpu; |
| + | int q = Q->pcpu; |
| + | |
| + | if( p > q ) return -1; |
| + | if( p < q ) return 1; |
| + | return 0; |
| + | } |
| + | |
| + | static int time_sort (status_t *P, status_t *Q) |
| + | { |
| + | long p = P->stime; |
| + | long q = Q->stime; |
| + | |
| + | p += P->utime; |
| + | q += Q->utime; |
| + | if( p > q ) return -1; |
| + | if( p < q ) return 1; |
| + | return 0; |
| + | } |
| + | |
| + | int mult_lvl_cmp(void* a, void* b) { |
| + | int i, cmp_val; |
| + | |
| + | for(i = 0; i < sort_depth; i++) { |
| + | cmp_val = (*sort_function[i])(a, b); |
| + | if (cmp_val != 0) |
| + | return cmp_val; |
| + | } |
| + | return 0; |
| + | } |
| + | |
| + | /* This structure stores some critical information from one frame to |
| + | the next. mostly used for sorting. Added cumulative and resident fields. */ |
| + | struct save_hist { |
| + | int ticks; |
| + | int pid; |
| + | int utime; |
| + | int stime; |
| + | }; |
| + | |
| + | /* |
| + | * Calculates percent cpu usage for each task. |
| + | */ |
| + | |
| + | static struct save_hist *save_history; |
| + | |
| + | static unsigned long Hertz; |
| + | |
| + | /*********************************************************************** |
| + | * Some values in /proc are expressed in units of 1/HZ seconds, where HZ |
| + | * is the kernel clock tick rate. One of these units is called a jiffy. |
| + | * The HZ value used in the kernel may vary according to hacker desire. |
| + | * According to Linus Torvalds, this is not true. He considers the values |
| + | * in /proc as being in architecture-dependant units that have no relation |
| + | * to the kernel clock tick rate. Examination of the kernel source code |
| + | * reveals that opinion as wishful thinking. |
| + | * |
| + | * In any case, we need the HZ constant as used in /proc. (the real HZ value |
| + | * may differ, but we don't care) There are several ways we could get HZ: |
| + | * |
| + | * 1. Include the kernel header file. If it changes, recompile this library. |
| + | * 2. Use the sysconf() function. When HZ changes, recompile the C library! |
| + | * 3. Ask the kernel. This is obviously correct... |
| + | * |
| + | * Linus Torvalds won't let us ask the kernel, because he thinks we should |
| + | * not know the HZ value. Oh well, we don't have to listen to him. |
| + | * Someone smuggled out the HZ value. :-) |
| + | * |
| + | * This code should work fine, even if Linus fixes the kernel to match his |
| + | * stated behavior. The code only fails in case of a partial conversion. |
| + | * |
| + | */ |
| + | |
| + | #define FILE_TO_BUF(filename, fd) do{ \ |
| + | if (fd == -1 && (fd = open(filename, O_RDONLY)) == -1) { \ |
| + | perror_msg_and_die("/proc not be mounted?"); \ |
| + | } \ |
| + | lseek(fd, 0L, SEEK_SET); \ |
| + | if ((local_n = read(fd, buf, sizeof buf - 1)) < 0) { \ |
| + | perror_msg_and_die("%s", filename); \ |
| + | } \ |
| + | buf[local_n] = '\0'; \ |
| + | }while(0) |
| + | |
| + | #define FILE_TO_BUF2(filename, fd) do{ \ |
| + | lseek(fd, 0L, SEEK_SET); \ |
| + | if ((local_n = read(fd, buf, sizeof buf - 1)) < 0) { \ |
| + | perror_msg_and_die("%s", filename); \ |
| + | } \ |
| + | buf[local_n] = '\0'; \ |
| + | }while(0) |
| + | |
| + | static void init_Hertz_value(void) { |
| + | unsigned long user_j, nice_j, sys_j, other_j; /* jiffies (clock ticks) */ |
| + | double up_1, up_2, seconds; |
| + | unsigned long jiffies, h; |
| + | char buf[80]; |
| + | int uptime_fd = -1; |
| + | int stat_fd = -1; |
| + | |
| + | long smp_num_cpus = sysconf(_SC_NPROCESSORS_CONF); |
| + | |
| + | if(smp_num_cpus<1) smp_num_cpus=1; |
| + | do { |
| + | int local_n; |
| + | |
| + | FILE_TO_BUF("uptime", uptime_fd); |
| + | up_1 = strtod(buf, 0); |
| + | FILE_TO_BUF("stat", stat_fd); |
| + | sscanf(buf, "cpu %lu %lu %lu %lu", &user_j, &nice_j, &sys_j, &other_j); |
| + | FILE_TO_BUF2("uptime", uptime_fd); |
| + | up_2 = strtod(buf, 0); |
| + | } while((long)( (up_2-up_1)*1000.0/up_1 )); /* want under 0.1% error */ |
| + | |
| + | close(uptime_fd); |
| + | close(stat_fd); |
| + | |
| + | jiffies = user_j + nice_j + sys_j + other_j; |
| + | seconds = (up_1 + up_2) / 2; |
| + | h = (unsigned long)( (double)jiffies/seconds/smp_num_cpus ); |
| + | /* actual values used by 2.4 kernels: 32 64 100 128 1000 1024 1200 */ |
| + | switch(h){ |
| + | case 30 ... 34 : Hertz = 32; break; /* ia64 emulator */ |
| + | case 48 ... 52 : Hertz = 50; break; |
| + | case 58 ... 62 : Hertz = 60; break; |
| + | case 63 ... 65 : Hertz = 64; break; /* StrongARM /Shark */ |
| + | case 95 ... 105 : Hertz = 100; break; /* normal Linux */ |
| + | case 124 ... 132 : Hertz = 128; break; /* MIPS, ARM */ |
| + | case 195 ... 204 : Hertz = 200; break; /* normal << 1 */ |
| + | case 253 ... 260 : Hertz = 256; break; |
| + | case 295 ... 304 : Hertz = 300; break; /* 3 cpus */ |
| + | case 393 ... 408 : Hertz = 400; break; /* normal << 2 */ |
| + | case 495 ... 504 : Hertz = 500; break; /* 5 cpus */ |
| + | case 595 ... 604 : Hertz = 600; break; /* 6 cpus */ |
| + | case 695 ... 704 : Hertz = 700; break; /* 7 cpus */ |
| + | case 790 ... 808 : Hertz = 800; break; /* normal << 3 */ |
| + | case 895 ... 904 : Hertz = 900; break; /* 9 cpus */ |
| + | case 990 ... 1010 : Hertz = 1000; break; /* ARM */ |
| + | case 1015 ... 1035 : Hertz = 1024; break; /* Alpha, ia64 */ |
| + | case 1095 ... 1104 : Hertz = 1100; break; /* 11 cpus */ |
| + | case 1180 ... 1220 : Hertz = 1200; break; /* Alpha */ |
| + | default: |
| + | /* If 32-bit or big-endian (not Alpha or ia64), assume HZ is 100. */ |
| + | Hertz = (sizeof(long)==sizeof(int) || htons(999)==999) ? 100UL : 1024UL; |
| + | } |
| + | } |
| + | |
| + | static void do_stats(void) |
| + | { |
| + | struct timeval t; |
| + | static struct timeval oldtime; |
| + | struct timezone timez; |
| + | float elapsed_time; |
| + | |
| + | status_t *cur; |
| + | int total_time, i, n; |
| + | static int prev_count; |
| + | int systime, usrtime, pid; |
| + | |
| + | struct save_hist *New_save_hist; |
| + | |
| + | /* |
| + | * Finds the current time (in microseconds) and calculates the time |
| + | * elapsed since the last update. |
| + | */ |
| + | gettimeofday(&t, &timez); |
| + | elapsed_time = (t.tv_sec - oldtime.tv_sec) |
| + | + (float) (t.tv_usec - oldtime.tv_usec) / 1000000.0; |
| + | oldtime.tv_sec = t.tv_sec; |
| + | oldtime.tv_usec = t.tv_usec; |
| + | |
| + | New_save_hist = alloca(sizeof(struct save_hist)*ntop); |
| + | /* |
| + | * Make a pass through the data to get stats. |
| + | */ |
| + | for(n = 0; n < ntop; n++) { |
| + | cur = top + n; |
| + | |
| + | /* |
| + | * Calculate time in cur process. Time is sum of user time |
| + | * (usrtime) plus system time (systime). |
| + | */ |
| + | systime = cur->stime; |
| + | usrtime = cur->utime; |
| + | pid = cur->pid; |
| + | total_time = systime + usrtime; |
| + | New_save_hist[n].ticks = total_time; |
| + | New_save_hist[n].pid = pid; |
| + | New_save_hist[n].stime = systime; |
| + | New_save_hist[n].utime = usrtime; |
| + | |
| + | /* find matching entry from previous pass */ |
| + | for (i = 0; i < prev_count; i++) { |
| + | if (save_history[i].pid == pid) { |
| + | total_time -= save_history[i].ticks; |
| + | systime -= save_history[i].stime; |
| + | usrtime -= save_history[i].utime; |
| + | break; |
| + | } |
| + | } |
| + | |
| + | /* |
| + | * Calculate percent cpu time for cur task. |
| + | */ |
| + | i = (total_time * 10 * 100/Hertz) / elapsed_time; |
| + | if (i > 999) |
| + | i = 999; |
| + | cur->pcpu = i; |
| + | |
| + | } |
| + | |
| + | /* |
| + | * Save cur frame's information. |
| + | */ |
| + | free(save_history); |
| + | save_history = memcpy(xmalloc(sizeof(struct save_hist)*n), New_save_hist, |
| + | sizeof(struct save_hist)*n); |
| + | prev_count = n; |
| + | qsort(top, n, sizeof(status_t), (void*)mult_lvl_cmp); |
| + | } |
| + | #else |
| + | static cmp_t sort_function; |
| + | #endif /* FEATURE_CPU_USAGE_PERCENTAGE */ |
| + | |
| /* display generic info (meminfo / loadavg) */ |
| - | static void display_generic(void) |
| + | static unsigned long display_generic(void) |
| { |
| FILE *fp; |
| char buf[80]; |
| @@ -62,303 +332,245 @@ static void display_generic(void) |
| unsigned long total, used, mfree, shared, buffers, cached; |
| |
| /* read memory info */ |
| - | fp = fopen("meminfo", "r"); |
| - | if (!fp) { |
| - | perror("fopen('meminfo')"); |
| - | return; |
| - | } |
| + | fp = xfopen("meminfo", "r"); |
| fgets(buf, sizeof(buf), fp); /* skip first line */ |
| |
| if (fscanf(fp, "Mem: %lu %lu %lu %lu %lu %lu", |
| &total, &used, &mfree, &shared, &buffers, &cached) != 6) { |
| - | fprintf(stderr, "Error: failed to read 'meminfo'"); |
| - | fclose(fp); |
| + | error_msg_and_die("failed to read '%s'", "meminfo"); |
| } |
| fclose(fp); |
| |
| /* read load average */ |
| - | fp = fopen("loadavg", "r"); |
| - | if (!fp) { |
| - | perror("fopen('loadavg')"); |
| - | return; |
| - | } |
| + | fp = xfopen("loadavg", "r"); |
| if (fscanf(fp, "%f %f %f", &avg1, &avg2, &avg3) != 3) { |
| - | fprintf(stderr, "Error: failed to read 'loadavg'"); |
| - | fclose(fp); |
| - | return; |
| + | error_msg_and_die("failed to read '%s'", "loadavg"); |
| } |
| fclose(fp); |
| |
| /* convert to kilobytes */ |
| - | if (total) total /= 1024; |
| - | if (used) used /= 1024; |
| - | if (mfree) mfree /= 1024; |
| - | if (shared) shared /= 1024; |
| - | if (buffers) buffers /= 1024; |
| - | if (cached) cached /= 1024; |
| + | used /= 1024; |
| + | mfree /= 1024; |
| + | shared /= 1024; |
| + | buffers /= 1024; |
| + | cached /= 1024; |
| |
| /* output memory info and load average */ |
| - | printf("Mem: %ldK, %ldK used, %ldK free, %ldK shrd, %ldK buff, %ldK cached\n", |
| - | total, used, mfree, shared, buffers, cached); |
| - | printf("Load average: %.2f, %.2f, %.2f (State: S=sleeping R=running, W=waiting)\n", |
| + | /* clear screen & go to top */ |
| + | printf("\e[H\e[J" "Mem: " |
| + | "%ldK used, %ldK free, %ldK shrd, %ldK buff, %ldK cached\n", |
| + | used, mfree, shared, buffers, cached); |
| + | printf("Load average: %.2f, %.2f, %.2f " |
| + | "(State: S=sleeping R=running, W=waiting)\n", |
| avg1, avg2, avg3); |
| + | return total / 1024; |
| } |
| |
| |
| /* display process statuses */ |
| - | static void display_status(int count, const status_t *s) |
| + | static void display_status(int count, int col) |
| { |
| - | const char *fmt, *cmd; |
| - | |
| - | /* clear screen & go to top */ |
| - | printf("\e[2J\e[1;1H"); |
| - | |
| - | display_generic(); |
| + | status_t *s = top; |
| + | char rss_str_buf[8]; |
| + | unsigned long total_memory = display_generic(); |
| |
| + | #ifdef FEATURE_CPU_USAGE_PERCENTAGE |
| /* what info of the processes is shown */ |
| - | printf("\n%*s %*s %*s %*s %*s %*s %-*s\n", |
| - | sizeof(s->pid)-1, "Pid:", |
| - | sizeof(s->state)-1, "", |
| - | sizeof(s->ppid)-1, "PPid:", |
| - | sizeof(s->uid)-1, "UID:", |
| - | sizeof(s->size)-1, "WmSize:", |
| - | sizeof(s->rss)-1, "WmRSS:", |
| - | sizeof(s->cmd)-1, "command line:"); |
| + | printf("\n\e[7m PID USER STATUS RSS PPID %%CPU %%MEM COMMAND\e[0m\n"); |
| + | #else |
| + | printf("\n\e[7m PID USER STATUS RSS PPID %%MEM COMMAND\e[0m\n"); |
| + | #endif |
| |
| while (count--) { |
| - | if (s->cmd[0]) { |
| - | /* normal process, has command line */ |
| - | cmd = s->cmd; |
| - | fmt = "%*s %*s %*s %*s %*s %*s %s\n"; |
| - | } else { |
| - | /* no command line, show only process name */ |
| - | cmd = s->name; |
| - | fmt = "%*s %*s %*s %*s %*s %*s [%s]\n"; |
| - | } |
| - | printf(fmt, |
| - | sizeof(s->pid)-1, s->pid, |
| - | sizeof(s->state)-1, s->state, |
| - | sizeof(s->ppid)-1, s->ppid, |
| - | sizeof(s->uid)-1, s->uid, |
| - | sizeof(s->size)-1, s->size, |
| - | sizeof(s->rss)-1, s->rss, |
| - | cmd); |
| - | s++; |
| - | } |
| - | } |
| + | char *namecmd = s->cmd; |
| + | int pmem; |
| |
| - | |
| - | /* checks if given 'buf' for process starts with 'id' + ':' + TAB |
| - | * and stores rest of the buf to 'store' with max size 'size' |
| - | */ |
| - | static int process_status(const char *buf, const char *id, char *store, size_t size) |
| - | { |
| - | int len, i; |
| + | pmem = 1000.0 * s->rss / total_memory; |
| + | if (pmem > 999) pmem = 999; |
| |
| - | /* check status field name */ |
| - | len = strlen(id); |
| - | if (strncmp(buf, id, len) != 0) { |
| - | if(store) |
| - | error_msg_and_die("ERROR status: line doesn't start with '%s' in:\n%s\n", id, buf); |
| + | if(s->rss > 10*1024) |
| + | sprintf(rss_str_buf, "%6ldM", s->rss/1024); |
| else |
| - | return 0; |
| - | } |
| - | if (!store) { |
| - | /* ignoring this field */ |
| - | return 1; |
| - | } |
| - | buf += len; |
| - | |
| - | /* check status field format */ |
| - | if ((*buf++ != ':') || (*buf++ != '\t')) { |
| - | error_msg_and_die("ERROR status: field '%s' not followed with ':' + TAB in:\n%s\n", id, buf); |
| - | } |
| - | |
| - | /* skip whitespace in Wm* fields */ |
| - | if (id[0] == 'V' && id[1] == 'm') { |
| - | i = 3; |
| - | while (i--) { |
| - | if (*buf == ' ') { |
| - | buf++; |
| + | sprintf(rss_str_buf, "%7ld", s->rss); |
| + | #ifdef FEATURE_CPU_USAGE_PERCENTAGE |
| + | printf("%5d %-8s %s %s %5d %2d.%d %2u.%u ", |
| + | #else |
| + | printf("%5d %-8s %s %s %5d %2u.%u ", |
| + | #endif |
| + | s->pid, s->user, s->state, rss_str_buf, s->ppid, |
| + | #ifdef FEATURE_CPU_USAGE_PERCENTAGE |
| + | s->pcpu/10, s->pcpu%10, |
| + | #endif |
| + | pmem/10, pmem%10); |
| + | if(namecmd != 0 && namecmd[0] != 0) { |
| + | if(strlen(namecmd) > col) |
| + | namecmd[col] = 0; |
| + | printf("%s\n", namecmd); |
| } else { |
| - | error_msg_and_die("ERROR status: can't skip whitespace for " |
| - | "'%s' field in:\n%s\n", id, buf); |
| + | namecmd = s->short_cmd; |
| + | if(strlen(namecmd) > (col-2)) |
| + | namecmd[col-2] = 0; |
| + | printf("[%s]\n", namecmd); |
| } |
| + | s++; |
| } |
| - | } |
| - | |
| - | /* copy at max (size-1) chars and force '\0' to the end */ |
| - | while (--size) { |
| - | if (*buf < ' ') { |
| - | break; |
| - | } |
| - | *store++ = *buf++; |
| - | } |
| - | *store = '\0'; |
| - | return 1; |
| } |
| |
| - | /* read process statuses */ |
| - | static void read_status(int num, status_t *s) |
| + | /* returns true for file names which are PID dirs |
| + | * (i.e. start with number) |
| + | */ |
| + | static int filter_pids(const struct dirent *dir) |
| { |
| + | char *name = dir->d_name; |
| + | int n; |
| char status[20]; |
| - | char buf[80]; |
| + | char buf[1024]; |
| FILE *fp; |
| + | status_t curstatus; |
| + | int pid; |
| + | long tasknice; |
| + | struct stat sb; |
| + | |
| + | if (!(*name >= '0' && *name <= '9')) |
| + | return 0; |
| + | if(stat(name, &sb)) |
| + | return 0; |
| + | |
| + | memset(&curstatus, 0, sizeof(status_t)); |
| + | pid = atoi(name); |
| + | curstatus.pid = pid; |
| |
| - | while (num--) { |
| - | sprintf(status, "%s/status", s->pid); |
| - | |
| - | /* read the command line from 'cmdline' in PID dir */ |
| - | fp = fopen(status, "r"); |
| - | if (!fp) { |
| - | strncpy(s->pid, "EXIT", sizeof(s->pid)); |
| - | s->pid[sizeof(s->pid)-1] = '\0'; |
| + | my_getpwuid(curstatus.user, sb.st_uid); |
| + | |
| + | sprintf(status, "%d/stat", pid); |
| + | if((fp = fopen(status, "r")) == NULL) |
| + | return 0; |
| + | name = fgets(buf, sizeof(buf), fp); |
| fclose(fp); |
| - | continue; |
| - | } |
| + | if(name == NULL) |
| + | return 0; |
| + | name = strrchr(buf, ')'); /* split into "PID (cmd" and "<rest>" */ |
| + | if(name == 0 || name[1] != ' ') |
| + | return 0; |
| + | *name = 0; |
| + | sscanf(buf, "%*s (%15c", curstatus.short_cmd); |
| + | n = sscanf(name+2, |
| + | "%c %d " |
| + | "%*s %*s %*s %*s " /* pgrp, session, tty, tpgid */ |
| + | "%*s %*s %*s %*s %*s " /* flags, min_flt, cmin_flt, maj_flt, cmaj_flt */ |
| + | #ifdef FEATURE_CPU_USAGE_PERCENTAGE |
| + | "%lu %lu " |
| + | #else |
| + | "%*s %*s " |
| + | #endif |
| + | "%*s %*s %*s " /* cutime, cstime, priority */ |
| + | "%ld " |
| + | "%*s %*s %*s " /* timeout, it_real_value, start_time */ |
| + | "%*s " /* vsize */ |
| + | "%ld", |
| + | curstatus.state, &curstatus.ppid, |
| + | #ifdef FEATURE_CPU_USAGE_PERCENTAGE |
| + | &curstatus.utime, &curstatus.stime, |
| + | #endif |
| + | &tasknice, |
| + | &curstatus.rss); |
| + | #ifdef FEATURE_CPU_USAGE_PERCENTAGE |
| + | if(n != 6) |
| + | #else |
| + | if(n != 4) |
| + | #endif |
| + | return 0; |
| + | |
| + | if (curstatus.rss == 0 && curstatus.state[0] != 'Z') |
| + | curstatus.state[1] = 'W'; |
| + | else |
| + | curstatus.state[1] = ' '; |
| + | if (tasknice < 0) |
| + | curstatus.state[2] = '<'; |
| + | else if (tasknice > 0) |
| + | curstatus.state[2] = 'N'; |
| + | else |
| + | curstatus.state[2] = ' '; |
| + | |
| + | curstatus.rss <<= (PAGE_SHIFT - 10); /* 2**10 = 1kb */ |
| |
| - | /* get and process the information */ |
| - | fgets(buf, sizeof(buf), fp); |
| - | process_status(buf, "Name", s->name, sizeof(s->name)); |
| - | fgets(buf, sizeof(buf), fp); |
| - | process_status(buf, "State", s->state, sizeof(s->state)); |
| - | fgets(buf, sizeof(buf), fp); |
| - | if(process_status(buf, "Tgid", NULL, 0)) |
| - | fgets(buf, sizeof(buf), fp); |
| - | process_status(buf, "Pid", NULL, 0); |
| - | fgets(buf, sizeof(buf), fp); |
| - | process_status(buf, "PPid", s->ppid, sizeof(s->ppid)); |
| - | fgets(buf, sizeof(buf), fp); |
| - | if(process_status(buf, "TracerPid", NULL, 0)) |
| - | fgets(buf, sizeof(buf), fp); |
| - | process_status(buf, "Uid", s->uid, sizeof(s->uid)); |
| - | fgets(buf, sizeof(buf), fp); |
| - | process_status(buf, "Gid", NULL, 0); |
| - | fgets(buf, sizeof(buf), fp); |
| - | if(process_status(buf, "FDSize", NULL, 0)) |
| - | fgets(buf, sizeof(buf), fp); |
| - | process_status(buf, "Groups", NULL, 0); |
| - | fgets(buf, sizeof(buf), fp); |
| - | /* only user space processes have command line |
| - | * and memory statistics |
| - | */ |
| - | if (s->cmd[0]) { |
| - | process_status(buf, "VmSize", s->size, sizeof(s->size)); |
| - | fgets(buf, sizeof(buf), fp); |
| - | process_status(buf, "VmLck", s->lck, sizeof(s->lck)); |
| - | fgets(buf, sizeof(buf), fp); |
| - | process_status(buf, "VmRSS", s->rss, sizeof(s->rss)); |
| - | fgets(buf, sizeof(buf), fp); |
| - | process_status(buf, "VmData", s->data, sizeof(s->data)); |
| - | fgets(buf, sizeof(buf), fp); |
| - | process_status(buf, "VmStk", s->stk, sizeof(s->stk)); |
| - | fgets(buf, sizeof(buf), fp); |
| - | process_status(buf, "VmExe", s->exe, sizeof(s->exe)); |
| - | fgets(buf, sizeof(buf), fp); |
| - | process_status(buf, "VmLib", s->lib, sizeof(s->lib)); |
| + | sprintf(status, "%d/cmdline", pid); |
| + | if((fp = fopen(status, "r")) == NULL) |
| + | return 0; |
| + | if(fgets(buf, sizeof(buf), fp) != NULL) { |
| + | name = strchr(buf, '\n'); |
| + | if(name != NULL) |
| + | *name = 0; |
| + | if(buf[0]) |
| + | curstatus.cmd = strdup(buf); /* if NULL it work true also */ |
| } |
| fclose(fp); |
| |
| - | /* next process */ |
| - | s++; |
| - | } |
| + | n = ntop; |
| + | top = xrealloc(top, (++ntop)*sizeof(status_t)); |
| + | memcpy(top + n, &curstatus, sizeof(status_t)); |
| + | return 1; |
| } |
| |
| |
| - | /* allocs statuslist and reads process command lines, frees namelist, |
| - | * returns filled statuslist or NULL in case of error. |
| - | */ |
| - | static status_t *read_info(int num, struct dirent **namelist) |
| - | { |
| - | status_t *statuslist, *s; |
| - | char cmdline[20]; |
| - | FILE *fp; |
| - | int idx; |
| + | static struct dirent **namelist; |
| |
| - | /* allocate & zero status for each of the processes */ |
| - | statuslist = calloc(num, sizeof(status_t)); |
| - | if (!statuslist) { |
| - | return NULL; |
| - | } |
| - | |
| - | /* go through the processes */ |
| - | for (idx = 0; idx < num; idx++) { |
| - | |
| - | /* copy PID string to status struct and free name */ |
| - | s = &(statuslist[idx]); |
| - | if (strlen(namelist[idx]->d_name) > sizeof(s->pid)-1) { |
| - | fprintf(stderr, "PID '%s' too long\n", namelist[idx]->d_name); |
| - | return NULL; |
| - | } |
| - | strncpy(s->pid, namelist[idx]->d_name, sizeof(s->pid)); |
| - | s->pid[sizeof(s->pid)-1] = '\0'; |
| - | free(namelist[idx]); |
| - | |
| - | /* read the command line from 'cmdline' in PID dir */ |
| - | sprintf(cmdline, "%s/cmdline", s->pid); |
| - | fp = fopen(cmdline, "r"); |
| - | if (!fp) { |
| - | fclose(fp); |
| - | perror("fopen('cmdline')"); |
| - | return NULL; |
| - | } |
| - | fgets(statuslist[idx].cmd, sizeof(statuslist[idx].cmd), fp); |
| - | fclose(fp); |
| + | static void clearmems(void) { |
| + | int i; |
| + | |
| + | for(i = 0; i < ntop; i++) { |
| + | free(top[i].cmd); |
| + | free(namelist[i]); |
| } |
| + | free(top); |
| free(namelist); |
| - | return statuslist; |
| + | top = 0; |
| + | namelist = 0; |
| + | ntop = 0; |
| } |
| |
| + | #if defined CONFIG_FEATURE_USE_TERMIOS |
| + | #include <termios.h> |
| + | #include <sys/time.h> |
| + | #include <signal.h> |
| |
| - | /* returns true for file names which are PID dirs |
| - | * (i.e. start with number) |
| - | */ |
| - | static int filter_pids(const struct dirent *dir) |
| - | { |
| - | status_t dummy; |
| - | char *name = dir->d_name; |
| - | |
| - | if (*name >= '0' && *name <= '9') { |
| - | if (strlen(name) > sizeof(dummy.pid)-1) { |
| - | fprintf(stderr, "PID name '%s' too long\n", name); |
| - | return 0; |
| - | } |
| - | return 1; |
| - | } |
| - | return 0; |
| - | } |
| |
| + | static struct termios initial_settings; |
| |
| - | /* compares two directory entry names as numeric strings |
| - | */ |
| - | static int num_sort(const void *a, const void *b) |
| + | static void reset_term(void) |
| { |
| - | int ia = atoi((*(struct dirent **)a)->d_name); |
| - | int ib = atoi((*(struct dirent **)b)->d_name); |
| + | tcsetattr(0, TCSANOW, (void *) &initial_settings); |
| + | #ifdef CONFIG_FEATURE_CLEAN_UP |
| + | clearmems(); |
| + | #ifdef FEATURE_CPU_USAGE_PERCENTAGE |
| + | free(save_history); |
| + | #endif |
| + | #endif /* CONFIG_FEATURE_CLEAN_UP */ |
| + | } |
| |
| - | if (ia == ib) { |
| - | return 0; |
| - | } |
| - | /* NOTE: by switching the check, you change the process sort order */ |
| - | if (ia < ib) { |
| - | return -1; |
| - | } else { |
| - | return 1; |
| - | } |
| + | static void sig_catcher (int sig) |
| + | { |
| + | reset_term(); |
| } |
| + | #endif /* CONFIG_FEATURE_USE_TERMIOS */ |
| + | |
| |
| int top_main(int argc, char **argv) |
| { |
| - | status_t *statuslist; |
| - | struct dirent **namelist; |
| - | int opt, num, interval, lines; |
| - | #if defined CONFIG_FEATURE_AUTOWIDTH && defined CONFIG_FEATURE_USE_TERMIOS |
| + | int opt, interval, lines, col; |
| + | #if defined CONFIG_FEATURE_USE_TERMIOS |
| + | struct termios new_settings; |
| + | struct timeval tv; |
| + | fd_set readfds; |
| + | unsigned char c; |
| + | struct sigaction sa; |
| + | #if defined CONFIG_FEATURE_AUTOWIDTH |
| struct winsize win = { 0, 0, 0, 0 }; |
| #endif |
| + | #endif /* CONFIG_FEATURE_USE_TERMIOS */ |
| + | |
| /* Default update rate is 5 seconds */ |
| interval = 5; |
| - | /* Default to 25 lines - 5 lines for status */ |
| - | lines = 25 - 5; |
| |
| /* do normal option parsing */ |
| while ((opt = getopt(argc, argv, "d:")) > 0) { |
| @@ -371,42 +583,121 @@ int top_main(int argc, char **argv) |
| } |
| } |
| |
| - | #if defined CONFIG_FEATURE_AUTOWIDTH && defined CONFIG_FEATURE_USE_TERMIOS |
| - | ioctl(fileno(stdout), TIOCGWINSZ, &win); |
| - | if (win.ws_row > 4) |
| - | lines = win.ws_row - 5; |
| + | /* Default to 25 lines - 5 lines for status */ |
| + | lines = 25 - 5; |
| + | /* Default CMD format size */ |
| + | #ifdef FEATURE_CPU_USAGE_PERCENTAGE |
| + | col = 35 - 6; |
| + | #else |
| + | col = 35; |
| #endif |
| - | |
| /* change to proc */ |
| if (chdir("/proc") < 0) { |
| perror_msg_and_die("chdir('/proc')"); |
| } |
| - | |
| - | /* read process IDs for all the processes from the procfs */ |
| - | num = scandir(".", &namelist, filter_pids, num_sort); |
| - | if (num < 0) { |
| + | #if defined CONFIG_FEATURE_USE_TERMIOS |
| + | tcgetattr(0, (void *) &initial_settings); |
| + | memcpy(&new_settings, &initial_settings, sizeof(struct termios)); |
| + | new_settings.c_lflag &= ~(ISIG | ICANON); /* unbuffered input */ |
| + | /* Turn off echoing */ |
| + | new_settings.c_lflag &= ~(ECHO | ECHONL); |
| + | |
| + | signal (SIGTERM, sig_catcher); |
| + | sigaction (SIGTERM, (struct sigaction *) 0, &sa); |
| + | sa.sa_flags |= SA_RESTART; |
| + | sa.sa_flags &= ~SA_INTERRUPT; |
| + | sigaction (SIGTERM, &sa, (struct sigaction *) 0); |
| + | sigaction (SIGINT, &sa, (struct sigaction *) 0); |
| + | tcsetattr(0, TCSANOW, (void *) &new_settings); |
| + | atexit(reset_term); |
| + | #if defined CONFIG_FEATURE_AUTOWIDTH |
| + | ioctl(0, TIOCGWINSZ, &win); |
| + | if (win.ws_row > 4) { |
| + | lines = win.ws_row - 5; |
| + | #ifdef FEATURE_CPU_USAGE_PERCENTAGE |
| + | col = win.ws_col - 80 + 35 - 6; |
| + | #else |
| + | col = win.ws_col - 80 + 35; |
| + | #endif |
| + | } |
| + | #endif |
| + | #endif /* CONFIG_FEATURE_USE_TERMIOS */ |
| + | #ifdef FEATURE_CPU_USAGE_PERCENTAGE |
| + | sort_function[0] = pcpu_sort; |
| + | sort_function[1] = mem_sort; |
| + | sort_function[2] = time_sort; |
| + | #else |
| + | sort_function = mem_sort; |
| + | #endif |
| + | while (1) { |
| + | /* read process IDs & status for all the processes */ |
| + | if (scandir(".", &namelist, filter_pids, 0) < 0) { |
| perror_msg_and_die("scandir('/proc')"); |
| } |
| - | if (lines > num) { |
| - | lines = num; |
| + | #ifdef FEATURE_CPU_USAGE_PERCENTAGE |
| + | if(!Hertz) { |
| + | init_Hertz_value(); |
| + | do_stats(); |
| + | sleep(1); |
| + | clearmems(); |
| + | continue; |
| } |
| - | |
| - | /* read command line for each of the processes */ |
| - | statuslist = read_info(num, namelist); |
| - | if (!statuslist) { |
| + | do_stats(); |
| + | #else |
| + | qsort(top, ntop, sizeof(status_t), (void*)sort_function); |
| + | #endif |
| + | opt = lines; |
| + | if (opt > ntop) { |
| + | opt = ntop; |
| + | } |
| + | /* show status for each of the processes */ |
| + | display_status(opt, col); |
| + | #if defined CONFIG_FEATURE_USE_TERMIOS |
| + | tv.tv_sec = interval; |
| + | tv.tv_usec = 0; |
| + | FD_ZERO (&readfds); |
| + | FD_SET (0, &readfds); |
| + | select (1, &readfds, NULL, NULL, &tv); |
| + | if (FD_ISSET (0, &readfds)) { |
| + | if (read (0, &c, 1) <= 0) { /* signal */ |
| return EXIT_FAILURE; |
| } |
| - | |
| - | while (1) { |
| - | /* read status for each of the processes */ |
| - | read_status(num, statuslist); |
| - | |
| - | /* display status */ |
| - | display_status(lines, statuslist); |
| - | |
| + | if(c == 'q' || c == initial_settings.c_cc[VINTR]) |
| + | return EXIT_SUCCESS; |
| + | if(c == 'M') { |
| + | #ifdef FEATURE_CPU_USAGE_PERCENTAGE |
| + | sort_function[0] = mem_sort; |
| + | sort_function[1] = pcpu_sort; |
| + | sort_function[2] = time_sort; |
| + | #else |
| + | sort_function = mem_sort; |
| + | #endif |
| + | } |
| + | #ifdef FEATURE_CPU_USAGE_PERCENTAGE |
| + | if(c == 'P') { |
| + | sort_function[0] = pcpu_sort; |
| + | sort_function[1] = mem_sort; |
| + | sort_function[2] = time_sort; |
| + | } |
| + | if(c == 'T') { |
| + | sort_function[0] = time_sort; |
| + | sort_function[1] = mem_sort; |
| + | sort_function[2] = pcpu_sort; |
| + | } |
| + | #endif |
| + | if(c == 'N') { |
| + | #ifdef FEATURE_CPU_USAGE_PERCENTAGE |
| + | sort_function[0] = pid_sort; |
| + | #else |
| + | sort_function = pid_sort; |
| + | #endif |
| + | } |
| + | } |
| + | #else |
| sleep(interval); |
| + | #endif /* CONFIG_FEATURE_USE_TERMIOS */ |
| + | clearmems(); |
| } |
| |
| - | free(statuslist); |
| return EXIT_SUCCESS; |
| } |