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