2 * Copyright (c) 2007 Apple Computer, Inc. All rights reserved.
4 * @APPLE_LICENSE_HEADER_START@
6 * The contents of this file constitute Original Code as defined in and
7 * are subject to the Apple Public Source License Version 1.1 (the
8 * "License"). You may not use this file except in compliance with the
9 * License. Please obtain a copy of the License at
10 * http://www.apple.com/publicsource and read it before using this file.
12 * This Original Code and all software distributed under the License are
13 * distributed on an "AS IS" basis, WITHOUT WARRANTY OF ANY KIND, EITHER
14 * EXPRESS OR IMPLIED, AND APPLE HEREBY DISCLAIMS ALL SUCH WARRANTIES,
15 * INCLUDING WITHOUT LIMITATION, ANY WARRANTIES OF MERCHANTABILITY,
16 * FITNESS FOR A PARTICULAR PURPOSE OR NON-INFRINGEMENT. Please see the
17 * License for the specific language governing rights and limitations
20 * @APPLE_LICENSE_HEADER_END@
24 * Copyright (C) 1995, 1996, 1997, and 1998 WIDE Project.
25 * All rights reserved.
27 * Redistribution and use in source and binary forms, with or without
28 * modification, are permitted provided that the following conditions
30 * 1. Redistributions of source code must retain the above copyright
31 * notice, this list of conditions and the following disclaimer.
32 * 2. Redistributions in binary form must reproduce the above copyright
33 * notice, this list of conditions and the following disclaimer in the
34 * documentation and/or other materials provided with the distribution.
35 * 3. Neither the name of the project nor the names of its contributors
36 * may be used to endorse or promote products derived from this software
37 * without specific prior written permission.
39 * THIS SOFTWARE IS PROVIDED BY THE PROJECT AND CONTRIBUTORS ``AS IS'' AND
40 * ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
41 * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE
42 * ARE DISCLAIMED. IN NO EVENT SHALL THE PROJECT OR CONTRIBUTORS BE LIABLE
43 * FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL
44 * DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS
45 * OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION)
46 * HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT
47 * LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY
48 * OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF
54 #include <sys/types.h>
55 #include <sys/param.h>
56 #include <sys/socket.h>
57 #include <sys/signal.h>
61 #include <net/pfkeyv2.h>
63 #include <netinet/in.h>
64 #ifndef HAVE_NETINET6_IPSEC
65 #include <netinet/ipsec.h>
67 #include <netinet6/ipsec.h>
91 #include "localconf.h"
92 #include "remoteconf.h"
93 #include "grabmyaddr.h"
94 #include "isakmp_var.h"
98 #include "ipsec_doi.h"
99 #include "isakmp_inf.h"
101 #include "isakmp_cfg.h"
102 #include "isakmp_unity.h"
105 #include "gcmalloc.h"
107 #include "ipsec_doi.h"
108 #include "nattraversal.h"
111 #include "vpn_control.h"
112 #include "vpn_control_var.h"
113 #include "strnames.h"
114 #include "ike_session.h"
115 #include "ipsecMessageTracer.h"
118 static int vpn_get_ph2pfs (phase1_handle_t
*);
121 vpn_connect(struct bound_addr
*srv
, int oper
)
124 struct sockaddr_storage
*dst
;
125 struct remoteconf
*rmconf
;
126 struct sockaddr_storage
*remote
= NULL
;
127 struct sockaddr_storage
*local
= NULL
;
130 dst
= racoon_calloc(1, sizeof(struct sockaddr_storage
)); // this should come from the bound_addr parameter
133 ((struct sockaddr_in
*)(dst
))->sin_len
= sizeof(struct sockaddr_in
);
134 ((struct sockaddr_in
*)(dst
))->sin_family
= AF_INET
;
135 ((struct sockaddr_in
*)(dst
))->sin_port
= 500;
136 ((struct sockaddr_in
*)(dst
))->sin_addr
.s_addr
= srv
->address
;
138 /* find appropreate configuration */
139 rmconf
= getrmconf(dst
);
140 if (rmconf
== NULL
) {
142 "no configuration found "
143 "for %s\n", saddrwop2str((struct sockaddr
*)dst
));
148 * Find the source address
150 if (rmconf
->forced_local
!= NULL
) {
151 if ((local
= dupsaddr(rmconf
->forced_local
)) == NULL
) {
152 plog(ASL_LEVEL_ERR
, "failed to duplicate local address\n");
155 } else if ((local
= getlocaladdr((struct sockaddr
*)dst
)) == NULL
) {
156 plog(ASL_LEVEL_ERR
, "cannot get local address\n");
160 /* get remote IP address and port number. */
161 if ((remote
= dupsaddr(dst
)) == NULL
) {
163 "failed to duplicate address\n");
167 switch (remote
->ss_family
) {
169 ((struct sockaddr_in
*)remote
)->sin_port
=
170 ((struct sockaddr_in
*)rmconf
->remote
)->sin_port
;
174 ((struct sockaddr_in6
*)remote
)->sin6_port
=
175 ((struct sockaddr_in6
*)rmconf
->remote
)->sin6_port
;
180 "invalid family: %d\n",
186 port
= ntohs(getmyaddrsport(local
));
187 if (set_port(local
, port
) == NULL
)
191 "accept a request to establish IKE-SA: "
192 "%s\n", saddrwop2str((struct sockaddr
*)remote
));
194 IPSECLOGASLMSG("IPSec connecting to server %s\n",
195 saddrwop2str((struct sockaddr
*)remote
));
196 if (ikev1_ph1begin_i(NULL
, rmconf
, remote
, local
, oper
) < 0)
213 vpn_disconnect(struct bound_addr
*srv
, const char *reason
)
215 union { // Wcast-align fix - force alignment
216 struct sockaddr_storage ss
;
217 struct sockaddr_in saddr
;
220 bzero(&u
.saddr
, sizeof(u
.saddr
));
221 u
.saddr
.sin_len
= sizeof(u
.saddr
);
222 u
.saddr
.sin_addr
.s_addr
= srv
->address
;
223 u
.saddr
.sin_port
= 0;
224 u
.saddr
.sin_family
= AF_INET
;
226 IPSECLOGASLMSG("IPSec disconnecting from server %s\n",
227 saddrwop2str((struct sockaddr
*)&u
.ss
));
229 ike_sessions_stopped_by_controller(&u
.ss
,
232 if (ike_session_purgephXbydstaddrwop(&u
.ss
) > 0) {
240 vpn_start_ph2(struct bound_addr
*addr
, struct vpnctl_cmd_start_ph2
*pkt
)
242 struct vpnctl_sa_selector
*selector_ptr
;
243 struct vpnctl_algo
*algo_ptr
, *next_algo
;
245 struct sainfoalg
*new_algo
;
246 struct sainfo
*new_sainfo
= NULL
, *check
;
247 u_int16_t
class, algorithm
, keylen
;
248 phase1_handle_t
*ph1
;
249 struct sockaddr_in saddr
;
252 u_int8_t type
; /* ID Type */
253 u_int8_t proto_id
; /* Protocol ID */
254 u_int16_t port
; /* Port */
255 u_int32_t addr
; /* IPv4 address */
259 /* verify ph1 exists */
260 bzero(&saddr
, sizeof(saddr
));
261 saddr
.sin_len
= sizeof(saddr
);
262 saddr
.sin_addr
.s_addr
= addr
->address
;
264 saddr
.sin_family
= AF_INET
;
265 ph1
= ike_session_getph1bydstaddrwop(NULL
, (struct sockaddr_storage
*)(&saddr
));
268 "Cannot start Phase 2 - no Phase 1 found.\n");
271 if (!FSM_STATE_IS_ESTABLISHED(ph1
->status
)) {
273 "Cannot start Phase 2 - Phase 1 not established.\n");
277 selector_ptr
= (struct vpnctl_sa_selector
*)(pkt
+ 1);
278 algo_ptr
= (struct vpnctl_algo
*)(selector_ptr
+ ntohs(pkt
->selector_count
));
280 for (i
= 0; i
< ntohs(pkt
->selector_count
); i
++, selector_ptr
++) {
281 new_sainfo
= create_sainfo();
282 if (new_sainfo
== NULL
) {
284 "Unable to allocate sainfo struct.\n");
288 if (ntohl(selector_ptr
->src_tunnel_mask
) == 0xFFFFFFFF)
289 new_sainfo
->idsrc
= vmalloc(sizeof(struct id
) - sizeof(u_int32_t
));
291 new_sainfo
->idsrc
= vmalloc(sizeof(struct id
));
292 if (new_sainfo
->idsrc
== NULL
) {
294 "Unable to allocate id struct.\n");
297 if (selector_ptr
->dst_tunnel_mask
== 0xFFFFFFFF)
298 new_sainfo
->iddst
= vmalloc(sizeof(struct id
) - sizeof(u_int32_t
));
300 new_sainfo
->iddst
= vmalloc(sizeof(struct id
));
301 if (new_sainfo
->iddst
== NULL
) {
303 "Unable to allocate id struct.\n");
307 id_ptr
= ALIGNED_CAST(struct id
*)new_sainfo
->idsrc
->v
;
308 if (ntohl(selector_ptr
->src_tunnel_mask
) == 0xFFFFFFFF)
309 id_ptr
->type
= IPSECDOI_ID_IPV4_ADDR
;
311 id_ptr
->type
= IPSECDOI_ID_IPV4_ADDR_SUBNET
;
312 id_ptr
->mask
= selector_ptr
->src_tunnel_mask
;
314 id_ptr
->addr
= selector_ptr
->src_tunnel_address
;
315 id_ptr
->port
= selector_ptr
->src_tunnel_port
;
316 id_ptr
->proto_id
= selector_ptr
->ul_protocol
;
318 id_ptr
= ALIGNED_CAST(struct id
*)new_sainfo
->iddst
->v
;
319 if (selector_ptr
->dst_tunnel_mask
== 0xFFFFFFFF)
320 id_ptr
->type
= IPSECDOI_ID_IPV4_ADDR
;
322 id_ptr
->type
= IPSECDOI_ID_IPV4_ADDR_SUBNET
;
323 id_ptr
->mask
= selector_ptr
->dst_tunnel_mask
;
325 id_ptr
->addr
= selector_ptr
->dst_tunnel_address
;
326 id_ptr
->port
= selector_ptr
->dst_tunnel_port
;
327 id_ptr
->proto_id
= selector_ptr
->ul_protocol
;
329 new_sainfo
->dynamic
= addr
->address
;
330 new_sainfo
->lifetime
= ntohl(pkt
->lifetime
);
332 if (ntohs(pkt
->pfs_group
) != 0) {
333 new_sainfo
->pfs_group
= algtype2doi(algclass_isakmp_dh
, ntohs(pkt
->pfs_group
));
334 if (new_sainfo
->pfs_group
== -1) {
335 plog(ASL_LEVEL_ERR
, "Invalid dh group specified\n");
339 for (j
= 0, next_algo
= algo_ptr
; j
< ntohs(pkt
->algo_count
); j
++, next_algo
++) {
341 new_algo
= newsainfoalg();
342 if (new_algo
== NULL
) {
344 "Failed to allocate algorithm structure\n");
348 class = ntohs(next_algo
->algo_class
);
349 algorithm
= ntohs(next_algo
->algo
);
350 keylen
= ntohs(next_algo
->key_len
);
352 new_algo
->alg
= algtype2doi(class, algorithm
);
353 if (new_algo
->alg
== -1) {
354 plog(ASL_LEVEL_ERR
, "Algorithm mismatched\n");
355 racoon_free(new_algo
);
359 defklen
= default_keylen(class, algorithm
);
362 plog(ASL_LEVEL_ERR
, "keylen not allowed\n");
363 racoon_free(new_algo
);
367 if (keylen
&& check_keylen(class, algorithm
, keylen
) < 0) {
368 plog(ASL_LEVEL_ERR
, "invalid keylen %d\n", keylen
);
369 racoon_free(new_algo
);
375 new_algo
->encklen
= keylen
;
377 new_algo
->encklen
= defklen
;
379 /* check if it's supported algorithm by kernel */
380 if (!(class == algclass_ipsec_auth
&& algorithm
== algtype_non_auth
)
381 && pk_checkalg(class, algorithm
, new_algo
->encklen
)) {
382 int a
= algclass2doi(class);
383 int b
= new_algo
->alg
;
384 if (a
== IPSECDOI_ATTR_AUTH
)
385 a
= IPSECDOI_PROTO_IPSEC_AH
;
387 "Algorithm %s not supported by the kernel (missing module?)\n", s_ipsecdoi_trns(a
, b
));
388 racoon_free(new_algo
);
391 inssainfoalg(&new_sainfo
->algs
[class], new_algo
);
394 if (new_sainfo
->algs
[algclass_ipsec_enc
] == 0) {
396 "No encryption algorithm at %s\n", sainfo2str(new_sainfo
));
399 if (new_sainfo
->algs
[algclass_ipsec_auth
] == 0) {
401 "No authentication algorithm at %s\n", sainfo2str(new_sainfo
));
404 if (new_sainfo
->algs
[algclass_ipsec_comp
] == 0) {
406 "No compression algorithm at %s\n", sainfo2str(new_sainfo
));
410 /* duplicate check */
411 check
= getsainfo(new_sainfo
->idsrc
, new_sainfo
->iddst
, new_sainfo
->id_i
, 0);
412 if (check
&& (!check
->idsrc
&& !new_sainfo
->idsrc
)) {
413 plog(ASL_LEVEL_ERR
, "Duplicated sainfo: %s\n", sainfo2str(new_sainfo
));
416 //plog(ASL_LEVEL_DEBUG, "create sainfo: %s\n", sainfo2str(new_sainfo));
417 inssainfo(new_sainfo
);
425 release_sainfo(new_sainfo
);
426 flushsainfo_dynamic((u_int32_t
)addr
->address
);
431 vpn_get_ph2pfs(phase1_handle_t
*ph1
)
437 vpn_get_config(phase1_handle_t
*iph1
, struct vpnctl_status_phase_change
**msg
, size_t *msg_size
)
440 struct vpnctl_modecfg_params
*params
;
441 struct myaddrs
*myaddr
;
442 u_int16_t ifname_len
, msize
;
448 if (((struct sockaddr_in
*)iph1
->local
)->sin_family
!= AF_INET
) {
450 "IPv6 not supported for mode config.\n");
454 if (iph1
->mode_cfg
->attr_list
== NULL
)
455 return 1; /* haven't received configuration yet */
457 myaddr
= find_myaddr((struct sockaddr
*)iph1
->local
, 0);
458 if (myaddr
== NULL
) {
460 "Unable to find address structure.\n");
464 msize
= sizeof(struct vpnctl_status_phase_change
)
465 + sizeof(struct vpnctl_modecfg_params
);
466 msize
+= iph1
->mode_cfg
->attr_list
->l
;
468 *msg
= racoon_calloc(1, msize
);
471 "Failed to allocate space for message.\n");
475 (*msg
)->hdr
.flags
= htons(VPNCTL_FLAG_MODECFG_USED
);
476 params
= (struct vpnctl_modecfg_params
*)(*msg
+ 1);
477 params
->outer_local_addr
= ((struct sockaddr_in
*)iph1
->local
)->sin_addr
.s_addr
;
478 params
->outer_remote_port
= htons(0);
479 params
->outer_local_port
= htons(0);
480 ifname_len
= strlen(myaddr
->ifname
);
481 memset(¶ms
->ifname
, 0, IFNAMSIZ
);
482 memcpy(¶ms
->ifname
, myaddr
->ifname
, ifname_len
< IFNAMSIZ
? ifname_len
: IFNAMSIZ
-1);
483 cptr
= (u_int8_t
*)(params
+ 1);
484 memcpy(cptr
, iph1
->mode_cfg
->attr_list
->v
, iph1
->mode_cfg
->attr_list
->l
);
487 IPSECLOGASLMSG("IPSec Network Configuration established.\n");
493 vpn_xauth_reply(u_int32_t address
, void *attr_list
, size_t attr_len
)
496 struct isakmp_pl_attr
*reply
;
498 vchar_t
*payload
= NULL
;
499 phase1_handle_t
*iph1
;
500 struct sockaddr_in saddr
;
503 struct isakmp_data
*attr
;
504 char *dataptr
= (char *)attr_list
;
507 bzero(&saddr
, sizeof(saddr
));
508 saddr
.sin_len
= sizeof(saddr
);
509 saddr
.sin_addr
.s_addr
= address
;
511 saddr
.sin_family
= AF_INET
;
512 iph1
= ike_session_getph1bydstaddrwop(NULL
, (struct sockaddr_storage
*)(&saddr
));
515 "Cannot reply to xauth request - no ph1 found.\n");
519 if (iph1
->xauth_awaiting_userinput
== 0) {
520 plog(ASL_LEVEL_ERR
, "Received xauth reply data with no xauth reply pending \n");
524 /* validate attr lengths */
529 attr
= (struct isakmp_data
*)dataptr
;
530 tlv
= (attr
->type
& htons(0x8000)) == 0;
533 tlen
-= ntohs(attr
->lorv
);
534 dataptr
+= ntohs(attr
->lorv
);
536 tlen
-= sizeof(u_int32_t
);
537 dataptr
+= sizeof(u_int32_t
);
540 plog(ASL_LEVEL_ERR
, "Invalid auth info received from VPN Control socket.\n");
544 payload
= vmalloc(sizeof(struct isakmp_pl_attr
) + attr_len
);
545 if (payload
== NULL
) {
546 plog(ASL_LEVEL_ERR
, "Cannot allocate memory for xauth reply\n");
549 memset(payload
->v
, 0, sizeof(reply
));
551 reply
= (struct isakmp_pl_attr
*)payload
->v
;
552 reply
->h
.len
= htons(payload
->l
);
553 reply
->type
= ISAKMP_CFG_REPLY
;
554 reply
->id
= iph1
->pended_xauth_id
; /* network byte order */
555 iph1
->xauth_awaiting_userinput
= 0; /* no longer waiting */
556 attr_ptr
= reply
+ 1;
557 memcpy(attr_ptr
, attr_list
, attr_len
);
559 plog(ASL_LEVEL_DEBUG
,
560 "Sending MODE_CFG REPLY\n");
561 error
= isakmp_cfg_send(iph1
, payload
,
562 ISAKMP_NPTYPE_ATTR
, ISAKMP_FLAG_E
, 0, 0, iph1
->xauth_awaiting_userinput_msg
);
563 VPTRINIT(iph1
->xauth_awaiting_userinput_msg
);
564 ike_session_stop_xauth_timer(iph1
);
566 IPSECLOGASLMSG("IPSec Extended Authentication sent.\n");
575 vpn_assert(struct sockaddr_storage
*src_addr
, struct sockaddr_storage
*dst_addr
)
577 if (ike_session_assert(src_addr
, dst_addr
)) {
579 "Cannot assert - no matching session.\n");