path: root/m_freebsd.c

/*
 * Copyright (c) 1984 through 2008, William LeFebvre
 * All rights reserved.
 * 
 * Redistribution and use in source and binary forms, with or without
 * modification, are permitted provided that the following conditions are met:
 * 
 *     * Redistributions of source code must retain the above copyright
 * notice, this list of conditions and the following disclaimer.
 * 
 *     * Redistributions in binary form must reproduce the above
 * copyright notice, this list of conditions and the following disclaimer
 * in the documentation and/or other materials provided with the
 * distribution.
 * 
 *     * Neither the name of William LeFebvre nor the names of other
 * contributors may be used to endorse or promote products derived from
 * this software without specific prior written permission.
 * 
 * THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS
 * "AS IS" AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT
 * LIMITED TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR
 * A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT
 * OWNER OR CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL,
 * SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT
 * LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE,
 * DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY
 * THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT
 * (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE
 * OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
 */

/*
 * top - a top users display for Unix
 *
 * SYNOPSIS:  For FreeBSD 5.x, 6.x, 7.x, 8.x
 *
 * DESCRIPTION:
 * Originally written for BSD4.4 system by Christos Zoulas.
 * Ported to FreeBSD 2.x by Steven Wallace && Wolfram Schneider
 * Order support hacked in from top-3.5beta6/machine/m_aix41.c
 *   by Monte Mitzelfelt
 * Ported to FreeBSD 5.x and higher by William LeFebvre
 *
 * AUTHOR:  Christos Zoulas <christos@ee.cornell.edu>
 *          Steven Wallace  <swallace@freebsd.org>
 *          Wolfram Schneider <wosch@FreeBSD.org>
 */


#include <sys/time.h>
#include <sys/types.h>
#include <sys/signal.h>
#include <sys/param.h>

#include "config.h"
#include <stdio.h>
#include <string.h>
#include <nlist.h>
#include <math.h>
#include <kvm.h>
#include <pwd.h>
#include <sys/errno.h>
#include <sys/sysctl.h>
#include <sys/dkstat.h>
#include <sys/file.h>
#include <sys/time.h>
#include <sys/proc.h>
#include <sys/user.h>
#include <sys/vmmeter.h>
#include <sys/resource.h>
#include <sys/rtprio.h>
#ifdef HAVE_UNISTD_H
#include <unistd.h>
#endif

/* Swap */
#include <stdlib.h>
#include <sys/conf.h>

#include <osreldate.h> /* for changes in kernel structures */

#include "top.h"
#include "machine.h"
#include "utils.h"
#include "username.h"
#include "hash.h"
#include "display.h"

extern char* printable __P((char *));
int swapmode __P((int *retavail, int *retfree));
static int smpmode;
static int namelength;

/*
 * Versions prior to 5.x do not track threads in kinfo_proc, so we
 * simply do not display any information about them.
 * Versions 5.x, 6.x, and 7.x track threads but the data reported
 * as runtime for each thread is actually per-process and is just
 * duplicated across all threads.  It would be very wrong to show
 * this data individually for each thread.  Therefore we will show
 * a THR column (number of threads) but not provide any sort of
 * per-thread display.  We distinguish between these three ways of
 * handling threads as follows:  HAS_THREADS indicates that the
 * system has and tracks kernel threads (a THR column will appear
 * in the display).  HAS_SHOWTHREADS indicates that the system 
 * reports correct per-thread information and we will provide a
 * per-thread display (the 'H' and 't' command) upon request.
 * HAS_SHOWTHREADS implies HAS_THREADS.
 */

/* HAS_THREADS for anything 5.x and up */
#if OSMAJOR >= 5
#define HAS_THREADS
#endif

/* HAS_SHOWTHREADS for anything 8.x and up */
#if OSMAJOR >=8
#define HAS_SHOWTHREADS
#endif

/* get_process_info passes back a handle.  This is what it looks like: */

struct handle
{
    struct kinfo_proc **next_proc;	/* points to next valid proc pointer */
    int remaining;		/* number of pointers remaining */
};

/* declarations for load_avg */
#include "loadavg.h"

/*
 * Macros to access process information:
 * In versions 4.x and earlier the kinfo_proc structure was a collection of
 * substructures (kp_proc and kp_eproc).  Starting with 5.0 kinfo_proc was
 * redesigned and "flattene" so that most of the information was available
 * in a single structure.  We use macros to access the various types of
 * information and define these macros according to the OS revision.  The
 * names PP, EP, and VP are due to the fact that information was originally
 * contained in the different substructures.  We retain these names in the
 * code for backward compatibility.  These macros use ANSI concatenation.
 * PP: proc
 * EP: extented proc
 * VP: vm (virtual memory information)
 * PRUID: Real uid
 * RP: rusage
 * PPCPU: where we store calculated cpu% data
 * SPPTR: where we store pointer to extra calculated data
 * SP: access to the extra calculated data pointed to by SPPTR
 */
#if OSMAJOR <= 4
#define PP(pp, field) ((pp)->kp_proc . p_##field)
#define EP(pp, field) ((pp)->kp_eproc . e_##field)
#define VP(pp, field) ((pp)->kp_eproc.e_vm . vm_##field)
#define PRUID(pp) ((pp)->kp_eproc.e_pcred.p_ruid)
#else
#define PP(pp, field) ((pp)->ki_##field)
#define EP(pp, field) ((pp)->ki_##field)
#define VP(pp, field) ((pp)->ki_##field)
#define PRUID(pp) ((pp)->ki_ruid)
#define RP(pp, field) ((pp)->ki_rusage.ru_##field)
#define PPCPU(pp) ((pp)->ki_sparelongs[0])
#define SPPTR(pp) ((pp)->ki_spareptrs[0])
#define SP(pp, field) (((struct save_proc *)((pp)->ki_spareptrs[0]))->sp_##field)
#endif

/* what we consider to be process size: */
#if OSMAJOR <= 4
#define PROCSIZE(pp) (VP((pp), map.size) / 1024)
#else
#define PROCSIZE(pp) (((pp)->ki_size) / 1024)
#endif

/* calculate a per-second rate using milliseconds */
#define per_second(n, msec)   (((n) * 1000) / (msec))

/* process state names for the "STATE" column of the display */
/* the extra nulls in the string "run" are for adding a slash and
   the processor number when needed */

char *state_abbrev[] =
{
    "?", "START", "RUN", "SLEEP", "STOP", "ZOMB", "WAIT", "LOCK"
};
#define NUM_STATES 8

/* kernel access */
static kvm_t *kd;

