iostat.c revision 1.1 
1/*	$NetBSD: iostat.c,v 1.3 1995/05/17 15:51:47 mycroft Exp $	*/
2
3/*
4 * Copyright (c) 1980, 1992, 1993
5 *	The Regents of the University of California.  All rights reserved.
6 *
7 * Redistribution and use in source and binary forms, with or without
8 * modification, are permitted provided that the following conditions
9 * are met:
10 * 1. Redistributions of source code must retain the above copyright
11 *    notice, this list of conditions and the following disclaimer.
12 * 2. Redistributions in binary form must reproduce the above copyright
13 *    notice, this list of conditions and the following disclaimer in the
14 *    documentation and/or other materials provided with the distribution.
15 * 3. All advertising materials mentioning features or use of this software
16 *    must display the following acknowledgement:
17 *	This product includes software developed by the University of
18 *	California, Berkeley and its contributors.
19 * 4. Neither the name of the University nor the names of its contributors
20 *    may be used to endorse or promote products derived from this software
21 *    without specific prior written permission.
22 *
23 * THIS SOFTWARE IS PROVIDED BY THE REGENTS AND CONTRIBUTORS ``AS IS'' AND
24 * ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
25 * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE
26 * ARE DISCLAIMED.  IN NO EVENT SHALL THE REGENTS OR CONTRIBUTORS BE LIABLE
27 * FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL
28 * DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS
29 * OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION)
30 * HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT
31 * LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY
32 * OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF
33 * SUCH DAMAGE.
34 */
35
36#ifndef lint
37#if 0
38static char sccsid[] = "@(#)iostat.c	8.1 (Berkeley) 6/6/93";
39#endif
40static char rcsid[] = "$NetBSD: iostat.c,v 1.3 1995/05/17 15:51:47 mycroft Exp $";
41#endif not lint
42
43#include <sys/param.h>
44#include <sys/dkstat.h>
45#include <sys/buf.h>
46
47#include <string.h>
48#include <stdlib.h>
49#include <nlist.h>
50#include <paths.h>
51#include "systat.h"
52#include "extern.h"
53
54static struct nlist namelist[] = {
55#define X_DK_BUSY	0
56	{ "_dk_busy" },
57#define X_DK_TIME	1
58	{ "_dk_time" },
59#define X_DK_XFER	2
60	{ "_dk_xfer" },
61#define X_DK_WDS	3
62	{ "_dk_wds" },
63#define X_DK_SEEK	4
64	{ "_dk_seek" },
65#define X_CP_TIME	5
66	{ "_cp_time" },
67#ifdef vax
68#define X_MBDINIT	(X_CP_TIME+1)
69	{ "_mbdinit" },
70#define X_UBDINIT	(X_CP_TIME+2)
71	{ "_ubdinit" },
72#endif
73#ifdef tahoe
74#define	X_VBDINIT	(X_CP_TIME+1)
75	{ "_vbdinit" },
76#endif
77	{ "" },
78};
79
80static struct {
81	int	dk_busy;
82	long	cp_time[CPUSTATES];
83	long	*dk_time;
84	long	*dk_wds;
85	long	*dk_seek;
86	long	*dk_xfer;
87} s, s1;
88
89static  int linesperregion;
90static  double etime;
91static  int numbers = 0;		/* default display bar graphs */
92static  int msps = 0;			/* default ms/seek shown */
93
94static int barlabels __P((int));
95static void histogram __P((double, int, double));
96static int numlabels __P((int));
97static int stats __P((int, int, int));
98static void stat1 __P((int, int));
99
100
101WINDOW *
102openiostat()
103{
104	return (subwin(stdscr, LINES-1-5, 0, 5, 0));
105}
106
107void
108closeiostat(w)
109	WINDOW *w;
110{
111	if (w == NULL)
112		return;
113	wclear(w);
114	wrefresh(w);
115	delwin(w);
116}
117
118int
119initiostat()
120{
121	if (namelist[X_DK_BUSY].n_type == 0) {
122		if (kvm_nlist(kd, namelist)) {
123			nlisterr(namelist);
124			return(0);
125		}
126		if (namelist[X_DK_BUSY].n_type == 0) {
127			error("Disk init information isn't in namelist");
128			return(0);
129		}
130	}
131	if (! dkinit())
132		return(0);
133	if (dk_ndrive) {
134#define	allocate(e, t) \
135    s./**/e = (t *)calloc(dk_ndrive, sizeof (t)); \
136    s1./**/e = (t *)calloc(dk_ndrive, sizeof (t));
137		allocate(dk_time, long);
138		allocate(dk_wds, long);
139		allocate(dk_seek, long);
140		allocate(dk_xfer, long);
141#undef allocate
142	}
143	return(1);
144}
145
146void
147fetchiostat()
148{
149	if (namelist[X_DK_BUSY].n_type == 0)
150		return;
151	NREAD(X_DK_BUSY, &s.dk_busy, LONG);
152	NREAD(X_DK_TIME, s.dk_time, dk_ndrive * LONG);
153	NREAD(X_DK_XFER, s.dk_xfer, dk_ndrive * LONG);
154	NREAD(X_DK_WDS, s.dk_wds, dk_ndrive * LONG);
155	NREAD(X_DK_SEEK, s.dk_seek, dk_ndrive * LONG);
156	NREAD(X_CP_TIME, s.cp_time, sizeof s.cp_time);
157}
158
159#define	INSET	10
160
161void
162labeliostat()
163{
164	int row;
165
166	if (namelist[X_DK_BUSY].n_type == 0) {
167		error("No dk_busy defined.");
168		return;
169	}
170	row = 0;
171	wmove(wnd, row, 0); wclrtobot(wnd);
172	mvwaddstr(wnd, row++, INSET,
173	    "/0   /10  /20  /30  /40  /50  /60  /70  /80  /90  /100");
174	mvwaddstr(wnd, row++, 0, "cpu  user|");
175	mvwaddstr(wnd, row++, 0, "     nice|");
176	mvwaddstr(wnd, row++, 0, "   system|");
177	mvwaddstr(wnd, row++, 0, "interrupt|");
178	mvwaddstr(wnd, row++, 0, "     idle|");
179	if (numbers)
180		row = numlabels(row + 1);
181	else
182		row = barlabels(row + 1);
183}
184
185static int
186numlabels(row)
187	int row;
188{
189	int i, col, regions, ndrives;
190
191#define COLWIDTH	14
192#define DRIVESPERLINE	((wnd->maxx - INSET) / COLWIDTH)
193	for (ndrives = 0, i = 0; i < dk_ndrive; i++)
194		if (dk_select[i])
195			ndrives++;
196	regions = howmany(ndrives, DRIVESPERLINE);
197	/*
198	 * Deduct -regions for blank line after each scrolling region.
199	 */
200	linesperregion = (wnd->maxy - row - regions) / regions;
201	/*
202	 * Minimum region contains space for two
203	 * label lines and one line of statistics.
204	 */
205	if (linesperregion < 3)
206		linesperregion = 3;
207	col = 0;
208	for (i = 0; i < dk_ndrive; i++)
209		if (dk_select[i] && dk_mspw[i] != 0.0) {
210			if (col + COLWIDTH >= wnd->maxx - INSET) {
211				col = 0, row += linesperregion + 1;
212				if (row > wnd->maxy - (linesperregion + 1))
213					break;
214			}
215			mvwaddstr(wnd, row, col + 4, dr_name[i]);
216			mvwaddstr(wnd, row + 1, col, "bps tps msps");
217			col += COLWIDTH;
218		}
219	if (col)
220		row += linesperregion + 1;
221	return (row);
222}
223
224static int
225barlabels(row)
226	int row;
227{
228	int i;
229
230	mvwaddstr(wnd, row++, INSET,
231	    "/0   /5   /10  /15  /20  /25  /30  /35  /40  /45  /50");
232	linesperregion = 2 + msps;
233	for (i = 0; i < dk_ndrive; i++)
234		if (dk_select[i] && dk_mspw[i] != 0.0) {
235			if (row > wnd->maxy - linesperregion)
236				break;
237			mvwprintw(wnd, row++, 0, "%3.3s   bps|", dr_name[i]);
238			mvwaddstr(wnd, row++, 0, "      tps|");
239			if (msps)
240				mvwaddstr(wnd, row++, 0, "     msps|");
241		}
242	return (row);
243}
244
245
246void
247showiostat()
248{
249	register long t;
250	register int i, row, col;
251
252	if (namelist[X_DK_BUSY].n_type == 0)
253		return;
254	for (i = 0; i < dk_ndrive; i++) {
255#define X(fld)	t = s.fld[i]; s.fld[i] -= s1.fld[i]; s1.fld[i] = t
256		X(dk_xfer); X(dk_seek); X(dk_wds); X(dk_time);
257	}
258	etime = 0;
259	for(i = 0; i < CPUSTATES; i++) {
260		X(cp_time);
261		etime += s.cp_time[i];
262	}
263	if (etime == 0.0)
264		etime = 1.0;
265	etime /= (float) hz;
266	row = 1;
267
268	/*
269	 * Interrupt CPU state not calculated yet.
270	 */
271	for (i = 0; i < CPUSTATES; i++)
272		stat1(row++, i);
273	if (!numbers) {
274		row += 2;
275		for (i = 0; i < dk_ndrive; i++)
276			if (dk_select[i] && dk_mspw[i] != 0.0) {
277				if (row > wnd->maxy - linesperregion)
278					break;
279				row = stats(row, INSET, i);
280			}
281		return;
282	}
283	col = 0;
284	wmove(wnd, row + linesperregion, 0);
285	wdeleteln(wnd);
286	wmove(wnd, row + 3, 0);
287	winsertln(wnd);
288	for (i = 0; i < dk_ndrive; i++)
289		if (dk_select[i] && dk_mspw[i] != 0.0) {
290			if (col + COLWIDTH >= wnd->maxx) {
291				col = 0, row += linesperregion + 1;
292				if (row > wnd->maxy - (linesperregion + 1))
293					break;
294				wmove(wnd, row + linesperregion, 0);
295				wdeleteln(wnd);
296				wmove(wnd, row + 3, 0);
297				winsertln(wnd);
298			}
299			(void) stats(row + 3, col, i);
300			col += COLWIDTH;
301		}
302}
303
304static int
305stats(row, col, dn)
306	int row, col, dn;
307{
308	double atime, words, xtime, itime;
309
310	atime = s.dk_time[dn];
311	atime /= (float) hz;
312	words = s.dk_wds[dn]*32.0;	/* number of words transferred */
313	xtime = dk_mspw[dn]*words;	/* transfer time */
314	itime = atime - xtime;		/* time not transferring */
315	if (xtime < 0)
316		itime += xtime, xtime = 0;
317	if (itime < 0)
318		xtime += itime, itime = 0;
319	if (numbers) {
320		mvwprintw(wnd, row, col, "%3.0f%4.0f%5.1f",
321		    words / 512 / etime, s.dk_xfer[dn] / etime,
322		    s.dk_seek[dn] ? itime * 1000. / s.dk_seek[dn] : 0.0);
323		return (row);
324	}
325	wmove(wnd, row++, col);
326	histogram(words / 512 / etime, 50, 1.0);
327	wmove(wnd, row++, col);
328	histogram(s.dk_xfer[dn] / etime, 50, 1.0);
329	if (msps) {
330		wmove(wnd, row++, col);
331		histogram(s.dk_seek[dn] ? itime * 1000. / s.dk_seek[dn] : 0,
332		   50, 1.0);
333	}
334	return (row);
335}
336
337static void
338stat1(row, o)
339	int row, o;
340{
341	register int i;
342	double time;
343
344	time = 0;
345	for (i = 0; i < CPUSTATES; i++)
346		time += s.cp_time[i];
347	if (time == 0.0)
348		time = 1.0;
349	wmove(wnd, row, INSET);
350#define CPUSCALE	0.5
351	histogram(100.0 * s.cp_time[o] / time, 50, CPUSCALE);
352}
353
354static void
355histogram(val, colwidth, scale)
356	double val;
357	int colwidth;
358	double scale;
359{
360	char buf[10];
361	register int k;
362	register int v = (int)(val * scale) + 0.5;
363
364	k = MIN(v, colwidth);
365	if (v > colwidth) {
366		sprintf(buf, "%4.1f", val);
367		k -= strlen(buf);
368		while (k--)
369			waddch(wnd, 'X');
370		waddstr(wnd, buf);
371		return;
372	}
373	while (k--)
374		waddch(wnd, 'X');
375	wclrtoeol(wnd);
376}
377
378int
379cmdiostat(cmd, args)
380	char *cmd, *args;
381{
382
383	if (prefix(cmd, "msps"))
384		msps = !msps;
385	else if (prefix(cmd, "numbers"))
386		numbers = 1;
387	else if (prefix(cmd, "bars"))
388		numbers = 0;
389	else if (!dkcmd(cmd, args))
390		return (0);
391	wclear(wnd);
392	labeliostat();
393	refresh();
394	return (1);
395}
396