X-Git-Url: http://git.meshlink.io/?a=blobdiff_plain;f=src%2Fnet_setup.c;h=1a123cf5415665e9ead4390fde87742dc9d8ff80;hb=b055d934d156a379a219b01e53a1cbfe043ebfd1;hp=aa5b669e07d5bb4a991fc3fc0a48fdb99db48a1e;hpb=940fcb6701d055f49530f12c93371f0280efce80;p=meshlink diff --git a/src/net_setup.c b/src/net_setup.c index aa5b669e..1a123cf5 100644 --- a/src/net_setup.c +++ b/src/net_setup.c @@ -1,7 +1,6 @@ /* net_setup.c -- Setup. - Copyright (C) 1998-2002 Ivo Timmermans , - 2000-2002 Guus Sliepen + Copyright (C) 2014-2017 Guus Sliepen 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 @@ -13,587 +12,480 @@ MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU General Public License for more details. - You should have received a copy of the GNU General Public License - along with this program; if not, write to the Free Software - Foundation, Inc., 675 Mass Ave, Cambridge, MA 02139, USA. - - $Id: net_setup.c,v 1.1.2.19 2002/06/13 16:12:40 guus Exp $ + You should have received a copy of the GNU General Public License along + with this program; if not, write to the Free Software Foundation, Inc., + 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301 USA. */ -#include "config.h" - -#include -#include -#include -#include -#ifdef HAVE_NETINET_IN_SYSTM_H - #include -#endif -#ifdef HAVE_NETINET_IP_H - #include -#endif -#ifdef HAVE_NETINET_TCP_H - #include -#endif -#include -#include -#include -#include -#include -#include -#include -#include -#include -/* SunOS really wants sys/socket.h BEFORE net/if.h, - and FreeBSD wants these lines below the rest. */ -#include -#include -#include - -#include -#include -#include - -#include -#include -#include -#include +#include "system.h" #include "conf.h" #include "connection.h" -#include "meta.h" +#include "ecdsa.h" +#include "graph.h" +#include "logger.h" +#include "meshlink_internal.h" #include "net.h" #include "netutl.h" -#include "process.h" +#include "packmsg.h" #include "protocol.h" -#include "subnet.h" -#include "graph.h" -#include "process.h" #include "route.h" -#include "device.h" -#include "event.h" +#include "utils.h" +#include "xalloc.h" +#include "submesh.h" + +/// Helper function to start parsing a host config file +static bool node_get_config(meshlink_handle_t *mesh, node_t *n, config_t *config, packmsg_input_t *in) { + if(!config_read(mesh, "current", n->name, config, mesh->config_key)) { + return false; + } -#include "system.h" + in->ptr = config->buf; + in->len = config->len; + + uint32_t version = packmsg_get_uint32(in); + + if(version != MESHLINK_CONFIG_VERSION) { + logger(mesh, MESHLINK_ERROR, "Invalid config file for node %s", n->name); + config_free(config); + return false; + } + + const char *name; + uint32_t len = packmsg_get_str_raw(in, &name); -char *myport; - -int read_rsa_public_key(connection_t *c) -{ - FILE *fp; - char *fname; - char *key; -cp - if(!c->rsa_key) - c->rsa_key = RSA_new(); - - /* First, check for simple PublicKey statement */ - - if(get_config_string(lookup_config(c->config_tree, "PublicKey"), &key)) - { - BN_hex2bn(&c->rsa_key->n, key); - BN_hex2bn(&c->rsa_key->e, "FFFF"); - free(key); - return 0; - } - - /* Else, check for PublicKeyFile statement and read it */ - - if(get_config_string(lookup_config(c->config_tree, "PublicKeyFile"), &fname)) - { - if(is_safe_path(fname)) - { - if((fp = fopen(fname, "r")) == NULL) - { - syslog(LOG_ERR, _("Error reading RSA public key file `%s': %s"), - fname, strerror(errno)); - free(fname); - return -1; - } - free(fname); - c->rsa_key = PEM_read_RSAPublicKey(fp, &c->rsa_key, NULL, NULL); - fclose(fp); - if(c->rsa_key) - return 0; /* Woohoo. */ - - /* If it fails, try PEM_read_RSA_PUBKEY. */ - if((fp = fopen(fname, "r")) == NULL) - { - syslog(LOG_ERR, _("Error reading RSA public key file `%s': %s"), - fname, strerror(errno)); - free(fname); - return -1; - } - free(fname); - c->rsa_key = PEM_read_RSA_PUBKEY(fp, &c->rsa_key, NULL, NULL); - fclose(fp); - if(c->rsa_key) - return 0; - - syslog(LOG_ERR, _("Reading RSA public key file `%s' failed: %s"), - fname, strerror(errno)); - return -1; - } - else - { - free(fname); - return -1; - } - } - - /* Else, check if a harnessed public key is in the config file */ - - asprintf(&fname, "%s/hosts/%s", confbase, c->name); - if((fp = fopen(fname, "r"))) - { - c->rsa_key = PEM_read_RSAPublicKey(fp, &c->rsa_key, NULL, NULL); - fclose(fp); - } - - free(fname); - - if(c->rsa_key) - return 0; - - /* Try again with PEM_read_RSA_PUBKEY. */ - - asprintf(&fname, "%s/hosts/%s", confbase, c->name); - if((fp = fopen(fname, "r"))) - { - c->rsa_key = PEM_read_RSA_PUBKEY(fp, &c->rsa_key, NULL, NULL); - fclose(fp); - } - - free(fname); - - if(c->rsa_key) - return 0; - - syslog(LOG_ERR, _("No public key for %s specified!"), c->name); - return -1; + if(len != strlen(n->name) || !name || strncmp(name, n->name, len)) { + logger(mesh, MESHLINK_ERROR, "Invalid config file for node %s", n->name); + config_free(config); + return false; + } + + return true; } -int read_rsa_private_key(void) -{ - FILE *fp; - char *fname, *key; -cp - if(get_config_string(lookup_config(config_tree, "PrivateKey"), &key)) - { - myself->connection->rsa_key = RSA_new(); - BN_hex2bn(&myself->connection->rsa_key->d, key); - BN_hex2bn(&myself->connection->rsa_key->e, "FFFF"); - free(key); - return 0; - } - - if(!get_config_string(lookup_config(config_tree, "PrivateKeyFile"), &fname)) - asprintf(&fname, "%s/rsa_key.priv", confbase); - - if(is_safe_path(fname)) - { - if((fp = fopen(fname, "r")) == NULL) - { - syslog(LOG_ERR, _("Error reading RSA private key file `%s': %s"), - fname, strerror(errno)); - free(fname); - return -1; - } - free(fname); - myself->connection->rsa_key = PEM_read_RSAPrivateKey(fp, NULL, NULL, NULL); - fclose(fp); - if(!myself->connection->rsa_key) - { - syslog(LOG_ERR, _("Reading RSA private key file `%s' failed: %s"), - fname, strerror(errno)); - return -1; - } - return 0; - } - - free(fname); - return -1; +/// Read the public key from a host config file. Used whenever we need to start an SPTPS session. +bool node_read_public_key(meshlink_handle_t *mesh, node_t *n) { + if(ecdsa_active(n->ecdsa)) { + return true; + } + + config_t config; + packmsg_input_t in; + + if(!node_get_config(mesh, n, &config, &in)) { + return false; + } + + packmsg_skip_element(&in); /* submesh */ + packmsg_get_int32(&in); /* devclass */ + packmsg_get_bool(&in); /* blacklisted */ + + const void *key; + uint32_t len = packmsg_get_bin_raw(&in, &key); + + if(len != 32) { + config_free(&config); + return false; + } + + n->ecdsa = ecdsa_set_public_key(key); + + // While we are at it, read known address information + if(!n->canonical_address) { + n->canonical_address = packmsg_get_str_dup(&in); + } else { + packmsg_skip_element(&in); + } + + // Append any known addresses in the config file to the list we currently have + uint32_t known_count = 0; + + for(uint32_t i = 0; i < 5; i++) { + if(n->recent[i].sa.sa_family) { + known_count++; + } + } + + uint32_t count = packmsg_get_array(&in); + + if(count > 5 - known_count) { + count = 5 - known_count; + } + + for(uint32_t i = 0; i < count; i++) { + n->recent[i + known_count] = packmsg_get_sockaddr(&in); + } + + + config_free(&config); + return true; +} + +/// Fill in node details from a config blob. +bool node_read_from_config(meshlink_handle_t *mesh, node_t *n, const config_t *config) { + if(n->canonical_address) { + return true; + } + + packmsg_input_t in = {config->buf, config->len}; + uint32_t version = packmsg_get_uint32(&in); + + if(version != MESHLINK_CONFIG_VERSION) { + return false; + } + + char *name = packmsg_get_str_dup(&in); + + if(!name) { + return false; + } + + if(n->name) { + if(strcmp(n->name, name)) { + free(name); + return false; + } + + free(name); + } else { + n->name = name; + } + + char *submesh_name = packmsg_get_str_dup(&in); + + if(!strcmp(submesh_name, CORE_MESH)) { + free(submesh_name); + n->submesh = NULL; + } else { + n->submesh = lookup_or_create_submesh(mesh, submesh_name); + free(submesh_name); + + if(!n->submesh) { + return false; + } + } + + n->devclass = packmsg_get_int32(&in); + n->status.blacklisted = packmsg_get_bool(&in); + const void *key; + uint32_t len = packmsg_get_bin_raw(&in, &key); + + if(len != 32) { + return false; + } + + if(!ecdsa_active(n->ecdsa)) { + n->ecdsa = ecdsa_set_public_key(key); + } + + n->canonical_address = packmsg_get_str_dup(&in); + uint32_t count = packmsg_get_array(&in); + + if(count > 5) { + count = 5; + } + + for(uint32_t i = 0; i < count; i++) { + n->recent[i] = packmsg_get_sockaddr(&in); + } + + return packmsg_done(&in); +} + +bool node_write_config(meshlink_handle_t *mesh, node_t *n) { + if(!mesh->confbase) { + return true; + } + + uint8_t buf[4096]; + packmsg_output_t out = {buf, sizeof(buf)}; + + packmsg_add_uint32(&out, MESHLINK_CONFIG_VERSION); + packmsg_add_str(&out, n->name); + packmsg_add_str(&out, n->submesh ? n->submesh->name : CORE_MESH); + packmsg_add_int32(&out, n->devclass); + packmsg_add_bool(&out, n->status.blacklisted); + + if(ecdsa_active(n->ecdsa)) { + packmsg_add_bin(&out, ecdsa_get_public_key(n->ecdsa), 32); + } else { + packmsg_add_bin(&out, "", 0); + } + + packmsg_add_str(&out, n->canonical_address ? n->canonical_address : ""); + + uint32_t count = 0; + + for(uint32_t i = 0; i < 5; i++) { + if(n->recent[i].sa.sa_family) { + count++; + } else { + break; + } + } + + packmsg_add_array(&out, count); + + for(uint32_t i = 0; i < count; i++) { + packmsg_add_sockaddr(&out, &n->recent[i]); + } + + if(!packmsg_output_ok(&out)) { + return false; + } + + config_t config = {buf, packmsg_output_size(&out, buf)}; + + if(!config_write(mesh, "current", n->name, &config, mesh->config_key)) { + call_error_cb(mesh, MESHLINK_ESTORAGE); + return false; + } + + return true; +} + +static bool load_node(meshlink_handle_t *mesh, const char *name, void *priv) { + (void)priv; + + if(!check_id(name)) { + return true; + } + + node_t *n = lookup_node(mesh, name); + + if(n) { + return true; + } + + n = new_node(); + n->name = xstrdup(name); + + config_t config; + packmsg_input_t in; + + if(!node_get_config(mesh, n, &config, &in)) { + free_node(n); + return false; + } + + if(!node_read_from_config(mesh, n, &config)) { + logger(mesh, MESHLINK_ERROR, "Invalid config file for node %s", n->name); + config_free(&config); + free_node(n); + return false; + } + + config_free(&config); + + node_add(mesh, n); + + return true; +} + +/* + Add listening sockets. +*/ +static bool add_listen_address(meshlink_handle_t *mesh, char *address, bool bindto) { + char *port = mesh->myport; + + if(address) { + char *space = strchr(address, ' '); + + if(space) { + *space++ = 0; + port = space; + } + + if(!strcmp(address, "*")) { + *address = 0; + } + } + + struct addrinfo *ai; + + struct addrinfo hint = { + .ai_family = AF_UNSPEC, + .ai_socktype = SOCK_STREAM, + .ai_protocol = IPPROTO_TCP, + .ai_flags = AI_PASSIVE, + }; + + int err = getaddrinfo(address && *address ? address : NULL, port, &hint, &ai); + + free(address); + + if(err || !ai) { + logger(mesh, MESHLINK_ERROR, "System call `%s' failed: %s", "getaddrinfo", err == EAI_SYSTEM ? strerror(err) : gai_strerror(err)); + return false; + } + + bool success = false; + + for(struct addrinfo *aip = ai; aip; aip = aip->ai_next) { + // Ignore duplicate addresses + bool found = false; + + for(int i = 0; i < mesh->listen_sockets; i++) + if(!memcmp(&mesh->listen_socket[i].sa, aip->ai_addr, aip->ai_addrlen)) { + found = true; + break; + } + + if(found) { + continue; + } + + if(mesh->listen_sockets >= MAXSOCKETS) { + logger(mesh, MESHLINK_ERROR, "Too many listening sockets"); + return false; + } + + int tcp_fd = setup_listen_socket((sockaddr_t *) aip->ai_addr); + + if(tcp_fd < 0) { + continue; + } + + int udp_fd = setup_vpn_in_socket(mesh, (sockaddr_t *) aip->ai_addr); + + if(udp_fd < 0) { + close(tcp_fd); + continue; + } + + io_add(&mesh->loop, &mesh->listen_socket[mesh->listen_sockets].tcp, handle_new_meta_connection, &mesh->listen_socket[mesh->listen_sockets], tcp_fd, IO_READ); + io_add(&mesh->loop, &mesh->listen_socket[mesh->listen_sockets].udp, handle_incoming_vpn_data, &mesh->listen_socket[mesh->listen_sockets], udp_fd, IO_READ); + + if(mesh->log_level >= MESHLINK_INFO) { + char *hostname = sockaddr2hostname((sockaddr_t *) aip->ai_addr); + logger(mesh, MESHLINK_INFO, "Listening on %s", hostname); + free(hostname); + } + + mesh->listen_socket[mesh->listen_sockets].bindto = bindto; + memcpy(&mesh->listen_socket[mesh->listen_sockets].sa, aip->ai_addr, aip->ai_addrlen); + memcpy(&mesh->listen_socket[mesh->listen_sockets].broadcast_sa, aip->ai_addr, aip->ai_addrlen); + + if(aip->ai_family == AF_INET6) { + mesh->listen_socket[mesh->listen_sockets].broadcast_sa.in6.sin6_addr.s6_addr[0x0] = 0xff; + mesh->listen_socket[mesh->listen_sockets].broadcast_sa.in6.sin6_addr.s6_addr[0x1] = 0x02; + mesh->listen_socket[mesh->listen_sockets].broadcast_sa.in6.sin6_addr.s6_addr[0xf] = 0x01; + } else { + mesh->listen_socket[mesh->listen_sockets].broadcast_sa.in.sin_addr.s_addr = 0xffffffff; + } + + mesh->listen_sockets++; + success = true; + } + + freeaddrinfo(ai); + return success; } /* - Configure node_t myself and set up the local sockets (listen only) + Configure node_t mesh->self and set up the local sockets (listen only) */ -int setup_myself(void) -{ - config_t *cfg; - subnet_t *subnet; - char *name, *hostname, *mode, *afname, *cipher, *digest; - char *address = NULL; - struct addrinfo hint, *ai, *aip; - int choice, err; -cp - myself = new_node(); - myself->connection = new_connection(); - init_configuration(&myself->connection->config_tree); - - asprintf(&myself->hostname, _("MYSELF")); - asprintf(&myself->connection->hostname, _("MYSELF")); - - myself->connection->options = 0; - myself->connection->protocol_version = PROT_CURRENT; - - if(!get_config_string(lookup_config(config_tree, "Name"), &name)) /* Not acceptable */ - { - syslog(LOG_ERR, _("Name for tinc daemon required!")); - return -1; - } - - if(check_id(name)) - { - syslog(LOG_ERR, _("Invalid name for myself!")); - free(name); - return -1; - } - - myself->name = name; - myself->connection->name = xstrdup(name); - -cp - if(read_rsa_private_key()) - return -1; - - if(read_connection_config(myself->connection)) - { - syslog(LOG_ERR, _("Cannot open host configuration file for myself!")); - return -1; - } - - if(read_rsa_public_key(myself->connection)) - return -1; -cp - - if(!get_config_string(lookup_config(myself->connection->config_tree, "Port"), &myport)) - asprintf(&myport, "655"); - -/* Read in all the subnets specified in the host configuration file */ - - cfg = lookup_config(myself->connection->config_tree, "Subnet"); - - while(cfg) - { - if(!get_config_subnet(cfg, &subnet)) - return -1; - - subnet_add(myself, subnet); - - cfg = lookup_config_next(myself->connection->config_tree, cfg); - } - -cp - /* Check some options */ - - if(get_config_bool(lookup_config(config_tree, "IndirectData"), &choice)) - if(choice) - myself->options |= OPTION_INDIRECT; - - if(get_config_bool(lookup_config(config_tree, "TCPOnly"), &choice)) - if(choice) - myself->options |= OPTION_TCPONLY; - - if(get_config_bool(lookup_config(myself->connection->config_tree, "IndirectData"), &choice)) - if(choice) - myself->options |= OPTION_INDIRECT; - - if(get_config_bool(lookup_config(myself->connection->config_tree, "TCPOnly"), &choice)) - if(choice) - myself->options |= OPTION_TCPONLY; - - if(myself->options & OPTION_TCPONLY) - myself->options |= OPTION_INDIRECT; - - if(get_config_string(lookup_config(config_tree, "Mode"), &mode)) - { - if(!strcasecmp(mode, "router")) - routing_mode = RMODE_ROUTER; - else if (!strcasecmp(mode, "switch")) - routing_mode = RMODE_SWITCH; - else if (!strcasecmp(mode, "hub")) - routing_mode = RMODE_HUB; - else - { - syslog(LOG_ERR, _("Invalid routing mode!")); - return -1; - } - free(mode); - } - else - routing_mode = RMODE_ROUTER; - - get_config_bool(lookup_config(config_tree, "PriorityInheritance"), &priorityinheritance); -#if !defined(SOL_IP) || !defined(IP_TOS) - if(priorityinheritance) - syslog(LOG_WARNING, _("PriorityInheritance not supported on this platform")); -#endif - - if(!get_config_int(lookup_config(config_tree, "MACExpire"), &macexpire)) - macexpire= 600; - - if(get_config_int(lookup_config(myself->connection->config_tree, "MaxTimeout"), &maxtimeout)) - { - if(maxtimeout <= 0) - { - syslog(LOG_ERR, _("Bogus maximum timeout!")); - return -1; - } - } - else - maxtimeout = 900; - - if(get_config_string(lookup_config(config_tree, "AddressFamily"), &afname)) - { - if(!strcasecmp(afname, "IPv4")) - addressfamily = AF_INET; - else if (!strcasecmp(afname, "IPv6")) - addressfamily = AF_INET6; - else if (!strcasecmp(afname, "any")) - addressfamily = AF_UNSPEC; - else - { - syslog(LOG_ERR, _("Invalid address family!")); - return -1; - } - free(afname); - } - else - addressfamily = AF_INET; - - get_config_bool(lookup_config(config_tree, "Hostnames"), &hostnames); -cp - /* Generate packet encryption key */ - - if(get_config_string(lookup_config(myself->connection->config_tree, "Cipher"), &cipher)) - { - if(!strcasecmp(cipher, "none")) - { - myself->cipher = NULL; - } - else - { - if(!(myself->cipher = EVP_get_cipherbyname(cipher))) - { - syslog(LOG_ERR, _("Unrecognized cipher type!")); - return -1; - } - } - } - else - myself->cipher = EVP_bf_cbc(); - - if(myself->cipher) - myself->keylength = myself->cipher->key_len + myself->cipher->iv_len; - else - myself->keylength = 1; - - myself->connection->outcipher = EVP_bf_ofb(); - - myself->key = (char *)xmalloc(myself->keylength); - RAND_pseudo_bytes(myself->key, myself->keylength); - - if(!get_config_int(lookup_config(config_tree, "KeyExpire"), &keylifetime)) - keylifetime = 3600; - - keyexpires = now + keylifetime; - - /* Check if we want to use message authentication codes... */ - - if(get_config_string(lookup_config(myself->connection->config_tree, "Digest"), &digest)) - { - if(!strcasecmp(digest, "none")) - { - myself->digest = NULL; - } - else - { - if(!(myself->digest = EVP_get_digestbyname(digest))) - { - syslog(LOG_ERR, _("Unrecognized digest type!")); - return -1; - } - } - } - else - myself->digest = EVP_sha1(); - - myself->connection->outdigest = EVP_sha1(); - - if(get_config_int(lookup_config(myself->connection->config_tree, "MACLength"), &myself->maclength)) - { - if(myself->digest) - { - if(myself->maclength > myself->digest->md_size) - { - syslog(LOG_ERR, _("MAC length exceeds size of digest!")); - return -1; - } - else if (myself->maclength < 0) - { - syslog(LOG_ERR, _("Bogus MAC length!")); - return -1; - } - } - } - else - myself->maclength = 4; - - myself->connection->outmaclength = 0; - - /* Compression */ - - if(get_config_int(lookup_config(myself->connection->config_tree, "Compression"), &myself->compression)) - { - if(myself->compression < 0 || myself->compression > 9) - { - syslog(LOG_ERR, _("Bogus compression level!")); - return -1; - } - } - else - myself->compression = 0; - - myself->connection->outcompression = 0; -cp - /* Done */ - - myself->nexthop = myself; - myself->via = myself; - myself->status.active = 1; - myself->status.reachable = 1; - node_add(myself); - - graph(); - -cp - /* Open sockets */ - - memset(&hint, 0, sizeof(hint)); - - get_config_string(lookup_config(config_tree, "BindToAddress"), &address); - - hint.ai_family = addressfamily; - hint.ai_socktype = SOCK_STREAM; - hint.ai_protocol = IPPROTO_TCP; - hint.ai_flags = AI_PASSIVE; - - if((err = getaddrinfo(address, myport, &hint, &ai)) || !ai) - { - syslog(LOG_ERR, _("System call `%s' failed: %s"), "getaddrinfo", gai_strerror(err)); - return -1; - } - - listen_sockets = 0; - - for(aip = ai; aip; aip = aip->ai_next) - { - if((listen_socket[listen_sockets].tcp = setup_listen_socket((sockaddr_t *)aip->ai_addr)) < 0) - continue; - - if((listen_socket[listen_sockets].udp = setup_vpn_in_socket((sockaddr_t *)aip->ai_addr)) < 0) - continue; - - if(debug_lvl >= DEBUG_CONNECTIONS) - { - hostname = sockaddr2hostname((sockaddr_t *)aip->ai_addr); - syslog(LOG_NOTICE, _("Listening on %s"), hostname); - free(hostname); - } - - listen_socket[listen_sockets].sa.sa = *aip->ai_addr; - listen_sockets++; - } - - freeaddrinfo(ai); - - if(listen_sockets) - syslog(LOG_NOTICE, _("Ready")); - else - { - syslog(LOG_ERR, _("Unable to create any listening socket!")); - return -1; - } -cp - return 0; +bool setup_myself(meshlink_handle_t *mesh) { + /* Set some defaults */ + + mesh->maxtimeout = 900; + + /* Done */ + + mesh->self->nexthop = mesh->self; + mesh->self->status.reachable = true; + mesh->self->last_state_change = mesh->loop.now.tv_sec; + + node_add(mesh, mesh->self); + + graph(mesh); + + if(!config_scan_all(mesh, "current", "hosts", load_node, NULL)) { + meshlink_errno = MESHLINK_ESTORAGE; + return false; + } + + /* Open sockets */ + + mesh->listen_sockets = 0; + + if(!add_listen_address(mesh, NULL, NULL)) { + if(strcmp(mesh->myport, "0")) { + logger(mesh, MESHLINK_INFO, "Could not bind to port %s, asking OS to choose one for us", mesh->myport); + free(mesh->myport); + mesh->myport = strdup("0"); + + if(!mesh->myport) { + return false; + } + + if(!add_listen_address(mesh, NULL, NULL)) { + return false; + } + } else { + return false; + } + } + + if(!mesh->listen_sockets) { + logger(mesh, MESHLINK_ERROR, "Unable to create any listening socket!"); + return false; + } + + /* Done. */ + + mesh->last_config_check = mesh->loop.now.tv_sec; + + return true; } /* - setup all initial network connections + initialize network */ -int setup_network_connections(void) -{ -cp - now = time(NULL); - - init_connections(); - init_subnets(); - init_nodes(); - init_edges(); - init_events(); - init_requests(); - - if(get_config_int(lookup_config(config_tree, "PingTimeout"), &pingtimeout)) - { - if(pingtimeout < 1) - { - pingtimeout = 86400; - } - } - else - pingtimeout = 60; - - if(setup_device() < 0) - return -1; - - /* Run tinc-up script to further initialize the tap interface */ - execute_script("tinc-up"); - - if(setup_myself() < 0) - return -1; - - try_outgoing_connections(); -cp - return 0; +bool setup_network(meshlink_handle_t *mesh) { + init_connections(mesh); + init_submeshes(mesh); + init_nodes(mesh); + init_edges(mesh); + init_requests(mesh); + + if(!setup_myself(mesh)) { + return false; + } + + return true; } /* close all open network connections */ -void close_network_connections(void) -{ - avl_node_t *node, *next; - connection_t *c; - int i; -cp - for(node = connection_tree->head; node; node = next) - { - next = node->next; - c = (connection_t *)node->data; - if(c->outgoing) - free(c->outgoing->name), free(c->outgoing), c->outgoing = NULL; - terminate_connection(c, 0); - } - - if(myself && myself->connection) - terminate_connection(myself->connection, 0); - - for(i = 0; i < listen_sockets; i++) - { - close(listen_socket[i].tcp); - close(listen_socket[i].udp); - } - - exit_requests(); - exit_events(); - exit_edges(); - exit_subnets(); - exit_nodes(); - exit_connections(); - - execute_script("tinc-down"); - - close_device(); -cp - return; +void close_network_connections(meshlink_handle_t *mesh) { + if(mesh->connections) { + for(list_node_t *node = mesh->connections->head, *next; node; node = next) { + next = node->next; + connection_t *c = node->data; + c->outgoing = NULL; + terminate_connection(mesh, c, false); + } + } + + for(int i = 0; i < mesh->listen_sockets; i++) { + io_del(&mesh->loop, &mesh->listen_socket[i].tcp); + io_del(&mesh->loop, &mesh->listen_socket[i].udp); + close(mesh->listen_socket[i].tcp.fd); + close(mesh->listen_socket[i].udp.fd); + } + + exit_requests(mesh); + exit_edges(mesh); + exit_nodes(mesh); + exit_submeshes(mesh); + exit_connections(mesh); + + free(mesh->myport); + mesh->myport = NULL; + + mesh->self = NULL; + + return; }