/* these are for dealing with sysctl-based data */
#define MAXMIBLEN 8
struct sysctl_mib {
    char *name;
    int mib[MAXMIBLEN];
    size_t miblen;
};
static struct sysctl_mib mibs[] = {
    { "vm.stats.sys.v_swtch" },
#define V_SWTCH 0
    { "vm.stats.sys.v_trap" },
#define V_TRAP 1
    { "vm.stats.sys.v_intr" },
#define V_INTR 2
    { "vm.stats.sys.v_soft" },
#define V_SOFT 3
    { "vm.stats.vm.v_forks" },
#define V_FORKS 4
    { "vm.stats.vm.v_vforks" },
#define V_VFORKS 5
    { "vm.stats.vm.v_rforks" },
#define V_RFORKS 6
    { "vm.stats.vm.v_vm_faults" },
#define V_VM_FAULTS 7
    { "vm.stats.vm.v_swapin" },
#define V_SWAPIN 8
    { "vm.stats.vm.v_swapout" },
#define V_SWAPOUT 9
    { "vm.stats.vm.v_tfree" },
#define V_TFREE 10
    { "vm.stats.vm.v_vnodein" },
#define V_VNODEIN 11
    { "vm.stats.vm.v_vnodeout" },
#define V_VNODEOUT 12
    { "vm.stats.vm.v_active_count" },
#define V_ACTIVE_COUNT 13
    { "vm.stats.vm.v_inactive_count" },
#define V_INACTIVE_COUNT 14
    { "vm.stats.vm.v_wire_count" },
#define V_WIRE_COUNT 15
    { "vm.stats.vm.v_cache_count" },
#define V_CACHE_COUNT 16
    { "vm.stats.vm.v_free_count" },
#define V_FREE_COUNT 17
    { "vm.stats.vm.v_swappgsin" },
#define V_SWAPPGSIN 18
    { "vm.stats.vm.v_swappgsout" },
#define V_SWAPPGSOUT 19
    { "vfs.bufspace" },
#define VFS_BUFSPACE 20
    { "kern.cp_time" },
#define K_CP_TIME 21
#ifdef HAS_SHOWTHREADS
    { "kern.proc.all" },
#else
    { "kern.proc.proc" },
#endif
#define K_PROC 22
    { NULL }
};
    

/* these are for calculating cpu state percentages */

static long cp_time[CPUSTATES];
static long cp_old[CPUSTATES];
static long cp_diff[CPUSTATES];

/* these are for detailing the process states */

int process_states[8];
char *procstatenames[] = {
    "", " starting, ", " running, ", " sleeping, ", " stopped, ", " zombie, ",
    " waiting, ", " locked, ",
    NULL
};

/* these are for detailing the cpu states */

int cpu_states[CPUSTATES];
char *cpustatenames[] = {
    "user", "nice", "system", "interrupt", "idle", NULL
};

/* these are for detailing the kernel information */

int kernel_stats[9];
char *kernelnames[] = {
    " ctxsw, ", " trap, ", " intr, ", " soft, ", " fork, ",
    " flt, ", " pgin, ", " pgout, ", " fr",
    NULL
};

/* these are for detailing the memory statistics */

long memory_stats[7];
char *memorynames[] = {
    "K Active, ", "K Inact, ", "K Wired, ", "K Cache, ", "K Buf, ", "K Free",
    NULL
};

long swap_stats[7];
char *swapnames[] = {
/*   0           1            2           3            4       5 */
    "K Total, ", "K Used, ", "K Free, ", "% Inuse, ", "K In, ", "K Out",
    NULL
};


/*
 * pbase points to the array that holds the kinfo_proc structures.  pref
 * (pronounced p-ref) points to an array of kinfo_proc pointers and is where
 * we build up a list of processes we wish to display.  Both pbase and pref are
 * potentially resized on every call to get_process_info.  psize is the number
 * of procs for which we currently have space allocated.  pref_len is the number
 * of valid pointers in pref (this is used by proc_owner).  We start psize off
 * at -1 to ensure that space gets allocated on the first call to
 * get_process_info.
 */

static int psize = -1;
static int pref_len;
static struct kinfo_proc *pbase = NULL;
static struct kinfo_proc **pref = NULL;

/* this structure retains information from the proc array between samples */
struct save_proc {
    pid_t sp_pid;
    u_int64_t sp_runtime;
    long sp_vcsw;
    long sp_ivcsw;
    long sp_inblock;
    long sp_oublock;
    long sp_majflt;
    long sp_totalio;
    long sp_old_nvcsw;
    long sp_old_nivcsw;
    long sp_old_inblock;
    long sp_old_oublock;
    long sp_old_majflt;
};
hash_table *procs;

struct proc_field {
    char *name;
    int width;
    int rjust;
    int min_screenwidth;
    int (*format)(char *, int, struct kinfo_proc *);
};

/* these are for getting the memory statistics */

static int pagesize;		/* kept from getpagesize */
static int pageshift;		/* log base 2 of the pagesize */

/* define pagetok in terms of pageshift */

#define pagetok(size) ((size) << pageshift)

/* things that we track between updates */
static u_int ctxsws = 0;
static u_int traps = 0;
static u_int intrs = 0;
static u_int softs = 0;
static u_int64_t forks = 0;
static u_int pfaults;
static u_int pagein;
static u_int pageout;
static u_int tfreed;
static int swappgsin = -1;
static int swappgsout = -1;
extern struct timeval timeout;
static struct timeval lasttime = { 0, 0 };
static long elapsed_time;
static long elapsed_msecs;

/* things that we track during an update */
static long total_io;
static int show_fullcmd;
static struct handle handle;
static int username_length;
static int show_usernames;
static int display_mode;
static int *display_fields;
#ifdef HAS_SHOWTHREADS
static int show_threads = 0;
#endif


/* sorting orders. first is default */
char *ordernames[] = {
    "cpu", "size", "res", "time", "pri", "io", "pid", NULL
};

/* compare routines */
int proc_compare(), compare_size(), compare_res(), compare_time(),
    compare_prio(), compare_io(), compare_pid();

int (*proc_compares[])() = {
    proc_compare,
    compare_size,
    compare_res,
    compare_time,
    compare_prio,
    compare_io,
    compare_pid,
    NULL
};

/* swap related calculations */

static int mib_swapinfo[16];
static int *mib_swapinfo_idx;
static int mib_swapinfo_size = 0;

void
swap_init()

{
    size_t m;

    m = sizeof(mib_swapinfo) / sizeof(mib_swapinfo[0]);
    if (sysctlnametomib("vm.swap_info", mib_swapinfo, &m) != -1)
    {
	mib_swapinfo_size = m + 1;
	mib_swapinfo_idx = &(mib_swapinfo[m]);
    }
}

int
swap_getdata(long long *retavail, long long *retfree)

{
    int n;
    size_t size;
    long long total = 0;
    long long used = 0;
    struct xswdev xsw;

    n = 0;
    if (mib_swapinfo_size > 0)
    {
	*mib_swapinfo_idx = 0;
	while (size = sizeof(xsw),
	       sysctl(mib_swapinfo, mib_swapinfo_size, &xsw, &size, NULL, 0) != -1)
	{
	    dprintf("swap_getdata: swaparea %d: nblks %d, used %d\n",
		    n, xsw.xsw_nblks, xsw.xsw_used);
	    total += (long long)xsw.xsw_nblks;
	    used += (long long)xsw.xsw_used;
	    *mib_swapinfo_idx = ++n;
	}

	*retavail = pagetok(total);
	*retfree = pagetok(total) - pagetok(used);

	if (total > 0)
	{
	    n = (int)((double)used * 100.0 / (double)total);
	}
	else
	{
	    n = 0;
	}
    }
    else
    {
	*retavail = 0;
	*retfree = 0;
    }

    dprintf("swap_getdata: avail %lld, free %lld, %d%%\n",
	    *retavail, *retfree, n);
    return(n);
}

/*
 *  getkval(offset, ptr, size) - get a value out of the kernel.
 *	"offset" is the byte offset into the kernel for the desired value,
 *  	"ptr" points to a buffer into which the value is retrieved,
 *  	"size" is the size of the buffer (and the object to retrieve).
 *      Return 0 on success, -1 on any kind of failure.
 */

static int
getkval(unsigned long offset, int *ptr, int size)

{
    if (kd != NULL)
    {
	if (kvm_read(kd, offset, (char *) ptr, size) == size)
	{
	    return(0);
	}
    }
    return(-1);
}

int
get_sysctl_mibs()

{
    struct sysctl_mib *mp;
    size_t len;

    mp = mibs;
    while (mp->name != NULL)
    {
	len = MAXMIBLEN;
	if (sysctlnametomib(mp->name, mp->mib, &len) == -1)
	{
	    message_error(" sysctlnametomib: %s", strerror(errno));
	    return -1;
	}
	mp->miblen = len;
	mp++;
    }
    return 0;
}

int
get_sysctl(int idx, void *v, size_t l)

{
    struct sysctl_mib *m;
    size_t len;

    m = &(mibs[idx]);
    len = l;
    if (sysctl(m->mib, m->miblen, v, &len, NULL, 0) == -1)
    {
	message_error(" sysctl: %s", strerror(errno));
	return -1;
    }
    return len;
}

size_t
get_sysctlsize(int idx)

{
    size_t len;
    struct sysctl_mib *m;

    m = &(mibs[idx]);
    if (sysctl(m->mib, m->miblen, NULL, &len, NULL, 0) == -1)
    {
	message_error(" sysctl (size): %s", strerror(errno));
	len = 0;
    }
    return len;
}
    
int
fmt_pid(char *buf, int sz, struct kinfo_proc *pp)

{
    return snprintf(buf, sz, "%6d", PP(pp, pid));
}

int
fmt_username(char *buf, int sz, struct kinfo_proc *pp)

{
    return snprintf(buf, sz, "%-*.*s",
		    username_length, username_length, username(PRUID(pp)));
}

int
fmt_uid(char *buf, int sz, struct kinfo_proc *pp)

{
    return snprintf(buf, sz, "%6d", PRUID(pp));
}

int
fmt_thr(char *buf, int sz, struct kinfo_proc *pp)

{
    return snprintf(buf, sz, "%3d", PP(pp, numthreads));
}

int
fmt_pri(char *buf, int sz, struct kinfo_proc *pp)

{
#if OSMAJOR <= 4
    return snprintf(buf, sz, "%3d", PP(pp, priority));
#else
    return snprintf(buf, sz, "%3d", PP(pp, pri.pri_level));
#endif
}

int
fmt_nice(char *buf, int sz, struct kinfo_proc *pp)

{
    return snprintf(buf, sz, "%4d", PP(pp, nice) - NZERO);
}

int
fmt_size(char *buf, int sz, struct kinfo_proc *pp)

{
    return snprintf(buf, sz, "%5s", format_k(PROCSIZE(pp)));
}

int
fmt_res(char *buf, int sz, struct kinfo_proc *pp)

{
    return snprintf(buf, sz, "%5s", format_k(pagetok(VP(pp, rssize))));
}

int
fmt_state(char *buf, int sz, struct kinfo_proc *pp)

{
    int state;
    char status[16];

    state = PP(pp, stat);
    switch(state)
    {
    case SRUN:
	if (smpmode && PP(pp, oncpu) != 0xff)
	    sprintf(status, "CPU%d", PP(pp, oncpu));
	else
	    strcpy(status, "RUN");
	break;

    case SSLEEP:
	if (EP(pp, wmesg) != NULL) {
	    sprintf(status, "%.6s", EP(pp, wmesg));
	    break;
	}
	/* fall through */
    default:
	if (state >= 0 && state < NUM_STATES)
	    sprintf(status, "%.6s", state_abbrev[(unsigned char) state]);
	else
	    sprintf(status, "?%-5d", state);
	break;
    }

    return snprintf(buf, sz, "%-6.6s", status);
}

int
fmt_flags(char *buf, int sz, struct kinfo_proc *pp)

{
    long flag;
    char chrs[12];
    char *p;

    flag = PP(pp, flag);
    p = chrs;
    if (PP(pp, nice) < NZERO)
	*p++ = '<';
    else if (PP(pp, nice) > NZERO)
	*p++ = 'N';
    if (flag & P_TRACED)
	*p++ = 'X';
    if (flag & P_WEXIT && PP(pp, stat) != SZOMB)
	*p++ = 'E';
    if (flag & P_PPWAIT)
	*p++ = 'V';
    if (flag & P_SYSTEM || PP(pp, lock) > 0)
	*p++ = 'L';
    if (PP(pp, kiflag) & KI_SLEADER)
	*p++ = 's';
    if (flag & P_CONTROLT)
	*p++ = '+';
    if (flag & P_JAILED)
	*p++ = 'J';
    *p = '\0';

    return snprintf(buf, sz, "%-3.3s", chrs);
}

int
fmt_c(char *buf, int sz, struct kinfo_proc *pp)

{
    return snprintf(buf, sz, "%1x", PP(pp, lastcpu));
}

int
fmt_time(char *buf, int sz, struct kinfo_proc *pp)

{
    return snprintf(buf, sz, "%6s",
		    format_time((PP(pp, runtime) + 500000) / 1000000));
}

int
fmt_cpu(char *buf, int sz, struct kinfo_proc *pp)

{
    return snprintf(buf, sz, "%5.2f%%", (double)PPCPU(pp) / 100.0);
}

