1 /*- 2 * Copyright (c) 1986, 1991 The Regents of the University of California. 3 * All rights reserved. 4 * 5 * Redistribution and use in source and binary forms, with or without 6 * modification, are permitted provided that the following conditions 7 * are met: 8 * 1. Redistributions of source code must retain the above copyright 9 * notice, this list of conditions and the following disclaimer. 10 * 2. Redistributions in binary form must reproduce the above copyright 11 * notice, this list of conditions and the following disclaimer in the 12 * documentation and/or other materials provided with the distribution. 13 * 3. All advertising materials mentioning features or use of this software 14 * must display the following acknowledgement: 15 * This product includes software developed by the University of 16 * California, Berkeley and its contributors. 17 * 4. Neither the name of the University nor the names of its contributors 18 * may be used to endorse or promote products derived from this software 19 * without specific prior written permission. 20 * 21 * THIS SOFTWARE IS PROVIDED BY THE REGENTS AND CONTRIBUTORS ``AS IS'' AND 22 * ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE 23 * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE 24 * ARE DISCLAIMED. IN NO EVENT SHALL THE REGENTS OR CONTRIBUTORS BE LIABLE 25 * FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL 26 * DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS 27 * OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) 28 * HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT 29 * LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY 30 * OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF 31 * SUCH DAMAGE. 32 */ 33 34 #ifndef lint 35 char copyright[] = 36 "@(#) Copyright (c) 1986, 1991 The Regents of the University of California.\n\ 37 All rights reserved.\n"; 38 #endif /* not lint */ 39 40 #ifndef lint 41 static char sccsid[] = "@(#)iostat.c 5.9 (Berkeley) 6/27/91"; 42 #endif /* not lint */ 43 44 #include <sys/param.h> 45 #include <sys/buf.h> 46 #include <sys/dkstat.h> 47 #include <signal.h> 48 #include <fcntl.h> 49 #include <nlist.h> 50 #include <unistd.h> 51 #include <stdio.h> 52 #include <ctype.h> 53 #include <stdlib.h> 54 #include <string.h> 55 #include <paths.h> 56 #include <kvm.h> 57 58 struct nlist nl[] = { 59 #define X_DK_TIME 0 60 { "_dk_time" }, 61 #define X_DK_XFER 1 62 { "_dk_xfer" }, 63 #define X_DK_WDS 2 64 { "_dk_wds" }, 65 #define X_TK_NIN 3 66 { "_tk_nin" }, 67 #define X_TK_NOUT 4 68 { "_tk_nout" }, 69 #define X_DK_SEEK 5 70 { "_dk_seek" }, 71 #define X_CP_TIME 6 72 { "_cp_time" }, 73 #define X_DK_WPMS 7 74 { "_dk_wpms" }, 75 #define X_HZ 8 76 { "_hz" }, 77 #define X_PHZ 9 78 { "_phz" }, 79 #define X_DK_NDRIVE 10 80 { "_dk_ndrive" }, 81 #define X_END 10 82 #ifdef hp300 83 #define X_HPDINIT (X_END+1) 84 { "_hp_dinit" }, 85 #endif 86 #ifdef tahoe 87 #define X_VBDINIT (X_END+1) 88 { "_vbdinit" }, 89 #endif 90 #ifdef vax 91 { "_mbdinit" }, 92 #define X_MBDINIT (X_END+1) 93 { "_ubdinit" }, 94 #define X_UBDINIT (X_END+2) 95 #endif 96 #ifdef __386BSD__ 97 #define X_ISA_BIO (X_END+1) 98 { "_isa_devtab_bio" }, 99 #endif /* __386BSD__ */ 100 { NULL }, 101 }; 102 103 struct _disk { 104 long cp_time[CPUSTATES]; 105 long *dk_time; 106 long *dk_wds; 107 long *dk_seek; 108 long *dk_xfer; 109 long tk_nin; 110 long tk_nout; 111 } cur, last; 112 113 double etime; 114 long *dk_wpms; 115 int dk_ndrive, *dr_select, hz, kmemfd, ndrives; 116 char **dr_name; 117 118 #define nlread(x, v) \ 119 kvm_read((void *)nl[x].n_value, (void *)&(v), sizeof(v)) 120 121 #include "names.c" /* XXX */ 122 123 static void cpustats __P((void)), dkstats __P((void)), phdr __P((int)); 124 static void usage __P((void)), err __P((const char *, ...)); 125 126 main(argc, argv) 127 int argc; 128 char **argv; 129 { 130 register int i; 131 long tmp; 132 int ch, hdrcnt, reps, interval, phz, ndrives; 133 char **cp, *memfile, *namelist, buf[30]; 134 135 interval = reps = 0; 136 namelist = memfile = NULL; 137 while ((ch = getopt(argc, argv, "c:M:N:w:")) != EOF) 138 switch(ch) { 139 case 'c': 140 reps = atoi(optarg); 141 break; 142 case 'M': 143 memfile = optarg; 144 break; 145 case 'N': 146 namelist = optarg; 147 break; 148 case 'w': 149 interval = atoi(optarg); 150 break; 151 case '?': 152 default: 153 usage(); 154 } 155 argc -= optind; 156 argv += optind; 157 158 if (kvm_openfiles(namelist, memfile, NULL) == -1) 159 err("kvm_openfiles: %s", kvm_geterr()); 160 if (kvm_nlist(nl) == -1) 161 err("kvm_nlist: %s", kvm_geterr()); 162 if (nl[X_DK_NDRIVE].n_type == 0) 163 err("dk_ndrive not found in namelist"); 164 (void)nlread(X_DK_NDRIVE, dk_ndrive); 165 if (dk_ndrive <= 0) 166 err("invalid dk_ndrive %d\n", dk_ndrive); 167 168 cur.dk_time = calloc(dk_ndrive, sizeof(long)); 169 cur.dk_wds = calloc(dk_ndrive, sizeof(long)); 170 cur.dk_seek = calloc(dk_ndrive, sizeof(long)); 171 cur.dk_xfer = calloc(dk_ndrive, sizeof(long)); 172 last.dk_time = calloc(dk_ndrive, sizeof(long)); 173 last.dk_wds = calloc(dk_ndrive, sizeof(long)); 174 last.dk_seek = calloc(dk_ndrive, sizeof(long)); 175 last.dk_xfer = calloc(dk_ndrive, sizeof(long)); 176 dr_select = calloc(dk_ndrive, sizeof(int)); 177 dr_name = calloc(dk_ndrive, sizeof(char *)); 178 dk_wpms = calloc(dk_ndrive, sizeof(long)); 179 180 for (i = 0; i < dk_ndrive; i++) { 181 (void)sprintf(buf, "dk%d", i); 182 dr_name[i] = strdup(buf); 183 } 184 read_names(); 185 (void)nlread(X_HZ, hz); 186 (void)nlread(X_PHZ, phz); 187 if (phz) 188 hz = phz; 189 (void)kvm_read((void *)nl[X_DK_WPMS].n_value, dk_wpms, 190 dk_ndrive * sizeof(dk_wpms)); 191 192 /* 193 * Choose drives to be displayed. Priority goes to (in order) drives 194 * supplied as arguments and default drives. If everything isn't 195 * filled in and there are drives not taken care of, display the first 196 * few that fit. 197 * 198 * The backward compatibility #ifdefs permit the syntax: 199 * iostat [ drives ] [ interval [ count ] ] 200 */ 201 #define BACKWARD_COMPATIBILITY 202 for (ndrives = 0; *argv; ++argv) { 203 #ifdef BACKWARD_COMPATIBILITY 204 if (isdigit(**argv)) 205 break; 206 #endif 207 for (i = 0; i < dk_ndrive; i++) { 208 if (strcmp(dr_name[i], *argv)) 209 continue; 210 dr_select[i] = 1; 211 ++ndrives; 212 } 213 } 214 #ifdef BACKWARD_COMPATIBILITY 215 if (*argv) { 216 interval = atoi(*argv); 217 if (*++argv) 218 reps = atoi(*argv); 219 } 220 #endif 221 222 if (interval) { 223 if (!reps) 224 reps = -1; 225 } else 226 if (reps) 227 interval = 1; 228 229 for (i = 0; i < dk_ndrive && ndrives < 4; i++) { 230 if (dr_select[i] || dk_wpms[i] == 0) 231 continue; 232 for (cp = defdrives; *cp; cp++) 233 if (strcmp(dr_name[i], *cp) == 0) { 234 dr_select[i] = 1; 235 ++ndrives; 236 break; 237 } 238 } 239 for (i = 0; i < dk_ndrive && ndrives < 4; i++) { 240 if (dr_select[i]) 241 continue; 242 dr_select[i] = 1; 243 ++ndrives; 244 } 245 246 (void)signal(SIGCONT, phdr); 247 248 for (hdrcnt = 1;;) { 249 if (!--hdrcnt) { 250 phdr(0); 251 hdrcnt = 20; 252 } 253 (void)kvm_read((void *)nl[X_DK_TIME].n_value, 254 cur.dk_time, dk_ndrive * sizeof(long)); 255 (void)kvm_read((void *)nl[X_DK_XFER].n_value, 256 cur.dk_xfer, dk_ndrive * sizeof(long)); 257 (void)kvm_read((void *)nl[X_DK_WDS].n_value, 258 cur.dk_wds, dk_ndrive * sizeof(long)); 259 (void)kvm_read((void *)nl[X_DK_SEEK].n_value, 260 cur.dk_seek, dk_ndrive * sizeof(long)); 261 (void)kvm_read((void *)nl[X_TK_NIN].n_value, 262 &cur.tk_nin, sizeof(cur.tk_nin)); 263 (void)kvm_read((void *)nl[X_TK_NOUT].n_value, 264 &cur.tk_nout, sizeof(cur.tk_nout)); 265 (void)kvm_read((void *)nl[X_CP_TIME].n_value, 266 cur.cp_time, sizeof(cur.cp_time)); 267 for (i = 0; i < dk_ndrive; i++) { 268 if (!dr_select[i]) 269 continue; 270 #define X(fld) tmp = cur.fld[i]; cur.fld[i] -= last.fld[i]; last.fld[i] = tmp 271 X(dk_xfer); 272 X(dk_seek); 273 X(dk_wds); 274 X(dk_time); 275 } 276 tmp = cur.tk_nin; 277 cur.tk_nin -= last.tk_nin; 278 last.tk_nin = tmp; 279 tmp = cur.tk_nout; 280 cur.tk_nout -= last.tk_nout; 281 last.tk_nout = tmp; 282 etime = 0; 283 for (i = 0; i < CPUSTATES; i++) { 284 X(cp_time); 285 etime += cur.cp_time[i]; 286 } 287 if (etime == 0.0) 288 etime = 1.0; 289 etime /= (float)hz; 290 (void)printf("%4.0f%5.0f", 291 cur.tk_nin / etime, cur.tk_nout / etime); 292 dkstats(); 293 cpustats(); 294 (void)printf("\n"); 295 (void)fflush(stdout); 296 297 if (reps >= 0 && --reps <= 0) 298 break; 299 (void)sleep(interval); 300 } 301 exit(0); 302 } 303 304 /* ARGUSED */ 305 void 306 phdr(notused) 307 int notused; 308 { 309 register int i; 310 311 (void)printf(" tty"); 312 for (i = 0; i < dk_ndrive; i++) 313 if (dr_select[i]) 314 (void)printf(" %3.3s ", dr_name[i]); 315 (void)printf(" cpu\n tin tout"); 316 for (i = 0; i < dk_ndrive; i++) 317 if (dr_select[i]) 318 (void)printf(" sps tps msps "); 319 (void)printf(" us ni sy id\n"); 320 } 321 322 void 323 dkstats() 324 { 325 register int dn; 326 double atime, itime, msps, words, xtime; 327 328 for (dn = 0; dn < dk_ndrive; ++dn) { 329 if (!dr_select[dn]) 330 continue; 331 words = cur.dk_wds[dn] * 32; /* words xfer'd */ 332 (void)printf("%4.0f", /* sectors */ 333 words / (DEV_BSIZE / 2) / etime); 334 335 (void)printf("%4.0f", cur.dk_xfer[dn] / etime); 336 337 if (dk_wpms[dn] && cur.dk_xfer[dn]) { 338 atime = cur.dk_time[dn]; /* ticks disk busy */ 339 atime /= (float)hz; /* ticks to seconds */ 340 xtime = words / dk_wpms[dn]; /* transfer time */ 341 itime = atime - xtime; /* time not xfer'ing */ 342 if (itime < 0) 343 msps = 0; 344 else 345 msps = itime * 1000 / cur.dk_xfer[dn]; 346 } else 347 msps = 0; 348 (void)printf("%5.1f ", msps); 349 } 350 } 351 352 void 353 cpustats() 354 { 355 register int state; 356 double time; 357 358 time = 0; 359 for (state = 0; state < CPUSTATES; ++state) 360 time += cur.cp_time[state]; 361 for (state = 0; state < CPUSTATES; ++state) 362 (void)printf("%3.0f", 363 100. * cur.cp_time[state] / (time ? time : 1)); 364 } 365 366 void 367 usage() 368 { 369 (void)fprintf(stderr, 370 "usage: iostat [-c count] [-M core] [-N system] [-w wait] [drives]\n"); 371 exit(1); 372 } 373 374 #if __STDC__ 375 #include <stdarg.h> 376 #else 377 #include <varargs.h> 378 #endif 379 380 void 381 #if __STDC__ 382 err(const char *fmt, ...) 383 #else 384 err(fmt, va_alist) 385 char *fmt; 386 va_dcl 387 #endif 388 { 389 va_list ap; 390 #if __STDC__ 391 va_start(ap, fmt); 392 #else 393 va_start(ap); 394 #endif 395 (void)fprintf(stderr, "iostat: "); 396 (void)vfprintf(stderr, fmt, ap); 397 va_end(ap); 398 (void)fprintf(stderr, "\n"); 399 exit(1); 400 /* NOTREACHED */ 401 } 402