X-Git-Url: https://tinc-vpn.org/git/browse?a=blobdiff_plain;f=src%2Fconnection.c;h=b61609ad16010543f0c520ac0264a44e371f5eec;hb=65d6f023c46ac3a087f59b60762f87c869783f21;hp=fecb48d42d141d37a1830e039fd91e8d629736d9;hpb=ce8775000ab38229a78ecf3dc26bab008ca0f332;p=tinc diff --git a/src/connection.c b/src/connection.c index fecb48d4..b61609ad 100644 --- a/src/connection.c +++ b/src/connection.c @@ -27,14 +27,12 @@ #include "control_common.h" #include "list.h" #include "logger.h" -#include "net.h" /* Don't ask. */ -#include "netutl.h" #include "subnet.h" #include "utils.h" #include "xalloc.h" splay_tree_t *connection_tree; /* Meta connections */ -connection_t *broadcast; +connection_t *everyone; static int connection_compare(const connection_t *a, const connection_t *b) { return a < b ? -1 : a == b ? 0 : 1; @@ -42,14 +40,14 @@ static int connection_compare(const connection_t *a, const connection_t *b) { 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"); + everyone = new_connection(); + everyone->name = xstrdup("everyone"); + everyone->hostname = xstrdup("BROADCAST"); } void exit_connections(void) { splay_delete_tree(connection_tree); - free_connection(broadcast); + free_connection(everyone); } connection_t *new_connection(void) { @@ -67,7 +65,13 @@ void free_connection(connection_t *c) { free(c->hostname); cipher_close(&c->incipher); + digest_close(&c->indigest); cipher_close(&c->outcipher); + digest_close(&c->outdigest); + + stop_sptps(&c->sptps); + ecdsa_free(&c->ecdsa); + rsa_free(&c->rsa); if(c->hischallenge) free(c->hischallenge); @@ -75,12 +79,18 @@ void free_connection(connection_t *c) { if(c->config_tree) exit_configuration(&c->config_tree); - if(c->buffer) - bufferevent_free(c->buffer); + buffer_clear(&c->inbuf); + buffer_clear(&c->outbuf); if(event_initialized(&c->inevent)) event_del(&c->inevent); + if(event_initialized(&c->outevent)) + event_del(&c->outevent); + + if(c->socket > 0) + closesocket(c->socket); + free(c); }