- handles now INITIATE_IKE_SA jobs

diff --git a/Source/charon/thread_pool.c b/Source/charon/thread_pool.c
index 6451624..add3815 100644 (file)
--- a/Source/charon/thread_pool.c
+++ b/Source/charon/thread_pool.c
@@ -165,6 +165,46 @@ static void job_processing(private_thread_pool_t *this)
                        }
                        case INITIATE_IKE_SA:
                        {
+                               /*
+                                * Initiatie an IKE_SA:
+                                * - is defined by a name of a configuration
+                                * - create an empty IKE_SA via manager
+                                * - call initiate_connection on this sa
+                                */
+                               initiate_ike_sa_job_t *initiate_job;
+                               ike_sa_id_t *ike_sa_id;
+                               ike_sa_t *ike_sa;
+                               status_t status;
+                               
+                               initiate_job = (initiate_ike_sa_job_t *)job;
+                               this->logger->log(this->logger, CONTROL, "thread %u: Initiating an IKE_SA for config \"%s\"", 
+                                                                       pthread_self(), initiate_job->get_configuration_name(initiate_job));                            
+                               
+                               ike_sa_id = ike_sa_id_create(0, 0, TRUE);
+                               if (ike_sa_id == NULL)
+                               {
+                                       this->logger->log(this->logger, ERROR, "thread %u: %s by creating ike_sa_id_t, job rejected.", 
+                                                                               pthread_self(), mapping_find(status_m, status));
+                                       break;
+                               }
+                               
+                               status = global_ike_sa_manager->checkout(global_ike_sa_manager, ike_sa_id, &ike_sa);
+                               ike_sa_id->destroy(ike_sa_id);
+                               if (status != SUCCESS)
+                               {
+                                       this->logger->log(this->logger, ERROR, "thread %u: %s by checking out new IKE_SA, job rejected.", 
+                                                                               pthread_self(), mapping_find(status_m, status));
+                                       break;
+                               }
+                               
+                               status = ike_sa->initialize_connection(ike_sa, initiate_job->get_configuration_name(initiate_job));
+                               if (status != SUCCESS)
+                               {
+                                       this->logger->log(this->logger, ERROR, "thread %u: %s by initialize_conection, job and rejected, IKE_SA deleted.", 
+                                                                               pthread_self(), mapping_find(status_m, status));
+                                       global_ike_sa_manager->checkin_and_delete(global_ike_sa_manager, ike_sa);
+                                       break;
+                               }
                                break;
                        }
                        case RETRANSMIT_REQUEST: