2006-09-27 14:14:44 +00:00
|
|
|
/*
|
|
|
|
* Copyright (C) 2006 Martin Willi
|
|
|
|
* Hochschule fuer Technik Rapperswil
|
|
|
|
*
|
|
|
|
* This program is free software; you can redistribute it and/or modify it
|
|
|
|
* under the terms of the GNU General Public License as published by the
|
|
|
|
* Free Software Foundation; either version 2 of the License, or (at your
|
|
|
|
* option) any later version. See <http://www.fsf.org/copyleft/gpl.txt>.
|
|
|
|
*
|
|
|
|
* This program is distributed in the hope that it will be useful, but
|
|
|
|
* WITHOUT ANY WARRANTY; without even the implied warranty of MERCHANTABILITY
|
|
|
|
* or FITNESS FOR A PARTICULAR PURPOSE. See the GNU General Public License
|
|
|
|
* for more details.
|
2008-03-13 14:14:44 +00:00
|
|
|
*
|
|
|
|
* $Id$
|
2006-09-27 14:14:44 +00:00
|
|
|
*/
|
|
|
|
|
|
|
|
#include "bus.h"
|
|
|
|
|
2006-10-18 11:46:13 +00:00
|
|
|
#include <pthread.h>
|
2008-10-16 11:32:43 +00:00
|
|
|
#include <stdint.h>
|
2006-10-18 11:46:13 +00:00
|
|
|
|
2007-11-15 18:35:54 +00:00
|
|
|
#include <daemon.h>
|
2008-03-13 14:14:44 +00:00
|
|
|
#include <utils/mutex.h>
|
2007-11-15 18:35:54 +00:00
|
|
|
|
2008-10-14 08:52:13 +00:00
|
|
|
ENUM(debug_names, DBG_DMN, DBG_LIB,
|
2006-10-18 11:46:13 +00:00
|
|
|
"DMN",
|
|
|
|
"MGR",
|
|
|
|
"IKE",
|
|
|
|
"CHD",
|
|
|
|
"JOB",
|
|
|
|
"CFG",
|
|
|
|
"KNL",
|
|
|
|
"NET",
|
|
|
|
"ENC",
|
|
|
|
"LIB",
|
|
|
|
);
|
|
|
|
|
2007-11-15 18:35:54 +00:00
|
|
|
typedef struct private_bus_t private_bus_t;
|
2006-10-18 11:46:13 +00:00
|
|
|
|
|
|
|
/**
|
2007-11-15 18:35:54 +00:00
|
|
|
* Private data of a bus_t object.
|
2006-10-18 11:46:13 +00:00
|
|
|
*/
|
2007-11-15 18:35:54 +00:00
|
|
|
struct private_bus_t {
|
2006-10-18 11:46:13 +00:00
|
|
|
/**
|
2007-11-15 18:35:54 +00:00
|
|
|
* Public part of a bus_t object.
|
2006-10-18 11:46:13 +00:00
|
|
|
*/
|
2007-11-15 18:35:54 +00:00
|
|
|
bus_t public;
|
2006-10-18 11:46:13 +00:00
|
|
|
|
|
|
|
/**
|
2007-11-15 18:35:54 +00:00
|
|
|
* List of registered listeners as entry_t's
|
2006-10-18 11:46:13 +00:00
|
|
|
*/
|
2007-11-15 18:35:54 +00:00
|
|
|
linked_list_t *listeners;
|
2006-10-18 11:46:13 +00:00
|
|
|
|
|
|
|
/**
|
2008-03-13 14:14:44 +00:00
|
|
|
* mutex to synchronize active listeners, recursively
|
2006-10-18 11:46:13 +00:00
|
|
|
*/
|
2008-03-13 14:14:44 +00:00
|
|
|
mutex_t *mutex;
|
2006-10-18 11:46:13 +00:00
|
|
|
|
|
|
|
/**
|
2007-11-15 18:35:54 +00:00
|
|
|
* Thread local storage for a unique, simple thread ID
|
2006-10-18 11:46:13 +00:00
|
|
|
*/
|
2007-11-15 18:35:54 +00:00
|
|
|
pthread_key_t thread_id;
|
2006-10-18 11:46:13 +00:00
|
|
|
|
|
|
|
/**
|
2007-11-15 18:35:54 +00:00
|
|
|
* Thread local storage the threads IKE_SA
|
2006-10-18 11:46:13 +00:00
|
|
|
*/
|
2007-11-15 18:35:54 +00:00
|
|
|
pthread_key_t thread_sa;
|
2006-10-18 11:46:13 +00:00
|
|
|
};
|
|
|
|
|
2007-11-15 18:35:54 +00:00
|
|
|
typedef struct entry_t entry_t;
|
2006-09-27 14:14:44 +00:00
|
|
|
|
|
|
|
/**
|
2007-11-15 18:35:54 +00:00
|
|
|
* a listener entry, either active or passive
|
2006-09-27 14:14:44 +00:00
|
|
|
*/
|
2007-11-15 18:35:54 +00:00
|
|
|
struct entry_t {
|
|
|
|
|
2006-10-18 11:46:13 +00:00
|
|
|
/**
|
2007-11-15 18:35:54 +00:00
|
|
|
* registered listener interface
|
2006-10-18 11:46:13 +00:00
|
|
|
*/
|
2008-10-14 08:52:13 +00:00
|
|
|
listener_t *listener;
|
2006-10-18 11:46:13 +00:00
|
|
|
|
|
|
|
/**
|
2007-11-15 18:35:54 +00:00
|
|
|
* is this a active listen() call with a blocking thread
|
2006-10-18 11:46:13 +00:00
|
|
|
*/
|
2007-11-15 18:35:54 +00:00
|
|
|
bool blocker;
|
2006-10-18 11:46:13 +00:00
|
|
|
|
2008-07-18 11:05:01 +00:00
|
|
|
/**
|
|
|
|
* are we currently calling this listener
|
|
|
|
*/
|
2008-10-16 11:32:43 +00:00
|
|
|
int calling;
|
2008-07-18 11:05:01 +00:00
|
|
|
|
2006-09-27 14:14:44 +00:00
|
|
|
/**
|
2007-11-15 18:35:54 +00:00
|
|
|
* condvar where active listeners wait
|
2006-09-27 14:14:44 +00:00
|
|
|
*/
|
2008-03-13 14:14:44 +00:00
|
|
|
condvar_t *condvar;
|
2007-11-15 18:35:54 +00:00
|
|
|
};
|
|
|
|
|
|
|
|
/**
|
|
|
|
* create a listener entry
|
|
|
|
*/
|
2008-10-14 08:52:13 +00:00
|
|
|
static entry_t *entry_create(listener_t *listener, bool blocker)
|
2007-11-15 18:35:54 +00:00
|
|
|
{
|
|
|
|
entry_t *this = malloc_thing(entry_t);
|
2006-09-27 14:14:44 +00:00
|
|
|
|
2007-11-15 18:35:54 +00:00
|
|
|
this->listener = listener;
|
|
|
|
this->blocker = blocker;
|
2008-10-16 11:32:43 +00:00
|
|
|
this->calling = 0;
|
2008-03-13 14:14:44 +00:00
|
|
|
this->condvar = condvar_create(CONDVAR_DEFAULT);
|
2006-09-27 14:14:44 +00:00
|
|
|
|
2007-11-15 18:35:54 +00:00
|
|
|
return this;
|
|
|
|
}
|
2006-09-27 14:14:44 +00:00
|
|
|
|
2008-03-13 14:14:44 +00:00
|
|
|
/**
|
|
|
|
* destroy an entry_t
|
|
|
|
*/
|
|
|
|
static void entry_destroy(entry_t *entry)
|
|
|
|
{
|
|
|
|
entry->condvar->destroy(entry->condvar);
|
|
|
|
free(entry);
|
|
|
|
}
|
|
|
|
|
2006-09-27 14:14:44 +00:00
|
|
|
/**
|
|
|
|
* Get a unique thread number for a calling thread. Since
|
|
|
|
* pthread_self returns large and ugly numbers, use this function
|
|
|
|
* for logging; these numbers are incremental starting at 1
|
|
|
|
*/
|
2008-10-16 11:32:43 +00:00
|
|
|
static u_int get_thread_number(private_bus_t *this)
|
2006-09-27 14:14:44 +00:00
|
|
|
{
|
2008-10-16 11:32:43 +00:00
|
|
|
static uintptr_t current_num = 0;
|
|
|
|
uintptr_t stored_num;
|
2006-09-27 14:14:44 +00:00
|
|
|
|
2008-10-16 11:32:43 +00:00
|
|
|
stored_num = (uintptr_t)pthread_getspecific(this->thread_id);
|
2006-09-27 14:14:44 +00:00
|
|
|
if (stored_num == 0)
|
|
|
|
{ /* first call of current thread */
|
2006-11-01 10:57:08 +00:00
|
|
|
pthread_setspecific(this->thread_id, (void*)++current_num);
|
2006-09-27 14:14:44 +00:00
|
|
|
return current_num;
|
|
|
|
}
|
|
|
|
else
|
|
|
|
{
|
|
|
|
return stored_num;
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
/**
|
|
|
|
* Implementation of bus_t.add_listener.
|
|
|
|
*/
|
2008-10-14 08:52:13 +00:00
|
|
|
static void add_listener(private_bus_t *this, listener_t *listener)
|
2006-09-27 14:14:44 +00:00
|
|
|
{
|
2008-03-13 14:14:44 +00:00
|
|
|
this->mutex->lock(this->mutex);
|
2007-11-15 18:35:54 +00:00
|
|
|
this->listeners->insert_last(this->listeners, entry_create(listener, FALSE));
|
2008-03-13 14:14:44 +00:00
|
|
|
this->mutex->unlock(this->mutex);
|
2006-10-18 11:46:13 +00:00
|
|
|
}
|
|
|
|
|
2007-05-23 09:08:13 +00:00
|
|
|
/**
|
|
|
|
* Implementation of bus_t.remove_listener.
|
|
|
|
*/
|
2008-10-14 08:52:13 +00:00
|
|
|
static void remove_listener(private_bus_t *this, listener_t *listener)
|
2007-05-23 09:08:13 +00:00
|
|
|
{
|
2008-10-14 08:52:13 +00:00
|
|
|
enumerator_t *enumerator;
|
2007-11-15 18:35:54 +00:00
|
|
|
entry_t *entry;
|
2007-05-23 09:08:13 +00:00
|
|
|
|
2008-03-13 14:14:44 +00:00
|
|
|
this->mutex->lock(this->mutex);
|
2008-10-14 08:52:13 +00:00
|
|
|
enumerator = this->listeners->create_enumerator(this->listeners);
|
|
|
|
while (enumerator->enumerate(enumerator, &entry))
|
2007-05-23 09:08:13 +00:00
|
|
|
{
|
2007-11-15 18:35:54 +00:00
|
|
|
if (entry->listener == listener)
|
2007-05-23 09:08:13 +00:00
|
|
|
{
|
2008-10-14 08:52:13 +00:00
|
|
|
this->listeners->remove_at(this->listeners, enumerator);
|
2008-03-13 14:14:44 +00:00
|
|
|
entry_destroy(entry);
|
2007-05-23 09:08:13 +00:00
|
|
|
break;
|
|
|
|
}
|
|
|
|
}
|
2008-10-14 08:52:13 +00:00
|
|
|
enumerator->destroy(enumerator);
|
2008-03-13 14:14:44 +00:00
|
|
|
this->mutex->unlock(this->mutex);
|
2007-05-23 09:08:13 +00:00
|
|
|
}
|
|
|
|
|
2007-11-19 12:32:28 +00:00
|
|
|
typedef struct cleanup_data_t cleanup_data_t;
|
|
|
|
|
|
|
|
/**
|
|
|
|
* data to remove a listener using pthread_cleanup handler
|
|
|
|
*/
|
|
|
|
struct cleanup_data_t {
|
|
|
|
/** bus instance */
|
|
|
|
private_bus_t *this;
|
|
|
|
/** listener entry */
|
|
|
|
entry_t *entry;
|
|
|
|
};
|
|
|
|
|
|
|
|
/**
|
|
|
|
* pthread_cleanup handler to remove a listener
|
|
|
|
*/
|
|
|
|
static void listener_cleanup(cleanup_data_t *data)
|
|
|
|
{
|
2008-10-14 08:52:13 +00:00
|
|
|
data->this->listeners->remove(data->this->listeners, data->entry, NULL);
|
|
|
|
entry_destroy(data->entry);
|
2007-11-19 12:32:28 +00:00
|
|
|
}
|
|
|
|
|
2006-10-18 11:46:13 +00:00
|
|
|
/**
|
|
|
|
* Implementation of bus_t.listen.
|
|
|
|
*/
|
2008-10-14 08:52:13 +00:00
|
|
|
static void listen_(private_bus_t *this, listener_t *listener, job_t *job)
|
2006-10-18 11:46:13 +00:00
|
|
|
{
|
2007-11-15 18:35:54 +00:00
|
|
|
int old;
|
2007-11-19 12:32:28 +00:00
|
|
|
cleanup_data_t data;
|
2006-10-18 11:46:13 +00:00
|
|
|
|
2007-11-19 12:32:28 +00:00
|
|
|
data.this = this;
|
|
|
|
data.entry = entry_create(listener, TRUE);
|
2006-09-27 14:14:44 +00:00
|
|
|
|
2008-03-13 14:14:44 +00:00
|
|
|
this->mutex->lock(this->mutex);
|
2007-11-19 12:32:28 +00:00
|
|
|
this->listeners->insert_last(this->listeners, data.entry);
|
2007-11-15 18:35:54 +00:00
|
|
|
charon->processor->queue_job(charon->processor, job);
|
2008-03-13 14:14:44 +00:00
|
|
|
pthread_cleanup_push((void*)this->mutex->unlock, this->mutex);
|
2007-11-19 12:32:28 +00:00
|
|
|
pthread_cleanup_push((void*)listener_cleanup, &data);
|
2007-11-15 18:35:54 +00:00
|
|
|
pthread_setcancelstate(PTHREAD_CANCEL_ENABLE, &old);
|
2007-11-19 12:32:28 +00:00
|
|
|
while (data.entry->blocker)
|
2006-10-18 11:46:13 +00:00
|
|
|
{
|
2008-03-13 14:14:44 +00:00
|
|
|
data.entry->condvar->wait(data.entry->condvar, this->mutex);
|
2006-10-18 11:46:13 +00:00
|
|
|
}
|
2007-11-15 18:35:54 +00:00
|
|
|
pthread_setcancelstate(old, NULL);
|
2007-11-19 12:32:28 +00:00
|
|
|
pthread_cleanup_pop(FALSE);
|
|
|
|
/* unlock mutex */
|
2007-11-15 18:35:54 +00:00
|
|
|
pthread_cleanup_pop(TRUE);
|
2008-03-13 14:14:44 +00:00
|
|
|
entry_destroy(data.entry);
|
2006-10-18 11:46:13 +00:00
|
|
|
}
|
|
|
|
|
2006-09-27 14:14:44 +00:00
|
|
|
/**
|
|
|
|
* Implementation of bus_t.set_sa.
|
|
|
|
*/
|
|
|
|
static void set_sa(private_bus_t *this, ike_sa_t *ike_sa)
|
|
|
|
{
|
|
|
|
pthread_setspecific(this->thread_sa, ike_sa);
|
|
|
|
}
|
|
|
|
|
|
|
|
/**
|
2008-07-17 11:45:58 +00:00
|
|
|
* data associated to a signal, passed to callback
|
2006-09-27 14:14:44 +00:00
|
|
|
*/
|
2008-07-17 11:45:58 +00:00
|
|
|
typedef struct {
|
|
|
|
/** associated IKE_SA */
|
2006-09-27 14:14:44 +00:00
|
|
|
ike_sa_t *ike_sa;
|
2008-07-17 11:45:58 +00:00
|
|
|
/** invoking thread */
|
2006-10-30 14:07:05 +00:00
|
|
|
long thread;
|
2008-10-14 08:52:13 +00:00
|
|
|
/** debug group */
|
|
|
|
debug_t group;
|
|
|
|
/** debug level */
|
2008-07-17 11:45:58 +00:00
|
|
|
level_t level;
|
|
|
|
/** format string */
|
|
|
|
char *format;
|
|
|
|
/** argument list */
|
|
|
|
va_list args;
|
2008-10-14 08:52:13 +00:00
|
|
|
} log_data_t;
|
2008-07-17 11:45:58 +00:00
|
|
|
|
|
|
|
/**
|
2008-10-14 08:52:13 +00:00
|
|
|
* listener->log() invocation as a list remove callback
|
2008-07-17 11:45:58 +00:00
|
|
|
*/
|
2008-10-14 08:52:13 +00:00
|
|
|
static bool log_cb(entry_t *entry, log_data_t *data)
|
2008-07-17 11:45:58 +00:00
|
|
|
{
|
2008-07-21 14:23:43 +00:00
|
|
|
va_list args;
|
|
|
|
|
2008-10-14 08:52:13 +00:00
|
|
|
if (entry->calling || !entry->listener->log)
|
2008-07-18 11:05:01 +00:00
|
|
|
{ /* avoid recursive calls */
|
|
|
|
return FALSE;
|
|
|
|
}
|
2008-10-16 11:32:43 +00:00
|
|
|
entry->calling++;
|
2008-07-21 14:23:43 +00:00
|
|
|
va_copy(args, data->args);
|
2008-10-14 08:52:13 +00:00
|
|
|
if (!entry->listener->log(entry->listener, data->group, data->level,
|
|
|
|
data->thread, data->ike_sa, data->format, args))
|
2006-09-27 14:14:44 +00:00
|
|
|
{
|
2008-07-17 11:45:58 +00:00
|
|
|
if (entry->blocker)
|
2007-02-28 14:04:36 +00:00
|
|
|
{
|
2008-07-17 11:45:58 +00:00
|
|
|
entry->blocker = FALSE;
|
|
|
|
entry->condvar->signal(entry->condvar);
|
|
|
|
}
|
|
|
|
else
|
|
|
|
{
|
|
|
|
entry_destroy(entry);
|
2007-02-28 14:04:36 +00:00
|
|
|
}
|
2008-07-21 14:23:43 +00:00
|
|
|
va_end(args);
|
2008-10-16 11:32:43 +00:00
|
|
|
entry->calling--;
|
2008-07-17 11:45:58 +00:00
|
|
|
return TRUE;
|
2006-09-27 14:14:44 +00:00
|
|
|
}
|
2008-07-21 14:23:43 +00:00
|
|
|
va_end(args);
|
2008-10-16 11:32:43 +00:00
|
|
|
entry->calling--;
|
2008-07-17 11:45:58 +00:00
|
|
|
return FALSE;
|
|
|
|
}
|
|
|
|
|
|
|
|
/**
|
2008-10-14 08:52:13 +00:00
|
|
|
* Implementation of bus_t.vlog.
|
2008-07-17 11:45:58 +00:00
|
|
|
*/
|
2008-10-14 08:52:13 +00:00
|
|
|
static void vlog(private_bus_t *this, debug_t group, level_t level,
|
|
|
|
char* format, va_list args)
|
2008-07-17 11:45:58 +00:00
|
|
|
{
|
2008-10-14 08:52:13 +00:00
|
|
|
log_data_t data;
|
2008-07-17 11:45:58 +00:00
|
|
|
|
|
|
|
data.ike_sa = pthread_getspecific(this->thread_sa);
|
|
|
|
data.thread = get_thread_number(this);
|
2008-10-14 08:52:13 +00:00
|
|
|
data.group = group;
|
2008-07-17 11:45:58 +00:00
|
|
|
data.level = level;
|
|
|
|
data.format = format;
|
|
|
|
va_copy(data.args, args);
|
2006-10-18 11:46:13 +00:00
|
|
|
|
2008-07-17 11:45:58 +00:00
|
|
|
this->mutex->lock(this->mutex);
|
2008-10-14 08:52:13 +00:00
|
|
|
/* We use the remove() method to invoke all listeners. This is cheap and
|
|
|
|
* does not require an allocation for this performance critical function. */
|
|
|
|
this->listeners->remove(this->listeners, &data, (void*)log_cb);
|
2008-03-13 14:14:44 +00:00
|
|
|
this->mutex->unlock(this->mutex);
|
2008-07-17 11:45:58 +00:00
|
|
|
|
|
|
|
va_end(data.args);
|
2006-10-18 11:46:13 +00:00
|
|
|
}
|
|
|
|
|
|
|
|
/**
|
2008-10-14 08:52:13 +00:00
|
|
|
* Implementation of bus_t.log.
|
2006-10-18 11:46:13 +00:00
|
|
|
*/
|
2008-10-14 08:52:13 +00:00
|
|
|
static void log_(private_bus_t *this, debug_t group, level_t level,
|
|
|
|
char* format, ...)
|
2006-10-18 11:46:13 +00:00
|
|
|
{
|
|
|
|
va_list args;
|
|
|
|
|
|
|
|
va_start(args, format);
|
2008-10-14 08:52:13 +00:00
|
|
|
vlog(this, group, level, format, args);
|
2006-09-27 14:14:44 +00:00
|
|
|
va_end(args);
|
|
|
|
}
|
|
|
|
|
2008-10-16 11:48:18 +00:00
|
|
|
/**
|
|
|
|
* unregister a listener
|
|
|
|
*/
|
2008-10-16 11:32:43 +00:00
|
|
|
static void unregister_listener(private_bus_t *this, entry_t *entry,
|
|
|
|
enumerator_t *enumerator)
|
|
|
|
{
|
|
|
|
if (entry->blocker)
|
|
|
|
{
|
|
|
|
entry->blocker = FALSE;
|
|
|
|
entry->condvar->signal(entry->condvar);
|
|
|
|
}
|
|
|
|
else
|
|
|
|
{
|
|
|
|
entry_destroy(entry);
|
|
|
|
}
|
|
|
|
this->listeners->remove_at(this->listeners, enumerator);
|
|
|
|
}
|
|
|
|
|
2008-10-14 08:52:13 +00:00
|
|
|
/**
|
|
|
|
* Implementation of bus_t.ike_state_change
|
|
|
|
*/
|
|
|
|
static void ike_state_change(private_bus_t *this, ike_sa_t *ike_sa,
|
|
|
|
ike_sa_state_t state)
|
|
|
|
{
|
|
|
|
enumerator_t *enumerator;
|
|
|
|
entry_t *entry;
|
2008-10-16 11:32:43 +00:00
|
|
|
bool keep;
|
2008-10-14 08:52:13 +00:00
|
|
|
|
|
|
|
this->mutex->lock(this->mutex);
|
|
|
|
enumerator = this->listeners->create_enumerator(this->listeners);
|
|
|
|
while (enumerator->enumerate(enumerator, &entry))
|
|
|
|
{
|
2008-10-16 11:32:43 +00:00
|
|
|
if (entry->calling || !entry->listener->ike_state_change)
|
2008-10-14 08:52:13 +00:00
|
|
|
{
|
2008-10-16 11:32:43 +00:00
|
|
|
continue;
|
|
|
|
}
|
|
|
|
entry->calling++;
|
|
|
|
keep = entry->listener->ike_state_change(entry->listener, ike_sa, state);
|
|
|
|
entry->calling--;
|
|
|
|
if (!keep)
|
|
|
|
{
|
|
|
|
unregister_listener(this, entry, enumerator);
|
2008-10-14 08:52:13 +00:00
|
|
|
break;
|
|
|
|
}
|
|
|
|
}
|
|
|
|
enumerator->destroy(enumerator);
|
|
|
|
this->mutex->unlock(this->mutex);
|
|
|
|
}
|
|
|
|
|
|
|
|
/**
|
|
|
|
* Implementation of bus_t.child_state_change
|
|
|
|
*/
|
|
|
|
static void child_state_change(private_bus_t *this, child_sa_t *child_sa,
|
|
|
|
child_sa_state_t state)
|
|
|
|
{
|
|
|
|
enumerator_t *enumerator;
|
|
|
|
ike_sa_t *ike_sa;
|
|
|
|
entry_t *entry;
|
2008-10-16 11:32:43 +00:00
|
|
|
bool keep;
|
2008-10-14 08:52:13 +00:00
|
|
|
|
|
|
|
ike_sa = pthread_getspecific(this->thread_sa);
|
|
|
|
|
|
|
|
this->mutex->lock(this->mutex);
|
|
|
|
enumerator = this->listeners->create_enumerator(this->listeners);
|
|
|
|
while (enumerator->enumerate(enumerator, &entry))
|
|
|
|
{
|
2008-10-16 11:32:43 +00:00
|
|
|
if (entry->calling || !entry->listener->child_state_change)
|
2008-10-14 08:52:13 +00:00
|
|
|
{
|
2008-10-16 11:32:43 +00:00
|
|
|
continue;
|
|
|
|
}
|
|
|
|
entry->calling++;
|
|
|
|
keep = entry->listener->child_state_change(entry->listener, ike_sa,
|
|
|
|
child_sa, state);
|
|
|
|
entry->calling--;
|
|
|
|
if (!keep)
|
|
|
|
{
|
|
|
|
unregister_listener(this, entry, enumerator);
|
2008-10-14 08:52:13 +00:00
|
|
|
break;
|
|
|
|
}
|
|
|
|
}
|
|
|
|
enumerator->destroy(enumerator);
|
|
|
|
this->mutex->unlock(this->mutex);
|
|
|
|
}
|
|
|
|
|
|
|
|
/**
|
|
|
|
* Implementation of bus_t.message
|
|
|
|
*/
|
|
|
|
static void message(private_bus_t *this, message_t *message, bool incoming)
|
|
|
|
{
|
|
|
|
enumerator_t *enumerator;
|
|
|
|
ike_sa_t *ike_sa;
|
|
|
|
entry_t *entry;
|
2008-10-16 11:32:43 +00:00
|
|
|
bool keep;
|
2008-10-14 08:52:13 +00:00
|
|
|
|
|
|
|
ike_sa = pthread_getspecific(this->thread_sa);
|
|
|
|
|
|
|
|
this->mutex->lock(this->mutex);
|
|
|
|
enumerator = this->listeners->create_enumerator(this->listeners);
|
|
|
|
while (enumerator->enumerate(enumerator, &entry))
|
|
|
|
{
|
2008-10-16 11:32:43 +00:00
|
|
|
if (entry->calling || !entry->listener->message)
|
2008-10-14 08:52:13 +00:00
|
|
|
{
|
2008-10-16 11:32:43 +00:00
|
|
|
continue;
|
|
|
|
}
|
|
|
|
entry->calling++;
|
|
|
|
keep = entry->listener->message(entry->listener, ike_sa,
|
|
|
|
message, incoming);
|
|
|
|
entry->calling--;
|
|
|
|
if (!keep)
|
|
|
|
{
|
|
|
|
unregister_listener(this, entry, enumerator);
|
2008-10-14 08:52:13 +00:00
|
|
|
break;
|
|
|
|
}
|
|
|
|
}
|
|
|
|
enumerator->destroy(enumerator);
|
|
|
|
this->mutex->unlock(this->mutex);
|
|
|
|
}
|
|
|
|
|
2008-10-30 12:58:54 +00:00
|
|
|
/**
|
|
|
|
* Implementation of bus_t.ike_keys
|
|
|
|
*/
|
|
|
|
static void ike_keys(private_bus_t *this, ike_sa_t *ike_sa,
|
|
|
|
diffie_hellman_t *dh, chunk_t nonce_i, chunk_t nonce_r,
|
|
|
|
ike_sa_t *rekey)
|
|
|
|
{
|
|
|
|
enumerator_t *enumerator;
|
|
|
|
entry_t *entry;
|
|
|
|
bool keep;
|
|
|
|
|
|
|
|
this->mutex->lock(this->mutex);
|
|
|
|
enumerator = this->listeners->create_enumerator(this->listeners);
|
|
|
|
while (enumerator->enumerate(enumerator, &entry))
|
|
|
|
{
|
|
|
|
if (entry->calling || !entry->listener->ike_keys)
|
|
|
|
{
|
|
|
|
continue;
|
|
|
|
}
|
|
|
|
entry->calling++;
|
|
|
|
keep = entry->listener->ike_keys(entry->listener, ike_sa, dh,
|
|
|
|
nonce_i, nonce_r, rekey);
|
|
|
|
entry->calling--;
|
|
|
|
if (!keep)
|
|
|
|
{
|
|
|
|
unregister_listener(this, entry, enumerator);
|
|
|
|
break;
|
|
|
|
}
|
|
|
|
}
|
|
|
|
enumerator->destroy(enumerator);
|
|
|
|
this->mutex->unlock(this->mutex);
|
|
|
|
}
|
|
|
|
|
|
|
|
/**
|
|
|
|
* Implementation of bus_t.child_keys
|
|
|
|
*/
|
|
|
|
static void child_keys(private_bus_t *this, child_sa_t *child_sa,
|
|
|
|
diffie_hellman_t *dh, chunk_t nonce_i, chunk_t nonce_r)
|
|
|
|
{
|
|
|
|
enumerator_t *enumerator;
|
|
|
|
ike_sa_t *ike_sa;
|
|
|
|
entry_t *entry;
|
|
|
|
bool keep;
|
|
|
|
|
|
|
|
ike_sa = pthread_getspecific(this->thread_sa);
|
|
|
|
|
|
|
|
this->mutex->lock(this->mutex);
|
|
|
|
enumerator = this->listeners->create_enumerator(this->listeners);
|
|
|
|
while (enumerator->enumerate(enumerator, &entry))
|
|
|
|
{
|
|
|
|
if (entry->calling || !entry->listener->child_keys)
|
|
|
|
{
|
|
|
|
continue;
|
|
|
|
}
|
|
|
|
entry->calling++;
|
|
|
|
keep = entry->listener->child_keys(entry->listener, ike_sa, child_sa,
|
|
|
|
dh, nonce_i, nonce_r);
|
|
|
|
entry->calling--;
|
|
|
|
if (!keep)
|
|
|
|
{
|
|
|
|
unregister_listener(this, entry, enumerator);
|
|
|
|
break;
|
|
|
|
}
|
|
|
|
}
|
|
|
|
enumerator->destroy(enumerator);
|
|
|
|
this->mutex->unlock(this->mutex);
|
|
|
|
}
|
|
|
|
|
2006-09-27 14:14:44 +00:00
|
|
|
/**
|
|
|
|
* Implementation of bus_t.destroy.
|
|
|
|
*/
|
|
|
|
static void destroy(private_bus_t *this)
|
|
|
|
{
|
2008-03-13 14:14:44 +00:00
|
|
|
this->mutex->destroy(this->mutex);
|
|
|
|
this->listeners->destroy_function(this->listeners, (void*)entry_destroy);
|
2006-09-27 14:14:44 +00:00
|
|
|
free(this);
|
|
|
|
}
|
|
|
|
|
|
|
|
/*
|
|
|
|
* Described in header.
|
|
|
|
*/
|
|
|
|
bus_t *bus_create()
|
|
|
|
{
|
|
|
|
private_bus_t *this = malloc_thing(private_bus_t);
|
|
|
|
|
2008-10-14 08:52:13 +00:00
|
|
|
this->public.add_listener = (void(*)(bus_t*,listener_t*))add_listener;
|
|
|
|
this->public.remove_listener = (void(*)(bus_t*,listener_t*))remove_listener;
|
|
|
|
this->public.listen = (void(*)(bus_t*, listener_t *listener, job_t *job))listen_;
|
2006-09-27 14:14:44 +00:00
|
|
|
this->public.set_sa = (void(*)(bus_t*,ike_sa_t*))set_sa;
|
2008-10-14 08:52:13 +00:00
|
|
|
this->public.log = (void(*)(bus_t*,debug_t,level_t,char*,...))log_;
|
|
|
|
this->public.vlog = (void(*)(bus_t*,debug_t,level_t,char*,va_list))vlog;
|
|
|
|
this->public.ike_state_change = (void(*)(bus_t*,ike_sa_t*,ike_sa_state_t))ike_state_change;
|
|
|
|
this->public.child_state_change = (void(*)(bus_t*,child_sa_t*,child_sa_state_t))child_state_change;
|
|
|
|
this->public.message = (void(*)(bus_t*, message_t *message, bool incoming))message;
|
2008-10-30 12:58:54 +00:00
|
|
|
this->public.ike_keys = (void(*)(bus_t*, ike_sa_t *ike_sa, diffie_hellman_t *dh, chunk_t nonce_i, chunk_t nonce_r, ike_sa_t *rekey))ike_keys;
|
|
|
|
this->public.child_keys = (void(*)(bus_t*, child_sa_t *child_sa, diffie_hellman_t *dh, chunk_t nonce_i, chunk_t nonce_r))child_keys;
|
2006-09-27 14:14:44 +00:00
|
|
|
this->public.destroy = (void(*)(bus_t*)) destroy;
|
|
|
|
|
|
|
|
this->listeners = linked_list_create();
|
2008-10-16 11:32:43 +00:00
|
|
|
this->mutex = mutex_create(MUTEX_RECURSIVE);
|
2006-09-27 14:14:44 +00:00
|
|
|
pthread_key_create(&this->thread_id, NULL);
|
|
|
|
pthread_key_create(&this->thread_sa, NULL);
|
|
|
|
|
2007-11-15 18:35:54 +00:00
|
|
|
return &this->public;
|
2006-09-27 14:14:44 +00:00
|
|
|
}
|
2007-11-15 18:35:54 +00:00
|
|
|
|