2 * @file initiator_init.c
4 * @brief Implementation of initiator_init_t.
9 * Copyright (C) 2005 Jan Hutter, Martin Willi
10 * Hochschule fuer Technik Rapperswil
12 * This program is free software; you can redistribute it and/or modify it
13 * under the terms of the GNU General Public License as published by the
14 * Free Software Foundation; either version 2 of the License, or (at your
15 * option) any later version. See <http://www.fsf.org/copyleft/gpl.txt>.
17 * This program is distributed in the hope that it will be useful, but
18 * WITHOUT ANY WARRANTY; without even the implied warranty of MERCHANTABILITY
19 * or FITNESS FOR A PARTICULAR PURPOSE. See the GNU General Public License
23 #include "initiator_init.h"
27 #include <sa/states/state.h>
28 #include <sa/states/ike_sa_init_requested.h>
29 #include <utils/allocator.h>
30 #include <transforms/diffie_hellman.h>
31 #include <encoding/payloads/sa_payload.h>
32 #include <encoding/payloads/ke_payload.h>
33 #include <encoding/payloads/nonce_payload.h>
36 typedef struct private_initiator_init_t private_initiator_init_t
;
39 * Private data of a initiator_init_t object..
42 struct private_initiator_init_t
{
44 * Methods of the state_t interface.
46 initiator_init_t
public;
51 protected_ike_sa_t
*ike_sa
;
54 * Diffie hellman object used to generate public DH value.
55 * This objet is passed to the next state of type ike_sa_init_requested_t.
57 diffie_hellman_t
*diffie_hellman
;
62 u_int16_t dh_group_number
;
65 * DH group priority used to get dh_group_number from configuration manager.
66 * This priority is passed to the next state of type ike_sa_init_requested_t.
68 u_int16_t dh_group_priority
;
72 * This nonce is passed to the next state of type ike_sa_init_requested_t.
77 * Logger used to log :-)
79 * Is logger of ike_sa!
84 * Builds the IKE_SA_INIT request message.
86 * @param this calling object
87 * @param message the created message will be stored at this location
89 void (*build_ike_sa_init_request
) (private_initiator_init_t
*this, message_t
**message
);
92 * Builds the SA payload for this state.
94 * @param this calling object
95 * @param payload The generated SA payload object of type ke_payload_t is
96 * stored at this location.
98 void (*build_sa_payload
) (private_initiator_init_t
*this, payload_t
**payload
);
101 * Builds the KE payload for this state.
103 * @param this calling object
104 * @param payload The generated KE payload object of type ke_payload_t is
105 * stored at this location.
107 void (*build_ke_payload
) (private_initiator_init_t
*this, payload_t
**payload
);
110 * Builds the NONCE payload for this state.
112 * @param this calling object
113 * @param payload The generated NONCE payload object of type ke_payload_t is
114 * stored at this location.
116 void (*build_nonce_payload
) (private_initiator_init_t
*this, payload_t
**payload
);
119 * Destroy function called internally of this class after state change succeeded.
121 * This destroy function does not destroy objects which were passed to the new state.
123 * @param this calling object
125 void (*destroy_after_state_change
) (private_initiator_init_t
*this);
129 * Implementation of initiator_init_t.initiate_connection.
131 static status_t
initiate_connection (private_initiator_init_t
*this, char *name
)
133 init_config_t
*init_config
;
134 sa_config_t
*sa_config
;
137 this->logger
->log(this->logger
, CONTROL
, "Initializing connection %s",name
);
139 status
= charon
->configuration_manager
->get_init_config_for_name(charon
->configuration_manager
,name
,&init_config
);
140 if (status
!= SUCCESS
)
142 this->logger
->log(this->logger
, ERROR
| MORE
, "Could not retrieve INIT configuration informations for %s",name
);
146 this->ike_sa
->set_init_config(this->ike_sa
,init_config
);
148 status
= charon
->configuration_manager
->get_sa_config_for_name(charon
->configuration_manager
,name
,&sa_config
);
150 if (status
!= SUCCESS
)
152 this->logger
->log(this->logger
, ERROR
| MORE
, "Could not retrieve SA configuration informations for %s",name
);
156 this->ike_sa
->set_sa_config(this->ike_sa
,sa_config
);
158 /* host informations are read from configuration */
159 this->ike_sa
->set_other_host(this->ike_sa
,init_config
->get_other_host_clone(init_config
));
160 this->ike_sa
->set_my_host(this->ike_sa
,init_config
->get_my_host_clone(init_config
));
162 this->dh_group_number
= init_config
->get_dh_group_number(init_config
,this->dh_group_priority
);
163 if (this->dh_group_number
== MODP_UNDEFINED
)
165 this->logger
->log(this->logger
, ERROR
| MORE
, "Diffie hellman group could not be retrieved with priority %d", this->dh_group_priority
);
169 /* next step is done in retry_initiate_connection */
170 return this->public.retry_initiate_connection(&(this->public),this->dh_group_priority
);
174 * Implementation of initiator_init_t.retry_initiate_connection.
176 status_t
retry_initiate_connection (private_initiator_init_t
*this, int dh_group_priority
)
178 ike_sa_init_requested_t
*next_state
;
179 init_config_t
*init_config
;
180 randomizer_t
*randomizer
;
184 ike_sa_id_t
*ike_sa_id
;
186 this->dh_group_priority
= dh_group_priority
;
188 init_config
= this->ike_sa
->get_init_config(this->ike_sa
);
190 ike_sa_id
= this->ike_sa
->public.get_id(&(this->ike_sa
->public));
191 ike_sa_id
->set_responder_spi(ike_sa_id
,0);
193 this->dh_group_number
= init_config
->get_dh_group_number(init_config
,dh_group_priority
);
194 if (this->dh_group_number
== MODP_UNDEFINED
)
196 this->logger
->log(this->logger
, ERROR
| MORE
, "Diffie hellman group could not be retrieved with priority %d", dh_group_priority
);
200 this->diffie_hellman
= diffie_hellman_create(this->dh_group_number
);
202 this->logger
->log(this->logger
, CONTROL
|MOST
, "Get pseudo random bytes for nonce");
203 randomizer
= this->ike_sa
->get_randomizer(this->ike_sa
);
204 randomizer
->allocate_pseudo_random_bytes(randomizer
, NONCE_SIZE
, &(this->sent_nonce
));
206 this->logger
->log(this->logger
, RAW
|MOST
, "Nonce",&(this->sent_nonce
));
208 this->build_ike_sa_init_request (this,&message
);
210 /* generate packet */
211 this->logger
->log(this->logger
, CONTROL
|MOST
, "generate packet from message");
212 status
= message
->generate(message
, NULL
, NULL
, &packet
);
213 if (status
!= SUCCESS
)
215 this->logger
->log(this->logger
, ERROR
, "could not generate packet from message");
216 message
->destroy(message
);
220 this->logger
->log(this->logger
, CONTROL
|MOST
, "Add packet to global send queue");
221 charon
->send_queue
->add(charon
->send_queue
, packet
);
223 /* state can now be changed */
224 this->logger
->log(this->logger
, CONTROL
|MOST
, "Create next state object");
225 next_state
= ike_sa_init_requested_create(this->ike_sa
, this->dh_group_priority
, this->diffie_hellman
, this->sent_nonce
);
227 /* last message can now be set */
228 status
= this->ike_sa
->set_last_requested_message(this->ike_sa
, message
);
230 if (status
!= SUCCESS
)
232 this->logger
->log(this->logger
, ERROR
, "Could not set last requested message");
233 (next_state
->state_interface
).destroy(&(next_state
->state_interface
));
234 message
->destroy(message
);
238 /* state can now be changed */
239 this->ike_sa
->set_new_state(this->ike_sa
,(state_t
*) next_state
);
241 /* state has NOW changed :-) */
242 this->logger
->log(this->logger
, CONTROL
|MORE
, "Changed state of IKE_SA from %s to %s", mapping_find(ike_sa_state_m
,INITIATOR_INIT
),mapping_find(ike_sa_state_m
,IKE_SA_INIT_REQUESTED
) );
244 this->logger
->log(this->logger
, CONTROL
|MOST
, "Destroy old sate object");
245 this->destroy_after_state_change(this);
251 * implements private_initiator_init_t.build_ike_sa_init_request
253 static void build_ike_sa_init_request (private_initiator_init_t
*this, message_t
**request
)
258 /* going to build message */
259 this->logger
->log(this->logger
, CONTROL
|MOST
, "Going to build message");
260 this->ike_sa
->build_message(this->ike_sa
, IKE_SA_INIT
, TRUE
, &message
);
262 /* build SA payload */
263 this->build_sa_payload(this, &payload
);
264 this->logger
->log(this->logger
, CONTROL
|MOST
, "add SA payload to message");
265 message
->add_payload(message
, payload
);
267 /* build KE payload */
268 this->build_ke_payload(this, &payload
);
269 this->logger
->log(this->logger
, CONTROL
|MOST
, "add KE payload to message");
270 message
->add_payload(message
, payload
);
272 /* build Nonce payload */
273 this->build_nonce_payload(this, &payload
);
274 this->logger
->log(this->logger
, CONTROL
|MOST
, "add nonce payload to message");
275 message
->add_payload(message
, payload
);
281 * implements private_initiator_init_t.build_sa_payload
283 static void build_sa_payload(private_initiator_init_t
*this, payload_t
**payload
)
285 sa_payload_t
* sa_payload
;
286 size_t proposal_count
;
287 ike_proposal_t
*proposals
;
288 init_config_t
*init_config
;
290 this->logger
->log(this->logger
, CONTROL
|MORE
, "building sa payload");
292 init_config
= this->ike_sa
->get_init_config(this->ike_sa
);
294 proposal_count
= init_config
->get_proposals(init_config
,&proposals
);
296 sa_payload
= sa_payload_create_from_ike_proposals(proposals
,proposal_count
);
298 allocator_free(proposals
);
299 *payload
= (payload_t
*) sa_payload
;
303 * implements private_initiator_init_t.build_ke_payload
305 static void build_ke_payload(private_initiator_init_t
*this, payload_t
**payload
)
307 ke_payload_t
*ke_payload
;
310 this->logger
->log(this->logger
, CONTROL
|MORE
, "building ke payload");
312 this->diffie_hellman
->get_my_public_value(this->diffie_hellman
,&key_data
);
314 ke_payload
= ke_payload_create();
315 ke_payload
->set_dh_group_number(ke_payload
, this->dh_group_number
);
316 ke_payload
->set_key_exchange_data(ke_payload
, key_data
);
318 allocator_free_chunk(&key_data
);
319 *payload
= (payload_t
*) ke_payload
;
323 * implements private_initiator_init_t.build_nonce_payload
325 static void build_nonce_payload(private_initiator_init_t
*this, payload_t
**payload
)
327 nonce_payload_t
*nonce_payload
;
329 this->logger
->log(this->logger
, CONTROL
|MORE
, "building nonce payload");
331 nonce_payload
= nonce_payload_create();
333 nonce_payload
->set_nonce(nonce_payload
, this->sent_nonce
);
335 *payload
= (payload_t
*) nonce_payload
;
339 * Implements state_t.get_state
341 static status_t
process_message(private_initiator_init_t
*this, message_t
*message
)
343 this->logger
->log(this->logger
, ERROR
|MORE
, "In state INITIATOR_INIT no message is processed");
348 * Implements state_t.get_state
350 static ike_sa_state_t
get_state(private_initiator_init_t
*this)
352 return INITIATOR_INIT
;
356 * Implements state_t.get_state
358 static void destroy(private_initiator_init_t
*this)
360 this->logger
->log(this->logger
, CONTROL
| MORE
, "Going to destroy initiator_init_t state object");
362 /* destroy stored proposal */
363 this->logger
->log(this->logger
, CONTROL
| MOST
, "Destroy stored proposals");
365 /* destroy diffie hellman object */
366 if (this->diffie_hellman
!= NULL
)
368 this->logger
->log(this->logger
, CONTROL
| MOST
, "Destroy diffie_hellman_t object");
369 this->diffie_hellman
->destroy(this->diffie_hellman
);
371 if (this->sent_nonce
.ptr
!= NULL
)
373 this->logger
->log(this->logger
, CONTROL
| MOST
, "Free memory of sent nonce");
374 allocator_free(this->sent_nonce
.ptr
);
376 allocator_free(this);
380 * Implements private_initiator_init_t.destroy_after_state_change
382 static void destroy_after_state_change (private_initiator_init_t
*this)
384 this->logger
->log(this->logger
, CONTROL
| MORE
, "Going to destroy initiator_init_t state object");
386 /* destroy stored proposal */
387 this->logger
->log(this->logger
, CONTROL
| MOST
, "Destroy stored proposals");
388 allocator_free(this);
392 * Described in header.
394 initiator_init_t
*initiator_init_create(protected_ike_sa_t
*ike_sa
)
396 private_initiator_init_t
*this = allocator_alloc_thing(private_initiator_init_t
);
398 /* interface functions */
399 this->public.state_interface
.process_message
= (status_t (*) (state_t
*,message_t
*)) process_message
;
400 this->public.state_interface
.get_state
= (ike_sa_state_t (*) (state_t
*)) get_state
;
401 this->public.state_interface
.destroy
= (void (*) (state_t
*)) destroy
;
403 /* public functions */
404 this->public.initiate_connection
= (status_t (*)(initiator_init_t
*, char *)) initiate_connection
;
405 this->public.retry_initiate_connection
= (status_t (*)(initiator_init_t
*, int )) retry_initiate_connection
;
407 /* private functions */
408 this->destroy_after_state_change
= destroy_after_state_change
;
409 this->build_ike_sa_init_request
= build_ike_sa_init_request
;
410 this->build_nonce_payload
= build_nonce_payload
;
411 this->build_sa_payload
= build_sa_payload
;
412 this->build_ke_payload
= build_ke_payload
;
415 this->ike_sa
= ike_sa
;
416 this->dh_group_priority
= 1;
417 this->logger
= this->ike_sa
->get_logger(this->ike_sa
);
418 this->sent_nonce
= CHUNK_INITIALIZER
;
420 return &(this->public);