X-Git-Url: https://tinc-vpn.org/git/browse?a=blobdiff_plain;f=src%2Fconnection.c;h=06f51b50aac3e4b55dfe14ffa89d7c0321a83ee6;hb=6eaefb4dbce240334e35f67d9f3db5d4f44e49c9;hp=5985cbf0c5ac4317c912c07088862b6c394c76cf;hpb=df3220a1549f992cbf4a9b6e67c1e67b69896c7d;p=tinc diff --git a/src/connection.c b/src/connection.c index 5985cbf0..06f51b50 100644 --- a/src/connection.c +++ b/src/connection.c @@ -1,7 +1,7 @@ /* connection.c -- connection list management - Copyright (C) 2000-2005 Guus Sliepen , - 2000-2005 Ivo Timmermans + Copyright (C) 2000-2007 Guus Sliepen , + 2000-2005 Ivo Timmermans 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 @@ -22,7 +22,7 @@ #include "system.h" -#include "avl_tree.h" +#include "splay_tree.h" #include "conf.h" #include "list.h" #include "logger.h" @@ -32,52 +32,44 @@ #include "utils.h" #include "xalloc.h" -avl_tree_t *connection_tree; /* Meta connections */ +splay_tree_t *connection_tree; /* Meta connections */ connection_t *broadcast; -static int connection_compare(const connection_t *a, const connection_t *b) -{ +static int connection_compare(const connection_t *a, const connection_t *b) { return (void *)a - (void *)b; } -void init_connections(void) -{ +void init_connections(void) { cp(); - connection_tree = avl_alloc_tree((avl_compare_t) connection_compare, (avl_action_t) free_connection); + connection_tree = splay_alloc_tree((splay_compare_t) connection_compare, (splay_action_t) free_connection); broadcast = new_connection(); broadcast->name = xstrdup(_("everyone")); broadcast->hostname = xstrdup(_("BROADCAST")); } -void exit_connections(void) -{ +void exit_connections(void) { cp(); - avl_delete_tree(connection_tree); + splay_delete_tree(connection_tree); free_connection(broadcast); } -connection_t *new_connection(void) -{ - connection_t *c; - +connection_t *new_connection(void) { cp(); - c = xmalloc_and_zero(sizeof(connection_t)); - - if(!c) - return NULL; - - gettimeofday(&c->start, NULL); - - return c; + return xmalloc_and_zero(sizeof(connection_t)); } -void free_connection(connection_t *c) -{ +void free_connection(connection_t *c) { cp(); + if(!c) + return; + + if(c->name) + free(c->name); + if(c->hostname) free(c->hostname); @@ -93,43 +85,46 @@ void free_connection(connection_t *c) if(c->hischallenge) free(c->hischallenge); + if(c->buffer) + bufferevent_free(c->buffer); + + if(event_initialized(&c->inevent)) + event_del(&c->inevent); + free(c); } -void connection_add(connection_t *c) -{ +void connection_add(connection_t *c) { cp(); - avl_insert(connection_tree, c); + splay_insert(connection_tree, c); } -void connection_del(connection_t *c) -{ +void connection_del(connection_t *c) { cp(); - avl_delete(connection_tree, c); + splay_delete(connection_tree, c); } -void dump_connections(void) -{ - avl_node_t *node; +int dump_connections(struct evbuffer *out) { + splay_node_t *node; connection_t *c; cp(); - logger(LOG_DEBUG, _("Connections:")); - for(node = connection_tree->head; node; node = node->next) { c = node->data; - logger(LOG_DEBUG, _(" %s at %s options %lx socket %d status %04x"), - c->name, c->hostname, c->options, c->socket, *(uint32_t *)&c->status); + if(evbuffer_add_printf(out, + _(" %s at %s options %lx socket %d status %04x\n"), + c->name, c->hostname, c->options, c->socket, + c->status.value) == -1) + return errno; } - logger(LOG_DEBUG, _("End of connections.")); + return 0; } -bool read_connection_config(connection_t *c) -{ +bool read_connection_config(connection_t *c) { char *fname; int x;