git.meshlink.io Git - meshlink/blob - src/subnet.c

   1 /*
   2     subnet.c -- handle subnet lookups and lists
   3     Copyright (C) 2000-2013 Guus Sliepen <guus@tinc-vpn.org>,
   4                   2000-2005 Ivo Timmermans
   5
   6     This program is free software; you can redistribute it and/or modify
   7     it under the terms of the GNU General Public License as published by
   8     the Free Software Foundation; either version 2 of the License, or
   9     (at your option) any later version.
  10
  11     This program is distributed in the hope that it will be useful,
  12     but WITHOUT ANY WARRANTY; without even the implied warranty of
  13     MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
  14     GNU General Public License for more details.
  15
  16     You should have received a copy of the GNU General Public License along
  17     with this program; if not, write to the Free Software Foundation, Inc.,
  18     51 Franklin Street, Fifth Floor, Boston, MA 02110-1301 USA.
  19 */
  20
  21 #include "system.h"
  22
  23 #include "splay_tree.h"
  24 #include "control_common.h"
  25 #include "device.h"
  26 #include "hash.h"
  27 #include "logger.h"
  28 #include "names.h"
  29 #include "net.h"
  30 #include "netutl.h"
  31 #include "node.h"
  32 #include "process.h"
  33 #include "subnet.h"
  34 #include "utils.h"
  35 #include "xalloc.h"
  36
  37 /* lists type of subnet */
  38
  39 splay_tree_t *subnet_tree;
  40
  41 /* Subnet lookup cache */
  42
  43 hash_t *ipv4_cache;
  44 hash_t *ipv6_cache;
  45 hash_t *mac_cache;
  46
  47 void subnet_cache_flush(void) {
  48         hash_clear(ipv4_cache);
  49         hash_clear(ipv6_cache);
  50         hash_clear(mac_cache);
  51 }
  52
  53 /* Initialising trees */
  54
  55 void init_subnets(void) {
  56         subnet_tree = splay_alloc_tree((splay_compare_t) subnet_compare, (splay_action_t) free_subnet);
  57
  58         ipv4_cache = hash_alloc(0x100, sizeof(ipv4_t));
  59         ipv6_cache = hash_alloc(0x100, sizeof(ipv6_t));
  60         mac_cache = hash_alloc(0x100, sizeof(mac_t));
  61 }
  62
  63 void exit_subnets(void) {
  64         splay_delete_tree(subnet_tree);
  65
  66         hash_free(ipv4_cache);
  67         hash_free(ipv6_cache);
  68         hash_free(mac_cache);
  69 }
  70
  71 splay_tree_t *new_subnet_tree(void) {
  72         return splay_alloc_tree((splay_compare_t) subnet_compare, NULL);
  73 }
  74
  75 void free_subnet_tree(splay_tree_t *subnet_tree) {
  76         splay_delete_tree(subnet_tree);
  77 }
  78
  79 /* Allocating and freeing space for subnets */
  80
  81 subnet_t *new_subnet(void) {
  82         return xzalloc(sizeof(subnet_t));
  83 }
  84
  85 void free_subnet(subnet_t *subnet) {
  86         free(subnet);
  87 }
  88
  89 /* Adding and removing subnets */
  90
  91 void subnet_add(node_t *n, subnet_t *subnet) {
  92         subnet->owner = n;
  93
  94         splay_insert(subnet_tree, subnet);
  95         splay_insert(n->subnet_tree, subnet);
  96
  97         subnet_cache_flush();
  98 }
  99
 100 void subnet_del(node_t *n, subnet_t *subnet) {
 101         splay_delete(n->subnet_tree, subnet);
 102         splay_delete(subnet_tree, subnet);
 103
 104         subnet_cache_flush();
 105 }
 106
 107 /* Subnet lookup routines */
 108
 109 subnet_t *lookup_subnet(const node_t *owner, const subnet_t *subnet) {
 110         return splay_search(owner->subnet_tree, subnet);
 111 }
 112
 113 subnet_t *lookup_subnet_mac(const node_t *owner, const mac_t *address) {
 114         subnet_t *r = NULL;
 115
 116         // Check if this address is cached
 117
 118         if((r = hash_search(mac_cache, address)))
 119                 return r;
 120
 121         // Search all subnets for a matching one
 122
 123         for splay_each(subnet_t, p, owner ? owner->subnet_tree : subnet_tree) {
 124                 if(!p || p->type != SUBNET_MAC)
 125                         continue;
 126
 127                 if(!memcmp(address, &p->net.mac.address, sizeof *address)) {
 128                         r = p;
 129                         if(p->owner->status.reachable)
 130                                 break;
 131                 }
 132         }
 133
 134         // Cache the result
 135
 136         if(r)
 137                 hash_insert(mac_cache, address, r);
 138
 139         return r;
 140 }
 141
 142 subnet_t *lookup_subnet_ipv4(const ipv4_t *address) {
 143         subnet_t *r = NULL;
 144
 145         // Check if this address is cached
 146
 147         if((r = hash_search(ipv4_cache, address)))
 148                 return r;
 149
 150         // Search all subnets for a matching one
 151
 152         for splay_each(subnet_t, p, subnet_tree) {
 153                 if(!p || p->type != SUBNET_IPV4)
 154                         continue;
 155
 156                 if(!maskcmp(address, &p->net.ipv4.address, p->net.ipv4.prefixlength)) {
 157                         r = p;
 158                         if(p->owner->status.reachable)
 159                                 break;
 160                 }
 161         }
 162
 163         // Cache the result
 164
 165         if(r)
 166                 hash_insert(ipv4_cache, address, r);
 167
 168         return r;
 169 }
 170
 171 subnet_t *lookup_subnet_ipv6(const ipv6_t *address) {
 172         subnet_t *r = NULL;
 173
 174         // Check if this address is cached
 175
 176         if((r = hash_search(ipv6_cache, address)))
 177                 return r;
 178
 179         // Search all subnets for a matching one
 180
 181         for splay_each(subnet_t, p, subnet_tree) {
 182                 if(!p || p->type != SUBNET_IPV6)
 183                         continue;
 184
 185                 if(!maskcmp(address, &p->net.ipv6.address, p->net.ipv6.prefixlength)) {
 186                         r = p;
 187                         if(p->owner->status.reachable)
 188                                 break;
 189                 }
 190         }
 191
 192         // Cache the result
 193
 194         if(r)
 195                 hash_insert(ipv6_cache, address, r);
 196
 197         return r;
 198 }
 199
 200 void subnet_update(node_t *owner, subnet_t *subnet, bool up) {
 201         char netstr[MAXNETSTR];
 202         char *name, *address, *port;
 203         char empty[] = "";
 204
 205         // Prepare environment variables to be passed to the script
 206
 207         char *envp[10] = {NULL};
 208         xasprintf(&envp[0], "NETNAME=%s", netname ? : "");
 209         xasprintf(&envp[1], "DEVICE=%s", device ? : "");
 210         xasprintf(&envp[2], "INTERFACE=%s", iface ? : "");
 211         xasprintf(&envp[3], "NODE=%s", owner->name);
 212
 213         if(owner != myself) {
 214                 sockaddr2str(&owner->address, &address, &port);
 215                 // 4 and 5 are reserved for SUBNET and WEIGHT
 216                 xasprintf(&envp[6], "REMOTEADDRESS=%s", address);
 217                 xasprintf(&envp[7], "REMOTEPORT=%s", port);
 218                 free(port);
 219                 free(address);
 220         }
 221
 222         xasprintf(&envp[8], "NAME=%s", myself->name);
 223
 224         name = up ? "subnet-up" : "subnet-down";
 225
 226         if(!subnet) {
 227                 for splay_each(subnet_t, subnet, owner->subnet_tree) {
 228                         if(!net2str(netstr, sizeof netstr, subnet))
 229                                 continue;
 230
 231                         // Strip the weight from the subnet, and put it in its own environment variable
 232                         char *weight = strchr(netstr, '#');
 233                         if(weight)
 234                                 *weight++ = 0;
 235                         else
 236                                 weight = empty;
 237
 238                         // Prepare the SUBNET and WEIGHT variables
 239                         if(envp[4])
 240                                 free(envp[4]);
 241                         if(envp[5])
 242                                 free(envp[5]);
 243                         xasprintf(&envp[4], "SUBNET=%s", netstr);
 244                         xasprintf(&envp[5], "WEIGHT=%s", weight);
 245
 246                         execute_script(name, envp);
 247                 }
 248         } else {
 249                 if(net2str(netstr, sizeof netstr, subnet)) {
 250                         // Strip the weight from the subnet, and put it in its own environment variable
 251                         char *weight = strchr(netstr, '#');
 252                         if(weight)
 253                                 *weight++ = 0;
 254                         else
 255                                 weight = empty;
 256
 257                         // Prepare the SUBNET and WEIGHT variables
 258                         xasprintf(&envp[4], "SUBNET=%s", netstr);
 259                         xasprintf(&envp[5], "WEIGHT=%s", weight);
 260
 261                         execute_script(name, envp);
 262                 }
 263         }
 264
 265         for(int i = 0; envp[i] && i < 9; i++)
 266                 free(envp[i]);
 267 }
 268
 269 bool dump_subnets(connection_t *c) {
 270         for splay_each(subnet_t, subnet, subnet_tree) {
 271                 char netstr[MAXNETSTR];
 272
 273                 if(!net2str(netstr, sizeof netstr, subnet))
 274                         continue;
 275
 276                 send_request(c, "%d %d %s %s",
 277                                 CONTROL, REQ_DUMP_SUBNETS,
 278                                 netstr, subnet->owner->name);
 279         }
 280
 281         return send_request(c, "%d %d", CONTROL, REQ_DUMP_SUBNETS);
 282 }