child-delete: Delay the removal of the inbound SA of rekeyed CHILD_SAs
After deleting a rekeyed CHILD_SA we uninstall the outbound SA but don't destroy the CHILD_SA (and the inbound SA) immediately. We delay it a few seconds or until the SA expires to allow delayed packets to get processed. The CHILD_SA remains in state CHILD_DELETING until it finally gets destroyed.
This commit is contained in:
1 parent
ba0796fe75
commit
44107cb7b7
4 files changed
+422
-128
No files matched your search
@@ -75,6 +75,16 @@ charon.delete_rekeyed = no
|
|||||||
However, this might cause problems with implementations that continue to
|
However, this might cause problems with implementations that continue to
|
||||||
use rekeyed SAs until they expire.
|
use rekeyed SAs until they expire.
|
||||||
|
|
||||||
|
charon.delete_rekeyed_delay = 5
|
||||||
|
Delay in seconds until inbound IPsec SAs are deleted after rekeyings (IKEv2
|
||||||
|
only).
|
||||||
|
|
||||||
|
Delay in seconds until inbound IPsec SAs are deleted after rekeyings (IKEv2
|
||||||
|
only). To process delayed packets the inbound part of a CHILD_SA is kept
|
||||||
|
installed up to the configured number of seconds after it got replaced
|
||||||
|
during a rekeying. If set to 0 the CHILD_SA will be kept installed until it
|
||||||
|
expires (if no lifetime is set it will be destroyed immediately).
|
||||||
|
|
||||||
charon.dh_exponent_ansi_x9_42 = yes
|
charon.dh_exponent_ansi_x9_42 = yes
|
||||||
Use ANSI X9.42 DH exponent size or optimum size matched to cryptographic
|
Use ANSI X9.42 DH exponent size or optimum size matched to cryptographic
|
||||||
strength.
|
strength.
|
||||||
|
|||||||
@@ -18,9 +18,14 @@
|
|||||||
|
|
||||||
#include <daemon.h>
|
#include <daemon.h>
|
||||||
#include <encoding/payloads/delete_payload.h>
|
#include <encoding/payloads/delete_payload.h>
|
||||||
|
#include <processing/jobs/delete_child_sa_job.h>
|
||||||
#include <sa/ikev2/tasks/child_create.h>
|
#include <sa/ikev2/tasks/child_create.h>
|
||||||
#include <sa/ikev2/tasks/child_rekey.h>
|
#include <sa/ikev2/tasks/child_rekey.h>
|
||||||
|
|
||||||
|
#ifndef DELETE_REKEYED_DELAY
|
||||||
|
#define DELETE_REKEYED_DELAY 5
|
||||||
|
#endif
|
||||||
|
|
||||||
typedef struct private_child_delete_t private_child_delete_t;
|
typedef struct private_child_delete_t private_child_delete_t;
|
||||||
|
|
||||||
/**
|
/**
|
||||||
@@ -308,6 +313,12 @@ static status_t destroy_and_reestablish(private_child_delete_t *this)
|
|||||||
uint32_t spi, reqid, rekey_spi;
|
uint32_t spi, reqid, rekey_spi;
|
||||||
action_t action;
|
action_t action;
|
||||||
status_t status = SUCCESS;
|
status_t status = SUCCESS;
|
||||||
|
time_t now, expire;
|
||||||
|
u_int delay;
|
||||||
|
|
||||||
|
now = time_monotonic(NULL);
|
||||||
|
delay = lib->settings->get_int(lib->settings, "%s.delete_rekeyed_delay",
|
||||||
|
DELETE_REKEYED_DELAY, lib->ns);
|
||||||
|
|
||||||
enumerator = this->child_sas->create_enumerator(this->child_sas);
|
enumerator = this->child_sas->create_enumerator(this->child_sas);
|
||||||
while (enumerator->enumerate(enumerator, (void**)&entry))
|
while (enumerator->enumerate(enumerator, (void**)&entry))
|
||||||
@@ -326,13 +337,32 @@ static status_t destroy_and_reestablish(private_child_delete_t *this)
|
|||||||
{
|
{
|
||||||
install_outbound(this, protocol, rekey_spi);
|
install_outbound(this, protocol, rekey_spi);
|
||||||
}
|
}
|
||||||
|
/* for rekeyed CHILD_SAs we uninstall the outbound SA but don't
|
||||||
|
* immediately destroy it, by default, so we can process delayed
|
||||||
|
* packets */
|
||||||
|
child_sa->remove_outbound(child_sa);
|
||||||
|
expire = child_sa->get_lifetime(child_sa, TRUE);
|
||||||
|
if (delay && (!expire || ((now + delay) < expire)))
|
||||||
|
{
|
||||||
|
lib->scheduler->schedule_job(lib->scheduler,
|
||||||
|
(job_t*)delete_child_sa_job_create_id(
|
||||||
|
child_sa->get_unique_id(child_sa)), delay);
|
||||||
|
continue;
|
||||||
|
}
|
||||||
|
else if (expire)
|
||||||
|
{ /* let it expire naturally */
|
||||||
|
continue;
|
||||||
|
}
|
||||||
|
/* no delay and no lifetime, destroy it immediately */
|
||||||
}
|
}
|
||||||
spi = child_sa->get_spi(child_sa, TRUE);
|
spi = child_sa->get_spi(child_sa, TRUE);
|
||||||
reqid = child_sa->get_reqid(child_sa);
|
reqid = child_sa->get_reqid(child_sa);
|
||||||
child_cfg = child_sa->get_config(child_sa);
|
child_cfg = child_sa->get_config(child_sa);
|
||||||
child_cfg->get_ref(child_cfg);
|
child_cfg->get_ref(child_cfg);
|
||||||
action = child_sa->get_close_action(child_sa);
|
action = child_sa->get_close_action(child_sa);
|
||||||
|
|
||||||
this->ike_sa->destroy_child_sa(this->ike_sa, protocol, spi);
|
this->ike_sa->destroy_child_sa(this->ike_sa, protocol, spi);
|
||||||
|
|
||||||
if (entry->check_delete_action)
|
if (entry->check_delete_action)
|
||||||
{ /* enforce child_cfg policy if deleted passively */
|
{ /* enforce child_cfg policy if deleted passively */
|
||||||
switch (action)
|
switch (action)
|
||||||
@@ -425,14 +455,20 @@ METHOD(task_t, build_i, status_t,
|
|||||||
/* we work only with the inbound SPI */
|
/* we work only with the inbound SPI */
|
||||||
this->spi = child_sa->get_spi(child_sa, TRUE);
|
this->spi = child_sa->get_spi(child_sa, TRUE);
|
||||||
}
|
}
|
||||||
|
|
||||||
|
if (child_sa->get_state(child_sa) == CHILD_DELETING)
|
||||||
|
{ /* DELETEs for this CHILD_SA were already exchanged, but it was not yet
|
||||||
|
* destroyed to allow delayed packets to get processed */
|
||||||
|
this->ike_sa->destroy_child_sa(this->ike_sa, this->protocol, this->spi);
|
||||||
|
message->set_exchange_type(message, EXCHANGE_TYPE_UNDEFINED);
|
||||||
|
return SUCCESS;
|
||||||
|
}
|
||||||
|
|
||||||
INIT(entry,
|
INIT(entry,
|
||||||
.child_sa = child_sa,
|
.child_sa = child_sa,
|
||||||
|
.rekeyed = child_sa->get_state(child_sa) == CHILD_REKEYED,
|
||||||
);
|
);
|
||||||
this->child_sas->insert_last(this->child_sas, entry);
|
this->child_sas->insert_last(this->child_sas, entry);
|
||||||
if (child_sa->get_state(child_sa) == CHILD_REKEYED)
|
|
||||||
{
|
|
||||||
entry->rekeyed = TRUE;
|
|
||||||
}
|
|
||||||
log_children(this);
|
log_children(this);
|
||||||
build_payloads(this, message);
|
build_payloads(this, message);
|
||||||
|
|
||||||
|
|||||||
@@ -132,6 +132,7 @@ static void find_child(private_child_rekey_t *this, message_t *message)
|
|||||||
notify_payload_t *notify;
|
notify_payload_t *notify;
|
||||||
protocol_id_t protocol;
|
protocol_id_t protocol;
|
||||||
uint32_t spi;
|
uint32_t spi;
|
||||||
|
child_sa_t *child_sa;
|
||||||
|
|
||||||
notify = message->get_notify(message, REKEY_SA);
|
notify = message->get_notify(message, REKEY_SA);
|
||||||
if (notify)
|
if (notify)
|
||||||
@@ -141,8 +142,15 @@ static void find_child(private_child_rekey_t *this, message_t *message)
|
|||||||
|
|
||||||
if (protocol == PROTO_ESP || protocol == PROTO_AH)
|
if (protocol == PROTO_ESP || protocol == PROTO_AH)
|
||||||
{
|
{
|
||||||
this->child_sa = this->ike_sa->get_child_sa(this->ike_sa, protocol,
|
child_sa = this->ike_sa->get_child_sa(this->ike_sa, protocol,
|
||||||
spi, FALSE);
|
spi, FALSE);
|
||||||
|
if (child_sa &&
|
||||||
|
child_sa->get_state(child_sa) == CHILD_DELETING &&
|
||||||
|
child_sa->get_outbound_state(child_sa) == CHILD_OUTBOUND_NONE)
|
||||||
|
{ /* ignore rekeyed CHILD_SAs we keep around */
|
||||||
|
return;
|
||||||
|
}
|
||||||
|
this->child_sa = child_sa;
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -1,5 +1,5 @@
|
|||||||
/*
|
/*
|
||||||
* Copyright (C) 2016 Tobias Brunner
|
* Copyright (C) 2016-2017 Tobias Brunner
|
||||||
* HSR Hochschule fuer Technik Rapperswil
|
* HSR Hochschule fuer Technik Rapperswil
|
||||||
*
|
*
|
||||||
* This program is free software; you can redistribute it and/or modify it
|
* This program is free software; you can redistribute it and/or modify it
|
||||||
@@ -28,7 +28,23 @@
|
|||||||
assert_hook_not_called(child_updown); \
|
assert_hook_not_called(child_updown); \
|
||||||
assert_hook_not_called(child_rekey); \
|
assert_hook_not_called(child_rekey); \
|
||||||
call_ikesa(sa, rekey_child_sa, PROTO_ESP, spi); \
|
call_ikesa(sa, rekey_child_sa, PROTO_ESP, spi); \
|
||||||
assert_child_sa_state(sa, spi, CHILD_REKEYING); \
|
assert_child_sa_state(sa, spi, CHILD_REKEYING, CHILD_OUTBOUND_INSTALLED); \
|
||||||
|
assert_hook(); \
|
||||||
|
assert_hook(); \
|
||||||
|
})
|
||||||
|
|
||||||
|
/**
|
||||||
|
* Destroy a rekeyed CHILD_SA that was kept around to accept inbound traffic.
|
||||||
|
* Simulates the job that's scheduled to do this.
|
||||||
|
*/
|
||||||
|
#define destroy_rekeyed(sa, spi) ({ \
|
||||||
|
assert_hook_not_called(child_updown); \
|
||||||
|
assert_hook_not_called(child_rekey); \
|
||||||
|
assert_no_jobs_scheduled(); \
|
||||||
|
assert_child_sa_state(sa, spi, CHILD_DELETING, CHILD_OUTBOUND_NONE); \
|
||||||
|
call_ikesa(sa, delete_child_sa, PROTO_ESP, spi, FALSE); \
|
||||||
|
assert_child_sa_not_exists(sa, spi); \
|
||||||
|
assert_scheduler(); \
|
||||||
assert_hook(); \
|
assert_hook(); \
|
||||||
assert_hook(); \
|
assert_hook(); \
|
||||||
})
|
})
|
||||||
@@ -61,7 +77,7 @@ START_TEST(test_regular)
|
|||||||
assert_hook_called(child_rekey);
|
assert_hook_called(child_rekey);
|
||||||
assert_notify(IN, REKEY_SA);
|
assert_notify(IN, REKEY_SA);
|
||||||
exchange_test_helper->process_message(exchange_test_helper, b, NULL);
|
exchange_test_helper->process_message(exchange_test_helper, b, NULL);
|
||||||
assert_child_sa_state(b, spi_b, CHILD_REKEYED);
|
assert_child_sa_state(b, spi_b, CHILD_REKEYED, CHILD_OUTBOUND_INSTALLED);
|
||||||
assert_child_sa_state(b, 4, CHILD_INSTALLED, CHILD_OUTBOUND_REGISTERED);
|
assert_child_sa_state(b, 4, CHILD_INSTALLED, CHILD_OUTBOUND_REGISTERED);
|
||||||
assert_hook();
|
assert_hook();
|
||||||
|
|
||||||
@@ -69,25 +85,37 @@ START_TEST(test_regular)
|
|||||||
assert_hook_called(child_rekey);
|
assert_hook_called(child_rekey);
|
||||||
assert_no_notify(IN, REKEY_SA);
|
assert_no_notify(IN, REKEY_SA);
|
||||||
exchange_test_helper->process_message(exchange_test_helper, a, NULL);
|
exchange_test_helper->process_message(exchange_test_helper, a, NULL);
|
||||||
assert_child_sa_state(a, spi_a, CHILD_DELETING);
|
assert_child_sa_state(a, spi_a, CHILD_DELETING, CHILD_OUTBOUND_INSTALLED);
|
||||||
assert_child_sa_state(a, 3, CHILD_INSTALLED, CHILD_OUTBOUND_INSTALLED);
|
assert_child_sa_state(a, 3, CHILD_INSTALLED, CHILD_OUTBOUND_INSTALLED);
|
||||||
assert_hook();
|
assert_hook();
|
||||||
|
|
||||||
/* INFORMATIONAL { D } --> */
|
/* INFORMATIONAL { D } --> */
|
||||||
assert_hook_not_called(child_rekey);
|
assert_hook_not_called(child_rekey);
|
||||||
|
assert_jobs_scheduled(1);
|
||||||
assert_single_payload(IN, PLV2_DELETE);
|
assert_single_payload(IN, PLV2_DELETE);
|
||||||
exchange_test_helper->process_message(exchange_test_helper, b, NULL);
|
exchange_test_helper->process_message(exchange_test_helper, b, NULL);
|
||||||
|
assert_child_sa_state(b, spi_b, CHILD_DELETING, CHILD_OUTBOUND_NONE);
|
||||||
assert_child_sa_state(b, 4, CHILD_INSTALLED, CHILD_OUTBOUND_INSTALLED);
|
assert_child_sa_state(b, 4, CHILD_INSTALLED, CHILD_OUTBOUND_INSTALLED);
|
||||||
assert_child_sa_count(b, 1);
|
assert_child_sa_count(b, 2);
|
||||||
|
assert_scheduler();
|
||||||
assert_hook();
|
assert_hook();
|
||||||
/* <-- INFORMATIONAL { D } */
|
/* <-- INFORMATIONAL { D } */
|
||||||
assert_hook_not_called(child_rekey);
|
assert_hook_not_called(child_rekey);
|
||||||
|
assert_jobs_scheduled(1);
|
||||||
assert_single_payload(IN, PLV2_DELETE);
|
assert_single_payload(IN, PLV2_DELETE);
|
||||||
exchange_test_helper->process_message(exchange_test_helper, a, NULL);
|
exchange_test_helper->process_message(exchange_test_helper, a, NULL);
|
||||||
assert_child_sa_state(a, 3, CHILD_INSTALLED);
|
assert_child_sa_state(a, spi_a, CHILD_DELETING, CHILD_OUTBOUND_NONE);
|
||||||
assert_child_sa_count(a, 1);
|
assert_child_sa_state(a, 3, CHILD_INSTALLED, CHILD_OUTBOUND_INSTALLED);
|
||||||
|
assert_child_sa_count(a, 2);
|
||||||
|
assert_scheduler();
|
||||||
assert_hook();
|
assert_hook();
|
||||||
|
|
||||||
|
/* simulate the execution of the scheduled jobs */
|
||||||
|
destroy_rekeyed(a, spi_a);
|
||||||
|
assert_child_sa_count(a, 1);
|
||||||
|
destroy_rekeyed(b, spi_b);
|
||||||
|
assert_child_sa_count(b, 1);
|
||||||
|
|
||||||
/* child_updown */
|
/* child_updown */
|
||||||
assert_hook();
|
assert_hook();
|
||||||
|
|
||||||
@@ -165,17 +193,25 @@ START_TEST(test_regular_ke_invalid)
|
|||||||
assert_hook_not_called(child_rekey);
|
assert_hook_not_called(child_rekey);
|
||||||
assert_single_payload(IN, PLV2_DELETE);
|
assert_single_payload(IN, PLV2_DELETE);
|
||||||
exchange_test_helper->process_message(exchange_test_helper, b, NULL);
|
exchange_test_helper->process_message(exchange_test_helper, b, NULL);
|
||||||
|
assert_child_sa_state(b, spi_b, CHILD_DELETING, CHILD_OUTBOUND_NONE);
|
||||||
assert_child_sa_state(b, 6, CHILD_INSTALLED, CHILD_OUTBOUND_INSTALLED);
|
assert_child_sa_state(b, 6, CHILD_INSTALLED, CHILD_OUTBOUND_INSTALLED);
|
||||||
assert_child_sa_count(b, 1);
|
assert_child_sa_count(b, 2);
|
||||||
assert_hook();
|
assert_hook();
|
||||||
/* <-- INFORMATIONAL { D } */
|
/* <-- INFORMATIONAL { D } */
|
||||||
assert_hook_not_called(child_rekey);
|
assert_hook_not_called(child_rekey);
|
||||||
assert_single_payload(IN, PLV2_DELETE);
|
assert_single_payload(IN, PLV2_DELETE);
|
||||||
exchange_test_helper->process_message(exchange_test_helper, a, NULL);
|
exchange_test_helper->process_message(exchange_test_helper, a, NULL);
|
||||||
|
assert_child_sa_state(a, spi_a, CHILD_DELETING, CHILD_OUTBOUND_NONE);
|
||||||
assert_child_sa_state(a, 5, CHILD_INSTALLED);
|
assert_child_sa_state(a, 5, CHILD_INSTALLED);
|
||||||
assert_child_sa_count(a, 1);
|
assert_child_sa_count(a, 2);
|
||||||
assert_hook();
|
assert_hook();
|
||||||
|
|
||||||
|
/* simulate the execution of the scheduled jobs */
|
||||||
|
destroy_rekeyed(a, spi_a);
|
||||||
|
assert_child_sa_count(a, 1);
|
||||||
|
destroy_rekeyed(b, spi_b);
|
||||||
|
assert_child_sa_count(b, 1);
|
||||||
|
|
||||||
/* child_updown */
|
/* child_updown */
|
||||||
assert_hook();
|
assert_hook();
|
||||||
|
|
||||||
@@ -223,15 +259,27 @@ START_TEST(test_regular_responder_ignore_soft_expire)
|
|||||||
assert_child_sa_state(b, 2, CHILD_REKEYED);
|
assert_child_sa_state(b, 2, CHILD_REKEYED);
|
||||||
|
|
||||||
/* INFORMATIONAL { D } --> */
|
/* INFORMATIONAL { D } --> */
|
||||||
|
assert_jobs_scheduled(1);
|
||||||
assert_single_payload(IN, PLV2_DELETE);
|
assert_single_payload(IN, PLV2_DELETE);
|
||||||
exchange_test_helper->process_message(exchange_test_helper, b, NULL);
|
exchange_test_helper->process_message(exchange_test_helper, b, NULL);
|
||||||
|
assert_child_sa_state(b, 2, CHILD_DELETING, CHILD_OUTBOUND_NONE);
|
||||||
assert_child_sa_state(b, 4, CHILD_INSTALLED, CHILD_OUTBOUND_INSTALLED);
|
assert_child_sa_state(b, 4, CHILD_INSTALLED, CHILD_OUTBOUND_INSTALLED);
|
||||||
assert_child_sa_count(b, 1);
|
assert_child_sa_count(b, 2);
|
||||||
|
assert_scheduler();
|
||||||
/* <-- INFORMATIONAL { D } */
|
/* <-- INFORMATIONAL { D } */
|
||||||
|
assert_jobs_scheduled(1);
|
||||||
assert_single_payload(IN, PLV2_DELETE);
|
assert_single_payload(IN, PLV2_DELETE);
|
||||||
exchange_test_helper->process_message(exchange_test_helper, a, NULL);
|
exchange_test_helper->process_message(exchange_test_helper, a, NULL);
|
||||||
|
assert_child_sa_state(a, 1, CHILD_DELETING, CHILD_OUTBOUND_NONE);
|
||||||
assert_child_sa_state(a, 3, CHILD_INSTALLED);
|
assert_child_sa_state(a, 3, CHILD_INSTALLED);
|
||||||
|
assert_child_sa_count(a, 2);
|
||||||
|
assert_scheduler();
|
||||||
|
|
||||||
|
/* simulate the execution of the scheduled jobs */
|
||||||
|
destroy_rekeyed(a, 1);
|
||||||
assert_child_sa_count(a, 1);
|
assert_child_sa_count(a, 1);
|
||||||
|
destroy_rekeyed(b, 2);
|
||||||
|
assert_child_sa_count(b, 1);
|
||||||
|
|
||||||
/* child_rekey/child_updown */
|
/* child_rekey/child_updown */
|
||||||
assert_hook();
|
assert_hook();
|
||||||
@@ -279,27 +327,40 @@ START_TEST(test_regular_responder_handle_hard_expire)
|
|||||||
/* this is similar to a regular delete collision */
|
/* this is similar to a regular delete collision */
|
||||||
assert_single_payload(OUT, PLV2_DELETE);
|
assert_single_payload(OUT, PLV2_DELETE);
|
||||||
call_ikesa(b, delete_child_sa, PROTO_ESP, 2, TRUE);
|
call_ikesa(b, delete_child_sa, PROTO_ESP, 2, TRUE);
|
||||||
assert_child_sa_state(b, 2, CHILD_DELETING);
|
assert_child_sa_state(b, 2, CHILD_DELETING, CHILD_OUTBOUND_INSTALLED);
|
||||||
|
assert_child_sa_state(b, 4, CHILD_INSTALLED, CHILD_OUTBOUND_REGISTERED);
|
||||||
|
|
||||||
/* INFORMATIONAL { D } --> */
|
/* INFORMATIONAL { D } --> */
|
||||||
assert_single_payload(IN, PLV2_DELETE);
|
assert_single_payload(IN, PLV2_DELETE);
|
||||||
exchange_test_helper->process_message(exchange_test_helper, b, NULL);
|
exchange_test_helper->process_message(exchange_test_helper, b, NULL);
|
||||||
|
assert_child_sa_state(a, 2, CHILD_DELETING, CHILD_OUTBOUND_INSTALLED);
|
||||||
assert_child_sa_state(b, 4, CHILD_INSTALLED, CHILD_OUTBOUND_REGISTERED);
|
assert_child_sa_state(b, 4, CHILD_INSTALLED, CHILD_OUTBOUND_REGISTERED);
|
||||||
assert_child_sa_state(a, 2, CHILD_DELETING);
|
|
||||||
/* <-- INFORMATIONAL { D } */
|
/* <-- INFORMATIONAL { D } */
|
||||||
assert_single_payload(IN, PLV2_DELETE);
|
assert_single_payload(IN, PLV2_DELETE);
|
||||||
exchange_test_helper->process_message(exchange_test_helper, a, NULL);
|
exchange_test_helper->process_message(exchange_test_helper, a, NULL);
|
||||||
|
assert_child_sa_state(a, 1, CHILD_DELETING, CHILD_OUTBOUND_INSTALLED);
|
||||||
assert_child_sa_state(a, 3, CHILD_INSTALLED, CHILD_OUTBOUND_INSTALLED);
|
assert_child_sa_state(a, 3, CHILD_INSTALLED, CHILD_OUTBOUND_INSTALLED);
|
||||||
assert_child_sa_state(a, 1, CHILD_DELETING);
|
|
||||||
/* <-- INFORMATIONAL { } */
|
/* <-- INFORMATIONAL { } */
|
||||||
|
assert_jobs_scheduled(1);
|
||||||
assert_message_empty(IN);
|
assert_message_empty(IN);
|
||||||
exchange_test_helper->process_message(exchange_test_helper, a, NULL);
|
exchange_test_helper->process_message(exchange_test_helper, a, NULL);
|
||||||
assert_child_sa_state(a, 3, CHILD_INSTALLED);
|
assert_child_sa_state(a, 1, CHILD_DELETING, CHILD_OUTBOUND_NONE);
|
||||||
assert_child_sa_count(a, 1);
|
assert_child_sa_state(a, 3, CHILD_INSTALLED, CHILD_OUTBOUND_INSTALLED);
|
||||||
|
assert_child_sa_count(a, 2);
|
||||||
|
assert_scheduler();
|
||||||
/* INFORMATIONAL { } --> */
|
/* INFORMATIONAL { } --> */
|
||||||
|
assert_jobs_scheduled(1);
|
||||||
assert_message_empty(IN);
|
assert_message_empty(IN);
|
||||||
exchange_test_helper->process_message(exchange_test_helper, b, NULL);
|
exchange_test_helper->process_message(exchange_test_helper, b, NULL);
|
||||||
assert_child_sa_state(b, 4, CHILD_INSTALLED);
|
assert_child_sa_state(b, 2, CHILD_DELETING, CHILD_OUTBOUND_NONE);
|
||||||
|
assert_child_sa_state(b, 4, CHILD_INSTALLED, CHILD_OUTBOUND_INSTALLED);
|
||||||
|
assert_child_sa_count(b, 2);
|
||||||
|
assert_scheduler();
|
||||||
|
|
||||||
|
/* simulate the execution of the scheduled jobs */
|
||||||
|
destroy_rekeyed(a, 1);
|
||||||
|
assert_child_sa_count(a, 1);
|
||||||
|
destroy_rekeyed(b, 2);
|
||||||
assert_child_sa_count(b, 1);
|
assert_child_sa_count(b, 1);
|
||||||
|
|
||||||
/* child_rekey/child_updown */
|
/* child_rekey/child_updown */
|
||||||
@@ -360,14 +421,14 @@ START_TEST(test_collision)
|
|||||||
exchange_test_helper->nonce_first_byte = data[_i].nonces[2];
|
exchange_test_helper->nonce_first_byte = data[_i].nonces[2];
|
||||||
assert_hook_rekey(child_rekey, 2, 5);
|
assert_hook_rekey(child_rekey, 2, 5);
|
||||||
exchange_test_helper->process_message(exchange_test_helper, b, NULL);
|
exchange_test_helper->process_message(exchange_test_helper, b, NULL);
|
||||||
assert_child_sa_state(b, 2, CHILD_REKEYED);
|
assert_child_sa_state(b, 2, CHILD_REKEYED, CHILD_OUTBOUND_INSTALLED);
|
||||||
assert_child_sa_state(b, 5, CHILD_INSTALLED, CHILD_OUTBOUND_REGISTERED);
|
assert_child_sa_state(b, 5, CHILD_INSTALLED, CHILD_OUTBOUND_REGISTERED);
|
||||||
assert_hook();
|
assert_hook();
|
||||||
/* <-- CREATE_CHILD_SA { N(REKEY_SA), SA, Ni, [KEi,] TSi, TSr } */
|
/* <-- CREATE_CHILD_SA { N(REKEY_SA), SA, Ni, [KEi,] TSi, TSr } */
|
||||||
exchange_test_helper->nonce_first_byte = data[_i].nonces[3];
|
exchange_test_helper->nonce_first_byte = data[_i].nonces[3];
|
||||||
assert_hook_rekey(child_rekey, 1, 6);
|
assert_hook_rekey(child_rekey, 1, 6);
|
||||||
exchange_test_helper->process_message(exchange_test_helper, a, NULL);
|
exchange_test_helper->process_message(exchange_test_helper, a, NULL);
|
||||||
assert_child_sa_state(a, 1, CHILD_REKEYED);
|
assert_child_sa_state(a, 1, CHILD_REKEYED, CHILD_OUTBOUND_INSTALLED);
|
||||||
assert_child_sa_state(a, 6, CHILD_INSTALLED, CHILD_OUTBOUND_REGISTERED);
|
assert_child_sa_state(a, 6, CHILD_INSTALLED, CHILD_OUTBOUND_REGISTERED);
|
||||||
assert_hook();
|
assert_hook();
|
||||||
|
|
||||||
@@ -378,56 +439,100 @@ START_TEST(test_collision)
|
|||||||
assert_hook_rekey(child_rekey, 1, data[_i].spi_a);
|
assert_hook_rekey(child_rekey, 1, data[_i].spi_a);
|
||||||
exchange_test_helper->process_message(exchange_test_helper, a, NULL);
|
exchange_test_helper->process_message(exchange_test_helper, a, NULL);
|
||||||
assert_hook();
|
assert_hook();
|
||||||
|
assert_child_sa_state(a, data[_i].spi_del_b, CHILD_REKEYED,
|
||||||
|
CHILD_OUTBOUND_REGISTERED);
|
||||||
|
assert_child_sa_state(a, data[_i].spi_a, CHILD_INSTALLED,
|
||||||
|
CHILD_OUTBOUND_INSTALLED);
|
||||||
}
|
}
|
||||||
else
|
else
|
||||||
{
|
{
|
||||||
assert_hook_not_called(child_rekey);
|
assert_hook_not_called(child_rekey);
|
||||||
exchange_test_helper->process_message(exchange_test_helper, a, NULL);
|
exchange_test_helper->process_message(exchange_test_helper, a, NULL);
|
||||||
assert_hook();
|
assert_hook();
|
||||||
|
assert_child_sa_state(a, data[_i].spi_del_b, CHILD_REKEYED,
|
||||||
|
CHILD_OUTBOUND_INSTALLED);
|
||||||
|
assert_child_sa_state(a, data[_i].spi_a, CHILD_INSTALLED,
|
||||||
|
CHILD_OUTBOUND_REGISTERED);
|
||||||
}
|
}
|
||||||
assert_child_sa_state(a, data[_i].spi_del_a, CHILD_DELETING);
|
assert_child_sa_state(a, data[_i].spi_del_a, CHILD_DELETING,
|
||||||
assert_child_sa_state(a, data[_i].spi_del_b, CHILD_REKEYED);
|
CHILD_OUTBOUND_INSTALLED);
|
||||||
assert_child_sa_state(a, data[_i].spi_a, CHILD_INSTALLED,
|
|
||||||
data[_i].spi_del_a == 1 ? CHILD_OUTBOUND_INSTALLED
|
|
||||||
: CHILD_OUTBOUND_REGISTERED);
|
|
||||||
/* CREATE_CHILD_SA { SA, Nr, [KEr,] TSi, TSr } --> */
|
/* CREATE_CHILD_SA { SA, Nr, [KEr,] TSi, TSr } --> */
|
||||||
if (data[_i].spi_del_b == 2)
|
if (data[_i].spi_del_b == 2)
|
||||||
{
|
{
|
||||||
assert_hook_rekey(child_rekey, 2, data[_i].spi_b);
|
assert_hook_rekey(child_rekey, 2, data[_i].spi_b);
|
||||||
exchange_test_helper->process_message(exchange_test_helper, b, NULL);
|
exchange_test_helper->process_message(exchange_test_helper, b, NULL);
|
||||||
assert_hook();
|
assert_hook();
|
||||||
|
assert_child_sa_state(b, data[_i].spi_del_a, CHILD_REKEYED,
|
||||||
|
CHILD_OUTBOUND_REGISTERED);
|
||||||
|
assert_child_sa_state(b, data[_i].spi_b, CHILD_INSTALLED,
|
||||||
|
CHILD_OUTBOUND_INSTALLED);
|
||||||
}
|
}
|
||||||
else
|
else
|
||||||
{
|
{
|
||||||
assert_hook_not_called(child_rekey);
|
assert_hook_not_called(child_rekey);
|
||||||
exchange_test_helper->process_message(exchange_test_helper, b, NULL);
|
exchange_test_helper->process_message(exchange_test_helper, b, NULL);
|
||||||
assert_hook();
|
assert_hook();
|
||||||
|
assert_child_sa_state(b, data[_i].spi_del_a, CHILD_REKEYED,
|
||||||
|
CHILD_OUTBOUND_INSTALLED);
|
||||||
|
assert_child_sa_state(b, data[_i].spi_b, CHILD_INSTALLED,
|
||||||
|
CHILD_OUTBOUND_REGISTERED);
|
||||||
}
|
}
|
||||||
assert_child_sa_state(b, data[_i].spi_del_b, CHILD_DELETING);
|
assert_child_sa_state(b, data[_i].spi_del_b, CHILD_DELETING,
|
||||||
assert_child_sa_state(b, data[_i].spi_del_a, CHILD_REKEYED);
|
CHILD_OUTBOUND_INSTALLED);
|
||||||
assert_child_sa_state(b, data[_i].spi_b, CHILD_INSTALLED,
|
|
||||||
data[_i].spi_del_b == 2 ? CHILD_OUTBOUND_INSTALLED
|
|
||||||
: CHILD_OUTBOUND_REGISTERED);
|
|
||||||
|
|
||||||
/* we don't expect this hook to get called anymore */
|
/* we don't expect this hook to get called anymore */
|
||||||
assert_hook_not_called(child_rekey);
|
assert_hook_not_called(child_rekey);
|
||||||
/* INFORMATIONAL { D } --> */
|
/* INFORMATIONAL { D } --> */
|
||||||
|
assert_jobs_scheduled(1);
|
||||||
exchange_test_helper->process_message(exchange_test_helper, b, NULL);
|
exchange_test_helper->process_message(exchange_test_helper, b, NULL);
|
||||||
assert_child_sa_state(b, data[_i].spi_del_b, CHILD_DELETING);
|
assert_child_sa_state(b, data[_i].spi_del_b, CHILD_DELETING,
|
||||||
assert_child_sa_state(b, data[_i].spi_b, CHILD_INSTALLED);
|
CHILD_OUTBOUND_INSTALLED);
|
||||||
assert_child_sa_count(b, 2);
|
assert_child_sa_state(b, data[_i].spi_del_a, CHILD_DELETING,
|
||||||
|
CHILD_OUTBOUND_NONE);
|
||||||
|
assert_child_sa_state(b, data[_i].spi_b, CHILD_INSTALLED,
|
||||||
|
CHILD_OUTBOUND_INSTALLED);
|
||||||
|
assert_child_sa_count(b, 3);
|
||||||
|
assert_scheduler();
|
||||||
/* <-- INFORMATIONAL { D } */
|
/* <-- INFORMATIONAL { D } */
|
||||||
|
assert_jobs_scheduled(1);
|
||||||
exchange_test_helper->process_message(exchange_test_helper, a, NULL);
|
exchange_test_helper->process_message(exchange_test_helper, a, NULL);
|
||||||
assert_child_sa_state(a, data[_i].spi_del_a, CHILD_DELETING);
|
assert_child_sa_state(a, data[_i].spi_del_a, CHILD_DELETING,
|
||||||
assert_child_sa_state(a, data[_i].spi_a, CHILD_INSTALLED);
|
CHILD_OUTBOUND_INSTALLED);
|
||||||
assert_child_sa_count(a, 2);
|
assert_child_sa_state(a, data[_i].spi_del_b, CHILD_DELETING,
|
||||||
|
CHILD_OUTBOUND_NONE);
|
||||||
|
assert_child_sa_state(a, data[_i].spi_a, CHILD_INSTALLED,
|
||||||
|
CHILD_OUTBOUND_INSTALLED);
|
||||||
|
assert_child_sa_count(a, 3);
|
||||||
|
assert_scheduler();
|
||||||
/* <-- INFORMATIONAL { D } */
|
/* <-- INFORMATIONAL { D } */
|
||||||
|
assert_jobs_scheduled(1);
|
||||||
exchange_test_helper->process_message(exchange_test_helper, a, NULL);
|
exchange_test_helper->process_message(exchange_test_helper, a, NULL);
|
||||||
assert_child_sa_state(a, data[_i].spi_a, CHILD_INSTALLED);
|
assert_child_sa_state(a, data[_i].spi_del_a, CHILD_DELETING,
|
||||||
assert_child_sa_count(a, 1);
|
CHILD_OUTBOUND_NONE);
|
||||||
|
assert_child_sa_state(a, data[_i].spi_del_b, CHILD_DELETING,
|
||||||
|
CHILD_OUTBOUND_NONE);
|
||||||
|
assert_child_sa_state(a, data[_i].spi_a, CHILD_INSTALLED,
|
||||||
|
CHILD_OUTBOUND_INSTALLED);
|
||||||
|
assert_child_sa_count(a, 3);
|
||||||
|
assert_scheduler();
|
||||||
/* INFORMATIONAL { D } --> */
|
/* INFORMATIONAL { D } --> */
|
||||||
|
assert_jobs_scheduled(1);
|
||||||
exchange_test_helper->process_message(exchange_test_helper, b, NULL);
|
exchange_test_helper->process_message(exchange_test_helper, b, NULL);
|
||||||
assert_child_sa_state(b, data[_i].spi_b, CHILD_INSTALLED);
|
assert_child_sa_state(b, data[_i].spi_del_b, CHILD_DELETING,
|
||||||
|
CHILD_OUTBOUND_NONE);
|
||||||
|
assert_child_sa_state(b, data[_i].spi_del_a, CHILD_DELETING,
|
||||||
|
CHILD_OUTBOUND_NONE);
|
||||||
|
assert_child_sa_state(b, data[_i].spi_b, CHILD_INSTALLED,
|
||||||
|
CHILD_OUTBOUND_INSTALLED);
|
||||||
|
assert_child_sa_count(b, 3);
|
||||||
|
assert_scheduler();
|
||||||
|
|
||||||
|
/* simulate the execution of the scheduled jobs */
|
||||||
|
destroy_rekeyed(a, data[_i].spi_del_a);
|
||||||
|
destroy_rekeyed(a, data[_i].spi_del_b);
|
||||||
|
assert_child_sa_count(a, 1);
|
||||||
|
destroy_rekeyed(b, data[_i].spi_del_a);
|
||||||
|
destroy_rekeyed(b, data[_i].spi_del_b);
|
||||||
assert_child_sa_count(b, 1);
|
assert_child_sa_count(b, 1);
|
||||||
|
|
||||||
/* child_rekey/child_updown */
|
/* child_rekey/child_updown */
|
||||||
@@ -497,14 +602,14 @@ START_TEST(test_collision_delayed_response)
|
|||||||
exchange_test_helper->nonce_first_byte = data[_i].nonces[2];
|
exchange_test_helper->nonce_first_byte = data[_i].nonces[2];
|
||||||
assert_hook_rekey(child_rekey, 2, 5);
|
assert_hook_rekey(child_rekey, 2, 5);
|
||||||
exchange_test_helper->process_message(exchange_test_helper, b, NULL);
|
exchange_test_helper->process_message(exchange_test_helper, b, NULL);
|
||||||
assert_child_sa_state(b, 2, CHILD_REKEYED);
|
assert_child_sa_state(b, 2, CHILD_REKEYED, CHILD_OUTBOUND_INSTALLED);
|
||||||
assert_child_sa_state(b, 5, CHILD_INSTALLED, CHILD_OUTBOUND_REGISTERED);
|
assert_child_sa_state(b, 5, CHILD_INSTALLED, CHILD_OUTBOUND_REGISTERED);
|
||||||
assert_hook();
|
assert_hook();
|
||||||
/* <-- CREATE_CHILD_SA { N(REKEY_SA), SA, Ni, [KEi,] TSi, TSr } */
|
/* <-- CREATE_CHILD_SA { N(REKEY_SA), SA, Ni, [KEi,] TSi, TSr } */
|
||||||
exchange_test_helper->nonce_first_byte = data[_i].nonces[3];
|
exchange_test_helper->nonce_first_byte = data[_i].nonces[3];
|
||||||
assert_hook_rekey(child_rekey, 1, 6);
|
assert_hook_rekey(child_rekey, 1, 6);
|
||||||
exchange_test_helper->process_message(exchange_test_helper, a, NULL);
|
exchange_test_helper->process_message(exchange_test_helper, a, NULL);
|
||||||
assert_child_sa_state(a, 1, CHILD_REKEYED);
|
assert_child_sa_state(a, 1, CHILD_REKEYED, CHILD_OUTBOUND_INSTALLED);
|
||||||
assert_child_sa_state(a, 6, CHILD_INSTALLED, CHILD_OUTBOUND_REGISTERED);
|
assert_child_sa_state(a, 6, CHILD_INSTALLED, CHILD_OUTBOUND_REGISTERED);
|
||||||
assert_hook();
|
assert_hook();
|
||||||
|
|
||||||
@@ -517,39 +622,64 @@ START_TEST(test_collision_delayed_response)
|
|||||||
assert_hook_rekey(child_rekey, 2, data[_i].spi_b);
|
assert_hook_rekey(child_rekey, 2, data[_i].spi_b);
|
||||||
exchange_test_helper->process_message(exchange_test_helper, b, NULL);
|
exchange_test_helper->process_message(exchange_test_helper, b, NULL);
|
||||||
assert_hook();
|
assert_hook();
|
||||||
|
assert_child_sa_state(b, data[_i].spi_del_a, CHILD_REKEYED,
|
||||||
|
CHILD_OUTBOUND_REGISTERED);
|
||||||
|
assert_child_sa_state(b, data[_i].spi_b, CHILD_INSTALLED,
|
||||||
|
CHILD_OUTBOUND_INSTALLED);
|
||||||
}
|
}
|
||||||
else
|
else
|
||||||
{
|
{
|
||||||
assert_hook_not_called(child_rekey);
|
assert_hook_not_called(child_rekey);
|
||||||
exchange_test_helper->process_message(exchange_test_helper, b, NULL);
|
exchange_test_helper->process_message(exchange_test_helper, b, NULL);
|
||||||
assert_hook();
|
assert_hook();
|
||||||
|
assert_child_sa_state(b, data[_i].spi_del_a, CHILD_REKEYED,
|
||||||
|
CHILD_OUTBOUND_INSTALLED);
|
||||||
|
assert_child_sa_state(b, data[_i].spi_b, CHILD_INSTALLED,
|
||||||
|
CHILD_OUTBOUND_REGISTERED);
|
||||||
}
|
}
|
||||||
assert_child_sa_state(b, data[_i].spi_del_b, CHILD_DELETING);
|
assert_child_sa_state(b, data[_i].spi_del_b, CHILD_DELETING,
|
||||||
assert_child_sa_state(b, data[_i].spi_del_a, CHILD_REKEYED);
|
CHILD_OUTBOUND_INSTALLED);
|
||||||
assert_child_sa_state(b, data[_i].spi_b, CHILD_INSTALLED,
|
|
||||||
data[_i].spi_del_b == 2 ? CHILD_OUTBOUND_INSTALLED
|
|
||||||
: CHILD_OUTBOUND_REGISTERED);
|
|
||||||
|
|
||||||
/* <-- INFORMATIONAL { D } */
|
/* <-- INFORMATIONAL { D } */
|
||||||
assert_hook_not_called(child_rekey);
|
assert_hook_not_called(child_rekey);
|
||||||
|
assert_jobs_scheduled(1);
|
||||||
exchange_test_helper->process_message(exchange_test_helper, a, NULL);
|
exchange_test_helper->process_message(exchange_test_helper, a, NULL);
|
||||||
if (data[_i].spi_del_b == 2)
|
if (data[_i].spi_del_b == 2)
|
||||||
{
|
{
|
||||||
assert_child_sa_state(a, data[_i].spi_a, CHILD_INSTALLED);
|
assert_child_sa_state(a, 1, CHILD_DELETING, CHILD_OUTBOUND_NONE);
|
||||||
assert_child_sa_count(a, 1);
|
assert_child_sa_state(a, data[_i].spi_a, CHILD_INSTALLED,
|
||||||
|
CHILD_OUTBOUND_INSTALLED);
|
||||||
|
assert_child_sa_count(a, 2);
|
||||||
}
|
}
|
||||||
else
|
else
|
||||||
{
|
{
|
||||||
assert_child_sa_state(a, 1, CHILD_REKEYED);
|
assert_child_sa_state(a, 1, CHILD_REKEYED, CHILD_OUTBOUND_INSTALLED);
|
||||||
assert_child_sa_count(a, 1);
|
assert_child_sa_state(a, data[_i].spi_del_b, CHILD_DELETING,
|
||||||
|
CHILD_OUTBOUND_NONE);
|
||||||
|
assert_child_sa_count(a, 2);
|
||||||
}
|
}
|
||||||
|
assert_scheduler();
|
||||||
/* INFORMATIONAL { D } --> */
|
/* INFORMATIONAL { D } --> */
|
||||||
|
assert_jobs_scheduled(1);
|
||||||
exchange_test_helper->process_message(exchange_test_helper, b, NULL);
|
exchange_test_helper->process_message(exchange_test_helper, b, NULL);
|
||||||
assert_child_sa_state(b, data[_i].spi_del_a, CHILD_REKEYED);
|
if (data[_i].spi_del_b == 2)
|
||||||
assert_child_sa_state(b, data[_i].spi_b, CHILD_INSTALLED,
|
{
|
||||||
data[_i].spi_del_b == 2 ? CHILD_OUTBOUND_INSTALLED
|
assert_child_sa_state(b, data[_i].spi_del_a, CHILD_REKEYED,
|
||||||
: CHILD_OUTBOUND_REGISTERED);
|
CHILD_OUTBOUND_REGISTERED);
|
||||||
assert_child_sa_count(b, 2);
|
assert_child_sa_state(b, data[_i].spi_b, CHILD_INSTALLED,
|
||||||
|
CHILD_OUTBOUND_INSTALLED);
|
||||||
|
}
|
||||||
|
else
|
||||||
|
{
|
||||||
|
assert_child_sa_state(b, data[_i].spi_del_a, CHILD_REKEYED,
|
||||||
|
CHILD_OUTBOUND_INSTALLED);
|
||||||
|
assert_child_sa_state(b, data[_i].spi_b, CHILD_INSTALLED,
|
||||||
|
CHILD_OUTBOUND_REGISTERED);
|
||||||
|
}
|
||||||
|
assert_child_sa_state(b, data[_i].spi_del_b, CHILD_DELETING,
|
||||||
|
CHILD_OUTBOUND_NONE);
|
||||||
|
assert_child_sa_count(b, 3);
|
||||||
|
assert_scheduler();
|
||||||
assert_hook();
|
assert_hook();
|
||||||
|
|
||||||
/* <-- CREATE_CHILD_SA { SA, Nr, [KEr,] TSi, TSr } (delayed) */
|
/* <-- CREATE_CHILD_SA { SA, Nr, [KEr,] TSi, TSr } (delayed) */
|
||||||
@@ -565,20 +695,46 @@ START_TEST(test_collision_delayed_response)
|
|||||||
exchange_test_helper->process_message(exchange_test_helper, a, msg);
|
exchange_test_helper->process_message(exchange_test_helper, a, msg);
|
||||||
assert_hook();
|
assert_hook();
|
||||||
}
|
}
|
||||||
assert_child_sa_state(a, data[_i].spi_del_a, CHILD_DELETING);
|
assert_child_sa_state(a, data[_i].spi_del_a, CHILD_DELETING,
|
||||||
assert_child_sa_state(a, data[_i].spi_a, CHILD_INSTALLED);
|
CHILD_OUTBOUND_INSTALLED);
|
||||||
assert_child_sa_count(a, 2);
|
assert_child_sa_state(a, data[_i].spi_del_b, CHILD_DELETING,
|
||||||
|
CHILD_OUTBOUND_NONE);
|
||||||
|
assert_child_sa_state(a, data[_i].spi_a, CHILD_INSTALLED,
|
||||||
|
CHILD_OUTBOUND_INSTALLED);
|
||||||
|
assert_child_sa_count(a, 3);
|
||||||
|
|
||||||
/* we don't expect this hook to get called anymore */
|
/* we don't expect this hook to get called anymore */
|
||||||
assert_hook_not_called(child_rekey);
|
assert_hook_not_called(child_rekey);
|
||||||
/* INFORMATIONAL { D } --> */
|
/* INFORMATIONAL { D } --> */
|
||||||
|
assert_jobs_scheduled(1);
|
||||||
exchange_test_helper->process_message(exchange_test_helper, b, NULL);
|
exchange_test_helper->process_message(exchange_test_helper, b, NULL);
|
||||||
assert_child_sa_state(b, data[_i].spi_b, CHILD_INSTALLED);
|
assert_child_sa_state(b, data[_i].spi_del_a, CHILD_DELETING,
|
||||||
assert_child_sa_count(b, 1);
|
CHILD_OUTBOUND_NONE);
|
||||||
|
assert_child_sa_state(b, data[_i].spi_del_b, CHILD_DELETING,
|
||||||
|
CHILD_OUTBOUND_NONE);
|
||||||
|
assert_child_sa_state(b, data[_i].spi_b, CHILD_INSTALLED,
|
||||||
|
CHILD_OUTBOUND_INSTALLED);
|
||||||
|
assert_child_sa_count(b, 3);
|
||||||
|
assert_scheduler();
|
||||||
/* <-- INFORMATIONAL { D } */
|
/* <-- INFORMATIONAL { D } */
|
||||||
|
assert_jobs_scheduled(1);
|
||||||
exchange_test_helper->process_message(exchange_test_helper, a, NULL);
|
exchange_test_helper->process_message(exchange_test_helper, a, NULL);
|
||||||
assert_child_sa_state(a, data[_i].spi_a, CHILD_INSTALLED);
|
assert_child_sa_state(a, data[_i].spi_del_a, CHILD_DELETING,
|
||||||
|
CHILD_OUTBOUND_NONE);
|
||||||
|
assert_child_sa_state(a, data[_i].spi_del_b, CHILD_DELETING,
|
||||||
|
CHILD_OUTBOUND_NONE);
|
||||||
|
assert_child_sa_state(a, data[_i].spi_a, CHILD_INSTALLED,
|
||||||
|
CHILD_OUTBOUND_INSTALLED);
|
||||||
|
assert_child_sa_count(a, 3);
|
||||||
|
assert_scheduler();
|
||||||
|
|
||||||
|
/* simulate the execution of the scheduled jobs */
|
||||||
|
destroy_rekeyed(a, data[_i].spi_del_a);
|
||||||
|
destroy_rekeyed(a, data[_i].spi_del_b);
|
||||||
assert_child_sa_count(a, 1);
|
assert_child_sa_count(a, 1);
|
||||||
|
destroy_rekeyed(b, data[_i].spi_del_a);
|
||||||
|
destroy_rekeyed(b, data[_i].spi_del_b);
|
||||||
|
assert_child_sa_count(b, 1);
|
||||||
|
|
||||||
/* child_rekey/child_updown */
|
/* child_rekey/child_updown */
|
||||||
assert_hook();
|
assert_hook();
|
||||||
@@ -642,13 +798,13 @@ START_TEST(test_collision_delayed_request)
|
|||||||
exchange_test_helper->nonce_first_byte = data[_i].nonces[2];
|
exchange_test_helper->nonce_first_byte = data[_i].nonces[2];
|
||||||
assert_hook_rekey(child_rekey, 1, 5);
|
assert_hook_rekey(child_rekey, 1, 5);
|
||||||
exchange_test_helper->process_message(exchange_test_helper, a, NULL);
|
exchange_test_helper->process_message(exchange_test_helper, a, NULL);
|
||||||
assert_child_sa_state(a, 1, CHILD_REKEYED);
|
assert_child_sa_state(a, 1, CHILD_REKEYED, CHILD_OUTBOUND_INSTALLED);
|
||||||
assert_child_sa_state(a, 5, CHILD_INSTALLED, CHILD_OUTBOUND_REGISTERED);
|
assert_child_sa_state(a, 5, CHILD_INSTALLED, CHILD_OUTBOUND_REGISTERED);
|
||||||
assert_hook();
|
assert_hook();
|
||||||
/* CREATE_CHILD_SA { SA, Nr, [KEr,] TSi, TSr } --> */
|
/* CREATE_CHILD_SA { SA, Nr, [KEr,] TSi, TSr } --> */
|
||||||
assert_hook_rekey(child_rekey, 2, 4);
|
assert_hook_rekey(child_rekey, 2, 4);
|
||||||
exchange_test_helper->process_message(exchange_test_helper, b, NULL);
|
exchange_test_helper->process_message(exchange_test_helper, b, NULL);
|
||||||
assert_child_sa_state(b, 2, CHILD_DELETING);
|
assert_child_sa_state(b, 2, CHILD_DELETING, CHILD_OUTBOUND_INSTALLED);
|
||||||
assert_child_sa_state(b, 4, CHILD_INSTALLED, CHILD_OUTBOUND_INSTALLED);
|
assert_child_sa_state(b, 4, CHILD_INSTALLED, CHILD_OUTBOUND_INSTALLED);
|
||||||
assert_hook();
|
assert_hook();
|
||||||
|
|
||||||
@@ -658,24 +814,37 @@ START_TEST(test_collision_delayed_request)
|
|||||||
/* CREATE_CHILD_SA { N(REKEY_SA), SA, Ni, [KEi,] TSi, TSr } --> (delayed) */
|
/* CREATE_CHILD_SA { N(REKEY_SA), SA, Ni, [KEi,] TSi, TSr } --> (delayed) */
|
||||||
assert_single_notify(OUT, TEMPORARY_FAILURE);
|
assert_single_notify(OUT, TEMPORARY_FAILURE);
|
||||||
exchange_test_helper->process_message(exchange_test_helper, b, msg);
|
exchange_test_helper->process_message(exchange_test_helper, b, msg);
|
||||||
assert_child_sa_state(b, 2, CHILD_DELETING);
|
assert_child_sa_state(b, 2, CHILD_DELETING, CHILD_OUTBOUND_INSTALLED);
|
||||||
assert_child_sa_state(b, 4, CHILD_INSTALLED);
|
assert_child_sa_state(b, 4, CHILD_INSTALLED, CHILD_OUTBOUND_INSTALLED);
|
||||||
|
|
||||||
/* <-- INFORMATIONAL { D } */
|
/* <-- INFORMATIONAL { D } */
|
||||||
|
assert_jobs_scheduled(1);
|
||||||
exchange_test_helper->process_message(exchange_test_helper, a, NULL);
|
exchange_test_helper->process_message(exchange_test_helper, a, NULL);
|
||||||
|
assert_child_sa_state(a, 1, CHILD_DELETING, CHILD_OUTBOUND_NONE);
|
||||||
assert_child_sa_state(a, 5, CHILD_INSTALLED, CHILD_OUTBOUND_INSTALLED);
|
assert_child_sa_state(a, 5, CHILD_INSTALLED, CHILD_OUTBOUND_INSTALLED);
|
||||||
assert_child_sa_count(a, 1);
|
assert_child_sa_count(a, 2);
|
||||||
|
assert_scheduler();
|
||||||
|
|
||||||
/* <-- CREATE_CHILD_SA { N(TEMP_FAIL) } */
|
/* <-- CREATE_CHILD_SA { N(TEMP_FAIL) } */
|
||||||
assert_no_jobs_scheduled();
|
assert_no_jobs_scheduled();
|
||||||
exchange_test_helper->process_message(exchange_test_helper, a, NULL);
|
exchange_test_helper->process_message(exchange_test_helper, a, NULL);
|
||||||
assert_child_sa_state(a, 5, CHILD_INSTALLED);
|
assert_child_sa_state(a, 1, CHILD_DELETING, CHILD_OUTBOUND_NONE);
|
||||||
assert_child_sa_count(a, 1);
|
assert_child_sa_state(a, 5, CHILD_INSTALLED, CHILD_OUTBOUND_INSTALLED);
|
||||||
|
assert_child_sa_count(a, 2);
|
||||||
assert_scheduler();
|
assert_scheduler();
|
||||||
|
|
||||||
/* INFORMATIONAL { D } --> */
|
/* INFORMATIONAL { D } --> */
|
||||||
|
assert_jobs_scheduled(1);
|
||||||
exchange_test_helper->process_message(exchange_test_helper, b, NULL);
|
exchange_test_helper->process_message(exchange_test_helper, b, NULL);
|
||||||
assert_child_sa_state(b, 4, CHILD_INSTALLED);
|
assert_child_sa_state(b, 2, CHILD_DELETING, CHILD_OUTBOUND_NONE);
|
||||||
|
assert_child_sa_state(b, 4, CHILD_INSTALLED, CHILD_OUTBOUND_INSTALLED);
|
||||||
|
assert_child_sa_count(b, 2);
|
||||||
|
assert_scheduler();
|
||||||
|
|
||||||
|
/* simulate the execution of the scheduled jobs */
|
||||||
|
destroy_rekeyed(a, 1);
|
||||||
|
assert_child_sa_count(a, 1);
|
||||||
|
destroy_rekeyed(b, 2);
|
||||||
assert_child_sa_count(b, 1);
|
assert_child_sa_count(b, 1);
|
||||||
|
|
||||||
/* child_rekey/child_updown */
|
/* child_rekey/child_updown */
|
||||||
@@ -743,13 +912,13 @@ START_TEST(test_collision_delayed_request_more)
|
|||||||
exchange_test_helper->nonce_first_byte = data[_i].nonces[2];
|
exchange_test_helper->nonce_first_byte = data[_i].nonces[2];
|
||||||
assert_hook_rekey(child_rekey, 1, 5);
|
assert_hook_rekey(child_rekey, 1, 5);
|
||||||
exchange_test_helper->process_message(exchange_test_helper, a, NULL);
|
exchange_test_helper->process_message(exchange_test_helper, a, NULL);
|
||||||
assert_child_sa_state(a, 1, CHILD_REKEYED);
|
assert_child_sa_state(a, 1, CHILD_REKEYED, CHILD_OUTBOUND_INSTALLED);
|
||||||
assert_child_sa_state(a, 5, CHILD_INSTALLED, CHILD_OUTBOUND_REGISTERED);
|
assert_child_sa_state(a, 5, CHILD_INSTALLED, CHILD_OUTBOUND_REGISTERED);
|
||||||
assert_hook();
|
assert_hook();
|
||||||
/* CREATE_CHILD_SA { SA, Nr, [KEr,] TSi, TSr } --> */
|
/* CREATE_CHILD_SA { SA, Nr, [KEr,] TSi, TSr } --> */
|
||||||
assert_hook_rekey(child_rekey, 2, 4);
|
assert_hook_rekey(child_rekey, 2, 4);
|
||||||
exchange_test_helper->process_message(exchange_test_helper, b, NULL);
|
exchange_test_helper->process_message(exchange_test_helper, b, NULL);
|
||||||
assert_child_sa_state(b, 2, CHILD_DELETING);
|
assert_child_sa_state(b, 2, CHILD_DELETING, CHILD_OUTBOUND_INSTALLED);
|
||||||
assert_child_sa_state(b, 4, CHILD_INSTALLED, CHILD_OUTBOUND_INSTALLED);
|
assert_child_sa_state(b, 4, CHILD_INSTALLED, CHILD_OUTBOUND_INSTALLED);
|
||||||
assert_hook();
|
assert_hook();
|
||||||
|
|
||||||
@@ -757,26 +926,40 @@ START_TEST(test_collision_delayed_request_more)
|
|||||||
assert_hook_not_called(child_rekey);
|
assert_hook_not_called(child_rekey);
|
||||||
|
|
||||||
/* <-- INFORMATIONAL { D } */
|
/* <-- INFORMATIONAL { D } */
|
||||||
|
assert_jobs_scheduled(1);
|
||||||
exchange_test_helper->process_message(exchange_test_helper, a, NULL);
|
exchange_test_helper->process_message(exchange_test_helper, a, NULL);
|
||||||
|
assert_child_sa_state(a, 1, CHILD_DELETING, CHILD_OUTBOUND_NONE);
|
||||||
assert_child_sa_state(a, 5, CHILD_INSTALLED, CHILD_OUTBOUND_INSTALLED);
|
assert_child_sa_state(a, 5, CHILD_INSTALLED, CHILD_OUTBOUND_INSTALLED);
|
||||||
assert_child_sa_count(a, 1);
|
assert_child_sa_count(a, 2);
|
||||||
|
assert_scheduler();
|
||||||
/* INFORMATIONAL { D } --> */
|
/* INFORMATIONAL { D } --> */
|
||||||
|
assert_jobs_scheduled(1);
|
||||||
exchange_test_helper->process_message(exchange_test_helper, b, NULL);
|
exchange_test_helper->process_message(exchange_test_helper, b, NULL);
|
||||||
assert_child_sa_state(b, 4, CHILD_INSTALLED);
|
assert_child_sa_state(b, 2, CHILD_DELETING, CHILD_OUTBOUND_NONE);
|
||||||
assert_child_sa_count(b, 1);
|
assert_child_sa_state(b, 4, CHILD_INSTALLED, CHILD_OUTBOUND_INSTALLED);
|
||||||
|
assert_child_sa_count(b, 2);
|
||||||
|
assert_scheduler();
|
||||||
|
|
||||||
/* CREATE_CHILD_SA { N(REKEY_SA), SA, Ni, [KEi,] TSi, TSr } --> */
|
/* CREATE_CHILD_SA { N(REKEY_SA), SA, Ni, [KEi,] TSi, TSr } --> */
|
||||||
assert_single_notify(OUT, CHILD_SA_NOT_FOUND);
|
assert_single_notify(OUT, CHILD_SA_NOT_FOUND);
|
||||||
exchange_test_helper->process_message(exchange_test_helper, b, msg);
|
exchange_test_helper->process_message(exchange_test_helper, b, msg);
|
||||||
assert_child_sa_state(b, 4, CHILD_INSTALLED);
|
assert_child_sa_state(b, 2, CHILD_DELETING, CHILD_OUTBOUND_NONE);
|
||||||
assert_child_sa_count(b, 1);
|
assert_child_sa_state(b, 4, CHILD_INSTALLED, CHILD_OUTBOUND_INSTALLED);
|
||||||
|
assert_child_sa_count(b, 2);
|
||||||
/* <-- CREATE_CHILD_SA { N(NO_CHILD_SA) } */
|
/* <-- CREATE_CHILD_SA { N(NO_CHILD_SA) } */
|
||||||
assert_no_jobs_scheduled();
|
assert_no_jobs_scheduled();
|
||||||
exchange_test_helper->process_message(exchange_test_helper, a, NULL);
|
exchange_test_helper->process_message(exchange_test_helper, a, NULL);
|
||||||
assert_child_sa_state(a, 5, CHILD_INSTALLED);
|
assert_child_sa_state(a, 1, CHILD_DELETING, CHILD_OUTBOUND_NONE);
|
||||||
assert_child_sa_count(a, 1);
|
assert_child_sa_state(a, 5, CHILD_INSTALLED, CHILD_OUTBOUND_INSTALLED);
|
||||||
|
assert_child_sa_count(a, 2);
|
||||||
assert_scheduler();
|
assert_scheduler();
|
||||||
|
|
||||||
|
/* simulate the execution of the scheduled jobs */
|
||||||
|
destroy_rekeyed(a, 1);
|
||||||
|
assert_child_sa_count(a, 1);
|
||||||
|
destroy_rekeyed(b, 2);
|
||||||
|
assert_child_sa_count(b, 1);
|
||||||
|
|
||||||
/* child_rekey/child_updown */
|
/* child_rekey/child_updown */
|
||||||
assert_hook();
|
assert_hook();
|
||||||
assert_hook();
|
assert_hook();
|
||||||
@@ -850,13 +1033,13 @@ START_TEST(test_collision_ke_invalid)
|
|||||||
/* CREATE_CHILD_SA { N(REKEY_SA), SA, Ni, [KEi,] TSi, TSr } --> */
|
/* CREATE_CHILD_SA { N(REKEY_SA), SA, Ni, [KEi,] TSi, TSr } --> */
|
||||||
assert_hook_not_called(child_rekey);
|
assert_hook_not_called(child_rekey);
|
||||||
exchange_test_helper->process_message(exchange_test_helper, b, NULL);
|
exchange_test_helper->process_message(exchange_test_helper, b, NULL);
|
||||||
assert_child_sa_state(b, 2, CHILD_REKEYING);
|
assert_child_sa_state(b, 2, CHILD_REKEYING, CHILD_OUTBOUND_INSTALLED);
|
||||||
assert_child_sa_count(b, 1);
|
assert_child_sa_count(b, 1);
|
||||||
assert_hook();
|
assert_hook();
|
||||||
/* <-- CREATE_CHILD_SA { N(REKEY_SA), SA, Ni, [KEi,] TSi, TSr } */
|
/* <-- CREATE_CHILD_SA { N(REKEY_SA), SA, Ni, [KEi,] TSi, TSr } */
|
||||||
assert_hook_not_called(child_rekey);
|
assert_hook_not_called(child_rekey);
|
||||||
exchange_test_helper->process_message(exchange_test_helper, a, NULL);
|
exchange_test_helper->process_message(exchange_test_helper, a, NULL);
|
||||||
assert_child_sa_state(a, 1, CHILD_REKEYING);
|
assert_child_sa_state(a, 1, CHILD_REKEYING, CHILD_OUTBOUND_INSTALLED);
|
||||||
assert_child_sa_count(a, 1);
|
assert_child_sa_count(a, 1);
|
||||||
assert_hook();
|
assert_hook();
|
||||||
|
|
||||||
@@ -865,7 +1048,7 @@ START_TEST(test_collision_ke_invalid)
|
|||||||
assert_hook_not_called(child_rekey);
|
assert_hook_not_called(child_rekey);
|
||||||
assert_single_notify(IN, INVALID_KE_PAYLOAD);
|
assert_single_notify(IN, INVALID_KE_PAYLOAD);
|
||||||
exchange_test_helper->process_message(exchange_test_helper, a, NULL);
|
exchange_test_helper->process_message(exchange_test_helper, a, NULL);
|
||||||
assert_child_sa_state(a, 1, CHILD_REKEYING);
|
assert_child_sa_state(a, 1, CHILD_REKEYING, CHILD_OUTBOUND_INSTALLED);
|
||||||
assert_child_sa_count(a, 1);
|
assert_child_sa_count(a, 1);
|
||||||
assert_hook();
|
assert_hook();
|
||||||
/* CREATE_CHILD_SA { N(INVAL_KE) } --> */
|
/* CREATE_CHILD_SA { N(INVAL_KE) } --> */
|
||||||
@@ -873,7 +1056,7 @@ START_TEST(test_collision_ke_invalid)
|
|||||||
assert_hook_not_called(child_rekey);
|
assert_hook_not_called(child_rekey);
|
||||||
assert_single_notify(IN, INVALID_KE_PAYLOAD);
|
assert_single_notify(IN, INVALID_KE_PAYLOAD);
|
||||||
exchange_test_helper->process_message(exchange_test_helper, b, NULL);
|
exchange_test_helper->process_message(exchange_test_helper, b, NULL);
|
||||||
assert_child_sa_state(b, 2, CHILD_REKEYING);
|
assert_child_sa_state(b, 2, CHILD_REKEYING, CHILD_OUTBOUND_INSTALLED);
|
||||||
assert_child_sa_count(b, 1);
|
assert_child_sa_count(b, 1);
|
||||||
assert_hook();
|
assert_hook();
|
||||||
|
|
||||||
@@ -881,14 +1064,14 @@ START_TEST(test_collision_ke_invalid)
|
|||||||
exchange_test_helper->nonce_first_byte = data[_i].nonces[2];
|
exchange_test_helper->nonce_first_byte = data[_i].nonces[2];
|
||||||
assert_hook_rekey(child_rekey, 2, 9);
|
assert_hook_rekey(child_rekey, 2, 9);
|
||||||
exchange_test_helper->process_message(exchange_test_helper, b, NULL);
|
exchange_test_helper->process_message(exchange_test_helper, b, NULL);
|
||||||
assert_child_sa_state(b, 2, CHILD_REKEYED);
|
assert_child_sa_state(b, 2, CHILD_REKEYED, CHILD_OUTBOUND_INSTALLED);
|
||||||
assert_child_sa_state(b, 9, CHILD_INSTALLED, CHILD_OUTBOUND_REGISTERED);
|
assert_child_sa_state(b, 9, CHILD_INSTALLED, CHILD_OUTBOUND_REGISTERED);
|
||||||
assert_hook();
|
assert_hook();
|
||||||
/* <-- CREATE_CHILD_SA { N(REKEY_SA), SA, Ni, [KEi,] TSi, TSr } */
|
/* <-- CREATE_CHILD_SA { N(REKEY_SA), SA, Ni, [KEi,] TSi, TSr } */
|
||||||
exchange_test_helper->nonce_first_byte = data[_i].nonces[3];
|
exchange_test_helper->nonce_first_byte = data[_i].nonces[3];
|
||||||
assert_hook_rekey(child_rekey, 1, 10);
|
assert_hook_rekey(child_rekey, 1, 10);
|
||||||
exchange_test_helper->process_message(exchange_test_helper, a, NULL);
|
exchange_test_helper->process_message(exchange_test_helper, a, NULL);
|
||||||
assert_child_sa_state(a, 1, CHILD_REKEYED);
|
assert_child_sa_state(a, 1, CHILD_REKEYED, CHILD_OUTBOUND_INSTALLED);
|
||||||
assert_child_sa_state(a,10, CHILD_INSTALLED, CHILD_OUTBOUND_REGISTERED);
|
assert_child_sa_state(a,10, CHILD_INSTALLED, CHILD_OUTBOUND_REGISTERED);
|
||||||
assert_hook();
|
assert_hook();
|
||||||
|
|
||||||
@@ -899,52 +1082,96 @@ START_TEST(test_collision_ke_invalid)
|
|||||||
assert_hook_rekey(child_rekey, 1, data[_i].spi_a);
|
assert_hook_rekey(child_rekey, 1, data[_i].spi_a);
|
||||||
exchange_test_helper->process_message(exchange_test_helper, a, NULL);
|
exchange_test_helper->process_message(exchange_test_helper, a, NULL);
|
||||||
assert_hook();
|
assert_hook();
|
||||||
|
assert_child_sa_state(a, data[_i].spi_del_b, CHILD_REKEYED,
|
||||||
|
CHILD_OUTBOUND_REGISTERED);
|
||||||
|
assert_child_sa_state(a, data[_i].spi_a, CHILD_INSTALLED,
|
||||||
|
CHILD_OUTBOUND_INSTALLED);
|
||||||
}
|
}
|
||||||
else
|
else
|
||||||
{
|
{
|
||||||
exchange_test_helper->process_message(exchange_test_helper, a, NULL);
|
exchange_test_helper->process_message(exchange_test_helper, a, NULL);
|
||||||
|
assert_child_sa_state(a, data[_i].spi_del_b, CHILD_REKEYED,
|
||||||
|
CHILD_OUTBOUND_INSTALLED);
|
||||||
|
assert_child_sa_state(a, data[_i].spi_a, CHILD_INSTALLED,
|
||||||
|
CHILD_OUTBOUND_REGISTERED);
|
||||||
}
|
}
|
||||||
assert_child_sa_state(a, data[_i].spi_del_a, CHILD_DELETING);
|
assert_child_sa_state(a, data[_i].spi_del_a, CHILD_DELETING,
|
||||||
assert_child_sa_state(a, data[_i].spi_del_b, CHILD_REKEYED);
|
CHILD_OUTBOUND_INSTALLED);
|
||||||
assert_child_sa_state(a, data[_i].spi_a, CHILD_INSTALLED,
|
|
||||||
data[_i].spi_del_a == 1 ? CHILD_OUTBOUND_INSTALLED
|
|
||||||
: CHILD_OUTBOUND_REGISTERED);
|
|
||||||
/* CREATE_CHILD_SA { SA, Nr, [KEr,] TSi, TSr } --> */
|
/* CREATE_CHILD_SA { SA, Nr, [KEr,] TSi, TSr } --> */
|
||||||
if (data[_i].spi_del_b == 2)
|
if (data[_i].spi_del_b == 2)
|
||||||
{
|
{
|
||||||
assert_hook_rekey(child_rekey, 2, data[_i].spi_b);
|
assert_hook_rekey(child_rekey, 2, data[_i].spi_b);
|
||||||
exchange_test_helper->process_message(exchange_test_helper, b, NULL);
|
exchange_test_helper->process_message(exchange_test_helper, b, NULL);
|
||||||
assert_hook();
|
assert_hook();
|
||||||
|
assert_child_sa_state(b, data[_i].spi_del_a, CHILD_REKEYED,
|
||||||
|
CHILD_OUTBOUND_REGISTERED);
|
||||||
|
assert_child_sa_state(b, data[_i].spi_b, CHILD_INSTALLED,
|
||||||
|
CHILD_OUTBOUND_INSTALLED);
|
||||||
}
|
}
|
||||||
else
|
else
|
||||||
{
|
{
|
||||||
exchange_test_helper->process_message(exchange_test_helper, b, NULL);
|
exchange_test_helper->process_message(exchange_test_helper, b, NULL);
|
||||||
|
assert_child_sa_state(b, data[_i].spi_del_a, CHILD_REKEYED,
|
||||||
|
CHILD_OUTBOUND_INSTALLED);
|
||||||
|
assert_child_sa_state(b, data[_i].spi_b, CHILD_INSTALLED,
|
||||||
|
CHILD_OUTBOUND_REGISTERED);
|
||||||
}
|
}
|
||||||
assert_child_sa_state(b, data[_i].spi_del_b, CHILD_DELETING);
|
assert_child_sa_state(b, data[_i].spi_del_b, CHILD_DELETING,
|
||||||
assert_child_sa_state(b, data[_i].spi_del_a, CHILD_REKEYED);
|
CHILD_OUTBOUND_INSTALLED);
|
||||||
assert_child_sa_state(b, data[_i].spi_b, CHILD_INSTALLED,
|
|
||||||
data[_i].spi_del_b == 2 ? CHILD_OUTBOUND_INSTALLED
|
|
||||||
: CHILD_OUTBOUND_REGISTERED);
|
|
||||||
|
|
||||||
/* we don't expect this hook to get called anymore */
|
/* we don't expect this hook to get called anymore */
|
||||||
assert_hook_not_called(child_rekey);
|
assert_hook_not_called(child_rekey);
|
||||||
/* INFORMATIONAL { D } --> */
|
/* INFORMATIONAL { D } --> */
|
||||||
|
assert_jobs_scheduled(1);
|
||||||
exchange_test_helper->process_message(exchange_test_helper, b, NULL);
|
exchange_test_helper->process_message(exchange_test_helper, b, NULL);
|
||||||
assert_child_sa_state(b, data[_i].spi_del_b, CHILD_DELETING);
|
assert_child_sa_state(b, data[_i].spi_del_b, CHILD_DELETING,
|
||||||
assert_child_sa_state(b, data[_i].spi_b, CHILD_INSTALLED);
|
CHILD_OUTBOUND_INSTALLED);
|
||||||
assert_child_sa_count(b, 2);
|
assert_child_sa_state(b, data[_i].spi_del_a, CHILD_DELETING,
|
||||||
|
CHILD_OUTBOUND_NONE);
|
||||||
|
assert_child_sa_state(b, data[_i].spi_b, CHILD_INSTALLED,
|
||||||
|
CHILD_OUTBOUND_INSTALLED);
|
||||||
|
assert_child_sa_count(b, 3);
|
||||||
|
assert_scheduler();
|
||||||
/* <-- INFORMATIONAL { D } */
|
/* <-- INFORMATIONAL { D } */
|
||||||
|
assert_jobs_scheduled(1);
|
||||||
exchange_test_helper->process_message(exchange_test_helper, a, NULL);
|
exchange_test_helper->process_message(exchange_test_helper, a, NULL);
|
||||||
assert_child_sa_state(a, data[_i].spi_del_a, CHILD_DELETING);
|
assert_child_sa_state(a, data[_i].spi_del_a, CHILD_DELETING,
|
||||||
assert_child_sa_state(a, data[_i].spi_a, CHILD_INSTALLED);
|
CHILD_OUTBOUND_INSTALLED);
|
||||||
assert_child_sa_count(a, 2);
|
assert_child_sa_state(a, data[_i].spi_del_b, CHILD_DELETING,
|
||||||
|
CHILD_OUTBOUND_NONE);
|
||||||
|
assert_child_sa_state(a, data[_i].spi_a, CHILD_INSTALLED,
|
||||||
|
CHILD_OUTBOUND_INSTALLED);
|
||||||
|
assert_child_sa_count(a, 3);
|
||||||
|
assert_scheduler();
|
||||||
/* <-- INFORMATIONAL { D } */
|
/* <-- INFORMATIONAL { D } */
|
||||||
|
assert_jobs_scheduled(1);
|
||||||
exchange_test_helper->process_message(exchange_test_helper, a, NULL);
|
exchange_test_helper->process_message(exchange_test_helper, a, NULL);
|
||||||
assert_child_sa_state(a, data[_i].spi_a, CHILD_INSTALLED);
|
assert_child_sa_state(a, data[_i].spi_del_a, CHILD_DELETING,
|
||||||
assert_child_sa_count(a, 1);
|
CHILD_OUTBOUND_NONE);
|
||||||
|
assert_child_sa_state(a, data[_i].spi_del_b, CHILD_DELETING,
|
||||||
|
CHILD_OUTBOUND_NONE);
|
||||||
|
assert_child_sa_state(a, data[_i].spi_a, CHILD_INSTALLED,
|
||||||
|
CHILD_OUTBOUND_INSTALLED);
|
||||||
|
assert_child_sa_count(a, 3);
|
||||||
|
assert_scheduler();
|
||||||
/* INFORMATIONAL { D } --> */
|
/* INFORMATIONAL { D } --> */
|
||||||
|
assert_jobs_scheduled(1);
|
||||||
exchange_test_helper->process_message(exchange_test_helper, b, NULL);
|
exchange_test_helper->process_message(exchange_test_helper, b, NULL);
|
||||||
assert_child_sa_state(b, data[_i].spi_b, CHILD_INSTALLED);
|
assert_child_sa_state(b, data[_i].spi_del_b, CHILD_DELETING,
|
||||||
|
CHILD_OUTBOUND_NONE);
|
||||||
|
assert_child_sa_state(b, data[_i].spi_del_a, CHILD_DELETING,
|
||||||
|
CHILD_OUTBOUND_NONE);
|
||||||
|
assert_child_sa_state(b, data[_i].spi_b, CHILD_INSTALLED,
|
||||||
|
CHILD_OUTBOUND_INSTALLED);
|
||||||
|
assert_child_sa_count(b, 3);
|
||||||
|
assert_scheduler();
|
||||||
|
|
||||||
|
/* simulate the execution of the scheduled jobs */
|
||||||
|
destroy_rekeyed(a, data[_i].spi_del_a);
|
||||||
|
destroy_rekeyed(a, data[_i].spi_del_b);
|
||||||
|
assert_child_sa_count(a, 1);
|
||||||
|
destroy_rekeyed(b, data[_i].spi_del_a);
|
||||||
|
destroy_rekeyed(b, data[_i].spi_del_b);
|
||||||
assert_child_sa_count(b, 1);
|
assert_child_sa_count(b, 1);
|
||||||
|
|
||||||
/* child_rekey/child_updown */
|
/* child_rekey/child_updown */
|
||||||
@@ -1016,13 +1243,13 @@ START_TEST(test_collision_ke_invalid_delayed_retry)
|
|||||||
/* CREATE_CHILD_SA { N(REKEY_SA), SA, Ni, [KEi,] TSi, TSr } --> */
|
/* CREATE_CHILD_SA { N(REKEY_SA), SA, Ni, [KEi,] TSi, TSr } --> */
|
||||||
assert_hook_not_called(child_rekey);
|
assert_hook_not_called(child_rekey);
|
||||||
exchange_test_helper->process_message(exchange_test_helper, b, NULL);
|
exchange_test_helper->process_message(exchange_test_helper, b, NULL);
|
||||||
assert_child_sa_state(b, 2, CHILD_REKEYING);
|
assert_child_sa_state(b, 2, CHILD_REKEYING, CHILD_OUTBOUND_INSTALLED);
|
||||||
assert_child_sa_count(b, 1);
|
assert_child_sa_count(b, 1);
|
||||||
assert_hook();
|
assert_hook();
|
||||||
/* <-- CREATE_CHILD_SA { N(REKEY_SA), SA, Ni, [KEi,] TSi, TSr } */
|
/* <-- CREATE_CHILD_SA { N(REKEY_SA), SA, Ni, [KEi,] TSi, TSr } */
|
||||||
assert_hook_not_called(child_rekey);
|
assert_hook_not_called(child_rekey);
|
||||||
exchange_test_helper->process_message(exchange_test_helper, a, NULL);
|
exchange_test_helper->process_message(exchange_test_helper, a, NULL);
|
||||||
assert_child_sa_state(a, 1, CHILD_REKEYING);
|
assert_child_sa_state(a, 1, CHILD_REKEYING, CHILD_OUTBOUND_INSTALLED);
|
||||||
assert_child_sa_count(a, 1);
|
assert_child_sa_count(a, 1);
|
||||||
assert_hook();
|
assert_hook();
|
||||||
|
|
||||||
@@ -1031,7 +1258,7 @@ START_TEST(test_collision_ke_invalid_delayed_retry)
|
|||||||
assert_hook_not_called(child_rekey);
|
assert_hook_not_called(child_rekey);
|
||||||
assert_single_notify(IN, INVALID_KE_PAYLOAD);
|
assert_single_notify(IN, INVALID_KE_PAYLOAD);
|
||||||
exchange_test_helper->process_message(exchange_test_helper, a, NULL);
|
exchange_test_helper->process_message(exchange_test_helper, a, NULL);
|
||||||
assert_child_sa_state(a, 1, CHILD_REKEYING);
|
assert_child_sa_state(a, 1, CHILD_REKEYING, CHILD_OUTBOUND_INSTALLED);
|
||||||
assert_child_sa_count(a, 1);
|
assert_child_sa_count(a, 1);
|
||||||
assert_hook();
|
assert_hook();
|
||||||
/* CREATE_CHILD_SA { N(INVAL_KE) } --> */
|
/* CREATE_CHILD_SA { N(INVAL_KE) } --> */
|
||||||
@@ -1039,7 +1266,7 @@ START_TEST(test_collision_ke_invalid_delayed_retry)
|
|||||||
assert_hook_not_called(child_rekey);
|
assert_hook_not_called(child_rekey);
|
||||||
assert_single_notify(IN, INVALID_KE_PAYLOAD);
|
assert_single_notify(IN, INVALID_KE_PAYLOAD);
|
||||||
exchange_test_helper->process_message(exchange_test_helper, b, NULL);
|
exchange_test_helper->process_message(exchange_test_helper, b, NULL);
|
||||||
assert_child_sa_state(b, 2, CHILD_REKEYING);
|
assert_child_sa_state(b, 2, CHILD_REKEYING, CHILD_OUTBOUND_INSTALLED);
|
||||||
assert_child_sa_count(b, 1);
|
assert_child_sa_count(b, 1);
|
||||||
assert_hook();
|
assert_hook();
|
||||||
|
|
||||||
@@ -1050,14 +1277,14 @@ START_TEST(test_collision_ke_invalid_delayed_retry)
|
|||||||
exchange_test_helper->nonce_first_byte = data[_i].nonces[2];
|
exchange_test_helper->nonce_first_byte = data[_i].nonces[2];
|
||||||
assert_hook_rekey(child_rekey, 1, 9);
|
assert_hook_rekey(child_rekey, 1, 9);
|
||||||
exchange_test_helper->process_message(exchange_test_helper, a, NULL);
|
exchange_test_helper->process_message(exchange_test_helper, a, NULL);
|
||||||
assert_child_sa_state(a, 1, CHILD_REKEYED);
|
assert_child_sa_state(a, 1, CHILD_REKEYED, CHILD_OUTBOUND_INSTALLED);
|
||||||
assert_child_sa_state(a, 9, CHILD_INSTALLED, CHILD_OUTBOUND_REGISTERED);
|
assert_child_sa_state(a, 9, CHILD_INSTALLED, CHILD_OUTBOUND_REGISTERED);
|
||||||
assert_hook();
|
assert_hook();
|
||||||
/* CREATE_CHILD_SA { SA, Nr, [KEr,] TSi, TSr } --> */
|
/* CREATE_CHILD_SA { SA, Nr, [KEr,] TSi, TSr } --> */
|
||||||
assert_hook_rekey(child_rekey, 2, 8);
|
assert_hook_rekey(child_rekey, 2, 8);
|
||||||
exchange_test_helper->process_message(exchange_test_helper, b, NULL);
|
exchange_test_helper->process_message(exchange_test_helper, b, NULL);
|
||||||
assert_child_sa_state(b, 2, CHILD_DELETING);
|
assert_child_sa_state(b, 2, CHILD_DELETING, CHILD_OUTBOUND_INSTALLED);
|
||||||
assert_child_sa_state(b, 8, CHILD_INSTALLED);
|
assert_child_sa_state(b, 8, CHILD_INSTALLED, CHILD_OUTBOUND_INSTALLED);
|
||||||
assert_hook();
|
assert_hook();
|
||||||
|
|
||||||
/* we don't expect this hook to get called anymore */
|
/* we don't expect this hook to get called anymore */
|
||||||
@@ -1066,24 +1293,37 @@ START_TEST(test_collision_ke_invalid_delayed_retry)
|
|||||||
/* CREATE_CHILD_SA { N(REKEY_SA), SA, Ni, [KEi,] TSi, TSr } --> (delayed) */
|
/* CREATE_CHILD_SA { N(REKEY_SA), SA, Ni, [KEi,] TSi, TSr } --> (delayed) */
|
||||||
assert_single_notify(OUT, TEMPORARY_FAILURE);
|
assert_single_notify(OUT, TEMPORARY_FAILURE);
|
||||||
exchange_test_helper->process_message(exchange_test_helper, b, msg);
|
exchange_test_helper->process_message(exchange_test_helper, b, msg);
|
||||||
assert_child_sa_state(b, 2, CHILD_DELETING);
|
assert_child_sa_state(b, 2, CHILD_DELETING, CHILD_OUTBOUND_INSTALLED);
|
||||||
assert_child_sa_state(b, 8, CHILD_INSTALLED);
|
assert_child_sa_state(b, 8, CHILD_INSTALLED, CHILD_OUTBOUND_INSTALLED);
|
||||||
|
|
||||||
/* <-- INFORMATIONAL { D } */
|
/* <-- INFORMATIONAL { D } */
|
||||||
|
assert_jobs_scheduled(1);
|
||||||
exchange_test_helper->process_message(exchange_test_helper, a, NULL);
|
exchange_test_helper->process_message(exchange_test_helper, a, NULL);
|
||||||
|
assert_child_sa_state(a, 1, CHILD_DELETING, CHILD_OUTBOUND_NONE);
|
||||||
assert_child_sa_state(a, 9, CHILD_INSTALLED, CHILD_OUTBOUND_INSTALLED);
|
assert_child_sa_state(a, 9, CHILD_INSTALLED, CHILD_OUTBOUND_INSTALLED);
|
||||||
assert_child_sa_count(a, 1);
|
assert_child_sa_count(a, 2);
|
||||||
|
assert_scheduler();
|
||||||
|
|
||||||
/* <-- CREATE_CHILD_SA { N(TEMP_FAIL) } */
|
/* <-- CREATE_CHILD_SA { N(TEMP_FAIL) } */
|
||||||
assert_no_jobs_scheduled();
|
assert_no_jobs_scheduled();
|
||||||
exchange_test_helper->process_message(exchange_test_helper, a, NULL);
|
exchange_test_helper->process_message(exchange_test_helper, a, NULL);
|
||||||
assert_child_sa_state(a, 9, CHILD_INSTALLED);
|
assert_child_sa_state(a, 1, CHILD_DELETING, CHILD_OUTBOUND_NONE);
|
||||||
assert_child_sa_count(a, 1);
|
assert_child_sa_state(a, 9, CHILD_INSTALLED, CHILD_OUTBOUND_INSTALLED);
|
||||||
|
assert_child_sa_count(a, 2);
|
||||||
assert_scheduler();
|
assert_scheduler();
|
||||||
|
|
||||||
/* INFORMATIONAL { D } --> */
|
/* INFORMATIONAL { D } --> */
|
||||||
|
assert_jobs_scheduled(1);
|
||||||
exchange_test_helper->process_message(exchange_test_helper, b, NULL);
|
exchange_test_helper->process_message(exchange_test_helper, b, NULL);
|
||||||
assert_child_sa_state(b, 8, CHILD_INSTALLED);
|
assert_child_sa_state(b, 2, CHILD_DELETING, CHILD_OUTBOUND_NONE);
|
||||||
|
assert_child_sa_state(b, 8, CHILD_INSTALLED, CHILD_OUTBOUND_INSTALLED);
|
||||||
|
assert_child_sa_count(b, 2);
|
||||||
|
assert_scheduler();
|
||||||
|
|
||||||
|
/* simulate the execution of the scheduled jobs */
|
||||||
|
destroy_rekeyed(a, 1);
|
||||||
|
assert_child_sa_count(a, 1);
|
||||||
|
destroy_rekeyed(b, 2);
|
||||||
assert_child_sa_count(b, 1);
|
assert_child_sa_count(b, 1);
|
||||||
|
|
||||||
/* child_rekey/child_updown */
|
/* child_rekey/child_updown */
|
||||||
@@ -1126,7 +1366,7 @@ START_TEST(test_collision_delete)
|
|||||||
}
|
}
|
||||||
initiate_rekey(a, spi_a);
|
initiate_rekey(a, spi_a);
|
||||||
call_ikesa(b, delete_child_sa, PROTO_ESP, spi_b, FALSE);
|
call_ikesa(b, delete_child_sa, PROTO_ESP, spi_b, FALSE);
|
||||||
assert_child_sa_state(b, spi_b, CHILD_DELETING);
|
assert_child_sa_state(b, spi_b, CHILD_DELETING, CHILD_OUTBOUND_INSTALLED);
|
||||||
|
|
||||||
/* this should never get called as there is no successful rekeying on
|
/* this should never get called as there is no successful rekeying on
|
||||||
* either side */
|
* either side */
|
||||||
@@ -1141,7 +1381,7 @@ START_TEST(test_collision_delete)
|
|||||||
assert_notify(IN, REKEY_SA);
|
assert_notify(IN, REKEY_SA);
|
||||||
assert_single_notify(OUT, TEMPORARY_FAILURE);
|
assert_single_notify(OUT, TEMPORARY_FAILURE);
|
||||||
exchange_test_helper->process_message(exchange_test_helper, b, NULL);
|
exchange_test_helper->process_message(exchange_test_helper, b, NULL);
|
||||||
assert_child_sa_state(b, spi_b, CHILD_DELETING);
|
assert_child_sa_state(b, spi_b, CHILD_DELETING, CHILD_OUTBOUND_INSTALLED);
|
||||||
assert_hook();
|
assert_hook();
|
||||||
|
|
||||||
/* RFC 7296, 2.25.1: If a peer receives a request to delete a CHILD_SA that
|
/* RFC 7296, 2.25.1: If a peer receives a request to delete a CHILD_SA that
|
||||||
@@ -1213,7 +1453,7 @@ START_TEST(test_collision_delete_drop_delete)
|
|||||||
}
|
}
|
||||||
initiate_rekey(a, spi_a);
|
initiate_rekey(a, spi_a);
|
||||||
call_ikesa(b, delete_child_sa, PROTO_ESP, spi_b, FALSE);
|
call_ikesa(b, delete_child_sa, PROTO_ESP, spi_b, FALSE);
|
||||||
assert_child_sa_state(b, spi_b, CHILD_DELETING);
|
assert_child_sa_state(b, spi_b, CHILD_DELETING, CHILD_OUTBOUND_INSTALLED);
|
||||||
|
|
||||||
/* this should never get called as there is no successful rekeying on
|
/* this should never get called as there is no successful rekeying on
|
||||||
* either side */
|
* either side */
|
||||||
@@ -1228,7 +1468,7 @@ START_TEST(test_collision_delete_drop_delete)
|
|||||||
assert_notify(IN, REKEY_SA);
|
assert_notify(IN, REKEY_SA);
|
||||||
assert_single_notify(OUT, TEMPORARY_FAILURE);
|
assert_single_notify(OUT, TEMPORARY_FAILURE);
|
||||||
exchange_test_helper->process_message(exchange_test_helper, b, NULL);
|
exchange_test_helper->process_message(exchange_test_helper, b, NULL);
|
||||||
assert_child_sa_state(b, spi_b, CHILD_DELETING);
|
assert_child_sa_state(b, spi_b, CHILD_DELETING, CHILD_OUTBOUND_INSTALLED);
|
||||||
assert_hook();
|
assert_hook();
|
||||||
|
|
||||||
/* delay the DELETE request */
|
/* delay the DELETE request */
|
||||||
@@ -1239,7 +1479,7 @@ START_TEST(test_collision_delete_drop_delete)
|
|||||||
/* we expect a job to retry the rekeying is scheduled */
|
/* we expect a job to retry the rekeying is scheduled */
|
||||||
assert_jobs_scheduled(1);
|
assert_jobs_scheduled(1);
|
||||||
exchange_test_helper->process_message(exchange_test_helper, a, NULL);
|
exchange_test_helper->process_message(exchange_test_helper, a, NULL);
|
||||||
assert_child_sa_state(a, spi_a, CHILD_INSTALLED);
|
assert_child_sa_state(a, spi_a, CHILD_INSTALLED, CHILD_OUTBOUND_INSTALLED);
|
||||||
assert_scheduler();
|
assert_scheduler();
|
||||||
assert_hook();
|
assert_hook();
|
||||||
|
|
||||||
@@ -1298,7 +1538,7 @@ END_TEST
|
|||||||
}
|
}
|
||||||
initiate_rekey(a, spi_a);
|
initiate_rekey(a, spi_a);
|
||||||
call_ikesa(b, delete_child_sa, PROTO_ESP, spi_b, FALSE);
|
call_ikesa(b, delete_child_sa, PROTO_ESP, spi_b, FALSE);
|
||||||
assert_child_sa_state(b, spi_b, CHILD_DELETING);
|
assert_child_sa_state(b, spi_b, CHILD_DELETING, CHILD_OUTBOUND_INSTALLED);
|
||||||
|
|
||||||
/* this should never get called as there is no successful rekeying on
|
/* this should never get called as there is no successful rekeying on
|
||||||
* either side */
|
* either side */
|
||||||
@@ -1431,13 +1671,13 @@ START_TEST(test_collision_ike_rekey)
|
|||||||
/* <-- CREATE_CHILD_SA { SA, Ni, KEi } */
|
/* <-- CREATE_CHILD_SA { SA, Ni, KEi } */
|
||||||
assert_single_notify(OUT, TEMPORARY_FAILURE);
|
assert_single_notify(OUT, TEMPORARY_FAILURE);
|
||||||
exchange_test_helper->process_message(exchange_test_helper, a, NULL);
|
exchange_test_helper->process_message(exchange_test_helper, a, NULL);
|
||||||
assert_child_sa_state(a, spi_a, CHILD_REKEYING);
|
assert_child_sa_state(a, spi_a, CHILD_REKEYING, CHILD_OUTBOUND_INSTALLED);
|
||||||
|
|
||||||
/* <-- CREATE_CHILD_SA { N(TEMP_FAIL) } */
|
/* <-- CREATE_CHILD_SA { N(TEMP_FAIL) } */
|
||||||
/* we expect a job to retry the rekeying is scheduled */
|
/* we expect a job to retry the rekeying is scheduled */
|
||||||
assert_jobs_scheduled(1);
|
assert_jobs_scheduled(1);
|
||||||
exchange_test_helper->process_message(exchange_test_helper, a, NULL);
|
exchange_test_helper->process_message(exchange_test_helper, a, NULL);
|
||||||
assert_child_sa_state(a, spi_a, CHILD_INSTALLED);
|
assert_child_sa_state(a, spi_a, CHILD_INSTALLED, CHILD_OUTBOUND_INSTALLED);
|
||||||
assert_scheduler();
|
assert_scheduler();
|
||||||
|
|
||||||
/* CREATE_CHILD_SA { N(TEMP_FAIL) } --> */
|
/* CREATE_CHILD_SA { N(TEMP_FAIL) } --> */
|
||||||
|
|||||||
Reference in new issue
Block a user