int
fmt_command(char *buf, int sz, struct kinfo_proc *pp)

{
    int inmem;
    char cmd[MAX_COLS];
    char *bufp;
    struct pargs pargs;
    int len;

#if OSMAJOR <= 4
    inmem = (PP(pp, flag) & P_INMEM);
#else
    inmem = (PP(pp, sflag) & PS_INMEM);
#endif

    if (show_fullcmd && inmem)
    {
        /* get the pargs structure */
        if (getkval((unsigned long)PP(pp, args), (int *)&pargs, sizeof(pargs)) != -1)
        {
            /* determine workable length */
            if ((len = pargs.ar_length) >= MAX_COLS)
            {
                len = MAX_COLS - 1;
            }

            /* get the string from that */
            if (len > 0 && getkval((unsigned long)PP(pp, args) +
				   sizeof(pargs.ar_ref) +
				   sizeof(pargs.ar_length),
				   (int *)cmd, len) != -1)
            {
                /* successfull retrieval: now convert nulls in to spaces */
                bufp = cmd;
                while (len-- > 0)
                {
                    if (*bufp == '\0')
                    {
                        *bufp = ' ';
                    }
                    bufp++;
                }

                /* null terminate cmd */
                *--bufp = '\0';

		/* format cmd as our answer */
		return snprintf(buf, sz, "%s", cmd);
            }
        }
    }

    /* for anything else we just display comm */
    return snprintf(buf, sz, inmem ? "%s" : "<%s>", printable(PP(pp, comm)));
}

int
fmt_vcsw(char *buf, int sz, struct kinfo_proc *pp)

{
    return snprintf(buf, sz, "%6ld", per_second(SP(pp, vcsw), elapsed_msecs));
}

int
fmt_ivcsw(char *buf, int sz, struct kinfo_proc *pp)

{
    return snprintf(buf, sz, "%6ld", per_second(SP(pp, ivcsw), elapsed_msecs));
}

int
fmt_read(char *buf, int sz, struct kinfo_proc *pp)

{
    return snprintf(buf, sz, "%6ld", per_second(SP(pp, inblock), elapsed_msecs));
}

int
fmt_write(char *buf, int sz, struct kinfo_proc *pp)

{
    return snprintf(buf, sz, "%6ld", per_second(SP(pp, oublock), elapsed_msecs));
}

int
fmt_fault(char *buf, int sz, struct kinfo_proc *pp)

{
    return snprintf(buf, sz, "%6ld", per_second(SP(pp, majflt), elapsed_msecs));
}

int
fmt_iototal(char *buf, int sz, struct kinfo_proc *pp)

{
    return snprintf(buf, sz, "%6ld", per_second(SP(pp, totalio), elapsed_msecs));
}

int
fmt_iopct(char *buf, int sz, struct kinfo_proc *pp)

{
    return snprintf(buf, sz, "%6.2f", (SP(pp, totalio) * 100.) / total_io);
}


struct proc_field proc_field[] = {
    { "PID", 6, 1, 0, fmt_pid },
    { "USERNAME", 8, 0, 0, fmt_username },
#define FIELD_USERNAME 1
    { "UID", 6, 1, 0, fmt_uid },
#define FIELD_UID 2
    { "THR", 3, 1, 0, fmt_thr },
    { "PRI", 3, 1, 0, fmt_pri },
    { "NICE", 4, 1, 0, fmt_nice },
    { "SIZE", 5, 1, 0, fmt_size },
    { "RES", 5, 1, 0, fmt_res },
    { "STATE", 6, 0, 0, fmt_state },
    { "FLG", 3, 0, 84, fmt_flags },
    { "C", 1, 0, 0, fmt_c },
    { "TIME", 6, 1, 0, fmt_time },
    { "CPU", 6, 1, 0, fmt_cpu },
    { "COMMAND", 7, 0, 0, fmt_command },
    { "VCSW", 6, 1, 0, fmt_vcsw },
    { "IVCSW", 6, 1, 0, fmt_ivcsw },
    { "READ", 6, 1, 0, fmt_read },
    { "WRITE", 6, 1, 0, fmt_write },
    { "FAULT", 6, 1, 0, fmt_fault },
    { "TOTAL", 6, 1, 0, fmt_iototal },
    { "PERCENT", 7, 1, 0, fmt_iopct },
    { NULL, 0, 0, 0, NULL }
};
#define MAX_FIELDS 24

static int mode0_display[MAX_FIELDS];
static int mode0thr_display[MAX_FIELDS];
static int mode1_display[MAX_FIELDS];

int
field_index(char *col)

{
    struct proc_field *fp;
    int i = 0;

    fp = proc_field;
    while (fp->name != NULL)
    {
	if (strcmp(col, fp->name) == 0)
	{
	    return i;
	}
	fp++;
	i++;
    }

    return -1;
}

void
field_subst(int *fp, int old, int new)

{
    while (*fp != -1)
    {
	if (*fp == old)
	{
	    *fp = new;
	}
	fp++;
    }
}

int
machine_init(struct statics *statics)

