/*
- * Copyright (c) 2009-2011 Apple Inc. All rights reserved.
+ * Copyright (c) 2009-2013 Apple Inc. All rights reserved.
*
* @APPLE_OSREFERENCE_LICENSE_HEADER_START@
*
int error, type = 0, code = 0;
boolean_t proxy = FALSE;
struct mbuf *mcopy = NULL;
- struct ifnet *ifp, *origifp; /* maybe unnecessary */
- u_int32_t inzone, outzone;
+ struct ifnet *ifp, *rcvifp, *origifp; /* maybe unnecessary */
+ u_int32_t inzone, outzone, len;
struct in6_addr src_in6, dst_in6;
+ uint64_t curtime = net_uptime();
#if IPSEC
struct secpolicy *sp = NULL;
#endif
- struct timeval timenow;
unsigned int ifscope = IFSCOPE_NONE;
#if PF
struct pf_mtag *pf_mtag;
#endif /* PF */
- getmicrotime(&timenow);
+ /*
+ * In the prefix proxying case, the route to the proxied node normally
+ * gets created by nd6_prproxy_ns_output(), as part of forwarding a
+ * NS (NUD/AR) packet to the proxied node. In the event that such
+ * packet did not arrive in time before the correct route gets created,
+ * ip6_input() would have performed a rtalloc() which most likely will
+ * create the wrong cloned route; this route points back to the same
+ * interface as the inbound interface, since the parent non-scoped
+ * prefix route points there. Therefore we check if that is the case
+ * and perform the necessary fixup to get the correct route installed.
+ */
+ if (!srcrt && nd6_prproxy &&
+ (rt = ip6forward_rt->ro_rt) != NULL && (rt->rt_flags & RTF_PROXY)) {
+ nd6_proxy_find_fwdroute(m->m_pkthdr.rcvif, ip6forward_rt);
+ if ((rt = ip6forward_rt->ro_rt) != NULL)
+ ifscope = rt->rt_ifp->if_index;
+ }
+
#if PF
pf_mtag = pf_find_mtag(m);
if (pf_mtag != NULL && pf_mtag->pftag_rtableid != IFSCOPE_NONE)
RT_LOCK(rt);
if (rt->rt_ifp->if_index != ifscope) {
RT_UNLOCK(rt);
- rtfree(rt);
- rt = ip6forward_rt->ro_rt = NULL;
+ ROUTE_RELEASE(ip6forward_rt);
+ rt = NULL;
} else {
RT_UNLOCK(rt);
}
#endif /*IPSEC*/
/*
- * Do not forward packets to multicast destination (should be handled
- * by ip6_mforward().
+ * Do not forward packets to multicast destination.
* Do not forward packets with unspecified source. It was discussed
* in July 2000, on ipngwg mailing list.
*/
IN6_IS_ADDR_UNSPECIFIED(&ip6->ip6_src)) {
ip6stat.ip6s_cantforward++;
/* XXX in6_ifstat_inc(rt->rt_ifp, ifs6_in_discard) */
- if (ip6_log_time + ip6_log_interval < timenow.tv_sec) {
- ip6_log_time = timenow.tv_sec;
+ if (ip6_log_time + ip6_log_interval < curtime) {
+ ip6_log_time = curtime;
log(LOG_DEBUG,
"cannot forward "
"from %s to %s nxt %d received on %s\n",
error = ipsec6_output_tunnel(&state, sp, 0);
key_freesp(sp, KEY_SADB_UNLOCKED);
- if (state.tunneled == 4)
+ if (state.tunneled == 4) {
+ ROUTE_RELEASE(&state.ro);
return (NULL); /* packet is gone - sent over IPv4 */
-
- m = state.m;
- if (state.ro.ro_rt) {
- rtfree(state.ro.ro_rt);
- state.ro.ro_rt = NULL;
}
+
+ m = state.m;
+ ROUTE_RELEASE(&state.ro);
+
if (error) {
/* mbuf is already reclaimed in ipsec6_output_tunnel. */
switch (error) {
return (NULL);
}
}
- skip_ipsec:
#endif /* IPSEC */
+ skip_ipsec:
dst = (struct sockaddr_in6 *)&ip6forward_rt->ro_dst;
if ((rt = ip6forward_rt->ro_rt) != NULL) {
RT_ADDREF_LOCKED(rt);
}
+ VERIFY(rt == NULL || rt == ip6forward_rt->ro_rt);
if (!srcrt) {
/*
* ip6forward_rt->ro_dst.sin6_addr is equal to ip6->ip6_dst
*/
- if (rt == NULL || !(rt->rt_flags & RTF_UP) ||
- rt->generation_id != route_generation) {
+ if (ROUTE_UNUSABLE(ip6forward_rt)) {
if (rt != NULL) {
/* Release extra ref */
RT_REMREF_LOCKED(rt);
RT_UNLOCK(rt);
- rtfree(rt);
- ip6forward_rt->ro_rt = NULL;
}
+ ROUTE_RELEASE(ip6forward_rt);
+
/* this probably fails but give it a try again */
rtalloc_scoped_ign((struct route *)ip6forward_rt,
RTF_PRCLONING, ifscope);
return (NULL);
}
RT_LOCK_ASSERT_HELD(rt);
- } else if (rt == NULL || !(rt->rt_flags & RTF_UP) ||
- !IN6_ARE_ADDR_EQUAL(&ip6->ip6_dst, &dst->sin6_addr) ||
- rt->generation_id != route_generation) {
+ } else if (ROUTE_UNUSABLE(ip6forward_rt) ||
+ !IN6_ARE_ADDR_EQUAL(&ip6->ip6_dst, &dst->sin6_addr)) {
if (rt != NULL) {
/* Release extra ref */
RT_REMREF_LOCKED(rt);
RT_UNLOCK(rt);
- rtfree(rt);
- ip6forward_rt->ro_rt = NULL;
}
+ ROUTE_RELEASE(ip6forward_rt);
+
bzero(dst, sizeof(*dst));
dst->sin6_len = sizeof(struct sockaddr_in6);
dst->sin6_family = AF_INET6;
ip6stat.ip6s_badscope++;
in6_ifstat_inc(rt->rt_ifp, ifs6_in_discard);
- if (ip6_log_time + ip6_log_interval < timenow.tv_sec) {
- ip6_log_time = timenow.tv_sec;
+ if (ip6_log_time + ip6_log_interval < curtime) {
+ ip6_log_time = curtime;
log(LOG_DEBUG,
"cannot forward "
"src %s, dst %s, nxt %d, rcvif %s, outif %s\n",
* rthdr. (itojun)
*/
#if 1
- if (0)
+ if ((0))
#else
if ((rt->rt_flags & (RTF_BLACKHOLE|RTF_REJECT)) == 0)
#endif
}
/* we can just use rcvif in forwarding. */
- origifp = m->m_pkthdr.rcvif;
- }
- else
+ origifp = rcvifp = m->m_pkthdr.rcvif;
+ } else if (nd6_prproxy) {
+ /*
+ * In the prefix proxying case, we need to inform nd6_output()
+ * about the inbound interface, so that any subsequent NS
+ * packets generated by nd6_prproxy_ns_output() will not be
+ * sent back to that same interface.
+ */
+ origifp = rcvifp = m->m_pkthdr.rcvif;
+ } else {
+ rcvifp = m->m_pkthdr.rcvif;
origifp = rt->rt_ifp;
+ }
/*
* clear embedded scope identifiers if necessary.
* in6_clearscope will touch the addresses only when necessary.
* If this is to be processed locally, let ip6_input have it.
*/
if (proxy) {
- VERIFY(m->m_pkthdr.aux_flags & MAUXF_PROXY_DST);
+ VERIFY(m->m_pkthdr.pkt_flags & PKTF_PROXY_DST);
/* Release extra ref */
RT_REMREF(rt);
if (mcopy != NULL)
ip6 = mtod(m, struct ip6_hdr *);
#endif /* PF */
+ /* Mark this packet as being forwarded from another interface */
+ m->m_pkthdr.pkt_flags |= PKTF_FORWARDED;
+ len = m_pktlen(m);
+
error = nd6_output(ifp, origifp, m, dst, rt, NULL);
if (error) {
in6_ifstat_inc(ifp, ifs6_out_discard);
ip6stat.ip6s_cantforward++;
} else {
+ /*
+ * Increment stats on the source interface; the ones
+ * for destination interface has been taken care of
+ * during output above by virtue of PKTF_FORWARDED.
+ */
+ rcvifp->if_fpackets++;
+ rcvifp->if_fbytes += len;
+
ip6stat.ip6s_forward++;
in6_ifstat_inc(ifp, ifs6_out_forward);
if (type)
projects / apple / xnu.git / blobdiff