Home | History | Annotate | Line # | Download | only in netinet
ip_input.c revision 1.75
      1  1.75   thorpej /*	$NetBSD: ip_input.c,v 1.75 1998/12/18 21:35:11 thorpej Exp $	*/
      2  1.14       cgd 
      3   1.1       cgd /*
      4  1.13   mycroft  * Copyright (c) 1982, 1986, 1988, 1993
      5  1.13   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.14       cgd  *	@(#)ip_input.c	8.2 (Berkeley) 1/4/94
     36  1.71       tls  */
     37  1.71       tls 
     38  1.71       tls /*-
     39  1.71       tls  * Copyright (c) 1998 The NetBSD Foundation, Inc.
     40  1.71       tls  * All rights reserved.
     41  1.71       tls  *
     42  1.71       tls  * This code is derived from software contributed to The NetBSD Foundation
     43  1.71       tls  * by Public Access Networks Corporation ("Panix").  It was developed under
     44  1.71       tls  * contract to Panix by Eric Haszlakiewicz and Thor Lancelot Simon.
     45  1.71       tls  *
     46  1.71       tls  * Redistribution and use in source and binary forms, with or without
     47  1.71       tls  * modification, are permitted provided that the following conditions
     48  1.71       tls  * are met:
     49  1.71       tls  * 1. Redistributions of source code must retain the above copyright
     50  1.71       tls  *    notice, this list of conditions and the following disclaimer.
     51  1.71       tls  * 2. Redistributions in binary form must reproduce the above copyright
     52  1.71       tls  *    notice, this list of conditions and the following disclaimer in the
     53  1.71       tls  *    documentation and/or other materials provided with the distribution.
     54  1.71       tls  * 3. All advertising materials mentioning features or use of this software
     55  1.71       tls  *    must display the following acknowledgement:
     56  1.71       tls  *      This product includes software developed by the NetBSD
     57  1.71       tls  *      Foundation, Inc. and its contributors.
     58  1.71       tls  * 4. Neither the name of The NetBSD Foundation nor the names of its
     59  1.71       tls  *    contributors may be used to endorse or promote products derived
     60  1.71       tls  *    from this software without specific prior written permission.
     61  1.71       tls  *
     62  1.71       tls  * THIS SOFTWARE IS PROVIDED BY THE NETBSD FOUNDATION, INC. AND CONTRIBUTORS
     63  1.71       tls  * ``AS IS'' AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED
     64  1.71       tls  * TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR
     65  1.71       tls  * PURPOSE ARE DISCLAIMED.  IN NO EVENT SHALL THE FOUNDATION OR CONTRIBUTORS
     66  1.71       tls  * BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR
     67  1.71       tls  * CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF
     68  1.71       tls  * SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS
     69  1.71       tls  * INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN
     70  1.71       tls  * CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE)
     71  1.71       tls  * ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE
     72  1.71       tls  * POSSIBILITY OF SUCH DAMAGE.
     73   1.1       cgd  */
     74  1.55    scottr 
     75  1.62      matt #include "opt_gateway.h"
     76  1.69       mrg #include "opt_pfil_hooks.h"
     77  1.55    scottr #include "opt_mrouting.h"
     78   1.1       cgd 
     79   1.5   mycroft #include <sys/param.h>
     80   1.5   mycroft #include <sys/systm.h>
     81   1.5   mycroft #include <sys/malloc.h>
     82   1.5   mycroft #include <sys/mbuf.h>
     83   1.5   mycroft #include <sys/domain.h>
     84   1.5   mycroft #include <sys/protosw.h>
     85   1.5   mycroft #include <sys/socket.h>
     86  1.44   thorpej #include <sys/socketvar.h>
     87   1.5   mycroft #include <sys/errno.h>
     88   1.5   mycroft #include <sys/time.h>
     89   1.5   mycroft #include <sys/kernel.h>
     90  1.28  christos #include <sys/proc.h>
     91  1.72   thorpej #include <sys/pool.h>
     92  1.28  christos 
     93  1.28  christos #include <vm/vm.h>
     94  1.28  christos #include <sys/sysctl.h>
     95   1.1       cgd 
     96   1.5   mycroft #include <net/if.h>
     97  1.44   thorpej #include <net/if_dl.h>
     98   1.5   mycroft #include <net/route.h>
     99  1.45       mrg #include <net/pfil.h>
    100   1.1       cgd 
    101   1.5   mycroft #include <netinet/in.h>
    102   1.5   mycroft #include <netinet/in_systm.h>
    103   1.5   mycroft #include <netinet/ip.h>
    104   1.5   mycroft #include <netinet/in_pcb.h>
    105   1.5   mycroft #include <netinet/in_var.h>
    106   1.5   mycroft #include <netinet/ip_var.h>
    107   1.5   mycroft #include <netinet/ip_icmp.h>
    108  1.44   thorpej 
    109   1.1       cgd #ifndef	IPFORWARDING
    110   1.1       cgd #ifdef GATEWAY
    111   1.1       cgd #define	IPFORWARDING	1	/* forward IP packets not for us */
    112   1.1       cgd #else /* GATEWAY */
    113   1.1       cgd #define	IPFORWARDING	0	/* don't forward IP packets not for us */
    114   1.1       cgd #endif /* GATEWAY */
    115   1.1       cgd #endif /* IPFORWARDING */
    116   1.1       cgd #ifndef	IPSENDREDIRECTS
    117   1.1       cgd #define	IPSENDREDIRECTS	1
    118   1.1       cgd #endif
    119  1.26   thorpej #ifndef IPFORWSRCRT
    120  1.47       cjs #define	IPFORWSRCRT	1	/* forward source-routed packets */
    121  1.47       cjs #endif
    122  1.47       cjs #ifndef IPALLOWSRCRT
    123  1.48       mrg #define	IPALLOWSRCRT	1	/* allow source-routed packets */
    124  1.26   thorpej #endif
    125  1.53       kml #ifndef IPMTUDISC
    126  1.53       kml #define IPMTUDISC	0
    127  1.53       kml #endif
    128  1.60       kml #ifndef IPMTUDISCTIMEOUT
    129  1.61       kml #define IPMTUDISCTIMEOUT (10 * 60)	/* as per RFC 1191 */
    130  1.60       kml #endif
    131  1.53       kml 
    132  1.27   thorpej /*
    133  1.27   thorpej  * Note: DIRECTED_BROADCAST is handled this way so that previous
    134  1.27   thorpej  * configuration using this option will Just Work.
    135  1.27   thorpej  */
    136  1.27   thorpej #ifndef IPDIRECTEDBCAST
    137  1.27   thorpej #ifdef DIRECTED_BROADCAST
    138  1.27   thorpej #define IPDIRECTEDBCAST	1
    139  1.27   thorpej #else
    140  1.27   thorpej #define	IPDIRECTEDBCAST	0
    141  1.27   thorpej #endif /* DIRECTED_BROADCAST */
    142  1.27   thorpej #endif /* IPDIRECTEDBCAST */
    143   1.1       cgd int	ipforwarding = IPFORWARDING;
    144   1.1       cgd int	ipsendredirects = IPSENDREDIRECTS;
    145  1.13   mycroft int	ip_defttl = IPDEFTTL;
    146  1.26   thorpej int	ip_forwsrcrt = IPFORWSRCRT;
    147  1.27   thorpej int	ip_directedbcast = IPDIRECTEDBCAST;
    148  1.47       cjs int	ip_allowsrcrt = IPALLOWSRCRT;
    149  1.53       kml int	ip_mtudisc = IPMTUDISC;
    150  1.60       kml u_int	ip_mtudisc_timeout = IPMTUDISCTIMEOUT;
    151   1.1       cgd #ifdef DIAGNOSTIC
    152   1.1       cgd int	ipprintfs = 0;
    153   1.1       cgd #endif
    154   1.1       cgd 
    155  1.60       kml struct rttimer_queue *ip_mtudisc_timeout_q = NULL;
    156  1.60       kml 
    157   1.1       cgd extern	struct domain inetdomain;
    158   1.1       cgd extern	struct protosw inetsw[];
    159   1.1       cgd u_char	ip_protox[IPPROTO_MAX];
    160   1.1       cgd int	ipqmaxlen = IFQ_MAXLEN;
    161  1.22   mycroft struct	in_ifaddrhead in_ifaddr;
    162  1.57       tls struct	in_ifaddrhashhead *in_ifaddrhashtbl;
    163  1.13   mycroft struct	ifqueue ipintrq;
    164  1.63      matt struct	ipstat	ipstat;
    165  1.63      matt u_int16_t	ip_id;
    166  1.63      matt int	ip_defttl;
    167  1.75   thorpej 
    168  1.63      matt struct ipqhead ipq;
    169  1.75   thorpej int	ipq_locked;
    170  1.75   thorpej 
    171  1.75   thorpej static __inline int ipq_lock_try __P((void));
    172  1.75   thorpej static __inline void ipq_unlock __P((void));
    173  1.75   thorpej 
    174  1.75   thorpej static __inline int
    175  1.75   thorpej ipq_lock_try()
    176  1.75   thorpej {
    177  1.75   thorpej 	int s;
    178  1.75   thorpej 
    179  1.75   thorpej 	s = splimp();
    180  1.75   thorpej 	if (ipq_locked) {
    181  1.75   thorpej 		splx(s);
    182  1.75   thorpej 		return (0);
    183  1.75   thorpej 	}
    184  1.75   thorpej 	ipq_locked = 1;
    185  1.75   thorpej 	splx(s);
    186  1.75   thorpej 	return (1);
    187  1.75   thorpej }
    188  1.75   thorpej 
    189  1.75   thorpej static __inline void
    190  1.75   thorpej ipq_unlock()
    191  1.75   thorpej {
    192  1.75   thorpej 	int s;
    193  1.75   thorpej 
    194  1.75   thorpej 	s = splimp();
    195  1.75   thorpej 	ipq_locked = 0;
    196  1.75   thorpej 	splx(s);
    197  1.75   thorpej }
    198  1.75   thorpej 
    199  1.75   thorpej #ifdef DIAGNOSTIC
    200  1.75   thorpej #define	IPQ_LOCK()							\
    201  1.75   thorpej do {									\
    202  1.75   thorpej 	if (ipq_lock_try() == 0) {					\
    203  1.75   thorpej 		printf("%s:%d: ipq already locked\n", __FILE__, __LINE__); \
    204  1.75   thorpej 		panic("ipq_lock");					\
    205  1.75   thorpej 	}								\
    206  1.75   thorpej } while (0)
    207  1.75   thorpej #define	IPQ_LOCK_CHECK()						\
    208  1.75   thorpej do {									\
    209  1.75   thorpej 	if (ipq_locked == 0) {						\
    210  1.75   thorpej 		printf("%s:%d: ipq lock not held\n", __FILE__, __LINE__); \
    211  1.75   thorpej 		panic("ipq lock check");				\
    212  1.75   thorpej 	}								\
    213  1.75   thorpej } while (0)
    214  1.75   thorpej #else
    215  1.75   thorpej #define	IPQ_LOCK()		(void) ipq_lock_try()
    216  1.75   thorpej #define	IPQ_LOCK_CHECK()	/* nothing */
    217  1.75   thorpej #endif
    218  1.75   thorpej 
    219  1.75   thorpej #define	IPQ_UNLOCK()		ipq_unlock()
    220   1.1       cgd 
    221  1.72   thorpej struct pool ipqent_pool;
    222  1.72   thorpej 
    223   1.1       cgd /*
    224   1.1       cgd  * We need to save the IP options in case a protocol wants to respond
    225   1.1       cgd  * to an incoming packet over the same route if the packet got here
    226   1.1       cgd  * using IP source routing.  This allows connection establishment and
    227   1.1       cgd  * maintenance when the remote end is on a network that is not known
    228   1.1       cgd  * to us.
    229   1.1       cgd  */
    230   1.1       cgd int	ip_nhops = 0;
    231   1.1       cgd static	struct ip_srcrt {
    232   1.1       cgd 	struct	in_addr dst;			/* final destination */
    233   1.1       cgd 	char	nop;				/* one NOP to align */
    234   1.1       cgd 	char	srcopt[IPOPT_OFFSET + 1];	/* OPTVAL, OLEN and OFFSET */
    235   1.1       cgd 	struct	in_addr route[MAX_IPOPTLEN/sizeof(struct in_addr)];
    236   1.1       cgd } ip_srcrt;
    237   1.1       cgd 
    238  1.13   mycroft static void save_rte __P((u_char *, struct in_addr));
    239  1.35   mycroft 
    240   1.1       cgd /*
    241   1.1       cgd  * IP initialization: fill in IP protocol switch table.
    242   1.1       cgd  * All protocols not implemented in kernel go to raw IP protocol handler.
    243   1.1       cgd  */
    244   1.8   mycroft void
    245   1.1       cgd ip_init()
    246   1.1       cgd {
    247   1.1       cgd 	register struct protosw *pr;
    248   1.1       cgd 	register int i;
    249   1.1       cgd 
    250  1.72   thorpej 	pool_init(&ipqent_pool, sizeof(struct ipqent), 0, 0, 0, "ipqepl",
    251  1.72   thorpej 	    0, NULL, NULL, M_IPQ);
    252  1.72   thorpej 
    253   1.1       cgd 	pr = pffindproto(PF_INET, IPPROTO_RAW, SOCK_RAW);
    254   1.1       cgd 	if (pr == 0)
    255   1.1       cgd 		panic("ip_init");
    256   1.1       cgd 	for (i = 0; i < IPPROTO_MAX; i++)
    257   1.1       cgd 		ip_protox[i] = pr - inetsw;
    258   1.1       cgd 	for (pr = inetdomain.dom_protosw;
    259   1.1       cgd 	    pr < inetdomain.dom_protoswNPROTOSW; pr++)
    260   1.1       cgd 		if (pr->pr_domain->dom_family == PF_INET &&
    261   1.1       cgd 		    pr->pr_protocol && pr->pr_protocol != IPPROTO_RAW)
    262   1.1       cgd 			ip_protox[pr->pr_protocol] = pr - inetsw;
    263  1.25       cgd 	LIST_INIT(&ipq);
    264   1.1       cgd 	ip_id = time.tv_sec & 0xffff;
    265   1.1       cgd 	ipintrq.ifq_maxlen = ipqmaxlen;
    266  1.22   mycroft 	TAILQ_INIT(&in_ifaddr);
    267  1.57       tls 	in_ifaddrhashtbl =
    268  1.57       tls 	    hashinit(IN_IFADDR_HASH_SIZE, M_IFADDR, M_WAITOK, &in_ifaddrhash);
    269  1.60       kml 	if (ip_mtudisc != 0)
    270  1.60       kml 		ip_mtudisc_timeout_q =
    271  1.60       kml 		    rt_timer_queue_create(ip_mtudisc_timeout);
    272  1.73   thorpej #ifdef GATEWAY
    273  1.73   thorpej 	ipflow_init();
    274  1.73   thorpej #endif
    275   1.1       cgd }
    276   1.1       cgd 
    277   1.1       cgd struct	sockaddr_in ipaddr = { sizeof(ipaddr), AF_INET };
    278   1.1       cgd struct	route ipforward_rt;
    279   1.1       cgd 
    280   1.1       cgd /*
    281   1.1       cgd  * Ip input routine.  Checksum and byte swap header.  If fragmented
    282   1.1       cgd  * try to reassemble.  Process options.  Pass to next level.
    283   1.1       cgd  */
    284   1.8   mycroft void
    285   1.1       cgd ipintr()
    286   1.1       cgd {
    287  1.33       mrg 	register struct ip *ip = NULL;
    288   1.1       cgd 	register struct mbuf *m;
    289   1.1       cgd 	register struct ipq *fp;
    290   1.1       cgd 	register struct in_ifaddr *ia;
    291  1.57       tls 	register struct ifaddr *ifa;
    292  1.25       cgd 	struct ipqent *ipqe;
    293  1.35   mycroft 	int hlen = 0, mff, len, s;
    294  1.36       mrg #ifdef PFIL_HOOKS
    295  1.33       mrg 	struct packet_filter_hook *pfh;
    296  1.33       mrg 	struct mbuf *m0;
    297  1.43       mrg 	int rv;
    298  1.36       mrg #endif /* PFIL_HOOKS */
    299   1.1       cgd 
    300   1.1       cgd next:
    301   1.1       cgd 	/*
    302   1.1       cgd 	 * Get next datagram off input queue and get IP header
    303   1.1       cgd 	 * in first mbuf.
    304   1.1       cgd 	 */
    305   1.1       cgd 	s = splimp();
    306   1.1       cgd 	IF_DEQUEUE(&ipintrq, m);
    307   1.1       cgd 	splx(s);
    308  1.13   mycroft 	if (m == 0)
    309   1.1       cgd 		return;
    310   1.1       cgd #ifdef	DIAGNOSTIC
    311   1.1       cgd 	if ((m->m_flags & M_PKTHDR) == 0)
    312   1.1       cgd 		panic("ipintr no HDR");
    313   1.1       cgd #endif
    314   1.1       cgd 	/*
    315   1.1       cgd 	 * If no IP addresses have been set yet but the interfaces
    316   1.1       cgd 	 * are receiving, can't do anything with incoming packets yet.
    317   1.1       cgd 	 */
    318  1.22   mycroft 	if (in_ifaddr.tqh_first == 0)
    319   1.1       cgd 		goto bad;
    320   1.1       cgd 	ipstat.ips_total++;
    321   1.1       cgd 	if (m->m_len < sizeof (struct ip) &&
    322   1.1       cgd 	    (m = m_pullup(m, sizeof (struct ip))) == 0) {
    323   1.1       cgd 		ipstat.ips_toosmall++;
    324   1.1       cgd 		goto next;
    325   1.1       cgd 	}
    326   1.1       cgd 	ip = mtod(m, struct ip *);
    327  1.13   mycroft 	if (ip->ip_v != IPVERSION) {
    328  1.13   mycroft 		ipstat.ips_badvers++;
    329  1.13   mycroft 		goto bad;
    330  1.13   mycroft 	}
    331   1.1       cgd 	hlen = ip->ip_hl << 2;
    332   1.1       cgd 	if (hlen < sizeof(struct ip)) {	/* minimum header length */
    333   1.1       cgd 		ipstat.ips_badhlen++;
    334   1.1       cgd 		goto bad;
    335   1.1       cgd 	}
    336   1.1       cgd 	if (hlen > m->m_len) {
    337   1.1       cgd 		if ((m = m_pullup(m, hlen)) == 0) {
    338   1.1       cgd 			ipstat.ips_badhlen++;
    339   1.1       cgd 			goto next;
    340   1.1       cgd 		}
    341   1.1       cgd 		ip = mtod(m, struct ip *);
    342   1.1       cgd 	}
    343  1.28  christos 	if ((ip->ip_sum = in_cksum(m, hlen)) != 0) {
    344   1.1       cgd 		ipstat.ips_badsum++;
    345   1.1       cgd 		goto bad;
    346   1.1       cgd 	}
    347   1.1       cgd 
    348   1.1       cgd 	/*
    349   1.1       cgd 	 * Convert fields to host representation.
    350   1.1       cgd 	 */
    351   1.1       cgd 	NTOHS(ip->ip_len);
    352   1.1       cgd 	NTOHS(ip->ip_id);
    353   1.1       cgd 	NTOHS(ip->ip_off);
    354  1.35   mycroft 	len = ip->ip_len;
    355   1.1       cgd 
    356   1.1       cgd 	/*
    357   1.1       cgd 	 * Check that the amount of data in the buffers
    358   1.1       cgd 	 * is as at least much as the IP header would have us expect.
    359   1.1       cgd 	 * Trim mbufs if longer than we expect.
    360   1.1       cgd 	 * Drop packet if shorter than we expect.
    361   1.1       cgd 	 */
    362  1.35   mycroft 	if (m->m_pkthdr.len < len) {
    363   1.1       cgd 		ipstat.ips_tooshort++;
    364   1.1       cgd 		goto bad;
    365   1.1       cgd 	}
    366  1.35   mycroft 	if (m->m_pkthdr.len > len) {
    367   1.1       cgd 		if (m->m_len == m->m_pkthdr.len) {
    368  1.35   mycroft 			m->m_len = len;
    369  1.35   mycroft 			m->m_pkthdr.len = len;
    370   1.1       cgd 		} else
    371  1.35   mycroft 			m_adj(m, len - m->m_pkthdr.len);
    372   1.1       cgd 	}
    373   1.1       cgd 
    374  1.64   thorpej 	/*
    375  1.64   thorpej 	 * Assume that we can create a fast-forward IP flow entry
    376  1.64   thorpej 	 * based on this packet.
    377  1.64   thorpej 	 */
    378  1.64   thorpej 	m->m_flags |= M_CANFASTFWD;
    379  1.64   thorpej 
    380  1.36       mrg #ifdef PFIL_HOOKS
    381  1.33       mrg 	/*
    382  1.64   thorpej 	 * Run through list of hooks for input packets.  If there are any
    383  1.64   thorpej 	 * filters which require that additional packets in the flow are
    384  1.64   thorpej 	 * not fast-forwarded, they must clear the M_CANFASTFWD flag.
    385  1.64   thorpej 	 * Note that filters must _never_ set this flag, as another filter
    386  1.64   thorpej 	 * in the list may have previously cleared it.
    387  1.33       mrg 	 */
    388  1.33       mrg 	m0 = m;
    389  1.59       mrg 	for (pfh = pfil_hook_get(PFIL_IN); pfh; pfh = pfh->pfil_link.tqe_next)
    390  1.33       mrg 		if (pfh->pfil_func) {
    391  1.43       mrg 			rv = pfh->pfil_func(ip, hlen, m->m_pkthdr.rcvif, 0, &m0);
    392  1.43       mrg 			if (rv)
    393  1.40     veego 				goto next;
    394  1.68  sommerfe 			m = m0;
    395  1.68  sommerfe 			if (m == NULL)
    396  1.68  sommerfe 				goto next;
    397  1.68  sommerfe 			ip = mtod(m, struct ip *);
    398  1.33       mrg 		}
    399  1.36       mrg #endif /* PFIL_HOOKS */
    400  1.33       mrg 
    401   1.1       cgd 	/*
    402   1.1       cgd 	 * Process options and, if not destined for us,
    403   1.1       cgd 	 * ship it on.  ip_dooptions returns 1 when an
    404   1.1       cgd 	 * error was detected (causing an icmp message
    405   1.1       cgd 	 * to be sent and the original packet to be freed).
    406   1.1       cgd 	 */
    407   1.1       cgd 	ip_nhops = 0;		/* for source routed packets */
    408   1.1       cgd 	if (hlen > sizeof (struct ip) && ip_dooptions(m))
    409   1.1       cgd 		goto next;
    410   1.1       cgd 
    411   1.1       cgd 	/*
    412   1.1       cgd 	 * Check our list of addresses, to see if the packet is for us.
    413   1.1       cgd 	 */
    414  1.57       tls 	INADDR_TO_IA(ip->ip_dst, ia);
    415  1.57       tls 	if (ia != NULL) goto ours;
    416  1.57       tls 	if (m->m_pkthdr.rcvif->if_flags & IFF_BROADCAST) {
    417  1.57       tls 		for (ifa = m->m_pkthdr.rcvif->if_addrlist.tqh_first;
    418  1.57       tls 		    ifa != NULL; ifa = ifa->ifa_list.tqe_next) {
    419  1.57       tls 			if (ifa->ifa_addr->sa_family != AF_INET) continue;
    420  1.57       tls 			ia = ifatoia(ifa);
    421  1.35   mycroft 			if (in_hosteq(ip->ip_dst, ia->ia_broadaddr.sin_addr) ||
    422  1.35   mycroft 			    in_hosteq(ip->ip_dst, ia->ia_netbroadcast) ||
    423  1.20   mycroft 			    /*
    424  1.20   mycroft 			     * Look for all-0's host part (old broadcast addr),
    425  1.20   mycroft 			     * either for subnet or net.
    426  1.20   mycroft 			     */
    427  1.20   mycroft 			    ip->ip_dst.s_addr == ia->ia_subnet ||
    428  1.18   mycroft 			    ip->ip_dst.s_addr == ia->ia_net)
    429   1.1       cgd 				goto ours;
    430  1.57       tls 			/*
    431  1.57       tls 			 * An interface with IP address zero accepts
    432  1.57       tls 			 * all packets that arrive on that interface.
    433  1.57       tls 			 */
    434  1.57       tls 			if (in_nullhost(ia->ia_addr.sin_addr))
    435  1.57       tls 				goto ours;
    436   1.1       cgd 		}
    437   1.1       cgd 	}
    438  1.18   mycroft 	if (IN_MULTICAST(ip->ip_dst.s_addr)) {
    439   1.4   hpeyerl 		struct in_multi *inm;
    440   1.4   hpeyerl #ifdef MROUTING
    441   1.4   hpeyerl 		extern struct socket *ip_mrouter;
    442  1.10    brezak 
    443  1.10    brezak 		if (m->m_flags & M_EXT) {
    444  1.10    brezak 			if ((m = m_pullup(m, hlen)) == 0) {
    445  1.10    brezak 				ipstat.ips_toosmall++;
    446  1.10    brezak 				goto next;
    447  1.10    brezak 			}
    448  1.10    brezak 			ip = mtod(m, struct ip *);
    449  1.10    brezak 		}
    450   1.4   hpeyerl 
    451   1.4   hpeyerl 		if (ip_mrouter) {
    452   1.4   hpeyerl 			/*
    453   1.4   hpeyerl 			 * If we are acting as a multicast router, all
    454   1.4   hpeyerl 			 * incoming multicast packets are passed to the
    455   1.4   hpeyerl 			 * kernel-level multicast forwarding function.
    456   1.4   hpeyerl 			 * The packet is returned (relatively) intact; if
    457   1.4   hpeyerl 			 * ip_mforward() returns a non-zero value, the packet
    458   1.4   hpeyerl 			 * must be discarded, else it may be accepted below.
    459   1.4   hpeyerl 			 *
    460   1.4   hpeyerl 			 * (The IP ident field is put in the same byte order
    461   1.4   hpeyerl 			 * as expected when ip_mforward() is called from
    462   1.4   hpeyerl 			 * ip_output().)
    463   1.4   hpeyerl 			 */
    464   1.4   hpeyerl 			ip->ip_id = htons(ip->ip_id);
    465  1.13   mycroft 			if (ip_mforward(m, m->m_pkthdr.rcvif) != 0) {
    466  1.13   mycroft 				ipstat.ips_cantforward++;
    467   1.4   hpeyerl 				m_freem(m);
    468   1.4   hpeyerl 				goto next;
    469   1.4   hpeyerl 			}
    470   1.4   hpeyerl 			ip->ip_id = ntohs(ip->ip_id);
    471   1.4   hpeyerl 
    472   1.4   hpeyerl 			/*
    473   1.4   hpeyerl 			 * The process-level routing demon needs to receive
    474   1.4   hpeyerl 			 * all multicast IGMP packets, whether or not this
    475   1.4   hpeyerl 			 * host belongs to their destination groups.
    476   1.4   hpeyerl 			 */
    477   1.4   hpeyerl 			if (ip->ip_p == IPPROTO_IGMP)
    478   1.4   hpeyerl 				goto ours;
    479  1.13   mycroft 			ipstat.ips_forward++;
    480   1.4   hpeyerl 		}
    481   1.4   hpeyerl #endif
    482   1.4   hpeyerl 		/*
    483   1.4   hpeyerl 		 * See if we belong to the destination multicast group on the
    484   1.4   hpeyerl 		 * arrival interface.
    485   1.4   hpeyerl 		 */
    486   1.4   hpeyerl 		IN_LOOKUP_MULTI(ip->ip_dst, m->m_pkthdr.rcvif, inm);
    487   1.4   hpeyerl 		if (inm == NULL) {
    488  1.13   mycroft 			ipstat.ips_cantforward++;
    489   1.4   hpeyerl 			m_freem(m);
    490   1.4   hpeyerl 			goto next;
    491   1.4   hpeyerl 		}
    492   1.4   hpeyerl 		goto ours;
    493   1.4   hpeyerl 	}
    494  1.19   mycroft 	if (ip->ip_dst.s_addr == INADDR_BROADCAST ||
    495  1.35   mycroft 	    in_nullhost(ip->ip_dst))
    496   1.1       cgd 		goto ours;
    497   1.1       cgd 
    498   1.1       cgd 	/*
    499   1.1       cgd 	 * Not for us; forward if possible and desirable.
    500   1.1       cgd 	 */
    501   1.1       cgd 	if (ipforwarding == 0) {
    502   1.1       cgd 		ipstat.ips_cantforward++;
    503   1.1       cgd 		m_freem(m);
    504   1.1       cgd 	} else
    505   1.1       cgd 		ip_forward(m, 0);
    506   1.1       cgd 	goto next;
    507   1.1       cgd 
    508   1.1       cgd ours:
    509   1.1       cgd 	/*
    510   1.1       cgd 	 * If offset or IP_MF are set, must reassemble.
    511   1.1       cgd 	 * Otherwise, nothing need be done.
    512   1.1       cgd 	 * (We could look in the reassembly queue to see
    513   1.1       cgd 	 * if the packet was previously fragmented,
    514   1.1       cgd 	 * but it's not worth the time; just let them time out.)
    515   1.1       cgd 	 */
    516  1.37     perry 	if (ip->ip_off & ~(IP_DF|IP_RF)) {
    517   1.1       cgd 		/*
    518   1.1       cgd 		 * Look for queue of fragments
    519   1.1       cgd 		 * of this datagram.
    520   1.1       cgd 		 */
    521  1.75   thorpej 		IPQ_LOCK();
    522  1.25       cgd 		for (fp = ipq.lh_first; fp != NULL; fp = fp->ipq_q.le_next)
    523   1.1       cgd 			if (ip->ip_id == fp->ipq_id &&
    524  1.35   mycroft 			    in_hosteq(ip->ip_src, fp->ipq_src) &&
    525  1.35   mycroft 			    in_hosteq(ip->ip_dst, fp->ipq_dst) &&
    526   1.1       cgd 			    ip->ip_p == fp->ipq_p)
    527   1.1       cgd 				goto found;
    528   1.1       cgd 		fp = 0;
    529   1.1       cgd found:
    530   1.1       cgd 
    531   1.1       cgd 		/*
    532   1.1       cgd 		 * Adjust ip_len to not reflect header,
    533  1.25       cgd 		 * set ipqe_mff if more fragments are expected,
    534   1.1       cgd 		 * convert offset of this to bytes.
    535   1.1       cgd 		 */
    536   1.1       cgd 		ip->ip_len -= hlen;
    537  1.25       cgd 		mff = (ip->ip_off & IP_MF) != 0;
    538  1.25       cgd 		if (mff) {
    539  1.16       cgd 		        /*
    540  1.16       cgd 		         * Make sure that fragments have a data length
    541  1.16       cgd 			 * that's a non-zero multiple of 8 bytes.
    542  1.16       cgd 		         */
    543  1.17       cgd 			if (ip->ip_len == 0 || (ip->ip_len & 0x7) != 0) {
    544  1.16       cgd 				ipstat.ips_badfrags++;
    545  1.75   thorpej 				IPQ_UNLOCK();
    546  1.16       cgd 				goto bad;
    547  1.16       cgd 			}
    548  1.16       cgd 		}
    549   1.1       cgd 		ip->ip_off <<= 3;
    550   1.1       cgd 
    551   1.1       cgd 		/*
    552   1.1       cgd 		 * If datagram marked as having more fragments
    553   1.1       cgd 		 * or if this is not the first fragment,
    554   1.1       cgd 		 * attempt reassembly; if it succeeds, proceed.
    555   1.1       cgd 		 */
    556  1.25       cgd 		if (mff || ip->ip_off) {
    557   1.1       cgd 			ipstat.ips_fragments++;
    558  1.72   thorpej 			ipqe = pool_get(&ipqent_pool, PR_NOWAIT);
    559  1.25       cgd 			if (ipqe == NULL) {
    560  1.25       cgd 				ipstat.ips_rcvmemdrop++;
    561  1.75   thorpej 				IPQ_UNLOCK();
    562  1.25       cgd 				goto bad;
    563  1.25       cgd 			}
    564  1.25       cgd 			ipqe->ipqe_mff = mff;
    565  1.50   thorpej 			ipqe->ipqe_m = m;
    566  1.25       cgd 			ipqe->ipqe_ip = ip;
    567  1.50   thorpej 			m = ip_reass(ipqe, fp);
    568  1.75   thorpej 			if (m == 0) {
    569  1.75   thorpej 				IPQ_UNLOCK();
    570   1.1       cgd 				goto next;
    571  1.75   thorpej 			}
    572  1.13   mycroft 			ipstat.ips_reassembled++;
    573  1.50   thorpej 			ip = mtod(m, struct ip *);
    574  1.74   thorpej 			hlen = ip->ip_hl << 2;
    575   1.1       cgd 		} else
    576   1.1       cgd 			if (fp)
    577   1.1       cgd 				ip_freef(fp);
    578  1.75   thorpej 		IPQ_UNLOCK();
    579   1.1       cgd 	} else
    580   1.1       cgd 		ip->ip_len -= hlen;
    581   1.1       cgd 
    582   1.1       cgd 	/*
    583   1.1       cgd 	 * Switch out to protocol's input routine.
    584   1.1       cgd 	 */
    585   1.1       cgd 	ipstat.ips_delivered++;
    586   1.1       cgd 	(*inetsw[ip_protox[ip->ip_p]].pr_input)(m, hlen);
    587   1.1       cgd 	goto next;
    588   1.1       cgd bad:
    589   1.1       cgd 	m_freem(m);
    590   1.1       cgd 	goto next;
    591   1.1       cgd }
    592   1.1       cgd 
    593   1.1       cgd /*
    594   1.1       cgd  * Take incoming datagram fragment and try to
    595   1.1       cgd  * reassemble it into whole datagram.  If a chain for
    596   1.1       cgd  * reassembly of this datagram already exists, then it
    597   1.1       cgd  * is given as fp; otherwise have to make a chain.
    598   1.1       cgd  */
    599  1.50   thorpej struct mbuf *
    600  1.25       cgd ip_reass(ipqe, fp)
    601  1.25       cgd 	register struct ipqent *ipqe;
    602   1.1       cgd 	register struct ipq *fp;
    603   1.1       cgd {
    604  1.50   thorpej 	register struct mbuf *m = ipqe->ipqe_m;
    605  1.25       cgd 	register struct ipqent *nq, *p, *q;
    606  1.25       cgd 	struct ip *ip;
    607   1.1       cgd 	struct mbuf *t;
    608  1.25       cgd 	int hlen = ipqe->ipqe_ip->ip_hl << 2;
    609   1.1       cgd 	int i, next;
    610   1.1       cgd 
    611  1.75   thorpej 	IPQ_LOCK_CHECK();
    612  1.75   thorpej 
    613   1.1       cgd 	/*
    614   1.1       cgd 	 * Presence of header sizes in mbufs
    615   1.1       cgd 	 * would confuse code below.
    616   1.1       cgd 	 */
    617   1.1       cgd 	m->m_data += hlen;
    618   1.1       cgd 	m->m_len -= hlen;
    619   1.1       cgd 
    620   1.1       cgd 	/*
    621   1.1       cgd 	 * If first fragment to arrive, create a reassembly queue.
    622   1.1       cgd 	 */
    623   1.1       cgd 	if (fp == 0) {
    624  1.50   thorpej 		MALLOC(fp, struct ipq *, sizeof (struct ipq),
    625  1.50   thorpej 		    M_FTABLE, M_NOWAIT);
    626  1.50   thorpej 		if (fp == NULL)
    627   1.1       cgd 			goto dropfrag;
    628  1.25       cgd 		LIST_INSERT_HEAD(&ipq, fp, ipq_q);
    629   1.1       cgd 		fp->ipq_ttl = IPFRAGTTL;
    630  1.25       cgd 		fp->ipq_p = ipqe->ipqe_ip->ip_p;
    631  1.25       cgd 		fp->ipq_id = ipqe->ipqe_ip->ip_id;
    632  1.25       cgd 		LIST_INIT(&fp->ipq_fragq);
    633  1.25       cgd 		fp->ipq_src = ipqe->ipqe_ip->ip_src;
    634  1.25       cgd 		fp->ipq_dst = ipqe->ipqe_ip->ip_dst;
    635  1.25       cgd 		p = NULL;
    636   1.1       cgd 		goto insert;
    637   1.1       cgd 	}
    638   1.1       cgd 
    639   1.1       cgd 	/*
    640   1.1       cgd 	 * Find a segment which begins after this one does.
    641   1.1       cgd 	 */
    642  1.25       cgd 	for (p = NULL, q = fp->ipq_fragq.lh_first; q != NULL;
    643  1.25       cgd 	    p = q, q = q->ipqe_q.le_next)
    644  1.25       cgd 		if (q->ipqe_ip->ip_off > ipqe->ipqe_ip->ip_off)
    645   1.1       cgd 			break;
    646   1.1       cgd 
    647   1.1       cgd 	/*
    648   1.1       cgd 	 * If there is a preceding segment, it may provide some of
    649   1.1       cgd 	 * our data already.  If so, drop the data from the incoming
    650   1.1       cgd 	 * segment.  If it provides all of our data, drop us.
    651   1.1       cgd 	 */
    652  1.25       cgd 	if (p != NULL) {
    653  1.25       cgd 		i = p->ipqe_ip->ip_off + p->ipqe_ip->ip_len -
    654  1.25       cgd 		    ipqe->ipqe_ip->ip_off;
    655   1.1       cgd 		if (i > 0) {
    656  1.25       cgd 			if (i >= ipqe->ipqe_ip->ip_len)
    657   1.1       cgd 				goto dropfrag;
    658  1.50   thorpej 			m_adj(ipqe->ipqe_m, i);
    659  1.25       cgd 			ipqe->ipqe_ip->ip_off += i;
    660  1.25       cgd 			ipqe->ipqe_ip->ip_len -= i;
    661   1.1       cgd 		}
    662   1.1       cgd 	}
    663   1.1       cgd 
    664   1.1       cgd 	/*
    665   1.1       cgd 	 * While we overlap succeeding segments trim them or,
    666   1.1       cgd 	 * if they are completely covered, dequeue them.
    667   1.1       cgd 	 */
    668  1.25       cgd 	for (; q != NULL && ipqe->ipqe_ip->ip_off + ipqe->ipqe_ip->ip_len >
    669  1.25       cgd 	    q->ipqe_ip->ip_off; q = nq) {
    670  1.25       cgd 		i = (ipqe->ipqe_ip->ip_off + ipqe->ipqe_ip->ip_len) -
    671  1.25       cgd 		    q->ipqe_ip->ip_off;
    672  1.25       cgd 		if (i < q->ipqe_ip->ip_len) {
    673  1.25       cgd 			q->ipqe_ip->ip_len -= i;
    674  1.25       cgd 			q->ipqe_ip->ip_off += i;
    675  1.50   thorpej 			m_adj(q->ipqe_m, i);
    676   1.1       cgd 			break;
    677   1.1       cgd 		}
    678  1.25       cgd 		nq = q->ipqe_q.le_next;
    679  1.50   thorpej 		m_freem(q->ipqe_m);
    680  1.25       cgd 		LIST_REMOVE(q, ipqe_q);
    681  1.72   thorpej 		pool_put(&ipqent_pool, q);
    682   1.1       cgd 	}
    683   1.1       cgd 
    684   1.1       cgd insert:
    685   1.1       cgd 	/*
    686   1.1       cgd 	 * Stick new segment in its place;
    687   1.1       cgd 	 * check for complete reassembly.
    688   1.1       cgd 	 */
    689  1.25       cgd 	if (p == NULL) {
    690  1.25       cgd 		LIST_INSERT_HEAD(&fp->ipq_fragq, ipqe, ipqe_q);
    691  1.25       cgd 	} else {
    692  1.25       cgd 		LIST_INSERT_AFTER(p, ipqe, ipqe_q);
    693  1.25       cgd 	}
    694   1.1       cgd 	next = 0;
    695  1.25       cgd 	for (p = NULL, q = fp->ipq_fragq.lh_first; q != NULL;
    696  1.25       cgd 	    p = q, q = q->ipqe_q.le_next) {
    697  1.25       cgd 		if (q->ipqe_ip->ip_off != next)
    698   1.1       cgd 			return (0);
    699  1.25       cgd 		next += q->ipqe_ip->ip_len;
    700   1.1       cgd 	}
    701  1.25       cgd 	if (p->ipqe_mff)
    702   1.1       cgd 		return (0);
    703   1.1       cgd 
    704   1.1       cgd 	/*
    705  1.41   thorpej 	 * Reassembly is complete.  Check for a bogus message size and
    706  1.41   thorpej 	 * concatenate fragments.
    707   1.1       cgd 	 */
    708  1.25       cgd 	q = fp->ipq_fragq.lh_first;
    709  1.25       cgd 	ip = q->ipqe_ip;
    710  1.41   thorpej 	if ((next + (ip->ip_hl << 2)) > IP_MAXPACKET) {
    711  1.41   thorpej 		ipstat.ips_toolong++;
    712  1.41   thorpej 		ip_freef(fp);
    713  1.41   thorpej 		return (0);
    714  1.41   thorpej 	}
    715  1.50   thorpej 	m = q->ipqe_m;
    716   1.1       cgd 	t = m->m_next;
    717   1.1       cgd 	m->m_next = 0;
    718   1.1       cgd 	m_cat(m, t);
    719  1.25       cgd 	nq = q->ipqe_q.le_next;
    720  1.72   thorpej 	pool_put(&ipqent_pool, q);
    721  1.25       cgd 	for (q = nq; q != NULL; q = nq) {
    722  1.50   thorpej 		t = q->ipqe_m;
    723  1.25       cgd 		nq = q->ipqe_q.le_next;
    724  1.72   thorpej 		pool_put(&ipqent_pool, q);
    725   1.1       cgd 		m_cat(m, t);
    726   1.1       cgd 	}
    727   1.1       cgd 
    728   1.1       cgd 	/*
    729   1.1       cgd 	 * Create header for new ip packet by
    730   1.1       cgd 	 * modifying header of first packet;
    731   1.1       cgd 	 * dequeue and discard fragment reassembly header.
    732   1.1       cgd 	 * Make header visible.
    733   1.1       cgd 	 */
    734   1.1       cgd 	ip->ip_len = next;
    735  1.25       cgd 	ip->ip_src = fp->ipq_src;
    736  1.25       cgd 	ip->ip_dst = fp->ipq_dst;
    737  1.25       cgd 	LIST_REMOVE(fp, ipq_q);
    738  1.50   thorpej 	FREE(fp, M_FTABLE);
    739   1.1       cgd 	m->m_len += (ip->ip_hl << 2);
    740   1.1       cgd 	m->m_data -= (ip->ip_hl << 2);
    741   1.1       cgd 	/* some debugging cruft by sklower, below, will go away soon */
    742   1.1       cgd 	if (m->m_flags & M_PKTHDR) { /* XXX this should be done elsewhere */
    743   1.1       cgd 		register int plen = 0;
    744  1.50   thorpej 		for (t = m; t; t = t->m_next)
    745  1.50   thorpej 			plen += t->m_len;
    746  1.50   thorpej 		m->m_pkthdr.len = plen;
    747   1.1       cgd 	}
    748  1.50   thorpej 	return (m);
    749   1.1       cgd 
    750   1.1       cgd dropfrag:
    751   1.1       cgd 	ipstat.ips_fragdropped++;
    752   1.1       cgd 	m_freem(m);
    753  1.72   thorpej 	pool_put(&ipqent_pool, ipqe);
    754   1.1       cgd 	return (0);
    755   1.1       cgd }
    756   1.1       cgd 
    757   1.1       cgd /*
    758   1.1       cgd  * Free a fragment reassembly header and all
    759   1.1       cgd  * associated datagrams.
    760   1.1       cgd  */
    761   1.8   mycroft void
    762   1.1       cgd ip_freef(fp)
    763   1.1       cgd 	struct ipq *fp;
    764   1.1       cgd {
    765  1.25       cgd 	register struct ipqent *q, *p;
    766   1.1       cgd 
    767  1.75   thorpej 	IPQ_LOCK_CHECK();
    768  1.75   thorpej 
    769  1.25       cgd 	for (q = fp->ipq_fragq.lh_first; q != NULL; q = p) {
    770  1.25       cgd 		p = q->ipqe_q.le_next;
    771  1.50   thorpej 		m_freem(q->ipqe_m);
    772  1.25       cgd 		LIST_REMOVE(q, ipqe_q);
    773  1.72   thorpej 		pool_put(&ipqent_pool, q);
    774   1.1       cgd 	}
    775  1.25       cgd 	LIST_REMOVE(fp, ipq_q);
    776  1.50   thorpej 	FREE(fp, M_FTABLE);
    777   1.1       cgd }
    778   1.1       cgd 
    779   1.1       cgd /*
    780   1.1       cgd  * IP timer processing;
    781   1.1       cgd  * if a timer expires on a reassembly
    782   1.1       cgd  * queue, discard it.
    783   1.1       cgd  */
    784   1.8   mycroft void
    785   1.1       cgd ip_slowtimo()
    786   1.1       cgd {
    787  1.25       cgd 	register struct ipq *fp, *nfp;
    788  1.24   mycroft 	int s = splsoftnet();
    789   1.1       cgd 
    790  1.75   thorpej 	IPQ_LOCK();
    791  1.25       cgd 	for (fp = ipq.lh_first; fp != NULL; fp = nfp) {
    792  1.25       cgd 		nfp = fp->ipq_q.le_next;
    793  1.25       cgd 		if (--fp->ipq_ttl == 0) {
    794   1.1       cgd 			ipstat.ips_fragtimeout++;
    795  1.25       cgd 			ip_freef(fp);
    796   1.1       cgd 		}
    797   1.1       cgd 	}
    798  1.75   thorpej 	IPQ_UNLOCK();
    799  1.63      matt #ifdef GATEWAY
    800  1.63      matt 	ipflow_slowtimo();
    801  1.63      matt #endif
    802   1.1       cgd 	splx(s);
    803   1.1       cgd }
    804   1.1       cgd 
    805   1.1       cgd /*
    806   1.1       cgd  * Drain off all datagram fragments.
    807   1.1       cgd  */
    808   1.8   mycroft void
    809   1.1       cgd ip_drain()
    810   1.1       cgd {
    811   1.1       cgd 
    812  1.75   thorpej 	/*
    813  1.75   thorpej 	 * We may be called from a device's interrupt context.  If
    814  1.75   thorpej 	 * the ipq is already busy, just bail out now.
    815  1.75   thorpej 	 */
    816  1.75   thorpej 	if (ipq_lock_try() == 0)
    817  1.75   thorpej 		return;
    818  1.75   thorpej 
    819  1.25       cgd 	while (ipq.lh_first != NULL) {
    820   1.1       cgd 		ipstat.ips_fragdropped++;
    821  1.25       cgd 		ip_freef(ipq.lh_first);
    822   1.1       cgd 	}
    823  1.75   thorpej 
    824  1.75   thorpej 	IPQ_UNLOCK();
    825   1.1       cgd }
    826   1.1       cgd 
    827   1.1       cgd /*
    828   1.1       cgd  * Do option processing on a datagram,
    829   1.1       cgd  * possibly discarding it if bad options are encountered,
    830   1.1       cgd  * or forwarding it if source-routed.
    831   1.1       cgd  * Returns 1 if packet has been forwarded/freed,
    832   1.1       cgd  * 0 if the packet should be processed further.
    833   1.1       cgd  */
    834   1.8   mycroft int
    835   1.1       cgd ip_dooptions(m)
    836   1.1       cgd 	struct mbuf *m;
    837   1.1       cgd {
    838   1.1       cgd 	register struct ip *ip = mtod(m, struct ip *);
    839   1.1       cgd 	register u_char *cp;
    840   1.1       cgd 	register struct ip_timestamp *ipt;
    841   1.1       cgd 	register struct in_ifaddr *ia;
    842   1.1       cgd 	int opt, optlen, cnt, off, code, type = ICMP_PARAMPROB, forward = 0;
    843  1.13   mycroft 	struct in_addr *sin, dst;
    844   1.1       cgd 	n_time ntime;
    845   1.1       cgd 
    846  1.13   mycroft 	dst = ip->ip_dst;
    847   1.1       cgd 	cp = (u_char *)(ip + 1);
    848   1.1       cgd 	cnt = (ip->ip_hl << 2) - sizeof (struct ip);
    849   1.1       cgd 	for (; cnt > 0; cnt -= optlen, cp += optlen) {
    850   1.1       cgd 		opt = cp[IPOPT_OPTVAL];
    851   1.1       cgd 		if (opt == IPOPT_EOL)
    852   1.1       cgd 			break;
    853   1.1       cgd 		if (opt == IPOPT_NOP)
    854   1.1       cgd 			optlen = 1;
    855   1.1       cgd 		else {
    856   1.1       cgd 			optlen = cp[IPOPT_OLEN];
    857   1.1       cgd 			if (optlen <= 0 || optlen > cnt) {
    858   1.1       cgd 				code = &cp[IPOPT_OLEN] - (u_char *)ip;
    859   1.1       cgd 				goto bad;
    860   1.1       cgd 			}
    861   1.1       cgd 		}
    862   1.1       cgd 		switch (opt) {
    863   1.1       cgd 
    864   1.1       cgd 		default:
    865   1.1       cgd 			break;
    866   1.1       cgd 
    867   1.1       cgd 		/*
    868   1.1       cgd 		 * Source routing with record.
    869   1.1       cgd 		 * Find interface with current destination address.
    870   1.1       cgd 		 * If none on this machine then drop if strictly routed,
    871   1.1       cgd 		 * or do nothing if loosely routed.
    872   1.1       cgd 		 * Record interface address and bring up next address
    873   1.1       cgd 		 * component.  If strictly routed make sure next
    874   1.1       cgd 		 * address is on directly accessible net.
    875   1.1       cgd 		 */
    876   1.1       cgd 		case IPOPT_LSRR:
    877   1.1       cgd 		case IPOPT_SSRR:
    878  1.47       cjs 			if (ip_allowsrcrt == 0) {
    879  1.47       cjs 				type = ICMP_UNREACH;
    880  1.47       cjs 				code = ICMP_UNREACH_NET_PROHIB;
    881  1.47       cjs 				goto bad;
    882  1.47       cjs 			}
    883   1.1       cgd 			if ((off = cp[IPOPT_OFFSET]) < IPOPT_MINOFF) {
    884   1.1       cgd 				code = &cp[IPOPT_OFFSET] - (u_char *)ip;
    885   1.1       cgd 				goto bad;
    886   1.1       cgd 			}
    887   1.1       cgd 			ipaddr.sin_addr = ip->ip_dst;
    888  1.19   mycroft 			ia = ifatoia(ifa_ifwithaddr(sintosa(&ipaddr)));
    889   1.1       cgd 			if (ia == 0) {
    890   1.1       cgd 				if (opt == IPOPT_SSRR) {
    891   1.1       cgd 					type = ICMP_UNREACH;
    892   1.1       cgd 					code = ICMP_UNREACH_SRCFAIL;
    893   1.1       cgd 					goto bad;
    894   1.1       cgd 				}
    895   1.1       cgd 				/*
    896   1.1       cgd 				 * Loose routing, and not at next destination
    897   1.1       cgd 				 * yet; nothing to do except forward.
    898   1.1       cgd 				 */
    899   1.1       cgd 				break;
    900   1.1       cgd 			}
    901   1.1       cgd 			off--;			/* 0 origin */
    902   1.1       cgd 			if (off > optlen - sizeof(struct in_addr)) {
    903   1.1       cgd 				/*
    904   1.1       cgd 				 * End of source route.  Should be for us.
    905   1.1       cgd 				 */
    906   1.1       cgd 				save_rte(cp, ip->ip_src);
    907   1.1       cgd 				break;
    908   1.1       cgd 			}
    909   1.1       cgd 			/*
    910   1.1       cgd 			 * locate outgoing interface
    911   1.1       cgd 			 */
    912   1.1       cgd 			bcopy((caddr_t)(cp + off), (caddr_t)&ipaddr.sin_addr,
    913   1.1       cgd 			    sizeof(ipaddr.sin_addr));
    914   1.1       cgd 			if (opt == IPOPT_SSRR) {
    915   1.1       cgd #define	INA	struct in_ifaddr *
    916   1.1       cgd #define	SA	struct sockaddr *
    917  1.29       mrg 			    ia = (INA)ifa_ifwithladdr((SA)&ipaddr);
    918   1.1       cgd 			} else
    919   1.1       cgd 				ia = ip_rtaddr(ipaddr.sin_addr);
    920   1.1       cgd 			if (ia == 0) {
    921   1.1       cgd 				type = ICMP_UNREACH;
    922   1.1       cgd 				code = ICMP_UNREACH_SRCFAIL;
    923   1.1       cgd 				goto bad;
    924   1.1       cgd 			}
    925   1.1       cgd 			ip->ip_dst = ipaddr.sin_addr;
    926  1.20   mycroft 			bcopy((caddr_t)&ia->ia_addr.sin_addr,
    927   1.1       cgd 			    (caddr_t)(cp + off), sizeof(struct in_addr));
    928   1.1       cgd 			cp[IPOPT_OFFSET] += sizeof(struct in_addr);
    929  1.13   mycroft 			/*
    930  1.13   mycroft 			 * Let ip_intr's mcast routing check handle mcast pkts
    931  1.13   mycroft 			 */
    932  1.18   mycroft 			forward = !IN_MULTICAST(ip->ip_dst.s_addr);
    933   1.1       cgd 			break;
    934   1.1       cgd 
    935   1.1       cgd 		case IPOPT_RR:
    936   1.1       cgd 			if ((off = cp[IPOPT_OFFSET]) < IPOPT_MINOFF) {
    937   1.1       cgd 				code = &cp[IPOPT_OFFSET] - (u_char *)ip;
    938   1.1       cgd 				goto bad;
    939   1.1       cgd 			}
    940   1.1       cgd 			/*
    941   1.1       cgd 			 * If no space remains, ignore.
    942   1.1       cgd 			 */
    943   1.1       cgd 			off--;			/* 0 origin */
    944   1.1       cgd 			if (off > optlen - sizeof(struct in_addr))
    945   1.1       cgd 				break;
    946   1.1       cgd 			bcopy((caddr_t)(&ip->ip_dst), (caddr_t)&ipaddr.sin_addr,
    947   1.1       cgd 			    sizeof(ipaddr.sin_addr));
    948   1.1       cgd 			/*
    949   1.1       cgd 			 * locate outgoing interface; if we're the destination,
    950   1.1       cgd 			 * use the incoming interface (should be same).
    951   1.1       cgd 			 */
    952   1.1       cgd 			if ((ia = (INA)ifa_ifwithaddr((SA)&ipaddr)) == 0 &&
    953   1.1       cgd 			    (ia = ip_rtaddr(ipaddr.sin_addr)) == 0) {
    954   1.1       cgd 				type = ICMP_UNREACH;
    955   1.1       cgd 				code = ICMP_UNREACH_HOST;
    956   1.1       cgd 				goto bad;
    957   1.1       cgd 			}
    958  1.20   mycroft 			bcopy((caddr_t)&ia->ia_addr.sin_addr,
    959   1.1       cgd 			    (caddr_t)(cp + off), sizeof(struct in_addr));
    960   1.1       cgd 			cp[IPOPT_OFFSET] += sizeof(struct in_addr);
    961   1.1       cgd 			break;
    962   1.1       cgd 
    963   1.1       cgd 		case IPOPT_TS:
    964   1.1       cgd 			code = cp - (u_char *)ip;
    965   1.1       cgd 			ipt = (struct ip_timestamp *)cp;
    966   1.1       cgd 			if (ipt->ipt_len < 5)
    967   1.1       cgd 				goto bad;
    968  1.15       cgd 			if (ipt->ipt_ptr > ipt->ipt_len - sizeof (int32_t)) {
    969   1.1       cgd 				if (++ipt->ipt_oflw == 0)
    970   1.1       cgd 					goto bad;
    971   1.1       cgd 				break;
    972   1.1       cgd 			}
    973   1.1       cgd 			sin = (struct in_addr *)(cp + ipt->ipt_ptr - 1);
    974   1.1       cgd 			switch (ipt->ipt_flg) {
    975   1.1       cgd 
    976   1.1       cgd 			case IPOPT_TS_TSONLY:
    977   1.1       cgd 				break;
    978   1.1       cgd 
    979   1.1       cgd 			case IPOPT_TS_TSANDADDR:
    980  1.66   thorpej 				if (ipt->ipt_ptr - 1 + sizeof(n_time) +
    981   1.1       cgd 				    sizeof(struct in_addr) > ipt->ipt_len)
    982   1.1       cgd 					goto bad;
    983  1.13   mycroft 				ipaddr.sin_addr = dst;
    984  1.13   mycroft 				ia = (INA)ifaof_ifpforaddr((SA)&ipaddr,
    985  1.13   mycroft 							    m->m_pkthdr.rcvif);
    986  1.13   mycroft 				if (ia == 0)
    987  1.13   mycroft 					continue;
    988  1.20   mycroft 				bcopy((caddr_t)&ia->ia_addr.sin_addr,
    989   1.1       cgd 				    (caddr_t)sin, sizeof(struct in_addr));
    990   1.1       cgd 				ipt->ipt_ptr += sizeof(struct in_addr);
    991   1.1       cgd 				break;
    992   1.1       cgd 
    993   1.1       cgd 			case IPOPT_TS_PRESPEC:
    994  1.66   thorpej 				if (ipt->ipt_ptr - 1 + sizeof(n_time) +
    995   1.1       cgd 				    sizeof(struct in_addr) > ipt->ipt_len)
    996   1.1       cgd 					goto bad;
    997   1.1       cgd 				bcopy((caddr_t)sin, (caddr_t)&ipaddr.sin_addr,
    998   1.1       cgd 				    sizeof(struct in_addr));
    999   1.1       cgd 				if (ifa_ifwithaddr((SA)&ipaddr) == 0)
   1000   1.1       cgd 					continue;
   1001   1.1       cgd 				ipt->ipt_ptr += sizeof(struct in_addr);
   1002   1.1       cgd 				break;
   1003   1.1       cgd 
   1004   1.1       cgd 			default:
   1005   1.1       cgd 				goto bad;
   1006   1.1       cgd 			}
   1007   1.1       cgd 			ntime = iptime();
   1008   1.1       cgd 			bcopy((caddr_t)&ntime, (caddr_t)cp + ipt->ipt_ptr - 1,
   1009   1.1       cgd 			    sizeof(n_time));
   1010   1.1       cgd 			ipt->ipt_ptr += sizeof(n_time);
   1011   1.1       cgd 		}
   1012   1.1       cgd 	}
   1013   1.1       cgd 	if (forward) {
   1014  1.26   thorpej 		if (ip_forwsrcrt == 0) {
   1015  1.26   thorpej 			type = ICMP_UNREACH;
   1016  1.26   thorpej 			code = ICMP_UNREACH_SRCFAIL;
   1017  1.26   thorpej 			goto bad;
   1018  1.26   thorpej 		}
   1019   1.1       cgd 		ip_forward(m, 1);
   1020   1.1       cgd 		return (1);
   1021  1.13   mycroft 	}
   1022  1.13   mycroft 	return (0);
   1023   1.1       cgd bad:
   1024  1.13   mycroft 	ip->ip_len -= ip->ip_hl << 2;   /* XXX icmp_error adds in hdr length */
   1025  1.13   mycroft 	icmp_error(m, type, code, 0, 0);
   1026  1.13   mycroft 	ipstat.ips_badoptions++;
   1027   1.1       cgd 	return (1);
   1028   1.1       cgd }
   1029   1.1       cgd 
   1030   1.1       cgd /*
   1031   1.1       cgd  * Given address of next destination (final or next hop),
   1032   1.1       cgd  * return internet address info of interface to be used to get there.
   1033   1.1       cgd  */
   1034   1.1       cgd struct in_ifaddr *
   1035   1.1       cgd ip_rtaddr(dst)
   1036   1.1       cgd 	 struct in_addr dst;
   1037   1.1       cgd {
   1038   1.1       cgd 	register struct sockaddr_in *sin;
   1039   1.1       cgd 
   1040  1.19   mycroft 	sin = satosin(&ipforward_rt.ro_dst);
   1041   1.1       cgd 
   1042  1.35   mycroft 	if (ipforward_rt.ro_rt == 0 || !in_hosteq(dst, sin->sin_addr)) {
   1043   1.1       cgd 		if (ipforward_rt.ro_rt) {
   1044   1.1       cgd 			RTFREE(ipforward_rt.ro_rt);
   1045   1.1       cgd 			ipforward_rt.ro_rt = 0;
   1046   1.1       cgd 		}
   1047   1.1       cgd 		sin->sin_family = AF_INET;
   1048   1.1       cgd 		sin->sin_len = sizeof(*sin);
   1049   1.1       cgd 		sin->sin_addr = dst;
   1050   1.1       cgd 
   1051   1.1       cgd 		rtalloc(&ipforward_rt);
   1052   1.1       cgd 	}
   1053   1.1       cgd 	if (ipforward_rt.ro_rt == 0)
   1054   1.1       cgd 		return ((struct in_ifaddr *)0);
   1055  1.19   mycroft 	return (ifatoia(ipforward_rt.ro_rt->rt_ifa));
   1056   1.1       cgd }
   1057   1.1       cgd 
   1058   1.1       cgd /*
   1059   1.1       cgd  * Save incoming source route for use in replies,
   1060   1.1       cgd  * to be picked up later by ip_srcroute if the receiver is interested.
   1061   1.1       cgd  */
   1062  1.13   mycroft void
   1063   1.1       cgd save_rte(option, dst)
   1064   1.1       cgd 	u_char *option;
   1065   1.1       cgd 	struct in_addr dst;
   1066   1.1       cgd {
   1067   1.1       cgd 	unsigned olen;
   1068   1.1       cgd 
   1069   1.1       cgd 	olen = option[IPOPT_OLEN];
   1070   1.1       cgd #ifdef DIAGNOSTIC
   1071   1.1       cgd 	if (ipprintfs)
   1072  1.39  christos 		printf("save_rte: olen %d\n", olen);
   1073   1.1       cgd #endif
   1074   1.1       cgd 	if (olen > sizeof(ip_srcrt) - (1 + sizeof(dst)))
   1075   1.1       cgd 		return;
   1076   1.1       cgd 	bcopy((caddr_t)option, (caddr_t)ip_srcrt.srcopt, olen);
   1077   1.1       cgd 	ip_nhops = (olen - IPOPT_OFFSET - 1) / sizeof(struct in_addr);
   1078   1.1       cgd 	ip_srcrt.dst = dst;
   1079   1.1       cgd }
   1080   1.1       cgd 
   1081   1.1       cgd /*
   1082   1.1       cgd  * Retrieve incoming source route for use in replies,
   1083   1.1       cgd  * in the same form used by setsockopt.
   1084   1.1       cgd  * The first hop is placed before the options, will be removed later.
   1085   1.1       cgd  */
   1086   1.1       cgd struct mbuf *
   1087   1.1       cgd ip_srcroute()
   1088   1.1       cgd {
   1089   1.1       cgd 	register struct in_addr *p, *q;
   1090   1.1       cgd 	register struct mbuf *m;
   1091   1.1       cgd 
   1092   1.1       cgd 	if (ip_nhops == 0)
   1093   1.1       cgd 		return ((struct mbuf *)0);
   1094   1.1       cgd 	m = m_get(M_DONTWAIT, MT_SOOPTS);
   1095   1.1       cgd 	if (m == 0)
   1096   1.1       cgd 		return ((struct mbuf *)0);
   1097   1.1       cgd 
   1098  1.13   mycroft #define OPTSIZ	(sizeof(ip_srcrt.nop) + sizeof(ip_srcrt.srcopt))
   1099   1.1       cgd 
   1100   1.1       cgd 	/* length is (nhops+1)*sizeof(addr) + sizeof(nop + srcrt header) */
   1101   1.1       cgd 	m->m_len = ip_nhops * sizeof(struct in_addr) + sizeof(struct in_addr) +
   1102   1.1       cgd 	    OPTSIZ;
   1103   1.1       cgd #ifdef DIAGNOSTIC
   1104   1.1       cgd 	if (ipprintfs)
   1105  1.39  christos 		printf("ip_srcroute: nhops %d mlen %d", ip_nhops, m->m_len);
   1106   1.1       cgd #endif
   1107   1.1       cgd 
   1108   1.1       cgd 	/*
   1109   1.1       cgd 	 * First save first hop for return route
   1110   1.1       cgd 	 */
   1111   1.1       cgd 	p = &ip_srcrt.route[ip_nhops - 1];
   1112   1.1       cgd 	*(mtod(m, struct in_addr *)) = *p--;
   1113   1.1       cgd #ifdef DIAGNOSTIC
   1114   1.1       cgd 	if (ipprintfs)
   1115  1.39  christos 		printf(" hops %x", ntohl(mtod(m, struct in_addr *)->s_addr));
   1116   1.1       cgd #endif
   1117   1.1       cgd 
   1118   1.1       cgd 	/*
   1119   1.1       cgd 	 * Copy option fields and padding (nop) to mbuf.
   1120   1.1       cgd 	 */
   1121   1.1       cgd 	ip_srcrt.nop = IPOPT_NOP;
   1122   1.1       cgd 	ip_srcrt.srcopt[IPOPT_OFFSET] = IPOPT_MINOFF;
   1123   1.1       cgd 	bcopy((caddr_t)&ip_srcrt.nop,
   1124   1.1       cgd 	    mtod(m, caddr_t) + sizeof(struct in_addr), OPTSIZ);
   1125   1.1       cgd 	q = (struct in_addr *)(mtod(m, caddr_t) +
   1126   1.1       cgd 	    sizeof(struct in_addr) + OPTSIZ);
   1127   1.1       cgd #undef OPTSIZ
   1128   1.1       cgd 	/*
   1129   1.1       cgd 	 * Record return path as an IP source route,
   1130   1.1       cgd 	 * reversing the path (pointers are now aligned).
   1131   1.1       cgd 	 */
   1132   1.1       cgd 	while (p >= ip_srcrt.route) {
   1133   1.1       cgd #ifdef DIAGNOSTIC
   1134   1.1       cgd 		if (ipprintfs)
   1135  1.39  christos 			printf(" %x", ntohl(q->s_addr));
   1136   1.1       cgd #endif
   1137   1.1       cgd 		*q++ = *p--;
   1138   1.1       cgd 	}
   1139   1.1       cgd 	/*
   1140   1.1       cgd 	 * Last hop goes to final destination.
   1141   1.1       cgd 	 */
   1142   1.1       cgd 	*q = ip_srcrt.dst;
   1143   1.1       cgd #ifdef DIAGNOSTIC
   1144   1.1       cgd 	if (ipprintfs)
   1145  1.39  christos 		printf(" %x\n", ntohl(q->s_addr));
   1146   1.1       cgd #endif
   1147   1.1       cgd 	return (m);
   1148   1.1       cgd }
   1149   1.1       cgd 
   1150   1.1       cgd /*
   1151   1.1       cgd  * Strip out IP options, at higher
   1152   1.1       cgd  * level protocol in the kernel.
   1153   1.1       cgd  * Second argument is buffer to which options
   1154   1.1       cgd  * will be moved, and return value is their length.
   1155   1.1       cgd  * XXX should be deleted; last arg currently ignored.
   1156   1.1       cgd  */
   1157   1.8   mycroft void
   1158   1.1       cgd ip_stripoptions(m, mopt)
   1159   1.1       cgd 	register struct mbuf *m;
   1160   1.1       cgd 	struct mbuf *mopt;
   1161   1.1       cgd {
   1162   1.1       cgd 	register int i;
   1163   1.1       cgd 	struct ip *ip = mtod(m, struct ip *);
   1164   1.1       cgd 	register caddr_t opts;
   1165   1.1       cgd 	int olen;
   1166   1.1       cgd 
   1167   1.1       cgd 	olen = (ip->ip_hl<<2) - sizeof (struct ip);
   1168   1.1       cgd 	opts = (caddr_t)(ip + 1);
   1169   1.1       cgd 	i = m->m_len - (sizeof (struct ip) + olen);
   1170   1.1       cgd 	bcopy(opts  + olen, opts, (unsigned)i);
   1171   1.1       cgd 	m->m_len -= olen;
   1172   1.1       cgd 	if (m->m_flags & M_PKTHDR)
   1173   1.1       cgd 		m->m_pkthdr.len -= olen;
   1174   1.1       cgd 	ip->ip_hl = sizeof(struct ip) >> 2;
   1175   1.1       cgd }
   1176   1.1       cgd 
   1177  1.23   mycroft int inetctlerrmap[PRC_NCMDS] = {
   1178   1.1       cgd 	0,		0,		0,		0,
   1179   1.1       cgd 	0,		EMSGSIZE,	EHOSTDOWN,	EHOSTUNREACH,
   1180   1.1       cgd 	EHOSTUNREACH,	EHOSTUNREACH,	ECONNREFUSED,	ECONNREFUSED,
   1181   1.1       cgd 	EMSGSIZE,	EHOSTUNREACH,	0,		0,
   1182   1.1       cgd 	0,		0,		0,		0,
   1183   1.1       cgd 	ENOPROTOOPT
   1184   1.1       cgd };
   1185   1.1       cgd 
   1186   1.1       cgd /*
   1187   1.1       cgd  * Forward a packet.  If some error occurs return the sender
   1188   1.1       cgd  * an icmp packet.  Note we can't always generate a meaningful
   1189   1.1       cgd  * icmp message because icmp doesn't have a large enough repertoire
   1190   1.1       cgd  * of codes and types.
   1191   1.1       cgd  *
   1192   1.1       cgd  * If not forwarding, just drop the packet.  This could be confusing
   1193   1.1       cgd  * if ipforwarding was zero but some routing protocol was advancing
   1194   1.1       cgd  * us as a gateway to somewhere.  However, we must let the routing
   1195   1.1       cgd  * protocol deal with that.
   1196   1.1       cgd  *
   1197   1.1       cgd  * The srcrt parameter indicates whether the packet is being forwarded
   1198   1.1       cgd  * via a source route.
   1199   1.1       cgd  */
   1200  1.13   mycroft void
   1201   1.1       cgd ip_forward(m, srcrt)
   1202   1.1       cgd 	struct mbuf *m;
   1203   1.1       cgd 	int srcrt;
   1204   1.1       cgd {
   1205   1.1       cgd 	register struct ip *ip = mtod(m, struct ip *);
   1206   1.1       cgd 	register struct sockaddr_in *sin;
   1207   1.1       cgd 	register struct rtentry *rt;
   1208  1.28  christos 	int error, type = 0, code = 0;
   1209   1.1       cgd 	struct mbuf *mcopy;
   1210  1.13   mycroft 	n_long dest;
   1211  1.13   mycroft 	struct ifnet *destifp;
   1212   1.1       cgd 
   1213  1.13   mycroft 	dest = 0;
   1214   1.1       cgd #ifdef DIAGNOSTIC
   1215   1.1       cgd 	if (ipprintfs)
   1216  1.70   thorpej 		printf("forward: src %2.2x dst %2.2x ttl %x\n",
   1217  1.70   thorpej 		    ntohl(ip->ip_src.s_addr),
   1218  1.70   thorpej 		    ntohl(ip->ip_dst.s_addr), ip->ip_ttl);
   1219   1.1       cgd #endif
   1220   1.1       cgd 	if (m->m_flags & M_BCAST || in_canforward(ip->ip_dst) == 0) {
   1221   1.1       cgd 		ipstat.ips_cantforward++;
   1222   1.1       cgd 		m_freem(m);
   1223   1.1       cgd 		return;
   1224   1.1       cgd 	}
   1225   1.1       cgd 	HTONS(ip->ip_id);
   1226   1.1       cgd 	if (ip->ip_ttl <= IPTTLDEC) {
   1227  1.13   mycroft 		icmp_error(m, ICMP_TIMXCEED, ICMP_TIMXCEED_INTRANS, dest, 0);
   1228   1.1       cgd 		return;
   1229   1.1       cgd 	}
   1230   1.1       cgd 	ip->ip_ttl -= IPTTLDEC;
   1231   1.1       cgd 
   1232  1.19   mycroft 	sin = satosin(&ipforward_rt.ro_dst);
   1233   1.1       cgd 	if ((rt = ipforward_rt.ro_rt) == 0 ||
   1234  1.35   mycroft 	    !in_hosteq(ip->ip_dst, sin->sin_addr)) {
   1235   1.1       cgd 		if (ipforward_rt.ro_rt) {
   1236   1.1       cgd 			RTFREE(ipforward_rt.ro_rt);
   1237   1.1       cgd 			ipforward_rt.ro_rt = 0;
   1238   1.1       cgd 		}
   1239   1.1       cgd 		sin->sin_family = AF_INET;
   1240  1.35   mycroft 		sin->sin_len = sizeof(struct sockaddr_in);
   1241   1.1       cgd 		sin->sin_addr = ip->ip_dst;
   1242   1.1       cgd 
   1243   1.1       cgd 		rtalloc(&ipforward_rt);
   1244   1.1       cgd 		if (ipforward_rt.ro_rt == 0) {
   1245  1.13   mycroft 			icmp_error(m, ICMP_UNREACH, ICMP_UNREACH_HOST, dest, 0);
   1246   1.1       cgd 			return;
   1247   1.1       cgd 		}
   1248   1.1       cgd 		rt = ipforward_rt.ro_rt;
   1249   1.1       cgd 	}
   1250   1.1       cgd 
   1251   1.1       cgd 	/*
   1252  1.34   mycroft 	 * Save at most 68 bytes of the packet in case
   1253   1.1       cgd 	 * we need to generate an ICMP message to the src.
   1254   1.1       cgd 	 */
   1255  1.34   mycroft 	mcopy = m_copy(m, 0, imin((int)ip->ip_len, 68));
   1256   1.1       cgd 
   1257   1.1       cgd 	/*
   1258   1.1       cgd 	 * If forwarding packet using same interface that it came in on,
   1259   1.1       cgd 	 * perhaps should send a redirect to sender to shortcut a hop.
   1260   1.1       cgd 	 * Only send redirect if source is sending directly to us,
   1261   1.1       cgd 	 * and if packet was not source routed (or has any options).
   1262   1.1       cgd 	 * Also, don't send redirect if forwarding using a default route
   1263   1.1       cgd 	 * or a route modified by a redirect.
   1264   1.1       cgd 	 */
   1265   1.1       cgd 	if (rt->rt_ifp == m->m_pkthdr.rcvif &&
   1266   1.1       cgd 	    (rt->rt_flags & (RTF_DYNAMIC|RTF_MODIFIED)) == 0 &&
   1267  1.35   mycroft 	    !in_nullhost(satosin(rt_key(rt))->sin_addr) &&
   1268   1.1       cgd 	    ipsendredirects && !srcrt) {
   1269  1.19   mycroft 		if (rt->rt_ifa &&
   1270  1.19   mycroft 		    (ip->ip_src.s_addr & ifatoia(rt->rt_ifa)->ia_subnetmask) ==
   1271  1.19   mycroft 		    ifatoia(rt->rt_ifa)->ia_subnet) {
   1272   1.1       cgd 		    if (rt->rt_flags & RTF_GATEWAY)
   1273  1.13   mycroft 			dest = satosin(rt->rt_gateway)->sin_addr.s_addr;
   1274   1.1       cgd 		    else
   1275  1.13   mycroft 			dest = ip->ip_dst.s_addr;
   1276  1.13   mycroft 		    /* Router requirements says to only send host redirects */
   1277   1.1       cgd 		    type = ICMP_REDIRECT;
   1278  1.13   mycroft 		    code = ICMP_REDIRECT_HOST;
   1279   1.1       cgd #ifdef DIAGNOSTIC
   1280   1.1       cgd 		    if (ipprintfs)
   1281  1.39  christos 		    	printf("redirect (%d) to %x\n", code, (u_int32_t)dest);
   1282   1.1       cgd #endif
   1283   1.1       cgd 		}
   1284   1.1       cgd 	}
   1285   1.1       cgd 
   1286  1.27   thorpej 	error = ip_output(m, (struct mbuf *)0, &ipforward_rt,
   1287  1.27   thorpej 	    (IP_FORWARDING | (ip_directedbcast ? IP_ALLOWBROADCAST : 0)), 0);
   1288   1.1       cgd 	if (error)
   1289   1.1       cgd 		ipstat.ips_cantforward++;
   1290   1.1       cgd 	else {
   1291   1.1       cgd 		ipstat.ips_forward++;
   1292   1.1       cgd 		if (type)
   1293   1.1       cgd 			ipstat.ips_redirectsent++;
   1294   1.1       cgd 		else {
   1295  1.63      matt 			if (mcopy) {
   1296  1.63      matt #ifdef GATEWAY
   1297  1.64   thorpej 				if (mcopy->m_flags & M_CANFASTFWD)
   1298  1.64   thorpej 					ipflow_create(&ipforward_rt, mcopy);
   1299  1.63      matt #endif
   1300   1.1       cgd 				m_freem(mcopy);
   1301  1.63      matt 			}
   1302   1.1       cgd 			return;
   1303   1.1       cgd 		}
   1304   1.1       cgd 	}
   1305   1.1       cgd 	if (mcopy == NULL)
   1306   1.1       cgd 		return;
   1307  1.13   mycroft 	destifp = NULL;
   1308  1.13   mycroft 
   1309   1.1       cgd 	switch (error) {
   1310   1.1       cgd 
   1311   1.1       cgd 	case 0:				/* forwarded, but need redirect */
   1312   1.1       cgd 		/* type, code set above */
   1313   1.1       cgd 		break;
   1314   1.1       cgd 
   1315   1.1       cgd 	case ENETUNREACH:		/* shouldn't happen, checked above */
   1316   1.1       cgd 	case EHOSTUNREACH:
   1317   1.1       cgd 	case ENETDOWN:
   1318   1.1       cgd 	case EHOSTDOWN:
   1319   1.1       cgd 	default:
   1320   1.1       cgd 		type = ICMP_UNREACH;
   1321   1.1       cgd 		code = ICMP_UNREACH_HOST;
   1322   1.1       cgd 		break;
   1323   1.1       cgd 
   1324   1.1       cgd 	case EMSGSIZE:
   1325   1.1       cgd 		type = ICMP_UNREACH;
   1326   1.1       cgd 		code = ICMP_UNREACH_NEEDFRAG;
   1327  1.13   mycroft 		if (ipforward_rt.ro_rt)
   1328  1.13   mycroft 			destifp = ipforward_rt.ro_rt->rt_ifp;
   1329   1.1       cgd 		ipstat.ips_cantfrag++;
   1330   1.1       cgd 		break;
   1331   1.1       cgd 
   1332   1.1       cgd 	case ENOBUFS:
   1333   1.1       cgd 		type = ICMP_SOURCEQUENCH;
   1334   1.1       cgd 		code = 0;
   1335   1.1       cgd 		break;
   1336   1.1       cgd 	}
   1337  1.13   mycroft 	icmp_error(mcopy, type, code, dest, destifp);
   1338  1.44   thorpej }
   1339  1.44   thorpej 
   1340  1.44   thorpej void
   1341  1.44   thorpej ip_savecontrol(inp, mp, ip, m)
   1342  1.44   thorpej 	register struct inpcb *inp;
   1343  1.44   thorpej 	register struct mbuf **mp;
   1344  1.44   thorpej 	register struct ip *ip;
   1345  1.44   thorpej 	register struct mbuf *m;
   1346  1.44   thorpej {
   1347  1.44   thorpej 
   1348  1.44   thorpej 	if (inp->inp_socket->so_options & SO_TIMESTAMP) {
   1349  1.44   thorpej 		struct timeval tv;
   1350  1.44   thorpej 
   1351  1.44   thorpej 		microtime(&tv);
   1352  1.44   thorpej 		*mp = sbcreatecontrol((caddr_t) &tv, sizeof(tv),
   1353  1.44   thorpej 		    SCM_TIMESTAMP, SOL_SOCKET);
   1354  1.44   thorpej 		if (*mp)
   1355  1.44   thorpej 			mp = &(*mp)->m_next;
   1356  1.44   thorpej 	}
   1357  1.44   thorpej 	if (inp->inp_flags & INP_RECVDSTADDR) {
   1358  1.44   thorpej 		*mp = sbcreatecontrol((caddr_t) &ip->ip_dst,
   1359  1.44   thorpej 		    sizeof(struct in_addr), IP_RECVDSTADDR, IPPROTO_IP);
   1360  1.44   thorpej 		if (*mp)
   1361  1.44   thorpej 			mp = &(*mp)->m_next;
   1362  1.44   thorpej 	}
   1363  1.44   thorpej #ifdef notyet
   1364  1.44   thorpej 	/*
   1365  1.44   thorpej 	 * XXX
   1366  1.44   thorpej 	 * Moving these out of udp_input() made them even more broken
   1367  1.44   thorpej 	 * than they already were.
   1368  1.44   thorpej 	 *	- fenner (at) parc.xerox.com
   1369  1.44   thorpej 	 */
   1370  1.44   thorpej 	/* options were tossed already */
   1371  1.44   thorpej 	if (inp->inp_flags & INP_RECVOPTS) {
   1372  1.44   thorpej 		*mp = sbcreatecontrol((caddr_t) opts_deleted_above,
   1373  1.44   thorpej 		    sizeof(struct in_addr), IP_RECVOPTS, IPPROTO_IP);
   1374  1.44   thorpej 		if (*mp)
   1375  1.44   thorpej 			mp = &(*mp)->m_next;
   1376  1.44   thorpej 	}
   1377  1.44   thorpej 	/* ip_srcroute doesn't do what we want here, need to fix */
   1378  1.44   thorpej 	if (inp->inp_flags & INP_RECVRETOPTS) {
   1379  1.44   thorpej 		*mp = sbcreatecontrol((caddr_t) ip_srcroute(),
   1380  1.44   thorpej 		    sizeof(struct in_addr), IP_RECVRETOPTS, IPPROTO_IP);
   1381  1.44   thorpej 		if (*mp)
   1382  1.44   thorpej 			mp = &(*mp)->m_next;
   1383  1.44   thorpej 	}
   1384  1.44   thorpej #endif
   1385  1.44   thorpej 	if (inp->inp_flags & INP_RECVIF) {
   1386  1.44   thorpej 		struct sockaddr_dl sdl;
   1387  1.44   thorpej 
   1388  1.44   thorpej 		sdl.sdl_len = offsetof(struct sockaddr_dl, sdl_data[0]);
   1389  1.44   thorpej 		sdl.sdl_family = AF_LINK;
   1390  1.44   thorpej 		sdl.sdl_index = m->m_pkthdr.rcvif ?
   1391  1.44   thorpej 		    m->m_pkthdr.rcvif->if_index : 0;
   1392  1.44   thorpej 		sdl.sdl_nlen = sdl.sdl_alen = sdl.sdl_slen = 0;
   1393  1.44   thorpej 		*mp = sbcreatecontrol((caddr_t) &sdl, sdl.sdl_len,
   1394  1.44   thorpej 		    IP_RECVIF, IPPROTO_IP);
   1395  1.44   thorpej 		if (*mp)
   1396  1.44   thorpej 			mp = &(*mp)->m_next;
   1397  1.44   thorpej 	}
   1398  1.13   mycroft }
   1399  1.13   mycroft 
   1400  1.13   mycroft int
   1401  1.13   mycroft ip_sysctl(name, namelen, oldp, oldlenp, newp, newlen)
   1402  1.13   mycroft 	int *name;
   1403  1.13   mycroft 	u_int namelen;
   1404  1.13   mycroft 	void *oldp;
   1405  1.13   mycroft 	size_t *oldlenp;
   1406  1.13   mycroft 	void *newp;
   1407  1.13   mycroft 	size_t newlen;
   1408  1.13   mycroft {
   1409  1.52   thorpej 	extern int subnetsarelocal;
   1410  1.52   thorpej 
   1411  1.54     lukem 	int error, old;
   1412  1.54     lukem 
   1413  1.13   mycroft 	/* All sysctl names at this level are terminal. */
   1414  1.13   mycroft 	if (namelen != 1)
   1415  1.13   mycroft 		return (ENOTDIR);
   1416  1.13   mycroft 
   1417  1.13   mycroft 	switch (name[0]) {
   1418  1.13   mycroft 	case IPCTL_FORWARDING:
   1419  1.13   mycroft 		return (sysctl_int(oldp, oldlenp, newp, newlen, &ipforwarding));
   1420  1.13   mycroft 	case IPCTL_SENDREDIRECTS:
   1421  1.13   mycroft 		return (sysctl_int(oldp, oldlenp, newp, newlen,
   1422  1.13   mycroft 			&ipsendredirects));
   1423  1.13   mycroft 	case IPCTL_DEFTTL:
   1424  1.13   mycroft 		return (sysctl_int(oldp, oldlenp, newp, newlen, &ip_defttl));
   1425  1.13   mycroft #ifdef notyet
   1426  1.13   mycroft 	case IPCTL_DEFMTU:
   1427  1.13   mycroft 		return (sysctl_int(oldp, oldlenp, newp, newlen, &ip_mtu));
   1428  1.13   mycroft #endif
   1429  1.26   thorpej 	case IPCTL_FORWSRCRT:
   1430  1.47       cjs 		/* Don't allow this to change in a secure environment.  */
   1431  1.26   thorpej 		if (securelevel > 0)
   1432  1.46       cjs 			return (sysctl_rdint(oldp, oldlenp, newp,
   1433  1.46       cjs 			    ip_forwsrcrt));
   1434  1.46       cjs 		else
   1435  1.46       cjs 			return (sysctl_int(oldp, oldlenp, newp, newlen,
   1436  1.46       cjs 			    &ip_forwsrcrt));
   1437  1.27   thorpej 	case IPCTL_DIRECTEDBCAST:
   1438  1.27   thorpej 		return (sysctl_int(oldp, oldlenp, newp, newlen,
   1439  1.27   thorpej 		    &ip_directedbcast));
   1440  1.47       cjs 	case IPCTL_ALLOWSRCRT:
   1441  1.47       cjs 		return (sysctl_int(oldp, oldlenp, newp, newlen,
   1442  1.47       cjs 		    &ip_allowsrcrt));
   1443  1.52   thorpej 	case IPCTL_SUBNETSARELOCAL:
   1444  1.52   thorpej 		return (sysctl_int(oldp, oldlenp, newp, newlen,
   1445  1.52   thorpej 		    &subnetsarelocal));
   1446  1.53       kml 	case IPCTL_MTUDISC:
   1447  1.60       kml 		error = sysctl_int(oldp, oldlenp, newp, newlen,
   1448  1.60       kml 		    &ip_mtudisc);
   1449  1.60       kml 		if (ip_mtudisc != 0 && ip_mtudisc_timeout_q == NULL) {
   1450  1.60       kml 			ip_mtudisc_timeout_q =
   1451  1.60       kml 			    rt_timer_queue_create(ip_mtudisc_timeout);
   1452  1.60       kml 		} else if (ip_mtudisc == 0 && ip_mtudisc_timeout_q != NULL) {
   1453  1.60       kml 			rt_timer_queue_destroy(ip_mtudisc_timeout_q, TRUE);
   1454  1.60       kml 			ip_mtudisc_timeout_q = NULL;
   1455  1.60       kml 		}
   1456  1.60       kml 		return error;
   1457  1.54     lukem 	case IPCTL_ANONPORTMIN:
   1458  1.54     lukem 		old = anonportmin;
   1459  1.54     lukem 		error = sysctl_int(oldp, oldlenp, newp, newlen, &anonportmin);
   1460  1.54     lukem 		if (anonportmin >= anonportmax || anonportmin > 65535
   1461  1.54     lukem #ifndef IPNOPRIVPORTS
   1462  1.54     lukem 		    || anonportmin < IPPORT_RESERVED
   1463  1.54     lukem #endif
   1464  1.54     lukem 		    ) {
   1465  1.54     lukem 			anonportmin = old;
   1466  1.54     lukem 			return (EINVAL);
   1467  1.54     lukem 		}
   1468  1.54     lukem 		return (error);
   1469  1.54     lukem 	case IPCTL_ANONPORTMAX:
   1470  1.54     lukem 		old = anonportmax;
   1471  1.54     lukem 		error = sysctl_int(oldp, oldlenp, newp, newlen, &anonportmax);
   1472  1.54     lukem 		if (anonportmin >= anonportmax || anonportmax > 65535
   1473  1.54     lukem #ifndef IPNOPRIVPORTS
   1474  1.54     lukem 		    || anonportmax < IPPORT_RESERVED
   1475  1.54     lukem #endif
   1476  1.54     lukem 		    ) {
   1477  1.54     lukem 			anonportmax = old;
   1478  1.54     lukem 			return (EINVAL);
   1479  1.54     lukem 		}
   1480  1.60       kml 		return (error);
   1481  1.60       kml 	case IPCTL_MTUDISCTIMEOUT:
   1482  1.60       kml 		error = sysctl_int(oldp, oldlenp, newp, newlen,
   1483  1.60       kml 		   &ip_mtudisc_timeout);
   1484  1.60       kml 		if (ip_mtudisc_timeout_q != NULL)
   1485  1.60       kml 			rt_timer_queue_change(ip_mtudisc_timeout_q,
   1486  1.60       kml 					      ip_mtudisc_timeout);
   1487  1.54     lukem 		return (error);
   1488  1.65      matt #ifdef GATEWAY
   1489  1.65      matt 	case IPCTL_MAXFLOWS:
   1490  1.67   thorpej 	    {
   1491  1.67   thorpej 		int s;
   1492  1.67   thorpej 
   1493  1.65      matt 		error = sysctl_int(oldp, oldlenp, newp, newlen,
   1494  1.65      matt 		   &ip_maxflows);
   1495  1.67   thorpej 		s = splsoftnet();
   1496  1.65      matt 		ipflow_reap(0);
   1497  1.67   thorpej 		splx(s);
   1498  1.65      matt 		return (error);
   1499  1.67   thorpej 	    }
   1500  1.65      matt #endif
   1501  1.13   mycroft 	default:
   1502  1.13   mycroft 		return (EOPNOTSUPP);
   1503  1.13   mycroft 	}
   1504  1.13   mycroft 	/* NOTREACHED */
   1505   1.1       cgd }
   1506