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