projects / unix-history / blobdiff
? search:
summary | tags | clone url | shortlog | log | commit | commitdiff | tree
raw | inline | side by side
=/^G show total bytes now; document may not always work
[unix-history] / usr / src / usr.bin / systat / iostat.c
diff --git a/usr/src/usr.bin/systat/iostat.c b/usr/src/usr.bin/systat/iostat.c
index 97455c3..f9b8c9b 100644 (file)
--- a/usr/src/usr.bin/systat/iostat.c
+++ b/usr/src/usr.bin/systat/iostat.c
@@ -1,322 +1,343 @@
+/*
+ * Copyright (c) 1980 Regents of the University of California.
+ * All rights reserved.  The Berkeley software License Agreement
+ * specifies the terms and conditions for redistribution.
+ */
+
 #ifndef lint
 #ifndef lint
-static char sccsid[] = "@(#)iostat.c   1.2 (Lucasfilm) %G%";
-#endif
+static char sccsid[] = "@(#)iostat.c   5.3 (Berkeley) %G%";
+#endif not lint
 
 /*
  * iostat
  */
 #include "systat.h"
 
 /*
  * iostat
  */
 #include "systat.h"
-
 #include <sys/buf.h>
 #include <sys/buf.h>
-#include <sys/dk.h>
-#ifdef vax
-#include <vaxuba/ubavar.h>
-#include <vaxmba/mbavar.h>
-#endif
-#ifdef sun
-#include <sundev/mbvar.h>
-#endif
 
 WINDOW *
 openiostat()
 {
 
 WINDOW *
 openiostat()
 {
-       static WINDOW *w = NULL;
 
 
-        if (w == NULL)
-               w = newwin(20, 70, 4, 5);
-       return (w);
+       return (subwin(stdscr, LINES-1-5, 0, 5, 0));
 }
 
 closeiostat(w)
 }
 
 closeiostat(w)
-       WINDOW *w;
+        WINDOW *w;
 {
 
 {
 
-       if (w == NULL)
-               return;
-       move(5, 0);
-       clrtobot();
-       wclear(w);
-       wrefresh(w);
+        if (w == NULL)
+                return;
+        wclear(w);
+        wrefresh(w);
+       delwin(w);
 }
 
 static struct nlist nlst[] = {
 }
 
 static struct nlist nlst[] = {
-#define        X_DK_BUSY       0
-       { "_dk_busy" },
-#define        X_DK_TIME       1
-       { "_dk_time" },
-#define        X_DK_XFER       2
-       { "_dk_xfer" },
-#define        X_DK_WDS        3
-       { "_dk_wds" },
-#define        X_DK_SEEK       4
-       { "_dk_seek" },
-#define        X_CP_TIME       5
-       { "_cp_time" },
-#define        X_DK_MSPW       6
-       { "_dk_mspw" },
-#define        X_HZ            7
-       { "_hz" },
-
+#define X_DK_BUSY       0
+        { "_dk_busy" },
+#define X_DK_TIME       1
+        { "_dk_time" },
+#define X_DK_XFER       2
+        { "_dk_xfer" },
+#define X_DK_WDS        3
+        { "_dk_wds" },
+#define X_DK_SEEK       4
+        { "_dk_seek" },
+#define X_CP_TIME       5
+        { "_cp_time" },
 #ifdef vax
 #ifdef vax
-#define X_MBDINIT      8
-       { "_mbdinit" },
-#define X_UBDINIT      9
-       { "_ubdinit" },
+#define X_MBDINIT       (X_CP_TIME+1)
+        { "_mbdinit" },
+#define X_UBDINIT       (X_CP_TIME+2)
+        { "_ubdinit" },
 #endif
 #endif
-#ifdef sun
-#define X_MBDINIT      8
-       { "_mbdinit" },
+#ifdef tahoe
+#define        X_VBDINIT       (X_CP_TIME+1)
+       { "_vbdinit" },
 #endif
 #endif
-       { "" },
+        { "" },
 };
 
 };
 
-char dr_name[DK_NDRIVE][10];
-
-struct {
-       int     dk_busy;
-       long    cp_time[CPUSTATES];
-       long    dk_time[DK_NDRIVE];
-       long    dk_wds[DK_NDRIVE];
-       long    dk_seek[DK_NDRIVE];
-       long    dk_xfer[DK_NDRIVE];
-       float   dk_mspw[DK_NDRIVE];
+static struct {
+        int     dk_busy;
+        long    cp_time[CPUSTATES];
+        long    *dk_time;
+        long    *dk_wds;
+        long    *dk_seek;
+        long    *dk_xfer;
 } s, s1;
 
 } s, s1;
 
