ikev2: Allow tasks to do work after generating requests/responses

diff --git a/src/libcharon/sa/ikev2/task_manager_v2.c b/src/libcharon/sa/ikev2/task_manager_v2.c
index c9ea9792bf29ed0e9bfec44bd58caf9765d5baf4..31964d7ea196e62d7c236bcdb11a02e97a708765 100644 (file)
--- a/src/libcharon/sa/ikev2/task_manager_v2.c
+++ b/src/libcharon/sa/ikev2/task_manager_v2.c
@@ -472,6 +472,7 @@ METHOD(task_manager_t, initiate, status_t,
        message_t *message;
        host_t *me, *other;
        exchange_type_t exchange = 0;
+       bool result;
 
        if (this->initiating.type != EXCHANGE_TYPE_UNDEFINED)
        {
@@ -686,16 +687,46 @@ METHOD(task_manager_t, initiate, status_t,
                return initiate(this);
        }
 
-       if (!generate_message(this, message, &this->initiating.packets))
+       result = generate_message(this, message, &this->initiating.packets);
+
+       if (result)
        {
-               /* message generation failed. There is nothing more to do than to
+               enumerator = array_create_enumerator(this->active_tasks);
+               while (enumerator->enumerate(enumerator, &task))
+               {
+                       if (!task->post_build)
+                       {
+                               continue;
+                       }
+                       switch (task->post_build(task, message))
+                       {
+                               case SUCCESS:
+                                       array_remove_at(this->active_tasks, enumerator);
+                                       task->destroy(task);
+                                       break;
+                               case NEED_MORE:
+                                       break;
+                               default:
+                                       /* critical failure, destroy IKE_SA */
+                                       result = FALSE;
+                                       break;
+                       }
+               }
+               enumerator->destroy(enumerator);
+       }
+       message->destroy(message);
+
+       if (!result)
+       {       /* message generation failed. There is nothing more to do than to
                 * close the SA */
-               message->destroy(message);
                flush(this);
-               charon->bus->ike_updown(charon->bus, this->ike_sa, FALSE);
+               if (this->ike_sa->get_state(this->ike_sa) != IKE_CONNECTING &&
+                       this->ike_sa->get_state(this->ike_sa) != IKE_REKEYED)
+               {
+                       charon->bus->ike_updown(charon->bus, this->ike_sa, FALSE);
+               }
                return DESTROY_ME;
        }
-       message->destroy(message);
 
        array_compress(this->active_tasks);
        array_compress(this->queued_tasks);
@@ -947,7 +978,34 @@ static status_t build_response(private_task_manager_t *this, message_t *request)
        /* message complete, send it */
        clear_packets(this->responding.packets);
        result = generate_message(this, message, &this->responding.packets);
+
+       if (result && !delete)
+       {
+               enumerator = array_create_enumerator(this->passive_tasks);
+               while (enumerator->enumerate(enumerator, &task))
+               {
+                       if (!task->post_build)
+                       {
+                               continue;
+                       }
+                       switch (task->post_build(task, message))
+                       {
+                               case SUCCESS:
+                                       array_remove_at(this->passive_tasks, enumerator);
+                                       task->destroy(task);
+                                       break;
+                               case NEED_MORE:
+                                       break;
+                               default:
+                                       /* critical failure, destroy IKE_SA */
+                                       result = FALSE;
+                                       break;
+                       }
+               }
+               enumerator->destroy(enumerator);
+       }
        message->destroy(message);
+
        if (id)
        {
                id->set_responder_spi(id, responder_spi);