-/*
- * Top users display for Berkeley Unix
- * Version 1.8
- *
- * This program may be freely redistributed to other Unix sites, but this
- * entire comment MUST remain intact.
- *
- * Copyright (c) 1984, William LeFebvre, Rice University
- *
- * This program is designed to run on either Berkeley 4.1 or 4.2 Unix.
- * Compile with the preprocessor constant "FOUR_ONE" set to get an
- * executable that will run on Berkeley 4.1 Unix.
- *
- * The Sun kernel uses scaled integers instead of floating point so compile
- * with the preprocessor variable "SUN" to get an executable that will run
- * on Sun Unix version 1.1 or later.
- *
- * Fixes and enhancements since version 1.5:
- *
- * Jonathon Feiber at sun:
- * added "#ifdef SUN" code to make top work on a Sun,
- * fixed race bug in getkval for getting user structure,
- * efficiency improvements: added register variables and
- * removed the function hashit
- *
- * added real and virtual memory status line
- *
- * added second "key" to the qsort comparisn function "proc_compar"
- * which sorts by on cpu ticks if percentage is equal
- *
- **********************************************************************
- * HISTORY
- * 22-Apr-99 Avadis Tevanian (avie) at Apple
- * Another rewrite for Mach 3.0
- *
- * 21-Apr-90 Avadis Tevanian (avie) at NeXT
- * Completely rewritten again for processor sets.
- *
- * 6-May-88 David Golub (dbg) at Carnegie-Mellon University
- * Completely rewritten for MACH. This version will NOT run on any
- * other version of BSD.
- *
- */
-
-#define Default_TOPN 16 /* default number of lines */
-#define Default_DELAY 1 /* default delay interval */
-#define IOKIT 1 /* for io_name_t in device_types.h */
-
-#include <mach/mach.h>
-#include <stdlib.h>
-#include <stdio.h>
-#include <signal.h>
-#include <strings.h>
-#include <nlist.h>
-#include <fcntl.h>
-#include <string.h>
-
-#include <sys/types.h>
-#include <sys/param.h>
-#include <sys/sysctl.h>
-#include <sys/time.h>
-
-#include <mach/bootstrap.h>
-#include <mach/host_info.h>
-#include <mach/mach_error.h>
-#include <mach/mach_types.h>
-#include <mach/message.h>
-#include <mach/vm_region.h>
-#include <mach/vm_map.h>
-#include <mach/vm_types.h>
-#include <mach/vm_prot.h>
-#include <mach/shared_memory_server.h>
-
-#include <device/device_types.h>
-#include <CoreFoundation/CoreFoundation.h>
-#include <IOKit/IOKitLib.h>
-#include <IOKit/storage/IOBlockStorageDriver.h>
-
-#include <kvm.h>
-#include <sys/socket.h>
-#include <net/if.h>
-#include <net/if_var.h>
-
-#include <libc.h>
-#include <termios.h>
-#include <curses.h>
-#include <sys/ioctl.h>
-
-/* Number of lines of header information on the standard screen */
-#define HEADER_LINES 8
-
-#define sec_to_minutes(t) ((t) / 60)
-#define sec_to_seconds(t) ((t) % 60)
-#define usec_to_100ths(t) ((t) / 10000)
-
-#ifndef TH_USAGE_SCALE
-#define TH_USAGE_SCALE 1000
-#endif TH_USAGE_SCALE
-#define usage_to_percent(u) ((u*100)/TH_USAGE_SCALE)
-#define usage_to_tenths(u) (((u*1000)/TH_USAGE_SCALE) % 10)
-
-
-#define time_value_sub(tvp, uvp, vvp) \
- do { \
- (vvp)->seconds = (tvp)->seconds - (uvp)->seconds; \
- (vvp)->microseconds = (tvp)->microseconds - (uvp)->microseconds; \
- if ((vvp)->microseconds < 0) { \
- (vvp)->seconds--; \
- (vvp)->microseconds += 1000000; \
- } \
- } while (0)
-
-
-
-/* From libcurses */
-int wclear(WINDOW *win);
-int wmove(WINDOW *win, int y, int x);
-int wrefresh(WINDOW *win);
-int endwin(void);
-int werase(WINDOW *win);
-
-int total_threads;
-unsigned long long total_fw_private;
-
-char bytesread[128];
-
-host_cpu_load_info_data_t lastcounters, curcounters, startcounters;
-double userticks, systicks, idleticks, totalticks;
-
-struct timeval cur_tod;
-struct timeval start_tod;
-struct timeval last_tod;
-struct timeval elapsed_tod;
-int elapsed_milliseconds;
-int newLINES = 0;
-int Header_lines = HEADER_LINES;
-
-int do_proc0_vm;
-int sort_by_usage;
-int wide_output;
-int oneshot;
-int logcnt;
-int events_only;
-int events_delta;
-int events_accumulate;
-long start_time = 0;
-
-
-struct io_stats {
- UInt64 io_accum;
- UInt64 io_prev;
- UInt64 io;
- UInt64 kbytes_accum;
- UInt64 kbytes_prev;
- UInt64 kbytes;
-};
-
-struct io_stats i_net, o_net;
-struct io_stats i_dsk, o_dsk;
-struct io_stats i_vm, o_vm;
-
-
-io_iterator_t drivelist = 0; /* needs release */
-mach_port_t masterPort = 0;
-
-
-struct proc_info {
- uid_t uid;
- short pid;
- short ppid;
- short pgrp;
- int status;
- int flag;
-
- int state;
- int pri;
- int base_pri;
- boolean_t all_swapped;
- boolean_t has_idle_thread;
- time_value_t total_time;
- time_value_t idle_time;
- time_value_t beg_total_time;
- time_value_t beg_idle_time;
-
- vm_size_t virtual_size;
- vm_size_t resident_size;
- vm_size_t orig_virtual_size;
- vm_offset_t drsize, dvsize;
- vm_offset_t drprvt, drshrd;
- vm_offset_t rvsize;
- unsigned int shared;
- unsigned int private;
- unsigned int vprivate;
- int obj_count;
- int cpu_usage;
- int cpu_idle;
-
- char command[20];
-
- int num_ports;
- int orig_num_ports;
- int dnum_ports;
- int num_threads;
- thread_basic_info_t threads; /* array */
- task_events_info_data_t tei;
- task_events_info_data_t deltatei;
- task_events_info_data_t accumtei;
-};
-
-typedef struct proc_info *proc_info_t;
-
-mach_port_t host_priv_port, host_port;
-
-struct object_info {
- int id;
- int pid;
- int share_type;
- int resident_page_count;
- int ref_count;
- int task_ref_count;
- int size;
- struct object_info *next;
-};
-
-#define OBJECT_TABLE_SIZE 537
-#define OT_HASH(object) (((unsigned)object)%OBJECT_TABLE_SIZE)
-
-struct object_info *shared_hash_table[OBJECT_TABLE_SIZE];
-
-struct object_info *of_free_list = 0;
-
-/*
- * Translate thread state to a number in an ordered scale.
- * When collapsing all the threads' states to one for the
- * entire task, the lower-numbered state dominates.
- */
-#define STATE_MAX 7
-
-int
-mach_state_order(s, sleep_time)
- int s;
- long sleep_time;
- {
- switch (s) {
- case TH_STATE_RUNNING: return(1);
- case TH_STATE_UNINTERRUPTIBLE:
- return(2);
- case TH_STATE_WAITING: return((sleep_time > 20) ? 4 : 3);
- case TH_STATE_STOPPED: return(5);
- case TH_STATE_HALTED: return(6);
- default: return(7);
- }
-}
- /*01234567 */
-char mach_state_table[] = "ZRUSITH?";
-
-char * state_name[] = {
- "zombie",
- "running",
- "stuck",
- "sleeping",
- "idle",
- "stopped",
- "halted",
- "unknown",
-};
-int state_breakdown[STATE_MAX+1];
-
-
-char *state_to_string(pi)
- proc_info_t pi;
-{
- static char s[5]; /* STATIC! */
-
- s[0] = mach_state_table[pi->state];
- s[1] = (pi->all_swapped) ? 'W' : ' ';
- s[2] = (pi->base_pri > 50) ? 'N' :
- (pi->base_pri < 40) ? '<' : ' ';
- s[3] = ' ';
- s[4] = '\0';
- return(s);
-}
-
-void print_time(char *p, time_value_t t)
-{
- long seconds, useconds, minutes, hours;
-
- seconds = t.seconds;
- useconds = t.microseconds;
- minutes = seconds / 60;
- hours = minutes / 60;
-
- if (minutes < 100) { // up to 100 minutes
- sprintf(p, "%2ld:%02ld.%02ld", minutes, seconds % 60,
- usec_to_100ths(useconds));
- }
- else if (hours < 100) { // up to 100 hours
- sprintf(p, "%2ld:%02ld:%02ld", hours, minutes % 60,
- seconds % 60);
- }
- else {
- sprintf(p, "%4ld hrs", hours);
- }
-}
-
-
-void
-print_usage(char *p, int cpu_usage)
-{
- int left_of_decimal;
- int right_of_decimal;
-
- if (elapsed_milliseconds) {
- left_of_decimal = (cpu_usage * 100) / elapsed_milliseconds;
-
- right_of_decimal = (((cpu_usage * 100) - (left_of_decimal * elapsed_milliseconds)) * 10) /
- elapsed_milliseconds;
- } else {
- left_of_decimal = 0;
- right_of_decimal = 0;
- }
- sprintf(p, "%3d.%01d%%%%", left_of_decimal, right_of_decimal); /* %cpu */
-}
-
-
-
-char *
-digits(n)
- float n;
-{
- static char tmp[10]; /* STATIC! */
-
- if ((n > 0) && (n < 10))
- sprintf(tmp, "%4.2f", n);
- else if ((n > 0) && (n < 100))
- sprintf(tmp, "%4.1f", n);
- else if ((n < 0) && (n > -10))
- sprintf(tmp, "%4.1f", n);
- else
- sprintf(tmp, "%4.0f", n);
- return(tmp);
-}
-
-char *
-mem_to_string(n)
- unsigned long long n;
-{
- static char s[10]; /* STATIC! */
-
- /* convert to kilobytes */
- n /= 1024;
-
- if (n > 1024*1024)
- sprintf(s, "%sG", digits(((float)n)/(1024.0*1024.0)));
- else if (n > 1024)
- sprintf(s, "%sM", digits((float)n/(1024.0)));
- else
- sprintf(s, "%dK", (int)n);
-
- return(s);
-}
-
-char *
-offset_to_string(n)
- int n;
-{
- static char s[10]; /* STATIC! */
- int an;
-
- /* convert to kilobytes */
- n /= 1024;
- an = abs(n);
-
- if (an > 1024*1024)
- sprintf(s, "%sG", digits(((float)n)/(1024.0*1024.0)));
- else if (an > 1024)
- sprintf(s, "%sM", digits((float)n/(1024.0)));
- else
- sprintf(s, "%dK", n);
-
- return(s);
-}
-
-mach_port_t get_host_priv()
-{
- return(mach_host_self());
-}
-
-mach_port_t get_host_port()
-{
- return(mach_host_self());
-}
-
-void
-shared_hash_enter(int obj_id, int share_type, int resident_page_count, int ref_count, int size, int pid)
-{
- register struct object_info **bucket;
- register struct object_info *of;
-
- of = shared_hash_table[OT_HASH(obj_id/OBJECT_TABLE_SIZE)];
- while (of) {
- if (of->id == obj_id) {
- of->size += size;
- of->task_ref_count++;
- of->pid = pid;
- return;
- }
- of = of->next;
- }
- bucket = &shared_hash_table[OT_HASH(obj_id/OBJECT_TABLE_SIZE)];
-
- if (of = of_free_list)
- of_free_list = of->next;
- else
- of = (struct object_info *) malloc(sizeof(*of));
-
- of->resident_page_count = resident_page_count;
- of->id = obj_id;
- of->share_type = share_type;
- of->ref_count = ref_count;
- of->task_ref_count = 1;
- of->pid = pid;
- of->size = size;
-
- of->next = *bucket;
- *bucket = of;
-}
-
-void
-pmem_doit(task_port_t task, int pid, int *shared, int *private, int *aliased, int *obj_count, int *vprivate, vm_size_t *vsize, unsigned long long *fw_private)
-{
- vm_address_t address = 0;
- kern_return_t err = 0;
- register int i;
- int split = 0;
-
- *obj_count = *aliased = *shared = *private = *vprivate = 0;
-
- while (1) {
- mach_port_t object_name;
- vm_region_top_info_data_t info;
- mach_msg_type_number_t count;
- vm_size_t size;
-
- count = VM_REGION_TOP_INFO_COUNT;
-
- if (err = vm_region(task, &address, &size, VM_REGION_TOP_INFO, (vm_region_info_t)&info,
- &count, &object_name))
- break;
-
- if (address >= GLOBAL_SHARED_TEXT_SEGMENT && address < (GLOBAL_SHARED_DATA_SEGMENT + SHARED_DATA_REGION_SIZE)) {
-
- *fw_private += info.private_pages_resident * vm_page_size;
-
- if ( !split && info.share_mode == SM_EMPTY) {
- vm_region_basic_info_data_64_t b_info;
-
- count = VM_REGION_BASIC_INFO_COUNT_64;
- if (err = vm_region_64(task, &address, &size, VM_REGION_BASIC_INFO, (vm_region_info_t)&b_info,
- &count, &object_name))
- break;
-
- if (b_info.reserved)
- split = 1;
- }
- if (info.share_mode != SM_PRIVATE) {
- address += size;
- continue;
- }
- }
- address += size;
-
- *obj_count += 1;
-
- switch (info.share_mode) {
-
- case SM_PRIVATE:
- *private += info.private_pages_resident * vm_page_size;
- *vprivate += size;
- break;
-
- case SM_COW:
- if (info.ref_count == 1)
- info.share_mode = SM_PRIVATE;
- if (pid && info.share_mode == SM_COW)
- shared_hash_enter(info.obj_id, SM_COW, info.shared_pages_resident,
- info.ref_count, size, pid);
- if (info.share_mode == SM_PRIVATE)
- *private += info.shared_pages_resident * vm_page_size;
- *private += info.private_pages_resident * vm_page_size;
-
- if (info.share_mode == SM_PRIVATE)
- *vprivate += size;
- else
- *vprivate += info.private_pages_resident * vm_page_size;
- break;
-
- case SM_SHARED:
- if (pid)
- shared_hash_enter(info.obj_id, SM_SHARED, info.shared_pages_resident,
- info.ref_count, size, pid);
- break;
- }
- }
- for (i = 0; i < OBJECT_TABLE_SIZE; i++) {
- register struct object_info *sl;
-
- sl = shared_hash_table[i];
-
- while (sl) {
- if (sl->pid == pid) {
- if (sl->share_type == SM_SHARED) {
- if (sl->ref_count == sl->task_ref_count) {
- sl->share_type = SM_PRIVATE_ALIASED;
-
- *aliased += sl->resident_page_count * vm_page_size;
- *vprivate += sl->size;
- }
- }
- if (sl->share_type != SM_PRIVATE_ALIASED)
- *shared += sl->resident_page_count * vm_page_size;
- }
- sl->task_ref_count = 0;
-
- sl = sl->next;
- }
- }
- if (split)
- *vsize -= (SHARED_TEXT_REGION_SIZE + SHARED_DATA_REGION_SIZE);
-}
-
-
-void
-pmem_fw_resident(unsigned int *num_fw, unsigned long long *vsize, unsigned int *code_size, unsigned int *data_size, unsigned int *linkedit_size)
-{ vm_address_t address = GLOBAL_SHARED_TEXT_SEGMENT;
- kern_return_t err = 0;
- int state = 0;
-
- *vsize = 0;
- *num_fw = 0;
- *code_size = 0;
- *data_size = 0;
- *linkedit_size = 0;
-
- while (address < (GLOBAL_SHARED_DATA_SEGMENT + SHARED_DATA_REGION_SIZE)) {
- vm_region_submap_info_data_64_t s_info;
- mach_msg_type_number_t count;
- vm_size_t size;
- int nesting_depth;
-
- nesting_depth = 1;
- count = VM_REGION_SUBMAP_INFO_COUNT_64;
-
- if (err = vm_region_recurse_64(mach_task_self(), &address, &size, &nesting_depth, (vm_region_info_t)&s_info, &count))
- break;
-
- if (address >= (GLOBAL_SHARED_DATA_SEGMENT + SHARED_DATA_REGION_SIZE))
- break;
- if (address < GLOBAL_SHARED_DATA_SEGMENT) {
-
- if (s_info.share_mode == SM_SHARED || s_info.share_mode == SM_COW) {
- if (s_info.max_protection & VM_PROT_EXECUTE) {
- *code_size += (s_info.pages_resident * vm_page_size);
-
- if (state == 0)
- *num_fw += 1;
- state = 1;
-
- } else {
- *linkedit_size += (s_info.pages_resident * vm_page_size);
-
- state = 0;
- }
- }
-
- } else {
- if (s_info.share_mode == SM_SHARED || s_info.share_mode == SM_COW || s_info.share_mode == SM_TRUESHARED)
- *data_size += (s_info.pages_resident * vm_page_size);
- }
- *vsize += size;
-
- address += size;
- }
-}
-
-
-
-
-void
-pmem_shared_resident(unsigned long long *total, int *number)
-{ register int i;
- register int total_size;
- register int total_num;
- register struct object_info *sl, *next;
-
- total_size = total_num = 0;
-
- for (i = 0; i < OBJECT_TABLE_SIZE; i++) {
- sl = shared_hash_table[i];
- shared_hash_table[i] = 0;
-
- while (sl) {
- if (sl->share_type != SM_PRIVATE_ALIASED) {
- total_size += sl->resident_page_count;
- total_num++;
- }
- next = sl->next;
-
- sl->next = of_free_list;
- of_free_list = sl;
-
- sl = next;
- }
- }
- *number = total_num;
- *total = total_size * vm_page_size;
-}
-
-
-int
-get_real_command_name(int pid, char *cbuf, int csize)
-{
- /*
- * Get command and arguments.
- */
- volatile int *ip, *savedip;
- volatile char *cp;
- char c;
- char *end_argc;
- int mib[4];
- char *arguments;
- int arguments_size = 4096;
- volatile unsigned int *valuep;
- unsigned int value;
- int blahlen=0, skiplen=0;
-
- /*
- * A sysctl() is made to find out the full path that the command
- * was called with.
- */
- mib[0] = CTL_KERN;
- mib[1] = KERN_PROCARGS;
- mib[2] = pid;
- mib[3] = 0;
-
- arguments = (char *) malloc(arguments_size);
- if (sysctl(mib, 3, arguments, (size_t *)&arguments_size, NULL, 0) < 0) {
- free(arguments);
- return(0);
- }
- end_argc = &arguments[arguments_size];
-
- ip = (int *)end_argc;
- ip -= 2; /* last arg word and .long 0 */
- while (*--ip) {
- if (ip == (int *)arguments) {
- free(arguments);
- return(0);
- }
- }
- savedip = ip;
- savedip++;
- cp = (char *)savedip;
- while (*--ip) {
- if (ip == (int *)arguments) {
- free(arguments);
- return(0);
- }
- }
- ip++;
- valuep = (unsigned int *)ip;
- value = *valuep;
-
- if ((value & 0xbfff0000) == 0xbfff0000) {
- ip++; ip++;
- valuep = ip;
- blahlen = strlen((char *)ip);
- skiplen = (blahlen +3 ) /4 ;
- valuep += skiplen;
- cp = (char *)valuep;
- while (!*cp)
- cp++;
- savedip = (int *)cp;
- }
- for (cp = (char *)savedip; cp < (end_argc-1); cp++) {
- c = *cp & 0177;
-
- if (c == 0)
- break;
- }
- *cp = 0;
-
- if (cp > (char *)savedip)
- cp--;
-
- while (cp > (char *)savedip) {
- if (*cp == '/') {
- cp++;
- break;
- }
- cp--;
- }
- if (cp[0] == '-' || cp[0] == '?' || cp[0] <= ' ') {
- /*
- * Not enough information
- */
- free(arguments);
- return(0);
- }
- (void) strncpy(cbuf, (char *)cp, csize);
- cbuf[csize] = '\0';
-
- free(arguments);
- return(1);
-}
-
-
-/* All of this should come out of the process manager... */
-
-void get_proc_info(kpb, pi)
- struct kinfo_proc *kpb;
- struct proc_info *pi;
-{
- task_port_t task;
- mach_port_array_t names, types;
- unsigned int ncnt, tcnt;
-
- pi->uid = kpb->kp_eproc.e_ucred.cr_uid;
- pi->pid = kpb->kp_proc.p_pid;
- pi->ppid = kpb->kp_eproc.e_ppid;
- pi->pgrp = kpb->kp_eproc.e_pgid;
- pi->status = kpb->kp_proc.p_stat;
- pi->flag = kpb->kp_proc.p_flag;
-
- /*
- * Find the other stuff
- */
- if (task_for_pid(mach_task_self(), pi->pid, &task) != KERN_SUCCESS) {
- pi->status = SZOMB;
- }
-
- else {
- task_basic_info_data_t ti;
- unsigned int count;
- unsigned int aliased;
- thread_array_t thread_table;
- unsigned int table_size;
- thread_basic_info_t thi;
- thread_basic_info_data_t thi_data;
- int i, t_state;
-
- count = TASK_BASIC_INFO_COUNT;
- if (task_info(task, TASK_BASIC_INFO, (task_info_t)&ti,
- &count) != KERN_SUCCESS) {
- pi->status = SZOMB;
- } else {
- pi->virtual_size = ti.virtual_size;
-
- pi->resident_size = ti.resident_size;
-
- if ((pi->pid || do_proc0_vm) && (!events_only)) {
- pmem_doit(task, pi->pid, &pi->shared, &pi->private, &aliased, &pi->obj_count, &pi->vprivate, &pi->virtual_size, &total_fw_private);
- pi->private += aliased;
- } else {
- pi->shared = 0;
- pi->private = 0;
- pi->vprivate = 0;
- pi->obj_count = 0;
- }
- pi->orig_virtual_size = pi->virtual_size;
- pi->total_time = ti.user_time;
- time_value_add(&pi->total_time, &ti.system_time);
-
- pi->idle_time.seconds = 0;
- pi->idle_time.microseconds = 0;
-
- if (task_threads(task, &thread_table, &table_size) != KERN_SUCCESS)
- pi->status = SZOMB;
- else {
- pi->state = STATE_MAX;
- pi->pri = 255;
- pi->base_pri = 255;
- pi->all_swapped = TRUE;
- pi->has_idle_thread = FALSE;
-
- thi = &thi_data;
-
- pi->num_threads = table_size;
- total_threads += table_size;
-
- for (i = 0; i < table_size; i++) {
- count = THREAD_BASIC_INFO_COUNT;
- if (thread_info(thread_table[i], THREAD_BASIC_INFO,
- (thread_info_t)thi, &count) == KERN_SUCCESS) {
-
- if (thi->flags & TH_FLAGS_IDLE) {
- pi->has_idle_thread = TRUE;
-
- time_value_add(&pi->idle_time,
- &thi->user_time);
- time_value_add(&pi->idle_time,
- &thi->system_time);
- } else {
- time_value_add(&pi->total_time,
- &thi->user_time);
- time_value_add(&pi->total_time,
- &thi->system_time);
- }
- t_state = mach_state_order(thi->run_state,
- thi->sleep_time);
- if (t_state < pi->state)
- pi->state = t_state;
-// update priority info based on schedule policy
-// if (thi->cur_priority < pi->pri)
-// pi->pri = thi->cur_priority;
-// if (thi->base_priority < pi->base_pri)
-// pi->base_pri = thi->base_priority;
- if ((thi->flags & TH_FLAGS_SWAPPED) == 0)
- pi->all_swapped = FALSE;
-
- }
- if (task != mach_task_self()) {
- mach_port_deallocate(mach_task_self(),
- thread_table[i]);
- }
- }
- (void) vm_deallocate(mach_task_self(), (vm_offset_t)thread_table,
- table_size * sizeof(*thread_table));
-
- if (!events_only) {
- if (mach_port_names(task, &names, &ncnt,
- &types, &tcnt) == KERN_SUCCESS) {
- pi->num_ports = ncnt;
- pi->orig_num_ports = ncnt;
- (void) vm_deallocate(mach_task_self(),
- (vm_offset_t) names,
- ncnt * sizeof(*names));
- (void) vm_deallocate(mach_task_self(),
- (vm_offset_t) types,
- tcnt * sizeof(*types));
- } else {
- pi->num_ports = -1;
- }
- } else
- pi->num_ports = 0;
-
- if (events_only) {
- task_events_info_data_t tei;
-
- count = TASK_EVENTS_INFO_COUNT;
- if (task_info(task, TASK_EVENTS_INFO, (task_info_t)&tei,
- &count) != KERN_SUCCESS) {
- pi->status = SZOMB;
- } else {
- pi->tei = tei;
-
- }
- }
- }
- }
- if (task != mach_task_self()) {
- mach_port_deallocate(mach_task_self(), task);
- }
- }
- if ( strncmp (kpb->kp_proc.p_comm, "LaunchCFMA", 10) ||
- !get_real_command_name(pi->pid, pi->command, sizeof(kpb->kp_proc.p_comm)-1)) {
- (void) strncpy(pi->command, kpb->kp_proc.p_comm,
- sizeof(kpb->kp_proc.p_comm)-1);
- pi->command[sizeof(kpb->kp_proc.p_comm)-1] = '\0';
- }
-}
-
-
-/*
- * signal handlers
- */
-
-void leave() /* exit under normal conditions -- INT handler */
-{
- if (!oneshot) {
- move(LINES - 1, 0);
- refresh();
- endwin();
- }
- exit(0);
-}
-
-void quit(status) /* exit under duress */
- int status;
-{
- if (!oneshot)
- endwin();
- exit(status);
-}
-
-void sigwinch()
-{
- newLINES = 1;
-}
-
-
-/*
- * comparison function for "qsort"
- * Do first order sort based on cpu percentage computed by kernel and
- * second order sort based on total time for the process.
- */
-
-int proc_compar(p1, p2)
- register struct proc_info **p1;
- register struct proc_info **p2;
-{
- if (sort_by_usage) {
- if ((*p1)->cpu_usage < (*p2)->cpu_usage)
- return(1);
- else if ((*p1)->cpu_usage > (*p2)->cpu_usage)
- return(-1);
- else {
- if ((*p1)->total_time.seconds < (*p2)->total_time.seconds)
- return(1);
- else
- return(-1);
- }
- }
- else {
- if ((*p1)->pid < (*p2)->pid)
- return(1);
- else
- return(-1);
- }
-}
-
-
-int nproc, total_procs, old_procs;
-struct kinfo_proc *kbase, *kpb;
-struct proc_info *proc, *pp, *oldproc;
-struct proc_info **pref, **prefp;
-
-int topn = 0;
-int wanted_topn = 0;
-vm_size_t pagesize;
-
-
-
-void grab_task(task)
- task_t task;
-{
- int pid;
- size_t size;
- kern_return_t ret;
- struct kinfo_proc ki;
- int mib[4];
-
- ret = pid_for_task(task, &pid);
- if (ret != KERN_SUCCESS)
- return;
- size = sizeof(ki);
- mib[0] = CTL_KERN;
- mib[1] = KERN_PROC;
- mib[2] = KERN_PROC_PID;
- mib[3] = pid;
-
- if (sysctl(mib, 4, &ki, &size, NULL, 0) < 0) {
- perror("failure calling sysctl");
- exit(1);
- }
- if (ki.kp_proc.p_stat == 0) {
- state_breakdown[0]++;
- return;
- }
- if (total_procs == nproc) {
- nproc *= 2;
- kbase = (struct kinfo_proc *) realloc(kbase,
- nproc*sizeof(struct kinfo_proc));
- bzero(&kbase[total_procs], total_procs*sizeof(struct kinfo_proc));
- proc = (struct proc_info *) realloc(proc,
- nproc*sizeof(struct proc_info));
- bzero(&proc[total_procs], total_procs*sizeof(struct proc_info));
- oldproc = (struct proc_info *) realloc(oldproc,
- nproc*sizeof(struct proc_info));
- bzero(&oldproc[total_procs], total_procs*sizeof(struct proc_info));
- pref = (struct proc_info **) realloc(pref,
- nproc*sizeof(struct proc_info *));
- bzero(&pref[total_procs], total_procs*sizeof(struct proc_info *));
- }
- kbase[total_procs] = ki;
- total_procs++;
-}
-
-void update_histdata()
-{
- struct proc_info *pp, *oldp;
- int i, j, pid;
- time_value_t elapsed_time;
-
- i = 0;
- pp = proc;
-
- // XXX use linear search since list is usually small
-
- while (i < total_procs) {
- j = 0;
- oldp = oldproc;
- pid = pp->pid;
-
- while (j < old_procs) {
- if (oldp->pid == pid) {
- pp->drprvt = pp->private - oldp->private;
- pp->drshrd = pp->shared - oldp->shared;
- pp->drsize = pp->resident_size - oldp->resident_size;
- pp->dvsize = pp->virtual_size - oldp->virtual_size;
-
- pp->rvsize = pp->virtual_size - oldp->orig_virtual_size;
- pp->orig_virtual_size = oldp->orig_virtual_size;
-
- pp->dnum_ports = pp->num_ports - oldp->orig_num_ports;
- pp->orig_num_ports = oldp->orig_num_ports;
-
- if (pp->has_idle_thread == TRUE) {
- if (events_accumulate) {
- time_value_sub(&pp->idle_time, &oldp->beg_idle_time, &elapsed_time);
- pp->beg_idle_time = oldp->beg_idle_time;
- pp->idle_time = elapsed_time;
- } else
- time_value_sub(&pp->idle_time, &oldp->idle_time, &elapsed_time);
-
- pp->cpu_idle = (elapsed_time.seconds * 1000) + (elapsed_time.microseconds / 1000);
- }
- if (events_accumulate) {
- time_value_sub(&pp->total_time, &oldp->beg_total_time, &elapsed_time);
- pp->beg_total_time = oldp->beg_total_time;
- pp->total_time = elapsed_time;
- } else
- time_value_sub(&pp->total_time, &oldp->total_time, &elapsed_time);
-
- pp->cpu_usage = (elapsed_time.seconds * 1000) + (elapsed_time.microseconds / 1000);
-
- if (events_delta)
- {
- pp->deltatei.pageins = pp->tei.pageins - oldp->tei.pageins;
- pp->deltatei.faults = pp->tei.faults - oldp->tei.faults;
- pp->deltatei.cow_faults = pp->tei.cow_faults - oldp->tei.cow_faults;
- pp->deltatei.messages_sent = pp->tei.messages_sent - oldp->tei.messages_sent;
- pp->deltatei.messages_received = pp->tei.messages_received - oldp->tei.messages_received;
- pp->deltatei.syscalls_unix = pp->tei.syscalls_unix - oldp->tei.syscalls_unix;
- pp->deltatei.syscalls_mach = pp->tei.syscalls_mach - oldp->tei.syscalls_mach;
- pp->deltatei.csw = pp->tei.csw - oldp->tei.csw;
- }
- if (events_accumulate)
- {
- pp->deltatei.pageins = pp->tei.pageins - oldp->accumtei.pageins;
- pp->deltatei.faults = pp->tei.faults - oldp->accumtei.faults;
- pp->deltatei.cow_faults = pp->tei.cow_faults - oldp->accumtei.cow_faults;
- pp->deltatei.messages_sent = pp->tei.messages_sent - oldp->accumtei.messages_sent;
- pp->deltatei.messages_received = pp->tei.messages_received - oldp->accumtei.messages_received;
- pp->deltatei.syscalls_unix = pp->tei.syscalls_unix - oldp->accumtei.syscalls_unix;
- pp->deltatei.syscalls_mach = pp->tei.syscalls_mach - oldp->accumtei.syscalls_mach;
- pp->deltatei.csw = pp->tei.csw - oldp->accumtei.csw;
-
- pp->accumtei = oldp->accumtei;
- }
- break;
- }
- j++;
- oldp++;
- }
- if (j >= old_procs) {
- if (events_accumulate) {
- pp->accumtei = pp->tei;
- pp->beg_total_time = pp->total_time;
- pp->beg_idle_time = pp->idle_time;
-
- pp->idle_time.seconds = 0;
- pp->idle_time.microseconds = 0;
- pp->total_time.seconds = 0;
- pp->total_time.microseconds = 0;
- }
- bzero(&pp->deltatei, sizeof (task_events_info_data_t));
-
- pp->drprvt = 0;
- pp->drshrd = 0;
- pp->drsize = 0;
- pp->dvsize = 0;
- pp->rvsize = 0;
- pp->dnum_ports = 0;
- pp->cpu_usage = 0;
- pp->cpu_idle = 0;
- }
- i++;
- pp++;
- }
- bcopy(proc, oldproc, total_procs*sizeof(struct proc_info));
- old_procs = total_procs;
-}
-
-void read_proc_table()
-{
- mach_port_t host;
- processor_set_t *psets;
- task_t *tasks;
- unsigned int pcount, tcount;
- kern_return_t ret;
- processor_set_t p;
- int i, j;
-
- total_procs = 0;
- total_threads = 0;
-
- host = host_priv_port;
-
- if (host == MACH_PORT_NULL) {
- printf("Insufficient privileges.\n");
- exit(0);
- }
- ret = host_processor_sets(host, &psets, &pcount);
- if (ret != KERN_SUCCESS) {
- mach_error("host_processor_sets", ret);
- exit(0);
- }
- for (i = 0; i < pcount; i++) {
- ret = host_processor_set_priv(host, psets[i], &p);
- if (ret != KERN_SUCCESS) {
- mach_error("host_processor_set_priv", ret);
- exit(0);
- }
-
- ret = processor_set_tasks(p, &tasks, &tcount);
- if (ret != KERN_SUCCESS) {
- mach_error("processor_set_tasks", ret);
- exit(0);
- }
- for (j = 0; j < tcount; j++) {
- grab_task(tasks[j]);
- // don't delete our own task port
- if (tasks[j] != mach_task_self())
- mach_port_deallocate(mach_task_self(),
- tasks[j]);
- }
- vm_deallocate(mach_task_self(), (vm_address_t)tasks,
- tcount * sizeof(task_t));
- mach_port_deallocate(mach_task_self(), p);
- mach_port_deallocate(mach_task_self(), psets[i]);
- }
- vm_deallocate(mach_task_self(), (vm_address_t)psets,
- pcount * sizeof(processor_set_t));
-}
-
-kern_return_t getCPU(cpucounters)
- host_cpu_load_info_t cpucounters;
-{
- mach_msg_type_number_t count;
- kern_return_t kr;
-
- count = HOST_CPU_LOAD_INFO_COUNT;
- kr = host_statistics (host_priv_port, HOST_CPU_LOAD_INFO,
- (host_info_t)cpucounters, &count);
-
- return(kr);
-}
-
-updateCPU()
-{
-
- if (events_accumulate) {
- userticks = curcounters.cpu_ticks[CPU_STATE_USER]-
- startcounters.cpu_ticks[CPU_STATE_USER];
-
- systicks = curcounters.cpu_ticks[CPU_STATE_SYSTEM]-
- startcounters.cpu_ticks[CPU_STATE_SYSTEM];
-
- idleticks = curcounters.cpu_ticks[CPU_STATE_IDLE]-
- startcounters.cpu_ticks[CPU_STATE_IDLE];
- } else if (events_only && !events_delta) {
-
- userticks = curcounters.cpu_ticks[CPU_STATE_USER];
-
- systicks = curcounters.cpu_ticks[CPU_STATE_SYSTEM];
-
- idleticks = curcounters.cpu_ticks[CPU_STATE_IDLE];
- } else {
- userticks = curcounters.cpu_ticks[CPU_STATE_USER]-
- lastcounters.cpu_ticks[CPU_STATE_USER];
-
- systicks = curcounters.cpu_ticks[CPU_STATE_SYSTEM]-
- lastcounters.cpu_ticks[CPU_STATE_SYSTEM];
-
- idleticks = curcounters.cpu_ticks[CPU_STATE_IDLE]-
- lastcounters.cpu_ticks[CPU_STATE_IDLE];
-
- lastcounters = curcounters;
- }
- totalticks = userticks + systicks + idleticks;
-}
-
-
-
-main(argc, argv)
- int argc;
- char *argv[];
-{
- char *myname = "top";
- int ch;
- int delay = Default_DELAY;
- kern_return_t error;
-
- void screen_update();
-
- /* get our name */
- if (argc > 0) {
- if ((myname = rindex(argv[0], '/')) == 0) {
- myname = argv[0];
- }
- else {
- myname++;
- }
- }
-
- /* check for options */
- sort_by_usage = 0;
- wide_output = 0;
- do_proc0_vm = 0;
- events_only = 0;
- events_delta = 0;
- events_accumulate = 0;
-
- while ((ch = getopt(argc, argv, "uwks:edal:")) != EOF) {
- switch(ch) {
- case 's':
- delay = atoi(optarg);
- break;
- case 'u':
- sort_by_usage = 1;
- break;
- case 'w':
- wide_output = 1;
- break;
- case 'k':
- do_proc0_vm = 1;
- break;
- case 'e':
- events_only = 1;
- break;
- case 'd':
- events_only = 1;
- events_delta = 1;
- break;
- case 'a':
- events_only = 1;
- events_accumulate = 1;
- break;
- case 'l':
- logcnt = atoi(optarg);
- oneshot = 1;
- LINES = 80;
- COLS = 132;
- break;
- default:
- fprintf(stderr, "Usage: %s [-u] [-w] [-k] [-sn] [-e | -d | -a] [-ln] [number]\n", myname);
- fprintf(stderr, " -u enables sort by usage\n");
- fprintf(stderr, " -w enables wide output of additional info\n");
- fprintf(stderr, " -k generate vm info for kernel(proc 0)... expensive\n");
- fprintf(stderr, " -sn change sample rate to every n seconds\n");
- fprintf(stderr, " -e switch to events info counter mode\n");
- fprintf(stderr, " -d switch to events info counter delta mode\n");
- fprintf(stderr, " -a switch to events info counter accumulate mode\n");
- fprintf(stderr, " -ln log n samples\n");
- fprintf(stderr, " number limit number of processes monitored\n");
-
- exit(1);
- }
- }
-
- argc -= optind;
- //argv += optind;
-
- if (events_only)
- {
- if ( wide_output || do_proc0_vm)
- {
- fprintf(stderr, " The -w and -k flag have no effect in event mode.\n");
- wide_output = 0;
- do_proc0_vm = 0;
- }
- }
-
- host_priv_port = get_host_priv();
- host_port = get_host_port();
-
- /* get count of top processes to display (if any) */
- if (argc) {
- wanted_topn = topn = atoi(argv[optind]);
- } else
- wanted_topn = -1;
-
- /* allocate space for proc structure array and array of pointers */
- nproc = 50; /* starting point */
- kbase = (struct kinfo_proc *) malloc(nproc*sizeof(struct kinfo_proc));
- bzero(kbase, nproc*sizeof(struct kinfo_proc));
- proc = (struct proc_info *) malloc(nproc*sizeof(struct proc_info));
- bzero(proc, nproc*sizeof(struct proc_info));
- oldproc = (struct proc_info *) malloc(nproc*sizeof(struct proc_info));
- bzero(oldproc, nproc*sizeof(struct proc_info));
- pref = (struct proc_info **) malloc(nproc*sizeof(struct proc_info *));
- bzero(pref, nproc*sizeof(struct proc_info *));
-
- (void) host_page_size(host_port, &pagesize);
- /* initializes curses and screen (last) */
-
- if (!oneshot) {
- initscr();
- cbreak();
- timeout(delay * 1000);
- noecho();
- erase();
- clear();
- refresh();
- }
- /* set up signal handlers */
- signal(SIGINT, leave);
- signal(SIGQUIT, leave);
- signal(SIGWINCH, sigwinch);
-
- /* can only display (LINES - Header_lines) processes */
- if (topn > LINES - Header_lines) {
- if (!oneshot)
- printw("Warning: this terminal can only display %d processes...\n",
- LINES - Header_lines);
- else
- printf("Warning: this terminal can only display %d processes...\n",
- LINES - Header_lines);
-
- if (!oneshot)
- refresh();
- sleep(2);
- topn = LINES - Header_lines;
- if (!oneshot)
- clear();
- }
- if (topn == 0) { // use default
- // leave one blank line at bottom
-
- topn = LINES - Header_lines - 1;
- }
-
- /* prime the pump for gathering networking stats */
- kread(0, 0, 0);
-
- /**************************************************/
- /* get ports and services for drive stats */
- /* Obtain the I/O Kit communication handle */
-
- error = IOMasterPort(bootstrap_port, &masterPort);
-
- /* Obtain the list of all drive objects */
-
- error = IOServiceGetMatchingServices(masterPort,
- IOServiceMatching("IOBlockStorageDriver"),
- &drivelist);
- getCPU(&lastcounters);
- startcounters = lastcounters;
-
- gettimeofday(&cur_tod, NULL);
- start_tod = cur_tod;
- elapsed_milliseconds = -1;
-
- /* main loop */
-
- while (1) {
- int n;
-
- if (newLINES) {
- newLINES = 0;
-
- if (!oneshot) {
- struct winsize size;
-
- if (ioctl(1, TIOCGWINSZ, &size) != -1) {
- resizeterm(size.ws_row, size.ws_col);
- erase();
- clear();
- }
- }
- n = LINES - Header_lines;
-
- if (topn >= n)
- topn = n;
- else {
- if (wanted_topn == -1)
- topn = n;
- else if (topn < wanted_topn) {
- if (wanted_topn < n)
- topn = wanted_topn;
- else
- topn = n;
- }
- }
- }
- (void)screen_update();
-
- if (!oneshot) {
- int c;
-
- if ((c = getch()) != ERR && (char)c == 'q')
- leave();
- } else
- sleep(delay);
- }
-}
-
-void screen_update()
-{
- char c;
- int i, n, mpid;
- int active_procs;
- int avenrun[3];
- long curr_time;
- long elapsed_secs;
- unsigned long long total_fw_vsize;
- unsigned long long total_virtual_size;
- unsigned long long total_private_size;
- unsigned long long total_shared_size;
- unsigned int total_memory_regions = 0;
- unsigned int total_shared_objects;
- unsigned int total_fw_code_size;
- unsigned int total_fw_data_size;
- unsigned int total_fw_linkedit_size;
- unsigned int total_frameworks;
- vm_statistics_data_t vm_stat;
- struct host_load_info load_data;
- int host_count;
- kern_return_t error;
- char tbuf[256];
- char *dp;
- int clen;
-
- bzero((char *)state_breakdown, sizeof(state_breakdown));
-
- if (!oneshot) {
- /* clear for new display */
- erase();
- }
- /* read all of the process information */
- read_proc_table();
-
- /* get the load averages */
- host_count = sizeof(load_data)/sizeof(integer_t);
- error = host_statistics(host_priv_port, HOST_LOAD_INFO,
- (host_info_t)&load_data, &host_count);
- if (error != KERN_SUCCESS) {
- mach_error("host_statistics", error);
- exit(EXIT_FAILURE);
- }
-
- avenrun[0] = load_data.avenrun[0];
- avenrun[1] = load_data.avenrun[1];
- avenrun[2] = load_data.avenrun[2];
-
- /* get total - systemwide main memory usage structure */
- host_count = sizeof(vm_stat)/sizeof(integer_t);
- error = host_statistics(host_priv_port, HOST_VM_INFO,
- (host_info_t)&vm_stat, &host_count);
- if (error != KERN_SUCCESS) {
- mach_error("host_info", error);
- exit(EXIT_FAILURE);
- }
-
- if (events_only) {
- getNETWORKcounters();
- getDISKcounters();
- }
- /* count up process states and get pointers to interesting procs */
-
- mpid = 0;
- active_procs = 0;
- total_virtual_size = 0;
- total_private_size = 0;
- total_fw_private = 0;
-
- prefp = pref;
- for (kpb = kbase, pp = proc, i = 0;
- i < total_procs;
- kpb++, pp++, i++) {
-
- /* place pointers to each valid proc structure in pref[] */
- get_proc_info(kpb, pp);
-
- if (kpb->kp_proc.p_stat != 0) {
- *prefp++ = pp;
- active_procs++;
- if (pp->pid > mpid)
- mpid = pp->pid;
-
- if ((unsigned int)pp->state > (unsigned int)STATE_MAX)
- pp->state = STATE_MAX;
- state_breakdown[pp->state]++;
- total_virtual_size += pp->virtual_size;
- total_private_size += pp->private;
- total_memory_regions += pp->obj_count;
- }
- else
- state_breakdown[0]++;
- }
- /* get the cpu counters */
- getCPU(&curcounters);
- updateCPU();
-
- if (elapsed_milliseconds != -1) {
- last_tod = cur_tod;
- gettimeofday(&cur_tod, NULL);
-
- if (events_accumulate)
- timersub(&cur_tod, &start_tod, &elapsed_tod);
- else
- timersub(&cur_tod, &last_tod, &elapsed_tod);
-
- elapsed_milliseconds = (elapsed_tod.tv_sec * 1000) + (elapsed_tod.tv_usec / 1000);
- } else
- elapsed_milliseconds = 0;
-
- if (!events_only) {
- pmem_fw_resident(&total_frameworks, &total_fw_vsize, &total_fw_code_size, &total_fw_data_size, &total_fw_linkedit_size);
-
- pmem_shared_resident(&total_shared_size, &total_shared_objects);
- }
- if (!oneshot)
- move(0,0);
-
- /* display process state breakdown */
- sprintf(tbuf, "Processes: %d total", total_procs);
- clen = strlen(tbuf);
-
-
- for (i = 0; i <= STATE_MAX; i++) {
- if (state_breakdown[i] != 0) {
- sprintf(&tbuf[clen], ", %d %s%s",
- state_breakdown[i],
- state_name[i],
- (i == 0 && state_breakdown[0] > 1) ? "s" : ""
- );
-
- clen = clen + strlen(&tbuf[clen]);
- }
- }
- sprintf(&tbuf[clen], "... %d threads", total_threads);
-
- clen = clen + strlen(&tbuf[clen]);
- /*
- * Display the current time.
- * "ctime" always returns a string that looks like this:
- *
- * Sun Sep 16 01:03:52 1973
- * 012345678901234567890123
- * 1 2
- *
- * We want indices 11 thru 18 (length 8).
- */
- curr_time = time((long *)0);
-
- if (start_time == 0)
- start_time = curr_time;
-
- memset(&tbuf[clen], ' ', 111 - clen);
-
- if (wide_output)
- clen = 118 - 8;
- else if (events_accumulate)
- clen = 103 - 8;
- else if (events_only && !events_delta)
- clen = 115 - 8;
- else
- clen = 79 - 8;
-
- sprintf(&tbuf[clen], "%-8.8s", &(ctime(&curr_time)[11]));
- clen = clen + strlen(&tbuf[clen]);
-
- if (events_accumulate) {
- int hours;
- int minutes;
-
- elapsed_secs = curr_time - start_time;
- minutes = elapsed_secs / 60;
- hours = minutes / 60;
-
- sprintf(&tbuf[clen], " %3ld:%02ld:%02ld\n", hours, minutes % 60, elapsed_secs % 60);
- } else {
- sprintf(&tbuf[clen], "\n");
- }
-
- if (tbuf[COLS-2] != '\n') {
- tbuf[COLS-1] = '\n';
- tbuf[COLS] = 0;
- }
- if (!oneshot)
- printw(tbuf);
- else
- printf(tbuf);
-
- /* display the load averages */
- sprintf(tbuf, "Load Avg");
- clen = strlen(tbuf);
-
- for (i = 0; i < 3; i++) {
- sprintf(&tbuf[clen], "%s %4.2f", i == 0 ? ": " : ",",
- (double)avenrun[i] / LOAD_SCALE);
- clen = clen + strlen(&tbuf[clen]);
- }
- if (totalticks) {
- sprintf(&tbuf[clen], " CPU usage: %.1f%%%% user, %.1f%%%% sys, %.1f%%%% idle\n",
- (100*userticks)/totalticks, (100*systicks)/totalticks, (100*idleticks)/totalticks);
- clen = clen + strlen(&tbuf[clen]);
- }
- if (tbuf[COLS-2] != '\n') {
- tbuf[COLS-1] = '\n';
- tbuf[COLS] = 0;
- }
- if (!oneshot)
- printw(tbuf);
- else
- printf(tbuf);
-
- if (!events_only) {
- sprintf(tbuf, "SharedLibs: num = %4d, ", total_frameworks);
- clen = strlen(tbuf);
- sprintf(&tbuf[clen], "resident = %s code, ", mem_to_string((unsigned long long)total_fw_code_size));
- clen = clen + strlen(&tbuf[clen]);
- sprintf(&tbuf[clen], "%s data, ", mem_to_string((unsigned long long)total_fw_data_size));
- clen = clen + strlen(&tbuf[clen]);
- sprintf(&tbuf[clen], "%s LinkEdit\n", mem_to_string((unsigned long long)total_fw_linkedit_size));
-
- if (tbuf[COLS-2] != '\n') {
- tbuf[COLS-1] = '\n';
- tbuf[COLS] = 0;
- }
- if (!oneshot)
- printw(tbuf);
- else
- printf(tbuf);
-
- sprintf(tbuf, "MemRegions: num = %4d, ", total_memory_regions);
- clen = strlen(tbuf);
- sprintf(&tbuf[clen], "resident = %s + ", mem_to_string(total_private_size - total_fw_private));
- clen = clen + strlen(&tbuf[clen]);
- sprintf(&tbuf[clen], "%s private, ", mem_to_string(total_fw_private));
- clen = clen + strlen(&tbuf[clen]);
- sprintf(&tbuf[clen], "%s shared\n", mem_to_string(total_shared_size));
-
- if (tbuf[COLS-2] != '\n') {
- tbuf[COLS-1] = '\n';
- tbuf[COLS] = 0;
- }
- if (!oneshot)
- printw(tbuf);
- else
- printf(tbuf);
-
- /* display main memory statistics */
- {
- unsigned long long total_resident_size,
- active_resident_size,
- inactive_resident_size,
- wire_resident_size,
- free_size;
-
- active_resident_size = (unsigned long long) vm_stat.active_count * (unsigned long long) pagesize;
- inactive_resident_size = (unsigned long long) vm_stat.inactive_count * (unsigned long long) pagesize;
- wire_resident_size = (unsigned long long) vm_stat.wire_count * (unsigned long long) pagesize;
- total_resident_size = (unsigned long long) (vm_stat.active_count + vm_stat.inactive_count + vm_stat.wire_count) * (unsigned long long) pagesize;
- free_size = (unsigned long long) vm_stat.free_count * (unsigned long long) pagesize;
-
- sprintf(tbuf, "PhysMem: ");
- clen = strlen(tbuf);
- sprintf(&tbuf[clen], "%s wired, ", mem_to_string(wire_resident_size));
- clen = clen + strlen(&tbuf[clen]);
- sprintf(&tbuf[clen], "%s active, ", mem_to_string(active_resident_size));
- clen = clen + strlen(&tbuf[clen]);
- sprintf(&tbuf[clen], "%s inactive, ", mem_to_string(inactive_resident_size));
- clen = clen + strlen(&tbuf[clen]);
- sprintf(&tbuf[clen], "%s used, ", mem_to_string(total_resident_size));
- clen = clen + strlen(&tbuf[clen]);
- sprintf(&tbuf[clen], "%s free\n", mem_to_string(free_size));
-
- if (tbuf[COLS-2] != '\n') {
- tbuf[COLS-1] = '\n';
- tbuf[COLS] = 0;
- }
- if (!oneshot)
- printw(tbuf);
- else
- printf(tbuf);
- }
- } else {
- int i_io, o_io, i_kbytes, o_kbytes;
-
- i_io = o_io = i_kbytes = o_kbytes = 0;
-
- if (events_delta) {
- if (i_net.io_prev || o_net.io_prev) {
- i_io = i_net.io - i_net.io_prev;
- o_io = o_net.io - o_net.io_prev;
- i_kbytes = i_net.kbytes - i_net.kbytes_prev;
- o_kbytes = o_net.kbytes - o_net.kbytes_prev;
- }
- } else if (events_accumulate) {
- if (i_net.io_prev || o_net.io_prev) {
- i_net.io_accum += i_net.io - i_net.io_prev;
- o_net.io_accum += o_net.io - o_net.io_prev;
- i_net.kbytes_accum += i_net.kbytes - i_net.kbytes_prev;
- o_net.kbytes_accum += o_net.kbytes - o_net.kbytes_prev;
-
- i_io = i_net.io_accum;
- o_io = o_net.io_accum;
- i_kbytes = i_net.kbytes_accum;
- o_kbytes = o_net.kbytes_accum;
- }
- } else {
- i_io = i_net.io;
- o_io = o_net.io;
- i_kbytes = i_net.kbytes;
- o_kbytes = o_net.kbytes;
- }
- sprintf(tbuf, "Networks:%10d ipkts/%dK", i_io, i_kbytes);
- clen = strlen(tbuf);
- memset(&tbuf[clen], ' ', 36 - clen);
- sprintf(&tbuf[36], "%10d opkts /%dK\n", o_io, o_kbytes);
-
- i_net.io_prev = i_net.io;
- o_net.io_prev = o_net.io;
- i_net.kbytes_prev = i_net.kbytes;
- o_net.kbytes_prev = o_net.kbytes;
-
- if (tbuf[COLS-2] != '\n') {
- tbuf[COLS-1] = '\n';
- tbuf[COLS] = 0;
- }
- if (!oneshot)
- printw(tbuf);
- else
- printf(tbuf);
-
- i_io = o_io = i_kbytes = o_kbytes = 0;
-
- if (events_delta) {
- if (i_dsk.io_prev || o_dsk.io_prev) {
- i_io = i_dsk.io - i_dsk.io_prev;
- o_io = o_dsk.io - o_dsk.io_prev;
- i_kbytes = i_dsk.kbytes - i_dsk.kbytes_prev;
- o_kbytes = o_dsk.kbytes - o_dsk.kbytes_prev;
- }
- } else if (events_accumulate) {
- if (i_dsk.io_prev || o_dsk.io_prev) {
- i_dsk.io_accum += i_dsk.io - i_dsk.io_prev;
- o_dsk.io_accum += o_dsk.io - o_dsk.io_prev;
- i_dsk.kbytes_accum += i_dsk.kbytes - i_dsk.kbytes_prev;
- o_dsk.kbytes_accum += o_dsk.kbytes - o_dsk.kbytes_prev;
-
- i_io = i_dsk.io_accum;
- o_io = o_dsk.io_accum;
- i_kbytes = i_dsk.kbytes_accum;
- o_kbytes = o_dsk.kbytes_accum;
- }
- } else {
- i_io = i_dsk.io;
- o_io = o_dsk.io;
- i_kbytes = i_dsk.kbytes;
- o_kbytes = o_dsk.kbytes;
- }
- sprintf(tbuf, "Disks: %10d reads/%dK", i_io, i_kbytes);
- clen = strlen(tbuf);
- memset(&tbuf[clen], ' ', 36 - clen);
- sprintf(&tbuf[36], "%10d writes/%dK\n", o_io, o_kbytes);
-
- i_dsk.io_prev = i_dsk.io;
- o_dsk.io_prev = o_dsk.io;
- i_dsk.kbytes_prev = i_dsk.kbytes;
- o_dsk.kbytes_prev = o_dsk.kbytes;
-
- if (tbuf[COLS-2] != '\n') {
- tbuf[COLS-1] = '\n';
- tbuf[COLS] = 0;
- }
- if (!oneshot)
- printw(tbuf);
- else
- printf(tbuf);
- }
-
- /* display paging statistics */
- if (events_only) {
- int pageins, pageouts;
-
- pageins = pageouts = 0;
-
- if (events_delta) {
- if (i_vm.io_prev || o_vm.io_prev) {
- pageins = vm_stat.pageins - i_vm.io_prev;
- pageouts = vm_stat.pageouts - o_vm.io_prev;
- }
- } else if (events_accumulate) {
- if (i_vm.io_prev || o_vm.io_prev) {
- i_vm.io_accum += vm_stat.pageins - i_vm.io_prev;
- o_vm.io_accum += vm_stat.pageouts - o_vm.io_prev;
-
- pageins = i_vm.io_accum;
- pageouts = o_vm.io_accum;
- }
- } else {
- pageins = vm_stat.pageins;
- pageouts = vm_stat.pageouts;
- }
- sprintf(tbuf, "VM: %10d pageins", pageins);
- clen = strlen(tbuf);
- memset(&tbuf[clen], ' ', 36 - clen);
- sprintf(&tbuf[36], "%10d pageouts\n", pageouts);
- } else {
- sprintf(tbuf, "VM: %5.5s + ", mem_to_string(total_virtual_size));
- clen = strlen(tbuf);
- sprintf(&tbuf[clen], "%5.5s ", mem_to_string(total_fw_vsize));
- clen = clen + strlen(&tbuf[clen]);
- sprintf(&tbuf[clen], "%d(%d) pageins, ", vm_stat.pageins, vm_stat.pageins - (int)i_vm.io_prev);
- clen = clen + strlen(&tbuf[clen]);
- sprintf(&tbuf[clen], "%d(%d) pageouts\n", vm_stat.pageouts, vm_stat.pageouts - (int)o_vm.io_prev);
- }
- if (tbuf[COLS-2] != '\n') {
- tbuf[COLS-1] = '\n';
- tbuf[COLS] = 0;
- }
- if (!oneshot)
- printw(tbuf);
- else
- printf(tbuf);
-
- i_vm.io_prev = vm_stat.pageins;
- o_vm.io_prev = vm_stat.pageouts;
-
-
- /* display the processes */
- if (topn > 0) {
- if (events_delta)
- sprintf(tbuf, "\n PID COMMAND %%%%CPU TIME FAULTS PGINS/COWS MSENT/MRCVD BSD/MACH CSW\n");
- else if (events_only)
- sprintf(tbuf, "\n PID COMMAND %%%%CPU TIME FAULTS PAGEINS COW_FAULTS MSGS_SENT MSGS_RCVD BSDSYSCALL MACHSYSCALL CSWITCH\n");
- else if (wide_output)
- sprintf(tbuf, "\n PID COMMAND %%%%CPU TIME #TH #PRTS(delta) #MREGS VPRVT RPRVT(delta) RSHRD(delta) RSIZE(delta) VSIZE(delta)\n");
- else
- sprintf(tbuf, "\n PID COMMAND %%%%CPU TIME #TH #PRTS #MREGS RPRVT RSHRD RSIZE VSIZE\n");
-
-
- if (tbuf[COLS] != '\n') {
- tbuf[COLS+1] = '\n';
- tbuf[COLS+2] = 0;
- }
- if (!oneshot)
- printw(tbuf);
- else
- printf(tbuf);
-
- update_histdata();
-
- /* sort */
- qsort((char *)pref,
- active_procs,
- sizeof(struct proc_info *),
- proc_compar);
-
- /* now, show the top whatever */
- if (active_procs > topn)
- {
- /* adjust for too many processes */
- active_procs = topn;
- }
-
- for (prefp = pref, i = 0; i < active_procs; prefp++, i++)
- {
- pp = *prefp;
-
- sprintf(tbuf, "%5d", pp->pid); /* pid */
- clen = strlen(tbuf);
- sprintf(&tbuf[clen], " %-10.10s ", pp->command); /* command */
- clen = clen + strlen(&tbuf[clen]);
-
- print_usage(&tbuf[clen], pp->cpu_usage);
- clen = clen + strlen(&tbuf[clen]);
-
- sprintf(&tbuf[clen], " ");
- clen++;
-
- print_time(&tbuf[clen], pp->total_time); /* cputime */
- clen = clen + strlen(&tbuf[clen]);
-
-
- if (events_only) {
- if (events_delta) {
- sprintf(&tbuf[clen], " %6d", pp->deltatei.faults);
- clen = clen + strlen(&tbuf[clen]);
- sprintf(&tbuf[clen], " %5d", pp->deltatei.pageins);
- clen = clen + strlen(&tbuf[clen]);
- sprintf(&tbuf[clen], "/%-4d", pp->deltatei.cow_faults);
- clen = clen + strlen(&tbuf[clen]);
- sprintf(&tbuf[clen], " %5d", pp->deltatei.messages_sent);
- clen = clen + strlen(&tbuf[clen]);
- sprintf(&tbuf[clen], "/%-4d", pp->deltatei.messages_received);
- clen = clen + strlen(&tbuf[clen]);
- sprintf(&tbuf[clen], " %5d", pp->deltatei.syscalls_unix);
- clen = clen + strlen(&tbuf[clen]);
- sprintf(&tbuf[clen], "/%-5d", pp->deltatei.syscalls_mach);
- clen = clen + strlen(&tbuf[clen]);
- sprintf(&tbuf[clen], "%6d", pp->deltatei.csw);
- clen = clen + strlen(&tbuf[clen]);
- } else if (events_accumulate) {
- sprintf(&tbuf[clen], " %-8d", pp->deltatei.faults);
- clen = clen + strlen(&tbuf[clen]);
- sprintf(&tbuf[clen], " %-8d", pp->deltatei.pageins);
- clen = clen + strlen(&tbuf[clen]);
- sprintf(&tbuf[clen], " %-10d", pp->deltatei.cow_faults);
- clen = clen + strlen(&tbuf[clen]);
- sprintf(&tbuf[clen], " %-10d", pp->deltatei.messages_sent);
- clen = clen + strlen(&tbuf[clen]);
- sprintf(&tbuf[clen], " %-10d", pp->deltatei.messages_received);
- clen = clen + strlen(&tbuf[clen]);
- sprintf(&tbuf[clen], " %-10d", pp->deltatei.syscalls_unix);
- clen = clen + strlen(&tbuf[clen]);
- sprintf(&tbuf[clen], " %-11d", pp->deltatei.syscalls_mach);
- clen = clen + strlen(&tbuf[clen]);
- sprintf(&tbuf[clen], " %-8d", pp->deltatei.csw);
- clen = clen + strlen(&tbuf[clen]);
- } else {
- sprintf(&tbuf[clen], " %-8d", pp->tei.faults);
- clen = clen + strlen(&tbuf[clen]);
- sprintf(&tbuf[clen], " %-8d", pp->tei.pageins);
- clen = clen + strlen(&tbuf[clen]);
- sprintf(&tbuf[clen], " %-10d", pp->tei.cow_faults);
- clen = clen + strlen(&tbuf[clen]);
- sprintf(&tbuf[clen], " %-10d", pp->tei.messages_sent);
- clen = clen + strlen(&tbuf[clen]);
- sprintf(&tbuf[clen], " %-10d", pp->tei.messages_received);
- clen = clen + strlen(&tbuf[clen]);
- sprintf(&tbuf[clen], " %-10d", pp->tei.syscalls_unix);
- clen = clen + strlen(&tbuf[clen]);
- sprintf(&tbuf[clen], " %-11d", pp->tei.syscalls_mach);
- clen = clen + strlen(&tbuf[clen]);
- sprintf(&tbuf[clen], " %-8d", pp->tei.csw);
- clen = clen + strlen(&tbuf[clen]);
- }
- } else {
-
- sprintf(&tbuf[clen], " %3d", pp->num_threads); /* # of threads */
- clen = clen + strlen(&tbuf[clen]);
- sprintf(&tbuf[clen], " %5d", pp->num_ports); /* # of ports */
- clen = clen + strlen(&tbuf[clen]);
-
- if (wide_output) {
- if (pp->dnum_ports)
- sprintf(&tbuf[clen], "(%5d)", pp->dnum_ports);
- else
- sprintf(&tbuf[clen], " ");
- clen = clen + strlen(&tbuf[clen]);
- }
- if (pp->pid || do_proc0_vm)
- sprintf(&tbuf[clen], " %4d", pp->obj_count);
- else
- sprintf(&tbuf[clen], " -");
- clen = clen + strlen(&tbuf[clen]);
-
- if (wide_output) {
- if (pp->pid || do_proc0_vm) {
- sprintf(&tbuf[clen], " %5.5s", mem_to_string((unsigned long long)pp->vprivate)); /* res size */
- clen = clen + strlen(&tbuf[clen]);
- sprintf(&tbuf[clen], " %5.5s", mem_to_string((unsigned long long)pp->private)); /* res size */
- clen = clen + strlen(&tbuf[clen]);
-
- if (pp->drprvt)
- sprintf(&tbuf[clen], "(%5.5s)", offset_to_string(pp->drprvt));
- else
- sprintf(&tbuf[clen], " ");
- } else
- sprintf(&tbuf[clen], " - - ");
- } else {
- if (pp->drprvt == 0)
- dp = " ";
- else if ((int)pp->drprvt > 0)
- dp = "+";
- else
- dp = "-";
-
- if (pp->pid || do_proc0_vm)
- sprintf(&tbuf[clen], " %5.5s%s", mem_to_string((unsigned long long)pp->private), dp); /* res size */
- else
- sprintf(&tbuf[clen], " -");
- }
- clen = clen + strlen(&tbuf[clen]);
-
- if (wide_output) {
- if (pp->pid || do_proc0_vm) {
- sprintf(&tbuf[clen], " %5.5s", mem_to_string((unsigned long long)pp->shared));
- clen = clen + strlen(&tbuf[clen]);
-
- if (pp->drshrd)
- sprintf(&tbuf[clen], "(%5.5s)", offset_to_string(pp->drshrd));
- else
- sprintf(&tbuf[clen], " ");
- } else
- sprintf(&tbuf[clen], " - ");
- } else {
- if (pp->drshrd == 0)
- dp = " ";
- else if ((int)pp->drshrd > 0)
- dp = "+";
- else
- dp = "-";
-
- if (pp->pid || do_proc0_vm)
- sprintf(&tbuf[clen], " %5.5s%s", mem_to_string((unsigned long long)pp->shared), dp);
- else
- sprintf(&tbuf[clen], " - ");
- }
- clen = clen + strlen(&tbuf[clen]);
-
- if (wide_output) {
- sprintf(&tbuf[clen], " %5.5s", mem_to_string((unsigned long long)pp->resident_size)); /* res size */
- clen = clen + strlen(&tbuf[clen]);
-
- if (pp->drsize)
- sprintf(&tbuf[clen], "(%5.5s)", offset_to_string(pp->drsize));
- else
- sprintf(&tbuf[clen], " ");
- } else {
- if (pp->drsize == 0)
- dp = " ";
- else if ((int)pp->drsize > 0)
- dp = "+";
- else
- dp = "-";
-
- sprintf(&tbuf[clen], " %5.5s%s", mem_to_string((unsigned long long)pp->resident_size), dp); /* res size */
- }
- clen = clen + strlen(&tbuf[clen]);
-
- if (wide_output) {
- sprintf(&tbuf[clen], " %5.5s", mem_to_string((unsigned long long)pp->virtual_size)); /* size */
- clen = clen + strlen(&tbuf[clen]);
-
- if (pp->rvsize)
- sprintf(&tbuf[clen], "(%5.5s)", offset_to_string(pp->rvsize));
- else
- sprintf(&tbuf[clen], " ");
- } else {
- if (pp->dvsize == 0)
- dp = " ";
- else if ((int)pp->dvsize > 0)
- dp = "+";
- else
- dp = "-";
-
- sprintf(&tbuf[clen], " %5.5s%s", mem_to_string((unsigned long long)pp->virtual_size), dp); /* size */
- }
- clen = clen + strlen(&tbuf[clen]);
-
- } /* else not events only */
-
- sprintf(&tbuf[clen], "\n");
-
- if (tbuf[COLS-1] != '\n') {
- tbuf[COLS] = '\n';
- tbuf[COLS+1] = 0;
- }
- if (!oneshot)
- printw(tbuf);
- else
- printf(tbuf);
- }
-
- for (n = 0, prefp = pref; n < total_procs && i < topn; prefp++, n++)
- {
- pp = *prefp;
-
- if (pp->has_idle_thread == TRUE) {
- sprintf(tbuf, "%5d", pp->pid);
- clen = strlen(tbuf);
- sprintf(&tbuf[clen], " %-10.10s ", "idle_thread");
- clen = clen + strlen(&tbuf[clen]);
-
- print_usage(&tbuf[clen], pp->cpu_idle);
- clen = clen + strlen(&tbuf[clen]);
- sprintf(&tbuf[clen], " ");
- clen++;
- print_time(&tbuf[clen], pp->idle_time);
- clen = clen + strlen(&tbuf[clen]);
- sprintf(&tbuf[clen], "\n");
-
- if (tbuf[COLS-1] != '\n') {
- tbuf[COLS] = '\n';
- tbuf[COLS+1] = 0;
- }
- if (!oneshot)
- printw(tbuf);
- else
- printf(tbuf);
- i++;
- }
- }
- }
- if (oneshot) {
- printf("\n");
-
- if (--logcnt <= 0)
- leave();
- } else
- refresh();
-}
-
-
-void
-update_eventsdata()
-{
- /* unimplemented */
-}
-
-
-static struct nlist nl_net[] = {
-#define N_IFNET 0
- { "_ifnet" },
- { "" },
-};
-
-
-
-/*
- * Read kernel memory, return 0 on success.
- */
-int
-kread(addr, buf, size)
- u_long addr;
- char *buf;
- int size;
-{
- static kvm_t *kvmd = 0;
-
- if (kvmd == 0) {
- /*
- * XXX.
- */
- kvmd = kvm_openfiles(NULL, NULL, NULL, O_RDONLY, buf);
- if (kvmd != NULL) {
- if (kvm_nlist(kvmd, nl_net) < 0)
- errx(1, "kvm_nlist: %s", kvm_geterr(kvmd));
-
- if (nl_net[0].n_type == 0)
- errx(1, "no namelist");
- } else {
- return(-1);
- }
- }
- if (!buf)
- return (0);
- if (kvm_read(kvmd, addr, buf, size) != size) {
- warnx("%s", kvm_geterr(kvmd));
- return (-1);
- }
- return (0);
-}
-
-
-getNETWORKcounters()
-{
- struct ifnet ifnet;
- struct ifnethead ifnethead;
- u_long off;
-
- if (nl_net[N_IFNET].n_value == 0)
- return;
- if (kread(nl_net[N_IFNET].n_value, (char *)&ifnethead, sizeof ifnethead))
- return;
-
- i_net.io = 0;
- o_net.io = 0;
-
- i_net.kbytes = 0;
- o_net.kbytes = 0;
-
- for (off = (u_long)ifnethead.tqh_first; off; ) {
- char tname[16];
-
- if (kread(off, (char *)&ifnet, sizeof ifnet))
- break;
- if (kread((u_long)ifnet.if_name, tname, 16))
- break;
-
- if (strncmp(tname, "lo", 2)) {
- i_net.io += ifnet.if_ipackets;
- o_net.io += ifnet.if_opackets;
-
- i_net.kbytes += ifnet.if_ibytes/1024;
- o_net.kbytes += ifnet.if_obytes/1024;
- }
- off = (u_long) ifnet.if_link.tqe_next;
- }
- return;
-}
-
-
-getDISKcounters()
-{
- io_registry_entry_t drive = 0; /* needs release */
- UInt64 totalReadBytes = 0;
- UInt64 totalReadCount = 0;
- UInt64 totalWriteBytes = 0;
- UInt64 totalWriteCount = 0;
-
- kern_return_t status = 0;
-
- while ( (drive = IOIteratorNext(drivelist)) )
- {
- CFNumberRef number = 0; /* don't release */
- CFDictionaryRef properties = 0; /* needs release */
- CFDictionaryRef statistics = 0; /* don't release */
- UInt64 value = 0;
-
- /* Obtain the properties for this drive object */
-
- status = IORegistryEntryCreateCFProperties (drive,
- (CFMutableDictionaryRef *) &properties,
- kCFAllocatorDefault,
- kNilOptions);
- if (properties) {
-
- /* Obtain the statistics from the drive properties */
- statistics = (CFDictionaryRef) CFDictionaryGetValue(properties, CFSTR(kIOBlockStorageDriverStatisticsKey));
-
- if (statistics) {
- /* Obtain the number of bytes read from the drive statistics */
- number = (CFNumberRef) CFDictionaryGetValue (statistics,
- CFSTR(kIOBlockStorageDriverStatisticsBytesReadKey));
- if (number) {
- status = CFNumberGetValue(number, kCFNumberSInt64Type, &value);
- totalReadBytes += value;
- }
- /* Obtain the number of reads from the drive statistics */
- number = (CFNumberRef) CFDictionaryGetValue (statistics,
- CFSTR(kIOBlockStorageDriverStatisticsReadsKey));
- if (number) {
- status = CFNumberGetValue(number, kCFNumberSInt64Type, &value);
- totalReadCount += value;
- }
-
- /* Obtain the number of writes from the drive statistics */
- number = (CFNumberRef) CFDictionaryGetValue (statistics,
- CFSTR(kIOBlockStorageDriverStatisticsWritesKey));
- if (number) {
- status = CFNumberGetValue(number, kCFNumberSInt64Type, &value);
- totalWriteCount += value;
- }
- /* Obtain the number of bytes written from the drive statistics */
- number = (CFNumberRef) CFDictionaryGetValue (statistics,
- CFSTR(kIOBlockStorageDriverStatisticsBytesWrittenKey));
- if (number) {
- status = CFNumberGetValue(number, kCFNumberSInt64Type, &value);
- totalWriteBytes += value;
- }
- }
- /* Release resources */
-
- CFRelease(properties); properties = 0;
- }
- IOObjectRelease(drive); drive = 0;
- }
- IOIteratorReset(drivelist);
-
- i_dsk.io = (int)totalReadCount;
- o_dsk.io = (int)totalWriteCount;
- i_dsk.kbytes = (int)(totalReadBytes / 1024);
- o_dsk.kbytes = (int)(totalWriteBytes / 1024);
-}
projects / apple / system_cmds.git / commitdiff
