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