10Sstevel@tonic-gate /* 20Sstevel@tonic-gate * CDDL HEADER START 30Sstevel@tonic-gate * 40Sstevel@tonic-gate * The contents of this file are subject to the terms of the 51676Sjpk * Common Development and Distribution License (the "License"). 61676Sjpk * You may not use this file except in compliance with the License. 70Sstevel@tonic-gate * 80Sstevel@tonic-gate * You can obtain a copy of the license at usr/src/OPENSOLARIS.LICENSE 90Sstevel@tonic-gate * or http://www.opensolaris.org/os/licensing. 100Sstevel@tonic-gate * See the License for the specific language governing permissions 110Sstevel@tonic-gate * and limitations under the License. 120Sstevel@tonic-gate * 130Sstevel@tonic-gate * When distributing Covered Code, include this CDDL HEADER in each 140Sstevel@tonic-gate * file and include the License file at usr/src/OPENSOLARIS.LICENSE. 150Sstevel@tonic-gate * If applicable, add the following below this CDDL HEADER, with the 160Sstevel@tonic-gate * fields enclosed by brackets "[]" replaced with your own identifying 170Sstevel@tonic-gate * information: Portions Copyright [yyyy] [name of copyright owner] 180Sstevel@tonic-gate * 190Sstevel@tonic-gate * CDDL HEADER END 200Sstevel@tonic-gate */ 210Sstevel@tonic-gate /* 22*3628Sss150715 * Copyright 2007 Sun Microsystems, Inc. All rights reserved. 230Sstevel@tonic-gate * Use is subject to license terms. 240Sstevel@tonic-gate */ 250Sstevel@tonic-gate 260Sstevel@tonic-gate #pragma ident "%Z%%M% %I% %E% SMI" /* SunOS */ 270Sstevel@tonic-gate 280Sstevel@tonic-gate #include <stdio.h> 290Sstevel@tonic-gate #include <string.h> 300Sstevel@tonic-gate #include <errno.h> 310Sstevel@tonic-gate #include <fcntl.h> 320Sstevel@tonic-gate #include <setjmp.h> 330Sstevel@tonic-gate #include <sys/types.h> 340Sstevel@tonic-gate #include <sys/signal.h> 350Sstevel@tonic-gate #include <sys/time.h> 360Sstevel@tonic-gate #include <sys/socket.h> 370Sstevel@tonic-gate #include <sys/sockio.h> 380Sstevel@tonic-gate #include <net/if.h> 390Sstevel@tonic-gate #include <netinet/in_systm.h> 400Sstevel@tonic-gate #include <netinet/in.h> 410Sstevel@tonic-gate #include <netinet/ip.h> 420Sstevel@tonic-gate #include <sys/pfmod.h> 430Sstevel@tonic-gate #include <netinet/if_ether.h> 440Sstevel@tonic-gate #include <sys/mman.h> 450Sstevel@tonic-gate #include <sys/stat.h> 460Sstevel@tonic-gate #include <sys/stropts.h> 470Sstevel@tonic-gate #include <sys/bufmod.h> 480Sstevel@tonic-gate 490Sstevel@tonic-gate #include <unistd.h> 500Sstevel@tonic-gate #include <stropts.h> 510Sstevel@tonic-gate #include <stdlib.h> 520Sstevel@tonic-gate #include <ctype.h> 530Sstevel@tonic-gate #include <values.h> 540Sstevel@tonic-gate #include <libdlpi.h> 550Sstevel@tonic-gate 560Sstevel@tonic-gate #include "snoop.h" 570Sstevel@tonic-gate 581676Sjpk /* 591676Sjpk * Old header format. 601676Sjpk * Actually two concatenated structs: nit_bufhdr + nit_head 611676Sjpk */ 621676Sjpk struct ohdr { 631676Sjpk /* nit_bufhdr */ 641676Sjpk int o_msglen; 651676Sjpk int o_totlen; 661676Sjpk /* nit_head */ 671676Sjpk struct timeval o_time; 681676Sjpk int o_drops; 691676Sjpk int o_len; 701676Sjpk }; 711676Sjpk 721676Sjpk static void scan(char *, int, int, int, int, void (*)(), int, int, int); 730Sstevel@tonic-gate void convert_to_network(); 740Sstevel@tonic-gate void convert_from_network(); 751676Sjpk static void convert_old(struct ohdr *); 760Sstevel@tonic-gate extern sigjmp_buf jmp_env, ojmp_env; 77*3628Sss150715 static dlpi_info_t dlinfo; 781676Sjpk static char *bufp; /* pointer to read buffer */ 790Sstevel@tonic-gate 801676Sjpk static int strioctl(int, int, int, int, void *); 81410Skcpoon 820Sstevel@tonic-gate /* 83*3628Sss150715 * Open up the device in raw mode and passive mode 84*3628Sss150715 * (see dlpi_open(3DLPI)) and start finding out something about it, 85*3628Sss150715 * especially stuff about the data link headers. We need that information 860Sstevel@tonic-gate * to build the proper packet filters. 870Sstevel@tonic-gate */ 88410Skcpoon boolean_t 89*3628Sss150715 check_device(dlpi_handle_t *dhp, char **devicep) 900Sstevel@tonic-gate { 91*3628Sss150715 int retval; 92*3628Sss150715 930Sstevel@tonic-gate /* 940Sstevel@tonic-gate * Determine which network device 950Sstevel@tonic-gate * to use if none given. 960Sstevel@tonic-gate * Should get back a value like "le0". 970Sstevel@tonic-gate */ 980Sstevel@tonic-gate if (*devicep == NULL) { 990Sstevel@tonic-gate char *cbuf; 1000Sstevel@tonic-gate static struct ifconf ifc; 1010Sstevel@tonic-gate static struct ifreq *ifr; 1020Sstevel@tonic-gate int s; 1030Sstevel@tonic-gate int n; 1040Sstevel@tonic-gate int numifs; 1050Sstevel@tonic-gate unsigned bufsize; 1060Sstevel@tonic-gate 1070Sstevel@tonic-gate if ((s = socket(AF_INET, SOCK_DGRAM, 0)) < 0) 1080Sstevel@tonic-gate pr_err("socket"); 1090Sstevel@tonic-gate 1100Sstevel@tonic-gate if (ioctl(s, SIOCGIFNUM, (char *)&numifs) < 0) { 1110Sstevel@tonic-gate pr_err("check_device: ioctl SIOCGIFNUM"); 1120Sstevel@tonic-gate (void) close(s); 1130Sstevel@tonic-gate s = -1; 114410Skcpoon return (B_FALSE); 1150Sstevel@tonic-gate } 1160Sstevel@tonic-gate 1170Sstevel@tonic-gate bufsize = numifs * sizeof (struct ifreq); 1180Sstevel@tonic-gate cbuf = (char *)malloc(bufsize); 1190Sstevel@tonic-gate if (cbuf == NULL) { 1200Sstevel@tonic-gate pr_err("out of memory\n"); 1210Sstevel@tonic-gate (void) close(s); 1220Sstevel@tonic-gate s = -1; 123410Skcpoon return (B_FALSE); 1240Sstevel@tonic-gate } 1250Sstevel@tonic-gate ifc.ifc_len = bufsize; 1260Sstevel@tonic-gate ifc.ifc_buf = cbuf; 1270Sstevel@tonic-gate if (ioctl(s, SIOCGIFCONF, (char *)&ifc) < 0) { 1280Sstevel@tonic-gate pr_err("check_device: ioctl SIOCGIFCONF"); 1290Sstevel@tonic-gate (void) close(s); 1300Sstevel@tonic-gate s = -1; 1310Sstevel@tonic-gate (void) free(cbuf); 132410Skcpoon return (B_FALSE); 1330Sstevel@tonic-gate } 1340Sstevel@tonic-gate n = ifc.ifc_len / sizeof (struct ifreq); 1350Sstevel@tonic-gate ifr = ifc.ifc_req; 1360Sstevel@tonic-gate for (; n > 0; n--, ifr++) { 1370Sstevel@tonic-gate if (strchr(ifr->ifr_name, ':') != NULL) 1380Sstevel@tonic-gate continue; 1390Sstevel@tonic-gate if (ioctl(s, SIOCGIFFLAGS, (char *)ifr) < 0) 1400Sstevel@tonic-gate pr_err("ioctl SIOCGIFFLAGS"); 1410Sstevel@tonic-gate if ((ifr->ifr_flags & 1420Sstevel@tonic-gate (IFF_VIRTUAL|IFF_LOOPBACK|IFF_UP| 1430Sstevel@tonic-gate IFF_RUNNING)) == (IFF_UP|IFF_RUNNING)) 1440Sstevel@tonic-gate break; 1450Sstevel@tonic-gate } 1460Sstevel@tonic-gate 1470Sstevel@tonic-gate if (n == 0) 1480Sstevel@tonic-gate pr_err("No network interface devices found"); 1490Sstevel@tonic-gate 1500Sstevel@tonic-gate *devicep = ifr->ifr_name; 1510Sstevel@tonic-gate (void) close(s); 1520Sstevel@tonic-gate } 1530Sstevel@tonic-gate 154*3628Sss150715 retval = dlpi_open(*devicep, dhp, DLPI_PASSIVE|DLPI_RAW); 155*3628Sss150715 if (retval != DLPI_SUCCESS) { 156*3628Sss150715 pr_err("cannot open \"%s\": %s", *devicep, 157*3628Sss150715 dlpi_strerror(retval)); 1580Sstevel@tonic-gate } 1590Sstevel@tonic-gate 160*3628Sss150715 if ((retval = dlpi_info(*dhp, &dlinfo, 0)) != DLPI_SUCCESS) 161*3628Sss150715 pr_errdlpi(*dhp, "dlpi_info failed", retval); 1620Sstevel@tonic-gate 1630Sstevel@tonic-gate for (interface = &INTERFACES[0]; interface->mac_type != -1; interface++) 164*3628Sss150715 if (interface->mac_type == dlinfo.di_mactype) 1650Sstevel@tonic-gate break; 1660Sstevel@tonic-gate 167*3628Sss150715 /* allow limited functionality even if interface isn't known */ 1680Sstevel@tonic-gate if (interface->mac_type == -1) { 169*3628Sss150715 (void) fprintf(stderr, "snoop: WARNING: Mac Type = %x " 170*3628Sss150715 "not supported\n", dlinfo.di_mactype); 1710Sstevel@tonic-gate } 1720Sstevel@tonic-gate 1730Sstevel@tonic-gate /* for backward compatibility, allow known interface mtu_sizes */ 174*3628Sss150715 if (interface->mtu_size > dlinfo.di_max_sdu) 175*3628Sss150715 dlinfo.di_max_sdu = interface->mtu_size; 1760Sstevel@tonic-gate 1772760Sdg199075 return (interface->try_kernel_filter); 1780Sstevel@tonic-gate } 1790Sstevel@tonic-gate 1800Sstevel@tonic-gate /* 1810Sstevel@tonic-gate * Do whatever is necessary to initialize the interface 182*3628Sss150715 * for packet capture. Bind the device opened in check_device(), set 183*3628Sss150715 * promiscuous mode, push the streams buffer module and packet filter 184*3628Sss150715 * module, set various buffer parameters. 1850Sstevel@tonic-gate */ 1860Sstevel@tonic-gate void 187*3628Sss150715 initdevice(dlpi_handle_t dh, ulong_t snaplen, ulong_t chunksize, 188*3628Sss150715 struct timeval *timeout, struct Pf_ext_packetfilt *fp) 1890Sstevel@tonic-gate { 1900Sstevel@tonic-gate extern int Pflg; 191*3628Sss150715 int retv; 192*3628Sss150715 int netfd; 1930Sstevel@tonic-gate 194*3628Sss150715 retv = dlpi_bind(dh, DLPI_ANY_SAP, NULL); 195*3628Sss150715 if (retv != DLPI_SUCCESS) 196*3628Sss150715 pr_errdlpi(dh, "cannot bind on", retv); 1970Sstevel@tonic-gate 198*3628Sss150715 (void) fprintf(stderr, "Using device %s ", dlpi_linkname(dh)); 1990Sstevel@tonic-gate 2000Sstevel@tonic-gate /* 2010Sstevel@tonic-gate * If Pflg not set - use physical level 2020Sstevel@tonic-gate * promiscuous mode. Otherwise - just SAP level. 2030Sstevel@tonic-gate */ 2040Sstevel@tonic-gate if (!Pflg) { 2050Sstevel@tonic-gate (void) fprintf(stderr, "(promiscuous mode)\n"); 206*3628Sss150715 retv = dlpi_promiscon(dh, DL_PROMISC_PHYS); 207*3628Sss150715 if (retv != DLPI_SUCCESS) { 208*3628Sss150715 pr_errdlpi(dh, "promiscuous mode(physical) failed", 209*3628Sss150715 retv); 210*3628Sss150715 } 2110Sstevel@tonic-gate } else { 2120Sstevel@tonic-gate (void) fprintf(stderr, "(non promiscuous)\n"); 213*3628Sss150715 retv = dlpi_promiscon(dh, DL_PROMISC_MULTI); 214*3628Sss150715 if (retv != DLPI_SUCCESS) { 215*3628Sss150715 pr_errdlpi(dh, "promiscuous mode(multicast) failed", 216*3628Sss150715 retv); 217*3628Sss150715 } 2180Sstevel@tonic-gate } 2190Sstevel@tonic-gate 220*3628Sss150715 retv = dlpi_promiscon(dh, DL_PROMISC_SAP); 221*3628Sss150715 if (retv != DLPI_SUCCESS) 222*3628Sss150715 pr_errdlpi(dh, "promiscuous mode(SAP) failed", retv); 2230Sstevel@tonic-gate 224*3628Sss150715 netfd = dlpi_fd(dh); 2250Sstevel@tonic-gate 2260Sstevel@tonic-gate if (fp) { 2270Sstevel@tonic-gate /* 2280Sstevel@tonic-gate * push and configure the packet filtering module 2290Sstevel@tonic-gate */ 230*3628Sss150715 if (ioctl(netfd, I_PUSH, "pfmod") < 0) 231*3628Sss150715 pr_errdlpi(dh, "cannot push \"pfmod\"", DL_SYSERR); 2320Sstevel@tonic-gate 233410Skcpoon if (strioctl(netfd, PFIOCSETF, -1, sizeof (*fp), 234*3628Sss150715 (char *)fp) < 0) 235*3628Sss150715 pr_errdlpi(dh, "PFIOCSETF", DL_SYSERR); 2360Sstevel@tonic-gate } 2370Sstevel@tonic-gate 238*3628Sss150715 if (ioctl(netfd, I_PUSH, "bufmod") < 0) 239*3628Sss150715 pr_errdlpi(dh, "cannot push \"bufmod\"", DL_SYSERR); 240*3628Sss150715 2410Sstevel@tonic-gate if (strioctl(netfd, SBIOCSTIME, -1, sizeof (struct timeval), 242*3628Sss150715 (char *)timeout) < 0) 243*3628Sss150715 pr_errdlpi(dh, "SBIOCSTIME", DL_SYSERR); 2440Sstevel@tonic-gate 2450Sstevel@tonic-gate if (strioctl(netfd, SBIOCSCHUNK, -1, sizeof (uint_t), 246*3628Sss150715 (char *)&chunksize) < 0) 247*3628Sss150715 pr_errdlpi(dh, "SBIOCGCHUNK", DL_SYSERR); 2480Sstevel@tonic-gate 2490Sstevel@tonic-gate if (strioctl(netfd, SBIOCSSNAP, -1, sizeof (uint_t), 250*3628Sss150715 (char *)&snaplen) < 0) 251*3628Sss150715 pr_errdlpi(dh, "SBIOCSSNAP", DL_SYSERR); 2520Sstevel@tonic-gate 2530Sstevel@tonic-gate /* 2540Sstevel@tonic-gate * Flush the read queue, to get rid of anything that 2550Sstevel@tonic-gate * accumulated before the device reached its final configuration. 2560Sstevel@tonic-gate */ 257*3628Sss150715 if (ioctl(netfd, I_FLUSH, FLUSHR) < 0) 258*3628Sss150715 pr_errdlpi(dh, "cannot flush \"I_FLUSH\"", DL_SYSERR); 2590Sstevel@tonic-gate } 2600Sstevel@tonic-gate 2610Sstevel@tonic-gate /* 2620Sstevel@tonic-gate * Read packets from the network. Initdevice is called in 2630Sstevel@tonic-gate * here to set up the network interface for reading of 2640Sstevel@tonic-gate * raw ethernet packets in promiscuous mode into a buffer. 2650Sstevel@tonic-gate * Packets are read and either written directly to a file 2660Sstevel@tonic-gate * or interpreted for display on the fly. 2670Sstevel@tonic-gate */ 2680Sstevel@tonic-gate void 269*3628Sss150715 net_read(dlpi_handle_t dh, size_t chunksize, int filter, void (*proc)(), 270*3628Sss150715 int flags) 2710Sstevel@tonic-gate { 272*3628Sss150715 int retval; 2730Sstevel@tonic-gate extern int count; 274*3628Sss150715 size_t msglen; 2750Sstevel@tonic-gate 2760Sstevel@tonic-gate count = 0; 2770Sstevel@tonic-gate 2780Sstevel@tonic-gate /* allocate a read buffer */ 2790Sstevel@tonic-gate bufp = malloc(chunksize); 2800Sstevel@tonic-gate if (bufp == NULL) 281*3628Sss150715 pr_err("no memory for %d buffer", chunksize); 2820Sstevel@tonic-gate 2830Sstevel@tonic-gate /* 284*3628Sss150715 * read frames 2850Sstevel@tonic-gate */ 2860Sstevel@tonic-gate for (;;) { 287*3628Sss150715 msglen = chunksize; 288*3628Sss150715 retval = dlpi_recv(dh, NULL, NULL, bufp, &msglen, -1, NULL); 2890Sstevel@tonic-gate 290*3628Sss150715 if (retval != DLPI_SUCCESS || quitting) 2910Sstevel@tonic-gate break; 2920Sstevel@tonic-gate 293*3628Sss150715 if (msglen != 0) 294*3628Sss150715 scan(bufp, msglen, filter, 0, 0, proc, 0, 0, flags); 2950Sstevel@tonic-gate } 2960Sstevel@tonic-gate 2970Sstevel@tonic-gate free(bufp); 2980Sstevel@tonic-gate 299*3628Sss150715 if (!quitting) 300*3628Sss150715 pr_errdlpi(dh, "network read failed", retval); 3010Sstevel@tonic-gate } 3020Sstevel@tonic-gate 3030Sstevel@tonic-gate #ifdef DEBUG 3040Sstevel@tonic-gate /* 3050Sstevel@tonic-gate * corrupt: simulate packet corruption for debugging interpreters 3060Sstevel@tonic-gate */ 3070Sstevel@tonic-gate void 3080Sstevel@tonic-gate corrupt(volatile char *pktp, volatile char *pstop, char *buf, 3090Sstevel@tonic-gate volatile char *bufstop) 3100Sstevel@tonic-gate { 3110Sstevel@tonic-gate int c; 3120Sstevel@tonic-gate int i; 3130Sstevel@tonic-gate int p; 3140Sstevel@tonic-gate int li = rand() % (pstop - pktp - 1) + 1; 3150Sstevel@tonic-gate volatile char *pp = pktp; 3160Sstevel@tonic-gate volatile char *pe = bufstop < pstop ? bufstop : pstop; 3170Sstevel@tonic-gate 3180Sstevel@tonic-gate if (pktp < buf || pktp > bufstop) 3190Sstevel@tonic-gate return; 3200Sstevel@tonic-gate 3210Sstevel@tonic-gate for (pp = pktp; pp < pe; pp += li) { 3220Sstevel@tonic-gate c = ((pe - pp) < li ? pe - pp : li); 3230Sstevel@tonic-gate i = (rand() % c)>>1; 3240Sstevel@tonic-gate while (--i > 0) { 3250Sstevel@tonic-gate p = (rand() % c); 3260Sstevel@tonic-gate pp[p] = (unsigned char)(rand() & 0xFF); 3270Sstevel@tonic-gate } 3280Sstevel@tonic-gate } 3290Sstevel@tonic-gate } 3300Sstevel@tonic-gate #endif /* DEBUG */ 3310Sstevel@tonic-gate 3321676Sjpk static void 3331676Sjpk scan(char *buf, int len, int filter, int cap, int old, void (*proc)(), 3341676Sjpk int first, int last, int flags) 3350Sstevel@tonic-gate { 3360Sstevel@tonic-gate volatile char *bp, *bufstop; 3370Sstevel@tonic-gate volatile struct sb_hdr *hdrp; 3380Sstevel@tonic-gate volatile struct sb_hdr nhdr, *nhdrp; 3390Sstevel@tonic-gate volatile char *pktp; 3400Sstevel@tonic-gate volatile struct timeval last_timestamp; 3410Sstevel@tonic-gate volatile int header_okay; 3420Sstevel@tonic-gate extern int count, maxcount; 3430Sstevel@tonic-gate extern int snoop_nrecover; 3440Sstevel@tonic-gate #ifdef DEBUG 3450Sstevel@tonic-gate extern int zflg; 3460Sstevel@tonic-gate #endif /* DEBUG */ 3470Sstevel@tonic-gate 3480Sstevel@tonic-gate proc(0, 0, 0); 3490Sstevel@tonic-gate bufstop = buf + len; 3500Sstevel@tonic-gate 3510Sstevel@tonic-gate /* 3520Sstevel@tonic-gate * 3530Sstevel@tonic-gate * Loop through each packet in the buffer 3540Sstevel@tonic-gate */ 3550Sstevel@tonic-gate last_timestamp.tv_sec = 0; 3560Sstevel@tonic-gate (void) memcpy((char *)ojmp_env, (char *)jmp_env, sizeof (jmp_env)); 3570Sstevel@tonic-gate for (bp = buf; bp < bufstop; bp += nhdrp->sbh_totlen) { 3580Sstevel@tonic-gate /* 3590Sstevel@tonic-gate * Gracefully exit if user terminates 3600Sstevel@tonic-gate */ 3610Sstevel@tonic-gate if (quitting) 3620Sstevel@tonic-gate break; 3630Sstevel@tonic-gate /* 3640Sstevel@tonic-gate * Global error recocery: Prepare to continue when a corrupt 3650Sstevel@tonic-gate * packet or header is encountered. 3660Sstevel@tonic-gate */ 3670Sstevel@tonic-gate if (sigsetjmp(jmp_env, 1)) { 3680Sstevel@tonic-gate goto err; 3690Sstevel@tonic-gate } 3700Sstevel@tonic-gate 3710Sstevel@tonic-gate header_okay = 0; 3720Sstevel@tonic-gate hdrp = (struct sb_hdr *)bp; 3730Sstevel@tonic-gate nhdrp = hdrp; 3740Sstevel@tonic-gate pktp = (char *)hdrp + sizeof (*hdrp); 3750Sstevel@tonic-gate 3760Sstevel@tonic-gate /* 3770Sstevel@tonic-gate * If reading a capture file 3780Sstevel@tonic-gate * convert the headers from network 3790Sstevel@tonic-gate * byte order (for little-endians like X86) 3800Sstevel@tonic-gate */ 3810Sstevel@tonic-gate if (cap) { 3820Sstevel@tonic-gate /* 3830Sstevel@tonic-gate * If the packets come from an old 3840Sstevel@tonic-gate * capture file, convert the header. 3850Sstevel@tonic-gate */ 3860Sstevel@tonic-gate if (old) { 3871676Sjpk convert_old((struct ohdr *)hdrp); 3880Sstevel@tonic-gate } 3890Sstevel@tonic-gate 3900Sstevel@tonic-gate nhdrp = &nhdr; 3910Sstevel@tonic-gate 3920Sstevel@tonic-gate nhdrp->sbh_origlen = ntohl(hdrp->sbh_origlen); 3930Sstevel@tonic-gate nhdrp->sbh_msglen = ntohl(hdrp->sbh_msglen); 3940Sstevel@tonic-gate nhdrp->sbh_totlen = ntohl(hdrp->sbh_totlen); 3950Sstevel@tonic-gate nhdrp->sbh_drops = ntohl(hdrp->sbh_drops); 3960Sstevel@tonic-gate nhdrp->sbh_timestamp.tv_sec = 3970Sstevel@tonic-gate ntohl(hdrp->sbh_timestamp.tv_sec); 3980Sstevel@tonic-gate nhdrp->sbh_timestamp.tv_usec = 3990Sstevel@tonic-gate ntohl(hdrp->sbh_timestamp.tv_usec); 4000Sstevel@tonic-gate } 4010Sstevel@tonic-gate 4020Sstevel@tonic-gate /* Enhanced check for valid header */ 4030Sstevel@tonic-gate 4040Sstevel@tonic-gate if ((nhdrp->sbh_totlen == 0) || 4050Sstevel@tonic-gate (bp + nhdrp->sbh_totlen) < bp || 4060Sstevel@tonic-gate (bp + nhdrp->sbh_totlen) > bufstop || 4070Sstevel@tonic-gate (nhdrp->sbh_origlen == 0) || 4080Sstevel@tonic-gate (bp + nhdrp->sbh_origlen) < bp || 4090Sstevel@tonic-gate (nhdrp->sbh_msglen == 0) || 4100Sstevel@tonic-gate (bp + nhdrp->sbh_msglen) < bp || 4110Sstevel@tonic-gate (bp + nhdrp->sbh_msglen) > bufstop || 4120Sstevel@tonic-gate (nhdrp->sbh_msglen > nhdrp->sbh_origlen) || 4130Sstevel@tonic-gate (nhdrp->sbh_totlen < nhdrp->sbh_msglen) || 4140Sstevel@tonic-gate (nhdrp->sbh_timestamp.tv_sec == 0)) { 4150Sstevel@tonic-gate if (cap) 416*3628Sss150715 (void) fprintf(stderr, "(warning) bad packet " 417*3628Sss150715 "header in capture file"); 4180Sstevel@tonic-gate else 419*3628Sss150715 (void) fprintf(stderr, "(warning) bad packet " 420*3628Sss150715 "header in buffer"); 4210Sstevel@tonic-gate (void) fprintf(stderr, " offset %d: length=%d\n", 4220Sstevel@tonic-gate bp - buf, nhdrp->sbh_totlen); 4230Sstevel@tonic-gate goto err; 4240Sstevel@tonic-gate } 4250Sstevel@tonic-gate 4260Sstevel@tonic-gate if (nhdrp->sbh_totlen > 427*3628Sss150715 (dlinfo.di_max_sdu + MAX_HDRTRAILER)) { 4280Sstevel@tonic-gate if (cap) 429*3628Sss150715 (void) fprintf(stderr, "(warning) packet length" 430*3628Sss150715 " greater than MTU in capture file"); 4310Sstevel@tonic-gate else 432*3628Sss150715 (void) fprintf(stderr, "(warning) packet length" 433*3628Sss150715 " greater than MTU in buffer"); 4340Sstevel@tonic-gate 4350Sstevel@tonic-gate (void) fprintf(stderr, " offset %d: length=%d\n", 4360Sstevel@tonic-gate bp - buf, nhdrp->sbh_totlen); 4370Sstevel@tonic-gate } 4380Sstevel@tonic-gate 4390Sstevel@tonic-gate /* 4400Sstevel@tonic-gate * Check for incomplete packet. We are conservative here, 4410Sstevel@tonic-gate * since we don't know how good the checking is in other 4420Sstevel@tonic-gate * parts of the code. We pass a partial packet, with 4430Sstevel@tonic-gate * a warning. 4440Sstevel@tonic-gate */ 4450Sstevel@tonic-gate if (pktp + nhdrp->sbh_msglen > bufstop) { 446*3628Sss150715 (void) fprintf(stderr, "truncated packet buffer\n"); 4470Sstevel@tonic-gate nhdrp->sbh_msglen = bufstop - pktp; 4480Sstevel@tonic-gate } 4490Sstevel@tonic-gate 4500Sstevel@tonic-gate #ifdef DEBUG 4510Sstevel@tonic-gate if (zflg) 4520Sstevel@tonic-gate corrupt(pktp, pktp + nhdrp->sbh_msglen, buf, bufstop); 4530Sstevel@tonic-gate #endif /* DEBUG */ 4540Sstevel@tonic-gate 4550Sstevel@tonic-gate header_okay = 1; 4560Sstevel@tonic-gate if (!filter || 4570Sstevel@tonic-gate want_packet(pktp, 4580Sstevel@tonic-gate nhdrp->sbh_msglen, 4590Sstevel@tonic-gate nhdrp->sbh_origlen)) { 4600Sstevel@tonic-gate count++; 4610Sstevel@tonic-gate 4620Sstevel@tonic-gate /* 4630Sstevel@tonic-gate * Start deadman timer for interpreter processing 4640Sstevel@tonic-gate */ 4650Sstevel@tonic-gate (void) snoop_alarm(SNOOP_ALARM_GRAN*SNOOP_MAXRECOVER, 4660Sstevel@tonic-gate NULL); 4670Sstevel@tonic-gate 4680Sstevel@tonic-gate encap_levels = 0; 4690Sstevel@tonic-gate if (!cap || count >= first) 4700Sstevel@tonic-gate proc(nhdrp, pktp, count, flags); 4710Sstevel@tonic-gate 4720Sstevel@tonic-gate if (cap && count >= last) { 4730Sstevel@tonic-gate (void) snoop_alarm(0, NULL); 4740Sstevel@tonic-gate break; 4750Sstevel@tonic-gate } 4760Sstevel@tonic-gate 4770Sstevel@tonic-gate if (maxcount && count >= maxcount) { 478*3628Sss150715 (void) fprintf(stderr, "%d packets captured\n", 479*3628Sss150715 count); 4800Sstevel@tonic-gate exit(0); 4810Sstevel@tonic-gate } 4820Sstevel@tonic-gate 4830Sstevel@tonic-gate snoop_nrecover = 0; /* success */ 4840Sstevel@tonic-gate (void) snoop_alarm(0, NULL); 4850Sstevel@tonic-gate last_timestamp = hdrp->sbh_timestamp; /* save stamp */ 4860Sstevel@tonic-gate } 4870Sstevel@tonic-gate continue; 4880Sstevel@tonic-gate err: 4890Sstevel@tonic-gate /* 4900Sstevel@tonic-gate * Corruption has been detected. Reset errors. 4910Sstevel@tonic-gate */ 4920Sstevel@tonic-gate snoop_recover(); 4930Sstevel@tonic-gate 4940Sstevel@tonic-gate /* 4950Sstevel@tonic-gate * packet header was apparently okay. Continue. 4960Sstevel@tonic-gate */ 4970Sstevel@tonic-gate if (header_okay) 4980Sstevel@tonic-gate continue; 4990Sstevel@tonic-gate 5000Sstevel@tonic-gate /* 5010Sstevel@tonic-gate * Otherwise try to scan forward to the next packet, using 5020Sstevel@tonic-gate * the last known timestamp if it is available. 5030Sstevel@tonic-gate */ 5040Sstevel@tonic-gate nhdrp = &nhdr; 5050Sstevel@tonic-gate nhdrp->sbh_totlen = 0; 5060Sstevel@tonic-gate if (last_timestamp.tv_sec == 0) { 5070Sstevel@tonic-gate bp += sizeof (int); 5080Sstevel@tonic-gate } else { 5090Sstevel@tonic-gate for (bp += sizeof (int); bp <= bufstop; 5100Sstevel@tonic-gate bp += sizeof (int)) { 5110Sstevel@tonic-gate hdrp = (struct sb_hdr *)bp; 5120Sstevel@tonic-gate /* An approximate timestamp located */ 5130Sstevel@tonic-gate if ((hdrp->sbh_timestamp.tv_sec >> 8) == 5140Sstevel@tonic-gate (last_timestamp.tv_sec >> 8)) 5150Sstevel@tonic-gate break; 5160Sstevel@tonic-gate } 5170Sstevel@tonic-gate } 5180Sstevel@tonic-gate } 5190Sstevel@tonic-gate /* reset jmp_env for program exit */ 5200Sstevel@tonic-gate (void) memcpy((char *)jmp_env, (char *)ojmp_env, sizeof (jmp_env)); 5210Sstevel@tonic-gate proc(0, -1, 0); 5220Sstevel@tonic-gate } 5230Sstevel@tonic-gate 5240Sstevel@tonic-gate /* 5250Sstevel@tonic-gate * Called if nwrite() encounters write problems. 5260Sstevel@tonic-gate */ 5270Sstevel@tonic-gate static void 5280Sstevel@tonic-gate cap_write_error(const char *msgtype) 5290Sstevel@tonic-gate { 5300Sstevel@tonic-gate (void) fprintf(stderr, 5310Sstevel@tonic-gate "snoop: cannot write %s to capture file: %s\n", 5320Sstevel@tonic-gate msgtype, strerror(errno)); 5330Sstevel@tonic-gate exit(1); 5340Sstevel@tonic-gate } 5350Sstevel@tonic-gate 5360Sstevel@tonic-gate /* 5370Sstevel@tonic-gate * Writes target buffer to the open file descriptor. Upon detection of a short 5380Sstevel@tonic-gate * write, an attempt to process the remaining bytes occurs until all anticipated 5390Sstevel@tonic-gate * bytes are written. An error status is returned to indicate any serious write 5400Sstevel@tonic-gate * failures. 5410Sstevel@tonic-gate */ 5420Sstevel@tonic-gate static int 5430Sstevel@tonic-gate nwrite(int fd, const void *buffer, size_t buflen) 5440Sstevel@tonic-gate { 5450Sstevel@tonic-gate size_t nwritten; 5460Sstevel@tonic-gate ssize_t nbytes = 0; 5470Sstevel@tonic-gate const char *buf = buffer; 5480Sstevel@tonic-gate 5490Sstevel@tonic-gate for (nwritten = 0; nwritten < buflen; nwritten += nbytes) { 5500Sstevel@tonic-gate nbytes = write(fd, &buf[nwritten], buflen - nwritten); 5510Sstevel@tonic-gate if (nbytes == -1) 5520Sstevel@tonic-gate return (-1); 5530Sstevel@tonic-gate if (nbytes == 0) { 5540Sstevel@tonic-gate errno = EIO; 5550Sstevel@tonic-gate return (-1); 5560Sstevel@tonic-gate } 5570Sstevel@tonic-gate } 5580Sstevel@tonic-gate return (0); 5590Sstevel@tonic-gate } 5600Sstevel@tonic-gate 5610Sstevel@tonic-gate /* 5620Sstevel@tonic-gate * Routines for opening, closing, reading and writing 5630Sstevel@tonic-gate * a capture file of packets saved with the -o option. 5640Sstevel@tonic-gate */ 5650Sstevel@tonic-gate static int capfile_out; 5660Sstevel@tonic-gate 5670Sstevel@tonic-gate /* 5680Sstevel@tonic-gate * The snoop capture file has a header to identify 5690Sstevel@tonic-gate * it as a capture file and record its version. 5700Sstevel@tonic-gate * A file without this header is assumed to be an 5710Sstevel@tonic-gate * old format snoop file. 5720Sstevel@tonic-gate * 5730Sstevel@tonic-gate * A version 1 header looks like this: 5740Sstevel@tonic-gate * 5750Sstevel@tonic-gate * 0 1 2 3 4 5 6 7 8 9 10 11 5760Sstevel@tonic-gate * +---+---+---+---+---+---+---+---+---+---+---+---+---+ 5770Sstevel@tonic-gate * | s | n | o | o | p | \0| \0| \0| version | data 5780Sstevel@tonic-gate * +---+---+---+---+---+---+---+---+---+---+---+---+---+ 5790Sstevel@tonic-gate * | word 0 | word 1 | word 2 | 5800Sstevel@tonic-gate * 5810Sstevel@tonic-gate * 5820Sstevel@tonic-gate * A version 2 header adds a word that identifies the MAC type. 5830Sstevel@tonic-gate * This allows for capture files from FDDI etc. 5840Sstevel@tonic-gate * 5850Sstevel@tonic-gate * 0 1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 5860Sstevel@tonic-gate * +---+---+---+---+---+---+---+---+---+---+---+---+---+---+---+---+---+ 5870Sstevel@tonic-gate * | s | n | o | o | p | \0| \0| \0| version | MAC type | data 5880Sstevel@tonic-gate * +---+---+---+---+---+---+---+---+---+---+---+---+---+---+---+---+---+ 5890Sstevel@tonic-gate * | word 0 | word 1 | word 2 | word 3 5900Sstevel@tonic-gate * 5910Sstevel@tonic-gate */ 5921676Sjpk static const char *snoop_id = "snoop\0\0\0"; 5931676Sjpk static const int snoop_idlen = 8; 5941676Sjpk static const int snoop_version = 2; 5950Sstevel@tonic-gate 5960Sstevel@tonic-gate void 597*3628Sss150715 cap_open_write(const char *name) 5980Sstevel@tonic-gate { 5990Sstevel@tonic-gate int vers; 6000Sstevel@tonic-gate 6010Sstevel@tonic-gate capfile_out = open(name, O_CREAT | O_TRUNC | O_RDWR, 0666); 6020Sstevel@tonic-gate if (capfile_out < 0) 6030Sstevel@tonic-gate pr_err("%s: %m", name); 6040Sstevel@tonic-gate 6050Sstevel@tonic-gate vers = htonl(snoop_version); 6061676Sjpk if (nwrite(capfile_out, snoop_id, snoop_idlen) == -1) 6070Sstevel@tonic-gate cap_write_error("snoop_id"); 6080Sstevel@tonic-gate 6091676Sjpk if (nwrite(capfile_out, &vers, sizeof (int)) == -1) 6100Sstevel@tonic-gate cap_write_error("version"); 6110Sstevel@tonic-gate } 6120Sstevel@tonic-gate 6130Sstevel@tonic-gate 6140Sstevel@tonic-gate void 6151676Sjpk cap_close(void) 6160Sstevel@tonic-gate { 6171676Sjpk (void) close(capfile_out); 6180Sstevel@tonic-gate } 6190Sstevel@tonic-gate 6200Sstevel@tonic-gate static char *cap_buffp = NULL; 6210Sstevel@tonic-gate static int cap_len = 0; 6220Sstevel@tonic-gate static int cap_new; 6230Sstevel@tonic-gate 6240Sstevel@tonic-gate void 625*3628Sss150715 cap_open_read(const char *name) 6260Sstevel@tonic-gate { 6270Sstevel@tonic-gate struct stat st; 6280Sstevel@tonic-gate int cap_vers; 6290Sstevel@tonic-gate int *word, device_mac_type; 6300Sstevel@tonic-gate int capfile_in; 6310Sstevel@tonic-gate 6320Sstevel@tonic-gate capfile_in = open(name, O_RDONLY); 6330Sstevel@tonic-gate if (capfile_in < 0) 6340Sstevel@tonic-gate pr_err("couldn't open %s: %m", name); 6350Sstevel@tonic-gate 6360Sstevel@tonic-gate if (fstat(capfile_in, &st) < 0) 6370Sstevel@tonic-gate pr_err("couldn't stat %s: %m", name); 6380Sstevel@tonic-gate cap_len = st.st_size; 6390Sstevel@tonic-gate 6400Sstevel@tonic-gate cap_buffp = mmap(0, cap_len, PROT_READ, MAP_PRIVATE, capfile_in, 0); 6411676Sjpk (void) close(capfile_in); 6420Sstevel@tonic-gate if ((int)cap_buffp == -1) 6430Sstevel@tonic-gate pr_err("couldn't mmap %s: %m", name); 6440Sstevel@tonic-gate 6450Sstevel@tonic-gate /* Check if new snoop capture file format */ 6460Sstevel@tonic-gate 6470Sstevel@tonic-gate cap_new = bcmp(cap_buffp, snoop_id, snoop_idlen) == 0; 6480Sstevel@tonic-gate 6490Sstevel@tonic-gate /* 6500Sstevel@tonic-gate * If new file - check version and 6510Sstevel@tonic-gate * set buffer pointer to point at first packet 6520Sstevel@tonic-gate */ 6530Sstevel@tonic-gate if (cap_new) { 6540Sstevel@tonic-gate cap_vers = ntohl(*(int *)(cap_buffp + snoop_idlen)); 6550Sstevel@tonic-gate cap_buffp += snoop_idlen + sizeof (int); 6560Sstevel@tonic-gate cap_len -= snoop_idlen + sizeof (int); 6570Sstevel@tonic-gate 6580Sstevel@tonic-gate switch (cap_vers) { 6590Sstevel@tonic-gate case 1: 6600Sstevel@tonic-gate device_mac_type = DL_ETHER; 6610Sstevel@tonic-gate break; 6620Sstevel@tonic-gate 6630Sstevel@tonic-gate case 2: 6640Sstevel@tonic-gate device_mac_type = ntohl(*((int *)cap_buffp)); 6650Sstevel@tonic-gate cap_buffp += sizeof (int); 6660Sstevel@tonic-gate cap_len -= sizeof (int); 6670Sstevel@tonic-gate break; 6680Sstevel@tonic-gate 6690Sstevel@tonic-gate default: 6700Sstevel@tonic-gate pr_err("capture file: %s: Version %d unrecognized\n", 6710Sstevel@tonic-gate name, cap_vers); 6720Sstevel@tonic-gate } 6730Sstevel@tonic-gate 6740Sstevel@tonic-gate for (interface = &INTERFACES[0]; interface->mac_type != -1; 6750Sstevel@tonic-gate interface++) 6760Sstevel@tonic-gate if (interface->mac_type == device_mac_type) 6770Sstevel@tonic-gate break; 6780Sstevel@tonic-gate 6790Sstevel@tonic-gate if (interface->mac_type == -1) 6800Sstevel@tonic-gate pr_err("Mac Type = %x is not supported\n", 6810Sstevel@tonic-gate device_mac_type); 6820Sstevel@tonic-gate } else { 6830Sstevel@tonic-gate /* Use heuristic to check if it's an old-style file */ 6840Sstevel@tonic-gate 6850Sstevel@tonic-gate device_mac_type = DL_ETHER; 6860Sstevel@tonic-gate word = (int *)cap_buffp; 6870Sstevel@tonic-gate 6880Sstevel@tonic-gate if (!((word[0] < 1600 && word[1] < 1600) && 6890Sstevel@tonic-gate (word[0] < word[1]) && 6900Sstevel@tonic-gate (word[2] > 610000000 && word[2] < 770000000))) 6910Sstevel@tonic-gate pr_err("not a capture file: %s", name); 6920Sstevel@tonic-gate 6930Sstevel@tonic-gate /* Change protection so's we can fix the headers */ 6940Sstevel@tonic-gate 6950Sstevel@tonic-gate if (mprotect(cap_buffp, cap_len, PROT_READ | PROT_WRITE) < 0) 6960Sstevel@tonic-gate pr_err("mprotect: %s: %m", name); 6970Sstevel@tonic-gate } 698*3628Sss150715 dlinfo.di_max_sdu = MAXINT; /* Decode any stored packet. */ 6990Sstevel@tonic-gate } 7000Sstevel@tonic-gate 7010Sstevel@tonic-gate void 702*3628Sss150715 cap_read(int first, int last, int filter, void (*proc)(), int flags) 7030Sstevel@tonic-gate { 7040Sstevel@tonic-gate extern int count; 7050Sstevel@tonic-gate 7060Sstevel@tonic-gate count = 0; 7070Sstevel@tonic-gate 7080Sstevel@tonic-gate scan(cap_buffp, cap_len, filter, 1, !cap_new, proc, first, last, flags); 7090Sstevel@tonic-gate 7101676Sjpk (void) munmap(cap_buffp, cap_len); 7110Sstevel@tonic-gate } 7120Sstevel@tonic-gate 7131676Sjpk /* ARGSUSED */ 7140Sstevel@tonic-gate void 715*3628Sss150715 cap_write(struct sb_hdr *hdrp, char *pktp, int num, int flags) 7160Sstevel@tonic-gate { 7170Sstevel@tonic-gate int pktlen, mac; 7180Sstevel@tonic-gate static int first = 1; 7190Sstevel@tonic-gate struct sb_hdr nhdr; 7200Sstevel@tonic-gate extern boolean_t qflg; 7210Sstevel@tonic-gate 7220Sstevel@tonic-gate if (hdrp == NULL) 7230Sstevel@tonic-gate return; 7240Sstevel@tonic-gate 7250Sstevel@tonic-gate if (first) { 7260Sstevel@tonic-gate first = 0; 7270Sstevel@tonic-gate mac = htonl(interface->mac_type); 7281676Sjpk if (nwrite(capfile_out, &mac, sizeof (int)) == -1) 7290Sstevel@tonic-gate cap_write_error("mac_type"); 7300Sstevel@tonic-gate } 7310Sstevel@tonic-gate 7320Sstevel@tonic-gate pktlen = hdrp->sbh_totlen - sizeof (*hdrp); 7330Sstevel@tonic-gate 7340Sstevel@tonic-gate /* 7350Sstevel@tonic-gate * Convert sb_hdr to network byte order 7360Sstevel@tonic-gate */ 7370Sstevel@tonic-gate nhdr.sbh_origlen = htonl(hdrp->sbh_origlen); 7380Sstevel@tonic-gate nhdr.sbh_msglen = htonl(hdrp->sbh_msglen); 7390Sstevel@tonic-gate nhdr.sbh_totlen = htonl(hdrp->sbh_totlen); 7400Sstevel@tonic-gate nhdr.sbh_drops = htonl(hdrp->sbh_drops); 7410Sstevel@tonic-gate nhdr.sbh_timestamp.tv_sec = htonl(hdrp->sbh_timestamp.tv_sec); 7420Sstevel@tonic-gate nhdr.sbh_timestamp.tv_usec = htonl(hdrp->sbh_timestamp.tv_usec); 7430Sstevel@tonic-gate 7441676Sjpk if (nwrite(capfile_out, &nhdr, sizeof (nhdr)) == -1) 7450Sstevel@tonic-gate cap_write_error("packet header"); 7460Sstevel@tonic-gate 7471676Sjpk if (nwrite(capfile_out, pktp, pktlen) == -1) 7480Sstevel@tonic-gate cap_write_error("packet"); 7490Sstevel@tonic-gate 7500Sstevel@tonic-gate if (! qflg) 7510Sstevel@tonic-gate show_count(); 7520Sstevel@tonic-gate } 7530Sstevel@tonic-gate 7540Sstevel@tonic-gate /* 7550Sstevel@tonic-gate * Convert a packet header from 7560Sstevel@tonic-gate * old to new format. 7570Sstevel@tonic-gate */ 7581676Sjpk static void 7591676Sjpk convert_old(struct ohdr *ohdrp) 7600Sstevel@tonic-gate { 7610Sstevel@tonic-gate struct sb_hdr nhdr; 7620Sstevel@tonic-gate 7630Sstevel@tonic-gate nhdr.sbh_origlen = ohdrp->o_len; 7640Sstevel@tonic-gate nhdr.sbh_msglen = ohdrp->o_msglen; 7650Sstevel@tonic-gate nhdr.sbh_totlen = ohdrp->o_totlen; 7660Sstevel@tonic-gate nhdr.sbh_drops = ohdrp->o_drops; 7670Sstevel@tonic-gate nhdr.sbh_timestamp = ohdrp->o_time; 7680Sstevel@tonic-gate 7690Sstevel@tonic-gate *(struct sb_hdr *)ohdrp = nhdr; 7700Sstevel@tonic-gate } 7710Sstevel@tonic-gate 772410Skcpoon static int 7731676Sjpk strioctl(int fd, int cmd, int timout, int len, void *dp) 7740Sstevel@tonic-gate { 7750Sstevel@tonic-gate struct strioctl sioc; 7760Sstevel@tonic-gate int rc; 7770Sstevel@tonic-gate 7780Sstevel@tonic-gate sioc.ic_cmd = cmd; 7790Sstevel@tonic-gate sioc.ic_timout = timout; 7800Sstevel@tonic-gate sioc.ic_len = len; 7810Sstevel@tonic-gate sioc.ic_dp = dp; 7820Sstevel@tonic-gate rc = ioctl(fd, I_STR, &sioc); 7830Sstevel@tonic-gate 7840Sstevel@tonic-gate if (rc < 0) 7850Sstevel@tonic-gate return (rc); 7860Sstevel@tonic-gate else 7870Sstevel@tonic-gate return (sioc.ic_len); 7880Sstevel@tonic-gate } 789