Annotation of src/usr.bin/systat/iostat.c, Revision 1.46
1.46 ! beck 1: /* $OpenBSD: iostat.c,v 1.45 2015/01/16 00:03:37 deraadt 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.19 tdeval 46: extern struct _disk cur, last;
1.29 beck 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:
90:
91: /* Define view managers */
92: struct view_manager iostat_mgr = {
93: "Iostat", select_io, read_io, NULL, print_header,
94: print_io, keyboard_callback, NULL, NULL
95: };
96:
97:
98: field_view views_io[] = {
99: {view_io_0, "iostat", '2', &iostat_mgr},
100: {NULL, NULL, 0, NULL}
101: };
1.1 deraadt 102:
103:
104: int
1.30 canacar 105: select_io(void)
1.1 deraadt 106: {
1.30 canacar 107: num_disp = cur.dk_ndrive + 1;
108: return (0);
1.1 deraadt 109: }
110:
1.30 canacar 111: int
112: read_io(void)
1.1 deraadt 113: {
1.29 beck 114: int mib[3];
115: size_t size;
116:
1.3 deraadt 117: dkreadstats();
1.30 canacar 118: dkswap();
119: num_disp = cur.dk_ndrive + 1;
1.29 beck 120:
121: bclast = bccur;
122: mib[0] = CTL_VFS;
123: mib[1] = VFS_GENERIC;
124: mib[2] = VFS_BCACHESTAT;
125: size = sizeof(bccur);
1.30 canacar 126:
1.29 beck 127: if (sysctl(mib, 3, &bccur, &size, NULL, 0) < 0)
1.30 canacar 128: error("cannot get vfs.bcachestat");
129:
1.29 beck 130: if (bclast.numbufs == 0)
131: bclast = bccur;
1.30 canacar 132:
133: return 0;
1.1 deraadt 134: }
135:
136:
137: void
1.30 canacar 138: print_io(void)
1.1 deraadt 139: {
1.30 canacar 140: int n, count = 0;
1.1 deraadt 141:
1.35 canacar 142: int curr;
1.31 canacar 143: etime = naptime;
1.19 tdeval 144:
1.30 canacar 145: /* XXX engine internals: save and restore curr_line for bcache */
146: curr = curr_line;
147:
148: for (n = dispstart; n < num_disp - 1; n++) {
149: showdrive(n);
150: count++;
151: if (maxprint > 0 && count >= maxprint)
152: break;
153: }
154:
155:
156: if (maxprint == 0 || count < maxprint)
157: showtotal();
158:
159: curr_line = curr;
160: showbcache();
161: }
162:
163: int
164: initiostat(void)
165: {
166: field_view *v;
167:
168: dkinit(1);
169: dkreadstats();
170:
171: bzero(&bccur, sizeof(bccur));
1.7 kstailey 172:
1.30 canacar 173: for (v = views_io; v->name != NULL; v++)
174: add_view(v);
1.29 beck 175:
1.30 canacar 176: return(1);
1.1 deraadt 177: }
178:
1.25 dlg 179: void
1.30 canacar 180: showtotal(void)
1.1 deraadt 181: {
1.25 dlg 182: double rsum, wsum, rtsum, wtsum, mssum;
1.30 canacar 183: int dn;
1.1 deraadt 184:
1.25 dlg 185: rsum = wsum = rtsum = wtsum = mssum = 0.0;
1.1 deraadt 186:
1.25 dlg 187: for (dn = 0; dn < cur.dk_ndrive; dn++) {
188: rsum += cur.dk_rbytes[dn] / etime;
1.26 dlg 189: wsum += cur.dk_wbytes[dn] / etime;
1.25 dlg 190: rtsum += cur.dk_rxfer[dn] / etime;
191: wtsum += cur.dk_wxfer[dn] / etime;
192: mssum += ATIME(cur.dk_time, dn) / etime;
1.1 deraadt 193: }
1.30 canacar 194:
195: print_fld_str(FLD_IO_DEVICE, "Totals");
196: print_fld_size(FLD_IO_READ, rsum);
197: print_fld_size(FLD_IO_WRITE, wsum);
198: print_fld_size(FLD_IO_RTPS, rtsum);
199: print_fld_size(FLD_IO_WTPS, wtsum);
1.34 naddy 200: print_fld_float(FLD_IO_SEC, mssum, 1);
1.30 canacar 201:
202: end_line();
203: }
204:
205: void
206: showdrive(int dn)
207: {
208: print_fld_str(FLD_IO_DEVICE, cur.dk_name[dn]);
209: print_fld_size(FLD_IO_READ, cur.dk_rbytes[dn]/etime);
210: print_fld_size(FLD_IO_WRITE, cur.dk_wbytes[dn]/ etime);
211: print_fld_size(FLD_IO_RTPS, cur.dk_rxfer[dn] / etime);
212: print_fld_size(FLD_IO_WTPS, cur.dk_wxfer[dn] / etime);
1.34 naddy 213: print_fld_float(FLD_IO_SEC, ATIME(cur.dk_time, dn) / etime, 1);
1.30 canacar 214:
215: end_line();
1.1 deraadt 216: }
1.30 canacar 217:
218: void
219: showbcache(void)
1.1 deraadt 220: {
1.39 beck 221: print_fld_str(FLD_IO_SSTR, "total pages");
1.33 thib 222: print_fld_ssize(FLD_IO_SVAL, bccur.numbufpages);
1.46 ! beck 223: end_line();
! 224:
! 225: print_fld_str(FLD_IO_SSTR, "dma pages");
! 226: print_fld_ssize(FLD_IO_SVAL, bccur.dmapages);
1.41 beck 227: end_line();
228:
1.40 beck 229: print_fld_str(FLD_IO_SSTR, "dirty pages");
230: print_fld_ssize(FLD_IO_SVAL, bccur.numdirtypages);
231: end_line();
232:
233: print_fld_str(FLD_IO_SSTR, "delwri bufs");
234: print_fld_ssize(FLD_IO_SVAL, bccur.delwribufs);
235: end_line();
236:
237: print_fld_str(FLD_IO_SSTR, "busymap bufs");
238: print_fld_ssize(FLD_IO_SVAL, bccur.busymapped);
239: end_line();
240:
241: print_fld_str(FLD_IO_SSTR, "avail kvaslots");
242: print_fld_ssize(FLD_IO_SVAL, bccur.kvaslots_avail);
1.30 canacar 243: end_line();
244:
1.40 beck 245: print_fld_str(FLD_IO_SSTR, "kvaslots");
246: print_fld_ssize(FLD_IO_SVAL, bccur.kvaslots);
1.30 canacar 247: end_line();
248:
1.39 beck 249: print_fld_str(FLD_IO_SSTR, "pending writes");
1.33 thib 250: print_fld_ssize(FLD_IO_SVAL, bccur.pendingwrites);
1.30 canacar 251: end_line();
252:
1.39 beck 253: print_fld_str(FLD_IO_SSTR, "pending reads");
1.33 thib 254: print_fld_ssize(FLD_IO_SVAL, bccur.pendingreads);
1.30 canacar 255: end_line();
256:
1.39 beck 257: print_fld_str(FLD_IO_SSTR, "cache hits");
1.33 thib 258: print_fld_ssize(FLD_IO_SVAL, bccur.cachehits - bclast.cachehits);
1.30 canacar 259: end_line();
1.1 deraadt 260: }
![[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