static void send_udppacket(node_t *, vpn_packet_t *);
unsigned replaywin = 16;
-bool localdiscovery = false;
-sockaddr_t localdiscovery_address;
#define MAX_SEQNO 1073741824
timeout = pingtimeout;
}
- for(int i = 0; i < 4 + localdiscovery; i++) {
+ for(int i = 0; i < 4 + mesh->localdiscovery; i++) {
int len;
if(i == 0) {
*sock = rand() % listen_sockets;
if(listen_socket[*sock].sa.sa.sa_family == AF_INET6) {
- if(localdiscovery_address.sa.sa_family == AF_INET6) {
- localdiscovery_address.in6.sin6_port = n->prevedge->address.in.sin_port;
- *sa = &localdiscovery_address;
+ if(mesh->localdiscovery_address.sa.sa_family == AF_INET6) {
+ mesh->localdiscovery_address.in6.sin6_port = n->prevedge->address.in.sin_port;
+ *sa = &mesh->localdiscovery_address;
} else {
broadcast_ipv6.in6.sin6_port = n->prevedge->address.in.sin_port;
broadcast_ipv6.in6.sin6_scope_id = listen_socket[*sock].sa.in6.sin6_scope_id;
*sa = &broadcast_ipv6;
}
} else {
- if(localdiscovery_address.sa.sa_family == AF_INET) {
- localdiscovery_address.in.sin_port = n->prevedge->address.in.sin_port;
- *sa = &localdiscovery_address;
+ if(mesh->localdiscovery_address.sa.sa_family == AF_INET) {
+ mesh->localdiscovery_address.in.sin_port = n->prevedge->address.in.sin_port;
+ *sa = &mesh->localdiscovery_address;
} else {
broadcast_ipv4.in.sin_port = n->prevedge->address.in.sin_port;
*sa = &broadcast_ipv4;
logger(DEBUG_TRAFFIC, LOG_INFO, "Broadcasting packet of %d bytes from %s (%s)",
packet->len, from->name, from->hostname);
- for list_each(connection_t, c, connection_list)
+ for list_each(connection_t, c, mesh->connections)
if(c->status.active && c->status.mst && c != from->nexthop->connection)
send_packet(c->node, packet);
}
bool hard = false;
static time_t last_hard_try = 0;
- for splay_each(edge_t, e, edge_weight_tree) {
+ for splay_each(edge_t, e, mesh->edges) {
if(!e->to->status.reachable || e->to == mesh->self)
continue;