Home | History | Annotate | Line # | Download | only in netinet
ip_input.c revision 1.7
      1  1.1      cgd /*
      2  1.1      cgd  * Copyright (c) 1982, 1986, 1988 Regents of the University of California.
      3  1.1      cgd  * All rights reserved.
      4  1.1      cgd  *
      5  1.1      cgd  * Redistribution and use in source and binary forms, with or without
      6  1.1      cgd  * modification, are permitted provided that the following conditions
      7  1.1      cgd  * are met:
      8  1.1      cgd  * 1. Redistributions of source code must retain the above copyright
      9  1.1      cgd  *    notice, this list of conditions and the following disclaimer.
     10  1.1      cgd  * 2. Redistributions in binary form must reproduce the above copyright
     11  1.1      cgd  *    notice, this list of conditions and the following disclaimer in the
     12  1.1      cgd  *    documentation and/or other materials provided with the distribution.
     13  1.1      cgd  * 3. All advertising materials mentioning features or use of this software
     14  1.1      cgd  *    must display the following acknowledgement:
     15  1.1      cgd  *	This product includes software developed by the University of
     16  1.1      cgd  *	California, Berkeley and its contributors.
     17  1.1      cgd  * 4. Neither the name of the University nor the names of its contributors
     18  1.1      cgd  *    may be used to endorse or promote products derived from this software
     19  1.1      cgd  *    without specific prior written permission.
     20  1.1      cgd  *
     21  1.1      cgd  * THIS SOFTWARE IS PROVIDED BY THE REGENTS AND CONTRIBUTORS ``AS IS'' AND
     22  1.1      cgd  * ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
     23  1.1      cgd  * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE
     24  1.1      cgd  * ARE DISCLAIMED.  IN NO EVENT SHALL THE REGENTS OR CONTRIBUTORS BE LIABLE
     25  1.1      cgd  * FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL
     26  1.1      cgd  * DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS
     27  1.1      cgd  * OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION)
     28  1.1      cgd  * HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT
     29  1.1      cgd  * LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY
     30  1.1      cgd  * OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF
     31  1.1      cgd  * SUCH DAMAGE.
     32  1.1      cgd  *
     33  1.3      cgd  *	from: @(#)ip_input.c	7.19 (Berkeley) 5/25/91
     34  1.7  mycroft  *	$Id: ip_input.c,v 1.7 1994/01/08 23:50:45 mycroft Exp $
     35  1.1      cgd  */
     36  1.1      cgd 
     37  1.5  mycroft #include <sys/param.h>
     38  1.5  mycroft #include <sys/systm.h>
     39  1.5  mycroft #include <sys/malloc.h>
     40  1.5  mycroft #include <sys/mbuf.h>
     41  1.5  mycroft #include <sys/domain.h>
     42  1.5  mycroft #include <sys/protosw.h>
     43  1.5  mycroft #include <sys/socket.h>
     44  1.5  mycroft #include <sys/errno.h>
     45  1.5  mycroft #include <sys/time.h>
     46  1.5  mycroft #include <sys/kernel.h>
     47  1.1      cgd 
     48  1.5  mycroft #include <net/if.h>
     49  1.5  mycroft #include <net/route.h>
     50  1.1      cgd 
     51  1.5  mycroft #include <netinet/in.h>
     52  1.5  mycroft #include <netinet/in_systm.h>
     53  1.5  mycroft #include <netinet/ip.h>
     54  1.5  mycroft #include <netinet/in_pcb.h>
     55  1.5  mycroft #include <netinet/in_var.h>
     56  1.5  mycroft #include <netinet/ip_var.h>
     57  1.5  mycroft #include <netinet/ip_icmp.h>
     58  1.1      cgd 
     59  1.1      cgd #ifndef	IPFORWARDING
     60  1.1      cgd #ifdef GATEWAY
     61  1.1      cgd #define	IPFORWARDING	1	/* forward IP packets not for us */
     62  1.1      cgd #else /* GATEWAY */
     63  1.1      cgd #define	IPFORWARDING	0	/* don't forward IP packets not for us */
     64  1.1      cgd #endif /* GATEWAY */
     65  1.1      cgd #endif /* IPFORWARDING */
     66  1.1      cgd #ifndef	IPSENDREDIRECTS
     67  1.1      cgd #define	IPSENDREDIRECTS	1
     68  1.1      cgd #endif
     69  1.1      cgd int	ipforwarding = IPFORWARDING;
     70  1.1      cgd int	ipsendredirects = IPSENDREDIRECTS;
     71  1.1      cgd #ifdef DIAGNOSTIC
     72  1.1      cgd int	ipprintfs = 0;
     73  1.1      cgd #endif
     74  1.1      cgd 
     75  1.1      cgd extern	struct domain inetdomain;
     76  1.1      cgd extern	struct protosw inetsw[];
     77  1.1      cgd u_char	ip_protox[IPPROTO_MAX];
     78  1.1      cgd int	ipqmaxlen = IFQ_MAXLEN;
     79  1.1      cgd struct	in_ifaddr *in_ifaddr;			/* first inet address */
     80  1.1      cgd 
     81  1.1      cgd /*
     82  1.1      cgd  * We need to save the IP options in case a protocol wants to respond
     83  1.1      cgd  * to an incoming packet over the same route if the packet got here
     84  1.1      cgd  * using IP source routing.  This allows connection establishment and
     85  1.1      cgd  * maintenance when the remote end is on a network that is not known
     86  1.1      cgd  * to us.
     87  1.1      cgd  */
     88  1.1      cgd int	ip_nhops = 0;
     89  1.1      cgd static	struct ip_srcrt {
     90  1.1      cgd 	struct	in_addr dst;			/* final destination */
     91  1.1      cgd 	char	nop;				/* one NOP to align */
     92  1.1      cgd 	char	srcopt[IPOPT_OFFSET + 1];	/* OPTVAL, OLEN and OFFSET */
     93  1.1      cgd 	struct	in_addr route[MAX_IPOPTLEN/sizeof(struct in_addr)];
     94  1.1      cgd } ip_srcrt;
     95  1.1      cgd 
     96  1.1      cgd #ifdef GATEWAY
     97  1.1      cgd extern	int if_index;
     98  1.1      cgd u_long	*ip_ifmatrix;
     99  1.1      cgd #endif
    100  1.1      cgd 
    101  1.1      cgd /*
    102  1.1      cgd  * IP initialization: fill in IP protocol switch table.
    103  1.1      cgd  * All protocols not implemented in kernel go to raw IP protocol handler.
    104  1.1      cgd  */
    105  1.1      cgd ip_init()
    106  1.1      cgd {
    107  1.1      cgd 	register struct protosw *pr;
    108  1.1      cgd 	register int i;
    109  1.1      cgd 
    110  1.1      cgd 	pr = pffindproto(PF_INET, IPPROTO_RAW, SOCK_RAW);
    111  1.1      cgd 	if (pr == 0)
    112  1.1      cgd 		panic("ip_init");
    113  1.1      cgd 	for (i = 0; i < IPPROTO_MAX; i++)
    114  1.1      cgd 		ip_protox[i] = pr - inetsw;
    115  1.1      cgd 	for (pr = inetdomain.dom_protosw;
    116  1.1      cgd 	    pr < inetdomain.dom_protoswNPROTOSW; pr++)
    117  1.1      cgd 		if (pr->pr_domain->dom_family == PF_INET &&
    118  1.1      cgd 		    pr->pr_protocol && pr->pr_protocol != IPPROTO_RAW)
    119  1.1      cgd 			ip_protox[pr->pr_protocol] = pr - inetsw;
    120  1.1      cgd 	ipq.next = ipq.prev = &ipq;
    121  1.1      cgd 	ip_id = time.tv_sec & 0xffff;
    122  1.1      cgd 	ipintrq.ifq_maxlen = ipqmaxlen;
    123  1.1      cgd #ifdef GATEWAY
    124  1.1      cgd 	i = (if_index + 1) * (if_index + 1) * sizeof (u_long);
    125  1.1      cgd 	if ((ip_ifmatrix = (u_long *) malloc(i, M_RTABLE, M_WAITOK)) == 0)
    126  1.1      cgd 		panic("no memory for ip_ifmatrix");
    127  1.1      cgd #endif
    128  1.1      cgd }
    129  1.1      cgd 
    130  1.1      cgd struct	ip *ip_reass();
    131  1.1      cgd struct	sockaddr_in ipaddr = { sizeof(ipaddr), AF_INET };
    132  1.1      cgd struct	route ipforward_rt;
    133  1.1      cgd 
    134  1.1      cgd /*
    135  1.1      cgd  * Ip input routine.  Checksum and byte swap header.  If fragmented
    136  1.1      cgd  * try to reassemble.  Process options.  Pass to next level.
    137  1.1      cgd  */
    138  1.1      cgd ipintr()
    139  1.1      cgd {
    140  1.1      cgd 	register struct ip *ip;
    141  1.1      cgd 	register struct mbuf *m;
    142  1.1      cgd 	register struct ipq *fp;
    143  1.1      cgd 	register struct in_ifaddr *ia;
    144  1.1      cgd 	int hlen, s;
    145  1.2      cgd #ifdef PARANOID
    146  1.2      cgd 	static int busy = 0;
    147  1.1      cgd 
    148  1.2      cgd 	if (busy)
    149  1.2      cgd 		panic("ipintr: called recursively\n");
    150  1.2      cgd 	++busy;
    151  1.2      cgd #endif
    152  1.1      cgd next:
    153  1.1      cgd 	/*
    154  1.1      cgd 	 * Get next datagram off input queue and get IP header
    155  1.1      cgd 	 * in first mbuf.
    156  1.1      cgd 	 */
    157  1.1      cgd 	s = splimp();
    158  1.1      cgd 	IF_DEQUEUE(&ipintrq, m);
    159  1.1      cgd 	splx(s);
    160  1.2      cgd 	if (m == 0) {
    161  1.2      cgd #ifdef PARANOID
    162  1.2      cgd 		--busy;
    163  1.2      cgd #endif
    164  1.1      cgd 		return;
    165  1.2      cgd 	}
    166  1.1      cgd #ifdef	DIAGNOSTIC
    167  1.1      cgd 	if ((m->m_flags & M_PKTHDR) == 0)
    168  1.1      cgd 		panic("ipintr no HDR");
    169  1.1      cgd #endif
    170  1.1      cgd 	/*
    171  1.1      cgd 	 * If no IP addresses have been set yet but the interfaces
    172  1.1      cgd 	 * are receiving, can't do anything with incoming packets yet.
    173  1.1      cgd 	 */
    174  1.1      cgd 	if (in_ifaddr == NULL)
    175  1.1      cgd 		goto bad;
    176  1.1      cgd 	ipstat.ips_total++;
    177  1.1      cgd 	if (m->m_len < sizeof (struct ip) &&
    178  1.1      cgd 	    (m = m_pullup(m, sizeof (struct ip))) == 0) {
    179  1.1      cgd 		ipstat.ips_toosmall++;
    180  1.1      cgd 		goto next;
    181  1.1      cgd 	}
    182  1.1      cgd 	ip = mtod(m, struct ip *);
    183  1.1      cgd 	hlen = ip->ip_hl << 2;
    184  1.1      cgd 	if (hlen < sizeof(struct ip)) {	/* minimum header length */
    185  1.1      cgd 		ipstat.ips_badhlen++;
    186  1.1      cgd 		goto bad;
    187  1.1      cgd 	}
    188  1.1      cgd 	if (hlen > m->m_len) {
    189  1.1      cgd 		if ((m = m_pullup(m, hlen)) == 0) {
    190  1.1      cgd 			ipstat.ips_badhlen++;
    191  1.1      cgd 			goto next;
    192  1.1      cgd 		}
    193  1.1      cgd 		ip = mtod(m, struct ip *);
    194  1.1      cgd 	}
    195  1.1      cgd 	if (ip->ip_sum = in_cksum(m, hlen)) {
    196  1.1      cgd 		ipstat.ips_badsum++;
    197  1.1      cgd 		goto bad;
    198  1.1      cgd 	}
    199  1.1      cgd 
    200  1.1      cgd 	/*
    201  1.1      cgd 	 * Convert fields to host representation.
    202  1.1      cgd 	 */
    203  1.1      cgd 	NTOHS(ip->ip_len);
    204  1.1      cgd 	if (ip->ip_len < hlen) {
    205  1.1      cgd 		ipstat.ips_badlen++;
    206  1.1      cgd 		goto bad;
    207  1.1      cgd 	}
    208  1.1      cgd 	NTOHS(ip->ip_id);
    209  1.1      cgd 	NTOHS(ip->ip_off);
    210  1.1      cgd 
    211  1.1      cgd 	/*
    212  1.1      cgd 	 * Check that the amount of data in the buffers
    213  1.1      cgd 	 * is as at least much as the IP header would have us expect.
    214  1.1      cgd 	 * Trim mbufs if longer than we expect.
    215  1.1      cgd 	 * Drop packet if shorter than we expect.
    216  1.1      cgd 	 */
    217  1.1      cgd 	if (m->m_pkthdr.len < ip->ip_len) {
    218  1.1      cgd 		ipstat.ips_tooshort++;
    219  1.1      cgd 		goto bad;
    220  1.1      cgd 	}
    221  1.1      cgd 	if (m->m_pkthdr.len > ip->ip_len) {
    222  1.1      cgd 		if (m->m_len == m->m_pkthdr.len) {
    223  1.1      cgd 			m->m_len = ip->ip_len;
    224  1.1      cgd 			m->m_pkthdr.len = ip->ip_len;
    225  1.1      cgd 		} else
    226  1.1      cgd 			m_adj(m, ip->ip_len - m->m_pkthdr.len);
    227  1.1      cgd 	}
    228  1.1      cgd 
    229  1.1      cgd 	/*
    230  1.1      cgd 	 * Process options and, if not destined for us,
    231  1.1      cgd 	 * ship it on.  ip_dooptions returns 1 when an
    232  1.1      cgd 	 * error was detected (causing an icmp message
    233  1.1      cgd 	 * to be sent and the original packet to be freed).
    234  1.1      cgd 	 */
    235  1.1      cgd 	ip_nhops = 0;		/* for source routed packets */
    236  1.1      cgd 	if (hlen > sizeof (struct ip) && ip_dooptions(m))
    237  1.1      cgd 		goto next;
    238  1.1      cgd 
    239  1.1      cgd 	/*
    240  1.1      cgd 	 * Check our list of addresses, to see if the packet is for us.
    241  1.1      cgd 	 */
    242  1.1      cgd 	for (ia = in_ifaddr; ia; ia = ia->ia_next) {
    243  1.1      cgd #define	satosin(sa)	((struct sockaddr_in *)(sa))
    244  1.1      cgd 
    245  1.1      cgd 		if (IA_SIN(ia)->sin_addr.s_addr == ip->ip_dst.s_addr)
    246  1.1      cgd 			goto ours;
    247  1.1      cgd 		if (
    248  1.1      cgd #ifdef	DIRECTED_BROADCAST
    249  1.1      cgd 		    ia->ia_ifp == m->m_pkthdr.rcvif &&
    250  1.1      cgd #endif
    251  1.1      cgd 		    (ia->ia_ifp->if_flags & IFF_BROADCAST)) {
    252  1.1      cgd 			u_long t;
    253  1.1      cgd 
    254  1.1      cgd 			if (satosin(&ia->ia_broadaddr)->sin_addr.s_addr ==
    255  1.1      cgd 			    ip->ip_dst.s_addr)
    256  1.1      cgd 				goto ours;
    257  1.1      cgd 			if (ip->ip_dst.s_addr == ia->ia_netbroadcast.s_addr)
    258  1.1      cgd 				goto ours;
    259  1.1      cgd 			/*
    260  1.1      cgd 			 * Look for all-0's host part (old broadcast addr),
    261  1.1      cgd 			 * either for subnet or net.
    262  1.1      cgd 			 */
    263  1.1      cgd 			t = ntohl(ip->ip_dst.s_addr);
    264  1.1      cgd 			if (t == ia->ia_subnet)
    265  1.1      cgd 				goto ours;
    266  1.1      cgd 			if (t == ia->ia_net)
    267  1.1      cgd 				goto ours;
    268  1.1      cgd 		}
    269  1.1      cgd 	}
    270  1.4  hpeyerl #ifdef MULTICAST
    271  1.4  hpeyerl 	if (IN_MULTICAST(ntohl(ip->ip_dst.s_addr))) {
    272  1.4  hpeyerl 		struct in_multi *inm;
    273  1.4  hpeyerl #ifdef MROUTING
    274  1.4  hpeyerl 		extern struct socket *ip_mrouter;
    275  1.4  hpeyerl 
    276  1.4  hpeyerl 		if (ip_mrouter) {
    277  1.4  hpeyerl 			/*
    278  1.4  hpeyerl 			 * If we are acting as a multicast router, all
    279  1.4  hpeyerl 			 * incoming multicast packets are passed to the
    280  1.4  hpeyerl 			 * kernel-level multicast forwarding function.
    281  1.4  hpeyerl 			 * The packet is returned (relatively) intact; if
    282  1.4  hpeyerl 			 * ip_mforward() returns a non-zero value, the packet
    283  1.4  hpeyerl 			 * must be discarded, else it may be accepted below.
    284  1.4  hpeyerl 			 *
    285  1.4  hpeyerl 			 * (The IP ident field is put in the same byte order
    286  1.4  hpeyerl 			 * as expected when ip_mforward() is called from
    287  1.4  hpeyerl 			 * ip_output().)
    288  1.4  hpeyerl 			 */
    289  1.4  hpeyerl 			ip->ip_id = htons(ip->ip_id);
    290  1.4  hpeyerl 			if (ip_mforward(ip, m->m_pkthdr.rcvif, m) != 0) {
    291  1.4  hpeyerl 				m_freem(m);
    292  1.4  hpeyerl 				goto next;
    293  1.4  hpeyerl 			}
    294  1.4  hpeyerl 			ip->ip_id = ntohs(ip->ip_id);
    295  1.4  hpeyerl 
    296  1.4  hpeyerl 			/*
    297  1.4  hpeyerl 			 * The process-level routing demon needs to receive
    298  1.4  hpeyerl 			 * all multicast IGMP packets, whether or not this
    299  1.4  hpeyerl 			 * host belongs to their destination groups.
    300  1.4  hpeyerl 			 */
    301  1.4  hpeyerl 			if (ip->ip_p == IPPROTO_IGMP)
    302  1.4  hpeyerl 				goto ours;
    303  1.4  hpeyerl 		}
    304  1.4  hpeyerl #endif
    305  1.4  hpeyerl 		/*
    306  1.4  hpeyerl 		 * See if we belong to the destination multicast group on the
    307  1.4  hpeyerl 		 * arrival interface.
    308  1.4  hpeyerl 		 */
    309  1.4  hpeyerl 		IN_LOOKUP_MULTI(ip->ip_dst, m->m_pkthdr.rcvif, inm);
    310  1.4  hpeyerl 		if (inm == NULL) {
    311  1.4  hpeyerl 			m_freem(m);
    312  1.4  hpeyerl 			goto next;
    313  1.4  hpeyerl 		}
    314  1.4  hpeyerl 		goto ours;
    315  1.4  hpeyerl 	}
    316  1.4  hpeyerl #endif
    317  1.1      cgd 	if (ip->ip_dst.s_addr == (u_long)INADDR_BROADCAST)
    318  1.1      cgd 		goto ours;
    319  1.1      cgd 	if (ip->ip_dst.s_addr == INADDR_ANY)
    320  1.1      cgd 		goto ours;
    321  1.1      cgd 
    322  1.1      cgd 	/*
    323  1.1      cgd 	 * Not for us; forward if possible and desirable.
    324  1.1      cgd 	 */
    325  1.1      cgd 	if (ipforwarding == 0) {
    326  1.1      cgd 		ipstat.ips_cantforward++;
    327  1.1      cgd 		m_freem(m);
    328  1.1      cgd 	} else
    329  1.1      cgd 		ip_forward(m, 0);
    330  1.1      cgd 	goto next;
    331  1.1      cgd 
    332  1.1      cgd ours:
    333  1.1      cgd 	/*
    334  1.1      cgd 	 * If offset or IP_MF are set, must reassemble.
    335  1.1      cgd 	 * Otherwise, nothing need be done.
    336  1.1      cgd 	 * (We could look in the reassembly queue to see
    337  1.1      cgd 	 * if the packet was previously fragmented,
    338  1.1      cgd 	 * but it's not worth the time; just let them time out.)
    339  1.1      cgd 	 */
    340  1.1      cgd 	if (ip->ip_off &~ IP_DF) {
    341  1.1      cgd 		if (m->m_flags & M_EXT) {		/* XXX */
    342  1.1      cgd 			if ((m = m_pullup(m, sizeof (struct ip))) == 0) {
    343  1.1      cgd 				ipstat.ips_toosmall++;
    344  1.1      cgd 				goto next;
    345  1.1      cgd 			}
    346  1.1      cgd 			ip = mtod(m, struct ip *);
    347  1.1      cgd 		}
    348  1.1      cgd 		/*
    349  1.1      cgd 		 * Look for queue of fragments
    350  1.1      cgd 		 * of this datagram.
    351  1.1      cgd 		 */
    352  1.1      cgd 		for (fp = ipq.next; fp != &ipq; fp = fp->next)
    353  1.1      cgd 			if (ip->ip_id == fp->ipq_id &&
    354  1.1      cgd 			    ip->ip_src.s_addr == fp->ipq_src.s_addr &&
    355  1.1      cgd 			    ip->ip_dst.s_addr == fp->ipq_dst.s_addr &&
    356  1.1      cgd 			    ip->ip_p == fp->ipq_p)
    357  1.1      cgd 				goto found;
    358  1.1      cgd 		fp = 0;
    359  1.1      cgd found:
    360  1.1      cgd 
    361  1.1      cgd 		/*
    362  1.1      cgd 		 * Adjust ip_len to not reflect header,
    363  1.1      cgd 		 * set ip_mff if more fragments are expected,
    364  1.1      cgd 		 * convert offset of this to bytes.
    365  1.1      cgd 		 */
    366  1.1      cgd 		ip->ip_len -= hlen;
    367  1.1      cgd 		((struct ipasfrag *)ip)->ipf_mff = 0;
    368  1.1      cgd 		if (ip->ip_off & IP_MF)
    369  1.1      cgd 			((struct ipasfrag *)ip)->ipf_mff = 1;
    370  1.1      cgd 		ip->ip_off <<= 3;
    371  1.1      cgd 
    372  1.1      cgd 		/*
    373  1.1      cgd 		 * If datagram marked as having more fragments
    374  1.1      cgd 		 * or if this is not the first fragment,
    375  1.1      cgd 		 * attempt reassembly; if it succeeds, proceed.
    376  1.1      cgd 		 */
    377  1.1      cgd 		if (((struct ipasfrag *)ip)->ipf_mff || ip->ip_off) {
    378  1.1      cgd 			ipstat.ips_fragments++;
    379  1.1      cgd 			ip = ip_reass((struct ipasfrag *)ip, fp);
    380  1.1      cgd 			if (ip == 0)
    381  1.1      cgd 				goto next;
    382  1.1      cgd 			else
    383  1.1      cgd 				ipstat.ips_reassembled++;
    384  1.1      cgd 			m = dtom(ip);
    385  1.1      cgd 		} else
    386  1.1      cgd 			if (fp)
    387  1.1      cgd 				ip_freef(fp);
    388  1.1      cgd 	} else
    389  1.1      cgd 		ip->ip_len -= hlen;
    390  1.1      cgd 
    391  1.1      cgd 	/*
    392  1.1      cgd 	 * Switch out to protocol's input routine.
    393  1.1      cgd 	 */
    394  1.1      cgd 	ipstat.ips_delivered++;
    395  1.1      cgd 	(*inetsw[ip_protox[ip->ip_p]].pr_input)(m, hlen);
    396  1.1      cgd 	goto next;
    397  1.1      cgd bad:
    398  1.1      cgd 	m_freem(m);
    399  1.1      cgd 	goto next;
    400  1.1      cgd }
    401  1.1      cgd 
    402  1.1      cgd /*
    403  1.1      cgd  * Take incoming datagram fragment and try to
    404  1.1      cgd  * reassemble it into whole datagram.  If a chain for
    405  1.1      cgd  * reassembly of this datagram already exists, then it
    406  1.1      cgd  * is given as fp; otherwise have to make a chain.
    407  1.1      cgd  */
    408  1.1      cgd struct ip *
    409  1.1      cgd ip_reass(ip, fp)
    410  1.1      cgd 	register struct ipasfrag *ip;
    411  1.1      cgd 	register struct ipq *fp;
    412  1.1      cgd {
    413  1.1      cgd 	register struct mbuf *m = dtom(ip);
    414  1.1      cgd 	register struct ipasfrag *q;
    415  1.1      cgd 	struct mbuf *t;
    416  1.1      cgd 	int hlen = ip->ip_hl << 2;
    417  1.1      cgd 	int i, next;
    418  1.1      cgd 
    419  1.1      cgd 	/*
    420  1.1      cgd 	 * Presence of header sizes in mbufs
    421  1.1      cgd 	 * would confuse code below.
    422  1.1      cgd 	 */
    423  1.1      cgd 	m->m_data += hlen;
    424  1.1      cgd 	m->m_len -= hlen;
    425  1.1      cgd 
    426  1.1      cgd 	/*
    427  1.1      cgd 	 * If first fragment to arrive, create a reassembly queue.
    428  1.1      cgd 	 */
    429  1.1      cgd 	if (fp == 0) {
    430  1.1      cgd 		if ((t = m_get(M_DONTWAIT, MT_FTABLE)) == NULL)
    431  1.1      cgd 			goto dropfrag;
    432  1.1      cgd 		fp = mtod(t, struct ipq *);
    433  1.1      cgd 		insque(fp, &ipq);
    434  1.1      cgd 		fp->ipq_ttl = IPFRAGTTL;
    435  1.1      cgd 		fp->ipq_p = ip->ip_p;
    436  1.1      cgd 		fp->ipq_id = ip->ip_id;
    437  1.1      cgd 		fp->ipq_next = fp->ipq_prev = (struct ipasfrag *)fp;
    438  1.1      cgd 		fp->ipq_src = ((struct ip *)ip)->ip_src;
    439  1.1      cgd 		fp->ipq_dst = ((struct ip *)ip)->ip_dst;
    440  1.1      cgd 		q = (struct ipasfrag *)fp;
    441  1.1      cgd 		goto insert;
    442  1.1      cgd 	}
    443  1.1      cgd 
    444  1.1      cgd 	/*
    445  1.1      cgd 	 * Find a segment which begins after this one does.
    446  1.1      cgd 	 */
    447  1.1      cgd 	for (q = fp->ipq_next; q != (struct ipasfrag *)fp; q = q->ipf_next)
    448  1.1      cgd 		if (q->ip_off > ip->ip_off)
    449  1.1      cgd 			break;
    450  1.1      cgd 
    451  1.1      cgd 	/*
    452  1.1      cgd 	 * If there is a preceding segment, it may provide some of
    453  1.1      cgd 	 * our data already.  If so, drop the data from the incoming
    454  1.1      cgd 	 * segment.  If it provides all of our data, drop us.
    455  1.1      cgd 	 */
    456  1.1      cgd 	if (q->ipf_prev != (struct ipasfrag *)fp) {
    457  1.1      cgd 		i = q->ipf_prev->ip_off + q->ipf_prev->ip_len - ip->ip_off;
    458  1.1      cgd 		if (i > 0) {
    459  1.1      cgd 			if (i >= ip->ip_len)
    460  1.1      cgd 				goto dropfrag;
    461  1.1      cgd 			m_adj(dtom(ip), i);
    462  1.1      cgd 			ip->ip_off += i;
    463  1.1      cgd 			ip->ip_len -= i;
    464  1.1      cgd 		}
    465  1.1      cgd 	}
    466  1.1      cgd 
    467  1.1      cgd 	/*
    468  1.1      cgd 	 * While we overlap succeeding segments trim them or,
    469  1.1      cgd 	 * if they are completely covered, dequeue them.
    470  1.1      cgd 	 */
    471  1.1      cgd 	while (q != (struct ipasfrag *)fp && ip->ip_off + ip->ip_len > q->ip_off) {
    472  1.1      cgd 		i = (ip->ip_off + ip->ip_len) - q->ip_off;
    473  1.1      cgd 		if (i < q->ip_len) {
    474  1.1      cgd 			q->ip_len -= i;
    475  1.1      cgd 			q->ip_off += i;
    476  1.1      cgd 			m_adj(dtom(q), i);
    477  1.1      cgd 			break;
    478  1.1      cgd 		}
    479  1.1      cgd 		q = q->ipf_next;
    480  1.1      cgd 		m_freem(dtom(q->ipf_prev));
    481  1.1      cgd 		ip_deq(q->ipf_prev);
    482  1.1      cgd 	}
    483  1.1      cgd 
    484  1.1      cgd insert:
    485  1.1      cgd 	/*
    486  1.1      cgd 	 * Stick new segment in its place;
    487  1.1      cgd 	 * check for complete reassembly.
    488  1.1      cgd 	 */
    489  1.1      cgd 	ip_enq(ip, q->ipf_prev);
    490  1.1      cgd 	next = 0;
    491  1.1      cgd 	for (q = fp->ipq_next; q != (struct ipasfrag *)fp; q = q->ipf_next) {
    492  1.1      cgd 		if (q->ip_off != next)
    493  1.1      cgd 			return (0);
    494  1.1      cgd 		next += q->ip_len;
    495  1.1      cgd 	}
    496  1.1      cgd 	if (q->ipf_prev->ipf_mff)
    497  1.1      cgd 		return (0);
    498  1.1      cgd 
    499  1.1      cgd 	/*
    500  1.1      cgd 	 * Reassembly is complete; concatenate fragments.
    501  1.1      cgd 	 */
    502  1.1      cgd 	q = fp->ipq_next;
    503  1.1      cgd 	m = dtom(q);
    504  1.1      cgd 	t = m->m_next;
    505  1.1      cgd 	m->m_next = 0;
    506  1.1      cgd 	m_cat(m, t);
    507  1.1      cgd 	q = q->ipf_next;
    508  1.1      cgd 	while (q != (struct ipasfrag *)fp) {
    509  1.1      cgd 		t = dtom(q);
    510  1.1      cgd 		q = q->ipf_next;
    511  1.1      cgd 		m_cat(m, t);
    512  1.1      cgd 	}
    513  1.1      cgd 
    514  1.1      cgd 	/*
    515  1.1      cgd 	 * Create header for new ip packet by
    516  1.1      cgd 	 * modifying header of first packet;
    517  1.1      cgd 	 * dequeue and discard fragment reassembly header.
    518  1.1      cgd 	 * Make header visible.
    519  1.1      cgd 	 */
    520  1.1      cgd 	ip = fp->ipq_next;
    521  1.1      cgd 	ip->ip_len = next;
    522  1.1      cgd 	((struct ip *)ip)->ip_src = fp->ipq_src;
    523  1.1      cgd 	((struct ip *)ip)->ip_dst = fp->ipq_dst;
    524  1.1      cgd 	remque(fp);
    525  1.1      cgd 	(void) m_free(dtom(fp));
    526  1.1      cgd 	m = dtom(ip);
    527  1.1      cgd 	m->m_len += (ip->ip_hl << 2);
    528  1.1      cgd 	m->m_data -= (ip->ip_hl << 2);
    529  1.1      cgd 	/* some debugging cruft by sklower, below, will go away soon */
    530  1.1      cgd 	if (m->m_flags & M_PKTHDR) { /* XXX this should be done elsewhere */
    531  1.1      cgd 		register int plen = 0;
    532  1.1      cgd 		for (t = m; m; m = m->m_next)
    533  1.1      cgd 			plen += m->m_len;
    534  1.1      cgd 		t->m_pkthdr.len = plen;
    535  1.1      cgd 	}
    536  1.1      cgd 	return ((struct ip *)ip);
    537  1.1      cgd 
    538  1.1      cgd dropfrag:
    539  1.1      cgd 	ipstat.ips_fragdropped++;
    540  1.1      cgd 	m_freem(m);
    541  1.1      cgd 	return (0);
    542  1.1      cgd }
    543  1.1      cgd 
    544  1.1      cgd /*
    545  1.1      cgd  * Free a fragment reassembly header and all
    546  1.1      cgd  * associated datagrams.
    547  1.1      cgd  */
    548  1.1      cgd ip_freef(fp)
    549  1.1      cgd 	struct ipq *fp;
    550  1.1      cgd {
    551  1.1      cgd 	register struct ipasfrag *q, *p;
    552  1.1      cgd 
    553  1.1      cgd 	for (q = fp->ipq_next; q != (struct ipasfrag *)fp; q = p) {
    554  1.1      cgd 		p = q->ipf_next;
    555  1.1      cgd 		ip_deq(q);
    556  1.1      cgd 		m_freem(dtom(q));
    557  1.1      cgd 	}
    558  1.1      cgd 	remque(fp);
    559  1.1      cgd 	(void) m_free(dtom(fp));
    560  1.1      cgd }
    561  1.1      cgd 
    562  1.1      cgd /*
    563  1.1      cgd  * Put an ip fragment on a reassembly chain.
    564  1.1      cgd  * Like insque, but pointers in middle of structure.
    565  1.1      cgd  */
    566  1.1      cgd ip_enq(p, prev)
    567  1.1      cgd 	register struct ipasfrag *p, *prev;
    568  1.1      cgd {
    569  1.1      cgd 
    570  1.1      cgd 	p->ipf_prev = prev;
    571  1.1      cgd 	p->ipf_next = prev->ipf_next;
    572  1.1      cgd 	prev->ipf_next->ipf_prev = p;
    573  1.1      cgd 	prev->ipf_next = p;
    574  1.1      cgd }
    575  1.1      cgd 
    576  1.1      cgd /*
    577  1.1      cgd  * To ip_enq as remque is to insque.
    578  1.1      cgd  */
    579  1.1      cgd ip_deq(p)
    580  1.1      cgd 	register struct ipasfrag *p;
    581  1.1      cgd {
    582  1.1      cgd 
    583  1.1      cgd 	p->ipf_prev->ipf_next = p->ipf_next;
    584  1.1      cgd 	p->ipf_next->ipf_prev = p->ipf_prev;
    585  1.1      cgd }
    586  1.1      cgd 
    587  1.1      cgd /*
    588  1.1      cgd  * IP timer processing;
    589  1.1      cgd  * if a timer expires on a reassembly
    590  1.1      cgd  * queue, discard it.
    591  1.1      cgd  */
    592  1.1      cgd ip_slowtimo()
    593  1.1      cgd {
    594  1.1      cgd 	register struct ipq *fp;
    595  1.1      cgd 	int s = splnet();
    596  1.1      cgd 
    597  1.1      cgd 	fp = ipq.next;
    598  1.1      cgd 	if (fp == 0) {
    599  1.1      cgd 		splx(s);
    600  1.1      cgd 		return;
    601  1.1      cgd 	}
    602  1.1      cgd 	while (fp != &ipq) {
    603  1.1      cgd 		--fp->ipq_ttl;
    604  1.1      cgd 		fp = fp->next;
    605  1.1      cgd 		if (fp->prev->ipq_ttl == 0) {
    606  1.1      cgd 			ipstat.ips_fragtimeout++;
    607  1.1      cgd 			ip_freef(fp->prev);
    608  1.1      cgd 		}
    609  1.1      cgd 	}
    610  1.1      cgd 	splx(s);
    611  1.1      cgd }
    612  1.1      cgd 
    613  1.1      cgd /*
    614  1.1      cgd  * Drain off all datagram fragments.
    615  1.1      cgd  */
    616  1.1      cgd ip_drain()
    617  1.1      cgd {
    618  1.1      cgd 
    619  1.1      cgd 	while (ipq.next != &ipq) {
    620  1.1      cgd 		ipstat.ips_fragdropped++;
    621  1.1      cgd 		ip_freef(ipq.next);
    622  1.1      cgd 	}
    623  1.1      cgd }
    624  1.1      cgd 
    625  1.1      cgd extern struct in_ifaddr *ifptoia();
    626  1.1      cgd struct in_ifaddr *ip_rtaddr();
    627  1.1      cgd 
    628  1.1      cgd /*
    629  1.1      cgd  * Do option processing on a datagram,
    630  1.1      cgd  * possibly discarding it if bad options are encountered,
    631  1.1      cgd  * or forwarding it if source-routed.
    632  1.1      cgd  * Returns 1 if packet has been forwarded/freed,
    633  1.1      cgd  * 0 if the packet should be processed further.
    634  1.1      cgd  */
    635  1.1      cgd ip_dooptions(m)
    636  1.1      cgd 	struct mbuf *m;
    637  1.1      cgd {
    638  1.1      cgd 	register struct ip *ip = mtod(m, struct ip *);
    639  1.1      cgd 	register u_char *cp;
    640  1.1      cgd 	register struct ip_timestamp *ipt;
    641  1.1      cgd 	register struct in_ifaddr *ia;
    642  1.1      cgd 	int opt, optlen, cnt, off, code, type = ICMP_PARAMPROB, forward = 0;
    643  1.1      cgd 	struct in_addr *sin;
    644  1.1      cgd 	n_time ntime;
    645  1.1      cgd 
    646  1.1      cgd 	cp = (u_char *)(ip + 1);
    647  1.1      cgd 	cnt = (ip->ip_hl << 2) - sizeof (struct ip);
    648  1.1      cgd 	for (; cnt > 0; cnt -= optlen, cp += optlen) {
    649  1.1      cgd 		opt = cp[IPOPT_OPTVAL];
    650  1.1      cgd 		if (opt == IPOPT_EOL)
    651  1.1      cgd 			break;
    652  1.1      cgd 		if (opt == IPOPT_NOP)
    653  1.1      cgd 			optlen = 1;
    654  1.1      cgd 		else {
    655  1.1      cgd 			optlen = cp[IPOPT_OLEN];
    656  1.1      cgd 			if (optlen <= 0 || optlen > cnt) {
    657  1.1      cgd 				code = &cp[IPOPT_OLEN] - (u_char *)ip;
    658  1.1      cgd 				goto bad;
    659  1.1      cgd 			}
    660  1.1      cgd 		}
    661  1.1      cgd 		switch (opt) {
    662  1.1      cgd 
    663  1.1      cgd 		default:
    664  1.1      cgd 			break;
    665  1.1      cgd 
    666  1.1      cgd 		/*
    667  1.1      cgd 		 * Source routing with record.
    668  1.1      cgd 		 * Find interface with current destination address.
    669  1.1      cgd 		 * If none on this machine then drop if strictly routed,
    670  1.1      cgd 		 * or do nothing if loosely routed.
    671  1.1      cgd 		 * Record interface address and bring up next address
    672  1.1      cgd 		 * component.  If strictly routed make sure next
    673  1.1      cgd 		 * address is on directly accessible net.
    674  1.1      cgd 		 */
    675  1.1      cgd 		case IPOPT_LSRR:
    676  1.1      cgd 		case IPOPT_SSRR:
    677  1.1      cgd 			if ((off = cp[IPOPT_OFFSET]) < IPOPT_MINOFF) {
    678  1.1      cgd 				code = &cp[IPOPT_OFFSET] - (u_char *)ip;
    679  1.1      cgd 				goto bad;
    680  1.1      cgd 			}
    681  1.1      cgd 			ipaddr.sin_addr = ip->ip_dst;
    682  1.1      cgd 			ia = (struct in_ifaddr *)
    683  1.1      cgd 				ifa_ifwithaddr((struct sockaddr *)&ipaddr);
    684  1.1      cgd 			if (ia == 0) {
    685  1.1      cgd 				if (opt == IPOPT_SSRR) {
    686  1.1      cgd 					type = ICMP_UNREACH;
    687  1.1      cgd 					code = ICMP_UNREACH_SRCFAIL;
    688  1.1      cgd 					goto bad;
    689  1.1      cgd 				}
    690  1.1      cgd 				/*
    691  1.1      cgd 				 * Loose routing, and not at next destination
    692  1.1      cgd 				 * yet; nothing to do except forward.
    693  1.1      cgd 				 */
    694  1.1      cgd 				break;
    695  1.1      cgd 			}
    696  1.1      cgd 			off--;			/* 0 origin */
    697  1.1      cgd 			if (off > optlen - sizeof(struct in_addr)) {
    698  1.1      cgd 				/*
    699  1.1      cgd 				 * End of source route.  Should be for us.
    700  1.1      cgd 				 */
    701  1.1      cgd 				save_rte(cp, ip->ip_src);
    702  1.1      cgd 				break;
    703  1.1      cgd 			}
    704  1.1      cgd 			/*
    705  1.1      cgd 			 * locate outgoing interface
    706  1.1      cgd 			 */
    707  1.1      cgd 			bcopy((caddr_t)(cp + off), (caddr_t)&ipaddr.sin_addr,
    708  1.1      cgd 			    sizeof(ipaddr.sin_addr));
    709  1.1      cgd 			if (opt == IPOPT_SSRR) {
    710  1.1      cgd #define	INA	struct in_ifaddr *
    711  1.1      cgd #define	SA	struct sockaddr *
    712  1.1      cgd 			    if ((ia = (INA)ifa_ifwithdstaddr((SA)&ipaddr)) == 0)
    713  1.1      cgd 				ia = in_iaonnetof(in_netof(ipaddr.sin_addr));
    714  1.1      cgd 			} else
    715  1.1      cgd 				ia = ip_rtaddr(ipaddr.sin_addr);
    716  1.1      cgd 			if (ia == 0) {
    717  1.1      cgd 				type = ICMP_UNREACH;
    718  1.1      cgd 				code = ICMP_UNREACH_SRCFAIL;
    719  1.1      cgd 				goto bad;
    720  1.1      cgd 			}
    721  1.1      cgd 			ip->ip_dst = ipaddr.sin_addr;
    722  1.1      cgd 			bcopy((caddr_t)&(IA_SIN(ia)->sin_addr),
    723  1.1      cgd 			    (caddr_t)(cp + off), sizeof(struct in_addr));
    724  1.1      cgd 			cp[IPOPT_OFFSET] += sizeof(struct in_addr);
    725  1.1      cgd 			forward = 1;
    726  1.1      cgd 			break;
    727  1.1      cgd 
    728  1.1      cgd 		case IPOPT_RR:
    729  1.1      cgd 			if ((off = cp[IPOPT_OFFSET]) < IPOPT_MINOFF) {
    730  1.1      cgd 				code = &cp[IPOPT_OFFSET] - (u_char *)ip;
    731  1.1      cgd 				goto bad;
    732  1.1      cgd 			}
    733  1.1      cgd 			/*
    734  1.1      cgd 			 * If no space remains, ignore.
    735  1.1      cgd 			 */
    736  1.1      cgd 			off--;			/* 0 origin */
    737  1.1      cgd 			if (off > optlen - sizeof(struct in_addr))
    738  1.1      cgd 				break;
    739  1.1      cgd 			bcopy((caddr_t)(&ip->ip_dst), (caddr_t)&ipaddr.sin_addr,
    740  1.1      cgd 			    sizeof(ipaddr.sin_addr));
    741  1.1      cgd 			/*
    742  1.1      cgd 			 * locate outgoing interface; if we're the destination,
    743  1.1      cgd 			 * use the incoming interface (should be same).
    744  1.1      cgd 			 */
    745  1.1      cgd 			if ((ia = (INA)ifa_ifwithaddr((SA)&ipaddr)) == 0 &&
    746  1.1      cgd 			    (ia = ip_rtaddr(ipaddr.sin_addr)) == 0) {
    747  1.1      cgd 				type = ICMP_UNREACH;
    748  1.1      cgd 				code = ICMP_UNREACH_HOST;
    749  1.1      cgd 				goto bad;
    750  1.1      cgd 			}
    751  1.1      cgd 			bcopy((caddr_t)&(IA_SIN(ia)->sin_addr),
    752  1.1      cgd 			    (caddr_t)(cp + off), sizeof(struct in_addr));
    753  1.1      cgd 			cp[IPOPT_OFFSET] += sizeof(struct in_addr);
    754  1.1      cgd 			break;
    755  1.1      cgd 
    756  1.1      cgd 		case IPOPT_TS:
    757  1.1      cgd 			code = cp - (u_char *)ip;
    758  1.1      cgd 			ipt = (struct ip_timestamp *)cp;
    759  1.1      cgd 			if (ipt->ipt_len < 5)
    760  1.1      cgd 				goto bad;
    761  1.1      cgd 			if (ipt->ipt_ptr > ipt->ipt_len - sizeof (long)) {
    762  1.1      cgd 				if (++ipt->ipt_oflw == 0)
    763  1.1      cgd 					goto bad;
    764  1.1      cgd 				break;
    765  1.1      cgd 			}
    766  1.1      cgd 			sin = (struct in_addr *)(cp + ipt->ipt_ptr - 1);
    767  1.1      cgd 			switch (ipt->ipt_flg) {
    768  1.1      cgd 
    769  1.1      cgd 			case IPOPT_TS_TSONLY:
    770  1.1      cgd 				break;
    771  1.1      cgd 
    772  1.1      cgd 			case IPOPT_TS_TSANDADDR:
    773  1.1      cgd 				if (ipt->ipt_ptr + sizeof(n_time) +
    774  1.1      cgd 				    sizeof(struct in_addr) > ipt->ipt_len)
    775  1.1      cgd 					goto bad;
    776  1.1      cgd 				ia = ifptoia(m->m_pkthdr.rcvif);
    777  1.1      cgd 				bcopy((caddr_t)&IA_SIN(ia)->sin_addr,
    778  1.1      cgd 				    (caddr_t)sin, sizeof(struct in_addr));
    779  1.1      cgd 				ipt->ipt_ptr += sizeof(struct in_addr);
    780  1.1      cgd 				break;
    781  1.1      cgd 
    782  1.1      cgd 			case IPOPT_TS_PRESPEC:
    783  1.1      cgd 				if (ipt->ipt_ptr + sizeof(n_time) +
    784  1.1      cgd 				    sizeof(struct in_addr) > ipt->ipt_len)
    785  1.1      cgd 					goto bad;
    786  1.1      cgd 				bcopy((caddr_t)sin, (caddr_t)&ipaddr.sin_addr,
    787  1.1      cgd 				    sizeof(struct in_addr));
    788  1.1      cgd 				if (ifa_ifwithaddr((SA)&ipaddr) == 0)
    789  1.1      cgd 					continue;
    790  1.1      cgd 				ipt->ipt_ptr += sizeof(struct in_addr);
    791  1.1      cgd 				break;
    792  1.1      cgd 
    793  1.1      cgd 			default:
    794  1.1      cgd 				goto bad;
    795  1.1      cgd 			}
    796  1.1      cgd 			ntime = iptime();
    797  1.1      cgd 			bcopy((caddr_t)&ntime, (caddr_t)cp + ipt->ipt_ptr - 1,
    798  1.1      cgd 			    sizeof(n_time));
    799  1.1      cgd 			ipt->ipt_ptr += sizeof(n_time);
    800  1.1      cgd 		}
    801  1.1      cgd 	}
    802  1.1      cgd 	if (forward) {
    803  1.1      cgd 		ip_forward(m, 1);
    804  1.1      cgd 		return (1);
    805  1.1      cgd 	} else
    806  1.1      cgd 		return (0);
    807  1.1      cgd bad:
    808  1.7  mycroft     {
    809  1.7  mycroft 	register struct in_addr foo = {};
    810  1.7  mycroft 	icmp_error(m, type, code, foo);
    811  1.7  mycroft     }
    812  1.1      cgd 	return (1);
    813  1.1      cgd }
    814  1.1      cgd 
    815  1.1      cgd /*
    816  1.1      cgd  * Given address of next destination (final or next hop),
    817  1.1      cgd  * return internet address info of interface to be used to get there.
    818  1.1      cgd  */
    819  1.1      cgd struct in_ifaddr *
    820  1.1      cgd ip_rtaddr(dst)
    821  1.1      cgd 	 struct in_addr dst;
    822  1.1      cgd {
    823  1.1      cgd 	register struct sockaddr_in *sin;
    824  1.1      cgd 
    825  1.1      cgd 	sin = (struct sockaddr_in *) &ipforward_rt.ro_dst;
    826  1.1      cgd 
    827  1.1      cgd 	if (ipforward_rt.ro_rt == 0 || dst.s_addr != sin->sin_addr.s_addr) {
    828  1.1      cgd 		if (ipforward_rt.ro_rt) {
    829  1.1      cgd 			RTFREE(ipforward_rt.ro_rt);
    830  1.1      cgd 			ipforward_rt.ro_rt = 0;
    831  1.1      cgd 		}
    832  1.1      cgd 		sin->sin_family = AF_INET;
    833  1.1      cgd 		sin->sin_len = sizeof(*sin);
    834  1.1      cgd 		sin->sin_addr = dst;
    835  1.1      cgd 
    836  1.1      cgd 		rtalloc(&ipforward_rt);
    837  1.1      cgd 	}
    838  1.1      cgd 	if (ipforward_rt.ro_rt == 0)
    839  1.1      cgd 		return ((struct in_ifaddr *)0);
    840  1.1      cgd 	return ((struct in_ifaddr *) ipforward_rt.ro_rt->rt_ifa);
    841  1.1      cgd }
    842  1.1      cgd 
    843  1.1      cgd /*
    844  1.1      cgd  * Save incoming source route for use in replies,
    845  1.1      cgd  * to be picked up later by ip_srcroute if the receiver is interested.
    846  1.1      cgd  */
    847  1.1      cgd save_rte(option, dst)
    848  1.1      cgd 	u_char *option;
    849  1.1      cgd 	struct in_addr dst;
    850  1.1      cgd {
    851  1.1      cgd 	unsigned olen;
    852  1.1      cgd 
    853  1.1      cgd 	olen = option[IPOPT_OLEN];
    854  1.1      cgd #ifdef DIAGNOSTIC
    855  1.1      cgd 	if (ipprintfs)
    856  1.1      cgd 		printf("save_rte: olen %d\n", olen);
    857  1.1      cgd #endif
    858  1.1      cgd 	if (olen > sizeof(ip_srcrt) - (1 + sizeof(dst)))
    859  1.1      cgd 		return;
    860  1.1      cgd 	bcopy((caddr_t)option, (caddr_t)ip_srcrt.srcopt, olen);
    861  1.1      cgd 	ip_nhops = (olen - IPOPT_OFFSET - 1) / sizeof(struct in_addr);
    862  1.1      cgd 	ip_srcrt.dst = dst;
    863  1.1      cgd }
    864  1.1      cgd 
    865  1.1      cgd /*
    866  1.1      cgd  * Retrieve incoming source route for use in replies,
    867  1.1      cgd  * in the same form used by setsockopt.
    868  1.1      cgd  * The first hop is placed before the options, will be removed later.
    869  1.1      cgd  */
    870  1.1      cgd struct mbuf *
    871  1.1      cgd ip_srcroute()
    872  1.1      cgd {
    873  1.1      cgd 	register struct in_addr *p, *q;
    874  1.1      cgd 	register struct mbuf *m;
    875  1.1      cgd 
    876  1.1      cgd 	if (ip_nhops == 0)
    877  1.1      cgd 		return ((struct mbuf *)0);
    878  1.1      cgd 	m = m_get(M_DONTWAIT, MT_SOOPTS);
    879  1.1      cgd 	if (m == 0)
    880  1.1      cgd 		return ((struct mbuf *)0);
    881  1.1      cgd 
    882  1.6  mycroft #define	OPTSIZ	(sizeof(ip_srcrt.nop) + sizeof(ip_srcrt.srcopt))
    883  1.1      cgd 
    884  1.1      cgd 	/* length is (nhops+1)*sizeof(addr) + sizeof(nop + srcrt header) */
    885  1.1      cgd 	m->m_len = ip_nhops * sizeof(struct in_addr) + sizeof(struct in_addr) +
    886  1.1      cgd 	    OPTSIZ;
    887  1.1      cgd #ifdef DIAGNOSTIC
    888  1.1      cgd 	if (ipprintfs)
    889  1.1      cgd 		printf("ip_srcroute: nhops %d mlen %d", ip_nhops, m->m_len);
    890  1.1      cgd #endif
    891  1.1      cgd 
    892  1.1      cgd 	/*
    893  1.1      cgd 	 * First save first hop for return route
    894  1.1      cgd 	 */
    895  1.1      cgd 	p = &ip_srcrt.route[ip_nhops - 1];
    896  1.1      cgd 	*(mtod(m, struct in_addr *)) = *p--;
    897  1.1      cgd #ifdef DIAGNOSTIC
    898  1.1      cgd 	if (ipprintfs)
    899  1.1      cgd 		printf(" hops %lx", ntohl(mtod(m, struct in_addr *)->s_addr));
    900  1.1      cgd #endif
    901  1.1      cgd 
    902  1.1      cgd 	/*
    903  1.1      cgd 	 * Copy option fields and padding (nop) to mbuf.
    904  1.1      cgd 	 */
    905  1.1      cgd 	ip_srcrt.nop = IPOPT_NOP;
    906  1.1      cgd 	ip_srcrt.srcopt[IPOPT_OFFSET] = IPOPT_MINOFF;
    907  1.1      cgd 	bcopy((caddr_t)&ip_srcrt.nop,
    908  1.1      cgd 	    mtod(m, caddr_t) + sizeof(struct in_addr), OPTSIZ);
    909  1.1      cgd 	q = (struct in_addr *)(mtod(m, caddr_t) +
    910  1.1      cgd 	    sizeof(struct in_addr) + OPTSIZ);
    911  1.1      cgd #undef OPTSIZ
    912  1.1      cgd 	/*
    913  1.1      cgd 	 * Record return path as an IP source route,
    914  1.1      cgd 	 * reversing the path (pointers are now aligned).
    915  1.1      cgd 	 */
    916  1.1      cgd 	while (p >= ip_srcrt.route) {
    917  1.1      cgd #ifdef DIAGNOSTIC
    918  1.1      cgd 		if (ipprintfs)
    919  1.1      cgd 			printf(" %lx", ntohl(q->s_addr));
    920  1.1      cgd #endif
    921  1.1      cgd 		*q++ = *p--;
    922  1.1      cgd 	}
    923  1.1      cgd 	/*
    924  1.1      cgd 	 * Last hop goes to final destination.
    925  1.1      cgd 	 */
    926  1.1      cgd 	*q = ip_srcrt.dst;
    927  1.1      cgd #ifdef DIAGNOSTIC
    928  1.1      cgd 	if (ipprintfs)
    929  1.1      cgd 		printf(" %lx\n", ntohl(q->s_addr));
    930  1.1      cgd #endif
    931  1.1      cgd 	return (m);
    932  1.1      cgd }
    933  1.1      cgd 
    934  1.1      cgd /*
    935  1.1      cgd  * Strip out IP options, at higher
    936  1.1      cgd  * level protocol in the kernel.
    937  1.1      cgd  * Second argument is buffer to which options
    938  1.1      cgd  * will be moved, and return value is their length.
    939  1.1      cgd  * XXX should be deleted; last arg currently ignored.
    940  1.1      cgd  */
    941  1.1      cgd ip_stripoptions(m, mopt)
    942  1.1      cgd 	register struct mbuf *m;
    943  1.1      cgd 	struct mbuf *mopt;
    944  1.1      cgd {
    945  1.1      cgd 	register int i;
    946  1.1      cgd 	struct ip *ip = mtod(m, struct ip *);
    947  1.1      cgd 	register caddr_t opts;
    948  1.1      cgd 	int olen;
    949  1.1      cgd 
    950  1.1      cgd 	olen = (ip->ip_hl<<2) - sizeof (struct ip);
    951  1.1      cgd 	opts = (caddr_t)(ip + 1);
    952  1.1      cgd 	i = m->m_len - (sizeof (struct ip) + olen);
    953  1.1      cgd 	bcopy(opts  + olen, opts, (unsigned)i);
    954  1.1      cgd 	m->m_len -= olen;
    955  1.1      cgd 	if (m->m_flags & M_PKTHDR)
    956  1.1      cgd 		m->m_pkthdr.len -= olen;
    957  1.1      cgd 	ip->ip_hl = sizeof(struct ip) >> 2;
    958  1.1      cgd }
    959  1.1      cgd 
    960  1.1      cgd u_char inetctlerrmap[PRC_NCMDS] = {
    961  1.1      cgd 	0,		0,		0,		0,
    962  1.1      cgd 	0,		EMSGSIZE,	EHOSTDOWN,	EHOSTUNREACH,
    963  1.1      cgd 	EHOSTUNREACH,	EHOSTUNREACH,	ECONNREFUSED,	ECONNREFUSED,
    964  1.1      cgd 	EMSGSIZE,	EHOSTUNREACH,	0,		0,
    965  1.1      cgd 	0,		0,		0,		0,
    966  1.1      cgd 	ENOPROTOOPT
    967  1.1      cgd };
    968  1.1      cgd 
    969  1.1      cgd /*
    970  1.1      cgd  * Forward a packet.  If some error occurs return the sender
    971  1.1      cgd  * an icmp packet.  Note we can't always generate a meaningful
    972  1.1      cgd  * icmp message because icmp doesn't have a large enough repertoire
    973  1.1      cgd  * of codes and types.
    974  1.1      cgd  *
    975  1.1      cgd  * If not forwarding, just drop the packet.  This could be confusing
    976  1.1      cgd  * if ipforwarding was zero but some routing protocol was advancing
    977  1.1      cgd  * us as a gateway to somewhere.  However, we must let the routing
    978  1.1      cgd  * protocol deal with that.
    979  1.1      cgd  *
    980  1.1      cgd  * The srcrt parameter indicates whether the packet is being forwarded
    981  1.1      cgd  * via a source route.
    982  1.1      cgd  */
    983  1.1      cgd ip_forward(m, srcrt)
    984  1.1      cgd 	struct mbuf *m;
    985  1.1      cgd 	int srcrt;
    986  1.1      cgd {
    987  1.1      cgd 	register struct ip *ip = mtod(m, struct ip *);
    988  1.1      cgd 	register struct sockaddr_in *sin;
    989  1.1      cgd 	register struct rtentry *rt;
    990  1.1      cgd 	int error, type = 0, code;
    991  1.1      cgd 	struct mbuf *mcopy;
    992  1.1      cgd 	struct in_addr dest;
    993  1.1      cgd 
    994  1.1      cgd 	dest.s_addr = 0;
    995  1.1      cgd #ifdef DIAGNOSTIC
    996  1.1      cgd 	if (ipprintfs)
    997  1.1      cgd 		printf("forward: src %x dst %x ttl %x\n", ip->ip_src,
    998  1.1      cgd 			ip->ip_dst, ip->ip_ttl);
    999  1.1      cgd #endif
   1000  1.1      cgd 	if (m->m_flags & M_BCAST || in_canforward(ip->ip_dst) == 0) {
   1001  1.1      cgd 		ipstat.ips_cantforward++;
   1002  1.1      cgd 		m_freem(m);
   1003  1.1      cgd 		return;
   1004  1.1      cgd 	}
   1005  1.1      cgd 	HTONS(ip->ip_id);
   1006  1.1      cgd 	if (ip->ip_ttl <= IPTTLDEC) {
   1007  1.1      cgd 		icmp_error(m, ICMP_TIMXCEED, ICMP_TIMXCEED_INTRANS, dest);
   1008  1.1      cgd 		return;
   1009  1.1      cgd 	}
   1010  1.1      cgd 	ip->ip_ttl -= IPTTLDEC;
   1011  1.1      cgd 
   1012  1.1      cgd 	sin = (struct sockaddr_in *)&ipforward_rt.ro_dst;
   1013  1.1      cgd 	if ((rt = ipforward_rt.ro_rt) == 0 ||
   1014  1.1      cgd 	    ip->ip_dst.s_addr != sin->sin_addr.s_addr) {
   1015  1.1      cgd 		if (ipforward_rt.ro_rt) {
   1016  1.1      cgd 			RTFREE(ipforward_rt.ro_rt);
   1017  1.1      cgd 			ipforward_rt.ro_rt = 0;
   1018  1.1      cgd 		}
   1019  1.1      cgd 		sin->sin_family = AF_INET;
   1020  1.1      cgd 		sin->sin_len = sizeof(*sin);
   1021  1.1      cgd 		sin->sin_addr = ip->ip_dst;
   1022  1.1      cgd 
   1023  1.1      cgd 		rtalloc(&ipforward_rt);
   1024  1.1      cgd 		if (ipforward_rt.ro_rt == 0) {
   1025  1.1      cgd 			icmp_error(m, ICMP_UNREACH, ICMP_UNREACH_HOST, dest);
   1026  1.1      cgd 			return;
   1027  1.1      cgd 		}
   1028  1.1      cgd 		rt = ipforward_rt.ro_rt;
   1029  1.1      cgd 	}
   1030  1.1      cgd 
   1031  1.1      cgd 	/*
   1032  1.1      cgd 	 * Save at most 64 bytes of the packet in case
   1033  1.1      cgd 	 * we need to generate an ICMP message to the src.
   1034  1.1      cgd 	 */
   1035  1.1      cgd 	mcopy = m_copy(m, 0, imin((int)ip->ip_len, 64));
   1036  1.1      cgd 
   1037  1.1      cgd #ifdef GATEWAY
   1038  1.1      cgd 	ip_ifmatrix[rt->rt_ifp->if_index +
   1039  1.1      cgd 	     if_index * m->m_pkthdr.rcvif->if_index]++;
   1040  1.1      cgd #endif
   1041  1.1      cgd 	/*
   1042  1.1      cgd 	 * If forwarding packet using same interface that it came in on,
   1043  1.1      cgd 	 * perhaps should send a redirect to sender to shortcut a hop.
   1044  1.1      cgd 	 * Only send redirect if source is sending directly to us,
   1045  1.1      cgd 	 * and if packet was not source routed (or has any options).
   1046  1.1      cgd 	 * Also, don't send redirect if forwarding using a default route
   1047  1.1      cgd 	 * or a route modified by a redirect.
   1048  1.1      cgd 	 */
   1049  1.1      cgd #define	satosin(sa)	((struct sockaddr_in *)(sa))
   1050  1.1      cgd 	if (rt->rt_ifp == m->m_pkthdr.rcvif &&
   1051  1.1      cgd 	    (rt->rt_flags & (RTF_DYNAMIC|RTF_MODIFIED)) == 0 &&
   1052  1.1      cgd 	    satosin(rt_key(rt))->sin_addr.s_addr != 0 &&
   1053  1.1      cgd 	    ipsendredirects && !srcrt) {
   1054  1.1      cgd 		struct in_ifaddr *ia;
   1055  1.1      cgd 		u_long src = ntohl(ip->ip_src.s_addr);
   1056  1.1      cgd 		u_long dst = ntohl(ip->ip_dst.s_addr);
   1057  1.1      cgd 
   1058  1.1      cgd 		if ((ia = ifptoia(m->m_pkthdr.rcvif)) &&
   1059  1.1      cgd 		   (src & ia->ia_subnetmask) == ia->ia_subnet) {
   1060  1.1      cgd 		    if (rt->rt_flags & RTF_GATEWAY)
   1061  1.1      cgd 			dest = satosin(rt->rt_gateway)->sin_addr;
   1062  1.1      cgd 		    else
   1063  1.1      cgd 			dest = ip->ip_dst;
   1064  1.1      cgd 		    /*
   1065  1.1      cgd 		     * If the destination is reached by a route to host,
   1066  1.1      cgd 		     * is on a subnet of a local net, or is directly
   1067  1.1      cgd 		     * on the attached net (!), use host redirect.
   1068  1.1      cgd 		     * (We may be the correct first hop for other subnets.)
   1069  1.1      cgd 		     */
   1070  1.1      cgd #define	RTA(rt)	((struct in_ifaddr *)(rt->rt_ifa))
   1071  1.1      cgd 		    type = ICMP_REDIRECT;
   1072  1.1      cgd 		    if ((rt->rt_flags & RTF_HOST) ||
   1073  1.1      cgd 		        (rt->rt_flags & RTF_GATEWAY) == 0)
   1074  1.1      cgd 			    code = ICMP_REDIRECT_HOST;
   1075  1.1      cgd 		    else if (RTA(rt)->ia_subnetmask != RTA(rt)->ia_netmask &&
   1076  1.1      cgd 		        (dst & RTA(rt)->ia_netmask) ==  RTA(rt)->ia_net)
   1077  1.1      cgd 			    code = ICMP_REDIRECT_HOST;
   1078  1.1      cgd 		    else
   1079  1.1      cgd 			    code = ICMP_REDIRECT_NET;
   1080  1.1      cgd #ifdef DIAGNOSTIC
   1081  1.1      cgd 		    if (ipprintfs)
   1082  1.1      cgd 		        printf("redirect (%d) to %x\n", code, dest.s_addr);
   1083  1.1      cgd #endif
   1084  1.1      cgd 		}
   1085  1.1      cgd 	}
   1086  1.1      cgd 
   1087  1.1      cgd 	error = ip_output(m, (struct mbuf *)0, &ipforward_rt, IP_FORWARDING);
   1088  1.1      cgd 	if (error)
   1089  1.1      cgd 		ipstat.ips_cantforward++;
   1090  1.1      cgd 	else {
   1091  1.1      cgd 		ipstat.ips_forward++;
   1092  1.1      cgd 		if (type)
   1093  1.1      cgd 			ipstat.ips_redirectsent++;
   1094  1.1      cgd 		else {
   1095  1.1      cgd 			if (mcopy)
   1096  1.1      cgd 				m_freem(mcopy);
   1097  1.1      cgd 			return;
   1098  1.1      cgd 		}
   1099  1.1      cgd 	}
   1100  1.1      cgd 	if (mcopy == NULL)
   1101  1.1      cgd 		return;
   1102  1.1      cgd 	switch (error) {
   1103  1.1      cgd 
   1104  1.1      cgd 	case 0:				/* forwarded, but need redirect */
   1105  1.1      cgd 		/* type, code set above */
   1106  1.1      cgd 		break;
   1107  1.1      cgd 
   1108  1.1      cgd 	case ENETUNREACH:		/* shouldn't happen, checked above */
   1109  1.1      cgd 	case EHOSTUNREACH:
   1110  1.1      cgd 	case ENETDOWN:
   1111  1.1      cgd 	case EHOSTDOWN:
   1112  1.1      cgd 	default:
   1113  1.1      cgd 		type = ICMP_UNREACH;
   1114  1.1      cgd 		code = ICMP_UNREACH_HOST;
   1115  1.1      cgd 		break;
   1116  1.1      cgd 
   1117  1.1      cgd 	case EMSGSIZE:
   1118  1.1      cgd 		type = ICMP_UNREACH;
   1119  1.1      cgd 		code = ICMP_UNREACH_NEEDFRAG;
   1120  1.1      cgd 		ipstat.ips_cantfrag++;
   1121  1.1      cgd 		break;
   1122  1.1      cgd 
   1123  1.1      cgd 	case ENOBUFS:
   1124  1.1      cgd 		type = ICMP_SOURCEQUENCH;
   1125  1.1      cgd 		code = 0;
   1126  1.1      cgd 		break;
   1127  1.1      cgd 	}
   1128  1.1      cgd 	icmp_error(mcopy, type, code, dest);
   1129  1.1      cgd }
   1130