/* * 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 . * * 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. * * $Id: bus.c 4622 2008-11-11 10:52:37Z martin $ */ #include "bus.h" #include #include #include #include ENUM(debug_names, DBG_DMN, DBG_LIB, "DMN", "MGR", "IKE", "CHD", "JOB", "CFG", "KNL", "NET", "ENC", "LIB", ); ENUM(debug_lower_names, DBG_DMN, DBG_LIB, "dmn", "mgr", "ike", "chd", "job", "cfg", "knl", "net", "enc", "lib", ); typedef struct private_bus_t private_bus_t; /** * Private data of a bus_t object. */ struct private_bus_t { /** * Public part of a bus_t object. */ bus_t public; /** * List of registered listeners as entry_t's */ linked_list_t *listeners; /** * mutex to synchronize active listeners, recursively */ mutex_t *mutex; /** * Thread local storage for a unique, simple thread ID */ pthread_key_t thread_id; /** * Thread local storage the threads IKE_SA */ pthread_key_t thread_sa; }; typedef struct entry_t entry_t; /** * a listener entry, either active or passive */ struct entry_t { /** * registered listener interface */ listener_t *listener; /** * is this a active listen() call with a blocking thread */ bool blocker; /** * are we currently calling this listener */ int calling; /** * condvar where active listeners wait */ condvar_t *condvar; }; /** * create a listener entry */ static entry_t *entry_create(listener_t *listener, bool blocker) { entry_t *this = malloc_thing(entry_t); this->listener = listener; this->blocker = blocker; this->calling = 0; this->condvar = condvar_create(CONDVAR_DEFAULT); return this; } /** * destroy an entry_t */ static void entry_destroy(entry_t *entry) { entry->condvar->destroy(entry->condvar); free(entry); } /** * 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 */ static u_int get_thread_number(private_bus_t *this) { static uintptr_t current_num = 0; uintptr_t stored_num; stored_num = (uintptr_t)pthread_getspecific(this->thread_id); if (stored_num == 0) { /* first call of current thread */ pthread_setspecific(this->thread_id, (void*)++current_num); return current_num; } else { return stored_num; } } /** * Implementation of bus_t.add_listener. */ static void add_listener(private_bus_t *this, listener_t *listener) { this->mutex->lock(this->mutex); this->listeners->insert_last(this->listeners, entry_create(listener, FALSE)); this->mutex->unlock(this->mutex); } /** * Implementation of bus_t.remove_listener. */ static void remove_listener(private_bus_t *this, listener_t *listener) { enumerator_t *enumerator; entry_t *entry; this->mutex->lock(this->mutex); enumerator = this->listeners->create_enumerator(this->listeners); while (enumerator->enumerate(enumerator, &entry)) { if (entry->listener == listener) { this->listeners->remove_at(this->listeners, enumerator); entry_destroy(entry); break; } } enumerator->destroy(enumerator); this->mutex->unlock(this->mutex); } 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) { data->this->listeners->remove(data->this->listeners, data->entry, NULL); entry_destroy(data->entry); } /** * Implementation of bus_t.listen. */ static void listen_(private_bus_t *this, listener_t *listener, job_t *job) { int old; cleanup_data_t data; data.this = this; data.entry = entry_create(listener, TRUE); this->mutex->lock(this->mutex); this->listeners->insert_last(this->listeners, data.entry); charon->processor->queue_job(charon->processor, job); pthread_cleanup_push((void*)this->mutex->unlock, this->mutex); pthread_cleanup_push((void*)listener_cleanup, &data); pthread_setcancelstate(PTHREAD_CANCEL_ENABLE, &old); while (data.entry->blocker) { data.entry->condvar->wait(data.entry->condvar, this->mutex); } pthread_setcancelstate(old, NULL); pthread_cleanup_pop(FALSE); /* unlock mutex */ pthread_cleanup_pop(TRUE); entry_destroy(data.entry); } /** * 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); } /** * data associated to a signal, passed to callback */ typedef struct { /** associated IKE_SA */ ike_sa_t *ike_sa; /** invoking thread */ long thread; /** debug group */ debug_t group; /** debug level */ level_t level; /** format string */ char *format; /** argument list */ va_list args; } log_data_t; /** * listener->log() invocation as a list remove callback */ static bool log_cb(entry_t *entry, log_data_t *data) { va_list args; if (entry->calling || !entry->listener->log) { /* avoid recursive calls */ return FALSE; } entry->calling++; va_copy(args, data->args); if (!entry->listener->log(entry->listener, data->group, data->level, data->thread, data->ike_sa, data->format, args)) { if (entry->blocker) { entry->blocker = FALSE; entry->condvar->signal(entry->condvar); } else { entry_destroy(entry); } va_end(args); entry->calling--; return TRUE; } va_end(args); entry->calling--; return FALSE; } /** * Implementation of bus_t.vlog. */ static void vlog(private_bus_t *this, debug_t group, level_t level, char* format, va_list args) { log_data_t data; data.ike_sa = pthread_getspecific(this->thread_sa); data.thread = get_thread_number(this); data.group = group; data.level = level; data.format = format; va_copy(data.args, args); this->mutex->lock(this->mutex); /* 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); this->mutex->unlock(this->mutex); va_end(data.args); } /** * Implementation of bus_t.log. */ static void log_(private_bus_t *this, debug_t group, level_t level, char* format, ...) { va_list args; va_start(args, format); vlog(this, group, level, format, args); va_end(args); } /** * unregister a listener */ 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); } /** * 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; 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_state_change) { continue; } entry->calling++; keep = entry->listener->ike_state_change(entry->listener, ike_sa, state); entry->calling--; if (!keep) { unregister_listener(this, entry, enumerator); 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; 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_state_change) { 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); 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; 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->message) { continue; } entry->calling++; keep = entry->listener->message(entry->listener, ike_sa, message, incoming); entry->calling--; if (!keep) { unregister_listener(this, entry, enumerator); break; } } enumerator->destroy(enumerator); this->mutex->unlock(this->mutex); } /** * 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); } /** * Implementation of bus_t.destroy. */ static void destroy(private_bus_t *this) { this->mutex->destroy(this->mutex); this->listeners->destroy_function(this->listeners, (void*)entry_destroy); free(this); } /* * Described in header. */ bus_t *bus_create() { private_bus_t *this = malloc_thing(private_bus_t); 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_; this->public.set_sa = (void(*)(bus_t*,ike_sa_t*))set_sa; 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; 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; this->public.destroy = (void(*)(bus_t*)) destroy; this->listeners = linked_list_create(); this->mutex = mutex_create(MUTEX_RECURSIVE); pthread_key_create(&this->thread_id, NULL); pthread_key_create(&this->thread_sa, NULL); return &this->public; }