/home/build/libreswan/programs/pluto/kernel.c

Bug Summary

File:	programs/pluto/kernel.c
Warning:	line 1242, column 3 7th function call argument is an uninitialized value
Annotated Source Code

Press '?' to see keyboard shortcuts
Show analyzer invocation
clang -cc1 -triple x86_64-unknown-linux-gnu -analyze -disable-free -disable-llvm-verifier -discard-value-names -main-file-name kernel.c -analyzer-store=region -analyzer-opt-analyze-nested-blocks -analyzer-checker=core -analyzer-checker=apiModeling -analyzer-checker=unix -analyzer-checker=deadcode -analyzer-checker=security.insecureAPI.UncheckedReturn -analyzer-checker=security.insecureAPI.getpw -analyzer-checker=security.insecureAPI.gets -analyzer-checker=security.insecureAPI.mktemp -analyzer-checker=security.insecureAPI.mkstemp -analyzer-checker=security.insecureAPI.vfork -analyzer-checker=nullability.NullPassedToNonnull -analyzer-checker=nullability.NullReturnedFromNonnull -analyzer-output plist -w -mrelocation-model pic -pic-level 2 -pic-is-pie -mthread-model posix -mdisable-fp-elim -relaxed-aliasing -fmath-errno -masm-verbose -mconstructor-aliases -munwind-tables -fuse-init-array -target-cpu x86-64 -dwarf-column-info -debugger-tuning=gdb -resource-dir /usr/lib64/clang/8.0.0 -D TimeZoneOffset=timezone -D linux -D PIE -D NSS_IPSEC_PROFILE -D XFRM_SUPPORT -D USE_XFRM_INTERFACE -D USE_DNSSEC -D DEFAULT_DNSSEC_ROOTKEY_FILE="/var/lib/unbound/root.key" -D HAVE_LABELED_IPSEC -D HAVE_SECCOMP -D LIBCURL -D USE_LINUX_AUDIT -D USE_SYSTEMD_WATCHDOG -D HAVE_NM -D XAUTH_HAVE_PAM -D USE_3DES -D USE_AES -D USE_CAMELLIA -D USE_CHACHA -D USE_DH31 -D USE_MD5 -D USE_SHA1 -D USE_SHA2 -D USE_PRF_AES_XCBC -D DEFAULT_RUNDIR="/run/pluto" -D IPSEC_CONF="/etc/ipsec.conf" -D IPSEC_CONFDDIR="/etc/ipsec.d" -D IPSEC_NSSDIR="/etc/ipsec.d" -D IPSEC_CONFDIR="/etc" -D IPSEC_EXECDIR="/usr/local/libexec/ipsec" -D IPSEC_SBINDIR="/usr/local/sbin" -D IPSEC_VARDIR="/var" -D POLICYGROUPSDIR="/etc/ipsec.d/policies" -D IPSEC_SECRETS_FILE="/etc/ipsec.secrets" -D FORCE_PR_ASSERT -D USE_FORK=1 -D USE_VFORK=0 -D USE_DAEMON=0 -D USE_PTHREAD_SETSCHEDPRIO=1 -D GCC_LINT -D HAVE_LIBCAP_NG -I . -I ../../OBJ.linux.x86_64/programs/pluto -I ../../include -I /usr/include/nss3 -I /usr/include/nspr4 -I /home/build/libreswan/programs/pluto/linux-copy -D HERE_BASENAME="kernel.c" -internal-isystem /usr/local/include -internal-isystem /usr/lib64/clang/8.0.0/include -internal-externc-isystem /include -internal-externc-isystem /usr/include -Wno-missing-field-initializers -std=gnu99 -fdebug-compilation-dir /home/build/libreswan/programs/pluto -ferror-limit 19 -fmessage-length 0 -stack-protector 3 -fobjc-runtime=gcc -fdiagnostics-show-option -analyzer-output=html -o /tmp/scan-build-2020-09-09-193337-25440-1 -x c /home/build/libreswan/programs/pluto/kernel.c -faddrsig
1/* routines that interface with the kernel's IPsec mechanism, for libreswan
*
* Copyright (C) 1997 Angelos D. Keromytis.
* Copyright (C) 1998-2010  D. Hugh Redelmeier.
* Copyright (C) 2003-2008 Michael Richardson <mcr@xelerance.com>
* Copyright (C) 2007-2010 Paul Wouters <paul@xelerance.com>
* Copyright (C) 2008-2010 David McCullough <david_mccullough@securecomputing.com>
* Copyright (C) 2010 Bart Trojanowski <bart@jukie.net>
* Copyright (C) 2009-2010 Tuomo Soini <tis@foobar.fi>
* Copyright (C) 2010 Avesh Agarwal <avagarwa@redhat.com>
* Copyright (C) 2010-2019 D. Hugh Redelmeier <hugh@mimosa.com>
* Copyright (C) 2012-2015 Paul Wouters <paul@libreswan.org>
* Copyright (C) 2013 Kim B. Heino <b@bbbs.net>
* Copyright (C) 2016-2019 Andrew Cagney <cagney@gnu.org>
* Copyright (C) 2019 Paul Wouters <pwouters@redhat.com>
* Copyright (C) 2017 Mayank Totale <mtotale@gmail.com>
*
* This program is free software; you can redistribute it and/or modify it
* under the terms of the GNU General Public License as published by the
* Free Software Foundation; either version 2 of the License, or (at your
* option) any later version.  See <https://www.gnu.org/licenses/gpl2.txt>.
*
* This program is distributed in the hope that it will be useful, but
* WITHOUT ANY WARRANTY; without even the implied warranty of MERCHANTABILITY
* or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU General Public License
* for more details.
*/

29#include <stddef.h>
30#include <string.h>
31#include <stdio.h>
32#include <stdlib.h>
33#include <errno(*__errno_location ()).h>
34#include <sys/wait.h>		/* for WIFEXITED() et.al. */
35#include <unistd.h>
36#include <fcntl.h>
37#include <sys/utsname.h>
38#include <sys/ioctl.h>

40#include <sys/stat.h>
41#include <sys/socket.h>
42#include <netinet/in.h>
43#include <arpa/inet.h>

45#include <event2/event.h>
46#include <event2/event_struct.h>
47#include <event2/thread.h>


50#include "sysdep.h"
51#include "constants.h"
52#include "lsw-pfkeyv2.h"	/* for SADB_X_CALG_DEFLATE et.al., grrr */

54#include "defs.h"
55#include "rnd.h"
56#include "id.h"
57#include "connections.h"        /* needs id.h */
58#include "state.h"
59#include "timer.h"
60#include "kernel.h"
61#include "kernel_xfrm.h"
62#include "packet.h"
63#include "x509.h"
64#include "pluto_x509.h"
65#include "certs.h"
66#include "secrets.h"
67#include "log.h"
68#include "server.h"
69#include "whack.h"      /* for RC_LOG_SERIOUS */
70#include "keys.h"
71#include "ike_alg.h"
72#include "ike_alg_encrypt.h"
73#include "ike_alg_integ.h"

75#include "packet.h"  /* for pb_stream in nat_traversal.h */
76#include "nat_traversal.h"
77#include "ip_address.h"
78#include "ip_info.h"
79#include "lswfips.h" /* for libreswan_fipsmode() */
80# include "kernel_xfrm_interface.h"
81#include "iface.h"
82#include "ip_selector.h"
83#include "ip_encap.h"
84#include "show.h"

86bool_Bool can_do_IPcomp = TRUE1;  /* can system actually perform IPCOMP? */

88/* test if the routes required for two different connections agree
* It is assumed that the destination subnets agree; we are only
* testing that the interfaces and nexthops match.
*/
92#define routes_agree(c, d)((c)->interface->ip_dev == (d)->interface->ip_dev
 && sameaddr(&(c)->spd.this.host_nexthop, &
(d)->spd.this.host_nexthop)) \
((c)->interface->ip_dev == (d)->interface->ip_dev && \
sameaddr(&(c)->spd.this.host_nexthop, &(d)->spd.this.host_nexthop))

96const struct pfkey_proto_info null_proto_info[2] = {
{
.proto = IPPROTO_ESPIPPROTO_ESP,
.mode = ENCAPSULATION_MODE_TRANSPORT2,
.reqid = 0
},
{
.proto = 0,
.mode = 0,
.reqid = 0
}
107};

109struct bare_shunt {
policy_prio_t policy_prio;
ip_selector our_client;
ip_selector peer_client;
ip_said said;
int transport_proto; /* XXX: same value in local/remote */
unsigned long count;
monotime_t last_activity;

/*
* Note: "why" must be in stable storage (not auto, not heap)
* because we use it indefinitely without copying or pfreeing.
* Simple rule: use a string literal.
*/
const char *why;
/* the connection from where it came - used to re-load /32 conns */
char *from_cn;

struct bare_shunt *next;
128};

130static struct bare_shunt *bare_shunts = NULL((void*)0);

132#ifdef IPSEC_CONNECTION_LIMIT
133static int num_ipsec_eroute = 0;
134#endif

136static void log_bare_shunt(lset_t rc_flags, const char *op, const struct bare_shunt *bs)
137{
said_buf sat;
selector_buf ourb;
selector_buf peerb;

char prio[POLICY_PRIO_BUF(3 + 1 + 3 + 1 + 10)];
fmt_policy_prio(bs->policy_prio, prio);

log_global(rc_flags, null_fd,{ struct logger log_ = (struct logger) { .where = (where_t) {
 .func = __func__, .basename = "kernel.c" , .line = 152}, .global_whackfd
 = ((struct fd *) ((void*)0)), .object = ((void*)0), .object_vec
 = &logger_global_vec, }; log_message(rc_flags, &log_
, "%s bare shunt %p %s --%d--> %s => %s %s    %s", op, (
const void *)bs, str_selector(&bs->our_client, &ourb
), bs->transport_proto, str_selector(&bs->peer_client
, &peerb), str_said(&bs->said, &sat), prio, bs
->why); }
   "%s bare shunt %p %s --%d--> %s => %s %s    %s",{ struct logger log_ = (struct logger) { .where = (where_t) {
 .func = __func__, .basename = "kernel.c" , .line = 152}, .global_whackfd
 = ((struct fd *) ((void*)0)), .object = ((void*)0), .object_vec
 = &logger_global_vec, }; log_message(rc_flags, &log_
, "%s bare shunt %p %s --%d--> %s => %s %s    %s", op, (
const void *)bs, str_selector(&bs->our_client, &ourb
), bs->transport_proto, str_selector(&bs->peer_client
, &peerb), str_said(&bs->said, &sat), prio, bs
->why); }
   op, (const void *)bs,{ struct logger log_ = (struct logger) { .where = (where_t) {
 .func = __func__, .basename = "kernel.c" , .line = 152}, .global_whackfd
 = ((struct fd *) ((void*)0)), .object = ((void*)0), .object_vec
 = &logger_global_vec, }; log_message(rc_flags, &log_
, "%s bare shunt %p %s --%d--> %s => %s %s    %s", op, (
const void *)bs, str_selector(&bs->our_client, &ourb
), bs->transport_proto, str_selector(&bs->peer_client
, &peerb), str_said(&bs->said, &sat), prio, bs
->why); }
   str_selector(&bs->our_client, &ourb),{ struct logger log_ = (struct logger) { .where = (where_t) {
 .func = __func__, .basename = "kernel.c" , .line = 152}, .global_whackfd
 = ((struct fd *) ((void*)0)), .object = ((void*)0), .object_vec
 = &logger_global_vec, }; log_message(rc_flags, &log_
, "%s bare shunt %p %s --%d--> %s => %s %s    %s", op, (
const void *)bs, str_selector(&bs->our_client, &ourb
), bs->transport_proto, str_selector(&bs->peer_client
, &peerb), str_said(&bs->said, &sat), prio, bs
->why); }
   bs->transport_proto,{ struct logger log_ = (struct logger) { .where = (where_t) {
 .func = __func__, .basename = "kernel.c" , .line = 152}, .global_whackfd
 = ((struct fd *) ((void*)0)), .object = ((void*)0), .object_vec
 = &logger_global_vec, }; log_message(rc_flags, &log_
, "%s bare shunt %p %s --%d--> %s => %s %s    %s", op, (
const void *)bs, str_selector(&bs->our_client, &ourb
), bs->transport_proto, str_selector(&bs->peer_client
, &peerb), str_said(&bs->said, &sat), prio, bs
->why); }
   str_selector(&bs->peer_client, &peerb),{ struct logger log_ = (struct logger) { .where = (where_t) {
 .func = __func__, .basename = "kernel.c" , .line = 152}, .global_whackfd
 = ((struct fd *) ((void*)0)), .object = ((void*)0), .object_vec
 = &logger_global_vec, }; log_message(rc_flags, &log_
, "%s bare shunt %p %s --%d--> %s => %s %s    %s", op, (
const void *)bs, str_selector(&bs->our_client, &ourb
), bs->transport_proto, str_selector(&bs->peer_client
, &peerb), str_said(&bs->said, &sat), prio, bs
->why); }
   str_said(&bs->said, &sat),{ struct logger log_ = (struct logger) { .where = (where_t) {
 .func = __func__, .basename = "kernel.c" , .line = 152}, .global_whackfd
 = ((struct fd *) ((void*)0)), .object = ((void*)0), .object_vec
 = &logger_global_vec, }; log_message(rc_flags, &log_
, "%s bare shunt %p %s --%d--> %s => %s %s    %s", op, (
const void *)bs, str_selector(&bs->our_client, &ourb
), bs->transport_proto, str_selector(&bs->peer_client
, &peerb), str_said(&bs->said, &sat), prio, bs
->why); }
   prio, bs->why){ struct logger log_ = (struct logger) { .where = (where_t) {
 .func = __func__, .basename = "kernel.c" , .line = 152}, .global_whackfd
 = ((struct fd *) ((void*)0)), .object = ((void*)0), .object_vec
 = &logger_global_vec, }; log_message(rc_flags, &log_
, "%s bare shunt %p %s --%d--> %s => %s %s    %s", op, (
const void *)bs, str_selector(&bs->our_client, &ourb
), bs->transport_proto, str_selector(&bs->peer_client
, &peerb), str_said(&bs->said, &sat), prio, bs
->why); };
153}

155static void dbg_bare_shunt(const char *op, const struct bare_shunt *bs)
156{
/* same as log_bare_shunt but goes to debug log */
if (DBGP(DBG_BASE)(cur_debugging & (((lset_t)1 << (DBG_BASE_IX))))) {
log_bare_shunt(DEBUG_STREAM, op, bs);
}
161}

163/*
* Note: "why" must be in stable storage (not auto, not heap)
* because we use it indefinitely without copying or pfreeing.
* Simple rule: use a string literal.
*/
168void add_bare_shunt(const ip_subnet *our_client, const ip_subnet *peer_client,
    int transport_proto, ipsec_spi_t shunt_spi,
    const char *why)
171{
/* report any duplication; this should NOT happen */
struct bare_shunt **bspp = bare_shunt_ptr(our_client, peer_client, transport_proto);

if (bspp != NULL((void*)0)) {
/* maybe: passert(bsp == NULL); */
log_bare_shunt(RC_LOG, "CONFLICTING existing", *bspp);
}

struct bare_shunt *bs = alloc_thing(struct bare_shunt,((struct bare_shunt*) alloc_bytes(sizeof(struct bare_shunt), (
"bare shunt")))
			"bare shunt")((struct bare_shunt*) alloc_bytes(sizeof(struct bare_shunt), (
"bare shunt")));

bs->why = why;
bs->from_cn = NULL((void*)0);
bs->our_client = *our_client;
bs->peer_client = *peer_client;
bs->transport_proto = transport_proto;
bs->policy_prio = BOTTOM_PRIO((policy_prio_t)0);

bs->said = said3(&subnet_type(our_client)->any_address, htonl(shunt_spi), &ip_protocol_internal);
bs->count = 0;
bs->last_activity = mononow();

bs->next = bare_shunts;
bare_shunts = bs;
dbg_bare_shunt("add", bs);

/* report duplication; this should NOT happen */
if (bspp != NULL((void*)0)) {
log_bare_shunt(RC_LOG, "CONFLICTING      new", bs);
}
202}


205/*
* Note: "why" must be in stable storage (not auto, not heap)
* because we use it indefinitely without copying or pfreeing.
* Simple rule: use a string literal.
*/

211void record_and_initiate_opportunistic(const ip_selector *our_client,
		       const ip_selector *peer_client,
		       unsigned transport_proto,
		       struct xfrm_user_sec_ctx_ike *uctx,
		       const char *why)
216{
passert(selector_type(our_client) == selector_type(peer_client)){ _Bool assertion__ = selector_type(our_client) == selector_type
(peer_client); if (!assertion__) { lsw_passert_fail((where_t)
 { .func = __func__, .basename = "kernel.c" , .line = 217}, "%s"
, "selector_type(our_client) == selector_type(peer_client)");
 } };
passert(selector_ipproto(our_client) == transport_proto){ _Bool assertion__ = selector_ipproto(our_client) == transport_proto
; if (!assertion__) { lsw_passert_fail((where_t) { .func = __func__
, .basename = "kernel.c" , .line = 218}, "%s", "selector_ipproto(our_client) == transport_proto"
); } };
passert(selector_ipproto(peer_client) == transport_proto){ _Bool assertion__ = selector_ipproto(peer_client) == transport_proto
; if (!assertion__) { lsw_passert_fail((where_t) { .func = __func__
, .basename = "kernel.c" , .line = 219}, "%s", "selector_ipproto(peer_client) == transport_proto"
); } };
/* XXX: port may or may not be zero */

/*
* Add the kernel shunt to the pluto bare shunt list.
*
* We need to do this because the %hold shunt was installed by
* kernel and we want to keep track of it inside pluto.
*/

/*const*/ struct bare_shunt **bspp = bare_shunt_ptr(our_client, peer_client,
					    transport_proto);
if (bspp != NULL((void*)0) &&
   (*bspp)->said.proto == &ip_protocol_internal &&
   (*bspp)->said.spi == htonl(SPI_HOLD259)) {
log_global(RC_LOG_SERIOUS, null_fd, "existing bare shunt found - refusing to add a duplicate"){ struct logger log_ = (struct logger) { .where = (where_t) {
 .func = __func__, .basename = "kernel.c" , .line = 234}, .global_whackfd
 = ((struct fd *) ((void*)0)), .object = ((void*)0), .object_vec
 = &logger_global_vec, }; log_message(RC_LOG_SERIOUS, &
log_, "existing bare shunt found - refusing to add a duplicate"
); };
/* should we continue with initiate_ondemand() ? */
} else {
add_bare_shunt(our_client, peer_client, transport_proto, SPI_HOLD259, why);
}

/* XXX: missing transport_proto */
ip_address sp = subnet_prefix(our_client);
ip_address dp = subnet_prefix(peer_client);
ip_endpoint src = endpoint(&sp, subnet_hport(our_client));
ip_endpoint dst = endpoint(&dp, subnet_hport(peer_client));
passert(endpoint_type(&src) == endpoint_type(&dst)){ _Bool assertion__ = endpoint_type(&src) == endpoint_type
(&dst); if (!assertion__) { lsw_passert_fail((where_t) { .
func = __func__, .basename = "kernel.c" , .line = 245}, "%s",
 "endpoint_type(&src) == endpoint_type(&dst)"); } }; /* duh */

/* actually initiate opportunism / ondemand */
initiate_ondemand(&src, &dst, transport_proto,
	  TRUE1, null_fd((struct fd *) ((void*)0)), true1/*background*/,
	  uctx, "acquire");

if (kernel_ops->remove_orphaned_holds != NULL((void*)0)) {
dbg("record_and_initiate_opportunistic(): tell kernel to remove orphan hold for our bare shunt"){ if ((cur_debugging & (((lset_t)1 << (DBG_BASE_IX)
)))) { DBG_log("record_and_initiate_opportunistic(): tell kernel to remove orphan hold for our bare shunt"
); } };
kernel_ops->remove_orphaned_holds(transport_proto,
				  our_client, peer_client);
}
257}

259static reqid_t get_proto_reqid(reqid_t base, const struct ip_protocol *proto)
260{
if (proto == &ip_protocol_comp)
return reqid_ipcomp(base);

if (proto == &ip_protocol_esp)
return reqid_esp(base);

if (proto == &ip_protocol_ah)
return reqid_ah(base);

PASSERT_FAIL("bad protocol %s", proto->name)lsw_passert_fail((where_t) { .func = __func__, .basename = "kernel.c"
 , .line = 270}, "bad protocol %s", proto->name);
271}

273/* Generate Unique SPI numbers.
*
* The specs say that the number must not be less than IPSEC_DOI_SPI_MIN.
* Pluto generates numbers not less than IPSEC_DOI_SPI_OUR_MIN,
* reserving numbers in between for manual keying (but we cannot so
* restrict numbers generated by our peer).
* XXX This should be replaced by a call to the kernel when
* XXX we get an API.
* The returned SPI is in network byte order.
* We use a random number as the initial SPI so that there is
* a good chance that different Pluto instances will choose
* different SPIs.  This is good for two reasons.
* - the keying material for the initiator and responder only
*   differs if the SPIs differ.
* - if Pluto is restarted, it would otherwise recycle the SPI
*   numbers and confuse everything.  When the kernel generates
*   SPIs, this will no longer matter.
* We then allocate numbers sequentially.  Thus we don't have to
* check if the number was previously used (assuming that no
* SPI lives longer than 4G of its successors).
*/
294ipsec_spi_t get_ipsec_spi(ipsec_spi_t avoid,
	const struct ip_protocol *proto,
	const struct spd_route *sr,
	bool_Bool tunnel)
298{
passert(proto == &ip_protocol_ah || proto == &ip_protocol_esp){ _Bool assertion__ = proto == &ip_protocol_ah || proto ==
 &ip_protocol_esp; if (!assertion__) { lsw_passert_fail((
where_t) { .func = __func__, .basename = "kernel.c" , .line =
 299}, "%s", "proto == &ip_protocol_ah || proto == &ip_protocol_esp"
); } };

if (kernel_ops->get_spi != NULL((void*)0)) {
char text_said[SATOT_BUFsizeof(said_buf)];
set_text_said(text_said, &sr->this.host_addr, 0, proto);
return kernel_ops->get_spi(&sr->that.host_addr,
			&sr->this.host_addr, proto, tunnel,
			get_proto_reqid(sr->reqid, proto),
			IPSEC_DOI_SPI_OUR_MIN0x1000, 0xffffffff,
			text_said);
} else {
static ipsec_spi_t spi = 0; /* host order, so not returned directly! */

spi++;
while (spi < IPSEC_DOI_SPI_OUR_MIN0x1000 || spi == ntohl(avoid))
	get_rnd_bytes((u_char *)&spi, sizeof(spi));

if (DBGP(DBG_BASE)(cur_debugging & (((lset_t)1 << (DBG_BASE_IX))))) {
	ipsec_spi_t spi_net = htonl(spi);
	DBG_dump("generate SPI:", (u_char *)&spi_net,
		 sizeof(spi_net));
}

return htonl(spi);
}
324}

