X-Git-Url: https://tinc-vpn.org/git/browse?p=tinc;a=blobdiff_plain;f=src%2Fconnection.c;h=0e61132c9182a637278b8fe87053962ef23481a8;hp=2372890dd393d6e9ff122a708f6ee2510c157d2a;hb=c2dc3784f127ef6db6e9960a4abecc1aab6f4e31;hpb=c4afc481541bff4db7f57c81796b7a5f61cdb1b5 diff --git a/src/connection.c b/src/connection.c index 2372890d..0e61132c 100644 --- a/src/connection.c +++ b/src/connection.c @@ -1,6 +1,6 @@ /* connection.c -- connection list management - Copyright (C) 2000-2009 Guus Sliepen , + Copyright (C) 2000-2013 Guus Sliepen , 2000-2005 Ivo Timmermans 2008 Max Rijevski @@ -21,99 +21,85 @@ #include "system.h" -#include "splay_tree.h" +#include "list.h" #include "cipher.h" #include "conf.h" +#include "control_common.h" #include "list.h" #include "logger.h" -#include "net.h" /* Don't ask. */ -#include "netutl.h" +#include "rsa.h" #include "subnet.h" #include "utils.h" #include "xalloc.h" -splay_tree_t *connection_tree; /* Meta connections */ -connection_t *broadcast; - -static int connection_compare(const connection_t *a, const connection_t *b) { - return a < b ? -1 : a == b ? 0 : 1; -} +list_t *connection_list; +connection_t *everyone; void init_connections(void) { - 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"); + connection_list = list_alloc((list_action_t) free_connection); + everyone = new_connection(); + everyone->name = xstrdup("everyone"); + everyone->hostname = xstrdup("BROADCAST"); } void exit_connections(void) { - splay_delete_tree(connection_tree); - free_connection(broadcast); + list_delete_list(connection_list); + free_connection(everyone); } connection_t *new_connection(void) { - return xmalloc_and_zero(sizeof(connection_t)); + return xzalloc(sizeof(connection_t)); } void free_connection(connection_t *c) { if(!c) return; - if(c->name) - free(c->name); +#ifndef DISABLE_LEGACY + cipher_close(c->incipher); + digest_close(c->indigest); + cipher_close(c->outcipher); + digest_close(c->outdigest); + rsa_free(c->rsa); +#endif + + sptps_stop(&c->sptps); + ecdsa_free(c->ecdsa); + + free(c->hischallenge); + + buffer_clear(&c->inbuf); + buffer_clear(&c->outbuf); - if(c->hostname) - free(c->hostname); + io_del(&c->io); - cipher_close(&c->incipher); - cipher_close(&c->outcipher); + if(c->socket > 0) + closesocket(c->socket); - if(c->hischallenge) - free(c->hischallenge); + free(c->name); + free(c->hostname); if(c->config_tree) exit_configuration(&c->config_tree); - if(c->buffer) - bufferevent_free(c->buffer); - - if(event_initialized(&c->inevent)) - event_del(&c->inevent); - free(c); } void connection_add(connection_t *c) { - splay_insert(connection_tree, c); + list_insert_tail(connection_list, c); } void connection_del(connection_t *c) { - splay_delete(connection_tree, c); + list_delete(connection_list, c); } -int dump_connections(struct evbuffer *out) { - splay_node_t *node; - connection_t *c; - - for(node = connection_tree->head; node; node = node->next) { - c = node->data; - if(evbuffer_add_printf(out, - " %s at %s options %x socket %d status %04x\n", - c->name, c->hostname, c->options, c->socket, - bitfield_to_int(&c->status, sizeof c->status)) == -1) - return errno; +bool dump_connections(connection_t *cdump) { + for list_each(connection_t, c, connection_list) { + send_request(cdump, "%d %d %s %s %x %d %x", + CONTROL, REQ_DUMP_CONNECTIONS, + c->name, c->hostname, c->options, c->socket, + bitfield_to_int(&c->status, sizeof c->status)); } - return 0; -} - -bool read_connection_config(connection_t *c) { - char *fname; - int x; - - xasprintf(&fname, "%s/hosts/%s", confbase, c->name); - x = read_config_file(c->config_tree, fname); - free(fname); - - return x == 0; + return send_request(cdump, "%d %d", CONTROL, REQ_DUMP_CONNECTIONS); }