![[BACK]](/cvsweb/icons/back.gif){kind=icon}
Return to iostat.c CVS log ![[TXT]](/cvsweb/icons/text.gif){kind=icon}
![[DIR]](/cvsweb/icons/dir.gif){kind=icon}
Up to [CSRG BSD Unix] / 43BSDTahoe / ucb / systat|
Return to iostat.c CVS log | Up to [CSRG BSD Unix] / 43BSDTahoe / ucb / systat |
1.1 root 1: /*
2: * Copyright (c) 1980 Regents of the University of California.
3: * All rights reserved. The Berkeley software License Agreement
4: * specifies the terms and conditions for redistribution.
5: */
6:
7: #ifndef lint
8: static char sccsid[] = "@(#)iostat.c 5.3 (Berkeley) 1/12/86";
9: #endif not lint
10:
11: /*
12: * iostat
13: */
14: #include "systat.h"
15: #include <sys/buf.h>
16:
17: WINDOW *
18: openiostat()
19: {
20:
21: return (subwin(stdscr, LINES-1-5, 0, 5, 0));
22: }
23:
24: closeiostat(w)
25: WINDOW *w;
26: {
27:
28: if (w == NULL)
29: return;
30: wclear(w);
31: wrefresh(w);
32: delwin(w);
33: }
34:
35: static struct nlist nlst[] = {
36: #define X_DK_BUSY 0
37: { "_dk_busy" },
38: #define X_DK_TIME 1
39: { "_dk_time" },
40: #define X_DK_XFER 2
41: { "_dk_xfer" },
42: #define X_DK_WDS 3
43: { "_dk_wds" },
44: #define X_DK_SEEK 4
45: { "_dk_seek" },
46: #define X_CP_TIME 5
47: { "_cp_time" },
48: #ifdef vax
49: #define X_MBDINIT (X_CP_TIME+1)
50: { "_mbdinit" },
51: #define X_UBDINIT (X_CP_TIME+2)
52: { "_ubdinit" },
53: #endif
54: #ifdef tahoe
55: #define X_VBDINIT (X_CP_TIME+1)
56: { "_vbdinit" },
57: #endif
58: { "" },
59: };
60:
61: static struct {
62: int dk_busy;
63: long cp_time[CPUSTATES];
64: long *dk_time;
65: long *dk_wds;
66: long *dk_seek;
67: long *dk_xfer;
68: } s, s1;
69:
70: static int linesperregion;
71: static double etime;
72: static int numbers = 0; /* default display bar graphs */
73: static int msps = 0; /* default ms/seek shown */
74:
75: initiostat()
76: {
77:
78: if (nlst[X_DK_BUSY].n_type == 0) {
79: nlist("/vmunix", nlst);
80: if (nlst[X_DK_BUSY].n_type == 0) {
81: error("Disk init information isn't in namelist");
82: return(0);
83: }
84: }
85: if (! dkinit())
86: return(0);
87: if (dk_ndrive) {
88: #define allocate(e, t) \
89: s./**/e = (t *)calloc(dk_ndrive, sizeof (t)); \
90: s1./**/e = (t *)calloc(dk_ndrive, sizeof (t));
91: allocate(dk_time, long);
92: allocate(dk_wds, long);
93: allocate(dk_seek, long);
94: allocate(dk_xfer, long);
95: #undef allocate
96: }
97: return(1);
98: }
99:
100: fetchiostat()
101: {
102:
103: if (nlst[X_DK_BUSY].n_type == 0)
104: return;
105: s.dk_busy = getw(nlst[X_DK_BUSY].n_value);
106: lseek(kmem, (long)nlst[X_DK_TIME].n_value, L_SET);
107: read(kmem, s.dk_time, dk_ndrive * sizeof (long));
108: lseek(kmem, (long)nlst[X_DK_XFER].n_value, L_SET);
109: read(kmem, s.dk_xfer, dk_ndrive * sizeof (long));
110: lseek(kmem, (long)nlst[X_DK_WDS].n_value, L_SET);
111: read(kmem, s.dk_wds, dk_ndrive * sizeof (long));
112: lseek(kmem, (long)nlst[X_DK_SEEK].n_value, L_SET);
113: read(kmem, s.dk_seek, dk_ndrive * sizeof (long));
114: lseek(kmem, (long)nlst[X_CP_TIME].n_value, L_SET);
115: read(kmem, s.cp_time, sizeof s.cp_time);
116: }
117:
118: #define INSET 10
119:
120: labeliostat()
121: {
122: int row;
123:
124: if (nlst[X_DK_BUSY].n_type == 0) {
125: error("No dk_busy defined.");
126: return;
127: }
128: row = 0;
129: wmove(wnd, row, 0); wclrtobot(wnd);
130: mvwaddstr(wnd, row++, INSET,
131: "/0 /10 /20 /30 /40 /50 /60 /70 /80 /90 /100");
132: mvwaddstr(wnd, row++, 0, "cpu user|");
133: mvwaddstr(wnd, row++, 0, " nice|");
134: mvwaddstr(wnd, row++, 0, " system|");
135: mvwaddstr(wnd, row++, 0, " idle|");
136: if (numbers)
137: row = numlabels(row + 1);
138: else
139: row = barlabels(row + 1);
140: }
141:
142: static
143: numlabels(row)
144: {
145: int i, col, regions, ndrives;
146:
147: #define COLWIDTH 14
148: #define DRIVESPERLINE ((wnd->_maxx - INSET) / COLWIDTH)
149: for (ndrives = 0, i = 0; i < dk_ndrive; i++)
150: if (dk_select[i])
151: ndrives++;
152: regions = howmany(ndrives, DRIVESPERLINE);
153: /*
154: * Deduct -regions for blank line after each scrolling region.
155: */
156: linesperregion = (wnd->_maxy - row - regions) / regions;
157: /*
158: * Minimum region contains space for two
159: * label lines and one line of statistics.
160: */
161: if (linesperregion < 3)
162: linesperregion = 3;
163: col = 0;
164: for (i = 0; i < dk_ndrive; i++)
165: if (dk_select[i] && dk_mspw[i] != 0.0) {
166: if (col + COLWIDTH >= wnd->_maxx - INSET) {
167: col = 0, row += linesperregion + 1;
168: if (row > wnd->_maxy - (linesperregion + 1))
169: break;
170: }
171: mvwaddstr(wnd, row, col + 4, dr_name[i]);
172: mvwaddstr(wnd, row + 1, col, "bps tps msps");
173: col += COLWIDTH;
174: }
175: if (col)
176: row += linesperregion + 1;
177: return (row);
178: }
179:
180: static
181: barlabels(row)
182: int row;
183: {
184: int i;
185:
186: mvwaddstr(wnd, row++, INSET,
187: "/0 /5 /10 /15 /20 /25 /30 /35 /40 /45 /50");
188: linesperregion = 2 + msps;
189: for (i = 0; i < dk_ndrive; i++)
190: if (dk_select[i] && dk_mspw[i] != 0.0) {
191: if (row > wnd->_maxy - linesperregion)
192: break;
193: mvwprintw(wnd, row++, 0, "%3.3s bps|", dr_name[i]);
194: mvwaddstr(wnd, row++, 0, " tps|");
195: if (msps)
196: mvwaddstr(wnd, row++, 0, " msps|");
197: }
198: return (row);
199: }
200:
201: showiostat()
202: {
203: register int i, row, col;
204: register long t;
205:
206: if (nlst[X_DK_BUSY].n_type == 0)
207: return;
208: for (i = 0; i < dk_ndrive; i++) {
209: #define X(fld) t = s.fld[i]; s.fld[i] -= s1.fld[i]; s1.fld[i] = t
210: X(dk_xfer); X(dk_seek); X(dk_wds); X(dk_time);
211: }
212: etime = 0;
213: for(i = 0; i < CPUSTATES; i++) {
214: X(cp_time);
215: etime += s.cp_time[i];
216: }
217: if (etime == 0.0)
218: etime = 1.0;
219: etime /= (float) hz;
220: row = 1;
221: for (i = 0; i < CPUSTATES; i++)
222: stat1(row++, i);
223: if (!numbers) {
224: row += 2;
225: for (i = 0; i < dk_ndrive; i++)
226: if (dk_select[i] && dk_mspw[i] != 0.0) {
227: if (row > wnd->_maxy - linesperregion)
228: break;
229: row = stats(row, INSET, i);
230: }
231: return;
232: }
233: col = 0;
234: wmove(wnd, row + linesperregion, 0);
235: wdeleteln(wnd);
236: wmove(wnd, row + 3, 0);
237: winsertln(wnd);
238: for (i = 0; i < dk_ndrive; i++)
239: if (dk_select[i] && dk_mspw[i] != 0.0) {
240: if (col + COLWIDTH >= wnd->_maxx) {
241: col = 0, row += linesperregion + 1;
242: if (row > wnd->_maxy - (linesperregion + 1))
243: break;
244: wmove(wnd, row + linesperregion, 0);
245: wdeleteln(wnd);
246: wmove(wnd, row + 3, 0);
247: winsertln(wnd);
248: }
249: (void) stats(row + 3, col, i);
250: col += COLWIDTH;
251: }
252: }
253:
254: static
255: stats(row, col, dn)
256: int row, dn;
257: {
258: double atime, words, xtime, itime;
259:
260: atime = s.dk_time[dn];
261: atime /= (float) hz;
262: words = s.dk_wds[dn]*32.0; /* number of words transferred */
263: xtime = dk_mspw[dn]*words; /* transfer time */
264: itime = atime - xtime; /* time not transferring */
265: if (xtime < 0)
266: itime += xtime, xtime = 0;
267: if (itime < 0)
268: xtime += itime, itime = 0;
269: if (numbers) {
270: mvwprintw(wnd, row, col, "%3.0f%4.0f%5.1f",
271: words / 512 / etime, s.dk_xfer[dn] / etime,
272: s.dk_seek[dn] ? itime * 1000. / s.dk_seek[dn] : 0.0);
273: return (row);
274: }
275: wmove(wnd, row++, col);
276: histogram(words / 512 / etime, 50, 1.0);
277: wmove(wnd, row++, col);
278: histogram(s.dk_xfer[dn] / etime, 50, 1.0);
279: if (msps) {
280: wmove(wnd, row++, col);
281: histogram(s.dk_seek[dn] ? itime * 1000. / s.dk_seek[dn] : 0,
282: 50, 1.0);
283: }
284: return (row);
285: }
286:
287: static
288: stat1(row, o)
289: int row, o;
290: {
291: register i;
292: double time;
293:
294: time = 0;
295: for (i = 0; i < CPUSTATES; i++)
296: time += s.cp_time[i];
297: if (time == 0.0)
298: time = 1.0;
299: wmove(wnd, row, INSET);
300: #define CPUSCALE 0.5
301: histogram(100 * s.cp_time[o] / time, 50, CPUSCALE);
302: }
303:
304: histogram(val, colwidth, scale)
305: double val;
306: int colwidth;
307: double scale;
308: {
309: char buf[10];
310: register int k;
311: register int v = (int)(val * scale) + 0.5;
312:
313: k = MIN(v, colwidth);
314: if (v > colwidth) {
315: sprintf(buf, "%4.1f", val);
316: k -= strlen(buf);
317: while (k--)
318: waddch(wnd, 'X');
319: waddstr(wnd, buf);
320: return;
321: }
322: while (k--)
323: waddch(wnd, 'X');
324: wclrtoeol(wnd);
325: }
326:
327: cmdiostat(cmd, args)
328: char *cmd, *args;
329: {
330:
331: if (prefix(cmd, "msps"))
332: msps = !msps;
333: else if (prefix(cmd, "numbers"))
334: numbers = 1;
335: else if (prefix(cmd, "bars"))
336: numbers = 0;
337: else if (!dkcmd(cmd, args))
338: return (0);
339: wclear(wnd);
340: labeliostat();
341: refresh();
342: return (1);
343: }
This archive runs on limited infrastructure. Preserving old code on modern bandwidth. Automated agents are requested to crawl responsibly.