326/* Generate Unique CPI numbers.
* The result is returned as an SPI (4 bytes) in network order!
* The real bits are in the nework-low-order 2 bytes.
* Modelled on get_ipsec_spi, but range is more limited:
* 256-61439.
* If we can't find one easily, return 0 (a bad SPI,
* no matter what order) indicating failure.
*/
334ipsec_spi_t get_my_cpi(const struct spd_route *sr, bool_Bool tunnel)
335{
if (kernel_ops->get_spi != NULL((void*)0)) {
char text_said[SATOT_BUFsizeof(said_buf)];
set_text_said(text_said, &sr->this.host_addr, 0, &ip_protocol_comp);
return kernel_ops->get_spi(&sr->that.host_addr,
			&sr->this.host_addr, &ip_protocol_comp,
			tunnel,
			get_proto_reqid(sr->reqid, &ip_protocol_comp),
			IPCOMP_FIRST_NEGOTIATED256,
			IPCOMP_LAST_NEGOTIATED61439,
			text_said);
} else {
static cpi_t first_busy_cpi = 0;
static cpi_t latest_cpi = 0;

while (!(IPCOMP_FIRST_NEGOTIATED256 <= first_busy_cpi &&
		first_busy_cpi < IPCOMP_LAST_NEGOTIATED61439)) {
	get_rnd_bytes((u_char *)&first_busy_cpi,
		sizeof(first_busy_cpi));
	latest_cpi = first_busy_cpi;
}

latest_cpi++;

if (latest_cpi == first_busy_cpi)
	find_my_cpi_gap(&latest_cpi, &first_busy_cpi);

if (latest_cpi > IPCOMP_LAST_NEGOTIATED61439)
	latest_cpi = IPCOMP_FIRST_NEGOTIATED256;

return htonl((ipsec_spi_t)latest_cpi);
}
367}

369/*
* Remove all characters but [-_.0-9a-zA-Z] from a character string.
* Truncates the result if it would be too long.
*/

374static void jam_clean_xauth_username(struct jambuf *buf, const char *src)
375{
bool_Bool changed = false0;
const char *dst = jambuf_cursor(buf);
while (*src != '\0') {
if ((*src >= '0' && *src <= '9') ||
    (*src >= 'a' && *src <= 'z') ||
    (*src >= 'A' && *src <= 'Z') ||
    *src == '_' || *src == '-' || *src == '.') {
	jam_char(buf, *src);
} else {
	changed = true1;
}
src++;
}
if (changed || !jambuf_ok(buf)) {
libreswan_log("Warning: XAUTH username changed from '%s' to '%s'",loglog(RC_LOG, "Warning: XAUTH username changed from '%s' to '%s'"
, src, dst)
	      src, dst)loglog(RC_LOG, "Warning: XAUTH username changed from '%s' to '%s'"
, src, dst);
}
393}

395/*
* form the command string
*
* note: this mutates *st by calling get_sa_info().
*/
400static void jam_common_shell_out(struct jambuf *buf, const struct connection *c,
		 const struct spd_route *sr, struct state *st,
		 bool_Bool inbytes, bool_Bool outbytes)
403{
ip_address ta;

char *id_vname = NULL((void*)0);

if (c->xfrmi != NULL((void*)0) && c->xfrmi->name != NULL((void*)0))
id_vname = c->xfrmi->name;
else
id_vname = "NULL";

/* change VERSION when interface spec changes */
jam(buf, "PLUTO_VERSION='2.0' ");
jam(buf, "PLUTO_CONNECTION='%s' ", c->name);
jam(buf, "PLUTO_VIRT_INTERFACE='%s' ", id_vname);
jam(buf, "PLUTO_INTERFACE='%s' ", c->interface == NULL((void*)0) ? "NULL" : c->interface->ip_dev->id_rname);
jam(buf, "PLUTO_XFRMI_ROUTE='%s' ",  (c->xfrmi != NULL((void*)0) && c->xfrmi->if_id > 0) ? "yes" : "");

if (address_is_specified(&sr->this.host_nexthop)) {
jam(buf, "PLUTO_NEXT_HOP='");
jam_address(buf, &sr->this.host_nexthop);
jam(buf, "' ");
}

ipstr_buf bme;
jam(buf, "PLUTO_ME='%s' ", ipstr(&sr->this.host_addr, &bme));

jam(buf, "PLUTO_MY_ID='");
jam_id(buf, &sr->this.id, jam_meta_escaped_bytes);
jam(buf, "' ");

jam(buf, "PLUTO_MY_CLIENT='");
jam_subnet(buf, &sr->this.client);
jam(buf, "' ");

jam(buf, "PLUTO_MY_CLIENT_NET='");
ta = subnet_prefix(&sr->this.client);
jam_address(buf, &ta);
jam(buf, "' ");

jam(buf, "PLUTO_MY_CLIENT_MASK='");
ta = subnet_mask(&sr->this.client);
jam_address(buf, &ta);
jam(buf, "' ");

if (subnet_is_specified(&sr->this.host_vtiip)) {
jam(buf, "VTI_IP='");
jam_subnet(buf, &sr->this.host_vtiip);
jam(buf, "' ");
}

if (!isanyaddr(&sr->this.ifaceip.addr)) {
jam(buf, "INTERFACE_IP='");
jam_subnet(buf, &sr->this.ifaceip);
jam(buf, "' ");
}

jam(buf, "PLUTO_MY_PORT='%u' ", sr->this.port);
jam(buf, "PLUTO_MY_PROTOCOL='%u' ", sr->this.protocol);
jam(buf, "PLUTO_SA_REQID='%u' ", sr->reqid);
jam(buf, "PLUTO_SA_TYPE='%s' ", (st == NULL((void*)0) ? "none" :
			st->st_esp.present ? "ESP" :
			st->st_ah.present ? "AH" :
			st->st_ipcomp.present ? "IPCOMP" :
			"unknown?"));
ipstr_buf bpeer;
jam(buf, "PLUTO_PEER='%s' ", ipstr(&sr->that.host_addr, &bpeer));

jam(buf, "PLUTO_PEER_ID='");
jam_id(buf, &sr->that.id, jam_meta_escaped_bytes);
jam(buf, "' ");

jam(buf, "PLUTO_PEER_CLIENT='");
jam_subnet(buf, &sr->that.client);
jam(buf, "' ");

jam(buf, "PLUTO_PEER_CLIENT_NET='");
ta = subnet_prefix(&sr->that.client);
jam_address(buf, &ta);
jam(buf, "' ");

jam(buf, "PLUTO_PEER_CLIENT_MASK='");
ta = subnet_mask(&sr->that.client);
jam_address(buf, &ta);
jam(buf, "' ");

jam(buf, "PLUTO_PEER_PORT='%u' ", sr->that.port);
jam(buf, "PLUTO_PEER_PROTOCOL='%u' ", sr->that.protocol);

jam(buf, "PLUTO_PEER_CA='");
for (struct pubkey_list *p = pluto_pubkeys; p != NULL((void*)0); p = p->next) {
struct pubkey *key = p->key;
int pathlen;	/* value ignored */
if (key->type == &pubkey_type_rsa &&
    same_id(&sr->that.id, &key->id) &&
    trusted_ca_nss(key->issuer, sr->that.ca, &pathlen)) {
	jam_dn_or_null(buf, key->issuer, "", jam_meta_escaped_bytes);
	break;
}
}
jam(buf, "' ");

jam(buf, "PLUTO_STACK='%s' ", kernel_ops->kern_name);

if (c->metric != 0) {
jam(buf, "PLUTO_METRIC=%d ", c->metric);
}

if (c->connmtu != 0) {
jam(buf, "PLUTO_MTU=%d ", c->connmtu);
}

jam(buf, "PLUTO_ADDTIME='%" PRIu64"l" "u" "' ", st == NULL((void*)0) ? (uint64_t)0 : st->st_esp.add_time);
jam(buf, "PLUTO_CONN_POLICY='%s%s' ", prettypolicy(c->policy), NEVER_NEGOTIATE(c->policy)(((((c->policy)) & (((lset_t)1 << (POLICY_ENCRYPT_IX
)) | ((lset_t)1 << (POLICY_AUTHENTICATE_IX)))) == ((lset_t
)0))) ? "+NEVER_NEGOTIATE" : "");
jam(buf, "PLUTO_CONN_KIND='%s' ", enum_show(&connection_kind_names, c->kind));
jam(buf, "PLUTO_CONN_ADDRFAMILY='ipv%d' ", address_type(&sr->this.host_addr)->ip_version);
jam(buf, "XAUTH_FAILED=%d ", (st != NULL((void*)0) && st->st_xauth_soft) ? 1 : 0);

if (st != NULL((void*)0) && st->st_xauth_username[0] != '\0') {
jam(buf, "PLUTO_USERNAME='");
jam_clean_xauth_username(buf, st->st_xauth_username);
jam(buf, "' ");
}

if (address_is_specified(&sr->this.host_srcip)) {
jam(buf, "PLUTO_MY_SOURCEIP='");
jam_address(buf, &sr->this.host_srcip);
jam(buf, "' ");
if (st != NULL((void*)0))
	jam(buf, "PLUTO_MOBIKE_EVENT='%s' ",
			st->st_mobike_del_src_ip ? "yes" : "");
}

jam(buf, "PLUTO_IS_PEER_CISCO='%u' ", c->remotepeertype /* ??? kind of odd printing an enum with %u */);
jam(buf, "PLUTO_PEER_DNS_INFO='%s' ", (st != NULL((void*)0) && st->st_seen_cfg_dns != NULL((void*)0)) ? st->st_seen_cfg_dns : "");
jam(buf, "PLUTO_PEER_DOMAIN_INFO='%s' ", (st != NULL((void*)0) && st->st_seen_cfg_domains != NULL((void*)0)) ? st->st_seen_cfg_domains : "");
jam(buf, "PLUTO_PEER_BANNER='%s' ", (st != NULL((void*)0) && st->st_seen_cfg_banner != NULL((void*)0)) ? st->st_seen_cfg_banner : "");
jam(buf, "PLUTO_CFG_SERVER='%u' ", sr->this.modecfg_server);
jam(buf, "PLUTO_CFG_CLIENT='%u' ", sr->this.modecfg_client);
541#ifdef HAVE_NM1
jam(buf, "PLUTO_NM_CONFIGURED='%u' ", c->nmconfigured);
543#endif

if (inbytes) {
jam(buf, "PLUTO_INBYTES='%" PRIu64"l" "u" "' ",
    st->st_esp.present ? st->st_esp.our_bytes :
    st->st_ah.present ? st->st_ah.our_bytes :
    st->st_ipcomp.present ? st->st_ipcomp.our_bytes :
    0);
}
if (outbytes) {
jam(buf, "PLUTO_OUTBYTES='%" PRIu64"l" "u" "' ",
    st->st_esp.present ? st->st_esp.peer_bytes :
    st->st_ah.present ? st->st_ah.peer_bytes :
    st->st_ipcomp.present ? st->st_ipcomp.peer_bytes :
    0);
}

if (c->nflog_group != 0) {
jam(buf, "NFLOG=%d ", c->nflog_group);
}

if (c->sa_marks.in.val != 0) {
jam(buf, "CONNMARK_IN=%" PRIu32"u" "/%#08" PRIx32"x" " ",
    c->sa_marks.in.val, c->sa_marks.in.mask);
}
if (c->sa_marks.out.val != 0) {
jam(buf, "CONNMARK_OUT=%" PRIu32"u" "/%#08" PRIx32"x" " ",
    c->sa_marks.out.val, c->sa_marks.out.mask);
}
if (c->xfrmi != NULL((void*)0) && c->xfrmi->if_id > 0) {
if (addrinsubnet(&sr->that.host_addr, &sr->that.client)) {
	jam(buf, "PLUTO_XFRMI_FWMARK='%" PRIu32"u" "/0xffffffff' ",
			c->xfrmi->if_id);
} else {
	address_buf bpeer;
	subnet_buf peerclient_str;
	dbg("not adding PLUTO_XFRMI_FWMARK. PLUTO_PEER=%s is not inside PLUTO_PEER_CLIENT=%s",{ if ((cur_debugging & (((lset_t)1 << (DBG_BASE_IX)
)))) { DBG_log("not adding PLUTO_XFRMI_FWMARK. PLUTO_PEER=%s is not inside PLUTO_PEER_CLIENT=%s"
, str_address(&sr->that.host_addr, &bpeer), str_subnet
(&sr->that.client, &peerclient_str)); } }
	    str_address(&sr->that.host_addr, &bpeer),{ if ((cur_debugging & (((lset_t)1 << (DBG_BASE_IX)
)))) { DBG_log("not adding PLUTO_XFRMI_FWMARK. PLUTO_PEER=%s is not inside PLUTO_PEER_CLIENT=%s"
, str_address(&sr->that.host_addr, &bpeer), str_subnet
(&sr->that.client, &peerclient_str)); } }
	    str_subnet(&sr->that.client, &peerclient_str)){ if ((cur_debugging & (((lset_t)1 << (DBG_BASE_IX)
)))) { DBG_log("not adding PLUTO_XFRMI_FWMARK. PLUTO_PEER=%s is not inside PLUTO_PEER_CLIENT=%s"
, str_address(&sr->that.host_addr, &bpeer), str_subnet
(&sr->that.client, &peerclient_str)); } };
	jam(buf, "PLUTO_XFRMI_FWMARK='' ");
}
}
jam(buf, "VTI_IFACE='%s' ", c->vti_iface ? c->vti_iface : "");
jam(buf, "VTI_ROUTING='%s' ", bool_str(c->vti_routing));
jam(buf, "VTI_SHARED='%s' ", bool_str(c->vti_shared));

if (sr->this.has_cat) {
jam(buf, "CAT='YES' ");
}

jam(buf, "SPI_IN=0x%x SPI_OUT=0x%x " /* SPI_IN SPI_OUT */,
   (st == NULL((void*)0) ? 0 : st->st_esp.present ? ntohl(st->st_esp.attrs.spi) :
    st->st_ah.present ? ntohl(st->st_ah.attrs.spi) :
    st->st_ipcomp.present ? ntohl(st->st_ipcomp.attrs.spi) : 0),
   (st == NULL((void*)0) ? 0 : st->st_esp.present ? ntohl(st->st_esp.our_spi) :
    st->st_ah.present ? ntohl(st->st_ah.our_spi) :
    st->st_ipcomp.present ? ntohl(st->st_ipcomp.our_spi) : 0));
600}

602/*
* form the command string
*
* note: this mutates *st by calling fmt_traffic_str
*/
607bool_Bool fmt_common_shell_out(char *buf, size_t blen, const struct connection *c,
	  const struct spd_route *sr, struct state *st)
609{
/*
* note: this mutates *st by calling get_sa_info
*
* XXX: does the get_sa_info() call order matter? Should this
* be a single "atomic" call?
*
* true==inbound: inbound updates OUR_BYTES; !inbound updates
* PEER_BYTES.
*/
bool_Bool outbytes = st != NULL((void*)0) && get_sa_info(st, false0, NULL((void*)0));
bool_Bool inbytes = st != NULL((void*)0) && get_sa_info(st, true1, NULL((void*)0));
struct jambuf jambuf = array_as_jambuf(buf, blen);
jam_common_shell_out(&jambuf, c, sr, st, inbytes, outbytes);
return jambuf_ok(&jambuf);
624}

626bool_Bool do_command(const struct connection *c,
const struct spd_route *sr,
const char *verb,
struct state *st)
630{
const char *verb_suffix;

/*
* Support for skipping updown, eg leftupdown=""
* Useful on busy servers that do not need to use updown for anything
*/
if (sr->this.updown == NULL((void*)0) || streq(sr->this.updown, "%disabled")(strcmp((sr->this.updown), ("%disabled")) == 0)) {
dbg("skipped updown %s command - disabled per policy", verb){ if ((cur_debugging & (((lset_t)1 << (DBG_BASE_IX)
)))) { DBG_log("skipped updown %s command - disabled per policy"
, verb); } };
return TRUE1;
}
dbg("running updown command \"%s\" for verb %s ", sr->this.updown, verb){ if ((cur_debugging & (((lset_t)1 << (DBG_BASE_IX)
)))) { DBG_log("running updown command \"%s\" for verb %s ", sr
->this.updown, verb); } };

/*
* Figure out which verb suffix applies.
* NOTE: this is a duplicate of code in mast_do_command_vs.
*/
{
const char *hs, *cs;

switch (addrtypeof(&sr->this.host_addr)) {
case AF_INET2:
	hs = "-host";
	cs = "-client";
	break;
case AF_INET610:
	hs = "-host-v6";
	cs = "-client-v6";
	break;
default:
	loglog(RC_LOG_SERIOUS, "unknown address family");
	return FALSE0;
}
verb_suffix = subnetisaddr(&sr->this.client,(subnetishost(&sr->this.client) && addrinsubnet
((&sr->this.host_addr), (&sr->this.client)))
			&sr->this.host_addr)(subnetishost(&sr->this.client) && addrinsubnet
((&sr->this.host_addr), (&sr->this.client))) ?
	hs : cs;
}

dbg("command executing %s%s", verb, verb_suffix){ if ((cur_debugging & (((lset_t)1 << (DBG_BASE_IX)
)))) { DBG_log("command executing %s%s", verb, verb_suffix); }
 };

if (kernel_ops->docommand == NULL((void*)0)) {
dbg("no do_command for method %s", kernel_ops->kern_name){ if ((cur_debugging & (((lset_t)1 << (DBG_BASE_IX)
)))) { DBG_log("no do_command for method %s", kernel_ops->
kern_name); } };
} else {
return (*kernel_ops->docommand)(c, sr, verb, verb_suffix, st);
}
return TRUE1;
676}

678bool_Bool invoke_command(const char *verb, const char *verb_suffix, const char *cmd)
679{
680#	define CHUNK_WIDTH	80	/* units for cmd logging */
if (DBGP(DBG_BASE)(cur_debugging & (((lset_t)1 << (DBG_BASE_IX))))) {
int slen = strlen(cmd);
int i;

DBG_log("executing %s%s: %s",
	verb, verb_suffix, cmd);
DBG_log("popen cmd is %d chars long", slen);
for (i = 0; i < slen; i += CHUNK_WIDTH)
	DBG_log("cmd(%4d):%.*s:", i,
		slen-i < CHUNK_WIDTH? slen-i : CHUNK_WIDTH,
		&cmd[i]);
}
693#	undef CHUNK_WIDTH


{
/*
 * invoke the script, catching stderr and stdout
 * It may be of concern that some file descriptors will
 * be inherited.  For the ones under our control, we
 * have done fcntl(fd, F_SETFD, FD_CLOEXEC) to prevent this.
 * Any used by library routines (perhaps the resolver or
 * syslog) will remain.
 */
FILE *f = popen(cmd, "r");

if (f == NULL((void*)0)) {
708#ifdef HAVE_BROKEN_POPEN
	/*
	 * See bug #1067  Angstrom Linux on a arm7 has no
	 * popen()
	 */
	if (errno(*__errno_location ()) == ENOSYS38) {
		/*
		 * Try system(), though it will not give us
		 * output
		 */
		DBG_log("unable to popen(), falling back to system()");
		system(cmd);
		return TRUE1;
	}
722#endif
	loglog(RC_LOG_SERIOUS, "unable to popen %s%s command",
		verb, verb_suffix);
	return FALSE0;
}

/* log any output */
for (;; ) {
	/*
	 * if response doesn't fit in this buffer, it will
	 * be folded
	 */
	char resp[256];

	if (fgets(resp, sizeof(resp), f) == NULL((void*)0)) {
		if (ferror(f)) {
			LOG_ERRNO(errno, "fgets failed on output of %s%s command",{ int e_ = (*__errno_location ()); for (char lswbuf[((size_t)
1024)], *lswbuf_ = lswbuf; lswbuf_ != ((void*)0); lswbuf_ = (
(void*)0)) for (struct jambuf jambuf = array_as_jambuf((lswbuf
), sizeof(lswbuf)), *buf = &jambuf; buf != ((void*)0); buf
 = ((void*)0)) { jam(buf, "ERROR: "); jam_cur_prefix(buf); jam
(buf, "fgets failed on output of %s%s command", verb, verb_suffix
); jam_string(buf, "."); jam(buf, " ""Errno %d: %s", (e_), strerror
(e_)); jambuf_to_error_stream(buf); } }
				  verb, verb_suffix){ int e_ = (*__errno_location ()); for (char lswbuf[((size_t)
1024)], *lswbuf_ = lswbuf; lswbuf_ != ((void*)0); lswbuf_ = (
(void*)0)) for (struct jambuf jambuf = array_as_jambuf((lswbuf
), sizeof(lswbuf)), *buf = &jambuf; buf != ((void*)0); buf
 = ((void*)0)) { jam(buf, "ERROR: "); jam_cur_prefix(buf); jam
(buf, "fgets failed on output of %s%s command", verb, verb_suffix
); jam_string(buf, "."); jam(buf, " ""Errno %d: %s", (e_), strerror
(e_)); jambuf_to_error_stream(buf); } };
			pclose(f);
			return FALSE0;
		} else {
			passert(feof(f)){ _Bool assertion__ = feof(f); if (!assertion__) { lsw_passert_fail
((where_t) { .func = __func__, .basename = "kernel.c" , .line
 = 743}, "%s", "feof(f)"); } };
			break;
		}
	} else {
		char *e = resp + strlen(resp);

		if (e > resp && e[-1] == '\n')
			e[-1] = '\0'; /* trim trailing '\n' */
		libreswan_log("%s%s output: %s", verb,loglog(RC_LOG, "%s%s output: %s", verb, verb_suffix, resp)
			verb_suffix, resp)loglog(RC_LOG, "%s%s output: %s", verb, verb_suffix, resp);
	}
}

/* report on and react to return code */
{
	int r = pclose(f);

	if (r == -1) {
		LOG_ERRNO(errno, "pclose failed for %s%s command",{ int e_ = (*__errno_location ()); for (char lswbuf[((size_t)
1024)], *lswbuf_ = lswbuf; lswbuf_ != ((void*)0); lswbuf_ = (
(void*)0)) for (struct jambuf jambuf = array_as_jambuf((lswbuf
), sizeof(lswbuf)), *buf = &jambuf; buf != ((void*)0); buf
 = ((void*)0)) { jam(buf, "ERROR: "); jam_cur_prefix(buf); jam
(buf, "pclose failed for %s%s command", verb, verb_suffix); jam_string
(buf, "."); jam(buf, " ""Errno %d: %s", (e_), strerror(e_)); jambuf_to_error_stream
(buf); } }
			  verb, verb_suffix){ int e_ = (*__errno_location ()); for (char lswbuf[((size_t)
1024)], *lswbuf_ = lswbuf; lswbuf_ != ((void*)0); lswbuf_ = (
(void*)0)) for (struct jambuf jambuf = array_as_jambuf((lswbuf
), sizeof(lswbuf)), *buf = &jambuf; buf != ((void*)0); buf
 = ((void*)0)) { jam(buf, "ERROR: "); jam_cur_prefix(buf); jam
(buf, "pclose failed for %s%s command", verb, verb_suffix); jam_string
(buf, "."); jam(buf, " ""Errno %d: %s", (e_), strerror(e_)); jambuf_to_error_stream
(buf); } };
		return FALSE0;
	} else if (WIFEXITED(r)(((r) & 0x7f) == 0)) {
		if (WEXITSTATUS(r)(((r) & 0xff00) >> 8) != 0) {
			loglog(RC_LOG_SERIOUS,
				"%s%s command exited with status %d",
				verb, verb_suffix,
				WEXITSTATUS(r)(((r) & 0xff00) >> 8));
			return FALSE0;
		}
	} else if (WIFSIGNALED(r)(((signed char) (((r) & 0x7f) + 1) >> 1) > 0)) {
		loglog(RC_LOG_SERIOUS,
			"%s%s command exited with signal %d",
			verb, verb_suffix, WTERMSIG(r)((r) & 0x7f));
		return FALSE0;
	} else {
		loglog(RC_LOG_SERIOUS,
			"%s%s command exited with unknown status %d",
			verb, verb_suffix, r);
		return FALSE0;
	}
}
}
return TRUE1;
786}

788/* Check that we can route (and eroute).  Diagnose if we cannot. */