-int    kmem;
-int    hz;
-double etime;
+static  int linesperregion;
+static  double etime;
+static  int numbers = 0;                /* default display bar graphs */
+static  int msps = 0;                   /* default ms/seek shown */
 
 initiostat()
 {
 
 initiostat()
 {
-       register  i;
 
 
-       if (nlst[X_DK_BUSY].n_type == 0) {
-               nlist("/vmunix", nlst);
-               if (nlst[X_DK_BUSY].n_type == 0) {
-                       error("Disk init information isn't in namelist");
-                       return;
-               }
+        if (nlst[X_DK_BUSY].n_type == 0) {
+                nlist("/vmunix", nlst);
+                if (nlst[X_DK_BUSY].n_type == 0) {
+                        error("Disk init information isn't in namelist");
+                        return(0);
+                }
+        }
+       if (! dkinit())
+               return(0);
+       if (dk_ndrive) {
+#define        allocate(e, t) \
+    s./**/e = (t *)calloc(dk_ndrive, sizeof (t)); \
+    s1./**/e = (t *)calloc(dk_ndrive, sizeof (t));
+               allocate(dk_time, long);
+               allocate(dk_wds, long);
+               allocate(dk_seek, long);
+               allocate(dk_xfer, long);
+#undef allocate
        }
        }
-       lseek(kmem, (long)nlst[X_DK_MSPW].n_value, L_SET);
-       read(kmem, s.dk_mspw, sizeof s.dk_mspw);
-       for (i = 0; i < DK_NDRIVE; i++)
-               sprintf(dr_name[i], "dk%d", i);
-       lseek(kmem, (long)nlst[X_DK_MSPW].n_value, L_SET);
-       read(kmem, s.dk_mspw, sizeof s.dk_mspw);
-       lseek(kmem, (long)nlst[X_HZ].n_value, L_SET);
-       read(kmem, &hz, sizeof hz);
-       read_names();
+       return(1);
 }
 
 fetchiostat()
 {
 
 }
 
 fetchiostat()
 {
 
-       if (nlst[X_DK_BUSY].n_type == 0)
-               return;
-       lseek(kmem, (long)nlst[X_DK_BUSY].n_value, L_SET);
-       read(kmem, &s.dk_busy, sizeof s.dk_busy);
-       lseek(kmem, (long)nlst[X_DK_TIME].n_value, L_SET);
-       read(kmem, s.dk_time, sizeof s.dk_time);
-       lseek(kmem, (long)nlst[X_DK_XFER].n_value, L_SET);
-       read(kmem, s.dk_xfer, sizeof s.dk_xfer);
-       lseek(kmem, (long)nlst[X_DK_WDS].n_value, L_SET);
-       read(kmem, s.dk_wds, sizeof s.dk_wds);
-       lseek(kmem, (long)nlst[X_DK_SEEK].n_value, L_SET);
-       read(kmem, s.dk_seek, sizeof s.dk_seek);
-       lseek(kmem, (long)nlst[X_CP_TIME].n_value, L_SET);
-       read(kmem, s.cp_time, sizeof s.cp_time);
+        if (nlst[X_DK_BUSY].n_type == 0)
+                return;
+       s.dk_busy = getw(nlst[X_DK_BUSY].n_value);
+        lseek(kmem, (long)nlst[X_DK_TIME].n_value, L_SET);
+        read(kmem, s.dk_time, dk_ndrive * sizeof (long));
+        lseek(kmem, (long)nlst[X_DK_XFER].n_value, L_SET);
+        read(kmem, s.dk_xfer, dk_ndrive * sizeof (long));
+        lseek(kmem, (long)nlst[X_DK_WDS].n_value, L_SET);
+        read(kmem, s.dk_wds, dk_ndrive * sizeof (long));
+        lseek(kmem, (long)nlst[X_DK_SEEK].n_value, L_SET);
+        read(kmem, s.dk_seek, dk_ndrive * sizeof (long));
+        lseek(kmem, (long)nlst[X_CP_TIME].n_value, L_SET);
+        read(kmem, s.cp_time, sizeof s.cp_time);
 }
 
 }
 
