Home | History | Annotate | Line # | Download | only in netinet
ip_input.c revision 1.190
      1  1.190  jonathan /*	$NetBSD: ip_input.c,v 1.190 2003/12/06 23:56:10 jonathan 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.152    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.152    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.172       agc  * 3. Neither the name of the University nor the names of its contributors
     82    1.1       cgd  *    may be used to endorse or promote products derived from this software
     83    1.1       cgd  *    without specific prior written permission.
     84    1.1       cgd  *
     85    1.1       cgd  * THIS SOFTWARE IS PROVIDED BY THE REGENTS AND CONTRIBUTORS ``AS IS'' AND
     86    1.1       cgd  * ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
     87    1.1       cgd  * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE
     88    1.1       cgd  * ARE DISCLAIMED.  IN NO EVENT SHALL THE REGENTS OR CONTRIBUTORS BE LIABLE
     89    1.1       cgd  * FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL
     90    1.1       cgd  * DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS
     91    1.1       cgd  * OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION)
     92    1.1       cgd  * HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT
     93    1.1       cgd  * LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY
     94    1.1       cgd  * OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF
     95    1.1       cgd  * SUCH DAMAGE.
     96    1.1       cgd  *
     97   1.14       cgd  *	@(#)ip_input.c	8.2 (Berkeley) 1/4/94
     98    1.1       cgd  */
     99  1.141     lukem 
    100  1.141     lukem #include <sys/cdefs.h>
    101  1.190  jonathan __KERNEL_RCSID(0, "$NetBSD: ip_input.c,v 1.190 2003/12/06 23:56:10 jonathan Exp $");
    102   1.55    scottr 
    103  1.184  jonathan #include "opt_inet.h"
    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.167    martin #include "opt_mbuftrace.h"
    109  1.135   thorpej #include "opt_inet_csum.h"
    110    1.1       cgd 
    111    1.5   mycroft #include <sys/param.h>
    112    1.5   mycroft #include <sys/systm.h>
    113    1.5   mycroft #include <sys/malloc.h>
    114    1.5   mycroft #include <sys/mbuf.h>
    115    1.5   mycroft #include <sys/domain.h>
    116    1.5   mycroft #include <sys/protosw.h>
    117    1.5   mycroft #include <sys/socket.h>
    118   1.44   thorpej #include <sys/socketvar.h>
    119    1.5   mycroft #include <sys/errno.h>
    120    1.5   mycroft #include <sys/time.h>
    121    1.5   mycroft #include <sys/kernel.h>
    122   1.72   thorpej #include <sys/pool.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.144    martin #include <net/if_gre.h>
    141  1.144    martin #include "gre.h"
    142  1.111  jdolecek 
    143  1.111  jdolecek #ifdef MROUTING
    144  1.111  jdolecek #include <netinet/ip_mroute.h>
    145  1.111  jdolecek #endif
    146   1.89    itojun 
    147   1.89    itojun #ifdef IPSEC
    148   1.89    itojun #include <netinet6/ipsec.h>
    149   1.89    itojun #include <netkey/key.h>
    150   1.89    itojun #endif
    151  1.173  jonathan #ifdef FAST_IPSEC
    152  1.173  jonathan #include <netipsec/ipsec.h>
    153  1.173  jonathan #include <netipsec/key.h>
    154  1.173  jonathan #endif	/* FAST_IPSEC*/
    155   1.44   thorpej 
    156    1.1       cgd #ifndef	IPFORWARDING
    157    1.1       cgd #ifdef GATEWAY
    158    1.1       cgd #define	IPFORWARDING	1	/* forward IP packets not for us */
    159    1.1       cgd #else /* GATEWAY */
    160    1.1       cgd #define	IPFORWARDING	0	/* don't forward IP packets not for us */
    161    1.1       cgd #endif /* GATEWAY */
    162    1.1       cgd #endif /* IPFORWARDING */
    163    1.1       cgd #ifndef	IPSENDREDIRECTS
    164    1.1       cgd #define	IPSENDREDIRECTS	1
    165    1.1       cgd #endif
    166   1.26   thorpej #ifndef IPFORWSRCRT
    167   1.47       cjs #define	IPFORWSRCRT	1	/* forward source-routed packets */
    168   1.47       cjs #endif
    169   1.47       cjs #ifndef IPALLOWSRCRT
    170   1.48       mrg #define	IPALLOWSRCRT	1	/* allow source-routed packets */
    171   1.26   thorpej #endif
    172   1.53       kml #ifndef IPMTUDISC
    173  1.153    itojun #define IPMTUDISC	1
    174   1.53       kml #endif
    175   1.60       kml #ifndef IPMTUDISCTIMEOUT
    176   1.61       kml #define IPMTUDISCTIMEOUT (10 * 60)	/* as per RFC 1191 */
    177   1.60       kml #endif
    178   1.53       kml 
    179   1.27   thorpej /*
    180   1.27   thorpej  * Note: DIRECTED_BROADCAST is handled this way so that previous
    181   1.27   thorpej  * configuration using this option will Just Work.
    182   1.27   thorpej  */
    183   1.27   thorpej #ifndef IPDIRECTEDBCAST
    184   1.27   thorpej #ifdef DIRECTED_BROADCAST
    185   1.27   thorpej #define IPDIRECTEDBCAST	1
    186   1.27   thorpej #else
    187   1.27   thorpej #define	IPDIRECTEDBCAST	0
    188   1.27   thorpej #endif /* DIRECTED_BROADCAST */
    189   1.27   thorpej #endif /* IPDIRECTEDBCAST */
    190    1.1       cgd int	ipforwarding = IPFORWARDING;
    191    1.1       cgd int	ipsendredirects = IPSENDREDIRECTS;
    192   1.13   mycroft int	ip_defttl = IPDEFTTL;
    193   1.26   thorpej int	ip_forwsrcrt = IPFORWSRCRT;
    194   1.27   thorpej int	ip_directedbcast = IPDIRECTEDBCAST;
    195   1.47       cjs int	ip_allowsrcrt = IPALLOWSRCRT;
    196   1.53       kml int	ip_mtudisc = IPMTUDISC;
    197  1.156    itojun int	ip_mtudisc_timeout = IPMTUDISCTIMEOUT;
    198    1.1       cgd #ifdef DIAGNOSTIC
    199    1.1       cgd int	ipprintfs = 0;
    200    1.1       cgd #endif
    201  1.184  jonathan 
    202  1.184  jonathan int	ip_do_randomid = 0;
    203  1.184  jonathan 
    204  1.165  christos /*
    205  1.165  christos  * XXX - Setting ip_checkinterface mostly implements the receive side of
    206  1.165  christos  * the Strong ES model described in RFC 1122, but since the routing table
    207  1.165  christos  * and transmit implementation do not implement the Strong ES model,
    208  1.165  christos  * setting this to 1 results in an odd hybrid.
    209  1.165  christos  *
    210  1.165  christos  * XXX - ip_checkinterface currently must be disabled if you use ipnat
    211  1.165  christos  * to translate the destination address to another local interface.
    212  1.165  christos  *
    213  1.165  christos  * XXX - ip_checkinterface must be disabled if you add IP aliases
    214  1.165  christos  * to the loopback interface instead of the interface where the
    215  1.165  christos  * packets for those addresses are received.
    216  1.165  christos  */
    217  1.165  christos int	ip_checkinterface = 0;
    218  1.165  christos 
    219    1.1       cgd 
    220   1.60       kml struct rttimer_queue *ip_mtudisc_timeout_q = NULL;
    221   1.60       kml 
    222    1.1       cgd extern	struct domain inetdomain;
    223    1.1       cgd int	ipqmaxlen = IFQ_MAXLEN;
    224  1.150      matt u_long	in_ifaddrhash;				/* size of hash table - 1 */
    225  1.150      matt int	in_ifaddrentries;			/* total number of addrs */
    226  1.181  jonathan struct in_ifaddrhead in_ifaddrhead;
    227   1.57       tls struct	in_ifaddrhashhead *in_ifaddrhashtbl;
    228  1.166      matt u_long	in_multihash;				/* size of hash table - 1 */
    229  1.166      matt int	in_multientries;			/* total number of addrs */
    230  1.166      matt struct	in_multihashhead *in_multihashtbl;
    231   1.13   mycroft struct	ifqueue ipintrq;
    232   1.63      matt struct	ipstat	ipstat;
    233  1.183  jonathan uint16_t ip_id;
    234   1.75   thorpej 
    235  1.121   thorpej #ifdef PFIL_HOOKS
    236  1.121   thorpej struct pfil_head inet_pfil_hook;
    237  1.121   thorpej #endif
    238  1.121   thorpej 
    239  1.190  jonathan /* IP datagram reassembly queues (hashed) */
    240  1.190  jonathan #define IPREASS_NHASH_LOG2      6
    241  1.190  jonathan #define IPREASS_NHASH           (1 << IPREASS_NHASH_LOG2)
    242  1.190  jonathan #define IPREASS_HMASK           (IPREASS_NHASH - 1)
    243  1.190  jonathan #define IPREASS_HASH(x,y) \
    244  1.190  jonathan 	(((((x) & 0xF) | ((((x) >> 8) & 0xF) << 4)) ^ (y)) & IPREASS_HMASK)
    245  1.190  jonathan struct ipqhead ipq[IPREASS_NHASH];
    246  1.190  jonathan #ifdef notyet
    247  1.190  jonathan static int    nipq = 0;         /* total # of reass queues */
    248  1.190  jonathan #endif
    249   1.75   thorpej int	ipq_locked;
    250  1.131    itojun int	ip_nfragpackets = 0;
    251  1.133    itojun int	ip_maxfragpackets = 200;
    252   1.75   thorpej 
    253   1.75   thorpej static __inline int ipq_lock_try __P((void));
    254   1.75   thorpej static __inline void ipq_unlock __P((void));
    255   1.75   thorpej 
    256   1.75   thorpej static __inline int
    257   1.75   thorpej ipq_lock_try()
    258   1.75   thorpej {
    259   1.75   thorpej 	int s;
    260   1.75   thorpej 
    261  1.132   thorpej 	/*
    262  1.149       wiz 	 * Use splvm() -- we're blocking things that would cause
    263  1.132   thorpej 	 * mbuf allocation.
    264  1.132   thorpej 	 */
    265  1.132   thorpej 	s = splvm();
    266   1.75   thorpej 	if (ipq_locked) {
    267   1.75   thorpej 		splx(s);
    268   1.75   thorpej 		return (0);
    269   1.75   thorpej 	}
    270   1.75   thorpej 	ipq_locked = 1;
    271   1.75   thorpej 	splx(s);
    272   1.75   thorpej 	return (1);
    273   1.75   thorpej }
    274   1.75   thorpej 
    275   1.75   thorpej static __inline void
    276   1.75   thorpej ipq_unlock()
    277   1.75   thorpej {
    278   1.75   thorpej 	int s;
    279   1.75   thorpej 
    280  1.132   thorpej 	s = splvm();
    281   1.75   thorpej 	ipq_locked = 0;
    282   1.75   thorpej 	splx(s);
    283   1.75   thorpej }
    284   1.75   thorpej 
    285   1.75   thorpej #ifdef DIAGNOSTIC
    286   1.75   thorpej #define	IPQ_LOCK()							\
    287   1.75   thorpej do {									\
    288   1.75   thorpej 	if (ipq_lock_try() == 0) {					\
    289   1.75   thorpej 		printf("%s:%d: ipq already locked\n", __FILE__, __LINE__); \
    290   1.75   thorpej 		panic("ipq_lock");					\
    291   1.75   thorpej 	}								\
    292  1.159     perry } while (/*CONSTCOND*/ 0)
    293   1.75   thorpej #define	IPQ_LOCK_CHECK()						\
    294   1.75   thorpej do {									\
    295   1.75   thorpej 	if (ipq_locked == 0) {						\
    296   1.75   thorpej 		printf("%s:%d: ipq lock not held\n", __FILE__, __LINE__); \
    297   1.75   thorpej 		panic("ipq lock check");				\
    298   1.75   thorpej 	}								\
    299  1.159     perry } while (/*CONSTCOND*/ 0)
    300   1.75   thorpej #else
    301   1.75   thorpej #define	IPQ_LOCK()		(void) ipq_lock_try()
    302   1.75   thorpej #define	IPQ_LOCK_CHECK()	/* nothing */
    303   1.75   thorpej #endif
    304   1.75   thorpej 
    305   1.75   thorpej #define	IPQ_UNLOCK()		ipq_unlock()
    306    1.1       cgd 
    307  1.166      matt struct pool inmulti_pool;
    308   1.72   thorpej struct pool ipqent_pool;
    309   1.72   thorpej 
    310  1.135   thorpej #ifdef INET_CSUM_COUNTERS
    311  1.135   thorpej #include <sys/device.h>
    312  1.135   thorpej 
    313  1.135   thorpej struct evcnt ip_hwcsum_bad = EVCNT_INITIALIZER(EVCNT_TYPE_MISC,
    314  1.135   thorpej     NULL, "inet", "hwcsum bad");
    315  1.135   thorpej struct evcnt ip_hwcsum_ok = EVCNT_INITIALIZER(EVCNT_TYPE_MISC,
    316  1.135   thorpej     NULL, "inet", "hwcsum ok");
    317  1.135   thorpej struct evcnt ip_swcsum = EVCNT_INITIALIZER(EVCNT_TYPE_MISC,
    318  1.135   thorpej     NULL, "inet", "swcsum");
    319  1.135   thorpej 
    320  1.135   thorpej #define	INET_CSUM_COUNTER_INCR(ev)	(ev)->ev_count++
    321  1.135   thorpej 
    322  1.135   thorpej #else
    323  1.135   thorpej 
    324  1.135   thorpej #define	INET_CSUM_COUNTER_INCR(ev)	/* nothing */
    325  1.135   thorpej 
    326  1.135   thorpej #endif /* INET_CSUM_COUNTERS */
    327  1.135   thorpej 
    328    1.1       cgd /*
    329    1.1       cgd  * We need to save the IP options in case a protocol wants to respond
    330    1.1       cgd  * to an incoming packet over the same route if the packet got here
    331    1.1       cgd  * using IP source routing.  This allows connection establishment and
    332    1.1       cgd  * maintenance when the remote end is on a network that is not known
    333    1.1       cgd  * to us.
    334    1.1       cgd  */
    335    1.1       cgd int	ip_nhops = 0;
    336    1.1       cgd static	struct ip_srcrt {
    337    1.1       cgd 	struct	in_addr dst;			/* final destination */
    338    1.1       cgd 	char	nop;				/* one NOP to align */
    339    1.1       cgd 	char	srcopt[IPOPT_OFFSET + 1];	/* OPTVAL, OLEN and OFFSET */
    340    1.1       cgd 	struct	in_addr route[MAX_IPOPTLEN/sizeof(struct in_addr)];
    341    1.1       cgd } ip_srcrt;
    342    1.1       cgd 
    343   1.13   mycroft static void save_rte __P((u_char *, struct in_addr));
    344   1.35   mycroft 
    345  1.164      matt #ifdef MBUFTRACE
    346  1.164      matt struct mowner ip_rx_mowner = { "internet", "rx" };
    347  1.164      matt struct mowner ip_tx_mowner = { "internet", "tx" };
    348  1.164      matt #endif
    349  1.164      matt 
    350    1.1       cgd /*
    351    1.1       cgd  * IP initialization: fill in IP protocol switch table.
    352    1.1       cgd  * All protocols not implemented in kernel go to raw IP protocol handler.
    353    1.1       cgd  */
    354    1.8   mycroft void
    355    1.1       cgd ip_init()
    356    1.1       cgd {
    357  1.109  augustss 	struct protosw *pr;
    358  1.109  augustss 	int i;
    359    1.1       cgd 
    360  1.166      matt 	pool_init(&inmulti_pool, sizeof(struct in_multi), 0, 0, 0, "inmltpl",
    361  1.166      matt 	    NULL);
    362   1.72   thorpej 	pool_init(&ipqent_pool, sizeof(struct ipqent), 0, 0, 0, "ipqepl",
    363  1.146   thorpej 	    NULL);
    364   1.72   thorpej 
    365    1.1       cgd 	pr = pffindproto(PF_INET, IPPROTO_RAW, SOCK_RAW);
    366    1.1       cgd 	if (pr == 0)
    367    1.1       cgd 		panic("ip_init");
    368    1.1       cgd 	for (i = 0; i < IPPROTO_MAX; i++)
    369    1.1       cgd 		ip_protox[i] = pr - inetsw;
    370    1.1       cgd 	for (pr = inetdomain.dom_protosw;
    371    1.1       cgd 	    pr < inetdomain.dom_protoswNPROTOSW; pr++)
    372    1.1       cgd 		if (pr->pr_domain->dom_family == PF_INET &&
    373    1.1       cgd 		    pr->pr_protocol && pr->pr_protocol != IPPROTO_RAW)
    374    1.1       cgd 			ip_protox[pr->pr_protocol] = pr - inetsw;
    375  1.190  jonathan 	for (i = 0; i < IPREASS_NHASH; i++)
    376  1.190  jonathan 	    	LIST_INIT(&ipq[i]);
    377  1.190  jonathan 
    378  1.183  jonathan 	ip_id = time.tv_sec & 0xfffff;
    379    1.1       cgd 	ipintrq.ifq_maxlen = ipqmaxlen;
    380  1.181  jonathan 	TAILQ_INIT(&in_ifaddrhead);
    381  1.120        ad 	in_ifaddrhashtbl = hashinit(IN_IFADDR_HASH_SIZE, HASH_LIST, M_IFADDR,
    382  1.120        ad 	    M_WAITOK, &in_ifaddrhash);
    383  1.166      matt 	in_multihashtbl = hashinit(IN_IFADDR_HASH_SIZE, HASH_LIST, M_IPMADDR,
    384  1.166      matt 	    M_WAITOK, &in_multihash);
    385  1.160    itojun 	ip_mtudisc_timeout_q = rt_timer_queue_create(ip_mtudisc_timeout);
    386   1.73   thorpej #ifdef GATEWAY
    387   1.73   thorpej 	ipflow_init();
    388   1.73   thorpej #endif
    389  1.121   thorpej 
    390  1.121   thorpej #ifdef PFIL_HOOKS
    391  1.121   thorpej 	/* Register our Packet Filter hook. */
    392  1.126   thorpej 	inet_pfil_hook.ph_type = PFIL_TYPE_AF;
    393  1.126   thorpej 	inet_pfil_hook.ph_af   = AF_INET;
    394  1.121   thorpej 	i = pfil_head_register(&inet_pfil_hook);
    395  1.121   thorpej 	if (i != 0)
    396  1.121   thorpej 		printf("ip_init: WARNING: unable to register pfil hook, "
    397  1.121   thorpej 		    "error %d\n", i);
    398  1.121   thorpej #endif /* PFIL_HOOKS */
    399  1.135   thorpej 
    400  1.135   thorpej #ifdef INET_CSUM_COUNTERS
    401  1.135   thorpej 	evcnt_attach_static(&ip_hwcsum_bad);
    402  1.135   thorpej 	evcnt_attach_static(&ip_hwcsum_ok);
    403  1.135   thorpej 	evcnt_attach_static(&ip_swcsum);
    404  1.135   thorpej #endif /* INET_CSUM_COUNTERS */
    405  1.164      matt 
    406  1.164      matt #ifdef MBUFTRACE
    407  1.164      matt 	MOWNER_ATTACH(&ip_tx_mowner);
    408  1.164      matt 	MOWNER_ATTACH(&ip_rx_mowner);
    409  1.164      matt #endif /* MBUFTRACE */
    410    1.1       cgd }
    411    1.1       cgd 
    412    1.1       cgd struct	sockaddr_in ipaddr = { sizeof(ipaddr), AF_INET };
    413    1.1       cgd struct	route ipforward_rt;
    414    1.1       cgd 
    415    1.1       cgd /*
    416   1.89    itojun  * IP software interrupt routine
    417   1.89    itojun  */
    418   1.89    itojun void
    419   1.89    itojun ipintr()
    420   1.89    itojun {
    421   1.89    itojun 	int s;
    422   1.89    itojun 	struct mbuf *m;
    423   1.89    itojun 
    424   1.89    itojun 	while (1) {
    425  1.132   thorpej 		s = splnet();
    426   1.89    itojun 		IF_DEQUEUE(&ipintrq, m);
    427   1.89    itojun 		splx(s);
    428   1.89    itojun 		if (m == 0)
    429   1.89    itojun 			return;
    430  1.164      matt 		MCLAIM(m, &ip_rx_mowner);
    431   1.89    itojun 		ip_input(m);
    432   1.89    itojun 	}
    433   1.89    itojun }
    434   1.89    itojun 
    435   1.89    itojun /*
    436    1.1       cgd  * Ip input routine.  Checksum and byte swap header.  If fragmented
    437    1.1       cgd  * try to reassemble.  Process options.  Pass to next level.
    438    1.1       cgd  */
    439    1.8   mycroft void
    440   1.89    itojun ip_input(struct mbuf *m)
    441    1.1       cgd {
    442  1.109  augustss 	struct ip *ip = NULL;
    443  1.109  augustss 	struct ipq *fp;
    444  1.109  augustss 	struct in_ifaddr *ia;
    445  1.109  augustss 	struct ifaddr *ifa;
    446   1.25       cgd 	struct ipqent *ipqe;
    447   1.89    itojun 	int hlen = 0, mff, len;
    448  1.100    itojun 	int downmatch;
    449  1.165  christos 	int checkif;
    450  1.169    itojun 	int srcrt = 0;
    451  1.190  jonathan 	u_int hash;
    452  1.173  jonathan #ifdef FAST_IPSEC
    453  1.173  jonathan 	struct m_tag *mtag;
    454  1.173  jonathan 	struct tdb_ident *tdbi;
    455  1.173  jonathan 	struct secpolicy *sp;
    456  1.173  jonathan 	int s, error;
    457  1.173  jonathan #endif /* FAST_IPSEC */
    458    1.1       cgd 
    459  1.164      matt 	MCLAIM(m, &ip_rx_mowner);
    460    1.1       cgd #ifdef	DIAGNOSTIC
    461    1.1       cgd 	if ((m->m_flags & M_PKTHDR) == 0)
    462    1.1       cgd 		panic("ipintr no HDR");
    463   1.89    itojun #endif
    464  1.164      matt 
    465    1.1       cgd 	/*
    466    1.1       cgd 	 * If no IP addresses have been set yet but the interfaces
    467    1.1       cgd 	 * are receiving, can't do anything with incoming packets yet.
    468    1.1       cgd 	 */
    469  1.181  jonathan 	if (TAILQ_FIRST(&in_ifaddrhead) == 0)
    470    1.1       cgd 		goto bad;
    471    1.1       cgd 	ipstat.ips_total++;
    472  1.154   thorpej 	/*
    473  1.154   thorpej 	 * If the IP header is not aligned, slurp it up into a new
    474  1.154   thorpej 	 * mbuf with space for link headers, in the event we forward
    475  1.154   thorpej 	 * it.  Otherwise, if it is aligned, make sure the entire
    476  1.154   thorpej 	 * base IP header is in the first mbuf of the chain.
    477  1.154   thorpej 	 */
    478  1.154   thorpej 	if (IP_HDR_ALIGNED_P(mtod(m, caddr_t)) == 0) {
    479  1.154   thorpej 		if ((m = m_copyup(m, sizeof(struct ip),
    480  1.154   thorpej 				  (max_linkhdr + 3) & ~3)) == NULL) {
    481  1.154   thorpej 			/* XXXJRT new stat, please */
    482  1.154   thorpej 			ipstat.ips_toosmall++;
    483  1.154   thorpej 			return;
    484  1.154   thorpej 		}
    485  1.154   thorpej 	} else if (__predict_false(m->m_len < sizeof (struct ip))) {
    486  1.154   thorpej 		if ((m = m_pullup(m, sizeof (struct ip))) == NULL) {
    487  1.154   thorpej 			ipstat.ips_toosmall++;
    488  1.154   thorpej 			return;
    489  1.154   thorpej 		}
    490    1.1       cgd 	}
    491    1.1       cgd 	ip = mtod(m, struct ip *);
    492   1.13   mycroft 	if (ip->ip_v != IPVERSION) {
    493   1.13   mycroft 		ipstat.ips_badvers++;
    494   1.13   mycroft 		goto bad;
    495   1.13   mycroft 	}
    496    1.1       cgd 	hlen = ip->ip_hl << 2;
    497    1.1       cgd 	if (hlen < sizeof(struct ip)) {	/* minimum header length */
    498    1.1       cgd 		ipstat.ips_badhlen++;
    499    1.1       cgd 		goto bad;
    500    1.1       cgd 	}
    501    1.1       cgd 	if (hlen > m->m_len) {
    502    1.1       cgd 		if ((m = m_pullup(m, hlen)) == 0) {
    503    1.1       cgd 			ipstat.ips_badhlen++;
    504   1.89    itojun 			return;
    505    1.1       cgd 		}
    506    1.1       cgd 		ip = mtod(m, struct ip *);
    507    1.1       cgd 	}
    508   1.98   thorpej 
    509   1.85       hwr 	/*
    510   1.99   thorpej 	 * RFC1122: packets with a multicast source address are
    511   1.98   thorpej 	 * not allowed.
    512   1.85       hwr 	 */
    513   1.85       hwr 	if (IN_MULTICAST(ip->ip_src.s_addr)) {
    514  1.130    itojun 		ipstat.ips_badaddr++;
    515   1.85       hwr 		goto bad;
    516  1.129    itojun 	}
    517  1.129    itojun 
    518  1.129    itojun 	/* 127/8 must not appear on wire - RFC1122 */
    519  1.129    itojun 	if ((ntohl(ip->ip_dst.s_addr) >> IN_CLASSA_NSHIFT) == IN_LOOPBACKNET ||
    520  1.129    itojun 	    (ntohl(ip->ip_src.s_addr) >> IN_CLASSA_NSHIFT) == IN_LOOPBACKNET) {
    521  1.130    itojun 		if ((m->m_pkthdr.rcvif->if_flags & IFF_LOOPBACK) == 0) {
    522  1.130    itojun 			ipstat.ips_badaddr++;
    523  1.129    itojun 			goto bad;
    524  1.130    itojun 		}
    525   1.85       hwr 	}
    526   1.85       hwr 
    527  1.135   thorpej 	switch (m->m_pkthdr.csum_flags &
    528  1.137   thorpej 		((m->m_pkthdr.rcvif->if_csum_flags_rx & M_CSUM_IPv4) |
    529  1.135   thorpej 		 M_CSUM_IPv4_BAD)) {
    530  1.135   thorpej 	case M_CSUM_IPv4|M_CSUM_IPv4_BAD:
    531  1.135   thorpej 		INET_CSUM_COUNTER_INCR(&ip_hwcsum_bad);
    532  1.135   thorpej 		goto badcsum;
    533  1.135   thorpej 
    534  1.135   thorpej 	case M_CSUM_IPv4:
    535  1.135   thorpej 		/* Checksum was okay. */
    536  1.135   thorpej 		INET_CSUM_COUNTER_INCR(&ip_hwcsum_ok);
    537  1.135   thorpej 		break;
    538  1.135   thorpej 
    539  1.135   thorpej 	default:
    540  1.135   thorpej 		/* Must compute it ourselves. */
    541  1.135   thorpej 		INET_CSUM_COUNTER_INCR(&ip_swcsum);
    542  1.135   thorpej 		if (in_cksum(m, hlen) != 0)
    543  1.135   thorpej 			goto bad;
    544  1.135   thorpej 		break;
    545    1.1       cgd 	}
    546    1.1       cgd 
    547  1.121   thorpej 	/* Retrieve the packet length. */
    548  1.121   thorpej 	len = ntohs(ip->ip_len);
    549   1.81     proff 
    550   1.81     proff 	/*
    551   1.81     proff 	 * Check for additional length bogosity
    552   1.81     proff 	 */
    553   1.84     proff 	if (len < hlen) {
    554   1.81     proff 	 	ipstat.ips_badlen++;
    555   1.81     proff 		goto bad;
    556   1.81     proff 	}
    557    1.1       cgd 
    558    1.1       cgd 	/*
    559    1.1       cgd 	 * Check that the amount of data in the buffers
    560    1.1       cgd 	 * is as at least much as the IP header would have us expect.
    561    1.1       cgd 	 * Trim mbufs if longer than we expect.
    562    1.1       cgd 	 * Drop packet if shorter than we expect.
    563    1.1       cgd 	 */
    564   1.35   mycroft 	if (m->m_pkthdr.len < len) {
    565    1.1       cgd 		ipstat.ips_tooshort++;
    566    1.1       cgd 		goto bad;
    567    1.1       cgd 	}
    568   1.35   mycroft 	if (m->m_pkthdr.len > len) {
    569    1.1       cgd 		if (m->m_len == m->m_pkthdr.len) {
    570   1.35   mycroft 			m->m_len = len;
    571   1.35   mycroft 			m->m_pkthdr.len = len;
    572    1.1       cgd 		} else
    573   1.35   mycroft 			m_adj(m, len - m->m_pkthdr.len);
    574    1.1       cgd 	}
    575    1.1       cgd 
    576  1.188       scw #if defined(IPSEC) || defined(FAST_IPSEC)
    577  1.149       wiz 	/* ipflow (IP fast forwarding) is not compatible with IPsec. */
    578   1.94    itojun 	m->m_flags &= ~M_CANFASTFWD;
    579   1.94    itojun #else
    580   1.64   thorpej 	/*
    581   1.64   thorpej 	 * Assume that we can create a fast-forward IP flow entry
    582   1.64   thorpej 	 * based on this packet.
    583   1.64   thorpej 	 */
    584   1.64   thorpej 	m->m_flags |= M_CANFASTFWD;
    585   1.94    itojun #endif
    586   1.64   thorpej 
    587   1.36       mrg #ifdef PFIL_HOOKS
    588   1.33       mrg 	/*
    589   1.64   thorpej 	 * Run through list of hooks for input packets.  If there are any
    590   1.64   thorpej 	 * filters which require that additional packets in the flow are
    591   1.64   thorpej 	 * not fast-forwarded, they must clear the M_CANFASTFWD flag.
    592   1.64   thorpej 	 * Note that filters must _never_ set this flag, as another filter
    593   1.64   thorpej 	 * in the list may have previously cleared it.
    594   1.33       mrg 	 */
    595  1.127    itojun 	/*
    596  1.127    itojun 	 * let ipfilter look at packet on the wire,
    597  1.127    itojun 	 * not the decapsulated packet.
    598  1.127    itojun 	 */
    599  1.127    itojun #ifdef IPSEC
    600  1.136    itojun 	if (!ipsec_getnhist(m))
    601  1.186       scw #elif defined(FAST_IPSEC)
    602  1.186       scw 	if (!ipsec_indone(m))
    603  1.127    itojun #else
    604  1.127    itojun 	if (1)
    605  1.127    itojun #endif
    606  1.127    itojun 	{
    607  1.169    itojun 		struct in_addr odst;
    608  1.169    itojun 
    609  1.169    itojun 		odst = ip->ip_dst;
    610  1.127    itojun 		if (pfil_run_hooks(&inet_pfil_hook, &m, m->m_pkthdr.rcvif,
    611  1.168    itojun 		    PFIL_IN) != 0)
    612  1.168    itojun 			return;
    613  1.127    itojun 		if (m == NULL)
    614  1.127    itojun 			return;
    615  1.127    itojun 		ip = mtod(m, struct ip *);
    616  1.142   darrenr 		hlen = ip->ip_hl << 2;
    617  1.169    itojun 		srcrt = (odst.s_addr != ip->ip_dst.s_addr);
    618  1.127    itojun 	}
    619   1.36       mrg #endif /* PFIL_HOOKS */
    620  1.123   thorpej 
    621  1.123   thorpej #ifdef ALTQ
    622  1.123   thorpej 	/* XXX Temporary until ALTQ is changed to use a pfil hook */
    623  1.123   thorpej 	if (altq_input != NULL && (*altq_input)(m, AF_INET) == 0) {
    624  1.123   thorpej 		/* packet dropped by traffic conditioner */
    625  1.123   thorpej 		return;
    626  1.123   thorpej 	}
    627  1.123   thorpej #endif
    628  1.121   thorpej 
    629  1.121   thorpej 	/*
    630    1.1       cgd 	 * Process options and, if not destined for us,
    631    1.1       cgd 	 * ship it on.  ip_dooptions returns 1 when an
    632    1.1       cgd 	 * error was detected (causing an icmp message
    633    1.1       cgd 	 * to be sent and the original packet to be freed).
    634    1.1       cgd 	 */
    635    1.1       cgd 	ip_nhops = 0;		/* for source routed packets */
    636    1.1       cgd 	if (hlen > sizeof (struct ip) && ip_dooptions(m))
    637   1.89    itojun 		return;
    638    1.1       cgd 
    639    1.1       cgd 	/*
    640  1.165  christos 	 * Enable a consistency check between the destination address
    641  1.165  christos 	 * and the arrival interface for a unicast packet (the RFC 1122
    642  1.165  christos 	 * strong ES model) if IP forwarding is disabled and the packet
    643  1.165  christos 	 * is not locally generated.
    644  1.165  christos 	 *
    645  1.165  christos 	 * XXX - Checking also should be disabled if the destination
    646  1.165  christos 	 * address is ipnat'ed to a different interface.
    647  1.165  christos 	 *
    648  1.165  christos 	 * XXX - Checking is incompatible with IP aliases added
    649  1.165  christos 	 * to the loopback interface instead of the interface where
    650  1.165  christos 	 * the packets are received.
    651  1.165  christos 	 *
    652  1.165  christos 	 * XXX - We need to add a per ifaddr flag for this so that
    653  1.165  christos 	 * we get finer grain control.
    654  1.165  christos 	 */
    655  1.165  christos 	checkif = ip_checkinterface && (ipforwarding == 0) &&
    656  1.165  christos 	    (m->m_pkthdr.rcvif != NULL) &&
    657  1.165  christos 	    ((m->m_pkthdr.rcvif->if_flags & IFF_LOOPBACK) == 0);
    658  1.165  christos 
    659  1.165  christos 	/*
    660    1.1       cgd 	 * Check our list of addresses, to see if the packet is for us.
    661  1.100    itojun 	 *
    662  1.100    itojun 	 * Traditional 4.4BSD did not consult IFF_UP at all.
    663  1.100    itojun 	 * The behavior here is to treat addresses on !IFF_UP interface
    664  1.100    itojun 	 * as not mine.
    665    1.1       cgd 	 */
    666  1.100    itojun 	downmatch = 0;
    667  1.140      matt 	LIST_FOREACH(ia, &IN_IFADDR_HASH(ip->ip_dst.s_addr), ia_hash) {
    668   1.97    itojun 		if (in_hosteq(ia->ia_addr.sin_addr, ip->ip_dst)) {
    669  1.165  christos 			if (checkif && ia->ia_ifp != m->m_pkthdr.rcvif)
    670  1.165  christos 				continue;
    671   1.97    itojun 			if ((ia->ia_ifp->if_flags & IFF_UP) != 0)
    672   1.97    itojun 				break;
    673  1.100    itojun 			else
    674  1.100    itojun 				downmatch++;
    675   1.97    itojun 		}
    676   1.97    itojun 	}
    677   1.86   thorpej 	if (ia != NULL)
    678   1.86   thorpej 		goto ours;
    679   1.57       tls 	if (m->m_pkthdr.rcvif->if_flags & IFF_BROADCAST) {
    680  1.140      matt 		TAILQ_FOREACH(ifa, &m->m_pkthdr.rcvif->if_addrlist, ifa_list) {
    681  1.140      matt 			if (ifa->ifa_addr->sa_family != AF_INET)
    682  1.140      matt 				continue;
    683   1.57       tls 			ia = ifatoia(ifa);
    684   1.35   mycroft 			if (in_hosteq(ip->ip_dst, ia->ia_broadaddr.sin_addr) ||
    685   1.35   mycroft 			    in_hosteq(ip->ip_dst, ia->ia_netbroadcast) ||
    686   1.20   mycroft 			    /*
    687   1.20   mycroft 			     * Look for all-0's host part (old broadcast addr),
    688   1.20   mycroft 			     * either for subnet or net.
    689   1.20   mycroft 			     */
    690   1.20   mycroft 			    ip->ip_dst.s_addr == ia->ia_subnet ||
    691   1.18   mycroft 			    ip->ip_dst.s_addr == ia->ia_net)
    692    1.1       cgd 				goto ours;
    693   1.57       tls 			/*
    694   1.57       tls 			 * An interface with IP address zero accepts
    695   1.57       tls 			 * all packets that arrive on that interface.
    696   1.57       tls 			 */
    697   1.57       tls 			if (in_nullhost(ia->ia_addr.sin_addr))
    698   1.57       tls 				goto ours;
    699    1.1       cgd 		}
    700    1.1       cgd 	}
    701   1.18   mycroft 	if (IN_MULTICAST(ip->ip_dst.s_addr)) {
    702    1.4   hpeyerl 		struct in_multi *inm;
    703    1.4   hpeyerl #ifdef MROUTING
    704    1.4   hpeyerl 		extern struct socket *ip_mrouter;
    705   1.10    brezak 
    706  1.147      matt 		if (M_READONLY(m)) {
    707   1.10    brezak 			if ((m = m_pullup(m, hlen)) == 0) {
    708   1.10    brezak 				ipstat.ips_toosmall++;
    709   1.89    itojun 				return;
    710   1.10    brezak 			}
    711   1.10    brezak 			ip = mtod(m, struct ip *);
    712   1.10    brezak 		}
    713    1.4   hpeyerl 
    714    1.4   hpeyerl 		if (ip_mrouter) {
    715    1.4   hpeyerl 			/*
    716    1.4   hpeyerl 			 * If we are acting as a multicast router, all
    717    1.4   hpeyerl 			 * incoming multicast packets are passed to the
    718    1.4   hpeyerl 			 * kernel-level multicast forwarding function.
    719    1.4   hpeyerl 			 * The packet is returned (relatively) intact; if
    720    1.4   hpeyerl 			 * ip_mforward() returns a non-zero value, the packet
    721    1.4   hpeyerl 			 * must be discarded, else it may be accepted below.
    722    1.4   hpeyerl 			 *
    723    1.4   hpeyerl 			 * (The IP ident field is put in the same byte order
    724    1.4   hpeyerl 			 * as expected when ip_mforward() is called from
    725    1.4   hpeyerl 			 * ip_output().)
    726    1.4   hpeyerl 			 */
    727   1.13   mycroft 			if (ip_mforward(m, m->m_pkthdr.rcvif) != 0) {
    728   1.13   mycroft 				ipstat.ips_cantforward++;
    729    1.4   hpeyerl 				m_freem(m);
    730   1.89    itojun 				return;
    731    1.4   hpeyerl 			}
    732    1.4   hpeyerl 
    733    1.4   hpeyerl 			/*
    734    1.4   hpeyerl 			 * The process-level routing demon needs to receive
    735    1.4   hpeyerl 			 * all multicast IGMP packets, whether or not this
    736    1.4   hpeyerl 			 * host belongs to their destination groups.
    737    1.4   hpeyerl 			 */
    738    1.4   hpeyerl 			if (ip->ip_p == IPPROTO_IGMP)
    739    1.4   hpeyerl 				goto ours;
    740   1.13   mycroft 			ipstat.ips_forward++;
    741    1.4   hpeyerl 		}
    742    1.4   hpeyerl #endif
    743    1.4   hpeyerl 		/*
    744    1.4   hpeyerl 		 * See if we belong to the destination multicast group on the
    745    1.4   hpeyerl 		 * arrival interface.
    746    1.4   hpeyerl 		 */
    747    1.4   hpeyerl 		IN_LOOKUP_MULTI(ip->ip_dst, m->m_pkthdr.rcvif, inm);
    748    1.4   hpeyerl 		if (inm == NULL) {
    749   1.13   mycroft 			ipstat.ips_cantforward++;
    750    1.4   hpeyerl 			m_freem(m);
    751   1.89    itojun 			return;
    752    1.4   hpeyerl 		}
    753    1.4   hpeyerl 		goto ours;
    754    1.4   hpeyerl 	}
    755   1.19   mycroft 	if (ip->ip_dst.s_addr == INADDR_BROADCAST ||
    756   1.35   mycroft 	    in_nullhost(ip->ip_dst))
    757    1.1       cgd 		goto ours;
    758    1.1       cgd 
    759    1.1       cgd 	/*
    760    1.1       cgd 	 * Not for us; forward if possible and desirable.
    761    1.1       cgd 	 */
    762    1.1       cgd 	if (ipforwarding == 0) {
    763    1.1       cgd 		ipstat.ips_cantforward++;
    764    1.1       cgd 		m_freem(m);
    765  1.100    itojun 	} else {
    766  1.100    itojun 		/*
    767  1.100    itojun 		 * If ip_dst matched any of my address on !IFF_UP interface,
    768  1.100    itojun 		 * and there's no IFF_UP interface that matches ip_dst,
    769  1.100    itojun 		 * send icmp unreach.  Forwarding it will result in in-kernel
    770  1.100    itojun 		 * forwarding loop till TTL goes to 0.
    771  1.100    itojun 		 */
    772  1.100    itojun 		if (downmatch) {
    773  1.100    itojun 			icmp_error(m, ICMP_UNREACH, ICMP_UNREACH_HOST, 0, 0);
    774  1.100    itojun 			ipstat.ips_cantforward++;
    775  1.100    itojun 			return;
    776  1.100    itojun 		}
    777  1.145    itojun #ifdef IPSEC
    778  1.145    itojun 		if (ipsec4_in_reject(m, NULL)) {
    779  1.145    itojun 			ipsecstat.in_polvio++;
    780  1.145    itojun 			goto bad;
    781  1.145    itojun 		}
    782  1.145    itojun #endif
    783  1.173  jonathan #ifdef FAST_IPSEC
    784  1.173  jonathan 		mtag = m_tag_find(m, PACKET_TAG_IPSEC_IN_DONE, NULL);
    785  1.173  jonathan 		s = splsoftnet();
    786  1.173  jonathan 		if (mtag != NULL) {
    787  1.173  jonathan 			tdbi = (struct tdb_ident *)(mtag + 1);
    788  1.173  jonathan 			sp = ipsec_getpolicy(tdbi, IPSEC_DIR_INBOUND);
    789  1.173  jonathan 		} else {
    790  1.173  jonathan 			sp = ipsec_getpolicybyaddr(m, IPSEC_DIR_INBOUND,
    791  1.173  jonathan 						   IP_FORWARDING, &error);
    792  1.173  jonathan 		}
    793  1.173  jonathan 		if (sp == NULL) {	/* NB: can happen if error */
    794  1.173  jonathan 			splx(s);
    795  1.173  jonathan 			/*XXX error stat???*/
    796  1.173  jonathan 			DPRINTF(("ip_input: no SP for forwarding\n"));	/*XXX*/
    797  1.173  jonathan 			goto bad;
    798  1.173  jonathan 		}
    799  1.173  jonathan 
    800  1.173  jonathan 		/*
    801  1.173  jonathan 		 * Check security policy against packet attributes.
    802  1.173  jonathan 		 */
    803  1.173  jonathan 		error = ipsec_in_reject(sp, m);
    804  1.173  jonathan 		KEY_FREESP(&sp);
    805  1.173  jonathan 		splx(s);
    806  1.173  jonathan 		if (error) {
    807  1.173  jonathan 			ipstat.ips_cantforward++;
    808  1.173  jonathan 			goto bad;
    809  1.173  jonathan 		}
    810  1.173  jonathan #endif	/* FAST_IPSEC */
    811  1.145    itojun 
    812  1.169    itojun 		ip_forward(m, srcrt);
    813  1.100    itojun 	}
    814   1.89    itojun 	return;
    815    1.1       cgd 
    816    1.1       cgd ours:
    817    1.1       cgd 	/*
    818    1.1       cgd 	 * If offset or IP_MF are set, must reassemble.
    819    1.1       cgd 	 * Otherwise, nothing need be done.
    820    1.1       cgd 	 * (We could look in the reassembly queue to see
    821    1.1       cgd 	 * if the packet was previously fragmented,
    822    1.1       cgd 	 * but it's not worth the time; just let them time out.)
    823    1.1       cgd 	 */
    824  1.155    itojun 	if (ip->ip_off & ~htons(IP_DF|IP_RF)) {
    825  1.155    itojun 		if (M_READONLY(m)) {
    826  1.155    itojun 			if ((m = m_pullup(m, hlen)) == NULL) {
    827  1.155    itojun 				ipstat.ips_toosmall++;
    828  1.155    itojun 				goto bad;
    829  1.155    itojun 			}
    830  1.155    itojun 			ip = mtod(m, struct ip *);
    831  1.155    itojun 		}
    832  1.155    itojun 
    833    1.1       cgd 		/*
    834    1.1       cgd 		 * Look for queue of fragments
    835    1.1       cgd 		 * of this datagram.
    836    1.1       cgd 		 */
    837   1.75   thorpej 		IPQ_LOCK();
    838  1.190  jonathan 		hash = IPREASS_HASH(ip->ip_src.s_addr, ip->ip_id);
    839  1.190  jonathan 		/* XXX LIST_FOREACH(fp, &ipq[hash], ipq_q) */
    840  1.190  jonathan 		for (fp = LIST_FIRST(&ipq[hash]); fp != NULL;
    841  1.190  jonathan 		     fp = LIST_NEXT(fp, ipq_q)) {
    842    1.1       cgd 			if (ip->ip_id == fp->ipq_id &&
    843   1.35   mycroft 			    in_hosteq(ip->ip_src, fp->ipq_src) &&
    844   1.35   mycroft 			    in_hosteq(ip->ip_dst, fp->ipq_dst) &&
    845    1.1       cgd 			    ip->ip_p == fp->ipq_p)
    846    1.1       cgd 				goto found;
    847  1.190  jonathan 
    848  1.190  jonathan 		}
    849    1.1       cgd 		fp = 0;
    850    1.1       cgd found:
    851    1.1       cgd 
    852    1.1       cgd 		/*
    853    1.1       cgd 		 * Adjust ip_len to not reflect header,
    854   1.25       cgd 		 * set ipqe_mff if more fragments are expected,
    855    1.1       cgd 		 * convert offset of this to bytes.
    856    1.1       cgd 		 */
    857  1.155    itojun 		ip->ip_len = htons(ntohs(ip->ip_len) - hlen);
    858  1.155    itojun 		mff = (ip->ip_off & htons(IP_MF)) != 0;
    859   1.25       cgd 		if (mff) {
    860   1.16       cgd 		        /*
    861   1.16       cgd 		         * Make sure that fragments have a data length
    862   1.16       cgd 			 * that's a non-zero multiple of 8 bytes.
    863   1.16       cgd 		         */
    864  1.155    itojun 			if (ntohs(ip->ip_len) == 0 ||
    865  1.155    itojun 			    (ntohs(ip->ip_len) & 0x7) != 0) {
    866   1.16       cgd 				ipstat.ips_badfrags++;
    867   1.75   thorpej 				IPQ_UNLOCK();
    868   1.16       cgd 				goto bad;
    869   1.16       cgd 			}
    870   1.16       cgd 		}
    871  1.155    itojun 		ip->ip_off = htons((ntohs(ip->ip_off) & IP_OFFMASK) << 3);
    872    1.1       cgd 
    873    1.1       cgd 		/*
    874    1.1       cgd 		 * If datagram marked as having more fragments
    875    1.1       cgd 		 * or if this is not the first fragment,
    876    1.1       cgd 		 * attempt reassembly; if it succeeds, proceed.
    877    1.1       cgd 		 */
    878  1.155    itojun 		if (mff || ip->ip_off != htons(0)) {
    879    1.1       cgd 			ipstat.ips_fragments++;
    880   1.72   thorpej 			ipqe = pool_get(&ipqent_pool, PR_NOWAIT);
    881   1.25       cgd 			if (ipqe == NULL) {
    882   1.25       cgd 				ipstat.ips_rcvmemdrop++;
    883   1.75   thorpej 				IPQ_UNLOCK();
    884   1.25       cgd 				goto bad;
    885   1.25       cgd 			}
    886   1.25       cgd 			ipqe->ipqe_mff = mff;
    887   1.50   thorpej 			ipqe->ipqe_m = m;
    888   1.25       cgd 			ipqe->ipqe_ip = ip;
    889  1.190  jonathan 			m = ip_reass(ipqe, fp, &ipq[hash]);
    890   1.75   thorpej 			if (m == 0) {
    891   1.75   thorpej 				IPQ_UNLOCK();
    892   1.89    itojun 				return;
    893   1.75   thorpej 			}
    894   1.13   mycroft 			ipstat.ips_reassembled++;
    895   1.50   thorpej 			ip = mtod(m, struct ip *);
    896   1.74   thorpej 			hlen = ip->ip_hl << 2;
    897  1.155    itojun 			ip->ip_len = htons(ntohs(ip->ip_len) + hlen);
    898    1.1       cgd 		} else
    899    1.1       cgd 			if (fp)
    900    1.1       cgd 				ip_freef(fp);
    901   1.75   thorpej 		IPQ_UNLOCK();
    902   1.79   mycroft 	}
    903  1.128    itojun 
    904  1.173  jonathan #if defined(IPSEC)
    905  1.128    itojun 	/*
    906  1.128    itojun 	 * enforce IPsec policy checking if we are seeing last header.
    907  1.128    itojun 	 * note that we do not visit this with protocols with pcb layer
    908  1.128    itojun 	 * code - like udp/tcp/raw ip.
    909  1.128    itojun 	 */
    910  1.128    itojun 	if ((inetsw[ip_protox[ip->ip_p]].pr_flags & PR_LASTHDR) != 0 &&
    911  1.128    itojun 	    ipsec4_in_reject(m, NULL)) {
    912  1.128    itojun 		ipsecstat.in_polvio++;
    913  1.128    itojun 		goto bad;
    914  1.128    itojun 	}
    915  1.128    itojun #endif
    916  1.173  jonathan #if FAST_IPSEC
    917  1.173  jonathan 	/*
    918  1.173  jonathan 	 * enforce IPsec policy checking if we are seeing last header.
    919  1.173  jonathan 	 * note that we do not visit this with protocols with pcb layer
    920  1.173  jonathan 	 * code - like udp/tcp/raw ip.
    921  1.173  jonathan 	 */
    922  1.173  jonathan 	if ((inetsw[ip_protox[ip->ip_p]].pr_flags & PR_LASTHDR) != 0) {
    923  1.173  jonathan 		/*
    924  1.173  jonathan 		 * Check if the packet has already had IPsec processing
    925  1.173  jonathan 		 * done.  If so, then just pass it along.  This tag gets
    926  1.173  jonathan 		 * set during AH, ESP, etc. input handling, before the
    927  1.173  jonathan 		 * packet is returned to the ip input queue for delivery.
    928  1.173  jonathan 		 */
    929  1.173  jonathan 		mtag = m_tag_find(m, PACKET_TAG_IPSEC_IN_DONE, NULL);
    930  1.173  jonathan 		s = splsoftnet();
    931  1.173  jonathan 		if (mtag != NULL) {
    932  1.173  jonathan 			tdbi = (struct tdb_ident *)(mtag + 1);
    933  1.173  jonathan 			sp = ipsec_getpolicy(tdbi, IPSEC_DIR_INBOUND);
    934  1.173  jonathan 		} else {
    935  1.173  jonathan 			sp = ipsec_getpolicybyaddr(m, IPSEC_DIR_INBOUND,
    936  1.173  jonathan 						   IP_FORWARDING, &error);
    937  1.173  jonathan 		}
    938  1.173  jonathan 		if (sp != NULL) {
    939  1.173  jonathan 			/*
    940  1.173  jonathan 			 * Check security policy against packet attributes.
    941  1.173  jonathan 			 */
    942  1.173  jonathan 			error = ipsec_in_reject(sp, m);
    943  1.173  jonathan 			KEY_FREESP(&sp);
    944  1.173  jonathan 		} else {
    945  1.173  jonathan 			/* XXX error stat??? */
    946  1.173  jonathan 			error = EINVAL;
    947  1.173  jonathan DPRINTF(("ip_input: no SP, packet discarded\n"));/*XXX*/
    948  1.173  jonathan 			goto bad;
    949  1.173  jonathan 		}
    950  1.173  jonathan 		splx(s);
    951  1.173  jonathan 		if (error)
    952  1.173  jonathan 			goto bad;
    953  1.173  jonathan 	}
    954  1.173  jonathan #endif /* FAST_IPSEC */
    955    1.1       cgd 
    956    1.1       cgd 	/*
    957    1.1       cgd 	 * Switch out to protocol's input routine.
    958    1.1       cgd 	 */
    959   1.82     aidan #if IFA_STATS
    960  1.122    itojun 	if (ia && ip)
    961  1.155    itojun 		ia->ia_ifa.ifa_data.ifad_inbytes += ntohs(ip->ip_len);
    962   1.82     aidan #endif
    963    1.1       cgd 	ipstat.ips_delivered++;
    964   1.89    itojun     {
    965   1.89    itojun 	int off = hlen, nh = ip->ip_p;
    966   1.89    itojun 
    967   1.89    itojun 	(*inetsw[ip_protox[nh]].pr_input)(m, off, nh);
    968   1.89    itojun 	return;
    969   1.89    itojun     }
    970    1.1       cgd bad:
    971    1.1       cgd 	m_freem(m);
    972  1.135   thorpej 	return;
    973  1.135   thorpej 
    974  1.135   thorpej badcsum:
    975  1.135   thorpej 	ipstat.ips_badsum++;
    976  1.135   thorpej 	m_freem(m);
    977    1.1       cgd }
    978    1.1       cgd 
    979    1.1       cgd /*
    980    1.1       cgd  * Take incoming datagram fragment and try to
    981    1.1       cgd  * reassemble it into whole datagram.  If a chain for
    982    1.1       cgd  * reassembly of this datagram already exists, then it
    983    1.1       cgd  * is given as fp; otherwise have to make a chain.
    984    1.1       cgd  */
    985   1.50   thorpej struct mbuf *
    986  1.190  jonathan ip_reass(ipqe, fp, ipqhead)
    987  1.109  augustss 	struct ipqent *ipqe;
    988  1.109  augustss 	struct ipq *fp;
    989  1.190  jonathan 	struct ipqhead *ipqhead;
    990    1.1       cgd {
    991  1.109  augustss 	struct mbuf *m = ipqe->ipqe_m;
    992  1.109  augustss 	struct ipqent *nq, *p, *q;
    993   1.25       cgd 	struct ip *ip;
    994    1.1       cgd 	struct mbuf *t;
    995   1.25       cgd 	int hlen = ipqe->ipqe_ip->ip_hl << 2;
    996    1.1       cgd 	int i, next;
    997    1.1       cgd 
    998   1.75   thorpej 	IPQ_LOCK_CHECK();
    999   1.75   thorpej 
   1000    1.1       cgd 	/*
   1001    1.1       cgd 	 * Presence of header sizes in mbufs
   1002    1.1       cgd 	 * would confuse code below.
   1003    1.1       cgd 	 */
   1004    1.1       cgd 	m->m_data += hlen;
   1005    1.1       cgd 	m->m_len -= hlen;
   1006    1.1       cgd 
   1007    1.1       cgd 	/*
   1008    1.1       cgd 	 * If first fragment to arrive, create a reassembly queue.
   1009    1.1       cgd 	 */
   1010    1.1       cgd 	if (fp == 0) {
   1011  1.131    itojun 		/*
   1012  1.131    itojun 		 * Enforce upper bound on number of fragmented packets
   1013  1.131    itojun 		 * for which we attempt reassembly;
   1014  1.131    itojun 		 * If maxfrag is 0, never accept fragments.
   1015  1.131    itojun 		 * If maxfrag is -1, accept all fragments without limitation.
   1016  1.131    itojun 		 */
   1017  1.131    itojun 		if (ip_maxfragpackets < 0)
   1018  1.131    itojun 			;
   1019  1.131    itojun 		else if (ip_nfragpackets >= ip_maxfragpackets)
   1020  1.131    itojun 			goto dropfrag;
   1021  1.131    itojun 		ip_nfragpackets++;
   1022   1.50   thorpej 		MALLOC(fp, struct ipq *, sizeof (struct ipq),
   1023   1.50   thorpej 		    M_FTABLE, M_NOWAIT);
   1024   1.50   thorpej 		if (fp == NULL)
   1025    1.1       cgd 			goto dropfrag;
   1026  1.190  jonathan 		LIST_INSERT_HEAD(ipqhead, fp, ipq_q);
   1027    1.1       cgd 		fp->ipq_ttl = IPFRAGTTL;
   1028   1.25       cgd 		fp->ipq_p = ipqe->ipqe_ip->ip_p;
   1029   1.25       cgd 		fp->ipq_id = ipqe->ipqe_ip->ip_id;
   1030  1.148      matt 		TAILQ_INIT(&fp->ipq_fragq);
   1031   1.25       cgd 		fp->ipq_src = ipqe->ipqe_ip->ip_src;
   1032   1.25       cgd 		fp->ipq_dst = ipqe->ipqe_ip->ip_dst;
   1033   1.25       cgd 		p = NULL;
   1034    1.1       cgd 		goto insert;
   1035    1.1       cgd 	}
   1036    1.1       cgd 
   1037    1.1       cgd 	/*
   1038    1.1       cgd 	 * Find a segment which begins after this one does.
   1039    1.1       cgd 	 */
   1040  1.148      matt 	for (p = NULL, q = TAILQ_FIRST(&fp->ipq_fragq); q != NULL;
   1041  1.148      matt 	    p = q, q = TAILQ_NEXT(q, ipqe_q))
   1042  1.155    itojun 		if (ntohs(q->ipqe_ip->ip_off) > ntohs(ipqe->ipqe_ip->ip_off))
   1043    1.1       cgd 			break;
   1044    1.1       cgd 
   1045    1.1       cgd 	/*
   1046    1.1       cgd 	 * If there is a preceding segment, it may provide some of
   1047    1.1       cgd 	 * our data already.  If so, drop the data from the incoming
   1048    1.1       cgd 	 * segment.  If it provides all of our data, drop us.
   1049    1.1       cgd 	 */
   1050   1.25       cgd 	if (p != NULL) {
   1051  1.155    itojun 		i = ntohs(p->ipqe_ip->ip_off) + ntohs(p->ipqe_ip->ip_len) -
   1052  1.155    itojun 		    ntohs(ipqe->ipqe_ip->ip_off);
   1053    1.1       cgd 		if (i > 0) {
   1054  1.155    itojun 			if (i >= ntohs(ipqe->ipqe_ip->ip_len))
   1055    1.1       cgd 				goto dropfrag;
   1056   1.50   thorpej 			m_adj(ipqe->ipqe_m, i);
   1057  1.155    itojun 			ipqe->ipqe_ip->ip_off =
   1058  1.155    itojun 			    htons(ntohs(ipqe->ipqe_ip->ip_off) + i);
   1059  1.155    itojun 			ipqe->ipqe_ip->ip_len =
   1060  1.155    itojun 			    htons(ntohs(ipqe->ipqe_ip->ip_len) - i);
   1061    1.1       cgd 		}
   1062    1.1       cgd 	}
   1063    1.1       cgd 
   1064    1.1       cgd 	/*
   1065    1.1       cgd 	 * While we overlap succeeding segments trim them or,
   1066    1.1       cgd 	 * if they are completely covered, dequeue them.
   1067    1.1       cgd 	 */
   1068  1.155    itojun 	for (; q != NULL &&
   1069  1.155    itojun 	    ntohs(ipqe->ipqe_ip->ip_off) + ntohs(ipqe->ipqe_ip->ip_len) >
   1070  1.155    itojun 	    ntohs(q->ipqe_ip->ip_off); q = nq) {
   1071  1.155    itojun 		i = (ntohs(ipqe->ipqe_ip->ip_off) +
   1072  1.155    itojun 		    ntohs(ipqe->ipqe_ip->ip_len)) - ntohs(q->ipqe_ip->ip_off);
   1073  1.155    itojun 		if (i < ntohs(q->ipqe_ip->ip_len)) {
   1074  1.155    itojun 			q->ipqe_ip->ip_len =
   1075  1.155    itojun 			    htons(ntohs(q->ipqe_ip->ip_len) - i);
   1076  1.155    itojun 			q->ipqe_ip->ip_off =
   1077  1.155    itojun 			    htons(ntohs(q->ipqe_ip->ip_off) + i);
   1078   1.50   thorpej 			m_adj(q->ipqe_m, i);
   1079    1.1       cgd 			break;
   1080    1.1       cgd 		}
   1081  1.148      matt 		nq = TAILQ_NEXT(q, ipqe_q);
   1082   1.50   thorpej 		m_freem(q->ipqe_m);
   1083  1.148      matt 		TAILQ_REMOVE(&fp->ipq_fragq, q, ipqe_q);
   1084   1.72   thorpej 		pool_put(&ipqent_pool, q);
   1085    1.1       cgd 	}
   1086    1.1       cgd 
   1087    1.1       cgd insert:
   1088    1.1       cgd 	/*
   1089    1.1       cgd 	 * Stick new segment in its place;
   1090    1.1       cgd 	 * check for complete reassembly.
   1091    1.1       cgd 	 */
   1092   1.25       cgd 	if (p == NULL) {
   1093  1.148      matt 		TAILQ_INSERT_HEAD(&fp->ipq_fragq, ipqe, ipqe_q);
   1094   1.25       cgd 	} else {
   1095  1.148      matt 		TAILQ_INSERT_AFTER(&fp->ipq_fragq, p, ipqe, ipqe_q);
   1096   1.25       cgd 	}
   1097    1.1       cgd 	next = 0;
   1098  1.148      matt 	for (p = NULL, q = TAILQ_FIRST(&fp->ipq_fragq); q != NULL;
   1099  1.148      matt 	    p = q, q = TAILQ_NEXT(q, ipqe_q)) {
   1100  1.155    itojun 		if (ntohs(q->ipqe_ip->ip_off) != next)
   1101    1.1       cgd 			return (0);
   1102  1.155    itojun 		next += ntohs(q->ipqe_ip->ip_len);
   1103    1.1       cgd 	}
   1104   1.25       cgd 	if (p->ipqe_mff)
   1105    1.1       cgd 		return (0);
   1106    1.1       cgd 
   1107    1.1       cgd 	/*
   1108   1.41   thorpej 	 * Reassembly is complete.  Check for a bogus message size and
   1109   1.41   thorpej 	 * concatenate fragments.
   1110    1.1       cgd 	 */
   1111  1.148      matt 	q = TAILQ_FIRST(&fp->ipq_fragq);
   1112   1.25       cgd 	ip = q->ipqe_ip;
   1113   1.41   thorpej 	if ((next + (ip->ip_hl << 2)) > IP_MAXPACKET) {
   1114   1.41   thorpej 		ipstat.ips_toolong++;
   1115   1.41   thorpej 		ip_freef(fp);
   1116   1.41   thorpej 		return (0);
   1117   1.41   thorpej 	}
   1118   1.50   thorpej 	m = q->ipqe_m;
   1119    1.1       cgd 	t = m->m_next;
   1120    1.1       cgd 	m->m_next = 0;
   1121    1.1       cgd 	m_cat(m, t);
   1122  1.148      matt 	nq = TAILQ_NEXT(q, ipqe_q);
   1123   1.72   thorpej 	pool_put(&ipqent_pool, q);
   1124   1.25       cgd 	for (q = nq; q != NULL; q = nq) {
   1125   1.50   thorpej 		t = q->ipqe_m;
   1126  1.148      matt 		nq = TAILQ_NEXT(q, ipqe_q);
   1127   1.72   thorpej 		pool_put(&ipqent_pool, q);
   1128    1.1       cgd 		m_cat(m, t);
   1129    1.1       cgd 	}
   1130    1.1       cgd 
   1131    1.1       cgd 	/*
   1132    1.1       cgd 	 * Create header for new ip packet by
   1133    1.1       cgd 	 * modifying header of first packet;
   1134    1.1       cgd 	 * dequeue and discard fragment reassembly header.
   1135    1.1       cgd 	 * Make header visible.
   1136    1.1       cgd 	 */
   1137  1.155    itojun 	ip->ip_len = htons(next);
   1138   1.25       cgd 	ip->ip_src = fp->ipq_src;
   1139   1.25       cgd 	ip->ip_dst = fp->ipq_dst;
   1140   1.25       cgd 	LIST_REMOVE(fp, ipq_q);
   1141   1.50   thorpej 	FREE(fp, M_FTABLE);
   1142  1.131    itojun 	ip_nfragpackets--;
   1143    1.1       cgd 	m->m_len += (ip->ip_hl << 2);
   1144    1.1       cgd 	m->m_data -= (ip->ip_hl << 2);
   1145    1.1       cgd 	/* some debugging cruft by sklower, below, will go away soon */
   1146    1.1       cgd 	if (m->m_flags & M_PKTHDR) { /* XXX this should be done elsewhere */
   1147  1.109  augustss 		int plen = 0;
   1148   1.50   thorpej 		for (t = m; t; t = t->m_next)
   1149   1.50   thorpej 			plen += t->m_len;
   1150   1.50   thorpej 		m->m_pkthdr.len = plen;
   1151    1.1       cgd 	}
   1152   1.50   thorpej 	return (m);
   1153    1.1       cgd 
   1154    1.1       cgd dropfrag:
   1155    1.1       cgd 	ipstat.ips_fragdropped++;
   1156    1.1       cgd 	m_freem(m);
   1157   1.72   thorpej 	pool_put(&ipqent_pool, ipqe);
   1158    1.1       cgd 	return (0);
   1159    1.1       cgd }
   1160    1.1       cgd 
   1161    1.1       cgd /*
   1162    1.1       cgd  * Free a fragment reassembly header and all
   1163    1.1       cgd  * associated datagrams.
   1164    1.1       cgd  */
   1165    1.8   mycroft void
   1166    1.1       cgd ip_freef(fp)
   1167    1.1       cgd 	struct ipq *fp;
   1168    1.1       cgd {
   1169  1.109  augustss 	struct ipqent *q, *p;
   1170    1.1       cgd 
   1171   1.75   thorpej 	IPQ_LOCK_CHECK();
   1172   1.75   thorpej 
   1173  1.148      matt 	for (q = TAILQ_FIRST(&fp->ipq_fragq); q != NULL; q = p) {
   1174  1.148      matt 		p = TAILQ_NEXT(q, ipqe_q);
   1175   1.50   thorpej 		m_freem(q->ipqe_m);
   1176  1.148      matt 		TAILQ_REMOVE(&fp->ipq_fragq, q, ipqe_q);
   1177   1.72   thorpej 		pool_put(&ipqent_pool, q);
   1178    1.1       cgd 	}
   1179   1.25       cgd 	LIST_REMOVE(fp, ipq_q);
   1180   1.50   thorpej 	FREE(fp, M_FTABLE);
   1181  1.131    itojun 	ip_nfragpackets--;
   1182    1.1       cgd }
   1183    1.1       cgd 
   1184    1.1       cgd /*
   1185    1.1       cgd  * IP timer processing;
   1186    1.1       cgd  * if a timer expires on a reassembly
   1187    1.1       cgd  * queue, discard it.
   1188    1.1       cgd  */
   1189    1.8   mycroft void
   1190    1.1       cgd ip_slowtimo()
   1191    1.1       cgd {
   1192  1.190  jonathan 	static unsigned dropscanidx = 0;
   1193  1.190  jonathan 	unsigned i;
   1194  1.109  augustss 	struct ipq *fp, *nfp;
   1195   1.24   mycroft 	int s = splsoftnet();
   1196    1.1       cgd 
   1197   1.75   thorpej 	IPQ_LOCK();
   1198  1.190  jonathan 	for (i = 0; i < IPREASS_NHASH; i++) {
   1199  1.190  jonathan 		for (fp = LIST_FIRST(&ipq[i]); fp != NULL; fp = nfp) {
   1200  1.190  jonathan 			nfp = LIST_NEXT(fp, ipq_q);
   1201  1.190  jonathan 			if (--fp->ipq_ttl == 0) {
   1202  1.190  jonathan 				ipstat.ips_fragtimeout++;
   1203  1.190  jonathan 				ip_freef(fp);
   1204  1.190  jonathan 			}
   1205    1.1       cgd 		}
   1206    1.1       cgd 	}
   1207  1.131    itojun 	/*
   1208  1.131    itojun 	 * If we are over the maximum number of fragments
   1209  1.131    itojun 	 * (due to the limit being lowered), drain off
   1210  1.190  jonathan 	 * enough to get down to the new limit. Start draining
   1211  1.190  jonathan 	 * from the reassembly hashqueue most recently drained.
   1212  1.131    itojun 	 */
   1213  1.131    itojun 	if (ip_maxfragpackets < 0)
   1214  1.131    itojun 		;
   1215  1.131    itojun 	else {
   1216  1.190  jonathan 		int wrapped = 0;
   1217  1.190  jonathan 
   1218  1.190  jonathan 		i = dropscanidx;
   1219  1.190  jonathan 		while (ip_nfragpackets > ip_maxfragpackets && wrapped == 0) {
   1220  1.190  jonathan 			while (LIST_FIRST(&ipq[i]) != NULL)
   1221  1.190  jonathan 				ip_freef(LIST_FIRST(&ipq[i]));
   1222  1.190  jonathan 			if (++i >= IPREASS_NHASH) {
   1223  1.190  jonathan 				i = 0;
   1224  1.190  jonathan 			}
   1225  1.190  jonathan 			/*
   1226  1.190  jonathan 			 * Dont scan forever even if fragment counters are
   1227  1.190  jonathan 			 * wrong: stop after scanning entire reassembly queue.
   1228  1.190  jonathan 			 */
   1229  1.190  jonathan 			if (i == dropscanidx)
   1230  1.190  jonathan 			    wrapped = 1;
   1231  1.190  jonathan 		}
   1232  1.190  jonathan 		dropscanidx = i;
   1233  1.131    itojun 	}
   1234   1.75   thorpej 	IPQ_UNLOCK();
   1235   1.63      matt #ifdef GATEWAY
   1236   1.63      matt 	ipflow_slowtimo();
   1237   1.63      matt #endif
   1238    1.1       cgd 	splx(s);
   1239    1.1       cgd }
   1240    1.1       cgd 
   1241    1.1       cgd /*
   1242    1.1       cgd  * Drain off all datagram fragments.
   1243    1.1       cgd  */
   1244    1.8   mycroft void
   1245    1.1       cgd ip_drain()
   1246    1.1       cgd {
   1247  1.190  jonathan 	int i;
   1248    1.1       cgd 
   1249   1.75   thorpej 	/*
   1250   1.75   thorpej 	 * We may be called from a device's interrupt context.  If
   1251   1.75   thorpej 	 * the ipq is already busy, just bail out now.
   1252   1.75   thorpej 	 */
   1253   1.75   thorpej 	if (ipq_lock_try() == 0)
   1254   1.75   thorpej 		return;
   1255   1.75   thorpej 
   1256  1.190  jonathan 	for (i = 0; i < IPREASS_NHASH; i++) {
   1257  1.190  jonathan 		struct ipqhead *ipqh = &ipq[i];
   1258  1.190  jonathan 		struct ipq *fp, *nfp;
   1259  1.190  jonathan 		for (fp = LIST_FIRST(ipqh); fp != NULL; fp = nfp) {
   1260  1.190  jonathan 			nfp = LIST_NEXT(fp, ipq_q);
   1261  1.190  jonathan 			ip_freef(fp);
   1262  1.190  jonathan 			ipstat.ips_fragdropped++;
   1263  1.190  jonathan 		}
   1264    1.1       cgd 	}
   1265   1.75   thorpej 
   1266   1.75   thorpej 	IPQ_UNLOCK();
   1267    1.1       cgd }
   1268    1.1       cgd 
   1269    1.1       cgd /*
   1270    1.1       cgd  * Do option processing on a datagram,
   1271    1.1       cgd  * possibly discarding it if bad options are encountered,
   1272    1.1       cgd  * or forwarding it if source-routed.
   1273    1.1       cgd  * Returns 1 if packet has been forwarded/freed,
   1274    1.1       cgd  * 0 if the packet should be processed further.
   1275    1.1       cgd  */
   1276    1.8   mycroft int
   1277    1.1       cgd ip_dooptions(m)
   1278    1.1       cgd 	struct mbuf *m;
   1279    1.1       cgd {
   1280  1.109  augustss 	struct ip *ip = mtod(m, struct ip *);
   1281  1.109  augustss 	u_char *cp, *cp0;
   1282  1.109  augustss 	struct ip_timestamp *ipt;
   1283  1.109  augustss 	struct in_ifaddr *ia;
   1284    1.1       cgd 	int opt, optlen, cnt, off, code, type = ICMP_PARAMPROB, forward = 0;
   1285  1.104   thorpej 	struct in_addr dst;
   1286    1.1       cgd 	n_time ntime;
   1287    1.1       cgd 
   1288   1.13   mycroft 	dst = ip->ip_dst;
   1289    1.1       cgd 	cp = (u_char *)(ip + 1);
   1290    1.1       cgd 	cnt = (ip->ip_hl << 2) - sizeof (struct ip);
   1291    1.1       cgd 	for (; cnt > 0; cnt -= optlen, cp += optlen) {
   1292    1.1       cgd 		opt = cp[IPOPT_OPTVAL];
   1293    1.1       cgd 		if (opt == IPOPT_EOL)
   1294    1.1       cgd 			break;
   1295    1.1       cgd 		if (opt == IPOPT_NOP)
   1296    1.1       cgd 			optlen = 1;
   1297    1.1       cgd 		else {
   1298  1.113    itojun 			if (cnt < IPOPT_OLEN + sizeof(*cp)) {
   1299  1.113    itojun 				code = &cp[IPOPT_OLEN] - (u_char *)ip;
   1300  1.113    itojun 				goto bad;
   1301  1.113    itojun 			}
   1302    1.1       cgd 			optlen = cp[IPOPT_OLEN];
   1303  1.114    itojun 			if (optlen < IPOPT_OLEN + sizeof(*cp) || optlen > cnt) {
   1304    1.1       cgd 				code = &cp[IPOPT_OLEN] - (u_char *)ip;
   1305    1.1       cgd 				goto bad;
   1306    1.1       cgd 			}
   1307    1.1       cgd 		}
   1308    1.1       cgd 		switch (opt) {
   1309    1.1       cgd 
   1310    1.1       cgd 		default:
   1311    1.1       cgd 			break;
   1312    1.1       cgd 
   1313    1.1       cgd 		/*
   1314    1.1       cgd 		 * Source routing with record.
   1315    1.1       cgd 		 * Find interface with current destination address.
   1316    1.1       cgd 		 * If none on this machine then drop if strictly routed,
   1317    1.1       cgd 		 * or do nothing if loosely routed.
   1318    1.1       cgd 		 * Record interface address and bring up next address
   1319    1.1       cgd 		 * component.  If strictly routed make sure next
   1320    1.1       cgd 		 * address is on directly accessible net.
   1321    1.1       cgd 		 */
   1322    1.1       cgd 		case IPOPT_LSRR:
   1323    1.1       cgd 		case IPOPT_SSRR:
   1324   1.47       cjs 			if (ip_allowsrcrt == 0) {
   1325   1.47       cjs 				type = ICMP_UNREACH;
   1326   1.47       cjs 				code = ICMP_UNREACH_NET_PROHIB;
   1327   1.47       cjs 				goto bad;
   1328   1.47       cjs 			}
   1329  1.114    itojun 			if (optlen < IPOPT_OFFSET + sizeof(*cp)) {
   1330  1.114    itojun 				code = &cp[IPOPT_OLEN] - (u_char *)ip;
   1331  1.114    itojun 				goto bad;
   1332  1.114    itojun 			}
   1333    1.1       cgd 			if ((off = cp[IPOPT_OFFSET]) < IPOPT_MINOFF) {
   1334    1.1       cgd 				code = &cp[IPOPT_OFFSET] - (u_char *)ip;
   1335    1.1       cgd 				goto bad;
   1336    1.1       cgd 			}
   1337    1.1       cgd 			ipaddr.sin_addr = ip->ip_dst;
   1338   1.19   mycroft 			ia = ifatoia(ifa_ifwithaddr(sintosa(&ipaddr)));
   1339    1.1       cgd 			if (ia == 0) {
   1340    1.1       cgd 				if (opt == IPOPT_SSRR) {
   1341    1.1       cgd 					type = ICMP_UNREACH;
   1342    1.1       cgd 					code = ICMP_UNREACH_SRCFAIL;
   1343    1.1       cgd 					goto bad;
   1344    1.1       cgd 				}
   1345    1.1       cgd 				/*
   1346    1.1       cgd 				 * Loose routing, and not at next destination
   1347    1.1       cgd 				 * yet; nothing to do except forward.
   1348    1.1       cgd 				 */
   1349    1.1       cgd 				break;
   1350    1.1       cgd 			}
   1351    1.1       cgd 			off--;			/* 0 origin */
   1352  1.112  sommerfe 			if ((off + sizeof(struct in_addr)) > optlen) {
   1353    1.1       cgd 				/*
   1354    1.1       cgd 				 * End of source route.  Should be for us.
   1355    1.1       cgd 				 */
   1356    1.1       cgd 				save_rte(cp, ip->ip_src);
   1357    1.1       cgd 				break;
   1358    1.1       cgd 			}
   1359    1.1       cgd 			/*
   1360    1.1       cgd 			 * locate outgoing interface
   1361    1.1       cgd 			 */
   1362    1.1       cgd 			bcopy((caddr_t)(cp + off), (caddr_t)&ipaddr.sin_addr,
   1363    1.1       cgd 			    sizeof(ipaddr.sin_addr));
   1364   1.96   thorpej 			if (opt == IPOPT_SSRR)
   1365   1.96   thorpej 				ia = ifatoia(ifa_ifwithaddr(sintosa(&ipaddr)));
   1366   1.96   thorpej 			else
   1367    1.1       cgd 				ia = ip_rtaddr(ipaddr.sin_addr);
   1368    1.1       cgd 			if (ia == 0) {
   1369    1.1       cgd 				type = ICMP_UNREACH;
   1370    1.1       cgd 				code = ICMP_UNREACH_SRCFAIL;
   1371    1.1       cgd 				goto bad;
   1372    1.1       cgd 			}
   1373    1.1       cgd 			ip->ip_dst = ipaddr.sin_addr;
   1374   1.20   mycroft 			bcopy((caddr_t)&ia->ia_addr.sin_addr,
   1375    1.1       cgd 			    (caddr_t)(cp + off), sizeof(struct in_addr));
   1376    1.1       cgd 			cp[IPOPT_OFFSET] += sizeof(struct in_addr);
   1377   1.13   mycroft 			/*
   1378   1.13   mycroft 			 * Let ip_intr's mcast routing check handle mcast pkts
   1379   1.13   mycroft 			 */
   1380   1.18   mycroft 			forward = !IN_MULTICAST(ip->ip_dst.s_addr);
   1381    1.1       cgd 			break;
   1382    1.1       cgd 
   1383    1.1       cgd 		case IPOPT_RR:
   1384  1.114    itojun 			if (optlen < IPOPT_OFFSET + sizeof(*cp)) {
   1385  1.114    itojun 				code = &cp[IPOPT_OLEN] - (u_char *)ip;
   1386  1.114    itojun 				goto bad;
   1387  1.114    itojun 			}
   1388    1.1       cgd 			if ((off = cp[IPOPT_OFFSET]) < IPOPT_MINOFF) {
   1389    1.1       cgd 				code = &cp[IPOPT_OFFSET] - (u_char *)ip;
   1390    1.1       cgd 				goto bad;
   1391    1.1       cgd 			}
   1392    1.1       cgd 			/*
   1393    1.1       cgd 			 * If no space remains, ignore.
   1394    1.1       cgd 			 */
   1395    1.1       cgd 			off--;			/* 0 origin */
   1396  1.112  sommerfe 			if ((off + sizeof(struct in_addr)) > optlen)
   1397    1.1       cgd 				break;
   1398    1.1       cgd 			bcopy((caddr_t)(&ip->ip_dst), (caddr_t)&ipaddr.sin_addr,
   1399    1.1       cgd 			    sizeof(ipaddr.sin_addr));
   1400    1.1       cgd 			/*
   1401    1.1       cgd 			 * locate outgoing interface; if we're the destination,
   1402    1.1       cgd 			 * use the incoming interface (should be same).
   1403    1.1       cgd 			 */
   1404   1.96   thorpej 			if ((ia = ifatoia(ifa_ifwithaddr(sintosa(&ipaddr))))
   1405   1.96   thorpej 			    == NULL &&
   1406   1.96   thorpej 			    (ia = ip_rtaddr(ipaddr.sin_addr)) == NULL) {
   1407    1.1       cgd 				type = ICMP_UNREACH;
   1408    1.1       cgd 				code = ICMP_UNREACH_HOST;
   1409    1.1       cgd 				goto bad;
   1410    1.1       cgd 			}
   1411   1.20   mycroft 			bcopy((caddr_t)&ia->ia_addr.sin_addr,
   1412    1.1       cgd 			    (caddr_t)(cp + off), sizeof(struct in_addr));
   1413    1.1       cgd 			cp[IPOPT_OFFSET] += sizeof(struct in_addr);
   1414    1.1       cgd 			break;
   1415    1.1       cgd 
   1416    1.1       cgd 		case IPOPT_TS:
   1417    1.1       cgd 			code = cp - (u_char *)ip;
   1418    1.1       cgd 			ipt = (struct ip_timestamp *)cp;
   1419  1.114    itojun 			if (ipt->ipt_len < 4 || ipt->ipt_len > 40) {
   1420  1.114    itojun 				code = (u_char *)&ipt->ipt_len - (u_char *)ip;
   1421    1.1       cgd 				goto bad;
   1422  1.114    itojun 			}
   1423  1.114    itojun 			if (ipt->ipt_ptr < 5) {
   1424  1.114    itojun 				code = (u_char *)&ipt->ipt_ptr - (u_char *)ip;
   1425  1.114    itojun 				goto bad;
   1426  1.114    itojun 			}
   1427   1.15       cgd 			if (ipt->ipt_ptr > ipt->ipt_len - sizeof (int32_t)) {
   1428  1.114    itojun 				if (++ipt->ipt_oflw == 0) {
   1429  1.114    itojun 					code = (u_char *)&ipt->ipt_ptr -
   1430  1.114    itojun 					    (u_char *)ip;
   1431    1.1       cgd 					goto bad;
   1432  1.114    itojun 				}
   1433    1.1       cgd 				break;
   1434    1.1       cgd 			}
   1435  1.104   thorpej 			cp0 = (cp + ipt->ipt_ptr - 1);
   1436    1.1       cgd 			switch (ipt->ipt_flg) {
   1437    1.1       cgd 
   1438    1.1       cgd 			case IPOPT_TS_TSONLY:
   1439    1.1       cgd 				break;
   1440    1.1       cgd 
   1441    1.1       cgd 			case IPOPT_TS_TSANDADDR:
   1442   1.66   thorpej 				if (ipt->ipt_ptr - 1 + sizeof(n_time) +
   1443  1.114    itojun 				    sizeof(struct in_addr) > ipt->ipt_len) {
   1444  1.114    itojun 					code = (u_char *)&ipt->ipt_ptr -
   1445  1.114    itojun 					    (u_char *)ip;
   1446    1.1       cgd 					goto bad;
   1447  1.114    itojun 				}
   1448   1.13   mycroft 				ipaddr.sin_addr = dst;
   1449   1.96   thorpej 				ia = ifatoia(ifaof_ifpforaddr(sintosa(&ipaddr),
   1450   1.96   thorpej 				    m->m_pkthdr.rcvif));
   1451   1.13   mycroft 				if (ia == 0)
   1452   1.13   mycroft 					continue;
   1453  1.104   thorpej 				bcopy(&ia->ia_addr.sin_addr,
   1454  1.104   thorpej 				    cp0, sizeof(struct in_addr));
   1455    1.1       cgd 				ipt->ipt_ptr += sizeof(struct in_addr);
   1456    1.1       cgd 				break;
   1457    1.1       cgd 
   1458    1.1       cgd 			case IPOPT_TS_PRESPEC:
   1459   1.66   thorpej 				if (ipt->ipt_ptr - 1 + sizeof(n_time) +
   1460  1.114    itojun 				    sizeof(struct in_addr) > ipt->ipt_len) {
   1461  1.114    itojun 					code = (u_char *)&ipt->ipt_ptr -
   1462  1.114    itojun 					    (u_char *)ip;
   1463    1.1       cgd 					goto bad;
   1464  1.114    itojun 				}
   1465  1.104   thorpej 				bcopy(cp0, &ipaddr.sin_addr,
   1466    1.1       cgd 				    sizeof(struct in_addr));
   1467   1.96   thorpej 				if (ifatoia(ifa_ifwithaddr(sintosa(&ipaddr)))
   1468   1.96   thorpej 				    == NULL)
   1469    1.1       cgd 					continue;
   1470    1.1       cgd 				ipt->ipt_ptr += sizeof(struct in_addr);
   1471    1.1       cgd 				break;
   1472    1.1       cgd 
   1473    1.1       cgd 			default:
   1474  1.114    itojun 				/* XXX can't take &ipt->ipt_flg */
   1475  1.114    itojun 				code = (u_char *)&ipt->ipt_ptr -
   1476  1.114    itojun 				    (u_char *)ip + 1;
   1477    1.1       cgd 				goto bad;
   1478    1.1       cgd 			}
   1479    1.1       cgd 			ntime = iptime();
   1480  1.107   thorpej 			cp0 = (u_char *) &ntime; /* XXX grumble, GCC... */
   1481  1.107   thorpej 			bcopy(cp0, (caddr_t)cp + ipt->ipt_ptr - 1,
   1482    1.1       cgd 			    sizeof(n_time));
   1483    1.1       cgd 			ipt->ipt_ptr += sizeof(n_time);
   1484    1.1       cgd 		}
   1485    1.1       cgd 	}
   1486    1.1       cgd 	if (forward) {
   1487   1.26   thorpej 		if (ip_forwsrcrt == 0) {
   1488   1.26   thorpej 			type = ICMP_UNREACH;
   1489   1.26   thorpej 			code = ICMP_UNREACH_SRCFAIL;
   1490   1.26   thorpej 			goto bad;
   1491   1.26   thorpej 		}
   1492    1.1       cgd 		ip_forward(m, 1);
   1493    1.1       cgd 		return (1);
   1494   1.13   mycroft 	}
   1495   1.13   mycroft 	return (0);
   1496    1.1       cgd bad:
   1497   1.13   mycroft 	icmp_error(m, type, code, 0, 0);
   1498   1.13   mycroft 	ipstat.ips_badoptions++;
   1499    1.1       cgd 	return (1);
   1500    1.1       cgd }
   1501    1.1       cgd 
   1502    1.1       cgd /*
   1503    1.1       cgd  * Given address of next destination (final or next hop),
   1504    1.1       cgd  * return internet address info of interface to be used to get there.
   1505    1.1       cgd  */
   1506    1.1       cgd struct in_ifaddr *
   1507    1.1       cgd ip_rtaddr(dst)
   1508    1.1       cgd 	 struct in_addr dst;
   1509    1.1       cgd {
   1510  1.109  augustss 	struct sockaddr_in *sin;
   1511    1.1       cgd 
   1512   1.19   mycroft 	sin = satosin(&ipforward_rt.ro_dst);
   1513    1.1       cgd 
   1514   1.35   mycroft 	if (ipforward_rt.ro_rt == 0 || !in_hosteq(dst, sin->sin_addr)) {
   1515    1.1       cgd 		if (ipforward_rt.ro_rt) {
   1516    1.1       cgd 			RTFREE(ipforward_rt.ro_rt);
   1517    1.1       cgd 			ipforward_rt.ro_rt = 0;
   1518    1.1       cgd 		}
   1519    1.1       cgd 		sin->sin_family = AF_INET;
   1520    1.1       cgd 		sin->sin_len = sizeof(*sin);
   1521    1.1       cgd 		sin->sin_addr = dst;
   1522    1.1       cgd 
   1523    1.1       cgd 		rtalloc(&ipforward_rt);
   1524    1.1       cgd 	}
   1525    1.1       cgd 	if (ipforward_rt.ro_rt == 0)
   1526    1.1       cgd 		return ((struct in_ifaddr *)0);
   1527   1.19   mycroft 	return (ifatoia(ipforward_rt.ro_rt->rt_ifa));
   1528    1.1       cgd }
   1529    1.1       cgd 
   1530    1.1       cgd /*
   1531    1.1       cgd  * Save incoming source route for use in replies,
   1532    1.1       cgd  * to be picked up later by ip_srcroute if the receiver is interested.
   1533    1.1       cgd  */
   1534   1.13   mycroft void
   1535    1.1       cgd save_rte(option, dst)
   1536    1.1       cgd 	u_char *option;
   1537    1.1       cgd 	struct in_addr dst;
   1538    1.1       cgd {
   1539    1.1       cgd 	unsigned olen;
   1540    1.1       cgd 
   1541    1.1       cgd 	olen = option[IPOPT_OLEN];
   1542    1.1       cgd #ifdef DIAGNOSTIC
   1543    1.1       cgd 	if (ipprintfs)
   1544   1.39  christos 		printf("save_rte: olen %d\n", olen);
   1545   1.89    itojun #endif /* 0 */
   1546    1.1       cgd 	if (olen > sizeof(ip_srcrt) - (1 + sizeof(dst)))
   1547    1.1       cgd 		return;
   1548    1.1       cgd 	bcopy((caddr_t)option, (caddr_t)ip_srcrt.srcopt, olen);
   1549    1.1       cgd 	ip_nhops = (olen - IPOPT_OFFSET - 1) / sizeof(struct in_addr);
   1550    1.1       cgd 	ip_srcrt.dst = dst;
   1551    1.1       cgd }
   1552    1.1       cgd 
   1553    1.1       cgd /*
   1554    1.1       cgd  * Retrieve incoming source route for use in replies,
   1555    1.1       cgd  * in the same form used by setsockopt.
   1556    1.1       cgd  * The first hop is placed before the options, will be removed later.
   1557    1.1       cgd  */
   1558    1.1       cgd struct mbuf *
   1559    1.1       cgd ip_srcroute()
   1560    1.1       cgd {
   1561  1.109  augustss 	struct in_addr *p, *q;
   1562  1.109  augustss 	struct mbuf *m;
   1563    1.1       cgd 
   1564    1.1       cgd 	if (ip_nhops == 0)
   1565    1.1       cgd 		return ((struct mbuf *)0);
   1566    1.1       cgd 	m = m_get(M_DONTWAIT, MT_SOOPTS);
   1567    1.1       cgd 	if (m == 0)
   1568    1.1       cgd 		return ((struct mbuf *)0);
   1569    1.1       cgd 
   1570  1.164      matt 	MCLAIM(m, &inetdomain.dom_mowner);
   1571   1.13   mycroft #define OPTSIZ	(sizeof(ip_srcrt.nop) + sizeof(ip_srcrt.srcopt))
   1572    1.1       cgd 
   1573    1.1       cgd 	/* length is (nhops+1)*sizeof(addr) + sizeof(nop + srcrt header) */
   1574    1.1       cgd 	m->m_len = ip_nhops * sizeof(struct in_addr) + sizeof(struct in_addr) +
   1575    1.1       cgd 	    OPTSIZ;
   1576    1.1       cgd #ifdef DIAGNOSTIC
   1577    1.1       cgd 	if (ipprintfs)
   1578   1.39  christos 		printf("ip_srcroute: nhops %d mlen %d", ip_nhops, m->m_len);
   1579    1.1       cgd #endif
   1580    1.1       cgd 
   1581    1.1       cgd 	/*
   1582    1.1       cgd 	 * First save first hop for return route
   1583    1.1       cgd 	 */
   1584    1.1       cgd 	p = &ip_srcrt.route[ip_nhops - 1];
   1585    1.1       cgd 	*(mtod(m, struct in_addr *)) = *p--;
   1586    1.1       cgd #ifdef DIAGNOSTIC
   1587    1.1       cgd 	if (ipprintfs)
   1588   1.39  christos 		printf(" hops %x", ntohl(mtod(m, struct in_addr *)->s_addr));
   1589    1.1       cgd #endif
   1590    1.1       cgd 
   1591    1.1       cgd 	/*
   1592    1.1       cgd 	 * Copy option fields and padding (nop) to mbuf.
   1593    1.1       cgd 	 */
   1594    1.1       cgd 	ip_srcrt.nop = IPOPT_NOP;
   1595    1.1       cgd 	ip_srcrt.srcopt[IPOPT_OFFSET] = IPOPT_MINOFF;
   1596    1.1       cgd 	bcopy((caddr_t)&ip_srcrt.nop,
   1597    1.1       cgd 	    mtod(m, caddr_t) + sizeof(struct in_addr), OPTSIZ);
   1598    1.1       cgd 	q = (struct in_addr *)(mtod(m, caddr_t) +
   1599    1.1       cgd 	    sizeof(struct in_addr) + OPTSIZ);
   1600    1.1       cgd #undef OPTSIZ
   1601    1.1       cgd 	/*
   1602    1.1       cgd 	 * Record return path as an IP source route,
   1603    1.1       cgd 	 * reversing the path (pointers are now aligned).
   1604    1.1       cgd 	 */
   1605    1.1       cgd 	while (p >= ip_srcrt.route) {
   1606    1.1       cgd #ifdef DIAGNOSTIC
   1607    1.1       cgd 		if (ipprintfs)
   1608   1.39  christos 			printf(" %x", ntohl(q->s_addr));
   1609    1.1       cgd #endif
   1610    1.1       cgd 		*q++ = *p--;
   1611    1.1       cgd 	}
   1612    1.1       cgd 	/*
   1613    1.1       cgd 	 * Last hop goes to final destination.
   1614    1.1       cgd 	 */
   1615    1.1       cgd 	*q = ip_srcrt.dst;
   1616    1.1       cgd #ifdef DIAGNOSTIC
   1617    1.1       cgd 	if (ipprintfs)
   1618   1.39  christos 		printf(" %x\n", ntohl(q->s_addr));
   1619    1.1       cgd #endif
   1620    1.1       cgd 	return (m);
   1621    1.1       cgd }
   1622    1.1       cgd 
   1623    1.1       cgd /*
   1624    1.1       cgd  * Strip out IP options, at higher
   1625    1.1       cgd  * level protocol in the kernel.
   1626    1.1       cgd  * Second argument is buffer to which options
   1627    1.1       cgd  * will be moved, and return value is their length.
   1628    1.1       cgd  * XXX should be deleted; last arg currently ignored.
   1629    1.1       cgd  */
   1630    1.8   mycroft void
   1631    1.1       cgd ip_stripoptions(m, mopt)
   1632  1.109  augustss 	struct mbuf *m;
   1633    1.1       cgd 	struct mbuf *mopt;
   1634    1.1       cgd {
   1635  1.109  augustss 	int i;
   1636    1.1       cgd 	struct ip *ip = mtod(m, struct ip *);
   1637  1.109  augustss 	caddr_t opts;
   1638    1.1       cgd 	int olen;
   1639    1.1       cgd 
   1640   1.79   mycroft 	olen = (ip->ip_hl << 2) - sizeof (struct ip);
   1641    1.1       cgd 	opts = (caddr_t)(ip + 1);
   1642    1.1       cgd 	i = m->m_len - (sizeof (struct ip) + olen);
   1643    1.1       cgd 	bcopy(opts  + olen, opts, (unsigned)i);
   1644    1.1       cgd 	m->m_len -= olen;
   1645    1.1       cgd 	if (m->m_flags & M_PKTHDR)
   1646    1.1       cgd 		m->m_pkthdr.len -= olen;
   1647  1.155    itojun 	ip->ip_len = htons(ntohs(ip->ip_len) - olen);
   1648   1.79   mycroft 	ip->ip_hl = sizeof (struct ip) >> 2;
   1649    1.1       cgd }
   1650    1.1       cgd 
   1651  1.139      matt const int inetctlerrmap[PRC_NCMDS] = {
   1652    1.1       cgd 	0,		0,		0,		0,
   1653    1.1       cgd 	0,		EMSGSIZE,	EHOSTDOWN,	EHOSTUNREACH,
   1654    1.1       cgd 	EHOSTUNREACH,	EHOSTUNREACH,	ECONNREFUSED,	ECONNREFUSED,
   1655    1.1       cgd 	EMSGSIZE,	EHOSTUNREACH,	0,		0,
   1656    1.1       cgd 	0,		0,		0,		0,
   1657    1.1       cgd 	ENOPROTOOPT
   1658    1.1       cgd };
   1659    1.1       cgd 
   1660    1.1       cgd /*
   1661    1.1       cgd  * Forward a packet.  If some error occurs return the sender
   1662    1.1       cgd  * an icmp packet.  Note we can't always generate a meaningful
   1663    1.1       cgd  * icmp message because icmp doesn't have a large enough repertoire
   1664    1.1       cgd  * of codes and types.
   1665    1.1       cgd  *
   1666    1.1       cgd  * If not forwarding, just drop the packet.  This could be confusing
   1667    1.1       cgd  * if ipforwarding was zero but some routing protocol was advancing
   1668    1.1       cgd  * us as a gateway to somewhere.  However, we must let the routing
   1669    1.1       cgd  * protocol deal with that.
   1670    1.1       cgd  *
   1671    1.1       cgd  * The srcrt parameter indicates whether the packet is being forwarded
   1672    1.1       cgd  * via a source route.
   1673    1.1       cgd  */
   1674   1.13   mycroft void
   1675    1.1       cgd ip_forward(m, srcrt)
   1676    1.1       cgd 	struct mbuf *m;
   1677    1.1       cgd 	int srcrt;
   1678    1.1       cgd {
   1679  1.109  augustss 	struct ip *ip = mtod(m, struct ip *);
   1680  1.109  augustss 	struct sockaddr_in *sin;
   1681  1.109  augustss 	struct rtentry *rt;
   1682   1.28  christos 	int error, type = 0, code = 0;
   1683    1.1       cgd 	struct mbuf *mcopy;
   1684   1.13   mycroft 	n_long dest;
   1685   1.13   mycroft 	struct ifnet *destifp;
   1686  1.173  jonathan #if defined(IPSEC) || defined(FAST_IPSEC)
   1687   1.89    itojun 	struct ifnet dummyifp;
   1688   1.89    itojun #endif
   1689  1.164      matt 
   1690  1.164      matt 	/*
   1691  1.164      matt 	 * We are now in the output path.
   1692  1.164      matt 	 */
   1693  1.164      matt 	MCLAIM(m, &ip_tx_mowner);
   1694  1.135   thorpej 
   1695  1.135   thorpej 	/*
   1696  1.135   thorpej 	 * Clear any in-bound checksum flags for this packet.
   1697  1.135   thorpej 	 */
   1698  1.135   thorpej 	m->m_pkthdr.csum_flags = 0;
   1699    1.1       cgd 
   1700   1.13   mycroft 	dest = 0;
   1701    1.1       cgd #ifdef DIAGNOSTIC
   1702    1.1       cgd 	if (ipprintfs)
   1703   1.70   thorpej 		printf("forward: src %2.2x dst %2.2x ttl %x\n",
   1704   1.70   thorpej 		    ntohl(ip->ip_src.s_addr),
   1705   1.70   thorpej 		    ntohl(ip->ip_dst.s_addr), ip->ip_ttl);
   1706    1.1       cgd #endif
   1707   1.93  sommerfe 	if (m->m_flags & (M_BCAST|M_MCAST) || in_canforward(ip->ip_dst) == 0) {
   1708    1.1       cgd 		ipstat.ips_cantforward++;
   1709    1.1       cgd 		m_freem(m);
   1710    1.1       cgd 		return;
   1711    1.1       cgd 	}
   1712    1.1       cgd 	if (ip->ip_ttl <= IPTTLDEC) {
   1713   1.13   mycroft 		icmp_error(m, ICMP_TIMXCEED, ICMP_TIMXCEED_INTRANS, dest, 0);
   1714    1.1       cgd 		return;
   1715    1.1       cgd 	}
   1716    1.1       cgd 	ip->ip_ttl -= IPTTLDEC;
   1717    1.1       cgd 
   1718   1.19   mycroft 	sin = satosin(&ipforward_rt.ro_dst);
   1719    1.1       cgd 	if ((rt = ipforward_rt.ro_rt) == 0 ||
   1720   1.35   mycroft 	    !in_hosteq(ip->ip_dst, sin->sin_addr)) {
   1721    1.1       cgd 		if (ipforward_rt.ro_rt) {
   1722    1.1       cgd 			RTFREE(ipforward_rt.ro_rt);
   1723    1.1       cgd 			ipforward_rt.ro_rt = 0;
   1724    1.1       cgd 		}
   1725    1.1       cgd 		sin->sin_family = AF_INET;
   1726   1.35   mycroft 		sin->sin_len = sizeof(struct sockaddr_in);
   1727    1.1       cgd 		sin->sin_addr = ip->ip_dst;
   1728    1.1       cgd 
   1729    1.1       cgd 		rtalloc(&ipforward_rt);
   1730    1.1       cgd 		if (ipforward_rt.ro_rt == 0) {
   1731   1.13   mycroft 			icmp_error(m, ICMP_UNREACH, ICMP_UNREACH_HOST, dest, 0);
   1732    1.1       cgd 			return;
   1733    1.1       cgd 		}
   1734    1.1       cgd 		rt = ipforward_rt.ro_rt;
   1735    1.1       cgd 	}
   1736    1.1       cgd 
   1737    1.1       cgd 	/*
   1738   1.34   mycroft 	 * Save at most 68 bytes of the packet in case
   1739    1.1       cgd 	 * we need to generate an ICMP message to the src.
   1740  1.119    itojun 	 * Pullup to avoid sharing mbuf cluster between m and mcopy.
   1741    1.1       cgd 	 */
   1742  1.155    itojun 	mcopy = m_copym(m, 0, imin(ntohs(ip->ip_len), 68), M_DONTWAIT);
   1743  1.119    itojun 	if (mcopy)
   1744  1.119    itojun 		mcopy = m_pullup(mcopy, ip->ip_hl << 2);
   1745    1.1       cgd 
   1746    1.1       cgd 	/*
   1747    1.1       cgd 	 * If forwarding packet using same interface that it came in on,
   1748    1.1       cgd 	 * perhaps should send a redirect to sender to shortcut a hop.
   1749    1.1       cgd 	 * Only send redirect if source is sending directly to us,
   1750    1.1       cgd 	 * and if packet was not source routed (or has any options).
   1751    1.1       cgd 	 * Also, don't send redirect if forwarding using a default route
   1752    1.1       cgd 	 * or a route modified by a redirect.
   1753    1.1       cgd 	 */
   1754    1.1       cgd 	if (rt->rt_ifp == m->m_pkthdr.rcvif &&
   1755    1.1       cgd 	    (rt->rt_flags & (RTF_DYNAMIC|RTF_MODIFIED)) == 0 &&
   1756   1.35   mycroft 	    !in_nullhost(satosin(rt_key(rt))->sin_addr) &&
   1757    1.1       cgd 	    ipsendredirects && !srcrt) {
   1758   1.19   mycroft 		if (rt->rt_ifa &&
   1759   1.19   mycroft 		    (ip->ip_src.s_addr & ifatoia(rt->rt_ifa)->ia_subnetmask) ==
   1760   1.19   mycroft 		    ifatoia(rt->rt_ifa)->ia_subnet) {
   1761   1.77   thorpej 			if (rt->rt_flags & RTF_GATEWAY)
   1762   1.77   thorpej 				dest = satosin(rt->rt_gateway)->sin_addr.s_addr;
   1763   1.77   thorpej 			else
   1764   1.77   thorpej 				dest = ip->ip_dst.s_addr;
   1765   1.77   thorpej 			/*
   1766   1.77   thorpej 			 * Router requirements says to only send host
   1767   1.77   thorpej 			 * redirects.
   1768   1.77   thorpej 			 */
   1769   1.77   thorpej 			type = ICMP_REDIRECT;
   1770   1.77   thorpej 			code = ICMP_REDIRECT_HOST;
   1771    1.1       cgd #ifdef DIAGNOSTIC
   1772   1.77   thorpej 			if (ipprintfs)
   1773   1.77   thorpej 				printf("redirect (%d) to %x\n", code,
   1774   1.77   thorpej 				    (u_int32_t)dest);
   1775    1.1       cgd #endif
   1776    1.1       cgd 		}
   1777    1.1       cgd 	}
   1778    1.1       cgd 
   1779   1.27   thorpej 	error = ip_output(m, (struct mbuf *)0, &ipforward_rt,
   1780  1.173  jonathan 	    (IP_FORWARDING | (ip_directedbcast ? IP_ALLOWBROADCAST : 0)),
   1781  1.174    itojun 	    (struct ip_moptions *)NULL, (struct socket *)NULL);
   1782  1.173  jonathan 
   1783    1.1       cgd 	if (error)
   1784    1.1       cgd 		ipstat.ips_cantforward++;
   1785    1.1       cgd 	else {
   1786    1.1       cgd 		ipstat.ips_forward++;
   1787    1.1       cgd 		if (type)
   1788    1.1       cgd 			ipstat.ips_redirectsent++;
   1789    1.1       cgd 		else {
   1790   1.63      matt 			if (mcopy) {
   1791   1.63      matt #ifdef GATEWAY
   1792   1.64   thorpej 				if (mcopy->m_flags & M_CANFASTFWD)
   1793   1.64   thorpej 					ipflow_create(&ipforward_rt, mcopy);
   1794   1.63      matt #endif
   1795    1.1       cgd 				m_freem(mcopy);
   1796   1.63      matt 			}
   1797    1.1       cgd 			return;
   1798    1.1       cgd 		}
   1799    1.1       cgd 	}
   1800    1.1       cgd 	if (mcopy == NULL)
   1801    1.1       cgd 		return;
   1802   1.13   mycroft 	destifp = NULL;
   1803   1.13   mycroft 
   1804    1.1       cgd 	switch (error) {
   1805    1.1       cgd 
   1806    1.1       cgd 	case 0:				/* forwarded, but need redirect */
   1807    1.1       cgd 		/* type, code set above */
   1808    1.1       cgd 		break;
   1809    1.1       cgd 
   1810    1.1       cgd 	case ENETUNREACH:		/* shouldn't happen, checked above */
   1811    1.1       cgd 	case EHOSTUNREACH:
   1812    1.1       cgd 	case ENETDOWN:
   1813    1.1       cgd 	case EHOSTDOWN:
   1814    1.1       cgd 	default:
   1815    1.1       cgd 		type = ICMP_UNREACH;
   1816    1.1       cgd 		code = ICMP_UNREACH_HOST;
   1817    1.1       cgd 		break;
   1818    1.1       cgd 
   1819    1.1       cgd 	case EMSGSIZE:
   1820    1.1       cgd 		type = ICMP_UNREACH;
   1821    1.1       cgd 		code = ICMP_UNREACH_NEEDFRAG;
   1822  1.173  jonathan #if !defined(IPSEC) && !defined(FAST_IPSEC)
   1823   1.13   mycroft 		if (ipforward_rt.ro_rt)
   1824   1.13   mycroft 			destifp = ipforward_rt.ro_rt->rt_ifp;
   1825   1.89    itojun #else
   1826   1.89    itojun 		/*
   1827   1.89    itojun 		 * If the packet is routed over IPsec tunnel, tell the
   1828   1.89    itojun 		 * originator the tunnel MTU.
   1829   1.89    itojun 		 *	tunnel MTU = if MTU - sizeof(IP) - ESP/AH hdrsiz
   1830   1.89    itojun 		 * XXX quickhack!!!
   1831   1.89    itojun 		 */
   1832   1.89    itojun 		if (ipforward_rt.ro_rt) {
   1833   1.89    itojun 			struct secpolicy *sp;
   1834   1.89    itojun 			int ipsecerror;
   1835   1.95    itojun 			size_t ipsechdr;
   1836   1.89    itojun 			struct route *ro;
   1837   1.89    itojun 
   1838   1.89    itojun 			sp = ipsec4_getpolicybyaddr(mcopy,
   1839  1.170    itojun 			    IPSEC_DIR_OUTBOUND, IP_FORWARDING,
   1840  1.170    itojun 			    &ipsecerror);
   1841   1.89    itojun 
   1842   1.89    itojun 			if (sp == NULL)
   1843   1.89    itojun 				destifp = ipforward_rt.ro_rt->rt_ifp;
   1844   1.89    itojun 			else {
   1845   1.89    itojun 				/* count IPsec header size */
   1846   1.95    itojun 				ipsechdr = ipsec4_hdrsiz(mcopy,
   1847  1.170    itojun 				    IPSEC_DIR_OUTBOUND, NULL);
   1848   1.89    itojun 
   1849   1.89    itojun 				/*
   1850   1.89    itojun 				 * find the correct route for outer IPv4
   1851   1.89    itojun 				 * header, compute tunnel MTU.
   1852   1.89    itojun 				 *
   1853   1.89    itojun 				 * XXX BUG ALERT
   1854   1.89    itojun 				 * The "dummyifp" code relies upon the fact
   1855   1.89    itojun 				 * that icmp_error() touches only ifp->if_mtu.
   1856   1.89    itojun 				 */
   1857   1.89    itojun 				/*XXX*/
   1858   1.89    itojun 				destifp = NULL;
   1859   1.89    itojun 				if (sp->req != NULL
   1860   1.95    itojun 				 && sp->req->sav != NULL
   1861   1.95    itojun 				 && sp->req->sav->sah != NULL) {
   1862   1.95    itojun 					ro = &sp->req->sav->sah->sa_route;
   1863   1.89    itojun 					if (ro->ro_rt && ro->ro_rt->rt_ifp) {
   1864   1.89    itojun 						dummyifp.if_mtu =
   1865  1.151    itojun 						    ro->ro_rt->rt_rmx.rmx_mtu ?
   1866  1.151    itojun 						    ro->ro_rt->rt_rmx.rmx_mtu :
   1867   1.89    itojun 						    ro->ro_rt->rt_ifp->if_mtu;
   1868   1.89    itojun 						dummyifp.if_mtu -= ipsechdr;
   1869   1.89    itojun 						destifp = &dummyifp;
   1870   1.89    itojun 					}
   1871   1.89    itojun 				}
   1872   1.89    itojun 
   1873  1.173  jonathan #ifdef	IPSEC
   1874   1.89    itojun 				key_freesp(sp);
   1875  1.173  jonathan #else
   1876  1.173  jonathan 				KEY_FREESP(&sp);
   1877  1.173  jonathan #endif
   1878   1.89    itojun 			}
   1879   1.89    itojun 		}
   1880   1.89    itojun #endif /*IPSEC*/
   1881    1.1       cgd 		ipstat.ips_cantfrag++;
   1882    1.1       cgd 		break;
   1883    1.1       cgd 
   1884    1.1       cgd 	case ENOBUFS:
   1885  1.143    itojun #if 1
   1886  1.143    itojun 		/*
   1887  1.143    itojun 		 * a router should not generate ICMP_SOURCEQUENCH as
   1888  1.143    itojun 		 * required in RFC1812 Requirements for IP Version 4 Routers.
   1889  1.143    itojun 		 * source quench could be a big problem under DoS attacks,
   1890  1.149       wiz 		 * or if the underlying interface is rate-limited.
   1891  1.143    itojun 		 */
   1892  1.143    itojun 		if (mcopy)
   1893  1.143    itojun 			m_freem(mcopy);
   1894  1.143    itojun 		return;
   1895  1.143    itojun #else
   1896    1.1       cgd 		type = ICMP_SOURCEQUENCH;
   1897    1.1       cgd 		code = 0;
   1898    1.1       cgd 		break;
   1899  1.143    itojun #endif
   1900    1.1       cgd 	}
   1901   1.13   mycroft 	icmp_error(mcopy, type, code, dest, destifp);
   1902   1.44   thorpej }
   1903   1.44   thorpej 
   1904   1.44   thorpej void
   1905   1.44   thorpej ip_savecontrol(inp, mp, ip, m)
   1906  1.109  augustss 	struct inpcb *inp;
   1907  1.109  augustss 	struct mbuf **mp;
   1908  1.109  augustss 	struct ip *ip;
   1909  1.109  augustss 	struct mbuf *m;
   1910   1.44   thorpej {
   1911   1.44   thorpej 
   1912   1.44   thorpej 	if (inp->inp_socket->so_options & SO_TIMESTAMP) {
   1913   1.44   thorpej 		struct timeval tv;
   1914   1.44   thorpej 
   1915   1.44   thorpej 		microtime(&tv);
   1916   1.44   thorpej 		*mp = sbcreatecontrol((caddr_t) &tv, sizeof(tv),
   1917   1.44   thorpej 		    SCM_TIMESTAMP, SOL_SOCKET);
   1918   1.44   thorpej 		if (*mp)
   1919   1.44   thorpej 			mp = &(*mp)->m_next;
   1920   1.44   thorpej 	}
   1921   1.44   thorpej 	if (inp->inp_flags & INP_RECVDSTADDR) {
   1922   1.44   thorpej 		*mp = sbcreatecontrol((caddr_t) &ip->ip_dst,
   1923   1.44   thorpej 		    sizeof(struct in_addr), IP_RECVDSTADDR, IPPROTO_IP);
   1924   1.44   thorpej 		if (*mp)
   1925   1.44   thorpej 			mp = &(*mp)->m_next;
   1926   1.44   thorpej 	}
   1927   1.44   thorpej #ifdef notyet
   1928   1.44   thorpej 	/*
   1929   1.44   thorpej 	 * XXX
   1930   1.44   thorpej 	 * Moving these out of udp_input() made them even more broken
   1931   1.44   thorpej 	 * than they already were.
   1932   1.44   thorpej 	 *	- fenner (at) parc.xerox.com
   1933   1.44   thorpej 	 */
   1934   1.44   thorpej 	/* options were tossed already */
   1935   1.44   thorpej 	if (inp->inp_flags & INP_RECVOPTS) {
   1936   1.44   thorpej 		*mp = sbcreatecontrol((caddr_t) opts_deleted_above,
   1937   1.44   thorpej 		    sizeof(struct in_addr), IP_RECVOPTS, IPPROTO_IP);
   1938   1.44   thorpej 		if (*mp)
   1939   1.44   thorpej 			mp = &(*mp)->m_next;
   1940   1.44   thorpej 	}
   1941   1.44   thorpej 	/* ip_srcroute doesn't do what we want here, need to fix */
   1942   1.44   thorpej 	if (inp->inp_flags & INP_RECVRETOPTS) {
   1943   1.44   thorpej 		*mp = sbcreatecontrol((caddr_t) ip_srcroute(),
   1944   1.44   thorpej 		    sizeof(struct in_addr), IP_RECVRETOPTS, IPPROTO_IP);
   1945   1.44   thorpej 		if (*mp)
   1946   1.44   thorpej 			mp = &(*mp)->m_next;
   1947   1.44   thorpej 	}
   1948   1.44   thorpej #endif
   1949   1.44   thorpej 	if (inp->inp_flags & INP_RECVIF) {
   1950   1.44   thorpej 		struct sockaddr_dl sdl;
   1951   1.44   thorpej 
   1952   1.44   thorpej 		sdl.sdl_len = offsetof(struct sockaddr_dl, sdl_data[0]);
   1953   1.44   thorpej 		sdl.sdl_family = AF_LINK;
   1954   1.44   thorpej 		sdl.sdl_index = m->m_pkthdr.rcvif ?
   1955   1.44   thorpej 		    m->m_pkthdr.rcvif->if_index : 0;
   1956   1.44   thorpej 		sdl.sdl_nlen = sdl.sdl_alen = sdl.sdl_slen = 0;
   1957   1.44   thorpej 		*mp = sbcreatecontrol((caddr_t) &sdl, sdl.sdl_len,
   1958   1.44   thorpej 		    IP_RECVIF, IPPROTO_IP);
   1959   1.44   thorpej 		if (*mp)
   1960   1.44   thorpej 			mp = &(*mp)->m_next;
   1961   1.44   thorpej 	}
   1962   1.13   mycroft }
   1963   1.13   mycroft 
   1964  1.189    atatat /*
   1965  1.189    atatat  * sysctl helper routine for net.inet.ip.mtudisctimeout.  checks the
   1966  1.189    atatat  * range of the new value and tweaks timers if it changes.
   1967  1.189    atatat  */
   1968  1.189    atatat static int
   1969  1.189    atatat sysctl_net_inet_ip_pmtudto(SYSCTLFN_ARGS)
   1970   1.13   mycroft {
   1971  1.189    atatat 	int error, tmp;
   1972  1.189    atatat 	struct sysctlnode node;
   1973  1.189    atatat 
   1974  1.189    atatat 	node = *rnode;
   1975  1.189    atatat 	tmp = ip_mtudisc_timeout;
   1976  1.189    atatat 	node.sysctl_data = &tmp;
   1977  1.189    atatat 	error = sysctl_lookup(SYSCTLFN_CALL(&node));
   1978  1.189    atatat 	if (error || newp == NULL)
   1979  1.189    atatat 		return (error);
   1980  1.189    atatat 	if (tmp < 0)
   1981  1.189    atatat 		return (EINVAL);
   1982   1.52   thorpej 
   1983  1.189    atatat 	ip_mtudisc_timeout = tmp;
   1984  1.189    atatat 	rt_timer_queue_change(ip_mtudisc_timeout_q, ip_mtudisc_timeout);
   1985  1.189    atatat 
   1986  1.189    atatat 	return (0);
   1987  1.189    atatat }
   1988   1.54     lukem 
   1989   1.65      matt #ifdef GATEWAY
   1990  1.189    atatat /*
   1991  1.189    atatat  * sysctl helper routine for net.inet.ip.maxflows.  apparently if
   1992  1.189    atatat  * maxflows is even looked up, we "reap flows".
   1993  1.189    atatat  */
   1994  1.189    atatat static int
   1995  1.189    atatat sysctl_net_inet_ip_maxflows(SYSCTLFN_ARGS)
   1996  1.189    atatat {
   1997  1.189    atatat 	int s;
   1998   1.67   thorpej 
   1999  1.189    atatat 	s = sysctl_lookup(SYSCTLFN_CALL(rnode));
   2000  1.189    atatat 	if (s)
   2001  1.189    atatat 		return (s);
   2002  1.189    atatat 
   2003  1.189    atatat 	s = splsoftnet();
   2004  1.189    atatat 	ipflow_reap(0);
   2005  1.189    atatat 	splx(s);
   2006  1.144    martin 
   2007  1.189    atatat 	return (0);
   2008  1.189    atatat }
   2009  1.189    atatat #endif /* GATEWAY */
   2010  1.117      tron 
   2011  1.131    itojun 
   2012  1.189    atatat SYSCTL_SETUP(sysctl_net_inet_ip_setup, "sysctl net.inet.ip subtree setup")
   2013  1.189    atatat {
   2014  1.189    atatat 	extern int subnetsarelocal, hostzeroisbroadcast;
   2015  1.180  jonathan 
   2016  1.189    atatat 	sysctl_createv(SYSCTL_PERMANENT,
   2017  1.189    atatat 		       CTLTYPE_NODE, "net", NULL,
   2018  1.189    atatat 		       NULL, 0, NULL, 0,
   2019  1.189    atatat 		       CTL_NET, CTL_EOL);
   2020  1.189    atatat 	sysctl_createv(SYSCTL_PERMANENT,
   2021  1.189    atatat 		       CTLTYPE_NODE, "inet", NULL,
   2022  1.189    atatat 		       NULL, 0, NULL, 0,
   2023  1.189    atatat 		       CTL_NET, PF_INET, CTL_EOL);
   2024  1.189    atatat 	sysctl_createv(SYSCTL_PERMANENT,
   2025  1.189    atatat 		       CTLTYPE_NODE, "ip", NULL,
   2026  1.189    atatat 		       NULL, 0, NULL, 0,
   2027  1.189    atatat 		       CTL_NET, PF_INET, IPPROTO_IP, CTL_EOL);
   2028  1.189    atatat 
   2029  1.189    atatat 	sysctl_createv(SYSCTL_PERMANENT|SYSCTL_READWRITE,
   2030  1.189    atatat 		       CTLTYPE_INT, "forwarding", NULL,
   2031  1.189    atatat 		       NULL, 0, &ipforwarding, 0,
   2032  1.189    atatat 		       CTL_NET, PF_INET, IPPROTO_IP,
   2033  1.189    atatat 		       IPCTL_FORWARDING, CTL_EOL);
   2034  1.189    atatat 	sysctl_createv(SYSCTL_PERMANENT|SYSCTL_READWRITE,
   2035  1.189    atatat 		       CTLTYPE_INT, "redirect", NULL,
   2036  1.189    atatat 		       NULL, 0, &ipsendredirects, 0,
   2037  1.189    atatat 		       CTL_NET, PF_INET, IPPROTO_IP,
   2038  1.189    atatat 		       IPCTL_SENDREDIRECTS, CTL_EOL);
   2039  1.189    atatat 	sysctl_createv(SYSCTL_PERMANENT|SYSCTL_READWRITE,
   2040  1.189    atatat 		       CTLTYPE_INT, "ttl", NULL,
   2041  1.189    atatat 		       NULL, 0, &ip_defttl, 0,
   2042  1.189    atatat 		       CTL_NET, PF_INET, IPPROTO_IP,
   2043  1.189    atatat 		       IPCTL_DEFTTL, CTL_EOL);
   2044  1.189    atatat #ifdef IPCTL_DEFMTU
   2045  1.189    atatat 	sysctl_createv(SYSCTL_PERMANENT /* |SYSCTL_READWRITE? */,
   2046  1.189    atatat 		       CTLTYPE_INT, "mtu", NULL,
   2047  1.189    atatat 		       NULL, 0, &ip_mtu, 0,
   2048  1.189    atatat 		       CTL_NET, PF_INET, IPPROTO_IP,
   2049  1.189    atatat 		       IPCTL_DEFMTU, CTL_EOL);
   2050  1.189    atatat #endif /* IPCTL_DEFMTU */
   2051  1.189    atatat 	sysctl_createv(SYSCTL_PERMANENT|SYSCTL_READONLY1,
   2052  1.189    atatat 		       CTLTYPE_INT, "forwsrcrt", NULL,
   2053  1.189    atatat 		       NULL, 0, &ip_forwsrcrt, 0,
   2054  1.189    atatat 		       CTL_NET, PF_INET, IPPROTO_IP,
   2055  1.189    atatat 		       IPCTL_FORWSRCRT, CTL_EOL);
   2056  1.189    atatat 	sysctl_createv(SYSCTL_PERMANENT|SYSCTL_READWRITE,
   2057  1.189    atatat 		       CTLTYPE_INT, "directed-broadcast", NULL,
   2058  1.189    atatat 		       NULL, 0, &ip_directedbcast, 0,
   2059  1.189    atatat 		       CTL_NET, PF_INET, IPPROTO_IP,
   2060  1.189    atatat 		       IPCTL_DIRECTEDBCAST, CTL_EOL);
   2061  1.189    atatat 	sysctl_createv(SYSCTL_PERMANENT|SYSCTL_READWRITE,
   2062  1.189    atatat 		       CTLTYPE_INT, "allowsrcrt", NULL,
   2063  1.189    atatat 		       NULL, 0, &ip_allowsrcrt, 0,
   2064  1.189    atatat 		       CTL_NET, PF_INET, IPPROTO_IP,
   2065  1.189    atatat 		       IPCTL_ALLOWSRCRT, CTL_EOL);
   2066  1.189    atatat 	sysctl_createv(SYSCTL_PERMANENT|SYSCTL_READWRITE,
   2067  1.189    atatat 		       CTLTYPE_INT, "subnetsarelocal", NULL,
   2068  1.189    atatat 		       NULL, 0, &subnetsarelocal, 0,
   2069  1.189    atatat 		       CTL_NET, PF_INET, IPPROTO_IP,
   2070  1.189    atatat 		       IPCTL_SUBNETSARELOCAL, CTL_EOL);
   2071  1.189    atatat 	sysctl_createv(SYSCTL_PERMANENT|SYSCTL_READWRITE,
   2072  1.189    atatat 		       CTLTYPE_INT, "mtudisc", NULL,
   2073  1.189    atatat 		       NULL, 0, &ip_mtudisc, 0,
   2074  1.189    atatat 		       CTL_NET, PF_INET, IPPROTO_IP,
   2075  1.189    atatat 		       IPCTL_MTUDISC, CTL_EOL);
   2076  1.189    atatat 	sysctl_createv(SYSCTL_PERMANENT|SYSCTL_READWRITE,
   2077  1.189    atatat 		       CTLTYPE_INT, "anonportmin", NULL,
   2078  1.189    atatat 		       sysctl_net_inet_ip_ports, 0, &anonportmin, 0,
   2079  1.189    atatat 		       CTL_NET, PF_INET, IPPROTO_IP,
   2080  1.189    atatat 		       IPCTL_ANONPORTMIN, CTL_EOL);
   2081  1.189    atatat 	sysctl_createv(SYSCTL_PERMANENT|SYSCTL_READWRITE,
   2082  1.189    atatat 		       CTLTYPE_INT, "anonportmax", NULL,
   2083  1.189    atatat 		       sysctl_net_inet_ip_ports, 0, &anonportmax, 0,
   2084  1.189    atatat 		       CTL_NET, PF_INET, IPPROTO_IP,
   2085  1.189    atatat 		       IPCTL_ANONPORTMAX, CTL_EOL);
   2086  1.189    atatat 	sysctl_createv(SYSCTL_PERMANENT|SYSCTL_READWRITE,
   2087  1.189    atatat 		       CTLTYPE_INT, "mtudisctimeout", NULL,
   2088  1.189    atatat 		       sysctl_net_inet_ip_pmtudto, 0, &ip_mtudisc_timeout, 0,
   2089  1.189    atatat 		       CTL_NET, PF_INET, IPPROTO_IP,
   2090  1.189    atatat 		       IPCTL_MTUDISCTIMEOUT, CTL_EOL);
   2091  1.189    atatat #ifdef GATEWAY
   2092  1.189    atatat 	sysctl_createv(SYSCTL_PERMANENT|SYSCTL_READWRITE,
   2093  1.189    atatat 		       CTLTYPE_INT, "maxflows", NULL,
   2094  1.189    atatat 		       sysctl_net_inet_ip_maxflows, 0, &ip_maxflows, 0,
   2095  1.189    atatat 		       CTL_NET, PF_INET, IPPROTO_IP,
   2096  1.189    atatat 		       IPCTL_MAXFLOWS, CTL_EOL);
   2097  1.189    atatat #endif /* GATEWAY */
   2098  1.189    atatat 	sysctl_createv(SYSCTL_PERMANENT|SYSCTL_READWRITE,
   2099  1.189    atatat 		       CTLTYPE_INT, "hostzerobroadcast", NULL,
   2100  1.189    atatat 		       NULL, 0, &hostzeroisbroadcast, 0,
   2101  1.189    atatat 		       CTL_NET, PF_INET, IPPROTO_IP,
   2102  1.189    atatat 		       IPCTL_HOSTZEROBROADCAST, CTL_EOL);
   2103  1.189    atatat #if NGIF > 0
   2104  1.189    atatat 	sysctl_createv(SYSCTL_PERMANENT|SYSCTL_READWRITE,
   2105  1.189    atatat 		       CTLTYPE_INT, "gifttl", NULL,
   2106  1.189    atatat 		       NULL, 0, &ip_gif_ttl, 0,
   2107  1.189    atatat 		       CTL_NET, PF_INET, IPPROTO_IP,
   2108  1.189    atatat 		       IPCTL_GIF_TTL, CTL_EOL);
   2109  1.189    atatat #endif /* NGIF */
   2110  1.189    atatat #ifndef IPNOPRIVPORTS
   2111  1.189    atatat 	sysctl_createv(SYSCTL_PERMANENT|SYSCTL_READWRITE,
   2112  1.189    atatat 		       CTLTYPE_INT, "lowportmin", NULL,
   2113  1.189    atatat 		       sysctl_net_inet_ip_ports, 0, &lowportmin, 0,
   2114  1.189    atatat 		       CTL_NET, PF_INET, IPPROTO_IP,
   2115  1.189    atatat 		       IPCTL_LOWPORTMIN, CTL_EOL);
   2116  1.189    atatat 	sysctl_createv(SYSCTL_PERMANENT|SYSCTL_READWRITE,
   2117  1.189    atatat 		       CTLTYPE_INT, "lowportmax", NULL,
   2118  1.189    atatat 		       sysctl_net_inet_ip_ports, 0, &lowportmax, 0,
   2119  1.189    atatat 		       CTL_NET, PF_INET, IPPROTO_IP,
   2120  1.189    atatat 		       IPCTL_LOWPORTMAX, CTL_EOL);
   2121  1.189    atatat #endif /* IPNOPRIVPORTS */
   2122  1.189    atatat 	sysctl_createv(SYSCTL_PERMANENT|SYSCTL_READWRITE,
   2123  1.189    atatat 		       CTLTYPE_INT, "maxfragpackets", NULL,
   2124  1.189    atatat 		       NULL, 0, &ip_maxfragpackets, 0,
   2125  1.189    atatat 		       CTL_NET, PF_INET, IPPROTO_IP,
   2126  1.189    atatat 		       IPCTL_MAXFRAGPACKETS, CTL_EOL);
   2127  1.189    atatat #if NGRE > 0
   2128  1.189    atatat 	sysctl_createv(SYSCTL_PERMANENT|SYSCTL_READWRITE,
   2129  1.189    atatat 		       CTLTYPE_INT, "grettl", NULL,
   2130  1.189    atatat 		       NULL, 0, &ip_gre_ttl, 0,
   2131  1.189    atatat 		       CTL_NET, PF_INET, IPPROTO_IP,
   2132  1.189    atatat 		       IPCTL_GRE_TTL, CTL_EOL);
   2133  1.189    atatat #endif /* NGRE */
   2134  1.189    atatat 	sysctl_createv(SYSCTL_PERMANENT|SYSCTL_READWRITE,
   2135  1.189    atatat 		       CTLTYPE_INT, "checkinterface", NULL,
   2136  1.189    atatat 		       NULL, 0, &ip_checkinterface, 0,
   2137  1.189    atatat 		       CTL_NET, PF_INET, IPPROTO_IP,
   2138  1.189    atatat 		       IPCTL_CHECKINTERFACE, CTL_EOL);
   2139  1.189    atatat 	sysctl_createv(SYSCTL_PERMANENT|SYSCTL_READWRITE,
   2140  1.189    atatat 		       CTLTYPE_INT, "random_id", NULL,
   2141  1.189    atatat 		       NULL, 0, &ip_do_randomid, 0,
   2142  1.189    atatat 		       CTL_NET, PF_INET, IPPROTO_IP,
   2143  1.189    atatat 		       IPCTL_RANDOMID, CTL_EOL);
   2144    1.1       cgd }
   2145