1 /* $NetBSD: iostat.c,v 1.39 2019/01/25 15:31:11 christos 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. Neither the name of the University nor the names of its contributors
16 * may be used to endorse or promote products derived from this software
17 * without specific prior written permission.
18 *
19 * THIS SOFTWARE IS PROVIDED BY THE REGENTS AND CONTRIBUTORS ``AS IS'' AND
20 * ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
21 * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE
22 * ARE DISCLAIMED. IN NO EVENT SHALL THE REGENTS OR CONTRIBUTORS BE LIABLE
23 * FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL
24 * DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS
25 * OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION)
26 * HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT
27 * LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY
28 * OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF
29 * SUCH DAMAGE.
30 */
31
32 #include <sys/cdefs.h>
33 #ifndef lint
34 #if 0
35 static char sccsid[] = "@(#)iostat.c 8.1 (Berkeley) 6/6/93";
36 #endif
37 __RCSID("$NetBSD: iostat.c,v 1.39 2019/01/25 15:31:11 christos Exp $");
38 #endif /* not lint */
39
40 #include <sys/param.h>
41
42 #include <string.h>
43
44 #include "systat.h"
45 #include "extern.h"
46 #include "drvstats.h"
47
48 static int linesperregion;
49 static int numbers = 0; /* default display bar graphs */
50 static int secs = 0; /* default seconds shown */
51 static int read_write = 0; /* default read/write shown */
52
53 static int barlabels(int);
54 static void histogram(double, int, double);
55 static int numlabels(int);
56 static int stats(int, int, int);
57 static void stat1(int, int);
58
59
60 WINDOW *
openiostat(void)61 openiostat(void)
62 {
63
64 return (subwin(stdscr, -1, 0, 5, 0));
65 }
66
67 void
closeiostat(WINDOW * w)68 closeiostat(WINDOW *w)
69 {
70
71 if (w == NULL)
72 return;
73 wclear(w);
74 wrefresh(w);
75 delwin(w);
76 }
77
78 int
initiostat(void)79 initiostat(void)
80 {
81
82 drvinit(1);
83 cpureadstats();
84 drvreadstats();
85 return(1);
86 }
87
88 void
fetchiostat(void)89 fetchiostat(void)
90 {
91
92 cpureadstats();
93
94 if (ndrive != 0)
95 drvreadstats();
96 }
97
98 #define INSET 14
99
100 void
labeliostat(void)101 labeliostat(void)
102 {
103 int row;
104
105 if (ndrive == 0) {
106 error("No drives defined.");
107 return;
108 }
109 row = 0;
110 wmove(wnd, row, 0); wclrtobot(wnd);
111 mvwaddstr(wnd, row++, INSET,
112 "/0 /10 /20 /30 /40 /50 /60 /70 /80 /90 /100");
113 mvwaddstr(wnd, row++, 0, " CPU user|");
114 mvwaddstr(wnd, row++, 0, " nice|");
115 mvwaddstr(wnd, row++, 0, " system|");
116 mvwaddstr(wnd, row++, 0, " interrupt|");
117 mvwaddstr(wnd, row++, 0, " idle|");
118 if (numbers)
119 row = numlabels(row + 1);
120 else
121 row = barlabels(row + 1);
122 }
123
124 static int
numlabels(int row)125 numlabels(int row)
126 {
127 int col, regions;
128 size_t i, ndrives;
129
130 #define COLWIDTH (9 + secs * 5 + 1 + read_write * 9 + 1)
131 #define DRIVESPERLINE ((getmaxx(wnd) + 1) / COLWIDTH)
132 for (ndrives = 0, i = 0; i < ndrive; i++)
133 if (cur.select[i])
134 ndrives++;
135
136 regions = howmany(ndrives, DRIVESPERLINE);
137 /*
138 * Deduct -regions for blank line after each scrolling region.
139 */
140 linesperregion = (getmaxy(wnd) - row - regions + 1) / 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 < ndrive; i++)
149 if (cur.select[i]) {
150 if (col + COLWIDTH - 1 > getmaxx(wnd)) {
151 col = 0, row += linesperregion + 1;
152 if (row > getmaxy(wnd) - (linesperregion))
153 break;
154 }
155
156 mvwprintw(wnd, row, col + 5, "%s", cur.name[i]);
157
158 if (read_write)
159 mvwprintw(wnd, row, col + 11 + secs * 5,
160 "(write)");
161 mvwprintw(wnd, row + 1, col, " kBps %s",
162 read_write ? "r/s" : "tps");
163 if (secs)
164 waddstr(wnd, " sec");
165 if (read_write)
166 waddstr(wnd, " kBps w/s");
167 col += COLWIDTH;
168 }
169 if (col)
170 row += linesperregion + 1;
171 return (row);
172 }
173
174 static int
barlabels(int row)175 barlabels(int row)
176 {
177 size_t i;
178
179 mvwaddstr(wnd, row++, INSET,
180 "/0 /10 /20 /30 /40 /50 /60 /70 /80 /90 /100");
181 linesperregion = 2 + secs + (read_write ? 2 : 0);
182 for (i = 0; i < ndrive; i++) {
183 if (cur.select[i]) {
184 if (row > getmaxy(wnd) - linesperregion)
185 break;
186 mvwprintw(wnd, row++, 0, "%7.7s kBps|",
187 cur.name[i]);
188 mvwaddstr(wnd, row++, 0, " tps|");
189 if (read_write) {
190 mvwprintw(wnd, row++, 0, " (write) kBps|");
191 mvwaddstr(wnd, row++, 0, " tps|");
192 }
193 if (secs)
194 mvwaddstr(wnd, row++, 0, " msec|");
195 }
196 }
197
198 return (row);
199 }
200
201 void
showiostat(void)202 showiostat(void)
203 {
204 int row, col;
205 size_t i;
206
207 if (ndrive == 0)
208 return;
209 cpuswap();
210 drvswap();
211
212 etime = cur.cp_etime;
213 row = 1;
214
215 /*
216 * Interrupt CPU state not calculated yet.
217 */
218 for (i = 0; i < CPUSTATES; i++)
219 stat1(row++, i);
220 if (!numbers) {
221 row += 2;
222 for (i = 0; i < ndrive; i++)
223 if (cur.select[i]) {
224 if (row > getmaxy(wnd) - linesperregion)
225 break;
226 row = stats(row, INSET, i);
227 }
228 return;
229 }
230 col = 0;
231 wmove(wnd, row + linesperregion, 0);
232 wdeleteln(wnd);
233 wmove(wnd, row + 3, 0);
234 winsertln(wnd);
235 for (i = 0; i < ndrive; i++)
236 if (cur.select[i]) {
237 if (col + COLWIDTH - 1 > getmaxx(wnd)) {
238 col = 0, row += linesperregion + 1;
239 if (row > getmaxy(wnd) - (linesperregion + 1))
240 break;
241 wmove(wnd, row + linesperregion, 0);
242 wdeleteln(wnd);
243 wmove(wnd, row + 3, 0);
244 winsertln(wnd);
245 }
246 (void) stats(row + 3, col, i);
247 col += COLWIDTH;
248 }
249 }
250
251 static int
stats(int row,int col,int dn)252 stats(int row, int col, int dn)
253 {
254 double atime, dtime, rwords, wwords;
255 uint64_t rxfer;
256
257 /* elapsed time for disk stats */
258 dtime = etime;
259 if (cur.timestamp[dn].tv_sec || cur.timestamp[dn].tv_usec)
260 dtime = (double)cur.timestamp[dn].tv_sec +
261 ((double)cur.timestamp[dn].tv_usec / (double)1000000);
262
263 /* time busy in disk activity */
264 atime = (double)cur.time[dn].tv_sec +
265 ((double)cur.time[dn].tv_usec / (double)1000000);
266
267 /* # of k transferred */
268 rwords = cur.rbytes[dn] / 1024.0;
269 wwords = cur.wbytes[dn] / 1024.0;
270 rxfer = cur.rxfer[dn];
271 if (!read_write) {
272 rwords += wwords;
273 rxfer += cur.wxfer[dn];
274 }
275 if (numbers) {
276 mvwprintw(wnd, row, col, "%5.0f%4.0f",
277 rwords / dtime, rxfer / dtime);
278 if (secs)
279 wprintw(wnd, "%5.1f", atime / dtime);
280 if (read_write)
281 wprintw(wnd, " %5.0f%4.0f",
282 wwords / dtime, cur.wxfer[dn] / dtime);
283 return (row);
284 }
285
286 wmove(wnd, row++, col);
287 histogram(rwords / dtime, 50, 0.5);
288 wmove(wnd, row++, col);
289 histogram(rxfer / dtime, 50, 0.5);
290 if (read_write) {
291 wmove(wnd, row++, col);
292 histogram(wwords / dtime, 50, 0.5);
293 wmove(wnd, row++, col);
294 histogram(cur.wxfer[dn] / dtime, 50, 0.5);
295 }
296
297 if (secs) {
298 wmove(wnd, row++, col);
299 atime *= 1000; /* In milliseconds */
300 histogram(atime / dtime, 50, 0.5);
301 }
302 return (row);
303 }
304
305 static void
stat1(int row,int o)306 stat1(int row, int o)
307 {
308 size_t i;
309 double total_time;
310
311 total_time = 0;
312 for (i = 0; i < CPUSTATES; i++)
313 total_time += cur.cp_time[i];
314 if (total_time == 0.0)
315 total_time = 1.0;
316 wmove(wnd, row, INSET);
317 #define CPUSCALE 0.5
318 histogram(100.0 * cur.cp_time[o] / total_time, 50, CPUSCALE);
319 }
320
321 static void
histogram(double val,int colwidth,double scale)322 histogram(double val, int colwidth, double scale)
323 {
324 int v = (int)(val * scale + 0.5);
325 int factor = 1;
326 int y, x;
327
328 while (v > colwidth) {
329 v = (v + 5) / 10;
330 factor *= 10;
331 }
332 getyx(wnd, y, x);
333 wclrtoeol(wnd);
334 whline(wnd, 'X', v);
335 if (factor != 1)
336 mvwprintw(wnd, y, x + colwidth + 1, "* %d ", factor);
337 }
338
339 void
iostat_bars(char * args)340 iostat_bars(char *args)
341 {
342 numbers = 0;
343 wclear(wnd);
344 labeliostat();
345 refresh();
346 }
347
348 void
iostat_numbers(char * args)349 iostat_numbers(char *args)
350 {
351 numbers = 1;
352 wclear(wnd);
353 labeliostat();
354 refresh();
355 }
356
357 void
iostat_secs(char * args)358 iostat_secs(char *args)
359 {
360 secs = !secs;
361 wclear(wnd);
362 labeliostat();
363 refresh();
364 }
365
366 void
iostat_rw(char * args)367 iostat_rw(char *args)
368 {
369 read_write ^= 1;
370 wclear(wnd);
371 labeliostat();
372 refresh();
373 }
374
375 void
iostat_all(char * args)376 iostat_all(char *args)
377 {
378 read_write = 0;
379 wclear(wnd);
380 labeliostat();
381 refresh();
382 }
383