source: trunk/athena/bin/mon/io.c @ 2

/*
 *      $Source: /afs/dev.mit.edu/source/repository/athena/bin/mon/io.c,v $
 *      $Author: dgg $
 *      $Locker:  $
 *      $Header: /afs/dev.mit.edu/source/repository/athena/bin/mon/io.c,v 1.1 1984-12-13 12:00:44 dgg Exp $
 */

#ifndef lint
static char *rcsid_io_c = "$Header: /afs/dev.mit.edu/source/repository/athena/bin/mon/io.c,v 1.1 1984-12-13 12:00:44 dgg Exp $";
#endif  lint

/*
 *      I O
 *
 * Purpose: Read the kernel's I/O statistics and display selected
 *      parameters about terminals and disks.
 *
 */

#include "mon.h"

double  kbps, tps;      /* Kbytes/sec and xfers/sec */
int     lasty;          /* Last disk y location */

/* Temporary Defines - All output should be moved to dispinfo */
#include <curses.h>
#define CHARX   37
#define CHARY   5
#define DISKX   55
#define DISKY   2
#define DISKOFF 6
#define DISKWDS DISKOFF
#define DISKXFER DISKOFF+4
#define DISKSEEK DISKOFF+8

io()
{
        int y;
        register i;
        long    t;
        double  tkbps, ttps;    /* Totals for all drives */

        lseek(kmem, (long)namelist[X_DK_TIME].n_value, 0);
        read(kmem, s.dk_time, sizeof s.dk_time);
        lseek(kmem, (long)namelist[X_DK_XFER].n_value, 0);
        read(kmem, s.dk_xfer, sizeof s.dk_xfer);
        lseek(kmem, (long)namelist[X_DK_WDS].n_value, 0);
        read(kmem, s.dk_wds, sizeof s.dk_wds);
        lseek(kmem, (long)namelist[X_TK_NIN].n_value, 0);
        read(kmem, &s.tk_nin, sizeof s.tk_nin);
        lseek(kmem, (long)namelist[X_TK_NOUT].n_value, 0);
        read(kmem, &s.tk_nout, sizeof s.tk_nout);
        lseek(kmem, (long)namelist[X_DK_SEEK].n_value, 0);
        read(kmem, s.dk_seek, sizeof s.dk_seek);
        lseek(kmem, (long)namelist[X_DK_MSPW].n_value, 0);
        read(kmem, s.dk_mspw, sizeof s.dk_mspw);
        lseek(kmem, (long)namelist[X_HZ].n_value, 0);
        read(kmem, &hz, sizeof hz);
        for (i = 0; i < DK_NDRIVE; i++) {
#define X(fld)  t = s.fld[i]; s.fld[i] -= s1.fld[i]; s1.fld[i] = t
                X(dk_xfer); X(dk_seek); X(dk_wds); X(dk_time);
        }
        t = s.tk_nin; s.tk_nin -= s1.tk_nin; s1.tk_nin = t;
        t = s.tk_nout; s.tk_nout -= s1.tk_nout; s1.tk_nout = t;

        /* output character I/O counts */
        mvprintw(CHARY+1,CHARX+4,"%4.0f %5.0f", s.tk_nin/etime, s.tk_nout/etime);

        /* Display Drive statistics */
        tkbps = ttps = 0;
        for (i=0; i<DK_NDRIVE; i++) {
                if (stats(i)) {
                        tkbps += kbps;
                        ttps += tps;
                }
        }
        /* Display Totals */
        mvprintw(lasty+2, DISKX+DISKOFF, "%4.0f%4.0f", tkbps, ttps);
}

/*
 * Display statistics for dk drive number dn.
 *  Returns 1 if totals should be updated.
 */
stats(dn)
{
        int y;
        register i;
        double atime, words, xtime, itime;

        /* only display info for named (real) devices */
        if (!*dr_name[dn])
                return(0);

        y = dn + DISKY+1;
        lasty = y;
        if (s.dk_mspw[dn] == 0.0) {
                mvprintw(y,DISKX+DISKOFF,"%4.0f%4.0f%6.1f ", 0.0, 0.0, 0.0);
                return(0);
        }
        atime = s.dk_time[dn];
        atime /= (float) hz;
        words = s.dk_wds[dn]*32.0;      /* number of 16 bit words transferred */
        xtime = s.dk_mspw[dn]*words;    /* transfer time */
        itime = atime - xtime;          /* time not transferring (seek time) */

        if (xtime < 0)
                itime += xtime, xtime = 0;
        if (itime < 0)
                xtime += itime, itime = 0;

        /* Avg Kbps, transfers/sec, avg seek time (in msec) */
        kbps = words/512/etime;
        tps = s.dk_xfer[dn]/etime;
        mvprintw(y,DISKX+DISKWDS,"%4.0f", kbps);
        mvprintw(y,DISKX+DISKXFER,"%4.0f", tps);
        mvprintw(y,DISKX+DISKSEEK,"%6.1f ",
            s.dk_seek[dn] ? itime*1000./s.dk_seek[dn] : 0.0);

        return(1);      /* Update totals */
}