Home | History | Annotate | Line # | Download | only in ping
ping.c revision 1.103
      1  1.103   msaitoh /*	$NetBSD: ping.c,v 1.103 2012/09/18 04:07:44 msaitoh 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.103   msaitoh __RCSID("$NetBSD: ping.c,v 1.103 2012/09/18 04:07:44 msaitoh 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.103   msaitoh #define F_POLICY	0x20000
    120   1.50    itojun #else
    121  1.103   msaitoh #define	F_AUTHHDR	0x20000
    122  1.103   msaitoh #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