335 lines
7.1 KiB
C
335 lines
7.1 KiB
C
/*
|
|
* Copyright (C) 2008 Martin Willi
|
|
* Hochschule fuer Technik Rapperswil
|
|
*
|
|
* 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 <http://www.fsf.org/copyleft/gpl.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.
|
|
*/
|
|
|
|
#define _GNU_SOURCE
|
|
#include <stdio.h>
|
|
|
|
#include "updown_listener.h"
|
|
|
|
#include <hydra.h>
|
|
#include <daemon.h>
|
|
#include <config/child_cfg.h>
|
|
|
|
typedef struct private_updown_listener_t private_updown_listener_t;
|
|
|
|
/**
|
|
* Private data of an updown_listener_t object.
|
|
*/
|
|
struct private_updown_listener_t {
|
|
|
|
/**
|
|
* Public updown_listener_t interface.
|
|
*/
|
|
updown_listener_t public;
|
|
|
|
/**
|
|
* List of cached interface names
|
|
*/
|
|
linked_list_t *iface_cache;
|
|
};
|
|
|
|
typedef struct cache_entry_t cache_entry_t;
|
|
|
|
/**
|
|
* Cache line in the interface name cache.
|
|
*/
|
|
struct cache_entry_t {
|
|
/** requid of the CHILD_SA */
|
|
u_int32_t reqid;
|
|
/** cached interface name */
|
|
char *iface;
|
|
};
|
|
|
|
/**
|
|
* Insert an interface name to the cache
|
|
*/
|
|
static void cache_iface(private_updown_listener_t *this, u_int32_t reqid,
|
|
char *iface)
|
|
{
|
|
cache_entry_t *entry = malloc_thing(cache_entry_t);
|
|
|
|
entry->reqid = reqid;
|
|
entry->iface = strdup(iface);
|
|
|
|
this->iface_cache->insert_first(this->iface_cache, entry);
|
|
}
|
|
|
|
/**
|
|
* Remove a cached interface name and return it.
|
|
*/
|
|
static char* uncache_iface(private_updown_listener_t *this, u_int32_t reqid)
|
|
{
|
|
enumerator_t *enumerator;
|
|
cache_entry_t *entry;
|
|
char *iface = NULL;
|
|
|
|
enumerator = this->iface_cache->create_enumerator(this->iface_cache);
|
|
while (enumerator->enumerate(enumerator, &entry))
|
|
{
|
|
if (entry->reqid == reqid)
|
|
{
|
|
this->iface_cache->remove_at(this->iface_cache, enumerator);
|
|
iface = entry->iface;
|
|
free(entry);
|
|
break;
|
|
}
|
|
}
|
|
enumerator->destroy(enumerator);
|
|
return iface;
|
|
}
|
|
|
|
METHOD(listener_t, child_updown, bool,
|
|
private_updown_listener_t *this, ike_sa_t *ike_sa, child_sa_t *child_sa,
|
|
bool up)
|
|
{
|
|
traffic_selector_t *my_ts, *other_ts;
|
|
enumerator_t *enumerator;
|
|
child_cfg_t *config;
|
|
host_t *vip, *me, *other;
|
|
char *script;
|
|
|
|
config = child_sa->get_config(child_sa);
|
|
vip = ike_sa->get_virtual_ip(ike_sa, TRUE);
|
|
script = config->get_updown(config);
|
|
me = ike_sa->get_my_host(ike_sa);
|
|
other = ike_sa->get_other_host(ike_sa);
|
|
|
|
if (script == NULL)
|
|
{
|
|
return TRUE;
|
|
}
|
|
|
|
enumerator = child_sa->create_policy_enumerator(child_sa);
|
|
while (enumerator->enumerate(enumerator, &my_ts, &other_ts))
|
|
{
|
|
char command[1024];
|
|
host_t *my_client, *other_client;
|
|
u_int8_t my_client_mask, other_client_mask;
|
|
char *virtual_ip, *iface, *mark_in, *mark_out, *udp_enc;
|
|
mark_t mark;
|
|
bool is_host, is_ipv6;
|
|
FILE *shell;
|
|
|
|
my_ts->to_subnet(my_ts, &my_client, &my_client_mask);
|
|
other_ts->to_subnet(other_ts, &other_client, &other_client_mask);
|
|
|
|
if (vip)
|
|
{
|
|
if (asprintf(&virtual_ip, "PLUTO_MY_SOURCEIP='%H' ", vip) < 0)
|
|
{
|
|
virtual_ip = NULL;
|
|
}
|
|
}
|
|
else
|
|
{
|
|
if (asprintf(&virtual_ip, "") < 0)
|
|
{
|
|
virtual_ip = NULL;
|
|
}
|
|
}
|
|
|
|
/* check for the presence of an inbound mark */
|
|
mark = config->get_mark(config, TRUE);
|
|
if (mark.value)
|
|
{
|
|
if (asprintf(&mark_in, "PLUTO_MARK_IN='%u/0x%08x' ",
|
|
mark.value, mark.mask ) < 0)
|
|
{
|
|
mark_in = NULL;
|
|
}
|
|
}
|
|
else
|
|
{
|
|
if (asprintf(&mark_in, "") < 0)
|
|
{
|
|
mark_in = NULL;
|
|
}
|
|
}
|
|
|
|
/* check for the presence of an outbound mark */
|
|
mark = config->get_mark(config, FALSE);
|
|
if (mark.value)
|
|
{
|
|
if (asprintf(&mark_out, "PLUTO_MARK_OUT='%u/0x%08x' ",
|
|
mark.value, mark.mask ) < 0)
|
|
{
|
|
mark_out = NULL;
|
|
}
|
|
}
|
|
else
|
|
{
|
|
if (asprintf(&mark_out, "") < 0)
|
|
{
|
|
mark_out = NULL;
|
|
}
|
|
}
|
|
|
|
/* check for a NAT condition causing ESP_IN_UDP encapsulation */
|
|
if (ike_sa->has_condition(ike_sa, COND_NAT_ANY))
|
|
{
|
|
if (asprintf(&udp_enc, "PLUTO_UDP_ENC='%u' ",
|
|
other->get_port(other)) < 0)
|
|
{
|
|
udp_enc = NULL;
|
|
}
|
|
|
|
}
|
|
else
|
|
{
|
|
if (asprintf(&udp_enc, "") < 0)
|
|
{
|
|
udp_enc = NULL;
|
|
}
|
|
|
|
}
|
|
|
|
if (up)
|
|
{
|
|
iface = hydra->kernel_interface->get_interface(
|
|
hydra->kernel_interface, me);
|
|
if (iface)
|
|
{
|
|
cache_iface(this, child_sa->get_reqid(child_sa), iface);
|
|
}
|
|
}
|
|
else
|
|
{
|
|
iface = uncache_iface(this, child_sa->get_reqid(child_sa));
|
|
}
|
|
|
|
/* determine IPv4/IPv6 and client/host situation */
|
|
is_host = my_ts->is_host(my_ts, me);
|
|
is_ipv6 = is_host ? (me->get_family(me) == AF_INET6) :
|
|
(my_ts->get_type(my_ts) == TS_IPV6_ADDR_RANGE);
|
|
|
|
/* build the command with all env variables.
|
|
* TODO: PLUTO_PEER_CA and PLUTO_NEXT_HOP are currently missing
|
|
*/
|
|
snprintf(command, sizeof(command),
|
|
"2>&1 "
|
|
"PLUTO_VERSION='1.1' "
|
|
"PLUTO_VERB='%s%s%s' "
|
|
"PLUTO_CONNECTION='%s' "
|
|
"PLUTO_INTERFACE='%s' "
|
|
"PLUTO_REQID='%u' "
|
|
"PLUTO_ME='%H' "
|
|
"PLUTO_MY_ID='%Y' "
|
|
"PLUTO_MY_CLIENT='%H/%u' "
|
|
"PLUTO_MY_PORT='%u' "
|
|
"PLUTO_MY_PROTOCOL='%u' "
|
|
"PLUTO_PEER='%H' "
|
|
"PLUTO_PEER_ID='%Y' "
|
|
"PLUTO_PEER_CLIENT='%H/%u' "
|
|
"PLUTO_PEER_PORT='%u' "
|
|
"PLUTO_PEER_PROTOCOL='%u' "
|
|
"%s"
|
|
"%s"
|
|
"%s"
|
|
"%s"
|
|
"%s"
|
|
"%s",
|
|
up ? "up" : "down",
|
|
is_host ? "-host" : "-client",
|
|
is_ipv6 ? "-v6" : "",
|
|
config->get_name(config),
|
|
iface ? iface : "unknown",
|
|
child_sa->get_reqid(child_sa),
|
|
me, ike_sa->get_my_id(ike_sa),
|
|
my_client, my_client_mask,
|
|
my_ts->get_from_port(my_ts),
|
|
my_ts->get_protocol(my_ts),
|
|
other, ike_sa->get_other_id(ike_sa),
|
|
other_client, other_client_mask,
|
|
other_ts->get_from_port(other_ts),
|
|
other_ts->get_protocol(other_ts),
|
|
virtual_ip,
|
|
mark_in,
|
|
mark_out,
|
|
udp_enc,
|
|
config->get_hostaccess(config) ? "PLUTO_HOST_ACCESS='1' " : "",
|
|
script);
|
|
my_client->destroy(my_client);
|
|
other_client->destroy(other_client);
|
|
free(virtual_ip);
|
|
free(mark_in);
|
|
free(mark_out);
|
|
free(udp_enc);
|
|
free(iface);
|
|
|
|
DBG3(DBG_CHD, "running updown script: %s", command);
|
|
shell = popen(command, "r");
|
|
|
|
if (shell == NULL)
|
|
{
|
|
DBG1(DBG_CHD, "could not execute updown script '%s'", script);
|
|
return TRUE;
|
|
}
|
|
|
|
while (TRUE)
|
|
{
|
|
char resp[128];
|
|
|
|
if (fgets(resp, sizeof(resp), shell) == NULL)
|
|
{
|
|
if (ferror(shell))
|
|
{
|
|
DBG1(DBG_CHD, "error reading output from updown script");
|
|
}
|
|
break;
|
|
}
|
|
else
|
|
{
|
|
char *e = resp + strlen(resp);
|
|
if (e > resp && e[-1] == '\n')
|
|
{ /* trim trailing '\n' */
|
|
e[-1] = '\0';
|
|
}
|
|
DBG1(DBG_CHD, "updown: %s", resp);
|
|
}
|
|
}
|
|
pclose(shell);
|
|
}
|
|
enumerator->destroy(enumerator);
|
|
return TRUE;
|
|
}
|
|
|
|
METHOD(updown_listener_t, destroy, void,
|
|
private_updown_listener_t *this)
|
|
{
|
|
this->iface_cache->destroy(this->iface_cache);
|
|
free(this);
|
|
}
|
|
|
|
/**
|
|
* See header
|
|
*/
|
|
updown_listener_t *updown_listener_create()
|
|
{
|
|
private_updown_listener_t *this;
|
|
|
|
INIT(this,
|
|
.public = {
|
|
.listener = {
|
|
.child_updown = _child_updown,
|
|
},
|
|
.destroy = _destroy,
|
|
},
|
|
.iface_cache = linked_list_create(),
|
|
);
|
|
|
|
return &this->public;
|
|
}
|
|
|