Annotation of src/usr.bin/systat/iostat.c, Revision 1.48
1.48 ! tedu 1: /* $OpenBSD: iostat.c,v 1.47 2017/04/16 14:24:03 beck Exp $ */
1.3 deraadt 2: /* $NetBSD: iostat.c,v 1.5 1996/05/10 23:16:35 thorpej Exp $ */
1.1 deraadt 3:
4: /*
5: * Copyright (c) 1980, 1992, 1993
6: * The Regents of the University of California. All rights reserved.
7: *
8: * Redistribution and use in source and binary forms, with or without
9: * modification, are permitted provided that the following conditions
10: * are met:
11: * 1. Redistributions of source code must retain the above copyright
12: * notice, this list of conditions and the following disclaimer.
13: * 2. Redistributions in binary form must reproduce the above copyright
14: * notice, this list of conditions and the following disclaimer in the
15: * documentation and/or other materials provided with the distribution.
1.21 millert 16: * 3. Neither the name of the University nor the names of its contributors
1.1 deraadt 17: * may be used to endorse or promote products derived from this software
18: * without specific prior written permission.
19: *
20: * THIS SOFTWARE IS PROVIDED BY THE REGENTS AND CONTRIBUTORS ``AS IS'' AND
21: * ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
22: * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE
23: * ARE DISCLAIMED. IN NO EVENT SHALL THE REGENTS OR CONTRIBUTORS BE LIABLE
24: * FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL
25: * DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS
26: * OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION)
27: * HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT
28: * LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY
29: * OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF
30: * SUCH DAMAGE.
31: */
32:
1.45 deraadt 33: #include <sys/types.h>
1.43 miod 34: #include <sys/mount.h>
1.45 deraadt 35: #include <sys/signal.h>
1.43 miod 36: #include <sys/sched.h>
37: #include <sys/sysctl.h>
1.3 deraadt 38: #include <sys/time.h>
1.1 deraadt 39:
40: #include <string.h>
41: #include <stdlib.h>
42: #include <paths.h>
43: #include "systat.h"
44:
1.3 deraadt 45: #include "dkstats.h"
1.48 ! tedu 46: extern struct _disk cur, last;
! 47: struct bcachestats bclast, bccur;
1.1 deraadt 48:
1.25 dlg 49: static double etime;
1.1 deraadt 50:
1.30 canacar 51: void showtotal(void);
52: void showdrive(int);
53: void print_io(void);
54: int read_io(void);
55: int select_io(void);
56: void showbcache(void);
1.25 dlg 57:
1.26 dlg 58: #define ATIME(x,y) ((double)x[y].tv_sec + \
59: ((double)x[y].tv_usec / (double)1000000))
60:
1.1 deraadt 61:
1.30 canacar 62: field_def fields_io[] = {
63: {"DEVICE", 8, 16, 1, FLD_ALIGN_LEFT, -1, 0, 0, 0},
64: {"READ", 5, 8, 1, FLD_ALIGN_RIGHT, -1, 0, 0, 0},
65: {"WRITE", 5, 8, 1, FLD_ALIGN_RIGHT, -1, 0, 0, 0},
66: {"RTPS", 5, 8, 1, FLD_ALIGN_RIGHT, -1, 0, 0, 0},
67: {"WTPS", 5, 8, 1, FLD_ALIGN_RIGHT, -1, 0, 0, 0},
68: {"SEC", 5, 8, 1, FLD_ALIGN_RIGHT, -1, 0, 0, 0},
1.32 thib 69: {"", 8, 19, 1, FLD_ALIGN_RIGHT, -1, 0, 0, 0},
1.30 canacar 70: {"STATS", 12, 15, 1, FLD_ALIGN_LEFT, -1, 0, 0, 0}
71: };
72:
1.38 jasper 73: #define FLD_IO_DEVICE FIELD_ADDR(fields_io,0)
74: #define FLD_IO_READ FIELD_ADDR(fields_io,1)
75: #define FLD_IO_WRITE FIELD_ADDR(fields_io,2)
76: #define FLD_IO_RTPS FIELD_ADDR(fields_io,3)
77: #define FLD_IO_WTPS FIELD_ADDR(fields_io,4)
78: #define FLD_IO_SEC FIELD_ADDR(fields_io,5)
1.30 canacar 79:
80: /* This is a hack that stuffs bcache statistics to the last two columns! */
1.38 jasper 81: #define FLD_IO_SVAL FIELD_ADDR(fields_io,6)
82: #define FLD_IO_SSTR FIELD_ADDR(fields_io,7)
1.30 canacar 83:
84: /* Define views */
85: field_def *view_io_0[] = {
86: FLD_IO_DEVICE, FLD_IO_READ, FLD_IO_WRITE, FLD_IO_RTPS,
87: FLD_IO_WTPS, FLD_IO_SEC, FLD_IO_SVAL, FLD_IO_SSTR, NULL
88: };
89:
1.48 ! tedu 90: static enum state { BOOT, TIME } state = TIME;
! 91:
! 92: static int
! 93: io_keyboard_callback(int ch)
! 94: {
! 95: switch (ch) {
! 96: case 'b':
! 97: state = BOOT;
! 98: break;
! 99: case 't':
! 100: state = TIME;
! 101: break;
! 102: default:
! 103: return keyboard_callback(ch);
! 104: }
! 105: return 0;
! 106: }
1.30 canacar 107:
108: /* Define view managers */
109: struct view_manager iostat_mgr = {
110: "Iostat", select_io, read_io, NULL, print_header,
1.48 ! tedu 111: print_io, io_keyboard_callback, NULL, NULL
1.30 canacar 112: };
113:
114:
115: field_view views_io[] = {
116: {view_io_0, "iostat", '2', &iostat_mgr},
117: {NULL, NULL, 0, NULL}
118: };
1.1 deraadt 119:
120:
121: int
1.30 canacar 122: select_io(void)
1.1 deraadt 123: {
1.30 canacar 124: num_disp = cur.dk_ndrive + 1;
125: return (0);
1.1 deraadt 126: }
127:
1.30 canacar 128: int
129: read_io(void)
1.1 deraadt 130: {
1.29 beck 131: int mib[3];
132: size_t size;
133:
1.3 deraadt 134: dkreadstats();
1.48 ! tedu 135: if (state == BOOT) {
! 136: unsigned int dn;
! 137: for (dn = 0; dn < last.dk_ndrive; dn++) {
! 138: last.dk_rbytes[dn] = 0;
! 139: last.dk_wbytes[dn] = 0;
! 140: last.dk_rxfer[dn] = 0;
! 141: last.dk_wxfer[dn] = 0;
! 142: }
! 143: }
1.30 canacar 144: dkswap();
145: num_disp = cur.dk_ndrive + 1;
1.29 beck 146:
147: bclast = bccur;
148: mib[0] = CTL_VFS;
149: mib[1] = VFS_GENERIC;
150: mib[2] = VFS_BCACHESTAT;
151: size = sizeof(bccur);
1.30 canacar 152:
1.29 beck 153: if (sysctl(mib, 3, &bccur, &size, NULL, 0) < 0)
1.30 canacar 154: error("cannot get vfs.bcachestat");
155:
1.29 beck 156: if (bclast.numbufs == 0)
157: bclast = bccur;
1.30 canacar 158:
1.48 ! tedu 159: if (state == BOOT)
! 160: memset(&bclast, 0, sizeof(bclast));
! 161:
1.30 canacar 162: return 0;
1.1 deraadt 163: }
164:
165:
166: void
1.30 canacar 167: print_io(void)
1.1 deraadt 168: {
1.30 canacar 169: int n, count = 0;
1.1 deraadt 170:
1.35 canacar 171: int curr;
1.31 canacar 172: etime = naptime;
1.19 tdeval 173:
1.30 canacar 174: /* XXX engine internals: save and restore curr_line for bcache */
175: curr = curr_line;
176:
177: for (n = dispstart; n < num_disp - 1; n++) {
178: showdrive(n);
179: count++;
180: if (maxprint > 0 && count >= maxprint)
181: break;
182: }
183:
184:
185: if (maxprint == 0 || count < maxprint)
186: showtotal();
187:
188: curr_line = curr;
189: showbcache();
190: }
191:
192: int
193: initiostat(void)
194: {
195: field_view *v;
196:
197: dkinit(1);
198: dkreadstats();
199:
200: bzero(&bccur, sizeof(bccur));
1.7 kstailey 201:
1.30 canacar 202: for (v = views_io; v->name != NULL; v++)
203: add_view(v);
1.29 beck 204:
1.48 ! tedu 205: return (1);
1.1 deraadt 206: }
207:
1.25 dlg 208: void
1.30 canacar 209: showtotal(void)
1.1 deraadt 210: {
1.25 dlg 211: double rsum, wsum, rtsum, wtsum, mssum;
1.30 canacar 212: int dn;
1.1 deraadt 213:
1.25 dlg 214: rsum = wsum = rtsum = wtsum = mssum = 0.0;
1.1 deraadt 215:
1.25 dlg 216: for (dn = 0; dn < cur.dk_ndrive; dn++) {
217: rsum += cur.dk_rbytes[dn] / etime;
1.26 dlg 218: wsum += cur.dk_wbytes[dn] / etime;
1.25 dlg 219: rtsum += cur.dk_rxfer[dn] / etime;
220: wtsum += cur.dk_wxfer[dn] / etime;
221: mssum += ATIME(cur.dk_time, dn) / etime;
1.1 deraadt 222: }
1.30 canacar 223:
224: print_fld_str(FLD_IO_DEVICE, "Totals");
225: print_fld_size(FLD_IO_READ, rsum);
226: print_fld_size(FLD_IO_WRITE, wsum);
227: print_fld_size(FLD_IO_RTPS, rtsum);
228: print_fld_size(FLD_IO_WTPS, wtsum);
1.34 naddy 229: print_fld_float(FLD_IO_SEC, mssum, 1);
1.30 canacar 230:
231: end_line();
232: }
233:
234: void
235: showdrive(int dn)
236: {
237: print_fld_str(FLD_IO_DEVICE, cur.dk_name[dn]);
1.48 ! tedu 238: print_fld_size(FLD_IO_READ, cur.dk_rbytes[dn] / etime);
! 239: print_fld_size(FLD_IO_WRITE, cur.dk_wbytes[dn] / etime);
1.30 canacar 240: print_fld_size(FLD_IO_RTPS, cur.dk_rxfer[dn] / etime);
241: print_fld_size(FLD_IO_WTPS, cur.dk_wxfer[dn] / etime);
1.34 naddy 242: print_fld_float(FLD_IO_SEC, ATIME(cur.dk_time, dn) / etime, 1);
1.30 canacar 243:
244: end_line();
1.1 deraadt 245: }
1.30 canacar 246:
247: void
248: showbcache(void)
1.1 deraadt 249: {
1.39 beck 250: print_fld_str(FLD_IO_SSTR, "total pages");
1.33 thib 251: print_fld_ssize(FLD_IO_SVAL, bccur.numbufpages);
1.46 beck 252: end_line();
253:
254: print_fld_str(FLD_IO_SSTR, "dma pages");
255: print_fld_ssize(FLD_IO_SVAL, bccur.dmapages);
1.41 beck 256: end_line();
257:
1.40 beck 258: print_fld_str(FLD_IO_SSTR, "dirty pages");
259: print_fld_ssize(FLD_IO_SVAL, bccur.numdirtypages);
260: end_line();
261:
262: print_fld_str(FLD_IO_SSTR, "delwri bufs");
263: print_fld_ssize(FLD_IO_SVAL, bccur.delwribufs);
264: end_line();
265:
266: print_fld_str(FLD_IO_SSTR, "busymap bufs");
267: print_fld_ssize(FLD_IO_SVAL, bccur.busymapped);
268: end_line();
269:
270: print_fld_str(FLD_IO_SSTR, "avail kvaslots");
271: print_fld_ssize(FLD_IO_SVAL, bccur.kvaslots_avail);
1.30 canacar 272: end_line();
273:
1.40 beck 274: print_fld_str(FLD_IO_SSTR, "kvaslots");
275: print_fld_ssize(FLD_IO_SVAL, bccur.kvaslots);
1.30 canacar 276: end_line();
277:
1.39 beck 278: print_fld_str(FLD_IO_SSTR, "pending writes");
1.33 thib 279: print_fld_ssize(FLD_IO_SVAL, bccur.pendingwrites);
1.30 canacar 280: end_line();
281:
1.39 beck 282: print_fld_str(FLD_IO_SSTR, "pending reads");
1.33 thib 283: print_fld_ssize(FLD_IO_SVAL, bccur.pendingreads);
1.30 canacar 284: end_line();
285:
1.39 beck 286: print_fld_str(FLD_IO_SSTR, "cache hits");
1.33 thib 287: print_fld_ssize(FLD_IO_SVAL, bccur.cachehits - bclast.cachehits);
1.47 beck 288: end_line();
289:
290: print_fld_str(FLD_IO_SSTR, "high flips");
291: print_fld_ssize(FLD_IO_SVAL, bccur.highflips - bclast.highflips);
292: end_line();
293:
294: print_fld_str(FLD_IO_SSTR, "high flops");
295: print_fld_ssize(FLD_IO_SVAL, bccur.highflops - bclast.highflops);
296: end_line();
297:
298: print_fld_str(FLD_IO_SSTR, "dma flips");
299: print_fld_ssize(FLD_IO_SVAL, bccur.dmaflips - bclast.dmaflips);
1.30 canacar 300: end_line();
1.1 deraadt 301: }
![[BACK]](/icons/back.gif){kind=icon}
Return to iostat.c CVS log ![[TXT]](/icons/text.gif){kind=icon}
![[DIR]](/icons/dir.gif){kind=icon}
Up to [local] / src / usr.bin / systat