usr.bin/netstat/inet.c

   1 /*
   2  * Copyright (c) 1983, 1988, 1993, 1995
   3  *      The Regents of the University of California.  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  * @(#)inet.c   8.5 (Berkeley) 5/24/95
  34  * $FreeBSD: src/usr.bin/netstat/inet.c,v 1.37.2.11 2003/11/27 14:46:49 ru Exp $
  35  * $DragonFly: src/usr.bin/netstat/inet.c,v 1.21 2007/12/29 22:15:06 hasso Exp $
  36  */
  37
  38 #include <sys/param.h>
  39 #include <sys/queue.h>
  40 #include <sys/socket.h>
  41 #include <sys/socketvar.h>
  42 #include <sys/sysctl.h>
  43 #include <sys/protosw.h>
  44 #include <sys/time.h>
  45
  46 #include <net/route.h>
  47 #include <netinet/in.h>
  48 #include <netinet/in_systm.h>
  49 #include <netinet/ip.h>
  50 #include <netinet/ip_carp.h>
  51 #ifdef INET6
  52 #include <netinet/ip6.h>
  53 #endif /* INET6 */
  54 #include <netinet/in_pcb.h>
  55 #include <netinet/ip_icmp.h>
  56 #include <netinet/icmp_var.h>
  57 #include <netinet/igmp_var.h>
  58 #include <netinet/ip_var.h>
  59 #include <netinet/pim_var.h>
  60 #include <netinet/tcp.h>
  61 #include <netinet/tcpip.h>
  62 #include <netinet/tcp_seq.h>
  63 #define TCPSTATES
  64 #include <netinet/tcp_fsm.h>
  65 #include <netinet/tcp_timer.h>
  66 #include <netinet/tcp_var.h>
  67 #include <netinet/tcp_debug.h>
  68 #include <netinet/udp.h>
  69 #include <netinet/udp_var.h>
  70
  71 #include <arpa/inet.h>
  72 #include <err.h>
  73 #include <errno.h>
  74 #include <libutil.h>
  75 #include <netdb.h>
  76 #include <stdio.h>
  77 #include <stdlib.h>
  78 #include <string.h>
  79 #include <unistd.h>
  80 #include "netstat.h"
  81
  82 char    *inetname (struct in_addr *);
  83 void    inetprint (struct in_addr *, int, const char *, int);
  84 #ifdef INET6
  85 extern void     inet6print (struct in6_addr *, int, const char *, int);
  86 static int udp_done, tcp_done;
  87 #endif /* INET6 */
  88
  89 /*
  90  * Print a summary of connections related to an Internet
  91  * protocol.  For TCP, also give state of connection.
  92  * Listening processes (aflag) are suppressed unless the
  93  * -a (all) flag is specified.
  94  */
  95
  96 static int ppr_first = 1;
  97 static void outputpcb(int proto, const char *name, struct inpcb *inp, struct xsocket *so, struct tcpcb *tp);
  98
  99 void
 100 protopr(u_long proto, char *name, int af)
 101 {
 102         int istcp;
 103         int i;
 104         void *buf;
 105         const char *mibvar;
 106         size_t len;
 107
 108         istcp = 0;
 109         switch (proto) {
 110         case IPPROTO_TCP:
 111 #ifdef INET6
 112                 if (tcp_done != 0)
 113                         return;
 114                 else
 115                         tcp_done = 1;
 116 #endif
 117                 istcp = 1;
 118                 mibvar = "net.inet.tcp.pcblist";
 119                 break;
 120         case IPPROTO_UDP:
 121 #ifdef INET6
 122                 if (udp_done != 0)
 123                         return;
 124                 else
 125                         udp_done = 1;
 126 #endif
 127                 mibvar = "net.inet.udp.pcblist";
 128                 break;
 129         case IPPROTO_DIVERT:
 130                 mibvar = "net.inet.divert.pcblist";
 131                 break;
 132         default:
 133                 mibvar = "net.inet.raw.pcblist";
 134                 break;
 135         }
 136         len = 0;
 137         if (sysctlbyname(mibvar, 0, &len, 0, 0) < 0) {
 138                 if (errno != ENOENT)
 139                         warn("sysctl: %s", mibvar);
 140                 return;
 141         }
 142         if (len == 0)
 143                 return;
 144         if ((buf = malloc(len)) == 0) {
 145                 warn("malloc %lu bytes", (u_long)len);
 146                 return;
 147         }
 148         if (sysctlbyname(mibvar, buf, &len, 0, 0) < 0) {
 149                 warn("sysctl: %s", mibvar);
 150                 free(buf);
 151                 return;
 152         }
 153
 154         if (istcp) {
 155                 struct xtcpcb *tcp = buf;
 156                 len /= sizeof(*tcp);
 157                 for (i = 0; i < len; i++) {
 158                         if (tcp[i].xt_len != sizeof(*tcp))
 159                                 break;
 160                         outputpcb(proto, name, &tcp[i].xt_inp,
 161                                   &tcp[i].xt_socket, &tcp[i].xt_tp);
 162                 }
 163         } else {
 164                 struct xinpcb *in = buf;
 165                 len /= sizeof(*in);
 166                 for (i = 0; i < len; i++) {
 167                         if (in[i].xi_len != sizeof(*in))
 168                                 break;
 169                         outputpcb(proto, name, &in[i].xi_inp,
 170                                   &in[i].xi_socket, NULL);
 171                 }
 172         }
 173         free(buf);
 174 }
 175
 176 static void
 177 outputpcb(int proto, const char *name, struct inpcb *inp, struct xsocket *so, struct tcpcb *tp)
 178 {
 179         const char *vchar;
 180         static struct clockinfo clockinfo;
 181
 182         if (clockinfo.hz == 0) {
 183                 int size = sizeof(clockinfo);
 184                 sysctlbyname("kern.clockrate", &clockinfo, &size, NULL, 0);
 185                 if (clockinfo.hz == 0)
 186                         clockinfo.hz = 100;
 187         }
 188
 189         /* Ignore sockets for protocols other than the desired one. */
 190         if (so->xso_protocol != (int)proto)
 191                 return;
 192
 193         if ((af == AF_INET && (inp->inp_vflag & INP_IPV4) == 0)
 194 #ifdef INET6
 195             || (af == AF_INET6 && (inp->inp_vflag & INP_IPV6) == 0)
 196 #endif /* INET6 */
 197             || (af == AF_UNSPEC && ((inp->inp_vflag & INP_IPV4) == 0
 198 #ifdef INET6
 199                 && (inp->inp_vflag & INP_IPV6) == 0
 200 #endif /* INET6 */
 201                 ))
 202             ) {
 203                 return;
 204         }
 205         if (!aflag && (
 206                 (proto == IPPROTO_TCP && tp->t_state == TCPS_LISTEN) ||
 207                 (af == AF_INET && inet_lnaof(inp->inp_laddr) == INADDR_ANY)
 208 #ifdef INET6
 209             || (af == AF_INET6 && IN6_IS_ADDR_UNSPECIFIED(&inp->in6p_laddr))
 210 #endif /* INET6 */
 211             || (af == AF_UNSPEC && (((inp->inp_vflag & INP_IPV4) != 0 &&
 212                 inet_lnaof(inp->inp_laddr) == INADDR_ANY)
 213 #ifdef INET6
 214             || ((inp->inp_vflag & INP_IPV6) != 0 &&
 215                 IN6_IS_ADDR_UNSPECIFIED(&inp->in6p_laddr))
 216 #endif
 217                   ))
 218              )) {
 219                 return;
 220         }
 221
 222         if (ppr_first) {
 223                 if (!Lflag) {
 224                         printf("Active Internet connections");
 225                         if (aflag)
 226                                 printf(" (including servers)");
 227                 } else {
 228                         printf("Current listen queue sizes "
 229                                 "(qlen/incqlen/maxqlen)");
 230                 }
 231                 putchar('\n');
 232                 if (Aflag)
 233                         printf("%-8.8s ", "Socket");
 234                 if (Pflag)
 235                         printf("%8.8s %8.8s %8.8s ", "TxWin", "Unacked", "RTT/ms");
 236                 if (Lflag) {
 237                         printf("%-5.5s %-14.14s %-22.22s\n",
 238                                 "Proto", "Listen", "Local Address");
 239                 } else {
 240                         printf((Aflag && !Wflag) ?
 241                             "%-5.5s %-6.6s %-6.6s %-17.17s %-17.17s %s\n" :
 242                             "%-5.5s %-6.6s %-6.6s %-21.21s %-21.21s %s\n",
 243                             "Proto", "Recv-Q", "Send-Q",
 244                             "Local Address", "Foreign Address",
 245                             "(state)");
 246                 }
 247                 ppr_first = 0;
 248         }
 249         if (Lflag && so->so_qlimit == 0)
 250                 return;
 251         if (Aflag) {
 252                 if (tp)
 253                         printf("%8lx ", (u_long)inp->inp_ppcb);
 254                 else
 255                         printf("%8lx ", (u_long)so->so_pcb);
 256         }
 257         if (Pflag) {
 258                 if (tp) {
 259                         int window = MIN(tp->snd_cwnd, tp->snd_bwnd);
 260                         if (window == 1073725440)
 261                                 printf("%8s ", "max");
 262                         else
 263                                 printf("%8d ", (int)MIN(tp->snd_cwnd, tp->snd_bwnd));
 264                         printf("%8d ", (int)(tp->snd_max - tp->snd_una));
 265                         if (tp->t_srtt == 0)
 266                             printf("%8s ", "-");
 267                         else
 268                             printf("%8.3f ", (double)tp->t_srtt * 1000.0 / TCP_RTT_SCALE / clockinfo.hz);
 269                 } else {
 270                         printf("%8s %8s %8s ", "-", "-", "-");
 271                 }
 272         }
 273 #ifdef INET6
 274         if ((inp->inp_vflag & INP_IPV6) != 0)
 275                 vchar = ((inp->inp_vflag & INP_IPV4) != 0) ? "46" : "6 ";
 276         else
 277 #endif
 278                 vchar = ((inp->inp_vflag & INP_IPV4) != 0) ? "4 " : "  ";
 279
 280         printf("%-3.3s%-2.2s ", name, vchar);
 281         if (Lflag) {
 282                 char buf[15];
 283
 284                 snprintf(buf, sizeof(buf), "%d/%d/%d", so->so_qlen,
 285                          so->so_incqlen, so->so_qlimit);
 286                 printf("%-13.13s ", buf);
 287         } else if (Bflag) {
 288                 printf("%6ld %6ld ",
 289                        so->so_rcv.sb_hiwat,
 290                        so->so_snd.sb_hiwat);
 291         } else {
 292                 printf("%6ld %6ld ",
 293                        so->so_rcv.sb_cc,
 294                        so->so_snd.sb_cc);
 295         }
 296         if (numeric_port) {
 297                 if (inp->inp_vflag & INP_IPV4) {
 298                         inetprint(&inp->inp_laddr, (int)inp->inp_lport,
 299                                   name, 1);
 300                         if (!Lflag)
 301                                 inetprint(&inp->inp_faddr,
 302                                           (int)inp->inp_fport, name, 1);
 303                 }
 304 #ifdef INET6
 305                 else if (inp->inp_vflag & INP_IPV6) {
 306                         inet6print(&inp->in6p_laddr,
 307                                    (int)inp->inp_lport, name, 1);
 308                         if (!Lflag)
 309                                 inet6print(&inp->in6p_faddr,
 310                                            (int)inp->inp_fport, name, 1);
 311                 } /* else nothing printed now */
 312 #endif /* INET6 */
 313         } else if (inp->inp_flags & INP_ANONPORT) {
 314                 if (inp->inp_vflag & INP_IPV4) {
 315                         inetprint(&inp->inp_laddr, (int)inp->inp_lport,
 316                                   name, 1);
 317                         if (!Lflag)
 318                                 inetprint(&inp->inp_faddr,
 319                                           (int)inp->inp_fport, name, 0);
 320                 }
 321 #ifdef INET6
 322                 else if (inp->inp_vflag & INP_IPV6) {
 323                         inet6print(&inp->in6p_laddr,
 324                                    (int)inp->inp_lport, name, 1);
 325                         if (!Lflag)
 326                                 inet6print(&inp->in6p_faddr,
 327                                            (int)inp->inp_fport, name, 0);
 328                 } /* else nothing printed now */
 329 #endif /* INET6 */
 330         } else {
 331                 if (inp->inp_vflag & INP_IPV4) {
 332                         inetprint(&inp->inp_laddr, (int)inp->inp_lport,
 333                                   name, 0);
 334                         if (!Lflag)
 335                                 inetprint(&inp->inp_faddr,
 336                                           (int)inp->inp_fport, name,
 337                                           inp->inp_lport !=
 338                                                 inp->inp_fport);
 339                 }
 340 #ifdef INET6
 341                 else if (inp->inp_vflag & INP_IPV6) {
 342                         inet6print(&inp->in6p_laddr,
 343                                    (int)inp->inp_lport, name, 0);
 344                         if (!Lflag)
 345                                 inet6print(&inp->in6p_faddr,
 346                                            (int)inp->inp_fport, name,
 347                                            inp->inp_lport !=
 348                                                 inp->inp_fport);
 349                 } /* else nothing printed now */
 350 #endif /* INET6 */
 351         }
 352         if (tp && !Lflag) {
 353                 if (tp->t_state < 0 || tp->t_state >= TCP_NSTATES)
 354                         printf("%d", tp->t_state);
 355               else {
 356                         printf("%s", tcpstates[tp->t_state]);
 357 #if defined(TF_NEEDSYN) && defined(TF_NEEDFIN)
 358                       /* Show T/TCP `hidden state' */
 359                       if (tp->t_flags & (TF_NEEDSYN|TF_NEEDFIN))
 360                               putchar('*');
 361 #endif /* defined(TF_NEEDSYN) && defined(TF_NEEDFIN) */
 362               }
 363         }
 364         putchar('\n');
 365 }
 366
 367
 368
 369 #define CPU_STATS_FUNC(proto,type)                            \
 370 static void                                                   \
 371 proto ##_stats_agg(type *ary, type *ttl, int cpucnt)          \
 372 {                                                             \
 373     int i, off, siz;                                          \
 374     siz = sizeof(type);                                       \
 375                                                               \
 376     if (!ary && !ttl)                                         \
 377         return;                                               \
 378                                                               \
 379     bzero(ttl, siz);                                          \
 380     if (cpucnt == 1) {                                        \
 381         *ttl = ary[0];                                        \
 382     } else {                                                  \
 383         for (i = 0; i < cpucnt; ++i) {                        \
 384             for (off = 0; off < siz; off += sizeof(u_long)) { \
 385                 *(u_long *)((char *)(*(&ttl)) + off) +=       \
 386                 *(u_long *)((char *)&ary[i] + off);           \
 387             }                                                 \
 388         }                                                     \
 389     }                                                         \
 390 }
 391 CPU_STATS_FUNC(tcp, struct tcp_stats);
 392 CPU_STATS_FUNC(ip, struct ip_stats);
 393
 394 /*
 395  * Dump TCP statistics structure.
 396  */
 397 void
 398 tcp_stats(u_long off __unused, char *name, int af __unused)
 399 {
 400         struct tcp_stats tcpstat, *stattmp;
 401         struct tcp_stats zerostat[SMP_MAXCPU];
 402         size_t len = sizeof(struct tcp_stats) * SMP_MAXCPU;
 403         int cpucnt;
 404
 405         if (zflag)
 406                 memset(zerostat, 0, len);
 407
 408         if ((stattmp = malloc(len)) == NULL) {
 409                 return;
 410         } else {
 411                 if (sysctlbyname("net.inet.tcp.stats", stattmp, &len,
 412                         zflag ? zerostat : NULL, zflag ? len : 0) < 0) {
 413                         warn("sysctl: net.inet.tcp.stats");
 414                         free(stattmp);
 415                         return;
 416                 } else {
 417                         if ((stattmp = realloc(stattmp, len)) == NULL) {
 418                                 warn("tcp_stats");
 419                                 return;
 420                         }
 421                 }
 422         }
 423         cpucnt = len / sizeof(struct tcp_stats);
 424         tcp_stats_agg(stattmp, &tcpstat, cpucnt);
 425
 426 #ifdef INET6
 427         if (tcp_done != 0)
 428                 return;
 429         else
 430                 tcp_done = 1;
 431 #endif
 432
 433         printf ("%s:\n", name);
 434
 435 #define p(f, m) if (tcpstat.f || sflag <= 1) \
 436     printf(m, tcpstat.f, plural(tcpstat.f))
 437 #define p1a(f, m) if (tcpstat.f || sflag <= 1) \
 438     printf(m, tcpstat.f)
 439 #define p2(f1, f2, m) if (tcpstat.f1 || tcpstat.f2 || sflag <= 1) \
 440     printf(m, tcpstat.f1, plural(tcpstat.f1), tcpstat.f2, plural(tcpstat.f2))
 441 #define p2a(f1, f2, m) if (tcpstat.f1 || tcpstat.f2 || sflag <= 1) \
 442     printf(m, tcpstat.f1, plural(tcpstat.f1), tcpstat.f2)
 443 #define p3(f, m) if (tcpstat.f || sflag <= 1) \
 444     printf(m, tcpstat.f, plurales(tcpstat.f))
 445
 446         p(tcps_sndtotal, "\t%lu packet%s sent\n");
 447         p2(tcps_sndpack,tcps_sndbyte,
 448                 "\t\t%lu data packet%s (%lu byte%s)\n");
 449         p2(tcps_sndrexmitpack, tcps_sndrexmitbyte,
 450                 "\t\t%lu data packet%s (%lu byte%s) retransmitted\n");
 451         p2a(tcps_sndfastrexmit, tcps_sndearlyrexmit,
 452                 "\t\t%lu Fast Retransmit%s (%lu early)\n");
 453         p(tcps_sndlimited, "\t\t%lu packet%s sent by Limited Transmit\n");
 454         p(tcps_sndrtobad, "\t\t%lu spurious RTO retransmit%s\n");
 455         p2a(tcps_sndfastrexmitbad, tcps_sndearlyrexmitbad,
 456                 "\t\t%lu spurious Fast Retransmit%s (%lu early)\n");
 457         p(tcps_eifeldetected, "\t\t%lu Eifel-detected spurious retransmit%s\n");
 458         p(tcps_rttdetected, "\t\t%lu RTT-detected spurious retransmit%s\n");
 459         p(tcps_mturesent, "\t\t%lu resend%s initiated by MTU discovery\n");
 460         p2a(tcps_sndacks, tcps_delack,
 461                 "\t\t%lu ack-only packet%s (%lu delayed)\n");
 462         p(tcps_sndurg, "\t\t%lu URG only packet%s\n");
 463         p(tcps_sndprobe, "\t\t%lu window probe packet%s\n");
 464         p(tcps_sndwinup, "\t\t%lu window update packet%s\n");
 465         p(tcps_sndctrl, "\t\t%lu control packet%s\n");
 466         p(tcps_rcvtotal, "\t%lu packet%s received\n");
 467         p2(tcps_rcvackpack, tcps_rcvackbyte, "\t\t%lu ack%s (for %lu byte%s)\n");
 468         p(tcps_rcvdupack, "\t\t%lu duplicate ack%s\n");
 469         p(tcps_rcvacktoomuch, "\t\t%lu ack%s for unsent data\n");
 470         p2(tcps_rcvpack, tcps_rcvbyte,
 471                 "\t\t%lu packet%s (%lu byte%s) received in-sequence\n");
 472         p2(tcps_rcvduppack, tcps_rcvdupbyte,
 473                 "\t\t%lu completely duplicate packet%s (%lu byte%s)\n");
 474         p(tcps_pawsdrop, "\t\t%lu old duplicate packet%s\n");
 475         p2(tcps_rcvpartduppack, tcps_rcvpartdupbyte,
 476                 "\t\t%lu packet%s with some dup. data (%lu byte%s duped)\n");
 477         p2(tcps_rcvoopack, tcps_rcvoobyte,
 478                 "\t\t%lu out-of-order packet%s (%lu byte%s)\n");
 479         p2(tcps_rcvpackafterwin, tcps_rcvbyteafterwin,
 480                 "\t\t%lu packet%s (%lu byte%s) of data after window\n");
 481         p(tcps_rcvwinprobe, "\t\t%lu window probe%s\n");
 482         p(tcps_rcvwinupd, "\t\t%lu window update packet%s\n");
 483         p(tcps_rcvafterclose, "\t\t%lu packet%s received after close\n");
 484         p(tcps_rcvbadsum, "\t\t%lu discarded for bad checksum%s\n");
 485         p(tcps_rcvbadoff, "\t\t%lu discarded for bad header offset field%s\n");
 486         p1a(tcps_rcvshort, "\t\t%lu discarded because packet too short\n");
 487         p(tcps_connattempt, "\t%lu connection request%s\n");
 488         p(tcps_accepts, "\t%lu connection accept%s\n");
 489         p(tcps_badsyn, "\t%lu bad connection attempt%s\n");
 490         p(tcps_listendrop, "\t%lu listen queue overflow%s\n");
 491         p(tcps_connects, "\t%lu connection%s established (including accepts)\n");
 492         p2(tcps_closed, tcps_drops,
 493                 "\t%lu connection%s closed (including %lu drop%s)\n");
 494         p(tcps_cachedrtt, "\t\t%lu connection%s updated cached RTT on close\n");
 495         p(tcps_cachedrttvar,
 496           "\t\t%lu connection%s updated cached RTT variance on close\n");
 497         p(tcps_cachedssthresh,
 498           "\t\t%lu connection%s updated cached ssthresh on close\n");
 499         p(tcps_conndrops, "\t%lu embryonic connection%s dropped\n");
 500         p2(tcps_rttupdated, tcps_segstimed,
 501                 "\t%lu segment%s updated rtt (of %lu attempt%s)\n");
 502         p(tcps_rexmttimeo, "\t%lu retransmit timeout%s\n");
 503         p(tcps_timeoutdrop, "\t\t%lu connection%s dropped by rexmit timeout\n");
 504         p(tcps_persisttimeo, "\t%lu persist timeout%s\n");
 505         p(tcps_persistdrop, "\t\t%lu connection%s dropped by persist timeout\n");
 506         p(tcps_keeptimeo, "\t%lu keepalive timeout%s\n");
 507         p(tcps_keepprobe, "\t\t%lu keepalive probe%s sent\n");
 508         p(tcps_keepdrops, "\t\t%lu connection%s dropped by keepalive\n");
 509         p(tcps_predack, "\t%lu correct ACK header prediction%s\n");
 510         p(tcps_preddat, "\t%lu correct data packet header prediction%s\n");
 511
 512         p1a(tcps_sc_added, "\t%lu syncache entries added\n");
 513         p1a(tcps_sc_retransmitted, "\t\t%lu retransmitted\n");
 514         p1a(tcps_sc_dupsyn, "\t\t%lu dupsyn\n");
 515         p1a(tcps_sc_dropped, "\t\t%lu dropped\n");
 516         p1a(tcps_sc_completed, "\t\t%lu completed\n");
 517         p1a(tcps_sc_bucketoverflow, "\t\t%lu bucket overflow\n");
 518         p1a(tcps_sc_cacheoverflow, "\t\t%lu cache overflow\n");
 519         p1a(tcps_sc_reset, "\t\t%lu reset\n");
 520         p1a(tcps_sc_stale, "\t\t%lu stale\n");
 521         p1a(tcps_sc_aborted, "\t\t%lu aborted\n");
 522         p1a(tcps_sc_badack, "\t\t%lu badack\n");
 523         p1a(tcps_sc_unreach, "\t\t%lu unreach\n");
 524         p1a(tcps_sc_zonefail, "\t\t%lu zone failures\n");
 525         p1a(tcps_sc_sendcookie, "\t%lu cookies sent\n");
 526         p1a(tcps_sc_recvcookie, "\t%lu cookies received\n");
 527         free(stattmp);
 528 #undef p
 529 #undef p1a
 530 #undef p2
 531 #undef p2a
 532 #undef p3
 533 }
 534
 535 /*
 536  * Dump UDP statistics structure.
 537  */
 538 void
 539 udp_stats(u_long off __unused, char *name, int af __unused)
 540 {
 541         struct udpstat udpstat, zerostat;
 542         size_t len = sizeof udpstat;
 543         u_long delivered;
 544
 545         if (zflag)
 546                 memset(&zerostat, 0, len);
 547         if (sysctlbyname("net.inet.udp.stats", &udpstat, &len,
 548             zflag ? &zerostat : NULL, zflag ? len : 0) < 0) {
 549                 warn("sysctl: net.inet.udp.stats");
 550                 return;
 551         }
 552
 553 #ifdef INET6
 554         if (udp_done != 0)
 555                 return;
 556         else
 557                 udp_done = 1;
 558 #endif
 559
 560         printf("%s:\n", name);
 561 #define p(f, m) if (udpstat.f || sflag <= 1) \
 562     printf(m, udpstat.f, plural(udpstat.f))
 563 #define p1a(f, m) if (udpstat.f || sflag <= 1) \
 564     printf(m, udpstat.f)
 565         p(udps_ipackets, "\t%lu datagram%s received\n");
 566         p1a(udps_hdrops, "\t%lu with incomplete header\n");
 567         p1a(udps_badlen, "\t%lu with bad data length field\n");
 568         p1a(udps_badsum, "\t%lu with bad checksum\n");
 569         p1a(udps_nosum, "\t%lu with no checksum\n");
 570         p1a(udps_noport, "\t%lu dropped due to no socket\n");
 571         p(udps_noportbcast,
 572             "\t%lu broadcast/multicast datagram%s dropped due to no socket\n");
 573         p1a(udps_fullsock, "\t%lu dropped due to full socket buffers\n");
 574         p1a(udpps_pcbhashmiss, "\t%lu not for hashed pcb\n");
 575         delivered = udpstat.udps_ipackets -
 576                     udpstat.udps_hdrops -
 577                     udpstat.udps_badlen -
 578                     udpstat.udps_badsum -
 579                     udpstat.udps_noport -
 580                     udpstat.udps_noportbcast -
 581                     udpstat.udps_fullsock;
 582         if (delivered || sflag <= 1)
 583                 printf("\t%lu delivered\n", delivered);
 584         p(udps_opackets, "\t%lu datagram%s output\n");
 585 #undef p
 586 #undef p1a
 587 }
 588
 589 /*
 590  * Dump CARP statistics structure.
 591  */
 592 void
 593 carp_stats(u_long off, const char *name, int af1 __unused)
 594 {
 595        struct carpstats carpstat, zerostat;
 596        size_t len = sizeof(struct carpstats);
 597
 598        if (zflag)
 599                memset(&zerostat, 0, len);
 600        if (sysctlbyname("net.inet.carp.stats", &carpstat, &len,
 601            zflag ? &zerostat : NULL, zflag ? len : 0) < 0) {
 602                warn("sysctl: net.inet.carp.stats");
 603                return;
 604        }
 605
 606        printf("%s:\n", name);
 607
 608 #define p(f, m) if (carpstat.f || sflag <= 1) \
 609        printf(m, (unsigned long long)carpstat.f, plural((int)carpstat.f))
 610 #define p2(f, m) if (carpstat.f || sflag <= 1) \
 611        printf(m, (unsigned long long)carpstat.f)
 612
 613        p(carps_ipackets, "\t%llu packet%s received (IPv4)\n");
 614        p(carps_ipackets6, "\t%llu packet%s received (IPv6)\n");
 615        p(carps_badttl, "\t\t%llu packet%s discarded for wrong TTL\n");
 616        p(carps_hdrops, "\t\t%llu packet%s shorter than header\n");
 617        p(carps_badsum, "\t\t%llu discarded for bad checksum%s\n");
 618        p(carps_badver, "\t\t%llu discarded packet%s with a bad version\n");
 619        p2(carps_badlen, "\t\t%llu discarded because packet too short\n");
 620        p2(carps_badauth, "\t\t%llu discarded for bad authentication\n");
 621        p2(carps_badvhid, "\t\t%llu discarded for bad vhid\n");
 622        p2(carps_badaddrs, "\t\t%llu discarded because of a bad address list\n");
 623        p(carps_opackets, "\t%llu packet%s sent (IPv4)\n");
 624        p(carps_opackets6, "\t%llu packet%s sent (IPv6)\n");
 625        p2(carps_onomem, "\t\t%llu send failed due to mbuf memory error\n");
 626 #if notyet
 627        p(carps_ostates, "\t\t%s state update%s sent\n");
 628 #endif
 629 #undef p
 630 #undef p2
 631 }
 632
 633 /*
 634  * Dump IP statistics structure.
 635  */
 636 void
 637 ip_stats(u_long off __unused, char *name, int af __unused)
 638 {
 639         struct ip_stats ipstat, *stattmp;
 640         struct ip_stats zerostat[SMP_MAXCPU];
 641         size_t len = sizeof(struct ip_stats) * SMP_MAXCPU;
 642         int cpucnt;
 643
 644         if (zflag)
 645                 memset(zerostat, 0, len);
 646         if ((stattmp = malloc(len)) == NULL) {
 647                 return;
 648         } else {
 649                 if (sysctlbyname("net.inet.ip.stats", stattmp, &len,
 650                         zflag ? zerostat : NULL, zflag ? len : 0) < 0) {
 651                                 warn("sysctl: net.inet.ip.stats");
 652                                 free(stattmp);
 653                                 return;
 654                 } else {
 655                         if ((stattmp = realloc(stattmp, len)) == NULL) {
 656                                 warn("ip_stats");
 657                                 return;
 658                         }
 659                 }
 660         }
 661         cpucnt = len / sizeof(struct ip_stats);
 662         ip_stats_agg(stattmp, &ipstat, cpucnt);
 663
 664         printf("%s:\n", name);
 665
 666 #define p(f, m) if (ipstat.f || sflag <= 1) \
 667     printf(m, ipstat.f, plural(ipstat.f))
 668 #define p1a(f, m) if (ipstat.f || sflag <= 1) \
 669     printf(m, ipstat.f)
 670
 671         p(ips_total, "\t%lu total packet%s received\n");
 672         p(ips_badsum, "\t%lu bad header checksum%s\n");
 673         p1a(ips_toosmall, "\t%lu with size smaller than minimum\n");
 674         p1a(ips_tooshort, "\t%lu with data size < data length\n");
 675         p1a(ips_toolong, "\t%lu with ip length > max ip packet size\n");
 676         p1a(ips_badhlen, "\t%lu with header length < data size\n");
 677         p1a(ips_badlen, "\t%lu with data length < header length\n");
 678         p1a(ips_badoptions, "\t%lu with bad options\n");
 679         p1a(ips_badvers, "\t%lu with incorrect version number\n");
 680         p(ips_fragments, "\t%lu fragment%s received\n");
 681         p(ips_fragdropped, "\t%lu fragment%s dropped (dup or out of space)\n");
 682         p(ips_fragtimeout, "\t%lu fragment%s dropped after timeout\n");
 683         p(ips_reassembled, "\t%lu packet%s reassembled ok\n");
 684         p(ips_delivered, "\t%lu packet%s for this host\n");
 685         p(ips_noproto, "\t%lu packet%s for unknown/unsupported protocol\n");
 686         p(ips_forward, "\t%lu packet%s forwarded");
 687         p(ips_fastforward, " (%lu packet%s fast forwarded)");
 688         if (ipstat.ips_forward || sflag <= 1)
 689                 putchar('\n');
 690         p(ips_cantforward, "\t%lu packet%s not forwardable\n");
 691         p(ips_notmember,
 692           "\t%lu packet%s received for unknown multicast group\n");
 693         p(ips_redirectsent, "\t%lu redirect%s sent\n");
 694         p(ips_localout, "\t%lu packet%s sent from this host\n");
 695         p(ips_rawout, "\t%lu packet%s sent with fabricated ip header\n");
 696         p(ips_odropped,
 697           "\t%lu output packet%s dropped due to no bufs, etc.\n");
 698         p(ips_noroute, "\t%lu output packet%s discarded due to no route\n");
 699         p(ips_fragmented, "\t%lu output datagram%s fragmented\n");
 700         p(ips_ofragments, "\t%lu fragment%s created\n");
 701         p(ips_cantfrag, "\t%lu datagram%s that can't be fragmented\n");
 702         p(ips_nogif, "\t%lu tunneling packet%s that can't find gif\n");
 703         p(ips_badaddr, "\t%lu datagram%s with bad address in header\n");
 704         free(stattmp);
 705 #undef p
 706 #undef p1a
 707 }
 708
 709 static  char *icmpnames[] = {
 710         "echo reply",
 711         "#1",
 712         "#2",
 713         "destination unreachable",
 714         "source quench",
 715         "routing redirect",
 716         "#6",
 717         "#7",
 718         "echo",
 719         "router advertisement",
 720         "router solicitation",
 721         "time exceeded",
 722         "parameter problem",
 723         "time stamp",
 724         "time stamp reply",
 725         "information request",
 726         "information request reply",
 727         "address mask request",
 728         "address mask reply",
 729 };
 730
 731 /*
 732  * Dump ICMP statistics.
 733  */
 734 void
 735 icmp_stats(u_long off __unused, char *name, int af __unused)
 736 {
 737         struct icmpstat icmpstat, zerostat;
 738         int i, first;
 739         int mib[4];             /* CTL_NET + PF_INET + IPPROTO_ICMP + req */
 740         size_t len;
 741
 742         mib[0] = CTL_NET;
 743         mib[1] = PF_INET;
 744         mib[2] = IPPROTO_ICMP;
 745         mib[3] = ICMPCTL_STATS;
 746
 747         len = sizeof icmpstat;
 748         if (zflag)
 749                 memset(&zerostat, 0, len);
 750         if (sysctl(mib, 4, &icmpstat, &len,
 751             zflag ? &zerostat : NULL, zflag ? len : 0) < 0) {
 752                 warn("sysctl: net.inet.icmp.stats");
 753                 return;
 754         }
 755
 756         printf("%s:\n", name);
 757
 758 #define p(f, m) if (icmpstat.f || sflag <= 1) \
 759     printf(m, icmpstat.f, plural(icmpstat.f))
 760 #define p1a(f, m) if (icmpstat.f || sflag <= 1) \
 761     printf(m, icmpstat.f)
 762 #define p2(f, m) if (icmpstat.f || sflag <= 1) \
 763     printf(m, icmpstat.f, plurales(icmpstat.f))
 764
 765         p(icps_error, "\t%lu call%s to icmp_error\n");
 766         p(icps_oldicmp,
 767             "\t%lu error%s not generated 'cuz old message was icmp\n");
 768         for (first = 1, i = 0; i < ICMP_MAXTYPE + 1; i++)
 769                 if (icmpstat.icps_outhist[i] != 0) {
 770                         if (first) {
 771                                 printf("\tOutput histogram:\n");
 772                                 first = 0;
 773                         }
 774                         printf("\t\t%s: %lu\n", icmpnames[i],
 775                                 icmpstat.icps_outhist[i]);
 776                 }
 777         p(icps_badcode, "\t%lu message%s with bad code fields\n");
 778         p(icps_tooshort, "\t%lu message%s < minimum length\n");
 779         p(icps_checksum, "\t%lu bad checksum%s\n");
 780         p(icps_badlen, "\t%lu message%s with bad length\n");
 781         p1a(icps_bmcastecho, "\t%lu multicast echo requests ignored\n");
 782         p1a(icps_bmcasttstamp, "\t%lu multicast timestamp requests ignored\n");
 783         for (first = 1, i = 0; i < ICMP_MAXTYPE + 1; i++)
 784                 if (icmpstat.icps_inhist[i] != 0) {
 785                         if (first) {
 786                                 printf("\tInput histogram:\n");
 787                                 first = 0;
 788                         }
 789                         printf("\t\t%s: %lu\n", icmpnames[i],
 790                                 icmpstat.icps_inhist[i]);
 791                 }
 792         p(icps_reflect, "\t%lu message response%s generated\n");
 793         p2(icps_badaddr, "\t%lu invalid return address%s\n");
 794         p(icps_noroute, "\t%lu no return route%s\n");
 795 #undef p
 796 #undef p1a
 797 #undef p2
 798         mib[3] = ICMPCTL_MASKREPL;
 799         len = sizeof i;
 800         if (sysctl(mib, 4, &i, &len, (void *)0, 0) < 0)
 801                 return;
 802         printf("\tICMP address mask responses are %sabled\n",
 803                i ? "en" : "dis");
 804 }
 805
 806 /*
 807  * Dump IGMP statistics structure.
 808  */
 809 void
 810 igmp_stats(u_long off __unused, char *name, int af __unused)
 811 {
 812         struct igmpstat igmpstat, zerostat;
 813         size_t len = sizeof igmpstat;
 814
 815         if (zflag)
 816                 memset(&zerostat, 0, len);
 817         if (sysctlbyname("net.inet.igmp.stats", &igmpstat, &len,
 818             zflag ? &zerostat : NULL, zflag ? len : 0) < 0) {
 819                 warn("sysctl: net.inet.igmp.stats");
 820                 return;
 821         }
 822
 823         printf("%s:\n", name);
 824
 825 #define p(f, m) if (igmpstat.f || sflag <= 1) \
 826     printf(m, igmpstat.f, plural(igmpstat.f))
 827 #define py(f, m) if (igmpstat.f || sflag <= 1) \
 828     printf(m, igmpstat.f, igmpstat.f != 1 ? "ies" : "y")
 829         p(igps_rcv_total, "\t%u message%s received\n");
 830         p(igps_rcv_tooshort, "\t%u message%s received with too few bytes\n");
 831         p(igps_rcv_badsum, "\t%u message%s received with bad checksum\n");
 832         py(igps_rcv_queries, "\t%u membership quer%s received\n");
 833         py(igps_rcv_badqueries, "\t%u membership quer%s received with invalid field(s)\n");
 834         p(igps_rcv_reports, "\t%u membership report%s received\n");
 835         p(igps_rcv_badreports, "\t%u membership report%s received with invalid field(s)\n");
 836         p(igps_rcv_ourreports, "\t%u membership report%s received for groups to which we belong\n");
 837         p(igps_snd_reports, "\t%u membership report%s sent\n");
 838 #undef p
 839 #undef py
 840 }
 841
 842 /*
 843  * Dump PIM statistics structure.
 844  */
 845 void
 846 pim_stats(u_long off __unused, char *name, int af1 __unused)
 847 {
 848         struct pimstat pimstat, zerostat;
 849         size_t len = sizeof pimstat;
 850
 851         if (zflag)
 852                 memset(&zerostat, 0, len);
 853         if (sysctlbyname("net.inet.pim.stats", &pimstat, &len,
 854             zflag ? &zerostat : NULL, zflag ? len : 0) < 0) {
 855                 if (errno != ENOENT)
 856                         warn("sysctl: net.inet.pim.stats");
 857                 return;
 858         }
 859
 860         printf("%s:\n", name);
 861
 862 #define p(f, m) if (pimstat.f || sflag <= 1) \
 863     printf(m, pimstat.f, plural(pimstat.f))
 864 #define py(f, m) if (pimstat.f || sflag <= 1) \
 865     printf(m, pimstat.f, pimstat.f != 1 ? "ies" : "y")
 866         p(pims_rcv_total_msgs, "\t%llu message%s received\n");
 867         p(pims_rcv_total_bytes, "\t%llu byte%s received\n");
 868         p(pims_rcv_tooshort, "\t%llu message%s received with too few bytes\n");
 869         p(pims_rcv_badsum, "\t%llu message%s received with bad checksum\n");
 870         p(pims_rcv_badversion, "\t%llu message%s received with bad version\n");
 871         p(pims_rcv_registers_msgs, "\t%llu data register message%s received\n");
 872         p(pims_rcv_registers_bytes, "\t%llu data register byte%s received\n");
 873         p(pims_rcv_registers_wrongiif, "\t%llu data register message%s received on wrong iif\n");
 874         p(pims_rcv_badregisters, "\t%llu bad register%s received\n");
 875         p(pims_snd_registers_msgs, "\t%llu data register message%s sent\n");
 876         p(pims_snd_registers_bytes, "\t%llu data register byte%s sent\n");
 877 #undef p
 878 #undef py
 879 }
 880
 881 /*
 882  * Pretty print an Internet address (net address + port).
 883  */
 884 void
 885 inetprint(struct in_addr *in, int port, const char *proto, int numeric_port)
 886 {
 887         struct servent *sp = 0;
 888         char line[80], *cp;
 889         int width;
 890
 891         if (Wflag)
 892             sprintf(line, "%s.", inetname(in));
 893         else
 894             sprintf(line, "%.*s.", (Aflag && !numeric_port) ? 12 : 16, inetname(in));
 895         cp = strchr(line, '\0');
 896         if (!numeric_port && port)
 897                 sp = getservbyport((int)port, proto);
 898         if (sp || port == 0)
 899                 sprintf(cp, "%.15s ", sp ? sp->s_name : "*");
 900         else
 901                 sprintf(cp, "%d ", ntohs((u_short)port));
 902         width = (Aflag && !Wflag) ? 17 : 21;
 903         if (Wflag)
 904             printf("%-*s ", width, line);
 905         else
 906             printf("%-*.*s ", width, width, line);
 907 }
 908
 909 /*
 910  * Construct an Internet address representation.
 911  * If numeric_addr has been supplied, give
 912  * numeric value, otherwise try for symbolic name.
 913  */
 914 char *
 915 inetname(struct in_addr *inp)
 916 {
 917         char *cp;
 918         static char line[MAXHOSTNAMELEN];
 919         struct hostent *hp;
 920         struct netent *np;
 921
 922         cp = 0;
 923         if (!numeric_addr && inp->s_addr != INADDR_ANY) {
 924                 int net = inet_netof(*inp);
 925                 int lna = inet_lnaof(*inp);
 926
 927                 if (lna == INADDR_ANY) {
 928                         np = getnetbyaddr(net, AF_INET);
 929                         if (np)
 930                                 cp = np->n_name;
 931                 }
 932                 if (cp == 0) {
 933                         hp = gethostbyaddr((char *)inp, sizeof (*inp), AF_INET);
 934                         if (hp) {
 935                                 cp = hp->h_name;
 936                                 trimdomain(cp, strlen(cp));
 937                         }
 938                 }
 939         }
 940         if (inp->s_addr == INADDR_ANY)
 941                 strcpy(line, "*");
 942         else if (cp) {
 943                 strncpy(line, cp, sizeof(line) - 1);
 944                 line[sizeof(line) - 1] = '\0';
 945         } else {
 946                 inp->s_addr = ntohl(inp->s_addr);
 947 #define C(x)    ((u_int)((x) & 0xff))
 948                 sprintf(line, "%u.%u.%u.%u", C(inp->s_addr >> 24),
 949                     C(inp->s_addr >> 16), C(inp->s_addr >> 8), C(inp->s_addr));
 950         }
 951         return (line);
 952 }