+#define        INSET   10
+
 labeliostat()
 {
 labeliostat()
 {
-       register int i, row;
+        int row;
 
 
-       if (nlst[X_DK_BUSY].n_type == 0) {
-               error("No dk_busy defined.");
-               return;
-       }
-       row = 5;
-       move(row, 0); clrtoeol();
-       mvaddstr(row++, 10,
+        if (nlst[X_DK_BUSY].n_type == 0) {
+                error("No dk_busy defined.");
+                return;
+        }
+        row = 0;
+        wmove(wnd, row, 0); wclrtobot(wnd);
+        mvwaddstr(wnd, row++, INSET, 
             "/0   /10  /20  /30  /40  /50  /60  /70  /80  /90  /100");
             "/0   /10  /20  /30  /40  /50  /60  /70  /80  /90  /100");
-       mvaddstr(row++, 0, "cpu  user|"); clrtoeol();
-       mvaddstr(row++, 0, "     nice|"); clrtoeol();
-       mvaddstr(row++, 0, "   system|"); clrtoeol();
-       mvaddstr(row++, 0, "     idle|"); clrtoeol();
-       row++;
-       for (i = 0; i < DK_NDRIVE; i++)
-               if (s.dk_mspw[i] != 0.0) {
-                       mvprintw(row++, 0, "%3.3s   bps|", dr_name[i]);
-                       clrtoeol();
-                       mvaddstr(row++, 0, "      tps|"); clrtoeol();
-                       mvaddstr(row++, 0, "      mps|"); clrtoeol();
-               }
+        mvwaddstr(wnd, row++, 0, "cpu  user|");
+        mvwaddstr(wnd, row++, 0, "     nice|");
+        mvwaddstr(wnd, row++, 0, "   system|");
+        mvwaddstr(wnd, row++, 0, "     idle|");
+        if (numbers)
+                row = numlabels(row + 1);
+        else
+                row = barlabels(row + 1);
 }
 
 }
 
-showiostat()
+static
+numlabels(row)
 {
 {
-       register int i;
-       register long t;
-       int row;
+        int i, col, regions, ndrives;
 
 
-       if (nlst[X_DK_BUSY].n_type == 0)
-               return;
-       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);
-       }
-       etime = 0;
-       for(i = 0; i < CPUSTATES; i++) {
-               X(cp_time);
-               etime += s.cp_time[i];
-       }
-       if (etime == 0.0)
-               etime = 1.0;
-       etime /= (float) hz;
-       row = 2;
-       for (i = 0; i < CPUSTATES; i++)
-               stat1(row++, i);
-       row++;
-       for (i = 0; i < DK_NDRIVE; i++)
-               if (s.dk_mspw[i] != 0.0)
-                       row = stats(row, i);
+#define COLWIDTH        14
+#define DRIVESPERLINE   ((wnd->_maxx - INSET) / COLWIDTH)
+       for (ndrives = 0, i = 0; i < dk_ndrive; i++)
+               if (dk_select[i])
+                       ndrives++;
+        regions = howmany(ndrives, DRIVESPERLINE);
+        /*
+         * Deduct -regions for blank line after each scrolling region.
+         */
+        linesperregion = (wnd->_maxy - row - regions) / regions;
+        /*
+         * Minimum region contains space for two
+         * label lines and one line of statistics.
+         */
+        if (linesperregion < 3)
+                linesperregion = 3;
+        col = 0;
+        for (i = 0; i < dk_ndrive; i++)
+                if (dk_select[i] && dk_mspw[i] != 0.0) {
+                        if (col + COLWIDTH >= wnd->_maxx - INSET) {
+                                col = 0, row += linesperregion + 1;
+                                if (row > wnd->_maxy - (linesperregion + 1))
+                                        break;
+                        }
+                        mvwaddstr(wnd, row, col + 4, dr_name[i]);
+                        mvwaddstr(wnd, row + 1, col, "bps tps msps");
+                        col += COLWIDTH;
+                }
+        if (col)
+                row += linesperregion + 1;
+        return (row);
 }
 
 }
 
