1 /* $NetBSD: if.c,v 1.94 2017/02/23 07:57:10 ozaki-r Exp $ */ 2 3 /* 4 * Copyright (c) 1983, 1988, 1993 5 * The Regents of the University of California. 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 * 3. Neither the name of the University nor the names of its contributors 16 * may be used to endorse or promote products derived from this software 17 * without specific prior written permission. 18 * 19 * THIS SOFTWARE IS PROVIDED BY THE REGENTS AND CONTRIBUTORS ``AS IS'' AND 20 * ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE 21 * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE 22 * ARE DISCLAIMED. IN NO EVENT SHALL THE REGENTS OR CONTRIBUTORS BE LIABLE 23 * FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL 24 * DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS 25 * OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) 26 * HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT 27 * LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY 28 * OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF 29 * SUCH DAMAGE. 30 */ 31 32 #include <sys/cdefs.h> 33 #ifndef lint 34 #if 0 35 static char sccsid[] = "from: @(#)if.c 8.2 (Berkeley) 2/21/94"; 36 #else 37 __RCSID("$NetBSD: if.c,v 1.94 2017/02/23 07:57:10 ozaki-r Exp $"); 38 #endif 39 #endif /* not lint */ 40 41 #include <sys/param.h> 42 #include <sys/types.h> 43 #include <sys/protosw.h> 44 #include <sys/socket.h> 45 #include <sys/time.h> 46 #include <sys/sysctl.h> 47 #include <sys/ioctl.h> 48 49 #include <net/if.h> 50 #include <net/if_dl.h> 51 #include <net/if_types.h> 52 #include <net/route.h> 53 #include <netinet/in.h> 54 #include <netinet/in_var.h> 55 #include <arpa/inet.h> 56 57 #include <kvm.h> 58 #include <signal.h> 59 #include <stdio.h> 60 #include <stdlib.h> 61 #include <string.h> 62 #include <unistd.h> 63 #include <netdb.h> 64 #include <err.h> 65 66 #include "netstat.h" 67 #include "rtutil.h" 68 #include "prog_ops.h" 69 70 #define MAXIF 100 71 72 #define HUMBUF_SIZE 7 73 74 struct iftot { 75 char ift_name[IFNAMSIZ]; /* interface name */ 76 u_quad_t ift_ip; /* input packets */ 77 u_quad_t ift_ib; /* input bytes */ 78 u_quad_t ift_ie; /* input errors */ 79 u_quad_t ift_op; /* output packets */ 80 u_quad_t ift_ob; /* output bytes */ 81 u_quad_t ift_oe; /* output errors */ 82 u_quad_t ift_co; /* collisions */ 83 u_quad_t ift_dr; /* drops */ 84 }; 85 86 static void set_lines(void); 87 static void print_addr(const int, struct sockaddr *, struct sockaddr **, 88 struct if_data *, struct ifnet *); 89 static void sidewaysintpr(u_int, u_long); 90 91 static void iftot_banner(struct iftot *); 92 static void iftot_print_sum(struct iftot *, struct iftot *); 93 static void iftot_print(struct iftot *, struct iftot *); 94 95 static void catchalarm(int); 96 static void get_rtaddrs(int, struct sockaddr *, struct sockaddr **); 97 static void fetchifs(void); 98 99 static void intpr_sysctl(void); 100 static void intpr_kvm(u_long, void (*)(const char *)); 101 102 struct iftot iftot[MAXIF], ip_cur, ip_old, sum_cur, sum_old; 103 static sig_atomic_t signalled; /* set when alarm goes off */ 104 105 static unsigned redraw_lines = 21; 106 107 static void 108 set_lines(void) 109 { 110 static bool first = true; 111 struct ttysize ts; 112 113 if (!first) 114 return; 115 first = false; 116 if (ioctl(STDOUT_FILENO, TIOCGSIZE, &ts) != -1 && ts.ts_lines) 117 redraw_lines = ts.ts_lines - 3; 118 } 119 120 121 /* 122 * Print a description of the network interfaces. 123 * NOTE: ifnetaddr is the location of the kernel global "ifnet", 124 * which is a TAILQ_HEAD. 125 */ 126 void 127 intpr(int interval, u_long ifnetaddr, void (*pfunc)(const char *)) 128 { 129 130 if (interval) { 131 sidewaysintpr((unsigned)interval, ifnetaddr); 132 return; 133 } 134 135 if (use_sysctl) { 136 intpr_sysctl(); 137 } else { 138 intpr_kvm(ifnetaddr, pfunc); 139 } 140 141 } 142 143 static void 144 intpr_header(void) 145 { 146 147 if (!sflag && !pflag) { 148 if (bflag) { 149 printf("%-5.5s %-5.5s %-13.13s %-17.17s " 150 "%10.10s %10.10s", 151 "Name", "Mtu", "Network", "Address", 152 "Ibytes", "Obytes"); 153 } else { 154 printf("%-5.5s %-5.5s %-13.13s %-17.17s " 155 "%8.8s %5.5s %8.8s %5.5s %5.5s", 156 "Name", "Mtu", "Network", "Address", "Ipkts", "Ierrs", 157 "Opkts", "Oerrs", "Colls"); 158 } 159 if (tflag) 160 printf(" %4.4s", "Time"); 161 if (dflag) 162 printf(" %5.5s", "Drops"); 163 putchar('\n'); 164 } 165 } 166 167 static void 168 intpr_sysctl(void) 169 { 170 struct if_msghdr *ifm; 171 int mib[6] = { CTL_NET, AF_ROUTE, 0, 0, NET_RT_IFLIST, 0 }; 172 static char *buf = NULL; 173 static size_t olen; 174 char *next, *lim, *cp; 175 struct rt_msghdr *rtm; 176 struct ifa_msghdr *ifam; 177 struct if_data *ifd = NULL; 178 struct sockaddr *sa, *rti_info[RTAX_MAX]; 179 struct sockaddr_dl *sdl; 180 uint64_t total = 0; 181 size_t len; 182 int did = 1, rtax = 0, n; 183 char name[IFNAMSIZ + 1]; /* + 1 for `*' */ 184 int ifindex = 0; 185 186 if (prog_sysctl(mib, 6, NULL, &len, NULL, 0) == -1) 187 err(1, "sysctl"); 188 if (len > olen) { 189 free(buf); 190 if ((buf = malloc(len)) == NULL) 191 err(1, NULL); 192 olen = len; 193 } 194 if (prog_sysctl(mib, 6, buf, &len, NULL, 0) == -1) 195 err(1, "sysctl"); 196 197 intpr_header(); 198 199 lim = buf + len; 200 for (next = buf; next < lim; next += rtm->rtm_msglen) { 201 rtm = (struct rt_msghdr *)next; 202 if (rtm->rtm_version != RTM_VERSION) 203 continue; 204 switch (rtm->rtm_type) { 205 case RTM_IFINFO: 206 total = 0; 207 ifm = (struct if_msghdr *)next; 208 ifd = &ifm->ifm_data; 209 210 sa = (struct sockaddr *)(ifm + 1); 211 get_rtaddrs(ifm->ifm_addrs, sa, rti_info); 212 213 sdl = (struct sockaddr_dl *)rti_info[RTAX_IFP]; 214 if (sdl == NULL || sdl->sdl_family != AF_LINK) { 215 continue; 216 } 217 bzero(name, sizeof(name)); 218 if (sdl->sdl_nlen >= IFNAMSIZ) 219 memcpy(name, sdl->sdl_data, IFNAMSIZ - 1); 220 else if (sdl->sdl_nlen > 0) 221 memcpy(name, sdl->sdl_data, sdl->sdl_nlen); 222 223 if (interface != 0 && strcmp(name, interface) != 0) 224 continue; 225 226 ifindex = sdl->sdl_index; 227 228 /* mark inactive interfaces with a '*' */ 229 cp = strchr(name, '\0'); 230 if ((ifm->ifm_flags & IFF_UP) == 0) 231 *cp++ = '*'; 232 *cp = '\0'; 233 234 if (qflag) { 235 total = ifd->ifi_ibytes + ifd->ifi_obytes + 236 ifd->ifi_ipackets + ifd->ifi_ierrors + 237 ifd->ifi_opackets + ifd->ifi_oerrors + 238 ifd->ifi_collisions; 239 if (dflag) 240 total += ifd->ifi_iqdrops; 241 if (total == 0) 242 continue; 243 } 244 /* Skip the first one */ 245 if (did) { 246 did = 0; 247 continue; 248 } 249 rtax = RTAX_IFP; 250 break; 251 case RTM_NEWADDR: 252 if (qflag && total == 0) 253 continue; 254 if (interface != 0 && strcmp(name, interface) != 0) 255 continue; 256 ifam = (struct ifa_msghdr *)next; 257 if ((ifam->ifam_addrs & (RTA_NETMASK | RTA_IFA | 258 RTA_BRD)) == 0) 259 break; 260 261 sa = (struct sockaddr *)(ifam + 1); 262 263 get_rtaddrs(ifam->ifam_addrs, sa, rti_info); 264 rtax = RTAX_IFA; 265 did = 1; 266 break; 267 default: 268 continue; 269 } 270 if (vflag) 271 n = strlen(name) < 5 ? 5 : strlen(name); 272 else 273 n = 5; 274 275 printf("%-*.*s %-5" PRIu64 " ", n, n, name, ifd->ifi_mtu); 276 print_addr(ifindex, rti_info[rtax], rti_info, ifd, NULL); 277 } 278 } 279 280 union ifaddr_u { 281 struct ifaddr ifa; 282 struct in_ifaddr in; 283 #ifdef INET6 284 struct in6_ifaddr in6; 285 #endif /* INET6 */ 286 }; 287 288 static void 289 intpr_kvm(u_long ifnetaddr, void (*pfunc)(const char *)) 290 { 291 struct ifnet ifnet; 292 union ifaddr_u ifaddr; 293 u_long ifaddraddr; 294 struct ifnet_head ifhead; /* TAILQ_HEAD */ 295 char name[IFNAMSIZ + 1]; /* + 1 for `*' */ 296 297 if (ifnetaddr == 0) { 298 printf("ifnet: symbol not defined\n"); 299 return; 300 } 301 302 /* 303 * Find the pointer to the first ifnet structure. Replace 304 * the pointer to the TAILQ_HEAD with the actual pointer 305 * to the first list element. 306 */ 307 if (kread(ifnetaddr, (char *)&ifhead, sizeof ifhead)) 308 return; 309 ifnetaddr = (u_long)ifhead.tqh_first; 310 311 intpr_header(); 312 313 ifaddraddr = 0; 314 while (ifnetaddr || ifaddraddr) { 315 char *cp; 316 int n; 317 318 if (ifaddraddr == 0) { 319 if (kread(ifnetaddr, (char *)&ifnet, sizeof ifnet)) 320 return; 321 memmove(name, ifnet.if_xname, IFNAMSIZ); 322 name[IFNAMSIZ - 1] = '\0'; /* sanity */ 323 ifnetaddr = (u_long)ifnet.if_list.tqe_next; 324 if (interface != 0 && strcmp(name, interface) != 0) 325 continue; 326 cp = strchr(name, '\0'); 327 328 if (pfunc) { 329 (*pfunc)(name); 330 continue; 331 } 332 333 if ((ifnet.if_flags & IFF_UP) == 0) 334 *cp++ = '*'; 335 *cp = '\0'; 336 ifaddraddr = (u_long)ifnet.if_addrlist.tqh_first; 337 } 338 if (vflag) 339 n = strlen(name) < 5 ? 5 : strlen(name); 340 else 341 n = 5; 342 printf("%-*.*s %-5llu ", n, n, name, 343 (unsigned long long)ifnet.if_mtu); 344 if (ifaddraddr == 0) { 345 printf("%-13.13s ", "none"); 346 printf("%-17.17s ", "none"); 347 } else { 348 struct sockaddr *sa; 349 350 if (kread(ifaddraddr, (char *)&ifaddr, sizeof ifaddr)) { 351 ifaddraddr = 0; 352 continue; 353 } 354 #define CP(x) ((char *)(x)) 355 cp = (CP(ifaddr.ifa.ifa_addr) - CP(ifaddraddr)) + 356 CP(&ifaddr); 357 sa = (struct sockaddr *)cp; 358 print_addr(ifnet.if_index, sa, (void *)&ifaddr, 359 &ifnet.if_data, &ifnet); 360 } 361 ifaddraddr = (u_long)ifaddr.ifa.ifa_list.tqe_next; 362 } 363 364 } 365 366 static void 367 mc_print(const int ifindex, const size_t ias, const char *oid, int *mcast_oids, 368 void (*pr)(const void *)) 369 { 370 uint8_t *mcast_addrs, *p; 371 const size_t incr = 2 * ias + sizeof(uint32_t); 372 size_t len; 373 374 if (mcast_oids[0] == 0) { 375 size_t oidlen = 4; 376 if (sysctlnametomib(oid, mcast_oids, &oidlen) == -1) { 377 warnx("'%s' not found", oid); 378 return; 379 } 380 if (oidlen != 3) { 381 warnx("Wrong OID path for '%s'", oid); 382 return; 383 } 384 } 385 386 if (mcast_oids[3] == ifindex) 387 return; 388 mcast_oids[3] = ifindex; 389 390 mcast_addrs = asysctl(mcast_oids, 4, &len); 391 if (mcast_addrs == NULL && len != 0) { 392 warn("failed to read '%s'", oid); 393 return; 394 } 395 if (len) { 396 p = mcast_addrs; 397 while (len >= incr) { 398 (*pr)((p + ias)); 399 p += incr; 400 len -= incr; 401 } 402 } 403 free(mcast_addrs); 404 } 405 406 #ifdef INET6 407 static void 408 ia6_print(const struct in6_addr *ia) 409 { 410 struct sockaddr_in6 as6; 411 char hbuf[NI_MAXHOST]; /* for getnameinfo() */ 412 int n; 413 414 memset(&as6, 0, sizeof(as6)); 415 as6.sin6_len = sizeof(struct sockaddr_in6); 416 as6.sin6_family = AF_INET6; 417 as6.sin6_addr = *ia; 418 inet6_getscopeid(&as6, INET6_IS_ADDR_MC_LINKLOCAL); 419 if (getnameinfo((struct sockaddr *)&as6, as6.sin6_len, hbuf, 420 sizeof(hbuf), NULL, 0, NI_NUMERICHOST) != 0) { 421 strlcpy(hbuf, "??", sizeof(hbuf)); 422 } 423 if (vflag) 424 n = strlen(hbuf) < 17 ? 17 : strlen(hbuf); 425 else 426 n = 17; 427 printf("\n%25s %-*.*s ", "", n, n, hbuf); 428 } 429 430 static void 431 mc6_print(const int ifindex) 432 { 433 static int mcast_oids[4]; 434 435 mc_print(ifindex, sizeof(struct in6_addr), "net.inet6.multicast", 436 mcast_oids, (void (*)(const void *))ia6_print); 437 } 438 #endif 439 440 static void 441 ia4_print(const struct in_addr *ia) 442 { 443 printf("\n%25s %-17.17s ", "", routename4(ia->s_addr, nflag)); 444 } 445 446 static void 447 mc4_print(const int ifindex) 448 { 449 static int mcast_oids[4]; 450 451 mc_print(ifindex, sizeof(struct in_addr), "net.inet.multicast", 452 mcast_oids, (void (*)(const void *))ia4_print); 453 } 454 455 static void 456 print_addr(const int ifindex, struct sockaddr *sa, 457 struct sockaddr **rtinfo, struct if_data *ifd, struct ifnet *ifnet) 458 { 459 char hexsep = '.'; /* for hexprint */ 460 static const char hexfmt[] = "%02x%c"; /* for hexprint */ 461 char hbuf[NI_MAXHOST]; /* for getnameinfo() */ 462 #ifdef INET6 463 const int niflag = NI_NUMERICHOST; 464 struct sockaddr_in6 *sin6, *netmask6; 465 #endif 466 struct sockaddr_in netmask; 467 struct sockaddr_in *sin; 468 char *cp; 469 int n, m; 470 471 switch (sa->sa_family) { 472 case AF_UNSPEC: 473 printf("%-13.13s ", "none"); 474 printf("%-17.17s ", "none"); 475 break; 476 case AF_INET: 477 sin = (struct sockaddr_in *)sa; 478 if (use_sysctl) { 479 netmask = *((struct sockaddr_in *)rtinfo[RTAX_NETMASK]); 480 } else { 481 struct in_ifaddr *ifaddr_in = (void *)rtinfo; 482 netmask.sin_addr.s_addr = ifaddr_in->ia_subnetmask; 483 } 484 cp = netname4(sin, &netmask, nflag); 485 if (vflag) 486 n = strlen(cp) < 13 ? 13 : strlen(cp); 487 else 488 n = 13; 489 printf("%-*.*s ", n, n, cp); 490 cp = routename4(sin->sin_addr.s_addr, nflag); 491 if (vflag) 492 n = strlen(cp) < 17 ? 17 : strlen(cp); 493 else 494 n = 17; 495 printf("%-*.*s ", n, n, cp); 496 497 if (!aflag) 498 break; 499 if (ifnet) { 500 u_long multiaddr; 501 struct in_multi inm; 502 union ifaddr_u *ifaddr = (union ifaddr_u *)rtinfo; 503 504 multiaddr = (u_long)ifaddr->in.ia_multiaddrs.lh_first; 505 while (multiaddr != 0) { 506 kread(multiaddr, (char *)&inm, sizeof inm); 507 ia4_print(&inm.inm_addr); 508 multiaddr = (u_long)inm.inm_list.le_next; 509 } 510 } else { 511 mc4_print(ifindex); 512 } 513 break; 514 #ifdef INET6 515 case AF_INET6: 516 sin6 = (struct sockaddr_in6 *)sa; 517 inet6_getscopeid(sin6, INET6_IS_ADDR_LINKLOCAL); 518 #ifdef __KAME__ 519 if (!vflag) 520 sin6->sin6_scope_id = 0; 521 #endif 522 523 if (use_sysctl) { 524 netmask6 = (struct sockaddr_in6 *)rtinfo[RTAX_NETMASK]; 525 } else { 526 struct in6_ifaddr *ifaddr_in6 = (void *)rtinfo; 527 netmask6 = &ifaddr_in6->ia_prefixmask; 528 } 529 530 cp = netname6(sin6, netmask6, nflag); 531 if (vflag) 532 n = strlen(cp) < 13 ? 13 : strlen(cp); 533 else 534 n = 13; 535 printf("%-*.*s ", n, n, cp); 536 if (getnameinfo((struct sockaddr *)sin6, 537 sin6->sin6_len, 538 hbuf, sizeof(hbuf), NULL, 0, 539 niflag) != 0) { 540 strlcpy(hbuf, "?", sizeof(hbuf)); 541 } 542 cp = hbuf; 543 if (vflag) 544 n = strlen(cp) < 17 ? 17 : strlen(cp); 545 else 546 n = 17; 547 printf("%-*.*s ", n, n, cp); 548 549 if (!aflag) 550 break; 551 if (ifnet) { 552 u_long multiaddr; 553 struct in6_multi inm; 554 union ifaddr_u *ifaddr = (union ifaddr_u *)rtinfo; 555 556 multiaddr = (u_long)ifaddr->in6._ia6_multiaddrs.lh_first; 557 while (multiaddr != 0) { 558 kread(multiaddr, (char *)&inm, sizeof inm); 559 ia6_print(&inm.in6m_addr); 560 multiaddr = (u_long)inm.in6m_entry.le_next; 561 } 562 } else { 563 mc6_print(ifindex); 564 } 565 break; 566 #endif /*INET6*/ 567 #ifndef SMALL 568 case AF_APPLETALK: 569 printf("atalk:%-7.7s ", 570 atalk_print(sa,0x10)); 571 printf("%-17.17s ", atalk_print(sa,0x0b)); 572 break; 573 #endif 574 case AF_LINK: 575 printf("%-13.13s ", "<Link>"); 576 if (getnameinfo(sa, sa->sa_len, 577 hbuf, sizeof(hbuf), NULL, 0, 578 NI_NUMERICHOST) != 0) { 579 strlcpy(hbuf, "?", sizeof(hbuf)); 580 } 581 cp = hbuf; 582 if (vflag) 583 n = strlen(cp) < 17 ? 17 : strlen(cp); 584 else 585 n = 17; 586 printf("%-*.*s ", n, n, cp); 587 break; 588 589 default: 590 m = printf("(%d)", sa->sa_family); 591 for (cp = sa->sa_len + (char *)sa; 592 --cp > sa->sa_data && (*cp == 0);) {} 593 n = cp - sa->sa_data + 1; 594 cp = sa->sa_data; 595 596 while (--n >= 0) 597 m += printf(hexfmt, *cp++ & 0xff, 598 n > 0 ? hexsep : ' '); 599 m = 32 - m; 600 while (m-- > 0) 601 putchar(' '); 602 break; 603 } 604 605 if (bflag) { 606 char humbuf[HUMBUF_SIZE]; 607 608 if (hflag && humanize_number(humbuf, sizeof(humbuf), 609 ifd->ifi_ibytes, "", HN_AUTOSCALE, HN_NOSPACE | HN_B) > 0) 610 printf("%10s ", humbuf); 611 else 612 printf("%10llu ", (unsigned long long)ifd->ifi_ibytes); 613 614 if (hflag && humanize_number(humbuf, sizeof(humbuf), 615 ifd->ifi_obytes, "", HN_AUTOSCALE, HN_NOSPACE | HN_B) > 0) 616 printf("%10s", humbuf); 617 else 618 printf("%10llu", (unsigned long long)ifd->ifi_obytes); 619 } else { 620 printf("%8llu %5llu %8llu %5llu %5llu", 621 (unsigned long long)ifd->ifi_ipackets, 622 (unsigned long long)ifd->ifi_ierrors, 623 (unsigned long long)ifd->ifi_opackets, 624 (unsigned long long)ifd->ifi_oerrors, 625 (unsigned long long)ifd->ifi_collisions); 626 } 627 if (tflag) 628 printf(" %4d", ifnet ? ifnet->if_timer : 0); 629 if (dflag) 630 printf(" %5lld", ifnet ? 631 (unsigned long long)ifnet->if_snd.ifq_drops : 632 ifd->ifi_iqdrops); 633 putchar('\n'); 634 } 635 636 static void 637 iftot_banner(struct iftot *ift) 638 { 639 if (bflag) 640 printf("%7.7s in %8.8s %6.6s out %5.5s", 641 ift->ift_name, " ", 642 ift->ift_name, " "); 643 else 644 printf("%5.5s in %5.5s%5.5s out %5.5s %5.5s", 645 ift->ift_name, " ", 646 ift->ift_name, " ", " "); 647 if (dflag) 648 printf(" %5.5s", " "); 649 650 if (bflag) 651 printf(" %7.7s in %8.8s %6.6s out %5.5s", 652 "total", " ", "total", " "); 653 else 654 printf(" %5.5s in %5.5s%5.5s out %5.5s %5.5s", 655 "total", " ", "total", " ", " "); 656 if (dflag) 657 printf(" %5.5s", " "); 658 putchar('\n'); 659 if (bflag) 660 printf("%10.10s %8.8s %10.10s %5.5s", 661 "bytes", " ", "bytes", " "); 662 else 663 printf("%8.8s %5.5s %8.8s %5.5s %5.5s", 664 "packets", "errs", "packets", "errs", "colls"); 665 if (dflag) 666 printf(" %5.5s", "drops"); 667 668 if (bflag) 669 printf(" %10.10s %8.8s %10.10s %5.5s", 670 "bytes", " ", "bytes", " "); 671 else 672 printf(" %8.8s %5.5s %8.8s %5.5s %5.5s", 673 "packets", "errs", "packets", "errs", "colls"); 674 if (dflag) 675 printf(" %5.5s", "drops"); 676 putchar('\n'); 677 fflush(stdout); 678 } 679 680 static void 681 iftot_print(struct iftot *cur, struct iftot *old) 682 { 683 if (bflag) 684 printf("%10" PRIu64 " %8.8s %10" PRIu64 " %5.5s", 685 cur->ift_ib - old->ift_ib, " ", 686 cur->ift_ob - old->ift_ob, " "); 687 else 688 printf("%8" PRIu64 " %5" PRIu64 " %8" PRIu64 " %5" PRIu64 " %5" PRIu64, 689 cur->ift_ip - old->ift_ip, 690 cur->ift_ie - old->ift_ie, 691 cur->ift_op - old->ift_op, 692 cur->ift_oe - old->ift_oe, 693 cur->ift_co - old->ift_co); 694 if (dflag) 695 printf(" %5" PRIu64, cur->ift_dr - old->ift_dr); 696 } 697 698 static void 699 iftot_print_sum(struct iftot *cur, struct iftot *old) 700 { 701 if (bflag) 702 printf(" %10" PRIu64 " %8.8s %10" PRIu64 " %5.5s", 703 cur->ift_ib - old->ift_ib, " ", 704 cur->ift_ob - old->ift_ob, " "); 705 else 706 printf(" %8" PRIu64 " %5" PRIu64 " %8" PRIu64 " %5" PRIu64 " %5" PRIu64, 707 cur->ift_ip - old->ift_ip, 708 cur->ift_ie - old->ift_ie, 709 cur->ift_op - old->ift_op, 710 cur->ift_oe - old->ift_oe, 711 cur->ift_co - old->ift_co); 712 713 if (dflag) 714 printf(" %5" PRIu64, cur->ift_dr - old->ift_dr); 715 } 716 717 __dead static void 718 sidewaysintpr_sysctl(unsigned interval) 719 { 720 struct itimerval it; 721 sigset_t emptyset; 722 sigset_t noalrm; 723 unsigned line; 724 725 set_lines(); 726 727 fetchifs(); 728 if (ip_cur.ift_name[0] == '\0') { 729 fprintf(stderr, "%s: %s: unknown interface\n", 730 getprogname(), interface); 731 exit(1); 732 } 733 734 sigemptyset(&emptyset); 735 sigemptyset(&noalrm); 736 sigaddset(&noalrm, SIGALRM); 737 sigprocmask(SIG_SETMASK, &noalrm, NULL); 738 739 signalled = 0; 740 (void)signal(SIGALRM, catchalarm); 741 742 it.it_interval.tv_sec = it.it_value.tv_sec = interval; 743 it.it_interval.tv_usec = it.it_value.tv_usec = 0; 744 setitimer(ITIMER_REAL, &it, NULL); 745 746 banner: 747 iftot_banner(&ip_cur); 748 749 line = 0; 750 bzero(&ip_old, sizeof(ip_old)); 751 bzero(&sum_old, sizeof(sum_old)); 752 loop: 753 bzero(&sum_cur, sizeof(sum_cur)); 754 755 fetchifs(); 756 757 iftot_print(&ip_cur, &ip_old); 758 759 ip_old = ip_cur; 760 761 iftot_print_sum(&sum_cur, &sum_old); 762 763 sum_old = sum_cur; 764 765 putchar('\n'); 766 fflush(stdout); 767 line++; 768 if (signalled == 0) { 769 sigsuspend(&emptyset); 770 } 771 signalled = 0; 772 if (line == redraw_lines) 773 goto banner; 774 goto loop; 775 /*NOTREACHED*/ 776 } 777 778 static void 779 sidewaysintpr_kvm(unsigned interval, u_long off) 780 { 781 struct itimerval it; 782 sigset_t emptyset; 783 sigset_t noalrm; 784 struct ifnet ifnet; 785 u_long firstifnet; 786 struct iftot *ip, *total; 787 unsigned line; 788 struct iftot *lastif, *sum, *interesting; 789 struct ifnet_head ifhead; /* TAILQ_HEAD */ 790 791 set_lines(); 792 793 /* 794 * Find the pointer to the first ifnet structure. Replace 795 * the pointer to the TAILQ_HEAD with the actual pointer 796 * to the first list element. 797 */ 798 if (kread(off, (char *)&ifhead, sizeof ifhead)) 799 return; 800 firstifnet = (u_long)ifhead.tqh_first; 801 802 lastif = iftot; 803 sum = iftot + MAXIF - 1; 804 total = sum - 1; 805 interesting = (interface == NULL) ? iftot : NULL; 806 for (off = firstifnet, ip = iftot; off;) { 807 if (kread(off, (char *)&ifnet, sizeof ifnet)) 808 break; 809 memset(ip->ift_name, 0, sizeof(ip->ift_name)); 810 snprintf(ip->ift_name, IFNAMSIZ, "%s", ifnet.if_xname); 811 if (interface && strcmp(ifnet.if_xname, interface) == 0) 812 interesting = ip; 813 ip++; 814 if (ip >= iftot + MAXIF - 2) 815 break; 816 off = (u_long)ifnet.if_list.tqe_next; 817 } 818 if (interesting == NULL) { 819 fprintf(stderr, "%s: %s: unknown interface\n", 820 getprogname(), interface); 821 exit(1); 822 } 823 lastif = ip; 824 825 sigemptyset(&emptyset); 826 sigemptyset(&noalrm); 827 sigaddset(&noalrm, SIGALRM); 828 sigprocmask(SIG_SETMASK, &noalrm, NULL); 829 830 signalled = 0; 831 (void)signal(SIGALRM, catchalarm); 832 833 it.it_interval.tv_sec = it.it_value.tv_sec = interval; 834 it.it_interval.tv_usec = it.it_value.tv_usec = 0; 835 setitimer(ITIMER_REAL, &it, NULL); 836 837 banner: 838 if (bflag) 839 printf("%7.7s in %8.8s %6.6s out %5.5s", 840 interesting->ift_name, " ", 841 interesting->ift_name, " "); 842 else 843 printf("%5.5s in %5.5s%5.5s out %5.5s %5.5s", 844 interesting->ift_name, " ", 845 interesting->ift_name, " ", " "); 846 if (dflag) 847 printf(" %5.5s", " "); 848 if (lastif - iftot > 0) { 849 if (bflag) 850 printf(" %7.7s in %8.8s %6.6s out %5.5s", 851 "total", " ", "total", " "); 852 else 853 printf(" %5.5s in %5.5s%5.5s out %5.5s %5.5s", 854 "total", " ", "total", " ", " "); 855 if (dflag) 856 printf(" %5.5s", " "); 857 } 858 for (ip = iftot; ip < iftot + MAXIF; ip++) { 859 ip->ift_ip = 0; 860 ip->ift_ib = 0; 861 ip->ift_ie = 0; 862 ip->ift_op = 0; 863 ip->ift_ob = 0; 864 ip->ift_oe = 0; 865 ip->ift_co = 0; 866 ip->ift_dr = 0; 867 } 868 putchar('\n'); 869 if (bflag) 870 printf("%10.10s %8.8s %10.10s %5.5s", 871 "bytes", " ", "bytes", " "); 872 else 873 printf("%8.8s %5.5s %8.8s %5.5s %5.5s", 874 "packets", "errs", "packets", "errs", "colls"); 875 if (dflag) 876 printf(" %5.5s", "drops"); 877 if (lastif - iftot > 0) { 878 if (bflag) 879 printf(" %10.10s %8.8s %10.10s %5.5s", 880 "bytes", " ", "bytes", " "); 881 else 882 printf(" %8.8s %5.5s %8.8s %5.5s %5.5s", 883 "packets", "errs", "packets", "errs", "colls"); 884 if (dflag) 885 printf(" %5.5s", "drops"); 886 } 887 putchar('\n'); 888 fflush(stdout); 889 line = 0; 890 loop: 891 sum->ift_ip = 0; 892 sum->ift_ib = 0; 893 sum->ift_ie = 0; 894 sum->ift_op = 0; 895 sum->ift_ob = 0; 896 sum->ift_oe = 0; 897 sum->ift_co = 0; 898 sum->ift_dr = 0; 899 for (off = firstifnet, ip = iftot; off && ip < lastif; ip++) { 900 if (kread(off, (char *)&ifnet, sizeof ifnet)) { 901 off = 0; 902 continue; 903 } 904 if (ip == interesting) { 905 if (bflag) { 906 char humbuf[HUMBUF_SIZE]; 907 908 if (hflag && humanize_number(humbuf, 909 sizeof(humbuf), 910 ifnet.if_ibytes - ip->ift_ib, "", 911 HN_AUTOSCALE, HN_NOSPACE | HN_B) > 0) 912 printf("%10s %8.8s ", humbuf, " "); 913 else 914 printf("%10llu %8.8s ", 915 (unsigned long long) 916 (ifnet.if_ibytes-ip->ift_ib), " "); 917 918 if (hflag && humanize_number(humbuf, 919 sizeof(humbuf), 920 ifnet.if_obytes - ip->ift_ob, "", 921 HN_AUTOSCALE, HN_NOSPACE | HN_B) > 0) 922 printf("%10s %5.5s", humbuf, " "); 923 else 924 printf("%10llu %5.5s", 925 (unsigned long long) 926 (ifnet.if_obytes-ip->ift_ob), " "); 927 } else { 928 printf("%8llu %5llu %8llu %5llu %5llu", 929 (unsigned long long) 930 (ifnet.if_ipackets - ip->ift_ip), 931 (unsigned long long) 932 (ifnet.if_ierrors - ip->ift_ie), 933 (unsigned long long) 934 (ifnet.if_opackets - ip->ift_op), 935 (unsigned long long) 936 (ifnet.if_oerrors - ip->ift_oe), 937 (unsigned long long) 938 (ifnet.if_collisions - ip->ift_co)); 939 } 940 if (dflag) 941 printf(" %5" PRIu64, 942 ifnet.if_snd.ifq_drops - ip->ift_dr); 943 } 944 ip->ift_ip = ifnet.if_ipackets; 945 ip->ift_ib = ifnet.if_ibytes; 946 ip->ift_ie = ifnet.if_ierrors; 947 ip->ift_op = ifnet.if_opackets; 948 ip->ift_ob = ifnet.if_obytes; 949 ip->ift_oe = ifnet.if_oerrors; 950 ip->ift_co = ifnet.if_collisions; 951 ip->ift_dr = ifnet.if_snd.ifq_drops; 952 sum->ift_ip += ip->ift_ip; 953 sum->ift_ib += ip->ift_ib; 954 sum->ift_ie += ip->ift_ie; 955 sum->ift_op += ip->ift_op; 956 sum->ift_ob += ip->ift_ob; 957 sum->ift_oe += ip->ift_oe; 958 sum->ift_co += ip->ift_co; 959 sum->ift_dr += ip->ift_dr; 960 off = (u_long)ifnet.if_list.tqe_next; 961 } 962 if (lastif - iftot > 0) { 963 if (bflag) { 964 char humbuf[HUMBUF_SIZE]; 965 966 if (hflag && humanize_number(humbuf, 967 sizeof(humbuf), sum->ift_ib - total->ift_ib, "", 968 HN_AUTOSCALE, HN_NOSPACE | HN_B) > 0) 969 printf(" %10s %8.8s ", humbuf, " "); 970 else 971 printf(" %10llu %8.8s ", 972 (unsigned long long) 973 (sum->ift_ib - total->ift_ib), " "); 974 975 if (hflag && humanize_number(humbuf, 976 sizeof(humbuf), sum->ift_ob - total->ift_ob, "", 977 HN_AUTOSCALE, HN_NOSPACE | HN_B) > 0) 978 printf("%10s %5.5s", humbuf, " "); 979 else 980 printf("%10llu %5.5s", 981 (unsigned long long) 982 (sum->ift_ob - total->ift_ob), " "); 983 } else { 984 printf(" %8llu %5llu %8llu %5llu %5llu", 985 (unsigned long long) 986 (sum->ift_ip - total->ift_ip), 987 (unsigned long long) 988 (sum->ift_ie - total->ift_ie), 989 (unsigned long long) 990 (sum->ift_op - total->ift_op), 991 (unsigned long long) 992 (sum->ift_oe - total->ift_oe), 993 (unsigned long long) 994 (sum->ift_co - total->ift_co)); 995 } 996 if (dflag) 997 printf(" %5llu", 998 (unsigned long long)(sum->ift_dr - total->ift_dr)); 999 } 1000 *total = *sum; 1001 putchar('\n'); 1002 fflush(stdout); 1003 line++; 1004 if (signalled == 0) { 1005 sigsuspend(&emptyset); 1006 } 1007 signalled = 0; 1008 if (line == redraw_lines) 1009 goto banner; 1010 goto loop; 1011 /*NOTREACHED*/ 1012 } 1013 1014 /* 1015 * Print a running summary of interface statistics. 1016 * Repeat display every interval seconds, showing statistics 1017 * collected over that interval. Assumes that interval is non-zero. 1018 * First line printed at top of screen is always cumulative. 1019 */ 1020 static void 1021 sidewaysintpr(unsigned int interval, u_long off) 1022 { 1023 1024 if (use_sysctl) { 1025 sidewaysintpr_sysctl(interval); 1026 } else { 1027 sidewaysintpr_kvm(interval, off); 1028 } 1029 } 1030 1031 /* 1032 * Called if an interval expires before sidewaysintpr has completed a loop. 1033 * Sets a flag to not wait for the alarm. 1034 */ 1035 static void 1036 catchalarm(int signo) 1037 { 1038 1039 signalled = true; 1040 } 1041 1042 static void 1043 get_rtaddrs(int addrs, struct sockaddr *sa, struct sockaddr **rti_info) 1044 { 1045 int i; 1046 1047 for (i = 0; i < RTAX_MAX; i++) { 1048 if (addrs & (1 << i)) { 1049 rti_info[i] = sa; 1050 sa = (struct sockaddr *)((char *)(sa) + 1051 RT_ROUNDUP(sa->sa_len)); 1052 } else 1053 rti_info[i] = NULL; 1054 } 1055 } 1056 1057 static void 1058 fetchifs(void) 1059 { 1060 struct if_msghdr *ifm; 1061 int mib[6] = { CTL_NET, AF_ROUTE, 0, 0, NET_RT_IFLIST, 0 }; 1062 struct rt_msghdr *rtm; 1063 struct if_data *ifd = NULL; 1064 struct sockaddr *sa, *rti_info[RTAX_MAX]; 1065 struct sockaddr_dl *sdl; 1066 static char *buf = NULL; 1067 static size_t olen; 1068 char *next, *lim; 1069 char name[IFNAMSIZ]; 1070 size_t len; 1071 1072 if (prog_sysctl(mib, 6, NULL, &len, NULL, 0) == -1) 1073 err(1, "sysctl"); 1074 if (len > olen) { 1075 free(buf); 1076 if ((buf = malloc(len)) == NULL) 1077 err(1, NULL); 1078 olen = len; 1079 } 1080 if (prog_sysctl(mib, 6, buf, &len, NULL, 0) == -1) 1081 err(1, "sysctl"); 1082 1083 lim = buf + len; 1084 for (next = buf; next < lim; next += rtm->rtm_msglen) { 1085 rtm = (struct rt_msghdr *)next; 1086 if (rtm->rtm_version != RTM_VERSION) 1087 continue; 1088 switch (rtm->rtm_type) { 1089 case RTM_IFINFO: 1090 ifm = (struct if_msghdr *)next; 1091 ifd = &ifm->ifm_data; 1092 1093 sa = (struct sockaddr *)(ifm + 1); 1094 get_rtaddrs(ifm->ifm_addrs, sa, rti_info); 1095 1096 sdl = (struct sockaddr_dl *)rti_info[RTAX_IFP]; 1097 if (sdl == NULL || sdl->sdl_family != AF_LINK) 1098 continue; 1099 bzero(name, sizeof(name)); 1100 if (sdl->sdl_nlen >= IFNAMSIZ) 1101 memcpy(name, sdl->sdl_data, IFNAMSIZ - 1); 1102 else if (sdl->sdl_nlen > 0) 1103 memcpy(name, sdl->sdl_data, sdl->sdl_nlen); 1104 1105 if (interface != 0 && !strcmp(name, interface)) { 1106 strlcpy(ip_cur.ift_name, name, 1107 sizeof(ip_cur.ift_name)); 1108 ip_cur.ift_ip = ifd->ifi_ipackets; 1109 ip_cur.ift_ib = ifd->ifi_ibytes; 1110 ip_cur.ift_ie = ifd->ifi_ierrors; 1111 ip_cur.ift_op = ifd->ifi_opackets; 1112 ip_cur.ift_ob = ifd->ifi_obytes; 1113 ip_cur.ift_oe = ifd->ifi_oerrors; 1114 ip_cur.ift_co = ifd->ifi_collisions; 1115 ip_cur.ift_dr = ifd->ifi_iqdrops; 1116 } 1117 1118 sum_cur.ift_ip += ifd->ifi_ipackets; 1119 sum_cur.ift_ib += ifd->ifi_ibytes; 1120 sum_cur.ift_ie += ifd->ifi_ierrors; 1121 sum_cur.ift_op += ifd->ifi_opackets; 1122 sum_cur.ift_ob += ifd->ifi_obytes; 1123 sum_cur.ift_oe += ifd->ifi_oerrors; 1124 sum_cur.ift_co += ifd->ifi_collisions; 1125 sum_cur.ift_dr += ifd->ifi_iqdrops; 1126 break; 1127 } 1128 } 1129 if (interface == NULL) { 1130 strlcpy(ip_cur.ift_name, name, 1131 sizeof(ip_cur.ift_name)); 1132 ip_cur.ift_ip = ifd->ifi_ipackets; 1133 ip_cur.ift_ib = ifd->ifi_ibytes; 1134 ip_cur.ift_ie = ifd->ifi_ierrors; 1135 ip_cur.ift_op = ifd->ifi_opackets; 1136 ip_cur.ift_ob = ifd->ifi_obytes; 1137 ip_cur.ift_oe = ifd->ifi_oerrors; 1138 ip_cur.ift_co = ifd->ifi_collisions; 1139 ip_cur.ift_dr = ifd->ifi_iqdrops; 1140 } 1141 } 1142