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