-stats(row, dn)
-       int row, dn;
+static
+barlabels(row)
+        int row;
 {
 {
-       register i;
-       double atime, words, xtime, itime;
+        int i;
 
 
-       if (s.dk_mspw[dn] == 0.0) {
-               wmove(wnd, row++, 5); wclrtoeol(wnd);
-               wmove(wnd, row++, 5); wclrtoeol(wnd);
-               wmove(wnd, row++, 5); wclrtoeol(wnd);
-               return (row);
-       }
-       atime = s.dk_time[dn];
-       atime /= (float) hz;
-       words = s.dk_wds[dn]*32.0;      /* number of words transferred */
-       xtime = s.dk_mspw[dn]*words;    /* transfer time */
-       itime = atime - xtime;          /* time not transferring */
-       if (xtime < 0)
-               itime += xtime, xtime = 0;
-       if (itime < 0)
-               xtime += itime, itime = 0;
-       wmove(wnd, row++, 5); histogram(words / 512 / etime, 60, 1.0, 'X');
-       wmove(wnd, row++, 5); histogram(s.dk_xfer[dn] / etime, 60, 1.0, 'X');
-       wmove(wnd, row++, 5); histogram(s.dk_seek[dn] ?
-           itime * 1000. / s.dk_seek[dn] : 0, 60, 1.0, 'X');
-       return (row);
+        mvwaddstr(wnd, row++, INSET,
+            "/0   /5   /10  /15  /20  /25  /30  /35  /40  /45  /50");
+        linesperregion = 2 + msps;
+        for (i = 0; i < dk_ndrive; i++)
+                if (dk_select[i] && dk_mspw[i] != 0.0) {
+                        if (row > wnd->_maxy - linesperregion)
+                                break;
+                        mvwprintw(wnd, row++, 0, "%3.3s   bps|", dr_name[i]);
+                        mvwaddstr(wnd, row++, 0, "      tps|");
+                        if (msps)
+                                mvwaddstr(wnd, row++, 0, "     msps|");
+                }
+        return (row);
 }
 
 }
 
-stat1(row, o)
-       int row, o;
+showiostat()
 {
 {
-       register i;
-       double time;
+        register int i, row, col;
+        register long t;
 
 
-       time = 0;
-       for (i = 0; i < CPUSTATES; i++)
-               time += s.cp_time[i];
-       if (time == 0.0)
-               time = 1.0;
-       wmove(wnd, row, 5); histogram(100*s.cp_time[o] / time, 60, 0.5, 'X');
+        if (nlst[X_DK_BUSY].n_type == 0)
+                return;
+        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);
+        }
+        etime = 0;
+        for(i = 0; i < CPUSTATES; i++) {
+                X(cp_time);
+                etime += s.cp_time[i];
+        }
+        if (etime == 0.0)
+                etime = 1.0;
+        etime /= (float) hz;
+        row = 1;
+        for (i = 0; i < CPUSTATES; i++)
+                stat1(row++, i);
+        if (!numbers) {
+                row += 2;
+                for (i = 0; i < dk_ndrive; i++)
+                        if (dk_select[i] && dk_mspw[i] != 0.0) {
+                                if (row > wnd->_maxy - linesperregion)
+                                        break;
+                                row = stats(row, INSET, i);
+                        }
+                return;
+        }
+        col = 0;
+        wmove(wnd, row + linesperregion, 0);
+        wdeleteln(wnd);
+        wmove(wnd, row + 3, 0);
+        winsertln(wnd);
+        for (i = 0; i < dk_ndrive; i++)
+                if (dk_select[i] && dk_mspw[i] != 0.0) {
+                        if (col + COLWIDTH >= wnd->_maxx) {
+                                col = 0, row += linesperregion + 1;
+                                if (row > wnd->_maxy - (linesperregion + 1))
+                                        break;
+                                wmove(wnd, row + linesperregion, 0);
+                                wdeleteln(wnd);
+                                wmove(wnd, row + 3, 0);
+                                winsertln(wnd);
+                        }
+                        (void) stats(row + 3, col, i);
+                        col += COLWIDTH;
+                }
 }
 
 }
 
-histogram(val, colwidth, scale, c)
-       double val;
-       int colwidth;
-       double scale;
-       char c;
+static
+stats(row, col, dn)
+        int row, dn;
 {
 {
-       char buf[10];
-       register int k;
-       register int v = (int)(val * scale) + 0.5;
+        double atime, words, xtime, itime;
 
 
-       k = MIN(v, colwidth);
-       if (v > colwidth) {
-               sprintf(buf, "%4.1f", v);
-               k -= strlen(buf);
-               while (k--)
-                       waddch(wnd, c);
-               waddstr(wnd, buf);
-               return;
-       }
-       while (k--)
-               waddch(wnd, c);
-       wclrtoeol(wnd);
+        atime = s.dk_time[dn];
+        atime /= (float) hz;
+        words = s.dk_wds[dn]*32.0;      /* number of words transferred */
+        xtime = dk_mspw[dn]*words;      /* transfer time */
+        itime = atime - xtime;          /* time not transferring */
+        if (xtime < 0)
+                itime += xtime, xtime = 0;
+        if (itime < 0)
+                xtime += itime, itime = 0;
+        if (numbers) {
+                mvwprintw(wnd, row, col, "%3.0f%4.0f%5.1f",
+                    words / 512 / etime, s.dk_xfer[dn] / etime,
+                    s.dk_seek[dn] ? itime * 1000. / s.dk_seek[dn] : 0.0);
+                return (row);
+        }
+        wmove(wnd, row++, col);
+        histogram(words / 512 / etime, 50, 1.0);
+        wmove(wnd, row++, col);
+        histogram(s.dk_xfer[dn] / etime, 50, 1.0);
+        if (msps) {
+                wmove(wnd, row++, col);
+                histogram(s.dk_seek[dn] ? itime * 1000. / s.dk_seek[dn] : 0,
+                   50, 1.0);
+        }
+        return (row);
 }
 
 }
 