{
    int i = 0;
    size_t len;
    int *ip;

    struct timeval boottime;

    len = sizeof(smpmode);
    if ((sysctlbyname("machdep.smp_active", &smpmode, &len, NULL, 0) < 0 &&
         sysctlbyname("smp.smp_active", &smpmode, &len, NULL, 0) < 0) ||
	len != sizeof(smpmode))
    {
	smpmode = 0;
    }
    smpmode = smpmode != 0;

    /* kvm_open the active kernel: its okay if this fails */
    kd = kvm_open(NULL, NULL, NULL, O_RDONLY, NULL);

    /* get boot time */
    len = sizeof(boottime);
    if (sysctlbyname("kern.boottime", &boottime, &len, NULL, 0) == -1)
    {
	/* we have no boottime to report */
	boottime.tv_sec = -1;
    }

    pbase = NULL;
    pref = NULL;

    /* get the page size with "getpagesize" and calculate pageshift from it */
    i = pagesize = getpagesize();
    pageshift = 0;
    while (i > 1)
    {
	pageshift++;
	i >>= 1;
    }

    /* translate sysctl paths to mibs for faster access */
    get_sysctl_mibs();

    /* initialize swap stuff */
    swap_init();

    /* create the hash table that remembers proc data */
    procs = hash_create(2039);

    /* we only need the amount of log(2)1024 for our conversion */
    pageshift -= LOG1024;

    /* fill in the statics information */
    statics->procstate_names = procstatenames;
    statics->cpustate_names = cpustatenames;
    statics->memory_names = memorynames;
    statics->kernel_names = kernelnames;
    statics->boottime = boottime.tv_sec;
    statics->swap_names = swapnames;
    statics->order_names = ordernames;
    statics->flags.warmup = 1;
    statics->modemax = 2;
#ifdef HAS_SHOWTHREADS
    statics->flags.threads = 1;
#endif

    /* we need kvm descriptor in order to show full commands */
    statics->flags.fullcmds = kd != NULL;

    /* set up the display indices for mode0 */
    ip = mode0_display;
    *ip++ = field_index("PID");
    *ip++ = field_index("USERNAME");
#ifdef HAS_THREADS
    *ip++ = field_index("THR");
#endif
    *ip++ = field_index("PRI");
    *ip++ = field_index("NICE");
    *ip++ = field_index("SIZE");
    *ip++ = field_index("RES");
    *ip++ = field_index("STATE");
    *ip++ = field_index("FLG");
    if (smpmode)
	*ip++ = field_index("C");
    *ip++ = field_index("TIME");
    *ip++ = field_index("CPU");
    *ip++ = field_index("COMMAND");
    *ip = -1;

#ifdef HAS_SHOWTHREADS
    /* set up the display indices for mode0 showing threads */
    ip = mode0thr_display;
    *ip++ = field_index("PID");
    *ip++ = field_index("USERNAME");
    *ip++ = field_index("PRI");
    *ip++ = field_index("NICE");
    *ip++ = field_index("SIZE");
    *ip++ = field_index("RES");
    *ip++ = field_index("STATE");
    *ip++ = field_index("FLG");
    if (smpmode)
	*ip++ = field_index("C");
    *ip++ = field_index("TIME");
    *ip++ = field_index("CPU");
    *ip++ = field_index("COMMAND");
    *ip = -1;
#endif

    /* set up the display indices for mode1 */
    ip = mode1_display;
    *ip++ = field_index("PID");
    *ip++ = field_index("USERNAME");
    *ip++ = field_index("VCSW");
    *ip++ = field_index("IVCSW");
    *ip++ = field_index("READ");
    *ip++ = field_index("WRITE");
    *ip++ = field_index("FAULT");
    *ip++ = field_index("TOTAL");
    *ip++ = field_index("PERCENT");
    *ip++ = field_index("COMMAND");
    *ip = -1;

    /* all done! */
    return(0);
}

char *format_header(char *uname_field)

{
    return "";
}

void
get_vm_sum(struct vmmeter *sum)

{
#define GET_VM_STAT(v, s)  (void)get_sysctl(v, &(sum->s), sizeof(sum->s))

    GET_VM_STAT(V_SWTCH, v_swtch);
    GET_VM_STAT(V_TRAP, v_trap);
    GET_VM_STAT(V_INTR, v_intr);
    GET_VM_STAT(V_SOFT, v_soft);
    GET_VM_STAT(V_VFORKS, v_vforks);
    GET_VM_STAT(V_FORKS, v_forks);
    GET_VM_STAT(V_RFORKS, v_rforks);
    GET_VM_STAT(V_VM_FAULTS, v_vm_faults);
    GET_VM_STAT(V_SWAPIN, v_swapin);
    GET_VM_STAT(V_SWAPOUT, v_swapout);
    GET_VM_STAT(V_TFREE, v_tfree);
    GET_VM_STAT(V_VNODEIN, v_vnodein);
    GET_VM_STAT(V_VNODEOUT, v_vnodeout);
    GET_VM_STAT(V_ACTIVE_COUNT, v_active_count);
    GET_VM_STAT(V_INACTIVE_COUNT, v_inactive_count);
    GET_VM_STAT(V_WIRE_COUNT, v_wire_count);
    GET_VM_STAT(V_CACHE_COUNT, v_cache_count);
    GET_VM_STAT(V_FREE_COUNT, v_free_count);
    GET_VM_STAT(V_SWAPPGSIN, v_swappgsin);
    GET_VM_STAT(V_SWAPPGSOUT, v_swappgsout);
}

void
get_system_info(struct system_info *si)

{
    long total;
    struct timeval thistime;
    struct timeval timediff;

    /* timestamp and time difference */
    gettimeofday(&thistime, 0);
    timersub(&thistime, &lasttime, &timediff);
    elapsed_time = timediff.tv_sec * 1000000 + timediff.tv_usec;
    elapsed_msecs = timediff.tv_sec * 1000 + timediff.tv_usec / 1000;

    /* get the load averages */
    if (getloadavg(si->load_avg, NUM_AVERAGES) == -1)
    {
	/* failed: fill in with zeroes */
	(void) memset(si->load_avg, 0, sizeof(si->load_avg));
    }

    /* get the cp_time array */
    (void)get_sysctl(K_CP_TIME, &cp_time, sizeof(cp_time));

    /* convert cp_time counts to percentages */
    total = percentages(CPUSTATES, cpu_states, cp_time, cp_old, cp_diff);

    /* sum memory & swap statistics */
    {
	struct vmmeter sum;
	static unsigned int swap_delay = 0;
	static long long swapavail = 0;
	static long long swapfree = 0;
	static int bufspace = 0;

	get_vm_sum(&sum);

	/* get bufspace */
	bufspace = 0;
	(void) get_sysctl(VFS_BUFSPACE, &bufspace, sizeof(bufspace));

	/* kernel stats */
	dprintf("kernel: swtch %d, trap %d, intr %d, soft %d, vforks %d\n",
		sum.v_swtch, sum.v_trap, sum.v_intr, sum.v_soft, sum.v_vforks);
	kernel_stats[0] = per_second(sum.v_swtch - ctxsws, elapsed_msecs);
	kernel_stats[1] = per_second(sum.v_trap - traps, elapsed_msecs);
	kernel_stats[2] = per_second(sum.v_intr - intrs, elapsed_msecs);
	kernel_stats[3] = per_second(sum.v_soft - softs, elapsed_msecs);
	kernel_stats[4] = per_second(sum.v_vforks + sum.v_forks +
				     sum.v_rforks - forks, elapsed_msecs);
	kernel_stats[5] = per_second(sum.v_vm_faults - pfaults, elapsed_msecs);
	kernel_stats[6] = per_second(sum.v_swapin + sum.v_vnodein - pagein, elapsed_msecs);
	kernel_stats[7] = per_second(sum.v_swapout + sum.v_vnodeout - pageout, elapsed_msecs);
	kernel_stats[8] = per_second(sum.v_tfree - tfreed, elapsed_msecs);
	ctxsws = sum.v_swtch;
	traps = sum.v_trap;
	intrs = sum.v_intr;
	softs = sum.v_soft;
	forks = (u_int64_t)sum.v_vforks + sum.v_forks + sum.v_rforks;
	pfaults = sum.v_vm_faults;
	pagein = sum.v_swapin + sum.v_vnodein;
	pageout = sum.v_swapout + sum.v_vnodeout;
	tfreed = sum.v_tfree;

	/* convert memory stats to Kbytes */
	memory_stats[0] = pagetok(sum.v_active_count);
	memory_stats[1] = pagetok(sum.v_inactive_count);
	memory_stats[2] = pagetok(sum.v_wire_count);
	memory_stats[3] = pagetok(sum.v_cache_count);
	memory_stats[4] = bufspace / 1024;
	memory_stats[5] = pagetok(sum.v_free_count);
	memory_stats[6] = -1;

	/* first interval */
        if (swappgsin < 0)
	{
	    swap_stats[4] = 0;
	    swap_stats[5] = 0;
	} 

	/* compute differences between old and new swap statistic */
	else
	{
	    swap_stats[4] = pagetok(sum.v_swappgsin - swappgsin);
	    swap_stats[5] = pagetok(sum.v_swappgsout - swappgsout);
	}

        swappgsin = sum.v_swappgsin;
	swappgsout = sum.v_swappgsout;

	/* call CPU heavy swap_getdata() only for changes */
        if (swap_stats[4] > 0 || swap_stats[5] > 0 || swap_delay == 0)
	{
	    swap_stats[3] = swap_getdata(&swapavail, &swapfree);
	    swap_stats[0] = swapavail;
	    swap_stats[1] = swapavail - swapfree;
	    swap_stats[2] = swapfree;
	}
        swap_delay = 1;
	swap_stats[6] = -1;
    }

    /* set arrays and strings */
    si->cpustates = cpu_states;
    si->kernel = kernel_stats;
    si->memory = memory_stats;
    si->swap = swap_stats;

    si->last_pid = -1;

    lasttime = thistime;
}