790enum routability {
route_impossible,
route_easy,
route_nearconflict,
route_farconflict,
route_unnecessary
796};

798/*
* handle co-terminal attempt of the "near" kind
*
* Note: it mutates both inside and outside
*/
803static enum routability note_nearconflict(
struct connection *outside,	/* CK_PERMANENT */
struct connection *inside)	/* CK_TEMPLATE */
806{
char inst[CONN_INST_BUF(2 + 10 + 1 + sizeof(subnet_buf) + 7 + sizeof(address_reversed_buf
) + 3 + sizeof(subnet_buf) + 1 + 1)];

/*
* this is a co-terminal attempt of the "near" kind.
* when chaining, we chain from inside to outside
*
* XXX permit multiple deep connections?
*/
passert(inside->policy_next == NULL){ _Bool assertion__ = inside->policy_next == ((void*)0); if
 (!assertion__) { lsw_passert_fail((where_t) { .func = __func__
, .basename = "kernel.c" , .line = 815}, "%s", "inside->policy_next == NULL"
); } };

inside->policy_next = outside;

/*
* since we are going to steal the eroute from the secondary
* policy, we need to make sure that it no longer thinks that
* it owns the eroute.
*/
outside->spd.eroute_owner = SOS_NOBODY0;
outside->spd.routing = RT_UNROUTED_KEYED;

/*
* set the priority of the new eroute owner to be higher
* than that of the current eroute owner
*/
inside->prio = outside->prio + 1;

loglog(RC_LOG_SERIOUS,
"conflict on eroute (%s), switching eroute to %s and linking %s",
fmt_conn_instance(inside, inst),
inside->name, outside->name);

return route_nearconflict;
839}

841/*
* Note: this may mutate c
*/
844static enum routability could_route(struct connection *c, struct logger *logger)
845{
dbg("could_route called for %s; kind=%s that.has_client=%s oppo=%s this.host_port=%u",{ if ((cur_debugging & (((lset_t)1 << (DBG_BASE_IX)
)))) { DBG_log("could_route called for %s; kind=%s that.has_client=%s oppo=%s this.host_port=%u"
, c->name, enum_show(&connection_kind_names, c->kind
), bool_str(c->spd.that.has_client), bool_str(c->policy
 & ((lset_t)1 << (POLICY_OPPORTUNISTIC_IX))), c->
spd.this.host_port); } }
   c->name,{ if ((cur_debugging & (((lset_t)1 << (DBG_BASE_IX)
)))) { DBG_log("could_route called for %s; kind=%s that.has_client=%s oppo=%s this.host_port=%u"
, c->name, enum_show(&connection_kind_names, c->kind
), bool_str(c->spd.that.has_client), bool_str(c->policy
 & ((lset_t)1 << (POLICY_OPPORTUNISTIC_IX))), c->
spd.this.host_port); } }
   enum_show(&connection_kind_names, c->kind),{ if ((cur_debugging & (((lset_t)1 << (DBG_BASE_IX)
)))) { DBG_log("could_route called for %s; kind=%s that.has_client=%s oppo=%s this.host_port=%u"
, c->name, enum_show(&connection_kind_names, c->kind
), bool_str(c->spd.that.has_client), bool_str(c->policy
 & ((lset_t)1 << (POLICY_OPPORTUNISTIC_IX))), c->
spd.this.host_port); } }
   bool_str(c->spd.that.has_client),{ if ((cur_debugging & (((lset_t)1 << (DBG_BASE_IX)
)))) { DBG_log("could_route called for %s; kind=%s that.has_client=%s oppo=%s this.host_port=%u"
, c->name, enum_show(&connection_kind_names, c->kind
), bool_str(c->spd.that.has_client), bool_str(c->policy
 & ((lset_t)1 << (POLICY_OPPORTUNISTIC_IX))), c->
spd.this.host_port); } }
   bool_str(c->policy & POLICY_OPPORTUNISTIC),{ if ((cur_debugging & (((lset_t)1 << (DBG_BASE_IX)
)))) { DBG_log("could_route called for %s; kind=%s that.has_client=%s oppo=%s this.host_port=%u"
, c->name, enum_show(&connection_kind_names, c->kind
), bool_str(c->spd.that.has_client), bool_str(c->policy
 & ((lset_t)1 << (POLICY_OPPORTUNISTIC_IX))), c->
spd.this.host_port); } }
   c->spd.this.host_port){ if ((cur_debugging & (((lset_t)1 << (DBG_BASE_IX)
)))) { DBG_log("could_route called for %s; kind=%s that.has_client=%s oppo=%s this.host_port=%u"
, c->name, enum_show(&connection_kind_names, c->kind
), bool_str(c->spd.that.has_client), bool_str(c->policy
 & ((lset_t)1 << (POLICY_OPPORTUNISTIC_IX))), c->
spd.this.host_port); } };

/* it makes no sense to route a connection that is ISAKMP-only */
if (!NEVER_NEGOTIATE(c->policy)(((((c->policy)) & (((lset_t)1 << (POLICY_ENCRYPT_IX
)) | ((lset_t)1 << (POLICY_AUTHENTICATE_IX)))) == ((lset_t
)0))) && !HAS_IPSEC_POLICY(c->policy)(((c->policy) & (((lset_t)1 << (POLICY_NOPMTUDISC_IX
)) - ((lset_t)1 << (POLICY_ENCRYPT_IX)) + ((lset_t)1 <<
 (POLICY_NOPMTUDISC_IX)))) != 0)) {
log_message(RC_ROUTE, logger,
	    "cannot route an ISAKMP-only connection");
return route_impossible;
}

/*
* if this is a transport SA, and overlapping SAs are supported, then
* this route is not necessary at all.
*/
if (kernel_ops->overlap_supported && !LIN(POLICY_TUNNEL, c->policy)(((((lset_t)1 << (POLICY_TUNNEL_IX))) & (c->policy
)) == (((lset_t)1 << (POLICY_TUNNEL_IX)))))
return route_unnecessary;

/*
* if this is a Road Warrior template, we cannot route.
* Opportunistic template is OK.
*/
if (!c->spd.that.has_client &&
   c->kind == CK_TEMPLATE &&
   !(c->policy & POLICY_OPPORTUNISTIC((lset_t)1 << (POLICY_OPPORTUNISTIC_IX)))) {
log_message(RC_ROUTE, logger,
	    "cannot route template policy of %s",
	    prettypolicy(c->policy));
return route_impossible;
}

/* if routing would affect IKE messages, reject */
if (c->spd.this.host_port != NAT_IKE_UDP_PORT4500 &&
   c->spd.this.host_port != IKE_UDP_PORT500 &&
   addrinsubnet(&c->spd.that.host_addr, &c->spd.that.client)) {
log_message(RC_LOG_SERIOUS, logger,
	    "cannot install route: peer is within its client");
return route_impossible;
}

struct spd_route *esr, *rosr;
struct connection *ero,		/* who, if anyone, owns our eroute? */
*ro = route_owner(c, &c->spd, &rosr, &ero, &esr);	/* who owns our route? */

/*
* If there is already a route for peer's client subnet
* and it disagrees about interface or nexthop, we cannot steal it.
* Note: if this connection is already routed (perhaps for another
* state object), the route will agree.
* This is as it should be -- it will arise during rekeying.
*/
if (ro != NULL((void*)0) && !routes_agree(ro, c)((ro)->interface->ip_dev == (c)->interface->ip_dev
 && sameaddr(&(ro)->spd.this.host_nexthop, &
(c)->spd.this.host_nexthop))) {

if (!compatible_overlapping_connections(c, ero)) {
	/*
	 * Another connection is already using the eroute.
	 * TODO: XFRM can do this? For now excempt OE only
	 */
	if ((c->policy & POLICY_OPPORTUNISTIC((lset_t)1 << (POLICY_OPPORTUNISTIC_IX))) == LEMPTY((lset_t)0)) {
		connection_buf cib;
		log_message(RC_LOG_SERIOUS, logger,
			    "cannot route -- route already in use for "PRI_CONNECTION"\"%s\"%s""",
			    pri_connection(ro, &cib)(ro)->name, str_connection_instance(ro, &cib));
		return route_impossible;
	} else {
		connection_buf cib;
		log_message(RC_LOG_SERIOUS, logger,
			    "cannot route -- route already in use for "PRI_CONNECTION"\"%s\"%s"" - but allowing anyway",
			    pri_connection(ro, &cib)(ro)->name, str_connection_instance(ro, &cib));
	}
}
}


/* if there is an eroute for another connection, there is a problem */
if (ero != NULL((void*)0) && ero != c) {
/*
 * note, wavesec (PERMANENT) goes *outside* and
 * OE goes *inside* (TEMPLATE)
 */
if (ero->kind == CK_PERMANENT &&
	c->kind == CK_TEMPLATE) {
	return note_nearconflict(ero, c);
} else if (c->kind == CK_PERMANENT &&
	ero->kind == CK_TEMPLATE) {
	return note_nearconflict(c, ero);
}

/* look along the chain of policies for one with the same name */

for (struct connection *ep = ero; ep != NULL((void*)0); ep = ero->policy_next) {
	if (ep->kind == CK_TEMPLATE &&
		streq(ep->name, c->name)(strcmp((ep->name), (c->name)) == 0))
		return route_easy;
}

/*
 * If we fell off the end of the list, then we found no
 * TEMPLATE so there must be a conflict that we can't resolve.
 * As the names are not equal, then we aren't
 * replacing/rekeying.
 *
 * ??? should there not be a conflict if ANYTHING in the list,
 * other than c, conflicts with c?
 */

if (LDISJOINT(POLICY_OVERLAPIP, c->policy | ero->policy)(((((lset_t)1 << (POLICY_OVERLAPIP_IX))) & (c->policy
 | ero->policy)) == ((lset_t)0))) {
	/*
	 * another connection is already using the eroute,
	 * TODO: XFRM apparently can do this though
	 */
	connection_buf erob;
	log_message(RC_LOG_SERIOUS, logger,
		    "cannot install eroute -- it is in use for "PRI_CONNECTION"\"%s\"%s"" #%lu",
		    pri_connection(ero, &erob)(ero)->name, str_connection_instance(ero, &erob), esr->eroute_owner);
	return route_impossible;
}

connection_buf erob;
dbg("overlapping permitted with "PRI_CONNECTION" #%lu",{ if ((cur_debugging & (((lset_t)1 << (DBG_BASE_IX)
)))) { DBG_log("overlapping permitted with ""\"%s\"%s"" #%lu"
, (ero)->name, str_connection_instance(ero, &erob), esr
->eroute_owner); } }
    pri_connection(ero, &erob), esr->eroute_owner){ if ((cur_debugging & (((lset_t)1 << (DBG_BASE_IX)
)))) { DBG_log("overlapping permitted with ""\"%s\"%s"" #%lu"
, (ero)->name, str_connection_instance(ero, &erob), esr
->eroute_owner); } };
}
return route_easy;
972}

974bool_Bool trap_connection(struct connection *c, struct fd *whackfd)
975{
struct logger logger = CONNECTION_LOGGER(c, whackfd)(struct logger) { .where = (where_t) { .func = __func__, .basename
 = "kernel.c" , .line = 976}, .global_whackfd = whackfd, .object
 = c, .object_vec = &logger_connection_vec, };
enum routability r = could_route(c, &logger);

switch (r) {
case route_impossible:
return FALSE0;

case route_easy:
case route_nearconflict:
/*
 * RT_ROUTED_TUNNEL is treated specially: we don't override
 * because we don't want to lose track of the IPSEC_SAs etc.
 * ??? The test treats RT_UNROUTED_KEYED specially too.
 */
if (c->spd.routing < RT_ROUTED_TUNNEL)
	return route_and_eroute(c, &c->spd, NULL((void*)0));

return TRUE1;

case route_farconflict:
return FALSE0;

case route_unnecessary:
return TRUE1;
default:
bad_case(r)libreswan_bad_case("r", (r), (where_t) { .func = __func__, .basename
 = "kernel.c" , .line = 1001});
}
1003}

1005/*
* Add/replace/delete a shunt eroute.
*
* Such an eroute determines the fate of packets without the use
* of any SAs.  These are defaults, in effect.
* If a negotiation has not been attempted, use %trap.
* If negotiation has failed, the choice between %trap/%pass/%drop/%reject
* is specified in the policy of connection c.
*/
1014static bool_Bool shunt_eroute(const struct connection *c,
	const struct spd_route *sr,
	enum routing_t rt_kind,
	enum pluto_sadb_operations op,
	const char *opname)
1019{
if (DBGP(DBG_BASE)(cur_debugging & (((lset_t)1 << (DBG_BASE_IX))))) {
selector_buf thisb, thatb;
DBG_log("shunt_eroute() called for connection '%s' to '%s' for rt_kind '%s' using protoports %s --%d->- %s",
	c->name, opname, enum_name(&routing_story, rt_kind),
	str_selector(&sr->this.client, &thisb),
	sr->this.protocol,
	str_selector(&sr->that.client, &thatb));
}

if (kernel_ops->shunt_eroute != NULL((void*)0)) {
return kernel_ops->shunt_eroute(c, sr, rt_kind, op, opname);
}

loglog(RC_COMMENT, "no shunt_eroute implemented for %s interface",
kernel_ops->kern_name);
return TRUE1;
1036}

1038static bool_Bool sag_eroute(const struct state *st,
const struct spd_route *sr,
enum pluto_sadb_operations op,
const char *opname)
1042{
pexpect(kernel_ops->sag_eroute != NULL)({ _Bool assertion__ = kernel_ops->sag_eroute != ((void*)0
); if (!assertion__) { log_pexpect((where_t) { .func = __func__
, .basename = "kernel.c" , .line = 1043}, "%s", "kernel_ops->sag_eroute != NULL"
); } assertion__; });
if (kernel_ops->sag_eroute != NULL((void*)0))
return kernel_ops->sag_eroute(st, sr, op, opname);

return FALSE0;
1048}

1050void migration_up(struct connection *c,  struct state *st)
1051{
for (struct spd_route *sr = &c->spd; sr != NULL((void*)0); sr = sr->spd_next) {
1053#ifdef IPSEC_CONNECTION_LIMIT
num_ipsec_eroute++;
1055#endif
sr->routing = RT_ROUTED_TUNNEL; /* do now so route_owner won't find us */
(void) do_command(c, sr, "up", st);
(void) do_command(c, sr, "route", st);
}
1060}

1062void migration_down(struct connection *c,  struct state *st)
1063{
for (struct spd_route *sr = &c->spd; sr != NULL((void*)0); sr = sr->spd_next) {
enum routing_t cr = sr->routing;

1067#ifdef IPSEC_CONNECTION_LIMIT
if (erouted(cr)((cr) != RT_UNROUTED))
	num_ipsec_eroute--;
1070#endif

sr->routing = RT_UNROUTED; /* do now so route_owner won't find us */

/* only unroute if no other connection shares it */
if (routed(cr)((cr) > RT_UNROUTED_HOLD) && route_owner(c, sr, NULL((void*)0), NULL((void*)0), NULL((void*)0)) == NULL((void*)0)) {
	(void) do_command(c, sr, "down", st);
	st->st_mobike_del_src_ip = true1;
	(void) do_command(c, sr, "unroute", st);
	st->st_mobike_del_src_ip = false0;
}
}
1082}


1085/* delete any eroute for a connection and unroute it if route isn't shared */
1086void unroute_connection(struct connection *c)
1087{
for (struct spd_route *sr = &c->spd; sr != NULL((void*)0); sr = sr->spd_next) {
enum routing_t cr = sr->routing;

if (erouted(cr)((cr) != RT_UNROUTED)) {
	/* cannot handle a live one */
	passert(cr != RT_ROUTED_TUNNEL){ _Bool assertion__ = cr != RT_ROUTED_TUNNEL; if (!assertion__
) { lsw_passert_fail((where_t) { .func = __func__, .basename =
 "kernel.c" , .line = 1093}, "%s", "cr != RT_ROUTED_TUNNEL");
 } };
	shunt_eroute(c, sr, RT_UNROUTED, ERO_DELETE, "delete");
1095#ifdef IPSEC_CONNECTION_LIMIT
	num_ipsec_eroute--;
1097#endif
}

sr->routing = RT_UNROUTED; /* do now so route_owner won't find us */

/* only unroute if no other connection shares it */
if (routed(cr)((cr) > RT_UNROUTED_HOLD) && route_owner(c, sr, NULL((void*)0), NULL((void*)0), NULL((void*)0)) == NULL((void*)0))
	(void) do_command(c, sr, "unroute", NULL((void*)0));
}
1106}

1108#include "kernel_alg.h"

1110void set_text_said(char *text_said, const ip_address *dst,
	ipsec_spi_t spi, const struct ip_protocol *sa_proto)
1112{
ip_said said = said3(dst, spi, sa_proto);
struct jambuf jam = array_as_jambuf(text_said, SATOT_BUFsizeof(said_buf));
jam_said(&jam, &said);
1116}

1118/* find an entry in the bare_shunt table.
* Trick: return a pointer to the pointer to the entry;
* this allows the entry to be deleted.
*/
1122struct bare_shunt **bare_shunt_ptr(const ip_selector *our_client,
		   const ip_selector *peer_client,
		   int transport_proto)

1126{
struct bare_shunt *p, **pp;

for (pp = &bare_shunts; (p = *pp) != NULL((void*)0); pp = &p->next) {
if (transport_proto == p->transport_proto &&
    selector_eq(our_client, &p->our_client) &&
    selector_eq(peer_client, &p->peer_client)) {
	return pp;
}
}
return NULL((void*)0);
1137}

1139/* free a bare_shunt entry, given a pointer to the pointer */
1140static void free_bare_shunt(struct bare_shunt **pp)
1141{
struct bare_shunt *p;

passert(pp != NULL){ _Bool assertion__ = pp != ((void*)0); if (!assertion__) { lsw_passert_fail
((where_t) { .func = __func__, .basename = "kernel.c" , .line
 = 1144}, "%s", "pp != NULL"); } };

p = *pp;

*pp = p->next;
dbg_bare_shunt("delete", p);
pfreeany(p->from_cn){ typeof(p->from_cn) *pp_ = &(p->from_cn); if (*pp_
 != ((void*)0)) { pfree(*pp_); *pp_ = ((void*)0); } };
pfree(p);
1152}

1154unsigned shunt_count(void)
1155{
unsigned i = 0;

for (const struct bare_shunt *bs = bare_shunts; bs != NULL((void*)0); bs = bs->next)
{
i++;
}

return i;
1164}

1166void show_shunt_status(struct show *s)
1167{
show_separator(s);
show_comment(s, "Bare Shunt list:");
show_separator(s);

for (const struct bare_shunt *bs = bare_shunts; bs != NULL((void*)0); bs = bs->next) {
/* Print interesting fields.  Ignore count and last_active. */
selector_buf ourb;
selector_buf peerb;
said_buf sat;

char prio[POLICY_PRIO_BUF(3 + 1 + 3 + 1 + 10)];
fmt_policy_prio(bs->policy_prio, prio);

show_comment(s, "%s -%d-> %s => %s %s    %s",
	     str_selector(&(bs)->our_client, &ourb),
	     bs->transport_proto,
	     str_selector(&(bs)->peer_client, &peerb),
	     str_said(&(bs)->said, &sat),
	     prio, bs->why);
}
1188}

1190/* Setup an IPsec route entry.
* op is one of the ERO_* operators.
*/

1194// should be made static again once we fix initiate.c calling this directly!
1195bool_Bool raw_eroute(const ip_address *this_host,
const ip_subnet *this_client,
const ip_address *that_host,
const ip_subnet *that_client,
ipsec_spi_t cur_spi,
ipsec_spi_t new_spi,
const struct ip_protocol *sa_proto,
unsigned int transport_proto,
enum eroute_type esatype,
const struct pfkey_proto_info *proto_info,
deltatime_t use_lifetime,
uint32_t sa_priority,
const struct sa_marks *sa_marks,
const uint32_t xfrm_if_id,
enum pluto_sadb_operations op,
const char *opname,
const char *policy_label)
1212{
char text_said[SATOT_BUFsizeof(said_buf) + SATOT_BUFsizeof(said_buf)];

switch (op) {
30
←
Control jumps to 'case ERO_ADD_INBOUND:'  at line 1217→
case ERO_ADD:
case ERO_ADD_INBOUND:
set_text_said(text_said, that_host, new_spi, sa_proto);
break;
31
←
 Execution continues on line 1239→
case ERO_DELETE:
case ERO_DEL_INBOUND:
set_text_said(text_said, that_host, cur_spi, sa_proto);
break;
case ERO_REPLACE:
case ERO_REPLACE_INBOUND:
{
size_t w;

set_text_said(text_said, that_host, cur_spi, sa_proto);
w = strlen(text_said);
text_said[w] = '>';
set_text_said(text_said + w + 1, that_host, new_spi, sa_proto);
break;
}
default:
bad_case(op)libreswan_bad_case("op", (op), (where_t) { .func = __func__, .
basename = "kernel.c" , .line = 1236});
}

if (DBGP(DBG_BASE)(cur_debugging & (((lset_t)1 << (DBG_BASE_IX))))) {
32
←
Assuming the condition is true→
33
←
Taking true branch→
selector_buf mybuf;
selector_buf peerbuf;
DBG_log("%s eroute %s --%d-> %s => %s using reqid %d (raw_eroute) proto=%d",
34
←
7th function call argument is an uninitialized value
	opname,
	str_selector(this_client, &mybuf),
	transport_proto,
	str_selector(that_client, &peerbuf),
	text_said,
	proto_info->reqid,
	proto_info->proto);

if (policy_label != NULL((void*)0))
	DBG_log("policy security label %s",
		policy_label);
}

bool_Bool result = kernel_ops->raw_eroute(this_host, this_client,
			that_host, that_client,
			cur_spi, new_spi, sa_proto,
			transport_proto,
			esatype, proto_info,
			use_lifetime, sa_priority, sa_marks,
			xfrm_if_id, op, text_said,
			policy_label);
dbg("raw_eroute result=%s", result ? "success" : "failed"){ if ((cur_debugging & (((lset_t)1 << (DBG_BASE_IX)
)))) { DBG_log("raw_eroute result=%s", result ? "success" : "failed"
); } };

return result;
1267}

1269/*
* Clear any bare shunt holds that overlap with the network we have
* just routed.  We only consider "narrow" holds: ones for a single
* address to single address.
*/
1274static void clear_narrow_holds(const ip_selector *our_client,
	       const ip_selector *peer_client,
	       int transport_proto)
1277{
struct bare_shunt *p, **pp;

for (pp = &bare_shunts; (p = *pp) != NULL((void*)0); ) {
/*
 * is p->{local,remote} within {local,remote}.
 */
if (p->said.spi == htonl(SPI_HOLD259) &&
    transport_proto == p->transport_proto &&
    selector_in_selector(&p->our_client, our_client) &&
    selector_in_selector(&p->peer_client, peer_client)) {
	if (!delete_bare_shunt(&p->our_client.addr, &p->peer_client.addr,
			       transport_proto, SPI_HOLD259,
			       "removing clashing narrow hold")) {
		/* ??? we could not delete a bare shunt */
		log_bare_shunt(RC_LOG, "failed to delete", p);
		break;	/* unlikely to succeed a second time */
	} else if (*pp == p) {
		/*
		 * ??? We deleted the wrong bare shunt!
		 * This happened because more than one entry
		 * matched and we happened to delete a
		 * different one.
		 * Log it!  And keep deleting.
		 */
		log_bare_shunt(RC_LOG, "UNEXPECTEDLY SURVIVING", p);
		pp = &bare_shunts;	/* just in case, start over */
	}
	/*
	 * ??? if we were sure that there could only be one
	 * matching entry, we could break out of the FOR.
	 * For an unknown reason this is not always the case,
	 * so we will continue the loop, with pp unchanged.
	 */
} else {
	pp = &p->next;
}
}
1315}

