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