caddr_t
get_process_info(struct system_info *si,
			 struct process_select *sel,
			 int compare_index)

{
    int i;
    int total_procs;
    int active_procs;
    struct kinfo_proc **prefp;
    struct kinfo_proc *pp;
    struct kinfo_proc *prev_pp = NULL;
    struct save_proc *savep;
    long proc_io;
    pid_t pid;
    size_t size;
    int nproc;

    /* these are copied out of sel for speed */
    int show_idle;
    int show_self;
    int show_system;
    int show_uid;
    char *show_command;

    /* get proc table size and give it a boost */
    nproc = (int)get_sysctlsize(K_PROC) / sizeof(struct kinfo_proc);
    nproc += nproc >> 4;
    size = nproc * sizeof(struct kinfo_proc);
    dprintf("get_process_info: nproc %d, psize %d, size %d\n", nproc, psize, size);

    /* make sure we have enough space allocated */
    if (nproc > psize)
    {
	/* reallocate both pbase and pref */
	pbase = (struct kinfo_proc *)realloc(pbase, size);
	pref  = (struct kinfo_proc **)realloc(pref,
		    sizeof(struct kinfo_proc *) * nproc);
	psize = nproc;
    }

    /* make sure we got the space we asked for */
    if (pref == NULL || pbase == NULL)
    {
	/* abandon all hope */
	message_error(" Out of memory!");
	nproc = psize = 0;
	si->p_total = 0;
	si->p_active = 0;
	return NULL;
    }

    /* get all process information (threads, too) */
    if (size > 0)
    {
	nproc = get_sysctl(K_PROC, pbase, size);
	if (nproc == -1)
	{
	    nproc = 0;
	}
	else
	{
	    nproc /= sizeof(struct kinfo_proc);
	}
    }

    /* get a pointer to the states summary array */
    si->procstates = process_states;

    /* set up flags which define what we are going to select */
    show_idle = sel->idle;
    show_self = 0;
    show_system = sel->system;
    show_uid = sel->uid != -1;
    show_fullcmd = sel->fullcmd;
    show_command = sel->command;
    show_usernames = sel->usernames;
    display_mode = sel->mode;
#ifdef HAS_SHOWTHREADS
    show_threads = sel->threads;
#endif

    /* count up process states and get pointers to interesting procs */
    total_procs = 0;
    active_procs = 0;
    total_io = 0;
    memset((char *)process_states, 0, sizeof(process_states));
    prefp = pref;
    for (pp = pbase, i = 0; i < nproc; pp++, i++)
    {
	/*
	 *  Place pointers to each valid proc structure in pref[].
	 *  Process slots that are actually in use have a non-zero
	 *  status field.  Processes with P_SYSTEM set are system
	 *  processes---these get ignored unless show_sysprocs is set.
	 */
	pid = PP(pp, pid);
	if (PP(pp, stat) != 0)
	{
#ifdef HAS_SHOWTHREADS
	    int is_thread;
	    lwpid_t tid;

	    /* get thread id */
	    tid = PP(pp, tid);

	    /* is this just a thread? */
	    is_thread = (prev_pp != NULL && PP(prev_pp, pid) == pid);

	    /* count this process and its state */
	    /* only count threads if we are showing them */
	    if (show_threads || !is_thread)
	    {
		total_procs++;
		process_states[(unsigned char) PP(pp, stat)]++;
	    }

	    /* grab old data from hash */
	    if ((savep = hash_lookup_lwpid(procs, tid)) != NULL)
	    {
		/* verify that this is not a new or different thread */
		/* (freebsd reuses thread ids fairly quickly) */
		/* pids must match and time can't have gone backwards */
		if (pid != savep->sp_pid || PP(pp, runtime) < savep->sp_runtime)
		{
		    /* not the same thread -- reuse the save_proc structure */
		    memset(savep, 0, sizeof(struct save_proc));
		    savep->sp_pid = pid;
		}
	    }
	    else
	    {
		/* havent seen this one before */
		savep = (struct save_proc *)calloc(1, sizeof(struct save_proc));
		savep->sp_pid = pid;
		hash_add_lwpid(procs, tid, savep);
	    }

#else /* !HAS_SHOWTHREADS */
	    total_procs++;
	    process_states[(unsigned char) PP(pp, stat)]++;

	    /* grab old data from hash */
	    if ((savep = hash_lookup_pid(procs, pid)) == NULL)
	    {
		/* havent seen this one before */
		savep = (struct save_proc *)calloc(1, sizeof(struct save_proc));
		savep->sp_pid = pid;
		hash_add_pid(procs, pid, savep);
	    }
#endif

	    /* save the pointer to the sp struct */
	    SPPTR(pp) = (void *)savep;

	    /* calculate %cpu */
	    PPCPU(pp) = ((PP(pp, runtime) - savep->sp_runtime) * 10000) /
		elapsed_time;
	    dprintf("%d (%d): runtime %lld, saved_pid %d, saved_runtime %lld, elapsed_time %d, ppcpu %d\n",
		    pid, PP(pp, tid), PP(pp, runtime), savep->sp_pid, savep->sp_runtime,
		    elapsed_time, PPCPU(pp));

	    /* calculate io differences */
	    proc_io = 0;
	    savep->sp_vcsw = (RP(pp, nvcsw) - savep->sp_old_nvcsw);
	    savep->sp_ivcsw = (RP(pp, nivcsw) - savep->sp_old_nivcsw);
	    proc_io += (savep->sp_inblock = (RP(pp, inblock) - savep->sp_old_inblock));
	    proc_io += (savep->sp_oublock = (RP(pp, oublock) - savep->sp_old_oublock));
	    proc_io += (savep->sp_majflt = (RP(pp, majflt) - savep->sp_old_majflt));
	    total_io += proc_io;
	    savep->sp_totalio = proc_io;

	    /* save data for next time */
	    savep->sp_runtime = PP(pp, runtime);
	    savep->sp_old_nvcsw = RP(pp, nvcsw);
	    savep->sp_old_nivcsw = RP(pp, nivcsw);
	    savep->sp_old_inblock = RP(pp, inblock);
	    savep->sp_old_oublock = RP(pp, oublock);
	    savep->sp_old_majflt = RP(pp, majflt);

	    /* is this one selected for viewing? */
	    if ((PP(pp, stat) != SZOMB) &&
		(show_system || ((PP(pp, flag) & P_SYSTEM) == 0)) &&
		(show_idle || (PP(pp, pctcpu) != 0) || 
		 (PP(pp, stat) == SRUN)) &&
		(!show_uid || PRUID(pp) == (uid_t)sel->uid) &&
		(show_command == NULL ||
		 strcasestr(PP(pp, comm), show_command) != NULL))
	    {
#ifdef HAS_SHOWTHREADS
		/* yes, but make sure it isn't just a thread */
		if (show_threads || !is_thread)
		{
		    /* we will be showing this thread */
		    *prefp++ = pp;
		    active_procs++;
		}
		else
		{
		    /* we will not be showing this thread, but we need to roll
		       up its cpu usage in to its process */
		    PP(prev_pp, pctcpu) += PP(pp, pctcpu);
		}
#else /* !HAS_SHOWTHREADS */
		/* we will be showing this process */
		*prefp++ = pp;
		active_procs++;
#endif
	    }
	    prev_pp = pp;
	}
    }

    dprintf("total_io: %d\n", total_io);
    if (total_io == 0) total_io = 1;

    /* if requested, sort the "interesting" processes */
    if (active_procs > 1)
    {
	qsort((char *)pref, active_procs, sizeof(struct kinfo_proc *),
	      proc_compares[compare_index]);
    }

    /* remember active and total counts */
    si->p_total = total_procs;
    si->p_active = pref_len = active_procs;

    /* pass back a handle */
    handle.next_proc = pref;
    handle.remaining = active_procs;
    return((caddr_t)&handle);
}