1317/*
* Replace (or delete) a shunt that is in the bare_shunts table.
* Issues the PF_KEY commands and updates the bare_shunts table.
*/
1321static bool_Bool fiddle_bare_shunt(const ip_address *src, const ip_address *dst,
	policy_prio_t policy_prio,	/* of replacing shunt*/
	ipsec_spi_t cur_shunt_spi,	/* in host order! */
	ipsec_spi_t new_shunt_spi,	/* in host order! */
	bool_Bool repl,		/* if TRUE, replace; if FALSE, delete */
	int transport_proto,
	const char *why)
1328{
ip_subnet this_client, that_client;
const ip_address null_host = address_any(address_type(src));

dbg("fiddle_bare_shunt called"){ if ((cur_debugging & (((lset_t)1 << (DBG_BASE_IX)
)))) { DBG_log("fiddle_bare_shunt called"); } };

passert(addrtypeof(src) == addrtypeof(dst)){ _Bool assertion__ = addrtypeof(src) == addrtypeof(dst); if (
!assertion__) { lsw_passert_fail((where_t) { .func = __func__
, .basename = "kernel.c" , .line = 1334}, "%s", "addrtypeof(src) == addrtypeof(dst)"
); } };
happy(endtosubnet(src, &this_client, HERE)){ err_t ugh = endtosubnet(src, &this_client, (where_t) { .
func = __func__, .basename = "kernel.c" , .line = 1335}); if (
ugh != ((void*)0)) { lsw_passert_fail((where_t) { .func = __func__
, .basename = "kernel.c" , .line = 1335}, "%s", ugh); } };
happy(endtosubnet(dst, &that_client, HERE)){ err_t ugh = endtosubnet(dst, &that_client, (where_t) { .
func = __func__, .basename = "kernel.c" , .line = 1336}); if (
ugh != ((void*)0)) { lsw_passert_fail((where_t) { .func = __func__
, .basename = "kernel.c" , .line = 1336}, "%s", ugh); } };

/*
* ??? this comment might be obsolete.
* If the transport protocol is not the wildcard (0), then we need
* to look for a host<->host shunt, and replace that with the
* shunt spi, and then we add a %HOLD for what was there before.
*
* This is at odds with !repl, which should delete things.
*
*/

dbg("fiddle_bare_shunt with transport_proto %d", transport_proto){ if ((cur_debugging & (((lset_t)1 << (DBG_BASE_IX)
)))) { DBG_log("fiddle_bare_shunt with transport_proto %d", transport_proto
); } };

enum pluto_sadb_operations op = repl ? ERO_REPLACE : ERO_DELETE;

dbg("%s specific host-to-host bare shunt", repl ? "replacing" : "removing"){ if ((cur_debugging & (((lset_t)1 << (DBG_BASE_IX)
)))) { DBG_log("%s specific host-to-host bare shunt", repl ? "replacing"
 : "removing"); } };
if (kernel_ops->type == USE_XFRM && strstr(why, "IGNORE_ON_XFRM:") != NULL((void*)0)) {
dbg("skipping raw_eroute because IGNORE_ON_XFRM"){ if ((cur_debugging & (((lset_t)1 << (DBG_BASE_IX)
)))) { DBG_log("skipping raw_eroute because IGNORE_ON_XFRM");
 } };
struct bare_shunt **bs_pp = bare_shunt_ptr(
	&this_client,
	&that_client,
	transport_proto);

free_bare_shunt(bs_pp);
libreswan_log("raw_eroute() to op='%s' with transport_proto='%d' kernel shunt skipped - deleting from pluto shunt table",loglog(RC_LOG, "raw_eroute() to op='%s' with transport_proto='%d' kernel shunt skipped - deleting from pluto shunt table"
, repl ? "replace" : "delete", transport_proto)
	repl ? "replace" : "delete",loglog(RC_LOG, "raw_eroute() to op='%s' with transport_proto='%d' kernel shunt skipped - deleting from pluto shunt table"
, repl ? "replace" : "delete", transport_proto)
	transport_proto)loglog(RC_LOG, "raw_eroute() to op='%s' with transport_proto='%d' kernel shunt skipped - deleting from pluto shunt table"
, repl ? "replace" : "delete", transport_proto);
return TRUE1;
} else if (raw_eroute(&null_host, &this_client,
	&null_host, &that_client,
	htonl(cur_shunt_spi),
	htonl(new_shunt_spi),
	&ip_protocol_internal, transport_proto,
	ET_INT, null_proto_info,
	deltatime(SHUNT_PATIENCE((2 * 10) * 15 / 2)),
	0, /* we don't know connection for priority yet */
	NULL((void*)0), /* sa_marks */
	0 /* xfrm interface id */,

	op, why, NULL((void*)0)))
{
struct bare_shunt **bs_pp = bare_shunt_ptr(
	&this_client,
	&that_client,
	transport_proto);

dbg("raw_eroute with op='%s' for transport_proto='%d' kernel shunt succeeded, bare shunt lookup %s",{ if ((cur_debugging & (((lset_t)1 << (DBG_BASE_IX)
)))) { DBG_log("raw_eroute with op='%s' for transport_proto='%d' kernel shunt succeeded, bare shunt lookup %s"
, repl ? "replace" : "delete", transport_proto, (bs_pp == ((void
*)0)) ? "failed" : "succeeded"); } }
    repl ? "replace" : "delete", transport_proto,{ if ((cur_debugging & (((lset_t)1 << (DBG_BASE_IX)
)))) { DBG_log("raw_eroute with op='%s' for transport_proto='%d' kernel shunt succeeded, bare shunt lookup %s"
, repl ? "replace" : "delete", transport_proto, (bs_pp == ((void
*)0)) ? "failed" : "succeeded"); } }
    (bs_pp == NULL) ? "failed" : "succeeded"){ if ((cur_debugging & (((lset_t)1 << (DBG_BASE_IX)
)))) { DBG_log("raw_eroute with op='%s' for transport_proto='%d' kernel shunt succeeded, bare shunt lookup %s"
, repl ? "replace" : "delete", transport_proto, (bs_pp == ((void
*)0)) ? "failed" : "succeeded"); } };

/* we can have proto mismatching acquires with xfrm - this is a bad workaround */
/* ??? what is the nature of those mismatching acquires? */
/* passert(bs_pp != NULL); */
if (bs_pp == NULL((void*)0)) {
	ipstr_buf srcb, dstb;

	libreswan_log("can't find expected bare shunt to %s: %s->%s transport_proto='%d'",loglog(RC_LOG, "can't find expected bare shunt to %s: %s->%s transport_proto='%d'"
, repl ? "replace" : "delete", ipstr(src, &srcb), ipstr(dst
, &dstb), transport_proto)
		repl ? "replace" : "delete",loglog(RC_LOG, "can't find expected bare shunt to %s: %s->%s transport_proto='%d'"
, repl ? "replace" : "delete", ipstr(src, &srcb), ipstr(dst
, &dstb), transport_proto)
		ipstr(src, &srcb), ipstr(dst, &dstb),loglog(RC_LOG, "can't find expected bare shunt to %s: %s->%s transport_proto='%d'"
, repl ? "replace" : "delete", ipstr(src, &srcb), ipstr(dst
, &dstb), transport_proto)
		transport_proto)loglog(RC_LOG, "can't find expected bare shunt to %s: %s->%s transport_proto='%d'"
, repl ? "replace" : "delete", ipstr(src, &srcb), ipstr(dst
, &dstb), transport_proto);
	return TRUE1;
}

if (repl) {
	/*
	 * change over to new bare eroute
	 * ours, peers, transport_proto are the same.
	 */
	struct bare_shunt *bs = *bs_pp;

	bs->why = why;
	bs->policy_prio = policy_prio;
	bs->said = said3(&null_host, htonl(new_shunt_spi), &ip_protocol_internal);
	bs->count = 0;
	bs->last_activity = mononow();
	dbg_bare_shunt("change", bs);
} else {
	/* delete pluto bare shunt */
	free_bare_shunt(bs_pp);
}
return TRUE1;
} else {
struct bare_shunt **bs_pp = bare_shunt_ptr(
	&this_client,
	&that_client,
	transport_proto);

free_bare_shunt(bs_pp);
libreswan_log("raw_eroute() to op='%s' with transport_proto='%d' kernel shunt failed - deleting from pluto shunt table",loglog(RC_LOG, "raw_eroute() to op='%s' with transport_proto='%d' kernel shunt failed - deleting from pluto shunt table"
, repl ? "replace" : "delete", transport_proto)
	repl ? "replace" : "delete",loglog(RC_LOG, "raw_eroute() to op='%s' with transport_proto='%d' kernel shunt failed - deleting from pluto shunt table"
, repl ? "replace" : "delete", transport_proto)
	transport_proto)loglog(RC_LOG, "raw_eroute() to op='%s' with transport_proto='%d' kernel shunt failed - deleting from pluto shunt table"
, repl ? "replace" : "delete", transport_proto);

return FALSE0;
}
1431}

1433bool_Bool replace_bare_shunt(const ip_address *src, const ip_address *dst,
	policy_prio_t policy_prio,	/* of replacing shunt*/
	ipsec_spi_t cur_shunt_spi,	/* in host order! */
	ipsec_spi_t new_shunt_spi,	/* in host order! */
	int transport_proto,
	const char *why)
1439{
return fiddle_bare_shunt(src, dst, policy_prio, cur_shunt_spi, new_shunt_spi, TRUE1, transport_proto, why);
1441}

1443bool_Bool delete_bare_shunt(const ip_address *src, const ip_address *dst,
	int transport_proto, ipsec_spi_t cur_shunt_spi,
	const char *why)
1446{
return fiddle_bare_shunt(src, dst, BOTTOM_PRIO((policy_prio_t)0), cur_shunt_spi, SPI_PASS256 /* unused */, FALSE0, transport_proto, why);
1448}

1450bool_Bool eroute_connection(const struct spd_route *sr,
ipsec_spi_t cur_spi,
ipsec_spi_t new_spi,
const struct ip_protocol *sa_proto,
enum eroute_type esatype,
const struct pfkey_proto_info *proto_info,
uint32_t sa_priority,
const struct sa_marks *sa_marks,
const uint32_t xfrm_if_id,
unsigned int op,
      	const char *opname,
const char *policy_label)
1462{
ip_address peer = sr->that.host_addr;
char buf2[256];

snprintf(buf2, sizeof(buf2),
"eroute_connection %s", opname);

if (sa_proto == &ip_protocol_internal)
peer = address_any(address_type(&peer));

if (sr->this.has_cat) {
ip_subnet client;

endtosubnet(&sr->this.host_addr, &client, HERE(where_t) { .func = __func__, .basename = "kernel.c" , .line =
 1475});
bool_Bool t = raw_eroute(&sr->this.host_addr, &client,
		    &peer, &sr->that.client,
		cur_spi,
		new_spi,
		sa_proto,
		sr->this.protocol,
		esatype,
		proto_info,
		deltatime(0),
		sa_priority, sa_marks, 
		xfrm_if_id,
		op, buf2,
		policy_label);
if (!t)
	libreswan_log("CAT: failed to eroute additional Client Address Translation policy")loglog(RC_LOG, "CAT: failed to eroute additional Client Address Translation policy"
);

dbg("%s CAT extra route added return=%d", __func__, t){ if ((cur_debugging & (((lset_t)1 << (DBG_BASE_IX)
)))) { DBG_log("%s CAT extra route added return=%d", __func__
, t); } };
}

return raw_eroute(&sr->this.host_addr, &sr->this.client,
	  &peer, &sr->that.client,
	cur_spi,
	new_spi,
	sa_proto,
	sr->this.protocol,
	esatype,
	proto_info,
	deltatime(0),
	sa_priority, sa_marks,
	xfrm_if_id,
       	op, buf2,
	policy_label);
1508}

1510/* assign a bare hold or pass to a connection */

1512bool_Bool assign_holdpass(const struct connection *c,
struct spd_route *sr,
int transport_proto, ipsec_spi_t negotiation_shunt,
const ip_address *src, const ip_address *dst)
1516{
/*
* either the automatically installed %hold eroute is broad enough
* or we try to add a broader one and delete the automatic one.
* Beware: this %hold might be already handled, but still squeak
* through because of a race.
*/
enum routing_t ro = sr->routing,	/* routing, old */
rn = ro;			/* routing, new */

passert(LHAS(LELEM(CK_PERMANENT) | LELEM(CK_INSTANCE), c->kind)){ _Bool assertion__ = (((((lset_t)1 << (CK_PERMANENT)) |
 ((lset_t)1 << (CK_INSTANCE))) & ((lset_t)1 <<
 (c->kind))) != ((lset_t)0)); if (!assertion__) { lsw_passert_fail
((where_t) { .func = __func__, .basename = "kernel.c" , .line
 = 1526}, "%s", "LHAS(LELEM(CK_PERMANENT) | LELEM(CK_INSTANCE), c->kind)"
); } };
/* figure out what routing should become */
switch (ro) {
case RT_UNROUTED:
rn = RT_UNROUTED_HOLD;
break;
case RT_ROUTED_PROSPECTIVE:
rn = RT_ROUTED_HOLD;
break;
default:
/* no change: this %hold or %pass is old news */
break;
}

dbg("assign hold, routing was %s, needs to be %s",{ if ((cur_debugging & (((lset_t)1 << (DBG_BASE_IX)
)))) { DBG_log("assign hold, routing was %s, needs to be %s",
 enum_name(&routing_story, ro), enum_name(&routing_story
, rn)); } }
   enum_name(&routing_story, ro),{ if ((cur_debugging & (((lset_t)1 << (DBG_BASE_IX)
)))) { DBG_log("assign hold, routing was %s, needs to be %s",
 enum_name(&routing_story, ro), enum_name(&routing_story
, rn)); } }
   enum_name(&routing_story, rn)){ if ((cur_debugging & (((lset_t)1 << (DBG_BASE_IX)
)))) { DBG_log("assign hold, routing was %s, needs to be %s",
 enum_name(&routing_story, ro), enum_name(&routing_story
, rn)); } };

if (eclipsable(sr)(subnetishost(&(sr)->this.client) && subnetishost
(&(sr)->that.client))) {
/*
 * Although %hold or %pass is appropriately broad, it will
 * no longer be bare so we must ditch it from the bare table
 */
struct bare_shunt **old = bare_shunt_ptr(&sr->this.client, &sr->that.client, sr->this.protocol);

if (old == NULL((void*)0)) {
	/* ??? should this happen?  It does. */
	libreswan_log("assign_holdpass() no bare shunt to remove? - mismatch?")loglog(RC_LOG, "assign_holdpass() no bare shunt to remove? - mismatch?"
);
} else {
	/* ??? should this happen? */
	dbg("assign_holdpass() removing bare shunt"){ if ((cur_debugging & (((lset_t)1 << (DBG_BASE_IX)
)))) { DBG_log("assign_holdpass() removing bare shunt"); } };
	free_bare_shunt(old);
}
} else {
dbg("assign_holdpass() need broad(er) shunt"){ if ((cur_debugging & (((lset_t)1 << (DBG_BASE_IX)
)))) { DBG_log("assign_holdpass() need broad(er) shunt"); } };
/*
 * we need a broad %hold, not the narrow one.
 * First we ensure that there is a broad %hold.
 * There may already be one (race condition): no need to
 * create one.
 * There may already be a %trap: replace it.
 * There may not be any broad eroute: add %hold.
 * Once the broad %hold is in place, delete the narrow one.
 */
if (rn != ro) {
	int op;
	const char *reason;

	if (erouted(ro)((ro) != RT_UNROUTED)) {
		op = ERO_REPLACE;
		reason = "replace %trap with broad %pass or %hold";
	} else {
		op = ERO_ADD;
		reason = "add broad %pass or %hold";
	}

	if (eroute_connection(sr,
				htonl(SPI_HOLD259), /* kernel induced */
				htonl(negotiation_shunt),
				&ip_protocol_internal, ET_INT,
				null_proto_info,
				calculate_sa_prio(c, FALSE0),
				NULL((void*)0), 0 /* xfrm_if_id */,
				op,
				reason,
				c->policy_label))
	{
		dbg("assign_holdpass() eroute_connection() done"){ if ((cur_debugging & (((lset_t)1 << (DBG_BASE_IX)
)))) { DBG_log("assign_holdpass() eroute_connection() done");
 } };
	} else {
		libreswan_log("assign_holdpass() eroute_connection() failed")loglog(RC_LOG, "assign_holdpass() eroute_connection() failed"
);
		return FALSE0;
	}
}

if (!delete_bare_shunt(src, dst,
			transport_proto,
			(c->policy & POLICY_NEGO_PASS((lset_t)1 << (POLICY_NEGO_PASS_IX))) ? SPI_PASS256 : SPI_HOLD259,
			(c->policy & POLICY_NEGO_PASS((lset_t)1 << (POLICY_NEGO_PASS_IX))) ? "delete narrow %pass" :
				"delete narrow %hold")) {
	dbg("assign_holdpass() delete_bare_shunt() succeeded"){ if ((cur_debugging & (((lset_t)1 << (DBG_BASE_IX)
)))) { DBG_log("assign_holdpass() delete_bare_shunt() succeeded"
); } };
} else {
	libreswan_log("assign_holdpass() delete_bare_shunt() failed")loglog(RC_LOG, "assign_holdpass() delete_bare_shunt() failed"
);
		return FALSE0;
}
}
sr->routing = rn;
dbg(" assign_holdpass() done - returning success"){ if ((cur_debugging & (((lset_t)1 << (DBG_BASE_IX)
)))) { DBG_log(" assign_holdpass() done - returning success")
; } };
return TRUE1;
1614}

1616/* compute a (host-order!) SPI to implement the policy in connection c */
1617ipsec_spi_t shunt_policy_spi(const struct connection *c, bool_Bool prospective)
1618{
/* note: these are in host order :-( */
static const ipsec_spi_t shunt_spi[] =
{
SPI_TRAP260,       /* --initiateontraffic */
SPI_PASS256,       /* --pass */
SPI_DROP257,       /* --drop */
SPI_REJECT258,     /* --reject */
};

static const ipsec_spi_t fail_spi[] =
{
0,              /* --none*/
SPI_PASS256,       /* --failpass */
SPI_DROP257,       /* --faildrop */
SPI_REJECT258,     /* --failreject */
};

return prospective ?
shunt_spi[(c->policy & POLICY_SHUNT_MASK(((lset_t)1 << (POLICY_SHUNT1_IX)) - ((lset_t)1 <<
 (POLICY_SHUNT0_IX)) + ((lset_t)1 << (POLICY_SHUNT1_IX)
))) >>
	POLICY_SHUNT_SHIFTPOLICY_SHUNT0_IX] :
fail_spi[(c->policy & POLICY_FAIL_MASK(((lset_t)1 << (POLICY_FAIL1_IX)) - ((lset_t)1 <<
 (POLICY_FAIL0_IX)) + ((lset_t)1 << (POLICY_FAIL1_IX)))) >> POLICY_FAIL_SHIFTPOLICY_FAIL0_IX];
1640}

1642bool_Bool del_spi(ipsec_spi_t spi, const struct ip_protocol *proto,
    const ip_address *src, const ip_address *dest)
1644{
char text_said[SATOT_BUFsizeof(said_buf)];

set_text_said(text_said, dest, spi, proto);

dbg("delete %s", text_said){ if ((cur_debugging & (((lset_t)1 << (DBG_BASE_IX)
)))) { DBG_log("delete %s", text_said); } };

struct kernel_sa sa = {
.spi = spi,
.proto = proto,
.src.address = src,
.dst.address = dest,
.text_said = text_said,
};

passert(kernel_ops->del_sa != NULL){ _Bool assertion__ = kernel_ops->del_sa != ((void*)0); if
 (!assertion__) { lsw_passert_fail((where_t) { .func = __func__
, .basename = "kernel.c" , .line = 1659}, "%s", "kernel_ops->del_sa != NULL"
); } };
return kernel_ops->del_sa(&sa);
1661}

1663static void setup_esp_nic_offload(struct kernel_sa *sa, struct connection *c,
bool_Bool *nic_offload_fallback)
1665{
if (c->nic_offload == yna_no ||
   c->interface == NULL((void*)0) || c->interface->ip_dev == NULL((void*)0) ||
   c->interface->ip_dev->id_rname == NULL((void*)0)) {
dbg("NIC esp-hw-offload disabled for connection '%s'", c->name){ if ((cur_debugging & (((lset_t)1 << (DBG_BASE_IX)
)))) { DBG_log("NIC esp-hw-offload disabled for connection '%s'"
, c->name); } };
return;
}

if (c->nic_offload == yna_auto) {
if (!c->interface->ip_dev->id_nic_offload) {
	dbg("NIC esp-hw-offload not for connection '%s' not available on interface %s",{ if ((cur_debugging & (((lset_t)1 << (DBG_BASE_IX)
)))) { DBG_log("NIC esp-hw-offload not for connection '%s' not available on interface %s"
, c->name, c->interface->ip_dev->id_rname); } }
		c->name, c->interface->ip_dev->id_rname){ if ((cur_debugging & (((lset_t)1 << (DBG_BASE_IX)
)))) { DBG_log("NIC esp-hw-offload not for connection '%s' not available on interface %s"
, c->name, c->interface->ip_dev->id_rname); } };
	return;
}
*nic_offload_fallback = TRUE1;
dbg("NIC esp-hw-offload offload for connection '%s' enabled on interface %s",{ if ((cur_debugging & (((lset_t)1 << (DBG_BASE_IX)
)))) { DBG_log("NIC esp-hw-offload offload for connection '%s' enabled on interface %s"
, c->name, c->interface->ip_dev->id_rname); } }
		c->name, c->interface->ip_dev->id_rname){ if ((cur_debugging & (((lset_t)1 << (DBG_BASE_IX)
)))) { DBG_log("NIC esp-hw-offload offload for connection '%s' enabled on interface %s"
, c->name, c->interface->ip_dev->id_rname); } };
}
sa->nic_offload_dev = c->interface->ip_dev->id_rname;
1684}

