Home | History | Annotate | Line # | Download | only in ping
ping.c revision 1.102.6.1
      1  1.102.6.1       tls /*	$NetBSD: ping.c,v 1.102.6.1 2012/11/20 03:00:49 tls Exp $	*/
      2       1.13       cgd 
      3        1.1       cgd /*
      4        1.8   mycroft  * Copyright (c) 1989, 1993
      5        1.8   mycroft  *	The Regents of the University of California.  All rights reserved.
      6        1.1       cgd  *
      7        1.1       cgd  * This code is derived from software contributed to Berkeley by
      8        1.1       cgd  * Mike Muuss.
      9        1.1       cgd  *
     10        1.1       cgd  * Redistribution and use in source and binary forms, with or without
     11        1.1       cgd  * modification, are permitted provided that the following conditions
     12        1.1       cgd  * are met:
     13        1.1       cgd  * 1. Redistributions of source code must retain the above copyright
     14        1.1       cgd  *    notice, this list of conditions and the following disclaimer.
     15        1.1       cgd  * 2. Redistributions in binary form must reproduce the above copyright
     16        1.1       cgd  *    notice, this list of conditions and the following disclaimer in the
     17        1.1       cgd  *    documentation and/or other materials provided with the distribution.
     18       1.73       agc  * 3. Neither the name of the University nor the names of its contributors
     19        1.1       cgd  *    may be used to endorse or promote products derived from this software
     20        1.1       cgd  *    without specific prior written permission.
     21        1.1       cgd  *
     22        1.1       cgd  * THIS SOFTWARE IS PROVIDED BY THE REGENTS AND CONTRIBUTORS ``AS IS'' AND
     23        1.1       cgd  * ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
     24        1.1       cgd  * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE
     25        1.1       cgd  * ARE DISCLAIMED.  IN NO EVENT SHALL THE REGENTS OR CONTRIBUTORS BE LIABLE
     26        1.1       cgd  * FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL
     27        1.1       cgd  * DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS
     28        1.1       cgd  * OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION)
     29        1.1       cgd  * HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT
     30        1.1       cgd  * LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY
     31        1.1       cgd  * OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF
     32        1.1       cgd  * SUCH DAMAGE.
     33        1.1       cgd  */
     34       1.41  christos 
     35        1.1       cgd /*
     36        1.1       cgd  *			P I N G . C
     37        1.1       cgd  *
     38       1.30  christos  * Using the InterNet Control Message Protocol (ICMP) "ECHO" facility,
     39        1.1       cgd  * measure round-trip-delays and packet loss across network paths.
     40        1.1       cgd  *
     41        1.1       cgd  * Author -
     42        1.1       cgd  *	Mike Muuss
     43        1.1       cgd  *	U. S. Army Ballistic Research Laboratory
     44        1.1       cgd  *	December, 1983
     45       1.22  christos  * Modified at Uc Berkeley
     46       1.22  christos  * Record Route and verbose headers - Phil Dykstra, BRL, March 1988.
     47       1.22  christos  * Multicast options (ttl, if, loop) - Steve Deering, Stanford, August 1988.
     48       1.22  christos  * ttl, duplicate detection - Cliff Frost, UCB, April 1989
     49       1.22  christos  * Pad pattern - Cliff Frost (from Tom Ferrin, UCSF), April 1989
     50        1.1       cgd  *
     51        1.1       cgd  * Status -
     52        1.1       cgd  *	Public Domain.  Distribution Unlimited.
     53       1.22  christos  *
     54        1.1       cgd  * Bugs -
     55        1.1       cgd  *	More statistics could always be gathered.
     56        1.1       cgd  *	This program has to run SUID to ROOT to access the ICMP socket.
     57        1.1       cgd  */
     58        1.1       cgd 
     59       1.32     lukem #include <sys/cdefs.h>
     60       1.22  christos #ifndef lint
     61  1.102.6.1       tls __RCSID("$NetBSD: ping.c,v 1.102.6.1 2012/11/20 03:00:49 tls Exp $");
     62       1.22  christos #endif
     63       1.22  christos 
     64       1.22  christos #include <stdio.h>
     65       1.60      yamt #include <stddef.h>
     66       1.22  christos #include <errno.h>
     67       1.81  christos #include <signal.h>
     68       1.22  christos #include <sys/time.h>
     69       1.22  christos #include <sys/types.h>
     70        1.1       cgd #include <sys/param.h>
     71        1.1       cgd #include <sys/socket.h>
     72        1.1       cgd #include <sys/file.h>
     73       1.41  christos #include <termios.h>
     74       1.22  christos #include <stdlib.h>
     75       1.22  christos #include <unistd.h>
     76       1.67   mycroft #include <poll.h>
     77       1.22  christos #include <limits.h>
     78       1.44     jwise #include <math.h>
     79       1.22  christos #include <string.h>
     80       1.22  christos #include <err.h>
     81        1.1       cgd 
     82        1.1       cgd #include <netinet/in_systm.h>
     83        1.1       cgd #include <netinet/in.h>
     84        1.1       cgd #include <netinet/ip.h>
     85        1.1       cgd #include <netinet/ip_icmp.h>
     86        1.1       cgd #include <netinet/ip_var.h>
     87       1.12       cgd #include <arpa/inet.h>
     88       1.22  christos #include <ctype.h>
     89        1.1       cgd #include <netdb.h>
     90        1.1       cgd 
     91       1.50    itojun #ifdef IPSEC
     92      1.102  drochner #include <netipsec/ipsec.h>
     93       1.50    itojun #endif /*IPSEC*/
     94       1.50    itojun 
     95       1.92     pooka #include "prog_ops.h"
     96       1.91     pooka 
     97       1.22  christos #define FLOOD_INTVL	0.01		/* default flood output interval */
     98       1.61      yamt #define	MAXPACKET	(IP_MAXPACKET-60-8)	/* max packet size */
     99        1.7   hpeyerl 
    100       1.22  christos #define F_VERBOSE	0x0001
    101       1.22  christos #define F_QUIET		0x0002		/* minimize all output */
    102       1.22  christos #define F_SEMI_QUIET	0x0004		/* ignore our ICMP errors */
    103       1.22  christos #define F_FLOOD		0x0008		/* flood-ping */
    104       1.22  christos #define	F_RECORD_ROUTE	0x0010		/* record route */
    105       1.22  christos #define F_SOURCE_ROUTE	0x0020		/* loose source route */
    106       1.22  christos #define F_PING_FILLED	0x0040		/* is buffer filled with user data? */
    107       1.22  christos #define F_PING_RANDOM	0x0080		/* use random data */
    108       1.22  christos #define	F_NUMERIC	0x0100		/* do not do gethostbyaddr() calls */
    109       1.22  christos #define F_TIMING	0x0200		/* room for a timestamp */
    110       1.30  christos #define F_DF		0x0400		/* set IP DF bit */
    111       1.30  christos #define F_SOURCE_ADDR	0x0800		/* set source IP address/interface */
    112       1.30  christos #define F_ONCE		0x1000		/* exit(0) after receiving 1 reply */
    113       1.30  christos #define F_MCAST		0x2000		/* multicast target */
    114       1.30  christos #define F_MCAST_NOLOOP	0x4000		/* no multicast loopback */
    115       1.49  sommerfe #define F_AUDIBLE	0x8000		/* audible output */
    116       1.99  christos #define F_TIMING64	0x10000		/* 64 bit time, nanoseconds */
    117       1.50    itojun #ifdef IPSEC
    118       1.50    itojun #ifdef IPSEC_POLICY_IPSEC
    119  1.102.6.1       tls #define F_POLICY	0x20000
    120       1.50    itojun #else
    121  1.102.6.1       tls #define	F_AUTHHDR	0x20000
    122  1.102.6.1       tls #define	F_ENCRYPT	0x40000
    123       1.50    itojun #endif /*IPSEC_POLICY_IPSEC*/
    124       1.50    itojun #endif /*IPSEC*/
    125       1.22  christos 
    126       1.41  christos 
    127       1.22  christos /* MAX_DUP_CHK is the number of bits in received table, the
    128       1.22  christos  *	maximum number of received sequence numbers we can track to check
    129       1.22  christos  *	for duplicates.
    130        1.1       cgd  */
    131       1.22  christos #define MAX_DUP_CHK     (8 * 2048)
    132       1.98     joerg static u_char	rcvd_tbl[MAX_DUP_CHK/8];
    133       1.98     joerg static int     nrepeats = 0;
    134       1.22  christos #define A(seq)	rcvd_tbl[(seq/8)%sizeof(rcvd_tbl)]  /* byte in array */
    135       1.22  christos #define B(seq)	(1 << (seq & 0x07))	/* bit in byte */
    136       1.22  christos #define SET(seq) (A(seq) |= B(seq))
    137       1.22  christos #define CLR(seq) (A(seq) &= (~B(seq)))
    138       1.22  christos #define TST(seq) (A(seq) & B(seq))
    139       1.22  christos 
    140       1.75    itojun struct tv32 {
    141       1.75    itojun 	int32_t tv32_sec;
    142       1.75    itojun 	int32_t tv32_usec;
    143       1.75    itojun };
    144       1.22  christos 
    145       1.22  christos 
    146       1.98     joerg static u_char	*packet;
    147       1.98     joerg static int	packlen;
    148       1.98     joerg static int	pingflags = 0, options;
    149       1.98     joerg static int	pongflags = 0;
    150       1.98     joerg static char	*fill_pat;
    151       1.22  christos 
    152       1.98     joerg static int s;					/* Socket file descriptor */
    153       1.98     joerg static int sloop;				/* Socket file descriptor/loopback */
    154       1.22  christos 
    155       1.99  christos #define PHDR_LEN sizeof(struct tv32)		/* size of timestamp header */
    156       1.99  christos #define PHDR64_LEN sizeof(struct timespec)	/* size of timestamp header */
    157       1.98     joerg static struct sockaddr_in whereto, send_addr;	/* Who to ping */
    158       1.98     joerg static struct sockaddr_in src_addr;		/* from where */
    159       1.98     joerg static struct sockaddr_in loc_addr;		/* 127.1 */
    160       1.99  christos static int datalen;				/* How much data */
    161       1.99  christos static int phdrlen;
    162       1.22  christos 
    163       1.59       cgd #ifndef __NetBSD__
    164       1.59       cgd static char *progname;
    165       1.59       cgd #define	getprogname()		(progname)
    166       1.59       cgd #define	setprogname(name)	((void)(progname = (name)))
    167       1.30  christos #endif
    168       1.22  christos 
    169       1.98     joerg static char hostname[MAXHOSTNAMELEN];
    170       1.22  christos 
    171       1.22  christos static struct {
    172       1.22  christos 	struct ip	o_ip;
    173       1.30  christos 	char		o_opt[MAX_IPOPTLEN];
    174       1.22  christos 	union {
    175       1.60      yamt 		u_char	    u_buf[MAXPACKET+offsetof(struct icmp, icmp_data)];
    176       1.30  christos 		struct icmp u_icmp;
    177       1.22  christos 	} o_u;
    178       1.22  christos } out_pack;
    179       1.30  christos #define	opack_icmp	out_pack.o_u.u_icmp
    180       1.98     joerg static struct ip *opack_ip;
    181       1.30  christos 
    182       1.98     joerg static char optspace[MAX_IPOPTLEN];		/* record route space */
    183       1.98     joerg static int optlen;
    184       1.30  christos 
    185       1.98     joerg static int npackets;				/* total packets to send */
    186       1.98     joerg static int preload;				/* number of packets to "preload" */
    187       1.98     joerg static int ntransmitted;			/* output sequence # = #sent */
    188       1.98     joerg static int ident;				/* our ID, in network byte order */
    189       1.98     joerg 
    190       1.98     joerg static int nreceived;				/* # of packets we got back */
    191       1.98     joerg 
    192       1.98     joerg static double interval;			/* interval between packets */
    193       1.99  christos static struct timespec interval_tv;
    194       1.98     joerg static double tmin = 999999999.0;
    195       1.98     joerg static double tmax = 0.0;
    196       1.98     joerg static double tsum = 0.0;			/* sum of all times */
    197       1.98     joerg static double tsumsq = 0.0;
    198       1.98     joerg static double maxwait = 0.0;
    199       1.98     joerg 
    200       1.98     joerg static int bufspace = IP_MAXPACKET;
    201       1.98     joerg 
    202       1.99  christos static struct timespec now, clear_cache, last_tx, next_tx, first_tx;
    203       1.99  christos static struct timespec last_rx, first_rx;
    204       1.98     joerg static int lastrcvd = 1;			/* last ping sent has been received */
    205       1.22  christos 
    206       1.99  christos static struct timespec jiggle_time;
    207       1.22  christos static int jiggle_cnt, total_jiggled, jiggle_direction = -1;
    208       1.22  christos 
    209       1.98     joerg __dead static void doit(void);
    210       1.22  christos static void prefinish(int);
    211       1.22  christos static void prtsig(int);
    212       1.98     joerg __dead static void finish(int);
    213       1.22  christos static void summary(int);
    214       1.22  christos static void pinger(void);
    215       1.22  christos static void fill(void);
    216       1.22  christos static void rnd_fill(void);
    217       1.99  christos static double diffsec(struct timespec *, struct timespec *);
    218       1.99  christos #if 0
    219       1.99  christos static void timespecadd(struct timespec *, struct timespec *);
    220       1.99  christos #endif
    221       1.99  christos static void sec_to_timespec(const double, struct timespec *);
    222       1.99  christos static double timespec_to_sec(const struct timespec *);
    223       1.22  christos static void pr_pack(u_char *, int, struct sockaddr_in *);
    224       1.65    itojun static u_int16_t in_cksum(u_int16_t *, u_int);
    225       1.57        is static void pr_saddr(u_char *);
    226       1.22  christos static char *pr_addr(struct in_addr *);
    227       1.22  christos static void pr_iph(struct icmp *, int);
    228       1.22  christos static void pr_retip(struct icmp *, int);
    229       1.22  christos static int pr_icmph(struct icmp *, struct sockaddr_in *, int);
    230       1.22  christos static void jiggle(int), jiggle_flush(int);
    231       1.30  christos static void gethost(const char *, const char *,
    232       1.30  christos 		    struct sockaddr_in *, char *, int);
    233       1.98     joerg __dead static void usage(void);
    234        1.1       cgd 
    235       1.12       cgd int
    236       1.22  christos main(int argc, char *argv[])
    237        1.1       cgd {
    238       1.30  christos 	int c, i, on = 1, hostind = 0;
    239       1.30  christos 	long l;
    240       1.99  christos 	int len = -1, compat = 0;
    241       1.30  christos 	u_char ttl = 0;
    242       1.30  christos 	u_long tos = 0;
    243       1.22  christos 	char *p;
    244       1.50    itojun #ifdef IPSEC
    245       1.50    itojun #ifdef IPSEC_POLICY_IPSEC
    246       1.55    itojun 	char *policy_in = NULL;
    247       1.55    itojun 	char *policy_out = NULL;
    248       1.50    itojun #endif
    249       1.50    itojun #endif
    250       1.81  christos #ifdef SIGINFO
    251       1.81  christos 	struct sigaction sa;
    252       1.81  christos #endif
    253        1.1       cgd 
    254       1.92     pooka 	if (prog_init && prog_init() == -1)
    255       1.92     pooka 		err(1, "init failed");
    256       1.91     pooka 
    257       1.92     pooka 	if ((s = prog_socket(AF_INET, SOCK_RAW, IPPROTO_ICMP)) < 0)
    258       1.83      elad 		err(1, "Cannot create socket");
    259       1.92     pooka 	if ((sloop = prog_socket(AF_INET, SOCK_RAW, IPPROTO_ICMP)) < 0)
    260       1.83      elad 		err(1, "Cannot create socket");
    261       1.83      elad 
    262       1.87     seanb 	/*
    263       1.87     seanb 	 * sloop is never read on.  This prevents packets from
    264       1.87     seanb 	 * queueing in its recv buffer.
    265       1.87     seanb 	 */
    266       1.92     pooka 	if (prog_shutdown(sloop, SHUT_RD) == -1)
    267       1.87     seanb 		warn("Cannot shutdown for read");
    268       1.87     seanb 
    269       1.93     pooka 	if (prog_setuid(prog_getuid()) == -1)
    270       1.85      elad 		err(1, "setuid");
    271       1.83      elad 
    272       1.59       cgd 	setprogname(argv[0]);
    273       1.59       cgd 
    274       1.50    itojun #ifndef IPSEC
    275       1.50    itojun #define IPSECOPT
    276       1.50    itojun #else
    277       1.50    itojun #ifdef IPSEC_POLICY_IPSEC
    278       1.50    itojun #define IPSECOPT	"E:"
    279       1.50    itojun #else
    280       1.50    itojun #define IPSECOPT	"AE"
    281       1.50    itojun #endif /*IPSEC_POLICY_IPSEC*/
    282       1.50    itojun #endif
    283       1.30  christos 	while ((c = getopt(argc, argv,
    284       1.99  christos 			   "ac:CdDfg:h:i:I:l:Lnop:PqQrRs:t:T:vw:" IPSECOPT)) != -1) {
    285       1.50    itojun #undef IPSECOPT
    286       1.22  christos 		switch (c) {
    287       1.49  sommerfe 		case 'a':
    288       1.49  sommerfe 			pingflags |= F_AUDIBLE;
    289       1.49  sommerfe 			break;
    290       1.99  christos 		case 'C':
    291       1.99  christos 			compat = 1;
    292       1.99  christos 			break;
    293        1.1       cgd 		case 'c':
    294       1.22  christos 			npackets = strtol(optarg, &p, 0);
    295       1.22  christos 			if (*p != '\0' || npackets <= 0)
    296       1.22  christos 				errx(1, "Bad/invalid number of packets");
    297       1.22  christos 			break;
    298       1.22  christos 		case 'D':
    299       1.30  christos 			pingflags |= F_DF;
    300        1.1       cgd 			break;
    301        1.1       cgd 		case 'd':
    302       1.22  christos 			options |= SO_DEBUG;
    303        1.1       cgd 			break;
    304        1.1       cgd 		case 'f':
    305       1.22  christos 			pingflags |= F_FLOOD;
    306        1.8   mycroft 			break;
    307       1.30  christos 		case 'h':
    308       1.30  christos 			hostind = optind-1;
    309       1.30  christos 			break;
    310        1.1       cgd 		case 'i':		/* wait between sending packets */
    311       1.22  christos 			interval = strtod(optarg, &p);
    312       1.22  christos 			if (*p != '\0' || interval <= 0)
    313       1.30  christos 				errx(1, "Bad/invalid interval %s", optarg);
    314        1.8   mycroft 			break;
    315        1.1       cgd 		case 'l':
    316       1.22  christos 			preload = strtol(optarg, &p, 0);
    317       1.22  christos 			if (*p != '\0' || preload < 0)
    318       1.30  christos 				errx(1, "Bad/invalid preload value %s",
    319       1.30  christos 				     optarg);
    320        1.1       cgd 			break;
    321        1.1       cgd 		case 'n':
    322       1.22  christos 			pingflags |= F_NUMERIC;
    323        1.1       cgd 			break;
    324       1.25  christos 		case 'o':
    325       1.25  christos 			pingflags |= F_ONCE;
    326       1.25  christos 			break;
    327        1.1       cgd 		case 'p':		/* fill buffer with user pattern */
    328       1.22  christos 			if (pingflags & F_PING_RANDOM)
    329       1.22  christos 				errx(1, "Only one of -P and -p allowed");
    330       1.22  christos 			pingflags |= F_PING_FILLED;
    331       1.22  christos 			fill_pat = optarg;
    332       1.22  christos 			break;
    333       1.22  christos 		case 'P':
    334       1.22  christos 			if (pingflags & F_PING_FILLED)
    335       1.22  christos 				errx(1, "Only one of -P and -p allowed");
    336       1.22  christos 			pingflags |= F_PING_RANDOM;
    337       1.22  christos 			break;
    338        1.1       cgd 		case 'q':
    339       1.22  christos 			pingflags |= F_QUIET;
    340        1.1       cgd 			break;
    341       1.22  christos 		case 'Q':
    342       1.22  christos 			pingflags |= F_SEMI_QUIET;
    343        1.1       cgd 			break;
    344        1.1       cgd 		case 'r':
    345       1.22  christos 			options |= SO_DONTROUTE;
    346       1.19   ghudson 			break;
    347        1.1       cgd 		case 's':		/* size of packet to send */
    348       1.89     lukem 			l = strtol(optarg, &p, 0);
    349       1.89     lukem 			if (*p != '\0' || l < 0)
    350       1.30  christos 				errx(1, "Bad/invalid packet size %s", optarg);
    351       1.89     lukem 			if (l > MAXPACKET)
    352       1.22  christos 				errx(1, "packet size is too large");
    353       1.99  christos 			len = (int)l;
    354       1.22  christos 			break;
    355       1.22  christos 		case 'v':
    356       1.22  christos 			pingflags |= F_VERBOSE;
    357       1.22  christos 			break;
    358       1.22  christos 		case 'R':
    359       1.22  christos 			pingflags |= F_RECORD_ROUTE;
    360       1.22  christos 			break;
    361       1.22  christos 		case 'L':
    362       1.30  christos 			pingflags |= F_MCAST_NOLOOP;
    363        1.8   mycroft 			break;
    364        1.8   mycroft 		case 't':
    365       1.30  christos 			tos = strtoul(optarg, &p, 0);
    366       1.30  christos 			if (*p != '\0' ||  tos > 0xFF)
    367       1.30  christos 				errx(1, "bad tos value: %s", optarg);
    368       1.22  christos 			break;
    369       1.22  christos 		case 'T':
    370       1.30  christos 			l = strtol(optarg, &p, 0);
    371       1.30  christos 			if (*p != '\0' || l > 255 || l <= 0)
    372       1.30  christos 				errx(1, "ttl out of range");
    373       1.30  christos 			ttl = (u_char)l;    /* cannot check >255 otherwise */
    374       1.22  christos 			break;
    375       1.22  christos 		case 'I':
    376       1.30  christos 			pingflags |= F_SOURCE_ADDR;
    377       1.30  christos 			gethost("-I", optarg, &src_addr, 0, 0);
    378        1.1       cgd 			break;
    379       1.22  christos 		case 'g':
    380       1.22  christos 			pingflags |= F_SOURCE_ROUTE;
    381       1.30  christos 			gethost("-g", optarg, &send_addr, 0, 0);
    382        1.1       cgd 			break;
    383       1.19   ghudson 		case 'w':
    384       1.22  christos 			maxwait = strtod(optarg, &p);
    385       1.22  christos 			if (*p != '\0' || maxwait <= 0)
    386       1.30  christos 				errx(1, "Bad/invalid maxwait time %s", optarg);
    387       1.19   ghudson 			break;
    388       1.50    itojun #ifdef IPSEC
    389       1.50    itojun #ifdef IPSEC_POLICY_IPSEC
    390       1.50    itojun 		case 'E':
    391       1.50    itojun 			pingflags |= F_POLICY;
    392       1.70    itojun 			if (!strncmp("in", optarg, 2)) {
    393       1.55    itojun 				policy_in = strdup(optarg);
    394       1.70    itojun 				if (!policy_in)
    395       1.70    itojun 					err(1, "strdup");
    396       1.70    itojun 			} else if (!strncmp("out", optarg, 3)) {
    397       1.55    itojun 				policy_out = strdup(optarg);
    398       1.70    itojun 				if (!policy_out)
    399       1.70    itojun 					err(1, "strdup");
    400       1.70    itojun 			} else
    401       1.55    itojun 				errx(1, "invalid security policy");
    402       1.50    itojun 			break;
    403       1.50    itojun #else
    404       1.50    itojun 		case 'A':
    405       1.50    itojun 			pingflags |= F_AUTHHDR;
    406       1.50    itojun 			break;
    407       1.50    itojun 		case 'E':
    408       1.50    itojun 			pingflags |= F_ENCRYPT;
    409       1.50    itojun 			break;
    410       1.50    itojun #endif /*IPSEC_POLICY_IPSEC*/
    411       1.50    itojun #endif /*IPSEC*/
    412        1.1       cgd 		default:
    413        1.1       cgd 			usage();
    414       1.22  christos 			break;
    415        1.1       cgd 		}
    416       1.22  christos 	}
    417        1.8   mycroft 
    418       1.22  christos 	if (interval == 0)
    419       1.22  christos 		interval = (pingflags & F_FLOOD) ? FLOOD_INTVL : 1.0;
    420       1.28  christos #ifndef sgi
    421       1.93     pooka 	if (pingflags & F_FLOOD && prog_getuid())
    422       1.39        tv 		errx(1, "Must be superuser to use -f");
    423       1.93     pooka 	if (interval < 1.0 && prog_getuid())
    424       1.28  christos 		errx(1, "Must be superuser to use < 1 sec ping interval");
    425       1.93     pooka 	if (preload > 0 && prog_getuid())
    426       1.39        tv 		errx(1, "Must be superuser to use -l");
    427       1.28  christos #endif
    428       1.99  christos 	sec_to_timespec(interval, &interval_tv);
    429       1.22  christos 
    430       1.49  sommerfe 	if ((pingflags & (F_AUDIBLE|F_FLOOD)) == (F_AUDIBLE|F_FLOOD))
    431       1.49  sommerfe 		warnx("Sorry, no audible output for flood pings");
    432       1.49  sommerfe 
    433       1.22  christos 	if (npackets != 0) {
    434       1.22  christos 		npackets += preload;
    435       1.22  christos 	} else {
    436       1.22  christos 		npackets = INT_MAX;
    437       1.22  christos 	}
    438       1.22  christos 
    439       1.30  christos 	if (hostind == 0) {
    440       1.30  christos 		if (optind != argc-1)
    441       1.30  christos 			usage();
    442       1.22  christos 		else
    443       1.30  christos 			hostind = optind;
    444       1.22  christos 	}
    445       1.30  christos 	else if (hostind >= argc - 1)
    446       1.30  christos 		usage();
    447       1.22  christos 
    448       1.30  christos 	gethost("", argv[hostind], &whereto, hostname, sizeof(hostname));
    449       1.30  christos 	if (IN_MULTICAST(ntohl(whereto.sin_addr.s_addr)))
    450       1.30  christos 		pingflags |= F_MCAST;
    451       1.22  christos 	if (!(pingflags & F_SOURCE_ROUTE))
    452       1.22  christos 		(void) memcpy(&send_addr, &whereto, sizeof(send_addr));
    453       1.22  christos 
    454       1.22  christos 	loc_addr.sin_family = AF_INET;
    455       1.71    itojun 	loc_addr.sin_len = sizeof(struct sockaddr_in);
    456       1.95  christos 	loc_addr.sin_addr.s_addr = htonl((127 << 24) + 1);
    457       1.22  christos 
    458       1.99  christos 	if (len != -1)
    459       1.99  christos 		datalen = len;
    460       1.99  christos 	else
    461       1.99  christos 		datalen = 64;
    462       1.99  christos 	if (!compat && datalen >= (int)PHDR64_LEN) { /* can we time them? */
    463       1.99  christos 		pingflags |= F_TIMING64;
    464       1.99  christos 		phdrlen = PHDR64_LEN;
    465       1.99  christos 	} else if (datalen >= (int)PHDR_LEN) {	/* can we time them? */
    466       1.22  christos 		pingflags |= F_TIMING;
    467       1.99  christos 		phdrlen = PHDR_LEN;
    468       1.99  christos 	} else
    469       1.99  christos 		phdrlen = 0;
    470       1.99  christos 	datalen -= phdrlen;
    471       1.99  christos 
    472       1.22  christos 	packlen = datalen + 60 + 76;	/* MAXIP + MAXICMP */
    473       1.95  christos 	if ((packet = malloc(packlen)) == NULL)
    474       1.22  christos 		err(1, "Out of memory");
    475       1.22  christos 
    476       1.22  christos 	if (pingflags & F_PING_FILLED) {
    477       1.22  christos 		fill();
    478       1.22  christos 	} else if (pingflags & F_PING_RANDOM) {
    479       1.22  christos 		rnd_fill();
    480       1.22  christos 	} else {
    481       1.99  christos 		for (i = phdrlen; i < datalen; i++)
    482       1.22  christos 			opack_icmp.icmp_data[i] = i;
    483       1.22  christos 	}
    484        1.1       cgd 
    485       1.77    kleink 	ident = arc4random() & 0xFFFF;
    486        1.1       cgd 
    487       1.22  christos 	if (options & SO_DEBUG) {
    488       1.92     pooka 		if (prog_setsockopt(s, SOL_SOCKET, SO_DEBUG,
    489       1.41  christos 			       (char *)&on, sizeof(on)) == -1)
    490       1.30  christos 			warn("Can't turn on socket debugging");
    491       1.22  christos 	}
    492       1.22  christos 	if (options & SO_DONTROUTE) {
    493       1.92     pooka 		if (prog_setsockopt(s, SOL_SOCKET, SO_DONTROUTE,
    494       1.41  christos 			       (char *)&on, sizeof(on)) == -1)
    495       1.30  christos 			warn("SO_DONTROUTE");
    496       1.22  christos 	}
    497       1.22  christos 
    498       1.50    itojun 	if (options & SO_DEBUG) {
    499       1.92     pooka 		if (prog_setsockopt(sloop, SOL_SOCKET, SO_DEBUG,
    500       1.50    itojun 			       (char *)&on, sizeof(on)) == -1)
    501       1.50    itojun 			warn("Can't turn on socket debugging");
    502       1.50    itojun 	}
    503       1.50    itojun 	if (options & SO_DONTROUTE) {
    504       1.92     pooka 		if (prog_setsockopt(sloop, SOL_SOCKET, SO_DONTROUTE,
    505       1.50    itojun 			       (char *)&on, sizeof(on)) == -1)
    506       1.50    itojun 			warn("SO_DONTROUTE");
    507       1.50    itojun 	}
    508       1.50    itojun 
    509       1.30  christos 	if (pingflags & F_SOURCE_ROUTE) {
    510       1.30  christos 		optspace[IPOPT_OPTVAL] = IPOPT_LSRR;
    511       1.30  christos 		optspace[IPOPT_OLEN] = optlen = 7;
    512       1.30  christos 		optspace[IPOPT_OFFSET] = IPOPT_MINOFF;
    513       1.41  christos 		(void)memcpy(&optspace[IPOPT_MINOFF-1], &whereto.sin_addr,
    514       1.41  christos 			     sizeof(whereto.sin_addr));
    515       1.30  christos 		optspace[optlen++] = IPOPT_NOP;
    516       1.30  christos 	}
    517       1.30  christos 	if (pingflags & F_RECORD_ROUTE) {
    518       1.30  christos 		optspace[optlen+IPOPT_OPTVAL] = IPOPT_RR;
    519       1.30  christos 		optspace[optlen+IPOPT_OLEN] = (MAX_IPOPTLEN -1-optlen);
    520       1.30  christos 		optspace[optlen+IPOPT_OFFSET] = IPOPT_MINOFF;
    521       1.30  christos 		optlen = MAX_IPOPTLEN;
    522       1.30  christos 	}
    523       1.30  christos 	/* this leaves opack_ip 0(mod 4) aligned */
    524       1.30  christos 	opack_ip = (struct ip *)((char *)&out_pack.o_ip
    525       1.30  christos 				 + sizeof(out_pack.o_opt)
    526       1.30  christos 				 - optlen);
    527       1.30  christos 	(void) memcpy(opack_ip + 1, optspace, optlen);
    528       1.30  christos 
    529       1.92     pooka 	if (prog_setsockopt(s,IPPROTO_IP,IP_HDRINCL,
    530       1.92     pooka 	    (char *) &on, sizeof(on)) < 0)
    531       1.30  christos 		err(1, "Can't set special IP header");
    532       1.30  christos 
    533       1.30  christos 	opack_ip->ip_v = IPVERSION;
    534       1.30  christos 	opack_ip->ip_hl = (sizeof(struct ip)+optlen) >> 2;
    535       1.30  christos 	opack_ip->ip_tos = tos;
    536       1.30  christos 	opack_ip->ip_off = (pingflags & F_DF) ? IP_DF : 0;
    537       1.30  christos 	opack_ip->ip_ttl = ttl ? ttl : MAXTTL;
    538       1.30  christos 	opack_ip->ip_p = IPPROTO_ICMP;
    539       1.30  christos 	opack_ip->ip_src = src_addr.sin_addr;
    540       1.30  christos 	opack_ip->ip_dst = send_addr.sin_addr;
    541       1.30  christos 
    542       1.30  christos 	if (pingflags & F_MCAST) {
    543       1.30  christos 		if (pingflags & F_MCAST_NOLOOP) {
    544       1.30  christos 			u_char loop = 0;
    545       1.92     pooka 			if (prog_setsockopt(s, IPPROTO_IP,
    546       1.92     pooka 			    IP_MULTICAST_LOOP,
    547       1.30  christos 			    (char *) &loop, 1) < 0)
    548       1.30  christos 				err(1, "Can't disable multicast loopback");
    549       1.22  christos 		}
    550        1.1       cgd 
    551       1.30  christos 		if (ttl != 0
    552       1.92     pooka 		    && prog_setsockopt(s, IPPROTO_IP, IP_MULTICAST_TTL,
    553       1.30  christos 		    (char *) &ttl, 1) < 0)
    554       1.22  christos 			err(1, "Can't set multicast time-to-live");
    555       1.30  christos 
    556       1.30  christos 		if ((pingflags & F_SOURCE_ADDR)
    557       1.92     pooka 		    && prog_setsockopt(s, IPPROTO_IP, IP_MULTICAST_IF,
    558       1.30  christos 				  (char *) &src_addr.sin_addr,
    559       1.30  christos 				  sizeof(src_addr.sin_addr)) < 0)
    560       1.22  christos 			err(1, "Can't set multicast source interface");
    561       1.30  christos 
    562       1.30  christos 	} else if (pingflags & F_SOURCE_ADDR) {
    563       1.92     pooka 		if (prog_setsockopt(s, IPPROTO_IP, IP_MULTICAST_IF,
    564       1.30  christos 			       (char *) &src_addr.sin_addr,
    565       1.30  christos 			       sizeof(src_addr.sin_addr)) < 0)
    566       1.30  christos 			err(1, "Can't set source interface/address");
    567       1.22  christos 	}
    568       1.50    itojun #ifdef IPSEC
    569       1.50    itojun #ifdef IPSEC_POLICY_IPSEC
    570       1.50    itojun     {
    571       1.50    itojun 	char *buf;
    572       1.50    itojun 	if (pingflags & F_POLICY) {
    573       1.55    itojun 		if (policy_in != NULL) {
    574       1.55    itojun 			buf = ipsec_set_policy(policy_in, strlen(policy_in));
    575       1.55    itojun 			if (buf == NULL)
    576       1.57        is 				errx(1, "%s", ipsec_strerror());
    577       1.92     pooka 			if (prog_setsockopt(s, IPPROTO_IP, IP_IPSEC_POLICY,
    578       1.55    itojun 					buf, ipsec_get_policylen(buf)) < 0) {
    579       1.55    itojun 				err(1, "ipsec policy cannot be configured");
    580       1.55    itojun 			}
    581       1.55    itojun 			free(buf);
    582       1.55    itojun 		}
    583       1.55    itojun 		if (policy_out != NULL) {
    584       1.55    itojun 			buf = ipsec_set_policy(policy_out, strlen(policy_out));
    585       1.55    itojun 			if (buf == NULL)
    586       1.57        is 				errx(1, "%s", ipsec_strerror());
    587       1.92     pooka 			if (prog_setsockopt(s, IPPROTO_IP, IP_IPSEC_POLICY,
    588       1.55    itojun 					buf, ipsec_get_policylen(buf)) < 0) {
    589       1.55    itojun 				err(1, "ipsec policy cannot be configured");
    590       1.55    itojun 			}
    591       1.55    itojun 			free(buf);
    592       1.55    itojun 		}
    593       1.50    itojun 	}
    594       1.55    itojun 	buf = ipsec_set_policy("out bypass", strlen("out bypass"));
    595       1.55    itojun 	if (buf == NULL)
    596       1.57        is 		errx(1, "%s", ipsec_strerror());
    597       1.92     pooka 	if (prog_setsockopt(sloop, IPPROTO_IP, IP_IPSEC_POLICY,
    598       1.55    itojun 			buf, ipsec_get_policylen(buf)) < 0) {
    599       1.52    itojun #if 0
    600       1.50    itojun 		warnx("ipsec is not configured");
    601       1.52    itojun #else
    602       1.52    itojun 		/* ignore it, should be okay */
    603       1.52    itojun #endif
    604       1.52    itojun 	}
    605       1.50    itojun 	free(buf);
    606       1.50    itojun     }
    607       1.50    itojun #else
    608       1.50    itojun     {
    609       1.50    itojun 	int optval;
    610       1.50    itojun 	if (pingflags & F_AUTHHDR) {
    611       1.50    itojun 		optval = IPSEC_LEVEL_REQUIRE;
    612       1.50    itojun #ifdef IP_AUTH_TRANS_LEVEL
    613       1.92     pooka 		(void)prog_setsockopt(s, IPPROTO_IP, IP_AUTH_TRANS_LEVEL,
    614       1.50    itojun 			(char *)&optval, sizeof(optval));
    615       1.50    itojun #else
    616       1.92     pooka 		(void)prog_setsockopt(s, IPPROTO_IP, IP_AUTH_LEVEL,
    617       1.50    itojun 			(char *)&optval, sizeof(optval));
    618       1.50    itojun #endif
    619       1.50    itojun 	}
    620       1.50    itojun 	if (pingflags & F_ENCRYPT) {
    621       1.50    itojun 		optval = IPSEC_LEVEL_REQUIRE;
    622       1.92     pooka 		(void)prog_setsockopt(s, IPPROTO_IP, IP_ESP_TRANS_LEVEL,
    623       1.50    itojun 			(char *)&optval, sizeof(optval));
    624       1.50    itojun 	}
    625       1.50    itojun 	optval = IPSEC_LEVEL_BYPASS;
    626       1.50    itojun #ifdef IP_AUTH_TRANS_LEVEL
    627       1.92     pooka 	(void)prog_setsockopt(sloop, IPPROTO_IP, IP_AUTH_TRANS_LEVEL,
    628       1.50    itojun 		(char *)&optval, sizeof(optval));
    629       1.50    itojun #else
    630       1.92     pooka 	(void)prog_setsockopt(sloop, IPPROTO_IP, IP_AUTH_LEVEL,
    631       1.50    itojun 		(char *)&optval, sizeof(optval));
    632       1.50    itojun #endif
    633       1.92     pooka 	(void)prog_setsockopt(sloop, IPPROTO_IP, IP_ESP_TRANS_LEVEL,
    634       1.50    itojun 		(char *)&optval, sizeof(optval));
    635       1.50    itojun     }
    636       1.50    itojun #endif /*IPSEC_POLICY_IPSEC*/
    637       1.50    itojun #endif /*IPSEC*/
    638        1.8   mycroft 
    639       1.30  christos 	(void)printf("PING %s (%s): %d data bytes\n", hostname,
    640       1.30  christos 		     inet_ntoa(whereto.sin_addr), datalen);
    641       1.22  christos 
    642       1.22  christos 	/* When pinging the broadcast address, you can get a lot
    643       1.22  christos 	 * of answers.  Doing something so evil is useful if you
    644       1.22  christos 	 * are trying to stress the ethernet, or just want to
    645       1.22  christos 	 * fill the arp cache to get some stuff for /etc/ethers.
    646        1.1       cgd 	 */
    647       1.92     pooka 	while (0 > prog_setsockopt(s, SOL_SOCKET, SO_RCVBUF,
    648       1.22  christos 			      (char*)&bufspace, sizeof(bufspace))) {
    649       1.60      yamt 		if ((bufspace -= 4096) <= 0)
    650       1.22  christos 			err(1, "Cannot set the receive buffer size");
    651       1.22  christos 	}
    652        1.1       cgd 
    653       1.30  christos 	/* make it possible to send giant probes, but do not worry now
    654       1.30  christos 	 * if it fails, since we probably won't send giant probes.
    655       1.30  christos 	 */
    656       1.92     pooka 	(void)prog_setsockopt(s, SOL_SOCKET, SO_SNDBUF,
    657       1.30  christos 			 (char*)&bufspace, sizeof(bufspace));
    658       1.22  christos 
    659       1.22  christos 	(void)signal(SIGINT, prefinish);
    660       1.48       mjl 
    661       1.22  christos #ifdef SIGINFO
    662       1.81  christos 	sa.sa_handler = prtsig;
    663       1.81  christos 	sa.sa_flags = SA_NOKERNINFO;
    664       1.81  christos 	sigemptyset(&sa.sa_mask);
    665       1.81  christos 	(void)sigaction(SIGINFO, &sa, NULL);
    666       1.22  christos #else
    667       1.22  christos 	(void)signal(SIGQUIT, prtsig);
    668       1.22  christos #endif
    669       1.22  christos 	(void)signal(SIGCONT, prtsig);
    670       1.22  christos 
    671       1.22  christos 	/* fire off them quickies */
    672       1.22  christos 	for (i = 0; i < preload; i++) {
    673       1.99  christos 		clock_gettime(CLOCK_MONOTONIC, &now);
    674        1.1       cgd 		pinger();
    675       1.22  christos 	}
    676       1.22  christos 
    677       1.22  christos 	doit();
    678       1.22  christos 	return 0;
    679       1.22  christos }
    680       1.22  christos 
    681       1.22  christos 
    682       1.22  christos static void
    683       1.22  christos doit(void)
    684       1.22  christos {
    685       1.22  christos 	int cc;
    686       1.22  christos 	struct sockaddr_in from;
    687       1.78       mrg 	socklen_t fromlen;
    688       1.30  christos 	double sec, last, d_last;
    689       1.67   mycroft 	struct pollfd fdmaskp[1];
    690        1.1       cgd 
    691       1.99  christos 	(void)clock_gettime(CLOCK_MONOTONIC, &clear_cache);
    692       1.30  christos 	if (maxwait != 0) {
    693       1.99  christos 		last = timespec_to_sec(&clear_cache) + maxwait;
    694       1.30  christos 		d_last = 0;
    695       1.30  christos 	} else {
    696       1.30  christos 		last = 0;
    697       1.30  christos 		d_last = 365*24*60*60;
    698       1.30  christos 	}
    699        1.1       cgd 
    700       1.30  christos 	do {
    701       1.99  christos 		clock_gettime(CLOCK_MONOTONIC, &now);
    702       1.22  christos 
    703       1.30  christos 		if (last != 0)
    704       1.99  christos 			d_last = last - timespec_to_sec(&now);
    705       1.22  christos 
    706       1.30  christos 		if (ntransmitted < npackets && d_last > 0) {
    707       1.22  christos 			/* send if within 100 usec or late for next packet */
    708       1.95  christos 			sec = diffsec(&next_tx, &now);
    709       1.75    itojun 			if (sec <= 0.0001 ||
    710       1.75    itojun 			    (lastrcvd && (pingflags & F_FLOOD))) {
    711       1.22  christos 				pinger();
    712       1.95  christos 				sec = diffsec(&next_tx, &now);
    713       1.22  christos 			}
    714       1.22  christos 			if (sec < 0.0)
    715       1.22  christos 				sec = 0.0;
    716       1.30  christos 			if (d_last < sec)
    717       1.30  christos 				sec = d_last;
    718       1.22  christos 
    719       1.22  christos 		} else {
    720       1.22  christos 			/* For the last response, wait twice as long as the
    721       1.22  christos 			 * worst case seen, or 10 times as long as the
    722       1.22  christos 			 * maximum interpacket interval, whichever is longer.
    723       1.22  christos 			 */
    724       1.75    itojun 			sec = MAX(2 * tmax, 10 * interval) -
    725       1.75    itojun 			    diffsec(&now, &last_tx);
    726       1.30  christos 			if (d_last < sec)
    727       1.30  christos 				sec = d_last;
    728       1.22  christos 			if (sec <= 0)
    729       1.30  christos 				break;
    730       1.22  christos 		}
    731       1.22  christos 
    732       1.67   mycroft 		fdmaskp[0].fd = s;
    733       1.67   mycroft 		fdmaskp[0].events = POLLIN;
    734       1.92     pooka 		cc = prog_poll(fdmaskp, 1, (int)(sec * 1000));
    735       1.22  christos 		if (cc <= 0) {
    736       1.22  christos 			if (cc < 0) {
    737       1.22  christos 				if (errno == EINTR)
    738       1.22  christos 					continue;
    739       1.22  christos 				jiggle_flush(1);
    740       1.68   mycroft 				err(1, "poll");
    741       1.22  christos 			}
    742       1.22  christos 			continue;
    743        1.1       cgd 		}
    744       1.22  christos 
    745       1.22  christos 		fromlen  = sizeof(from);
    746       1.92     pooka 		cc = prog_recvfrom(s, (char *) packet, packlen,
    747       1.30  christos 			      0, (struct sockaddr *)&from,
    748       1.22  christos 			      &fromlen);
    749       1.22  christos 		if (cc < 0) {
    750       1.22  christos 			if (errno != EINTR) {
    751       1.22  christos 				jiggle_flush(1);
    752       1.30  christos 				warn("recvfrom");
    753       1.22  christos 				(void)fflush(stderr);
    754       1.22  christos 			}
    755        1.1       cgd 			continue;
    756        1.1       cgd 		}
    757       1.99  christos 		clock_gettime(CLOCK_MONOTONIC, &now);
    758       1.22  christos 		pr_pack(packet, cc, &from);
    759       1.30  christos 
    760       1.30  christos 	} while (nreceived < npackets
    761       1.30  christos 		 && (nreceived == 0 || !(pingflags & F_ONCE)));
    762       1.30  christos 
    763       1.30  christos 	finish(0);
    764       1.22  christos }
    765       1.22  christos 
    766       1.22  christos 
    767       1.22  christos static void
    768       1.22  christos jiggle_flush(int nl)			/* new line if there are dots */
    769       1.22  christos {
    770       1.22  christos 	int serrno = errno;
    771       1.22  christos 
    772       1.22  christos 	if (jiggle_cnt > 0) {
    773       1.22  christos 		total_jiggled += jiggle_cnt;
    774       1.22  christos 		jiggle_direction = 1;
    775       1.22  christos 		do {
    776       1.22  christos 			(void)putchar('.');
    777       1.22  christos 		} while (--jiggle_cnt > 0);
    778       1.22  christos 
    779       1.22  christos 	} else if (jiggle_cnt < 0) {
    780       1.22  christos 		total_jiggled -= jiggle_cnt;
    781       1.22  christos 		jiggle_direction = -1;
    782       1.22  christos 		do {
    783       1.22  christos 			(void)putchar('\b');
    784       1.22  christos 		} while (++jiggle_cnt < 0);
    785       1.22  christos 	}
    786       1.22  christos 
    787       1.22  christos 	if (nl) {
    788       1.22  christos 		if (total_jiggled != 0)
    789       1.22  christos 			(void)putchar('\n');
    790       1.22  christos 		total_jiggled = 0;
    791       1.22  christos 		jiggle_direction = -1;
    792        1.1       cgd 	}
    793       1.22  christos 
    794       1.22  christos 	(void)fflush(stdout);
    795       1.22  christos 	(void)fflush(stderr);
    796       1.22  christos 	jiggle_time = now;
    797       1.22  christos 	errno = serrno;
    798        1.1       cgd }
    799        1.1       cgd 
    800       1.22  christos 
    801       1.22  christos /* jiggle the cursor for flood-ping
    802        1.1       cgd  */
    803       1.22  christos static void
    804       1.22  christos jiggle(int delta)
    805        1.1       cgd {
    806       1.22  christos 	double dt;
    807        1.1       cgd 
    808       1.22  christos 	if (pingflags & F_QUIET)
    809       1.22  christos 		return;
    810       1.22  christos 
    811       1.22  christos 	/* do not back up into messages */
    812       1.22  christos 	if (total_jiggled+jiggle_cnt+delta < 0)
    813       1.22  christos 		return;
    814       1.22  christos 
    815       1.22  christos 	jiggle_cnt += delta;
    816       1.22  christos 
    817       1.22  christos 	/* flush the FLOOD dots when things are quiet
    818       1.22  christos 	 * or occassionally to make the cursor jiggle.
    819       1.22  christos 	 */
    820       1.22  christos 	dt = diffsec(&last_tx, &jiggle_time);
    821       1.22  christos 	if (dt > 0.2 || (dt >= 0.15 && delta*jiggle_direction < 0))
    822       1.22  christos 		jiggle_flush(0);
    823        1.1       cgd }
    824        1.1       cgd 
    825       1.22  christos 
    826        1.1       cgd /*
    827       1.22  christos  * Compose and transmit an ICMP ECHO REQUEST packet.  The IP packet
    828       1.30  christos  * will be added on by the kernel.  The ID field is our UNIX process ID,
    829       1.99  christos  * and the sequence number is an ascending integer.  The first phdrlen bytes
    830        1.1       cgd  * of the data portion are used to hold a UNIX "timeval" struct in VAX
    831       1.99  christos  * byte-order, to compute the round-trip time, or a UNIX "timespec" in native
    832       1.99  christos  * format.
    833        1.1       cgd  */
    834       1.22  christos static void
    835       1.22  christos pinger(void)
    836        1.1       cgd {
    837       1.75    itojun 	struct tv32 tv32;
    838       1.30  christos 	int i, cc, sw;
    839       1.22  christos 
    840       1.22  christos 	opack_icmp.icmp_code = 0;
    841       1.65    itojun 	opack_icmp.icmp_seq = htons((u_int16_t)(ntransmitted));
    842       1.30  christos 
    843       1.30  christos 	/* clear the cached route in the kernel after an ICMP
    844       1.30  christos 	 * response such as a Redirect is seen to stop causing
    845       1.30  christos 	 * more such packets.  Also clear the cached route
    846       1.30  christos 	 * periodically in case of routing changes that make
    847       1.30  christos 	 * black holes come and go.
    848       1.30  christos 	 */
    849       1.22  christos 	if (clear_cache.tv_sec != now.tv_sec) {
    850       1.22  christos 		opack_icmp.icmp_type = ICMP_ECHOREPLY;
    851       1.22  christos 		opack_icmp.icmp_id = ~ident;
    852       1.22  christos 		opack_icmp.icmp_cksum = 0;
    853       1.65    itojun 		opack_icmp.icmp_cksum = in_cksum((u_int16_t *)&opack_icmp,
    854       1.99  christos 		    phdrlen);
    855       1.30  christos 		sw = 0;
    856       1.92     pooka 		if (prog_setsockopt(sloop,IPPROTO_IP,IP_HDRINCL,
    857       1.30  christos 			       (char *)&sw,sizeof(sw)) < 0)
    858       1.30  christos 			err(1, "Can't turn off special IP header");
    859       1.92     pooka 		if (prog_sendto(sloop, (char *) &opack_icmp,
    860       1.99  christos 			   phdrlen, MSG_DONTROUTE,
    861       1.30  christos 			   (struct sockaddr *)&loc_addr,
    862       1.34  christos 			   sizeof(struct sockaddr_in)) < 0) {
    863       1.34  christos 			/*
    864       1.34  christos 			 * XXX: we only report this as a warning in verbose
    865       1.34  christos 			 * mode because people get confused when they see
    866       1.34  christos 			 * this error when they are running in single user
    867       1.34  christos 			 * mode and they have not configured lo0
    868       1.34  christos 			 */
    869       1.34  christos 			if (pingflags & F_VERBOSE)
    870       1.34  christos 				warn("failed to clear cached route");
    871       1.34  christos 		}
    872       1.30  christos 		sw = 1;
    873       1.92     pooka 		if (prog_setsockopt(sloop,IPPROTO_IP,IP_HDRINCL,
    874       1.30  christos 			       (char *)&sw, sizeof(sw)) < 0)
    875       1.30  christos 			err(1, "Can't set special IP header");
    876       1.30  christos 
    877       1.99  christos 		(void)clock_gettime(CLOCK_MONOTONIC, &clear_cache);
    878       1.22  christos 	}
    879       1.30  christos 
    880       1.22  christos 	opack_icmp.icmp_type = ICMP_ECHO;
    881       1.22  christos 	opack_icmp.icmp_id = ident;
    882       1.99  christos 
    883       1.99  christos 	if (pingflags & F_TIMING) {
    884       1.99  christos 		tv32.tv32_sec = (uint32_t)htonl(now.tv_sec);
    885       1.99  christos 		tv32.tv32_usec = htonl(now.tv_nsec / 1000);
    886       1.75    itojun 		(void) memcpy(&opack_icmp.icmp_data[0], &tv32, sizeof(tv32));
    887       1.99  christos 	} else if (pingflags & F_TIMING64)
    888       1.99  christos 		(void) memcpy(&opack_icmp.icmp_data[0], &now, sizeof(now));
    889       1.99  christos 
    890       1.99  christos 	cc = datalen + phdrlen;
    891       1.22  christos 	opack_icmp.icmp_cksum = 0;
    892       1.65    itojun 	opack_icmp.icmp_cksum = in_cksum((u_int16_t *)&opack_icmp, cc);
    893       1.22  christos 
    894       1.30  christos 	cc += opack_ip->ip_hl<<2;
    895       1.30  christos 	opack_ip->ip_len = cc;
    896       1.92     pooka 	i = prog_sendto(s, (char *) opack_ip, cc, 0,
    897       1.30  christos 		   (struct sockaddr *)&send_addr, sizeof(struct sockaddr_in));
    898       1.22  christos 	if (i != cc) {
    899       1.22  christos 		jiggle_flush(1);
    900       1.22  christos 		if (i < 0)
    901       1.30  christos 			warn("sendto");
    902       1.22  christos 		else
    903       1.30  christos 			warnx("wrote %s %d chars, ret=%d", hostname, cc, i);
    904       1.22  christos 		(void)fflush(stderr);
    905       1.22  christos 	}
    906       1.22  christos 	lastrcvd = 0;
    907       1.22  christos 
    908       1.22  christos 	CLR(ntransmitted);
    909       1.22  christos 	ntransmitted++;
    910       1.22  christos 
    911       1.22  christos 	last_tx = now;
    912       1.22  christos 	if (next_tx.tv_sec == 0) {
    913       1.22  christos 		first_tx = now;
    914       1.22  christos 		next_tx = now;
    915       1.22  christos 	}
    916        1.1       cgd 
    917       1.22  christos 	/* Transmit regularly, at always the same microsecond in the
    918       1.22  christos 	 * second when going at one packet per second.
    919       1.22  christos 	 * If we are at most 100 ms behind, send extras to get caught up.
    920       1.22  christos 	 * Otherwise, skip packets we were too slow to send.
    921       1.22  christos 	 */
    922       1.22  christos 	if (diffsec(&next_tx, &now) <= interval) {
    923       1.22  christos 		do {
    924       1.99  christos 			timespecadd(&next_tx, &interval_tv, &next_tx);
    925       1.22  christos 		} while (diffsec(&next_tx, &now) < -0.1);
    926       1.22  christos 	}
    927        1.1       cgd 
    928       1.22  christos 	if (pingflags & F_FLOOD)
    929       1.22  christos 		jiggle(1);
    930        1.1       cgd 
    931       1.22  christos 	/* While the packet is going out, ready buffer for the next
    932       1.22  christos 	 * packet. Use a fast but not very good random number generator.
    933       1.22  christos 	 */
    934       1.22  christos 	if (pingflags & F_PING_RANDOM)
    935       1.22  christos 		rnd_fill();
    936       1.22  christos }
    937        1.1       cgd 
    938        1.1       cgd 
    939       1.22  christos static void
    940       1.30  christos pr_pack_sub(int cc,
    941       1.30  christos 	    char *addr,
    942       1.30  christos 	    int seqno,
    943       1.30  christos 	    int dupflag,
    944       1.30  christos 	    int ttl,
    945       1.22  christos 	    double triptime)
    946       1.22  christos {
    947       1.22  christos 	jiggle_flush(1);
    948        1.1       cgd 
    949       1.22  christos 	if (pingflags & F_FLOOD)
    950       1.22  christos 		return;
    951        1.1       cgd 
    952       1.22  christos 	(void)printf("%d bytes from %s: icmp_seq=%u", cc, addr, seqno);
    953       1.30  christos 	if (dupflag)
    954       1.30  christos 		(void)printf(" DUP!");
    955       1.22  christos 	(void)printf(" ttl=%d", ttl);
    956       1.99  christos 	if (pingflags & (F_TIMING|F_TIMING64))
    957       1.22  christos 		(void)printf(" time=%.3f ms", triptime*1000.0);
    958       1.49  sommerfe 
    959       1.49  sommerfe 	/*
    960       1.49  sommerfe 	 * Send beep to stderr, since that's more likely than stdout
    961       1.49  sommerfe 	 * to go to a terminal..
    962       1.49  sommerfe 	 */
    963       1.49  sommerfe 	if (pingflags & F_AUDIBLE && !dupflag)
    964       1.49  sommerfe 		(void)fprintf(stderr,"\a");
    965        1.1       cgd }
    966        1.1       cgd 
    967       1.22  christos 
    968        1.1       cgd /*
    969       1.22  christos  * Print out the packet, if it came from us.  This logic is necessary
    970        1.1       cgd  * because ALL readers of the ICMP socket get a copy of ALL ICMP packets
    971        1.1       cgd  * which arrive ('tis only fair).  This permits multiple copies of this
    972        1.1       cgd  * program to be run without having intermingled output (or statistics!).
    973        1.1       cgd  */
    974       1.22  christos static void
    975       1.30  christos pr_pack(u_char *buf,
    976       1.41  christos 	int tot_len,
    977       1.22  christos 	struct sockaddr_in *from)
    978        1.1       cgd {
    979       1.22  christos 	struct ip *ip;
    980       1.32     lukem 	struct icmp *icp;
    981       1.41  christos 	int i, j, net_len;
    982       1.32     lukem 	u_char *cp;
    983        1.1       cgd 	static int old_rrlen;
    984        1.1       cgd 	static char old_rr[MAX_IPOPTLEN];
    985       1.22  christos 	int hlen, dupflag = 0, dumped;
    986       1.22  christos 	double triptime = 0.0;
    987       1.22  christos #define PR_PACK_SUB() {if (!dumped) {			\
    988       1.22  christos 	dumped = 1;					\
    989       1.41  christos 	pr_pack_sub(net_len, inet_ntoa(from->sin_addr),	\
    990       1.65    itojun 		    ntohs((u_int16_t)icp->icmp_seq),	\
    991       1.22  christos 		    dupflag, ip->ip_ttl, triptime);}}
    992        1.1       cgd 
    993        1.1       cgd 	/* Check the IP header */
    994       1.22  christos 	ip = (struct ip *) buf;
    995        1.1       cgd 	hlen = ip->ip_hl << 2;
    996       1.41  christos 	if (tot_len < hlen + ICMP_MINLEN) {
    997       1.22  christos 		if (pingflags & F_VERBOSE) {
    998       1.22  christos 			jiggle_flush(1);
    999       1.30  christos 			(void)printf("packet too short (%d bytes) from %s\n",
   1000       1.41  christos 				     tot_len, inet_ntoa(from->sin_addr));
   1001       1.22  christos 		}
   1002        1.1       cgd 		return;
   1003        1.1       cgd 	}
   1004        1.1       cgd 
   1005        1.1       cgd 	/* Now the ICMP part */
   1006       1.22  christos 	dumped = 0;
   1007       1.41  christos 	net_len = tot_len - hlen;
   1008        1.1       cgd 	icp = (struct icmp *)(buf + hlen);
   1009       1.22  christos 	if (icp->icmp_type == ICMP_ECHOREPLY
   1010       1.22  christos 	    && icp->icmp_id == ident) {
   1011       1.99  christos 		struct timespec tv;
   1012       1.99  christos 
   1013       1.65    itojun 		if (icp->icmp_seq == htons((u_int16_t)(ntransmitted-1)))
   1014       1.22  christos 			lastrcvd = 1;
   1015       1.22  christos 		last_rx = now;
   1016       1.22  christos 		if (first_rx.tv_sec == 0)
   1017       1.22  christos 			first_rx = last_rx;
   1018       1.22  christos 		nreceived++;
   1019       1.22  christos 		if (pingflags & F_TIMING) {
   1020       1.75    itojun 			struct tv32 tv32;
   1021       1.75    itojun 
   1022       1.75    itojun 			(void) memcpy(&tv32, icp->icmp_data, sizeof(tv32));
   1023       1.95  christos 			tv.tv_sec = (uint32_t)ntohl(tv32.tv32_sec);
   1024       1.99  christos 			tv.tv_nsec = ntohl(tv32.tv32_usec) * 1000;
   1025       1.99  christos 		} else if (pingflags & F_TIMING64)
   1026       1.99  christos 			(void) memcpy(&tv, icp->icmp_data, sizeof(tv));
   1027       1.99  christos 
   1028       1.99  christos 		if (pingflags & (F_TIMING|F_TIMING64)) {
   1029       1.26  christos 			triptime = diffsec(&last_rx, &tv);
   1030        1.1       cgd 			tsum += triptime;
   1031       1.44     jwise 			tsumsq += triptime * triptime;
   1032        1.1       cgd 			if (triptime < tmin)
   1033        1.1       cgd 				tmin = triptime;
   1034        1.1       cgd 			if (triptime > tmax)
   1035        1.1       cgd 				tmax = triptime;
   1036        1.1       cgd 		}
   1037        1.1       cgd 
   1038       1.65    itojun 		if (TST(ntohs((u_int16_t)icp->icmp_seq))) {
   1039       1.22  christos 			nrepeats++, nreceived--;
   1040       1.22  christos 			dupflag=1;
   1041       1.30  christos 		} else {
   1042       1.65    itojun 			SET(ntohs((u_int16_t)icp->icmp_seq));
   1043       1.30  christos 		}
   1044        1.1       cgd 
   1045       1.41  christos 		if (tot_len != opack_ip->ip_len) {
   1046       1.41  christos 			PR_PACK_SUB();
   1047       1.88  christos 			switch (opack_ip->ip_len - tot_len) {
   1048       1.88  christos 			case MAX_IPOPTLEN:
   1049       1.88  christos 				if ((pongflags & F_RECORD_ROUTE) != 0)
   1050       1.88  christos 					break;
   1051       1.88  christos 				if ((pingflags & F_RECORD_ROUTE) == 0)
   1052       1.88  christos 					goto out;
   1053       1.88  christos 				pongflags |= F_RECORD_ROUTE;
   1054       1.88  christos 				(void)printf("\nremote host does not "
   1055       1.88  christos 				    "support record route");
   1056       1.88  christos 				break;
   1057       1.88  christos 			case 8:
   1058       1.88  christos 				if ((pongflags & F_SOURCE_ROUTE) != 0)
   1059       1.88  christos 					break;
   1060       1.88  christos 				if ((pingflags & F_SOURCE_ROUTE) == 0)
   1061       1.88  christos 					goto out;
   1062       1.88  christos 				pongflags |= F_SOURCE_ROUTE;
   1063       1.88  christos 				(void)printf("\nremote host does not "
   1064       1.88  christos 				    "support source route");
   1065       1.88  christos 				break;
   1066       1.88  christos 			default:
   1067       1.88  christos 			out:
   1068       1.88  christos 				(void)printf("\nwrong total length %d "
   1069       1.88  christos 				    "instead of %d", tot_len, opack_ip->ip_len);
   1070       1.88  christos 				break;
   1071       1.88  christos 			}
   1072       1.66      matt 		}
   1073       1.66      matt 
   1074       1.66      matt 		if (!dupflag) {
   1075       1.66      matt 			static u_int16_t last_seqno = 0xffff;
   1076       1.66      matt 			u_int16_t seqno = ntohs((u_int16_t)icp->icmp_seq);
   1077       1.66      matt 			u_int16_t gap = seqno - (last_seqno + 1);
   1078       1.66      matt 			if (gap > 0 && gap < 0x8000 &&
   1079       1.66      matt 			    (pingflags & F_VERBOSE)) {
   1080       1.66      matt 				(void)printf("[*** sequence gap of %u "
   1081       1.66      matt 				    "packets from %u ... %u ***]\n", gap,
   1082       1.66      matt 				    (u_int16_t) (last_seqno + 1),
   1083       1.66      matt 				    (u_int16_t) (seqno - 1));
   1084       1.66      matt 				if (pingflags & F_QUIET)
   1085       1.66      matt 					summary(0);
   1086       1.66      matt 			}
   1087       1.66      matt 
   1088       1.66      matt 			if (gap < 0x8000)
   1089       1.66      matt 				last_seqno = seqno;
   1090       1.41  christos 		}
   1091       1.41  christos 
   1092       1.22  christos 		if (pingflags & F_QUIET)
   1093        1.1       cgd 			return;
   1094        1.1       cgd 
   1095       1.22  christos 		if (!(pingflags & F_FLOOD))
   1096       1.22  christos 			PR_PACK_SUB();
   1097       1.22  christos 
   1098       1.22  christos 		/* check the data */
   1099       1.99  christos 		if (datalen > phdrlen
   1100       1.22  christos 		    && !(pingflags & F_PING_RANDOM)
   1101       1.99  christos 		    && memcmp(icp->icmp_data + phdrlen,
   1102       1.99  christos 			    opack_icmp.icmp_data + phdrlen,
   1103       1.99  christos 			    datalen - phdrlen)) {
   1104       1.99  christos 			for (i = phdrlen; i < datalen; i++) {
   1105       1.54   mycroft 				if (icp->icmp_data[i] !=
   1106       1.54   mycroft 				    opack_icmp.icmp_data[i])
   1107        1.1       cgd 					break;
   1108       1.22  christos 			}
   1109       1.22  christos 			PR_PACK_SUB();
   1110       1.22  christos 			(void)printf("\nwrong data byte #%d should have been"
   1111       1.54   mycroft 				     " %#x but was %#x", i,
   1112       1.54   mycroft 				     (u_char)opack_icmp.icmp_data[i],
   1113       1.22  christos 				     (u_char)icp->icmp_data[i]);
   1114       1.99  christos 			for (i = phdrlen; i < datalen; i++) {
   1115       1.99  christos 				if ((i % 16) == phdrlen)
   1116       1.22  christos 					(void)printf("\n\t");
   1117       1.30  christos 				(void)printf("%2x ",(u_char)icp->icmp_data[i]);
   1118        1.1       cgd 			}
   1119        1.1       cgd 		}
   1120       1.22  christos 
   1121        1.1       cgd 	} else {
   1122       1.41  christos 		if (!pr_icmph(icp, from, net_len))
   1123        1.1       cgd 			return;
   1124       1.22  christos 		dumped = 2;
   1125        1.1       cgd 	}
   1126        1.1       cgd 
   1127        1.1       cgd 	/* Display any IP options */
   1128       1.22  christos 	cp = buf + sizeof(struct ip);
   1129       1.22  christos 	while (hlen > (int)sizeof(struct ip)) {
   1130        1.1       cgd 		switch (*cp) {
   1131        1.1       cgd 		case IPOPT_EOL:
   1132        1.1       cgd 			hlen = 0;
   1133        1.1       cgd 			break;
   1134        1.1       cgd 		case IPOPT_LSRR:
   1135        1.1       cgd 			hlen -= 2;
   1136        1.1       cgd 			j = *++cp;
   1137        1.1       cgd 			++cp;
   1138       1.22  christos 			j -= IPOPT_MINOFF;
   1139       1.22  christos 			if (j <= 0)
   1140       1.22  christos 				continue;
   1141       1.22  christos 			if (dumped <= 1) {
   1142       1.22  christos 				j = ((j+3)/4)*4;
   1143       1.22  christos 				hlen -= j;
   1144       1.22  christos 				cp += j;
   1145       1.22  christos 				break;
   1146       1.22  christos 			}
   1147       1.22  christos 			PR_PACK_SUB();
   1148       1.22  christos 			(void)printf("\nLSRR: ");
   1149       1.22  christos 			for (;;) {
   1150       1.57        is 				pr_saddr(cp);
   1151       1.22  christos 				cp += 4;
   1152        1.1       cgd 				hlen -= 4;
   1153        1.1       cgd 				j -= 4;
   1154       1.22  christos 				if (j <= 0)
   1155        1.1       cgd 					break;
   1156        1.1       cgd 				(void)putchar('\n');
   1157        1.1       cgd 			}
   1158        1.1       cgd 			break;
   1159        1.1       cgd 		case IPOPT_RR:
   1160       1.22  christos 			j = *++cp;	/* get length */
   1161       1.22  christos 			i = *++cp;	/* and pointer */
   1162        1.1       cgd 			hlen -= 2;
   1163        1.1       cgd 			if (i > j)
   1164        1.1       cgd 				i = j;
   1165        1.1       cgd 			i -= IPOPT_MINOFF;
   1166        1.1       cgd 			if (i <= 0)
   1167        1.1       cgd 				continue;
   1168       1.22  christos 			if (dumped <= 1) {
   1169       1.22  christos 				if (i == old_rrlen
   1170       1.30  christos 				    && !memcmp(cp, old_rr, i)) {
   1171       1.22  christos 					if (dumped)
   1172       1.22  christos 					    (void)printf("\t(same route)");
   1173       1.22  christos 					j = ((i+3)/4)*4;
   1174       1.22  christos 					hlen -= j;
   1175       1.22  christos 					cp += j;
   1176       1.22  christos 					break;
   1177       1.22  christos 				}
   1178       1.22  christos 				old_rrlen = i;
   1179       1.30  christos 				(void) memcpy(old_rr, cp, i);
   1180       1.22  christos 			}
   1181       1.22  christos 			if (!dumped) {
   1182       1.22  christos 				jiggle_flush(1);
   1183       1.22  christos 				(void)printf("RR: ");
   1184       1.22  christos 				dumped = 1;
   1185       1.22  christos 			} else {
   1186       1.22  christos 				(void)printf("\nRR: ");
   1187        1.1       cgd 			}
   1188        1.1       cgd 			for (;;) {
   1189       1.57        is 				pr_saddr(cp);
   1190       1.22  christos 				cp += 4;
   1191        1.1       cgd 				hlen -= 4;
   1192        1.1       cgd 				i -= 4;
   1193        1.1       cgd 				if (i <= 0)
   1194        1.1       cgd 					break;
   1195        1.1       cgd 				(void)putchar('\n');
   1196        1.1       cgd 			}
   1197        1.1       cgd 			break;
   1198        1.1       cgd 		case IPOPT_NOP:
   1199       1.22  christos 			if (dumped <= 1)
   1200       1.22  christos 				break;
   1201       1.22  christos 			PR_PACK_SUB();
   1202        1.1       cgd 			(void)printf("\nNOP");
   1203        1.1       cgd 			break;
   1204       1.22  christos #ifdef sgi
   1205       1.22  christos 		case IPOPT_SECURITY:	/* RFC 1108 RIPSO BSO */
   1206       1.22  christos 		case IPOPT_ESO:		/* RFC 1108 RIPSO ESO */
   1207       1.22  christos 		case IPOPT_CIPSO:	/* Commercial IPSO */
   1208       1.22  christos 			if ((sysconf(_SC_IP_SECOPTS)) > 0) {
   1209       1.22  christos 				i = (unsigned)cp[1];
   1210       1.22  christos 				hlen -= i - 1;
   1211       1.22  christos 				PR_PACK_SUB();
   1212       1.22  christos 				(void)printf("\nSEC:");
   1213       1.22  christos 				while (i--) {
   1214       1.22  christos 					(void)printf(" %02x", *cp++);
   1215       1.22  christos 				}
   1216       1.22  christos 				cp--;
   1217       1.22  christos 				break;
   1218       1.22  christos 			}
   1219       1.22  christos #endif
   1220        1.1       cgd 		default:
   1221       1.22  christos 			PR_PACK_SUB();
   1222       1.32     lukem 			(void)printf("\nunknown option 0x%x", *cp);
   1223        1.1       cgd 			break;
   1224        1.1       cgd 		}
   1225       1.22  christos 		hlen--;
   1226       1.22  christos 		cp++;
   1227       1.22  christos 	}
   1228       1.22  christos 
   1229       1.22  christos 	if (dumped) {
   1230        1.1       cgd 		(void)putchar('\n');
   1231        1.1       cgd 		(void)fflush(stdout);
   1232       1.22  christos 	} else {
   1233       1.22  christos 		jiggle(-1);
   1234       1.22  christos 	}
   1235       1.22  christos }
   1236       1.22  christos 
   1237       1.22  christos 
   1238       1.22  christos /* Compute the IP checksum
   1239       1.22  christos  *	This assumes the packet is less than 32K long.
   1240       1.22  christos  */
   1241       1.65    itojun static u_int16_t
   1242       1.65    itojun in_cksum(u_int16_t *p, u_int len)
   1243       1.22  christos {
   1244       1.65    itojun 	u_int32_t sum = 0;
   1245       1.22  christos 	int nwords = len >> 1;
   1246       1.22  christos 
   1247       1.22  christos 	while (nwords-- != 0)
   1248       1.22  christos 		sum += *p++;
   1249       1.22  christos 
   1250       1.22  christos 	if (len & 1) {
   1251       1.22  christos 		union {
   1252       1.65    itojun 			u_int16_t w;
   1253       1.65    itojun 			u_int8_t c[2];
   1254       1.22  christos 		} u;
   1255       1.22  christos 		u.c[0] = *(u_char *)p;
   1256       1.22  christos 		u.c[1] = 0;
   1257       1.22  christos 		sum += u.w;
   1258        1.1       cgd 	}
   1259       1.22  christos 
   1260       1.22  christos 	/* end-around-carry */
   1261       1.22  christos 	sum = (sum >> 16) + (sum & 0xffff);
   1262       1.22  christos 	sum += (sum >> 16);
   1263       1.22  christos 	return (~sum);
   1264        1.1       cgd }
   1265        1.1       cgd 
   1266       1.22  christos 
   1267        1.1       cgd /*
   1268       1.99  christos  * compute the difference of two timespecs in seconds
   1269        1.1       cgd  */
   1270       1.22  christos static double
   1271       1.99  christos diffsec(struct timespec *timenow,
   1272       1.99  christos 	struct timespec *then)
   1273       1.22  christos {
   1274       1.97  christos 	if (timenow->tv_sec == 0)
   1275       1.97  christos 		return -1;
   1276       1.99  christos 	return (timenow->tv_sec - then->tv_sec)
   1277       1.99  christos 	    * 1.0 + (timenow->tv_nsec - then->tv_nsec) / 1000000000.0;
   1278       1.22  christos }
   1279       1.22  christos 
   1280       1.22  christos 
   1281       1.99  christos #if 0
   1282       1.22  christos static void
   1283       1.99  christos timespecadd(struct timespec *t1,
   1284       1.99  christos 	   struct timespec *t2)
   1285       1.22  christos {
   1286       1.22  christos 
   1287       1.22  christos 	t1->tv_sec += t2->tv_sec;
   1288       1.99  christos 	if ((t1->tv_nsec += t2->tv_nsec) >= 1000000000) {
   1289       1.22  christos 		t1->tv_sec++;
   1290       1.99  christos 		t1->tv_nsec -= 1000000000;
   1291       1.22  christos 	}
   1292       1.22  christos }
   1293       1.99  christos #endif
   1294       1.22  christos 
   1295       1.22  christos 
   1296       1.22  christos static void
   1297       1.99  christos sec_to_timespec(const double sec, struct timespec *tp)
   1298       1.22  christos {
   1299       1.30  christos 	tp->tv_sec = sec;
   1300       1.99  christos 	tp->tv_nsec = (sec - tp->tv_sec) * 1000000000.0;
   1301       1.22  christos }
   1302        1.1       cgd 
   1303       1.41  christos 
   1304       1.22  christos static double
   1305       1.99  christos timespec_to_sec(const struct timespec *tp)
   1306       1.22  christos {
   1307       1.99  christos 	return tp->tv_sec + tp->tv_nsec / 1000000000.0;
   1308        1.1       cgd }
   1309        1.1       cgd 
   1310       1.22  christos 
   1311        1.1       cgd /*
   1312       1.22  christos  * Print statistics.
   1313       1.22  christos  * Heavily buffered STDIO is used here, so that all the statistics
   1314       1.22  christos  * will be written with 1 sys-write call.  This is nice when more
   1315       1.22  christos  * than one copy of the program is running on a terminal;  it prevents
   1316       1.22  christos  * the statistics output from becomming intermingled.
   1317        1.1       cgd  */
   1318       1.22  christos static void
   1319       1.22  christos summary(int header)
   1320        1.1       cgd {
   1321       1.22  christos 	jiggle_flush(1);
   1322        1.8   mycroft 
   1323       1.22  christos 	if (header)
   1324       1.22  christos 		(void)printf("\n----%s PING Statistics----\n", hostname);
   1325       1.22  christos 	(void)printf("%d packets transmitted, ", ntransmitted);
   1326       1.22  christos 	(void)printf("%d packets received, ", nreceived);
   1327        1.1       cgd 	if (nrepeats)
   1328       1.22  christos 		(void)printf("+%d duplicates, ", nrepeats);
   1329       1.22  christos 	if (ntransmitted) {
   1330        1.1       cgd 		if (nreceived > ntransmitted)
   1331       1.64    itojun 			(void)printf("-- somebody's duplicating packets!");
   1332        1.1       cgd 		else
   1333       1.41  christos 			(void)printf("%.1f%% packet loss",
   1334       1.41  christos 				     (((ntransmitted-nreceived)*100.0) /
   1335       1.22  christos 					    ntransmitted));
   1336       1.22  christos 	}
   1337       1.22  christos 	(void)printf("\n");
   1338      1.101  christos 	if (nreceived && (pingflags & (F_TIMING|F_TIMING64))) {
   1339       1.44     jwise 		double n = nreceived + nrepeats;
   1340       1.44     jwise 		double avg = (tsum / n);
   1341       1.47  sommerfe 		double variance = 0.0;
   1342       1.47  sommerfe 		if (n>1)
   1343       1.47  sommerfe 			variance = (tsumsq - n*avg*avg) /(n-1);
   1344       1.44     jwise 
   1345       1.44     jwise 		printf("round-trip min/avg/max/stddev = "
   1346       1.44     jwise 			"%.3f/%.3f/%.3f/%.3f ms\n",
   1347       1.44     jwise 			tmin * 1000.0, avg * 1000.0,
   1348       1.45     jwise 			tmax * 1000.0, sqrt(variance) * 1000.0);
   1349       1.22  christos 		if (pingflags & F_FLOOD) {
   1350       1.22  christos 			double r = diffsec(&last_rx, &first_rx);
   1351       1.22  christos 			double t = diffsec(&last_tx, &first_tx);
   1352       1.22  christos 			if (r == 0)
   1353       1.22  christos 				r = 0.0001;
   1354       1.22  christos 			if (t == 0)
   1355       1.22  christos 				t = 0.0001;
   1356       1.22  christos 			(void)printf("  %.1f packets/sec sent, "
   1357       1.30  christos 				     " %.1f packets/sec received\n",
   1358       1.22  christos 				     ntransmitted/t, nreceived/r);
   1359       1.22  christos 		}
   1360        1.8   mycroft 	}
   1361       1.21       cgd }
   1362       1.21       cgd 
   1363       1.22  christos 
   1364       1.22  christos /*
   1365       1.22  christos  * Print statistics when SIGINFO is received.
   1366       1.22  christos  */
   1367       1.22  christos /* ARGSUSED */
   1368       1.22  christos static void
   1369       1.62     lukem prtsig(int dummy)
   1370       1.22  christos {
   1371       1.82      yamt 
   1372       1.22  christos 	summary(0);
   1373       1.81  christos #ifndef SIGINFO
   1374       1.22  christos 	(void)signal(SIGQUIT, prtsig);
   1375       1.22  christos #endif
   1376       1.22  christos }
   1377       1.22  christos 
   1378       1.22  christos 
   1379       1.21       cgd /*
   1380       1.22  christos  * On the first SIGINT, allow any outstanding packets to dribble in
   1381       1.21       cgd  */
   1382       1.22  christos static void
   1383       1.62     lukem prefinish(int dummy)
   1384       1.21       cgd {
   1385       1.22  christos 	if (lastrcvd			/* quit now if caught up */
   1386       1.22  christos 	    || nreceived == 0)		/* or if remote is dead */
   1387       1.22  christos 		finish(0);
   1388       1.22  christos 
   1389       1.62     lukem 	(void)signal(dummy, finish);	/* do this only the 1st time */
   1390       1.21       cgd 
   1391       1.22  christos 	if (npackets > ntransmitted)	/* let the normal limit work */
   1392       1.22  christos 		npackets = ntransmitted;
   1393       1.21       cgd }
   1394       1.21       cgd 
   1395       1.21       cgd /*
   1396       1.22  christos  * Print statistics and give up.
   1397       1.21       cgd  */
   1398       1.22  christos /* ARGSUSED */
   1399       1.22  christos static void
   1400       1.62     lukem finish(int dummy)
   1401       1.21       cgd {
   1402       1.81  christos #ifdef SIGINFO
   1403       1.81  christos 	(void)signal(SIGINFO, SIG_DFL);
   1404       1.22  christos #else
   1405       1.22  christos 	(void)signal(SIGQUIT, SIG_DFL);
   1406       1.22  christos #endif
   1407       1.22  christos 
   1408       1.22  christos 	summary(1);
   1409       1.30  christos 	exit(nreceived > 0 ? 0 : 2);
   1410       1.22  christos }
   1411       1.22  christos 
   1412       1.22  christos 
   1413       1.22  christos static int				/* 0=do not print it */
   1414       1.30  christos ck_pr_icmph(struct icmp *icp,
   1415       1.30  christos 	    struct sockaddr_in *from,
   1416       1.30  christos 	    int cc,
   1417       1.22  christos 	    int override)		/* 1=override VERBOSE if interesting */
   1418       1.22  christos {
   1419       1.22  christos 	int	hlen;
   1420       1.41  christos 	struct ip ipb, *ip = &ipb;
   1421       1.41  christos 	struct icmp icp2b, *icp2 = &icp2b;
   1422       1.22  christos 	int res;
   1423       1.21       cgd 
   1424       1.22  christos 	if (pingflags & F_VERBOSE) {
   1425       1.22  christos 		res = 1;
   1426       1.22  christos 		jiggle_flush(1);
   1427       1.22  christos 	} else {
   1428       1.22  christos 		res = 0;
   1429       1.22  christos 	}
   1430       1.21       cgd 
   1431       1.41  christos 	(void) memcpy(ip, icp->icmp_data, sizeof(*ip));
   1432       1.41  christos 	hlen = ip->ip_hl << 2;
   1433       1.41  christos 	if (ip->ip_p == IPPROTO_ICMP
   1434       1.22  christos 	    && hlen + 6 <= cc) {
   1435       1.41  christos 		(void) memcpy(icp2, &icp->icmp_data[hlen], sizeof(*icp2));
   1436       1.41  christos 		if (icp2->icmp_id == ident) {
   1437       1.22  christos 			/* remember to clear route cached in kernel
   1438       1.41  christos 			 * if this non-Echo-Reply ICMP message was for one
   1439       1.41  christos 			 * of our packets.
   1440       1.22  christos 			 */
   1441       1.22  christos 			clear_cache.tv_sec = 0;
   1442       1.22  christos 
   1443       1.22  christos 			if (!res && override
   1444       1.22  christos 			    && (pingflags & (F_QUIET|F_SEMI_QUIET)) == 0) {
   1445       1.22  christos 				jiggle_flush(1);
   1446       1.30  christos 				(void)printf("%d bytes from %s: ",
   1447       1.22  christos 					     cc, pr_addr(&from->sin_addr));
   1448       1.22  christos 				res = 1;
   1449       1.22  christos 			}
   1450       1.22  christos 		}
   1451       1.22  christos 	}
   1452       1.22  christos 
   1453       1.22  christos 	return res;
   1454        1.1       cgd }
   1455        1.1       cgd 
   1456        1.1       cgd 
   1457        1.1       cgd /*
   1458       1.22  christos  *  Print a descriptive string about an ICMP header other than an echo reply.
   1459        1.1       cgd  */
   1460       1.22  christos static int				/* 0=printed nothing */
   1461       1.30  christos pr_icmph(struct icmp *icp,
   1462       1.30  christos 	 struct sockaddr_in *from,
   1463       1.22  christos 	 int cc)
   1464        1.1       cgd {
   1465       1.22  christos 	switch (icp->icmp_type ) {
   1466        1.1       cgd 	case ICMP_UNREACH:
   1467       1.22  christos 		if (!ck_pr_icmph(icp, from, cc, 1))
   1468       1.22  christos 			return 0;
   1469       1.22  christos 		switch (icp->icmp_code) {
   1470        1.1       cgd 		case ICMP_UNREACH_NET:
   1471       1.22  christos 			(void)printf("Destination Net Unreachable");
   1472        1.1       cgd 			break;
   1473        1.1       cgd 		case ICMP_UNREACH_HOST:
   1474       1.22  christos 			(void)printf("Destination Host Unreachable");
   1475        1.1       cgd 			break;
   1476        1.1       cgd 		case ICMP_UNREACH_PROTOCOL:
   1477       1.22  christos 			(void)printf("Destination Protocol Unreachable");
   1478        1.1       cgd 			break;
   1479        1.1       cgd 		case ICMP_UNREACH_PORT:
   1480       1.22  christos 			(void)printf("Destination Port Unreachable");
   1481        1.1       cgd 			break;
   1482        1.1       cgd 		case ICMP_UNREACH_NEEDFRAG:
   1483       1.30  christos 			(void)printf("frag needed and DF set.  Next MTU=%d",
   1484       1.36    kleink 			       ntohs(icp->icmp_nextmtu));
   1485        1.1       cgd 			break;
   1486        1.1       cgd 		case ICMP_UNREACH_SRCFAIL:
   1487       1.22  christos 			(void)printf("Source Route Failed");
   1488       1.22  christos 			break;
   1489       1.22  christos 		case ICMP_UNREACH_NET_UNKNOWN:
   1490       1.22  christos 			(void)printf("Unreachable unknown net");
   1491       1.22  christos 			break;
   1492       1.22  christos 		case ICMP_UNREACH_HOST_UNKNOWN:
   1493       1.22  christos 			(void)printf("Unreachable unknown host");
   1494       1.22  christos 			break;
   1495       1.22  christos 		case ICMP_UNREACH_ISOLATED:
   1496       1.22  christos 			(void)printf("Unreachable host isolated");
   1497       1.22  christos 			break;
   1498       1.22  christos 		case ICMP_UNREACH_NET_PROHIB:
   1499       1.22  christos 			(void)printf("Net prohibited access");
   1500       1.22  christos 			break;
   1501       1.22  christos 		case ICMP_UNREACH_HOST_PROHIB:
   1502       1.22  christos 			(void)printf("Host prohibited access");
   1503       1.22  christos 			break;
   1504       1.22  christos 		case ICMP_UNREACH_TOSNET:
   1505       1.22  christos 			(void)printf("Bad TOS for net");
   1506       1.22  christos 			break;
   1507       1.22  christos 		case ICMP_UNREACH_TOSHOST:
   1508       1.22  christos 			(void)printf("Bad TOS for host");
   1509       1.22  christos 			break;
   1510       1.22  christos 		case 13:
   1511       1.22  christos 			(void)printf("Communication prohibited");
   1512       1.22  christos 			break;
   1513       1.22  christos 		case 14:
   1514       1.22  christos 			(void)printf("Host precedence violation");
   1515       1.22  christos 			break;
   1516       1.22  christos 		case 15:
   1517       1.22  christos 			(void)printf("Precedence cutoff");
   1518        1.1       cgd 			break;
   1519        1.1       cgd 		default:
   1520       1.30  christos 			(void)printf("Bad Destination Unreachable Code: %d",
   1521       1.22  christos 				     icp->icmp_code);
   1522        1.1       cgd 			break;
   1523        1.1       cgd 		}
   1524        1.1       cgd 		/* Print returned IP header information */
   1525       1.22  christos 		pr_retip(icp, cc);
   1526        1.1       cgd 		break;
   1527       1.22  christos 
   1528        1.1       cgd 	case ICMP_SOURCEQUENCH:
   1529       1.22  christos 		if (!ck_pr_icmph(icp, from, cc, 1))
   1530       1.22  christos 			return 0;
   1531       1.22  christos 		(void)printf("Source Quench");
   1532       1.22  christos 		pr_retip(icp, cc);
   1533        1.1       cgd 		break;
   1534       1.22  christos 
   1535        1.1       cgd 	case ICMP_REDIRECT:
   1536       1.22  christos 		if (!ck_pr_icmph(icp, from, cc, 1))
   1537       1.22  christos 			return 0;
   1538       1.22  christos 		switch (icp->icmp_code) {
   1539        1.1       cgd 		case ICMP_REDIRECT_NET:
   1540       1.41  christos 			(void)printf("Redirect Network");
   1541        1.1       cgd 			break;
   1542        1.1       cgd 		case ICMP_REDIRECT_HOST:
   1543       1.41  christos 			(void)printf("Redirect Host");
   1544        1.1       cgd 			break;
   1545        1.1       cgd 		case ICMP_REDIRECT_TOSNET:
   1546       1.41  christos 			(void)printf("Redirect Type of Service and Network");
   1547        1.1       cgd 			break;
   1548        1.1       cgd 		case ICMP_REDIRECT_TOSHOST:
   1549       1.41  christos 			(void)printf("Redirect Type of Service and Host");
   1550        1.1       cgd 			break;
   1551        1.1       cgd 		default:
   1552       1.41  christos 			(void)printf("Redirect--Bad Code: %d", icp->icmp_code);
   1553        1.1       cgd 			break;
   1554        1.1       cgd 		}
   1555       1.41  christos 		(void)printf(" New router addr: %s",
   1556       1.22  christos 			     pr_addr(&icp->icmp_hun.ih_gwaddr));
   1557       1.22  christos 		pr_retip(icp, cc);
   1558       1.22  christos 		break;
   1559       1.22  christos 
   1560       1.22  christos 	case ICMP_ECHO:
   1561       1.22  christos 		if (!ck_pr_icmph(icp, from, cc, 0))
   1562       1.22  christos 			return 0;
   1563       1.30  christos 		(void)printf("Echo Request: ID=%d seq=%d",
   1564       1.41  christos 			     ntohs(icp->icmp_id), ntohs(icp->icmp_seq));
   1565       1.22  christos 		break;
   1566       1.22  christos 
   1567       1.22  christos 	case ICMP_ECHOREPLY:
   1568       1.22  christos 		/* displaying other's pings is too noisey */
   1569       1.22  christos #if 0
   1570       1.22  christos 		if (!ck_pr_icmph(icp, from, cc, 0))
   1571       1.22  christos 			return 0;
   1572       1.30  christos 		(void)printf("Echo Reply: ID=%d seq=%d",
   1573       1.41  christos 			     ntohs(icp->icmp_id), ntohs(icp->icmp_seq));
   1574       1.22  christos 		break;
   1575        1.1       cgd #else
   1576       1.22  christos 		return 0;
   1577        1.1       cgd #endif
   1578       1.22  christos 
   1579       1.22  christos 	case ICMP_ROUTERADVERT:
   1580       1.22  christos 		if (!ck_pr_icmph(icp, from, cc, 0))
   1581       1.22  christos 			return 0;
   1582       1.22  christos 		(void)printf("Router Discovery Advert");
   1583        1.1       cgd 		break;
   1584       1.22  christos 
   1585       1.22  christos 	case ICMP_ROUTERSOLICIT:
   1586       1.22  christos 		if (!ck_pr_icmph(icp, from, cc, 0))
   1587       1.22  christos 			return 0;
   1588       1.22  christos 		(void)printf("Router Discovery Solicit");
   1589        1.1       cgd 		break;
   1590       1.22  christos 
   1591        1.1       cgd 	case ICMP_TIMXCEED:
   1592       1.22  christos 		if (!ck_pr_icmph(icp, from, cc, 1))
   1593       1.22  christos 			return 0;
   1594       1.22  christos 		switch (icp->icmp_code ) {
   1595        1.1       cgd 		case ICMP_TIMXCEED_INTRANS:
   1596       1.22  christos 			(void)printf("Time To Live exceeded");
   1597        1.1       cgd 			break;
   1598        1.1       cgd 		case ICMP_TIMXCEED_REASS:
   1599       1.22  christos 			(void)printf("Frag reassembly time exceeded");
   1600        1.1       cgd 			break;
   1601        1.1       cgd 		default:
   1602       1.30  christos 			(void)printf("Time exceeded, Bad Code: %d",
   1603       1.22  christos 				     icp->icmp_code);
   1604        1.1       cgd 			break;
   1605        1.1       cgd 		}
   1606       1.22  christos 		pr_retip(icp, cc);
   1607        1.1       cgd 		break;
   1608       1.22  christos 
   1609        1.1       cgd 	case ICMP_PARAMPROB:
   1610       1.22  christos 		if (!ck_pr_icmph(icp, from, cc, 1))
   1611       1.22  christos 			return 0;
   1612       1.30  christos 		(void)printf("Parameter problem: pointer = 0x%02x",
   1613       1.22  christos 			     icp->icmp_hun.ih_pptr);
   1614       1.22  christos 		pr_retip(icp, cc);
   1615        1.1       cgd 		break;
   1616       1.22  christos 
   1617        1.1       cgd 	case ICMP_TSTAMP:
   1618       1.22  christos 		if (!ck_pr_icmph(icp, from, cc, 0))
   1619       1.22  christos 			return 0;
   1620       1.22  christos 		(void)printf("Timestamp");
   1621        1.1       cgd 		break;
   1622       1.22  christos 
   1623        1.1       cgd 	case ICMP_TSTAMPREPLY:
   1624       1.22  christos 		if (!ck_pr_icmph(icp, from, cc, 0))
   1625       1.22  christos 			return 0;
   1626       1.22  christos 		(void)printf("Timestamp Reply");
   1627        1.1       cgd 		break;
   1628       1.22  christos 
   1629        1.1       cgd 	case ICMP_IREQ:
   1630       1.22  christos 		if (!ck_pr_icmph(icp, from, cc, 0))
   1631       1.22  christos 			return 0;
   1632       1.22  christos 		(void)printf("Information Request");
   1633        1.1       cgd 		break;
   1634       1.22  christos 
   1635        1.1       cgd 	case ICMP_IREQREPLY:
   1636       1.22  christos 		if (!ck_pr_icmph(icp, from, cc, 0))
   1637       1.22  christos 			return 0;
   1638       1.22  christos 		(void)printf("Information Reply");
   1639        1.1       cgd 		break;
   1640       1.22  christos 
   1641        1.1       cgd 	case ICMP_MASKREQ:
   1642       1.22  christos 		if (!ck_pr_icmph(icp, from, cc, 0))
   1643       1.22  christos 			return 0;
   1644       1.22  christos 		(void)printf("Address Mask Request");
   1645        1.1       cgd 		break;
   1646       1.22  christos 
   1647        1.1       cgd 	case ICMP_MASKREPLY:
   1648       1.22  christos 		if (!ck_pr_icmph(icp, from, cc, 0))
   1649       1.22  christos 			return 0;
   1650       1.22  christos 		(void)printf("Address Mask Reply");
   1651        1.1       cgd 		break;
   1652       1.22  christos 
   1653        1.1       cgd 	default:
   1654       1.22  christos 		if (!ck_pr_icmph(icp, from, cc, 0))
   1655       1.22  christos 			return 0;
   1656       1.22  christos 		(void)printf("Bad ICMP type: %d", icp->icmp_type);
   1657       1.22  christos 		if (pingflags & F_VERBOSE)
   1658       1.22  christos 			pr_iph(icp, cc);
   1659        1.1       cgd 	}
   1660       1.22  christos 
   1661       1.22  christos 	return 1;
   1662        1.1       cgd }
   1663        1.1       cgd 
   1664       1.22  christos 
   1665        1.1       cgd /*
   1666       1.22  christos  *  Print an IP header with options.
   1667        1.1       cgd  */
   1668       1.22  christos static void
   1669       1.30  christos pr_iph(struct icmp *icp,
   1670       1.22  christos        int cc)
   1671        1.1       cgd {
   1672       1.22  christos 	int	hlen;
   1673       1.22  christos 	u_char	*cp;
   1674       1.41  christos 	struct ip ipb, *ip = &ipb;
   1675       1.26  christos 
   1676       1.41  christos 	(void) memcpy(ip, icp->icmp_data, sizeof(*ip));
   1677        1.1       cgd 
   1678       1.41  christos 	hlen = ip->ip_hl << 2;
   1679       1.30  christos 	cp = (u_char *) &icp->icmp_data[20];	/* point to options */
   1680        1.1       cgd 
   1681       1.22  christos 	(void)printf("\n Vr HL TOS  Len   ID Flg  off TTL Pro  cks      Src	     Dst\n");
   1682       1.30  christos 	(void)printf("  %1x  %1x  %02x %04x %04x",
   1683       1.41  christos 		     ip->ip_v, ip->ip_hl, ip->ip_tos, ip->ip_len, ip->ip_id);
   1684       1.30  christos 	(void)printf("   %1x %04x",
   1685       1.41  christos 		     ((ip->ip_off)&0xe000)>>13, (ip->ip_off)&0x1fff);
   1686       1.30  christos 	(void)printf("  %02x  %02x %04x",
   1687       1.41  christos 		     ip->ip_ttl, ip->ip_p, ip->ip_sum);
   1688       1.30  christos 	(void)printf(" %15s ",
   1689       1.41  christos 		     inet_ntoa(*(struct in_addr *)&ip->ip_src.s_addr));
   1690       1.41  christos 	(void)printf(" %s ", inet_ntoa(*(struct in_addr *)&ip->ip_dst.s_addr));
   1691       1.22  christos 	/* dump any option bytes */
   1692       1.22  christos 	while (hlen-- > 20 && cp < (u_char*)icp+cc) {
   1693        1.1       cgd 		(void)printf("%02x", *cp++);
   1694        1.1       cgd 	}
   1695        1.1       cgd }
   1696        1.1       cgd 
   1697        1.1       cgd /*
   1698       1.22  christos  * Print an ASCII host address starting from a string of bytes.
   1699        1.1       cgd  */
   1700       1.22  christos static void
   1701       1.57        is pr_saddr(u_char *cp)
   1702       1.22  christos {
   1703       1.32     lukem 	n_long l;
   1704       1.22  christos 	struct in_addr addr;
   1705       1.22  christos 
   1706       1.22  christos 	l = (u_char)*++cp;
   1707       1.22  christos 	l = (l<<8) + (u_char)*++cp;
   1708       1.22  christos 	l = (l<<8) + (u_char)*++cp;
   1709       1.22  christos 	l = (l<<8) + (u_char)*++cp;
   1710       1.22  christos 	addr.s_addr = htonl(l);
   1711       1.57        is 	(void)printf("\t%s", (l == 0) ? "0.0.0.0" : pr_addr(&addr));
   1712       1.22  christos }
   1713       1.22  christos 
   1714       1.22  christos 
   1715       1.22  christos /*
   1716       1.22  christos  *  Return an ASCII host address
   1717       1.22  christos  *  as a dotted quad and optionally with a hostname
   1718       1.22  christos  */
   1719       1.22  christos static char *
   1720       1.22  christos pr_addr(struct in_addr *addr)		/* in network order */
   1721       1.22  christos {
   1722       1.22  christos 	struct	hostent	*hp;
   1723       1.22  christos 	static	char buf[MAXHOSTNAMELEN+4+16+1];
   1724       1.22  christos 
   1725       1.22  christos 	if ((pingflags & F_NUMERIC)
   1726       1.22  christos 	    || !(hp = gethostbyaddr((char *)addr, sizeof(*addr), AF_INET))) {
   1727       1.37   mycroft 		(void)snprintf(buf, sizeof(buf), "%s", inet_ntoa(*addr));
   1728       1.22  christos 	} else {
   1729       1.37   mycroft 		(void)snprintf(buf, sizeof(buf), "%s (%s)", hp->h_name,
   1730       1.37   mycroft 		    inet_ntoa(*addr));
   1731       1.22  christos 	}
   1732       1.22  christos 
   1733       1.22  christos 	return buf;
   1734        1.1       cgd }
   1735        1.1       cgd 
   1736        1.1       cgd /*
   1737       1.22  christos  *  Dump some info on a returned (via ICMP) IP packet.
   1738        1.1       cgd  */
   1739       1.22  christos static void
   1740       1.30  christos pr_retip(struct icmp *icp,
   1741       1.22  christos 	 int cc)
   1742        1.1       cgd {
   1743       1.22  christos 	int	hlen;
   1744       1.30  christos 	u_char	*cp;
   1745       1.41  christos 	struct ip ipb, *ip = &ipb;
   1746       1.26  christos 
   1747       1.41  christos 	(void) memcpy(ip, icp->icmp_data, sizeof(*ip));
   1748       1.22  christos 
   1749       1.22  christos 	if (pingflags & F_VERBOSE)
   1750       1.22  christos 		pr_iph(icp, cc);
   1751        1.1       cgd 
   1752       1.41  christos 	hlen = ip->ip_hl << 2;
   1753       1.30  christos 	cp = (u_char *) &icp->icmp_data[hlen];
   1754        1.1       cgd 
   1755       1.41  christos 	if (ip->ip_p == IPPROTO_TCP) {
   1756       1.22  christos 		if (pingflags & F_VERBOSE)
   1757       1.30  christos 			(void)printf("\n  TCP: from port %u, to port %u",
   1758       1.22  christos 				     (*cp*256+*(cp+1)), (*(cp+2)*256+*(cp+3)));
   1759       1.41  christos 	} else if (ip->ip_p == IPPROTO_UDP) {
   1760       1.22  christos 		if (pingflags & F_VERBOSE)
   1761       1.30  christos 			(void)printf("\n  UDP: from port %u, to port %u",
   1762       1.22  christos 				     (*cp*256+*(cp+1)), (*(cp+2)*256+*(cp+3)));
   1763       1.41  christos 	} else if (ip->ip_p == IPPROTO_ICMP) {
   1764       1.26  christos 		struct icmp icp2;
   1765       1.26  christos 		(void) memcpy(&icp2, cp, sizeof(icp2));
   1766       1.26  christos 		if (icp2.icmp_type == ICMP_ECHO) {
   1767       1.26  christos 			if (pingflags & F_VERBOSE)
   1768       1.30  christos 				(void)printf("\n  ID=%u icmp_seq=%u",
   1769       1.65    itojun 					     ntohs((u_int16_t)icp2.icmp_id),
   1770       1.65    itojun 					     ntohs((u_int16_t)icp2.icmp_seq));
   1771       1.26  christos 			else
   1772       1.30  christos 				(void)printf(" for icmp_seq=%u",
   1773       1.65    itojun 					     ntohs((u_int16_t)icp2.icmp_seq));
   1774       1.26  christos 		}
   1775       1.22  christos 	}
   1776        1.1       cgd }
   1777        1.1       cgd 
   1778       1.22  christos static void
   1779       1.22  christos fill(void)
   1780        1.1       cgd {
   1781       1.32     lukem 	int i, j, k;
   1782       1.22  christos 	char *cp;
   1783        1.1       cgd 	int pat[16];
   1784        1.1       cgd 
   1785       1.22  christos 	for (cp = fill_pat; *cp != '\0'; cp++) {
   1786       1.43  christos 		if (!isxdigit((unsigned char)*cp))
   1787       1.22  christos 			break;
   1788       1.22  christos 	}
   1789       1.22  christos 	if (cp == fill_pat || *cp != '\0' || (cp-fill_pat) > 16*2) {
   1790       1.22  christos 		(void)fflush(stdout);
   1791       1.30  christos 		errx(1, "\"-p %s\": patterns must be specified with"
   1792       1.30  christos 		     " 1-32 hex digits\n",
   1793       1.30  christos 		     fill_pat);
   1794       1.22  christos 	}
   1795       1.22  christos 
   1796       1.30  christos 	i = sscanf(fill_pat,
   1797       1.30  christos 		   "%2x%2x%2x%2x%2x%2x%2x%2x%2x%2x%2x%2x%2x%2x%2x%2x",
   1798       1.30  christos 		    &pat[0], &pat[1], &pat[2], &pat[3],
   1799       1.30  christos 		    &pat[4], &pat[5], &pat[6], &pat[7],
   1800       1.30  christos 		    &pat[8], &pat[9], &pat[10], &pat[11],
   1801       1.22  christos 		    &pat[12], &pat[13], &pat[14], &pat[15]);
   1802       1.22  christos 
   1803       1.99  christos 	for (k = phdrlen, j = 0; k <= datalen; k++) {
   1804       1.22  christos 		opack_icmp.icmp_data[k] = pat[j];
   1805       1.22  christos 		if (++j >= i)
   1806       1.22  christos 			j = 0;
   1807       1.22  christos 	}
   1808       1.22  christos 
   1809       1.22  christos 	if (!(pingflags & F_QUIET)) {
   1810        1.1       cgd 		(void)printf("PATTERN: 0x");
   1811       1.22  christos 		for (j=0; j<i; j++)
   1812       1.30  christos 			(void)printf("%02x",
   1813       1.99  christos 				     (u_char)opack_icmp.icmp_data[phdrlen + j]);
   1814        1.1       cgd 		(void)printf("\n");
   1815        1.1       cgd 	}
   1816       1.22  christos 
   1817        1.1       cgd }
   1818        1.1       cgd 
   1819       1.22  christos 
   1820       1.22  christos static void
   1821       1.22  christos rnd_fill(void)
   1822       1.22  christos {
   1823       1.41  christos 	static u_int32_t rnd;
   1824       1.22  christos 	int i;
   1825       1.22  christos 
   1826       1.99  christos 	for (i = phdrlen; i < datalen; i++) {
   1827       1.41  christos 		rnd = (3141592621U * rnd + 663896637U);
   1828       1.41  christos 		opack_icmp.icmp_data[i] = rnd>>24;
   1829       1.22  christos 	}
   1830       1.22  christos }
   1831       1.22  christos 
   1832       1.41  christos 
   1833       1.22  christos static void
   1834       1.30  christos gethost(const char *arg,
   1835       1.30  christos 	const char *name,
   1836       1.30  christos 	struct sockaddr_in *sa,
   1837       1.30  christos 	char *realname,
   1838       1.30  christos 	int realname_len)
   1839       1.22  christos {
   1840       1.30  christos 	struct hostent *hp;
   1841       1.22  christos 
   1842       1.33       cgd 	(void)memset(sa, 0, sizeof(*sa));
   1843       1.30  christos 	sa->sin_family = AF_INET;
   1844       1.69    itojun 	sa->sin_len = sizeof(struct sockaddr_in);
   1845       1.22  christos 
   1846       1.30  christos 	/* If it is an IP address, try to convert it to a name to
   1847       1.30  christos 	 * have something nice to display.
   1848       1.30  christos 	 */
   1849       1.30  christos 	if (inet_aton(name, &sa->sin_addr) != 0) {
   1850       1.30  christos 		if (realname) {
   1851       1.30  christos 			if (pingflags & F_NUMERIC)
   1852       1.30  christos 				hp = 0;
   1853       1.30  christos 			else
   1854       1.30  christos 				hp = gethostbyaddr((char *)&sa->sin_addr,
   1855       1.30  christos 						   sizeof(sa->sin_addr),
   1856       1.30  christos 						   AF_INET);
   1857       1.69    itojun 			(void)strlcpy(realname, hp ? hp->h_name : name,
   1858       1.69    itojun 			    realname_len);
   1859       1.30  christos 		}
   1860       1.22  christos 		return;
   1861       1.30  christos 	}
   1862       1.30  christos 
   1863       1.30  christos 	hp = gethostbyname(name);
   1864       1.30  christos 	if (!hp)
   1865       1.30  christos 		errx(1, "Cannot resolve \"%s\" (%s)",name,hstrerror(h_errno));
   1866       1.30  christos 
   1867       1.30  christos 	if (hp->h_addrtype != AF_INET)
   1868       1.30  christos 		errx(1, "%s only supported with IP", arg);
   1869       1.30  christos 
   1870       1.41  christos 	(void)memcpy(&sa->sin_addr, hp->h_addr, sizeof(sa->sin_addr));
   1871       1.30  christos 
   1872       1.69    itojun 	if (realname)
   1873       1.69    itojun 		(void)strlcpy(realname, hp->h_name, realname_len);
   1874       1.22  christos }
   1875       1.22  christos 
   1876       1.22  christos 
   1877       1.22  christos static void
   1878       1.22  christos usage(void)
   1879        1.1       cgd {
   1880       1.50    itojun #ifdef IPSEC
   1881       1.50    itojun #ifdef IPSEC_POLICY_IPSEC
   1882       1.50    itojun #define IPSECOPT	"\n     [-E policy] "
   1883       1.50    itojun #else
   1884       1.50    itojun #define IPSECOPT	"\n     [-AE] "
   1885       1.50    itojun #endif /*IPSEC_POLICY_IPSEC*/
   1886       1.50    itojun #else
   1887       1.50    itojun #define IPSECOPT	""
   1888       1.50    itojun #endif /*IPSEC*/
   1889       1.42     enami 
   1890       1.74      jmmv 	(void)fprintf(stderr, "usage: \n"
   1891      1.100       wiz 	    "%s [-aCDdfLnoPQqRrv] [-c count] [-g gateway] [-h host]"
   1892      1.100       wiz 	    " [-I addr] [-i interval]\n"
   1893      1.100       wiz 	    "     [-l preload] [-p pattern] [-s size] [-T ttl] [-t tos]"
   1894       1.50    itojun 	    " [-w maxwait] " IPSECOPT "host\n",
   1895       1.59       cgd 	    getprogname());
   1896        1.1       cgd 	exit(1);
   1897        1.1       cgd }
   1898