xref: /netbsd-src/usr.bin/systat/ip.c (revision 8b0f9554ff8762542c4defc4f70e1eb76fb508fa)
1 /*	$NetBSD: ip.c,v 1.13 2006/10/22 16:43:24 christos Exp $	*/
2 
3 /*
4  * Copyright (c) 1999, 2000 Andrew Doran <ad@NetBSD.org>
5  * 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  *
16  * THIS SOFTWARE IS PROVIDED BY THE AUTHOR AND CONTRIBUTORS ``AS IS'' AND
17  * ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
18  * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE
19  * ARE DISCLAIMED.  IN NO EVENT SHALL THE AUTHOR OR CONTRIBUTORS BE LIABLE
20  * FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL
21  * DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS
22  * OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION)
23  * HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT
24  * LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY
25  * OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF
26  * SUCH DAMAGE.
27  *
28  */
29 
30 #include <sys/cdefs.h>
31 #ifndef lint
32 __RCSID("$NetBSD: ip.c,v 1.13 2006/10/22 16:43:24 christos Exp $");
33 #endif /* not lint */
34 
35 #include <sys/param.h>
36 #include <sys/sysctl.h>
37 
38 #include <netinet/in.h>
39 #include <netinet/in_systm.h>
40 #include <netinet/ip.h>
41 #include <netinet/ip_var.h>
42 #include <netinet/udp.h>
43 #include <netinet/udp_var.h>
44 
45 #include <string.h>
46 
47 #include "systat.h"
48 #include "extern.h"
49 
50 #define LHD(row, str)		mvwprintw(wnd, row, 10, str)
51 #define RHD(row, str)		mvwprintw(wnd, row, 45, str);
52 #define SHOW(stat, row, col) \
53     mvwprintw(wnd, row, col, "%9llu", (unsigned long long)curstat.stat)
54 
55 struct mystat {
56 	struct ipstat i;
57 	struct udpstat u;
58 };
59 
60 enum update {
61 	UPDATE_TIME,
62 	UPDATE_BOOT,
63 	UPDATE_RUN,
64 };
65 
66 static enum update update = UPDATE_TIME;
67 static struct mystat curstat;
68 static struct mystat oldstat;
69 static struct mystat newstat;
70 
71 static struct nlist namelist[] = {
72 	{ .n_name = "_ipstat" },
73 	{ .n_name = "_udpstat" },
74 	{ .n_name = NULL }
75 };
76 
77 WINDOW *
78 openip(void)
79 {
80 
81 	return (subwin(stdscr, -1, 0, 5, 0));
82 }
83 
84 void
85 closeip(WINDOW *w)
86 {
87 
88 	if (w != NULL) {
89 		wclear(w);
90 		wrefresh(w);
91 		delwin(w);
92 	}
93 }
94 
95 void
96 labelip(void)
97 {
98 
99 	wmove(wnd, 0, 0); wclrtoeol(wnd);
100 
101 	LHD(0,  "total packets received");
102 	LHD(1,  "  passed to upper layers");
103 	LHD(2,  "  with bad checksums");
104 	LHD(3,  "  too short for header");
105 	LHD(4,  "  too short for data");
106 	LHD(5,  "  with invalid hlen");
107 	LHD(6,  "  with invalid length");
108 	LHD(7,  "  with invalid version");
109 	LHD(8,  "  too large");
110 	LHD(9,  "  option errors");
111 	LHD(10, "  fragments received");
112 	LHD(11, "  fragments dropped");
113 	LHD(12, "  fragments timed out");
114 	LHD(13, "  packets reassembled ok");
115 
116 	LHD(15, "packets forwarded");
117 	LHD(16, "  fast forwarded");
118 	LHD(17, "  unreachable dests");
119 	LHD(18, "  redirects generated");
120 
121 	RHD(0,  "total packets sent");
122 	RHD(1,  "  generated locally");
123 	RHD(2,  "  output drops");
124 	RHD(3,  "  output fragments generated");
125 	RHD(4,  "  fragmentation failed");
126 	RHD(5,  "  destinations unreachable");
127 	RHD(6,  "  packets output via raw IP");
128 	RHD(7,  "  total UDP packets sent");
129 
130 	RHD(9, "total UDP packets received");
131 	RHD(10, "  too short for header");
132 	RHD(11, "  invalid checksum");
133 	RHD(12, "  invalid length");
134 	RHD(13, "  no socket for dest port");
135 	RHD(14, "  no socket for broadcast");
136 	RHD(15, "  socket buffer full");
137 }
138 
139 void
140 showip(void)
141 {
142 	u_quad_t totalout;
143 
144 	totalout = curstat.i.ips_forward + curstat.i.ips_localout;
145 
146 	SHOW(i.ips_total, 0, 0);
147 	mvwprintw(wnd, 0, 35, "%9llu", (unsigned long long)totalout);
148 	SHOW(i.ips_delivered, 1, 0);
149 	SHOW(i.ips_badsum, 2, 0);
150 	SHOW(i.ips_tooshort, 3, 0);
151 	SHOW(i.ips_toosmall, 4, 0);
152 	SHOW(i.ips_badhlen, 5, 0);
153 	SHOW(i.ips_badlen, 6, 0);
154 	SHOW(i.ips_badvers, 7, 0);
155 	SHOW(i.ips_toolong, 8, 0);
156 	SHOW(i.ips_badoptions, 9, 0);
157 
158 	SHOW(i.ips_localout, 1, 35);
159 	SHOW(i.ips_odropped, 2, 35);
160 	SHOW(i.ips_ofragments, 3, 35);
161 	SHOW(i.ips_cantfrag, 4, 35);
162 	SHOW(i.ips_noroute, 5, 35);
163 	SHOW(i.ips_rawout, 6, 35);
164 	SHOW(u.udps_opackets, 7, 35);
165 
166 	SHOW(i.ips_fragments, 10, 0);
167 	SHOW(i.ips_fragdropped, 11, 0);
168 	SHOW(i.ips_fragtimeout, 12, 0);
169 	SHOW(i.ips_reassembled, 13, 0);
170 
171 	SHOW(i.ips_forward, 15, 0);
172 	SHOW(i.ips_fastforward, 16, 0);
173 	SHOW(i.ips_cantforward, 17, 0);
174 	SHOW(i.ips_redirectsent, 18, 0);
175 
176 	SHOW(u.udps_ipackets, 9, 35);
177 	SHOW(u.udps_hdrops, 10, 35);
178 	SHOW(u.udps_badsum, 11, 35);
179 	SHOW(u.udps_badlen, 12, 35);
180 	SHOW(u.udps_noport, 13, 35);
181 	SHOW(u.udps_noportbcast, 14, 35);
182 	SHOW(u.udps_fullsock, 15, 35);
183 }
184 
185 int
186 initip(void)
187 {
188 
189 	if (namelist[0].n_type == 0) {
190 		if (kvm_nlist(kd, namelist)) {
191 			nlisterr(namelist);
192 			return(0);
193 		}
194 		if ((namelist[0].n_type | namelist[1].n_type) == 0) {
195 			error("No namelist");
196 			return(0);
197 		}
198 	}
199 	return 1;
200 }
201 
202 void
203 fetchip(void)
204 {
205 
206 	KREAD((void *)namelist[0].n_value, &newstat.i,
207 	    sizeof(newstat.i));
208 	KREAD((void *)namelist[1].n_value, &newstat.u,
209 	    sizeof(newstat.u));
210 
211 	ADJINETCTR(curstat, oldstat, newstat, i.ips_total);
212 	ADJINETCTR(curstat, oldstat, newstat, i.ips_delivered);
213 	ADJINETCTR(curstat, oldstat, newstat, i.ips_badsum);
214 	ADJINETCTR(curstat, oldstat, newstat, i.ips_tooshort);
215 	ADJINETCTR(curstat, oldstat, newstat, i.ips_toosmall);
216 	ADJINETCTR(curstat, oldstat, newstat, i.ips_badhlen);
217 	ADJINETCTR(curstat, oldstat, newstat, i.ips_badlen);
218 	ADJINETCTR(curstat, oldstat, newstat, i.ips_badvers);
219 	ADJINETCTR(curstat, oldstat, newstat, i.ips_toolong);
220 	ADJINETCTR(curstat, oldstat, newstat, i.ips_badoptions);
221 	ADJINETCTR(curstat, oldstat, newstat, i.ips_localout);
222 	ADJINETCTR(curstat, oldstat, newstat, i.ips_odropped);
223 	ADJINETCTR(curstat, oldstat, newstat, i.ips_ofragments);
224 	ADJINETCTR(curstat, oldstat, newstat, i.ips_cantfrag);
225 	ADJINETCTR(curstat, oldstat, newstat, i.ips_noroute);
226 	ADJINETCTR(curstat, oldstat, newstat, i.ips_rawout);
227 	ADJINETCTR(curstat, oldstat, newstat, i.ips_fragments);
228 	ADJINETCTR(curstat, oldstat, newstat, i.ips_fragdropped);
229 	ADJINETCTR(curstat, oldstat, newstat, i.ips_fragtimeout);
230 	ADJINETCTR(curstat, oldstat, newstat, i.ips_reassembled);
231 	ADJINETCTR(curstat, oldstat, newstat, i.ips_forward);
232 	ADJINETCTR(curstat, oldstat, newstat, i.ips_fastforward);
233 	ADJINETCTR(curstat, oldstat, newstat, i.ips_cantforward);
234 	ADJINETCTR(curstat, oldstat, newstat, i.ips_redirectsent);
235 	ADJINETCTR(curstat, oldstat, newstat, u.udps_opackets);
236 	ADJINETCTR(curstat, oldstat, newstat, u.udps_ipackets);
237 	ADJINETCTR(curstat, oldstat, newstat, u.udps_hdrops);
238 	ADJINETCTR(curstat, oldstat, newstat, u.udps_badsum);
239 	ADJINETCTR(curstat, oldstat, newstat, u.udps_badlen);
240 	ADJINETCTR(curstat, oldstat, newstat, u.udps_noport);
241 	ADJINETCTR(curstat, oldstat, newstat, u.udps_noportbcast);
242 	ADJINETCTR(curstat, oldstat, newstat, u.udps_fullsock);
243 
244 	if (update == UPDATE_TIME)
245 		memcpy(&oldstat, &newstat, sizeof(oldstat));
246 }
247 
248 void
249 ip_boot(char *args)
250 {
251 
252 	memset(&oldstat, 0, sizeof(oldstat));
253 	update = UPDATE_BOOT;
254 }
255 
256 void
257 ip_run(char *args)
258 {
259 
260 	if (update != UPDATE_RUN) {
261 		memcpy(&oldstat, &newstat, sizeof(oldstat));
262 		update = UPDATE_RUN;
263 	}
264 }
265 
266 void
267 ip_time(char *args)
268 {
269 
270 	if (update != UPDATE_TIME) {
271 		memcpy(&oldstat, &newstat, sizeof(oldstat));
272 		update = UPDATE_TIME;
273 	}
274 }
275 
276 void
277 ip_zero(char *args)
278 {
279 
280 	if (update == UPDATE_RUN)
281 		memcpy(&oldstat, &newstat, sizeof(oldstat));
282 }
283