1686/*
* Set up one direction of the SA bundle
*/
1689static bool_Bool setup_half_ipsec_sa(struct state *st, bool_Bool inbound)
1690{
/* Build an inbound or outbound SA */

struct connection *c = st->st_connection;
ipsec_spi_t inner_spi = 0;
const struct ip_protocol *proto = NULL((void*)0);
enum eroute_type esatype = ET_UNSPEC;
bool_Bool replace = inbound && (kernel_ops->get_spi != NULL((void*)0));
1
Assuming 'inbound' is not equal to 0→
2
←
Assuming the condition is false→
bool_Bool outgoing_ref_set = FALSE0;
bool_Bool incoming_ref_set = FALSE0;
IPsecSAref_t ref_peer = st->st_ref_peer;
IPsecSAref_t new_ref_peer = IPSEC_SAREF_NULL((IPsecSAref_t)0u);
bool_Bool nic_offload_fallback = FALSE0;

/* SPIs, saved for spigrouping or undoing, if necessary */
struct kernel_sa said[EM_MAXRELSPIS4];
struct kernel_sa *said_next = said;

char text_ipcomp[SATOT_BUFsizeof(said_buf)];
char text_esp[SATOT_BUFsizeof(said_buf)];
char text_ah[SATOT_BUFsizeof(said_buf)];

ip_address src, dst;
ip_selector src_client, dst_client;
if (inbound) {
3
←
Taking true branch→
src = c->spd.that.host_addr;
src_client = c->spd.that.client;
dst = c->spd.this.host_addr;
dst_client = c->spd.this.client;
} else {
src = c->spd.this.host_addr,
src_client = c->spd.this.client;
dst = c->spd.that.host_addr;
dst_client = c->spd.that.client;
}
/* XXX: code is stuffing an endpoint in .host_addr */
src = strip_endpoint(&src, HERE(where_t) { .func = __func__, .basename = "kernel.c" , .line =
 1726});
dst = strip_endpoint(&dst, HERE(where_t) { .func = __func__, .basename = "kernel.c" , .line =
 1727});

/*
* mode: encapsulation mode called for
* encap_oneshot: copy of "encapsulation" but reset to
*	ENCAPSULATION_MODE_TRANSPORT after use.
*/
int mode = ENCAPSULATION_MODE_TRANSPORT2;
bool_Bool add_selector;

if (st->st_ah.attrs.mode == ENCAPSULATION_MODE_TUNNEL1 ||
4
←
Assuming the condition is false→
7
←
Taking false branch→
   st->st_esp.attrs.mode == ENCAPSULATION_MODE_TUNNEL1 ||
5
←
Assuming the condition is false→
   st->st_ipcomp.attrs.mode == ENCAPSULATION_MODE_TUNNEL1) {
6
←
Assuming the condition is false→
mode = ENCAPSULATION_MODE_TUNNEL1;
add_selector = FALSE0; /* Don't add selectors for tunnel mode */
} else {
/*
 * RFC 4301, Section 5.2 Requires traffic selectors to be set
 * on transport mode
 */
add_selector = TRUE1;
}
c->ipsec_mode = mode;

int encap_oneshot = mode;

struct kernel_sa said_boilerplate = {
.src.address = &src,
.dst.address = &dst,
.src.client = &src_client,
.dst.client = &dst_client,
.inbound = inbound,
.add_selector = add_selector,
.transport_proto = c->spd.this.protocol,
.sa_lifetime = c->sa_ipsec_life_seconds,
.outif = -1,
.sec_ctx = st->sec_ctx,
};

inner_spi = SPI_PASS256;
if (mode == ENCAPSULATION_MODE_TUNNEL1) {
8
←
Taking false branch→
/* If we are tunnelling, set up IP in IP pseudo SA */
proto = &ip_protocol_ipip;
esatype = ET_IPIP;
} else {
/* For transport mode set ESP */
/* ??? why are we sure that this isn't AH? */
proto = &ip_protocol_esp;
esatype = ET_ESP;
}

/* set up IPCOMP SA, if any */

if (st->st_ipcomp.present) {
9
←
Assuming the condition is false→
10
←
Taking false branch→
ipsec_spi_t ipcomp_spi =
	inbound ? st->st_ipcomp.our_spi : st->st_ipcomp.attrs.spi;
unsigned compalg;

switch (st->st_ipcomp.attrs.transattrs.ta_comp) {
case IPCOMP_DEFLATE:
	compalg = SADB_X_CALG_DEFLATE2;
	break;

default:
	loglog(RC_LOG_SERIOUS,
	       "IPCOMP transform %s not implemented",
	       st->st_ipcomp.attrs.transattrs.ta_encrypt->common.fqn);
	goto fail;
}

set_text_said(text_ipcomp, &dst, ipcomp_spi, &ip_protocol_comp);

*said_next = said_boilerplate;
said_next->spi = ipcomp_spi;
said_next->esatype = ET_IPCOMP;
said_next->compalg = compalg;
said_next->mode = encap_oneshot;
said_next->reqid = reqid_ipcomp(c->spd.reqid);
said_next->text_said = text_ipcomp;

if (inbound) {
	/*
	 * set corresponding outbound SA. We can do this on
	 * each SA in the bundle without harm.
	 */
	said_next->ref_peer = ref_peer;
} else if (!outgoing_ref_set) {
	/* on outbound, pick up the SAref if not already done */
	said_next->ref    = ref_peer;
	outgoing_ref_set  = TRUE1;
}

if (!kernel_ops->add_sa(said_next, replace)) {
	libreswan_log("add_sa ipcomp failed")loglog(RC_LOG, "add_sa ipcomp failed");
	goto fail;
}

/*
 * SA refs will have been allocated for this SA.
 * The inner most one is interesting for the outgoing SA,
 * since we refer to it in the policy that we instantiate.
 */
if (new_ref_peer == IPSEC_SAREF_NULL((IPsecSAref_t)0u) && !inbound) {
	new_ref_peer = said_next->ref;
	if (kernel_ops->type != USE_XFRM && new_ref_peer == IPSEC_SAREF_NULL((IPsecSAref_t)0u))
		new_ref_peer = IPSEC_SAREF_NA((IPsecSAref_t)0xffff0001);
}
if (!incoming_ref_set && inbound) {
	st->st_ref = said_next->ref;
	incoming_ref_set = TRUE1;
}
said_next++;

encap_oneshot = ENCAPSULATION_MODE_TRANSPORT2;
}

/* set up ESP SA, if any */

if (st->st_esp.present) {
11
←
Assuming the condition is false→
12
←
Taking false branch→
ipsec_spi_t esp_spi =
	inbound ? st->st_esp.our_spi : st->st_esp.attrs.spi;
u_char *esp_dst_keymat =
	inbound ? st->st_esp.our_keymat : st->st_esp.
	peer_keymat;
const struct trans_attrs *ta = &st->st_esp.attrs.transattrs;

const struct ip_encap *encap_type = NULL((void*)0);
uint16_t encap_sport = 0, encap_dport = 0;
ip_address natt_oa;

if (st->hidden_variables.st_nat_traversal & NAT_T_DETECTED( ((lset_t)1 << (NATED_HOST)) | ((lset_t)1 << (NATED_PEER
)) ) ||
    st->st_interface->protocol == &ip_protocol_tcp) {
	encap_type = st->st_interface->protocol->encap_esp;
	if (inbound) {
		encap_sport = endpoint_hport(&st->st_remote_endpoint);
		encap_dport = endpoint_hport(&st->st_interface->local_endpoint);
	} else {
		encap_sport = endpoint_hport(&st->st_interface->local_endpoint);
		encap_dport = endpoint_hport(&st->st_remote_endpoint);
	}
	natt_oa = st->hidden_variables.st_nat_oa;
	dbg("natt/tcp sa encap_type="PRI_IP_ENCAP" sport=%d dport=%d",{ if ((cur_debugging & (((lset_t)1 << (DBG_BASE_IX)
)))) { DBG_log("natt/tcp sa encap_type=""%u(%s)"" sport=%d dport=%d"
, (encap_type) == ((void*)0) ? 0 : (encap_type)->encap_type
, (encap_type) == ((void*)0) ? "none" : (encap_type)->name
, encap_sport, encap_dport); } }
	    pri_ip_encap(encap_type), encap_sport, encap_dport){ if ((cur_debugging & (((lset_t)1 << (DBG_BASE_IX)
)))) { DBG_log("natt/tcp sa encap_type=""%u(%s)"" sport=%d dport=%d"
, (encap_type) == ((void*)0) ? 0 : (encap_type)->encap_type
, (encap_type) == ((void*)0) ? "none" : (encap_type)->name
, encap_sport, encap_dport); } };
}

dbg("looking for alg with encrypt: %s keylen: %d integ: %s",{ if ((cur_debugging & (((lset_t)1 << (DBG_BASE_IX)
)))) { DBG_log("looking for alg with encrypt: %s keylen: %d integ: %s"
, ta->ta_encrypt->common.fqn, ta->enckeylen, ta->
ta_integ->common.fqn); } }
    ta->ta_encrypt->common.fqn, ta->enckeylen, ta->ta_integ->common.fqn){ if ((cur_debugging & (((lset_t)1 << (DBG_BASE_IX)
)))) { DBG_log("looking for alg with encrypt: %s keylen: %d integ: %s"
, ta->ta_encrypt->common.fqn, ta->enckeylen, ta->
ta_integ->common.fqn); } };

/*
 * Check that both integrity and encryption are
 * supported by the kernel.
 *
 * Since the parser uses these exact same checks when
 * loading the connection, they should never fail (if
 * they do then strange things have been going on
 * since the connection was loaded).
 */
if (!kernel_alg_integ_ok(ta->ta_integ)) {
	loglog(RC_LOG_SERIOUS,
	       "ESP integrity algorithm %s is not implemented or allowed",
	       ta->ta_integ->common.fqn);
	goto fail;
}
if (!kernel_alg_encrypt_ok(ta->ta_encrypt)) {
	loglog(RC_LOG_SERIOUS,
	       "ESP encryption algorithm %s is not implemented or allowed",
	       ta->ta_encrypt->common.fqn);
	goto fail;
}

/*
 * Validate the encryption key size.
 */
size_t encrypt_keymat_size;
if (!kernel_alg_encrypt_key_size(ta->ta_encrypt, ta->enckeylen,
				 &encrypt_keymat_size)) {
	loglog(RC_LOG_SERIOUS,
	       "ESP encryption algorithm %s with key length %d not implemented or allowed",
	       ta->ta_encrypt->common.fqn, ta->enckeylen);
	goto fail;
}

/* Fixup key lengths for special cases */
1910#ifdef USE_3DES1
if (ta->ta_encrypt == &ike_alg_encrypt_3des_cbc) {
	/* Grrrrr.... f*cking 7 bits jurassic algos  */
	/* 168 bits in kernel, need 192 bits for keymat_len */
	if (encrypt_keymat_size == 21) {
		dbg("%s requires a 7-bit jurassic adjust",{ if ((cur_debugging & (((lset_t)1 << (DBG_BASE_IX)
)))) { DBG_log("%s requires a 7-bit jurassic adjust", ta->
ta_encrypt->common.fqn); } }
		    ta->ta_encrypt->common.fqn){ if ((cur_debugging & (((lset_t)1 << (DBG_BASE_IX)
)))) { DBG_log("%s requires a 7-bit jurassic adjust", ta->
ta_encrypt->common.fqn); } };
		encrypt_keymat_size = 24;
	}
}
1920#endif

if (ta->ta_encrypt->salt_size > 0) {
	dbg("%s requires %zu salt bytes",{ if ((cur_debugging & (((lset_t)1 << (DBG_BASE_IX)
)))) { DBG_log("%s requires %zu salt bytes", ta->ta_encrypt
->common.fqn, ta->ta_encrypt->salt_size); } }
	    ta->ta_encrypt->common.fqn, ta->ta_encrypt->salt_size){ if ((cur_debugging & (((lset_t)1 << (DBG_BASE_IX)
)))) { DBG_log("%s requires %zu salt bytes", ta->ta_encrypt
->common.fqn, ta->ta_encrypt->salt_size); } };
	encrypt_keymat_size += ta->ta_encrypt->salt_size;
}

size_t integ_keymat_size = ta->ta_integ->integ_keymat_size; /* BYTES */

dbg("st->st_esp.keymat_len=%" PRIu16 " is encrypt_keymat_size=%zu + integ_keymat_size=%zu",{ if ((cur_debugging & (((lset_t)1 << (DBG_BASE_IX)
)))) { DBG_log("st->st_esp.keymat_len=%" "u" " is encrypt_keymat_size=%zu + integ_keymat_size=%zu"
, st->st_esp.keymat_len, encrypt_keymat_size, integ_keymat_size
); } }
    st->st_esp.keymat_len, encrypt_keymat_size, integ_keymat_size){ if ((cur_debugging & (((lset_t)1 << (DBG_BASE_IX)
)))) { DBG_log("st->st_esp.keymat_len=%" "u" " is encrypt_keymat_size=%zu + integ_keymat_size=%zu"
, st->st_esp.keymat_len, encrypt_keymat_size, integ_keymat_size
); } };

passert(st->st_esp.keymat_len == encrypt_keymat_size + integ_keymat_size){ _Bool assertion__ = st->st_esp.keymat_len == encrypt_keymat_size
 + integ_keymat_size; if (!assertion__) { lsw_passert_fail((where_t
) { .func = __func__, .basename = "kernel.c" , .line = 1933},
 "%s", "st->st_esp.keymat_len == encrypt_keymat_size + integ_keymat_size"
); } };

set_text_said(text_esp, &dst, esp_spi, &ip_protocol_esp);

*said_next = said_boilerplate;
said_next->spi = esp_spi;
said_next->esatype = ET_ESP;
said_next->replay_window = c->sa_replay_window;
dbg("setting IPsec SA replay-window to %d", c->sa_replay_window){ if ((cur_debugging & (((lset_t)1 << (DBG_BASE_IX)
)))) { DBG_log("setting IPsec SA replay-window to %d", c->
sa_replay_window); } };

if (c->xfrmi != NULL((void*)0))
	said_next->xfrm_if_id = c->xfrmi->if_id;

if (!inbound && c->sa_tfcpad != 0 && !st->st_seen_no_tfc) {
	dbg("Enabling TFC at %d bytes (up to PMTU)", c->sa_tfcpad){ if ((cur_debugging & (((lset_t)1 << (DBG_BASE_IX)
)))) { DBG_log("Enabling TFC at %d bytes (up to PMTU)", c->
sa_tfcpad); } };
	said_next->tfcpad = c->sa_tfcpad;
}

if (c->policy & POLICY_DECAP_DSCP((lset_t)1 << (POLICY_DECAP_DSCP_IX))) {
	dbg("Enabling Decap ToS/DSCP bits"){ if ((cur_debugging & (((lset_t)1 << (DBG_BASE_IX)
)))) { DBG_log("Enabling Decap ToS/DSCP bits"); } };
	said_next->decap_dscp = TRUE1;
}
if (c->policy & POLICY_NOPMTUDISC((lset_t)1 << (POLICY_NOPMTUDISC_IX))) {
	dbg("Disabling Path MTU Discovery"){ if ((cur_debugging & (((lset_t)1 << (DBG_BASE_IX)
)))) { DBG_log("Disabling Path MTU Discovery"); } };
	said_next->nopmtudisc = TRUE1;
}

said_next->integ = ta->ta_integ;
1961#ifdef USE_SHA21
if (said_next->integ == &ike_alg_integ_sha2_256 &&
	LIN(POLICY_SHA2_TRUNCBUG, c->policy)(((((lset_t)1 << (POLICY_SHA2_TRUNCBUG_IX))) & (c->
policy)) == (((lset_t)1 << (POLICY_SHA2_TRUNCBUG_IX))))) {
	if (kernel_ops->sha2_truncbug_support) {
		if (libreswan_fipsmode() == 1) {
			loglog(RC_LOG_SERIOUS,
				"Error: sha2-truncbug=yes is not allowed in FIPS mode");
			goto fail;
		}
		dbg(" authalg converted for sha2 truncation at 96bits instead of IETF's mandated 128bits"){ if ((cur_debugging & (((lset_t)1 << (DBG_BASE_IX)
)))) { DBG_log(" authalg converted for sha2 truncation at 96bits instead of IETF's mandated 128bits"
); } };
		/*
		 * We need to tell the kernel to mangle
		 * the sha2_256, as instructed by the user
		 */
		said_next->integ = &ike_alg_integ_hmac_sha2_256_truncbug;
	} else {
		loglog(RC_LOG_SERIOUS,
			"Error: %s stack does not support sha2_truncbug=yes",
			kernel_ops->kern_name);
		goto fail;
	}
}
1983#endif
said_next->authalg = said_next->integ->integ_ikev1_ah_transform;

if (st->st_esp.attrs.transattrs.esn_enabled) {
	dbg("Enabling ESN"){ if ((cur_debugging & (((lset_t)1 << (DBG_BASE_IX)
)))) { DBG_log("Enabling ESN"); } };
	said_next->esn = TRUE1;
}

/*
 * XXX: Assume SADB_ and ESP_ numbers match!  Clearly
 * setting .compalg is wrong, don't yet trust
 * lower-level code to be right.
 */
said_next->encrypt = ta->ta_encrypt;
said_next->compalg = said_next->encrypt->common.id[IKEv1_ESP_ID];

/* divide up keying material */
said_next->enckey = esp_dst_keymat;
said_next->enckeylen = encrypt_keymat_size; /* BYTES */
said_next->authkey = esp_dst_keymat + encrypt_keymat_size;
said_next->authkeylen = integ_keymat_size; /* BYTES */

said_next->mode = encap_oneshot;
said_next->reqid = reqid_esp(c->spd.reqid);

said_next->src.encap_port = encap_sport;
said_next->dst.encap_port = encap_dport;
said_next->encap_type = encap_type;
said_next->natt_oa = &natt_oa;
said_next->text_said = text_esp;

DBG(DBG_PRIVATE, {{ if ((cur_debugging & (((lset_t)1 << (DBG_PRIVATE_IX
))))) { { DBG_dump("ESP enckey:", said_next->enckey, said_next
->enckeylen); DBG_dump("ESP authkey:", said_next->authkey
, said_next->authkeylen); }; } }
	DBG_dump("ESP enckey:",  said_next->enckey,{ if ((cur_debugging & (((lset_t)1 << (DBG_PRIVATE_IX
))))) { { DBG_dump("ESP enckey:", said_next->enckey, said_next
->enckeylen); DBG_dump("ESP authkey:", said_next->authkey
, said_next->authkeylen); }; } }
		said_next->enckeylen);{ if ((cur_debugging & (((lset_t)1 << (DBG_PRIVATE_IX
))))) { { DBG_dump("ESP enckey:", said_next->enckey, said_next
->enckeylen); DBG_dump("ESP authkey:", said_next->authkey
, said_next->authkeylen); }; } }
	DBG_dump("ESP authkey:", said_next->authkey,{ if ((cur_debugging & (((lset_t)1 << (DBG_PRIVATE_IX
))))) { { DBG_dump("ESP enckey:", said_next->enckey, said_next
->enckeylen); DBG_dump("ESP authkey:", said_next->authkey
, said_next->authkeylen); }; } }
		said_next->authkeylen);{ if ((cur_debugging & (((lset_t)1 << (DBG_PRIVATE_IX
))))) { { DBG_dump("ESP enckey:", said_next->enckey, said_next
->enckeylen); DBG_dump("ESP authkey:", said_next->authkey
, said_next->authkeylen); }; } }
}){ if ((cur_debugging & (((lset_t)1 << (DBG_PRIVATE_IX
))))) { { DBG_dump("ESP enckey:", said_next->enckey, said_next
->enckeylen); DBG_dump("ESP authkey:", said_next->authkey
, said_next->authkeylen); }; } };

if (inbound) {
	/*
	 * set corresponding outbound SA. We can do this on
	 * each SA in the bundle without harm.
	 */
	said_next->ref_peer = ref_peer;
} else if (!outgoing_ref_set) {
	/* on outbound, pick up the SAref if not already done */
	said_next->ref = ref_peer;
	outgoing_ref_set = TRUE1;
}
setup_esp_nic_offload(said_next, c, &nic_offload_fallback);

bool_Bool ret = kernel_ops->add_sa(said_next, replace);

if (!ret && nic_offload_fallback &&
	said_next->nic_offload_dev != NULL((void*)0)) {
	/* Fallback to non-nic-offload crypto */
	said_next->nic_offload_dev = NULL((void*)0);
	ret = kernel_ops->add_sa(said_next, replace);
}

/* scrub keys from memory */
memset(said_next->enckey, 0, said_next->enckeylen);
memset(said_next->authkey, 0, said_next->authkeylen);

if (!ret)
	goto fail;

/*
 * SA refs will have been allocated for this SA.
 * The inner most one is interesting for the outgoing SA,
 * since we refer to it in the policy that we instantiate.
 */
if (new_ref_peer == IPSEC_SAREF_NULL((IPsecSAref_t)0u) && !inbound) {
	new_ref_peer = said_next->ref;
	if (kernel_ops->type != USE_XFRM && new_ref_peer == IPSEC_SAREF_NULL((IPsecSAref_t)0u))
		new_ref_peer = IPSEC_SAREF_NA((IPsecSAref_t)0xffff0001);
}
if (!incoming_ref_set && inbound) {
	st->st_ref = said_next->ref;
	incoming_ref_set = TRUE1;
}
said_next++;

encap_oneshot = ENCAPSULATION_MODE_TRANSPORT2;
}

/* set up AH SA, if any */

if (st->st_ah.present) {
13
←
Assuming the condition is false→
14
←
Taking false branch→
ipsec_spi_t ah_spi =
	inbound ? st->st_ah.our_spi : st->st_ah.attrs.spi;
u_char *ah_dst_keymat =
	inbound ? st->st_ah.our_keymat : st->st_ah.peer_keymat;

const struct integ_desc *integ = st->st_ah.attrs.transattrs.ta_integ;
size_t keymat_size = integ->integ_keymat_size;
int authalg = integ->integ_ikev1_ah_transform;
if (authalg <= 0) {
	loglog(RC_LOG_SERIOUS, "%s not implemented",
	       integ->common.fqn);
	goto fail;
}

passert(st->st_ah.keymat_len == keymat_size){ _Bool assertion__ = st->st_ah.keymat_len == keymat_size;
 if (!assertion__) { lsw_passert_fail((where_t) { .func = __func__
, .basename = "kernel.c" , .line = 2086}, "%s", "st->st_ah.keymat_len == keymat_size"
); } };

set_text_said(text_ah, &dst, ah_spi, &ip_protocol_ah);

*said_next = said_boilerplate;
said_next->spi = ah_spi;
said_next->esatype = ET_AH;
said_next->integ = integ;
said_next->authalg = authalg;
said_next->authkeylen = st->st_ah.keymat_len;
said_next->authkey = ah_dst_keymat;
said_next->mode = encap_oneshot;
said_next->reqid = reqid_ah(c->spd.reqid);
said_next->text_said = text_ah;
said_next->replay_window = c->sa_replay_window;
dbg("setting IPsec SA replay-window to %d", c->sa_replay_window){ if ((cur_debugging & (((lset_t)1 << (DBG_BASE_IX)
)))) { DBG_log("setting IPsec SA replay-window to %d", c->
sa_replay_window); } };

if (st->st_ah.attrs.transattrs.esn_enabled) {
	dbg("Enabling ESN"){ if ((cur_debugging & (((lset_t)1 << (DBG_BASE_IX)
)))) { DBG_log("Enabling ESN"); } };
	said_next->esn = TRUE1;
}

DBG(DBG_PRIVATE, {{ if ((cur_debugging & (((lset_t)1 << (DBG_PRIVATE_IX
))))) { { DBG_dump("AH authkey:", said_next->authkey, said_next
->authkeylen); }; } }
	DBG_dump("AH authkey:", said_next->authkey,{ if ((cur_debugging & (((lset_t)1 << (DBG_PRIVATE_IX
))))) { { DBG_dump("AH authkey:", said_next->authkey, said_next
->authkeylen); }; } }
		said_next->authkeylen);{ if ((cur_debugging & (((lset_t)1 << (DBG_PRIVATE_IX
))))) { { DBG_dump("AH authkey:", said_next->authkey, said_next
->authkeylen); }; } }
	}){ if ((cur_debugging & (((lset_t)1 << (DBG_PRIVATE_IX
))))) { { DBG_dump("AH authkey:", said_next->authkey, said_next
->authkeylen); }; } };

if (inbound) {
	/*
	 * set corresponding outbound SA. We can do this on
	 * each SA in the bundle without harm.
	 */
	said_next->ref_peer = ref_peer;
} else if (!outgoing_ref_set) {
	/* on outbound, pick up the SAref if not already done */
	said_next->ref = ref_peer;
	outgoing_ref_set = TRUE1;	/* outgoing_ref_set not subsequently used */
}

if (!kernel_ops->add_sa(said_next, replace)) {
	/* scrub key from memory */
	memset(said_next->authkey, 0, said_next->authkeylen);
	goto fail;
}
/* scrub key from memory */
memset(said_next->authkey, 0, said_next->authkeylen);

/*
 * SA refs will have been allocated for this SA.
 * The inner most one is interesting for the outgoing SA,
 * since we refer to it in the policy that we instantiate.
 */
if (new_ref_peer == IPSEC_SAREF_NULL((IPsecSAref_t)0u) && !inbound) {
	new_ref_peer = said_next->ref;
	if (kernel_ops->type != USE_XFRM && new_ref_peer == IPSEC_SAREF_NULL((IPsecSAref_t)0u))
		new_ref_peer = IPSEC_SAREF_NA((IPsecSAref_t)0xffff0001);
}
if (!incoming_ref_set && inbound) {
	st->st_ref = said_next->ref;
	incoming_ref_set = TRUE1;	/* incoming_ref_set not subsequently used */
}
said_next++;

encap_oneshot = ENCAPSULATION_MODE_TRANSPORT2;	/* encap_oneshot not subsequently used */
}

/*
* Add an inbound eroute to enforce an arrival check.
*
* If inbound,
* ??? and some more mysterious conditions,
* Note reversed ends.
* Not much to be done on failure.
*/
dbg("%s() is installing inbound eroute? inbound=%d owner=#%lu mode=%d",{ if ((cur_debugging & (((lset_t)1 << (DBG_BASE_IX)
)))) { DBG_log("%s() is installing inbound eroute? inbound=%d owner=#%lu mode=%d"
, __func__, inbound, c->spd.eroute_owner, mode); } }
15
←
Assuming the condition is false→
16
←
Taking false branch→
   __func__, inbound, c->spd.eroute_owner, mode){ if ((cur_debugging & (((lset_t)1 << (DBG_BASE_IX)
)))) { DBG_log("%s() is installing inbound eroute? inbound=%d owner=#%lu mode=%d"
, __func__, inbound, c->spd.eroute_owner, mode); } };
if (inbound && c->spd.eroute_owner == SOS_NOBODY0) {
17
←
Assuming the condition is true→
18
←
Taking true branch→
dbg("%s() is installing inbound eroute", __func__){ if ((cur_debugging & (((lset_t)1 << (DBG_BASE_IX)
)))) { DBG_log("%s() is installing inbound eroute", __func__)
; } };
19
←
Taking false branch→
struct pfkey_proto_info proto_info[4];
int i = 0;

/*
 * ??? why does this code care about
 * st->st_*.attrs.mode?
 * We have gone do some trouble to compute
 * "mode".  And later code uses
 * "mode".
 */
if (st->st_ipcomp.present) {
20
←
Taking false branch→
	proto_info[i].proto = ip_protocol_comp.ipproto;
	proto_info[i].mode =
		st->st_ipcomp.attrs.mode;
	proto_info[i].reqid = reqid_ipcomp(c->spd.reqid);
	i++;
}

if (st->st_esp.present) {
21
←
Taking false branch→
	proto_info[i].proto = IPPROTO_ESPIPPROTO_ESP;
	proto_info[i].mode =
		st->st_esp.attrs.mode;
	proto_info[i].reqid = reqid_esp(c->spd.reqid);
	i++;
}

if (st->st_ah.present) {
22
←
Taking false branch→
	proto_info[i].proto = IPPROTO_AHIPPROTO_AH;
	proto_info[i].mode =
		st->st_ah.attrs.mode;
	proto_info[i].reqid = reqid_ah(c->spd.reqid);
	i++;
}

dbg("%s() before proto %d", __func__, proto_info[0].proto){ if ((cur_debugging & (((lset_t)1 << (DBG_BASE_IX)
)))) { DBG_log("%s() before proto %d", __func__, proto_info[0
].proto); } };
23
←
Taking false branch→
proto_info[i].proto = 0;

/*
 * ??? why is mode overwritten ONLY if true
 * (kernel_ops->inbound_eroute)?
 */
if (mode == ENCAPSULATION_MODE_TUNNEL1) {
24
←
Taking false branch→
	proto_info[0].mode =
		ENCAPSULATION_MODE_TUNNEL1;
	for (i = 1; proto_info[i].proto; i++)
		proto_info[i].mode =
			ENCAPSULATION_MODE_TRANSPORT2;
}
dbg("%s() after proto %d", __func__, proto_info[0].proto){ if ((cur_debugging & (((lset_t)1 << (DBG_BASE_IX)
)))) { DBG_log("%s() after proto %d", __func__, proto_info[0]
.proto); } };
25
←
Taking false branch→

uint32_t xfrm_if_id = c->xfrmi != NULL((void*)0) ?
26
←
Assuming the condition is false→
27
←
'?' condition is false→
	c->xfrmi->if_id : 0;

dbg("%s() calling raw_eroute backwards (i.e., inbound)", __func__){ if ((cur_debugging & (((lset_t)1 << (DBG_BASE_IX)
)))) { DBG_log("%s() calling raw_eroute backwards (i.e., inbound)"
, __func__); } };
28
←
Taking false branch→
/* MCR - should be passed a spd_eroute structure here */
/* note: this and that are intentionally reversed */
if (!raw_eroute(&c->spd.that.host_addr,		/* this_host */
29
←
Calling 'raw_eroute'→
		&c->spd.that.client,	/* this_client */
		&c->spd.this.host_addr,	/* that_host */
		&c->spd.this.client,	/* that_client */
		inner_spi,		/* current spi - might not be used? */
		inner_spi,		/* new spi */
		proto,			/* SA proto */
		c->spd.this.protocol,	/* transport_proto */
		esatype,		/* esatype */
		proto_info,		/* " */
		deltatime(0),		/* lifetime */
		calculate_sa_prio(c, FALSE0),	/* priority */
		&c->sa_marks,		/* IPsec SA marks */
		xfrm_if_id,
		ERO_ADD_INBOUND,	/* op */
		"add inbound",		/* opname */
		st->st_connection->policy_label))
{
	libreswan_log("raw_eroute() in setup_half_ipsec_sa() failed to add inbound")loglog(RC_LOG, "raw_eroute() in setup_half_ipsec_sa() failed to add inbound"
);
}
}

/* If there are multiple SPIs, group them. */

if (kernel_ops->grp_sa != NULL((void*)0) && said_next > &said[1]) {
struct kernel_sa *s;

/*
 * group SAs, two at a time, inner to outer (backwards in
 * said[])
 *
 * The grouping is by pairs.  So if said[] contains
 * ah esp ipip,
 *
 * the grouping would be ipip:esp, esp:ah.
 */
for (s = said; s < said_next - 1; s++) {
	dbg("grouping %s (ref=%u) and %s (ref=%u)",{ if ((cur_debugging & (((lset_t)1 << (DBG_BASE_IX)
)))) { DBG_log("grouping %s (ref=%u) and %s (ref=%u)", s[0].text_said
, s[0].ref, s[1].text_said, s[1].ref); } }
	    s[0].text_said, s[0].ref,{ if ((cur_debugging & (((lset_t)1 << (DBG_BASE_IX)
)))) { DBG_log("grouping %s (ref=%u) and %s (ref=%u)", s[0].text_said
, s[0].ref, s[1].text_said, s[1].ref); } }
	    s[1].text_said, s[1].ref){ if ((cur_debugging & (((lset_t)1 << (DBG_BASE_IX)
)))) { DBG_log("grouping %s (ref=%u) and %s (ref=%u)", s[0].text_said
, s[0].ref, s[1].text_said, s[1].ref); } };
	if (!kernel_ops->grp_sa(s + 1, s)) {
		libreswan_log("grp_sa failed")loglog(RC_LOG, "grp_sa failed");
		goto fail;
	}
}
/* could update said, but it will not be used */
}

if (new_ref_peer != IPSEC_SAREF_NULL((IPsecSAref_t)0u))
st->st_ref_peer = new_ref_peer;

/* if the impaired is set, pretend this fails */
if (impair.sa_creation) {
DBG_log("Impair SA creation is set, pretending to fail");
goto fail;
}
return TRUE1;

2278fail:
{
libreswan_log("setup_half_ipsec_sa() hit fail:")loglog(RC_LOG, "setup_half_ipsec_sa() hit fail:");
/* undo the done SPIs */
while (said_next-- != said) {
	if (said_next->proto != 0) {
		(void) del_spi(said_next->spi,
			said_next->proto,
			&src, said_next->dst.address);
	}
}
return FALSE0;
}
2291}