static char p_header[MAX_COLS];

char *
format_process_header(struct process_select *sel, caddr_t handle, int count)

{
    int cols;
    int n;
    int w;
    char *p;
    int *fi;
    struct kinfo_proc **kip;
    struct proc_field *fp;

    /* check for null handle */
    if (handle == NULL)
    {
	return("");
    }

    /* remember how many columns there are on the display */
    cols = display_columns();

    /* mode & threads dictate format */
    fi = display_fields =
	sel->mode == 0 ?
	(sel->threads == 0 ? mode0_display : mode0thr_display) :
	mode1_display;

    /* set username field correctly */
    if (!sel->usernames)
    {
	/* display uids */
	field_subst(fi, FIELD_USERNAME, FIELD_UID);
    }
    else
    {
	/* display usernames */
	field_subst(fi, FIELD_UID, FIELD_USERNAME);

	/* we also need to determine the longest username for column width */
	/* calculate namelength from first "count" processes */
	kip = ((struct handle *)handle)->next_proc;
	n = ((struct handle *)handle)->remaining;
	if (n > count)
	    n = count;
	namelength = 0;
	while (n-- > 0)
	{
	    w = strlen(username(PRUID(*kip)));
	    if (w > namelength) namelength = w;
	    kip++;
	}
	dprintf("format_process_header: namelength %d\n", namelength);

	/* place it in bounds */
	if (namelength < 8)
	{
	    namelength = 8;
	}

	/* set the column width */
	proc_field[FIELD_USERNAME].width = username_length = namelength;
    }

    /* walk thru fields and construct header */
    /* are we worried about overflow??? */
    p = p_header;
    while (*fi != -1)
    {
	fp = &(proc_field[*fi++]);
	if (fp->min_screenwidth <= cols)
	{
	    p += sprintf(p, fp->rjust ? "%*s" : "%-*s", fp->width, fp->name);
	    *p++ = ' ';
	}
    }
    *--p = '\0';

    return p_header;
}

static char fmt[MAX_COLS];		/* static area where result is built */

char *
format_next_process(caddr_t handle, char *(*get_userid)(int))

{
    struct kinfo_proc *pp;
    struct handle *hp;
    struct proc_field *fp;
    int *fi;
    int i;
    int cols;
    char *p;
    int len;
    int x;

    /* find and remember the next proc structure */
    hp = (struct handle *)handle;
    pp = *(hp->next_proc++);
    hp->remaining--;
    
    /* mode & threads dictate format */
    fi = display_fields;

    /* screen width is a consideration, too */
    cols = display_columns();

    /* build output by field */
    p = fmt;
    len = MAX_COLS;
    while ((i = *fi++) != -1)
    {
	fp = &(proc_field[i]);
	if (len > 0 && fp->min_screenwidth <= cols)
	{
	    x = (*(fp->format))(p, len, pp);
	    if (x >= len)
	    {
		dprintf("format_next_process: formatter overflow: x %d, len %d, p %08x => %08x, fmt %08x - %08x\n",
			x, len, p, p + len, fmt, fmt + sizeof(fmt));
		p += len;
		len = 0;
	    }
	    else
	    {
		p += x;
		*p++ = ' ';
		len -= x + 1;
	    }
	}
    }
    *--p = '\0';

    /* return the result */
    return(fmt);
}

/* comparison routines for qsort */

/*
 *  proc_compare - comparison function for "qsort"
 *	Compares the resource consumption of two processes using five
 *  	distinct keys.  The keys (in descending order of importance) are:
 *  	percent cpu, cpu ticks, state, resident set size, total virtual
 *  	memory usage.  The process states are ordered as follows (from least
 *  	to most important):  WAIT, zombie, sleep, stop, start, run.  The
 *  	array declaration below maps a process state index into a number
 *  	that reflects this ordering.
 */

