Home | History | Annotate | Line # | Download | only in netipsec
ipsec_input.c revision 1.66
      1  1.66      maxv /*	$NetBSD: ipsec_input.c,v 1.66 2018/04/19 08:27:38 maxv Exp $	*/
      2  1.66      maxv /*	$FreeBSD: ipsec_input.c,v 1.2.4.2 2003/03/28 20:32:53 sam Exp $	*/
      3   1.7   thorpej /*	$OpenBSD: ipsec_input.c,v 1.63 2003/02/20 18:35:43 deraadt Exp $	*/
      4   1.7   thorpej 
      5   1.7   thorpej /*
      6   1.7   thorpej  * The authors of this code are John Ioannidis (ji (at) tla.org),
      7   1.7   thorpej  * Angelos D. Keromytis (kermit (at) csd.uch.gr) and
      8   1.7   thorpej  * Niels Provos (provos (at) physnet.uni-hamburg.de).
      9   1.7   thorpej  *
     10   1.7   thorpej  * This code was written by John Ioannidis for BSD/OS in Athens, Greece,
     11   1.7   thorpej  * in November 1995.
     12   1.7   thorpej  *
     13   1.7   thorpej  * Ported to OpenBSD and NetBSD, with additional transforms, in December 1996,
     14   1.7   thorpej  * by Angelos D. Keromytis.
     15   1.7   thorpej  *
     16   1.7   thorpej  * Additional transforms and features in 1997 and 1998 by Angelos D. Keromytis
     17   1.7   thorpej  * and Niels Provos.
     18   1.7   thorpej  *
     19   1.7   thorpej  * Additional features in 1999 by Angelos D. Keromytis.
     20   1.7   thorpej  *
     21   1.7   thorpej  * Copyright (C) 1995, 1996, 1997, 1998, 1999 by John Ioannidis,
     22   1.7   thorpej  * Angelos D. Keromytis and Niels Provos.
     23   1.7   thorpej  * Copyright (c) 2001, Angelos D. Keromytis.
     24   1.7   thorpej  *
     25   1.7   thorpej  * Permission to use, copy, and modify this software with or without fee
     26   1.7   thorpej  * is hereby granted, provided that this entire notice is included in
     27   1.7   thorpej  * all copies of any software which is or includes a copy or
     28   1.7   thorpej  * modification of this software.
     29   1.7   thorpej  * You may use this code under the GNU public license if you so wish. Please
     30   1.7   thorpej  * contribute changes back to the authors under this freer than GPL license
     31   1.7   thorpej  * so that we may further the use of strong encryption without limitations to
     32   1.7   thorpej  * all.
     33   1.7   thorpej  *
     34   1.7   thorpej  * THIS SOFTWARE IS BEING PROVIDED "AS IS", WITHOUT ANY EXPRESS OR
     35   1.7   thorpej  * IMPLIED WARRANTY. IN PARTICULAR, NONE OF THE AUTHORS MAKES ANY
     36   1.7   thorpej  * REPRESENTATION OR WARRANTY OF ANY KIND CONCERNING THE
     37   1.7   thorpej  * MERCHANTABILITY OF THIS SOFTWARE OR ITS FITNESS FOR ANY PARTICULAR
     38   1.7   thorpej  * PURPOSE.
     39   1.7   thorpej  */
     40   1.1  jonathan 
     41   1.1  jonathan #include <sys/cdefs.h>
     42  1.66      maxv __KERNEL_RCSID(0, "$NetBSD: ipsec_input.c,v 1.66 2018/04/19 08:27:38 maxv Exp $");
     43   1.1  jonathan 
     44   1.1  jonathan /*
     45   1.1  jonathan  * IPsec input processing.
     46   1.1  jonathan  */
     47   1.1  jonathan 
     48  1.38     ozaki #if defined(_KERNEL_OPT)
     49   1.1  jonathan #include "opt_inet.h"
     50  1.38     ozaki #endif
     51   1.1  jonathan 
     52   1.1  jonathan #include <sys/param.h>
     53   1.1  jonathan #include <sys/systm.h>
     54   1.1  jonathan #include <sys/mbuf.h>
     55   1.1  jonathan #include <sys/domain.h>
     56   1.1  jonathan #include <sys/protosw.h>
     57   1.1  jonathan #include <sys/socket.h>
     58   1.1  jonathan #include <sys/errno.h>
     59   1.1  jonathan #include <sys/syslog.h>
     60   1.1  jonathan 
     61   1.1  jonathan #include <net/if.h>
     62   1.1  jonathan #include <net/route.h>
     63   1.1  jonathan 
     64   1.1  jonathan #include <netinet/in.h>
     65   1.1  jonathan #include <netinet/in_systm.h>
     66   1.1  jonathan #include <netinet/ip.h>
     67   1.1  jonathan #include <netinet/ip_var.h>
     68   1.1  jonathan #include <netinet/in_var.h>
     69  1.29  drochner #include <netinet/in_proto.h>
     70  1.44  christos #include <netinet/udp.h>
     71  1.44  christos #include <netinet/tcp.h>
     72   1.1  jonathan 
     73   1.1  jonathan #include <netinet/ip6.h>
     74   1.1  jonathan #ifdef INET6
     75   1.1  jonathan #include <netinet6/ip6_var.h>
     76  1.19   thorpej #include <netinet6/ip6_private.h>
     77  1.26  drochner #include <netinet6/scope6_var.h>
     78   1.1  jonathan #endif
     79   1.1  jonathan #include <netinet/in_pcb.h>
     80   1.1  jonathan #ifdef INET6
     81   1.1  jonathan #include <netinet/icmp6.h>
     82   1.1  jonathan #endif
     83   1.1  jonathan 
     84   1.1  jonathan #include <netipsec/ipsec.h>
     85  1.20   thorpej #include <netipsec/ipsec_private.h>
     86   1.1  jonathan #ifdef INET6
     87   1.1  jonathan #include <netipsec/ipsec6.h>
     88   1.1  jonathan #endif
     89   1.1  jonathan #include <netipsec/ah_var.h>
     90   1.1  jonathan #include <netipsec/esp.h>
     91   1.1  jonathan #include <netipsec/esp_var.h>
     92   1.1  jonathan #include <netipsec/ipcomp_var.h>
     93   1.1  jonathan 
     94   1.6       tls #include <netipsec/key.h>
     95   1.6       tls #include <netipsec/keydb.h>
     96   1.1  jonathan 
     97   1.1  jonathan #include <netipsec/xform.h>
     98   1.1  jonathan #include <netinet6/ip6protosw.h>
     99   1.1  jonathan 
    100  1.20   thorpej #define	IPSEC_ISTAT(p, x, y, z)						\
    101  1.20   thorpej do {									\
    102  1.20   thorpej 	switch (p) {							\
    103  1.20   thorpej 	case IPPROTO_ESP:						\
    104  1.20   thorpej 		ESP_STATINC(x);						\
    105  1.20   thorpej 		break;							\
    106  1.20   thorpej 	case IPPROTO_AH:						\
    107  1.20   thorpej 		AH_STATINC(y);						\
    108  1.20   thorpej 		break;							\
    109  1.20   thorpej 	default:							\
    110  1.20   thorpej 		IPCOMP_STATINC(z);					\
    111  1.20   thorpej 		break;							\
    112  1.20   thorpej 	}								\
    113  1.20   thorpej } while (/*CONSTCOND*/0)
    114   1.1  jonathan 
    115   1.1  jonathan /*
    116  1.44  christos  * fixup TCP/UDP checksum
    117  1.44  christos  *
    118  1.44  christos  * XXX: if we have NAT-OA payload from IKE server,
    119  1.44  christos  *      we must do the differential update of checksum.
    120  1.44  christos  *
    121  1.44  christos  * XXX: NAT-OAi/NAT-OAr drived from IKE initiator/responder.
    122  1.44  christos  *      how to know the IKE side from kernel?
    123  1.44  christos  */
    124  1.44  christos static struct mbuf *
    125  1.44  christos ipsec4_fixup_checksum(struct mbuf *m)
    126  1.44  christos {
    127  1.52     ozaki 	struct ip *ip;
    128  1.52     ozaki 	struct tcphdr *th;
    129  1.52     ozaki 	struct udphdr *uh;
    130  1.52     ozaki 	int poff, off;
    131  1.52     ozaki 	int plen;
    132  1.52     ozaki 
    133  1.53     ozaki 	if (m->m_len < sizeof(*ip)) {
    134  1.52     ozaki 		m = m_pullup(m, sizeof(*ip));
    135  1.53     ozaki 		if (m == NULL)
    136  1.53     ozaki 			return NULL;
    137  1.53     ozaki 	}
    138  1.59      maxv 	ip = mtod(m, struct ip *);
    139  1.52     ozaki 	poff = ip->ip_hl << 2;
    140  1.52     ozaki 	plen = ntohs(ip->ip_len) - poff;
    141  1.52     ozaki 
    142  1.52     ozaki 	switch (ip->ip_p) {
    143  1.52     ozaki 	case IPPROTO_TCP:
    144  1.52     ozaki 		IP6_EXTHDR_GET(th, struct tcphdr *, m, poff, sizeof(*th));
    145  1.52     ozaki 		if (th == NULL)
    146  1.52     ozaki 			return NULL;
    147  1.52     ozaki 		off = th->th_off << 2;
    148  1.52     ozaki 		if (off < sizeof(*th) || off > plen) {
    149  1.52     ozaki 			m_freem(m);
    150  1.52     ozaki 			return NULL;
    151  1.52     ozaki 		}
    152  1.52     ozaki 		th->th_sum = 0;
    153  1.52     ozaki 		th->th_sum = in4_cksum(m, IPPROTO_TCP, poff, plen);
    154  1.52     ozaki 		break;
    155  1.52     ozaki 	case IPPROTO_UDP:
    156  1.52     ozaki 		IP6_EXTHDR_GET(uh, struct udphdr *, m, poff, sizeof(*uh));
    157  1.52     ozaki 		if (uh == NULL)
    158  1.52     ozaki 			return NULL;
    159  1.59      maxv 		off = sizeof(*uh);
    160  1.59      maxv 		if (off > plen) {
    161  1.52     ozaki 			m_freem(m);
    162  1.52     ozaki 			return NULL;
    163  1.52     ozaki 		}
    164  1.52     ozaki 		uh->uh_sum = 0;
    165  1.52     ozaki 		uh->uh_sum = in4_cksum(m, IPPROTO_UDP, poff, plen);
    166  1.52     ozaki 		break;
    167  1.52     ozaki 	default:
    168  1.59      maxv 		/* no checksum */
    169  1.52     ozaki 		return m;
    170  1.52     ozaki 	}
    171  1.44  christos 
    172  1.52     ozaki 	return m;
    173  1.44  christos }
    174  1.44  christos 
    175  1.44  christos /*
    176   1.1  jonathan  * ipsec_common_input gets called when an IPsec-protected packet
    177  1.64      maxv  * is received by IPv4 or IPv6.  Its job is to find the right SA
    178  1.64      maxv  * and call the appropriate transform.  The transform callback
    179   1.1  jonathan  * takes care of further processing (like ingress filtering).
    180   1.1  jonathan  */
    181   1.1  jonathan static int
    182   1.1  jonathan ipsec_common_input(struct mbuf *m, int skip, int protoff, int af, int sproto)
    183   1.1  jonathan {
    184  1.42       ryo 	char buf[IPSEC_ADDRSTRLEN];
    185   1.1  jonathan 	union sockaddr_union dst_address;
    186   1.1  jonathan 	struct secasvar *sav;
    187   1.1  jonathan 	u_int32_t spi;
    188  1.30  christos 	u_int16_t sport;
    189  1.30  christos 	u_int16_t dport;
    190   1.1  jonathan 	int s, error;
    191   1.1  jonathan 
    192  1.20   thorpej 	IPSEC_ISTAT(sproto, ESP_STAT_INPUT, AH_STAT_INPUT,
    193  1.20   thorpej 		IPCOMP_STAT_INPUT);
    194   1.1  jonathan 
    195  1.40     ozaki 	KASSERT(m != NULL);
    196   1.1  jonathan 
    197   1.1  jonathan 	if ((sproto == IPPROTO_ESP && !esp_enable) ||
    198   1.1  jonathan 	    (sproto == IPPROTO_AH && !ah_enable) ||
    199   1.1  jonathan 	    (sproto == IPPROTO_IPCOMP && !ipcomp_enable)) {
    200   1.1  jonathan 		m_freem(m);
    201  1.20   thorpej 		IPSEC_ISTAT(sproto, ESP_STAT_PDROPS, AH_STAT_PDROPS,
    202  1.20   thorpej 		    IPCOMP_STAT_PDROPS);
    203   1.1  jonathan 		return EOPNOTSUPP;
    204   1.1  jonathan 	}
    205   1.1  jonathan 
    206  1.59      maxv 	if (m->m_pkthdr.len - skip < 2 * sizeof(u_int32_t)) {
    207   1.1  jonathan 		m_freem(m);
    208  1.20   thorpej 		IPSEC_ISTAT(sproto, ESP_STAT_HDROPS, AH_STAT_HDROPS,
    209  1.20   thorpej 		    IPCOMP_STAT_HDROPS);
    210  1.43     ozaki 		IPSECLOG(LOG_DEBUG, "packet too small\n");
    211   1.1  jonathan 		return EINVAL;
    212   1.1  jonathan 	}
    213   1.1  jonathan 
    214   1.1  jonathan 	/* Retrieve the SPI from the relevant IPsec header */
    215  1.59      maxv 	if (sproto == IPPROTO_ESP) {
    216  1.16  degroote 		m_copydata(m, skip, sizeof(u_int32_t), &spi);
    217  1.59      maxv 	} else if (sproto == IPPROTO_AH) {
    218  1.16  degroote 		m_copydata(m, skip + sizeof(u_int32_t), sizeof(u_int32_t), &spi);
    219  1.59      maxv 	} else if (sproto == IPPROTO_IPCOMP) {
    220   1.1  jonathan 		u_int16_t cpi;
    221  1.16  degroote 		m_copydata(m, skip + sizeof(u_int16_t), sizeof(u_int16_t), &cpi);
    222   1.1  jonathan 		spi = ntohl(htons(cpi));
    223  1.17  degroote 	} else {
    224  1.59      maxv 		panic("%s called with bad protocol number: %d\n", __func__,
    225  1.59      maxv 		    sproto);
    226   1.1  jonathan 	}
    227  1.17  degroote 
    228  1.17  degroote 	/* find the source port for NAT-T */
    229  1.30  christos 	nat_t_ports_get(m, &dport, &sport);
    230   1.1  jonathan 
    231   1.1  jonathan 	/*
    232   1.1  jonathan 	 * Find the SA and (indirectly) call the appropriate
    233   1.1  jonathan 	 * kernel crypto routine. The resulting mbuf chain is a valid
    234   1.1  jonathan 	 * IP packet ready to go through input processing.
    235   1.1  jonathan 	 */
    236  1.59      maxv 	memset(&dst_address, 0, sizeof(dst_address));
    237   1.1  jonathan 	dst_address.sa.sa_family = af;
    238   1.1  jonathan 	switch (af) {
    239   1.1  jonathan #ifdef INET
    240   1.1  jonathan 	case AF_INET:
    241   1.1  jonathan 		dst_address.sin.sin_len = sizeof(struct sockaddr_in);
    242   1.1  jonathan 		m_copydata(m, offsetof(struct ip, ip_dst),
    243   1.1  jonathan 		    sizeof(struct in_addr),
    244  1.16  degroote 		    &dst_address.sin.sin_addr);
    245   1.1  jonathan 		break;
    246  1.59      maxv #endif
    247   1.1  jonathan #ifdef INET6
    248   1.1  jonathan 	case AF_INET6:
    249   1.1  jonathan 		dst_address.sin6.sin6_len = sizeof(struct sockaddr_in6);
    250   1.1  jonathan 		m_copydata(m, offsetof(struct ip6_hdr, ip6_dst),
    251   1.1  jonathan 		    sizeof(struct in6_addr),
    252  1.16  degroote 		    &dst_address.sin6.sin6_addr);
    253  1.26  drochner 		if (sa6_recoverscope(&dst_address.sin6)) {
    254  1.26  drochner 			m_freem(m);
    255  1.26  drochner 			return EINVAL;
    256  1.26  drochner 		}
    257   1.1  jonathan 		break;
    258  1.59      maxv #endif
    259   1.1  jonathan 	default:
    260  1.43     ozaki 		IPSECLOG(LOG_DEBUG, "unsupported protocol family %u\n", af);
    261   1.1  jonathan 		m_freem(m);
    262  1.20   thorpej 		IPSEC_ISTAT(sproto, ESP_STAT_NOPF, AH_STAT_NOPF,
    263  1.20   thorpej 		    IPCOMP_STAT_NOPF);
    264   1.1  jonathan 		return EPFNOSUPPORT;
    265   1.1  jonathan 	}
    266   1.1  jonathan 
    267   1.1  jonathan 	s = splsoftnet();
    268   1.1  jonathan 
    269  1.47     ozaki 	/* NB: only pass dst since key_lookup_sa follows RFC2401 */
    270  1.47     ozaki 	sav = KEY_LOOKUP_SA(&dst_address, sproto, spi, sport, dport);
    271   1.1  jonathan 	if (sav == NULL) {
    272  1.43     ozaki 		IPSECLOG(LOG_DEBUG,
    273  1.43     ozaki 		    "no key association found for SA %s/%08lx/%u/%u\n",
    274  1.43     ozaki 		    ipsec_address(&dst_address, buf, sizeof(buf)),
    275  1.43     ozaki 		    (u_long) ntohl(spi), sproto, ntohs(dport));
    276  1.20   thorpej 		IPSEC_ISTAT(sproto, ESP_STAT_NOTDB, AH_STAT_NOTDB,
    277  1.20   thorpej 		    IPCOMP_STAT_NOTDB);
    278   1.1  jonathan 		splx(s);
    279   1.1  jonathan 		m_freem(m);
    280   1.1  jonathan 		return ENOENT;
    281   1.1  jonathan 	}
    282   1.1  jonathan 
    283  1.46     ozaki 	KASSERT(sav->tdb_xform != NULL);
    284   1.1  jonathan 
    285   1.1  jonathan 	/*
    286   1.1  jonathan 	 * Call appropriate transform and return -- callback takes care of
    287   1.1  jonathan 	 * everything else.
    288   1.1  jonathan 	 */
    289   1.1  jonathan 	error = (*sav->tdb_xform->xf_input)(m, sav, skip, protoff);
    290  1.51     ozaki 	KEY_SA_UNREF(&sav);
    291   1.1  jonathan 	splx(s);
    292   1.1  jonathan 	return error;
    293   1.1  jonathan }
    294   1.1  jonathan 
    295   1.1  jonathan #ifdef INET
    296   1.1  jonathan /*
    297   1.1  jonathan  * Common input handler for IPv4 AH, ESP, and IPCOMP.
    298   1.1  jonathan  */
    299   1.2  jonathan void
    300   1.1  jonathan ipsec4_common_input(struct mbuf *m, ...)
    301   1.1  jonathan {
    302   1.1  jonathan 	va_list ap;
    303   1.1  jonathan 	int off, nxt;
    304   1.1  jonathan 
    305   1.1  jonathan 	va_start(ap, m);
    306   1.1  jonathan 	off = va_arg(ap, int);
    307   1.1  jonathan 	nxt = va_arg(ap, int);
    308   1.1  jonathan 	va_end(ap);
    309   1.1  jonathan 
    310  1.59      maxv 	(void)ipsec_common_input(m, off, offsetof(struct ip, ip_p),
    311  1.59      maxv 	    AF_INET, nxt);
    312   1.1  jonathan }
    313   1.1  jonathan 
    314   1.1  jonathan /*
    315   1.1  jonathan  * IPsec input callback for INET protocols.
    316   1.1  jonathan  * This routine is called as the transform callback.
    317   1.1  jonathan  * Takes care of filtering and other sanity checks on
    318   1.1  jonathan  * the processed packet.
    319   1.1  jonathan  */
    320   1.1  jonathan int
    321   1.1  jonathan ipsec4_common_input_cb(struct mbuf *m, struct secasvar *sav,
    322  1.45     ozaki     int skip, int protoff)
    323   1.1  jonathan {
    324  1.31       mrg 	int prot, af __diagused, sproto;
    325   1.1  jonathan 	struct ip *ip;
    326   1.1  jonathan 	struct secasindex *saidx;
    327   1.1  jonathan 	int error;
    328   1.1  jonathan 
    329   1.1  jonathan 	IPSEC_SPLASSERT_SOFTNET("ipsec4_common_input_cb");
    330   1.1  jonathan 
    331  1.60      maxv 	if (__predict_false(m == NULL)) {
    332  1.60      maxv 		panic("%s: NULL mbuf", __func__);
    333  1.60      maxv 	}
    334  1.61      maxv 	if (__predict_false(skip < sizeof(struct ip))) {
    335  1.61      maxv 		panic("%s: short skip", __func__);
    336  1.61      maxv 	}
    337  1.60      maxv 
    338  1.40     ozaki 	KASSERT(sav != NULL);
    339   1.1  jonathan 	saidx = &sav->sah->saidx;
    340   1.1  jonathan 	af = saidx->dst.sa.sa_family;
    341  1.40     ozaki 	KASSERTMSG(af == AF_INET, "unexpected af %u", af);
    342   1.1  jonathan 	sproto = saidx->proto;
    343  1.40     ozaki 	KASSERTMSG(sproto == IPPROTO_ESP || sproto == IPPROTO_AH ||
    344  1.40     ozaki 	    sproto == IPPROTO_IPCOMP,
    345  1.40     ozaki 	    "unexpected security protocol %u", sproto);
    346   1.1  jonathan 
    347  1.61      maxv 	/*
    348  1.61      maxv 	 * Update the IPv4 header. The length of the packet may have changed,
    349  1.61      maxv 	 * so fix it, and recompute the checksum.
    350  1.61      maxv 	 */
    351  1.61      maxv 	if (m->m_len < skip && (m = m_pullup(m, skip)) == NULL) {
    352  1.61      maxv 		char buf[IPSEC_ADDRSTRLEN];
    353  1.44  christos cantpull:
    354  1.61      maxv 		IPSECLOG(LOG_DEBUG,
    355  1.61      maxv 		    "processing failed for SA %s/%08lx\n",
    356  1.61      maxv 		    ipsec_address(&sav->sah->saidx.dst, buf,
    357  1.61      maxv 		    sizeof(buf)), (u_long) ntohl(sav->spi));
    358  1.61      maxv 		IPSEC_ISTAT(sproto, ESP_STAT_HDROPS, AH_STAT_HDROPS,
    359  1.61      maxv 		    IPCOMP_STAT_HDROPS);
    360  1.61      maxv 		error = ENOBUFS;
    361  1.61      maxv 		goto bad;
    362  1.29  drochner 	}
    363  1.61      maxv 	ip = mtod(m, struct ip *);
    364  1.61      maxv 	ip->ip_len = htons(m->m_pkthdr.len);
    365  1.61      maxv 	ip->ip_sum = 0;
    366  1.61      maxv 	ip->ip_sum = in_cksum(m, ip->ip_hl << 2);
    367   1.1  jonathan 
    368  1.44  christos 	/*
    369  1.44  christos 	 * Update TCP/UDP checksum
    370  1.44  christos 	 * XXX: should only do it in NAT-T case
    371  1.44  christos 	 * XXX: should do it incrementally, see FreeBSD code.
    372  1.44  christos 	 */
    373  1.44  christos 	m = ipsec4_fixup_checksum(m);
    374  1.44  christos 	if (m == NULL)
    375  1.44  christos 		goto cantpull;
    376  1.54      maxv 	ip = mtod(m, struct ip *);
    377  1.44  christos 
    378   1.1  jonathan 	prot = ip->ip_p;
    379   1.1  jonathan 
    380  1.57      maxv #ifdef notyet
    381   1.1  jonathan 	/* IP-in-IP encapsulation */
    382   1.1  jonathan 	if (prot == IPPROTO_IPIP) {
    383   1.1  jonathan 		struct ip ipn;
    384   1.1  jonathan 
    385   1.1  jonathan 		/* ipn will now contain the inner IPv4 header */
    386  1.57      maxv 		/* XXX: check m_pkthdr.len */
    387  1.16  degroote 		m_copydata(m, ip->ip_hl << 2, sizeof(struct ip), &ipn);
    388   1.1  jonathan 
    389   1.1  jonathan 		/* XXX PROXY address isn't recorded in SAH */
    390   1.1  jonathan 		/*
    391   1.1  jonathan 		 * Check that the inner source address is the same as
    392   1.1  jonathan 		 * the proxy address, if available.
    393   1.1  jonathan 		 */
    394   1.1  jonathan 		if ((saidx->proxy.sa.sa_family == AF_INET &&
    395   1.1  jonathan 		    saidx->proxy.sin.sin_addr.s_addr !=
    396   1.1  jonathan 		    INADDR_ANY &&
    397   1.1  jonathan 		    ipn.ip_src.s_addr !=
    398   1.1  jonathan 		    saidx->proxy.sin.sin_addr.s_addr) ||
    399   1.1  jonathan 		    (saidx->proxy.sa.sa_family != AF_INET &&
    400   1.1  jonathan 			saidx->proxy.sa.sa_family != 0)) {
    401   1.1  jonathan 
    402  1.42       ryo 			char ipbuf[INET_ADDRSTRLEN];
    403  1.43     ozaki 			IPSECLOG(LOG_DEBUG,
    404  1.43     ozaki 			    "inner source address %s doesn't correspond to "
    405   1.1  jonathan 			    "expected proxy source %s, SA %s/%08lx\n",
    406  1.42       ryo 			    IN_PRINT(ipbuf, ipn.ip_src),
    407   1.1  jonathan 			    ipsp_address(saidx->proxy),
    408   1.1  jonathan 			    ipsp_address(saidx->dst),
    409  1.43     ozaki 			    (u_long) ntohl(sav->spi));
    410   1.1  jonathan 
    411  1.20   thorpej 			IPSEC_ISTAT(sproto, ESP_STAT_PDROPS,
    412  1.20   thorpej 			    AH_STAT_PDROPS,
    413  1.20   thorpej 			    IPCOMP_STAT_PDROPS);
    414   1.1  jonathan 			error = EACCES;
    415   1.1  jonathan 			goto bad;
    416   1.1  jonathan 		}
    417   1.1  jonathan 	}
    418   1.1  jonathan #if INET6
    419   1.1  jonathan 	/* IPv6-in-IP encapsulation. */
    420   1.1  jonathan 	if (prot == IPPROTO_IPV6) {
    421   1.1  jonathan 		struct ip6_hdr ip6n;
    422   1.1  jonathan 
    423   1.1  jonathan 		/* ip6n will now contain the inner IPv6 header. */
    424  1.57      maxv 		/* XXX: check m_pkthdr.len */
    425  1.16  degroote 		m_copydata(m, ip->ip_hl << 2, sizeof(struct ip6_hdr), &ip6n);
    426   1.1  jonathan 
    427   1.1  jonathan 		/*
    428   1.1  jonathan 		 * Check that the inner source address is the same as
    429   1.1  jonathan 		 * the proxy address, if available.
    430   1.1  jonathan 		 */
    431   1.1  jonathan 		if ((saidx->proxy.sa.sa_family == AF_INET6 &&
    432   1.1  jonathan 		    !IN6_IS_ADDR_UNSPECIFIED(&saidx->proxy.sin6.sin6_addr) &&
    433   1.1  jonathan 		    !IN6_ARE_ADDR_EQUAL(&ip6n.ip6_src,
    434   1.1  jonathan 			&saidx->proxy.sin6.sin6_addr)) ||
    435   1.1  jonathan 		    (saidx->proxy.sa.sa_family != AF_INET6 &&
    436   1.1  jonathan 			saidx->proxy.sa.sa_family != 0)) {
    437   1.1  jonathan 
    438  1.37       ryo 			char ip6buf[INET6_ADDRSTRLEN];
    439  1.42       ryo 			char pbuf[IPSEC_ADDRSTRLEN], dbuf[IPSEC_ADDRSTRLEN];
    440  1.43     ozaki 			IPSECLOG(LOG_DEBUG,
    441  1.43     ozaki 			    "inner source address %s doesn't correspond to "
    442   1.1  jonathan 			    "expected proxy source %s, SA %s/%08lx\n",
    443  1.37       ryo 			    ip6_sprintf(ip6buf, &ip6n.ip6_src),
    444  1.42       ryo 			    ipsec_address(&saidx->proxy, pbuf, sizeof(pbuf)),
    445  1.42       ryo 			    ipsec_address(&saidx->dst, dbuf, sizeof(dbuf)),
    446  1.43     ozaki 			    (u_long) ntohl(sav->spi));
    447   1.1  jonathan 
    448  1.20   thorpej 			IPSEC_ISTAT(sproto, ESP_STAT_PDROPS,
    449  1.20   thorpej 			    AH_STAT_PDROPS,
    450  1.20   thorpej 			    IPCOMP_STAT_PDROPS);
    451   1.1  jonathan 			error = EACCES;
    452   1.1  jonathan 			goto bad;
    453   1.1  jonathan 		}
    454   1.1  jonathan 	}
    455   1.1  jonathan #endif /* INET6 */
    456  1.57      maxv #endif /* notyet */
    457   1.1  jonathan 
    458  1.63      maxv 	M_VERIFY_PACKET(m);
    459  1.63      maxv 
    460   1.1  jonathan 	key_sa_recordxfer(sav, m);		/* record data transfer */
    461   1.1  jonathan 
    462  1.35  riastrad 	if ((inetsw[ip_protox[prot]].pr_flags & PR_LASTHDR) != 0 &&
    463  1.62      maxv 	    ipsec_in_reject(m, NULL)) {
    464  1.29  drochner 		error = EINVAL;
    465  1.29  drochner 		goto bad;
    466   1.1  jonathan 	}
    467  1.35  riastrad 	(*inetsw[ip_protox[prot]].pr_input)(m, skip, prot);
    468   1.1  jonathan 	return 0;
    469  1.59      maxv 
    470   1.1  jonathan bad:
    471   1.1  jonathan 	m_freem(m);
    472   1.1  jonathan 	return error;
    473   1.1  jonathan }
    474   1.1  jonathan #endif /* INET */
    475   1.1  jonathan 
    476   1.1  jonathan #ifdef INET6
    477   1.1  jonathan int
    478   1.1  jonathan ipsec6_common_input(struct mbuf **mp, int *offp, int proto)
    479   1.1  jonathan {
    480   1.1  jonathan 	int l = 0;
    481  1.27  drochner 	int protoff, nxt;
    482   1.1  jonathan 	struct ip6_ext ip6e;
    483   1.1  jonathan 
    484   1.1  jonathan 	if (*offp < sizeof(struct ip6_hdr)) {
    485  1.43     ozaki 		IPSECLOG(LOG_DEBUG, "bad offset %u\n", *offp);
    486  1.25  drochner 		IPSEC_ISTAT(proto, ESP_STAT_HDROPS, AH_STAT_HDROPS,
    487  1.25  drochner 			    IPCOMP_STAT_HDROPS);
    488  1.25  drochner 		m_freem(*mp);
    489   1.1  jonathan 		return IPPROTO_DONE;
    490   1.1  jonathan 	} else if (*offp == sizeof(struct ip6_hdr)) {
    491   1.1  jonathan 		protoff = offsetof(struct ip6_hdr, ip6_nxt);
    492   1.1  jonathan 	} else {
    493   1.1  jonathan 		/* Chase down the header chain... */
    494   1.1  jonathan 		protoff = sizeof(struct ip6_hdr);
    495  1.27  drochner 		nxt = (mtod(*mp, struct ip6_hdr *))->ip6_nxt;
    496   1.1  jonathan 
    497   1.1  jonathan 		do {
    498   1.1  jonathan 			protoff += l;
    499  1.16  degroote 			m_copydata(*mp, protoff, sizeof(ip6e), &ip6e);
    500   1.1  jonathan 
    501  1.27  drochner 			if (nxt == IPPROTO_AH)
    502   1.1  jonathan 				l = (ip6e.ip6e_len + 2) << 2;
    503  1.55      maxv 			else if (nxt == IPPROTO_FRAGMENT)
    504  1.55      maxv 				l = sizeof(struct ip6_frag);
    505   1.1  jonathan 			else
    506   1.1  jonathan 				l = (ip6e.ip6e_len + 1) << 3;
    507  1.40     ozaki 			KASSERT(l > 0);
    508  1.27  drochner 
    509  1.27  drochner 			nxt = ip6e.ip6e_nxt;
    510   1.1  jonathan 		} while (protoff + l < *offp);
    511   1.1  jonathan 
    512   1.1  jonathan 		/* Malformed packet check */
    513   1.1  jonathan 		if (protoff + l != *offp) {
    514  1.43     ozaki 			IPSECLOG(LOG_DEBUG, "bad packet header chain, "
    515  1.43     ozaki 			    "protoff %u, l %u, off %u\n", protoff, l, *offp);
    516  1.20   thorpej 			IPSEC_ISTAT(proto, ESP_STAT_HDROPS,
    517  1.20   thorpej 				    AH_STAT_HDROPS,
    518  1.20   thorpej 				    IPCOMP_STAT_HDROPS);
    519   1.1  jonathan 			m_freem(*mp);
    520   1.1  jonathan 			*mp = NULL;
    521   1.1  jonathan 			return IPPROTO_DONE;
    522   1.1  jonathan 		}
    523   1.1  jonathan 		protoff += offsetof(struct ip6_ext, ip6e_nxt);
    524   1.1  jonathan 	}
    525   1.1  jonathan 	(void) ipsec_common_input(*mp, *offp, protoff, AF_INET6, proto);
    526   1.1  jonathan 	return IPPROTO_DONE;
    527   1.1  jonathan }
    528   1.1  jonathan 
    529  1.59      maxv extern const struct ip6protosw inet6sw[];
    530  1.59      maxv extern u_char ip6_protox[];
    531   1.1  jonathan 
    532   1.1  jonathan /*
    533   1.1  jonathan  * IPsec input callback, called by the transform callback. Takes care of
    534   1.1  jonathan  * filtering and other sanity checks on the processed packet.
    535   1.1  jonathan  */
    536   1.1  jonathan int
    537  1.45     ozaki ipsec6_common_input_cb(struct mbuf *m, struct secasvar *sav, int skip,
    538  1.45     ozaki     int protoff)
    539   1.1  jonathan {
    540  1.32     ozaki 	int af __diagused, sproto;
    541   1.1  jonathan 	struct ip6_hdr *ip6;
    542   1.1  jonathan 	struct secasindex *saidx;
    543   1.1  jonathan 	int nxt;
    544  1.24  drochner 	u_int8_t prot, nxt8;
    545   1.1  jonathan 	int error, nest;
    546   1.1  jonathan 
    547  1.60      maxv 	if (__predict_false(m == NULL)) {
    548  1.60      maxv 		panic("%s: NULL mbuf", __func__);
    549  1.60      maxv 	}
    550  1.60      maxv 
    551  1.40     ozaki 	KASSERT(sav != NULL);
    552   1.1  jonathan 	saidx = &sav->sah->saidx;
    553   1.1  jonathan 	af = saidx->dst.sa.sa_family;
    554  1.40     ozaki 	KASSERTMSG(af == AF_INET6, "unexpected af %u", af);
    555   1.1  jonathan 	sproto = saidx->proto;
    556  1.40     ozaki 	KASSERTMSG(sproto == IPPROTO_ESP || sproto == IPPROTO_AH ||
    557  1.40     ozaki 	    sproto == IPPROTO_IPCOMP,
    558  1.40     ozaki 	    "unexpected security protocol %u", sproto);
    559   1.1  jonathan 
    560   1.1  jonathan 	/* Fix IPv6 header */
    561   1.1  jonathan 	if (m->m_len < sizeof(struct ip6_hdr) &&
    562   1.1  jonathan 	    (m = m_pullup(m, sizeof(struct ip6_hdr))) == NULL) {
    563  1.42       ryo 		char buf[IPSEC_ADDRSTRLEN];
    564  1.43     ozaki 		IPSECLOG(LOG_DEBUG, "processing failed for SA %s/%08lx\n",
    565  1.43     ozaki 		    ipsec_address(&sav->sah->saidx.dst,
    566  1.43     ozaki 		    buf, sizeof(buf)), (u_long) ntohl(sav->spi));
    567  1.20   thorpej 		IPSEC_ISTAT(sproto, ESP_STAT_HDROPS, AH_STAT_HDROPS,
    568  1.20   thorpej 		    IPCOMP_STAT_HDROPS);
    569   1.1  jonathan 		error = EACCES;
    570   1.1  jonathan 		goto bad;
    571   1.1  jonathan 	}
    572   1.1  jonathan 
    573   1.1  jonathan 	ip6 = mtod(m, struct ip6_hdr *);
    574   1.1  jonathan 	ip6->ip6_plen = htons(m->m_pkthdr.len - sizeof(struct ip6_hdr));
    575   1.1  jonathan 
    576   1.1  jonathan 	/* Save protocol */
    577  1.24  drochner 	m_copydata(m, protoff, 1, &prot);
    578   1.1  jonathan 
    579  1.58      maxv #ifdef notyet
    580   1.1  jonathan #ifdef INET
    581   1.1  jonathan 	/* IP-in-IP encapsulation */
    582   1.1  jonathan 	if (prot == IPPROTO_IPIP) {
    583   1.1  jonathan 		struct ip ipn;
    584   1.1  jonathan 
    585   1.1  jonathan 		/* ipn will now contain the inner IPv4 header */
    586  1.58      maxv 		/* XXX: check m_pkthdr.len */
    587  1.16  degroote 		m_copydata(m, skip, sizeof(struct ip), &ipn);
    588   1.1  jonathan 
    589   1.1  jonathan 		/*
    590   1.1  jonathan 		 * Check that the inner source address is the same as
    591   1.1  jonathan 		 * the proxy address, if available.
    592   1.1  jonathan 		 */
    593   1.1  jonathan 		if ((saidx->proxy.sa.sa_family == AF_INET &&
    594   1.1  jonathan 		    saidx->proxy.sin.sin_addr.s_addr != INADDR_ANY &&
    595   1.1  jonathan 		    ipn.ip_src.s_addr != saidx->proxy.sin.sin_addr.s_addr) ||
    596   1.1  jonathan 		    (saidx->proxy.sa.sa_family != AF_INET &&
    597   1.1  jonathan 			saidx->proxy.sa.sa_family != 0)) {
    598   1.1  jonathan 
    599  1.42       ryo 			char ipbuf[INET_ADDRSTRLEN];
    600  1.42       ryo 			char pbuf[IPSEC_ADDRSTRLEN], dbuf[IPSEC_ADDRSTRLEN];
    601  1.43     ozaki 			IPSECLOG(LOG_DEBUG,
    602  1.43     ozaki 			    "inner source address %s doesn't correspond to "
    603   1.1  jonathan 			    "expected proxy source %s, SA %s/%08lx\n",
    604  1.42       ryo 			    IN_PRINT(ipbuf, ipn.ip_src),
    605  1.42       ryo 			    ipsec_address(&saidx->proxy, pbuf, sizeof(pbuf)),
    606  1.42       ryo 			    ipsec_address(&saidx->dst, dbuf, sizeof(dbuf)),
    607  1.43     ozaki 			    (u_long) ntohl(sav->spi));
    608   1.1  jonathan 
    609  1.20   thorpej 			IPSEC_ISTAT(sproto, ESP_STAT_PDROPS,
    610  1.20   thorpej 			    AH_STAT_PDROPS, IPCOMP_STAT_PDROPS);
    611   1.1  jonathan 			error = EACCES;
    612   1.1  jonathan 			goto bad;
    613   1.1  jonathan 		}
    614   1.1  jonathan 	}
    615   1.1  jonathan #endif /* INET */
    616   1.1  jonathan 	/* IPv6-in-IP encapsulation */
    617   1.1  jonathan 	if (prot == IPPROTO_IPV6) {
    618   1.1  jonathan 		struct ip6_hdr ip6n;
    619   1.1  jonathan 
    620   1.1  jonathan 		/* ip6n will now contain the inner IPv6 header. */
    621  1.58      maxv 		/* XXX: check m_pkthdr.len */
    622  1.16  degroote 		m_copydata(m, skip, sizeof(struct ip6_hdr), &ip6n);
    623   1.1  jonathan 
    624   1.1  jonathan 		/*
    625   1.1  jonathan 		 * Check that the inner source address is the same as
    626   1.1  jonathan 		 * the proxy address, if available.
    627   1.1  jonathan 		 */
    628   1.1  jonathan 		if ((saidx->proxy.sa.sa_family == AF_INET6 &&
    629   1.1  jonathan 		    !IN6_IS_ADDR_UNSPECIFIED(&saidx->proxy.sin6.sin6_addr) &&
    630   1.1  jonathan 		    !IN6_ARE_ADDR_EQUAL(&ip6n.ip6_src,
    631   1.1  jonathan 			&saidx->proxy.sin6.sin6_addr)) ||
    632   1.1  jonathan 		    (saidx->proxy.sa.sa_family != AF_INET6 &&
    633   1.1  jonathan 			saidx->proxy.sa.sa_family != 0)) {
    634   1.1  jonathan 
    635  1.37       ryo 			char ip6buf[INET6_ADDRSTRLEN];
    636  1.42       ryo 			char pbuf[IPSEC_ADDRSTRLEN], dbuf[IPSEC_ADDRSTRLEN];
    637  1.43     ozaki 			IPSECLOG(LOG_DEBUG,
    638  1.43     ozaki 			    "inner source address %s doesn't correspond to "
    639   1.1  jonathan 			    "expected proxy source %s, SA %s/%08lx\n",
    640  1.37       ryo 			    ip6_sprintf(ip6buf, &ip6n.ip6_src),
    641  1.42       ryo 			    ipsec_address(&saidx->proxy, pbuf, sizeof(pbuf)),
    642  1.42       ryo 			    ipsec_address(&saidx->dst, dbuf, sizeof(dbuf)),
    643  1.43     ozaki 			    (u_long) ntohl(sav->spi));
    644   1.1  jonathan 
    645  1.20   thorpej 			IPSEC_ISTAT(sproto, ESP_STAT_PDROPS,
    646  1.20   thorpej 			    AH_STAT_PDROPS, IPCOMP_STAT_PDROPS);
    647   1.1  jonathan 			error = EACCES;
    648   1.1  jonathan 			goto bad;
    649   1.1  jonathan 		}
    650   1.1  jonathan 	}
    651  1.58      maxv #endif /* notyet */
    652   1.1  jonathan 
    653   1.1  jonathan 	key_sa_recordxfer(sav, m);
    654   1.1  jonathan 
    655   1.1  jonathan 	/* Retrieve new protocol */
    656  1.16  degroote 	m_copydata(m, protoff, sizeof(u_int8_t), &nxt8);
    657   1.1  jonathan 
    658   1.1  jonathan 	/*
    659   1.1  jonathan 	 * See the end of ip6_input for this logic.
    660   1.1  jonathan 	 * IPPROTO_IPV[46] case will be processed just like other ones
    661   1.1  jonathan 	 */
    662   1.1  jonathan 	nest = 0;
    663   1.1  jonathan 	nxt = nxt8;
    664   1.1  jonathan 	while (nxt != IPPROTO_DONE) {
    665   1.1  jonathan 		if (ip6_hdrnestlimit && (++nest > ip6_hdrnestlimit)) {
    666  1.19   thorpej 			IP6_STATINC(IP6_STAT_TOOMANYHDR);
    667   1.1  jonathan 			error = EINVAL;
    668   1.1  jonathan 			goto bad;
    669   1.1  jonathan 		}
    670   1.1  jonathan 
    671  1.63      maxv 		M_VERIFY_PACKET(m);
    672  1.63      maxv 
    673   1.1  jonathan 		/*
    674   1.1  jonathan 		 * Protection against faulty packet - there should be
    675   1.1  jonathan 		 * more sanity checks in header chain processing.
    676   1.1  jonathan 		 */
    677   1.1  jonathan 		if (m->m_pkthdr.len < skip) {
    678  1.19   thorpej 			IP6_STATINC(IP6_STAT_TOOSHORT);
    679  1.36     ozaki 			in6_ifstat_inc(m_get_rcvif_NOMPSAFE(m),
    680  1.59      maxv 			    ifs6_in_truncated);
    681   1.1  jonathan 			error = EINVAL;
    682   1.1  jonathan 			goto bad;
    683   1.1  jonathan 		}
    684  1.59      maxv 
    685   1.1  jonathan 		/*
    686   1.1  jonathan 		 * Enforce IPsec policy checking if we are seeing last header.
    687  1.64      maxv 		 * Note that we do not visit this with protocols with pcb layer
    688   1.1  jonathan 		 * code - like udp/tcp/raw ip.
    689   1.1  jonathan 		 */
    690   1.1  jonathan 		if ((inet6sw[ip6_protox[nxt]].pr_flags & PR_LASTHDR) != 0 &&
    691  1.62      maxv 		    ipsec_in_reject(m, NULL)) {
    692   1.1  jonathan 			error = EINVAL;
    693   1.1  jonathan 			goto bad;
    694   1.1  jonathan 		}
    695   1.1  jonathan 		nxt = (*inet6sw[ip6_protox[nxt]].pr_input)(&m, &skip, nxt);
    696   1.1  jonathan 	}
    697   1.1  jonathan 	return 0;
    698  1.61      maxv 
    699   1.1  jonathan bad:
    700   1.1  jonathan 	if (m)
    701   1.1  jonathan 		m_freem(m);
    702   1.1  jonathan 	return error;
    703   1.1  jonathan }
    704   1.1  jonathan #endif /* INET6 */
    705