2293static bool_Bool teardown_half_ipsec_sa(struct state *st, bool_Bool inbound)
2294{
/* Delete any AH, ESP, and IP in IP SPIs. */

struct connection *const c = st->st_connection;

/*
* If we have a new address in c->spd.that.host_addr,
* we are the initiator, have been redirected,
* and yet this routine must use the old address.
*
* We point effective_that_host_address to the appropriate address.
*/

const ip_address *effective_that_host_addr = &c->spd.that.host_addr;

if (!sameaddr(&st->st_remote_endpoint, effective_that_host_addr) &&
   address_is_specified(&c->temp_vars.redirect_ip)) {
effective_that_host_addr = &st->st_remote_endpoint;
}

/* ??? CLANG 3.5 thinks that c might be NULL */
if (inbound && c->spd.eroute_owner == SOS_NOBODY0 &&
   !raw_eroute(effective_that_host_addr,
	&c->spd.that.client,
	&c->spd.this.host_addr,
	&c->spd.this.client,
	SPI_PASS256, SPI_PASS256,
	c->ipsec_mode == ENCAPSULATION_MODE_TRANSPORT2 ?
		&ip_protocol_esp : NULL((void*)0),
	c->spd.this.protocol,
	c->ipsec_mode == ENCAPSULATION_MODE_TRANSPORT2 ?
		ET_ESP : ET_UNSPEC,
	null_proto_info,
	deltatime(0),
	calculate_sa_prio(c, FALSE0),
	&c->sa_marks,
	0, /* xfrm_if_id. needed to tear down? */
	ERO_DEL_INBOUND,
	"delete inbound",
	c->policy_label))
{
libreswan_log("raw_eroute in teardown_half_ipsec_sa() failed to delete inbound")loglog(RC_LOG, "raw_eroute in teardown_half_ipsec_sa() failed to delete inbound"
);
}

/* collect each proto SA that needs deleting */

struct {
const struct ip_protocol *proto;
const struct ipsec_proto_info *info;
} protos[4];	/* at most 3 entries + terminator */
int i = 0;

if (st->st_ah.present) {
protos[i].proto = &ip_protocol_ah;
protos[i].info = &st->st_ah;
i++;
}

if (st->st_esp.present) {
protos[i].proto = &ip_protocol_esp;
protos[i].info = &st->st_esp;
i++;
}

if (st->st_ipcomp.present) {
protos[i].proto = &ip_protocol_comp;
protos[i].info = &st->st_ipcomp;
i++;
}

/*
* If the SAs have been grouped, deleting any one will do:
* we just delete the first one found (protos[0]).
*/
if (kernel_ops->grp_sa != NULL((void*)0) && i > 0)
i = 1;

protos[i].proto = NULL((void*)0);

/* delete each proto that needs deleting */
bool_Bool result = TRUE1;

for (i = 0; protos[i].proto != NULL((void*)0); i++) {
const struct ip_protocol *proto = protos[i].proto;
ipsec_spi_t spi;
const ip_address *src, *dst;

if (inbound) {
	spi = protos[i].info->our_spi;
	src = effective_that_host_addr;
	dst = &c->spd.this.host_addr;
} else {
	spi = protos[i].info->attrs.spi;
	src = &c->spd.this.host_addr;
	dst = effective_that_host_addr;
}

result &= del_spi(spi, proto, src, dst);
}

return result;
2395}

2397static event_callback_routine kernel_process_msg_cb;

2399static void kernel_process_msg_cb(evutil_socket_tint fd,
const short event UNUSED__attribute__ ((unused)), void *arg)
2401{
const struct kernel_ops *kernel_ops = arg;

dbg(" %s process netlink message", __func__){ if ((cur_debugging & (((lset_t)1 << (DBG_BASE_IX)
)))) { DBG_log(" %s process netlink message", __func__); } };
threadtime_t start = threadtime_start();
kernel_ops->process_msg(fd);
threadtime_stop(&start, SOS_NOBODY0, "kernel message");
pexpect_reset_globals()log_pexpect_reset_globals((where_t) { .func = __func__, .basename
 = "kernel.c" , .line = 2408});
2409}

2411static global_timer_cb kernel_process_queue_cb;

2413static void kernel_process_queue_cb(struct fd *unused_whackfd UNUSED__attribute__ ((unused)))
2414{
if (pexpect(kernel_ops->process_queue != NULL)({ _Bool assertion__ = kernel_ops->process_queue != ((void
*)0); if (!assertion__) { log_pexpect((where_t) { .func = __func__
, .basename = "kernel.c" , .line = 2415}, "%s", "kernel_ops->process_queue != NULL"
); } assertion__; })) {
kernel_ops->process_queue();
}
pexpect_reset_globals()log_pexpect_reset_globals((where_t) { .func = __func__, .basename
 = "kernel.c" , .line = 2418});
2419}

2421/* keep track of kernel version  */
2422static char kversion[256];

2424const struct kernel_ops *kernel_ops =
2425#ifdef XFRM_SUPPORT1
&xfrm_kernel_ops
2427#endif
2428#ifdef BSD_KAME
&bsdkame_kernel_ops
2430#endif
;

2433deltatime_t bare_shunt_interval = DELTATIME_INIT(SHUNT_SCAN_INTERVAL){ .dt = { .tv_sec = ((2 * 10)), } };

2435static void kernel_scan_shunts(struct fd *unused_whackfd UNUSED__attribute__ ((unused)))
2436{
kernel_ops->scan_shunts();
2438}

2440void init_kernel(void)
2441{
struct utsname un;

/* get kernel version */
uname(&un);
jam_str(kversion, sizeof(kversion), un.release);

switch (kernel_ops->type) {
2449#if defined(XFRM_SUPPORT1)
case USE_XFRM:
{
struct stat buf;
if (stat("/proc/sys/net/core/xfrm_acq_expires", &buf) != 0) {
	libreswan_log("No XFRM kernel support detected, missing /proc/sys/net/core/xfrm_acq_expires")loglog(RC_LOG, "No XFRM kernel support detected, missing /proc/sys/net/core/xfrm_acq_expires"
);
	exit_pluto(PLUTO_EXIT_KERNEL_FAIL);
}
libreswan_log("Using Linux XFRM/NETKEY IPsec kernel support code on %s",loglog(RC_LOG, "Using Linux XFRM/NETKEY IPsec kernel support code on %s"
, kversion)
	      kversion)loglog(RC_LOG, "Using Linux XFRM/NETKEY IPsec kernel support code on %s"
, kversion);
break;
}
2461#endif

2463#if defined(BSD_KAME)
case USE_BSDKAME:
libreswan_log("Using BSD/KAME IPsec interface code on %s",loglog(RC_LOG, "Using BSD/KAME IPsec interface code on %s", kversion
)
	kversion)loglog(RC_LOG, "Using BSD/KAME IPsec interface code on %s", kversion
);
break;
2468#endif

default:
libreswan_log("FATAL: kernel interface '%s' not available",loglog(RC_LOG, "FATAL: kernel interface '%s' not available", enum_name
(&kern_interface_names, kernel_ops->type))
	enum_name(&kern_interface_names,loglog(RC_LOG, "FATAL: kernel interface '%s' not available", enum_name
(&kern_interface_names, kernel_ops->type))
		kernel_ops->type))loglog(RC_LOG, "FATAL: kernel interface '%s' not available", enum_name
(&kern_interface_names, kernel_ops->type));
exit_pluto(PLUTO_EXIT_KERNEL_FAIL);
}

if (kernel_ops->init != NULL((void*)0))
kernel_ops->init();

/* Add the port bypass polcies */

if (kernel_ops->v6holes != NULL((void*)0)) {
if (!kernel_ops->v6holes()) {
	libreswan_log("Could not add the ICMP bypass policies")loglog(RC_LOG, "Could not add the ICMP bypass policies");
	exit_pluto(PLUTO_EXIT_KERNEL_FAIL);
}
}

/* register SA types that we can negotiate */
if (kernel_ops->pfkey_register != NULL((void*)0))
kernel_ops->pfkey_register();

enable_periodic_timer(EVENT_SHUNT_SCAN, kernel_scan_shunts,
	      bare_shunt_interval);

dbg("setup kernel fd callback"){ if ((cur_debugging & (((lset_t)1 << (DBG_BASE_IX)
)))) { DBG_log("setup kernel fd callback"); } };

if (kernel_ops->async_fdp != NULL((void*)0))
/* Note: kernel_ops is const but pluto_event_add cannot know that */
add_fd_read_event_handler(*kernel_ops->async_fdp, kernel_process_msg_cb,
		  (void *)kernel_ops, "KERNEL_XRM_FD");

if (kernel_ops->route_fdp != NULL((void*)0) && *kernel_ops->route_fdp  > NULL_FD(-1)) {
add_fd_read_event_handler(*kernel_ops->route_fdp, kernel_process_msg_cb,
			  (void *)kernel_ops, "KERNEL_ROUTE_FD");
}

if (kernel_ops->process_queue != NULL((void*)0)) {
/*
 * AA_2015 this is untested code. only for non xfrm ???
 * It seems in klips we should, besides kernel_process_msg,
 * call process_queue periodically.  Does the order
 * matter?
 */
enable_periodic_timer(EVENT_PROCESS_KERNEL_QUEUE,
		      kernel_process_queue_cb,
		      deltatime(KERNEL_PROCESS_Q_PERIOD1));
}
2519}

2521void show_kernel_interface(struct show *s)
2522{
if (kernel_ops != NULL((void*)0)) {
show_comment(s, "using kernel interface: %s",
	     kernel_ops->kern_name);
}
2527}

2529/*
* see if the attached connection refers to an older state.
* if it does, then initiate this state with the appropriate outgoing
* references, such that we won't break any userland applications
* that are using the conn with REFINFO.
*/
2535static void look_for_replacement_state(struct state *st)
2536{
struct connection *c = st->st_connection;
struct state *ost = state_with_serialno(c->newest_ipsec_sa);

if (DBGP(DBG_BASE)(cur_debugging & (((lset_t)1 << (DBG_BASE_IX))))) {
DBG_log("checking if this is a replacement state");
DBG_log("  st=%p ost=%p st->serialno=#%lu ost->serialno=#%lu",
	st, ost, st->st_serialno,
	ost == NULL((void*)0) ? 0 : ost->st_serialno);
}

if (ost != NULL((void*)0) && ost != st && ost->st_serialno != st->st_serialno) {
/*
 * then there is an old state associated, and it is
 * different then the new one.
 */
dbg("keeping ref_peer=%" PRIu32 " during rekey", ost->st_ref_peer){ if ((cur_debugging & (((lset_t)1 << (DBG_BASE_IX)
)))) { DBG_log("keeping ref_peer=%" "u" " during rekey", ost->
st_ref_peer); } };
st->st_ref_peer = ost->st_ref_peer;
}
2555}

2557/*
* Note: install_inbound_ipsec_sa is only used by the Responder.
* The Responder will subsequently use install_ipsec_sa for the outbound.
* The Initiator uses install_ipsec_sa to install both at once.
*/
2562bool_Bool install_inbound_ipsec_sa(struct state *st)
2563{
struct connection *const c = st->st_connection;

/*
* If our peer has a fixed-address client, check if we already
* have a route for that client that conflicts.  We will take this
* as proof that that route and the connections using it are
* obsolete and should be eliminated.  Interestingly, this is
* the only case in which we can tell that a connection is obsolete.
*/
passert(c->kind == CK_PERMANENT || c->kind == CK_INSTANCE){ _Bool assertion__ = c->kind == CK_PERMANENT || c->kind
 == CK_INSTANCE; if (!assertion__) { lsw_passert_fail((where_t
) { .func = __func__, .basename = "kernel.c" , .line = 2573},
 "%s", "c->kind == CK_PERMANENT || c->kind == CK_INSTANCE"
); } };
if (c->spd.that.has_client) {
for (;; ) {
	struct spd_route *esr;	/* value is ignored */
	struct connection *o = route_owner(c, &c->spd, &esr,
					NULL((void*)0), NULL((void*)0));

	if (o == NULL((void*)0) || c == o)
		break; /* nobody interesting has a route */

	/* note: we ignore the client addresses at this end */
	if (sameaddr(&o->spd.that.host_addr,
			&c->spd.that.host_addr) &&
		o->interface == c->interface)
		break;  /* existing route is compatible */

	if (kernel_ops->overlap_supported) {
		/*
		 * Both are transport mode, allow overlapping.
		 * [bart] not sure if this is actually
		 * intended, but am leaving it in to make it
		 * behave like before
		 */
		if (!LIN(POLICY_TUNNEL, c->policy | o->policy)(((((lset_t)1 << (POLICY_TUNNEL_IX))) & (c->policy
 | o->policy)) == (((lset_t)1 << (POLICY_TUNNEL_IX))
)))
			break;

		/* Both declared that overlapping is OK. */
		if (LIN(POLICY_OVERLAPIP, c->policy & o->policy)(((((lset_t)1 << (POLICY_OVERLAPIP_IX))) & (c->policy
 & o->policy)) == (((lset_t)1 << (POLICY_OVERLAPIP_IX
)))))
			break;
	}

	address_buf b;
	connection_buf cib;
	log_state(RC_LOG_SERIOUS, st,
		  "route to peer's client conflicts with "PRI_CONNECTION"\"%s\"%s"" %s; releasing old connection to free the route",
		  pri_connection(o, &cib)(o)->name, str_connection_instance(o, &cib),
		  str_address_sensitive(&o->spd.that.host_addr, &b));
	/*
	 * XXX: Assume this call shouldn't log to
	 * whack(?).  While ST has an attached whack,
	 * the global whack, which this code would
	 * have been using, detached long-ago.
	 */
	release_connection(o, false0, null_fd((struct fd *) ((void*)0)));
}
}

dbg("install_inbound_ipsec_sa() checking if we can route"){ if ((cur_debugging & (((lset_t)1 << (DBG_BASE_IX)
)))) { DBG_log("install_inbound_ipsec_sa() checking if we can route"
); } };
/* check that we will be able to route and eroute */
switch (could_route(c, st->st_logger)) {
case route_easy:
case route_nearconflict:
dbg("   routing is easy, or has resolvable near-conflict"){ if ((cur_debugging & (((lset_t)1 << (DBG_BASE_IX)
)))) { DBG_log("   routing is easy, or has resolvable near-conflict"
); } };
break;

case route_unnecessary:
/*
 * in this situation, we should look and see if there is
 * a state that our connection references, that we are
 * in fact replacing.
 */
break;

default:
return FALSE0;
}

look_for_replacement_state(st);

/*
* we now have to set up the outgoing SA first, so that
* we can refer to it in the incoming SA.
*/
if (st->st_ref_peer == IPSEC_SAREF_NULL((IPsecSAref_t)0u) && !st->st_outbound_done) {
dbg("installing outgoing SA now as ref_peer=%u", st->st_ref_peer){ if ((cur_debugging & (((lset_t)1 << (DBG_BASE_IX)
)))) { DBG_log("installing outgoing SA now as ref_peer=%u", st
->st_ref_peer); } };
if (!setup_half_ipsec_sa(st, FALSE0)) {
	DBG_log("failed to install outgoing SA: %u",
		st->st_ref_peer);
	return FALSE0;
}

st->st_outbound_done = TRUE1;
}
dbg("outgoing SA has ref_peer=%u", st->st_ref_peer){ if ((cur_debugging & (((lset_t)1 << (DBG_BASE_IX)
)))) { DBG_log("outgoing SA has ref_peer=%u", st->st_ref_peer
); } };

/* (attempt to) actually set up the SAs */

return setup_half_ipsec_sa(st, TRUE1);
2661}

