#include "system.h"
+#include "adns.h"
#include "conf.h"
#include "connection.h"
#include "list.h"
#endif
}
-bool setup_listen_socket(meshlink_handle_t *mesh, int nfd, int sa_family) {
-#ifdef FD_CLOEXEC
- fcntl(nfd, F_SETFD, FD_CLOEXEC);
-#endif
-
- int option = 1;
- setsockopt(nfd, SOL_SOCKET, SO_REUSEADDR, (void *)&option, sizeof(option));
-
-#if defined(IPV6_V6ONLY)
-
- if(sa_family == AF_INET6) {
- setsockopt(nfd, IPPROTO_IPV6, IPV6_V6ONLY, (void *)&option, sizeof(option));
- }
-
-#else
-#warning IPV6_V6ONLY not defined
-#endif
-
- if(listen(nfd, 3)) {
- logger(mesh, MESHLINK_ERROR, "System call `%s' failed: %s", "listen", sockstrerror(sockerrno));
- return false;
- }
-
- return true;
-}
-
-bool setup_vpn_in_socket(meshlink_handle_t *mesh, int nfd, int sa_family) {
-#ifdef FD_CLOEXEC
- fcntl(nfd, F_SETFD, FD_CLOEXEC);
-#endif
-
-#ifdef O_NONBLOCK
- {
- int flags = fcntl(nfd, F_GETFL);
-
- if(fcntl(nfd, F_SETFL, flags | O_NONBLOCK) < 0) {
- closesocket(nfd);
- logger(mesh, MESHLINK_ERROR, "System call `%s' failed: %s", "fcntl",
- strerror(errno));
- return false;
- }
- }
-#elif defined(WIN32)
- {
- unsigned long arg = 1;
-
- if(ioctlsocket(nfd, FIONBIO, &arg) != 0) {
- closesocket(nfd);
- logger(mesh, MESHLINK_ERROR, "Call to `%s' failed: %s", "ioctlsocket", sockstrerror(sockerrno));
- return false;
- }
- }
-#endif
-
- int option = 1;
- setsockopt(nfd, SOL_SOCKET, SO_REUSEADDR, (void *)&option, sizeof(option));
- setsockopt(nfd, SOL_SOCKET, SO_BROADCAST, (void *)&option, sizeof(option));
-
-#if defined(IPV6_V6ONLY)
-
- if(sa_family == AF_INET6) {
- setsockopt(nfd, IPPROTO_IPV6, IPV6_V6ONLY, (void *)&option, sizeof(option));
- }
-
-#endif
-
-#if defined(IP_DONTFRAG) && !defined(IP_DONTFRAGMENT)
-#define IP_DONTFRAGMENT IP_DONTFRAG
-#endif
-
-#if defined(IP_MTU_DISCOVER) && defined(IP_PMTUDISC_DO)
- option = IP_PMTUDISC_DO;
- setsockopt(nfd, IPPROTO_IP, IP_MTU_DISCOVER, (void *)&option, sizeof(option));
-#elif defined(IP_DONTFRAGMENT)
- option = 1;
- setsockopt(nfd, IPPROTO_IP, IP_DONTFRAGMENT, (void *)&option, sizeof(option));
-#endif
-
-#if defined(IPV6_MTU_DISCOVER) && defined(IPV6_PMTUDISC_DO)
- option = IPV6_PMTUDISC_DO;
- setsockopt(nfd, IPPROTO_IPV6, IPV6_MTU_DISCOVER, (void *)&option, sizeof(option));
-#elif defined(IPV6_DONTFRAG)
- option = 1;
- setsockopt(nfd, IPPROTO_IPV6, IPV6_DONTFRAG, (void *)&option, sizeof(option));
-#endif
-
- return true;
-} /* int setup_vpn_in_socket */
-
static void retry_outgoing_handler(event_loop_t *loop, void *data) {
assert(data);
outgoing->timeout = mesh->maxtimeout;
}
- timeout_add(&mesh->loop, &outgoing->ev, retry_outgoing_handler, outgoing, &(struct timeval) {
+ timeout_add(&mesh->loop, &outgoing->ev, retry_outgoing_handler, outgoing, &(struct timespec) {
outgoing->timeout, prng(mesh, TIMER_FUDGE)
});
}
}
-static struct addrinfo *get_canonical_address(node_t *n) {
- if(!n->canonical_address) {
- return false;
- }
-
- char *address = xstrdup(n->canonical_address);
- char *port = strchr(address, ' ');
+static void canonical_resolve_cb(meshlink_handle_t *mesh, char *host, char *serv, void *data, struct addrinfo *ai, int err) {
+ (void)serv;
+ (void)err;
+ node_t *n = data;
+
+ free(host);
+ free(serv);
+
+ for list_each(outgoing_t, outgoing, mesh->outgoings) {
+ if(outgoing->node == n) {
+ if(outgoing->state == OUTGOING_CANONICAL_RESOLVE) {
+ outgoing->ai = ai;
+ outgoing->aip = NULL;
+ outgoing->state = OUTGOING_CANONICAL;
+ do_outgoing_connection(mesh, outgoing);
+ }
- if(!port) {
- free(address);
- return false;
+ return;
+ }
}
-
- *port++ = 0;
-
- struct addrinfo *ai = str2addrinfo(address, port, SOCK_STREAM);
- free(address);
-
- return ai;
}
static bool get_next_outgoing_address(meshlink_handle_t *mesh, outgoing_t *outgoing) {
if(outgoing->state == OUTGOING_START) {
start = true;
- outgoing->state = OUTGOING_CANONICAL;
+ outgoing->state = OUTGOING_CANONICAL_RESOLVE;
+ }
+
+ if(outgoing->state == OUTGOING_CANONICAL_RESOLVE) {
+ node_t *n = outgoing->node;
+
+ if(n->canonical_address) {
+ char *address = xstrdup(n->canonical_address);
+ char *port = strchr(address, ' ');
+
+ if(port) {
+ *port++ = 0;
+ port = xstrdup(port);
+ adns_queue(mesh, address, port, canonical_resolve_cb, outgoing->node, 2);
+ return false;
+ } else {
+ logger(mesh, MESHLINK_ERROR, "Canonical address for %s is missing port number", n->name);
+ free(address);
+ outgoing->state = OUTGOING_RECENT;
+ }
+
+ } else {
+ outgoing->state = OUTGOING_RECENT;
+ }
}
if(outgoing->state == OUTGOING_CANONICAL) {
if(!outgoing->aip) {
- outgoing->ai = get_canonical_address(outgoing->node);
outgoing->aip = outgoing->ai;
} else {
outgoing->aip = outgoing->aip->ai_next;
return true;
}
- freeaddrinfo(outgoing->ai);
+ if(outgoing->ai) {
+ freeaddrinfo(outgoing->ai);
+ }
+
outgoing->ai = NULL;
outgoing->aip = NULL;
outgoing->state = OUTGOING_RECENT;
}
void do_outgoing_connection(meshlink_handle_t *mesh, outgoing_t *outgoing) {
- struct addrinfo *proxyai = NULL;
- int result;
-
begin:
if(!get_next_outgoing_address(mesh, outgoing)) {
- if(outgoing->state == OUTGOING_NO_KNOWN_ADDRESSES) {
+ if(outgoing->state == OUTGOING_CANONICAL_RESOLVE) {
+ /* We are waiting for a callback from the ADNS thread */
+ } else if(outgoing->state == OUTGOING_NO_KNOWN_ADDRESSES) {
logger(mesh, MESHLINK_ERROR, "No known addresses for %s", outgoing->node->name);
} else {
logger(mesh, MESHLINK_ERROR, "Could not set up a meta connection to %s", outgoing->node->name);
memcpy(&c->address, outgoing->aip->ai_addr, outgoing->aip->ai_addrlen);
- char *hostname = sockaddr2hostname(&c->address);
-
- logger(mesh, MESHLINK_INFO, "Trying to connect to %s at %s", outgoing->node->name, hostname);
+ if(mesh->log_level <= MESHLINK_INFO) {
+ char *hostname = sockaddr2hostname(&c->address);
+ logger(mesh, MESHLINK_INFO, "Trying to connect to %s at %s", outgoing->node->name, hostname);
+ free(hostname);
+ }
- if(!mesh->proxytype) {
- c->socket = socket(c->address.sa.sa_family, SOCK_STREAM, IPPROTO_TCP);
- configure_tcp(c);
- } else {
- proxyai = str2addrinfo(mesh->proxyhost, mesh->proxyport, SOCK_STREAM);
+ c->socket = socket(c->address.sa.sa_family, SOCK_STREAM, IPPROTO_TCP);
- if(!proxyai) {
- free_connection(c);
+ if(c->socket == -1) {
+ if(mesh->log_level <= MESHLINK_ERROR) {
+ char *hostname = sockaddr2hostname(&c->address);
+ logger(mesh, MESHLINK_ERROR, "Creating socket for %s at %s failed: %s", c->name, hostname, sockstrerror(sockerrno));
free(hostname);
- goto begin;
}
- logger(mesh, MESHLINK_INFO, "Using proxy at %s port %s", mesh->proxyhost, mesh->proxyport);
- c->socket = socket(proxyai->ai_family, SOCK_STREAM, IPPROTO_TCP);
- configure_tcp(c);
- }
-
- if(c->socket == -1) {
- logger(mesh, MESHLINK_ERROR, "Creating socket for %s at %s failed: %s", c->name, hostname, sockstrerror(sockerrno));
free_connection(c);
- free(hostname);
goto begin;
}
- free(hostname);
+ configure_tcp(c);
#ifdef FD_CLOEXEC
fcntl(c->socket, F_SETFD, FD_CLOEXEC);
/* Connect */
- if(!mesh->proxytype) {
- result = connect(c->socket, &c->address.sa, SALEN(c->address.sa));
- } else {
- result = connect(c->socket, proxyai->ai_addr, proxyai->ai_addrlen);
- freeaddrinfo(proxyai);
- }
+ int result = connect(c->socket, &c->address.sa, SALEN(c->address.sa));
if(result == -1 && !sockinprogress(sockerrno)) {
- logger(mesh, MESHLINK_ERROR, "Could not connect to %s: %s", outgoing->node->name, sockstrerror(sockerrno));
- free_connection(c);
+ if(mesh->log_level <= MESHLINK_ERROR) {
+ char *hostname = sockaddr2hostname(&c->address);
+ logger(mesh, MESHLINK_ERROR, "Could not connect to %s: %s", outgoing->node->name, sockstrerror(sockerrno));
+ free(hostname);
+ }
+ free_connection(c);
goto begin;
}