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