2663/* Install a route and then a prospective shunt eroute or an SA group eroute.
* Assumption: could_route gave a go-ahead.
* Any SA Group must have already been created.
* On failure, steps will be unwound.
*/
2668bool_Bool route_and_eroute(struct connection *c,
struct spd_route *sr,
struct state *st)
2671{
dbg("route_and_eroute() for proto %d, and source port %d dest port %d",{ if ((cur_debugging & (((lset_t)1 << (DBG_BASE_IX)
)))) { DBG_log("route_and_eroute() for proto %d, and source port %d dest port %d"
, sr->this.protocol, sr->this.port, sr->that.port); }
 }
   sr->this.protocol, sr->this.port, sr->that.port){ if ((cur_debugging & (((lset_t)1 << (DBG_BASE_IX)
)))) { DBG_log("route_and_eroute() for proto %d, and source port %d dest port %d"
, sr->this.protocol, sr->this.port, sr->that.port); }
 };
setportof(htons(sr->this.port), &sr->this.client.addr){ *(&sr->this.client.addr) = set_endpoint_hport((&
sr->this.client.addr), ntohs(htons(sr->this.port))); };
setportof(htons(sr->that.port), &sr->that.client.addr){ *(&sr->that.client.addr) = set_endpoint_hport((&
sr->that.client.addr), ntohs(htons(sr->that.port))); };

struct spd_route *esr, *rosr;
struct connection *ero,
*ro = route_owner(c, sr, &rosr, &ero, &esr);	/* who, if anyone, owns our eroute? */

dbg("route_and_eroute with c: %s (next: %s) ero:%s esr:{%p} ro:%s rosr:{%p} and state: #%lu",{ if ((cur_debugging & (((lset_t)1 << (DBG_BASE_IX)
)))) { DBG_log("route_and_eroute with c: %s (next: %s) ero:%s esr:{%p} ro:%s rosr:{%p} and state: #%lu"
, c->name, (c->policy_next ? c->policy_next->name
 : "none"), ero == ((void*)0) ? "null" : ero->name, esr, ro
 == ((void*)0) ? "null" : ro->name, rosr, st == ((void*)0)
 ? 0 : st->st_serialno); } }
   c->name,{ if ((cur_debugging & (((lset_t)1 << (DBG_BASE_IX)
)))) { DBG_log("route_and_eroute with c: %s (next: %s) ero:%s esr:{%p} ro:%s rosr:{%p} and state: #%lu"
, c->name, (c->policy_next ? c->policy_next->name
 : "none"), ero == ((void*)0) ? "null" : ero->name, esr, ro
 == ((void*)0) ? "null" : ro->name, rosr, st == ((void*)0)
 ? 0 : st->st_serialno); } }
   (c->policy_next ? c->policy_next->name : "none"),{ if ((cur_debugging & (((lset_t)1 << (DBG_BASE_IX)
)))) { DBG_log("route_and_eroute with c: %s (next: %s) ero:%s esr:{%p} ro:%s rosr:{%p} and state: #%lu"
, c->name, (c->policy_next ? c->policy_next->name
 : "none"), ero == ((void*)0) ? "null" : ero->name, esr, ro
 == ((void*)0) ? "null" : ro->name, rosr, st == ((void*)0)
 ? 0 : st->st_serialno); } }
   ero == NULL ? "null" : ero->name,{ if ((cur_debugging & (((lset_t)1 << (DBG_BASE_IX)
)))) { DBG_log("route_and_eroute with c: %s (next: %s) ero:%s esr:{%p} ro:%s rosr:{%p} and state: #%lu"
, c->name, (c->policy_next ? c->policy_next->name
 : "none"), ero == ((void*)0) ? "null" : ero->name, esr, ro
 == ((void*)0) ? "null" : ro->name, rosr, st == ((void*)0)
 ? 0 : st->st_serialno); } }
   esr,{ if ((cur_debugging & (((lset_t)1 << (DBG_BASE_IX)
)))) { DBG_log("route_and_eroute with c: %s (next: %s) ero:%s esr:{%p} ro:%s rosr:{%p} and state: #%lu"
, c->name, (c->policy_next ? c->policy_next->name
 : "none"), ero == ((void*)0) ? "null" : ero->name, esr, ro
 == ((void*)0) ? "null" : ro->name, rosr, st == ((void*)0)
 ? 0 : st->st_serialno); } }
   ro == NULL ? "null" : ro->name,{ if ((cur_debugging & (((lset_t)1 << (DBG_BASE_IX)
)))) { DBG_log("route_and_eroute with c: %s (next: %s) ero:%s esr:{%p} ro:%s rosr:{%p} and state: #%lu"
, c->name, (c->policy_next ? c->policy_next->name
 : "none"), ero == ((void*)0) ? "null" : ero->name, esr, ro
 == ((void*)0) ? "null" : ro->name, rosr, st == ((void*)0)
 ? 0 : st->st_serialno); } }
   rosr,{ if ((cur_debugging & (((lset_t)1 << (DBG_BASE_IX)
)))) { DBG_log("route_and_eroute with c: %s (next: %s) ero:%s esr:{%p} ro:%s rosr:{%p} and state: #%lu"
, c->name, (c->policy_next ? c->policy_next->name
 : "none"), ero == ((void*)0) ? "null" : ero->name, esr, ro
 == ((void*)0) ? "null" : ro->name, rosr, st == ((void*)0)
 ? 0 : st->st_serialno); } }
   st == NULL ? 0 : st->st_serialno){ if ((cur_debugging & (((lset_t)1 << (DBG_BASE_IX)
)))) { DBG_log("route_and_eroute with c: %s (next: %s) ero:%s esr:{%p} ro:%s rosr:{%p} and state: #%lu"
, c->name, (c->policy_next ? c->policy_next->name
 : "none"), ero == ((void*)0) ? "null" : ero->name, esr, ro
 == ((void*)0) ? "null" : ro->name, rosr, st == ((void*)0)
 ? 0 : st->st_serialno); } };

/* look along the chain of policies for same one */

/* we should look for dest port as well? */
/* ports are now switched to the ones in this.client / that.client ??????? */
/* but port set is sr->this.port and sr.that.port ! */
struct bare_shunt **bspp = (ero == NULL((void*)0)) ?
bare_shunt_ptr(&sr->this.client, &sr->that.client, sr->this.protocol) :
NULL((void*)0);

/* install the eroute */

bool_Bool eroute_installed = FALSE0;

2703#ifdef IPSEC_CONNECTION_LIMIT
bool_Bool new_eroute = FALSE0;
2705#endif

passert(bspp == NULL || ero == NULL){ _Bool assertion__ = bspp == ((void*)0) || ero == ((void*)0)
; if (!assertion__) { lsw_passert_fail((where_t) { .func = __func__
, .basename = "kernel.c" , .line = 2707}, "%s", "bspp == NULL || ero == NULL"
); } };   /* only one non-NULL */

if (bspp != NULL((void*)0) || ero != NULL((void*)0)) {
dbg("we are replacing an eroute"){ if ((cur_debugging & (((lset_t)1 << (DBG_BASE_IX)
)))) { DBG_log("we are replacing an eroute"); } };
/* if no state provided, then install a shunt for later */
if (st == NULL((void*)0)) {
	eroute_installed = shunt_eroute(c, sr,
					RT_ROUTED_PROSPECTIVE,
					ERO_REPLACE,
					"replace");
} else {
	eroute_installed = sag_eroute(st, sr, ERO_REPLACE,
				"replace");
}

/* remember to free bspp if we make it out of here alive */
} else {
/* we're adding an eroute */
2725#ifdef IPSEC_CONNECTION_LIMIT
if (num_ipsec_eroute == IPSEC_CONNECTION_LIMIT) {
	loglog(RC_LOG_SERIOUS,
		"Maximum number of IPsec connections reached (%d)",
		IPSEC_CONNECTION_LIMIT);
	return FALSE0;
}
new_eroute = TRUE1;
2733#endif

/* if no state provided, then install a shunt for later */
if (st == NULL((void*)0)) {
	eroute_installed = shunt_eroute(c, sr,
					RT_ROUTED_PROSPECTIVE,
					ERO_ADD, "add");
} else {
	eroute_installed = sag_eroute(st, sr, ERO_ADD, "add");
}
}

/* notify the firewall of a new tunnel */

bool_Bool firewall_notified = FALSE0;

if (eroute_installed) {
/*
 * do we have to notify the firewall?
 * Yes, if we are installing
 * a tunnel eroute and the firewall wasn't notified
 * for a previous tunnel with the same clients.  Any Previous
 * tunnel would have to be for our connection, so the actual
 * test is simple.
 */
firewall_notified = st == NULL((void*)0) || /* not a tunnel eroute */
	sr->eroute_owner != SOS_NOBODY0 || /* already notified */
	do_command(c, sr, "up", st); /* go ahead and notify */
}

/* install the route */

bool_Bool route_installed = FALSE0;

dbg("route_and_eroute: firewall_notified: %s",{ if ((cur_debugging & (((lset_t)1 << (DBG_BASE_IX)
)))) { DBG_log("route_and_eroute: firewall_notified: %s", firewall_notified
 ? "true" : "false"); } }
   firewall_notified ? "true" : "false"){ if ((cur_debugging & (((lset_t)1 << (DBG_BASE_IX)
)))) { DBG_log("route_and_eroute: firewall_notified: %s", firewall_notified
 ? "true" : "false"); } };
if (!firewall_notified) {
/* we're in trouble -- don't do routing */
} else if (ro == NULL((void*)0)) {
/* a new route: no deletion required, but preparation is */
if (!do_command(c, sr, "prepare", st))
	dbg("prepare command returned an error"){ if ((cur_debugging & (((lset_t)1 << (DBG_BASE_IX)
)))) { DBG_log("prepare command returned an error"); } };
route_installed = do_command(c, sr, "route", st);
if (!route_installed)
	dbg("route command returned an error"){ if ((cur_debugging & (((lset_t)1 << (DBG_BASE_IX)
)))) { DBG_log("route command returned an error"); } };
} else if (routed(sr->routing)((sr->routing) > RT_UNROUTED_HOLD) ||
routes_agree(ro, c)((ro)->interface->ip_dev == (c)->interface->ip_dev
 && sameaddr(&(ro)->spd.this.host_nexthop, &
(c)->spd.this.host_nexthop))) {
route_installed = TRUE1; /* nothing to be done */
} else {
/*
 * Some other connection must own the route
 * and the route must disagree.  But since could_route
 * must have allowed our stealing it, we'll do so.
 *
 * A feature of LINUX allows us to install the new route
 * before deleting the old if the nexthops differ.
 * This reduces the "window of vulnerability" when packets
 * might flow in the clear.
 */
if (sameaddr(&sr->this.host_nexthop,
		&esr->this.host_nexthop)) {
	if (!do_command(ro, sr, "unroute", st)) {
		dbg("unroute command returned an error"){ if ((cur_debugging & (((lset_t)1 << (DBG_BASE_IX)
)))) { DBG_log("unroute command returned an error"); } };
	}
	route_installed = do_command(c, sr, "route", st);
	if (!route_installed)
		dbg("route command returned an error"){ if ((cur_debugging & (((lset_t)1 << (DBG_BASE_IX)
)))) { DBG_log("route command returned an error"); } };
} else {
	route_installed = do_command(c, sr, "route", st);
	if (!route_installed)
		dbg("route command returned an error"){ if ((cur_debugging & (((lset_t)1 << (DBG_BASE_IX)
)))) { DBG_log("route command returned an error"); } };

	if (!do_command(ro, sr, "unroute", st)) {
		dbg("unroute command returned an error"){ if ((cur_debugging & (((lset_t)1 << (DBG_BASE_IX)
)))) { DBG_log("unroute command returned an error"); } };
	}
}

/* record unrouting */
if (route_installed) {
	do {
		dbg("installed route: ro name=%s, rosr->routing=%d", ro->name,{ if ((cur_debugging & (((lset_t)1 << (DBG_BASE_IX)
)))) { DBG_log("installed route: ro name=%s, rosr->routing=%d"
, ro->name, rosr->routing); } }
			rosr->routing){ if ((cur_debugging & (((lset_t)1 << (DBG_BASE_IX)
)))) { DBG_log("installed route: ro name=%s, rosr->routing=%d"
, ro->name, rosr->routing); } };
		pexpect(!erouted(rosr->routing))({ _Bool assertion__ = !((rosr->routing) != RT_UNROUTED); if
 (!assertion__) { log_pexpect((where_t) { .func = __func__, .
basename = "kernel.c" , .line = 2815}, "%s", "!erouted(rosr->routing)"
); } assertion__; }); /* warn for now - requires fixing */
		rosr->routing = RT_UNROUTED;

		/* no need to keep old value */
		ro = route_owner(c, sr, &rosr, NULL((void*)0), NULL((void*)0));
	} while (ro != NULL((void*)0));
}
}

/* all done -- clean up */
if (route_installed) {
/* Success! */

if (bspp != NULL((void*)0)) {
	free_bare_shunt(bspp);
} else if (ero != NULL((void*)0) && ero != c) {
	/* check if ero is an ancestor of c. */
	struct connection *ero2;

	for (ero2 = c; ero2 != NULL((void*)0) && ero2 != c;
		ero2 = ero2->policy_next)
		;

	if (ero2 == NULL((void*)0)) {
		/*
		 * By elimination, we must be eclipsing ero.
		 * Checked above.
		 */
		if (ero->spd.routing != RT_ROUTED_ECLIPSED) {
			ero->spd.routing = RT_ROUTED_ECLIPSED;
			eclipse_count++;
		}
	}
}

if (st == NULL((void*)0)) {
	passert(sr->eroute_owner == SOS_NOBODY){ _Bool assertion__ = sr->eroute_owner == 0; if (!assertion__
) { lsw_passert_fail((where_t) { .func = __func__, .basename =
 "kernel.c" , .line = 2851}, "%s", "sr->eroute_owner == SOS_NOBODY"
); } };
	sr->routing = RT_ROUTED_PROSPECTIVE;
} else {
	sr->routing = RT_ROUTED_TUNNEL;
	connection_buf cib;
	dbg("route_and_eroute: instance "PRI_CONNECTION", setting eroute_owner {spd=%p,sr=%p} to #%lu (was #%lu) (newest_ipsec_sa=#%lu)",{ if ((cur_debugging & (((lset_t)1 << (DBG_BASE_IX)
)))) { DBG_log("route_and_eroute: instance ""\"%s\"%s"", setting eroute_owner {spd=%p,sr=%p} to #%lu (was #%lu) (newest_ipsec_sa=#%lu)"
, (st->st_connection)->name, str_connection_instance(st
->st_connection, &cib), &st->st_connection->
spd, sr, st->st_serialno, sr->eroute_owner, st->st_connection
->newest_ipsec_sa); } }
	    pri_connection(st->st_connection, &cib),{ if ((cur_debugging & (((lset_t)1 << (DBG_BASE_IX)
)))) { DBG_log("route_and_eroute: instance ""\"%s\"%s"", setting eroute_owner {spd=%p,sr=%p} to #%lu (was #%lu) (newest_ipsec_sa=#%lu)"
, (st->st_connection)->name, str_connection_instance(st
->st_connection, &cib), &st->st_connection->
spd, sr, st->st_serialno, sr->eroute_owner, st->st_connection
->newest_ipsec_sa); } }
	    &st->st_connection->spd, sr,{ if ((cur_debugging & (((lset_t)1 << (DBG_BASE_IX)
)))) { DBG_log("route_and_eroute: instance ""\"%s\"%s"", setting eroute_owner {spd=%p,sr=%p} to #%lu (was #%lu) (newest_ipsec_sa=#%lu)"
, (st->st_connection)->name, str_connection_instance(st
->st_connection, &cib), &st->st_connection->
spd, sr, st->st_serialno, sr->eroute_owner, st->st_connection
->newest_ipsec_sa); } }
	    st->st_serialno,{ if ((cur_debugging & (((lset_t)1 << (DBG_BASE_IX)
)))) { DBG_log("route_and_eroute: instance ""\"%s\"%s"", setting eroute_owner {spd=%p,sr=%p} to #%lu (was #%lu) (newest_ipsec_sa=#%lu)"
, (st->st_connection)->name, str_connection_instance(st
->st_connection, &cib), &st->st_connection->
spd, sr, st->st_serialno, sr->eroute_owner, st->st_connection
->newest_ipsec_sa); } }
	    sr->eroute_owner,{ if ((cur_debugging & (((lset_t)1 << (DBG_BASE_IX)
)))) { DBG_log("route_and_eroute: instance ""\"%s\"%s"", setting eroute_owner {spd=%p,sr=%p} to #%lu (was #%lu) (newest_ipsec_sa=#%lu)"
, (st->st_connection)->name, str_connection_instance(st
->st_connection, &cib), &st->st_connection->
spd, sr, st->st_serialno, sr->eroute_owner, st->st_connection
->newest_ipsec_sa); } }
	    st->st_connection->newest_ipsec_sa){ if ((cur_debugging & (((lset_t)1 << (DBG_BASE_IX)
)))) { DBG_log("route_and_eroute: instance ""\"%s\"%s"", setting eroute_owner {spd=%p,sr=%p} to #%lu (was #%lu) (newest_ipsec_sa=#%lu)"
, (st->st_connection)->name, str_connection_instance(st
->st_connection, &cib), &st->st_connection->
spd, sr, st->st_serialno, sr->eroute_owner, st->st_connection
->newest_ipsec_sa); } };
	sr->eroute_owner = st->st_serialno;
	/* clear host shunts that clash with freshly installed route */
	clear_narrow_holds(&sr->this.client, &sr->that.client,
			sr->this.protocol);
}

2868#ifdef IPSEC_CONNECTION_LIMIT
if (new_eroute) {
	num_ipsec_eroute++;
	loglog(RC_COMMENT,
		"%d IPsec connections are currently being managed",
		num_ipsec_eroute);
}
2875#endif

return TRUE1;
} else {
/* Failure!  Unwind our work. */
if (firewall_notified && sr->eroute_owner == SOS_NOBODY0) {
	if (!do_command(c, sr, "down", st))
		dbg("down command returned an error"){ if ((cur_debugging & (((lset_t)1 << (DBG_BASE_IX)
)))) { DBG_log("down command returned an error"); } };
}

if (eroute_installed) {
	/*
	 * Restore original eroute, if we can.
	 * Since there is nothing much to be done if
	 * the restoration fails, ignore success or failure.
	 */
	if (bspp != NULL((void*)0)) {
		/*
		 * Restore old bare_shunt.
		 * I don't think that this case is very likely.
		 * Normally a bare shunt would have been
		 * assigned to a connection before we've
		 * gotten this far.
		 */
		struct bare_shunt *bs = *bspp;

		if (!raw_eroute(&bs->said.dst,        /* should be useless */
				&bs->our_client,
				&bs->said.dst,        /* should be useless */
				&bs->peer_client,
				bs->said.spi,         /* unused? network order */
				bs->said.spi,         /* network order */
				&ip_protocol_internal,               /* proto */
				sr->this.protocol,    /* transport_proto */
				ET_INT,
				null_proto_info,
				deltatime(SHUNT_PATIENCE((2 * 10) * 15 / 2)),
				calculate_sa_prio(c, FALSE0),
				NULL((void*)0),
				0,
				ERO_REPLACE,
				"restore",
				NULL((void*)0))) /* bare shunt are not associated with any connection so no security label */
		{
			libreswan_log("raw_eroute() in route_and_eroute() failed to restore/replace SA")loglog(RC_LOG, "raw_eroute() in route_and_eroute() failed to restore/replace SA"
);
		}
	} else if (ero != NULL((void*)0)) {
		passert(esr != NULL){ _Bool assertion__ = esr != ((void*)0); if (!assertion__) { lsw_passert_fail
((where_t) { .func = __func__, .basename = "kernel.c" , .line
 = 2922}, "%s", "esr != NULL"); } };
		/* restore ero's former glory */
		if (esr->eroute_owner == SOS_NOBODY0) {
			/* note: normal or eclipse case */
			if (!shunt_eroute(ero, esr,
						esr->routing,
						ERO_REPLACE,
						"restore")) {
				libreswan_log("shunt_eroute() in route_and_eroute() failed restore/replace")loglog(RC_LOG, "shunt_eroute() in route_and_eroute() failed restore/replace"
);
			}
		} else {
			/*
			 * Try to find state that owned eroute.
			 * Don't do anything if it cannot be
			 * found.
			 * This case isn't likely since we
			 * don't run the updown script when
			 * replacing a SA group with its
			 * successor (for the same conn).
			 */
			struct state *ost =
				state_with_serialno(
					esr->eroute_owner);

			if (ost != NULL((void*)0)) {
				if (!sag_eroute(ost, esr,
					ERO_REPLACE,
					"restore"))
					libreswan_log("sag_eroute() in route_and_eroute() failed restore/replace")loglog(RC_LOG, "sag_eroute() in route_and_eroute() failed restore/replace"
);
			}
		}
	} else {
		/* there was no previous eroute: delete whatever we installed */
		if (st == NULL((void*)0)) {
			if (!shunt_eroute(c, sr,
						sr->routing,
						ERO_DELETE,
						"delete")) {
				libreswan_log("shunt_eroute() in route_and_eroute() failed in !st case for delete")loglog(RC_LOG, "shunt_eroute() in route_and_eroute() failed in !st case for delete"
);
			}
		} else {
			if (!sag_eroute(st, sr,
						ERO_DELETE,
						"delete")) {
				libreswan_log("shunt_eroute() in route_and_eroute() failed in st case for delete")loglog(RC_LOG, "shunt_eroute() in route_and_eroute() failed in st case for delete"
);
			}
		}
	}
}

return FALSE0;
}
2974}

