Home | History | Annotate | Line # | Download | only in routed
output.c revision 1.13
      1  1.13     lukem /*	$NetBSD: output.c,v 1.13 1997/09/15 10:38:16 lukem Exp $	*/
      2   1.8       cgd 
      3   1.1       cgd /*
      4   1.5   mycroft  * Copyright (c) 1983, 1988, 1993
      5   1.5   mycroft  *	The Regents of the University of California.  All rights reserved.
      6   1.1       cgd  *
      7   1.1       cgd  * Redistribution and use in source and binary forms, with or without
      8   1.1       cgd  * modification, are permitted provided that the following conditions
      9   1.1       cgd  * are met:
     10   1.1       cgd  * 1. Redistributions of source code must retain the above copyright
     11   1.1       cgd  *    notice, this list of conditions and the following disclaimer.
     12   1.1       cgd  * 2. Redistributions in binary form must reproduce the above copyright
     13   1.1       cgd  *    notice, this list of conditions and the following disclaimer in the
     14   1.1       cgd  *    documentation and/or other materials provided with the distribution.
     15   1.1       cgd  * 3. All advertising materials mentioning features or use of this software
     16   1.1       cgd  *    must display the following acknowledgement:
     17   1.1       cgd  *	This product includes software developed by the University of
     18   1.1       cgd  *	California, Berkeley and its contributors.
     19   1.1       cgd  * 4. Neither the name of the University nor the names of its contributors
     20   1.1       cgd  *    may be used to endorse or promote products derived from this software
     21   1.1       cgd  *    without specific prior written permission.
     22   1.1       cgd  *
     23   1.1       cgd  * THIS SOFTWARE IS PROVIDED BY THE REGENTS AND CONTRIBUTORS ``AS IS'' AND
     24   1.1       cgd  * ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
     25   1.1       cgd  * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE
     26   1.1       cgd  * ARE DISCLAIMED.  IN NO EVENT SHALL THE REGENTS OR CONTRIBUTORS BE LIABLE
     27   1.1       cgd  * FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL
     28   1.1       cgd  * DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS
     29   1.1       cgd  * OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION)
     30   1.1       cgd  * HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT
     31   1.1       cgd  * LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY
     32   1.1       cgd  * OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF
     33   1.1       cgd  * SUCH DAMAGE.
     34   1.1       cgd  */
     35   1.1       cgd 
     36  1.11  christos #if !defined(lint) && !defined(sgi) && !defined(__NetBSD__)
     37   1.8       cgd static char sccsid[] = "@(#)output.c	8.1 (Berkeley) 6/5/93";
     38  1.11  christos #elif defined(__NetBSD__)
     39  1.13     lukem #include <sys/cdefs.h>
     40  1.13     lukem __RCSID("$NetBSD: output.c,v 1.13 1997/09/15 10:38:16 lukem Exp $");
     41   1.8       cgd #endif
     42   1.1       cgd 
     43  1.10   thorpej #include "defs.h"
     44  1.10   thorpej 
     45  1.10   thorpej 
     46  1.10   thorpej int update_seqno;
     47  1.10   thorpej 
     48  1.10   thorpej 
     49  1.10   thorpej /* walk the tree of routes with this for output
     50  1.10   thorpej  */
     51  1.10   thorpej struct {
     52  1.10   thorpej 	struct sockaddr_in to;
     53  1.10   thorpej 	naddr	to_mask;
     54  1.10   thorpej 	naddr	to_net;
     55  1.10   thorpej 	naddr	to_std_mask;
     56  1.10   thorpej 	naddr	to_std_net;
     57  1.10   thorpej 	struct interface *ifp;		/* usually output interface */
     58  1.12  christos 	struct auth *a;
     59  1.10   thorpej 	char	metric;			/* adjust metrics by interface */
     60  1.10   thorpej 	int	npackets;
     61  1.11  christos 	int	gen_limit;
     62  1.10   thorpej 	u_int	state;
     63  1.10   thorpej #define	    WS_ST_FLASH	    0x001	/* send only changed routes */
     64  1.12  christos #define	    WS_ST_RIP2_ALL  0x002	/* send full featured RIPv2 */
     65  1.12  christos #define	    WS_ST_AG	    0x004	/* ok to aggregate subnets */
     66  1.12  christos #define	    WS_ST_SUPER_AG  0x008	/* ok to aggregate networks */
     67  1.12  christos #define	    WS_ST_SUB_AG    0x010	/* aggregate subnets in odd case */
     68  1.12  christos #define	    WS_ST_QUERY	    0x020	/* responding to a query */
     69  1.12  christos #define	    WS_ST_TO_ON_NET 0x040	/* sending onto one of our nets */
     70  1.12  christos #define	    WS_ST_DEFAULT   0x080	/* faking a default */
     71  1.10   thorpej } ws;
     72  1.10   thorpej 
     73  1.10   thorpej /* A buffer for what can be heard by both RIPv1 and RIPv2 listeners */
     74  1.12  christos struct ws_buf v12buf;
     75  1.10   thorpej union pkt_buf ripv12_buf;
     76  1.10   thorpej 
     77  1.10   thorpej /* Another for only RIPv2 listeners */
     78  1.12  christos struct ws_buf v2buf;
     79  1.10   thorpej union pkt_buf rip_v2_buf;
     80  1.10   thorpej 
     81  1.10   thorpej 
     82  1.10   thorpej 
     83  1.12  christos void
     84  1.12  christos bufinit(void)
     85  1.12  christos {
     86  1.12  christos 	ripv12_buf.rip.rip_cmd = RIPCMD_RESPONSE;
     87  1.12  christos 	v12buf.buf = &ripv12_buf.rip;
     88  1.12  christos 	v12buf.base = &v12buf.buf->rip_nets[0];
     89  1.12  christos 
     90  1.12  christos 	rip_v2_buf.rip.rip_cmd = RIPCMD_RESPONSE;
     91  1.12  christos 	rip_v2_buf.rip.rip_vers = RIPv2;
     92  1.12  christos 	v2buf.buf = &rip_v2_buf.rip;
     93  1.12  christos 	v2buf.base = &v2buf.buf->rip_nets[0];
     94  1.12  christos }
     95  1.12  christos 
     96  1.12  christos 
     97  1.10   thorpej /* Send the contents of the global buffer via the non-multicast socket
     98  1.10   thorpej  */
     99  1.10   thorpej int					/* <0 on failure */
    100  1.10   thorpej output(enum output_type type,
    101  1.10   thorpej        struct sockaddr_in *dst,		/* send to here */
    102  1.10   thorpej        struct interface *ifp,
    103  1.10   thorpej        struct rip *buf,
    104  1.10   thorpej        int size)			/* this many bytes */
    105  1.10   thorpej {
    106  1.10   thorpej 	struct sockaddr_in sin;
    107  1.10   thorpej 	int flags;
    108  1.10   thorpej 	char *msg;
    109  1.10   thorpej 	int res;
    110  1.10   thorpej 	naddr tgt_mcast;
    111  1.10   thorpej 	int soc;
    112  1.10   thorpej 	int serrno;
    113  1.10   thorpej 
    114  1.10   thorpej 	sin = *dst;
    115  1.10   thorpej 	if (sin.sin_port == 0)
    116  1.10   thorpej 		sin.sin_port = htons(RIP_PORT);
    117  1.10   thorpej #ifdef _HAVE_SIN_LEN
    118  1.10   thorpej 	if (sin.sin_len == 0)
    119  1.10   thorpej 		sin.sin_len = sizeof(sin);
    120  1.10   thorpej #endif
    121  1.10   thorpej 
    122  1.10   thorpej 	soc = rip_sock;
    123  1.10   thorpej 	flags = 0;
    124  1.10   thorpej 
    125  1.10   thorpej 	switch (type) {
    126  1.10   thorpej 	case OUT_QUERY:
    127  1.10   thorpej 		msg = "Answer Query";
    128  1.10   thorpej 		if (soc < 0)
    129  1.10   thorpej 			soc = ifp->int_rip_sock;
    130  1.10   thorpej 		break;
    131  1.10   thorpej 	case OUT_UNICAST:
    132  1.10   thorpej 		msg = "Send";
    133  1.10   thorpej 		if (soc < 0)
    134  1.10   thorpej 			soc = ifp->int_rip_sock;
    135  1.10   thorpej 		flags = MSG_DONTROUTE;
    136  1.10   thorpej 		break;
    137  1.10   thorpej 	case OUT_BROADCAST:
    138  1.10   thorpej 		if (ifp->int_if_flags & IFF_POINTOPOINT) {
    139  1.10   thorpej 			msg = "Send";
    140  1.10   thorpej 		} else {
    141  1.10   thorpej 			msg = "Send bcast";
    142  1.10   thorpej 		}
    143  1.10   thorpej 		flags = MSG_DONTROUTE;
    144  1.10   thorpej 		break;
    145  1.10   thorpej 	case OUT_MULTICAST:
    146  1.10   thorpej 		if (ifp->int_if_flags & IFF_POINTOPOINT) {
    147  1.10   thorpej 			msg = "Send pt-to-pt";
    148  1.10   thorpej 		} else if (ifp->int_state & IS_DUP) {
    149  1.10   thorpej 			trace_act("abort multicast output via %s"
    150  1.12  christos 				  " with duplicate address",
    151  1.10   thorpej 				  ifp->int_name);
    152  1.10   thorpej 			return 0;
    153  1.10   thorpej 		} else {
    154  1.10   thorpej 			msg = "Send mcast";
    155  1.10   thorpej 			if (rip_sock_mcast != ifp) {
    156  1.10   thorpej #ifdef MCAST_PPP_BUG
    157  1.10   thorpej 				/* Do not specifiy the primary interface
    158  1.10   thorpej 				 * explicitly if we have the multicast
    159  1.10   thorpej 				 * point-to-point kernel bug, since the
    160  1.10   thorpej 				 * kernel will do the wrong thing if the
    161  1.10   thorpej 				 * local address of a point-to-point link
    162  1.10   thorpej 				 * is the same as the address of an ordinary
    163  1.10   thorpej 				 * interface.
    164  1.10   thorpej 				 */
    165  1.10   thorpej 				if (ifp->int_addr == myaddr) {
    166  1.10   thorpej 					tgt_mcast = 0;
    167  1.10   thorpej 				} else
    168  1.10   thorpej #endif
    169  1.10   thorpej 				tgt_mcast = ifp->int_addr;
    170  1.10   thorpej 				if (0 > setsockopt(rip_sock,
    171  1.10   thorpej 						   IPPROTO_IP, IP_MULTICAST_IF,
    172  1.10   thorpej 						   &tgt_mcast,
    173  1.10   thorpej 						   sizeof(tgt_mcast))) {
    174  1.10   thorpej 					serrno = errno;
    175  1.10   thorpej 					LOGERR("setsockopt(rip_sock,"
    176  1.10   thorpej 					       "IP_MULTICAST_IF)");
    177  1.10   thorpej 					errno = serrno;
    178  1.10   thorpej 					ifp = 0;
    179  1.10   thorpej 					return -1;
    180  1.10   thorpej 				}
    181  1.10   thorpej 				rip_sock_mcast = ifp;
    182  1.10   thorpej 			}
    183  1.10   thorpej 			sin.sin_addr.s_addr = htonl(INADDR_RIP_GROUP);
    184  1.10   thorpej 		}
    185  1.12  christos 		break;
    186  1.11  christos 
    187  1.11  christos 	case NO_OUT_MULTICAST:
    188  1.11  christos 	case NO_OUT_RIPV2:
    189  1.12  christos 	default:
    190  1.12  christos #ifdef DEBUG
    191  1.12  christos 		abort();
    192  1.12  christos #endif
    193  1.12  christos 		return -1;
    194  1.10   thorpej 	}
    195  1.10   thorpej 
    196  1.10   thorpej 	trace_rip(msg, "to", &sin, ifp, buf, size);
    197  1.10   thorpej 
    198  1.10   thorpej 	res = sendto(soc, buf, size, flags,
    199  1.10   thorpej 		     (struct sockaddr *)&sin, sizeof(sin));
    200  1.10   thorpej 	if (res < 0
    201  1.10   thorpej 	    && (ifp == 0 || !(ifp->int_state & IS_BROKE))) {
    202  1.10   thorpej 		serrno = errno;
    203  1.10   thorpej 		msglog("%s sendto(%s%s%s.%d): %s", msg,
    204  1.10   thorpej 		       ifp != 0 ? ifp->int_name : "",
    205  1.10   thorpej 		       ifp != 0 ? ", " : "",
    206  1.10   thorpej 		       inet_ntoa(sin.sin_addr),
    207  1.10   thorpej 		       ntohs(sin.sin_port),
    208  1.10   thorpej 		       strerror(errno));
    209  1.10   thorpej 		errno = serrno;
    210  1.10   thorpej 	}
    211  1.10   thorpej 
    212  1.10   thorpej 	return res;
    213  1.10   thorpej }
    214  1.10   thorpej 
    215  1.10   thorpej 
    216  1.12  christos /* Find the first key for a packet to send.
    217  1.12  christos  * Try for a key that is eligable and has not expired, but settle for
    218  1.12  christos  * the last key if they have all expired.
    219  1.12  christos  * If no key is ready yet, give up.
    220  1.10   thorpej  */
    221  1.12  christos struct auth *
    222  1.12  christos find_auth(struct interface *ifp)
    223  1.12  christos {
    224  1.12  christos 	struct auth *ap, *res;
    225  1.12  christos 	int i;
    226  1.12  christos 
    227  1.12  christos 
    228  1.12  christos 	if (ifp == 0)
    229  1.12  christos 		return 0;
    230  1.12  christos 
    231  1.12  christos 	res = 0;
    232  1.12  christos 	ap = ifp->int_auth;
    233  1.12  christos 	for (i = 0; i < MAX_AUTH_KEYS; i++, ap++) {
    234  1.12  christos 		/* stop looking after the last key */
    235  1.12  christos 		if (ap->type == RIP_AUTH_NONE)
    236  1.12  christos 			break;
    237  1.12  christos 
    238  1.12  christos 		/* ignore keys that are not ready yet */
    239  1.12  christos 		if ((u_long)ap->start > (u_long)clk.tv_sec)
    240  1.12  christos 			continue;
    241  1.12  christos 
    242  1.12  christos 		if ((u_long)ap->end < (u_long)clk.tv_sec) {
    243  1.12  christos 			/* note best expired password as a fall-back */
    244  1.12  christos 			if (res == 0 || (u_long)ap->end > (u_long)res->end)
    245  1.12  christos 				res = ap;
    246  1.12  christos 			continue;
    247  1.12  christos 		}
    248  1.12  christos 
    249  1.12  christos 		/* note key with the best future */
    250  1.12  christos 		if (res == 0 || (u_long)res->end < (u_long)ap->end)
    251  1.12  christos 			res = ap;
    252  1.12  christos 	}
    253  1.12  christos 	return res;
    254  1.12  christos }
    255  1.12  christos 
    256  1.12  christos 
    257  1.12  christos void
    258  1.12  christos clr_ws_buf(struct ws_buf *wb,
    259  1.12  christos 	   struct auth *ap)
    260  1.10   thorpej {
    261  1.12  christos 	struct netauth *na;
    262  1.12  christos 
    263  1.12  christos 	wb->lim = wb->base + NETS_LEN;
    264  1.12  christos 	wb->n = wb->base;
    265  1.13     lukem 	memset(wb->n, 0, NETS_LEN*sizeof(*wb->n));
    266  1.12  christos 
    267  1.12  christos 	/* install authentication if appropriate
    268  1.12  christos 	 */
    269  1.12  christos 	if (ap == 0)
    270  1.12  christos 		return;
    271  1.12  christos 	na = (struct netauth*)wb->n;
    272  1.12  christos 	if (ap->type == RIP_AUTH_PW) {
    273  1.12  christos 		na->a_family = RIP_AF_AUTH;
    274  1.12  christos 		na->a_type = RIP_AUTH_PW;
    275  1.12  christos 		bcopy(ap->key, na->au.au_pw, sizeof(na->au.au_pw));
    276  1.12  christos 		wb->n++;
    277  1.12  christos 
    278  1.12  christos 	} else if (ap->type ==  RIP_AUTH_MD5) {
    279  1.12  christos 		na->a_family = RIP_AF_AUTH;
    280  1.12  christos 		na->a_type = RIP_AUTH_MD5;
    281  1.12  christos 		na->au.a_md5.md5_keyid = ap->keyid;
    282  1.12  christos 		na->au.a_md5.md5_auth_len = RIP_AUTH_PW_LEN;
    283  1.12  christos 		na->au.a_md5.md5_seqno = clk.tv_sec;
    284  1.12  christos 		wb->n++;
    285  1.12  christos 		wb->lim--;		/* make room for trailer */
    286  1.10   thorpej 	}
    287  1.10   thorpej }
    288  1.10   thorpej 
    289  1.10   thorpej 
    290  1.12  christos void
    291  1.12  christos end_md5_auth(struct ws_buf *wb,
    292  1.12  christos 	     struct auth *ap)
    293  1.12  christos {
    294  1.12  christos 	struct netauth *na, *na2;
    295  1.12  christos 	MD5_CTX md5_ctx;
    296  1.12  christos 
    297  1.12  christos 
    298  1.12  christos 	na = (struct netauth*)wb->base;
    299  1.12  christos 	na2 = (struct netauth*)wb->n;
    300  1.12  christos 	na2->a_family = RIP_AF_AUTH;
    301  1.12  christos 	na2->a_type = 1;
    302  1.12  christos 	bcopy(ap->key, na2->au.au_pw, sizeof(na2->au.au_pw));
    303  1.12  christos 	na->au.a_md5.md5_pkt_len = (char *)na2-(char *)(na+1);
    304  1.12  christos 	MD5Init(&md5_ctx);
    305  1.12  christos 	MD5Update(&md5_ctx, (u_char *)na,
    306  1.12  christos 		  (char *)(na2+1) - (char *)na);
    307  1.12  christos 	MD5Final(na2->au.au_pw, &md5_ctx);
    308  1.12  christos 	wb->n++;
    309  1.12  christos }
    310  1.12  christos 
    311  1.12  christos 
    312  1.10   thorpej /* Send the buffer
    313  1.10   thorpej  */
    314  1.10   thorpej static void
    315  1.10   thorpej supply_write(struct ws_buf *wb)
    316  1.10   thorpej {
    317  1.10   thorpej 	/* Output multicast only if legal.
    318  1.10   thorpej 	 * If we would multcast and it would be illegal, then discard the
    319  1.10   thorpej 	 * packet.
    320  1.10   thorpej 	 */
    321  1.10   thorpej 	switch (wb->type) {
    322  1.10   thorpej 	case NO_OUT_MULTICAST:
    323  1.12  christos 		trace_pkt("skip multicast to %s because impossible",
    324  1.10   thorpej 			  naddr_ntoa(ws.to.sin_addr.s_addr));
    325  1.10   thorpej 		break;
    326  1.10   thorpej 	case NO_OUT_RIPV2:
    327  1.10   thorpej 		break;
    328  1.10   thorpej 	default:
    329  1.12  christos 		if (ws.a != 0 && ws.a->type == RIP_AUTH_MD5)
    330  1.12  christos 			end_md5_auth(wb,ws.a);
    331  1.10   thorpej 		if (output(wb->type, &ws.to, ws.ifp, wb->buf,
    332  1.10   thorpej 			   ((char *)wb->n - (char*)wb->buf)) < 0
    333  1.10   thorpej 		    && ws.ifp != 0)
    334  1.10   thorpej 			if_sick(ws.ifp);
    335  1.10   thorpej 		ws.npackets++;
    336  1.10   thorpej 		break;
    337  1.10   thorpej 	}
    338  1.10   thorpej 
    339  1.12  christos 	clr_ws_buf(wb,ws.a);
    340  1.10   thorpej }
    341  1.10   thorpej 
    342  1.10   thorpej 
    343  1.10   thorpej /* put an entry into the packet
    344   1.1       cgd  */
    345  1.10   thorpej static void
    346  1.10   thorpej supply_out(struct ag_info *ag)
    347  1.10   thorpej {
    348  1.10   thorpej 	int i;
    349  1.12  christos 	naddr mask, v1_mask, dst_h, ddst_h = 0;
    350  1.10   thorpej 	struct ws_buf *wb;
    351  1.10   thorpej 
    352  1.10   thorpej 
    353  1.10   thorpej 	/* Skip this route if doing a flash update and it and the routes
    354  1.10   thorpej 	 * it aggregates have not changed recently.
    355  1.10   thorpej 	 */
    356  1.10   thorpej 	if (ag->ag_seqno < update_seqno
    357  1.10   thorpej 	    && (ws.state & WS_ST_FLASH))
    358  1.10   thorpej 		return;
    359  1.10   thorpej 
    360  1.11  christos 	/* Skip this route if required by split-horizon.
    361  1.10   thorpej 	 */
    362  1.10   thorpej 	if (ag->ag_state & AGS_SPLIT_HZ)
    363  1.10   thorpej 		return;
    364  1.10   thorpej 
    365  1.10   thorpej 	dst_h = ag->ag_dst_h;
    366  1.10   thorpej 	mask = ag->ag_mask;
    367  1.10   thorpej 	v1_mask = ripv1_mask_host(htonl(dst_h),
    368  1.10   thorpej 				  (ws.state & WS_ST_TO_ON_NET) ? ws.ifp : 0);
    369  1.10   thorpej 	i = 0;
    370  1.10   thorpej 
    371  1.10   thorpej 	/* If we are sending RIPv2 packets that cannot (or must not) be
    372  1.10   thorpej 	 * heard by RIPv1 listeners, do not worry about sub- or supernets.
    373  1.10   thorpej 	 * Subnets (from other networks) can only be sent via multicast.
    374  1.10   thorpej 	 * A pair of subnet routes might have been promoted so that they
    375  1.10   thorpej 	 * are legal to send by RIPv1.
    376  1.12  christos 	 * If RIPv1 is off, use the multicast buffer.
    377  1.10   thorpej 	 */
    378  1.12  christos 	if ((ws.state & WS_ST_RIP2_ALL)
    379  1.10   thorpej 	    || ((ag->ag_state & AGS_RIPV2) && v1_mask != mask)) {
    380  1.10   thorpej 		/* use the RIPv2-only buffer */
    381  1.12  christos 		wb = &v2buf;
    382  1.10   thorpej 
    383  1.10   thorpej 	} else {
    384  1.10   thorpej 		/* use the RIPv1-or-RIPv2 buffer */
    385  1.12  christos 		wb = &v12buf;
    386  1.10   thorpej 
    387  1.10   thorpej 		/* Convert supernet route into corresponding set of network
    388  1.10   thorpej 		 * routes for RIPv1, but leave non-contiguous netmasks
    389  1.10   thorpej 		 * to ag_check().
    390  1.10   thorpej 		 */
    391  1.10   thorpej 		if (v1_mask > mask
    392  1.10   thorpej 		    && mask + (mask & -mask) == 0) {
    393  1.10   thorpej 			ddst_h = v1_mask & -v1_mask;
    394  1.10   thorpej 			i = (v1_mask & ~mask)/ddst_h;
    395  1.10   thorpej 
    396  1.11  christos 			if (i > ws.gen_limit) {
    397  1.10   thorpej 				/* Punt if we would have to generate an
    398  1.10   thorpej 				 * unreasonable number of routes.
    399  1.10   thorpej 				 */
    400  1.10   thorpej #ifdef DEBUG
    401  1.11  christos 				msglog("sending %s to %s as 1 instead"
    402  1.11  christos 				       " of %d routes",
    403  1.11  christos 				       addrname(htonl(dst_h),mask,1),
    404  1.11  christos 				       naddr_ntoa(ws.to.sin_addr.s_addr),
    405  1.11  christos 				       i+1);
    406  1.10   thorpej #endif
    407  1.10   thorpej 				i = 0;
    408  1.10   thorpej 
    409  1.10   thorpej 			} else {
    410  1.10   thorpej 				mask = v1_mask;
    411  1.11  christos 				ws.gen_limit -= i;
    412  1.10   thorpej 			}
    413  1.10   thorpej 		}
    414  1.10   thorpej 	}
    415  1.10   thorpej 
    416  1.10   thorpej 	do {
    417  1.10   thorpej 		wb->n->n_family = RIP_AF_INET;
    418  1.10   thorpej 		wb->n->n_dst = htonl(dst_h);
    419  1.10   thorpej 		/* If the route is from router-discovery or we are
    420  1.10   thorpej 		 * shutting down, admit only a bad metric.
    421  1.10   thorpej 		 */
    422  1.10   thorpej 		wb->n->n_metric = ((stopint || ag->ag_metric < 1)
    423  1.10   thorpej 				   ? HOPCNT_INFINITY
    424  1.10   thorpej 				   : ag->ag_metric);
    425  1.10   thorpej 		HTONL(wb->n->n_metric);
    426  1.12  christos 		/* Any non-zero bits in the supposedly unused RIPv1 fields
    427  1.12  christos 		 * cause the old `routed` to ignore the route.
    428  1.12  christos 		 * That means the mask and so forth cannot be sent
    429  1.12  christos 		 * in the hybrid RIPv1/RIPv2 mode.
    430  1.12  christos 		 */
    431  1.12  christos 		if (ws.state & WS_ST_RIP2_ALL) {
    432  1.10   thorpej 			if (ag->ag_nhop != 0
    433  1.10   thorpej 			    && ((ws.state & WS_ST_QUERY)
    434  1.10   thorpej 				|| (ag->ag_nhop != ws.ifp->int_addr
    435  1.10   thorpej 				    && on_net(ag->ag_nhop,
    436  1.10   thorpej 					      ws.ifp->int_net,
    437  1.10   thorpej 					      ws.ifp->int_mask))))
    438  1.10   thorpej 				wb->n->n_nhop = ag->ag_nhop;
    439  1.12  christos 			wb->n->n_mask = htonl(mask);
    440  1.10   thorpej 			wb->n->n_tag = ag->ag_tag;
    441  1.10   thorpej 		}
    442  1.10   thorpej 		dst_h += ddst_h;
    443  1.10   thorpej 
    444  1.10   thorpej 		if (++wb->n >= wb->lim)
    445  1.10   thorpej 			supply_write(wb);
    446  1.10   thorpej 	} while (i-- != 0);
    447  1.10   thorpej }
    448  1.10   thorpej 
    449   1.1       cgd 
    450  1.10   thorpej /* supply one route from the table
    451   1.1       cgd  */
    452  1.10   thorpej /* ARGSUSED */
    453  1.10   thorpej static int
    454  1.11  christos walk_supply(struct radix_node *rn, struct walkarg *argp)
    455  1.10   thorpej {
    456  1.10   thorpej #define RT ((struct rt_entry *)rn)
    457  1.11  christos 	u_short ags;
    458  1.10   thorpej 	char metric, pref;
    459  1.10   thorpej 	naddr dst, nhop;
    460  1.12  christos 	struct rt_spare *rts;
    461  1.12  christos 	int i;
    462  1.10   thorpej 
    463  1.10   thorpej 
    464  1.12  christos 	/* Do not advertise external remote interfaces or passive interfaces.
    465  1.10   thorpej 	 */
    466  1.11  christos 	if ((RT->rt_state & RS_IF)
    467  1.11  christos 	    && RT->rt_ifp != 0
    468  1.12  christos 	    && (RT->rt_ifp->int_if_flags & IS_PASSIVE)
    469  1.10   thorpej 	    && !(RT->rt_state & RS_MHOME))
    470  1.10   thorpej 		return 0;
    471  1.10   thorpej 
    472  1.10   thorpej 	/* If being quiet about our ability to forward, then
    473  1.12  christos 	 * do not say anything unless responding to a query,
    474  1.12  christos 	 * except about our main interface.
    475  1.10   thorpej 	 */
    476  1.12  christos 	if (!supplier && !(ws.state & WS_ST_QUERY)
    477  1.12  christos 	    && !(RT->rt_state & RS_MHOME))
    478  1.10   thorpej 		return 0;
    479  1.10   thorpej 
    480  1.10   thorpej 	dst = RT->rt_dst;
    481  1.10   thorpej 
    482  1.10   thorpej 	/* do not collide with the fake default route */
    483  1.10   thorpej 	if (dst == RIP_DEFAULT
    484  1.10   thorpej 	    && (ws.state & WS_ST_DEFAULT))
    485  1.10   thorpej 		return 0;
    486  1.10   thorpej 
    487  1.10   thorpej 	if (RT->rt_state & RS_NET_SYN) {
    488  1.10   thorpej 		if (RT->rt_state & RS_NET_INT) {
    489  1.10   thorpej 			/* Do not send manual synthetic network routes
    490  1.10   thorpej 			 * into the subnet.
    491  1.10   thorpej 			 */
    492  1.10   thorpej 			if (on_net(ws.to.sin_addr.s_addr,
    493  1.10   thorpej 				   ntohl(dst), RT->rt_mask))
    494  1.10   thorpej 				return 0;
    495  1.10   thorpej 
    496  1.10   thorpej 		} else {
    497  1.10   thorpej 			/* Do not send automatic synthetic network routes
    498  1.10   thorpej 			 * if they are not needed becaus no RIPv1 listeners
    499  1.10   thorpej 			 * can hear them.
    500  1.10   thorpej 			 */
    501  1.10   thorpej 			if (ws.state & WS_ST_RIP2_ALL)
    502  1.10   thorpej 				return 0;
    503  1.10   thorpej 
    504  1.10   thorpej 			/* Do not send automatic synthetic network routes to
    505  1.10   thorpej 			 * the real subnet.
    506  1.10   thorpej 			 */
    507  1.10   thorpej 			if (on_net(ws.to.sin_addr.s_addr,
    508  1.10   thorpej 				   ntohl(dst), RT->rt_mask))
    509  1.10   thorpej 				return 0;
    510  1.10   thorpej 		}
    511  1.10   thorpej 		nhop = 0;
    512  1.10   thorpej 
    513  1.10   thorpej 	} else {
    514  1.10   thorpej 		/* Advertise the next hop if this is not a route for one
    515  1.10   thorpej 		 * of our interfaces and the next hop is on the same
    516  1.10   thorpej 		 * network as the target.
    517  1.10   thorpej 		 */
    518  1.10   thorpej 		if (!(RT->rt_state & RS_IF)
    519  1.10   thorpej 		    && RT->rt_gate != myaddr
    520  1.10   thorpej 		    && RT->rt_gate != loopaddr)
    521  1.10   thorpej 			nhop = RT->rt_gate;
    522  1.10   thorpej 		else
    523  1.10   thorpej 			nhop = 0;
    524  1.10   thorpej 	}
    525  1.10   thorpej 
    526  1.11  christos 	metric = RT->rt_metric;
    527  1.11  christos 	ags = 0;
    528  1.10   thorpej 
    529  1.10   thorpej 	if (RT->rt_state & RS_MHOME) {
    530  1.10   thorpej 		/* retain host route of multi-homed servers */
    531  1.10   thorpej 		;
    532  1.10   thorpej 
    533  1.10   thorpej 	} else if (RT_ISHOST(RT)) {
    534  1.10   thorpej 		/* We should always aggregate the host routes
    535  1.10   thorpej 		 * for the local end of our point-to-point links.
    536  1.10   thorpej 		 * If we are suppressing host routes in general, then do so.
    537  1.10   thorpej 		 * Avoid advertising host routes onto their own network,
    538  1.10   thorpej 		 * where they should be handled by proxy-ARP.
    539  1.10   thorpej 		 */
    540  1.10   thorpej 		if ((RT->rt_state & RS_LOCAL)
    541  1.10   thorpej 		    || ridhosts
    542  1.10   thorpej 		    || (ws.state & WS_ST_SUPER_AG)
    543  1.10   thorpej 		    || on_net(dst, ws.to_net, ws.to_mask))
    544  1.10   thorpej 			ags |= AGS_SUPPRESS;
    545  1.10   thorpej 
    546  1.10   thorpej 		if (ws.state & WS_ST_SUPER_AG)
    547  1.10   thorpej 			ags |= AGS_PROMOTE;
    548  1.10   thorpej 
    549  1.10   thorpej 	} else if (ws.state & WS_ST_AG) {
    550  1.10   thorpej 		/* Aggregate network routes, if we are allowed.
    551  1.10   thorpej 		 */
    552  1.10   thorpej 		ags |= AGS_SUPPRESS;
    553  1.10   thorpej 
    554  1.10   thorpej 		/* Generate supernets if allowed.
    555  1.10   thorpej 		 * If we can be heard by RIPv1 systems, we will
    556  1.10   thorpej 		 * later convert back to ordinary nets.
    557  1.10   thorpej 		 * This unifies dealing with received supernets.
    558  1.10   thorpej 		 */
    559  1.10   thorpej 		if ((RT->rt_state & RS_SUBNET)
    560  1.10   thorpej 		    || (ws.state & WS_ST_SUPER_AG))
    561  1.10   thorpej 			ags |= AGS_PROMOTE;
    562  1.10   thorpej 
    563  1.10   thorpej 	}
    564  1.10   thorpej 
    565  1.10   thorpej 	/* Do not send RIPv1 advertisements of subnets to other
    566  1.10   thorpej 	 * networks. If possible, multicast them by RIPv2.
    567  1.10   thorpej 	 */
    568  1.10   thorpej 	if ((RT->rt_state & RS_SUBNET)
    569  1.10   thorpej 	    && !(ws.state & WS_ST_RIP2_ALL)
    570  1.10   thorpej 	    && !on_net(dst, ws.to_std_net, ws.to_std_mask)) {
    571  1.10   thorpej 		ags |= AGS_RIPV2 | AGS_PROMOTE;
    572  1.10   thorpej 		if (ws.state & WS_ST_SUB_AG)
    573  1.10   thorpej 			ags |= AGS_SUPPRESS;
    574  1.10   thorpej 	}
    575   1.1       cgd 
    576  1.10   thorpej 	/* Do not send a route back to where it came from, except in
    577  1.10   thorpej 	 * response to a query.  This is "split-horizon".  That means not
    578  1.10   thorpej 	 * advertising back to the same network	and so via the same interface.
    579  1.10   thorpej 	 *
    580  1.10   thorpej 	 * We want to suppress routes that might have been fragmented
    581  1.10   thorpej 	 * from this route by a RIPv1 router and sent back to us, and so we
    582  1.10   thorpej 	 * cannot forget this route here.  Let the split-horizon route
    583  1.10   thorpej 	 * aggregate (suppress) the fragmented routes and then itself be
    584  1.10   thorpej 	 * forgotten.
    585  1.10   thorpej 	 *
    586  1.10   thorpej 	 * Include the routes for both ends of point-to-point interfaces
    587  1.12  christos 	 * among those suppressed by split-horizon, since the other side
    588  1.12  christos 	 * should knows them as well as we do.
    589  1.12  christos 	 *
    590  1.12  christos 	 * Notice spare routes with the same metric that we are about to
    591  1.12  christos 	 * advertise, to split the horizon on redunant, inactive paths.
    592  1.10   thorpej 	 */
    593  1.12  christos 	if (ws.ifp != 0
    594  1.10   thorpej 	    && !(ws.state & WS_ST_QUERY)
    595  1.10   thorpej 	    && (ws.state & WS_ST_TO_ON_NET)
    596  1.10   thorpej 	    && (!(RT->rt_state & RS_IF)
    597  1.10   thorpej 		|| ws.ifp->int_if_flags & IFF_POINTOPOINT)) {
    598  1.12  christos 		for (rts = RT->rt_spares, i = NUM_SPARES; i != 0; i--, rts++) {
    599  1.12  christos 			if (rts->rts_ifp == ws.ifp
    600  1.12  christos 			    && rts->rts_metric <= metric)
    601  1.12  christos 				break;
    602  1.12  christos 		}
    603  1.12  christos 		if (i != 0) {
    604  1.12  christos 			/* If we do not mark the route with AGS_SPLIT_HZ here,
    605  1.12  christos 			 * it will be poisoned-reverse, or advertised back
    606  1.12  christos 			 * toward its source with an infinite metric.
    607  1.12  christos 			 * If we have recently advertised the route with a
    608  1.12  christos 			 * better metric than we now have, then we should
    609  1.12  christos 			 * poison-reverse the route before suppressing it for
    610  1.12  christos 			 * split-horizon.
    611  1.12  christos 			 *
    612  1.12  christos 			 * In almost all cases, if there is no spare for the
    613  1.12  christos 			 * route then it is either old and dead or a brand
    614  1.12  christos 			 * new route. If it is brand new, there is no need
    615  1.12  christos 			 * for poison-reverse. If it is old and dead, it
    616  1.12  christos 			 * is already poisoned.
    617  1.12  christos 			 */
    618  1.12  christos 			if (RT->rt_poison_time < now_expire
    619  1.12  christos 			    || RT->rt_poison_metric >= metric
    620  1.12  christos 			    || RT->rt_spares[1].rts_gate == 0) {
    621  1.12  christos 				ags |= AGS_SPLIT_HZ;
    622  1.12  christos 				ags &= ~(AGS_PROMOTE | AGS_SUPPRESS);
    623  1.12  christos 			}
    624  1.12  christos 			metric = HOPCNT_INFINITY;
    625  1.11  christos 		}
    626  1.11  christos 	}
    627  1.11  christos 
    628  1.12  christos 	/* Keep track of the best metric with which the
    629  1.12  christos 	 * route has been advertised recently.
    630  1.12  christos 	 */
    631  1.12  christos 	if (RT->rt_poison_metric >= metric
    632  1.12  christos 	    || RT->rt_poison_time < now_expire) {
    633  1.12  christos 		RT->rt_poison_time = now.tv_sec;
    634  1.12  christos 		RT->rt_poison_metric = metric;
    635  1.12  christos 	}
    636  1.12  christos 
    637  1.11  christos 	/* Adjust the outgoing metric by the cost of the link.
    638  1.12  christos 	 * Avoid aggregation when a route is counting to infinity.
    639  1.11  christos 	 */
    640  1.12  christos 	pref = RT->rt_poison_metric + ws.metric;
    641  1.12  christos 	metric += ws.metric;
    642  1.11  christos 
    643  1.12  christos 	/* Do not advertise stable routes that will be ignored,
    644  1.12  christos 	 * unless we are answering a query.
    645  1.12  christos 	 * If the route recently was advertised with a metric that
    646  1.12  christos 	 * would have been less than infinity through this interface,
    647  1.12  christos 	 * we need to continue to advertise it in order to poison it.
    648  1.12  christos 	 */
    649  1.12  christos 	if (metric >= HOPCNT_INFINITY) {
    650  1.12  christos 		if (!(ws.state & WS_ST_QUERY)
    651  1.12  christos 		    && (pref >= HOPCNT_INFINITY
    652  1.12  christos 			|| RT->rt_poison_time < now_garbage))
    653  1.11  christos 			return 0;
    654  1.11  christos 
    655  1.11  christos 		metric = HOPCNT_INFINITY;
    656   1.1       cgd 	}
    657  1.10   thorpej 
    658  1.10   thorpej 	ag_check(dst, RT->rt_mask, 0, nhop, metric, pref,
    659  1.10   thorpej 		 RT->rt_seqno, RT->rt_tag, ags, supply_out);
    660  1.10   thorpej 	return 0;
    661  1.10   thorpej #undef RT
    662   1.1       cgd }
    663   1.1       cgd 
    664  1.10   thorpej 
    665  1.10   thorpej /* Supply dst with the contents of the routing tables.
    666  1.10   thorpej  * If this won't fit in one packet, chop it up into several.
    667   1.1       cgd  */
    668   1.9  christos void
    669  1.10   thorpej supply(struct sockaddr_in *dst,
    670  1.10   thorpej        struct interface *ifp,		/* output interface */
    671  1.10   thorpej        enum output_type type,
    672  1.10   thorpej        int flash,			/* 1=flash update */
    673  1.12  christos        int vers,			/* RIP version */
    674  1.12  christos        int passwd_ok)			/* OK to include cleartext password */
    675   1.1       cgd {
    676  1.10   thorpej 	struct rt_entry *rt;
    677  1.12  christos 	int def_metric;
    678  1.10   thorpej 
    679  1.10   thorpej 
    680  1.10   thorpej 	ws.state = 0;
    681  1.11  christos 	ws.gen_limit = 1024;
    682  1.10   thorpej 
    683  1.10   thorpej 	ws.to = *dst;
    684  1.10   thorpej 	ws.to_std_mask = std_mask(ws.to.sin_addr.s_addr);
    685  1.10   thorpej 	ws.to_std_net = ntohl(ws.to.sin_addr.s_addr) & ws.to_std_mask;
    686  1.10   thorpej 
    687  1.10   thorpej 	if (ifp != 0) {
    688  1.10   thorpej 		ws.to_mask = ifp->int_mask;
    689  1.10   thorpej 		ws.to_net = ifp->int_net;
    690  1.10   thorpej 		if (on_net(ws.to.sin_addr.s_addr, ws.to_net, ws.to_mask))
    691  1.10   thorpej 			ws.state |= WS_ST_TO_ON_NET;
    692  1.10   thorpej 
    693  1.10   thorpej 	} else {
    694  1.10   thorpej 		ws.to_mask = ripv1_mask_net(ws.to.sin_addr.s_addr, 0);
    695  1.10   thorpej 		ws.to_net = ntohl(ws.to.sin_addr.s_addr) & ws.to_mask;
    696  1.10   thorpej 		rt = rtfind(dst->sin_addr.s_addr);
    697  1.10   thorpej 		if (rt)
    698  1.10   thorpej 			ifp = rt->rt_ifp;
    699  1.10   thorpej 	}
    700  1.10   thorpej 
    701  1.10   thorpej 	ws.npackets = 0;
    702  1.10   thorpej 	if (flash)
    703  1.10   thorpej 		ws.state |= WS_ST_FLASH;
    704  1.10   thorpej 	if (type == OUT_QUERY)
    705  1.10   thorpej 		ws.state |= WS_ST_QUERY;
    706  1.10   thorpej 
    707  1.10   thorpej 	if ((ws.ifp = ifp) == 0) {
    708  1.10   thorpej 		ws.metric = 1;
    709  1.10   thorpej 	} else {
    710  1.10   thorpej 		/* Adjust the advertised metric by the outgoing interface
    711  1.10   thorpej 		 * metric.
    712  1.10   thorpej 		 */
    713  1.10   thorpej 		ws.metric = ifp->int_metric+1;
    714  1.10   thorpej 	}
    715  1.10   thorpej 
    716  1.10   thorpej 	ripv12_buf.rip.rip_vers = vers;
    717  1.10   thorpej 
    718  1.10   thorpej 	switch (type) {
    719  1.10   thorpej 	case OUT_BROADCAST:
    720  1.12  christos 		v2buf.type = ((ifp != 0 && (ifp->int_if_flags & IFF_MULTICAST))
    721  1.10   thorpej 			      ? OUT_MULTICAST
    722  1.10   thorpej 			      : NO_OUT_MULTICAST);
    723  1.12  christos 		v12buf.type = OUT_BROADCAST;
    724  1.10   thorpej 		break;
    725  1.10   thorpej 	case OUT_MULTICAST:
    726  1.12  christos 		v2buf.type = ((ifp != 0 && (ifp->int_if_flags & IFF_MULTICAST))
    727  1.10   thorpej 			      ? OUT_MULTICAST
    728  1.10   thorpej 			      : NO_OUT_MULTICAST);
    729  1.12  christos 		v12buf.type = OUT_BROADCAST;
    730  1.10   thorpej 		break;
    731  1.10   thorpej 	case OUT_UNICAST:
    732  1.10   thorpej 	case OUT_QUERY:
    733  1.12  christos 		v2buf.type = (vers == RIPv2) ? type : NO_OUT_RIPV2;
    734  1.12  christos 		v12buf.type = type;
    735  1.10   thorpej 		break;
    736  1.10   thorpej 	default:
    737  1.12  christos 		v2buf.type = type;
    738  1.12  christos 		v12buf.type = type;
    739  1.10   thorpej 		break;
    740  1.10   thorpej 	}
    741  1.10   thorpej 
    742  1.10   thorpej 	if (vers == RIPv2) {
    743  1.10   thorpej 		/* full RIPv2 only if cannot be heard by RIPv1 listeners */
    744  1.10   thorpej 		if (type != OUT_BROADCAST)
    745  1.10   thorpej 			ws.state |= WS_ST_RIP2_ALL;
    746  1.10   thorpej 		if (!(ws.state & WS_ST_TO_ON_NET)) {
    747  1.10   thorpej 			ws.state |= (WS_ST_AG | WS_ST_SUPER_AG);
    748  1.12  christos 		} else if (ifp == 0 || !(ifp->int_state & IS_NO_AG)) {
    749  1.10   thorpej 			ws.state |= WS_ST_AG;
    750  1.10   thorpej 			if (type != OUT_BROADCAST
    751  1.12  christos 			    && (ifp == 0 || !(ifp->int_state&IS_NO_SUPER_AG)))
    752  1.10   thorpej 				ws.state |= WS_ST_SUPER_AG;
    753  1.10   thorpej 		}
    754  1.10   thorpej 
    755  1.12  christos 	} else if (ifp == 0 || !(ifp->int_state & IS_NO_AG)) {
    756  1.10   thorpej 		ws.state |= WS_ST_SUB_AG;
    757  1.10   thorpej 	}
    758  1.10   thorpej 
    759  1.12  christos 	ws.a = (vers == RIPv2) ? find_auth(ifp) : 0;
    760  1.12  christos 	if (!passwd_ok && ws.a != 0 && ws.a->type == RIP_AUTH_PW)
    761  1.12  christos 		ws.a = 0;
    762  1.12  christos 	clr_ws_buf(&v12buf,ws.a);
    763  1.12  christos 	clr_ws_buf(&v2buf,ws.a);
    764  1.12  christos 
    765  1.12  christos 	/*  Fake a default route if asked and if there is not already
    766  1.12  christos 	 * a better, real default route.
    767  1.12  christos 	 */
    768  1.12  christos 	if (supplier && (def_metric = ifp->int_d_metric) != 0) {
    769  1.12  christos 		if (0 == (rt = rtget(RIP_DEFAULT, 0))
    770  1.12  christos 		    || rt->rt_metric+ws.metric >= def_metric) {
    771  1.10   thorpej 			ws.state |= WS_ST_DEFAULT;
    772  1.12  christos 			ag_check(0, 0, 0, 0, def_metric, def_metric,
    773  1.10   thorpej 				 0, 0, 0, supply_out);
    774  1.12  christos 		} else {
    775  1.12  christos 			def_metric = rt->rt_metric+ws.metric;
    776  1.10   thorpej 		}
    777  1.12  christos 
    778  1.12  christos 		/* If both RIPv2 and the poor-man's router discovery
    779  1.12  christos 		 * kludge are on, arrange to advertise an extra
    780  1.12  christos 		 * default route via RIPv1.
    781  1.12  christos 		 */
    782  1.10   thorpej 		if ((ws.state & WS_ST_RIP2_ALL)
    783  1.10   thorpej 		    && (ifp->int_state & IS_PM_RDISC)) {
    784  1.10   thorpej 			ripv12_buf.rip.rip_vers = RIPv1;
    785  1.12  christos 			v12buf.n->n_family = RIP_AF_INET;
    786  1.12  christos 			v12buf.n->n_dst = htonl(RIP_DEFAULT);
    787  1.12  christos 			v12buf.n->n_metric = htonl(def_metric);
    788  1.12  christos 			v12buf.n++;
    789  1.10   thorpej 		}
    790  1.10   thorpej 	}
    791  1.10   thorpej 
    792  1.10   thorpej 	(void)rn_walktree(rhead, walk_supply, 0);
    793  1.10   thorpej 	ag_flush(0,0,supply_out);
    794   1.1       cgd 
    795  1.10   thorpej 	/* Flush the packet buffers, provided they are not empty and
    796  1.10   thorpej 	 * do not contain only the password.
    797  1.10   thorpej 	 */
    798  1.12  christos 	if (v12buf.n != v12buf.base
    799  1.12  christos 	    && (v12buf.n > v12buf.base+1
    800  1.12  christos 		|| v12buf.base->n_family != RIP_AF_AUTH))
    801  1.12  christos 		supply_write(&v12buf);
    802  1.12  christos 	if (v2buf.n != v2buf.base
    803  1.12  christos 	    && (v2buf.n > v2buf.base+1
    804  1.12  christos 		|| v2buf.base->n_family != RIP_AF_AUTH))
    805  1.12  christos 		supply_write(&v2buf);
    806  1.10   thorpej 
    807  1.10   thorpej 	/* If we sent nothing and this is an answer to a query, send
    808  1.10   thorpej 	 * an empty buffer.
    809  1.10   thorpej 	 */
    810  1.10   thorpej 	if (ws.npackets == 0
    811  1.10   thorpej 	    && (ws.state & WS_ST_QUERY))
    812  1.12  christos 		supply_write(&v12buf);
    813   1.1       cgd }
    814   1.1       cgd 
    815  1.10   thorpej 
    816  1.10   thorpej /* send all of the routing table or just do a flash update
    817   1.1       cgd  */
    818   1.9  christos void
    819  1.10   thorpej rip_bcast(int flash)
    820  1.10   thorpej {
    821  1.10   thorpej #ifdef _HAVE_SIN_LEN
    822  1.10   thorpej 	static struct sockaddr_in dst = {sizeof(dst), AF_INET};
    823  1.10   thorpej #else
    824  1.10   thorpej 	static struct sockaddr_in dst = {AF_INET};
    825  1.10   thorpej #endif
    826   1.9  christos 	struct interface *ifp;
    827  1.10   thorpej 	enum output_type type;
    828  1.10   thorpej 	int vers;
    829  1.10   thorpej 	struct timeval rtime;
    830  1.10   thorpej 
    831  1.10   thorpej 
    832  1.10   thorpej 	need_flash = 0;
    833  1.10   thorpej 	intvl_random(&rtime, MIN_WAITTIME, MAX_WAITTIME);
    834  1.10   thorpej 	no_flash = rtime;
    835  1.10   thorpej 	timevaladd(&no_flash, &now);
    836  1.10   thorpej 
    837  1.10   thorpej 	if (rip_sock < 0)
    838  1.10   thorpej 		return;
    839  1.10   thorpej 
    840  1.12  christos 	trace_act("send %s and inhibit dynamic updates for %.3f sec",
    841  1.10   thorpej 		  flash ? "dynamic update" : "all routes",
    842  1.10   thorpej 		  rtime.tv_sec + ((float)rtime.tv_usec)/1000000.0);
    843  1.10   thorpej 
    844  1.10   thorpej 	for (ifp = ifnet; ifp != 0; ifp = ifp->int_next) {
    845  1.12  christos 		/* Skip interfaces not doing RIP.
    846  1.12  christos 		 * Do try broken interfaces to see if they have healed.
    847   1.1       cgd 		 */
    848  1.12  christos 		if (IS_RIP_OUT_OFF(ifp->int_state))
    849   1.1       cgd 			continue;
    850  1.10   thorpej 
    851  1.10   thorpej 		/* skip turned off interfaces */
    852  1.10   thorpej 		if (!iff_alive(ifp->int_if_flags))
    853   1.1       cgd 			continue;
    854  1.10   thorpej 
    855  1.12  christos 		vers = (ifp->int_state & IS_NO_RIPV1_OUT) ? RIPv2 : RIPv1;
    856  1.10   thorpej 
    857  1.10   thorpej 		if (ifp->int_if_flags & IFF_BROADCAST) {
    858  1.10   thorpej 			/* ordinary, hardware interface */
    859  1.10   thorpej 			dst.sin_addr.s_addr = ifp->int_brdaddr;
    860  1.12  christos 
    861  1.12  christos 			/* If RIPv1 is not turned off, then broadcast so
    862  1.10   thorpej 			 * that RIPv1 listeners can hear.
    863  1.10   thorpej 			 */
    864  1.10   thorpej 			if (vers == RIPv2
    865  1.10   thorpej 			    && (ifp->int_state & IS_NO_RIPV1_OUT)) {
    866  1.10   thorpej 				type = OUT_MULTICAST;
    867  1.10   thorpej 			} else {
    868  1.10   thorpej 				type = OUT_BROADCAST;
    869  1.10   thorpej 			}
    870  1.10   thorpej 
    871  1.10   thorpej 		} else if (ifp->int_if_flags & IFF_POINTOPOINT) {
    872  1.10   thorpej 			/* point-to-point hardware interface */
    873  1.10   thorpej 			dst.sin_addr.s_addr = ifp->int_dstaddr;
    874  1.10   thorpej 			type = OUT_UNICAST;
    875  1.10   thorpej 
    876  1.12  christos 		} else if (ifp->int_state & IS_REMOTE) {
    877  1.10   thorpej 			/* remote interface */
    878  1.10   thorpej 			dst.sin_addr.s_addr = ifp->int_addr;
    879  1.10   thorpej 			type = OUT_UNICAST;
    880  1.12  christos 
    881  1.12  christos 		} else {
    882  1.12  christos 			/* ATM, HIPPI, etc. */
    883  1.12  christos 			continue;
    884  1.10   thorpej 		}
    885  1.10   thorpej 
    886  1.12  christos 		supply(&dst, ifp, type, flash, vers, 1);
    887  1.10   thorpej 	}
    888  1.10   thorpej 
    889  1.10   thorpej 	update_seqno++;			/* all routes are up to date */
    890  1.10   thorpej }
    891  1.10   thorpej 
    892  1.10   thorpej 
    893  1.10   thorpej /* Ask for routes
    894  1.10   thorpej  * Do it only once to an interface, and not even after the interface
    895  1.10   thorpej  * was broken and recovered.
    896  1.10   thorpej  */
    897  1.10   thorpej void
    898  1.10   thorpej rip_query(void)
    899  1.10   thorpej {
    900  1.10   thorpej #ifdef _HAVE_SIN_LEN
    901  1.10   thorpej 	static struct sockaddr_in dst = {sizeof(dst), AF_INET};
    902  1.10   thorpej #else
    903  1.10   thorpej 	static struct sockaddr_in dst = {AF_INET};
    904  1.10   thorpej #endif
    905  1.10   thorpej 	struct interface *ifp;
    906  1.10   thorpej 	struct rip buf;
    907  1.10   thorpej 	enum output_type type;
    908  1.10   thorpej 
    909  1.10   thorpej 
    910  1.10   thorpej 	if (rip_sock < 0)
    911  1.10   thorpej 		return;
    912  1.10   thorpej 
    913  1.13     lukem 	memset(&buf, 0, sizeof(buf));
    914  1.10   thorpej 
    915  1.10   thorpej 	for (ifp = ifnet; ifp; ifp = ifp->int_next) {
    916  1.12  christos 		/* Skip interfaces those already queried.
    917  1.12  christos 		 * Do not ask via interfaces through which we don't
    918  1.12  christos 		 * accept input.  Do not ask via interfaces that cannot
    919  1.12  christos 		 * send RIP packets.
    920  1.12  christos 		 * Do try broken interfaces to see if they have healed.
    921   1.1       cgd 		 */
    922  1.12  christos 		if (IS_RIP_IN_OFF(ifp->int_state)
    923  1.12  christos 		    || ifp->int_query_time != NEVER)
    924  1.10   thorpej 			continue;
    925  1.10   thorpej 
    926  1.10   thorpej 		/* skip turned off interfaces */
    927  1.10   thorpej 		if (!iff_alive(ifp->int_if_flags))
    928   1.1       cgd 			continue;
    929  1.10   thorpej 
    930  1.12  christos 		buf.rip_vers = (ifp->int_state&IS_NO_RIPV1_OUT) ? RIPv2:RIPv1;
    931  1.10   thorpej 		buf.rip_cmd = RIPCMD_REQUEST;
    932  1.10   thorpej 		buf.rip_nets[0].n_family = RIP_AF_UNSPEC;
    933  1.10   thorpej 		buf.rip_nets[0].n_metric = htonl(HOPCNT_INFINITY);
    934  1.10   thorpej 
    935  1.10   thorpej 		if (ifp->int_if_flags & IFF_BROADCAST) {
    936  1.10   thorpej 			/* ordinary, hardware interface */
    937  1.10   thorpej 			dst.sin_addr.s_addr = ifp->int_brdaddr;
    938  1.10   thorpej 			/* if RIPv1 is not turned off, then broadcast so
    939  1.10   thorpej 			 * that RIPv1 listeners can hear.
    940   1.1       cgd 			 */
    941  1.10   thorpej 			if (buf.rip_vers == RIPv2
    942  1.10   thorpej 			    && (ifp->int_state & IS_NO_RIPV1_OUT)) {
    943  1.10   thorpej 				type = OUT_MULTICAST;
    944  1.10   thorpej 			} else {
    945  1.10   thorpej 				type = OUT_BROADCAST;
    946  1.10   thorpej 			}
    947  1.10   thorpej 
    948  1.10   thorpej 		} else if (ifp->int_if_flags & IFF_POINTOPOINT) {
    949  1.10   thorpej 			/* point-to-point hardware interface */
    950  1.10   thorpej 			dst.sin_addr.s_addr = ifp->int_dstaddr;
    951  1.10   thorpej 			type = OUT_UNICAST;
    952  1.10   thorpej 
    953  1.12  christos 		} else if (ifp->int_state & IS_REMOTE) {
    954  1.10   thorpej 			/* remote interface */
    955  1.10   thorpej 			dst.sin_addr.s_addr = ifp->int_addr;
    956  1.10   thorpej 			type = OUT_UNICAST;
    957  1.12  christos 
    958  1.12  christos 		} else {
    959  1.12  christos 			/* ATM, HIPPI, etc. */
    960  1.12  christos 			continue;
    961  1.10   thorpej 		}
    962  1.10   thorpej 
    963  1.12  christos 		ifp->int_query_time = now.tv_sec+SUPPLY_INTERVAL;
    964  1.10   thorpej 		if (output(type, &dst, ifp, &buf, sizeof(buf)) < 0)
    965  1.10   thorpej 			if_sick(ifp);
    966   1.1       cgd 	}
    967   1.1       cgd }
    968