2 * Copyright (c) 1980, 1992, 1993
3 * The Regents of the University of California. All rights reserved.
5 * Redistribution and use in source and binary forms, with or without
6 * modification, are permitted provided that the following conditions
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.
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
33 * @(#)netstat.c 8.1 (Berkeley) 6/6/93
34 * $FreeBSD: src/usr.bin/systat/netstat.c,v 1.13 1999/08/30 08:18:08 peter Exp $
35 * $DragonFly: src/usr.bin/systat/netstat.c,v 1.8 2004/12/20 11:03:16 joerg Exp $
41 #include <sys/param.h>
42 #include <sys/queue.h>
43 #include <sys/socket.h>
44 #include <sys/socketvar.h>
45 #include <sys/protosw.h>
46 #include <sys/sysctl.h>
48 #include <netinet/in.h>
49 #include <arpa/inet.h>
50 #include <net/route.h>
51 #include <netinet/in_systm.h>
52 #include <netinet/ip.h>
53 #include <netinet/in_pcb.h>
54 #include <netinet/ip_icmp.h>
55 #include <netinet/icmp_var.h>
56 #include <netinet/ip_var.h>
57 #include <netinet/tcp.h>
58 #include <netinet/tcpip.h>
59 #include <netinet/tcp_seq.h>
61 #include <netinet/tcp_fsm.h>
62 #include <netinet/tcp_timer.h>
63 #include <netinet/tcp_var.h>
64 #include <netinet/tcp_debug.h>
65 #include <netinet/udp.h>
66 #include <netinet/udp_var.h>
78 static void enter(struct inpcb
*, struct xsocket
*, int, const char *);
79 static char *inetname(struct in_addr
);
80 static void inetprint(struct in_addr
*, int, const char *);
82 #define streq(a,b) (strcmp(a,b)==0)
83 #define YMAX(w) ((w)->_maxy-1)
90 return (subwin(stdscr
, LINES
-5-1, 0, 5, 0));
94 struct netinfo
*ni_forw
, *ni_prev
;
95 short ni_line
; /* line on screen */
96 short ni_seen
; /* 0 when not present in list */
98 #define NIF_LACHG 0x1 /* local address changed */
99 #define NIF_FACHG 0x2 /* foreign address changed */
100 short ni_state
; /* tcp state */
101 const char *ni_proto
; /* protocol */
102 struct in_addr ni_laddr
; /* local address */
103 long ni_lport
; /* local port */
104 struct in_addr ni_faddr
; /* foreign address */
105 long ni_fport
; /* foreign port */
106 long ni_rcvcc
; /* rcv buffer character count */
107 long ni_sndcc
; /* snd buffer character count */
111 struct netinfo
*ni_forw
, *ni_prev
;
114 static int aflag
= 0;
115 static int nflag
= 0;
116 static int lastrow
= 1;
119 closenetstat(WINDOW
*w
)
121 register struct netinfo
*p
;
125 p
= (struct netinfo
*)netcb
.ni_forw
;
126 while (p
!= (struct netinfo
*)&netcb
) {
127 if (p
->ni_line
!= -1)
142 netcb
.ni_forw
= netcb
.ni_prev
= (struct netinfo
*)&netcb
;
150 struct xtcpcb
*xtcp
= (struct xtcpcb
*)xig
;
154 if (xtcp
->xt_len
< sizeof(*xtcp
))
156 xso
= &xtcp
->xt_socket
;
157 state
= xtcp
->xt_tp
.t_state
;
158 enter(&xtcp
->xt_inp
, xso
, state
, "tcp");
164 struct xinpcb
*xinp
= (struct xinpcb
*)xig
;
167 if (xinp
->xi_len
< sizeof(*xinp
))
169 xso
= &xinp
->xi_socket
;
170 enter(&xinp
->xi_inp
, xso
, 0, "udp");
174 fetchnetstat_proto(void (*enter_proto
)(void *),
178 size_t i
, len
, elem_len
;
180 if (sysctlbyname(mibvar
, 0, &len
, 0, 0) < 0) {
182 warn("sysctl: %s", mibvar
);
185 if ((buf
= malloc(len
)) == NULL
) {
186 warn("malloc %lu bytes", (u_long
)len
);
189 if (sysctlbyname(mibvar
, buf
, &len
, 0, 0) < 0) {
190 warn("sysctl: %s", mibvar
);
196 * XXX this is better with a single PCB type
202 if (len
< sizeof(size_t)) {
203 warnx("sysctl: short read");
207 elem_len
= *(size_t *)buf
;
210 for (i
= 0; i
< len
; i
++, buf2
+= elem_len
) {
211 if (*(size_t *)(buf2
) != elem_len
) {
212 warn("sysctl: inconsistent PCB len");
224 register struct netinfo
*p
;
226 for (p
= netcb
.ni_forw
; p
!= (struct netinfo
*)&netcb
; p
= p
->ni_forw
)
229 fetchnetstat_proto(enter_tcp
, "net.inet.tcp.pcblist");
231 fetchnetstat_proto(enter_udp
, "net.inet.udp.pcblist");
235 enter(struct inpcb
*inp
, struct xsocket
*so
, int state
, const char *proto
)
237 register struct netinfo
*p
;
239 if (!aflag
&& inet_lnaof(inp
->inp_laddr
) == INADDR_ANY
)
241 if (nhosts
&& !checkhost(inp
))
243 if (nports
&& !checkport(inp
))
246 * pcblist may return non-ipv4 sockets, but at the moment
247 * -netstat code doesn't support other than ipv4.
249 if ((inp
->inp_vflag
& INP_IPV4
) == 0)
252 * Only take exact matches, any sockets with
253 * previously unbound addresses will be deleted
254 * below in the display routine because they
255 * will appear as ``not seen'' in the kernel
258 for (p
= netcb
.ni_forw
; p
!= (struct netinfo
*)&netcb
; p
= p
->ni_forw
) {
259 if (!streq(proto
, p
->ni_proto
))
261 if (p
->ni_lport
!= inp
->inp_lport
||
262 p
->ni_laddr
.s_addr
!= inp
->inp_laddr
.s_addr
)
264 if (p
->ni_faddr
.s_addr
== inp
->inp_faddr
.s_addr
&&
265 p
->ni_fport
== inp
->inp_fport
)
268 if (p
== (struct netinfo
*)&netcb
) {
269 if ((p
= malloc(sizeof(*p
))) == NULL
) {
270 error("Out of memory");
273 p
->ni_prev
= (struct netinfo
*)&netcb
;
274 p
->ni_forw
= netcb
.ni_forw
;
275 netcb
.ni_forw
->ni_prev
= p
;
278 p
->ni_laddr
= inp
->inp_laddr
;
279 p
->ni_lport
= inp
->inp_lport
;
280 p
->ni_faddr
= inp
->inp_faddr
;
281 p
->ni_fport
= inp
->inp_fport
;
283 p
->ni_flags
= NIF_LACHG
|NIF_FACHG
;
285 p
->ni_rcvcc
= so
->so_rcv
.sb_cc
;
286 p
->ni_sndcc
= so
->so_snd
.sb_cc
;
291 /* column locations */
293 #define FADDR LADDR+22
294 #define CPUID FADDR+22
295 #define PROTO CPUID+4
296 #define RCVCC PROTO+6
297 #define SNDCC RCVCC+7
298 #define STATE SNDCC+7
304 wmove(wnd
, 0, 0); wclrtobot(wnd
);
305 mvwaddstr(wnd
, 0, LADDR
, "Local Address");
306 mvwaddstr(wnd
, 0, FADDR
, "Foreign Address");
307 mvwaddstr(wnd
, 0, PROTO
, "Proto");
308 mvwaddstr(wnd
, 0, RCVCC
, "Recv-Q");
309 mvwaddstr(wnd
, 0, SNDCC
, "Send-Q");
310 mvwaddstr(wnd
, 0, STATE
, "(state)");
316 register struct netinfo
*p
, *q
;
319 * First, delete any connections that have gone
320 * away and adjust the position of connections
321 * below to reflect the deleted line.
324 while (p
!= (struct netinfo
*)&netcb
) {
325 if (p
->ni_line
== -1 || p
->ni_seen
) {
329 wmove(wnd
, p
->ni_line
, 0); wdeleteln(wnd
);
331 for (; q
!= (struct netinfo
*)&netcb
; q
= q
->ni_forw
)
332 if (q
!= p
&& q
->ni_line
> p
->ni_line
) {
334 /* this shouldn't be necessary */
335 q
->ni_flags
|= NIF_LACHG
|NIF_FACHG
;
339 p
->ni_prev
->ni_forw
= p
->ni_forw
;
340 p
->ni_forw
->ni_prev
= p
->ni_prev
;
345 * Update existing connections and add new ones.
347 for (p
= netcb
.ni_forw
; p
!= (struct netinfo
*)&netcb
; p
= p
->ni_forw
) {
348 if (p
->ni_line
== -1) {
350 * Add a new entry if possible.
352 if (lastrow
> YMAX(wnd
))
354 p
->ni_line
= lastrow
++;
355 p
->ni_flags
|= NIF_LACHG
|NIF_FACHG
;
357 if (p
->ni_flags
& NIF_LACHG
) {
358 wmove(wnd
, p
->ni_line
, LADDR
);
359 inetprint(&p
->ni_laddr
, p
->ni_lport
, p
->ni_proto
);
360 p
->ni_flags
&= ~NIF_LACHG
;
362 if (p
->ni_flags
& NIF_FACHG
) {
363 wmove(wnd
, p
->ni_line
, FADDR
);
364 inetprint(&p
->ni_faddr
, p
->ni_fport
, p
->ni_proto
);
365 p
->ni_flags
&= ~NIF_FACHG
;
367 mvwaddstr(wnd
, p
->ni_line
, PROTO
, p
->ni_proto
);
368 mvwprintw(wnd
, p
->ni_line
, RCVCC
, "%6d", p
->ni_rcvcc
);
369 mvwprintw(wnd
, p
->ni_line
, SNDCC
, "%6d", p
->ni_sndcc
);
370 if (streq(p
->ni_proto
, "tcp"))
371 if (p
->ni_state
< 0 || p
->ni_state
>= TCP_NSTATES
)
372 mvwprintw(wnd
, p
->ni_line
, STATE
, "%d",
375 mvwaddstr(wnd
, p
->ni_line
, STATE
,
376 tcpstates
[p
->ni_state
]);
379 if (lastrow
< YMAX(wnd
)) {
380 wmove(wnd
, lastrow
, 0); wclrtobot(wnd
);
381 wmove(wnd
, YMAX(wnd
), 0); wdeleteln(wnd
); /* XXX */
386 * Pretty print an Internet address (net address + port).
387 * If the nflag was specified, use numbers instead of names.
390 inetprint(register struct in_addr
*in
, int port
, const char *proto
)
392 struct servent
*sp
= 0;
395 snprintf(line
, sizeof(line
), "%.*s.", 16, inetname(*in
));
396 cp
= strchr(line
, '\0');
398 sp
= getservbyport(port
, proto
);
400 snprintf(cp
, sizeof(line
) - (cp
- line
), "%.8s",
401 sp
? sp
->s_name
: "*");
403 snprintf(cp
, sizeof(line
) - (cp
- line
), "%d",
404 ntohs((u_short
)port
));
405 /* pad to full column to clear any garbage */
406 cp
= strchr(line
, '\0');
407 while (cp
- line
< 22)
414 * Construct an Internet address representation.
415 * If the nflag has been supplied, give
416 * numeric value, otherwise try for symbolic name.
419 inetname(struct in_addr in
)
422 static char line
[50];
426 if (!nflag
&& in
.s_addr
!= INADDR_ANY
) {
427 int net
= inet_netof(in
);
428 int lna
= inet_lnaof(in
);
430 if (lna
== INADDR_ANY
) {
431 np
= getnetbyaddr(net
, AF_INET
);
436 hp
= gethostbyaddr((char *)&in
, sizeof (in
), AF_INET
);
441 if (in
.s_addr
== INADDR_ANY
)
444 snprintf(line
, sizeof(line
), "%s", cp
);
446 in
.s_addr
= ntohl(in
.s_addr
);
447 #define C(x) ((x) & 0xff)
448 snprintf(line
, sizeof(line
), "%u.%u.%u.%u", C(in
.s_addr
>> 24),
449 C(in
.s_addr
>> 16), C(in
.s_addr
>> 8), C(in
.s_addr
));
455 cmdnetstat(char *cmd
, char *args
)
457 register struct netinfo
*p
;
459 if (prefix(cmd
, "all")) {
463 if (prefix(cmd
, "numbers") || prefix(cmd
, "names")) {
466 new = prefix(cmd
, "numbers");
470 for (; p
!= (struct netinfo
*)&netcb
; p
= p
->ni_forw
) {
471 if (p
->ni_line
== -1)
473 p
->ni_flags
|= NIF_LACHG
|NIF_FACHG
;
478 if (!netcmd(cmd
, args
))