Home | History | Annotate | Line # | Download | only in rtquery
rtquery.c revision 1.4
      1  1.4  christos /*	$NetBSD: rtquery.c,v 1.4 1997/02/03 22:03:20 christos Exp $	*/
      2  1.2   thorpej 
      3  1.1   thorpej /*-
      4  1.1   thorpej  * Copyright (c) 1982, 1986, 1993
      5  1.1   thorpej  *	The Regents of the University of California.  All rights reserved.
      6  1.1   thorpej  *
      7  1.1   thorpej  * Redistribution and use in source and binary forms, with or without
      8  1.1   thorpej  * modification, are permitted provided that the following conditions
      9  1.1   thorpej  * are met:
     10  1.1   thorpej  * 1. Redistributions of source code must retain the above copyright
     11  1.1   thorpej  *    notice, this list of conditions and the following disclaimer.
     12  1.1   thorpej  * 2. Redistributions in binary form must reproduce the above copyright
     13  1.1   thorpej  *    notice, this list of conditions and the following disclaimer in the
     14  1.1   thorpej  *    documentation and/or other materials provided with the distribution.
     15  1.1   thorpej  * 3. All advertising materials mentioning features or use of this software
     16  1.1   thorpej  *    must display the following acknowledgement:
     17  1.1   thorpej  *	This product includes software developed by the University of
     18  1.1   thorpej  *	California, Berkeley and its contributors.
     19  1.1   thorpej  * 4. Neither the name of the University nor the names of its contributors
     20  1.1   thorpej  *    may be used to endorse or promote products derived from this software
     21  1.1   thorpej  *    without specific prior written permission.
     22  1.1   thorpej  *
     23  1.1   thorpej  * THIS SOFTWARE IS PROVIDED BY THE REGENTS AND CONTRIBUTORS ``AS IS'' AND
     24  1.1   thorpej  * ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
     25  1.1   thorpej  * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE
     26  1.1   thorpej  * ARE DISCLAIMED.  IN NO EVENT SHALL THE REGENTS OR CONTRIBUTORS BE LIABLE
     27  1.1   thorpej  * FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL
     28  1.1   thorpej  * DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS
     29  1.1   thorpej  * OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION)
     30  1.1   thorpej  * HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT
     31  1.1   thorpej  * LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY
     32  1.1   thorpej  * OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF
     33  1.1   thorpej  * SUCH DAMAGE.
     34  1.1   thorpej  */
     35  1.1   thorpej 
     36  1.1   thorpej char copyright[] =
     37  1.1   thorpej "@(#) Copyright (c) 1982, 1986, 1993\n\
     38  1.1   thorpej 	The Regents of the University of California.  All rights reserved.\n";
     39  1.1   thorpej 
     40  1.3  christos #if !defined(lint) && !defined(sgi) && !defined(__NetBSD__)
     41  1.1   thorpej static char sccsid[] = "@(#)query.c	8.1 (Berkeley) 6/5/93";
     42  1.3  christos #elif defined(__NetBSD__)
     43  1.4  christos static char rcsid[] = "$NetBSD: rtquery.c,v 1.4 1997/02/03 22:03:20 christos Exp $";
     44  1.2   thorpej #endif
     45  1.1   thorpej 
     46  1.1   thorpej #include <sys/param.h>
     47  1.1   thorpej #include <sys/protosw.h>
     48  1.1   thorpej #include <sys/socket.h>
     49  1.1   thorpej #include <sys/time.h>
     50  1.1   thorpej #include <netinet/in.h>
     51  1.1   thorpej #define RIPVERSION RIPv2
     52  1.1   thorpej #include <protocols/routed.h>
     53  1.1   thorpej #include <arpa/inet.h>
     54  1.1   thorpej #include <netdb.h>
     55  1.1   thorpej #include <errno.h>
     56  1.1   thorpej #include <unistd.h>
     57  1.1   thorpej #include <stdio.h>
     58  1.1   thorpej #include <stdlib.h>
     59  1.1   thorpej #include <string.h>
     60  1.1   thorpej #ifdef sgi
     61  1.1   thorpej #include <strings.h>
     62  1.1   thorpej #include <bstring.h>
     63  1.1   thorpej #endif
     64  1.1   thorpej 
     65  1.1   thorpej #ifndef sgi
     66  1.1   thorpej #define _HAVE_SIN_LEN
     67  1.1   thorpej #endif
     68  1.1   thorpej 
     69  1.4  christos #define MD5_DIGEST_LEN 16
     70  1.4  christos typedef struct {
     71  1.4  christos 	u_int32_t state[4];		/* state (ABCD) */
     72  1.4  christos 	u_int32_t count[2];		/* # of bits, modulo 2^64 (LSB 1st) */
     73  1.4  christos 	unsigned char buffer[64];	/* input buffer */
     74  1.4  christos } MD5_CTX;
     75  1.4  christos extern void MD5Init(MD5_CTX*);
     76  1.4  christos extern void MD5Update(MD5_CTX*, u_char*, u_int);
     77  1.4  christos extern void MD5Final(u_char[MD5_DIGEST_LEN], MD5_CTX*);
     78  1.4  christos 
     79  1.4  christos 
     80  1.1   thorpej #define	WTIME	15		/* Time to wait for all responses */
     81  1.1   thorpej #define	STIME	(250*1000)	/* usec to wait for another response */
     82  1.1   thorpej 
     83  1.1   thorpej int	s;
     84  1.1   thorpej 
     85  1.1   thorpej char	*pgmname;
     86  1.1   thorpej 
     87  1.1   thorpej union {
     88  1.1   thorpej 	struct rip rip;
     89  1.1   thorpej 	char	packet[MAXPACKETSIZE+MAXPATHLEN];
     90  1.1   thorpej } omsg_buf;
     91  1.1   thorpej #define OMSG omsg_buf.rip
     92  1.1   thorpej int omsg_len = sizeof(struct rip);
     93  1.1   thorpej 
     94  1.1   thorpej union {
     95  1.1   thorpej 	struct	rip rip;
     96  1.1   thorpej 	char	packet[MAXPACKETSIZE+1024];
     97  1.1   thorpej 	} imsg_buf;
     98  1.1   thorpej #define IMSG imsg_buf.rip
     99  1.1   thorpej 
    100  1.1   thorpej int	nflag;				/* numbers, no names */
    101  1.1   thorpej int	pflag;				/* play the `gated` game */
    102  1.1   thorpej int	ripv2 = 1;			/* use RIP version 2 */
    103  1.1   thorpej int	wtime = WTIME;
    104  1.1   thorpej int	rflag;				/* 1=ask about a particular route */
    105  1.4  christos int	trace, not_trace;		/* send trace command or not */
    106  1.4  christos int	auth_type = RIP_AUTH_NONE;
    107  1.4  christos char	passwd[RIP_AUTH_PW_LEN];
    108  1.4  christos u_long	keyid;
    109  1.1   thorpej 
    110  1.1   thorpej struct timeval sent;			/* when query sent */
    111  1.1   thorpej 
    112  1.1   thorpej static void rip_input(struct sockaddr_in*, int);
    113  1.1   thorpej static int out(char *);
    114  1.1   thorpej static void trace_loop(char *argv[]);
    115  1.1   thorpej static void query_loop(char *argv[], int);
    116  1.1   thorpej static int getnet(char *, struct netinfo *);
    117  1.1   thorpej static u_int std_mask(u_int);
    118  1.4  christos static int parse_quote(char **, char *, char *, char *, int);
    119  1.1   thorpej 
    120  1.1   thorpej 
    121  1.4  christos void
    122  1.1   thorpej main(int argc,
    123  1.1   thorpej      char *argv[])
    124  1.1   thorpej {
    125  1.1   thorpej 	int ch, bsize;
    126  1.4  christos 	char *p, *options, *value, delim;
    127  1.1   thorpej 
    128  1.1   thorpej 	OMSG.rip_nets[0].n_dst = RIP_DEFAULT;
    129  1.1   thorpej 	OMSG.rip_nets[0].n_family = RIP_AF_UNSPEC;
    130  1.1   thorpej 	OMSG.rip_nets[0].n_metric = htonl(HOPCNT_INFINITY);
    131  1.1   thorpej 
    132  1.1   thorpej 	pgmname = argv[0];
    133  1.4  christos 	while ((ch = getopt(argc, argv, "np1w:r:t:a:")) != EOF)
    134  1.1   thorpej 		switch (ch) {
    135  1.1   thorpej 		case 'n':
    136  1.1   thorpej 			not_trace = 1;
    137  1.1   thorpej 			nflag = 1;
    138  1.1   thorpej 			break;
    139  1.1   thorpej 
    140  1.1   thorpej 		case 'p':
    141  1.1   thorpej 			not_trace = 1;
    142  1.1   thorpej 			pflag = 1;
    143  1.1   thorpej 			break;
    144  1.1   thorpej 
    145  1.1   thorpej 		case '1':
    146  1.1   thorpej 			ripv2 = 0;
    147  1.1   thorpej 			break;
    148  1.1   thorpej 
    149  1.1   thorpej 		case 'w':
    150  1.1   thorpej 			not_trace = 1;
    151  1.1   thorpej 			wtime = (int)strtoul(optarg, &p, 0);
    152  1.1   thorpej 			if (*p != '\0'
    153  1.1   thorpej 			    || wtime <= 0)
    154  1.1   thorpej 				goto usage;
    155  1.1   thorpej 			break;
    156  1.1   thorpej 
    157  1.1   thorpej 		case 'r':
    158  1.1   thorpej 			not_trace = 1;
    159  1.1   thorpej 			if (rflag)
    160  1.1   thorpej 				goto usage;
    161  1.1   thorpej 			rflag = getnet(optarg, &OMSG.rip_nets[0]);
    162  1.1   thorpej 			if (!rflag) {
    163  1.1   thorpej 				struct hostent *hp = gethostbyname(optarg);
    164  1.1   thorpej 				if (hp == 0) {
    165  1.1   thorpej 					fprintf(stderr, "%s: %s:",
    166  1.1   thorpej 						pgmname, optarg);
    167  1.1   thorpej 					herror(0);
    168  1.1   thorpej 					exit(1);
    169  1.1   thorpej 				}
    170  1.1   thorpej 				bcopy(hp->h_addr, &OMSG.rip_nets[0].n_dst,
    171  1.1   thorpej 				      sizeof(OMSG.rip_nets[0].n_dst));
    172  1.1   thorpej 				OMSG.rip_nets[0].n_family = RIP_AF_INET;
    173  1.1   thorpej 				OMSG.rip_nets[0].n_mask = -1;
    174  1.1   thorpej 				rflag = 1;
    175  1.1   thorpej 			}
    176  1.1   thorpej 			break;
    177  1.1   thorpej 
    178  1.1   thorpej 		case 't':
    179  1.1   thorpej 			trace = 1;
    180  1.1   thorpej 			options = optarg;
    181  1.1   thorpej 			while (*options != '\0') {
    182  1.1   thorpej 				char *traceopts[] = {
    183  1.1   thorpej #				    define TRACE_ON	0
    184  1.1   thorpej 					"on",
    185  1.1   thorpej #				    define TRACE_MORE	1
    186  1.1   thorpej 					"more",
    187  1.1   thorpej #				    define TRACE_OFF	2
    188  1.1   thorpej 					"off",
    189  1.3  christos #				    define TRACE_DUMP	3
    190  1.3  christos 					"dump",
    191  1.1   thorpej 					0
    192  1.1   thorpej 				};
    193  1.1   thorpej 				switch (getsubopt(&options,traceopts,&value)) {
    194  1.1   thorpej 				case TRACE_ON:
    195  1.1   thorpej 					OMSG.rip_cmd = RIPCMD_TRACEON;
    196  1.1   thorpej 					if (!value
    197  1.1   thorpej 					    || strlen(value) > MAXPATHLEN)
    198  1.1   thorpej 						goto usage;
    199  1.1   thorpej 					break;
    200  1.1   thorpej 				case TRACE_MORE:
    201  1.1   thorpej 					if (value)
    202  1.1   thorpej 						goto usage;
    203  1.1   thorpej 					OMSG.rip_cmd = RIPCMD_TRACEON;
    204  1.3  christos 					value = "";
    205  1.1   thorpej 					break;
    206  1.1   thorpej 				case TRACE_OFF:
    207  1.1   thorpej 					if (value)
    208  1.1   thorpej 						goto usage;
    209  1.1   thorpej 					OMSG.rip_cmd = RIPCMD_TRACEOFF;
    210  1.3  christos 					value = "";
    211  1.3  christos 					break;
    212  1.3  christos 				case TRACE_DUMP:
    213  1.3  christos 					if (value)
    214  1.3  christos 						goto usage;
    215  1.3  christos 					OMSG.rip_cmd = RIPCMD_TRACEON;
    216  1.3  christos 					value = "dump/../table";
    217  1.1   thorpej 					break;
    218  1.1   thorpej 				default:
    219  1.1   thorpej 					goto usage;
    220  1.1   thorpej 				}
    221  1.3  christos 				strcpy((char*)OMSG.rip_tracefile, value);
    222  1.3  christos 				omsg_len += strlen(value) - sizeof(OMSG.ripun);
    223  1.1   thorpej 			}
    224  1.1   thorpej 			break;
    225  1.1   thorpej 
    226  1.4  christos 		case 'a':
    227  1.4  christos 			not_trace = 1;
    228  1.4  christos 			p = strchr(optarg,'=');
    229  1.4  christos 			if (!p)
    230  1.4  christos 				goto usage;
    231  1.4  christos 			*p++ = '\0';
    232  1.4  christos 			if (!strcasecmp("passwd",optarg))
    233  1.4  christos 				auth_type = RIP_AUTH_PW;
    234  1.4  christos 			else if (!strcasecmp("md5_passwd",optarg))
    235  1.4  christos 				auth_type = RIP_AUTH_MD5;
    236  1.4  christos 			else
    237  1.4  christos 				goto usage;
    238  1.4  christos 			if (0 > parse_quote(&p,"|",&delim,
    239  1.4  christos 					    passwd,sizeof(passwd)))
    240  1.4  christos 				goto usage;
    241  1.4  christos 			if (auth_type == RIP_AUTH_MD5
    242  1.4  christos 			    && delim == '|') {
    243  1.4  christos 				keyid = strtoul(p+1,&p,0);
    244  1.4  christos 				if (keyid > 255 || *p != '\0')
    245  1.4  christos 					goto usage;
    246  1.4  christos 			} else if (delim != '\0') {
    247  1.4  christos 				goto usage;
    248  1.4  christos 			}
    249  1.4  christos 			break;
    250  1.4  christos 
    251  1.1   thorpej 		default:
    252  1.1   thorpej 			goto usage;
    253  1.1   thorpej 	}
    254  1.1   thorpej 	argv += optind;
    255  1.1   thorpej 	argc -= optind;
    256  1.1   thorpej 	if ((not_trace && trace) || argc == 0) {
    257  1.1   thorpej usage:		fprintf(stderr, "%s: [-np1v] [-r tgt_rt] [-w wtime]"
    258  1.4  christos 			" [-a type=passwd] host1 [host2 ...]\n"
    259  1.4  christos 			"or\t-t {on=filename|more|off|dump}"
    260  1.4  christos 			" host1 [host2 ...]\n",
    261  1.1   thorpej 			pgmname);
    262  1.1   thorpej 		exit(1);
    263  1.1   thorpej 	}
    264  1.1   thorpej 
    265  1.1   thorpej 	s = socket(AF_INET, SOCK_DGRAM, 0);
    266  1.1   thorpej 	if (s < 0) {
    267  1.1   thorpej 		perror("socket");
    268  1.1   thorpej 		exit(2);
    269  1.1   thorpej 	}
    270  1.1   thorpej 
    271  1.1   thorpej 	/* be prepared to receive a lot of routes */
    272  1.1   thorpej 	for (bsize = 127*1024; ; bsize -= 1024) {
    273  1.1   thorpej 		if (setsockopt(s, SOL_SOCKET, SO_RCVBUF,
    274  1.1   thorpej 			       &bsize, sizeof(bsize)) == 0)
    275  1.1   thorpej 			break;
    276  1.1   thorpej 		if (bsize <= 4*1024) {
    277  1.1   thorpej 			perror("setsockopt SO_RCVBUF");
    278  1.1   thorpej 			break;
    279  1.1   thorpej 		}
    280  1.1   thorpej 	}
    281  1.1   thorpej 
    282  1.1   thorpej 	if (trace)
    283  1.1   thorpej 		trace_loop(argv);
    284  1.1   thorpej 	else
    285  1.1   thorpej 		query_loop(argv, argc);
    286  1.1   thorpej 	/* NOTREACHED */
    287  1.1   thorpej }
    288  1.1   thorpej 
    289  1.1   thorpej 
    290  1.1   thorpej /* tell the target hosts about tracing
    291  1.1   thorpej  */
    292  1.1   thorpej static void
    293  1.1   thorpej trace_loop(char *argv[])
    294  1.1   thorpej {
    295  1.1   thorpej 	struct sockaddr_in myaddr;
    296  1.1   thorpej 	int res;
    297  1.1   thorpej 
    298  1.1   thorpej 	if (geteuid() != 0) {
    299  1.1   thorpej 		(void)fprintf(stderr, "-t requires UID 0\n");
    300  1.1   thorpej 		exit(1);
    301  1.1   thorpej 	}
    302  1.1   thorpej 
    303  1.1   thorpej 	if (ripv2) {
    304  1.1   thorpej 		OMSG.rip_vers = RIPv2;
    305  1.1   thorpej 	} else {
    306  1.1   thorpej 		OMSG.rip_vers = RIPv1;
    307  1.1   thorpej 	}
    308  1.1   thorpej 
    309  1.1   thorpej 	bzero(&myaddr, sizeof(myaddr));
    310  1.1   thorpej 	myaddr.sin_family = AF_INET;
    311  1.1   thorpej #ifdef _HAVE_SIN_LEN
    312  1.1   thorpej 	myaddr.sin_len = sizeof(myaddr);
    313  1.1   thorpej #endif
    314  1.1   thorpej 	myaddr.sin_port = htons(IPPORT_RESERVED-1);
    315  1.1   thorpej 	while (bind(s, (struct sockaddr *)&myaddr, sizeof(myaddr)) < 0) {
    316  1.1   thorpej 		if (errno != EADDRINUSE
    317  1.1   thorpej 		    || myaddr.sin_port == 0) {
    318  1.1   thorpej 			perror("bind");
    319  1.1   thorpej 			exit(2);
    320  1.1   thorpej 		}
    321  1.1   thorpej 		myaddr.sin_port = htons(ntohs(myaddr.sin_port)-1);
    322  1.1   thorpej 	}
    323  1.1   thorpej 
    324  1.1   thorpej 	res = 1;
    325  1.1   thorpej 	while (*argv != 0) {
    326  1.1   thorpej 		if (out(*argv++) <= 0)
    327  1.1   thorpej 			res = 0;
    328  1.1   thorpej 	}
    329  1.1   thorpej 	exit(res);
    330  1.1   thorpej }
    331  1.1   thorpej 
    332  1.1   thorpej 
    333  1.1   thorpej /* query all of the listed hosts
    334  1.1   thorpej  */
    335  1.1   thorpej static void
    336  1.1   thorpej query_loop(char *argv[], int argc)
    337  1.1   thorpej {
    338  1.4  christos #	define NA0 (OMSG.rip_auths[0])
    339  1.4  christos #	define NA2 (OMSG.rip_auths[2])
    340  1.1   thorpej 	struct seen {
    341  1.1   thorpej 		struct seen *next;
    342  1.1   thorpej 		struct in_addr addr;
    343  1.1   thorpej 	} *seen, *sp;
    344  1.1   thorpej 	int answered = 0;
    345  1.1   thorpej 	int cc;
    346  1.1   thorpej 	fd_set bits;
    347  1.1   thorpej 	struct timeval now, delay;
    348  1.1   thorpej 	struct sockaddr_in from;
    349  1.1   thorpej 	int fromlen;
    350  1.4  christos 	MD5_CTX md5_ctx;
    351  1.1   thorpej 
    352  1.1   thorpej 
    353  1.1   thorpej 	OMSG.rip_cmd = (pflag) ? RIPCMD_POLL : RIPCMD_REQUEST;
    354  1.1   thorpej 	if (ripv2) {
    355  1.1   thorpej 		OMSG.rip_vers = RIPv2;
    356  1.4  christos 		if (auth_type == RIP_AUTH_PW) {
    357  1.4  christos 			OMSG.rip_nets[1] = OMSG.rip_nets[0];
    358  1.4  christos 			NA0.a_family = RIP_AF_AUTH;
    359  1.4  christos 			NA0.a_type = RIP_AUTH_PW;
    360  1.4  christos 			bcopy(passwd, NA0.au.au_pw,
    361  1.4  christos 			      RIP_AUTH_PW_LEN);
    362  1.4  christos 			omsg_len += sizeof(OMSG.rip_nets[0]);
    363  1.4  christos 
    364  1.4  christos 		} else if (auth_type == RIP_AUTH_MD5) {
    365  1.4  christos 			OMSG.rip_nets[1] = OMSG.rip_nets[0];
    366  1.4  christos 			NA0.a_family = RIP_AF_AUTH;
    367  1.4  christos 			NA0.a_type = RIP_AUTH_MD5;
    368  1.4  christos 			NA0.au.a_md5.md5_keyid = (int8_t)keyid;
    369  1.4  christos 			NA0.au.a_md5.md5_auth_len = RIP_AUTH_PW_LEN;
    370  1.4  christos 			NA0.au.a_md5.md5_seqno = 0;
    371  1.4  christos 			NA0.au.a_md5.md5_pkt_len = sizeof(OMSG.rip_nets[1]);
    372  1.4  christos 			NA2.a_family = RIP_AF_AUTH;
    373  1.4  christos 			NA2.a_type = 1;
    374  1.4  christos 			bcopy(passwd, NA2.au.au_pw, sizeof(NA2.au.au_pw));
    375  1.4  christos 			MD5Init(&md5_ctx);
    376  1.4  christos 			MD5Update(&md5_ctx, (u_char *)&NA0,
    377  1.4  christos 				  (char *)(&NA2+1) - (char *)&NA0);
    378  1.4  christos 			MD5Final(NA2.au.au_pw, &md5_ctx);
    379  1.4  christos 			omsg_len += 2*sizeof(OMSG.rip_nets[0]);
    380  1.4  christos 		}
    381  1.4  christos 
    382  1.1   thorpej 	} else {
    383  1.1   thorpej 		OMSG.rip_vers = RIPv1;
    384  1.1   thorpej 		OMSG.rip_nets[0].n_mask = 0;
    385  1.1   thorpej 	}
    386  1.1   thorpej 
    387  1.1   thorpej 	/* ask the first (valid) host */
    388  1.1   thorpej 	seen = 0;
    389  1.1   thorpej 	while (0 > out(*argv++)) {
    390  1.1   thorpej 		if (*argv == 0)
    391  1.1   thorpej 			exit(-1);
    392  1.1   thorpej 		answered++;
    393  1.1   thorpej 	}
    394  1.1   thorpej 
    395  1.1   thorpej 	FD_ZERO(&bits);
    396  1.1   thorpej 	for (;;) {
    397  1.1   thorpej 		FD_SET(s, &bits);
    398  1.1   thorpej 		delay.tv_sec = 0;
    399  1.1   thorpej 		delay.tv_usec = STIME;
    400  1.1   thorpej 		cc = select(s+1, &bits, 0,0, &delay);
    401  1.1   thorpej 		if (cc > 0) {
    402  1.1   thorpej 			fromlen = sizeof(from);
    403  1.1   thorpej 			cc = recvfrom(s, imsg_buf.packet,
    404  1.1   thorpej 				      sizeof(imsg_buf.packet), 0,
    405  1.1   thorpej 				      (struct sockaddr *)&from, &fromlen);
    406  1.1   thorpej 			if (cc < 0) {
    407  1.1   thorpej 				perror("recvfrom");
    408  1.1   thorpej 				exit(1);
    409  1.1   thorpej 			}
    410  1.1   thorpej 			/* count the distinct responding hosts.
    411  1.1   thorpej 			 * You cannot match responding hosts with
    412  1.1   thorpej 			 * addresses to which queries were transmitted,
    413  1.1   thorpej 			 * because a router might respond with a
    414  1.1   thorpej 			 * different source address.
    415  1.1   thorpej 			 */
    416  1.1   thorpej 			for (sp = seen; sp != 0; sp = sp->next) {
    417  1.1   thorpej 				if (sp->addr.s_addr == from.sin_addr.s_addr)
    418  1.1   thorpej 					break;
    419  1.1   thorpej 			}
    420  1.1   thorpej 			if (sp == 0) {
    421  1.1   thorpej 				sp = malloc(sizeof(*sp));
    422  1.1   thorpej 				sp->addr = from.sin_addr;
    423  1.1   thorpej 				sp->next = seen;
    424  1.1   thorpej 				seen = sp;
    425  1.1   thorpej 				answered++;
    426  1.1   thorpej 			}
    427  1.1   thorpej 
    428  1.1   thorpej 			rip_input(&from, cc);
    429  1.1   thorpej 			continue;
    430  1.1   thorpej 		}
    431  1.1   thorpej 
    432  1.1   thorpej 		if (cc < 0) {
    433  1.1   thorpej 			if ( errno == EINTR)
    434  1.1   thorpej 				continue;
    435  1.1   thorpej 			perror("select");
    436  1.1   thorpej 			exit(1);
    437  1.1   thorpej 		}
    438  1.1   thorpej 
    439  1.1   thorpej 		/* After a pause in responses, probe another host.
    440  1.1   thorpej 		 * This reduces the intermingling of answers.
    441  1.1   thorpej 		 */
    442  1.1   thorpej 		while (*argv != 0 && 0 > out(*argv++))
    443  1.1   thorpej 			answered++;
    444  1.1   thorpej 
    445  1.1   thorpej 		/* continue until no more packets arrive
    446  1.1   thorpej 		 * or we have heard from all hosts
    447  1.1   thorpej 		 */
    448  1.1   thorpej 		if (answered >= argc)
    449  1.1   thorpej 			break;
    450  1.1   thorpej 
    451  1.1   thorpej 		/* or until we have waited a long time
    452  1.1   thorpej 		 */
    453  1.1   thorpej 		if (gettimeofday(&now, 0) < 0) {
    454  1.1   thorpej 			perror("gettimeofday(now)");
    455  1.1   thorpej 			exit(1);
    456  1.1   thorpej 		}
    457  1.1   thorpej 		if (sent.tv_sec + wtime <= now.tv_sec)
    458  1.1   thorpej 			break;
    459  1.1   thorpej 	}
    460  1.1   thorpej 
    461  1.1   thorpej 	/* fail if there was no answer */
    462  1.1   thorpej 	exit (answered >= argc ? 0 : 1);
    463  1.1   thorpej }
    464  1.1   thorpej 
    465  1.1   thorpej 
    466  1.4  christos /* send to one host
    467  1.1   thorpej  */
    468  1.1   thorpej static int
    469  1.1   thorpej out(char *host)
    470  1.1   thorpej {
    471  1.1   thorpej 	struct sockaddr_in router;
    472  1.1   thorpej 	struct hostent *hp;
    473  1.1   thorpej 
    474  1.1   thorpej 	if (gettimeofday(&sent, 0) < 0) {
    475  1.1   thorpej 		perror("gettimeofday(sent)");
    476  1.1   thorpej 		return -1;
    477  1.1   thorpej 	}
    478  1.1   thorpej 
    479  1.1   thorpej 	bzero(&router, sizeof(router));
    480  1.1   thorpej 	router.sin_family = AF_INET;
    481  1.1   thorpej #ifdef _HAVE_SIN_LEN
    482  1.1   thorpej 	router.sin_len = sizeof(router);
    483  1.1   thorpej #endif
    484  1.1   thorpej 	if (!inet_aton(host, &router.sin_addr)) {
    485  1.1   thorpej 		hp = gethostbyname(host);
    486  1.1   thorpej 		if (hp == 0) {
    487  1.1   thorpej 			herror(host);
    488  1.1   thorpej 			return -1;
    489  1.1   thorpej 		}
    490  1.1   thorpej 		bcopy(hp->h_addr, &router.sin_addr, sizeof(router.sin_addr));
    491  1.1   thorpej 	}
    492  1.1   thorpej 	router.sin_port = htons(RIP_PORT);
    493  1.1   thorpej 
    494  1.1   thorpej 	if (sendto(s, &omsg_buf, omsg_len, 0,
    495  1.1   thorpej 		   (struct sockaddr *)&router, sizeof(router)) < 0) {
    496  1.1   thorpej 		perror(host);
    497  1.1   thorpej 		return -1;
    498  1.1   thorpej 	}
    499  1.1   thorpej 
    500  1.1   thorpej 	return 0;
    501  1.1   thorpej }
    502  1.1   thorpej 
    503  1.1   thorpej 
    504  1.1   thorpej /*
    505  1.4  christos  * Convert string to printable characters
    506  1.4  christos  */
    507  1.4  christos static char *
    508  1.4  christos qstring(u_char *s, int len)
    509  1.4  christos {
    510  1.4  christos 	static char buf[8*20+1];
    511  1.4  christos 	char *p;
    512  1.4  christos 	u_char *s2, c;
    513  1.4  christos 
    514  1.4  christos 
    515  1.4  christos 	for (p = buf; len != 0 && p < &buf[sizeof(buf)-1]; len--) {
    516  1.4  christos 		c = *s++;
    517  1.4  christos 		if (c == '\0') {
    518  1.4  christos 			for (s2 = s+1; s2 < &s[len]; s2++) {
    519  1.4  christos 				if (*s2 != '\0')
    520  1.4  christos 					break;
    521  1.4  christos 			}
    522  1.4  christos 			if (s2 >= &s[len])
    523  1.4  christos 			    goto exit;
    524  1.4  christos 		}
    525  1.4  christos 
    526  1.4  christos 		if (c >= ' ' && c < 0x7f && c != '\\') {
    527  1.4  christos 			*p++ = c;
    528  1.4  christos 			continue;
    529  1.4  christos 		}
    530  1.4  christos 		*p++ = '\\';
    531  1.4  christos 		switch (c) {
    532  1.4  christos 		case '\\':
    533  1.4  christos 			*p++ = '\\';
    534  1.4  christos 			break;
    535  1.4  christos 		case '\n':
    536  1.4  christos 			*p++= 'n';
    537  1.4  christos 			break;
    538  1.4  christos 		case '\r':
    539  1.4  christos 			*p++= 'r';
    540  1.4  christos 			break;
    541  1.4  christos 		case '\t':
    542  1.4  christos 			*p++ = 't';
    543  1.4  christos 			break;
    544  1.4  christos 		case '\b':
    545  1.4  christos 			*p++ = 'b';
    546  1.4  christos 			break;
    547  1.4  christos 		default:
    548  1.4  christos 			p += sprintf(p,"%o",c);
    549  1.4  christos 			break;
    550  1.4  christos 		}
    551  1.4  christos 	}
    552  1.4  christos exit:
    553  1.4  christos 	*p = '\0';
    554  1.4  christos 	return buf;
    555  1.4  christos }
    556  1.4  christos 
    557  1.4  christos 
    558  1.4  christos /*
    559  1.1   thorpej  * Handle an incoming RIP packet.
    560  1.1   thorpej  */
    561  1.1   thorpej static void
    562  1.1   thorpej rip_input(struct sockaddr_in *from,
    563  1.1   thorpej 	  int size)
    564  1.1   thorpej {
    565  1.1   thorpej 	struct netinfo *n, *lim;
    566  1.1   thorpej 	struct in_addr in;
    567  1.1   thorpej 	char *name;
    568  1.1   thorpej 	char net_buf[80];
    569  1.1   thorpej 	u_int mask, dmask;
    570  1.1   thorpej 	char *sp;
    571  1.1   thorpej 	int i;
    572  1.1   thorpej 	struct hostent *hp;
    573  1.1   thorpej 	struct netent *np;
    574  1.4  christos 	struct netauth *na;
    575  1.1   thorpej 
    576  1.1   thorpej 
    577  1.1   thorpej 	if (nflag) {
    578  1.1   thorpej 		printf("%s:", inet_ntoa(from->sin_addr));
    579  1.1   thorpej 	} else {
    580  1.1   thorpej 		hp = gethostbyaddr((char*)&from->sin_addr,
    581  1.1   thorpej 				   sizeof(struct in_addr), AF_INET);
    582  1.1   thorpej 		if (hp == 0) {
    583  1.1   thorpej 			printf("%s:",
    584  1.1   thorpej 			       inet_ntoa(from->sin_addr));
    585  1.1   thorpej 		} else {
    586  1.1   thorpej 			printf("%s (%s):", hp->h_name,
    587  1.1   thorpej 			       inet_ntoa(from->sin_addr));
    588  1.1   thorpej 		}
    589  1.1   thorpej 	}
    590  1.1   thorpej 	if (IMSG.rip_cmd != RIPCMD_RESPONSE) {
    591  1.1   thorpej 		printf("\n    unexpected response type %d\n", IMSG.rip_cmd);
    592  1.1   thorpej 		return;
    593  1.1   thorpej 	}
    594  1.1   thorpej 	printf(" RIPv%d%s %d bytes\n", IMSG.rip_vers,
    595  1.1   thorpej 	       (IMSG.rip_vers != RIPv1 && IMSG.rip_vers != RIPv2) ? " ?" : "",
    596  1.1   thorpej 	       size);
    597  1.1   thorpej 	if (size > MAXPACKETSIZE) {
    598  1.1   thorpej 		if (size > sizeof(imsg_buf) - sizeof(*n)) {
    599  1.1   thorpej 			printf("       at least %d bytes too long\n",
    600  1.1   thorpej 			       size-MAXPACKETSIZE);
    601  1.1   thorpej 			size = sizeof(imsg_buf) - sizeof(*n);
    602  1.1   thorpej 		} else {
    603  1.1   thorpej 			printf("       %d bytes too long\n",
    604  1.1   thorpej 			       size-MAXPACKETSIZE);
    605  1.1   thorpej 		}
    606  1.1   thorpej 	} else if (size%sizeof(*n) != sizeof(struct rip)%sizeof(*n)) {
    607  1.1   thorpej 		printf("    response of bad length=%d\n", size);
    608  1.1   thorpej 	}
    609  1.1   thorpej 
    610  1.1   thorpej 	n = IMSG.rip_nets;
    611  1.1   thorpej 	lim = (struct netinfo *)((char*)n + size) - 1;
    612  1.1   thorpej 	for (; n <= lim; n++) {
    613  1.1   thorpej 		name = "";
    614  1.1   thorpej 		if (n->n_family == RIP_AF_INET) {
    615  1.1   thorpej 			in.s_addr = n->n_dst;
    616  1.1   thorpej 			(void)strcpy(net_buf, inet_ntoa(in));
    617  1.1   thorpej 
    618  1.1   thorpej 			mask = ntohl(n->n_mask);
    619  1.1   thorpej 			dmask = mask & -mask;
    620  1.1   thorpej 			if (mask != 0) {
    621  1.1   thorpej 				sp = &net_buf[strlen(net_buf)];
    622  1.1   thorpej 				if (IMSG.rip_vers == RIPv1) {
    623  1.1   thorpej 					(void)sprintf(sp," mask=%#x ? ",mask);
    624  1.1   thorpej 					mask = 0;
    625  1.1   thorpej 				} else if (mask + dmask == 0) {
    626  1.1   thorpej 					for (i = 0;
    627  1.1   thorpej 					     (i != 32
    628  1.1   thorpej 					      && ((1<<i)&mask) == 0);
    629  1.1   thorpej 					     i++)
    630  1.1   thorpej 						continue;
    631  1.1   thorpej 					(void)sprintf(sp, "/%d",32-i);
    632  1.1   thorpej 				} else {
    633  1.1   thorpej 					(void)sprintf(sp," (mask %#x)", mask);
    634  1.1   thorpej 				}
    635  1.1   thorpej 			}
    636  1.1   thorpej 
    637  1.1   thorpej 			if (!nflag) {
    638  1.1   thorpej 				if (mask == 0) {
    639  1.1   thorpej 					mask = std_mask(in.s_addr);
    640  1.1   thorpej 					if ((ntohl(in.s_addr) & ~mask) != 0)
    641  1.1   thorpej 						mask = 0;
    642  1.1   thorpej 				}
    643  1.1   thorpej 				/* Without a netmask, do not worry about
    644  1.1   thorpej 				 * whether the destination is a host or a
    645  1.1   thorpej 				 * network. Try both and use the first name
    646  1.1   thorpej 				 * we get.
    647  1.1   thorpej 				 *
    648  1.1   thorpej 				 * If we have a netmask we can make a
    649  1.1   thorpej 				 * good guess.
    650  1.1   thorpej 				 */
    651  1.1   thorpej 				if ((in.s_addr & ~mask) == 0) {
    652  1.1   thorpej 					np = getnetbyaddr((long)in.s_addr,
    653  1.1   thorpej 							  AF_INET);
    654  1.1   thorpej 					if (np != 0)
    655  1.1   thorpej 						name = np->n_name;
    656  1.1   thorpej 					else if (in.s_addr == 0)
    657  1.1   thorpej 						name = "default";
    658  1.1   thorpej 				}
    659  1.1   thorpej 				if (name[0] == '\0'
    660  1.1   thorpej 				    && ((in.s_addr & ~mask) != 0
    661  1.1   thorpej 					|| mask == 0xffffffff)) {
    662  1.1   thorpej 					hp = gethostbyaddr((char*)&in,
    663  1.1   thorpej 							   sizeof(in),
    664  1.1   thorpej 							   AF_INET);
    665  1.1   thorpej 					if (hp != 0)
    666  1.1   thorpej 						name = hp->h_name;
    667  1.1   thorpej 				}
    668  1.1   thorpej 			}
    669  1.1   thorpej 
    670  1.1   thorpej 		} else if (n->n_family == RIP_AF_AUTH) {
    671  1.4  christos 			na = (struct netauth*)n;
    672  1.4  christos 			if (na->a_type == RIP_AUTH_PW
    673  1.4  christos 			    && n == IMSG.rip_nets) {
    674  1.4  christos 				(void)printf("  Password Authentication:"
    675  1.4  christos 					     " \"%s\"\n",
    676  1.4  christos 					     qstring(na->au.au_pw,
    677  1.4  christos 						     RIP_AUTH_PW_LEN));
    678  1.4  christos 				continue;
    679  1.4  christos 			}
    680  1.4  christos 
    681  1.4  christos 			if (na->a_type == RIP_AUTH_MD5
    682  1.4  christos 			    && n == IMSG.rip_nets) {
    683  1.4  christos 				(void)printf("  MD5 Authentication"
    684  1.4  christos 					     " len=%d KeyID=%d"
    685  1.4  christos 					     " seqno=%d"
    686  1.4  christos 					     " rsvd=%#x,%#x\n",
    687  1.4  christos 					     na->au.a_md5.md5_pkt_len,
    688  1.4  christos 					     na->au.a_md5.md5_keyid,
    689  1.4  christos 					     na->au.a_md5.md5_seqno,
    690  1.4  christos 					     na->au.a_md5.rsvd[0],
    691  1.4  christos 					     na->au.a_md5.rsvd[1]);
    692  1.4  christos 				continue;
    693  1.4  christos 			}
    694  1.4  christos 			(void)printf("  Authentication type %d: ",
    695  1.4  christos 				     ntohs(na->a_type));
    696  1.4  christos 			for (i = 0; i < sizeof(na->au.au_pw); i++)
    697  1.4  christos 				(void)printf("%02x ", na->au.au_pw[i]);
    698  1.1   thorpej 			putc('\n', stdout);
    699  1.1   thorpej 			continue;
    700  1.1   thorpej 
    701  1.1   thorpej 		} else {
    702  1.1   thorpej 			(void)sprintf(net_buf, "(af %#x) %d.%d.%d.%d",
    703  1.1   thorpej 				      ntohs(n->n_family),
    704  1.1   thorpej 				      (char)(n->n_dst >> 24),
    705  1.1   thorpej 				      (char)(n->n_dst >> 16),
    706  1.1   thorpej 				      (char)(n->n_dst >> 8),
    707  1.1   thorpej 				      (char)n->n_dst);
    708  1.1   thorpej 		}
    709  1.1   thorpej 
    710  1.1   thorpej 		(void)printf("  %-18s metric %2d %-10s",
    711  1.1   thorpej 			     net_buf, ntohl(n->n_metric), name);
    712  1.1   thorpej 
    713  1.1   thorpej 		if (n->n_nhop != 0) {
    714  1.1   thorpej 			in.s_addr = n->n_nhop;
    715  1.1   thorpej 			if (nflag)
    716  1.1   thorpej 				hp = 0;
    717  1.1   thorpej 			else
    718  1.1   thorpej 				hp = gethostbyaddr((char*)&in, sizeof(in),
    719  1.1   thorpej 						   AF_INET);
    720  1.1   thorpej 			(void)printf(" nhop=%-15s%s",
    721  1.1   thorpej 				     (hp != 0) ? hp->h_name : inet_ntoa(in),
    722  1.1   thorpej 				     (IMSG.rip_vers == RIPv1) ? " ?" : "");
    723  1.1   thorpej 		}
    724  1.1   thorpej 		if (n->n_tag != 0)
    725  1.1   thorpej 			(void)printf(" tag=%#x%s", n->n_tag,
    726  1.1   thorpej 				     (IMSG.rip_vers == RIPv1) ? " ?" : "");
    727  1.1   thorpej 		putc('\n', stdout);
    728  1.1   thorpej 	}
    729  1.1   thorpej }
    730  1.1   thorpej 
    731  1.1   thorpej 
    732  1.1   thorpej /* Return the classical netmask for an IP address.
    733  1.1   thorpej  */
    734  1.1   thorpej static u_int
    735  1.1   thorpej std_mask(u_int addr)			/* in network order */
    736  1.1   thorpej {
    737  1.1   thorpej 	NTOHL(addr);			/* was a host, not a network */
    738  1.1   thorpej 
    739  1.1   thorpej 	if (addr == 0)			/* default route has mask 0 */
    740  1.1   thorpej 		return 0;
    741  1.1   thorpej 	if (IN_CLASSA(addr))
    742  1.1   thorpej 		return IN_CLASSA_NET;
    743  1.1   thorpej 	if (IN_CLASSB(addr))
    744  1.1   thorpej 		return IN_CLASSB_NET;
    745  1.1   thorpej 	return IN_CLASSC_NET;
    746  1.1   thorpej }
    747  1.1   thorpej 
    748  1.1   thorpej 
    749  1.1   thorpej /* get a network number as a name or a number, with an optional "/xx"
    750  1.1   thorpej  * netmask.
    751  1.1   thorpej  */
    752  1.1   thorpej static int				/* 0=bad */
    753  1.1   thorpej getnet(char *name,
    754  1.1   thorpej        struct netinfo *rt)
    755  1.1   thorpej {
    756  1.1   thorpej 	int i;
    757  1.1   thorpej 	struct netent *nentp;
    758  1.1   thorpej 	u_int mask;
    759  1.1   thorpej 	struct in_addr in;
    760  1.1   thorpej 	char hname[MAXHOSTNAMELEN+1];
    761  1.1   thorpej 	char *mname, *p;
    762  1.1   thorpej 
    763  1.1   thorpej 
    764  1.1   thorpej 	/* Detect and separate "1.2.3.4/24"
    765  1.1   thorpej 	 */
    766  1.1   thorpej 	if (0 != (mname = rindex(name,'/'))) {
    767  1.1   thorpej 		i = (int)(mname - name);
    768  1.1   thorpej 		if (i > sizeof(hname)-1)	/* name too long */
    769  1.1   thorpej 			return 0;
    770  1.1   thorpej 		bcopy(name, hname, i);
    771  1.1   thorpej 		hname[i] = '\0';
    772  1.1   thorpej 		mname++;
    773  1.1   thorpej 		name = hname;
    774  1.1   thorpej 	}
    775  1.1   thorpej 
    776  1.1   thorpej 	nentp = getnetbyname(name);
    777  1.1   thorpej 	if (nentp != 0) {
    778  1.1   thorpej 		in.s_addr = nentp->n_net;
    779  1.1   thorpej 	} else if (inet_aton(name, &in) == 1) {
    780  1.1   thorpej 		NTOHL(in.s_addr);
    781  1.1   thorpej 	} else {
    782  1.1   thorpej 		return 0;
    783  1.1   thorpej 	}
    784  1.1   thorpej 
    785  1.1   thorpej 	if (mname == 0) {
    786  1.1   thorpej 		mask = std_mask(in.s_addr);
    787  1.1   thorpej 		if ((~mask & in.s_addr) != 0)
    788  1.1   thorpej 			mask = 0xffffffff;
    789  1.1   thorpej 	} else {
    790  1.1   thorpej 		mask = (u_int)strtoul(mname, &p, 0);
    791  1.1   thorpej 		if (*p != '\0' || mask > 32)
    792  1.1   thorpej 			return 0;
    793  1.1   thorpej 		mask = 0xffffffff << (32-mask);
    794  1.1   thorpej 	}
    795  1.1   thorpej 
    796  1.1   thorpej 	rt->n_dst = htonl(in.s_addr);
    797  1.1   thorpej 	rt->n_family = RIP_AF_INET;
    798  1.1   thorpej 	rt->n_mask = htonl(mask);
    799  1.1   thorpej 	return 1;
    800  1.4  christos }
    801  1.4  christos 
    802  1.4  christos 
    803  1.4  christos /* strtok(), but honoring backslash
    804  1.4  christos  */
    805  1.4  christos static int				/* -1=bad */
    806  1.4  christos parse_quote(char **linep,
    807  1.4  christos 	    char *delims,
    808  1.4  christos 	    char *delimp,
    809  1.4  christos 	    char *buf,
    810  1.4  christos 	    int	lim)
    811  1.4  christos {
    812  1.4  christos 	char c, *pc, *p;
    813  1.4  christos 
    814  1.4  christos 
    815  1.4  christos 	pc = *linep;
    816  1.4  christos 	if (*pc == '\0')
    817  1.4  christos 		return -1;
    818  1.4  christos 
    819  1.4  christos 	for (;;) {
    820  1.4  christos 		if (lim == 0)
    821  1.4  christos 			return -1;
    822  1.4  christos 		c = *pc++;
    823  1.4  christos 		if (c == '\0')
    824  1.4  christos 			break;
    825  1.4  christos 
    826  1.4  christos 		if (c == '\\' && pc != '\0') {
    827  1.4  christos 			if ((c = *pc++) == 'n') {
    828  1.4  christos 				c = '\n';
    829  1.4  christos 			} else if (c == 'r') {
    830  1.4  christos 				c = '\r';
    831  1.4  christos 			} else if (c == 't') {
    832  1.4  christos 				c = '\t';
    833  1.4  christos 			} else if (c == 'b') {
    834  1.4  christos 				c = '\b';
    835  1.4  christos 			} else if (c >= '0' && c <= '7') {
    836  1.4  christos 				c -= '0';
    837  1.4  christos 				if (*pc >= '0' && *pc <= '7') {
    838  1.4  christos 					c = (c<<3)+(*pc++ - '0');
    839  1.4  christos 					if (*pc >= '0' && *pc <= '7')
    840  1.4  christos 					    c = (c<<3)+(*pc++ - '0');
    841  1.4  christos 				}
    842  1.4  christos 			}
    843  1.4  christos 
    844  1.4  christos 		} else {
    845  1.4  christos 			for (p = delims; *p != '\0'; ++p) {
    846  1.4  christos 				if (*p == c)
    847  1.4  christos 					goto exit;
    848  1.4  christos 			}
    849  1.4  christos 		}
    850  1.4  christos 
    851  1.4  christos 		*buf++ = c;
    852  1.4  christos 		--lim;
    853  1.4  christos 	}
    854  1.4  christos exit:
    855  1.4  christos 	if (delimp != 0)
    856  1.4  christos 		*delimp = c;
    857  1.4  christos 	*linep = pc-1;
    858  1.4  christos 	if (lim != 0)
    859  1.4  christos 		*buf = '\0';
    860  1.4  christos 	return 0;
    861  1.1   thorpej }
    862