static unsigned char sorted_state[] =
{
    0,	/* not used		*/
    3,	/* sleep		*/
    1,	/* ABANDONED (WAIT)	*/
    6,	/* run			*/
    5,	/* start		*/
    2,	/* zombie		*/
    4	/* stop			*/
};
 

#define ORDERKEY_PCTCPU \
  if (lresult = (long) PPCPU(p2) - (long) PPCPU(p1), \
     (result = lresult > 0 ? 1 : lresult < 0 ? -1 : 0) == 0)

#define ORDERKEY_CPTICKS \
  if ((result = PP(p2, runtime) > PP(p1, runtime) ? 1 : \
                PP(p2, runtime) < PP(p1, runtime) ? -1 : 0) == 0)

#define ORDERKEY_STATE \
  if ((result = sorted_state[(unsigned char) PP(p2, stat)] - \
                sorted_state[(unsigned char) PP(p1, stat)]) == 0)

#if OSMAJOR <= 4
#define ORDERKEY_PRIO \
  if ((result = PP(p2, priority) - PP(p1, priority)) == 0)
#else
#define ORDERKEY_PRIO \
  if ((result = PP(p2, pri.pri_level) - PP(p1, pri.pri_level)) == 0)
#endif

#define ORDERKEY_RSSIZE \
  if ((result = VP(p2, rssize) - VP(p1, rssize)) == 0) 

#define ORDERKEY_MEM \
  if ( (result = PROCSIZE(p2) - PROCSIZE(p1)) == 0 )

#define ORDERKEY_IO \
  if ( (result = SP(p2, totalio) - SP(p1, totalio)) == 0)

#define ORDERKEY_PID \
  if ( (result = PP(p1, pid) - PP(p2, pid)) == 0)

/* compare_cpu - the comparison function for sorting by cpu percentage */

int
proc_compare(struct proc **pp1, struct proc **pp2)

{
    struct kinfo_proc *p1;
    struct kinfo_proc *p2;
    int result;
    pctcpu lresult;

    /* remove one level of indirection */
    p1 = *(struct kinfo_proc **) pp1;
    p2 = *(struct kinfo_proc **) pp2;

    ORDERKEY_PCTCPU
    ORDERKEY_CPTICKS
    ORDERKEY_STATE
    ORDERKEY_PRIO
    ORDERKEY_RSSIZE
    ORDERKEY_MEM
    ;

    return(result);
}

/* compare_size - the comparison function for sorting by total memory usage */

int
compare_size(struct proc **pp1, struct proc **pp2)

{
    struct kinfo_proc *p1;
    struct kinfo_proc *p2;
    int result;
    pctcpu lresult;

    /* remove one level of indirection */
    p1 = *(struct kinfo_proc **) pp1;
    p2 = *(struct kinfo_proc **) pp2;

    ORDERKEY_MEM
    ORDERKEY_RSSIZE
    ORDERKEY_PCTCPU
    ORDERKEY_CPTICKS
    ORDERKEY_STATE
    ORDERKEY_PRIO
    ;

    return(result);
}

/* compare_res - the comparison function for sorting by resident set size */

int
compare_res(struct proc **pp1, struct proc **pp2)

{
    struct kinfo_proc *p1;
    struct kinfo_proc *p2;
    int result;
    pctcpu lresult;

    /* remove one level of indirection */
    p1 = *(struct kinfo_proc **) pp1;
    p2 = *(struct kinfo_proc **) pp2;

    ORDERKEY_RSSIZE
    ORDERKEY_MEM
    ORDERKEY_PCTCPU
    ORDERKEY_CPTICKS
    ORDERKEY_STATE
    ORDERKEY_PRIO
    ;

    return(result);
}

/* compare_time - the comparison function for sorting by total cpu time */

int
compare_time(struct proc **pp1, struct proc **pp2)

{
    struct kinfo_proc *p1;
    struct kinfo_proc *p2;
    int result;
    pctcpu lresult;
  
    /* remove one level of indirection */
    p1 = *(struct kinfo_proc **) pp1;
    p2 = *(struct kinfo_proc **) pp2;

    ORDERKEY_CPTICKS
    ORDERKEY_PCTCPU
    ORDERKEY_STATE
    ORDERKEY_PRIO
    ORDERKEY_RSSIZE
    ORDERKEY_MEM
    ;

      return(result);
  }
  
/* compare_prio - the comparison function for sorting by priority */

int
compare_prio(struct proc **pp1, struct proc **pp2)

{
    struct kinfo_proc *p1;
    struct kinfo_proc *p2;
    int result;
    pctcpu lresult;

    /* remove one level of indirection */
    p1 = *(struct kinfo_proc **) pp1;
    p2 = *(struct kinfo_proc **) pp2;

    ORDERKEY_PRIO
    ORDERKEY_CPTICKS
    ORDERKEY_PCTCPU
    ORDERKEY_STATE
    ORDERKEY_RSSIZE
    ORDERKEY_MEM
    ;

    return(result);
}

/* compare_io - the comparison function for sorting by io count */

int
compare_io(struct proc **pp1, struct proc **pp2)

{
    struct kinfo_proc *p1;
    struct kinfo_proc *p2;
    int result;
    pctcpu lresult;

    /* remove one level of indirection */
    p1 = *(struct kinfo_proc **) pp1;
    p2 = *(struct kinfo_proc **) pp2;

    ORDERKEY_IO
    ORDERKEY_PCTCPU
    ORDERKEY_CPTICKS
    ORDERKEY_STATE
    ORDERKEY_PRIO
    ORDERKEY_RSSIZE
    ORDERKEY_MEM
    ;

    return(result);
}

/* compare_pid - the comparison function for sorting by process id */

int
compare_pid(struct proc **pp1, struct proc **pp2)

{
    struct kinfo_proc *p1;
    struct kinfo_proc *p2;
    int result;

    /* remove one level of indirection */
    p1 = *(struct kinfo_proc **) pp1;
    p2 = *(struct kinfo_proc **) pp2;

    ORDERKEY_PID
    ;

    return(result);
}

/*
 * proc_owner(pid) - returns the uid that owns process "pid", or -1 if
 *		the process does not exist.
 *		It is EXTREMLY IMPORTANT that this function work correctly.
 *		If top runs setuid root (as in SVR4), then this function
 *		is the only thing that stands in the way of a serious
 *		security problem.  It validates requests for the "kill"
 *		and "renice" commands.
 */

int
proc_owner(int pid)

{
    int cnt;
    struct kinfo_proc **prefp;
    struct kinfo_proc *pp;

    prefp = pref;
    cnt = pref_len;
    while (--cnt >= 0)
    {
	pp = *prefp++;	
	if (PP(pp, pid) == (pid_t)pid)
	{
	    return((int)PRUID(pp));
	}
    }
    return(-1);
}