ikev1: Trigger children_migrate event if CHILD_SAs are adopted

diff --git a/src/libcharon/processing/jobs/adopt_children_job.c b/src/libcharon/processing/jobs/adopt_children_job.c
index c8a9c17ded9ba5a447c8d1a0c5b73b6bb9a5120b..9ad4b73041df4d195765dbfde7951ac99c689659 100644 (file)
--- a/src/libcharon/processing/jobs/adopt_children_job.c
+++ b/src/libcharon/processing/jobs/adopt_children_job.c
@@ -64,11 +64,13 @@ METHOD(job_t, execute, job_requeue_t,
        ike_sa_id_t *id;
        ike_sa_t *ike_sa;
        child_sa_t *child_sa;
+       u_int32_t unique;
 
        ike_sa = charon->ike_sa_manager->checkout(charon->ike_sa_manager, this->id);
        if (ike_sa)
        {
                /* get what we need from new SA */
+               unique = ike_sa->get_unique_id(ike_sa);
                me = ike_sa->get_my_host(ike_sa);
                me = me->clone(me);
                other = ike_sa->get_other_host(ike_sa);
@@ -106,6 +108,7 @@ METHOD(job_t, execute, job_requeue_t,
                                        other_id->equals(other_id, ike_sa->get_other_id(ike_sa)) &&
                                        cfg->equals(cfg, ike_sa->get_peer_cfg(ike_sa)))
                                {
+                                       charon->bus->children_migrate(charon->bus, this->id, unique);
                                        subenum = ike_sa->create_child_sa_enumerator(ike_sa);
                                        while (subenum->enumerate(subenum, &child_sa))
                                        {
@@ -176,6 +179,7 @@ METHOD(job_t, execute, job_requeue_t,
                                        }
                                        charon->bus->assign_vips(charon->bus, ike_sa, TRUE);
                                }
+                               charon->bus->children_migrate(charon->bus, NULL, 0);
                                charon->ike_sa_manager->checkin(charon->ike_sa_manager, ike_sa);
                        }
                }

diff --git a/src/libcharon/sa/ike_sa_manager.c b/src/libcharon/sa/ike_sa_manager.c
index 13fc74ff7fe77fea65ec68d6651acf287a74af0b..938f7848fd82f05466968ec590182fd1871a3978 100644 (file)
--- a/src/libcharon/sa/ike_sa_manager.c
+++ b/src/libcharon/sa/ike_sa_manager.c
@@ -1737,7 +1737,8 @@ static void adopt_children_and_vips(ike_sa_t *old, ike_sa_t *new)
        host_t *vip;
        int chcount = 0, vipcount = 0;
 
-
+       charon->bus->children_migrate(charon->bus, new->get_id(new),
+                                                                 new->get_unique_id(new));
        enumerator = old->create_child_sa_enumerator(old);
        while (enumerator->enumerate(enumerator, &child_sa))
        {
@@ -1760,6 +1761,7 @@ static void adopt_children_and_vips(ike_sa_t *old, ike_sa_t *new)
        /* ...trigger the analogous event on the new SA */
        charon->bus->set_sa(charon->bus, new);
        charon->bus->assign_vips(charon->bus, new, TRUE);
+       charon->bus->children_migrate(charon->bus, NULL, 0);
        charon->bus->set_sa(charon->bus, old);
 
        if (chcount || vipcount)

diff --git a/src/libcharon/sa/ikev1/task_manager_v1.c b/src/libcharon/sa/ikev1/task_manager_v1.c
index cb22bf606972358cad2d68066e5a46a26ffa8fb5..ed547c4c26f14c75671453994ddc4ef53289f941 100644 (file)
--- a/src/libcharon/sa/ikev1/task_manager_v1.c
+++ b/src/libcharon/sa/ikev1/task_manager_v1.c
@@ -1475,6 +1475,8 @@ METHOD(task_manager_t, queue_ike_reauth, void,
        }
        enumerator->destroy(enumerator);
 
+       charon->bus->children_migrate(charon->bus, new->get_id(new),
+                                                                 new->get_unique_id(new));
        enumerator = this->ike_sa->create_child_sa_enumerator(this->ike_sa);
        while (enumerator->enumerate(enumerator, &child_sa))
        {
@@ -1482,6 +1484,9 @@ METHOD(task_manager_t, queue_ike_reauth, void,
                new->add_child_sa(new, child_sa);
        }
        enumerator->destroy(enumerator);
+       charon->bus->set_sa(charon->bus, new);
+       charon->bus->children_migrate(charon->bus, NULL, 0);
+       charon->bus->set_sa(charon->bus, this->ike_sa);
 
        if (!new->get_child_count(new))
        {       /* check if a Quick Mode task is queued (UNITY_LOAD_BALANCE case) */