tinc-vpn.org Git - tinc/blob - src/net.c

   1 /*
   2     net.c -- most of the network code
   3     Copyright (C) 1998-2001 Ivo Timmermans <itimmermans@bigfoot.com>,
   4                   2000,2001 Guus Sliepen <guus@sliepen.warande.net>
   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
  17     along with this program; if not, write to the Free Software
  18     Foundation, Inc., 675 Mass Ave, Cambridge, MA 02139, USA.
  19
  20     $Id: net.c,v 1.35.4.99 2001/02/27 16:17:04 guus Exp $
  21 */
  22
  23 #include "config.h"
  24
  25 #include <errno.h>
  26 #include <fcntl.h>
  27 #include <netdb.h>
  28 #include <netinet/in.h>
  29 #include <netinet/ip.h>
  30 #include <netinet/tcp.h>
  31 #include <stdio.h>
  32 #include <stdlib.h>
  33 #include <string.h>
  34 #include <sys/signal.h>
  35 #include <sys/time.h>
  36 #include <sys/types.h>
  37 #include <syslog.h>
  38 #include <unistd.h>
  39 #include <sys/ioctl.h>
  40 /* SunOS really wants sys/socket.h BEFORE net/if.h,
  41    and FreeBSD wants these lines below the rest. */
  42 #include <arpa/inet.h>
  43 #include <sys/socket.h>
  44 #include <net/if.h>
  45
  46 #ifdef HAVE_OPENSSL_RAND_H
  47 # include <openssl/rand.h>
  48 #else
  49 # include <rand.h>
  50 #endif
  51
  52 #ifdef HAVE_OPENSSL_EVP_H
  53 # include <openssl/evp.h>
  54 #else
  55 # include <evp.h>
  56 #endif
  57
  58 #ifdef HAVE_OPENSSL_ERR_H
  59 # include <openssl/err.h>
  60 #else
  61 # include <err.h>
  62 #endif
  63
  64 #ifdef HAVE_OPENSSL_PEM_H
  65 # include <openssl/pem.h>
  66 #else
  67 # include <pem.h>
  68 #endif
  69
  70 #ifdef HAVE_TUNTAP
  71 #include LINUX_IF_TUN_H
  72 #endif
  73
  74 #include <utils.h>
  75 #include <xalloc.h>
  76 #include <avl_tree.h>
  77 #include <list.h>
  78
  79 #include "conf.h"
  80 #include "connection.h"
  81 #include "meta.h"
  82 #include "net.h"
  83 #include "netutl.h"
  84 #include "process.h"
  85 #include "protocol.h"
  86 #include "subnet.h"
  87
  88 #include "system.h"
  89
  90 int tap_fd = -1;
  91 int taptype = TAP_TYPE_ETHERTAP;
  92 int total_tap_in = 0;
  93 int total_tap_out = 0;
  94 int total_socket_in = 0;
  95 int total_socket_out = 0;
  96
  97 config_t *upstreamcfg;
  98 static int seconds_till_retry;
  99
 100 int keylifetime = 0;
 101 int keyexpires = 0;
 102
 103 char *unknown = NULL;
 104
 105 subnet_t mymac;
 106
 107 int xsend(connection_t *cl, vpn_packet_t *inpkt)
 108 {
 109   vpn_packet_t outpkt;
 110   int outlen, outpad;
 111   EVP_CIPHER_CTX ctx;
 112   struct sockaddr_in to;
 113   socklen_t tolen = sizeof(to);
 114 cp
 115   outpkt.len = inpkt->len;
 116
 117   /* Encrypt the packet. */
 118
 119   EVP_EncryptInit(&ctx, cl->cipher_pkttype, cl->cipher_pktkey, cl->cipher_pktkey + cl->cipher_pkttype->key_len);
 120   EVP_EncryptUpdate(&ctx, outpkt.data, &outlen, inpkt->data, inpkt->len);
 121   EVP_EncryptFinal(&ctx, outpkt.data + outlen, &outpad);
 122   outlen += outpad + 2;
 123
 124 /* Bypass
 125   outlen = outpkt.len + 2;
 126   memcpy(&outpkt, inpkt, outlen);
 127 */
 128
 129   if(debug_lvl >= DEBUG_TRAFFIC)
 130     syslog(LOG_ERR, _("Sending packet of %d bytes to %s (%s)"),
 131            outlen, cl->name, cl->hostname);
 132
 133   total_socket_out += outlen;
 134
 135   to.sin_family = AF_INET;
 136   to.sin_addr.s_addr = htonl(cl->address);
 137   to.sin_port = htons(cl->port);
 138
 139   if((sendto(myself->socket, (char *) &(outpkt.len), outlen, 0, (const struct sockaddr *)&to, tolen)) < 0)
 140     {
 141       syslog(LOG_ERR, _("Error sending packet to %s (%s): %m"),
 142              cl->name, cl->hostname);
 143       return -1;
 144     }
 145 cp
 146   return 0;
 147 }
 148
 149 int xrecv(connection_t *cl, vpn_packet_t *inpkt)
 150 {
 151   vpn_packet_t outpkt;
 152   int outlen, outpad;
 153   EVP_CIPHER_CTX ctx;
 154 cp
 155   outpkt.len = inpkt->len;
 156
 157   /* Decrypt the packet */
 158
 159   EVP_DecryptInit(&ctx, myself->cipher_pkttype, myself->cipher_pktkey, myself->cipher_pktkey + myself->cipher_pkttype->key_len);
 160   EVP_DecryptUpdate(&ctx, outpkt.data, &outlen, inpkt->data, inpkt->len + 8);
 161   EVP_DecryptFinal(&ctx, outpkt.data + outlen, &outpad);
 162   outlen += outpad;
 163
 164 /* Bypass
 165   outlen = outpkt.len+2;
 166   memcpy(&outpkt, inpkt, outlen);
 167 */
 168 cp
 169   return receive_packet(cl, &outpkt);
 170 }
 171
 172 int receive_packet(connection_t *cl, vpn_packet_t *packet)
 173 {
 174   if(debug_lvl >= DEBUG_TRAFFIC)
 175     syslog(LOG_ERR, _("Writing packet of %d bytes to tap device"),
 176            packet->len);
 177
 178   /* Fix mac address */
 179
 180   memcpy(packet->data, mymac.net.mac.address.x, 6);
 181
 182   if(taptype == TAP_TYPE_TUNTAP)
 183     {
 184       if(write(tap_fd, packet->data, packet->len) < 0)
 185         syslog(LOG_ERR, _("Can't write to tun/tap device: %m"));
 186       else
 187         total_tap_out += packet->len;
 188     }
 189   else  /* ethertap */
 190     {
 191       if(write(tap_fd, packet->data - 2, packet->len + 2) < 0)
 192         syslog(LOG_ERR, _("Can't write to ethertap device: %m"));
 193       else
 194         total_tap_out += packet->len + 2;
 195     }
 196 cp
 197   return 0;
 198 }
 199
 200 /*
 201   send a packet to the given vpn ip.
 202 */
 203 int send_packet(ip_t to, vpn_packet_t *packet)
 204 {
 205   connection_t *cl;
 206   subnet_t *subnet;
 207   vpn_packet_t *copy;
 208 cp
 209   if((subnet = lookup_subnet_ipv4(&to)) == NULL)
 210     {
 211       if(debug_lvl >= DEBUG_TRAFFIC)
 212         {
 213           syslog(LOG_NOTICE, _("Trying to look up %d.%d.%d.%d in connection list failed!"),
 214                  IP_ADDR_V(to));
 215         }
 216
 217       return -1;
 218     }
 219
 220   cl = subnet->owner;
 221
 222   if(cl == myself)
 223     {
 224       if(debug_lvl >= DEBUG_TRAFFIC)
 225         {
 226           syslog(LOG_NOTICE, _("Packet with destination %d.%d.%d.%d is looping back to us!"),
 227                  IP_ADDR_V(to));
 228         }
 229
 230       return -1;
 231     }
 232
 233   if(!cl->status.active)
 234     {
 235       if(debug_lvl >= DEBUG_TRAFFIC)
 236         syslog(LOG_INFO, _("%s (%s) is not active, dropping packet"),
 237                cl->name, cl->hostname);
 238
 239       return 0;
 240     }
 241
 242   if(!cl->status.validkey)
 243     {
 244       if(debug_lvl >= DEBUG_TRAFFIC)
 245         syslog(LOG_INFO, _("No valid key known yet for %s (%s), queueing packet"),
 246                cl->name, cl->hostname);
 247
 248       /* Since packet is on the stack of handle_tap_input(),
 249          we have to make a copy of it first. */
 250
 251       copy = xmalloc(sizeof(vpn_packet_t));
 252       memcpy(copy, packet, sizeof(vpn_packet_t));
 253
 254       list_insert_tail(cl->queue, copy);
 255
 256       if(!cl->status.waitingforkey)
 257         send_req_key(myself, cl);                       /* Keys should be sent to the host running the tincd */
 258       return 0;
 259     }
 260
 261   /* Check if it has to go via UDP or TCP... */
 262 cp
 263   if(cl->options & OPTION_TCPONLY)
 264     return send_tcppacket(cl, packet);
 265   else
 266     return xsend(cl, packet);
 267 }
 268
 269 void flush_queue(connection_t *cl)
 270 {
 271   list_node_t *node, *next;
 272 cp
 273   if(debug_lvl >= DEBUG_TRAFFIC)
 274     syslog(LOG_INFO, _("Flushing queue for %s (%s)"), cl->name, cl->hostname);
 275
 276   for(node = cl->queue->head; node; node = next)
 277     {
 278       next = node->next;
 279       xsend(cl, (vpn_packet_t *)node->data);
 280       list_delete_node(cl->queue, node);
 281     }
 282 cp
 283 }
 284
 285 /*
 286   open the local ethertap device
 287 */
 288 int setup_tap_fd(void)
 289 {
 290   int nfd;
 291   const char *tapfname;
 292   config_t const *cfg;
 293 #ifdef HAVE_LINUX
 294 # ifdef HAVE_TUNTAP
 295   struct ifreq ifr;
 296 # endif
 297 #endif
 298
 299 cp
 300   if((cfg = get_config_val(config, config_tapdevice)))
 301     tapfname = cfg->data.ptr;
 302   else
 303    {
 304 #ifdef HAVE_LINUX
 305 # ifdef HAVE_TUNTAP
 306       tapfname = "/dev/misc/net/tun";
 307 # else
 308       tapfname = "/dev/tap0";
 309 # endif
 310 #endif
 311 #ifdef HAVE_FREEBSD
 312       tapfname = "/dev/tap0";
 313 #endif
 314 #ifdef HAVE_SOLARIS
 315       tapfname = "/dev/tun";
 316 #endif
 317    }
 318 cp
 319   if((nfd = open(tapfname, O_RDWR | O_NONBLOCK)) < 0)
 320     {
 321       syslog(LOG_ERR, _("Could not open %s: %m"), tapfname);
 322       return -1;
 323     }
 324 cp
 325   tap_fd = nfd;
 326
 327   taptype = TAP_TYPE_ETHERTAP;
 328
 329   /* Set default MAC address for ethertap devices */
 330
 331   mymac.type = SUBNET_MAC;
 332   mymac.net.mac.address.x[0] = 0xfe;
 333   mymac.net.mac.address.x[1] = 0xfd;
 334   mymac.net.mac.address.x[2] = 0x00;
 335   mymac.net.mac.address.x[3] = 0x00;
 336   mymac.net.mac.address.x[4] = 0x00;
 337   mymac.net.mac.address.x[5] = 0x00;
 338
 339 #ifdef HAVE_LINUX
 340  #ifdef HAVE_TUNTAP
 341   /* Ok now check if this is an old ethertap or a new tun/tap thingie */
 342   memset(&ifr, 0, sizeof(ifr));
 343 cp
 344   ifr.ifr_flags = IFF_TAP | IFF_NO_PI;
 345   if (netname)
 346     strncpy(ifr.ifr_name, netname, IFNAMSIZ);
 347 cp
 348   if (!ioctl(tap_fd, TUNSETIFF, (void *) &ifr))
 349   {
 350     syslog(LOG_INFO, _("%s is a new style tun/tap device"), tapfname);
 351     taptype = TAP_TYPE_TUNTAP;
 352   }
 353  #endif
 354 #endif
 355 #ifdef HAVE_FREEBSD
 356  taptype = TAP_TYPE_TUNTAP;
 357 #endif
 358 cp
 359   return 0;
 360 }
 361
 362 /*
 363   set up the socket that we listen on for incoming
 364   (tcp) connections
 365 */
 366 int setup_listen_meta_socket(int port)
 367 {
 368   int nfd, flags;
 369   struct sockaddr_in a;
 370   int option;
 371   config_t const *cfg;
 372 cp
 373   if((nfd = socket(AF_INET, SOCK_STREAM, IPPROTO_TCP)) < 0)
 374     {
 375       syslog(LOG_ERR, _("Creating metasocket failed: %m"));
 376       return -1;
 377     }
 378
 379   flags = fcntl(nfd, F_GETFL);
 380   if(fcntl(nfd, F_SETFL, flags | O_NONBLOCK) < 0)
 381     {
 382       close(nfd);
 383       syslog(LOG_ERR, _("System call `%s' failed: %m"),
 384              "fcntl");
 385       return -1;
 386     }
 387
 388   /* Optimize TCP settings */
 389
 390   option = 1;
 391   setsockopt(nfd, SOL_SOCKET, SO_REUSEADDR, &option, sizeof(option));
 392   setsockopt(nfd, SOL_SOCKET, SO_KEEPALIVE, &option, sizeof(option));
 393   setsockopt(nfd, SOL_TCP, TCP_NODELAY, &option, sizeof(option));
 394
 395   option = IPTOS_LOWDELAY;
 396   setsockopt(nfd, SOL_IP, IP_TOS, &option, sizeof(option));
 397
 398   if((cfg = get_config_val(config, config_interface)))
 399     {
 400       if(setsockopt(nfd, SOL_SOCKET, SO_BINDTODEVICE, cfg->data.ptr, strlen(cfg->data.ptr)))
 401         {
 402           close(nfd);
 403           syslog(LOG_ERR, _("Unable to bind listen socket to interface %s: %m"), cfg->data.ptr);
 404           return -1;
 405         }
 406     }
 407
 408   memset(&a, 0, sizeof(a));
 409   a.sin_family = AF_INET;
 410   a.sin_port = htons(port);
 411
 412   if((cfg = get_config_val(config, config_interfaceip)))
 413     a.sin_addr.s_addr = htonl(cfg->data.ip->address);
 414   else
 415     a.sin_addr.s_addr = htonl(INADDR_ANY);
 416
 417   if(bind(nfd, (struct sockaddr *)&a, sizeof(struct sockaddr)))
 418     {
 419       close(nfd);
 420       syslog(LOG_ERR, _("Can't bind to port %hd/tcp: %m"), port);
 421       return -1;
 422     }
 423
 424   if(listen(nfd, 3))
 425     {
 426       close(nfd);
 427       syslog(LOG_ERR, _("System call `%s' failed: %m"),
 428              "listen");
 429       return -1;
 430     }
 431 cp
 432   return nfd;
 433 }
 434
 435 /*
 436   setup the socket for incoming encrypted
 437   data (the udp part)
 438 */
 439 int setup_vpn_in_socket(int port)
 440 {
 441   int nfd, flags;
 442   struct sockaddr_in a;
 443   const int one = 1;
 444 cp
 445   if((nfd = socket(AF_INET, SOCK_DGRAM, IPPROTO_UDP)) < 0)
 446     {
 447       close(nfd);
 448       syslog(LOG_ERR, _("Creating socket failed: %m"));
 449       return -1;
 450     }
 451
 452   setsockopt(nfd, SOL_SOCKET, SO_REUSEADDR, &one, sizeof(one));
 453
 454   flags = fcntl(nfd, F_GETFL);
 455   if(fcntl(nfd, F_SETFL, flags | O_NONBLOCK) < 0)
 456     {
 457       close(nfd);
 458       syslog(LOG_ERR, _("System call `%s' failed: %m"),
 459              "fcntl");
 460       return -1;
 461     }
 462
 463   memset(&a, 0, sizeof(a));
 464   a.sin_family = AF_INET;
 465   a.sin_port = htons(port);
 466   a.sin_addr.s_addr = htonl(INADDR_ANY);
 467
 468   if(bind(nfd, (struct sockaddr *)&a, sizeof(struct sockaddr)))
 469     {
 470       close(nfd);
 471       syslog(LOG_ERR, _("Can't bind to port %hd/udp: %m"), port);
 472       return -1;
 473     }
 474 cp
 475   return nfd;
 476 }
 477
 478 /*
 479   setup an outgoing meta (tcp) socket
 480 */
 481 int setup_outgoing_meta_socket(connection_t *cl)
 482 {
 483   int flags;
 484   struct sockaddr_in a;
 485   config_t const *cfg;
 486   int option;
 487 cp
 488   if(debug_lvl >= DEBUG_CONNECTIONS)
 489     syslog(LOG_INFO, _("Trying to connect to %s"), cl->hostname);
 490
 491   if((cfg = get_config_val(cl->config, config_port)) == NULL)
 492     cl->port = 655;
 493   else
 494     cl->port = cfg->data.val;
 495
 496   cl->meta_socket = socket(AF_INET, SOCK_STREAM, IPPROTO_TCP);
 497   if(cl->meta_socket == -1)
 498     {
 499       syslog(LOG_ERR, _("Creating socket for %s port %d failed: %m"),
 500              cl->hostname, cl->port);
 501       return -1;
 502     }
 503
 504   /* Bind first to get a fix on our source port */
 505
 506   a.sin_family = AF_INET;
 507   a.sin_port = htons(0);
 508   a.sin_addr.s_addr = htonl(INADDR_ANY);
 509
 510   if(bind(cl->meta_socket, (struct sockaddr *)&a, sizeof(struct sockaddr)))
 511     {
 512       close(cl->meta_socket);
 513       syslog(LOG_ERR, _("System call `%s' failed: %m"), "bind");
 514       return -1;
 515     }
 516
 517   /* Optimize TCP settings */
 518
 519   option = 1;
 520   setsockopt(cl->meta_socket, SOL_SOCKET, SO_KEEPALIVE, &option, sizeof(option));
 521   setsockopt(cl->meta_socket, SOL_TCP, TCP_NODELAY, &option, sizeof(option));
 522
 523   option = IPTOS_LOWDELAY;
 524   setsockopt(cl->meta_socket, SOL_IP, IP_TOS, &option, sizeof(option));
 525
 526   /* Connect */
 527
 528   a.sin_family = AF_INET;
 529   a.sin_port = htons(cl->port);
 530   a.sin_addr.s_addr = htonl(cl->address);
 531
 532   if(connect(cl->meta_socket, (struct sockaddr *)&a, sizeof(a)) == -1)
 533     {
 534       close(cl->meta_socket);
 535       syslog(LOG_ERR, _("%s port %hd: %m"), cl->hostname, cl->port);
 536       return -1;
 537     }
 538
 539   flags = fcntl(cl->meta_socket, F_GETFL);
 540   if(fcntl(cl->meta_socket, F_SETFL, flags | O_NONBLOCK) < 0)
 541     {
 542       close(cl->meta_socket);
 543       syslog(LOG_ERR, _("fcntl for %s port %d: %m"),
 544              cl->hostname, cl->port);
 545       return -1;
 546     }
 547
 548   if(debug_lvl >= DEBUG_CONNECTIONS)
 549     syslog(LOG_INFO, _("Connected to %s port %hd"),
 550          cl->hostname, cl->port);
 551
 552   cl->status.meta = 1;
 553 cp
 554   return 0;
 555 }
 556
 557 /*
 558   Setup an outgoing meta connection.
 559 */
 560 int setup_outgoing_connection(char *name)
 561 {
 562   connection_t *ncn;
 563   struct hostent *h;
 564   config_t const *cfg;
 565 cp
 566   if(check_id(name))
 567     {
 568       syslog(LOG_ERR, _("Invalid name for outgoing connection"));
 569       return -1;
 570     }
 571
 572   ncn = new_connection();
 573   asprintf(&ncn->name, "%s", name);
 574
 575   if(read_host_config(ncn))
 576     {
 577       syslog(LOG_ERR, _("Error reading host configuration file for %s"), ncn->name);
 578       free_connection(ncn);
 579       return -1;
 580     }
 581
 582   if(!(cfg = get_config_val(ncn->config, config_address)))
 583     {
 584       syslog(LOG_ERR, _("No address specified for %s"), ncn->name);
 585       free_connection(ncn);
 586       return -1;
 587     }
 588
 589   if(!(h = gethostbyname(cfg->data.ptr)))
 590     {
 591       syslog(LOG_ERR, _("Error looking up `%s': %m"), cfg->data.ptr);
 592       free_connection(ncn);
 593       return -1;
 594     }
 595
 596   ncn->address = ntohl(*((ip_t*)(h->h_addr_list[0])));
 597   ncn->hostname = hostlookup(htonl(ncn->address));
 598
 599   if(setup_outgoing_meta_socket(ncn) < 0)
 600     {
 601       syslog(LOG_ERR, _("Could not set up a meta connection to %s"),
 602              ncn->hostname);
 603       free_connection(ncn);
 604       return -1;
 605     }
 606
 607   ncn->status.outgoing = 1;
 608   ncn->buffer = xmalloc(MAXBUFSIZE);
 609   ncn->buflen = 0;
 610   ncn->last_ping_time = time(NULL);
 611
 612   connection_add(ncn);
 613
 614   send_id(ncn);
 615 cp
 616   return 0;
 617 }
 618
 619 int read_rsa_public_key(connection_t *cl)
 620 {
 621   config_t const *cfg;
 622   FILE *fp;
 623   char *fname;
 624   void *result;
 625 cp
 626   if(!cl->rsa_key)
 627     cl->rsa_key = RSA_new();
 628
 629   /* First, check for simple PublicKey statement */
 630
 631   if((cfg = get_config_val(cl->config, config_publickey)))
 632     {
 633       BN_hex2bn(&cl->rsa_key->n, cfg->data.ptr);
 634       BN_hex2bn(&cl->rsa_key->e, "FFFF");
 635       return 0;
 636     }
 637
 638   /* Else, check for PublicKeyFile statement and read it */
 639
 640   if((cfg = get_config_val(cl->config, config_publickeyfile)))
 641     {
 642       if(is_safe_path(cfg->data.ptr))
 643         {
 644           if((fp = fopen(cfg->data.ptr, "r")) == NULL)
 645             {
 646               syslog(LOG_ERR, _("Error reading RSA public key file `%s': %m"),
 647                      cfg->data.ptr);
 648               return -1;
 649             }
 650           result = PEM_read_RSAPublicKey(fp, &cl->rsa_key, NULL, NULL);
 651           fclose(fp);
 652           if(!result)
 653             {
 654               syslog(LOG_ERR, _("Reading RSA public key file `%s' failed: %m"),
 655                      cfg->data.ptr);
 656               return -1;
 657             }
 658           return 0;
 659         }
 660       else
 661         return -1;
 662     }
 663
 664   /* Else, check if a harnessed public key is in the config file */
 665
 666   asprintf(&fname, "%s/hosts/%s", confbase, cl->name);
 667   if((fp = fopen(fname, "r")))
 668     {
 669       result = PEM_read_RSAPublicKey(fp, &cl->rsa_key, NULL, NULL);
 670       fclose(fp);
 671       free(fname);
 672       if(result)
 673         return 0;
 674     }
 675
 676   free(fname);
 677
 678   /* Nothing worked. */
 679
 680   syslog(LOG_ERR, _("No public key for %s specified!"), cl->name);
 681 cp
 682   return -1;
 683 }
 684
 685 int read_rsa_private_key(void)
 686 {
 687   config_t const *cfg;
 688   FILE *fp;
 689   void *result;
 690 cp
 691   if(!myself->rsa_key)
 692     myself->rsa_key = RSA_new();
 693
 694   if((cfg = get_config_val(config, config_privatekey)))
 695     {
 696       BN_hex2bn(&myself->rsa_key->d, cfg->data.ptr);
 697       BN_hex2bn(&myself->rsa_key->e, "FFFF");
 698     }
 699   else if((cfg = get_config_val(config, config_privatekeyfile)))
 700     {
 701       if((fp = fopen(cfg->data.ptr, "r")) == NULL)
 702         {
 703           syslog(LOG_ERR, _("Error reading RSA private key file `%s': %m"),
 704                  cfg->data.ptr);
 705           return -1;
 706         }
 707       result = PEM_read_RSAPrivateKey(fp, &myself->rsa_key, NULL, NULL);
 708       fclose(fp);
 709       if(!result)
 710         {
 711           syslog(LOG_ERR, _("Reading RSA private key file `%s' failed: %m"),
 712                  cfg->data.ptr);
 713           return -1;
 714         }
 715     }
 716   else
 717     {
 718       syslog(LOG_ERR, _("No private key for tinc daemon specified!"));
 719       return -1;
 720     }
 721 cp
 722   return 0;
 723 }
 724
 725 /*
 726   Configure connection_t myself and set up the local sockets (listen only)
 727 */
 728 int setup_myself(void)
 729 {
 730   config_t const *cfg;
 731   config_t *next;
 732   subnet_t *net;
 733 cp
 734   myself = new_connection();
 735
 736   asprintf(&myself->hostname, "MYSELF");
 737   myself->flags = 0;
 738   myself->protocol_version = PROT_CURRENT;
 739
 740   if(!(cfg = get_config_val(config, config_name))) /* Not acceptable */
 741     {
 742       syslog(LOG_ERR, _("Name for tinc daemon required!"));
 743       return -1;
 744     }
 745   else
 746     asprintf(&myself->name, "%s", (char*)cfg->data.val);
 747
 748   if(check_id(myself->name))
 749     {
 750       syslog(LOG_ERR, _("Invalid name for myself!"));
 751       return -1;
 752     }
 753 cp
 754   if(read_rsa_private_key())
 755     return -1;
 756
 757   if(read_host_config(myself))
 758     {
 759       syslog(LOG_ERR, _("Cannot open host configuration file for myself!"));
 760       return -1;
 761     }
 762
 763   if(read_rsa_public_key(myself))
 764     return -1;
 765 cp
 766
 767 /*
 768   if(RSA_check_key(myself->rsa_key) != 1)
 769     {
 770       syslog(LOG_ERR, _("Invalid public/private keypair!"));
 771       return -1;
 772     }
 773 */
 774   if(!(cfg = get_config_val(myself->config, config_port)))
 775     myself->port = 655;
 776   else
 777     myself->port = cfg->data.val;
 778
 779   if((cfg = get_config_val(myself->config, config_indirectdata)))
 780     if(cfg->data.val == stupid_true)
 781       myself->flags |= EXPORTINDIRECTDATA;
 782
 783   if((cfg = get_config_val(myself->config, config_tcponly)))
 784     if(cfg->data.val == stupid_true)
 785       myself->flags |= TCPONLY;
 786
 787 /* Read in all the subnets specified in the host configuration file */
 788
 789   for(next = myself->config; (cfg = get_config_val(next, config_subnet)); next = cfg->next)
 790     {
 791       net = new_subnet();
 792       net->type = SUBNET_IPV4;
 793       net->net.ipv4.address = cfg->data.ip->address;
 794       net->net.ipv4.mask = cfg->data.ip->mask;
 795
 796       /* Teach newbies what subnets are... */
 797
 798       if((net->net.ipv4.address & net->net.ipv4.mask) != net->net.ipv4.address)
 799         {
 800           syslog(LOG_ERR, _("Network address and subnet mask do not match!"));
 801           return -1;
 802         }
 803
 804       subnet_add(myself, net);
 805     }
 806
 807   if((myself->meta_socket = setup_listen_meta_socket(myself->port)) < 0)
 808     {
 809       syslog(LOG_ERR, _("Unable to set up a listening TCP socket!"));
 810       return -1;
 811     }
 812
 813   if((myself->socket = setup_vpn_in_socket(myself->port)) < 0)
 814     {
 815       syslog(LOG_ERR, _("Unable to set up a listening UDP socket!"));
 816       return -1;
 817     }
 818 cp
 819   /* Generate packet encryption key */
 820
 821   myself->cipher_pkttype = EVP_bf_cbc();
 822
 823   myself->cipher_pktkeylength = myself->cipher_pkttype->key_len + myself->cipher_pkttype->iv_len;
 824
 825   myself->cipher_pktkey = (char *)xmalloc(myself->cipher_pktkeylength);
 826   RAND_bytes(myself->cipher_pktkey, myself->cipher_pktkeylength);
 827
 828   if(!(cfg = get_config_val(config, config_keyexpire)))
 829     keylifetime = 3600;
 830   else
 831     keylifetime = cfg->data.val;
 832
 833   keyexpires = time(NULL) + keylifetime;
 834 cp
 835   /* Check some options */
 836
 837   if((cfg = get_config_val(config, config_indirectdata)))
 838     {
 839       if(cfg->data.val == stupid_true)
 840         myself->options |= OPTION_INDIRECT;
 841     }
 842
 843   if((cfg = get_config_val(config, config_tcponly)))
 844     {
 845       if(cfg->data.val == stupid_true)
 846         myself->options |= OPTION_TCPONLY;
 847     }
 848   /* Activate ourselves */
 849
 850   myself->status.active = 1;
 851
 852   syslog(LOG_NOTICE, _("Ready: listening on port %hd"), myself->port);
 853 cp
 854   return 0;
 855 }
 856
 857 RETSIGTYPE
 858 sigalrm_handler(int a)
 859 {
 860   config_t const *cfg;
 861 cp
 862   cfg = get_config_val(upstreamcfg, config_connectto);
 863
 864   if(!cfg && upstreamcfg == config)
 865     /* No upstream IP given, we're listen only. */
 866     return;
 867
 868   while(cfg)
 869     {
 870       upstreamcfg = cfg->next;
 871       if(!setup_outgoing_connection(cfg->data.ptr))   /* function returns 0 when there are no problems */
 872         {
 873           signal(SIGALRM, SIG_IGN);
 874           return;
 875         }
 876       cfg = get_config_val(upstreamcfg, config_connectto); /* Or else we try the next ConnectTo line */
 877     }
 878
 879   signal(SIGALRM, sigalrm_handler);
 880   upstreamcfg = config;
 881   seconds_till_retry += 5;
 882   if(seconds_till_retry > MAXTIMEOUT)    /* Don't wait more than MAXTIMEOUT seconds. */
 883     seconds_till_retry = MAXTIMEOUT;
 884   syslog(LOG_ERR, _("Still failed to connect to other, will retry in %d seconds"),
 885          seconds_till_retry);
 886   alarm(seconds_till_retry);
 887 cp
 888 }
 889
 890 /*
 891   setup all initial network connections
 892 */
 893 int setup_network_connections(void)
 894 {
 895   config_t const *cfg;
 896 cp
 897   init_connections();
 898   init_subnets();
 899
 900   if((cfg = get_config_val(config, config_pingtimeout)) == NULL)
 901     timeout = 60;
 902   else
 903     {
 904       timeout = cfg->data.val;
 905       if(timeout < 1)
 906         {
 907           timeout = 86400;
 908         }
 909      }
 910
 911   if(setup_tap_fd() < 0)
 912     return -1;
 913
 914   /* Run tinc-up script to further initialize the tap interface */
 915   execute_script("tinc-up");
 916
 917   if(setup_myself() < 0)
 918     return -1;
 919
 920   if(!(cfg = get_config_val(config, config_connectto)))
 921     /* No upstream IP given, we're listen only. */
 922     return 0;
 923
 924   while(cfg)
 925     {
 926       upstreamcfg = cfg->next;
 927       if(!setup_outgoing_connection(cfg->data.ptr))   /* function returns 0 when there are no problems */
 928         return 0;
 929       cfg = get_config_val(upstreamcfg, config_connectto); /* Or else we try the next ConnectTo line */
 930     }
 931
 932   signal(SIGALRM, sigalrm_handler);
 933   upstreamcfg = config;
 934   seconds_till_retry = MAXTIMEOUT;
 935   syslog(LOG_NOTICE, _("Trying to re-establish outgoing connection in %d seconds"), seconds_till_retry);
 936   alarm(seconds_till_retry);
 937 cp
 938   return 0;
 939 }
 940
 941 /*
 942   close all open network connections
 943 */
 944 void close_network_connections(void)
 945 {
 946   avl_node_t *node;
 947   connection_t *p;
 948 cp
 949   for(node = connection_tree->head; node; node = node->next)
 950     {
 951       p = (connection_t *)node->data;
 952       p->status.active = 0;
 953       terminate_connection(p);
 954     }
 955
 956   if(myself)
 957     if(myself->status.active)
 958       {
 959         close(myself->meta_socket);
 960         free_connection(myself);
 961         myself = NULL;
 962       }
 963
 964   close(tap_fd);
 965
 966   /* Execute tinc-down script right after shutting down the interface */
 967   execute_script("tinc-down");
 968
 969   destroy_connection_tree();
 970 cp
 971   return;
 972 }
 973
 974 /*
 975   create a data (udp) socket
 976   OBSOLETED: use only one listening socket for compatibility with non-Linux operating systems
 977 */
 978 int setup_vpn_connection(connection_t *cl)
 979 {
 980   int nfd, flags;
 981   struct sockaddr_in a;
 982   const int one = 1;
 983 cp
 984   if(debug_lvl >= DEBUG_TRAFFIC)
 985     syslog(LOG_DEBUG, _("Opening UDP socket to %s"), cl->hostname);
 986
 987   nfd = socket(AF_INET, SOCK_DGRAM, IPPROTO_UDP);
 988   if(nfd == -1)
 989     {
 990       syslog(LOG_ERR, _("Creating UDP socket failed: %m"));
 991       return -1;
 992     }
 993
 994   setsockopt(nfd, SOL_SOCKET, SO_REUSEADDR, &one, sizeof(one));
 995
 996   flags = fcntl(nfd, F_GETFL);
 997   if(fcntl(nfd, F_SETFL, flags | O_NONBLOCK) < 0)
 998     {
 999       close(nfd);
1000       syslog(LOG_ERR, _("System call `%s' failed: %m"),
1001              "fcntl");
1002       return -1;
1003     }
1004
1005   memset(&a, 0, sizeof(a));
1006   a.sin_family = AF_INET;
1007   a.sin_port = htons(myself->port);
1008   a.sin_addr.s_addr = htonl(INADDR_ANY);
1009
1010   if(bind(nfd, (struct sockaddr *)&a, sizeof(struct sockaddr)))
1011     {
1012       close(nfd);
1013       syslog(LOG_ERR, _("Can't bind to port %hd/udp: %m"), myself->port);
1014       return -1;
1015     }
1016
1017   a.sin_family = AF_INET;
1018   a.sin_port = htons(cl->port);
1019   a.sin_addr.s_addr = htonl(cl->address);
1020
1021   if(connect(nfd, (struct sockaddr *)&a, sizeof(a)) == -1)
1022     {
1023       close(nfd);
1024       syslog(LOG_ERR, _("Connecting to %s port %d failed: %m"),
1025              cl->hostname, cl->port);
1026       return -1;
1027     }
1028
1029   flags = fcntl(nfd, F_GETFL);
1030   if(fcntl(nfd, F_SETFL, flags | O_NONBLOCK) < 0)
1031     {
1032       close(nfd);
1033       syslog(LOG_ERR, _("This is a bug: %s:%d: %d:%m %s (%s)"), __FILE__, __LINE__, nfd,
1034              cl->name, cl->hostname);
1035       return -1;
1036     }
1037
1038   cl->socket = nfd;
1039   cl->status.dataopen = 1;
1040 cp
1041   return 0;
1042 }
1043
1044 /*
1045   handle an incoming tcp connect call and open
1046   a connection to it.
1047 */
1048 connection_t *create_new_connection(int sfd)
1049 {
1050   connection_t *p;
1051   struct sockaddr_in ci;
1052   int len = sizeof(ci);
1053 cp
1054   p = new_connection();
1055
1056   if(getpeername(sfd, (struct sockaddr *) &ci, (socklen_t *) &len) < 0)
1057     {
1058       syslog(LOG_ERR, _("System call `%s' failed: %m"),
1059              "getpeername");
1060       close(sfd);
1061       return NULL;
1062     }
1063
1064   p->name = unknown;
1065   p->address = ntohl(ci.sin_addr.s_addr);
1066   p->hostname = hostlookup(ci.sin_addr.s_addr);
1067   p->port = htons(ci.sin_port);                         /* This one will be overwritten later */
1068   p->meta_socket = sfd;
1069   p->status.meta = 1;
1070   p->buffer = xmalloc(MAXBUFSIZE);
1071   p->buflen = 0;
1072   p->last_ping_time = time(NULL);
1073
1074   if(debug_lvl >= DEBUG_CONNECTIONS)
1075     syslog(LOG_NOTICE, _("Connection from %s port %d"),
1076          p->hostname, htons(ci.sin_port));
1077
1078   p->allow_request = ID;
1079 cp
1080   return p;
1081 }
1082
1083 /*
1084   put all file descriptors in an fd_set array
1085 */
1086 void build_fdset(fd_set *fs)
1087 {
1088   avl_node_t *node;
1089   connection_t *p;
1090 cp
1091   FD_ZERO(fs);
1092
1093   FD_SET(myself->socket, fs);
1094
1095   for(node = connection_tree->head; node; node = node->next)
1096     {
1097       p = (connection_t *)node->data;
1098       if(p->status.meta)
1099         FD_SET(p->meta_socket, fs);
1100     }
1101
1102   FD_SET(myself->meta_socket, fs);
1103   FD_SET(tap_fd, fs);
1104 cp
1105 }
1106
1107 /*
1108   receive incoming data from the listening
1109   udp socket and write it to the ethertap
1110   device after being decrypted
1111 */
1112 int handle_incoming_vpn_data(void)
1113 {
1114   vpn_packet_t pkt;
1115   int x, l = sizeof(x);
1116   int lenin;
1117   struct sockaddr_in from;
1118   socklen_t fromlen = sizeof(from);
1119   connection_t *cl;
1120 cp
1121   if(getsockopt(myself->socket, SOL_SOCKET, SO_ERROR, &x, &l) < 0)
1122     {
1123       syslog(LOG_ERR, _("This is a bug: %s:%d: %d:%m"),
1124              __FILE__, __LINE__, myself->socket);
1125       return -1;
1126     }
1127   if(x)
1128     {
1129       syslog(LOG_ERR, _("Incoming data socket error: %s"), strerror(x));
1130       return -1;
1131     }
1132
1133   if((lenin = recvfrom(myself->socket, (char *) &(pkt.len), MTU, 0, (struct sockaddr *)&from, &fromlen)) <= 0)
1134     {
1135       syslog(LOG_ERR, _("Receiving packet failed: %m"));
1136       return -1;
1137     }
1138
1139   cl = lookup_connection(ntohl(from.sin_addr.s_addr), ntohs(from.sin_port));
1140
1141   if(!cl)
1142     {
1143       syslog(LOG_WARNING, _("Received UDP packets on port %hd from unknown source %x:%hd"), myself->port, ntohl(from.sin_addr.s_addr), ntohs(from.sin_port));
1144       return 0;
1145     }
1146
1147   if(debug_lvl >= DEBUG_TRAFFIC)
1148     {
1149       syslog(LOG_DEBUG, _("Received packet of %d bytes from %s (%s)"), lenin,
1150              cl->name, cl->hostname);
1151     }
1152
1153 cp
1154   return xrecv(cl, &pkt);
1155 }
1156
1157 /*
1158   terminate a connection and notify the other
1159   end before closing the sockets
1160 */
1161 void terminate_connection(connection_t *cl)
1162 {
1163   connection_t *p;
1164   subnet_t *subnet;
1165   avl_node_t *node, *next;
1166 cp
1167   if(cl->status.remove)
1168     return;
1169
1170   if(debug_lvl >= DEBUG_CONNECTIONS)
1171     syslog(LOG_NOTICE, _("Closing connection with %s (%s)"),
1172            cl->name, cl->hostname);
1173
1174   cl->status.remove = 1;
1175
1176   if(cl->socket)
1177     close(cl->socket);
1178   if(cl->status.meta)
1179     close(cl->meta_socket);
1180
1181   if(cl->status.meta)
1182     {
1183
1184       /* Find all connections that were lost because they were behind cl
1185          (the connection that was dropped). */
1186
1187         for(node = connection_tree->head; node; node = node->next)
1188           {
1189             p = (connection_t *)node->data;
1190             if(p->nexthop == cl && p != cl)
1191               terminate_connection(p);
1192           }
1193
1194       /* Inform others of termination if it was still active */
1195
1196       if(cl->status.active)
1197         for(node = connection_tree->head; node; node = node->next)
1198           {
1199             p = (connection_t *)node->data;
1200             if(p->status.meta && p->status.active && p != cl)
1201               send_del_host(p, cl);     /* Sounds like recursion, but p does not have a meta connection :) */
1202           }
1203     }
1204
1205   /* Remove the associated subnets */
1206
1207   for(node = cl->subnet_tree->head; node; node = next)
1208     {
1209       next = node->next;
1210       subnet = (subnet_t *)node->data;
1211       subnet_del(subnet);
1212     }
1213
1214   /* Check if this was our outgoing connection */
1215
1216   if(cl->status.outgoing)
1217     {
1218       cl->status.outgoing = 0;
1219       signal(SIGALRM, sigalrm_handler);
1220       seconds_till_retry = 5;
1221       alarm(seconds_till_retry);
1222       syslog(LOG_NOTICE, _("Trying to re-establish outgoing connection in 5 seconds"));
1223     }
1224
1225   /* Inactivate */
1226
1227   cl->status.active = 0;
1228 cp
1229 }
1230
1231 /*
1232   Check if the other end is active.
1233   If we have sent packets, but didn't receive any,
1234   then possibly the other end is dead. We send a
1235   PING request over the meta connection. If the other
1236   end does not reply in time, we consider them dead
1237   and close the connection.
1238 */
1239 void check_dead_connections(void)
1240 {
1241   time_t now;
1242   avl_node_t *node;
1243   connection_t *cl;
1244 cp
1245   now = time(NULL);
1246
1247   for(node = connection_tree->head; node; node = node->next)
1248     {
1249       cl = (connection_t *)node->data;
1250       if(cl->status.active && cl->status.meta)
1251         {
1252           if(cl->last_ping_time + timeout < now)
1253             {
1254               if(cl->status.pinged)
1255                 {
1256                   if(debug_lvl >= DEBUG_PROTOCOL)
1257                     syslog(LOG_INFO, _("%s (%s) didn't respond to PING"),
1258                            cl->name, cl->hostname);
1259                   cl->status.timeout = 1;
1260                   terminate_connection(cl);
1261                 }
1262               else
1263                 {
1264                   send_ping(cl);
1265                 }
1266             }
1267         }
1268     }
1269 cp
1270 }
1271
1272 /*
1273   accept a new tcp connect and create a
1274   new connection
1275 */
1276 int handle_new_meta_connection()
1277 {
1278   connection_t *ncn;
1279   struct sockaddr client;
1280   int nfd, len = sizeof(client);
1281 cp
1282   if((nfd = accept(myself->meta_socket, &client, &len)) < 0)
1283     {
1284       syslog(LOG_ERR, _("Accepting a new connection failed: %m"));
1285       return -1;
1286     }
1287
1288   if(!(ncn = create_new_connection(nfd)))
1289     {
1290       shutdown(nfd, 2);
1291       close(nfd);
1292       syslog(LOG_NOTICE, _("Closed attempted connection"));
1293       return 0;
1294     }
1295
1296   connection_add(ncn);
1297
1298   send_id(ncn);
1299 cp
1300   return 0;
1301 }
1302
1303 /*
1304   check all connections to see if anything
1305   happened on their sockets
1306 */
1307 void check_network_activity(fd_set *f)
1308 {
1309   connection_t *p;
1310   avl_node_t *node;
1311 cp
1312   if(FD_ISSET(myself->socket, f))
1313     handle_incoming_vpn_data();
1314
1315   for(node = connection_tree->head; node; node = node->next)
1316     {
1317       p = (connection_t *)node->data;
1318
1319       if(p->status.remove)
1320         return;
1321
1322       if(p->status.meta)
1323         if(FD_ISSET(p->meta_socket, f))
1324           if(receive_meta(p) < 0)
1325             {
1326               terminate_connection(p);
1327               return;
1328             }
1329     }
1330
1331   if(FD_ISSET(myself->meta_socket, f))
1332     handle_new_meta_connection();
1333 cp
1334 }
1335
1336 /*
1337   read, encrypt and send data that is
1338   available through the ethertap device
1339 */
1340 void handle_tap_input(void)
1341 {
1342   vpn_packet_t vp;
1343   int lenin;
1344 cp
1345   if(taptype == TAP_TYPE_TUNTAP)
1346     {
1347       if((lenin = read(tap_fd, vp.data, MTU)) <= 0)
1348         {
1349           syslog(LOG_ERR, _("Error while reading from tun/tap device: %m"));
1350           return;
1351         }
1352       vp.len = lenin;
1353     }
1354   else                  /* ethertap */
1355     {
1356       if((lenin = read(tap_fd, vp.data - 2, MTU)) <= 0)
1357         {
1358           syslog(LOG_ERR, _("Error while reading from ethertap device: %m"));
1359           return;
1360         }
1361       vp.len = lenin - 2;
1362     }
1363
1364   total_tap_in += lenin;
1365
1366   if(lenin < 32)
1367     {
1368       if(debug_lvl >= DEBUG_TRAFFIC)
1369         syslog(LOG_WARNING, _("Received short packet from tap device"));
1370       return;
1371     }
1372
1373   if(debug_lvl >= DEBUG_TRAFFIC)
1374     {
1375       syslog(LOG_DEBUG, _("Read packet of length %d from tap device"), vp.len);
1376     }
1377
1378   send_packet(ntohl(*((unsigned long*)(&vp.data[30]))), &vp);
1379 cp
1380 }
1381
1382 /*
1383   this is where it all happens...
1384 */
1385 void main_loop(void)
1386 {
1387   fd_set fset;
1388   struct timeval tv;
1389   int r;
1390   time_t last_ping_check;
1391   int t;
1392 cp
1393   last_ping_check = time(NULL);
1394
1395   for(;;)
1396     {
1397       tv.tv_sec = timeout;
1398       tv.tv_usec = 0;
1399
1400       prune_connection_tree();
1401       build_fdset(&fset);
1402
1403       if((r = select(FD_SETSIZE, &fset, NULL, NULL, &tv)) < 0)
1404         {
1405           if(errno != EINTR) /* because of alarm */
1406             {
1407               syslog(LOG_ERR, _("Error while waiting for input: %m"));
1408               return;
1409             }
1410         }
1411
1412       if(sighup)
1413         {
1414           syslog(LOG_INFO, _("Rereading configuration file and restarting in 5 seconds"));
1415           sighup = 0;
1416           close_network_connections();
1417           clear_config(&config);
1418
1419           if(read_server_config())
1420             {
1421               syslog(LOG_ERR, _("Unable to reread configuration file, exiting"));
1422               exit(0);
1423             }
1424
1425           sleep(5);
1426
1427           if(setup_network_connections())
1428             return;
1429
1430           continue;
1431         }
1432
1433       t = time(NULL);
1434
1435       /* Let's check if everybody is still alive */
1436
1437       if(last_ping_check + timeout < t)
1438         {
1439           check_dead_connections();
1440           last_ping_check = time(NULL);
1441
1442           /* Should we regenerate our key? */
1443
1444           if(keyexpires < t)
1445             {
1446               if(debug_lvl >= DEBUG_STATUS)
1447                 syslog(LOG_INFO, _("Regenerating symmetric key"));
1448
1449               RAND_bytes(myself->cipher_pktkey, myself->cipher_pktkeylength);
1450               send_key_changed(myself, NULL);
1451               keyexpires = time(NULL) + keylifetime;
1452             }
1453         }
1454
1455       if(r > 0)
1456         {
1457           check_network_activity(&fset);
1458
1459           /* local tap data */
1460           if(FD_ISSET(tap_fd, &fset))
1461             handle_tap_input();
1462         }
1463     }
1464 cp
1465 }