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