xref: /netbsd/usr.bin/systat/iostat.c (revision bf9ec67e)
1 /*	$NetBSD: iostat.c,v 1.19 2002/01/28 13:20:43 augustss 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 #include <sys/cdefs.h>
37 #ifndef lint
38 #if 0
39 static char sccsid[] = "@(#)iostat.c	8.1 (Berkeley) 6/6/93";
40 #endif
41 __RCSID("$NetBSD: iostat.c,v 1.19 2002/01/28 13:20:43 augustss Exp $");
42 #endif /* not lint */
43 
44 #include <sys/param.h>
45 
46 #include <string.h>
47 
48 #include "systat.h"
49 #include "extern.h"
50 #include "dkstats.h"
51 
52 static  int linesperregion;
53 static  double etime;
54 static  int numbers = 0;		/* default display bar graphs */
55 static  int secs = 0;			/* default seconds shown */
56 
57 static int barlabels(int);
58 static void histogram(double, int, double);
59 static int numlabels(int);
60 static int stats(int, int, int);
61 static void stat1(int, int);
62 
63 
64 WINDOW *
65 openiostat(void)
66 {
67 
68 	return (subwin(stdscr, LINES-1-5, 0, 5, 0));
69 }
70 
71 void
72 closeiostat(WINDOW *w)
73 {
74 
75 	if (w == NULL)
76 		return;
77 	wclear(w);
78 	wrefresh(w);
79 	delwin(w);
80 }
81 
82 int
83 initiostat(void)
84 {
85 
86 	dkinit(1);
87 	dkreadstats();
88 	return(1);
89 }
90 
91 void
92 fetchiostat(void)
93 {
94 
95 	if (dk_ndrive == 0)
96 		return;
97 	dkreadstats();
98 }
99 
100 #define	INSET	14
101 
102 void
103 labeliostat(void)
104 {
105 	int row;
106 
107 	if (dk_ndrive == 0) {
108 		error("No drives defined.");
109 		return;
110 	}
111 	row = 0;
112 	wmove(wnd, row, 0); wclrtobot(wnd);
113 	mvwaddstr(wnd, row++, INSET,
114 	    "/0   /10  /20  /30  /40  /50  /60  /70  /80  /90  /100");
115 	mvwaddstr(wnd, row++, 0, "    cpu  user|");
116 	mvwaddstr(wnd, row++, 0, "         nice|");
117 	mvwaddstr(wnd, row++, 0, "       system|");
118 	mvwaddstr(wnd, row++, 0, "    interrupt|");
119 	mvwaddstr(wnd, row++, 0, "         idle|");
120 	if (numbers)
121 		row = numlabels(row + 1);
122 	else
123 		row = barlabels(row + 1);
124 }
125 
126 static int
127 numlabels(int row)
128 {
129 	int i, col, regions, ndrives;
130 
131 #define COLWIDTH	14
132 #define DRIVESPERLINE	((getmaxx(wnd) - INSET) / COLWIDTH)
133 	for (ndrives = 0, i = 0; i < dk_ndrive; i++)
134 		if (cur.dk_select[i])
135 			ndrives++;
136 	regions = howmany(ndrives, DRIVESPERLINE);
137 	/*
138 	 * Deduct -regions for blank line after each scrolling region.
139 	 */
140 	linesperregion = (getmaxy(wnd) - row - regions) / regions;
141 	/*
142 	 * Minimum region contains space for two
143 	 * label lines and one line of statistics.
144 	 */
145 	if (linesperregion < 3)
146 		linesperregion = 3;
147 	col = 0;
148 	for (i = 0; i < dk_ndrive; i++)
149 		if (cur.dk_select[i] /*&& cur.dk_bytes[i] != 0.0*/) {
150 			if (col + COLWIDTH >= getmaxx(wnd) - INSET) {
151 				col = 0, row += linesperregion + 1;
152 				if (row > getmaxy(wnd) - (linesperregion + 1))
153 					break;
154 			}
155 			mvwaddstr(wnd, row, col + 4, cur.dk_name[i]);
156 			mvwaddstr(wnd, row + 1, col, "KBps tps  sec");
157 			col += COLWIDTH;
158 		}
159 	if (col)
160 		row += linesperregion + 1;
161 	return (row);
162 }
163 
164 static int
165 barlabels(int row)
166 {
167 	int i;
168 
169 	mvwaddstr(wnd, row++, INSET,
170 	    "/0   /10  /20  /30  /40  /50  /60  /70  /80  /90  /100");
171 	linesperregion = 2 + secs;
172 	for (i = 0; i < dk_ndrive; i++)
173 		if (cur.dk_select[i] /*&& cur.dk_bytes[i] != 0.0*/) {
174 			if (row > getmaxy(wnd) - linesperregion)
175 				break;
176 			mvwprintw(wnd, row++, 0, "%7.7s  KBps|", cur.dk_name[i]);
177 			mvwaddstr(wnd, row++, 0, "          tps|");
178 			if (secs)
179 				mvwaddstr(wnd, row++, 0, "         msec|");
180 		}
181 	return (row);
182 }
183 
184 void
185 showiostat(void)
186 {
187 	int i, row, col;
188 
189 	if (dk_ndrive == 0)
190 		return;
191 	dkswap();
192 
193 	etime = 0;
194 	for(i = 0; i < CPUSTATES; i++) {
195 		etime += cur.cp_time[i];
196 	}
197 	if (etime == 0.0)
198 		etime = 1.0;
199 	etime /= (float) hz;
200 	row = 1;
201 
202 	/*
203 	 * Interrupt CPU state not calculated yet.
204 	 */
205 	for (i = 0; i < CPUSTATES; i++)
206 		stat1(row++, i);
207 	if (!numbers) {
208 		row += 2;
209 		for (i = 0; i < dk_ndrive; i++)
210 			if (cur.dk_select[i] /*&& cur.dk_bytes[i] != 0.0*/) {
211 				if (row > getmaxy(wnd) - linesperregion)
212 					break;
213 				row = stats(row, INSET, i);
214 			}
215 		return;
216 	}
217 	col = 0;
218 	wmove(wnd, row + linesperregion, 0);
219 	wdeleteln(wnd);
220 	wmove(wnd, row + 3, 0);
221 	winsertln(wnd);
222 	for (i = 0; i < dk_ndrive; i++)
223 		if (cur.dk_select[i] /*&& cur.dk_bytes[i] != 0.0*/) {
224 			if (col + COLWIDTH >= getmaxx(wnd)) {
225 				col = 0, row += linesperregion + 1;
226 				if (row > getmaxy(wnd) - (linesperregion + 1))
227 					break;
228 				wmove(wnd, row + linesperregion, 0);
229 				wdeleteln(wnd);
230 				wmove(wnd, row + 3, 0);
231 				winsertln(wnd);
232 			}
233 			(void) stats(row + 3, col, i);
234 			col += COLWIDTH;
235 		}
236 }
237 
238 static int
239 stats(int row, int col, int dn)
240 {
241 	double atime, words;
242 
243 	/* time busy in disk activity */
244 	atime = (double)cur.dk_time[dn].tv_sec +
245 		((double)cur.dk_time[dn].tv_usec / (double)1000000);
246 
247 	words = cur.dk_bytes[dn] / 1024.0;	/* # of K transferred */
248 	if (numbers) {
249 		mvwprintw(wnd, row, col, " %3.0f%4.0f%5.1f",
250 		    words / etime, cur.dk_xfer[dn] / etime, atime / etime);
251 		return (row);
252 	}
253 	wmove(wnd, row++, col);
254 	histogram(words / etime, 50, 0.5);
255 	wmove(wnd, row++, col);
256 	histogram(cur.dk_xfer[dn] / etime, 50, 0.5);
257 	if (secs) {
258 		wmove(wnd, row++, col);
259 		atime *= 1000;	/* In milliseconds */
260 		histogram(atime / etime, 50, 0.5);
261 	}
262 	return (row);
263 }
264 
265 static void
266 stat1(int row, int o)
267 {
268 	int i;
269 	double time;
270 
271 	time = 0;
272 	for (i = 0; i < CPUSTATES; i++)
273 		time += cur.cp_time[i];
274 	if (time == 0.0)
275 		time = 1.0;
276 	wmove(wnd, row, INSET);
277 #define CPUSCALE	0.5
278 	histogram(100.0 * cur.cp_time[o] / time, 50, CPUSCALE);
279 }
280 
281 static void
282 histogram(double val, int colwidth, double scale)
283 {
284 	char buf[10];
285 	int k;
286 	int v = (int)(val * scale) + 0.5;
287 
288 	k = MIN(v, colwidth);
289 	if (v > colwidth) {
290 		snprintf(buf, sizeof buf, "%4.1f", val);
291 		k -= strlen(buf);
292 		while (k--)
293 			waddch(wnd, 'X');
294 		waddstr(wnd, buf);
295 		wclrtoeol(wnd);
296 		return;
297 	}
298 	wclrtoeol(wnd);
299 	whline(wnd, 'X', k);
300 }
301 
302 void
303 iostat_bars(char *args)
304 {
305 	numbers = 0;
306 	wclear(wnd);
307 	labeliostat();
308 	refresh();
309 }
310 
311 void
312 iostat_numbers(char *args)
313 {
314 	numbers = 1;
315 	wclear(wnd);
316 	labeliostat();
317 	refresh();
318 }
319 
320 void
321 iostat_secs(char *args)
322 {
323 	secs = !secs;
324 	wclear(wnd);
325 	labeliostat();
326 	refresh();
327 }
328