2976bool_Bool install_ipsec_sa(struct state *st, bool_Bool inbound_also)
2977{
dbg("install_ipsec_sa() for #%lu: %s", st->st_serialno,{ if ((cur_debugging & (((lset_t)1 << (DBG_BASE_IX)
)))) { DBG_log("install_ipsec_sa() for #%lu: %s", st->st_serialno
, inbound_also ? "inbound and outbound" : "outbound only"); }
 }
   inbound_also ? "inbound and outbound" : "outbound only"){ if ((cur_debugging & (((lset_t)1 << (DBG_BASE_IX)
)))) { DBG_log("install_ipsec_sa() for #%lu: %s", st->st_serialno
, inbound_also ? "inbound and outbound" : "outbound only"); }
 };

enum routability rb = could_route(st->st_connection, st->st_logger);

switch (rb) {
case route_easy:
case route_unnecessary:
case route_nearconflict:
break;

default:
return false0;
}

/* (attempt to) actually set up the SA group */

/* setup outgoing SA if we haven't already */
if (!st->st_outbound_done) {
if (!setup_half_ipsec_sa(st, FALSE0)) {
	return FALSE0;
}

dbg("set up outgoing SA, ref=%u/%u", st->st_ref,{ if ((cur_debugging & (((lset_t)1 << (DBG_BASE_IX)
)))) { DBG_log("set up outgoing SA, ref=%u/%u", st->st_ref
, st->st_ref_peer); } }
    st->st_ref_peer){ if ((cur_debugging & (((lset_t)1 << (DBG_BASE_IX)
)))) { DBG_log("set up outgoing SA, ref=%u/%u", st->st_ref
, st->st_ref_peer); } };
st->st_outbound_done = TRUE1;
}

/* now setup inbound SA */
if (st->st_ref == IPSEC_SAREF_NULL((IPsecSAref_t)0u) && inbound_also) {
if (!setup_half_ipsec_sa(st, TRUE1))
	return FALSE0;

dbg("set up incoming SA, ref=%u/%u", st->st_ref,{ if ((cur_debugging & (((lset_t)1 << (DBG_BASE_IX)
)))) { DBG_log("set up incoming SA, ref=%u/%u", st->st_ref
, st->st_ref_peer); } }
    st->st_ref_peer){ if ((cur_debugging & (((lset_t)1 << (DBG_BASE_IX)
)))) { DBG_log("set up incoming SA, ref=%u/%u", st->st_ref
, st->st_ref_peer); } };

/*
 * We successfully installed an IPsec SA, meaning it is safe
 * to clear our revival back-off delay. This is based on the
 * assumption that an unwilling partner might complete an IKE
 * SA to us, but won't complete an IPsec SA to us.
 */
st->st_connection->temp_vars.revive_delay = 0;
}

if (rb == route_unnecessary)
return TRUE1;

struct spd_route *sr = &st->st_connection->spd;

if (st->st_connection->remotepeertype == CISCO && sr->spd_next != NULL((void*)0))
sr = sr->spd_next;

/* for (sr = &st->st_connection->spd; sr != NULL; sr = sr->next) */
for (; sr != NULL((void*)0); sr = sr->spd_next) {
dbg("sr for #%lu: %s", st->st_serialno,{ if ((cur_debugging & (((lset_t)1 << (DBG_BASE_IX)
)))) { DBG_log("sr for #%lu: %s", st->st_serialno, enum_name
(&routing_story, sr->routing)); } }
    enum_name(&routing_story, sr->routing)){ if ((cur_debugging & (((lset_t)1 << (DBG_BASE_IX)
)))) { DBG_log("sr for #%lu: %s", st->st_serialno, enum_name
(&routing_story, sr->routing)); } };

/*
 * if the eroute owner is not us, then make it us.
 * See test co-terminal-02, pluto-rekey-01,
 * pluto-unit-02/oppo-twice
 */
pexpect(sr->eroute_owner == SOS_NOBODY ||({ _Bool assertion__ = sr->eroute_owner == 0 || sr->routing
 >= RT_ROUTED_TUNNEL; if (!assertion__) { log_pexpect((where_t
) { .func = __func__, .basename = "kernel.c" , .line = 3042},
 "%s", "sr->eroute_owner == SOS_NOBODY || sr->routing >= RT_ROUTED_TUNNEL"
); } assertion__; })
	sr->routing >= RT_ROUTED_TUNNEL)({ _Bool assertion__ = sr->eroute_owner == 0 || sr->routing
 >= RT_ROUTED_TUNNEL; if (!assertion__) { log_pexpect((where_t
) { .func = __func__, .basename = "kernel.c" , .line = 3042},
 "%s", "sr->eroute_owner == SOS_NOBODY || sr->routing >= RT_ROUTED_TUNNEL"
); } assertion__; });

if (sr->eroute_owner != st->st_serialno &&
	sr->routing != RT_UNROUTED_KEYED) {
	if (!route_and_eroute(st->st_connection, sr, st)) {
		delete_ipsec_sa(st);
		/*
		 * XXX go and unroute any SRs that were
		 * successfully routed already.
		 */
		return false0;
	}
}
}

/* XXX why is this needed? Skip the bogus original conn? */
if (st->st_connection->remotepeertype == CISCO) {
struct spd_route *srcisco = st->st_connection->spd.spd_next;

if (srcisco != NULL((void*)0)) {
	st->st_connection->spd.eroute_owner = srcisco->eroute_owner;
	st->st_connection->spd.routing = srcisco->routing;
}
}

if (inbound_also)
linux_audit_conn(st, LAK_CHILD_START);
return true1;
3070}

3072bool_Bool migrate_ipsec_sa(struct state *st)
3073{
switch (kernel_ops->type) {
case USE_XFRM:
/* support ah? if(!st->st_esp.present && !st->st_ah.present)) */
if (!st->st_esp.present) {
	libreswan_log("mobike SA migration only support ESP SA")loglog(RC_LOG, "mobike SA migration only support ESP SA");
	return FALSE0;
}

if (!kernel_ops->migrate_sa(st))
	return FALSE0;

return TRUE1;

default:
dbg("Usupported kernel stack in migrate_ipsec_sa"){ if ((cur_debugging & (((lset_t)1 << (DBG_BASE_IX)
)))) { DBG_log("Usupported kernel stack in migrate_ipsec_sa")
; } };
return FALSE0;
}
3091}

3093/*
* Delete an IPSEC SA.
* we may not succeed, but we bull ahead anyway because
* we cannot do anything better by recognizing failure
* This used to have a parameter bool inbound_only, but
* the saref code changed to always install inbound before
* outbound so this it was always false, and thus removed
*
*/
3102void delete_ipsec_sa(struct state *st)
3103{
/* XXX in IKEv2 we get a spurious call with a parent st :( */
if (IS_CHILD_SA(st)((st)->st_clonedfrom != 0)) {
if (st->st_esp.present || st->st_ah.present) {
	/* ESP or AH means this was an established IPsec SA */
	linux_audit_conn(st, LAK_CHILD_DESTROY);
}
} else {
libreswan_log("delete_ipsec_sa() called with (wrong?) parent state %s",loglog(RC_LOG, "delete_ipsec_sa() called with (wrong?) parent state %s"
, st->st_state->name)
		st->st_state->name)loglog(RC_LOG, "delete_ipsec_sa() called with (wrong?) parent state %s"
, st->st_state->name);
}

switch (kernel_ops->type) {
case USE_XFRM:
{
	/*
	 * If the state is the eroute owner, we must adjust
	 * the routing for the connection.
	 */
	struct connection *c = st->st_connection;
	struct spd_route *sr;

	for (sr = &c->spd; sr; sr = sr->spd_next) {
		if (sr->eroute_owner == st->st_serialno &&
			sr->routing == RT_ROUTED_TUNNEL) {
			sr->eroute_owner = SOS_NOBODY0;

			/*
			 * Routing should become
			 * RT_ROUTED_FAILURE,
			 * but if POLICY_FAIL_NONE, then we
			 * just go right back to
			 * RT_ROUTED_PROSPECTIVE as if no
			 * failure happened.
			 */
			sr->routing =
				(c->policy &
					POLICY_FAIL_MASK(((lset_t)1 << (POLICY_FAIL1_IX)) - ((lset_t)1 <<
 (POLICY_FAIL0_IX)) + ((lset_t)1 << (POLICY_FAIL1_IX)))) ==
				POLICY_FAIL_NONE(0 * ((lset_t)1 << (POLICY_FAIL0_IX))) ?
				RT_ROUTED_PROSPECTIVE :
				RT_ROUTED_FAILURE;

			if (sr == &c->spd &&
				c->remotepeertype == CISCO)
				continue;

			(void) do_command(c, sr, "down", st);
			if ((c->policy & POLICY_OPPORTUNISTIC((lset_t)1 << (POLICY_OPPORTUNISTIC_IX))) &&
					c->kind == CK_INSTANCE) {
				/*
				 * in this case we get rid of
				 * the IPSEC SA
				 */
				unroute_connection(c);
			} else if ((c->policy & POLICY_DONT_REKEY((lset_t)1 << (POLICY_DONT_REKEY_IX))) &&
				c->kind == CK_INSTANCE) {
				/*
				 * in this special case,
				 * even if the connection
				 * is still alive (due to
				 * an ISAKMP SA),
				 * we get rid of routing.
				 * Even though there is still
				 * an eroute, the c->routing
				 * setting will convince
				 * unroute_connection to
				 * delete it.
				 * unroute_connection
				 * would be upset
				 * if c->routing ==
				 * RT_ROUTED_TUNNEL
				 */
				unroute_connection(c);
			} else {
				if (!shunt_eroute(c, sr,
							sr->routing,
							ERO_REPLACE,
							"replace with shunt")) {
					libreswan_log("shunt_eroute() failed replace with shunt in delete_ipsec_sa()")loglog(RC_LOG, "shunt_eroute() failed replace with shunt in delete_ipsec_sa()"
);
				}
			}
		}
	}
	(void) teardown_half_ipsec_sa(st, FALSE0);
}
(void) teardown_half_ipsec_sa(st, TRUE1);

break;
default:
dbg("unknown kernel stack in delete_ipsec_sa"){ if ((cur_debugging & (((lset_t)1 << (DBG_BASE_IX)
)))) { DBG_log("unknown kernel stack in delete_ipsec_sa"); } };
break;
} /* switch kernel_ops->type */
3195}

3197bool_Bool was_eroute_idle(struct state *st, deltatime_t since_when)
3198{
if (kernel_ops->eroute_idle != NULL((void*)0))
return kernel_ops->eroute_idle(st, since_when);

/* it is never idle if we can't check */
return FALSE0;
3204}

3206/*
* get information about a given sa - needs merging with was_eroute_idle
*
* Note: this mutates *st.
*/
3211bool_Bool get_sa_info(struct state *st, bool_Bool inbound, deltatime_t *ago /* OUTPUT */)
3212{
struct connection *const c = st->st_connection;

if (kernel_ops->get_sa == NULL((void*)0) || (!st->st_esp.present && !st->st_ah.present)) {
return FALSE0;
}

const struct ip_protocol *proto;
struct ipsec_proto_info *p2;

if (st->st_esp.present) {
proto = &ip_protocol_esp;
p2 = &st->st_esp;
} else if (st->st_ah.present) {
proto = &ip_protocol_ah;
p2 = &st->st_ah;
} else {
return FALSE0;
}

const ip_address *src, *dst;
ipsec_spi_t spi;
bool_Bool redirected = FALSE0;
ip_address tmp_ip;

/*
* if we were redirected (using the REDIRECT
* mechanism), change
* spd.that.host_addr temporarily, we reset
* it back later
*/
if (!sameaddr(&st->st_remote_endpoint, &c->spd.that.host_addr) &&
   address_is_specified(&c->temp_vars.redirect_ip)) {
redirected = TRUE1;
tmp_ip = c->spd.that.host_addr;
tmp_ip.version = c->spd.that.host_addr.version;
tmp_ip.hport = c->spd.that.host_addr.hport;
c->spd.that.host_addr = st->st_remote_endpoint;
}

if (inbound) {
src = &c->spd.that.host_addr;
dst = &c->spd.this.host_addr;
spi = p2->our_spi;
} else {
src = &c->spd.this.host_addr;
dst = &c->spd.that.host_addr;
spi = p2->attrs.spi;
}

char text_said[SATOT_BUFsizeof(said_buf)];

set_text_said(text_said, dst, spi, proto);

struct kernel_sa sa = {
.spi = spi,
.proto = proto,
.src.address = src,
.dst.address = dst,
.text_said = text_said,
};

dbg("get_sa_info %s", text_said){ if ((cur_debugging & (((lset_t)1 << (DBG_BASE_IX)
)))) { DBG_log("get_sa_info %s", text_said); } };

uint64_t bytes;
uint64_t add_time;

if (!kernel_ops->get_sa(&sa, &bytes, &add_time))
return FALSE0;

p2->add_time = add_time;

/* field has been set? */
passert(!is_monotime_epoch(p2->our_lastused)){ _Bool assertion__ = !is_monotime_epoch(p2->our_lastused)
; if (!assertion__) { lsw_passert_fail((where_t) { .func = __func__
, .basename = "kernel.c" , .line = 3285}, "%s", "!is_monotime_epoch(p2->our_lastused)"
); } };
passert(!is_monotime_epoch(p2->peer_lastused)){ _Bool assertion__ = !is_monotime_epoch(p2->peer_lastused
); if (!assertion__) { lsw_passert_fail((where_t) { .func = __func__
, .basename = "kernel.c" , .line = 3286}, "%s", "!is_monotime_epoch(p2->peer_lastused)"
); } };

if (inbound) {
if (bytes > p2->our_bytes) {
	p2->our_bytes = bytes;
	p2->our_lastused = mononow();
}
if (ago != NULL((void*)0))
	*ago = monotimediff(mononow(), p2->our_lastused);
} else {
if (bytes > p2->peer_bytes) {
	p2->peer_bytes = bytes;
	p2->peer_lastused = mononow();
}
if (ago != NULL((void*)0))
	*ago = monotimediff(mononow(), p2->peer_lastused);
}

if (redirected)
c->spd.that.host_addr = tmp_ip;

return TRUE1;
3308}

3310bool_Bool orphan_holdpass(const struct connection *c, struct spd_route *sr,
int transport_proto, ipsec_spi_t failure_shunt)
3312{
enum routing_t ro = sr->routing,        /* routing, old */
	rn = ro;                 /* routing, new */
ipsec_spi_t negotiation_shunt = (c->policy & POLICY_NEGO_PASS((lset_t)1 << (POLICY_NEGO_PASS_IX))) ? SPI_PASS256 : SPI_DROP257;

if (negotiation_shunt != failure_shunt ) {
dbg("failureshunt != negotiationshunt, needs replacing"){ if ((cur_debugging & (((lset_t)1 << (DBG_BASE_IX)
)))) { DBG_log("failureshunt != negotiationshunt, needs replacing"
); } };
} else {
dbg("failureshunt == negotiationshunt, no replace needed"){ if ((cur_debugging & (((lset_t)1 << (DBG_BASE_IX)
)))) { DBG_log("failureshunt == negotiationshunt, no replace needed"
); } };
}

dbg("orphan_holdpass() called for %s with transport_proto '%d' and sport %d and dport %d",{ if ((cur_debugging & (((lset_t)1 << (DBG_BASE_IX)
)))) { DBG_log("orphan_holdpass() called for %s with transport_proto '%d' and sport %d and dport %d"
, c->name, transport_proto, sr->this.port, sr->that.
port); } }
   c->name, transport_proto, sr->this.port, sr->that.port){ if ((cur_debugging & (((lset_t)1 << (DBG_BASE_IX)
)))) { DBG_log("orphan_holdpass() called for %s with transport_proto '%d' and sport %d and dport %d"
, c->name, transport_proto, sr->this.port, sr->that.
port); } };

passert(LHAS(LELEM(CK_PERMANENT) | LELEM(CK_INSTANCE) |{ _Bool assertion__ = (((((lset_t)1 << (CK_PERMANENT)) |
 ((lset_t)1 << (CK_INSTANCE)) | ((lset_t)1 << (CK_GOING_AWAY
))) & ((lset_t)1 << (c->kind))) != ((lset_t)0));
 if (!assertion__) { lsw_passert_fail((where_t) { .func = __func__
, .basename = "kernel.c" , .line = 3327}, "%s", "LHAS(LELEM(CK_PERMANENT) | LELEM(CK_INSTANCE) | LELEM(CK_GOING_AWAY), c->kind)"
); } }
		LELEM(CK_GOING_AWAY), c->kind)){ _Bool assertion__ = (((((lset_t)1 << (CK_PERMANENT)) |
 ((lset_t)1 << (CK_INSTANCE)) | ((lset_t)1 << (CK_GOING_AWAY
))) & ((lset_t)1 << (c->kind))) != ((lset_t)0));
 if (!assertion__) { lsw_passert_fail((where_t) { .func = __func__
, .basename = "kernel.c" , .line = 3327}, "%s", "LHAS(LELEM(CK_PERMANENT) | LELEM(CK_INSTANCE) | LELEM(CK_GOING_AWAY), c->kind)"
); } };

switch (ro) {
case RT_UNROUTED_HOLD:
rn = RT_UNROUTED;
dbg("orphan_holdpass unrouted: hold -> pass"){ if ((cur_debugging & (((lset_t)1 << (DBG_BASE_IX)
)))) { DBG_log("orphan_holdpass unrouted: hold -> pass"); }
 };
break;
case RT_UNROUTED:
rn = RT_UNROUTED_HOLD;
dbg("orphan_holdpass unrouted: pass -> hold"){ if ((cur_debugging & (((lset_t)1 << (DBG_BASE_IX)
)))) { DBG_log("orphan_holdpass unrouted: pass -> hold"); }
 };
break;
case RT_ROUTED_HOLD:
rn = RT_ROUTED_PROSPECTIVE;
dbg("orphan_holdpass routed: hold -> trap (?)"){ if ((cur_debugging & (((lset_t)1 << (DBG_BASE_IX)
)))) { DBG_log("orphan_holdpass routed: hold -> trap (?)")
; } };
break;
default:
dbg("no routing change needed for ro=%s - negotiation shunt matched failure shunt?",{ if ((cur_debugging & (((lset_t)1 << (DBG_BASE_IX)
)))) { DBG_log("no routing change needed for ro=%s - negotiation shunt matched failure shunt?"
, enum_name(&routing_story, ro)); } }
    enum_name(&routing_story, ro)){ if ((cur_debugging & (((lset_t)1 << (DBG_BASE_IX)
)))) { DBG_log("no routing change needed for ro=%s - negotiation shunt matched failure shunt?"
, enum_name(&routing_story, ro)); } };
break;
}

dbg("orphaning holdpass for connection '%s', routing was %s, needs to be %s",{ if ((cur_debugging & (((lset_t)1 << (DBG_BASE_IX)
)))) { DBG_log("orphaning holdpass for connection '%s', routing was %s, needs to be %s"
, c->name, enum_name(&routing_story, ro), enum_name(&
routing_story, rn)); } }
   c->name,{ if ((cur_debugging & (((lset_t)1 << (DBG_BASE_IX)
)))) { DBG_log("orphaning holdpass for connection '%s', routing was %s, needs to be %s"
, c->name, enum_name(&routing_story, ro), enum_name(&
routing_story, rn)); } }
   enum_name(&routing_story, ro),{ if ((cur_debugging & (((lset_t)1 << (DBG_BASE_IX)
)))) { DBG_log("orphaning holdpass for connection '%s', routing was %s, needs to be %s"
, c->name, enum_name(&routing_story, ro), enum_name(&
routing_story, rn)); } }
   enum_name(&routing_story, rn)){ if ((cur_debugging & (((lset_t)1 << (DBG_BASE_IX)
)))) { DBG_log("orphaning holdpass for connection '%s', routing was %s, needs to be %s"
, c->name, enum_name(&routing_story, ro), enum_name(&
routing_story, rn)); } };

{
/* are we replacing a bare shunt ? */
setportof(htons(sr->this.port), &sr->this.client.addr){ *(&sr->this.client.addr) = set_endpoint_hport((&
sr->this.client.addr), ntohs(htons(sr->this.port))); };
setportof(htons(sr->that.port), &sr->that.client.addr){ *(&sr->that.client.addr) = set_endpoint_hport((&
sr->that.client.addr), ntohs(htons(sr->that.port))); };
struct bare_shunt **old = bare_shunt_ptr(&sr->this.client, &sr->that.client, sr->this.protocol);

if (old != NULL((void*)0)) {
	free_bare_shunt(old);
}
}

/* create the bare shunt and update kernel policy if needed */
{
struct bare_shunt *bs = alloc_thing(struct bare_shunt, "orphan shunt")((struct bare_shunt*) alloc_bytes(sizeof(struct bare_shunt), (
"orphan shunt")));

bs->why = "oe-failing";
bs->our_client = sr->this.client;
bs->peer_client = sr->that.client;
bs->transport_proto = sr->this.protocol;
bs->policy_prio = BOTTOM_PRIO((policy_prio_t)0);

bs->said = said3(&subnet_type(&sr->this.client)->any_address,
		 htonl(negotiation_shunt), &ip_protocol_internal);

bs->count = 0;
bs->last_activity = mononow();
if (strstr(c->name, "/32") != NULL((void*)0) || strstr(c->name, "/128") != NULL((void*)0)) {
	bs->from_cn = clone_str(c->name, "conn name in bare shunt")((c->name) == ((void*)0) ? ((void*)0) : clone_bytes((c->
name), strlen((c->name)) + 1, ("conn name in bare shunt"))
);
}

bs->next = bare_shunts;
bare_shunts = bs;
dbg_bare_shunt("add", bs);

/* update kernel policy if needed */
/* This really causes the name to remain "oe-failing", we should be able to update only only the name of the shunt */
if (negotiation_shunt != failure_shunt ) {
	dbg("replacing negotiation_shunt with failure_shunt"){ if ((cur_debugging & (((lset_t)1 << (DBG_BASE_IX)
)))) { DBG_log("replacing negotiation_shunt with failure_shunt"
); } };
	if (!replace_bare_shunt(&sr->this.host_addr, &sr->that.host_addr, bs->policy_prio,
				negotiation_shunt, failure_shunt, bs->transport_proto,
				"oe-failed")) {
		libreswan_log("assign_holdpass() failed to update shunt policy")loglog(RC_LOG, "assign_holdpass() failed to update shunt policy"
);
	}
} else {
	dbg("No need to replace negotiation_shunt with failure_shunt - they are the same"){ if ((cur_debugging & (((lset_t)1 << (DBG_BASE_IX)
)))) { DBG_log("No need to replace negotiation_shunt with failure_shunt - they are the same"
); } };
}
}

/* change routing so we don't get cleared out when state/connection dies */
sr->routing = rn;
dbg("orphan_holdpas() done - returning success"){ if ((cur_debugging & (((lset_t)1 << (DBG_BASE_IX)
)))) { DBG_log("orphan_holdpas() done - returning success"); }
 };
return TRUE1;
3405}

3407/* XXX move to proper kernel_ops in kernel_netlink */
3408void expire_bare_shunts(void)
3409{
dbg("checking for aged bare shunts from shunt table to expire"){ if ((cur_debugging & (((lset_t)1 << (DBG_BASE_IX)
)))) { DBG_log("checking for aged bare shunts from shunt table to expire"
); } };
for (struct bare_shunt **bspp = &bare_shunts; *bspp != NULL((void*)0); ) {
struct bare_shunt *bsp = *bspp;
time_t age = deltasecs(monotimediff(mononow(), bsp->last_activity));
struct connection *c = NULL((void*)0);

if (age > deltasecs(pluto_shunt_lifetime)) {
	dbg_bare_shunt("expiring old", bsp);
	if (bsp->from_cn != NULL((void*)0)) {
		c = conn_by_name(bsp->from_cn, FALSE0);
		if (c != NULL((void*)0)) {
			if (!shunt_eroute(c, &c->spd, RT_ROUTED_PROSPECTIVE, ERO_ADD, "add")) {
				libreswan_log("trap shunt install failed ")loglog(RC_LOG, "trap shunt install failed ");
			}
		}
	}
	if (!delete_bare_shunt(&bsp->our_client.addr, &bsp->peer_client.addr,
			       bsp->transport_proto,
			       ntohl(bsp->said.spi),
			       (bsp->from_cn == NULL((void*)0) ? "expire_bare_shunt" :
				"IGNORE_ON_XFRM: expire_bare_shunt"))) {
		    log_global(RC_LOG_SERIOUS, null_fd, "failed to delete bare shunt"){ struct logger log_ = (struct logger) { .where = (where_t) {
 .func = __func__, .basename = "kernel.c" , .line = 3431}, .global_whackfd
 = ((struct fd *) ((void*)0)), .object = ((void*)0), .object_vec
 = &logger_global_vec, }; log_message(RC_LOG_SERIOUS, &
log_, "failed to delete bare shunt"); };
	}
	passert(bsp != *bspp){ _Bool assertion__ = bsp != *bspp; if (!assertion__) { lsw_passert_fail
((where_t) { .func = __func__, .basename = "kernel.c" , .line
 = 3433}, "%s", "bsp != *bspp"); } };
} else {
	dbg_bare_shunt("keeping recent", bsp);
	bspp = &bsp->next;
}
}
3439}