-#define steal(where, var) \
-       lseek(kmem, where, L_SET); read(kmem, &var, sizeof var);
+static
+stat1(row, o)
+        int row, o;
+{
+        register i;
+        double time;
 
 
-#ifdef vax
-read_names()
+        time = 0;
+        for (i = 0; i < CPUSTATES; i++)
+                time += s.cp_time[i];
+        if (time == 0.0)
+                time = 1.0;
+        wmove(wnd, row, INSET);
+#define CPUSCALE        0.5
+        histogram(100 * s.cp_time[o] / time, 50, CPUSCALE);
+}
+
+histogram(val, colwidth, scale)
+        double val;
+        int colwidth;
+        double scale;
 {
 {
-       struct mba_device mdev;
-       register struct mba_device *mp;
-       struct mba_driver mdrv;
-       short two_char;
-       char *cp = (char *) &two_char;
-       struct uba_device udev, *up;
-       struct uba_driver udrv;
+        char buf[10];
+        register int k;
+        register int v = (int)(val * scale) + 0.5;
 
 
-       mp = (struct mba_device *) nlst[X_MBDINIT].n_value;
-       up = (struct uba_device *) nlst[X_UBDINIT].n_value;
-       if (up == 0) {
-               error("Disk init info not in namelist\n");
-               return;
-       }
-       if (mp) for (;;) {
-               steal(mp++, mdev);
-               if (mdev.mi_driver == 0)
-                       break;
-               if (mdev.mi_dk < 0 || mdev.mi_alive == 0)
-                       continue;
-               steal(mdev.mi_driver, mdrv);
-               steal(mdrv.md_dname, two_char);
-               sprintf(dr_name[mdev.mi_dk], "%c%c%d",
-                   cp[0], cp[1], mdev.mi_unit);
-       }
-       if (up) for (;;) {
-               steal(up++, udev);
-               if (udev.ui_driver == 0)
-                       break;
-               if (udev.ui_dk < 0 || udev.ui_alive == 0)
-                       continue;
-               steal(udev.ui_driver, udrv);
-               steal(udrv.ud_dname, two_char);
-               sprintf(dr_name[udev.ui_dk], "%c%c%d",
-                   cp[0], cp[1], udev.ui_unit);
-       }
+        k = MIN(v, colwidth);
+        if (v > colwidth) {
+                sprintf(buf, "%4.1f", val);
+                k -= strlen(buf);
+                while (k--)
+                        waddch(wnd, 'X');
+                waddstr(wnd, buf);
+                return;
+        }
+        while (k--)
+                waddch(wnd, 'X');
+        wclrtoeol(wnd);
 }
 }
-#endif
 
 
-#ifdef sun
-read_names()
+cmdiostat(cmd, args)
+        char *cmd, *args;
 {
 {
-       struct mb_device mdev;
-       register struct mb_device *mp;
-       struct mb_driver mdrv;
-       short two_char;
-       char *cp = (char *) &two_char;
 
 
-       mp = (struct mb_device *) nlst[X_MBDINIT].n_value;
-       if (mp == 0) {
-               error("Disk init info not in namelist\n");
-               return;
-       }
-       for (;;) {
-               steal(mp++, mdev);
-               if (mdev.md_driver == 0)
-                       break;
-               if (mdev.md_dk < 0 || mdev.md_alive == 0)
-                       continue;
-               steal(mdev.md_driver, mdrv);
-               steal(mdrv.mdr_dname, two_char);
-               sprintf(dr_name[mdev.md_dk], "%c%c%d",
-                   cp[0], cp[1], mdev.md_unit);
-       }
+        if (prefix(cmd, "msps"))
+                msps = !msps;
+       else if (prefix(cmd, "numbers"))
+                numbers = 1;
+       else if (prefix(cmd, "bars"))
+                numbers = 0;
+       else if (!dkcmd(cmd, args))
+               return (0);
+        wclear(wnd);
+        labeliostat();
+        refresh();
+        return (1);
 }
 }
-#endif
Continuous source code history from original PDP-7 UNIX to FreeBSD 2, the first fully unencumbered FreeBSD release.