1 /* $NetBSD: iostat.c,v 1.32 2005/02/26 22:28:23 dsl 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.32 2005/02/26 22:28:23 dsl 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 "dkstats.h" 47 48 static int linesperregion; 49 static double etime; 50 static int numbers = 0; /* default display bar graphs */ 51 static int secs = 0; /* default seconds shown */ 52 static int read_write = 0; /* default read/write shown */ 53 54 static int barlabels(int); 55 static void histogram(double, int, double); 56 static int numlabels(int); 57 static int stats(int, int, int); 58 static void stat1(int, int); 59 60 61 WINDOW * 62 openiostat(void) 63 { 64 65 return (subwin(stdscr, -1, 0, 5, 0)); 66 } 67 68 void 69 closeiostat(WINDOW *w) 70 { 71 72 if (w == NULL) 73 return; 74 wclear(w); 75 wrefresh(w); 76 delwin(w); 77 } 78 79 int 80 initiostat(void) 81 { 82 83 dkinit(1); 84 dkreadstats(); 85 return(1); 86 } 87 88 void 89 fetchiostat(void) 90 { 91 92 if (dk_ndrive == 0) 93 return; 94 dkreadstats(); 95 } 96 97 #define INSET 14 98 99 void 100 labeliostat(void) 101 { 102 int row; 103 104 if (dk_ndrive == 0) { 105 error("No drives defined."); 106 return; 107 } 108 row = 0; 109 wmove(wnd, row, 0); wclrtobot(wnd); 110 mvwaddstr(wnd, row++, INSET, 111 "/0 /10 /20 /30 /40 /50 /60 /70 /80 /90 /100"); 112 mvwaddstr(wnd, row++, 0, " CPU user|"); 113 mvwaddstr(wnd, row++, 0, " nice|"); 114 mvwaddstr(wnd, row++, 0, " system|"); 115 mvwaddstr(wnd, row++, 0, " interrupt|"); 116 mvwaddstr(wnd, row++, 0, " idle|"); 117 if (numbers) 118 row = numlabels(row + 1); 119 else 120 row = barlabels(row + 1); 121 } 122 123 static int 124 numlabels(int row) 125 { 126 int i, col, regions, ndrives; 127 128 #define COLWIDTH (9 + secs * 5 + 1 + read_write * 9 + 1) 129 #define DRIVESPERLINE ((getmaxx(wnd) + 1) / COLWIDTH) 130 for (ndrives = 0, i = 0; i < dk_ndrive; i++) 131 if (cur.dk_select[i]) 132 ndrives++; 133 regions = howmany(ndrives, DRIVESPERLINE); 134 /* 135 * Deduct -regions for blank line after each scrolling region. 136 */ 137 linesperregion = (getmaxy(wnd) - row - regions + 1) / regions; 138 /* 139 * Minimum region contains space for two 140 * label lines and one line of statistics. 141 */ 142 if (linesperregion < 3) 143 linesperregion = 3; 144 col = 0; 145 for (i = 0; i < dk_ndrive; i++) 146 if (cur.dk_select[i]) { 147 if (col + COLWIDTH - 1 > getmaxx(wnd)) { 148 col = 0, row += linesperregion + 1; 149 if (row > getmaxy(wnd) - (linesperregion)) 150 break; 151 } 152 mvwprintw(wnd, row, col + 5, "%s", cur.dk_name[i]); 153 if (read_write) 154 mvwprintw(wnd, row, col + 11 + secs * 5, 155 "(write)"); 156 mvwprintw(wnd, row + 1, col, " kBps %s", 157 read_write ? "r/s" : "tps"); 158 if (secs) 159 waddstr(wnd, " sec"); 160 if (read_write) 161 waddstr(wnd, " kBps w/s"); 162 col += COLWIDTH; 163 } 164 if (col) 165 row += linesperregion + 1; 166 return (row); 167 } 168 169 static int 170 barlabels(int row) 171 { 172 int i; 173 174 mvwaddstr(wnd, row++, INSET, 175 "/0 /10 /20 /30 /40 /50 /60 /70 /80 /90 /100"); 176 linesperregion = 2 + secs + (read_write ? 2 : 0); 177 for (i = 0; i < dk_ndrive; i++) 178 if (cur.dk_select[i]) { 179 if (row > getmaxy(wnd) - linesperregion) 180 break; 181 mvwprintw(wnd, row++, 0, "%7.7s kBps|", 182 cur.dk_name[i]); 183 mvwaddstr(wnd, row++, 0, " tps|"); 184 if (read_write) { 185 mvwprintw(wnd, row++, 0, " (write) kBps|"); 186 mvwaddstr(wnd, row++, 0, " tps|"); 187 } 188 if (secs) 189 mvwaddstr(wnd, row++, 0, " msec|"); 190 } 191 return (row); 192 } 193 194 void 195 showiostat(void) 196 { 197 int i, row, col; 198 199 if (dk_ndrive == 0) 200 return; 201 dkswap(); 202 203 etime = cur.cp_etime; 204 row = 1; 205 206 /* 207 * Interrupt CPU state not calculated yet. 208 */ 209 for (i = 0; i < CPUSTATES; i++) 210 stat1(row++, i); 211 if (!numbers) { 212 row += 2; 213 for (i = 0; i < dk_ndrive; i++) 214 if (cur.dk_select[i]) { 215 if (row > getmaxy(wnd) - linesperregion) 216 break; 217 row = stats(row, INSET, i); 218 } 219 return; 220 } 221 col = 0; 222 wmove(wnd, row + linesperregion, 0); 223 wdeleteln(wnd); 224 wmove(wnd, row + 3, 0); 225 winsertln(wnd); 226 for (i = 0; i < dk_ndrive; i++) 227 if (cur.dk_select[i]) { 228 if (col + COLWIDTH - 1 > getmaxx(wnd)) { 229 col = 0, row += linesperregion + 1; 230 if (row > getmaxy(wnd) - (linesperregion + 1)) 231 break; 232 wmove(wnd, row + linesperregion, 0); 233 wdeleteln(wnd); 234 wmove(wnd, row + 3, 0); 235 winsertln(wnd); 236 } 237 (void) stats(row + 3, col, i); 238 col += COLWIDTH; 239 } 240 } 241 242 static int 243 stats(int row, int col, int dn) 244 { 245 double atime, rwords, wwords; 246 uint64_t rxfer; 247 248 /* time busy in disk activity */ 249 atime = (double)cur.dk_time[dn].tv_sec + 250 ((double)cur.dk_time[dn].tv_usec / (double)1000000); 251 252 /* # of k transferred */ 253 rwords = cur.dk_rbytes[dn] / 1024.0; 254 wwords = cur.dk_wbytes[dn] / 1024.0; 255 rxfer = cur.dk_rxfer[dn]; 256 if (!read_write) { 257 rwords = wwords; 258 rxfer += cur.dk_wxfer[dn]; 259 } 260 if (numbers) { 261 mvwprintw(wnd, row, col, "%5.0f%4.0f", 262 rwords / etime, rxfer / etime); 263 if (secs) 264 wprintw(wnd, "%5.1f", atime / etime); 265 if (read_write) 266 wprintw(wnd, " %5.0f%4.0f", 267 wwords / etime, cur.dk_wxfer[dn] / etime); 268 return (row); 269 } 270 271 wmove(wnd, row++, col); 272 histogram(rwords / etime, 50, 0.5); 273 wmove(wnd, row++, col); 274 histogram(rxfer / etime, 50, 0.5); 275 if (read_write) { 276 wmove(wnd, row++, col); 277 histogram(wwords / etime, 50, 0.5); 278 wmove(wnd, row++, col); 279 histogram(cur.dk_wxfer[dn] / etime, 50, 0.5); 280 } 281 282 if (secs) { 283 wmove(wnd, row++, col); 284 atime *= 1000; /* In milliseconds */ 285 histogram(atime / etime, 50, 0.5); 286 } 287 return (row); 288 } 289 290 static void 291 stat1(int row, int o) 292 { 293 int i; 294 double total_time; 295 296 total_time = 0; 297 for (i = 0; i < CPUSTATES; i++) 298 total_time += cur.cp_time[i]; 299 if (total_time == 0.0) 300 total_time = 1.0; 301 wmove(wnd, row, INSET); 302 #define CPUSCALE 0.5 303 histogram(100.0 * cur.cp_time[o] / total_time, 50, CPUSCALE); 304 } 305 306 static void 307 histogram(double val, int colwidth, double scale) 308 { 309 int v = (int)(val * scale + 0.5); 310 int factor = 1; 311 int y, x; 312 313 while (v > colwidth) { 314 v = (v + 5) / 10; 315 factor *= 10; 316 } 317 getyx(wnd, y, x); 318 wclrtoeol(wnd); 319 whline(wnd, 'X', v); 320 if (factor != 1) 321 mvwprintw(wnd, y, x + colwidth + 1, "* %d ", factor); 322 } 323 324 void 325 iostat_bars(char *args) 326 { 327 numbers = 0; 328 wclear(wnd); 329 labeliostat(); 330 refresh(); 331 } 332 333 void 334 iostat_numbers(char *args) 335 { 336 numbers = 1; 337 wclear(wnd); 338 labeliostat(); 339 refresh(); 340 } 341 342 void 343 iostat_secs(char *args) 344 { 345 secs = !secs; 346 wclear(wnd); 347 labeliostat(); 348 refresh(); 349 } 350 351 void 352 iostat_rw(char *args) 353 { 354 read_write ^= 1; 355 wclear(wnd); 356 labeliostat(); 357 refresh(); 358 } 359 360 void 361 iostat_all(char *args) 362 { 363 read_write = 0; 364 wclear(wnd); 365 labeliostat(); 366 refresh(); 367 } 368