2 * Copyright (c) 2000-2007 Apple Inc. All rights reserved.
4 * @APPLE_OSREFERENCE_LICENSE_HEADER_START@
6 * This file contains Original Code and/or Modifications of Original Code
7 * as defined in and that are subject to the Apple Public Source License
8 * Version 2.0 (the 'License'). You may not use this file except in
9 * compliance with the License. The rights granted to you under the License
10 * may not be used to create, or enable the creation or redistribution of,
11 * unlawful or unlicensed copies of an Apple operating system, or to
12 * circumvent, violate, or enable the circumvention or violation of, any
13 * terms of an Apple operating system software license agreement.
15 * Please obtain a copy of the License at
16 * http://www.opensource.apple.com/apsl/ and read it before using this file.
18 * The Original Code and all software distributed under the License are
19 * distributed on an 'AS IS' basis, WITHOUT WARRANTY OF ANY KIND, EITHER
20 * EXPRESS OR IMPLIED, AND APPLE HEREBY DISCLAIMS ALL SUCH WARRANTIES,
21 * INCLUDING WITHOUT LIMITATION, ANY WARRANTIES OF MERCHANTABILITY,
22 * FITNESS FOR A PARTICULAR PURPOSE, QUIET ENJOYMENT OR NON-INFRINGEMENT.
23 * Please see the License for the specific language governing rights and
24 * limitations under the License.
26 * @APPLE_OSREFERENCE_LICENSE_HEADER_END@
29 * Copyright (c) 1982, 1986, 1988, 1990, 1993
30 * The Regents of the University of California. All rights reserved.
32 * Redistribution and use in source and binary forms, with or without
33 * modification, are permitted provided that the following conditions
35 * 1. Redistributions of source code must retain the above copyright
36 * notice, this list of conditions and the following disclaimer.
37 * 2. Redistributions in binary form must reproduce the above copyright
38 * notice, this list of conditions and the following disclaimer in the
39 * documentation and/or other materials provided with the distribution.
40 * 3. All advertising materials mentioning features or use of this software
41 * must display the following acknowledgement:
42 * This product includes software developed by the University of
43 * California, Berkeley and its contributors.
44 * 4. Neither the name of the University nor the names of its contributors
45 * may be used to endorse or promote products derived from this software
46 * without specific prior written permission.
48 * THIS SOFTWARE IS PROVIDED BY THE REGENTS AND CONTRIBUTORS ``AS IS'' AND
49 * ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
50 * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE
51 * ARE DISCLAIMED. IN NO EVENT SHALL THE REGENTS OR CONTRIBUTORS BE LIABLE
52 * FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL
53 * DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS
54 * OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION)
55 * HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT
56 * LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY
57 * OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF
60 * @(#)ip_output.c 8.3 (Berkeley) 1/21/94
61 * $FreeBSD: src/sys/netinet/ip_output.c,v 1.99.2.16 2001/07/19 06:37:26 kris Exp $
64 * NOTICE: This file was modified by SPARTA, Inc. in 2005 to introduce
65 * support for mandatory and extensible security protections. This notice
66 * is included in support of clause 2.2 (b) of the Apple Public License,
72 #include <sys/param.h>
73 #include <sys/systm.h>
74 #include <sys/kernel.h>
75 #include <sys/malloc.h>
77 #include <sys/protosw.h>
78 #include <sys/socket.h>
79 #include <sys/socketvar.h>
80 #include <kern/locks.h>
81 #include <sys/sysctl.h>
84 #include <net/route.h>
86 #include <netinet/in.h>
87 #include <netinet/in_systm.h>
88 #include <netinet/ip.h>
89 #include <netinet/in_pcb.h>
90 #include <netinet/in_var.h>
91 #include <netinet/ip_var.h>
93 #include <netinet/kpi_ipfilter_var.h>
96 #include <security/mac_framework.h>
101 #include <net/dlil.h>
102 #include <sys/kdebug.h>
103 #include <libkern/OSAtomic.h>
105 #define DBG_LAYER_BEG NETDBG_CODE(DBG_NETIP, 1)
106 #define DBG_LAYER_END NETDBG_CODE(DBG_NETIP, 3)
107 #define DBG_FNC_IP_OUTPUT NETDBG_CODE(DBG_NETIP, (1 << 8) | 1)
108 #define DBG_FNC_IPSEC4_OUTPUT NETDBG_CODE(DBG_NETIP, (2 << 8) | 1)
110 #define SWAP16(v) ((((v) & 0xff) << 8) | ((v) >> 8))
113 #include <netinet6/ipsec.h>
114 #include <netkey/key.h>
116 #include <netkey/key_debug.h>
118 #define KEYDEBUG(lev,arg)
122 #include <netinet/ip_fw.h>
123 #include <netinet/ip_divert.h>
126 #include <netinet/ip_dummynet.h>
129 #if IPFIREWALL_FORWARD_DEBUG
130 #define print_ip(a) printf("%ld.%ld.%ld.%ld",(ntohl(a.s_addr)>>24)&0xFF,\
131 (ntohl(a.s_addr)>>16)&0xFF,\
132 (ntohl(a.s_addr)>>8)&0xFF,\
133 (ntohl(a.s_addr))&0xFF);
139 static struct mbuf
*ip_insertoptions(struct mbuf
*, struct mbuf
*, int *);
140 static struct ifnet
*ip_multicast_if(struct in_addr
*, int *);
141 static void ip_mloopback(struct ifnet
*, struct mbuf
*,
142 struct sockaddr_in
*, int);
143 static int ip_getmoptions(struct sockopt
*, struct ip_moptions
*);
144 static int ip_pcbopts(int, struct mbuf
**, struct mbuf
*);
145 static int ip_setmoptions(struct sockopt
*, struct ip_moptions
**);
147 static void ip_out_cksum_stats(int, u_int32_t
);
149 int ip_createmoptions(struct ip_moptions
**imop
);
150 int ip_addmembership(struct ip_moptions
*imo
, struct ip_mreq
*mreq
);
151 int ip_dropmembership(struct ip_moptions
*imo
, struct ip_mreq
*mreq
);
152 int ip_optcopy(struct ip
*, struct ip
*);
153 void in_delayed_cksum_offset(struct mbuf
*, int );
154 void in_cksum_offset(struct mbuf
* , size_t );
156 extern int (*fr_checkp
)(struct ip
*, int, struct ifnet
*, int, struct mbuf
**);
158 extern u_long route_generation
;
160 extern struct protosw inetsw
[];
162 extern struct ip_linklocal_stat ip_linklocal_stat
;
163 extern lck_mtx_t
*ip_mutex
;
165 /* temporary: for testing */
167 extern int ipsec_bypass
;
170 static int ip_maxchainsent
= 0;
171 SYSCTL_INT(_net_inet_ip
, OID_AUTO
, maxchainsent
, CTLFLAG_RW
,
172 &ip_maxchainsent
, 0, "use dlil_output_list");
174 static int forge_ce
= 0;
175 SYSCTL_INT(_net_inet_ip
, OID_AUTO
, forge_ce
, CTLFLAG_RW
,
176 &forge_ce
, 0, "Forge ECN CE");
179 * IP output. The packet in mbuf chain m contains a skeletal IP
180 * header (with len, off, ttl, proto, tos, src, dst).
181 * The mbuf chain containing the packet will be freed.
182 * The mbuf opt, if present, will not be freed.
190 struct ip_moptions
*imo
,
194 error
= ip_output_list(m0
, 0, opt
, ro
, flags
, imo
, ifp
);
207 * ipsec4_getpolicybyaddr:??? [IPSEC 4th argument, contents modified]
208 * ipsec4_getpolicybysock:??? [IPSEC 4th argument, contents modified]
209 * key_spdacquire:??? [IPSEC]
210 * ipsec4_output:??? [IPSEC]
211 * <fr_checkp>:??? [firewall]
212 * ip_dn_io_ptr:??? [dummynet]
213 * dlil_output:??? [DLIL]
214 * dlil_output_list:??? [DLIL]
216 * Notes: The ipsec4_getpolicyby{addr|sock} function error returns are
217 * only used as the error return from this function where one of
218 * these functions fails to return a policy.
227 struct ip_moptions
*imo
,
228 #if CONFIG_FORCE_OUT_IFP
229 struct ifnet
*pdp_ifp
231 __unused
struct ifnet
*unused_ifp
235 struct ip
*ip
, *mhip
;
236 struct ifnet
*ifp
= NULL
;
238 int hlen
= sizeof (struct ip
);
239 int len
= 0, off
, error
= 0;
240 struct sockaddr_in
*dst
= NULL
;
241 struct in_ifaddr
*ia
= NULL
;
242 int isbroadcast
, sw_csum
;
243 struct in_addr pkt_dst
;
245 struct route iproute
;
246 struct socket
*so
= NULL
;
247 struct secpolicy
*sp
= NULL
;
249 #if IPFIREWALL_FORWARD
250 int fwd_rewrite_src
= 0;
252 struct ip_fw_args args
;
254 ipfilter_t inject_filter_ref
= 0;
256 struct route saved_route
;
257 struct mbuf
* packetlist
;
261 KERNEL_DEBUG(DBG_FNC_IP_OUTPUT
| DBG_FUNC_START
, 0,0,0,0,0);
264 args
.next_hop
= NULL
;
268 args
.divert_rule
= 0; /* divert cookie */
270 /* Grab info from mtags prepended to the chain */
272 if ((tag
= m_tag_locate(m0
, KERNEL_MODULE_TAG_ID
, KERNEL_TAG_TYPE_DUMMYNET
, NULL
)) != NULL
) {
273 struct dn_pkt_tag
*dn_tag
;
275 dn_tag
= (struct dn_pkt_tag
*)(tag
+1);
276 args
.rule
= dn_tag
->rule
;
278 saved_route
= dn_tag
->ro
;
282 dst
= dn_tag
->dn_dst
;
284 flags
= dn_tag
->flags
;
286 m_tag_delete(m0
, tag
);
288 #endif /* DUMMYNET */
291 if ((tag
= m_tag_locate(m0
, KERNEL_MODULE_TAG_ID
, KERNEL_TAG_TYPE_DIVERT
, NULL
)) != NULL
) {
292 struct divert_tag
*div_tag
;
294 div_tag
= (struct divert_tag
*)(tag
+1);
295 args
.divert_rule
= div_tag
->cookie
;
297 m_tag_delete(m0
, tag
);
299 #endif /* IPDIVERT */
300 #endif /* IPFIREWALL */
302 if ((tag
= m_tag_locate(m0
, KERNEL_MODULE_TAG_ID
, KERNEL_TAG_TYPE_IPFORWARD
, NULL
)) != NULL
) {
303 struct ip_fwd_tag
*ipfwd_tag
;
305 ipfwd_tag
= (struct ip_fwd_tag
*)(tag
+1);
306 args
.next_hop
= ipfwd_tag
->next_hop
;
308 m_tag_delete(m0
, tag
);
314 if ( !m
|| (m
->m_flags
& M_PKTHDR
) != 0)
315 panic("ip_output no HDR");
317 panic("ip_output no route, proto = %d",
318 mtod(m
, struct ip
*)->ip_p
);
322 if (args
.rule
!= NULL
) { /* dummynet already saw us */
323 ip
= mtod(m
, struct ip
*);
324 hlen
= IP_VHL_HL(ip
->ip_vhl
) << 2 ;
325 lck_mtx_lock(rt_mtx
);
326 if (ro
->ro_rt
!= NULL
)
327 ia
= (struct in_ifaddr
*)ro
->ro_rt
->rt_ifa
;
330 lck_mtx_unlock(rt_mtx
);
332 if (ipsec_bypass
== 0 && (flags
& IP_NOIPSEC
) == 0) {
333 so
= ipsec_getsocket(m
);
334 (void)ipsec_setsocket(m
, NULL
);
339 #endif /* IPFIREWALL */
342 if (ipsec_bypass
== 0 && (flags
& IP_NOIPSEC
) == 0) {
343 so
= ipsec_getsocket(m
);
344 (void)ipsec_setsocket(m
, NULL
);
349 * No need to proccess packet twice if we've
352 inject_filter_ref
= ipf_get_inject_filter(m
);
355 m
= ip_insertoptions(m
, opt
, &len
);
358 ip
= mtod(m
, struct ip
*);
359 pkt_dst
= args
.next_hop
? args
.next_hop
->sin_addr
: ip
->ip_dst
;
364 if ((flags
& (IP_FORWARDING
|IP_RAWOUTPUT
)) == 0) {
365 ip
->ip_vhl
= IP_MAKE_VHL(IPVERSION
, hlen
>> 2);
368 ip
->ip_id
= ip_randomid();
370 ip
->ip_id
= htons(ip_id
++);
372 OSAddAtomic(1, (SInt32
*)&ipstat
.ips_localout
);
374 hlen
= IP_VHL_HL(ip
->ip_vhl
) << 2;
378 /* For debugging, we let the stack forge congestion */
380 ((ip
->ip_tos
& IPTOS_ECN_MASK
) == IPTOS_ECN_ECT1
||
381 (ip
->ip_tos
& IPTOS_ECN_MASK
) == IPTOS_ECN_ECT0
)) {
382 ip
->ip_tos
= (ip
->ip_tos
& ~IPTOS_ECN_MASK
) | IPTOS_ECN_CE
;
387 KERNEL_DEBUG(DBG_LAYER_BEG
, ip
->ip_dst
.s_addr
,
388 ip
->ip_src
.s_addr
, ip
->ip_p
, ip
->ip_off
, ip
->ip_len
);
390 dst
= (struct sockaddr_in
*)&ro
->ro_dst
;
393 * If there is a cached route,
394 * check that it is to the same destination
395 * and is still up. If not, free it and try again.
396 * The address family should also be checked in case of sharing the
400 lck_mtx_lock(rt_mtx
);
401 if (ro
->ro_rt
!= NULL
) {
402 if (ro
->ro_rt
->generation_id
!= route_generation
&&
403 ((flags
& (IP_ROUTETOIF
| IP_FORWARDING
)) == 0) &&
404 (ip
->ip_src
.s_addr
!= INADDR_ANY
) &&
405 (ifa_foraddr(ip
->ip_src
.s_addr
) == 0)) {
406 error
= EADDRNOTAVAIL
;
407 lck_mtx_unlock(rt_mtx
);
410 if ((ro
->ro_rt
->rt_flags
& RTF_UP
) == 0 ||
411 dst
->sin_family
!= AF_INET
||
412 dst
->sin_addr
.s_addr
!= pkt_dst
.s_addr
) {
413 rtfree_locked(ro
->ro_rt
);
416 if (ro
->ro_rt
&& ro
->ro_rt
->generation_id
!= route_generation
)
417 ro
->ro_rt
->generation_id
= route_generation
;
419 if (ro
->ro_rt
== NULL
) {
420 bzero(dst
, sizeof(*dst
));
421 dst
->sin_family
= AF_INET
;
422 dst
->sin_len
= sizeof(*dst
);
423 dst
->sin_addr
= pkt_dst
;
426 * If routing to interface only,
427 * short circuit routing lookup.
429 #define ifatoia(ifa) ((struct in_ifaddr *)(ifa))
430 #define sintosa(sin) ((struct sockaddr *)(sin))
431 if (flags
& IP_ROUTETOIF
) {
433 ifafree(&ia
->ia_ifa
);
434 if ((ia
= ifatoia(ifa_ifwithdstaddr(sintosa(dst
)))) == 0) {
435 if ((ia
= ifatoia(ifa_ifwithnet(sintosa(dst
)))) == 0) {
436 OSAddAtomic(1, (SInt32
*)&ipstat
.ips_noroute
);
438 lck_mtx_unlock(rt_mtx
);
444 isbroadcast
= in_broadcast(dst
->sin_addr
, ifp
);
447 #if CONFIG_FORCE_OUT_IFP
448 /* Check if this packet should be forced out a specific interface */
449 if (ro
->ro_rt
== 0 && pdp_ifp
!= NULL
) {
450 pdp_context_route_locked(pdp_ifp
, ro
);
452 if (ro
->ro_rt
== NULL
) {
453 OSAddAtomic(1, (UInt32
*)&ipstat
.ips_noroute
);
454 error
= EHOSTUNREACH
;
455 lck_mtx_unlock(rt_mtx
);
462 * If this is the case, we probably don't want to allocate
463 * a protocol-cloned route since we didn't get one from the
464 * ULP. This lets TCP do its thing, while not burdening
465 * forwarding or ICMP with the overhead of cloning a route.
466 * Of course, we still want to do any cloning requested by
467 * the link layer, as this is probably required in all cases
468 * for correct operation (as it is for ARP).
471 if (ro
->ro_rt
== 0) {
472 unsigned long ign
= RTF_PRCLONING
;
474 * We make an exception here: if the destination
475 * address is INADDR_BROADCAST, allocate a protocol-
476 * cloned host route so that we end up with a route
477 * marked with the RTF_BROADCAST flag. Otherwise,
478 * we would end up referring to the default route,
479 * instead of creating a cloned host route entry.
480 * That would introduce inconsistencies between ULPs
481 * that allocate a route and those that don't. The
482 * RTF_BROADCAST route is important since we'd want
483 * to send out undirected IP broadcast packets using
484 * link-level broadcast address.
486 * This exception will no longer be necessary when
487 * the RTF_PRCLONING scheme is no longer present.
489 if (dst
->sin_addr
.s_addr
== INADDR_BROADCAST
)
490 ign
&= ~RTF_PRCLONING
;
492 rtalloc_ign_locked(ro
, ign
);
494 if (ro
->ro_rt
== 0) {
495 OSAddAtomic(1, (SInt32
*)&ipstat
.ips_noroute
);
496 error
= EHOSTUNREACH
;
497 lck_mtx_unlock(rt_mtx
);
502 ifafree(&ia
->ia_ifa
);
503 ia
= ifatoia(ro
->ro_rt
->rt_ifa
);
506 ifp
= ro
->ro_rt
->rt_ifp
;
508 if (ro
->ro_rt
->rt_flags
& RTF_GATEWAY
)
509 dst
= (struct sockaddr_in
*)ro
->ro_rt
->rt_gateway
;
510 if (ro
->ro_rt
->rt_flags
& RTF_HOST
)
511 isbroadcast
= (ro
->ro_rt
->rt_flags
& RTF_BROADCAST
);
513 isbroadcast
= in_broadcast(dst
->sin_addr
, ifp
);
515 lck_mtx_unlock(rt_mtx
);
516 if (IN_MULTICAST(ntohl(pkt_dst
.s_addr
))) {
517 struct in_multi
*inm
;
519 m
->m_flags
|= M_MCAST
;
521 * IP destination address is multicast. Make sure "dst"
522 * still points to the address in "ro". (It may have been
523 * changed to point to a gateway address, above.)
525 dst
= (struct sockaddr_in
*)&ro
->ro_dst
;
527 * See if the caller provided any multicast options
530 if ((flags
& IP_RAWOUTPUT
) == 0) ip
->ip_ttl
= imo
->imo_multicast_ttl
;
531 if (imo
->imo_multicast_ifp
!= NULL
) {
532 ifp
= imo
->imo_multicast_ifp
;
535 if (imo
->imo_multicast_vif
!= -1 &&
536 ((flags
& IP_RAWOUTPUT
) == 0 || ip
->ip_src
.s_addr
== INADDR_ANY
))
538 ip_mcast_src(imo
->imo_multicast_vif
);
539 #endif /* MROUTING */
541 if ((flags
& IP_RAWOUTPUT
) == 0) ip
->ip_ttl
= IP_DEFAULT_MULTICAST_TTL
;
543 * Confirm that the outgoing interface supports multicast.
545 if ((imo
== NULL
) || (imo
->imo_multicast_vif
== -1)) {
546 if ((ifp
->if_flags
& IFF_MULTICAST
) == 0) {
547 OSAddAtomic(1, (SInt32
*)&ipstat
.ips_noroute
);
553 * If source address not specified yet, use address
554 * of outgoing interface.
556 if (ip
->ip_src
.s_addr
== INADDR_ANY
) {
557 register struct in_ifaddr
*ia1
;
558 lck_mtx_lock(rt_mtx
);
559 TAILQ_FOREACH(ia1
, &in_ifaddrhead
, ia_link
)
560 if (ia1
->ia_ifp
== ifp
) {
561 ip
->ip_src
= IA_SIN(ia1
)->sin_addr
;
565 lck_mtx_unlock(rt_mtx
);
566 if (ip
->ip_src
.s_addr
== INADDR_ANY
) {
572 ifnet_lock_shared(ifp
);
573 IN_LOOKUP_MULTI(pkt_dst
, ifp
, inm
);
574 ifnet_lock_done(ifp
);
576 (imo
== NULL
|| imo
->imo_multicast_loop
)) {
578 * If we belong to the destination multicast group
579 * on the outgoing interface, and the caller did not
580 * forbid loopback, loop back a copy.
582 if (!TAILQ_EMPTY(&ipv4_filters
)) {
583 struct ipfilter
*filter
;
584 int seen
= (inject_filter_ref
== 0);
585 struct ipf_pktopts
*ippo
= 0, ipf_pktopts
;
589 ipf_pktopts
.ippo_mcast_ifnet
= imo
->imo_multicast_ifp
;
590 ipf_pktopts
.ippo_mcast_ttl
= imo
->imo_multicast_ttl
;
591 ipf_pktopts
.ippo_mcast_loop
= imo
->imo_multicast_loop
;
596 /* 4135317 - always pass network byte order to filter */
600 TAILQ_FOREACH(filter
, &ipv4_filters
, ipf_link
) {
602 if ((struct ipfilter
*)inject_filter_ref
== filter
)
604 } else if (filter
->ipf_filter
.ipf_output
) {
606 result
= filter
->ipf_filter
.ipf_output(filter
->ipf_filter
.cookie
, (mbuf_t
*)&m
, ippo
);
607 if (result
== EJUSTRETURN
) {
618 /* set back to host byte order */
619 ip
= mtod(m
, struct ip
*);
626 ip_mloopback(ifp
, m
, dst
, hlen
);
631 * If we are acting as a multicast router, perform
632 * multicast forwarding as if the packet had just
633 * arrived on the interface to which we are about
634 * to send. The multicast forwarding function
635 * recursively calls this function, using the
636 * IP_FORWARDING flag to prevent infinite recursion.
638 * Multicasts that are looped back by ip_mloopback(),
639 * above, will be forwarded by the ip_input() routine,
642 if (ip_mrouter
&& (flags
& IP_FORWARDING
) == 0) {
644 * Check if rsvp daemon is running. If not, don't
645 * set ip_moptions. This ensures that the packet
646 * is multicast and not just sent down one link
647 * as prescribed by rsvpd.
651 if (ip_mforward(ip
, ifp
, m
, imo
) != 0) {
657 #endif /* MROUTING */
660 * Multicasts with a time-to-live of zero may be looped-
661 * back, above, but must not be transmitted on a network.
662 * Also, multicasts addressed to the loopback interface
663 * are not sent -- the above call to ip_mloopback() will
664 * loop back a copy if this host actually belongs to the
665 * destination group on the loopback interface.
667 if (ip
->ip_ttl
== 0 || ifp
->if_flags
& IFF_LOOPBACK
) {
676 * If source address not specified yet, use address
677 * of outgoing interface.
679 if (ip
->ip_src
.s_addr
== INADDR_ANY
) {
680 ip
->ip_src
= IA_SIN(ia
)->sin_addr
;
681 #if IPFIREWALL_FORWARD
682 /* Keep note that we did this - if the firewall changes
683 * the next-hop, our interface may change, changing the
684 * default source IP. It's a shame so much effort happens
688 #endif /* IPFIREWALL_FORWARD */
693 * Look for broadcast address and
694 * and verify user is allowed to send
698 if ((ifp
->if_flags
& IFF_BROADCAST
) == 0) {
699 error
= EADDRNOTAVAIL
;
702 if ((flags
& IP_ALLOWBROADCAST
) == 0) {
706 /* don't allow broadcast messages to be fragmented */
707 if ((u_short
)ip
->ip_len
> ifp
->if_mtu
) {
711 m
->m_flags
|= M_BCAST
;
713 m
->m_flags
&= ~M_BCAST
;
718 * Force IP TTL to 255 following draft-ietf-zeroconf-ipv4-linklocal.txt
720 if (IN_LINKLOCAL(ntohl(ip
->ip_src
.s_addr
)) || IN_LINKLOCAL(ntohl(ip
->ip_dst
.s_addr
))) {
721 ip_linklocal_stat
.iplls_out_total
++;
722 if (ip
->ip_ttl
!= MAXTTL
) {
723 ip_linklocal_stat
.iplls_out_badttl
++;
728 if (!didfilter
&& !TAILQ_EMPTY(&ipv4_filters
)) {
729 struct ipfilter
*filter
;
730 int seen
= (inject_filter_ref
== 0);
734 /* 4135317 - always pass network byte order to filter */
738 TAILQ_FOREACH(filter
, &ipv4_filters
, ipf_link
) {
740 if ((struct ipfilter
*)inject_filter_ref
== filter
)
742 } else if (filter
->ipf_filter
.ipf_output
) {
744 result
= filter
->ipf_filter
.ipf_output(filter
->ipf_filter
.cookie
, (mbuf_t
*)&m
, 0);
745 if (result
== EJUSTRETURN
) {
756 /* set back to host byte order */
757 ip
= mtod(m
, struct ip
*);
765 /* temporary for testing only: bypass ipsec alltogether */
767 if (ipsec_bypass
!= 0 || (flags
& IP_NOIPSEC
) != 0)
770 KERNEL_DEBUG(DBG_FNC_IPSEC4_OUTPUT
| DBG_FUNC_START
, 0,0,0,0,0);
773 /* get SP for this packet */
775 sp
= ipsec4_getpolicybyaddr(m
, IPSEC_DIR_OUTBOUND
, flags
, &error
);
777 sp
= ipsec4_getpolicybysock(m
, IPSEC_DIR_OUTBOUND
, so
, &error
);
780 IPSEC_STAT_INCREMENT(ipsecstat
.out_inval
);
781 KERNEL_DEBUG(DBG_FNC_IPSEC4_OUTPUT
| DBG_FUNC_END
, 0,0,0,0,0);
788 switch (sp
->policy
) {
789 case IPSEC_POLICY_DISCARD
:
790 case IPSEC_POLICY_GENERATE
:
792 * This packet is just discarded.
794 IPSEC_STAT_INCREMENT(ipsecstat
.out_polvio
);
795 KERNEL_DEBUG(DBG_FNC_IPSEC4_OUTPUT
| DBG_FUNC_END
, 1,0,0,0,0);
798 case IPSEC_POLICY_BYPASS
:
799 case IPSEC_POLICY_NONE
:
800 /* no need to do IPsec. */
801 KERNEL_DEBUG(DBG_FNC_IPSEC4_OUTPUT
| DBG_FUNC_END
, 2,0,0,0,0);
804 case IPSEC_POLICY_IPSEC
:
805 if (sp
->req
== NULL
) {
806 /* acquire a policy */
807 error
= key_spdacquire(sp
);
808 KERNEL_DEBUG(DBG_FNC_IPSEC4_OUTPUT
| DBG_FUNC_END
, 3,0,0,0,0);
813 case IPSEC_POLICY_ENTRUST
:
815 printf("ip_output: Invalid policy found. %d\n", sp
->policy
);
818 struct ipsec_output_state state
;
819 bzero(&state
, sizeof(state
));
821 if (flags
& IP_ROUTETOIF
) {
823 bzero(&iproute
, sizeof(iproute
));
826 state
.dst
= (struct sockaddr
*)dst
;
832 * delayed checksums are not currently compatible with IPsec
834 if (m
->m_pkthdr
.csum_flags
& CSUM_DELAY_DATA
) {
836 m
->m_pkthdr
.csum_flags
&= ~CSUM_DELAY_DATA
;
842 error
= ipsec4_output(&state
, sp
, flags
);
846 if (flags
& IP_ROUTETOIF
) {
848 * if we have tunnel mode SA, we may need to ignore
851 if (state
.ro
!= &iproute
|| state
.ro
->ro_rt
!= NULL
) {
852 flags
&= ~IP_ROUTETOIF
;
858 dst
= (struct sockaddr_in
*)state
.dst
;
860 /* mbuf is already reclaimed in ipsec4_output. */
870 printf("ip4_output (ipsec): error code %d\n", error
);
873 /* don't show these error codes to the user */
877 KERNEL_DEBUG(DBG_FNC_IPSEC4_OUTPUT
| DBG_FUNC_END
, 4,0,0,0,0);
882 /* be sure to update variables that are affected by ipsec4_output() */
883 ip
= mtod(m
, struct ip
*);
886 hlen
= IP_VHL_HL(ip
->ip_vhl
) << 2;
888 hlen
= ip
->ip_hl
<< 2;
890 /* Check that there wasn't a route change and src is still valid */
892 lck_mtx_lock(rt_mtx
);
893 if (ro
->ro_rt
&& ro
->ro_rt
->generation_id
!= route_generation
) {
894 if (ifa_foraddr(ip
->ip_src
.s_addr
) == 0 && ((flags
& (IP_ROUTETOIF
| IP_FORWARDING
)) == 0)) {
895 error
= EADDRNOTAVAIL
;
896 lck_mtx_unlock(rt_mtx
);
897 KERNEL_DEBUG(DBG_FNC_IPSEC4_OUTPUT
| DBG_FUNC_END
, 5,0,0,0,0);
900 rtfree_locked(ro
->ro_rt
);
904 if (ro
->ro_rt
== NULL
) {
905 if ((flags
& IP_ROUTETOIF
) == 0) {
907 "can't update route after IPsec processing\n");
908 error
= EHOSTUNREACH
; /*XXX*/
909 lck_mtx_unlock(rt_mtx
);
910 KERNEL_DEBUG(DBG_FNC_IPSEC4_OUTPUT
| DBG_FUNC_END
, 6,0,0,0,0);
915 ifafree(&ia
->ia_ifa
);
916 ia
= ifatoia(ro
->ro_rt
->rt_ifa
);
919 ifp
= ro
->ro_rt
->rt_ifp
;
921 lck_mtx_unlock(rt_mtx
);
923 /* make it flipped, again. */
926 KERNEL_DEBUG(DBG_FNC_IPSEC4_OUTPUT
| DBG_FUNC_END
, 7,0xff,0xff,0xff,0xff);
928 /* Pass to filters again */
929 if (!TAILQ_EMPTY(&ipv4_filters
)) {
930 struct ipfilter
*filter
;
934 /* 4135317 - always pass network byte order to filter */
938 TAILQ_FOREACH(filter
, &ipv4_filters
, ipf_link
) {
939 if (filter
->ipf_filter
.ipf_output
) {
941 result
= filter
->ipf_filter
.ipf_output(filter
->ipf_filter
.cookie
, (mbuf_t
*)&m
, 0);
942 if (result
== EJUSTRETURN
) {
953 /* set back to host byte order */
954 ip
= mtod(m
, struct ip
*);
966 * - Xlate: translate packet's addr/port (NAT).
967 * - Firewall: deny/allow/etc.
968 * - Wrap: fake packet's addr/port <unimpl.>
969 * - Encapsulate: put it in another IP and send out. <unimp.>
974 if ((error
= (*fr_checkp
)(ip
, hlen
, ifp
, 1, &m1
)) || !m1
) {
977 ip
= mtod(m0
= m
= m1
, struct ip
*);
981 * Check with the firewall...
982 * but not if we are already being fwd'd from a firewall.
984 if (fw_enable
&& IPFW_LOADED
&& !args
.next_hop
) {
985 struct sockaddr_in
*old
= dst
;
990 off
= ip_fw_chk_ptr(&args
);
995 * On return we must do the following:
996 * IP_FW_PORT_DENY_FLAG -> drop the pkt (XXX new)
997 * 1<=off<= 0xffff -> DIVERT
998 * (off & IP_FW_PORT_DYNT_FLAG) -> send to a DUMMYNET pipe
999 * (off & IP_FW_PORT_TEE_FLAG) -> TEE the packet
1000 * dst != old -> IPFIREWALL_FORWARD
1001 * off==0, dst==old -> accept
1002 * If some of the above modules is not compiled in, then
1003 * we should't have to check the corresponding condition
1004 * (because the ipfw control socket should not accept
1005 * unsupported rules), but better play safe and drop
1006 * packets in case of doubt.
1009 if ( (off
& IP_FW_PORT_DENY_FLAG
) || m
== NULL
) {
1015 ip
= mtod(m
, struct ip
*);
1017 if (off
== 0 && dst
== old
) {/* common case */
1021 if (DUMMYNET_LOADED
&& (off
& IP_FW_PORT_DYNT_FLAG
) != 0) {
1023 * pass the pkt to dummynet. Need to include
1024 * pipe number, m, ifp, ro, dst because these are
1025 * not recomputed in the next pass.
1026 * All other parameters have been already used and
1027 * so they are not needed anymore.
1028 * XXX note: if the ifp or ro entry are deleted
1029 * while a pkt is in dummynet, we are in trouble!
1035 error
= ip_dn_io_ptr(m
, off
& 0xffff, DN_TO_IP_OUT
,
1039 #endif /* DUMMYNET */
1041 if (off
!= 0 && (off
& IP_FW_PORT_DYNT_FLAG
) == 0) {
1042 struct mbuf
*clone
= NULL
;
1044 /* Clone packet if we're doing a 'tee' */
1045 if ((off
& IP_FW_PORT_TEE_FLAG
) != 0)
1046 clone
= m_dup(m
, M_DONTWAIT
);
1049 * delayed checksums are not currently compatible
1050 * with divert sockets.
1052 if (m
->m_pkthdr
.csum_flags
& CSUM_DELAY_DATA
) {
1053 in_delayed_cksum(m
);
1054 m
->m_pkthdr
.csum_flags
&= ~CSUM_DELAY_DATA
;
1057 /* Restore packet header fields to original values */
1061 /* Deliver packet to divert input routine */
1062 divert_packet(m
, 0, off
& 0xffff, args
.divert_rule
);
1064 /* If 'tee', continue with original packet */
1065 if (clone
!= NULL
) {
1067 ip
= mtod(m
, struct ip
*);
1074 #if IPFIREWALL_FORWARD
1075 /* Here we check dst to make sure it's directly reachable on the
1076 * interface we previously thought it was.
1077 * If it isn't (which may be likely in some situations) we have
1078 * to re-route it (ie, find a route for the next-hop and the
1079 * associated interface) and set them here. This is nested
1080 * forwarding which in most cases is undesirable, except where
1081 * such control is nigh impossible. So we do it here.
1084 if (off
== 0 && old
!= dst
) {
1085 struct in_ifaddr
*ia_fw
;
1087 /* It's changed... */
1088 /* There must be a better way to do this next line... */
1089 static struct route sro_fwd
, *ro_fwd
= &sro_fwd
;
1090 #if IPFIREWALL_FORWARD_DEBUG
1091 printf("IPFIREWALL_FORWARD: New dst ip: ");
1092 print_ip(dst
->sin_addr
);
1096 * We need to figure out if we have been forwarded
1097 * to a local socket. If so then we should somehow
1098 * "loop back" to ip_input, and get directed to the
1099 * PCB as if we had received this packet. This is
1100 * because it may be dificult to identify the packets
1101 * you want to forward until they are being output
1102 * and have selected an interface. (e.g. locally
1103 * initiated packets) If we used the loopback inteface,
1104 * we would not be able to control what happens
1105 * as the packet runs through ip_input() as
1106 * it is done through a ISR.
1108 TAILQ_FOREACH(ia_fw
, &in_ifaddrhead
, ia_link
) {
1110 * If the addr to forward to is one
1111 * of ours, we pretend to
1112 * be the destination for this packet.
1114 if (IA_SIN(ia_fw
)->sin_addr
.s_addr
==
1115 dst
->sin_addr
.s_addr
)
1119 /* tell ip_input "dont filter" */
1120 struct m_tag
*fwd_tag
;
1121 struct ip_fwd_tag
*ipfwd_tag
;
1123 fwd_tag
= m_tag_alloc(KERNEL_MODULE_TAG_ID
, KERNEL_TAG_TYPE_IPFORWARD
,
1124 sizeof(struct sockaddr_in
), M_NOWAIT
);
1125 if (fwd_tag
== NULL
) {
1130 ipfwd_tag
= (struct ip_fwd_tag
*)(fwd_tag
+1);
1131 ipfwd_tag
->next_hop
= args
.next_hop
;
1133 m_tag_prepend(m
, fwd_tag
);
1135 if (m
->m_pkthdr
.rcvif
== NULL
)
1136 m
->m_pkthdr
.rcvif
= ifunit("lo0");
1137 if ((~IF_HWASSIST_CSUM_FLAGS(m
->m_pkthdr
.rcvif
->if_hwassist
) &
1138 m
->m_pkthdr
.csum_flags
) == 0) {
1139 if (m
->m_pkthdr
.csum_flags
& CSUM_DELAY_DATA
) {
1140 m
->m_pkthdr
.csum_flags
&= ~CSUM_DELAY_DATA
;
1141 m
->m_pkthdr
.csum_flags
|=
1142 CSUM_DATA_VALID
| CSUM_PSEUDO_HDR
;
1143 m
->m_pkthdr
.csum_data
= 0xffff;
1145 m
->m_pkthdr
.csum_flags
|=
1146 CSUM_IP_CHECKED
| CSUM_IP_VALID
;
1148 else if (m
->m_pkthdr
.csum_flags
& CSUM_DELAY_DATA
) {
1149 in_delayed_cksum(m
);
1150 m
->m_pkthdr
.csum_flags
&= ~CSUM_DELAY_DATA
;
1151 ip
->ip_sum
= in_cksum(m
, hlen
);
1157 /* we need to call dlil_output to run filters
1158 * and resync to avoid recursion loops.
1161 dlil_output(lo_ifp
, PF_INET
, m
, 0, (struct sockaddr
*)dst
, 0);
1164 printf("ip_output: no loopback ifp for forwarding!!!\n");
1168 /* Some of the logic for this was
1169 * nicked from above.
1171 * This rewrites the cached route in a local PCB.
1172 * Is this what we want to do?
1174 bcopy(dst
, &ro_fwd
->ro_dst
, sizeof(*dst
));
1177 lck_mtx_lock(rt_mtx
);
1178 rtalloc_ign_locked(ro_fwd
, RTF_PRCLONING
);
1180 if (ro_fwd
->ro_rt
== 0) {
1181 OSAddAtomic(1, (SInt32
*)&ipstat
.ips_noroute
);
1182 error
= EHOSTUNREACH
;
1183 lck_mtx_unlock(rt_mtx
);
1187 ia_fw
= ifatoia(ro_fwd
->ro_rt
->rt_ifa
);
1188 ifp
= ro_fwd
->ro_rt
->rt_ifp
;
1189 ro_fwd
->ro_rt
->rt_use
++;
1190 if (ro_fwd
->ro_rt
->rt_flags
& RTF_GATEWAY
)
1191 dst
= (struct sockaddr_in
*)ro_fwd
->ro_rt
->rt_gateway
;
1192 if (ro_fwd
->ro_rt
->rt_flags
& RTF_HOST
)
1194 (ro_fwd
->ro_rt
->rt_flags
& RTF_BROADCAST
);
1196 isbroadcast
= in_broadcast(dst
->sin_addr
, ifp
);
1197 rtfree_locked(ro
->ro_rt
);
1198 ro
->ro_rt
= ro_fwd
->ro_rt
;
1199 dst
= (struct sockaddr_in
*)&ro_fwd
->ro_dst
;
1200 lck_mtx_unlock(rt_mtx
);
1203 * If we added a default src ip earlier,
1204 * which would have been gotten from the-then
1205 * interface, do it again, from the new one.
1207 if (fwd_rewrite_src
)
1208 ip
->ip_src
= IA_SIN(ia_fw
)->sin_addr
;
1211 #endif /* IPFIREWALL_FORWARD */
1213 * if we get here, none of the above matches, and
1214 * we have to drop the pkt
1217 error
= EACCES
; /* not sure this is the right error msg */
1220 #endif /* IPFIREWALL */
1224 /* Do not allow loopback address to wind up on a wire */
1225 if ((ifp
->if_flags
& IFF_LOOPBACK
) == 0 &&
1226 ((ntohl(ip
->ip_src
.s_addr
) >> IN_CLASSA_NSHIFT
) == IN_LOOPBACKNET
||
1227 (ntohl(ip
->ip_dst
.s_addr
) >> IN_CLASSA_NSHIFT
) == IN_LOOPBACKNET
)) {
1228 OSAddAtomic(1, (SInt32
*)&ipstat
.ips_badaddr
);
1231 * Do not simply drop the packet just like a firewall -- we want the
1232 * the application to feel the pain.
1233 * Return ENETUNREACH like ip6_output does in some similar cases.
1234 * This can startle the otherwise clueless process that specifies
1235 * loopback as the source address.
1237 error
= ENETUNREACH
;
1241 m
->m_pkthdr
.csum_flags
|= CSUM_IP
;
1242 sw_csum
= m
->m_pkthdr
.csum_flags
1243 & ~IF_HWASSIST_CSUM_FLAGS(ifp
->if_hwassist
);
1245 if ((ifp
->if_hwassist
& CSUM_TCP_SUM16
) != 0) {
1247 * Special case code for GMACE
1248 * frames that can be checksumed by GMACE SUM16 HW:
1249 * frame >64, no fragments, no UDP
1251 if (apple_hwcksum_tx
&& (m
->m_pkthdr
.csum_flags
& CSUM_TCP
)
1252 && (ip
->ip_len
> 50) && (ip
->ip_len
<= ifp
->if_mtu
)) {
1253 /* Apple GMAC HW, expects STUFF_OFFSET << 16 | START_OFFSET */
1254 u_short offset
= (IP_VHL_HL(ip
->ip_vhl
) << 2) +14 ; /* IP+Enet header length */
1255 u_short csumprev
= m
->m_pkthdr
.csum_data
& 0xFFFF;
1256 m
->m_pkthdr
.csum_flags
= CSUM_DATA_VALID
| CSUM_TCP_SUM16
; /* for GMAC */
1257 m
->m_pkthdr
.csum_data
= (csumprev
+ offset
) << 16 ;
1258 m
->m_pkthdr
.csum_data
+= offset
;
1259 sw_csum
= CSUM_DELAY_IP
; /* do IP hdr chksum in software */
1262 /* let the software handle any UDP or TCP checksums */
1263 sw_csum
|= (CSUM_DELAY_DATA
& m
->m_pkthdr
.csum_flags
);
1265 } else if (apple_hwcksum_tx
== 0) {
1266 sw_csum
|= (CSUM_DELAY_DATA
| CSUM_DELAY_IP
) &
1267 m
->m_pkthdr
.csum_flags
;
1270 if (sw_csum
& CSUM_DELAY_DATA
) {
1271 in_delayed_cksum(m
);
1272 sw_csum
&= ~CSUM_DELAY_DATA
;
1273 m
->m_pkthdr
.csum_flags
&= ~CSUM_DELAY_DATA
;
1276 if (apple_hwcksum_tx
!= 0) {
1277 m
->m_pkthdr
.csum_flags
&=
1278 IF_HWASSIST_CSUM_FLAGS(ifp
->if_hwassist
);
1280 m
->m_pkthdr
.csum_flags
= 0;
1284 * If small enough for interface, or the interface will take
1285 * care of the fragmentation for us, can just send directly.
1287 if ((u_short
)ip
->ip_len
<= ifp
->if_mtu
||
1288 ifp
->if_hwassist
& CSUM_FRAGMENT
) {
1289 struct rtentry
*rte
;
1294 if (sw_csum
& CSUM_DELAY_IP
) {
1295 ip
->ip_sum
= in_cksum(m
, hlen
);
1299 /* Record statistics for this interface address. */
1300 if (!(flags
& IP_FORWARDING
) && ia
!= NULL
) {
1301 ia
->ia_ifa
.if_opackets
++;
1302 ia
->ia_ifa
.if_obytes
+= m
->m_pkthdr
.len
;
1307 /* clean ipsec history once it goes out of the node */
1308 if (ipsec_bypass
== 0 && (flags
& IP_NOIPSEC
) == 0)
1311 if (packetchain
== 0) {
1312 lck_mtx_lock(rt_mtx
);
1313 if ((rte
= ro
->ro_rt
) != NULL
)
1315 lck_mtx_unlock(rt_mtx
);
1316 error
= ifnet_output(ifp
, PF_INET
, m
, rte
,
1317 (struct sockaddr
*)dst
);
1322 else { /* packet chaining allows us to reuse the route for all packets */
1325 if (pktcnt
> ip_maxchainsent
)
1326 ip_maxchainsent
= pktcnt
;
1327 lck_mtx_lock(rt_mtx
);
1328 if ((rte
= ro
->ro_rt
) != NULL
)
1330 lck_mtx_unlock(rt_mtx
);
1332 error
= ifnet_output(ifp
, PF_INET
, packetlist
,
1333 rte
, (struct sockaddr
*)dst
);
1346 * Too large for interface; fragment if possible.
1347 * Must be able to put at least 8 bytes per fragment.
1349 if (ip
->ip_off
& IP_DF
) {
1352 * This case can happen if the user changed the MTU
1353 * of an interface after enabling IP on it. Because
1354 * most netifs don't keep track of routes pointing to
1355 * them, there is no way for one to update all its
1356 * routes when the MTU is changed.
1359 lck_mtx_lock(rt_mtx
);
1360 if (ro
->ro_rt
&& (ro
->ro_rt
->rt_flags
& (RTF_UP
| RTF_HOST
))
1361 && !(ro
->ro_rt
->rt_rmx
.rmx_locks
& RTV_MTU
)
1362 && (ro
->ro_rt
->rt_rmx
.rmx_mtu
> ifp
->if_mtu
)) {
1363 ro
->ro_rt
->rt_rmx
.rmx_mtu
= ifp
->if_mtu
;
1365 lck_mtx_unlock(rt_mtx
);
1366 OSAddAtomic(1, (SInt32
*)&ipstat
.ips_cantfrag
);
1369 len
= (ifp
->if_mtu
- hlen
) &~ 7;
1376 * if the interface will not calculate checksums on
1377 * fragmented packets, then do it here.
1379 if (m
->m_pkthdr
.csum_flags
& CSUM_DELAY_DATA
&&
1380 (ifp
->if_hwassist
& CSUM_IP_FRAGS
) == 0) {
1381 in_delayed_cksum(m
);
1382 m
->m_pkthdr
.csum_flags
&= ~CSUM_DELAY_DATA
;
1387 int mhlen
, firstlen
= len
;
1388 struct mbuf
**mnext
= &m
->m_nextpkt
;
1392 * Loop through length of segment after first fragment,
1393 * make new header and copy data of each part and link onto chain.
1396 mhlen
= sizeof (struct ip
);
1397 for (off
= hlen
+ len
; off
< (u_short
)ip
->ip_len
; off
+= len
) {
1398 MGETHDR(m
, M_DONTWAIT
, MT_HEADER
); /* MAC-OK */
1401 OSAddAtomic(1, (SInt32
*)&ipstat
.ips_odropped
);
1404 m
->m_flags
|= (m0
->m_flags
& M_MCAST
) | M_FRAG
;
1405 m
->m_data
+= max_linkhdr
;
1406 mhip
= mtod(m
, struct ip
*);
1408 if (hlen
> sizeof (struct ip
)) {
1409 mhlen
= ip_optcopy(ip
, mhip
) + sizeof (struct ip
);
1410 mhip
->ip_vhl
= IP_MAKE_VHL(IPVERSION
, mhlen
>> 2);
1413 mhip
->ip_off
= ((off
- hlen
) >> 3) + (ip
->ip_off
& ~IP_MF
);
1414 if (ip
->ip_off
& IP_MF
)
1415 mhip
->ip_off
|= IP_MF
;
1416 if (off
+ len
>= (u_short
)ip
->ip_len
)
1417 len
= (u_short
)ip
->ip_len
- off
;
1419 mhip
->ip_off
|= IP_MF
;
1420 mhip
->ip_len
= htons((u_short
)(len
+ mhlen
));
1421 m
->m_next
= m_copy(m0
, off
, len
);
1422 if (m
->m_next
== 0) {
1424 error
= ENOBUFS
; /* ??? */
1425 OSAddAtomic(1, (SInt32
*)&ipstat
.ips_odropped
);
1428 m
->m_pkthdr
.len
= mhlen
+ len
;
1429 m
->m_pkthdr
.rcvif
= 0;
1430 m
->m_pkthdr
.csum_flags
= m0
->m_pkthdr
.csum_flags
;
1431 m
->m_pkthdr
.socket_id
= m0
->m_pkthdr
.socket_id
;
1433 mac_netinet_fragment(m0
, m
);
1435 HTONS(mhip
->ip_off
);
1437 if (sw_csum
& CSUM_DELAY_IP
) {
1438 mhip
->ip_sum
= in_cksum(m
, mhlen
);
1441 mnext
= &m
->m_nextpkt
;
1444 OSAddAtomic(nfrags
, (SInt32
*)&ipstat
.ips_ofragments
);
1446 /* set first/last markers for fragment chain */
1447 m
->m_flags
|= M_LASTFRAG
;
1448 m0
->m_flags
|= M_FIRSTFRAG
| M_FRAG
;
1449 m0
->m_pkthdr
.csum_data
= nfrags
;
1452 * Update first fragment by trimming what's been copied out
1453 * and updating header, then send each fragment (in order).
1456 m_adj(m
, hlen
+ firstlen
- (u_short
)ip
->ip_len
);
1457 m
->m_pkthdr
.len
= hlen
+ firstlen
;
1458 ip
->ip_len
= htons((u_short
)m
->m_pkthdr
.len
);
1459 ip
->ip_off
|= IP_MF
;
1462 if (sw_csum
& CSUM_DELAY_IP
) {
1463 ip
->ip_sum
= in_cksum(m
, hlen
);
1467 KERNEL_DEBUG(DBG_LAYER_END
, ip
->ip_dst
.s_addr
,
1468 ip
->ip_src
.s_addr
, ip
->ip_p
, ip
->ip_off
, ip
->ip_len
);
1470 for (m
= m0
; m
; m
= m0
) {
1474 /* clean ipsec history once it goes out of the node */
1475 if (ipsec_bypass
== 0 && (flags
& IP_NOIPSEC
) == 0)
1479 struct rtentry
*rte
;
1481 /* Record statistics for this interface address. */
1483 ia
->ia_ifa
.if_opackets
++;
1484 ia
->ia_ifa
.if_obytes
+= m
->m_pkthdr
.len
;
1487 if ((packetchain
!= 0) && (pktcnt
> 0))
1488 panic("ip_output: mix of packet in packetlist is wrong=%p", packetlist
);
1489 lck_mtx_lock(rt_mtx
);
1490 if ((rte
= ro
->ro_rt
) != NULL
)
1492 lck_mtx_unlock(rt_mtx
);
1493 error
= ifnet_output(ifp
, PF_INET
, m
, rte
,
1494 (struct sockaddr
*)dst
);
1502 OSAddAtomic(1, (SInt32
*)&ipstat
.ips_fragmented
);
1506 ifafree(&ia
->ia_ifa
);
1510 if (ipsec_bypass
== 0 && (flags
& IP_NOIPSEC
) == 0) {
1511 if (ro
== &iproute
&& ro
->ro_rt
) {
1516 KEYDEBUG(KEYDEBUG_IPSEC_STAMP
,
1517 printf("DP ip_output call free SP:%x\n", sp
));
1518 key_freesp(sp
, KEY_SADB_UNLOCKED
);
1523 KERNEL_DEBUG(DBG_FNC_IP_OUTPUT
| DBG_FUNC_END
, error
,0,0,0,0);
1531 ip_out_cksum_stats(int proto
, u_int32_t len
)
1535 tcp_out_cksum_stats(len
);
1538 udp_out_cksum_stats(len
);
1541 /* keep only TCP or UDP stats for now */
1547 in_delayed_cksum_offset(struct mbuf
*m0
, int ip_offset
)
1550 unsigned char buf
[sizeof(struct ip
)];
1551 u_short csum
, offset
, ip_len
;
1552 struct mbuf
*m
= m0
;
1554 while (ip_offset
>= m
->m_len
) {
1555 ip_offset
-= m
->m_len
;
1558 printf("in_delayed_cksum_withoffset failed - ip_offset wasn't in the packet\n");
1563 /* Sometimes the IP header is not contiguous, yes this can happen! */
1564 if (ip_offset
+ sizeof(struct ip
) > m
->m_len
) {
1566 printf("delayed m_pullup, m->len: %ld off: %d\n",
1567 m
->m_len
, ip_offset
);
1569 m_copydata(m
, ip_offset
, sizeof(struct ip
), (caddr_t
) buf
);
1571 ip
= (struct ip
*)buf
;
1573 ip
= (struct ip
*)(m
->m_data
+ ip_offset
);
1578 m
->m_len
-= ip_offset
;
1579 m
->m_data
+= ip_offset
;
1582 offset
= IP_VHL_HL(ip
->ip_vhl
) << 2 ;
1585 * We could be in the context of an IP or interface filter; in the
1586 * former case, ip_len would be in host (correct) order while for
1587 * the latter it would be in network order. Because of this, we
1588 * attempt to interpret the length field by comparing it against
1589 * the actual packet length. If the comparison fails, byte swap
1590 * the length and check again. If it still fails, then the packet
1591 * is bogus and we give up.
1593 ip_len
= ip
->ip_len
;
1594 if (ip_len
!= (m0
->m_pkthdr
.len
- ip_offset
)) {
1595 ip_len
= SWAP16(ip_len
);
1596 if (ip_len
!= (m0
->m_pkthdr
.len
- ip_offset
)) {
1597 printf("in_delayed_cksum_offset: ip_len %d (%d) "
1598 "doesn't match actual length %d\n", ip
->ip_len
,
1599 ip_len
, (m0
->m_pkthdr
.len
- ip_offset
));
1604 csum
= in_cksum_skip(m
, ip_len
, offset
);
1607 ip_out_cksum_stats(ip
->ip_p
, ip_len
- offset
);
1609 if (m0
->m_pkthdr
.csum_flags
& CSUM_UDP
&& csum
== 0)
1611 offset
+= m0
->m_pkthdr
.csum_data
& 0xFFFF; /* checksum offset */
1615 if (M_LEADINGSPACE(m
) < ip_offset
)
1616 panic("in_delayed_cksum_offset - chain modified!\n");
1617 m
->m_len
+= ip_offset
;
1618 m
->m_data
-= ip_offset
;
1621 if (offset
> ip_len
) /* bogus offset */
1624 /* Insert the checksum in the existing chain */
1625 if (offset
+ ip_offset
+ sizeof(u_short
) > m
->m_len
) {
1629 printf("delayed m_copyback, m->len: %ld off: %d p: %d\n",
1630 m
->m_len
, offset
+ ip_offset
, ip
->ip_p
);
1632 *(u_short
*)tmp
= csum
;
1633 m_copyback(m
, offset
+ ip_offset
, 2, tmp
);
1635 *(u_short
*)(m
->m_data
+ offset
+ ip_offset
) = csum
;
1639 in_delayed_cksum(struct mbuf
*m
)
1641 in_delayed_cksum_offset(m
, 0);
1645 in_cksum_offset(struct mbuf
* m
, size_t ip_offset
)
1647 struct ip
* ip
= NULL
;
1649 unsigned char buf
[sizeof(struct ip
)];
1652 while (ip_offset
>= m
->m_len
) {
1653 ip_offset
-= m
->m_len
;
1656 printf("in_cksum_offset failed - ip_offset wasn't in the packet\n");
1661 /* Sometimes the IP header is not contiguous, yes this can happen! */
1662 if (ip_offset
+ sizeof(struct ip
) > m
->m_len
) {
1665 printf("in_cksum_offset - delayed m_pullup, m->len: %ld off: %lu\n",
1666 m
->m_len
, ip_offset
);
1668 m_copydata(m
, ip_offset
, sizeof(struct ip
), (caddr_t
) buf
);
1670 ip
= (struct ip
*)buf
;
1672 m_copyback(m
, ip_offset
+ offsetof(struct ip
, ip_sum
), 2, (caddr_t
)&ip
->ip_sum
);
1674 ip
= (struct ip
*)(m
->m_data
+ ip_offset
);
1680 m
->m_len
-= ip_offset
;
1681 m
->m_data
+= ip_offset
;
1685 hlen
= IP_VHL_HL(ip
->ip_vhl
) << 2;
1687 hlen
= ip
->ip_hl
<< 2;
1690 * We could be in the context of an IP or interface filter; in the
1691 * former case, ip_len would be in host order while for the latter
1692 * it would be in network (correct) order. Because of this, we
1693 * attempt to interpret the length field by comparing it against
1694 * the actual packet length. If the comparison fails, byte swap
1695 * the length and check again. If it still fails, then the packet
1696 * is bogus and we give up.
1698 if (ntohs(ip
->ip_len
) != (m
->m_pkthdr
.len
- ip_offset
)) {
1699 ip
->ip_len
= SWAP16(ip
->ip_len
);
1701 if (ntohs(ip
->ip_len
) != (m
->m_pkthdr
.len
- ip_offset
)) {
1702 ip
->ip_len
= SWAP16(ip
->ip_len
);
1703 printf("in_cksum_offset: ip_len %d (%d) "
1704 "doesn't match actual length %lu\n",
1705 ip
->ip_len
, SWAP16(ip
->ip_len
),
1706 (m
->m_pkthdr
.len
- ip_offset
));
1712 ip
->ip_sum
= in_cksum(m
, hlen
);
1714 ip
->ip_len
= SWAP16(ip
->ip_len
);
1718 if (M_LEADINGSPACE(m
) < ip_offset
)
1719 panic("in_cksum_offset - chain modified!\n");
1720 m
->m_len
+= ip_offset
;
1721 m
->m_data
-= ip_offset
;
1724 /* Insert the checksum in the existing chain if IP header not contiguous */
1725 if (ip_offset
+ sizeof(struct ip
) > m
->m_len
) {
1729 printf("in_cksum_offset m_copyback, m->len: %lu off: %lu p: %d\n",
1730 m
->m_len
, ip_offset
+ offsetof(struct ip
, ip_sum
), ip
->ip_p
);
1732 *(u_short
*)tmp
= ip
->ip_sum
;
1733 m_copyback(m
, ip_offset
+ offsetof(struct ip
, ip_sum
), 2, tmp
);
1738 * Insert IP options into preformed packet.
1739 * Adjust IP destination as required for IP source routing,
1740 * as indicated by a non-zero in_addr at the start of the options.
1742 * XXX This routine assumes that the packet has no options in place.
1744 static struct mbuf
*
1745 ip_insertoptions(m
, opt
, phlen
)
1746 register struct mbuf
*m
;
1750 register struct ipoption
*p
= mtod(opt
, struct ipoption
*);
1752 register struct ip
*ip
= mtod(m
, struct ip
*);
1755 optlen
= opt
->m_len
- sizeof(p
->ipopt_dst
);
1756 if (optlen
+ (u_short
)ip
->ip_len
> IP_MAXPACKET
)
1757 return (m
); /* XXX should fail */
1758 if (p
->ipopt_dst
.s_addr
)
1759 ip
->ip_dst
= p
->ipopt_dst
;
1760 if (m
->m_flags
& M_EXT
|| m
->m_data
- optlen
< m
->m_pktdat
) {
1761 MGETHDR(n
, M_DONTWAIT
, MT_HEADER
); /* MAC-OK */
1764 n
->m_pkthdr
.rcvif
= 0;
1766 mac_mbuf_label_copy(m
, n
);
1768 n
->m_pkthdr
.len
= m
->m_pkthdr
.len
+ optlen
;
1769 m
->m_len
-= sizeof(struct ip
);
1770 m
->m_data
+= sizeof(struct ip
);
1773 m
->m_len
= optlen
+ sizeof(struct ip
);
1774 m
->m_data
+= max_linkhdr
;
1775 (void)memcpy(mtod(m
, void *), ip
, sizeof(struct ip
));
1777 m
->m_data
-= optlen
;
1779 m
->m_pkthdr
.len
+= optlen
;
1780 ovbcopy((caddr_t
)ip
, mtod(m
, caddr_t
), sizeof(struct ip
));
1782 ip
= mtod(m
, struct ip
*);
1783 bcopy(p
->ipopt_list
, ip
+ 1, optlen
);
1784 *phlen
= sizeof(struct ip
) + optlen
;
1785 ip
->ip_vhl
= IP_MAKE_VHL(IPVERSION
, *phlen
>> 2);
1786 ip
->ip_len
+= optlen
;
1791 * Copy options from ip to jp,
1792 * omitting those not copied during fragmentation.
1798 register u_char
*cp
, *dp
;
1799 int opt
, optlen
, cnt
;
1801 cp
= (u_char
*)(ip
+ 1);
1802 dp
= (u_char
*)(jp
+ 1);
1803 cnt
= (IP_VHL_HL(ip
->ip_vhl
) << 2) - sizeof (struct ip
);
1804 for (; cnt
> 0; cnt
-= optlen
, cp
+= optlen
) {
1806 if (opt
== IPOPT_EOL
)
1808 if (opt
== IPOPT_NOP
) {
1809 /* Preserve for IP mcast tunnel's LSRR alignment. */
1815 if (cnt
< IPOPT_OLEN
+ sizeof(*cp
))
1816 panic("malformed IPv4 option passed to ip_optcopy");
1818 optlen
= cp
[IPOPT_OLEN
];
1820 if (optlen
< IPOPT_OLEN
+ sizeof(*cp
) || optlen
> cnt
)
1821 panic("malformed IPv4 option passed to ip_optcopy");
1823 /* bogus lengths should have been caught by ip_dooptions */
1826 if (IPOPT_COPIED(opt
)) {
1827 bcopy(cp
, dp
, optlen
);
1831 for (optlen
= dp
- (u_char
*)(jp
+1); optlen
& 0x3; optlen
++)
1837 * IP socket option processing.
1840 ip_ctloutput(so
, sopt
)
1842 struct sockopt
*sopt
;
1844 struct inpcb
*inp
= sotoinpcb(so
);
1848 if (sopt
->sopt_level
!= IPPROTO_IP
) {
1852 switch (sopt
->sopt_dir
) {
1854 switch (sopt
->sopt_name
) {
1861 if (sopt
->sopt_valsize
> MLEN
) {
1865 MGET(m
, sopt
->sopt_p
? M_WAIT
: M_DONTWAIT
, MT_HEADER
);
1870 m
->m_len
= sopt
->sopt_valsize
;
1871 error
= sooptcopyin(sopt
, mtod(m
, char *), m
->m_len
,
1876 return (ip_pcbopts(sopt
->sopt_name
, &inp
->inp_options
,
1883 case IP_RECVRETOPTS
:
1884 case IP_RECVDSTADDR
:
1887 #if defined(NFAITH) && NFAITH > 0
1890 error
= sooptcopyin(sopt
, &optval
, sizeof optval
,
1895 switch (sopt
->sopt_name
) {
1897 inp
->inp_ip_tos
= optval
;
1901 inp
->inp_ip_ttl
= optval
;
1903 #define OPTSET(bit) \
1905 inp->inp_flags |= bit; \
1907 inp->inp_flags &= ~bit;
1910 OPTSET(INP_RECVOPTS
);
1913 case IP_RECVRETOPTS
:
1914 OPTSET(INP_RECVRETOPTS
);
1917 case IP_RECVDSTADDR
:
1918 OPTSET(INP_RECVDSTADDR
);
1926 OPTSET(INP_RECVTTL
);
1929 #if defined(NFAITH) && NFAITH > 0
1938 #if CONFIG_FORCE_OUT_IFP
1939 case IP_FORCE_OUT_IFP
: {
1940 char ifname
[IFNAMSIZ
];
1943 /* Verify interface name parameter is sane */
1944 if (sopt
->sopt_valsize
> sizeof(ifname
)) {
1949 /* Copy the interface name */
1950 if (sopt
->sopt_valsize
!= 0) {
1951 error
= sooptcopyin(sopt
, ifname
, sizeof(ifname
), sopt
->sopt_valsize
);
1956 if (sopt
->sopt_valsize
== 0 || ifname
[0] == 0) {
1957 // Set pdp_ifp to NULL
1958 inp
->pdp_ifp
= NULL
;
1961 if (inp
->inp_route
.ro_rt
) {
1962 rtfree(inp
->inp_route
.ro_rt
);
1963 inp
->inp_route
.ro_rt
= NULL
;
1969 /* Verify name is NULL terminated */
1970 if (ifname
[sopt
->sopt_valsize
- 1] != 0) {
1975 if (ifnet_find_by_name(ifname
, &ifp
) != 0) {
1980 /* Won't actually free. Since we don't release this later, we should do it now. */
1983 /* This only works for point-to-point interfaces */
1984 if ((ifp
->if_flags
& IFF_POINTOPOINT
) == 0) {
1993 case IP_MULTICAST_IF
:
1994 case IP_MULTICAST_VIF
:
1995 case IP_MULTICAST_TTL
:
1996 case IP_MULTICAST_LOOP
:
1997 case IP_ADD_MEMBERSHIP
:
1998 case IP_DROP_MEMBERSHIP
:
1999 error
= ip_setmoptions(sopt
, &inp
->inp_moptions
);
2003 error
= sooptcopyin(sopt
, &optval
, sizeof optval
,
2009 case IP_PORTRANGE_DEFAULT
:
2010 inp
->inp_flags
&= ~(INP_LOWPORT
);
2011 inp
->inp_flags
&= ~(INP_HIGHPORT
);
2014 case IP_PORTRANGE_HIGH
:
2015 inp
->inp_flags
&= ~(INP_LOWPORT
);
2016 inp
->inp_flags
|= INP_HIGHPORT
;
2019 case IP_PORTRANGE_LOW
:
2020 inp
->inp_flags
&= ~(INP_HIGHPORT
);
2021 inp
->inp_flags
|= INP_LOWPORT
;
2031 case IP_IPSEC_POLICY
:
2039 if (sopt
->sopt_valsize
> MCLBYTES
) {
2043 if ((error
= soopt_getm(sopt
, &m
)) != 0) /* XXX */
2045 if ((error
= soopt_mcopyin(sopt
, m
)) != 0) /* XXX */
2047 priv
= (sopt
->sopt_p
!= NULL
&&
2048 proc_suser(sopt
->sopt_p
) != 0) ? 0 : 1;
2050 req
= mtod(m
, caddr_t
);
2053 optname
= sopt
->sopt_name
;
2054 error
= ipsec4_set_policy(inp
, optname
, req
, len
, priv
);
2061 case IP_TRAFFIC_MGT_BACKGROUND
:
2063 unsigned background
= 0;
2064 error
= sooptcopyin(sopt
, &background
, sizeof(background
), sizeof(background
));
2069 so
->so_traffic_mgt_flags
|= TRAFFIC_MGT_SO_BACKGROUND
;
2071 so
->so_traffic_mgt_flags
&= ~TRAFFIC_MGT_SO_BACKGROUND
;
2075 #endif /* TRAFFIC_MGT */
2078 error
= ENOPROTOOPT
;
2084 switch (sopt
->sopt_name
) {
2087 if (inp
->inp_options
)
2088 error
= sooptcopyout(sopt
,
2089 mtod(inp
->inp_options
,
2091 inp
->inp_options
->m_len
);
2093 sopt
->sopt_valsize
= 0;
2099 case IP_RECVRETOPTS
:
2100 case IP_RECVDSTADDR
:
2104 #if defined(NFAITH) && NFAITH > 0
2107 switch (sopt
->sopt_name
) {
2110 optval
= inp
->inp_ip_tos
;
2114 optval
= inp
->inp_ip_ttl
;
2117 #define OPTBIT(bit) (inp->inp_flags & bit ? 1 : 0)
2120 optval
= OPTBIT(INP_RECVOPTS
);
2123 case IP_RECVRETOPTS
:
2124 optval
= OPTBIT(INP_RECVRETOPTS
);
2127 case IP_RECVDSTADDR
:
2128 optval
= OPTBIT(INP_RECVDSTADDR
);
2132 optval
= OPTBIT(INP_RECVIF
);
2136 optval
= OPTBIT(INP_RECVTTL
);
2140 if (inp
->inp_flags
& INP_HIGHPORT
)
2141 optval
= IP_PORTRANGE_HIGH
;
2142 else if (inp
->inp_flags
& INP_LOWPORT
)
2143 optval
= IP_PORTRANGE_LOW
;
2148 #if defined(NFAITH) && NFAITH > 0
2150 optval
= OPTBIT(INP_FAITH
);
2154 error
= sooptcopyout(sopt
, &optval
, sizeof optval
);
2157 case IP_MULTICAST_IF
:
2158 case IP_MULTICAST_VIF
:
2159 case IP_MULTICAST_TTL
:
2160 case IP_MULTICAST_LOOP
:
2161 case IP_ADD_MEMBERSHIP
:
2162 case IP_DROP_MEMBERSHIP
:
2163 error
= ip_getmoptions(sopt
, inp
->inp_moptions
);
2167 case IP_IPSEC_POLICY
:
2169 struct mbuf
*m
= NULL
;
2174 req
= mtod(m
, caddr_t
);
2177 error
= ipsec4_get_policy(sotoinpcb(so
), req
, len
, &m
);
2179 error
= soopt_mcopyout(sopt
, m
); /* XXX */
2187 case IP_TRAFFIC_MGT_BACKGROUND
:
2189 unsigned background
= so
->so_traffic_mgt_flags
;
2190 return (sooptcopyout(sopt
, &background
, sizeof(background
)));
2193 #endif /* TRAFFIC_MGT */
2196 error
= ENOPROTOOPT
;
2205 * Set up IP options in pcb for insertion in output packets.
2206 * Store in mbuf with pointer in pcbopt, adding pseudo-option
2207 * with destination address if source routed.
2211 __unused
int optname
,
2212 struct mbuf
**pcbopt
,
2213 register struct mbuf
*m
)
2215 register int cnt
, optlen
;
2216 register u_char
*cp
;
2219 /* turn off any old options */
2221 (void)m_free(*pcbopt
);
2223 if (m
== (struct mbuf
*)0 || m
->m_len
== 0) {
2225 * Only turning off any previous options.
2233 if (m
->m_len
% sizeof(int32_t))
2237 * IP first-hop destination address will be stored before
2238 * actual options; move other options back
2239 * and clear it when none present.
2241 if (m
->m_data
+ m
->m_len
+ sizeof(struct in_addr
) >= &m
->m_dat
[MLEN
])
2244 m
->m_len
+= sizeof(struct in_addr
);
2245 cp
= mtod(m
, u_char
*) + sizeof(struct in_addr
);
2246 ovbcopy(mtod(m
, caddr_t
), (caddr_t
)cp
, (unsigned)cnt
);
2247 bzero(mtod(m
, caddr_t
), sizeof(struct in_addr
));
2249 for (; cnt
> 0; cnt
-= optlen
, cp
+= optlen
) {
2250 opt
= cp
[IPOPT_OPTVAL
];
2251 if (opt
== IPOPT_EOL
)
2253 if (opt
== IPOPT_NOP
)
2256 if (cnt
< IPOPT_OLEN
+ sizeof(*cp
))
2258 optlen
= cp
[IPOPT_OLEN
];
2259 if (optlen
< IPOPT_OLEN
+ sizeof(*cp
) || optlen
> cnt
)
2270 * user process specifies route as:
2272 * D must be our final destination (but we can't
2273 * check that since we may not have connected yet).
2274 * A is first hop destination, which doesn't appear in
2275 * actual IP option, but is stored before the options.
2277 if (optlen
< IPOPT_MINOFF
- 1 + sizeof(struct in_addr
))
2279 m
->m_len
-= sizeof(struct in_addr
);
2280 cnt
-= sizeof(struct in_addr
);
2281 optlen
-= sizeof(struct in_addr
);
2282 cp
[IPOPT_OLEN
] = optlen
;
2284 * Move first hop before start of options.
2286 bcopy((caddr_t
)&cp
[IPOPT_OFFSET
+1], mtod(m
, caddr_t
),
2287 sizeof(struct in_addr
));
2289 * Then copy rest of options back
2290 * to close up the deleted entry.
2292 ovbcopy((caddr_t
)(&cp
[IPOPT_OFFSET
+1] +
2293 sizeof(struct in_addr
)),
2294 (caddr_t
)&cp
[IPOPT_OFFSET
+1],
2295 (unsigned)cnt
+ sizeof(struct in_addr
));
2299 if (m
->m_len
> MAX_IPOPTLEN
+ sizeof(struct in_addr
))
2311 * The whole multicast option thing needs to be re-thought.
2312 * Several of these options are equally applicable to non-multicast
2313 * transmission, and one (IP_MULTICAST_TTL) totally duplicates a
2314 * standard option (IP_TTL).
2318 * following RFC1724 section 3.3, 0.0.0.0/8 is interpreted as interface index.
2320 static struct ifnet
*
2321 ip_multicast_if(a
, ifindexp
)
2330 if (ntohl(a
->s_addr
) >> 24 == 0) {
2331 ifindex
= ntohl(a
->s_addr
) & 0xffffff;
2332 ifnet_head_lock_shared();
2333 if (ifindex
< 0 || if_index
< ifindex
) {
2337 ifp
= ifindex2ifnet
[ifindex
];
2340 *ifindexp
= ifindex
;
2342 INADDR_TO_IFP(*a
, ifp
);
2348 * Set the IP multicast options in response to user setsockopt().
2351 ip_setmoptions(sopt
, imop
)
2352 struct sockopt
*sopt
;
2353 struct ip_moptions
**imop
;
2357 struct in_addr addr
;
2358 struct ip_mreq mreq
;
2359 struct ifnet
*ifp
= NULL
;
2360 struct ip_moptions
*imo
= *imop
;
2365 * No multicast option buffer attached to the pcb;
2366 * allocate one and initialize to default values.
2368 error
= ip_createmoptions(imop
);
2374 switch (sopt
->sopt_name
) {
2375 /* store an index number for the vif you wanna use in the send */
2377 case IP_MULTICAST_VIF
:
2378 if (legal_vif_num
== 0) {
2382 error
= sooptcopyin(sopt
, &i
, sizeof i
, sizeof i
);
2385 if (!legal_vif_num(i
) && (i
!= -1)) {
2389 imo
->imo_multicast_vif
= i
;
2391 #endif /* MROUTING */
2393 case IP_MULTICAST_IF
:
2395 * Select the interface for outgoing multicast packets.
2397 error
= sooptcopyin(sopt
, &addr
, sizeof addr
, sizeof addr
);
2401 * INADDR_ANY is used to remove a previous selection.
2402 * When no interface is selected, a default one is
2403 * chosen every time a multicast packet is sent.
2405 if (addr
.s_addr
== INADDR_ANY
) {
2406 imo
->imo_multicast_ifp
= NULL
;
2410 * The selected interface is identified by its local
2411 * IP address. Find the interface and confirm that
2412 * it supports multicasting.
2414 ifp
= ip_multicast_if(&addr
, &ifindex
);
2415 if (ifp
== NULL
|| (ifp
->if_flags
& IFF_MULTICAST
) == 0) {
2416 error
= EADDRNOTAVAIL
;
2419 imo
->imo_multicast_ifp
= ifp
;
2421 imo
->imo_multicast_addr
= addr
;
2423 imo
->imo_multicast_addr
.s_addr
= INADDR_ANY
;
2426 case IP_MULTICAST_TTL
:
2428 * Set the IP time-to-live for outgoing multicast packets.
2429 * The original multicast API required a char argument,
2430 * which is inconsistent with the rest of the socket API.
2431 * We allow either a char or an int.
2433 if (sopt
->sopt_valsize
== 1) {
2435 error
= sooptcopyin(sopt
, &ttl
, 1, 1);
2438 imo
->imo_multicast_ttl
= ttl
;
2441 error
= sooptcopyin(sopt
, &ttl
, sizeof ttl
,
2448 imo
->imo_multicast_ttl
= ttl
;
2452 case IP_MULTICAST_LOOP
:
2454 * Set the loopback flag for outgoing multicast packets.
2455 * Must be zero or one. The original multicast API required a
2456 * char argument, which is inconsistent with the rest
2457 * of the socket API. We allow either a char or an int.
2459 if (sopt
->sopt_valsize
== 1) {
2461 error
= sooptcopyin(sopt
, &loop
, 1, 1);
2464 imo
->imo_multicast_loop
= !!loop
;
2467 error
= sooptcopyin(sopt
, &loop
, sizeof loop
,
2471 imo
->imo_multicast_loop
= !!loop
;
2475 case IP_ADD_MEMBERSHIP
:
2477 * Add a multicast group membership.
2478 * Group must be a valid IP multicast address.
2480 error
= sooptcopyin(sopt
, &mreq
, sizeof mreq
, sizeof mreq
);
2484 error
= ip_addmembership(imo
, &mreq
);
2487 case IP_DROP_MEMBERSHIP
:
2489 * Drop a multicast group membership.
2490 * Group must be a valid IP multicast address.
2492 error
= sooptcopyin(sopt
, &mreq
, sizeof mreq
, sizeof mreq
);
2496 error
= ip_dropmembership(imo
, &mreq
);
2505 * If all options have default values, no need to keep the mbuf.
2507 if (imo
->imo_multicast_ifp
== NULL
&&
2508 imo
->imo_multicast_vif
== (u_long
)-1 &&
2509 imo
->imo_multicast_ttl
== IP_DEFAULT_MULTICAST_TTL
&&
2510 imo
->imo_multicast_loop
== IP_DEFAULT_MULTICAST_LOOP
&&
2511 imo
->imo_num_memberships
== 0) {
2512 FREE(*imop
, M_IPMOPTS
);
2520 * Set the IP multicast options in response to user setsockopt().
2522 __private_extern__
int
2524 struct ip_moptions
**imop
)
2526 struct ip_moptions
*imo
;
2527 imo
= (struct ip_moptions
*) _MALLOC(sizeof(*imo
), M_IPMOPTS
,
2533 imo
->imo_multicast_ifp
= NULL
;
2534 imo
->imo_multicast_addr
.s_addr
= INADDR_ANY
;
2535 imo
->imo_multicast_vif
= -1;
2536 imo
->imo_multicast_ttl
= IP_DEFAULT_MULTICAST_TTL
;
2537 imo
->imo_multicast_loop
= IP_DEFAULT_MULTICAST_LOOP
;
2538 imo
->imo_num_memberships
= 0;
2544 * Add membership to an IPv4 multicast.
2546 __private_extern__
int
2548 struct ip_moptions
*imo
,
2549 struct ip_mreq
*mreq
)
2552 struct sockaddr_in
*dst
;
2553 struct ifnet
*ifp
= NULL
;
2557 if (!IN_MULTICAST(ntohl(mreq
->imr_multiaddr
.s_addr
))) {
2562 * If no interface address was provided, use the interface of
2563 * the route to the given multicast address.
2565 if (mreq
->imr_interface
.s_addr
== INADDR_ANY
) {
2566 bzero((caddr_t
)&ro
, sizeof(ro
));
2567 dst
= (struct sockaddr_in
*)&ro
.ro_dst
;
2568 dst
->sin_len
= sizeof(*dst
);
2569 dst
->sin_family
= AF_INET
;
2570 dst
->sin_addr
= mreq
->imr_multiaddr
;
2571 lck_mtx_lock(rt_mtx
);
2572 rtalloc_ign_locked(&ro
, 0UL);
2573 if (ro
.ro_rt
!= NULL
) {
2574 ifp
= ro
.ro_rt
->rt_ifp
;
2575 rtfree_locked(ro
.ro_rt
);
2578 /* If there's no default route, try using loopback */
2579 mreq
->imr_interface
.s_addr
= INADDR_LOOPBACK
;
2581 lck_mtx_unlock(rt_mtx
);
2585 ifp
= ip_multicast_if(&mreq
->imr_interface
, NULL
);
2589 * See if we found an interface, and confirm that it
2590 * supports multicast.
2592 if (ifp
== NULL
|| (ifp
->if_flags
& IFF_MULTICAST
) == 0) {
2593 error
= EADDRNOTAVAIL
;
2597 * See if the membership already exists or if all the
2598 * membership slots are full.
2600 for (i
= 0; i
< imo
->imo_num_memberships
; ++i
) {
2601 if (imo
->imo_membership
[i
]->inm_ifp
== ifp
&&
2602 imo
->imo_membership
[i
]->inm_addr
.s_addr
2603 == mreq
->imr_multiaddr
.s_addr
)
2606 if (i
< imo
->imo_num_memberships
) {
2610 if (i
== IP_MAX_MEMBERSHIPS
) {
2611 error
= ETOOMANYREFS
;
2615 * Everything looks good; add a new record to the multicast
2616 * address list for the given interface.
2618 if ((imo
->imo_membership
[i
] =
2619 in_addmulti(&mreq
->imr_multiaddr
, ifp
)) == NULL
) {
2623 ++imo
->imo_num_memberships
;
2629 * Drop membership of an IPv4 multicast.
2631 __private_extern__
int
2633 struct ip_moptions
*imo
,
2634 struct ip_mreq
*mreq
)
2637 struct ifnet
* ifp
= NULL
;
2640 if (!IN_MULTICAST(ntohl(mreq
->imr_multiaddr
.s_addr
))) {
2646 * If an interface address was specified, get a pointer
2647 * to its ifnet structure.
2649 if (mreq
->imr_interface
.s_addr
== INADDR_ANY
)
2652 ifp
= ip_multicast_if(&mreq
->imr_interface
, NULL
);
2654 error
= EADDRNOTAVAIL
;
2659 * Find the membership in the membership array.
2661 for (i
= 0; i
< imo
->imo_num_memberships
; ++i
) {
2663 imo
->imo_membership
[i
]->inm_ifp
== ifp
) &&
2664 imo
->imo_membership
[i
]->inm_addr
.s_addr
==
2665 mreq
->imr_multiaddr
.s_addr
)
2668 if (i
== imo
->imo_num_memberships
) {
2669 error
= EADDRNOTAVAIL
;
2673 * Give up the multicast address record to which the
2674 * membership points.
2676 in_delmulti(&imo
->imo_membership
[i
]);
2678 * Remove the gap in the membership array.
2680 for (++i
; i
< imo
->imo_num_memberships
; ++i
)
2681 imo
->imo_membership
[i
-1] = imo
->imo_membership
[i
];
2682 --imo
->imo_num_memberships
;
2688 * Return the IP multicast options in response to user getsockopt().
2691 ip_getmoptions(sopt
, imo
)
2692 struct sockopt
*sopt
;
2693 register struct ip_moptions
*imo
;
2695 struct in_addr addr
;
2696 struct in_ifaddr
*ia
;
2701 switch (sopt
->sopt_name
) {
2703 case IP_MULTICAST_VIF
:
2705 optval
= imo
->imo_multicast_vif
;
2708 error
= sooptcopyout(sopt
, &optval
, sizeof optval
);
2710 #endif /* MROUTING */
2712 case IP_MULTICAST_IF
:
2713 if (imo
== NULL
|| imo
->imo_multicast_ifp
== NULL
)
2714 addr
.s_addr
= INADDR_ANY
;
2715 else if (imo
->imo_multicast_addr
.s_addr
) {
2716 /* return the value user has set */
2717 addr
= imo
->imo_multicast_addr
;
2719 IFP_TO_IA(imo
->imo_multicast_ifp
, ia
);
2720 addr
.s_addr
= (ia
== NULL
) ? INADDR_ANY
2721 : IA_SIN(ia
)->sin_addr
.s_addr
;
2723 error
= sooptcopyout(sopt
, &addr
, sizeof addr
);
2726 case IP_MULTICAST_TTL
:
2728 optval
= coptval
= IP_DEFAULT_MULTICAST_TTL
;
2730 optval
= coptval
= imo
->imo_multicast_ttl
;
2731 if (sopt
->sopt_valsize
== 1)
2732 error
= sooptcopyout(sopt
, &coptval
, 1);
2734 error
= sooptcopyout(sopt
, &optval
, sizeof optval
);
2737 case IP_MULTICAST_LOOP
:
2739 optval
= coptval
= IP_DEFAULT_MULTICAST_LOOP
;
2741 optval
= coptval
= imo
->imo_multicast_loop
;
2742 if (sopt
->sopt_valsize
== 1)
2743 error
= sooptcopyout(sopt
, &coptval
, 1);
2745 error
= sooptcopyout(sopt
, &optval
, sizeof optval
);
2749 error
= ENOPROTOOPT
;
2756 * Discard the IP multicast options.
2759 ip_freemoptions(imo
)
2760 register struct ip_moptions
*imo
;
2765 for (i
= 0; i
< imo
->imo_num_memberships
; ++i
)
2766 in_delmulti(&imo
->imo_membership
[i
]);
2767 FREE(imo
, M_IPMOPTS
);
2772 * Routine called from ip_output() to loop back a copy of an IP multicast
2773 * packet to the input queue of a specified interface. Note that this
2774 * calls the output routine of the loopback "driver", but with an interface
2775 * pointer that might NOT be a loopback interface -- evil, but easier than
2776 * replicating that code here.
2779 ip_mloopback(ifp
, m
, dst
, hlen
)
2781 register struct mbuf
*m
;
2782 register struct sockaddr_in
*dst
;
2785 register struct ip
*ip
;
2787 int sw_csum
= (apple_hwcksum_tx
== 0);
2789 copym
= m_copy(m
, 0, M_COPYALL
);
2790 if (copym
!= NULL
&& (copym
->m_flags
& M_EXT
|| copym
->m_len
< hlen
))
2791 copym
= m_pullup(copym
, hlen
);
2797 * We don't bother to fragment if the IP length is greater
2798 * than the interface's MTU. Can this possibly matter?
2800 ip
= mtod(copym
, struct ip
*);
2804 ip
->ip_sum
= in_cksum(copym
, hlen
);
2807 * It's not clear whether there are any lingering
2808 * reentrancy problems in other areas which might
2809 * be exposed by using ip_input directly (in
2810 * particular, everything which modifies the packet
2811 * in-place). Yet another option is using the
2812 * protosw directly to deliver the looped back
2813 * packet. For the moment, we'll err on the side
2814 * of safety by using if_simloop().
2817 if (dst
->sin_family
!= AF_INET
) {
2818 printf("ip_mloopback: bad address family %d\n",
2820 dst
->sin_family
= AF_INET
;
2825 * Mark checksum as valid or calculate checksum for loopback.
2827 * This is done this way because we have to embed the ifp of
2828 * the interface we will send the original copy of the packet
2829 * out on in the mbuf. ip_input will check if_hwassist of the
2830 * embedded ifp and ignore all csum_flags if if_hwassist is 0.
2831 * The UDP checksum has not been calculated yet.
2833 if (sw_csum
|| (copym
->m_pkthdr
.csum_flags
& CSUM_DELAY_DATA
)) {
2834 if (!sw_csum
&& IF_HWASSIST_CSUM_FLAGS(ifp
->if_hwassist
)) {
2835 copym
->m_pkthdr
.csum_flags
|=
2836 CSUM_DATA_VALID
| CSUM_PSEUDO_HDR
|
2837 CSUM_IP_CHECKED
| CSUM_IP_VALID
;
2838 copym
->m_pkthdr
.csum_data
= 0xffff;
2841 in_delayed_cksum(copym
);
2848 * We need to send all loopback traffic down to dlil in case
2849 * a filter has tapped-in.
2853 * Stuff the 'real' ifp into the pkthdr, to be used in matching
2854 * in ip_input(); we need the loopback ifp/dl_tag passed as args
2855 * to make the loopback driver compliant with the data link
2859 copym
->m_pkthdr
.rcvif
= ifp
;
2860 dlil_output(lo_ifp
, PF_INET
, copym
, 0,
2861 (struct sockaddr
*) dst
, 0);
2863 printf("Warning: ip_output call to dlil_find_dltag failed!\n");