1 /* $NetBSD: session.c,v 1.7.6.2 2007/08/01 11:52:22 vanhu Exp $ */
3 /* $KAME: session.c,v 1.32 2003/09/24 02:01:17 jinmei Exp $ */
6 * Copyright (C) 1995, 1996, 1997, and 1998 WIDE Project.
9 * Redistribution and use in source and binary forms, with or without
10 * modification, are permitted provided that the following conditions
12 * 1. Redistributions of source code must retain the above copyright
13 * notice, this list of conditions and the following disclaimer.
14 * 2. Redistributions in binary form must reproduce the above copyright
15 * notice, this list of conditions and the following disclaimer in the
16 * documentation and/or other materials provided with the distribution.
17 * 3. Neither the name of the project nor the names of its contributors
18 * may be used to endorse or promote products derived from this software
19 * without specific prior written permission.
21 * THIS SOFTWARE IS PROVIDED BY THE PROJECT AND CONTRIBUTORS ``AS IS'' AND
22 * ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
23 * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE
24 * ARE DISCLAIMED. IN NO EVENT SHALL THE PROJECT OR CONTRIBUTORS BE LIABLE
25 * FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL
26 * DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS
27 * OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION)
28 * HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT
29 * LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY
30 * OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF
36 #include <sys/types.h>
37 #include <sys/param.h>
39 #include <sys/socket.h>
41 # include <sys/wait.h>
44 # define WEXITSTATUS(s) ((unsigned)(s) >> 8)
47 # define WIFEXITED(s) (((s) & 255) == 0)
50 #ifndef HAVE_NETINET6_IPSEC
51 #include <netinet/ipsec.h>
53 #include <netinet6/ipsec.h>
67 #include <netinet/in.h>
68 #include <netinet/ip.h>
69 #include <netinet/ip_icmp.h>
72 #include <TargetConditionals.h>
73 #include <vproc_priv.h>
74 #include <dispatch/dispatch.h>
87 #include "grabmyaddr.h"
88 #include "cfparse_proto.h"
89 #include "isakmp_var.h"
90 #include "isakmp_xauth.h"
91 #include "isakmp_cfg.h"
95 #include "localconf.h"
96 #include "remoteconf.h"
98 #include "nattraversal.h"
100 #include "vpn_control_var.h"
102 #include "algorithm.h" /* XXX ??? */
105 #include "power_mgmt.h"
107 #include <NetworkExtension/NEPolicy.h>
108 #include <sys/proc_info.h>
112 extern pid_t racoon_pid
;
113 extern int launchdlaunched
;
114 static void close_session (int);
115 static int init_signal (void);
116 static int set_signal (int sig
, RETSIGTYPE (*func
) (int, siginfo_t
*, void *));
117 static void check_sigreq (void);
118 static void check_flushsa_stub (void *);
119 static void check_flushsa (void);
120 static void auto_exit_do (void *);
121 static int close_sockets (void);
123 static volatile sig_atomic_t sigreq
[NSIG
+ 1];
126 static int64_t racoon_keepalive
= -1;
128 dispatch_queue_t main_queue
;
130 static NEPolicySessionRef policySession
= NULL
;
133 * This is used to (manually) update racoon's launchd keepalive, which is needed because racoon is (mostly)
134 * launched on demand and for <rdar://problem/8768510> requires a keepalive on dirty/failure exits.
135 * The launchd plist can't be used for this because RunOnLoad is required to have keepalive on a failure exit.
138 launchd_update_racoon_keepalive (Boolean enabled
)
140 if (launchdlaunched
) {
141 int64_t val
= (__typeof__(val
))enabled
;
142 /* Set our own KEEPALIVE value */
143 if (vproc_swap_integer(NULL
,
144 VPROC_GSK_BASIC_KEEPALIVE
,
146 &racoon_keepalive
)) {
148 "failed to swap launchd keepalive integer %d\n", enabled
);
151 return racoon_keepalive
;
155 copy_racoon_proc_uuid(void)
157 struct proc_uniqidentifierinfo procu
;
158 CFUUIDBytes uuidBytes
;
161 memset(&procu
, 0, sizeof(procu
));
162 size
= proc_pidinfo(getpid(), PROC_PIDUNIQIDENTIFIERINFO
, 1, &procu
, PROC_PIDUNIQIDENTIFIERINFO_SIZE
);
163 if (size
!= PROC_PIDUNIQIDENTIFIERINFO_SIZE
) {
167 memcpy(&uuidBytes
, procu
.p_uuid
, sizeof(CFUUIDBytes
));
168 return CFUUIDCreateFromUUIDBytes(kCFAllocatorDefault
, uuidBytes
);
172 policy_session_init(void)
175 policySession
= NEPolicyCreateSession(kCFAllocatorDefault
, CFSTR("racoon"), NULL
, NULL
);
176 if (policySession
== NULL
) {
180 CFUUIDRef proc_uuid
= copy_racoon_proc_uuid();
181 if (proc_uuid
== NULL
) {
185 CFMutableArrayRef conditions
= CFArrayCreateMutable(kCFAllocatorDefault
, 0, &kCFTypeArrayCallBacks
);
187 CFMutableDictionaryRef uuidCondition
= CFDictionaryCreateMutable(kCFAllocatorDefault
, 0, &kCFTypeDictionaryKeyCallBacks
, &kCFTypeDictionaryValueCallBacks
);
189 CFDictionarySetValue(uuidCondition
, kNEPolicyConditionType
, kNEPolicyValPolicyConditionTypeApplication
);
190 CFDictionarySetValue(uuidCondition
, kNEPolicyApplicationUUID
, proc_uuid
);
191 CFArrayAppendValue(conditions
, uuidCondition
);
192 CFRelease(uuidCondition
);
197 CFMutableDictionaryRef interfacesCondition
= CFDictionaryCreateMutable(kCFAllocatorDefault
, 0, &kCFTypeDictionaryKeyCallBacks
, &kCFTypeDictionaryValueCallBacks
);
198 if (interfacesCondition
) {
199 CFDictionarySetValue(interfacesCondition
, kNEPolicyConditionType
, kNEPolicyValPolicyConditionTypeAllInterfaces
);
200 CFArrayAppendValue(conditions
, interfacesCondition
);
201 CFRelease(interfacesCondition
);
209 CFMutableDictionaryRef result
= CFDictionaryCreateMutable(kCFAllocatorDefault
, 0, &kCFTypeDictionaryKeyCallBacks
, &kCFTypeDictionaryValueCallBacks
);
211 CFDictionaryAddValue(result
, kNEPolicyResult
, kNEPolicyValPolicyResultPass
);
217 success
= (NEPolicyAdd(policySession
, 0, conditions
, result
, NULL
) != kNEPolicyIDInvalid
);
224 CFRelease(conditions
);
227 CFRelease(proc_uuid
);
230 return (success
&& NEPolicyApply(policySession
));
236 // Initialize listening sockets, timers, vpn control etc.,
237 // write the PID file and call dispatch_main.
242 char pid_file
[MAXPATHLEN
];
246 main_queue
= dispatch_get_main_queue();
248 /* initialize schedular */
251 /* needs to be called after schedular */
252 if (init_power_mgmt() < 0) {
254 "failed to initialize power-mgmt.");
258 if (lcconf
->autograbaddr
== 1)
259 if (pfroute_init()) {
260 plog(ASL_LEVEL_ERR
, "failed to initialize route socket.\n");
264 if (!policy_session_init()) {
265 plog(ASL_LEVEL_ERR
, "failed to initialize NEPolicy session.\n");
269 plog(ASL_LEVEL_ERR
, "failed to initialize listening addresses.\n");
273 plog(ASL_LEVEL_ERR
, "failed to initialize isakmp");
276 #ifdef ENABLE_VPNCONTROL_PORT
277 if (vpncontrol_init()) {
278 plog(ASL_LEVEL_ERR
, "failed to initialize vpn control port");
284 plog(ASL_LEVEL_ERR
, "failed to initialize signals.\n");
288 for (i
= 0; i
<= NSIG
; i
++)
291 /* write .pid file */
293 racoon_pid
= getpid();
294 if (lcconf
->pathinfo
[LC_PATHTYPE_PIDFILE
] == NULL
)
295 strlcpy(pid_file
, _PATH_VARRUN
"racoon.pid", sizeof(pid_file
));
296 else if (lcconf
->pathinfo
[LC_PATHTYPE_PIDFILE
][0] == '/')
297 strlcpy(pid_file
, lcconf
->pathinfo
[LC_PATHTYPE_PIDFILE
], sizeof(pid_file
));
299 strlcat(pid_file
, _PATH_VARRUN
, sizeof(pid_file
));
300 strlcat(pid_file
, lcconf
->pathinfo
[LC_PATHTYPE_PIDFILE
], sizeof(pid_file
));
302 fp
= fopen(pid_file
, "w");
304 if (fchmod(fileno(fp
),
305 S_IRUSR
| S_IWUSR
| S_IRGRP
| S_IROTH
) == -1) {
306 plog(ASL_LEVEL_ERR
, "%s", strerror(errno
));
310 fprintf(fp
, "%ld\n", (long)racoon_pid
);
314 "cannot open %s", pid_file
);
317 #if !TARGET_OS_EMBEDDED
318 // enable keepalive for recovery (from crashes and bad exits... after init)
319 (void)launchd_update_racoon_keepalive(true);
320 #endif // !TARGET_OS_EMBEDDED
327 exit(1); // should not be reached!!!
331 /* clear all status and exit program. */
333 close_session(int error
)
336 cleanup_power_mgmt();
338 ike_session_flush_all_phase2(false);
339 ike_session_flush_all_phase1(false);
342 #if !TARGET_OS_EMBEDDED
343 // a clean exit, so disable launchd keepalive
344 (void)launchd_update_racoon_keepalive(false);
345 #endif // !TARGET_OS_EMBEDDED
347 plog(ASL_LEVEL_INFO
, "racoon shutdown\n");
353 * waiting the termination of processing until sending DELETE message
354 * for all inbound SA will complete.
357 check_flushsa_stub(p
)
367 struct sadb_msg
*msg
, *end
, *next
;
369 caddr_t mhp
[SADB_EXT_MAX
+ 1];
372 buf
= pfkey_dump_sadb(SADB_SATYPE_UNSPEC
);
374 plog(ASL_LEVEL_DEBUG
,
375 "pfkey_dump_sadb: returned nothing.\n");
379 msg
= ALIGNED_CAST(struct sadb_msg
*)buf
->v
;
380 end
= ALIGNED_CAST(struct sadb_msg
*)(buf
->v
+ buf
->l
);
382 /* counting SA except of dead one. */
385 if (PFKEY_UNUNIT64(msg
->sadb_msg_len
) < sizeof(*msg
))
387 next
= ALIGNED_CAST(struct sadb_msg
*)((caddr_t
)msg
+ PFKEY_UNUNIT64(msg
->sadb_msg_len
)); // Wcast-align fix (void*) - aligned buffer + multiple of 64
388 if (msg
->sadb_msg_type
!= SADB_DUMP
) {
393 if (pfkey_align(msg
, mhp
) || pfkey_check(mhp
)) {
395 "pfkey_check (%s)\n", ipsec_strerror());
400 sa
= ALIGNED_CAST(struct sadb_sa
*)(mhp
[SADB_EXT_SA
]); // Wcast-align fix (void*) - mhp contains pointers to aligned structs
406 if (sa
->sadb_sa_state
!= SADB_SASTATE_DEAD
) {
419 sched_new(1, check_flushsa_stub
, NULL
);
423 #if !TARGET_OS_EMBEDDED
425 vproc_transaction_end(NULL
, lcconf
->vt
);
431 auto_exit_do(void *p
)
433 plog(ASL_LEVEL_DEBUG
,
434 "performing auto exit\n");
435 #if ENABLE_NO_SA_FLUSH
438 pfkey_send_flush(lcconf
->sock_pfkey
, SADB_SATYPE_UNSPEC
);
439 sched_new(1, check_flushsa_stub
, NULL
);
441 #endif /* ENABLE_NO_SA_FLUSH */
445 check_auto_exit(void)
447 if (lcconf
->auto_exit_sched
) { /* exit scheduled? */
448 if (lcconf
->auto_exit_state
!= LC_AUTOEXITSTATE_ENABLED
449 || vpn_control_connected() /* vpn control connected */
450 || policies_installed() /* policies installed in kernel */
451 || !no_remote_configs(FALSE
)) { /* remote or anonymous configs */
452 SCHED_KILL(lcconf
->auto_exit_sched
);
454 } else { /* exit not scheduled */
455 if (lcconf
->auto_exit_state
== LC_AUTOEXITSTATE_ENABLED
456 && !vpn_control_connected()
457 && !policies_installed()
458 && no_remote_configs(FALSE
)) {
459 if (lcconf
->auto_exit_delay
== 0) {
460 auto_exit_do(NULL
); /* immediate exit */
462 lcconf
->auto_exit_sched
= sched_new(lcconf
->auto_exit_delay
, auto_exit_do
, NULL
);
468 static int signals
[] = {
485 * XXX We are not able to tell if we got
486 * several time the same signal. This is
487 * not a problem for the current code,
488 * but we shall remember this limitation.
490 for (sig
= 0; sig
<= NSIG
; sig
++) {
491 if (sigreq
[sig
] == 0)
499 /* Catch up childs, mainly scripts.
505 if ((isakmp_cfg_init(ISAKMP_CFG_INIT_WARM
)) != 0) {
507 "ISAKMP mode config structure reset failed, "
516 * if we got a HUP... try graceful teardown of sessions before we close and reopen sockets...
517 * so that info-deletes notifications can make it to the peer.
520 ike_session_flush_all_phase2(true);
521 ike_session_flush_all_phase1(true);
524 /* Save old configuration, load new one... */
525 if (cfreparse(sig
)) {
527 "configuration read failed\n");
530 if (lcconf
->logfile_param
== NULL
&& logFileStr
[0] == 0)
531 plogresetfile(lcconf
->pathinfo
[LC_PATHTYPE_LOGFILE
]);
533 #if TARGET_OS_EMBEDDED
534 if (no_remote_configs(TRUE
)) {
535 #if ENABLE_NO_SA_FLUSH
538 pfkey_send_flush(lcconf
->sock_pfkey
, SADB_SATYPE_UNSPEC
);
539 #ifdef ENABLE_FASTQUIT
542 sched_new(1, check_flushsa_stub
, NULL
);
543 #endif /* ENABLE_FASTQUIT */
545 #endif /* ENABLE_NO_SA_FLUSH */
554 "caught signal %d\n", sig
);
555 #if ENABLE_NO_SA_FLUSH
558 pfkey_send_flush(lcconf
->sock_pfkey
,
560 if ( sig
== SIGTERM
){
561 terminated
= 1; /* in case if it hasn't been set yet */
565 sched_new(1, check_flushsa_stub
, NULL
);
568 #endif /* ENABLE_NO_SA_FLUSH */
573 "caught signal %d\n", sig
);
581 * asynchronous requests will actually dispatched in the
582 * main loop in session().
585 signal_handler(int sig
, siginfo_t
*sigi
, void *ctx
)
588 plog(ASL_LEVEL_DEBUG
,
589 "%s received signal %d from pid %d uid %d\n\n",
590 __FUNCTION__
, sig
, sigi
->si_pid
, sigi
->si_uid
);
593 /* Do not just set it to 1, because we may miss some signals by just setting
597 if ( sig
== SIGTERM
){
600 dispatch_async(main_queue
,
612 for (i
= 0; signals
[i
] != 0; i
++) {
613 if (set_signal(signals
[i
], signal_handler
) < 0) {
615 "failed to set_signal (%s)\n",
624 set_signal(int sig
, RETSIGTYPE (*func
) (int, siginfo_t
*, void *))
628 memset((caddr_t
)&sa
, 0, sizeof(sa
));
629 sa
.sa_sigaction
= func
;
630 sa
.sa_flags
= SA_RESTART
| SA_SIGINFO
;
632 if (sigemptyset(&sa
.sa_mask
) < 0)
635 if (sigaction(sig
, &sa
, (struct sigaction
*)0) < 0)
642 fatal_error(int error
)
644 close_session(error
== 0 ? -1 : error
);
647 /* suspend all socket sources except pf_key */
651 if (lcconf
->rt_source
)
652 dispatch_suspend(lcconf
->rt_source
);
653 if (lcconf
->vpncontrol_source
)
654 dispatch_suspend(lcconf
->vpncontrol_source
);
655 isakmp_suspend_sockets();
664 #ifdef ENABLE_VPNCONTROL_PORT